#include <searchhandler.h>

Inheritance diagram for SearchHandler:

Collaboration diagram for SearchHandler:

Signals
void	searchFinished (bool cancelled=false)

void	searchFailed ()

void	newSearchResults (const QVector< SearchResult > &results)

Public Member Functions
bool	isActive () const

QString	pattern () const

SearchPluginManager *	manager () const

QList< SearchResult >	results () const

void	cancelSearch ()

Private Member Functions
	SearchHandler (const QString &pattern, const QString &category, const QStringList &usedPlugins, SearchPluginManager *manager)

void	readSearchOutput ()

void	processFailed ()

void	processFinished (int exitcode)

bool	parseSearchResult (QStringView line, SearchResult &searchResult)

Private Attributes
const QString	m_pattern

const QString	m_category

const QStringList	m_usedPlugins

SearchPluginManager *	m_manager

QProcess *	m_searchProcess

QTimer *	m_searchTimeout

QByteArray	m_searchResultLineTruncated

bool	m_searchCancelled = false

QList< SearchResult >	m_results

Friends
class	SearchPluginManager

Detailed Description

Definition at line 54 of file searchhandler.h.

Constructor & Destructor Documentation

◆ SearchHandler()

SearchHandler::SearchHandler	(	const QString &	pattern,
		const QString &	category,
		const QStringList &	usedPlugins,
		SearchPluginManager *	manager
	)

private

Definition at line 56 of file searchhandler.cpp.

     : QObject {manager}
     , m_pattern {pattern}
     , m_category {category}
     , m_usedPlugins {usedPlugins}
     , m_manager {manager}
     , m_searchProcess {new QProcess {this}}
     , m_searchTimeout {new QTimer {this}}
 {
     // Load environment variables (proxy)
     m_searchProcess->setEnvironment(QProcess::systemEnvironment());
  
     const QStringList params
     {
         Utils::Fs::toNativePath(m_manager->engineLocation() + "/nova2.py"),
         m_usedPlugins.join(','),
         m_category
     };
  
     // Launch search
     m_searchProcess->setProgram(Utils::ForeignApps::pythonInfo().executableName);
     m_searchProcess->setArguments(params + m_pattern.split(' '));
  
     connect(m_searchProcess, &QProcess::errorOccurred, this, &SearchHandler::processFailed);
     connect(m_searchProcess, &QProcess::readyReadStandardOutput, this, &SearchHandler::readSearchOutput);
     connect(m_searchProcess, qOverload<int, QProcess::ExitStatus>(&QProcess::finished)
             , this, &SearchHandler::processFinished);
  
     m_searchTimeout->setSingleShot(true);
     connect(m_searchTimeout, &QTimer::timeout, this, &SearchHandler::cancelSearch);
     m_searchTimeout->start(180000); // 3 min
  
     // deferred start allows clients to handle starting-related signals
     QTimer::singleShot(0, this, [this]() { m_searchProcess->start(QIODevice::ReadOnly); });
 }

References cancelSearch(), SearchPluginManager::engineLocation(), m_category, m_manager, m_pattern, m_searchProcess, m_searchTimeout, m_usedPlugins, processFailed(), processFinished(), Utils::ForeignApps::pythonInfo(), readSearchOutput(), and Utils::Fs::toNativePath().

Here is the call graph for this function:

Member Function Documentation

◆ cancelSearch()

void SearchHandler::cancelSearch ( )

Definition at line 97 of file searchhandler.cpp.

 {
     if ((m_searchProcess->state() == QProcess::NotRunning) || m_searchCancelled)
         return;
  
 #ifdef Q_OS_WIN
     m_searchProcess->kill();
 #else
     m_searchProcess->terminate();
 #endif
     m_searchCancelled = true;
     m_searchTimeout->stop();
 }

References m_searchCancelled, m_searchProcess, and m_searchTimeout.

Referenced by SearchJobWidget::cancelSearch(), and SearchHandler().

Here is the caller graph for this function:

◆ isActive()

bool SearchHandler::isActive ( ) const

Definition at line 92 of file searchhandler.cpp.

 {
     return (m_searchProcess->state() != QProcess::NotRunning);
 }

References m_searchProcess.

◆ manager()

SearchPluginManager * SearchHandler::manager ( ) const

Definition at line 195 of file searchhandler.cpp.

 {
     return m_manager;
 }

References m_manager.

Referenced by SearchJobWidget::downloadTorrent().

Here is the caller graph for this function:

◆ newSearchResults

void SearchHandler::newSearchResults ( const QVector< SearchResult > & results )

signal

Referenced by readSearchOutput(), and SearchJobWidget::SearchJobWidget().

Here is the caller graph for this function:

◆ parseSearchResult()

bool SearchHandler::parseSearchResult	(	QStringView	line,
		SearchResult &	searchResult
	)

private

Definition at line 166 of file searchhandler.cpp.

 {
     const QList<QStringView> parts = line.split(u'|');
     const int nbFields = parts.size();
  
     if (nbFields < (NB_PLUGIN_COLUMNS - 1)) return false; // -1 because desc_link is optional
  
     searchResult = SearchResult();
     searchResult.fileUrl = parts.at(PL_DL_LINK).trimmed().toString(); // download URL
     searchResult.fileName = parts.at(PL_NAME).trimmed().toString(); // Name
     searchResult.fileSize = parts.at(PL_SIZE).trimmed().toLongLong(); // Size
  
     bool ok = false;
  
     searchResult.nbSeeders = parts.at(PL_SEEDS).trimmed().toLongLong(&ok); // Seeders
     if (!ok || (searchResult.nbSeeders < 0))
         searchResult.nbSeeders = -1;
  
     searchResult.nbLeechers = parts.at(PL_LEECHS).trimmed().toLongLong(&ok); // Leechers
     if (!ok || (searchResult.nbLeechers < 0))
         searchResult.nbLeechers = -1;
  
     searchResult.siteUrl = parts.at(PL_ENGINE_URL).trimmed().toString(); // Search site URL
     if (nbFields == NB_PLUGIN_COLUMNS)
         searchResult.descrLink = parts.at(PL_DESC_LINK).trimmed().toString(); // Description Link
  
     return true;
 }

References SearchResult::descrLink, SearchResult::fileName, SearchResult::fileSize, SearchResult::fileUrl, anonymous_namespace{searchhandler.cpp}::NB_PLUGIN_COLUMNS, SearchResult::nbLeechers, SearchResult::nbSeeders, anonymous_namespace{searchhandler.cpp}::PL_DESC_LINK, anonymous_namespace{searchhandler.cpp}::PL_DL_LINK, anonymous_namespace{searchhandler.cpp}::PL_ENGINE_URL, anonymous_namespace{searchhandler.cpp}::PL_LEECHS, anonymous_namespace{searchhandler.cpp}::PL_NAME, anonymous_namespace{searchhandler.cpp}::PL_SEEDS, anonymous_namespace{searchhandler.cpp}::PL_SIZE, and SearchResult::siteUrl.

Referenced by readSearchOutput().

Here is the caller graph for this function:

◆ pattern()

QString SearchHandler::pattern ( ) const

Definition at line 205 of file searchhandler.cpp.

 {
     return m_pattern;
 }

References m_pattern.

Referenced by SearchJobWidget::SearchJobWidget().

Here is the caller graph for this function:

◆ processFailed()

void SearchHandler::processFailed ( )

private

Definition at line 157 of file searchhandler.cpp.

 {
     if (!m_searchCancelled)
         emit searchFailed();
 }

References m_searchCancelled, and searchFailed().

Referenced by SearchHandler().

Here is the caller graph for this function:

◆ processFinished()

void SearchHandler::processFinished ( int exitcode )

private

Definition at line 114 of file searchhandler.cpp.

 {
     m_searchTimeout->stop();
  
     if (m_searchCancelled)
         emit searchFinished(true);
     else if ((m_searchProcess->exitStatus() == QProcess::NormalExit) && (exitcode == 0))
         emit searchFinished(false);
     else
         emit searchFailed();
 }

References m_searchCancelled, m_searchProcess, m_searchTimeout, searchFailed(), and searchFinished().

Referenced by SearchHandler().

Here is the caller graph for this function:

◆ readSearchOutput()

void SearchHandler::readSearchOutput ( )

private

Definition at line 129 of file searchhandler.cpp.

 {
     QByteArray output = m_searchProcess->readAllStandardOutput();
     output.replace('\r', "");
  
     QList<QByteArray> lines = output.split('\n');
     if (!m_searchResultLineTruncated.isEmpty())
         lines.prepend(m_searchResultLineTruncated + lines.takeFirst());
     m_searchResultLineTruncated = lines.takeLast().trimmed();
  
     QVector<SearchResult> searchResultList;
     searchResultList.reserve(lines.size());
  
     for (const QByteArray &line : asConst(lines))
     {
         SearchResult searchResult;
         if (parseSearchResult(QString::fromUtf8(line), searchResult))
             searchResultList << searchResult;
     }
  
     if (!searchResultList.isEmpty())
     {
         for (const SearchResult &result : searchResultList)
             m_results.append(result);
         emit newSearchResults(searchResultList);
     }
 }