154 lines
4.9 KiB
C++
154 lines
4.9 KiB
C++
/*
|
|
* This file Copyright (C) Mnemosyne LLC
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License version 2
|
|
* as published by the Free Software Foundation.
|
|
*
|
|
* http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
|
|
*
|
|
* $Id$
|
|
*/
|
|
|
|
#ifndef TR_APP_SESSION_H
|
|
#define TR_APP_SESSION_H
|
|
|
|
#include <QObject>
|
|
#include <QSet>
|
|
#include <QBuffer>
|
|
#include <QFileInfoList>
|
|
#include <QNetworkAccessManager>
|
|
#include <QString>
|
|
#include <QUrl>
|
|
|
|
class QStringList;
|
|
|
|
class AddData;
|
|
|
|
#include <libtransmission/transmission.h>
|
|
|
|
extern "C"
|
|
{
|
|
struct tr_benc;
|
|
}
|
|
|
|
class Prefs;
|
|
|
|
class Session: public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
public:
|
|
Session( const char * configDir, Prefs& prefs );
|
|
~Session( );
|
|
|
|
public:
|
|
void stop( );
|
|
void restart( );
|
|
|
|
private:
|
|
void start( );
|
|
|
|
public:
|
|
const QUrl& getRemoteUrl( ) const { return myUrl; }
|
|
const struct tr_session_stats& getStats( ) const { return myStats; }
|
|
const struct tr_session_stats& getCumulativeStats( ) const { return myCumulativeStats; }
|
|
const QString& sessionVersion( ) const { return mySessionVersion; }
|
|
|
|
public:
|
|
int64_t blocklistSize( ) const { return myBlocklistSize; }
|
|
void setBlocklistSize( int64_t i );
|
|
void updateBlocklist( );
|
|
void portTest( );
|
|
void copyMagnetLinkToClipboard( int torrentId );
|
|
|
|
public:
|
|
|
|
/** returns true if the transmission session is being run inside this client */
|
|
bool isServer( ) const;
|
|
|
|
/** returns true if isServer() is true or if the remote address is the localhost */
|
|
bool isLocal( ) const;
|
|
|
|
private:
|
|
void updateStats( struct tr_benc * args );
|
|
void updateInfo( struct tr_benc * args );
|
|
void parseResponse( const char * json, size_t len );
|
|
static void localSessionCallback( tr_session *, const char *, size_t, void * );
|
|
|
|
public:
|
|
void exec( const char * json );
|
|
void exec( const struct tr_benc * request );
|
|
|
|
public:
|
|
int64_t getUniqueTag( ) { return nextUniqueTag++; }
|
|
|
|
private:
|
|
void sessionSet( const char * key, const QVariant& variant );
|
|
void pumpRequests( );
|
|
void sendTorrentRequest( const char * request, const QSet<int>& torrentIds );
|
|
static void updateStats( struct tr_benc * d, struct tr_session_stats * stats );
|
|
void refreshTorrents( const QSet<int>& torrentIds );
|
|
QNetworkAccessManager * networkAccessManager( );
|
|
|
|
public:
|
|
void torrentSet( const QSet<int>& ids, const QString& key, bool val );
|
|
void torrentSet( const QSet<int>& ids, const QString& key, int val );
|
|
void torrentSet( const QSet<int>& ids, const QString& key, double val );
|
|
void torrentSet( const QSet<int>& ids, const QString& key, const QList<int>& val );
|
|
void torrentSet( const QSet<int>& ids, const QString& key, const QStringList& val );
|
|
void torrentSetLocation( const QSet<int>& ids, const QString& path, bool doMove );
|
|
|
|
|
|
public slots:
|
|
void pauseTorrents( const QSet<int>& torrentIds = QSet<int>() );
|
|
void startTorrents( const QSet<int>& torrentIds = QSet<int>() );
|
|
void refreshSessionInfo( );
|
|
void refreshSessionStats( );
|
|
void refreshActiveTorrents( );
|
|
void refreshAllTorrents( );
|
|
void initTorrents( const QSet<int>& ids = QSet<int>() );
|
|
void addNewlyCreatedTorrent( const QString& filename, const QString& localPath );
|
|
void addTorrent( const AddData& addme );
|
|
void removeTorrents( const QSet<int>& torrentIds, bool deleteFiles=false );
|
|
void verifyTorrents( const QSet<int>& torrentIds );
|
|
void reannounceTorrents( const QSet<int>& torrentIds );
|
|
void launchWebInterface( );
|
|
void updatePref( int key );
|
|
|
|
/** request a refresh for statistics, including the ones only used by the properties dialog, for a specific torrent */
|
|
void refreshExtraStats( const QSet<int>& ids );
|
|
|
|
private slots:
|
|
void onFinished( QNetworkReply * reply );
|
|
|
|
signals:
|
|
void executed( int64_t tag, const QString& result, struct tr_benc * arguments );
|
|
void sourceChanged( );
|
|
void portTested( bool isOpen );
|
|
void statsUpdated( );
|
|
void sessionUpdated( );
|
|
void blocklistUpdated( int );
|
|
void torrentsUpdated( struct tr_benc * torrentList, bool completeList );
|
|
void torrentsRemoved( struct tr_benc * torrentList );
|
|
void dataReadProgress( );
|
|
void dataSendProgress( );
|
|
void httpAuthenticationRequired( );
|
|
|
|
private:
|
|
int64_t nextUniqueTag;
|
|
int64_t myBlocklistSize;
|
|
Prefs& myPrefs;
|
|
tr_session * mySession;
|
|
QString myConfigDir;
|
|
QString mySessionId;
|
|
QUrl myUrl;
|
|
QNetworkAccessManager * myNAM;
|
|
struct tr_session_stats myStats;
|
|
struct tr_session_stats myCumulativeStats;
|
|
QString mySessionVersion;
|
|
};
|
|
|
|
#endif
|
|
|