#ifndef RTORRENT_RPC_SCGI_H
#define RTORRENT_RPC_SCGI_H

#include <array>
#include <memory>
#include <torrent/event.h>

#include "rpc/scgi_task.h"

namespace rpc {

class SCgi : public torrent::Event {
public:
  static const int max_tasks = 100;

  SCgi();
  ~SCgi() override;

  const char*         type_name() const override { return "scgi"; }

  void                open_port(sockaddr* sa, unsigned int length, bool dont_route);
  void                open_named(const std::string& filename);
  void                open_fd(int fd);

  void                activate();

  void                stop();

  const std::string&  path() const                             { return m_path; }

  int                 log_fd() const                           { return m_logFd; }
  void                set_log_fd(int fd)                       { m_logFd = fd; }

  void                event_read() override;
  void                event_write() override;
  void                event_error() override;

private:
  using task_list = std::array<std::unique_ptr<SCgiTask>, max_tasks>;

  void                open(sockaddr* sa, unsigned int length);

  std::string         m_path;
  int                 m_logFd{-1};

  task_list           m_tasks;
  task_list::iterator m_current;
};

}

#endif