Add docstrings and use @property when needed.
This commit is contained in:
parent
86dd1b0ef4
commit
06843adca1
@ -64,7 +64,7 @@ parser.add_option(
|
|||||||
help="certificate file ")
|
help="certificate file ")
|
||||||
options, args = parser.parse_args()
|
options, args = parser.parse_args()
|
||||||
|
|
||||||
# Update radicale configuration according to options
|
# Update Radicale configuration according to options
|
||||||
for option in parser.option_list:
|
for option in parser.option_list:
|
||||||
key = option.dest
|
key = option.dest
|
||||||
if key:
|
if key:
|
||||||
|
@ -18,6 +18,21 @@
|
|||||||
# You should have received a copy of the GNU General Public License
|
# You should have received a copy of the GNU General Public License
|
||||||
# along with Radicale. If not, see <http://www.gnu.org/licenses/>.
|
# along with Radicale. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
"""
|
||||||
|
Radicale Server module.
|
||||||
|
|
||||||
|
This module offers 3 useful classes:
|
||||||
|
|
||||||
|
- ``HTTPServer`` is a simple HTTP server;
|
||||||
|
- ``HTTPSServer`` is a HTTPS server, wrapping the HTTP server in a socket
|
||||||
|
managing SSL connections;
|
||||||
|
- ``CalendarHTTPHandler`` is a CalDAV request handler for HTTP(S) servers.
|
||||||
|
|
||||||
|
To use this module, you should take a look at the file ``radicale.py`` that
|
||||||
|
should have been included in this package.
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
# TODO: Manage errors (see xmlutils)
|
# TODO: Manage errors (see xmlutils)
|
||||||
|
|
||||||
import socket
|
import socket
|
||||||
@ -29,10 +44,14 @@ except ImportError:
|
|||||||
|
|
||||||
from radicale import config, support, xmlutils
|
from radicale import config, support, xmlutils
|
||||||
|
|
||||||
HTTPServer = server.HTTPServer
|
class HTTPServer(server.HTTPServer):
|
||||||
|
"""HTTP server."""
|
||||||
|
pass
|
||||||
|
|
||||||
class HTTPSServer(HTTPServer):
|
class HTTPSServer(HTTPServer):
|
||||||
|
"""HTTPS server."""
|
||||||
def __init__(self, address, handler):
|
def __init__(self, address, handler):
|
||||||
|
"""Create server by wrapping HTTP socket in an SSL socket."""
|
||||||
# Fails with Python 2.5, import if needed
|
# Fails with Python 2.5, import if needed
|
||||||
import ssl
|
import ssl
|
||||||
|
|
||||||
@ -48,16 +67,19 @@ class HTTPSServer(HTTPServer):
|
|||||||
|
|
||||||
class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
||||||
"""HTTP requests handler for calendars."""
|
"""HTTP requests handler for calendars."""
|
||||||
def _parse_path(self):
|
_encoding = config.get("encoding", "request")
|
||||||
|
|
||||||
|
@property
|
||||||
|
def calendar(self):
|
||||||
|
"""The ``calendar.Calendar`` object corresponding to the given path."""
|
||||||
path = self.path.strip("/").split("/")
|
path = self.path.strip("/").split("/")
|
||||||
if len(path) >= 2:
|
if len(path) >= 2:
|
||||||
cal = "%s/%s" % (path[0], path[1])
|
cal = "%s/%s" % (path[0], path[1])
|
||||||
self.calendar = calendar.Calendar("radicale", cal)
|
return calendar.Calendar("radicale", cal)
|
||||||
|
|
||||||
def do_GET(self):
|
def do_GET(self):
|
||||||
"""Manage GET ``request``."""
|
"""Manage GET request."""
|
||||||
self._parse_path()
|
answer = self.calendar.vcalendar.encode(_encoding)
|
||||||
answer = self.calendar.vcalendar().encode(config.get("encoding", "request"))
|
|
||||||
|
|
||||||
self.send_response(client.OK)
|
self.send_response(client.OK)
|
||||||
self.send_header("Content-Length", len(answer))
|
self.send_header("Content-Length", len(answer))
|
||||||
@ -65,8 +87,7 @@ class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
|||||||
self.wfile.write(answer)
|
self.wfile.write(answer)
|
||||||
|
|
||||||
def do_DELETE(self):
|
def do_DELETE(self):
|
||||||
"""Manage DELETE ``request``."""
|
"""Manage DELETE request."""
|
||||||
self._parse_path()
|
|
||||||
obj = self.headers.get("if-match", None)
|
obj = self.headers.get("if-match", None)
|
||||||
answer = xmlutils.delete(obj, self.calendar, self.path)
|
answer = xmlutils.delete(obj, self.calendar, self.path)
|
||||||
|
|
||||||
@ -76,15 +97,14 @@ class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
|||||||
self.wfile.write(answer)
|
self.wfile.write(answer)
|
||||||
|
|
||||||
def do_OPTIONS(self):
|
def do_OPTIONS(self):
|
||||||
"""Manage OPTIONS ``request``."""
|
"""Manage OPTIONS request."""
|
||||||
self.send_response(client.OK)
|
self.send_response(client.OK)
|
||||||
self.send_header("Allow", "DELETE, GET, OPTIONS, PROPFIND, PUT, REPORT")
|
self.send_header("Allow", "DELETE, GET, OPTIONS, PROPFIND, PUT, REPORT")
|
||||||
self.send_header("DAV", "1, calendar-access")
|
self.send_header("DAV", "1, calendar-access")
|
||||||
self.end_headers()
|
self.end_headers()
|
||||||
|
|
||||||
def do_PROPFIND(self):
|
def do_PROPFIND(self):
|
||||||
"""Manage PROPFIND ``request``."""
|
"""Manage PROPFIND request."""
|
||||||
self._parse_path()
|
|
||||||
xml_request = self.rfile.read(int(self.headers["Content-Length"]))
|
xml_request = self.rfile.read(int(self.headers["Content-Length"]))
|
||||||
answer = xmlutils.propfind(xml_request, self.calendar, self.path)
|
answer = xmlutils.propfind(xml_request, self.calendar, self.path)
|
||||||
|
|
||||||
@ -95,14 +115,13 @@ class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
|||||||
self.wfile.write(answer)
|
self.wfile.write(answer)
|
||||||
|
|
||||||
def do_PUT(self):
|
def do_PUT(self):
|
||||||
"""Manage PUT ``request``."""
|
"""Manage PUT request."""
|
||||||
# TODO: Improve charset detection
|
# TODO: Improve charset detection
|
||||||
self._parse_path()
|
|
||||||
contentType = self.headers["content-type"]
|
contentType = self.headers["content-type"]
|
||||||
if contentType and "charset=" in contentType:
|
if contentType and "charset=" in contentType:
|
||||||
charset = contentType.split("charset=")[1].strip()
|
charset = contentType.split("charset=")[1].strip()
|
||||||
else:
|
else:
|
||||||
charset = config.get("encoding", "request")
|
charset = self._encoding
|
||||||
ical_request = self.rfile.read(int(self.headers["Content-Length"])).decode(charset)
|
ical_request = self.rfile.read(int(self.headers["Content-Length"])).decode(charset)
|
||||||
obj = self.headers.get("if-match", None)
|
obj = self.headers.get("if-match", None)
|
||||||
xmlutils.put(ical_request, self.calendar, self.path, obj)
|
xmlutils.put(ical_request, self.calendar, self.path, obj)
|
||||||
@ -110,8 +129,7 @@ class CalendarHTTPHandler(server.BaseHTTPRequestHandler):
|
|||||||
self.send_response(client.CREATED)
|
self.send_response(client.CREATED)
|
||||||
|
|
||||||
def do_REPORT(self):
|
def do_REPORT(self):
|
||||||
"""Manage REPORT ``request``."""
|
"""Manage REPORT request."""
|
||||||
self._parse_path()
|
|
||||||
xml_request = self.rfile.read(int(self.headers["Content-Length"]))
|
xml_request = self.rfile.read(int(self.headers["Content-Length"]))
|
||||||
answer = xmlutils.report(xml_request, self.calendar, self.path)
|
answer = xmlutils.report(xml_request, self.calendar, self.path)
|
||||||
|
|
||||||
|
@ -39,31 +39,33 @@ class Calendar(object):
|
|||||||
self.user = user
|
self.user = user
|
||||||
self.cal = cal
|
self.cal = cal
|
||||||
self.version = "2.0"
|
self.version = "2.0"
|
||||||
self.ctag = hash_tag(self.vcalendar())
|
self.ctag = hash_tag(self.vcalendar)
|
||||||
|
|
||||||
def append(self, vcalendar):
|
def append(self, vcalendar):
|
||||||
"""Append vcalendar to the calendar."""
|
"""Append vcalendar to the calendar."""
|
||||||
self.ctag = hash_tag(self.vcalendar())
|
self.ctag = hash_tag(self.vcalendar)
|
||||||
self.support.append(self.cal, vcalendar)
|
self.support.append(self.cal, vcalendar)
|
||||||
|
|
||||||
def remove(self, uid):
|
def remove(self, uid):
|
||||||
"""Remove object named ``uid`` from the calendar."""
|
"""Remove object named ``uid`` from the calendar."""
|
||||||
self.ctag = hash_tag(self.vcalendar())
|
self.ctag = hash_tag(self.vcalendar)
|
||||||
self.support.remove(self.cal, uid)
|
self.support.remove(self.cal, uid)
|
||||||
|
|
||||||
def replace(self, uid, vcalendar):
|
def replace(self, uid, vcalendar):
|
||||||
"""Replace objet named ``uid`` by ``vcalendar`` in the calendar."""
|
"""Replace objet named ``uid`` by ``vcalendar`` in the calendar."""
|
||||||
self.ctag = hash_tag(self.vcalendar())
|
self.ctag = hash_tag(self.vcalendar)
|
||||||
self.support.remove(self.cal, uid)
|
self.support.remove(self.cal, uid)
|
||||||
self.support.append(self.cal, vcalendar)
|
self.support.append(self.cal, vcalendar)
|
||||||
|
|
||||||
|
@property
|
||||||
def vcalendar(self):
|
def vcalendar(self):
|
||||||
"""Return unicode calendar from the calendar."""
|
"""Unicode calendar from the calendar."""
|
||||||
return self.support.read(self.cal)
|
return self.support.read(self.cal)
|
||||||
|
|
||||||
|
@property
|
||||||
def etag(self):
|
def etag(self):
|
||||||
"""Return etag from calendar."""
|
"""Etag from calendar."""
|
||||||
return '"%s"' % hash_tag(self.vcalendar())
|
return '"%s"' % hash_tag(self.vcalendar)
|
||||||
|
|
||||||
class Event(object):
|
class Event(object):
|
||||||
"""Internal event class."""
|
"""Internal event class."""
|
||||||
@ -71,8 +73,9 @@ class Event(object):
|
|||||||
"""Initialize event from ``vcalendar``."""
|
"""Initialize event from ``vcalendar``."""
|
||||||
self.text = vcalendar
|
self.text = vcalendar
|
||||||
|
|
||||||
|
@property
|
||||||
def etag(self):
|
def etag(self):
|
||||||
"""Return etag from event."""
|
"""Etag from event."""
|
||||||
return '"%s"' % hash_tag(self.text)
|
return '"%s"' % hash_tag(self.text)
|
||||||
|
|
||||||
class Header(object):
|
class Header(object):
|
||||||
@ -99,6 +102,7 @@ class Todo(object):
|
|||||||
"""Initialize todo from ``vcalendar``."""
|
"""Initialize todo from ``vcalendar``."""
|
||||||
self.text = vcalendar
|
self.text = vcalendar
|
||||||
|
|
||||||
|
@property
|
||||||
def etag(self):
|
def etag(self):
|
||||||
"""Return etag from todo."""
|
"""Etag from todo."""
|
||||||
return hash_tag(self.text)
|
return hash_tag(self.text)
|
||||||
|
@ -63,8 +63,8 @@ def append(cal, vcalendar):
|
|||||||
path = os.path.join(_folder, cal.replace(posixpath.sep, os.path.sep))
|
path = os.path.join(_folder, cal.replace(posixpath.sep, os.path.sep))
|
||||||
|
|
||||||
old_objects = []
|
old_objects = []
|
||||||
old_objects.extend([event.etag() for event in ical.events(old_calendar)])
|
old_objects.extend([event.etag for event in ical.events(old_calendar)])
|
||||||
old_objects.extend([todo.etag() for todo in ical.todos(old_calendar)])
|
old_objects.extend([todo.etag for todo in ical.todos(old_calendar)])
|
||||||
|
|
||||||
objects = []
|
objects = []
|
||||||
objects.extend(ical.events(vcalendar))
|
objects.extend(ical.events(vcalendar))
|
||||||
@ -85,7 +85,7 @@ def append(cal, vcalendar):
|
|||||||
fd.close()
|
fd.close()
|
||||||
|
|
||||||
for obj in objects:
|
for obj in objects:
|
||||||
if obj.etag() not in old_objects:
|
if obj.etag not in old_objects:
|
||||||
# TODO: Manage position and EOL
|
# TODO: Manage position and EOL
|
||||||
fd = _open(path)
|
fd = _open(path)
|
||||||
lines = [line for line in fd.readlines() if line]
|
lines = [line for line in fd.readlines() if line]
|
||||||
@ -106,8 +106,8 @@ def remove(cal, etag):
|
|||||||
|
|
||||||
headers = ical.headers(cal)
|
headers = ical.headers(cal)
|
||||||
timezones = ical.timezones(cal)
|
timezones = ical.timezones(cal)
|
||||||
todos = [todo for todo in ical.todos(cal) if todo.etag() != etag]
|
todos = [todo for todo in ical.todos(cal) if todo.etag != etag]
|
||||||
events = [event for event in ical.events(cal) if event.etag() != etag]
|
events = [event for event in ical.events(cal) if event.etag != etag]
|
||||||
|
|
||||||
fd = _open(path, "w")
|
fd = _open(path, "w")
|
||||||
fd.write(ical.write_calendar(headers, timezones, todos, events))
|
fd.write(ical.write_calendar(headers, timezones, todos, events))
|
||||||
|
@ -114,7 +114,7 @@ def propfind(xml_request, calendar, url):
|
|||||||
|
|
||||||
if _tag("D", "getetag") in properties:
|
if _tag("D", "getetag") in properties:
|
||||||
getetag = ET.Element(_tag("D", "getetag"))
|
getetag = ET.Element(_tag("D", "getetag"))
|
||||||
getetag.text = calendar.etag()
|
getetag.text = calendar.etag
|
||||||
prop.append(getetag)
|
prop.append(getetag)
|
||||||
|
|
||||||
if _tag("CS", "getctag") in properties:
|
if _tag("CS", "getctag") in properties:
|
||||||
@ -172,13 +172,13 @@ def report(xml_request, calendar, url):
|
|||||||
# is that really what is needed?
|
# is that really what is needed?
|
||||||
# Read rfc4791-9.[6|10] for info
|
# Read rfc4791-9.[6|10] for info
|
||||||
for hreference in hreferences:
|
for hreference in hreferences:
|
||||||
headers = ical.headers(calendar.vcalendar())
|
headers = ical.headers(calendar.vcalendar)
|
||||||
# TODO: Define timezones by obj
|
# TODO: Define timezones by obj
|
||||||
timezones = ical.timezones(calendar.vcalendar())
|
timezones = ical.timezones(calendar.vcalendar)
|
||||||
|
|
||||||
objects = []
|
objects = []
|
||||||
objects.extend(ical.events(calendar.vcalendar()))
|
objects.extend(ical.events(calendar.vcalendar))
|
||||||
objects.extend(ical.todos(calendar.vcalendar()))
|
objects.extend(ical.todos(calendar.vcalendar))
|
||||||
|
|
||||||
if not objects:
|
if not objects:
|
||||||
# TODO: Read rfc4791-9.[6|10] to find a right answer
|
# TODO: Read rfc4791-9.[6|10] to find a right answer
|
||||||
@ -212,7 +212,7 @@ def report(xml_request, calendar, url):
|
|||||||
if _tag("D", "getetag") in properties:
|
if _tag("D", "getetag") in properties:
|
||||||
# TODO: Can UID and ETAG be the same?
|
# TODO: Can UID and ETAG be the same?
|
||||||
getetag = ET.Element(_tag("D", "getetag"))
|
getetag = ET.Element(_tag("D", "getetag"))
|
||||||
getetag.text = obj.etag()
|
getetag.text = obj.etag
|
||||||
prop.append(getetag)
|
prop.append(getetag)
|
||||||
|
|
||||||
if _tag("C", "calendar-data") in properties:
|
if _tag("C", "calendar-data") in properties:
|
||||||
|
Loading…
Reference in New Issue
Block a user