mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-09-06 11:34:57 +02:00
This makes resolving dependencies from the container much easier as you cannot resolve with primitives parameters in a way that is any more readable. The aim of this commit is to change as little as possible with the end result, loggers that were newed up for the parent object were given the same name. Objects that used the base or app loggers, were given a new logger with an appropriate name. Also removed some unused dependencies.
155 lines
5.5 KiB
C#
155 lines
5.5 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using MediaBrowser.Controller.Configuration;
|
|
using MediaBrowser.Model.Dlna;
|
|
using MediaBrowser.Model.Events;
|
|
using MediaBrowser.Model.Net;
|
|
using MediaBrowser.Model.Threading;
|
|
using Microsoft.Extensions.Logging;
|
|
using Rssdp;
|
|
using Rssdp.Infrastructure;
|
|
|
|
namespace Emby.Dlna.Ssdp
|
|
{
|
|
public class DeviceDiscovery : IDeviceDiscovery
|
|
{
|
|
private bool _disposed;
|
|
|
|
private readonly ILogger _logger;
|
|
private readonly IServerConfigurationManager _config;
|
|
|
|
private event EventHandler<GenericEventArgs<UpnpDeviceInfo>> DeviceDiscoveredInternal;
|
|
|
|
private int _listenerCount;
|
|
private object _syncLock = new object();
|
|
public event EventHandler<GenericEventArgs<UpnpDeviceInfo>> DeviceDiscovered
|
|
{
|
|
add
|
|
{
|
|
lock (_syncLock)
|
|
{
|
|
_listenerCount++;
|
|
DeviceDiscoveredInternal += value;
|
|
}
|
|
StartInternal();
|
|
}
|
|
remove
|
|
{
|
|
lock (_syncLock)
|
|
{
|
|
_listenerCount--;
|
|
DeviceDiscoveredInternal -= value;
|
|
}
|
|
}
|
|
}
|
|
|
|
public event EventHandler<GenericEventArgs<UpnpDeviceInfo>> DeviceLeft;
|
|
|
|
private SsdpDeviceLocator _deviceLocator;
|
|
|
|
private readonly ITimerFactory _timerFactory;
|
|
private readonly ISocketFactory _socketFactory;
|
|
private ISsdpCommunicationsServer _commsServer;
|
|
|
|
public DeviceDiscovery(
|
|
ILoggerFactory loggerFactory,
|
|
IServerConfigurationManager config,
|
|
ISocketFactory socketFactory,
|
|
ITimerFactory timerFactory)
|
|
{
|
|
_logger = loggerFactory.CreateLogger(nameof(DeviceDiscovery));
|
|
_config = config;
|
|
_socketFactory = socketFactory;
|
|
_timerFactory = timerFactory;
|
|
}
|
|
|
|
// Call this method from somewhere in your code to start the search.
|
|
public void Start(ISsdpCommunicationsServer communicationsServer)
|
|
{
|
|
_commsServer = communicationsServer;
|
|
|
|
StartInternal();
|
|
}
|
|
|
|
private void StartInternal()
|
|
{
|
|
lock (_syncLock)
|
|
{
|
|
if (_listenerCount > 0 && _deviceLocator == null)
|
|
{
|
|
_deviceLocator = new SsdpDeviceLocator(_commsServer, _timerFactory);
|
|
|
|
// (Optional) Set the filter so we only see notifications for devices we care about
|
|
// (can be any search target value i.e device type, uuid value etc - any value that appears in the
|
|
// DiscoverdSsdpDevice.NotificationType property or that is used with the searchTarget parameter of the Search method).
|
|
//_DeviceLocator.NotificationFilter = "upnp:rootdevice";
|
|
|
|
// Connect our event handler so we process devices as they are found
|
|
_deviceLocator.DeviceAvailable += deviceLocator_DeviceAvailable;
|
|
_deviceLocator.DeviceUnavailable += _DeviceLocator_DeviceUnavailable;
|
|
|
|
var dueTime = TimeSpan.FromSeconds(5);
|
|
var interval = TimeSpan.FromSeconds(_config.GetDlnaConfiguration().ClientDiscoveryIntervalSeconds);
|
|
|
|
_deviceLocator.RestartBroadcastTimer(dueTime, interval);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Process each found device in the event handler
|
|
void deviceLocator_DeviceAvailable(object sender, DeviceAvailableEventArgs e)
|
|
{
|
|
var originalHeaders = e.DiscoveredDevice.ResponseHeaders;
|
|
|
|
var headerDict = originalHeaders == null ? new Dictionary<string, KeyValuePair<string, IEnumerable<string>>>() : originalHeaders.ToDictionary(i => i.Key, StringComparer.OrdinalIgnoreCase);
|
|
|
|
var headers = headerDict.ToDictionary(i => i.Key, i => i.Value.Value.FirstOrDefault(), StringComparer.OrdinalIgnoreCase);
|
|
|
|
var args = new GenericEventArgs<UpnpDeviceInfo>
|
|
{
|
|
Argument = new UpnpDeviceInfo
|
|
{
|
|
Location = e.DiscoveredDevice.DescriptionLocation,
|
|
Headers = headers,
|
|
LocalIpAddress = e.LocalIpAddress
|
|
}
|
|
};
|
|
|
|
DeviceDiscoveredInternal?.Invoke(this, args);
|
|
}
|
|
|
|
private void _DeviceLocator_DeviceUnavailable(object sender, DeviceUnavailableEventArgs e)
|
|
{
|
|
var originalHeaders = e.DiscoveredDevice.ResponseHeaders;
|
|
|
|
var headerDict = originalHeaders == null ? new Dictionary<string, KeyValuePair<string, IEnumerable<string>>>() : originalHeaders.ToDictionary(i => i.Key, StringComparer.OrdinalIgnoreCase);
|
|
|
|
var headers = headerDict.ToDictionary(i => i.Key, i => i.Value.Value.FirstOrDefault(), StringComparer.OrdinalIgnoreCase);
|
|
|
|
var args = new GenericEventArgs<UpnpDeviceInfo>
|
|
{
|
|
Argument = new UpnpDeviceInfo
|
|
{
|
|
Location = e.DiscoveredDevice.DescriptionLocation,
|
|
Headers = headers
|
|
}
|
|
};
|
|
|
|
DeviceLeft?.Invoke(this, args);
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
if (!_disposed)
|
|
{
|
|
_disposed = true;
|
|
if (_deviceLocator != null)
|
|
{
|
|
_deviceLocator.Dispose();
|
|
_deviceLocator = null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|