namespace AniDBUdpClient {
-AbstractCommand::AbstractCommand(QObject *parent) : QObject(parent)
+AbstractCommand::AbstractCommand()
{
- m_replyCode = UNKNOWN_REPLY;
}
AbstractCommand::~AbstractCommand()
{
-
}
Command AbstractCommand::rawCommand() const
return true;
}
-void AbstractCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
+// ===
+
+AbstractReply::AbstractReply(const QByteArray &id, Client *client, QObject *parent) : QObject(parent)
+{
+ m_replyCode = UNKNOWN_REPLY;
+ m_id = id;
+ m_client = client;
+}
+
+AbstractReply::~AbstractReply()
+{
+
+}
+
+const AbstractCommand &AbstractReply::command() const
+{
+ return m_command;
+}
+
+void AbstractReply::setRawReply(ReplyCode replyCode, const QString &reply)
{
- Q_UNUSED(client);
m_replyCode = replyCode;
m_rawReply = reply;
}
-QString AbstractCommand::rawReply() const
+QString AbstractReply::rawReply() const
{
return m_rawReply;
}
-ReplyCode AbstractCommand::replyCode() const
+ReplyCode AbstractReply::replyCode() const
{
return m_replyCode;
}
+QByteArray AbstractReply::id() const
+{
+ return m_id;
+}
+
} // namespace AniDBUdpClient
typedef QPair<QString, QVariantMap> Command;
-class ANIDBUDPCLIENTSHARED_EXPORT AbstractCommand : public QObject
-{
- Q_OBJECT
-
- Q_PROPERTY(ReplyCode replyCode READ replyCode);
+class AbstractReply;
+class ANIDBUDPCLIENTSHARED_EXPORT AbstractCommand
+{
+ friend class Client;
public:
-
- AbstractCommand(QObject *parent = 0);
+ typedef AbstractReply ReplyType;
+ AbstractCommand();
virtual ~AbstractCommand();
virtual Command rawCommand() const;
virtual bool waitForResult() const;
virtual bool requiresSession() const;
+};
+
+#define REPLY_DEFINITION_HELPER(name) \
+ friend class Client; \
+ public: \
+ typedef name##Command CommandType; \
+ private: \
+ CommandType m_command; \
+ Client *m_client; \
+ name##Reply(const CommandType command, const QByteArray &id, Client *client, QObject *parent) : m_command(command), m_client(client), AbstractReply(id, client, parent) {} \
+ inline const CommandType &command() const { return m_command; }
+
+#define REPLY_DEFINITION_HELPER2(name) \
+ friend class Client; \
+ public: \
+ typedef name##Command CommandType; \
+ private: \
+ CommandType m_command; \
+ Client *m_client; \
+ name##Reply(const CommandType command, const QByteArray &id, Client *client, QObject *parent) : m_command(command), m_client(client), AbstractReply(id, client, parent) {init();} \
+ inline const CommandType &command() const { return m_command; }
+
+class ANIDBUDPCLIENTSHARED_EXPORT AbstractReply : public QObject
+{
+ Q_OBJECT
+
+ Q_PROPERTY(QByteArray id READ id);
+ Q_PROPERTY(ReplyCode replyCode READ replyCode);
+
+public:
+ typedef AbstractCommand CommandType;
- virtual void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
+ AbstractReply(const QByteArray &id, Client *client, QObject *parent = 0);
+ virtual ~AbstractReply();
+
+ const CommandType &command() const;
+
+ virtual void setRawReply(ReplyCode replyCode, const QString &reply);
virtual QString rawReply() const;
virtual ReplyCode replyCode() const;
+ virtual QByteArray id() const;
signals:
void replyReady(bool success = false);
protected:
QString m_rawReply;
ReplyCode m_replyCode;
+ QByteArray m_id;
+ Client *m_client;
+
+ AbstractCommand m_command;
};
} // namespace AniDBUdpClient
-#include <QScriptEngine>
-Q_SCRIPT_DECLARE_QMETAOBJECT(AniDBUdpClient::AbstractCommand, QObject*);
-
#endif // ABSTRACTCOMMAND_H
namespace AniDBUdpClient {
-AuthCommand::AuthCommand(QObject *parent) : AbstractCommand(parent)
+AuthCommand::AuthCommand() : AbstractCommand()
{
m_compression = false;
}
-AuthCommand::AuthCommand(const QString &user, const QString &pass, QObject *parent) : AbstractCommand(parent)
+AuthCommand::AuthCommand(const QString &user, const QString &pass) : AbstractCommand()
{
m_user = user;
m_pass = pass;
+ m_compression = false;
}
QString AuthCommand::user() const
m_compression = compress;
}
-QString AuthCommand::sessionId() const
-{
- return m_sessionId;
-}
-
-QString AuthCommand::errorString() const
-{
- return m_errorString;
-}
-
-void AuthCommand::clearError()
-{
- m_errorString = "";
-}
-
bool AuthCommand::waitForResult() const
{
return true;
return command;
}
-void AuthCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
+// ===
+
+QString AuthReply::sessionId() const
+{
+ return m_sessionId;
+}
+
+QString AuthReply::errorString() const
+{
+ return m_errorString;
+}
+
+void AuthReply::clearError()
+{
+ m_errorString = "";
+}
+
+void AuthReply::setRawReply(ReplyCode replyCode, const QString &reply)
{
qDebug() << replyCode;
- AbstractCommand::setRawReply(replyCode, reply, client);
+ AbstractReply::setRawReply(replyCode, reply);
switch(replyCode)
{
-#ifndef AUTHCOMMAND_H
-#define AUTHCOMMAND_H
-
-#include "abstractcommand.h"
-
-namespace AniDBUdpClient {
-
-class AuthCommand : public AbstractCommand
-{
- Q_OBJECT
-
- Q_PROPERTY(QString user READ user WRITE setUser);
- Q_PROPERTY(QString pass READ pass WRITE setPass);
- Q_PROPERTY(bool compression READ compression WRITE setCompression);
-
- Q_PROPERTY(QString sessionId READ sessionId);
- Q_PROPERTY(QString errorString READ errorString RESET clearError);
-
-public:
- AuthCommand(QObject *parent = 0);
- AuthCommand(const QString &user, const QString &pass, QObject *parent = 0);
-
- QString user() const;
- void setUser(const QString &user);
-
- QString pass() const;
- void setPass(const QString &pass);
-
- bool compression() const;
- void setCompression(bool compress);
-
-
- QString sessionId() const;
- QString errorString() const;
- void clearError();
-
-
- bool waitForResult() const;
- bool requiresSession() const;
-
- Command rawCommand() const;
- void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
-
-private:
- QString m_user;
- QString m_pass;
- QString m_sessionId;
- QString m_errorString;
-
- bool m_compression;
-};
-
-} // namespace AniDBUdpClient
-
-#endif // AUTHCOMMAND_H
+#ifndef AUTHCOMMAND_H\r
+#define AUTHCOMMAND_H\r
+\r
+#include "abstractcommand.h"\r
+\r
+namespace AniDBUdpClient {\r
+\r
+class AuthReply;\r
+\r
+class AuthCommand : public AbstractCommand\r
+{\r
+/*\r
+ Q_PROPERTY(QString user READ user WRITE setUser);\r
+ Q_PROPERTY(QString pass READ pass WRITE setPass);\r
+ Q_PROPERTY(bool compression READ compression WRITE setCompression);\r
+*/\r
+public:\r
+ typedef AuthReply ReplyType;\r
+ AuthCommand();\r
+ AuthCommand(const QString &user, const QString &pass);\r
+\r
+ QString user() const;\r
+ void setUser(const QString &user);\r
+\r
+ QString pass() const;\r
+ void setPass(const QString &pass);\r
+\r
+ bool compression() const;\r
+ void setCompression(bool compress);\r
+\r
+\r
+ bool waitForResult() const;\r
+ bool requiresSession() const;\r
+\r
+ Command rawCommand() const;\r
+\r
+private:\r
+ QString m_user;\r
+ QString m_pass;\r
+\r
+ bool m_compression;\r
+};\r
+\r
+class AuthReply : public AbstractReply\r
+{\r
+ Q_OBJECT\r
+ REPLY_DEFINITION_HELPER(Auth)\r
+\r
+ Q_PROPERTY(QString sessionId READ sessionId);\r
+ Q_PROPERTY(QString errorString READ errorString RESET clearError);\r
+\r
+public:\r
+\r
+ QString sessionId() const;\r
+ QString errorString() const;\r
+ void clearError();\r
+\r
+ void setRawReply(ReplyCode replyCode, const QString &reply);\r
+\r
+private:\r
+ QString m_sessionId;\r
+ QString m_errorString;\r
+};\r
+\r
+} // namespace AniDBUdpClient\r
+\r
+#endif // AUTHCOMMAND_H\r
m_host = "api.anidb.info";
m_hostPort = 9000;
- authCommand = new AuthCommand(this);
- QObject::connect(authCommand, SIGNAL(replyReady(bool)), this, SLOT(doAuthenticate(bool)));
-
- logoutCommand = new LogoutCommand(this);
- uptimeCommand = new UptimeCommand(this);
-
setFloodInterval(3);
stateMachine = new QStateMachine(this);
foreach (CommandData *cmd, sentCommands)
{
- if (!cmd->command->waitForResult())
+ if (!cmd->command->command().waitForResult())
{
// Send CLIENT_DESTROYED to indicate that no real reply will come.
- cmd->command->setRawReply(CLIENT_DESTROYED, "", this);
+ cmd->command->setRawReply(CLIENT_DESTROYED, "");
}
}
while (commandTimer->isActive())
QCoreApplication::processEvents();
- sendCommand(new LogoutCommand, true);
+ sendCommand(createReply(LogoutCommand()), true);
socket->waitForBytesWritten(5);
}
QString Client::user() const
{
- return m_user;
+ return authCommand.user();
}
void Client::setUser(const QString &user)
{
- m_user = user;
+ authCommand.setUser(user);
}
QString Client::pass() const
{
- return m_pass;
+ return authCommand.pass();
}
void Client::setPass(const QString &pass)
{
- m_pass = pass;
+ authCommand.setPass(pass);
}
bool Client::compression() const
{
- return m_compression;
+ return authCommand.compression();
}
void Client::setCompression(bool compress)
{
- m_compression = compress;
+ authCommand.setCompression(compress);
}
int Client::floodInterval() const
if (m_sessionId.isEmpty())
{
- authCommand->setUser(m_user);
- authCommand->setPass(m_pass);
- authCommand->setCompression(m_compression);
-
- enqueueControlCommand(authCommand, true);
+ enqueueControlCommand(createReply(authCommand), true);
return;
}
emit authenticated();
if (success)
{
qDebug() << "success!";
- m_sessionId = authCommand->sessionId().toUtf8();
+ m_sessionId = authReply->sessionId().toUtf8();
emit authenticated();
return;
}
m_error = AuthenticationError;
- m_errorString = authCommand->errorString();
+ m_errorString = authReply->errorString();
emit connectionError();
}
idleTimer->start(UDP_API_INACTIVITY_UPDATE * 1000);
break;
case ImmediateLogoutIdlePolicy:
- enqueueControlCommand(logoutCommand);
+ enqueueControlCommand(logoutReply);
break;
default:
break;
m_sessionId = "";
break;
case KeepAliveIdlePolicy:
- enqueueControlCommand(uptimeCommand);
+ enqueueControlCommand(uptimeReply);
default:
break;
}
continue;
}
- if (m_compression && tmp.mid(0, 2) == "00")
+ if (authCommand.compression() && tmp.mid(0, 2) == "00")
{
qDebug() << "COMPRESSED DATAGRAM = " << tmp;
tmp = qUncompress(tmp);
}
CommandData *commandData = sentCommands.take(commandId);
- AbstractCommand *cmd = commandData->command;
+ AbstractReply *cmd = commandData->command;
bool controlCommand = commandData->controlCommand;
delete commandData;
// tag + space + replyCode + space = 5 + 1 + 3 + 1
reply = reply.mid(10);
- cmd->setRawReply(replyCode, reply, this);
+ cmd->setRawReply(replyCode, reply);
continueLoop:
;
}
// Delete all unsent commands that are managed by the client.
while (!controlCommandQueue.isEmpty())
{
- AbstractCommand *cmd = commandQueue.dequeue();
- if (!cmd->waitForResult())
+ AbstractReply *reply = commandQueue.dequeue();
+ if (!reply->command().waitForResult())
{
// These would be deleted anyway
- delete cmd;
+ delete reply;
}
else
{
// Send CLIENT_DESTROYED to indicate that no real reply will come.
- cmd->setRawReply(CLIENT_DESTROYED, "", this);
+ reply->setRawReply(CLIENT_DESTROYED, "");
}
}
while (!commandQueue.isEmpty())
{
- AbstractCommand *cmd = commandQueue.dequeue();
- if (!cmd->waitForResult())
+ AbstractReply *reply = commandQueue.dequeue();
+ if (!reply->command().waitForResult())
{
// These would be deleted anyway
- delete cmd;
+ delete reply;
}
else
{
// Send CLIENT_DESTROYED to indicate that no real reply will come.
- cmd->setRawReply(CLIENT_DESTROYED, "", this);
+ reply->setRawReply(CLIENT_DESTROYED, "");
}
}
}
emit startDisconnecting();
}
-void Client::send(AbstractCommand *command)
+void Client::send(AbstractReply *command)
{
connect();
void Client::sendRaw(QByteArray command)
{
qDebug() << QString("Sending RAW command: %1").arg(command.constData());
- enqueueCommand(new RawCommand(command));
+ enqueueCommand(createReply(RawCommand(command)));
}
-void Client::cancel(AbstractCommand *command)
+void Client::cancel(AbstractReply *reply)
{
- commandQueue.removeAll(command);
+ commandQueue.removeAll(reply);
+ sentCommands.remove(reply->id());
}
void Client::logout()
{
if (!m_sessionId.isEmpty())
- enqueueControlCommand(logoutCommand);
+ enqueueControlCommand(logoutReply);
}
void Client::commandTimeout(const QByteArray &commandId)
emit sendFailed();
}
-void Client::enqueueCommand(AbstractCommand *command, bool first)
+void Client::enqueueCommand(AbstractReply *command, bool first)
{
if (first)
{
emit startSending();
}
-void Client::enqueueControlCommand(AbstractCommand *command, bool first)
+void Client::enqueueControlCommand(AbstractReply *command, bool first)
{
if (first)
{
emit startSending();
}
-void Client::sendCommand(AbstractCommand *command, bool controlCommand)
+void Client::sendCommand(AbstractReply *command, bool controlCommand)
{
- if (m_sessionId.isEmpty() && command->requiresSession())
+ if (m_sessionId.isEmpty() && command->command().requiresSession())
{
if (controlCommand)
enqueueControlCommand(command, true);
return;
}
- Command cmdPair = command->rawCommand();
+ Command cmdPair = command->command().rawCommand();
QByteArray datagram = buildCmd(cmdPair.first, cmdPair.second);
- QByteArray commandId = nextCommandId();
+ QByteArray commandId = command->id();
datagram += datagram.contains(" ") ? "&" : " ";
datagram += "tag=" + commandId;
void Client::removeDeletedFromQueue()
{
- AbstractCommand *cmd = (AbstractCommand *) sender();
+ AbstractReply *cmd = (AbstractReply *) sender();
cancel(cmd);
}
Client *Client::m_instance = 0;
-CommandData::CommandData(AbstractCommand *command, const QByteArray &commandId, bool controlCommand) : QObject()
+CommandData::CommandData(AbstractReply *command, const QByteArray &commandId, bool controlCommand) : QObject()
{
this->command = command;
this->controlCommand = controlCommand;
namespace AniDBUdpClient {
class AbstractCommand;
-class AuthCommand;
-class LogoutCommand;
-class UptimeCommand;
+class LogoutReply;
+class UptimeReply;
class CommandData;
class ANIDBUDPCLIENTSHARED_EXPORT Client : public QObject
{
friend class CommandData;
+ friend class AbstractReply;
Q_OBJECT
- Q_ENUMS(AniDBUdpClient::State AniDBUdpClient::Error AniDBUdpClient::IdlePolicy AniDBUdpClientReplyCode);
+ Q_ENUMS(AniDBUdpClient::State AniDBUdpClient::Error AniDBUdpClient::IdlePolicy AniDBUdpClient::ReplyCode);
Q_PROPERTY(QString host READ host WRITE setHost);
Q_PROPERTY(quint16 hostPort READ hostPort WRITE setHostPort);
*/
void disconnect(bool graceful = false);
- void send(AbstractCommand *command);
+public:
+ template<typename T> typename T::ReplyType *send(const T &command, QObject *parent = 0)
+ {
+ typename T::ReplyType *reply = createReply(command, parent);
+ send(reply);
+ return reply;
+ }
+
+private:
+ template<typename T> typename T::ReplyType *createReply(const T &command, QObject *parent = 0)
+ {
+ return new T::ReplyType(command, nextCommandId(), this, parent);
+ }
+public slots:
+
+ void send(AbstractReply *reply);
+
void sendRaw(QByteArray command);
- void cancel(AbstractCommand *command);
+ void cancel(AbstractReply *command);
signals:
void removeDeletedFromQueue();
private:
- void enqueueCommand(AbstractCommand *command, bool first = false);
- void enqueueControlCommand(AbstractCommand *command, bool first = false);
- void sendCommand(AbstractCommand *command, bool controlCommand = false);
+ void enqueueCommand(AbstractReply *command, bool first = false);
+ void enqueueControlCommand(AbstractReply *command, bool first = false);
+ void sendCommand(AbstractReply *command, bool controlCommand = false);
QByteArray buildCmd(const QString &cmd, const QVariantMap &args);
QTimer *idleTimer;
QTimer *replyTimeoutTimer;
- QQueue<AbstractCommand *> commandQueue;
- QQueue<AbstractCommand *> controlCommandQueue;
+ QQueue<AbstractReply *> commandQueue;
+ QQueue<AbstractReply *> controlCommandQueue;
QMap<QByteArray, CommandData *> sentCommands;
QUdpSocket *socket;
int m_floodInterval;
- // Auth params
- QString m_user;
- QString m_pass;
-
- bool m_compression;
-
QByteArray m_sessionId;
// Misc params
int commandsTimedOut;
- AuthCommand *authCommand;
- LogoutCommand *logoutCommand;
- UptimeCommand *uptimeCommand;
+ AuthCommand authCommand;
+ AuthReply *authReply;
+ LogoutReply *logoutReply;
+ UptimeReply *uptimeReply;
static Client *m_instance;
Q_OBJECT
public:
- AbstractCommand *command;
+ AbstractReply *command;
bool controlCommand;
QByteArray commandId;
QTimer timer;
- CommandData(AbstractCommand *command, const QByteArray &commandId, bool controlCommand = false);
+ CommandData(AbstractReply *command, const QByteArray &commandId, bool controlCommand = false);
signals:
void timeout(QByteArray commandId);
private slots:
File::~File()
{
- if (fileCommand)
+ if (fileReply)
{
- delete fileCommand;
- fileCommand = 0;
+ delete fileReply;
+ fileReply = 0;
}
- if (addCommand)
+ if (addReply)
{
- delete addCommand;
- addCommand = 0;
+ delete addReply;
+ addReply = 0;
}
if (hashResult)
{
return;
}
- QString name = fileCommand->value(FileAnimeFlag::RomajiName).toString();
+ QString name = fileReply->value(FileAnimeFlag::RomajiName).toString();
if (name.isEmpty())
- name = fileCommand->value(FileAnimeFlag::EnglishName).toString();
+ name = fileReply->value(FileAnimeFlag::EnglishName).toString();
QString newFileName = tr("%1 - %2 - %3 - [%4](%5).%6")
.arg(name)
- .arg(fileCommand->value(FileAnimeFlag::EpNo).toString())
- .arg(fileCommand->value(FileAnimeFlag::EpName).toString())
- .arg(fileCommand->value(FileAnimeFlag::GroupShortName).toString())
- .arg(fileCommand->value(FileFlag::Crc32).toString())
- .arg(fileCommand->value(FileFlag::FileType).toString());
+ .arg(fileReply->value(FileAnimeFlag::EpNo).toString())
+ .arg(fileReply->value(FileAnimeFlag::EpName).toString())
+ .arg(fileReply->value(FileAnimeFlag::GroupShortName).toString())
+ .arg(fileReply->value(FileFlag::Crc32).toString())
+ .arg(fileReply->value(FileFlag::FileType).toString());
newFileName.replace('"', "'");
newFileName.replace(QRegExp("[\\/]"), "-");
return;
}
- if (fileCommand)
- delete fileCommand;
-
- fileCommand = new FileCommand(m_ed2k,
- size(),
- FileFlag::Crc32
- | FileFlag::FileType
- | FileFlag::Lid,
- FileAnimeFlag::EnglishName
- | FileAnimeFlag::RomajiName
- | FileAnimeFlag::KanjiName
- | FileAnimeFlag::EpNo
- | FileAnimeFlag::EpName
- | FileAnimeFlag::GroupShortName,
- this);
-
- connect(fileCommand, SIGNAL(replyReady(bool)), this, SLOT(finishRenaming(bool)));
- Client::instance()->send(fileCommand);
+ if (fileReply)
+ delete fileReply;
+
+ FileCommand fileCommand(m_ed2k,
+ size(),
+ FileFlag::Crc32
+ | FileFlag::FileType
+ | FileFlag::Lid,
+ FileAnimeFlag::EnglishName
+ | FileAnimeFlag::RomajiName
+ | FileAnimeFlag::KanjiName
+ | FileAnimeFlag::EpNo
+ | FileAnimeFlag::EpName
+ | FileAnimeFlag::GroupShortName);
+ fileReply = Client::instance()->send(fileCommand);
+ connect(fileReply, SIGNAL(replyReady(bool)), this, SLOT(finishRenaming(bool)));
+
updateStatus(Renaming, InProgress);
}
return;
}
- if (addCommand)
- delete addCommand;
+ if (addReply)
+ delete addReply;
+
+ MyListAddCommand addCommand(m_ed2k, size(), false);
+ addCommand.setState(StateOnHdd);
+
+ addReply = Client::instance()->send(addCommand);
- addCommand = new MyListAddCommand(m_ed2k, size(), false);
- addCommand->setState(StateOnHdd);
+ connect(addReply, SIGNAL(replyReady(bool)), this, SLOT(finishAdding(bool)));
- connect(addCommand, SIGNAL(replyReady(bool)), this, SLOT(finishAdding(bool)));
- Client::instance()->send(addCommand);
updateStatus(Adding, InProgress);
}
void File::init()
{
hashResult = 0;
- fileCommand = 0;
- addCommand = 0;
+ fileReply = 0;
+ addReply = 0;
m_hashingState = m_renamingState = m_addingState = m_markingState = NotStarted;
notWorking = true;
ActionState m_markingState;
HashResult *hashResult;
- FileCommand *fileCommand;
- MyListAddCommand *addCommand;
+ FileReply *fileReply;
+ MyListAddReply *addReply;
};
namespace AniDBUdpClient {
-FileCommand::FileCommand(QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand() : AbstractCommand()
{
init();
}
-FileCommand::FileCommand(int fid, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(int fid, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_fid = fid;
m_amask = amask;
}
-FileCommand::FileCommand(const QByteArray &ed2k, qint64 size, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(const QByteArray &ed2k, qint64 size, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_ed2k = ed2k;
m_amask = amask;
}
-FileCommand::FileCommand(const QString &aname, const QString &gname, int epno, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(const QString &aname, const QString &gname, int epno, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_aname = aname;
m_amask = amask;
}
-FileCommand::FileCommand(const QString &aname, int gid, int epno, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(const QString &aname, int gid, int epno, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_aname = aname;
m_amask = amask;
}
-FileCommand::FileCommand(int aid, const QString &gname, int epno, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(int aid, const QString &gname, int epno, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_aid = aid;
m_amask = amask;
}
-FileCommand::FileCommand(int aid, int gid, int epno, FileFlags fmask, FileAnimeFlags amask, QObject *parent) : AbstractCommand(parent)
+FileCommand::FileCommand(int aid, int gid, int epno, FileFlags fmask, FileAnimeFlags amask) : AbstractCommand()
{
init();
m_aid = aid;
m_amask = amask;
}
-QVariant FileCommand::value(FileFlags f) const
-{
- return fileFlagData.value(f);
-}
-
-QVariant FileCommand::value(FileAnimeFlags f) const
-{
- return fileAnimeFlagData.value(f);
-}
-
bool FileCommand::waitForResult() const
{
return true;
return cmd;
}
+void FileCommand::init()
+{
+ m_fid = 0;
+ m_aid = 0;
+ m_gid = 0;
+
+ m_size = 0;
+ m_epno = 0;
+
+ m_fmask = FileFlags(0);
+ m_amask = AnimeFlags(0);
+}
+
+// ===
-void FileCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
+int FileReply::fid() const
{
- AbstractCommand::setRawReply(replyCode, reply, client);
+ return m_fid;
+}
+
+QVariant FileReply::value(FileFlags f) const
+{
+ return fileFlagData.value(f);
+}
+
+QVariant FileReply::value(FileAnimeFlags f) const
+{
+ return fileAnimeFlagData.value(f);
+}
+
+void FileReply::setRawReply(ReplyCode replyCode, const QString &reply)
+{
+ AbstractReply::setRawReply(replyCode, reply);
switch (replyCode)
{
}
}
-void FileCommand::readReplyData(const QString &reply)
+void FileReply::readReplyData(const QString &reply)
{
QString d = reply.mid(reply.indexOf('\n')).trimmed();
qDebug() << d;
qDebug() << parts;
m_fid = parts[0].toInt();
- if (m_fmask == 0 && m_amask == 0)
+ if (command().fmask() == 0 && command().amask() == 0)
{
fileFlagData.insert(FileFlag::Aid, parts[1].toInt());
fileFlagData.insert(FileFlag::Eid, parts[2].toInt());
int partNo = 1;
for (int i = 0, flag = 1 << 31; i < 32; ++i, flag = (flag >> 1) & ~(1 << 31))
{
- if (m_fmask & flag)
+ if (command().fmask() & flag)
{
if (partNo >= parts.size())
{
for (int i = 0, flag = 1 << 31; i < 32; ++i, flag = (flag >> 1) & ~(1 << 31))
{
- if (m_amask & flag)
+ if (command().amask() & flag)
{
if (partNo >= parts.size())
{
}
}
-void FileCommand::init()
+void FileReply::init()
{
m_fid = 0;
- m_aid = 0;
- m_gid = 0;
-
- m_size = 0;
- m_epno = 0;
-
- m_fmask = FileFlags(0);
- m_amask = AnimeFlags(0);
}
} // namespace AniDBUdpClient
-#ifndef FILECOMMAND_H
-#define FILECOMMAND_H
-
-#include "anidbudpclient_global.h"
-#include "abstractcommand.h"
-
-#include <QVariant>
-
-namespace AniDBUdpClient {
-
-class ANIDBUDPCLIENTSHARED_EXPORT FileCommand : public AbstractCommand
-{
- Q_OBJECT
-
- Q_PROPERTY(int fid READ fid WRITE setFid);
-
- Q_PROPERTY(QByteArray ed2k READ ed2k WRITE setEd2k);
- Q_PROPERTY(qint64 size READ size WRITE setSize);
-
- Q_PROPERTY(QString aname READ aname WRITE setAname);
- Q_PROPERTY(int aid READ aid WRITE setAid);
- Q_PROPERTY(QString gname READ gname WRITE setGname);
- Q_PROPERTY(int gid READ gid WRITE setGid);
- Q_PROPERTY(int epno READ epno WRITE setEpno);
-
- Q_PROPERTY(FileFlags fmask READ fmask WRITE setFmask);
- Q_PROPERTY(FileAnimeFlags amask READ amask WRITE setAmask);
-
-public:
- FileCommand(QObject *parent = 0);
- FileCommand(int fid, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
- FileCommand(const QByteArray &ed2k, qint64 size, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
- FileCommand(const QString &aname, const QString &gname, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
- FileCommand(const QString &aname, int gid, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
- FileCommand(int aid, const QString &gname, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
- FileCommand(int aid, int gid, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0), QObject *parent = 0);
-
- int fid() const;
- void setFid(int fid);
-
- QByteArray ed2k() const;
- void setEd2k(const QByteArray &ed2k);
- qint64 size() const;
- void setSize(qint64 size);
-
- QString aname() const;
- void setAname(const QString &aname);
- int aid() const;
- void setAid(int aid);
- QString gname() const;
- void setGname(const QString &gname);
- int gid() const;
- void setGid(int gid);
- int epno() const;
- void setEpno(int epno);
-
- FileFlags fmask() const;
- void setFmask(FileFlags fmask);
- FileAnimeFlags amask() const;
- void setAmask(FileAnimeFlags amask);
-
-
- QVariant value(FileFlags f) const;
- QVariant value(FileAnimeFlags f) const;
-
-
- bool waitForResult() const;
- Command rawCommand() const;
- void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
-
-
-private:
- void readReplyData(const QString &reply);
- void init();
-
- int m_fid;
-
- QByteArray m_ed2k;
- qint64 m_size;
-
- QString m_aname;
- int m_aid;
- QString m_gname;
- int m_gid;
- int m_epno;
-
- FileFlags m_fmask;
- FileAnimeFlags m_amask;
-
- QMap<FileFlags, QVariant> fileFlagData;
- QMap<FileAnimeFlags, QVariant> fileAnimeFlagData;
-};
-
-} // namespace AniDBUdpClient
-
-#include <QScriptEngine>
-Q_SCRIPT_DECLARE_QMETAOBJECT(AniDBUdpClient::FileCommand, QObject*);
-
-#endif // FILECOMMAND_H
+#ifndef FILECOMMAND_H\r
+#define FILECOMMAND_H\r
+\r
+#include "anidbudpclient_global.h"\r
+#include "abstractcommand.h"\r
+\r
+#include <QVariant>\r
+\r
+namespace AniDBUdpClient {\r
+\r
+class FileReply;\r
+\r
+class ANIDBUDPCLIENTSHARED_EXPORT FileCommand : public AbstractCommand\r
+{\r
+/*\r
+ Q_PROPERTY(int fid READ fid WRITE setFid);\r
+\r
+ Q_PROPERTY(QByteArray ed2k READ ed2k WRITE setEd2k);\r
+ Q_PROPERTY(qint64 size READ size WRITE setSize);\r
+\r
+ Q_PROPERTY(QString aname READ aname WRITE setAname);\r
+ Q_PROPERTY(int aid READ aid WRITE setAid);\r
+ Q_PROPERTY(QString gname READ gname WRITE setGname);\r
+ Q_PROPERTY(int gid READ gid WRITE setGid);\r
+ Q_PROPERTY(int epno READ epno WRITE setEpno);\r
+\r
+ Q_PROPERTY(FileFlags fmask READ fmask WRITE setFmask);\r
+ Q_PROPERTY(FileAnimeFlags amask READ amask WRITE setAmask);\r
+*/\r
+public:\r
+ typedef FileReply ReplyType;\r
+ FileCommand();\r
+ FileCommand(int fid, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+ FileCommand(const QByteArray &ed2k, qint64 size, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+ FileCommand(const QString &aname, const QString &gname, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+ FileCommand(const QString &aname, int gid, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+ FileCommand(int aid, const QString &gname, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+ FileCommand(int aid, int gid, int epno, FileFlags fmask = FileFlags(0), FileAnimeFlags = FileAnimeFlags(0));\r
+\r
+ int fid() const;\r
+ void setFid(int fid);\r
+\r
+ QByteArray ed2k() const;\r
+ void setEd2k(const QByteArray &ed2k);\r
+ qint64 size() const;\r
+ void setSize(qint64 size);\r
+\r
+ QString aname() const;\r
+ void setAname(const QString &aname);\r
+ int aid() const;\r
+ void setAid(int aid);\r
+ QString gname() const;\r
+ void setGname(const QString &gname);\r
+ int gid() const;\r
+ void setGid(int gid);\r
+ int epno() const;\r
+ void setEpno(int epno);\r
+\r
+ FileFlags fmask() const;\r
+ void setFmask(FileFlags fmask);\r
+ FileAnimeFlags amask() const;\r
+ void setAmask(FileAnimeFlags amask);\r
+\r
+ bool waitForResult() const;\r
+ Command rawCommand() const;\r
+\r
+private:\r
+ void init();\r
+\r
+ int m_fid;\r
+\r
+ QByteArray m_ed2k;\r
+ qint64 m_size;\r
+\r
+ QString m_aname;\r
+ int m_aid;\r
+ QString m_gname;\r
+ int m_gid;\r
+ int m_epno;\r
+\r
+ FileFlags m_fmask;\r
+ FileAnimeFlags m_amask;\r
+};\r
+\r
+class ANIDBUDPCLIENTSHARED_EXPORT FileReply : public AbstractReply\r
+{\r
+ Q_OBJECT\r
+ REPLY_DEFINITION_HELPER2(File)\r
+\r
+ Q_PROPERTY(int fid READ fid);\r
+\r
+public:\r
+ int fid() const;\r
+\r
+ QVariant value(FileFlags f) const;\r
+ QVariant value(FileAnimeFlags f) const;\r
+\r
+ void setRawReply(ReplyCode replyCode, const QString &reply);\r
+\r
+private:\r
+ void readReplyData(const QString &reply);\r
+ void init();\r
+\r
+ int m_fid;\r
+\r
+ QMap<FileFlags, QVariant> fileFlagData;\r
+ QMap<FileAnimeFlags, QVariant> fileAnimeFlagData;\r
+};\r
+\r
+} // namespace AniDBUdpClient\r
+\r
+#endif // FILECOMMAND_H\r
static Hash *m_instance;
};
-class HashRequest
+class ANIDBUDPCLIENTSHARED_EXPORT HashRequest
{
public:
HashRequest(const QFileInfo &fileInfo = QFileInfo());
QFileInfo m_fileInfo;
};
-class HashResult : public QObject
+class ANIDBUDPCLIENTSHARED_EXPORT HashResult : public QObject
{
friend class Hash;
namespace AniDBUdpClient {
-LogoutCommand::LogoutCommand(QObject *parent) : AbstractCommand(parent)
+LogoutCommand::LogoutCommand() : AbstractCommand()
{
}
namespace AniDBUdpClient {
+class LogoutReply;
+
class ANIDBUDPCLIENTSHARED_EXPORT LogoutCommand : public AbstractCommand
{
- Q_OBJECT
public:
- LogoutCommand(QObject *parent = 0);
+ typedef LogoutReply ReplyType;
+
+ LogoutCommand();
Command rawCommand() const;
};
+class ANIDBUDPCLIENTSHARED_EXPORT LogoutReply : public AbstractReply
+{
+ Q_OBJECT
+ REPLY_DEFINITION_HELPER(Logout)
+public:
+};
+
} // namespace AniDBUdpClient
#endif // LOGOUTCOMMAND_H
namespace AniDBUdpClient {
-MyListAddCommand::MyListAddCommand(int fid, bool edit, QObject *parent) : AbstractCommand(parent)
+MyListAddCommand::MyListAddCommand(int fid, bool edit) : AbstractCommand()
{
init();
m_fid = fid;
m_edit = edit;
}
-MyListAddCommand::MyListAddCommand(const QByteArray &ed2k, qint64 size, bool edit, QObject *parent) : AbstractCommand(parent)
+MyListAddCommand::MyListAddCommand(const QByteArray &ed2k, qint64 size, bool edit) : AbstractCommand()
{
init();
m_ed2k = ed2k;
m_edit = edit;
}
-MyListAddCommand::MyListAddCommand(int lid, QObject *parent) : AbstractCommand(parent)
+MyListAddCommand::MyListAddCommand(int lid) : AbstractCommand()
{
init();
m_lid = lid;
return cmd;
}
-void MyListAddCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
+void MyListAddCommand::init()
+{
+ m_fid = 0;
+ m_lid = 0;
+
+ m_state = StateUnknown;
+ m_viewed = Unset;
+}
+
+// ===
+
+int MyListAddReply::lid() const
+{
+ return m_lid;
+}
+
+void MyListAddReply::setRawReply(ReplyCode replyCode, const QString &reply)
{
- AbstractCommand::setRawReply(replyCode, reply, client);
+ AbstractReply::setRawReply(replyCode, reply);
switch (replyCode)
{
case MYLIST_ENTRY_ADDED:
{
QString lid = reply.mid(reply.indexOf('\n')).trimmed();
- if (!m_edit)
+ if (!command().edit())
{
m_lid = lid.toInt();
}
}
}
-
-void MyListAddCommand::init()
+void MyListAddReply::init()
{
- m_fid = 0;
m_lid = 0;
-
- m_state = StateUnknown;
- m_viewed = Unset;
-}
-
-
-// ===================================================================================
-
-
-MylistAddCommand::MylistAddCommand(QString file, QObject *parent) : AbstractCommand(parent)
-{
- m_file = file;
- m_size = QFileInfo(file).size();
- mylistId = 0;
-
- connect(&futureWatcher, SIGNAL(finished()), this, SLOT(completeHash()));
-}
-
-QString MylistAddCommand::file() const
-{
- return m_file;
-}
-
-QByteArray MylistAddCommand::ed2kHash() const
-{
- return m_ed2k;
-}
-
-qint64 MylistAddCommand::fileSize() const
-{
- return m_size;
-}
-
-bool MylistAddCommand::markWatched() const
-{
- return m_markWatched;
-}
-
-void MylistAddCommand::setMarkWatched(bool mark)
-{
- m_markWatched = mark;
-}
-
-bool MylistAddCommand::waitForResult() const
-{
- return true;
-}
-
-Command MylistAddCommand::rawCommand() const
-{
- Command command;
- switch (mylistId)
- {
- case 0:
- command.first = "MYLIST";
- command.second["size"] = m_size;
- command.second["ed2k"] = m_ed2k.constData();
- return command;
- break;
- case -1:
- command.first = "MYLISTADD";
- command.second["size"] = m_size;
- command.second["ed2k"] = m_ed2k.constData();
- command.second["state"] = 1;
- command.second["viewed"] = m_markWatched;
- return command;
- break;
- default:
- command.first = "MYLISTADD";
- command.second["lid"] = mylistId;
- command.second["viewed"] = m_markWatched;
- command.second["edit"] = 1;
- return command;
- break;
- }
-}
-
-void MylistAddCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
-{
- AbstractCommand::setRawReply(replyCode, reply, client);
-
- switch (mylistId)
- {
- case 0:
- switch(replyCode)
- {
- case MYLIST:
- {
- QString reply = m_rawReply.mid(m_rawReply.indexOf("\n"));
- QStringList parts = reply.split('|', QString::KeepEmptyParts);
-qDebug() << "PARTS" << parts;
- mylistId = parts[0].toInt();
-qDebug() << "Mylist ID: " << mylistId;
- if (!mylistId)
- {
-qDebug() << "FAILED to read Mylist ID";
- emit replyReady(false);
- }
- client->send(this);
- }
- break;
- default:
- mylistId = -1;
- client->send(this);
- break;
- }
- break;
- default:
- switch(replyCode)
- {
- case MYLIST_ENTRY_ADDED:
- case MYLIST_ENTRY_EDITED:
- case FILE_ALREADY_IN_MYLIST:
- emit replyReady(true);
- break;
- default:
- emit replyReady(false);
- break;
- }
- break;
- }
-}
-
-void MylistAddCommand::hash()
-{
- t.start();
- future = QtConcurrent::run(this, &MylistAddCommand::doHash, m_file);
- futureWatcher.setFuture(future);
-}
-
-void MylistAddCommand::completeHash()
-{
- if (!future.isFinished())
- {
-qDebug() << "WTF?";
- return;
- }
- m_ed2k = QByteArray(future);
- emit hashComplete();
- qDebug() << "Time:" << t.elapsed();
-}
-
-QByteArray MylistAddCommand::doHash(QString file)
-{
-qDebug() << "hash thread init";
- QThread::currentThread()->setPriority(QThread::LowPriority);
-
- QFile f(file);
- if (!f.open(QIODevice::ReadOnly))
- return QByteArray();
-
- QCryptographicHash ed2k(QCryptographicHash::Md4);
- char *data = new char[ED2K_PART_SIZE];
- int size;
- while (!f.atEnd())
- {
- size = f.read(data, ED2K_PART_SIZE);
- ed2k.addData(QCryptographicHash::hash(QByteArray(data, size), QCryptographicHash::Md4));
-//qDebug() << "hashing...";
- }
- f.close();
- delete[] data;
-qDebug() << "hashing... complete!";
- return ed2k.result().toHex();
}
} // namespace AniDBUdpClient
namespace AniDBUdpClient {
+class MyListAddReply;
+
class ANIDBUDPCLIENTSHARED_EXPORT MyListAddCommand : public AbstractCommand
{
+/*
Q_ENUMS(ViewedState);
- Q_OBJECT
-
Q_PROPERTY(int fid READ fid WRITE setFid);
Q_PROPERTY(int lid READ lid WRITE setLid);
Q_PROPERTY(QString source READ source WRITE setSource);
Q_PROPERTY(QString storage READ storage WRITE setStorage);
Q_PROPERTY(QString other READ other WRITE setOther);
-
+*/
public:
-
+ typedef MyListAddReply ReplyType;
enum ViewedState {
Unset = -1,
NotViewed = 0,
Viewed = 1,
};
- MyListAddCommand(int fid, bool edit, QObject *parent = 0);
- MyListAddCommand(const QByteArray &ed2k, qint64 size, bool edit, QObject *parent = 0);
- explicit MyListAddCommand(int lid, QObject *parent = 0);
+ MyListAddCommand(int fid, bool edit);
+ MyListAddCommand(const QByteArray &ed2k, qint64 size, bool edit);
+ explicit MyListAddCommand(int lid);
int fid() const;
void setFid(int fid);
QString other() const;
void setOther(QString other);
-
bool waitForResult() const;
Command rawCommand() const;
- void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
-
private:
void init();
QString m_other;
};
-class ANIDBUDPCLIENTSHARED_EXPORT MylistAddCommand : public AbstractCommand
+class ANIDBUDPCLIENTSHARED_EXPORT MyListAddReply : public AbstractReply
{
Q_OBJECT
+ REPLY_DEFINITION_HELPER2(MyListAdd)
-public:
- MylistAddCommand(QString file, QObject *parent = 0);
-
- QString file() const;
- QByteArray ed2kHash() const;
- qint64 fileSize() const;
-
- bool markWatched() const;
- void setMarkWatched(bool mark);
-
+ Q_PROPERTY(int lid READ lid);
- bool waitForResult() const;
-
- Command rawCommand() const;
-
- void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
-
- void hash();
-
-signals:
- void hashComplete();
+public:
+ int lid() const;
-private slots:
- void completeHash();
+ void setRawReply(ReplyCode replyCode, const QString &reply);
private:
- QByteArray doHash(QString file);
- QFuture<QByteArray> future;
- QFutureWatcher<QByteArray> futureWatcher;
-
- bool m_markWatched;
-
- qint64 m_size;
- QByteArray m_ed2k;
- QString m_file;
-
- int mylistId;
-
- static const qint64 ED2K_PART_SIZE = 9728000;
+ void init();
- QTime t;
+ int m_lid;
};
} // namespace AniDBUdpClient
-#include "mylistcommand.h"
-
-#include <QStringList>
-
-namespace AniDBUdpClient {
-
-MyListCommand::MyListCommand(QObject *parent) : AbstractCommand(parent)
-{
- init();
-}
-
-MyListCommand::MyListCommand(int lid, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_lid = lid;
-}
-
-MyListCommand::MyListCommand(int fid, bool isFid, QObject *parent) : AbstractCommand(parent)
-{
- Q_UNUSED(isFid);
- init();
- m_fid = fid;
-}
-
-MyListCommand::MyListCommand(const QByteArray &ed2k, qint64 size, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_ed2k = ed2k;
- m_size = size;
-}
-
-MyListCommand::MyListCommand(const QString &aname, const QString &gname, int epno, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_aname = aname;
- m_gname = gname;
- m_epno = epno;
-}
-
-MyListCommand::MyListCommand(const QString &aname, int gid, int epno, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_aname = aname;
- m_gid = gid;
- m_epno = epno;
-}
-
-MyListCommand::MyListCommand(int aid, const QString &gname, int epno, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_aid = aid;
- m_gname = gname;
- m_epno = epno;
-}
-
-MyListCommand::MyListCommand(int aid, int gid, int epno, QObject *parent) : AbstractCommand(parent)
-{
- init();
- m_aid = aid;
- m_gid = gid;
- m_epno = epno;
-}
-
-int MyListCommand::lid() const
-{
- return m_lid;
-}
-
-void MyListCommand::setLid(int lid)
-{
- m_lid = lid;
-}
-
-int MyListCommand::fid() const
-{
- return m_fid;
-}
-
-void MyListCommand::setFid(int fid)
-{
- m_fid = fid;
-}
-
-QByteArray MyListCommand::ed2k() const
-{
- return m_ed2k;
-}
-
-void MyListCommand::setEd2k(const QByteArray &ed2k)
-{
- m_ed2k = ed2k;
-}
-
-qint64 MyListCommand::size() const
-{
- return m_size;
-}
-
-void MyListCommand::setSize(qint64 size)
-{
- m_size = size;
-}
-
-QString MyListCommand::aname() const
-{
- return m_aname;
-}
-
-void MyListCommand::setAname(const QString &aname)
-{
- m_aname = aname;
-}
-
-int MyListCommand::aid() const
-{
- return m_aid;
-}
-
-void MyListCommand::setAid(int aid)
-{
- m_aid = aid;
-}
-
-QString MyListCommand::gname() const
-{
- return m_gname;
-}
-
-void MyListCommand::setGname(const QString &gname)
-{
- m_gname = gname;
-}
-
-int MyListCommand::gid() const
-{
- return m_gid;
-}
-
-void MyListCommand::setGid(int gid)
-{
- m_gid = gid;
-}
-
-
-int MyListCommand::epno() const
-{
- return m_epno;
-}
-
-void MyListCommand::setEpno(int epno)
-{
- m_epno = epno;
-}
-
-bool MyListCommand::isValid() const
-{
- return m_lid || m_fid || m_aid
- || !m_aname.isEmpty()
- || (!m_ed2k.isEmpty() && m_size);
-}
-
-int MyListCommand::eid() const
-{
- return m_eid;
-}
-
-QDateTime MyListCommand::date() const
-{
- return m_date;
-}
-
-State MyListCommand::state() const
-{
- return m_state;
-}
-
-QDateTime MyListCommand::viewDate() const
-{
- return m_viewDate;
-}
-
-QString MyListCommand::storage() const
-{
- return m_storage;
-}
-
-QString MyListCommand::source() const
-{
- return m_source;
-}
-
-QString MyListCommand::other() const
-{
- return m_other;
-}
-
-FileState MyListCommand::fileState() const
-{
- return m_fileState;
-}
-
-QStringList MyListCommand::multipleEntries() const
-{
- return m_multipleEntries;
-}
-
-bool MyListCommand::waitForResult() const
-{
- return true;
-}
-
-Command MyListCommand::rawCommand() const
-{
- Command cmd;
-
- cmd.first = "MYLIST";
-
- if (m_lid)
- {
- cmd.second["lid"] = m_lid;
- }
- else if (m_fid)
- {
- cmd.second["fid"] = m_fid;
- }
- else if (!m_ed2k.isEmpty() && m_size)
- {
- cmd.second["ed2k"] = m_ed2k;
- cmd.second["size"] = m_size;
- }
- else if (!m_aname.isEmpty())
- {
- cmd.second["aname"] = m_aname;
- if (!m_gname.isEmpty() && m_epno)
- {
- cmd.second["gname"] = m_gname;
- cmd.second["epno"] = m_epno;
- }
- else if (m_gid && m_epno)
- {
- cmd.second["gid"] = m_gid;
- cmd.second["epno"] = m_epno;
- }
- }
- else if (m_aid)
- {
- cmd.second["aid"] = m_aid;
- if (!m_gname.isEmpty() && m_epno)
- {
- cmd.second["gname"] = m_gname;
- cmd.second["epno"] = m_epno;
- }
- else if (m_gid && m_epno)
- {
- cmd.second["gid"] = m_gid;
- cmd.second["epno"] = m_epno;
- }
- }
- else
- {
- // TODO WTF NOW?!?
- }
- return cmd;
-}
-
-void MyListCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
-{
- AbstractCommand::setRawReply(replyCode, reply, client);
-
- switch (replyCode)
- {
- case MYLIST:
- {
- QStringList parts = reply.mid(reply.indexOf("\n")).split('|', QString::KeepEmptyParts);
- bool ok;
- m_lid = parts[0].toInt(&ok, 10);
- m_fid = parts[1].toInt(&ok, 10);
- m_eid = parts[2].toInt(&ok, 10);
- m_aid = parts[3].toInt(&ok, 10);
- m_gid = parts[4].toInt(&ok, 10);
- m_date = QDateTime::fromTime_t(parts[5].toUInt(&ok, 10));
- m_state = State(parts[6].toInt(&ok, 10));
- m_viewDate = QDateTime::fromTime_t(parts[7].toUInt(&ok, 10));
- m_storage = parts[8];
- m_source = parts[9];
- m_other = parts[10];
- m_fileState = FileState(parts[11].toInt(&ok, 10));
- emit replyReady(true);
- }
- break;
- case MULTIPLE_MYLIST_ENTRIES:
- {
- m_multipleEntries = reply.mid(reply.indexOf("\n")).split('|', QString::KeepEmptyParts);
- emit replyReady(true);
- }
- break;
- case NO_SUCH_ENTRY:
- default:
- emit replyReady(false);
- break;
- }
-}
-
-void MyListCommand::init()
-{
- m_lid = 0;
- m_fid = 0;
- m_aid = 0;
- m_gid = 0;
- m_eid = 0;
-
- m_size = 0;
- m_epno = 0;
-
- m_state = State(0);
- m_fileState = FileState(0);
-}
-
-} // namespace AniDBUdpClient
+#include "mylistcommand.h"\r
+\r
+#include <QStringList>\r
+\r
+namespace AniDBUdpClient {\r
+\r
+MyListCommand::MyListCommand() : AbstractCommand()\r
+{\r
+ init();\r
+}\r
+\r
+MyListCommand::MyListCommand(int lid) : AbstractCommand()\r
+{\r
+ init();\r
+ m_lid = lid;\r
+}\r
+\r
+MyListCommand::MyListCommand(int fid, bool isFid) : AbstractCommand()\r
+{\r
+ Q_UNUSED(isFid);\r
+ init();\r
+ m_fid = fid;\r
+}\r
+\r
+MyListCommand::MyListCommand(const QByteArray &ed2k, qint64 size) : AbstractCommand()\r
+{\r
+ init();\r
+ m_ed2k = ed2k;\r
+ m_size = size;\r
+}\r
+\r
+MyListCommand::MyListCommand(const QString &aname, const QString &gname, int epno) : AbstractCommand()\r
+{\r
+ init();\r
+ m_aname = aname;\r
+ m_gname = gname;\r
+ m_epno = epno;\r
+}\r
+\r
+MyListCommand::MyListCommand(const QString &aname, int gid, int epno) : AbstractCommand()\r
+{\r
+ init();\r
+ m_aname = aname;\r
+ m_gid = gid;\r
+ m_epno = epno;\r
+}\r
+\r
+MyListCommand::MyListCommand(int aid, const QString &gname, int epno) : AbstractCommand()\r
+{\r
+ init();\r
+ m_aid = aid;\r
+ m_gname = gname;\r
+ m_epno = epno;\r
+}\r
+\r
+MyListCommand::MyListCommand(int aid, int gid, int epno) : AbstractCommand()\r
+{\r
+ init();\r
+ m_aid = aid;\r
+ m_gid = gid;\r
+ m_epno = epno;\r
+}\r
+\r
+int MyListCommand::lid() const\r
+{\r
+ return m_lid;\r
+}\r
+\r
+void MyListCommand::setLid(int lid)\r
+{\r
+ m_lid = lid;\r
+}\r
+\r
+int MyListCommand::fid() const\r
+{\r
+ return m_fid;\r
+}\r
+\r
+void MyListCommand::setFid(int fid)\r
+{\r
+ m_fid = fid;\r
+}\r
+\r
+QByteArray MyListCommand::ed2k() const\r
+{\r
+ return m_ed2k;\r
+}\r
+\r
+void MyListCommand::setEd2k(const QByteArray &ed2k)\r
+{\r
+ m_ed2k = ed2k;\r
+}\r
+\r
+qint64 MyListCommand::size() const\r
+{\r
+ return m_size;\r
+}\r
+\r
+void MyListCommand::setSize(qint64 size)\r
+{\r
+ m_size = size;\r
+}\r
+\r
+QString MyListCommand::aname() const\r
+{\r
+ return m_aname;\r
+}\r
+\r
+void MyListCommand::setAname(const QString &aname)\r
+{\r
+ m_aname = aname;\r
+}\r
+\r
+int MyListCommand::aid() const\r
+{\r
+ return m_aid;\r
+}\r
+\r
+void MyListCommand::setAid(int aid)\r
+{\r
+ m_aid = aid;\r
+}\r
+\r
+QString MyListCommand::gname() const\r
+{\r
+ return m_gname;\r
+}\r
+\r
+void MyListCommand::setGname(const QString &gname)\r
+{\r
+ m_gname = gname;\r
+}\r
+\r
+int MyListCommand::gid() const\r
+{\r
+ return m_gid;\r
+}\r
+\r
+void MyListCommand::setGid(int gid)\r
+{\r
+ m_gid = gid;\r
+}\r
+\r
+\r
+int MyListCommand::epno() const\r
+{\r
+ return m_epno;\r
+}\r
+\r
+void MyListCommand::setEpno(int epno)\r
+{\r
+ m_epno = epno;\r
+}\r
+\r
+bool MyListCommand::isValid() const\r
+{\r
+ return m_lid || m_fid || m_aid\r
+ || !m_aname.isEmpty()\r
+ || (!m_ed2k.isEmpty() && m_size);\r
+}\r
+\r
+bool MyListCommand::waitForResult() const\r
+{\r
+ return true;\r
+}\r
+\r
+Command MyListCommand::rawCommand() const\r
+{\r
+ Command cmd;\r
+\r
+ cmd.first = "MYLIST";\r
+\r
+ if (m_lid)\r
+ {\r
+ cmd.second["lid"] = m_lid;\r
+ }\r
+ else if (m_fid)\r
+ {\r
+ cmd.second["fid"] = m_fid;\r
+ }\r
+ else if (!m_ed2k.isEmpty() && m_size)\r
+ {\r
+ cmd.second["ed2k"] = m_ed2k;\r
+ cmd.second["size"] = m_size;\r
+ }\r
+ else if (!m_aname.isEmpty())\r
+ {\r
+ cmd.second["aname"] = m_aname;\r
+ if (!m_gname.isEmpty() && m_epno)\r
+ {\r
+ cmd.second["gname"] = m_gname;\r
+ cmd.second["epno"] = m_epno;\r
+ }\r
+ else if (m_gid && m_epno)\r
+ {\r
+ cmd.second["gid"] = m_gid;\r
+ cmd.second["epno"] = m_epno;\r
+ }\r
+ }\r
+ else if (m_aid)\r
+ {\r
+ cmd.second["aid"] = m_aid;\r
+ if (!m_gname.isEmpty() && m_epno)\r
+ {\r
+ cmd.second["gname"] = m_gname;\r
+ cmd.second["epno"] = m_epno;\r
+ }\r
+ else if (m_gid && m_epno)\r
+ {\r
+ cmd.second["gid"] = m_gid;\r
+ cmd.second["epno"] = m_epno;\r
+ }\r
+ }\r
+ else\r
+ {\r
+ // TODO WTF NOW?!?\r
+ }\r
+ return cmd;\r
+}\r
+\r
+void MyListCommand::init()\r
+{\r
+ m_lid = 0;\r
+ m_fid = 0;\r
+ m_aid = 0;\r
+ m_gid = 0;\r
+\r
+ m_size = 0;\r
+ m_epno = 0;\r
+}\r
+\r
+\r
+// ===\r
+\r
+int MyListReply::lid() const\r
+{\r
+ return m_lid;\r
+}\r
+\r
+int MyListReply::fid() const\r
+{\r
+ return m_fid;\r
+}\r
+\r
+int MyListReply::aid() const\r
+{\r
+ return m_aid;\r
+}\r
+\r
+\r
+int MyListReply::gid() const\r
+{\r
+ return m_gid;\r
+}\r
+\r
+\r
+int MyListReply::eid() const\r
+{\r
+ return m_eid;\r
+}\r
+\r
+QDateTime MyListReply::date() const\r
+{\r
+ return m_date;\r
+}\r
+\r
+State MyListReply::state() const\r
+{\r
+ return m_state;\r
+}\r
+\r
+QDateTime MyListReply::viewDate() const\r
+{\r
+ return m_viewDate;\r
+}\r
+\r
+QString MyListReply::storage() const\r
+{\r
+ return m_storage;\r
+}\r
+\r
+QString MyListReply::source() const\r
+{\r
+ return m_source;\r
+}\r
+\r
+QString MyListReply::other() const\r
+{\r
+ return m_other;\r
+}\r
+\r
+FileState MyListReply::fileState() const\r
+{\r
+ return m_fileState;\r
+}\r
+\r
+QStringList MyListReply::multipleEntries() const\r
+{\r
+ return m_multipleEntries;\r
+}\r
+\r
+void MyListReply::setRawReply(ReplyCode replyCode, const QString &reply)\r
+{\r
+ AbstractReply::setRawReply(replyCode, reply);\r
+\r
+ switch (replyCode)\r
+ {\r
+ case MYLIST:\r
+ {\r
+ QStringList parts = reply.mid(reply.indexOf("\n")).split('|', QString::KeepEmptyParts);\r
+ bool ok;\r
+ m_lid = parts[0].toInt(&ok, 10);\r
+ m_fid = parts[1].toInt(&ok, 10);\r
+ m_eid = parts[2].toInt(&ok, 10);\r
+ m_aid = parts[3].toInt(&ok, 10);\r
+ m_gid = parts[4].toInt(&ok, 10);\r
+ m_date = QDateTime::fromTime_t(parts[5].toUInt(&ok, 10));\r
+ m_state = State(parts[6].toInt(&ok, 10));\r
+ m_viewDate = QDateTime::fromTime_t(parts[7].toUInt(&ok, 10));\r
+ m_storage = parts[8];\r
+ m_source = parts[9];\r
+ m_other = parts[10];\r
+ m_fileState = FileState(parts[11].toInt(&ok, 10));\r
+ emit replyReady(true);\r
+ }\r
+ break;\r
+ case MULTIPLE_MYLIST_ENTRIES:\r
+ {\r
+ m_multipleEntries = reply.mid(reply.indexOf("\n")).split('|', QString::KeepEmptyParts);\r
+ emit replyReady(true);\r
+ }\r
+ break;\r
+ case NO_SUCH_ENTRY:\r
+ default:\r
+ emit replyReady(false);\r
+ break;\r
+ }\r
+}\r
+\r
+void MyListReply::init()\r
+{\r
+ m_lid = 0;\r
+ m_fid = 0;\r
+ m_aid = 0;\r
+ m_gid = 0;\r
+ m_eid = 0;\r
+\r
+ m_state = State(0);\r
+ m_fileState = FileState(0);\r
+}\r
+\r
+} // namespace AniDBUdpClient\r
-#ifndef MYLISTCOMMAND_H
-#define MYLISTCOMMAND_H
-
-#include "anidbudpclient_global.h"
-#include "abstractcommand.h"
-
-#include <QDateTime>
-#include <QStringList>
-
-namespace AniDBUdpClient {
-
-class ANIDBUDPCLIENTSHARED_EXPORT MyListCommand : public AbstractCommand
-{
- Q_OBJECT
-
- Q_PROPERTY(int lid READ lid WRITE setLid);
- Q_PROPERTY(int fid READ fid WRITE setFid);
-
- Q_PROPERTY(QByteArray ed2k READ ed2k WRITE setEd2k);
- Q_PROPERTY(qint64 size READ size WRITE setSize);
-
- Q_PROPERTY(QString aname READ aname WRITE setAname);
- Q_PROPERTY(int aid READ aid WRITE setAid);
- Q_PROPERTY(QString gname READ gname WRITE setGname);
- Q_PROPERTY(int gid READ gid WRITE setGid);
- Q_PROPERTY(int epno READ epno WRITE setEpno);
-
- Q_PROPERTY(bool valid READ isValid);
-
- Q_PROPERTY(int eid READ eid);
- Q_PROPERTY(QDateTime date READ date);
- Q_PROPERTY(State state READ state);
- Q_PROPERTY(QDateTime viewDate READ viewDate);
- Q_PROPERTY(QString storage READ storage);
- Q_PROPERTY(QString source READ source);
- Q_PROPERTY(QString other READ other);
- Q_PROPERTY(FileState fileState READ fileState);
-
- Q_PROPERTY(QStringList multipleEntries READ multipleEntries);
-
-public:
- MyListCommand(QObject *parent = 0);
- MyListCommand(int lid, QObject *parent = 0);
- MyListCommand(int fid, bool isFid, QObject *parent = 0);
- MyListCommand(const QByteArray &ed2k, qint64 size, QObject *parent = 0);
- MyListCommand(const QString &aname, const QString &gname, int epno, QObject *parent = 0);
- MyListCommand(const QString &aname, int gid, int epno, QObject *parent = 0);
- MyListCommand(int aid, const QString &gname, int epno, QObject *parent = 0);
- MyListCommand(int aid, int gid, int epno, QObject *parent = 0);
-
- int lid() const;
- void setLid(int lid);
- int fid() const;
- void setFid(int fid);
-
- QByteArray ed2k() const;
- void setEd2k(const QByteArray &ed2k);
- qint64 size() const;
- void setSize(qint64 size);
-
- QString aname() const;
- void setAname(const QString &aname);
- int aid() const;
- void setAid(int aid);
- QString gname() const;
- void setGname(const QString &gname);
- int gid() const;
- void setGid(int gid);
- int epno() const;
- void setEpno(int epno);
-
- bool isValid() const;
-
-
- int eid() const;
- QDateTime date() const;
- State state() const;
- QDateTime viewDate() const;
- QString storage() const;
- QString source() const;
- QString other() const;
- FileState fileState() const;
-
- QStringList multipleEntries() const;
-
- bool waitForResult() const;
- Command rawCommand() const;
- void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
-
-private:
- void init();
-
- int m_lid;
- int m_fid;
-
- QByteArray m_ed2k;
- qint64 m_size;
-
- QString m_aname;
- int m_aid;
- QString m_gname;
- int m_gid;
- int m_epno;
-
- int m_eid;
- QDateTime m_date;
- State m_state;
- QDateTime m_viewDate;
- QString m_storage;
- QString m_source;
- QString m_other;
- FileState m_fileState;
-
- QStringList m_multipleEntries;
-
-};
-
-} // namespace AniDBUdpClient
-
-#include <QScriptEngine>
-Q_SCRIPT_DECLARE_QMETAOBJECT(AniDBUdpClient::MyListCommand, QObject*);
-
-#endif // MYLISTCOMMAND_H
+#ifndef MYLISTCOMMAND_H\r
+#define MYLISTCOMMAND_H\r
+\r
+#include "anidbudpclient_global.h"\r
+#include "abstractcommand.h"\r
+\r
+#include <QDateTime>\r
+#include <QStringList>\r
+\r
+namespace AniDBUdpClient {\r
+\r
+class MyListReply;\r
+\r
+class ANIDBUDPCLIENTSHARED_EXPORT MyListCommand : public AbstractCommand\r
+{\r
+public:\r
+ typedef MyListReply ReplyType;\r
+ MyListCommand();\r
+ MyListCommand(int lid);\r
+ MyListCommand(int fid, bool isFid);\r
+ MyListCommand(const QByteArray &ed2k, qint64 size);\r
+ MyListCommand(const QString &aname, const QString &gname, int epno);\r
+ MyListCommand(const QString &aname, int gid, int epno);\r
+ MyListCommand(int aid, const QString &gname, int epno);\r
+ MyListCommand(int aid, int gid, int epno);\r
+\r
+ int lid() const;\r
+ void setLid(int lid);\r
+ int fid() const;\r
+ void setFid(int fid);\r
+\r
+ QByteArray ed2k() const;\r
+ void setEd2k(const QByteArray &ed2k);\r
+ qint64 size() const;\r
+ void setSize(qint64 size);\r
+\r
+ QString aname() const;\r
+ void setAname(const QString &aname);\r
+ int aid() const;\r
+ void setAid(int aid);\r
+ QString gname() const;\r
+ void setGname(const QString &gname);\r
+ int gid() const;\r
+ void setGid(int gid);\r
+ int epno() const;\r
+ void setEpno(int epno);\r
+\r
+ bool isValid() const;\r
+\r
+ bool waitForResult() const;\r
+ Command rawCommand() const;\r
+ void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);\r
+\r
+private:\r
+ void init();\r
+\r
+ int m_lid;\r
+ int m_fid;\r
+\r
+ QByteArray m_ed2k;\r
+ qint64 m_size;\r
+\r
+ QString m_aname;\r
+ int m_aid;\r
+ QString m_gname;\r
+ int m_gid;\r
+ int m_epno;\r
+\r
+};\r
+\r
+class ANIDBUDPCLIENTSHARED_EXPORT MyListReply : public AbstractReply\r
+{\r
+ Q_OBJECT\r
+ REPLY_DEFINITION_HELPER2(MyList)\r
+\r
+ Q_PROPERTY(int lid READ lid);\r
+ Q_PROPERTY(int fid READ fid);\r
+\r
+ Q_PROPERTY(int aid READ aid);\r
+ Q_PROPERTY(int gid READ gid);\r
+\r
+ Q_PROPERTY(int eid READ eid);\r
+ Q_PROPERTY(QDateTime date READ date);\r
+ Q_PROPERTY(State state READ state);\r
+ Q_PROPERTY(QDateTime viewDate READ viewDate);\r
+ Q_PROPERTY(QString storage READ storage);\r
+ Q_PROPERTY(QString source READ source);\r
+ Q_PROPERTY(QString other READ other);\r
+ Q_PROPERTY(FileState fileState READ fileState);\r
+\r
+ Q_PROPERTY(QStringList multipleEntries READ multipleEntries);\r
+\r
+public:\r
+\r
+ int lid() const;\r
+ int fid() const;\r
+\r
+ int aid() const;\r
+ int gid() const;\r
+\r
+\r
+ int eid() const;\r
+ QDateTime date() const;\r
+ State state() const;\r
+ QDateTime viewDate() const;\r
+ QString storage() const;\r
+ QString source() const;\r
+ QString other() const;\r
+ FileState fileState() const;\r
+\r
+ QStringList multipleEntries() const;\r
+\r
+ void setRawReply(ReplyCode replyCode, const QString &reply);\r
+\r
+private:\r
+ void init();\r
+\r
+ int m_lid;\r
+ int m_fid;\r
+\r
+ int m_aid;\r
+ int m_gid;\r
+ int m_epno;\r
+\r
+ int m_eid;\r
+ QDateTime m_date;\r
+ State m_state;\r
+ QDateTime m_viewDate;\r
+ QString m_storage;\r
+ QString m_source;\r
+ QString m_other;\r
+ FileState m_fileState;\r
+\r
+ QStringList m_multipleEntries;\r
+\r
+};\r
+\r
+} // namespace AniDBUdpClient\r
+\r
+#endif // MYLISTCOMMAND_H\r
namespace AniDBUdpClient {
-RawCommand::RawCommand(const QString &command, QObject *parent) : AbstractCommand(parent)
+RawCommand::RawCommand(const QString &command) : AbstractCommand()
{
m_command = command;
}
namespace AniDBUdpClient {
+class RawReply;
+
class ANIDBUDPCLIENTSHARED_EXPORT RawCommand : public AbstractCommand
{
- Q_OBJECT
-
public:
- RawCommand(const QString &command, QObject *parent = 0);
+ typedef RawReply ReplyType;
+ RawCommand(const QString &command);
Command rawCommand() const;
QString m_command;
};
+class ANIDBUDPCLIENTSHARED_EXPORT RawReply : public AbstractReply
+{
+ Q_OBJECT
+ REPLY_DEFINITION_HELPER(Raw)
+public:
+};
+
} // namespace AniDBUdpClient
#endif // RAWCOMMAND_H
namespace AniDBUdpClient {
-UptimeCommand::UptimeCommand(QObject *parent) : AbstractCommand(parent)
+UptimeCommand::UptimeCommand() : AbstractCommand()
{
- m_uptime = 0;
-}
-
-int UptimeCommand::uptime()
-{
- return m_uptime;
}
Command UptimeCommand::rawCommand() const
return command;
}
-void UptimeCommand::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
+// ==
+
+int UptimeReply::uptime()
+{
+ return m_uptime;
+}
+
+void UptimeReply::setRawReply(ReplyCode replyCode, const QString &reply, Client *client)
{
Q_UNUSED(client);
}
}
+void UptimeReply::init()
+{
+ m_uptime = 0;
+}
+
} // namespace AniDBUdpClient
namespace AniDBUdpClient {
+class UptimeReply;
+
class ANIDBUDPCLIENTSHARED_EXPORT UptimeCommand : public AbstractCommand
+{
+public:
+ typedef UptimeReply ReplyType;
+ UptimeCommand();
+
+ Command rawCommand() const;
+};
+
+class ANIDBUDPCLIENTSHARED_EXPORT UptimeReply : public AbstractReply
{
Q_OBJECT
+ REPLY_DEFINITION_HELPER2(Uptime)
Q_PROPERTY(int uptime READ uptime);
public:
- UptimeCommand(QObject *parent = 0);
int uptime();
- Command rawCommand() const;
void setRawReply(ReplyCode replyCode, const QString &reply, Client *client);
private:
+ void init();
int m_uptime;
};
-} // namespace AniDBUdpClient
-#include <QScriptEngine>
-Q_SCRIPT_DECLARE_QMETAOBJECT(AniDBUdpClient::UptimeCommand, QObject*);
+} // namespace AniDBUdpClient
#endif // UPTIMECOMMAND_H
projects / anidbudpclient.git / commitdiff