1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/*
* Copyright (C) 2010 Bolloré telecom
*
* Author:
* Jeremy Lainé
*
* Source:
* http://code.google.com/p/qxmpp
*
* This file is a part of QXmpp library.
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
*/
#ifndef QXMPPTRANSFERMANAGER_H
#define QXMPPTRANSFERMANAGER_H
#include <QDateTime>
#include "QXmppIq.h"
class QXmppClient;
class QXmppIbbCloseIq;
class QXmppIbbDataIq;
class QXmppIbbOpenIq;
class QXmppStreamInitiationIq;
class QXmppTransferManager;
class QXmppTransferJob : public QObject
{
Q_OBJECT
public:
enum Error
{
NoError = 0,
FileCorruptError,
ProtocolError,
};
enum Method
{
InBandByteStream = 1,
SocksByteStream = 2,
};
void accept(QIODevice *output);
QXmppTransferJob::Error error() const;
QString jid() const;
// XEP-0096 : File transfer
QDateTime fileDate() const;
QString fileHash() const;
QString fileName() const;
int fileSize() const;
signals:
void error(QXmppTransferJob::Error error);
void finished();
void progress(qint64 done, qint64 total);
private:
QXmppTransferJob(const QString &jid, QXmppTransferManager *manager);
void terminate(QXmppTransferJob::Error error);
int m_done;
QXmppTransferJob::Error m_error;
QIODevice *m_iodevice;
QString m_jid;
QString m_sid;
int m_methods;
QString m_mimeType;
QDateTime m_fileDate;
QString m_fileHash;
QString m_fileName;
int m_fileSize;
QString m_requestId;
int m_ibbSequence;
friend class QXmppTransferManager;
};
class QXmppTransferManager : public QObject
{
Q_OBJECT
public:
QXmppTransferManager(QXmppClient* client);
QXmppTransferJob *sendFile(const QString &jid, const QString &fileName);
signals:
void fileReceived(QXmppTransferJob *offer);
private slots:
void ibbCloseIqReceived(const QXmppIbbCloseIq&);
void ibbDataIqReceived(const QXmppIbbDataIq&);
void ibbOpenIqReceived(const QXmppIbbOpenIq&);
void iqReceived(const QXmppIq&);
void streamInitiationIqReceived(const QXmppStreamInitiationIq&);
private:
QXmppTransferJob *getJobByRequestId(const QString &jid, const QString &id);
QXmppTransferJob *getJobBySid(const QString &jid, const QString &sid);
void streamInitiationResultReceived(const QXmppStreamInitiationIq&);
void streamInitiationSetReceived(const QXmppStreamInitiationIq&);
// reference to client object (no ownership)
QXmppClient* m_client;
QList<QXmppTransferJob*> m_jobs;
int m_ibbBlockSize;
};
#endif
|
