using MediaBrowser.Common.Net; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Persistence; using MediaBrowser.Controller.Session; using MediaBrowser.Dlna.PlayTo.Configuration; using MediaBrowser.Model.Logging; using System; using System.Collections.Concurrent; using System.Linq; using System.Net; using System.Net.NetworkInformation; using System.Net.Sockets; using System.Text; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Dlna.PlayTo { class PlayToManager : IDisposable { private bool _disposed = false; private readonly ILogger _logger; private readonly ISessionManager _sessionManager; private readonly IHttpClient _httpClient; private readonly CancellationTokenSource _tokenSource; private ConcurrentDictionary _locations; private readonly IItemRepository _itemRepository; private readonly ILibraryManager _libraryManager; private readonly INetworkManager _networkManager; private readonly IUserManager _userManager; public PlayToManager(ILogger logger, ISessionManager sessionManager, IHttpClient httpClient, IItemRepository itemRepository, ILibraryManager libraryManager, INetworkManager networkManager, IUserManager userManager) { _locations = new ConcurrentDictionary(); _tokenSource = new CancellationTokenSource(); _logger = logger; _sessionManager = sessionManager; _httpClient = httpClient; _itemRepository = itemRepository; _libraryManager = libraryManager; _networkManager = networkManager; _userManager = userManager; } public async void Start() { _logger.Log(LogSeverity.Info, "PlayTo-Manager starting"); _locations = new ConcurrentDictionary(); foreach (var network in NetworkInterface.GetAllNetworkInterfaces()) { _logger.Debug("Found interface: {0}. Type: {1}. Status: {2}", network.Name, network.NetworkInterfaceType, network.OperationalStatus); if (!network.SupportsMulticast || OperationalStatus.Up != network.OperationalStatus || !network.GetIPProperties().MulticastAddresses.Any()) continue; var ipV4 = network.GetIPProperties().GetIPv4Properties(); if (null == ipV4) continue; IPAddress localIp = null; foreach (UnicastIPAddressInformation ipInfo in network.GetIPProperties().UnicastAddresses) { if (ipInfo.Address.AddressFamily == AddressFamily.InterNetwork) { localIp = ipInfo.Address; break; } } if (localIp == null) { continue; } try { CreateListener(localIp); } catch (Exception e) { _logger.ErrorException("Failed to Initilize Socket", e); } await Task.Delay(100).ConfigureAwait(false); } } public void Stop() { } /// /// Creates a socket for the interface and listends for data. /// /// The local ip. private void CreateListener(IPAddress localIp) { Task.Factory.StartNew(async (o) => { try { var socket = GetMulticastSocket(); socket.Bind(new IPEndPoint(localIp, 0)); _logger.Info("Creating SSDP listener"); var receiveBuffer = new byte[64000]; CreateNotifier(socket); while (!_tokenSource.IsCancellationRequested) { var receivedBytes = await socket.ReceiveAsync(receiveBuffer, 0, 64000); if (receivedBytes > 0) { var rawData = Encoding.UTF8.GetString(receiveBuffer, 0, receivedBytes); var uri = SsdpHelper.ParseSsdpResponse(rawData); TryCreateController(uri); } } _logger.Info("SSDP listener - Task completed"); } catch (OperationCanceledException c) { } catch (Exception e) { _logger.ErrorException("Error in listener", e); } }, _tokenSource.Token, TaskCreationOptions.LongRunning); } private void TryCreateController(Uri uri) { Task.Run(async () => { try { await CreateController(uri).ConfigureAwait(false); } catch (OperationCanceledException c) { } catch (Exception ex) { _logger.ErrorException("Error creating play to controller", ex); } }); } private void CreateNotifier(Socket socket) { Task.Factory.StartNew(async (o) => { try { var request = SsdpHelper.CreateRendererSSDP(3); while (true) { socket.SendTo(request, new IPEndPoint(IPAddress.Parse("239.255.255.250"), 1900)); await Task.Delay(10000).ConfigureAwait(false); } } catch (OperationCanceledException c) { } catch (Exception ex) { _logger.ErrorException("Error in notifier", ex); } }, _tokenSource.Token, TaskCreationOptions.LongRunning); } /// /// Gets a socket configured for SDDP multicasting. /// /// private Socket GetMulticastSocket() { var socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true); socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("239.255.255.250"))); //socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastTimeToLive, 3); return socket; } /// /// Creates a new DlnaSessionController. /// and logs the session in SessionManager /// /// The URI. /// private async Task CreateController(Uri uri) { if (!IsUriValid(uri)) return; var device = await Device.CreateuPnpDeviceAsync(uri, _httpClient, _logger).ConfigureAwait(false); if (device != null && device.RendererCommands != null && !_sessionManager.Sessions.Any(s => string.Equals(s.DeviceId, device.Properties.UUID) && s.IsActive)) { var transcodeProfiles = TranscodeSettings.GetProfileSettings(device.Properties); var sessionInfo = await _sessionManager.LogSessionActivity(device.Properties.ClientType, device.Properties.Name, device.Properties.UUID, device.Properties.DisplayName, uri.OriginalString, null) .ConfigureAwait(false); var controller = sessionInfo.SessionController as PlayToController; if (controller == null) { sessionInfo.SessionController = controller = new PlayToController(sessionInfo, _sessionManager, _itemRepository, _libraryManager, _logger, _networkManager); } controller.Init(device, transcodeProfiles); _logger.Info("DLNA Session created for {0} - {1}", device.Properties.Name, device.Properties.ModelName); } } const string DefaultUser = "Play To"; private async Task GetPlayToUser() { var user = _userManager.Users.FirstOrDefault(u => string.Equals(DefaultUser, u.Name, StringComparison.OrdinalIgnoreCase)); if (user == null) { user = await _userManager.CreateUser(DefaultUser); user.Configuration.IsHidden = true; user.Configuration.IsAdministrator = false; user.SaveConfiguration(); } return user; } /// /// Determines if the Uri is valid for further inspection or not. /// (the limit for reinspection is 5 minutes) /// /// The URI. /// Returns True if the Uri is valid for further inspection private bool IsUriValid(Uri uri) { if (uri == null) return false; if (!_locations.ContainsKey(uri.OriginalString)) { _locations.AddOrUpdate(uri.OriginalString, DateTime.UtcNow, (key, existingVal) => existingVal); return true; } var time = _locations[uri.OriginalString]; if ((DateTime.UtcNow - time).TotalMinutes <= 5) { return false; } return _locations.TryUpdate(uri.OriginalString, DateTime.UtcNow, time); } public void Dispose() { if (!_disposed) { _disposed = true; _tokenSource.Cancel(); } } } }