#ifndef RTORRENT_CONTROL_H
#define RTORRENT_CONTROL_H

#include <atomic>
#include <cinttypes>
#include <memory>
#include <sys/types.h>
#include <torrent/torrent.h>
#include <torrent/utils/scheduler.h>

namespace ui {
  class Root;
}

namespace core {
  class Manager;
  class ViewManager;
  class DhtManager;
}

namespace display {
  class Manager;
}

namespace input {
  class InputEvent;
  class Manager;
}

namespace rpc {
  class CommandScheduler;
  class XmlRpc;
  class object_storage;
  class LuaEngine;
}

namespace torrent {
  class directory_events;
}

namespace utils {
  class WatchReadyQueue;
}

class Control {
public:
  Control();
  ~Control();

  bool                is_shutdown_completed();
  bool                is_shutdown_received()        { return m_shutdown_received; }
  bool                is_shutdown_started()         { return m_shutdown_quick; }

  void                initialize();
  void                cleanup();
  void                cleanup_exception();

  void                handle_shutdown();
  void                handle_shutdown_clear_requests();

  void                receive_normal_shutdown()     { m_shutdown_received = true; }
  void                receive_quick_shutdown()      { m_shutdown_received = true; m_shutdown_quick = true; }

  core::Manager*      core()                        { return m_core.get(); }
  core::ViewManager*  view_manager()                { return m_view_manager.get(); }
  core::DhtManager*   dht_manager()                 { return m_dht_manager.get(); }

  ui::Root*           ui()                          { return m_ui.get(); }
  display::Manager*   display()                     { return m_display.get(); }
  input::Manager*     input()                       { return m_input.get(); }
  input::InputEvent*  input_stdin()                 { return m_inputStdin.get(); }

  rpc::CommandScheduler* command_scheduler()        { return m_commandScheduler.get(); }
  rpc::object_storage*   object_storage()           { return m_objectStorage.get(); }
  rpc::LuaEngine*        lua_engine()               { return m_lua_engine.get(); }

  torrent::directory_events* directory_events()     { return m_directory_events.get(); }
  utils::WatchReadyQueue*    watch_ready_queue()    { return m_watch_ready_queue.get(); }

  uint64_t            tick() const                  { return m_tick; }
  void                inc_tick()                    { m_tick++; }

  const std::string&  working_directory() const     { return m_workingDirectory; }
  void                set_working_directory(const std::string& dir);

private:
  Control(const Control&);
  void operator = (const Control&);

  std::unique_ptr<core::Manager>     m_core;
  std::unique_ptr<core::ViewManager> m_view_manager;
  std::unique_ptr<core::DhtManager>  m_dht_manager;

  std::unique_ptr<ui::Root>          m_ui;
  std::unique_ptr<display::Manager>  m_display;
  std::unique_ptr<input::Manager>    m_input;
  std::unique_ptr<input::InputEvent> m_inputStdin;

  std::unique_ptr<rpc::CommandScheduler>     m_commandScheduler;
  std::unique_ptr<rpc::object_storage>       m_objectStorage;
  std::unique_ptr<rpc::LuaEngine>            m_lua_engine;
  std::unique_ptr<torrent::directory_events> m_directory_events;
  std::unique_ptr<utils::WatchReadyQueue>    m_watch_ready_queue;

  uint64_t            m_tick{};

  mode_t              m_umask;
  std::string         m_workingDirectory;

  torrent::utils::SchedulerEntry m_task_shutdown;
  torrent::utils::SchedulerEntry m_task_shutdown_clear_requests;

  int                 m_clear_requests_count{};

  align_cacheline

  std::atomic<bool>   m_shutdown_received{};
  std::atomic<bool>   m_shutdown_quick{};
};

#endif