using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Windows.Threading;
using IO = System.IO;

namespace FileSystem
{

  public class DevicesWatcher : DispatcherObject
  {

    #region DeviceWatcher creation

    DevicesWatcher() { }

    delegate DevicesWatcherImpl GetWatcherInstanceDelegate();
    static GetWatcherInstanceDelegate GetWatcherInstance = delegate() { return Singleton<DevicesWatcherImpl>.Instance; };

    public static DevicesWatcher Create(IDevicesView view)
    {
      Dispatcher disp = DispatcherBuilder.BuildDispatcher();
      DevicesWatcherImpl watcher
        = (DevicesWatcherImpl)disp.Invoke(DispatcherPriority.Normal, GetWatcherInstance);
      watcher.AttachToView(view);
      return watcher;
    }

    #endregion

    class DevicesWatcherImpl : DevicesWatcher
    {

      public DevicesWatcherImpl()
      {
        Thread.CurrentThread.IsBackground = true;

        lock (syncRoot)
        if (!started)
          Dispatcher.BeginInvoke(DispatcherPriority.Normal, new ThreadStart(Run));
      }

      public void AttachToView(IDevicesView view)
      {
        lock (syncRoot)
        {
          deviceAttached += new EventHandler<DeviceEventArgs>(view.AttachDevice);
          deviceDetached += new EventHandler<DeviceEventArgs>(view.DetachDevice);

          EventHandler<DeviceEventArgs> viewAttachDevice = new EventHandler<DeviceEventArgs>(view.AttachDevice);

          foreach (string device in lastKnowDevices)
            Dispatcher.BeginInvoke(DispatcherPriority.Send, viewAttachDevice, new DeviceEventArgs(device));
        }
      }

      void Run()
      {
        lock (syncRoot)
          if (!started)
            started = true;
          else
            return;

        while (true)
        {
          Thread.Sleep(timeout);
          lock (syncRoot)
          try
          {
            // Определяем текущее состояние дисковой системы
            List<string> currentDevices = (from drive in System.IO.DriveInfo.GetDrives()
                                           where drive.IsReady
                                           && !unusedDevices.Contains(drive.Name.Substring(0, 2))
                                           && watchedTypes.Contains(drive.DriveType)
                                           select drive.Name.Substring(0, 2)).ToList<string>();
            // Для каждого добавленного устройства вызываем обработчки
            foreach (string device in lastKnowDevices)
              if (!currentDevices.Contains(device))
                deviceDetached(this, new DeviceEventArgs(device));
            // Для каждого добавленного устройства вызываем обработчик
            foreach (string device in currentDevices)
              if (!lastKnowDevices.Contains(device))
                deviceAttached(this, new DeviceEventArgs(device));
            // Сохраняем текущее состояние дисковой подсистемы
            lastKnowDevices = currentDevices;
          } catch { }
        }
      }

      event EventHandler<DeviceEventArgs> deviceAttached = delegate { };
      event EventHandler<DeviceEventArgs> deviceDetached = delegate { };

      // Список неопрашиваемых устройств
      List<string> unusedDevices = new List<string>() { @"A:" };
      // Список опрашиваемых типов устройств
      List<IO.DriveType> watchedTypes = new List<IO.DriveType>() { IO.DriveType.CDRom, IO.DriveType.Removable };
      // Данные последнего опроса состояния дисковой подсистемы
      List<string> lastKnowDevices = new List<string>();
      // Время между опросами состояния
      TimeSpan timeout = new TimeSpan(0, 0, 0, 1);
      // Объект синхронизации доступа к списку устройств последнего опроса
      object syncRoot = new object();
      // Триггер состояния
      bool started = false;

    }

  }
}