#include <torrentfileswatcher.h>

Inheritance diagram for TorrentFilesWatcher:

Collaboration diagram for TorrentFilesWatcher:

Classes
struct	WatchedFolderOptions

class	Worker

Signals
void	watchedFolderSet (const QString &path, const WatchedFolderOptions &options)

void	watchedFolderRemoved (const QString &path)

Public Member Functions
QHash< QString, WatchedFolderOptions >	folders () const

void	setWatchedFolder (const QString &path, const WatchedFolderOptions &options)

void	removeWatchedFolder (const QString &path)

Static Public Member Functions
static void	initInstance ()

static void	freeInstance ()

static TorrentFilesWatcher *	instance ()

static QString	makeCleanPath (const QString &path)

Private Slots
void	onMagnetFound (const BitTorrent::MagnetUri &magnetURI, const BitTorrent::AddTorrentParams &addTorrentParams)

void	onTorrentFound (const BitTorrent::TorrentInfo &torrentInfo, const BitTorrent::AddTorrentParams &addTorrentParams)

Private Member Functions
	TorrentFilesWatcher (QObject *parent=nullptr)

	~TorrentFilesWatcher () override

void	load ()

void	loadLegacy ()

void	store () const

void	doSetWatchedFolder (const QString &path, const WatchedFolderOptions &options)

Private Attributes
QHash< QString, WatchedFolderOptions >	m_watchedFolders

QThread *	m_ioThread = nullptr

Worker *	m_asyncWorker = nullptr

Static Private Attributes
static TorrentFilesWatcher *	m_instance = nullptr

Detailed Description

Definition at line 48 of file torrentfileswatcher.h.

Constructor & Destructor Documentation

◆ TorrentFilesWatcher()

TorrentFilesWatcher::TorrentFilesWatcher ( QObject * parent = nullptr )

explicitprivate

Definition at line 256 of file torrentfileswatcher.cpp.

     : QObject {parent}
     , m_ioThread {new QThread(this)}
     , m_asyncWorker {new TorrentFilesWatcher::Worker}
 {
     connect(m_asyncWorker, &TorrentFilesWatcher::Worker::magnetFound, this, &TorrentFilesWatcher::onMagnetFound);
     connect(m_asyncWorker, &TorrentFilesWatcher::Worker::torrentFound, this, &TorrentFilesWatcher::onTorrentFound);
  
     m_asyncWorker->moveToThread(m_ioThread);
     m_ioThread->start();
  
     load();
 }

References load(), m_asyncWorker, m_ioThread, TorrentFilesWatcher::Worker::magnetFound(), onMagnetFound(), onTorrentFound(), and TorrentFilesWatcher::Worker::torrentFound().

Here is the call graph for this function:

◆ ~TorrentFilesWatcher()

TorrentFilesWatcher::~TorrentFilesWatcher ( )

overrideprivate

Definition at line 270 of file torrentfileswatcher.cpp.

 {
     m_ioThread->quit();
     m_ioThread->wait();
     delete m_asyncWorker;
 }

References m_asyncWorker, and m_ioThread.

Member Function Documentation

◆ doSetWatchedFolder()

void TorrentFilesWatcher::doSetWatchedFolder	(	const QString &	path,
		const WatchedFolderOptions &	options
	)

private

Definition at line 404 of file torrentfileswatcher.cpp.

 {
     const QString cleanPath = makeCleanPath(path);
     m_watchedFolders[cleanPath] = options;
  
     QMetaObject::invokeMethod(m_asyncWorker, [this, path, options]()
     {
         m_asyncWorker->setWatchedFolder(path, options);
     });
  
     emit watchedFolderSet(cleanPath, options);
 }

References m_asyncWorker, m_watchedFolders, makeCleanPath(), TorrentFilesWatcher::Worker::setWatchedFolder(), and watchedFolderSet().

Referenced by load(), loadLegacy(), and setWatchedFolder().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ folders()

QHash< QString, TorrentFilesWatcher::WatchedFolderOptions > TorrentFilesWatcher::folders ( ) const

Definition at line 393 of file torrentfileswatcher.cpp.

 {
     return m_watchedFolders;
 }

References m_watchedFolders.

Referenced by AppController::preferencesAction(), and AppController::setPreferencesAction().

Here is the caller graph for this function:

◆ freeInstance()

void TorrentFilesWatcher::freeInstance ( )

static

Definition at line 245 of file torrentfileswatcher.cpp.

 {
     delete m_instance;
     m_instance = nullptr;
 }

Referenced by Application::cleanup().

Here is the caller graph for this function:

◆ initInstance()

void TorrentFilesWatcher::initInstance ( )

static

Definition at line 239 of file torrentfileswatcher.cpp.

 {
     if (!m_instance)
         m_instance = new TorrentFilesWatcher;
 }

Referenced by Application::exec().

Here is the caller graph for this function:

◆ instance()

TorrentFilesWatcher * TorrentFilesWatcher::instance ( )

static

Definition at line 251 of file torrentfileswatcher.cpp.

 {
     return m_instance;
 }

Referenced by OptionsDialog::OptionsDialog(), AppController::preferencesAction(), and AppController::setPreferencesAction().

Here is the caller graph for this function:

◆ load()

void TorrentFilesWatcher::load ( )

private

Definition at line 288 of file torrentfileswatcher.cpp.

 {
     QFile confFile {QDir(specialFolderLocation(SpecialFolder::Config)).absoluteFilePath(CONF_FILE_NAME)};
     if (!confFile.exists())
     {
         loadLegacy();
         return;
     }
  
     if (!confFile.open(QFile::ReadOnly))
     {
         LogMsg(tr("Couldn't load Watched Folders configuration from %1. Error: %2")
             .arg(confFile.fileName(), confFile.errorString()), Log::WARNING);
         return;
     }
  
     QJsonParseError jsonError;
     const QJsonDocument jsonDoc = QJsonDocument::fromJson(confFile.readAll(), &jsonError);
     if (jsonError.error != QJsonParseError::NoError)
     {
         LogMsg(tr("Couldn't parse Watched Folders configuration from %1. Error: %2")
             .arg(confFile.fileName(), jsonError.errorString()), Log::WARNING);
         return;
     }
  
     if (!jsonDoc.isObject())
     {
         LogMsg(tr("Couldn't load Watched Folders configuration from %1. Invalid data format.")
             .arg(confFile.fileName()), Log::WARNING);
         return;
     }
  
     const QJsonObject jsonObj = jsonDoc.object();
     for (auto it = jsonObj.constBegin(); it != jsonObj.constEnd(); ++it)
     {
         const QString &watchedFolder = it.key();
         const WatchedFolderOptions options = parseWatchedFolderOptions(it.value().toObject());
         try
         {
             doSetWatchedFolder(watchedFolder, options);
         }
         catch (const InvalidArgument &err)
         {
             LogMsg(err.message(), Log::WARNING);
         }
     }
 }

References CONF_FILE_NAME, Config, doSetWatchedFolder(), loadLegacy(), LogMsg(), Exception::message(), anonymous_namespace{torrentfileswatcher.cpp}::parseWatchedFolderOptions(), specialFolderLocation(), and Log::WARNING.

Referenced by TorrentFilesWatcher().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ loadLegacy()

void TorrentFilesWatcher::loadLegacy ( )

private

Definition at line 336 of file torrentfileswatcher.cpp.

 {
     const auto dirs = SettingsStorage::instance()->loadValue<QVariantHash>("Preferences/Downloads/ScanDirsV2");
  
     for (auto i = dirs.cbegin(); i != dirs.cend(); ++i)
     {
         const QString watchedFolder = i.key();
         BitTorrent::AddTorrentParams params;
         if (i.value().type() == QVariant::Int)
         {
             if (i.value().toInt() == 0)
             {
                 params.savePath = watchedFolder;
                 params.useAutoTMM = false;
             }
         }
         else
         {
             const QString customSavePath = i.value().toString();
             params.savePath = customSavePath;
             params.useAutoTMM = false;
         }
  
         try
         {
             doSetWatchedFolder(watchedFolder, {params, false});
         }
         catch (const InvalidArgument &err)
         {
             LogMsg(err.message(), Log::WARNING);
         }
     }
  
     store();
     SettingsStorage::instance()->removeValue("Preferences/Downloads/ScanDirsV2");
 }

References doSetWatchedFolder(), SettingsStorage::instance(), SettingsStorage::loadValue(), LogMsg(), Exception::message(), SettingsStorage::removeValue(), BitTorrent::AddTorrentParams::savePath, store(), BitTorrent::AddTorrentParams::useAutoTMM, and Log::WARNING.

Referenced by load().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ makeCleanPath()

QString TorrentFilesWatcher::makeCleanPath ( const QString & path )

static

Definition at line 277 of file torrentfileswatcher.cpp.

 {
     if (path.isEmpty())
         throw InvalidArgument(tr("Watched folder path cannot be empty."));
  
     if (QDir::isRelativePath(path))
         throw InvalidArgument(tr("Watched folder path cannot be relative."));
  
     return QDir::cleanPath(path);
 }

Referenced by WatchedFoldersModel::addFolder(), doSetWatchedFolder(), removeWatchedFolder(), and AppController::setPreferencesAction().

Here is the caller graph for this function:

◆ onMagnetFound

void TorrentFilesWatcher::onMagnetFound	(	const BitTorrent::MagnetUri &	magnetURI,
		const BitTorrent::AddTorrentParams &	addTorrentParams
	)

privateslot

Definition at line 433 of file torrentfileswatcher.cpp.

 {
     BitTorrent::Session::instance()->addTorrent(magnetURI, addTorrentParams);
 }

References BitTorrent::Session::addTorrent(), and BitTorrent::Session::instance().

Referenced by TorrentFilesWatcher().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ onTorrentFound

void TorrentFilesWatcher::onTorrentFound	(	const BitTorrent::TorrentInfo &	torrentInfo,
		const BitTorrent::AddTorrentParams &	addTorrentParams
	)

privateslot

Definition at line 439 of file torrentfileswatcher.cpp.

 {
     BitTorrent::Session::instance()->addTorrent(torrentInfo, addTorrentParams);
 }

References BitTorrent::Session::addTorrent(), and BitTorrent::Session::instance().

Referenced by TorrentFilesWatcher().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeWatchedFolder()

void TorrentFilesWatcher::removeWatchedFolder ( const QString & path )

Definition at line 417 of file torrentfileswatcher.cpp.

 {
     const QString cleanPath = makeCleanPath(path);
     if (m_watchedFolders.remove(cleanPath))
     {
         QMetaObject::invokeMethod(m_asyncWorker, [this, cleanPath]()
         {
             m_asyncWorker->removeWatchedFolder(cleanPath);
         });
  
         emit watchedFolderRemoved(cleanPath);
  
         store();
     }
 }

References m_asyncWorker, m_watchedFolders, makeCleanPath(), TorrentFilesWatcher::Worker::removeWatchedFolder(), store(), and watchedFolderRemoved().

Referenced by WatchedFoldersModel::apply(), and AppController::setPreferencesAction().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setWatchedFolder()

void TorrentFilesWatcher::setWatchedFolder	(	const QString &	path,
		const WatchedFolderOptions &	options
	)

Definition at line 398 of file torrentfileswatcher.cpp.

 {
     doSetWatchedFolder(path, options);
     store();
 }

References doSetWatchedFolder(), and store().

Referenced by WatchedFoldersModel::apply(), and AppController::setPreferencesAction().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ store()

void TorrentFilesWatcher::store ( ) const

private

Definition at line 373 of file torrentfileswatcher.cpp.

 {
     QJsonObject jsonObj;
     for (auto it = m_watchedFolders.cbegin(); it != m_watchedFolders.cend(); ++it)
     {
         const QString &watchedFolder = it.key();
         const WatchedFolderOptions &options = it.value();
         jsonObj[watchedFolder] = serializeWatchedFolderOptions(options);
     }
  
     const QString path = QDir(specialFolderLocation(SpecialFolder::Config)).absoluteFilePath(CONF_FILE_NAME);
     const QByteArray data = QJsonDocument(jsonObj).toJson();
     const nonstd::expected<void, QString> result = Utils::IO::saveToFile(path, data);
     if (!result)
     {
         LogMsg(tr("Couldn't store Watched Folders configuration to %1. Error: %2")
             .arg(path, result.error()), Log::WARNING);
     }
 }