Fix false invalid session error on empty URI

Avoid triggering 'Session data is invalid' when loading downloads with an empty URI.

configure.ac

@@ -1,6 +1,6 @@
 m4_pattern_allow([PKG_CHECK_EXISTS])
 
-AC_INIT([rtorrent],[0.16.21],[sundell.software@gmail.com])
+AC_INIT([rtorrent],[0.16.22],[sundell.software@gmail.com])
 
 AC_CONFIG_HEADERS([config.h])
 AC_CONFIG_MACRO_DIRS([scripts])
@@ -49,7 +49,7 @@ fi
 
 PKG_CHECK_MODULES([CPPUNIT], [cppunit],, [no_cppunit="yes"])
 PKG_CHECK_MODULES([ZLIB], [zlib])
-PKG_CHECK_MODULES([DEPENDENCIES], [libtorrent >= 0.16.21])
+PKG_CHECK_MODULES([DEPENDENCIES], [libtorrent >= 0.16.22])
 
 AC_LANG_PUSH(C++)
 TORRENT_WITH_XMLRPC_C

src/Makefile.am

@@ -187,7 +187,6 @@ libsub_root_a_SOURCES = \
 	command_helpers.cc \
 	command_helpers.h \
 	command_groups.cc \
-	command_load.cc \
 	command_local.cc \
 	command_logging.cc \
 	command_network.cc \

src/command_events.cc

@@ -1,17 +1,25 @@
 #include "config.h"
 
-#include <torrent/exceptions.h>
+#include <functional>
+#include <cstdio>
+#include <string>
+#include <vector>
+#include <torrent/rate.h>
+#include <torrent/hash_string.h>
 #include <torrent/utils/log.h>
 #include <torrent/utils/directory_events.h>
 #include <torrent/utils/file_stat.h>
 #include <torrent/utils/string_manip.h>
 
+#include "globals.h"
 #include "control.h"
 #include "command_helpers.h"
 #include "core/download.h"
+#include "core/download_list.h"
 #include "core/manager.h"
 #include "core/view_manager.h"
 #include "rpc/command_scheduler.h"
+#include "rpc/parse.h"
 #include "rpc/parse_commands.h"
 #include "utils/watch_ready_queue.h"
 
@@ -138,6 +146,24 @@ apply_schedule(const torrent::Object::list_type& args, bool if_absent) {
   return torrent::Object();
 }
 
+torrent::Object
+apply_load(const torrent::Object::list_type& args, int flags) {
+  torrent::Object::list_const_iterator argsItr = args.begin();
+
+  if (argsItr == args.end())
+    throw torrent::input_error("Too few arguments.");
+
+  auto& filename = argsItr->as_string();
+  core::Manager::command_list_type commands;
+
+  while (++argsItr != args.end())
+    commands.push_back(argsItr->as_string());
+
+  control->core()->try_create_download_expand(filename, flags, commands);
+
+  return torrent::Object();
+}
+
 void apply_import(const std::string& path)     { if (!rpc::parse_command_file(path)) throw torrent::input_error("Could not open option file: " + path); }
 void apply_try_import(const std::string& path) { if (!rpc::parse_command_file(path)) control->core()->push_log_std("Could not read resource file: " + path); }
 
@@ -342,6 +368,15 @@ initialize_command_events() {
   CMD2_ANY_STRING_V("import",                     [](auto, auto& str) { return apply_import(str); });
   CMD2_ANY_STRING_V("try_import",                 [](auto, auto& str) { return apply_try_import(str); });
 
+  CMD2_ANY_LIST    ("load.normal",                [](auto, auto& args) { return apply_load(args, core::Manager::create_quiet | core::Manager::create_tied); });
+  CMD2_ANY_LIST    ("load.verbose",               [](auto, auto& args) { return apply_load(args, core::Manager::create_tied); });
+  CMD2_ANY_LIST    ("load.start",                 [](auto, auto& args) { return apply_load(args, core::Manager::create_quiet | core::Manager::create_tied | core::Manager::create_start); });
+  CMD2_ANY_LIST    ("load.start_verbose",         [](auto, auto& args) { return apply_load(args, core::Manager::create_tied | core::Manager::create_start); });
+  CMD2_ANY_LIST    ("load.raw",                   [](auto, auto& args) { return apply_load(args, core::Manager::create_quiet | core::Manager::create_raw_data); });
+  CMD2_ANY_LIST    ("load.raw_verbose",           [](auto, auto& args) { return apply_load(args, core::Manager::create_raw_data); });
+  CMD2_ANY_LIST    ("load.raw_start",             [](auto, auto& args) { return apply_load(args, core::Manager::create_quiet | core::Manager::create_start | core::Manager::create_raw_data); });
+  CMD2_ANY_LIST    ("load.raw_start_verbose",     [](auto, auto& args) { return apply_load(args, core::Manager::create_start | core::Manager::create_raw_data); });
+
   CMD2_ANY_VALUE   ("close_low_diskspace",        [](auto, auto& arg) { return apply_close_low_diskspace(arg, 99); });
   CMD2_ANY_VALUE   ("close_low_diskspace.normal", [](auto, auto& arg) { return apply_close_low_diskspace(arg, 3); });
 

src/command_load.cc

@@ -1,81 +0,0 @@
-#include "config.h"
-
-#include "command_helpers.h"
-#include "control.h"
-#include "core/manager.h"
-
-torrent::Object
-apply_load_trusted(const torrent::Object::list_type& args, int flags) {
-  auto argsItr = args.begin();
-
-  if (argsItr == args.end())
-    throw torrent::input_error("Too few arguments.");
-
-  auto& filename = argsItr->as_string();
-
-  core::Manager::command_list_type commands;
-
-  while (++argsItr != args.end())
-    commands.push_back(argsItr->as_string());
-
-  control->core()->try_create_download_expand(filename, flags, commands);
-
-  return torrent::Object();
-}
-
-torrent::Object
-apply_load_untrusted(const torrent::Object::list_type& args, int flags) {
-  auto argsItr = args.begin();
-
-  if (argsItr == args.end())
-    throw torrent::input_error("Too few arguments.");
-
-  auto& filename = argsItr->as_string();
-
-  core::Manager::command_list_type commands;
-
-  while (++argsItr != args.end())
-    commands.push_back(argsItr->as_string());
-
-  control->core()->try_create_download_untrusted(filename, flags, commands);
-
-  return torrent::Object();
-}
-
-void
-initialize_command_load() {
-  CMD2_ANY_LIST    ("load.normal",            [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_quiet | core::Manager::create_tied); });
-  CMD2_ANY_LIST    ("load.verbose",           [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_tied); });
-  CMD2_ANY_LIST    ("load.start",             [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_quiet | core::Manager::create_tied | core::Manager::create_start); });
-  CMD2_ANY_LIST    ("load.start_verbose",     [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_tied | core::Manager::create_start); });
-  CMD2_ANY_LIST    ("load.raw",               [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_quiet | core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.raw_verbose",       [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.raw_start",         [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_quiet | core::Manager::create_start | core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.raw_start_verbose", [](auto, auto& args) { return apply_load_trusted(args, core::Manager::create_start | core::Manager::create_raw_data); });
-
-  CMD2_ANY_LIST    ("load.untrusted.normal",            [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_quiet); });
-  CMD2_ANY_LIST    ("load.untrusted.verbose",           [](auto, auto& args) { return apply_load_untrusted(args, 0); });
-  CMD2_ANY_LIST    ("load.untrusted.start",             [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_quiet | core::Manager::create_start); });
-  CMD2_ANY_LIST    ("load.untrusted.start_verbose",     [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_start); });
-  CMD2_ANY_LIST    ("load.untrusted.raw",               [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_quiet | core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.untrusted.raw_verbose",       [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.untrusted.raw_start",         [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_quiet | core::Manager::create_start | core::Manager::create_raw_data); });
-  CMD2_ANY_LIST    ("load.untrusted.raw_start_verbose", [](auto, auto& args) { return apply_load_untrusted(args, core::Manager::create_start | core::Manager::create_raw_data); });
-
-  CMD2_ANY_VALUE_V("load.untrusted.mark_safe", [](auto, auto& arg) {
-    if (arg == 0)
-      return;
-
-    // TODO: Add a bool to core::Manager.
-
-    rpc::rpc.mark_safe("load.untrusted.normal");
-    rpc::rpc.mark_safe("load.untrusted.verbose");
-    rpc::rpc.mark_safe("load.untrusted.start");
-    rpc::rpc.mark_safe("load.untrusted.start_verbose");
-    rpc::rpc.mark_safe("load.untrusted.raw");
-    rpc::rpc.mark_safe("load.untrusted.raw_verbose");
-    rpc::rpc.mark_safe("load.untrusted.raw_start");
-    rpc::rpc.mark_safe("load.untrusted.raw_start_verbose");
-  });
-
-}

src/core/download_factory.cc

@@ -7,6 +7,7 @@
 #include <functional>
 #include <sstream>
 #include <stdexcept>
+#include <sys/stat.h>
 #include <torrent/utils/log.h>
 #include <torrent/utils/resume.h>
 #include <torrent/object.h>
@@ -27,8 +28,6 @@
 
 namespace core {
 
-static constexpr const char* session_invalid_message = "Session data is invalid, ignoring it";
-
 bool
 is_network_uri(const std::string& uri) {
   return
@@ -37,16 +36,15 @@ is_network_uri(const std::string& uri) {
     std::strncmp(uri.c_str(), "ftp://", 6) == 0;
 }
 
-bool
-is_magnet_uri(const std::string& uri) {
-  return
-    std::strncmp(uri.c_str(), "magnet:?", 8) == 0;
-}
+static constexpr const char* session_invalid_message = "Session data is invalid, ignoring it";
 
-namespace {
-
-std::unique_ptr<torrent::Object>
+static std::unique_ptr<torrent::Object>
 download_factory_load_stream(const char* filename, bool* is_invalid) {
+  struct stat sb;
+
+  if (stat(filename, &sb) != 0 || !S_ISREG(sb.st_mode))
+    return std::unique_ptr<torrent::Object>();
+
   std::fstream stream(filename, std::ios::in | std::ios::binary);
 
   if (!stream.is_open())
@@ -63,34 +61,17 @@ download_factory_load_stream(const char* filename, bool* is_invalid) {
   return obj;
 }
 
-std::unique_ptr<torrent::Object>
-create_untrusted_object(torrent::Object& obj) {
-  auto trusted_object = std::make_unique<torrent::Object>(torrent::Object::create_map());
-
-  if (obj.has_key("info"))
-    trusted_object->insert_key_move("info", obj.get_key("info"));
-
-  if (obj.has_key("announce"))
-    trusted_object->insert_key_move("announce", obj.get_key("announce"));
-
-  if (obj.has_key("announce-list"))
-    trusted_object->insert_key_move("announce-list", obj.get_key("announce-list"));
-
-  if (obj.has_key("creation date"))
-    trusted_object->insert_key_move("creation date", obj.get_key("creation date"));
-
-  if (obj.has_key("created by"))
-    trusted_object->insert_key_move("created by", obj.get_key("created by"));
-
-  return trusted_object;
+bool
+is_magnet_uri(const std::string& uri) {
+  return
+    std::strncmp(uri.c_str(), "magnet:?", 8) == 0;
 }
 
-} // namespace anonymous
+DownloadFactory::DownloadFactory(Manager* m) :
+    m_manager(m) {
 
-
-DownloadFactory::DownloadFactory(Manager* m, bool trusted)
-  : m_manager(m),
-    m_trusted(trusted) {
+  m_task_load.slot() = std::bind(&DownloadFactory::receive_load, this);
+  m_task_commit.slot() = std::bind(&DownloadFactory::receive_commit, this);
 
   // m_variables["connection_leech"] = rpc::call_command("protocol.connection.leech");
   // m_variables["connection_seed"]  = rpc::call_command("protocol.connection.seed");
@@ -103,49 +84,21 @@ DownloadFactory::DownloadFactory(Manager* m, bool trusted)
 DownloadFactory::~DownloadFactory() {
   torrent::this_thread::scheduler()->erase(&m_task_load);
   torrent::this_thread::scheduler()->erase(&m_task_commit);
+
+  delete m_object;
 }
 
 void
-DownloadFactory::load_trusted(const std::string& uri) {
-  if (!m_trusted)
-    throw torrent::internal_error("DownloadFactory::load_trusted() called on an untrusted object");
-
+DownloadFactory::load(const std::string& uri) {
   m_uri = uri;
-  m_task_load.slot() = [this]() { receive_load_trusted(); };
-
   torrent::this_thread::scheduler()->wait_for(&m_task_load, 0ms);
 }
 
+// This function must be called before DownloadFactory::commit().
 void
-DownloadFactory::load_untrusted(const std::string& uri) {
-  if (m_trusted)
-    throw torrent::internal_error("DownloadFactory::load_untrusted() called on a trusted object");
-
-  m_uri = uri;
-  m_task_load.slot() = [this]() { receive_load_untrusted(); };
-
-  torrent::this_thread::scheduler()->wait_for(&m_task_load, 0ms);
-}
-
-void
-DownloadFactory::load_raw_data_trusted(const std::string& input) {
-  if (!m_trusted)
-    throw torrent::internal_error("DownloadFactory::load_raw_data_trusted() called on an untrusted object");
-
+DownloadFactory::load_raw_data(const std::string& input) {
   if (m_stream)
-    throw torrent::internal_error("DownloadFactory::load_raw_data_trusted() called on an object with m_stream != NULL");
-
-  m_stream.reset(new std::stringstream(input));
-  m_loaded = true;
-}
-
-void
-DownloadFactory::load_raw_data_untrusted(const std::string& input) {
-  if (m_trusted)
-    throw torrent::internal_error("DownloadFactory::load_raw_data_untrusted() called on an trusted object");
-
-  if (m_stream)
-    throw torrent::internal_error("DownloadFactory::load_raw_data_untrusted() called on an object with m_stream != NULL");
+    throw torrent::internal_error("DownloadFactory::load*() called on an object with m_stream != NULL");
 
   m_stream.reset(new std::stringstream(input));
   m_loaded = true;
@@ -153,91 +106,53 @@ DownloadFactory::load_raw_data_untrusted(const std::string& input) {
 
 void
 DownloadFactory::commit() {
-  if (!m_trusted)
-    throw torrent::internal_error("DownloadFactory::commit() called on an untrusted object");
-
-  m_task_commit.slot() = [this]() { receive_commit(); };
   torrent::this_thread::scheduler()->wait_for(&m_task_commit, 0ms);
 }
 
 void
-DownloadFactory::process_load_network_uri() {
-  m_stream.reset(new std::stringstream);
+DownloadFactory::receive_load() {
+  if (m_stream)
+    throw torrent::internal_error("DownloadFactory::load*() called on an object with m_stream != NULL");
 
-  // TODO: Add trusted flag.
+  if (is_network_uri(m_uri)) {
+    m_stream.reset(new std::stringstream);
 
-  auto done_fn   = [this]()                         { receive_loaded(); };
-  auto failed_fn = [this](const std::string& error) { receive_failed(error); };
+    auto done_fn   = [this]() { receive_loaded(); };
+    auto failed_fn = [this](const std::string& error) { receive_failed(error); };
 
-  m_manager->http_queue()->insert(m_uri, m_stream, done_fn, failed_fn);
+    m_manager->http_queue()->insert(m_uri, m_stream, done_fn, failed_fn);
 
-  m_variables["tied_to_file"] = (int64_t)false;
-}
+    m_variables["tied_to_file"] = (int64_t)false;
+    return;
+  }
 
-void
-DownloadFactory::process_load_magnet_uri() {
-  m_stream.reset(new std::stringstream());
-  *m_stream << "d10:magnet-uri" << m_uri.length() << ":" << m_uri << "e";
+  if (is_magnet_uri(m_uri)) {
+    // DEBUG: Use m_object.
+    m_stream.reset(new std::stringstream());
+    *m_stream << "d10:magnet-uri" << m_uri.length() << ":" << m_uri << "e";
 
-  m_variables["tied_to_file"] = (int64_t)false;
+    m_variables["tied_to_file"] = (int64_t)false;
 
-  receive_loaded();
-}
+    receive_loaded();
+    return;
+  }
 
-void
-DownloadFactory::process_load_file_uri() {
   std::fstream stream(expand_path(m_uri).c_str(), std::ios::in | std::ios::binary);
 
   if (!stream.is_open())
     return receive_failed("Could not open file");
 
-  m_object = std::make_unique<torrent::Object>();
+  m_object = new torrent::Object;
   stream >> *m_object;
 
   if (!stream.good())
     return receive_failed("Reading torrent file failed");
 
-  m_is_file = true;
+  m_isFile = true;
 
   receive_loaded();
 }
 
-void
-DownloadFactory::receive_load_trusted() {
-  if (!m_trusted)
-    throw torrent::internal_error("DownloadFactory::receive_load_trusted() called on an untrusted object");
-
-  if (m_stream)
-    throw torrent::internal_error("DownloadFactory::receive_load_trusted() called on an object with null m_stream");
-
-  if (is_network_uri(m_uri))
-    return process_load_network_uri();
-
-  if (is_magnet_uri(m_uri))
-    return process_load_magnet_uri();
-
-  process_load_file_uri();
-}
-
-void
-DownloadFactory::receive_load_untrusted() {
-  if (m_trusted)
-    throw torrent::internal_error("DownloadFactory::receive_load_untrusted() called on a trusted object");
-
-  if (m_stream)
-    throw torrent::internal_error("DownloadFactory::load*() called on an object with null m_stream");
-
-  if (is_network_uri(m_uri))
-    return process_load_network_uri();
-
-  // TODO: Don't need to handle untrusted commands magnet URIs.
-
-  // if (is_magnet_uri(m_uri))
-  //   return process_load_magnet_uri();
-
-  throw torrent::internal_error("DownloadFactory::receive_load_untrusted() called on a non-network/magnet URI");
-}
-
 void
 DownloadFactory::receive_loaded() {
   m_loaded = true;
@@ -256,40 +171,38 @@ DownloadFactory::receive_commit() {
 
 void
 DownloadFactory::receive_success() {
-  if (!m_trusted && m_session)
-    throw torrent::internal_error("DownloadFactory::receive_success() called on an untrusted object with m_session == true");
+  bool session_invalid = false;
 
-  if (m_session && !m_is_file)
-    throw torrent::internal_error("DownloadFactory::receive_success() called on a non-file object with m_session == true");
-
-  bool     session_invalid = false;
-  uint32_t tracker_key     = tracker_key = random() % (std::numeric_limits<uint32_t>::max() - 1) + 1;
-
-  std::unique_ptr<torrent::Object> rtorrent_object, libtorrent_resume_object;
+  std::unique_ptr<torrent::Object> rtorrent_object;
+  std::unique_ptr<torrent::Object> libtorrent_resume_object;
 
   if (m_session) {
-     rtorrent_object          = download_factory_load_stream((expand_path(m_uri) + ".rtorrent").c_str(), &session_invalid);
-     libtorrent_resume_object = download_factory_load_stream((expand_path(m_uri) + ".libtorrent_resume").c_str(), &session_invalid);
+    if (m_uri.empty())
+      throw torrent::input_error("Session torrent URI is empty.");
 
-     if (session_invalid)
-       lt_log_print(torrent::LOG_ERROR, "%s: %s", session_invalid_message, m_uri.c_str());
+    rtorrent_object          = download_factory_load_stream((expand_path(m_uri) + ".rtorrent").c_str(), &session_invalid);
+    libtorrent_resume_object = download_factory_load_stream((expand_path(m_uri) + ".libtorrent_resume").c_str(), &session_invalid);
 
-     if (rtorrent_object && rtorrent_object->has_key_value("key"))
-       tracker_key = rtorrent_object->get_key_value("key");
+    if (session_invalid)
+      lt_log_print(torrent::LOG_ERROR, "%s: %s", session_invalid_message, m_uri.c_str());
   }
 
-  // TODO: This adds the torrent, so untrusted can add brokent torrents.
+  uint32_t tracker_key;
 
-  if (m_stream != nullptr)
-    object_from_stream();
+  if (rtorrent_object && rtorrent_object->has_key_value("key"))
+    tracker_key = rtorrent_object->get_key_value("key");
+  else
+    tracker_key = random() % (std::numeric_limits<uint32_t>::max() - 1) + 1;
 
-  if (m_trusted)
-    m_object = create_untrusted_object(*m_object);
+  Download* download = m_stream != nullptr ?
+    m_manager->download_list()->create(m_stream.get(), tracker_key, m_printLog) :
+    m_manager->download_list()->create(m_object, tracker_key, m_printLog);
 
-  Download* download = m_manager->download_list()->create(std::move(m_object), tracker_key, m_print_log);
+  m_object = NULL;
 
-  if (download == nullptr) {
-    // core::Manager should already have added the error message to the log.
+  if (download == NULL) {
+    // core::Manager should already have added the error message to
+    // the log.
     m_slot_finished();
     return;
   }
@@ -298,49 +211,39 @@ DownloadFactory::receive_success() {
     download->set_hash_failed(true);
     download->set_message(session_invalid_message);
 
-    if (m_print_log)
+    if (m_printLog)
       m_manager->push_log_std(std::string(session_invalid_message) + ": \"" + m_uri + "\"");
   }
 
   torrent::Object* root = download->bencode();
 
   if (download->download()->info()->is_meta_download()) {
-    if (!m_trusted)
-      throw torrent::internal_error("DownloadFactory::receive_success() called on an untrusted object with a meta download");
-
     torrent::Object& meta = root->insert_key("rtorrent_meta_download", torrent::Object::create_map());
     meta.insert_key("start", m_start);
-    meta.insert_key("print_log", m_print_log);
+    meta.insert_key("print_log", m_printLog);
 
-    // TODO: ADD UNTRUSTED!!!
-    auto& commands = meta.insert_key("commands", torrent::Object::create_list()).as_list();
+    torrent::Object::list_type& commands = meta.insert_key("commands", torrent::Object::create_list()).as_list();
 
     for (auto& m_command : m_commands)
       commands.push_back(m_command);
   }
 
   if (m_session) {
-    if (!m_trusted)
-      throw torrent::internal_error("DownloadFactory::receive_success() called on an untrusted object with m_session == true");
-
     if (rtorrent_object)
       root->insert_key_move("rtorrent", *rtorrent_object);
 
     if (libtorrent_resume_object)
       root->insert_key_move("libtorrent_resume", *libtorrent_resume_object);
 
-  } else if (!m_trusted) {
-    if (root->has_key("rtorrent") || root->has_key("libtorrent_resume"))
-      throw torrent::internal_error("DownloadFactory::receive_success() called on an untrusted object with 'rtorrent' or 'libtorrent_resume' keys");
-
   } else {
-    // We only allow session torrents to keep their 'rtorrent/libtorrent' sections. The
-    // "fast_resume" section should be safe to keep.
+    // We only allow session torrents to keep their
+    // 'rtorrent/libtorrent' sections. The "fast_resume" section
+    // should be safe to keep.
     root->erase_key("rtorrent");
   }
 
-  auto* rtorrent     = &root->insert_preserve_copy("rtorrent", torrent::Object::create_map()).first->second;
-  auto& resumeObject = root->insert_preserve_copy("libtorrent_resume", torrent::Object::create_map()).first->second;
+  torrent::Object* rtorrent = &root->insert_preserve_copy("rtorrent", torrent::Object::create_map()).first->second;
+  torrent::Object& resumeObject = root->insert_preserve_copy("libtorrent_resume", torrent::Object::create_map()).first->second;
 
   rtorrent->insert_key("key", download->tracker_controller().key());
 
@@ -370,7 +273,7 @@ DownloadFactory::receive_success() {
   }
 
   // Skip forcing trackers to scrape when rtorrent starts
-  if (m_init_load && rpc::call_command_value("trackers.delay_scrape"))
+  if (m_initLoad && rpc::call_command_value("trackers.delay_scrape"))
     download->set_resume_flags(torrent::Download::start_skip_tracker);
 
   // Check first if we already have these values set in the session
@@ -412,7 +315,7 @@ DownloadFactory::receive_success() {
 
     lt_log_print(torrent::LOG_ERROR, "%s: %s", msg.c_str(), m_uri.c_str());
 
-    if (m_print_log)
+    if (m_printLog)
       m_manager->push_log_std(msg + ": \"" + m_uri + "\"");
 
     download->set_hash_failed(true);
@@ -436,13 +339,8 @@ DownloadFactory::receive_success() {
     if (torrent::log_groups[torrent::LOG_TORRENT_DEBUG].valid())
       log_created(download, rtorrent);
 
-    if (m_trusted) {
-      for (const auto& command : m_commands)
-        rpc::parse_command_multiple_std(command, rpc::make_target(download));
-
-    } else {
-      // TODO: CALL UNTRUSTED COMMANDS
-    }
+    for (const auto& command : m_commands)
+      rpc::parse_command_multiple_std(command, rpc::make_target(download));
 
     if (m_manager->download_list()->find(infohash) == m_manager->download_list()->end())
       throw torrent::input_error("The newly created download was removed.");
@@ -456,7 +354,7 @@ DownloadFactory::receive_success() {
   } catch (torrent::input_error& e) {
     std::string msg = "Command on torrent creation failed: " + std::string(e.what());
 
-    if (m_print_log)
+    if (m_printLog)
       m_manager->push_log_std(msg);
 
     if (m_manager->download_list()->find(infohash) != m_manager->download_list()->end()) {
@@ -470,18 +368,6 @@ DownloadFactory::receive_success() {
   m_slot_finished();
 }
 
-void
-DownloadFactory::receive_failed(const std::string& msg) {
-  if (m_print_log) {
-    if (m_trusted)
-      m_manager->push_log_std("Failed to load torrent: " + msg + ": \"" + m_uri + "\"");
-    else
-      m_manager->push_log_std("Failed to load untrusted torrent: " + msg);
-  }
-
-  m_slot_finished();
-}
-
 void
 DownloadFactory::log_created(Download* download, torrent::Object* rtorrent) {
   std::stringstream dump;
@@ -508,6 +394,15 @@ DownloadFactory::log_created(Download* download, torrent::Object* rtorrent) {
   lt_log_print_dump(torrent::LOG_TORRENT_DEBUG, dump_str.c_str(), dump_str.size(), "Creating new download:");
 }
 
+void
+DownloadFactory::receive_failed(const std::string& msg) {
+  // Add message to log.
+  if (m_printLog)
+    m_manager->push_log_std(msg + ": \"" + m_uri + "\"");
+
+  m_slot_finished();
+}
+
 void
 DownloadFactory::initialize_rtorrent(Download* download, torrent::Object* rtorrent) {
   auto cached_seconds = torrent::this_thread::cached_seconds().count();
@@ -531,7 +426,7 @@ DownloadFactory::initialize_rtorrent(Download* download, torrent::Object* rtorre
   rtorrent->insert_preserve_copy("timestamp.finished", (int64_t)0);
 
   rtorrent->insert_preserve_copy("tied_to_file", "");
-  rtorrent->insert_key("loaded_file", m_is_file ? m_uri : std::string());
+  rtorrent->insert_key("loaded_file", m_isFile ? m_uri : std::string());
 
   if (rtorrent->has_key_value("priority"))
     rpc::call_command("d.priority.set", rtorrent->get_key_value("priority") % 4, rpc::make_target(download));
@@ -563,18 +458,4 @@ DownloadFactory::initialize_rtorrent(Download* download, torrent::Object* rtorre
   rtorrent->insert_preserve_copy("choke_heuristics.down.seed",  std::string());
 }
 
-void
-DownloadFactory::object_from_stream() {
-  m_object = std::make_unique<torrent::Object>();
-
-  *m_stream >> *m_object;
-
-  if (!m_stream->good() || !m_object->is_map()) {
-    if (m_print_log)
-      lt_log_print(torrent::LOG_TORRENT_ERROR, "Could not create download, stream is not a valid torrent.");
-
-    throw torrent::input_error("Invalid torrent data");
-  }
-}
-
 }

src/core/download_factory.h

@@ -24,18 +24,14 @@ public:
   typedef std::vector<std::string> command_list_type;
 
   // Do not destroy this object while it is in a HttpQueue.
-  DownloadFactory(Manager* m, bool trusted);
+  DownloadFactory(Manager* m);
   ~DownloadFactory();
 
   // Calling of receive_load() is delayed so you can change whatever
   // you want without fear of the slots being triggered as you call
   // load() or commit().
-  void                load_trusted(const std::string& uri);
-  void                load_untrusted(const std::string& uri);
-
-  void                load_raw_data_trusted(const std::string& input);
-  void                load_raw_data_untrusted(const std::string& input);
-
+  void                load(const std::string& uri);
+  void                load_raw_data(const std::string& input);
   void                commit();
 
   command_list_type&         commands()     { return m_commands; }
@@ -47,21 +43,16 @@ public:
   bool                get_start() const     { return m_start; }
   void                set_start(bool v)     { m_start = v; }
 
-  bool                get_init_load() const { return m_init_load; }
-  void                set_init_load(bool v) { m_init_load = v; }
+  bool                get_init_load() const { return m_initLoad; }
+  void                set_init_load(bool v) { m_initLoad = v; }
 
-  bool                print_log() const     { return m_print_log; }
-  void                set_print_log(bool v) { m_print_log = v; }
+  bool                print_log() const     { return m_printLog; }
+  void                set_print_log(bool v) { m_printLog = v; }
 
   void                slot_finished(slot_void s) { m_slot_finished = s; }
 
 private:
-  void                process_load_network_uri();
-  void                process_load_magnet_uri();
-  void                process_load_file_uri();
-
-  void                receive_load_trusted();
-  void                receive_load_untrusted();
+  void                receive_load();
   void                receive_loaded();
   void                receive_commit();
   void                receive_success();
@@ -71,23 +62,19 @@ private:
 
   void                initialize_rtorrent(Download* download, torrent::Object* rtorrent);
 
-  void                object_from_stream();
+  Manager*                       m_manager;
+  std::shared_ptr<std::iostream> m_stream;
+  torrent::Object*               m_object{};
 
-  Manager*            m_manager;
-
-  std::shared_ptr<std::iostream>   m_stream;
-  std::unique_ptr<torrent::Object> m_object{};
-
-  bool                m_trusted{};
   bool                m_commited{};
   bool                m_loaded{};
 
   std::string         m_uri;
   bool                m_session{};
   bool                m_start{};
-  bool                m_print_log{true};
-  bool                m_is_file{};
-  bool                m_init_load{};
+  bool                m_printLog{true};
+  bool                m_isFile{};
+  bool                m_initLoad{};
 
   command_list_type         m_commands;
   torrent::Object::map_type m_variables;

src/core/download_list.cc

@@ -101,17 +101,49 @@ DownloadList::find_hex_ptr(const char* hash) {
 }
 
 Download*
-DownloadList::create(std::unique_ptr<torrent::Object> obj, uint32_t tracker_key, bool printLog) {
+DownloadList::create(torrent::Object* obj, uint32_t tracker_key, bool printLog) {
   torrent::Download download;
 
-  auto obj_ptr = obj.get();
-
   try {
-    download = torrent::download_add(obj.release(), tracker_key);
+    download = torrent::download_add(obj, tracker_key);
 
   } catch (torrent::local_error& e) {
-    // TODO: Fix download_add so it takes the unique_ptr.
-    delete obj_ptr;
+    if (printLog)
+      lt_log_print(torrent::LOG_TORRENT_ERROR, "Could not create download: %s", e.what());
+
+    delete obj;
+
+    return NULL;
+  }
+
+  // There's no non-critical exceptions that should be throwable by
+  // the ctor, so don't catch.
+  return new Download(download);
+}
+
+Download*
+DownloadList::create(std::istream* str, uint32_t tracker_key, bool printLog) {
+  torrent::Object* object = new torrent::Object;
+  torrent::Download download;
+
+  try {
+    *str >> *object;
+
+    // Don't throw input_error from here as gcc-3.3.5 produces bad
+    // code.
+    if (str->fail()) {
+      delete object;
+
+      if (printLog)
+        lt_log_print(torrent::LOG_TORRENT_ERROR, "Could not create download, the input is not a valid torrent.");
+
+      return NULL;
+    }
+
+    download = torrent::download_add(object, tracker_key);
+
+  } catch (torrent::local_error& e) {
+    delete object;
 
     if (printLog)
       lt_log_print(torrent::LOG_TORRENT_ERROR, "Could not create download: %s", e.what());

src/core/download_list.h

@@ -52,7 +52,8 @@ public:
   Download*           find_hex_ptr(const char* hash);
 
   // Might move this to DownloadFactory.
-  Download*           create(std::unique_ptr<torrent::Object> obj, uint32_t tracker_key, bool printLog);
+  Download*           create(std::istream* str, uint32_t tracker_key, bool printLog);
+  Download*           create(torrent::Object* obj, uint32_t tracker_key, bool printLog);
 
   iterator            insert(Download* d);
 

src/core/manager.cc

@@ -37,8 +37,6 @@
 
 namespace core {
 
-void path_expand(std::vector<std::string>* paths, const std::string& pattern);
-
 const int Manager::create_start;
 const int Manager::create_tied;
 const int Manager::create_quiet;
@@ -197,7 +195,7 @@ Manager::try_create_download(const std::string& uri, int flags, const command_li
     return;
 
   // Adding download.
-  DownloadFactory* f = new DownloadFactory(this, true);
+  DownloadFactory* f = new DownloadFactory(this);
 
   f->variables()["tied_to_file"] = (int64_t)(bool)(flags & create_tied);
   f->commands().insert(f->commands().end(), commands.begin(), commands.end());
@@ -206,52 +204,29 @@ Manager::try_create_download(const std::string& uri, int flags, const command_li
   f->set_print_log(!(flags & create_quiet));
   f->slot_finished([f]() { delete f; });
 
-  if (flags & create_raw_data) {
-    f->load_raw_data_trusted(uri);
-
-  } else if (is_data_uri(uri)) {
+  if (is_data_uri(uri)) {
     // Allow the use of data URIs, primarily for JSON-RPC which
     // doesn't have a defined mechanism for binary data
-    f->load_raw_data_trusted(decode_data_uri(uri));
+    f->load_raw_data(decode_data_uri(uri));
     f->variables()["tied_to_file"] = (int64_t)false;
-
+  } else if (flags & create_raw_data) {
+    f->load_raw_data(uri);
   } else {
-    f->load_trusted(uri);
+    f->load(uri);
   }
 
   f->commit();
 }
 
-void
-Manager::try_create_download_expand(const std::string& uri, int flags, command_list_type commands) {
-  if (flags & create_raw_data) {
-    try_create_download(uri, flags, commands);
-    return;
-  }
-
-  std::vector<std::string> paths;
-  paths.reserve(256);
-
-  path_expand(&paths, uri);
-
-  if (!paths.empty())
-    for (auto& path : paths)
-      try_create_download(path, flags, commands);
-
-  else
-    try_create_download(uri, flags, commands);
-}
-
 void
 Manager::try_create_download_from_meta_download(torrent::Object* bencode, const std::string& metafile) {
-  DownloadFactory* f = new DownloadFactory(this, true);
+  DownloadFactory* f = new DownloadFactory(this);
 
   f->variables()["tied_to_file"] = (int64_t)true;
-  f->variables()["tied_file"]    = metafile;
+  f->variables()["tied_file"] = metafile;
 
   torrent::Object& meta = bencode->get_key("rtorrent_meta_download");
   torrent::Object::list_type& commands = meta.get_key_list("commands");
-
   for (const auto& command : commands)
     f->commands().insert(f->commands().end(), command.as_string());
 
@@ -264,46 +239,13 @@ Manager::try_create_download_from_meta_download(torrent::Object* bencode, const
   std::stringstream s;
   s.imbue(std::locale::classic());
   s << *bencode;
-
-  f->load_raw_data_trusted(s.str());
+  f->load_raw_data(s.str());
   f->commit();
 }
 
-void
-Manager::try_create_download_untrusted(const std::string& uri, int flags, const command_list_type& commands) {
-  // TODO: Need to check if we are allowed, also rate limit.
-
-  if (!(flags & create_raw_data) &&
-      !is_network_uri(uri) &&
-      !is_magnet_uri(uri) &&
-      !is_data_uri(uri)) {
-    push_log_std("URI type not allowed for untrusted loads.");
-    return;
-  }
-
-  DownloadFactory* f = new DownloadFactory(this, false);
-
-  f->commands().insert(f->commands().end(), commands.begin(), commands.end());
-
-  f->set_start(flags & create_start);
-  f->set_print_log(!(flags & create_quiet));
-  f->slot_finished([f]() { delete f; });
-
-  if (flags & create_raw_data) {
-    f->load_raw_data_untrusted(uri);
-
-  } else if (is_data_uri(uri)) {
-    // Allow the use of data URIs, primarily for JSON-RPC which
-    // doesn't have a defined mechanism for binary data
-    f->load_raw_data_untrusted(decode_data_uri(uri));
-    f->variables()["tied_to_file"] = (int64_t)false;
-
-  } else {
-    // f->load_untrusted(uri);
-    throw torrent::internal_error("Manager::try_create_download_untrusted() unimplemented.");
-  }
-
-  f->commit();
+utils::Directory
+path_expand_transform(std::string path, const utils::directory_entry& entry) {
+  return path + entry.s_name;
 }
 
 namespace {
@@ -362,11 +304,6 @@ split_iterator(const Sequence&) {
 
 }
 
-utils::Directory
-path_expand_transform(std::string path, const utils::directory_entry& entry) {
-  return path + entry.s_name;
-}
-
 // Move this somewhere better.
 void
 path_expand(std::vector<std::string>* paths, const std::string& pattern) {
@@ -423,6 +360,26 @@ manager_equal_tied(const std::string& path, Download* download) {
   return path == rpc::call_command_string("d.tied_to_file", rpc::make_target(download));
 }
 
+void
+Manager::try_create_download_expand(const std::string& uri, int flags, command_list_type commands) {
+  if (flags & create_raw_data) {
+    try_create_download(uri, flags, commands);
+    return;
+  }
+
+  std::vector<std::string> paths;
+  paths.reserve(256);
+
+  path_expand(&paths, uri);
+
+  if (!paths.empty())
+    for (auto& path : paths)
+      try_create_download(path, flags, commands);
+
+  else
+    try_create_download(uri, flags, commands);
+}
+
 // DownloadList's hashing related functions don't actually start the
 // hashing, it only reacts to events. This functions checks the
 // hashing view and starts hashing if nessesary.

src/core/manager.h

@@ -78,8 +78,6 @@ public:
   void                try_create_download_expand(const std::string& uri, int flags, command_list_type commands = command_list_type());
   void                try_create_download_from_meta_download(torrent::Object* bencode, const std::string& metafile);
 
-  void                try_create_download_untrusted(const std::string& uri, int flags, const command_list_type& commands);
-
 private:
   void                create_http(const std::string& uri);
   void                create_final(std::istream* s);

src/rpc/scgi_task.h

@@ -16,7 +16,7 @@ class SCgiTask : public torrent::system::Event {
 public:
   static constexpr int default_buffer_size = 8191;
   static constexpr int max_header_size     = 2000;
-  static constexpr int max_content_size    = (2 << 23);
+  static constexpr int max_content_size    = (1 << 26);
 
   static constexpr auto timeout_request = std::chrono::seconds(60);
 

src/setup.cc

@@ -157,12 +157,12 @@ load_session_torrents(const std::string& path) {
     if (!entry.is_file())
       continue;
 
-    auto* f = new core::DownloadFactory(control->core(), true);
+    auto* f = new core::DownloadFactory(control->core());
 
     f->set_session(true);
     f->set_init_load(true);
     f->slot_finished([f](){ delete f; });
-    f->load_trusted(entries.path() + entry.s_name);
+    f->load(entries.path() + entry.s_name);
     f->commit();
   }
 }
@@ -170,12 +170,12 @@ load_session_torrents(const std::string& path) {
 void
 load_arg_torrents(char** first, char** last) {
   for (; first != last; ++first) {
-    auto* f = new core::DownloadFactory(control->core(), true);
+    auto* f = new core::DownloadFactory(control->core());
 
     f->set_start(true);
     f->set_init_load(true);
     f->slot_finished([f](){ delete f; });
-    f->load_trusted(*first);
+    f->load(*first);
     f->commit();
   }
 }

src/setup.h

@@ -3,6 +3,7 @@
 
 #include <functional>
 #include <string>
+#include <vector>
 
 int  parse_main_options(int argc, char** argv);
 void parse_config_file(int argc, char** argv, std::function<void (const std::string&)> parse_fn);

src/utils/gzip.h

@@ -2,6 +2,7 @@
 #define RTORRENT_UTILS_GZIP_H
 
 #include <functional>
+#include <vector>
 
 namespace utils {