mirror of
https://github.com/samsonjs/vdirsyncer.git
synced 2026-04-19 13:05:52 +00:00
93 lines
2.5 KiB
Python
93 lines
2.5 KiB
Python
# -*- coding: utf-8 -*-
|
|
'''
|
|
vdirsyncer.storage.base
|
|
~~~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
:copyright: (c) 2014 Markus Unterwaditzer
|
|
:license: MIT, see LICENSE for more details.
|
|
'''
|
|
|
|
class Item(object):
|
|
'''should-be-immutable wrapper class for VCALENDAR and VCARD'''
|
|
def __init__(self, raw):
|
|
self.raw = raw
|
|
self._uid = None
|
|
|
|
@property
|
|
def uid(self):
|
|
if self._uid is None:
|
|
for line in self.raw.splitlines():
|
|
if line.startswith(b'UID:'):
|
|
self._uid = line[4:].strip()
|
|
return self._uid
|
|
|
|
|
|
class Storage(object):
|
|
'''Superclass of all storages, mainly useful to summarize the interface to
|
|
implement.
|
|
|
|
Terminology:
|
|
- UID: Global identifier of the item, across storages.
|
|
- HREF: Per-storage identifier of item, might be UID.
|
|
- ETAG: Checksum of item, or something similar that changes when the object does
|
|
'''
|
|
def __init__(self, fileext='.txt', item_class=Item):
|
|
self.fileext = fileext
|
|
self.item_class = item_class
|
|
|
|
def _get_href(self, uid):
|
|
return uid + self.fileext
|
|
|
|
def list(self):
|
|
'''
|
|
:returns: list of (href, etag)
|
|
'''
|
|
raise NotImplementedError()
|
|
|
|
def get(self, href):
|
|
'''
|
|
:param href: href to fetch
|
|
:returns: (object, etag)
|
|
'''
|
|
raise NotImplementedError()
|
|
|
|
def get_multi(self, hrefs):
|
|
'''
|
|
:param hrefs: list of hrefs to fetch
|
|
:returns: iterable of (href, obj, etag)
|
|
'''
|
|
for href in hrefs:
|
|
obj, etag = self.get(href)
|
|
yield href, obj, etag
|
|
|
|
def has(self, href):
|
|
'''
|
|
check if item exists by href
|
|
:returns: True or False
|
|
'''
|
|
raise NotImplementedError()
|
|
|
|
def upload(self, obj):
|
|
'''
|
|
Upload a new object, raise
|
|
:exc:`vdirsyncer.exceptions.AlreadyExistingError` if it already exists.
|
|
:returns: (href, etag)
|
|
'''
|
|
raise NotImplementedError()
|
|
|
|
def update(self, href, obj, etag):
|
|
'''
|
|
Update the object, raise :exc:`vdirsyncer.exceptions.WrongEtagError` if
|
|
the etag on the server doesn't match the given etag, raise
|
|
:exc:`vdirsyncer.exceptions.NotFoundError` if the item doesn't exist.
|
|
|
|
:returns: etag
|
|
'''
|
|
raise NotImplementedError()
|
|
|
|
def delete(self, href, etag):
|
|
'''
|
|
Delete the object by href, raise exceptions when etag doesn't match, no
|
|
return value
|
|
'''
|
|
raise NotImplementedError()
|