transmission/qt/session.h

155 lines
5.0 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 torrentSet( const QSet<int>& ids, const QString& key, const QPair<int,QString>& 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