X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Ftransfer.h;h=66e01e289c190de764a44f9d41fbd5e4ae7eaa2f;hp=88cf6f1c2aaa41e61ee6595c81b08348983f3694;hb=3a3e844f9fcfd12235a0086af75ecd503b621ef4;hpb=100a2678adf2016b7b4753d09d868929de83294e diff --git a/src/common/transfer.h b/src/common/transfer.h index 88cf6f1c..66e01e28 100644 --- a/src/common/transfer.h +++ b/src/common/transfer.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2013 by the Quassel Project * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,31 +18,35 @@ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ -#ifndef TRANSFER_H -#define TRANSFER_H +#pragma once + +#include "common-export.h" #include #include +#include "peer.h" #include "syncableobject.h" -class Transfer : public SyncableObject +class COMMON_EXPORT Transfer : public SyncableObject { Q_OBJECT SYNCABLE_OBJECT - Q_PROPERTY(QUuid uuid READ uuid); - Q_PROPERTY(State state READ state WRITE setState NOTIFY stateChanged); - Q_PROPERTY(Direction direction READ direction WRITE setDirection NOTIFY directionChanged); - Q_PROPERTY(QHostAddress address READ address WRITE setAddress NOTIFY addressChanged); - Q_PROPERTY(quint16 port READ port WRITE setPort NOTIFY portChanged); - Q_PROPERTY(QString fileName READ fileName WRITE setFileName NOTIFY fileNameChanged); - Q_PROPERTY(quint64 fileSize READ fileSize WRITE setFileSize NOTIFY fileSizeChanged); + Q_PROPERTY(QUuid uuid READ uuid) + Q_PROPERTY(Transfer::Status status READ status WRITE setStatus NOTIFY statusChanged) + Q_PROPERTY(Transfer::Direction direction READ direction WRITE setDirection NOTIFY directionChanged) + Q_PROPERTY(QHostAddress address READ address WRITE setAddress NOTIFY addressChanged) + Q_PROPERTY(quint16 port READ port WRITE setPort NOTIFY portChanged) + Q_PROPERTY(QString fileName READ fileName WRITE setFileName NOTIFY fileNameChanged) + Q_PROPERTY(quint64 fileSize READ fileSize WRITE setFileSize NOTIFY fileSizeChanged) + Q_PROPERTY(QString nick READ nick WRITE setNick NOTIFY nickChanged) public: - enum State { + enum class Status { New, Pending, + Connecting, Transferring, Paused, Completed, @@ -51,49 +55,85 @@ public: }; Q_ENUMS(State) - enum Direction { + enum class Direction { Send, Receive }; Q_ENUMS(Direction) - Transfer(const QUuid &uuid, QObject *parent = 0); // for creating a syncable object client-side - Transfer(Direction direction, const QString &fileName, const QHostAddress &address, quint16 port, quint64 size = 0, QObject *parent = 0); + Transfer(const QUuid &uuid, QObject *parent = nullptr); // for creating a syncable object client-side + Transfer(Direction direction, QString nick, QString fileName, const QHostAddress &address, quint16 port, quint64 size = 0, QObject *parent = nullptr); QUuid uuid() const; - State state() const; + Status status() const; + QString prettyStatus() const; Direction direction() const; QString fileName() const; QHostAddress address() const; quint16 port() const; quint64 fileSize() const; + QString nick() const; + + virtual quint64 transferred() const = 0; + +public slots: + // called on the client side + virtual void accept(const QString &savePath) const { Q_UNUSED(savePath); } + virtual void reject() const {} + + // called on the core side through sync calls + virtual void requestAccepted(PeerPtr peer) { Q_UNUSED(peer); } + virtual void requestRejected(PeerPtr peer) { Q_UNUSED(peer); } signals: - void stateChanged(State state); - void directionChanged(Direction direction); + void statusChanged(Transfer::Status state); + void directionChanged(Transfer::Direction direction); void addressChanged(const QHostAddress &address); void portChanged(quint16 port); void fileNameChanged(const QString &fileName); void fileSizeChanged(quint64 fileSize); + void transferredChanged(quint64 transferred); + void nickChanged(const QString &nick); + + void error(const QString &errorString); -protected: - void setState(State state); + void accepted(PeerPtr peer = nullptr) const; + void rejected(PeerPtr peer = nullptr) const; + +protected slots: + void setStatus(Transfer::Status status); + void setError(const QString &errorString); + + // called on the client side through sync calls + virtual void dataReceived(PeerPtr, const QByteArray &data) { Q_UNUSED(data); } + + virtual void cleanUp() = 0; private: + void init(); + void setDirection(Direction direction); void setAddress(const QHostAddress &address); void setPort(quint16 port); void setFileName(const QString &fileName); void setFileSize(quint64 fileSize); + void setNick(const QString &nick); - State _state; + Status _status; Direction _direction; QString _fileName; QHostAddress _address; quint16 _port; quint64 _fileSize; + QString _nick; QUuid _uuid; }; -#endif +Q_DECLARE_METATYPE(Transfer::Status) +Q_DECLARE_METATYPE(Transfer::Direction) + +QDataStream &operator<<(QDataStream &out, Transfer::Status state); +QDataStream &operator>>(QDataStream &in, Transfer::Status &state); +QDataStream &operator<<(QDataStream &out, Transfer::Direction direction); +QDataStream &operator>>(QDataStream &in, Transfer::Direction &direction);