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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
/****************************************************************************
**
** Copyright (C) 2013-2014 Jolla Ltd.
** Contact: Chris Adams <chris.adams@jollamobile.com>
**
** This program/library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public License
** version 2.1 as published by the Free Software Foundation.
**
** This program/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.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this program/library; if not, write to the Free
** Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
** 02110-1301 USA
**
****************************************************************************/
#ifndef SOCIALNETWORKSYNCADAPTOR_H
#define SOCIALNETWORKSYNCADAPTOR_H
#include <QtCore/QObject>
#include <QtCore/QDateTime>
#include <QtCore/QString>
#include <QtCore/QJsonObject>
#include <QtCore/QJsonArray>
#include <QtCore/QMap>
#include <QtCore/QList>
#include "buteosyncfw_p.h"
class QSqlDatabase;
class QNetworkAccessManager;
class QTimer;
class QNetworkReply;
class SocialNetworkSyncDatabase;
class SocialImagesDatabase;
namespace Accounts {
class Account;
class Manager;
}
class SocialNetworkSyncAdaptor : public QObject
{
Q_OBJECT
Q_PROPERTY(Status status READ status NOTIFY statusChanged)
Q_PROPERTY(bool enabled READ enabled NOTIFY enabledChanged)
public:
enum Status {
Initializing = 0,
Inactive,
Busy,
Error,
Invalid
};
enum PurgeMode {
SyncPurge = 0,
CleanUpPurge
};
enum DataType {
Contacts = 1, // "Contacts"
Calendars, // "Calendars"
Notifications, // "Notifications"
Images, // "Images"
Videos, // "Videos"
Posts, // "Posts"
Messages, // "Messages"
Emails, // "Emails"
Signon, // "Signon" -- for refreshing AccessTokens etc.
Backup, // "Backup"
BackupQuery, // "BackupQuery"
BackupRestore // "BackupRestore"
};
static QStringList validDataTypes();
static QString dataTypeName(DataType t);
public:
SocialNetworkSyncAdaptor(const QString &serviceName, SocialNetworkSyncAdaptor::DataType dataType,
QNetworkAccessManager *qnam, QObject *parent);
virtual ~SocialNetworkSyncAdaptor();
virtual QString syncServiceName() const = 0;
void setAccountSyncProfile(Buteo::SyncProfile* perAccountSyncProfile);
Status status() const;
bool enabled() const;
QString serviceName() const;
virtual void sync(const QString &dataType, int accountId = 0);
virtual void purgeDataForOldAccount(int accountId, PurgeMode mode = SyncPurge) = 0;
virtual void abortSync(Sync::SyncStatus status);
Q_SIGNALS:
void statusChanged();
void enabledChanged();
protected:
virtual bool checkAccount(Accounts::Account *account);
virtual void finalCleanup();
virtual void finalize(int accountId);
QDateTime lastSyncTimestamp(const QString &serviceName, const QString &dataType,
int accountId) const;
bool updateLastSyncTimestamp(const QString &serviceName, const QString &dataType,
int accountId, const QDateTime ×tamp);
QList<int> syncedAccounts(const QString &dataType);
void setStatus(Status status);
void setInitialActive(bool enabled);
void setFinishedInactive();
// whether the sync has been aborted (perhaps due to network connection loss)
bool syncAborted() const;
// Semaphore system
void incrementSemaphore(int accountId);
void decrementSemaphore(int accountId);
// network reply timeouts
void setupReplyTimeout(int accountId, QNetworkReply *reply, int msecs = 60000);
void removeReplyTimeout(int accountId, QNetworkReply *reply);
void triggerReplyTimeouts();
// Parsing methods
static QJsonObject parseJsonObjectReplyData(const QByteArray &replyData, bool *ok);
static QJsonArray parseJsonArrayReplyData(const QByteArray &replyData, bool *ok);
// Cache management
void purgeCachedImages(SocialImagesDatabase *database, int accountId);
void purgeExpiredImages(SocialImagesDatabase *database, int accountId);
const SocialNetworkSyncAdaptor::DataType m_dataType;
Accounts::Manager * const m_accountManager;
QNetworkAccessManager * const m_networkAccessManager;
Buteo::SyncProfile *m_accountSyncProfile;
protected Q_SLOTS:
virtual void timeoutReply();
private:
SocialNetworkSyncDatabase *m_syncDb;
SocialNetworkSyncAdaptor::Status m_status;
bool m_enabled;
bool m_syncAborted;
QString m_serviceName;
QMap<int, int> m_accountSyncSemaphores;
QMap<int, QMap<QNetworkReply*, QTimer *> > m_networkReplyTimeouts;
};
#endif // SOCIALNETWORKSYNCADAPTOR_H
|
