lay/toREST/include/torrent.hpp

#ifndef _TR_TORRENT_HPP_
#define _TR_TORRENT_HPP_

#include <boost/filesystem.hpp>
#include <http.hpp>
#include <libtorrent/sha1_hash.hpp>
#include <util.hpp>

namespace tr {

namespace torrent {
template <class torrent_t>
static nlohmann::json to_json(torrent_t torrent) {
  const auto status = torrent.status(
      torrent.query_name |
      torrent.query_save_path);
  return {{"info_hash", util::sha1::string(torrent.info_hash())},
          {"paused", status.paused},
          {"seeding", status.is_seeding},
          {"state", status.state},
          {"priority", status.priority},
          {"up_limit", torrent.upload_limit()},
          {"down_limit", torrent.download_limit()},
          {"name", status.name}};
}
}

namespace session {
namespace torrents {
namespace id {
template <class torrent_session, class request, class response>
void get(torrent_session &session, response resp, request req) {
  auto http_response = http::response();
  const auto respond = [&](http::status status) {
    const auto response_code = http::code(status);
    http_response.set_body({{"code", response_code.first}, {"status", response_code.second}});
    http_response.set_status(response_code.first);
    *resp << http_response;
  };

  if (!session.is_valid()) {
    return respond(http::service_unavailable);
  }

  const auto hash = req->path.substr(18, req->path.size() - 18); //TODO hacky
  const auto torrent = session.find_torrent(util::sha1::info_hash(hash));

  if (!torrent.is_valid()) {
    return respond(http::bad_request);
  }

  http_response.set_body(torrent::to_json(torrent));
  http_response.set_status(http::ok);
  *resp << http_response;
}

template <class torrent_session, class request, class response>
void patch(torrent_session &session, response resp, request req) {
  auto http_response = http::response();
  const auto respond = [&](http::status status) {
    const auto response_code = http::code(status);
    http_response.set_body({{"code", response_code.first}, {"status", response_code.second}});
    http_response.set_status(response_code.first);
    *resp << http_response;
  };

  if (!session.is_valid()) {
    return respond(http::service_unavailable);
  }
}
}
}
}
}
#endif