sjs/vdirsyncer
1
0
Fork 0
mirror of https://github.com/samsonjs/vdirsyncer.git synced 2026-03-25 08:55:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Catch more IdentConflicts

Browse source
This commit is contained in:
Markus Unterwaditzer 2015-09-18 19:36:34 +02:00
parent 21fb9f43ae
commit e303c907ae
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
vdirsyncer/sync.py
View file

@ -95,6 +95,12 @@ class StorageSyncer(object):
prefetch = {}
self.idents = {}
def _store_props(ident, props):
if self.idents.setdefault(ident, props) is not props:
raise IdentConflict(storage=self.storage,
hrefs=[self.idents[ident]['href'],
href])
for href, etag in self.storage.list():
props = {'href': href, 'etag': etag}
ident, old_etag = href_to_status.get(href, (None, None))
@ -104,7 +110,7 @@ class StorageSyncer(object):
# In both cases we should prefetch
prefetch[href] = props
else:
self.idents[ident] = props
_store_props(ident, props)
# Prefetch items
for href, item, etag in (self.storage.get_multi(prefetch)
@ -120,11 +126,7 @@ class StorageSyncer(object):
)
props['item'] = item
props['ident'] = ident = item.ident
if self.idents.setdefault(ident, props) is not props:
raise IdentConflict(storage=self.storage,
hrefs=[self.idents[ident]['href'],
href])
_store_props(ident, props)
def is_changed(self, ident):
_, status_etag = self.status.get(ident, (None, None))