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
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
|
'''
Task Coach - Your friendly task manager
Copyright (C) 2004-2014 Task Coach developers <developers@taskcoach.org>
Task Coach is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
Task Coach 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 General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
'''
import wx
from taskcoachlib.syncml.core import *
from taskcoachlib.i18n import _
class BaseSource(SyncSource):
def __init__(self, callback, objectList, *args, **kwargs):
super(BaseSource, self).__init__(*args, **kwargs)
self.callback = callback
self.objectList = objectList
self.allObjectsList = [obj for obj in objectList]
self.newObjectsList = [obj for obj in objectList if obj.isNew()]
self.changedObjectsList = [obj for obj in objectList if obj.isModified()]
self.deletedObjectsList = [obj for obj in objectList if obj.isDeleted()]
def beginSync(self):
if self.syncMode in [REFRESH_FROM_SERVER,
REFRESH_FROM_SERVER_BY_SERVER]:
if self.objectList:
if wx.MessageBox(_('The synchronization for source %s') % self.name + \
_('will be a refresh from server. All local items will\n' \
'be deleted. Do you wish to continue?'),
_('Refresh from server'), wx.YES_NO) != wx.YES:
return 514 # Not sure of this
self.objectList.clear()
self.allObjectsList = []
self.newObjectsList = []
self.changedObjectsList = []
self.deletedObjectsList = []
elif self.syncMode in [REFRESH_FROM_CLIENT,
REFRESH_FROM_CLIENT_BY_SERVER]:
if wx.MessageBox(_('The synchronization for source %s') % self.name + \
_('will be a refresh from client. All remote items will\n' \
'be deleted. Do you wish to continue?'),
_('Refresh from server'), wx.YES_NO) != wx.YES:
return 514 # Not sure of this
def endSync(self):
pass
def _getObject(self, key):
"""Returns the domain object with local ID 'key', or raise
KeyError if not found."""
for obj in self.allObjectsList:
if obj.id() == key:
return obj
raise KeyError, 'No such object: %s' % key
def _getItem(self, ls):
"""Returns a SyncItem instance representing the first domain
object in the 'ls' sequence."""
try:
obj = ls.pop(0)
except IndexError:
return None
item = SyncItem(obj.id())
if obj.getStatus() == obj.STATUS_NONE:
item.state = STATE_NONE
elif obj.getStatus() == obj.STATUS_NEW:
item.state = STATE_NEW
elif obj.getStatus() == obj.STATUS_CHANGED:
item.state = STATE_UPDATED
elif obj.getStatus() == obj.STATUS_DELETED:
item.state = STATE_DELETED
self.updateItemProperties(item, obj)
return item
def updateItemProperties(self, item, obj):
"""Set item properties (data, dataType...) according to the
domain object 'obj'. You must overload this in subclasses."""
raise NotImplementedError
def _parseObject(self, item):
"""Must return a new domain object from a SyncItem instance."""
raise NotImplementedError
# These two methods seem to be obsolete.
def getFirstItemKey(self):
return None
def getNextItemKey(self):
return None
def getFirstItem(self):
self.callback.pulse()
self.allObjectsListCopy = self.allObjectsList[:]
return self._getItem(self.allObjectsListCopy)
def getNextItem(self):
self.callback.pulse()
return self._getItem(self.allObjectsListCopy)
def getFirstNewItem(self):
self.callback.pulse()
self.newObjectsListCopy = self.newObjectsList[:]
return self._getItem(self.newObjectsListCopy)
def getNextNewItem(self):
self.callback.pulse()
return self._getItem(self.newObjectsListCopy)
def getFirstUpdatedItem(self):
self.callback.pulse()
self.changedObjectsListCopy = self.changedObjectsList[:]
return self._getItem(self.changedObjectsListCopy)
def getNextUpdatedItem(self):
self.callback.pulse()
return self._getItem(self.changedObjectsListCopy)
def getFirstDeletedItem(self):
self.callback.pulse()
self.deletedObjectsListCopy = self.deletedObjectsList[:]
return self._getItem(self.deletedObjectsListCopy)
def getNextDeletedItem(self):
self.callback.pulse()
return self._getItem(self.deletedObjectsListCopy)
def addItem(self, item):
self.callback.onAddItem()
obj = self._parseObject(item)
obj.cleanDirty()
self.objectList.append(obj)
item.key = obj.id().encode('UTF-8')
return self.doAddItem(obj)
def doAddItem(self, obj):
"""Called after a domain object has been added; use this to
set up the object if it needs to."""
return 201
def updateItem(self, item):
self.callback.onUpdateItem()
obj = self._parseObject(item)
try:
local = self._getObject(item.key)
except KeyError:
return 404
return self.doUpdateItem(obj, local)
def doUpdateItem(self, obj, local):
"""Must update the 'local' domain object according to 'obj'
(which is a 'temporary' domain object)"""
local.cleanDirty()
def deleteItem(self, item):
self.callback.onDeleteItem()
try:
obj = self._getObject(item.key)
except KeyError:
return 211
self.objectList.remove(obj)
return 200
def setItemStatus(self, key, status):
self.callback.pulse()
obj = self._getObject(key)
if status in [200, 201, 211, 418]:
# 200: Generic OK
# 201: Added.
# 211: Item not deleted (not found)
# 418: Already exists.
if obj.isDeleted():
self.objectList.remove(obj)
else:
obj.cleanDirty()
return 200
print 'UNHANDLED ITEM STATUS %s %d' % (key, status)
return 501
|
