33#include <libical/ical.h>
34#include <ne_session.h>
36#include <ne_request.h>
38#include <ne_redirect.h>
39#include <libxml/xmlreader.h>
54 .description =
"CalDAV calendars",
79 ne_session_destroy(pvt->
session);
81 ne_uri_free(&pvt->
uri);
99 struct ast_str **response = data;
113static int auth_credentials(
void *userdata,
const char *realm,
int attempts,
char *username,
char *secret)
122 ne_strnzcpy(username, pvt->
user, NE_ABUFSIZ);
130 if (st->code < 200 || st->code > 299) {
131 if (st->code == 401) {
132 ast_debug(1,
"Got a 401 from the server but we expect this to happen when authenticating, %d: %s\n", st->code, st->reason_phrase);
134 ast_debug(1,
"Unexpected response from server, %d: %s\n", st->code, st->reason_phrase);
163 ne_add_request_header(req,
"Content-type",
ast_strlen_zero(content_type) ?
"text/xml" : content_type);
164 ne_add_request_header(req,
"Depth",
"1");
166 ret = ne_request_dispatch(req);
167 ne_request_destroy(req);
182 icalcomponent *calendar, *icalevent;
183 icaltimezone *utc = icaltimezone_get_utc_timezone();
204 unsigned short val[8];
206 for (x = 0; x < 8; x++) {
210 (
unsigned)
val[0], (
unsigned)
val[1], (
unsigned)
val[2],
211 (
unsigned)
val[3], (
unsigned)
val[4], (
unsigned)
val[5],
212 (
unsigned)
val[6], (
unsigned)
val[7]);
215 calendar = icalcomponent_new(ICAL_VCALENDAR_COMPONENT);
216 icalcomponent_add_property(calendar, icalproperty_new_version(
"2.0"));
217 icalcomponent_add_property(calendar, icalproperty_new_prodid(
"-//Digium, Inc.//res_caldav//EN"));
219 icalevent = icalcomponent_new(ICAL_VEVENT_COMPONENT);
220 icalcomponent_add_property(icalevent, icalproperty_new_dtstamp(icaltime_current_time_with_zone(utc)));
221 icalcomponent_add_property(icalevent, icalproperty_new_uid(
event->uid));
222 icalcomponent_add_property(icalevent, icalproperty_new_dtstart(icaltime_from_timet_with_zone(
event->start, 0, utc)));
223 icalcomponent_add_property(icalevent, icalproperty_new_dtend(icaltime_from_timet_with_zone(
event->end, 0, utc)));
225 icalcomponent_add_property(icalevent, icalproperty_new_organizer(
event->organizer));
228 icalcomponent_add_property(icalevent, icalproperty_new_summary(
event->summary));
231 icalcomponent_add_property(icalevent, icalproperty_new_description(
event->description));
234 icalcomponent_add_property(icalevent, icalproperty_new_location(
event->location));
237 icalcomponent_add_property(icalevent, icalproperty_new_categories(
event->categories));
239 if (
event->priority > 0) {
240 icalcomponent_add_property(icalevent, icalproperty_new_priority(
event->priority));
243 switch (
event->busy_state) {
245 icalcomponent_add_property(icalevent, icalproperty_new_status(ICAL_STATUS_CONFIRMED));
249 icalcomponent_add_property(icalevent, icalproperty_new_status(ICAL_STATUS_TENTATIVE));
253 icalcomponent_add_property(icalevent, icalproperty_new_status(ICAL_STATUS_NONE));
256 icalcomponent_add_component(calendar, icalevent);
258 ast_str_append(&body, 0,
"%s", icalcomponent_as_ical_string(calendar));
261 if ((response =
caldav_request(pvt,
"PUT", body, subdir,
"text/calendar"))) {
281 struct ast_str *body, *response;
282 icaltimezone *utc = icaltimezone_get_utc_timezone();
283 icaltimetype start,
end;
284 const char *start_str, *end_str;
291 start = icaltime_from_timet_with_zone(start_time, 0, utc);
292 end = icaltime_from_timet_with_zone(end_time, 0, utc);
293 start_str = icaltime_as_ical_string(start);
294 end_str = icaltime_as_ical_string(
end);
301 "<?xml version=\"1.0\" encoding=\"utf-8\" ?>\n"
302 "<C:calendar-query xmlns:D=\"DAV:\" xmlns:C=\"urn:ietf:params:xml:ns:caldav\">\n"
304 " <C:calendar-data>\n"
305 " <C:expand start=\"%s\" end=\"%s\"/>\n"
306 " </C:calendar-data>\n"
309 " <C:comp-filter name=\"VCALENDAR\">\n"
310 " <C:comp-filter name=\"VEVENT\">\n"
311 " <C:time-range start=\"%s\" end=\"%s\"/>\n"
312 " </C:comp-filter>\n"
313 " </C:comp-filter>\n"
315 "</C:calendar-query>\n", start_str, end_str, start_str, end_str);
333 tm.
tm_mon = time.month - 1;
356 icaltimezone *utc = icaltimezone_get_utc_timezone();
358 icalcomponent *valarm;
360 struct icaltriggertype trigger;
362 if (!(pvt && pvt->
owner)) {
372 start = icalcomponent_get_dtstart(comp);
373 end = icalcomponent_get_dtend(comp);
379 if ((prop = icalcomponent_get_first_property(comp, ICAL_SUMMARY_PROPERTY))) {
383 if ((prop = icalcomponent_get_first_property(comp, ICAL_DESCRIPTION_PROPERTY))) {
387 if ((prop = icalcomponent_get_first_property(comp, ICAL_ORGANIZER_PROPERTY))) {
391 if ((prop = icalcomponent_get_first_property(comp, ICAL_LOCATION_PROPERTY))) {
395 if ((prop = icalcomponent_get_first_property(comp, ICAL_CATEGORIES_PROPERTY))) {
399 if ((prop = icalcomponent_get_first_property(comp, ICAL_PRIORITY_PROPERTY))) {
400 event->priority = icalvalue_get_integer(icalproperty_get_value(prop));
403 if ((prop = icalcomponent_get_first_property(comp, ICAL_UID_PROPERTY))) {
406 ast_log(
LOG_WARNING,
"No UID found, but one is required. Generating, but updates may not be accurate\n");
417 for (prop = icalcomponent_get_first_property(comp, ICAL_ATTENDEE_PROPERTY);
418 prop; prop = icalcomponent_get_next_property(comp, ICAL_ATTENDEE_PROPERTY)) {
422 if (!(attendee =
ast_calloc(1,
sizeof(*attendee)))) {
426 data = icalproperty_get_attendee(prop);
439 if (!(valarm = icalcomponent_get_first_component(comp, ICAL_VALARM_COMPONENT))) {
445 if (!(prop = icalcomponent_get_first_property(valarm, ICAL_TRIGGER_PROPERTY))) {
452 trigger = icalproperty_get_trigger(prop);
454 if (icaltriggertype_is_null_trigger(trigger)) {
461 if (!icaltime_is_null_time(trigger.time)) {
462 tmp = icaltime_convert_to_zone(trigger.time, utc);
463 event->alarm = icaltime_as_timet_with_zone(
tmp, utc);
467 tmp = icaltime_add(start, trigger.duration);
468 event->alarm = icaltime_as_timet_with_zone(
tmp, icaltime_get_timezone(start));
490 const xmlChar *localname = xmlTextReaderConstLocalName(reader);
491 const xmlChar *uri = xmlTextReaderConstNamespaceUri(reader);
497 state->in_caldata = 1;
503 struct icaltimetype start,
end;
504 icaltimezone *utc = icaltimezone_get_utc_timezone();
507 const xmlChar *localname = xmlTextReaderConstLocalName(reader);
508 const xmlChar *uri = xmlTextReaderConstNamespaceUri(reader);
514 state->in_caldata = 0;
520 start = icaltime_from_timet_with_zone(
state->start, 0, utc);
521 end = icaltime_from_timet_with_zone(
state->end, 0, utc);
524 for (iter = icalcomponent_get_first_component(comp, ICAL_VEVENT_COMPONENT);
526 iter = icalcomponent_get_next_component(comp, ICAL_VEVENT_COMPONENT))
531 icalcomponent_free(comp);
538 if (!
state->in_caldata) {
542 text = xmlTextReaderValue(reader);
550 xmlParserSeverities
severity, xmlTextReaderLocatorPtr locator)
553 case XML_PARSER_SEVERITY_VALIDITY_WARNING:
554 case XML_PARSER_SEVERITY_WARNING:
556 xmlTextReaderLocatorLineNumber(locator),
559 case XML_PARSER_SEVERITY_VALIDITY_ERROR:
560 case XML_PARSER_SEVERITY_ERROR:
563 xmlTextReaderLocatorLineNumber(locator),
574 xmlTextReaderPtr reader;
594 reader = xmlReaderForMemory(
606 res = xmlTextReaderRead(reader);
608 int node_type = xmlTextReaderNodeType(reader);
610 case XML_READER_TYPE_ELEMENT:
613 case XML_READER_TYPE_END_ELEMENT:
616 case XML_READER_TYPE_TEXT:
617 case XML_READER_TYPE_CDATA:
623 res = xmlTextReaderRead(reader);
625 xmlFreeTextReader(reader);
636static int verify_cert(
void *userdata,
int failures,
const ne_ssl_certificate *cert)
651 ast_log(
LOG_ERROR,
"You must enable calendar support for res_caldav to load\n");
674 ast_log(
LOG_ERROR,
"Could not allocate space for fetching events for calendar: %s\n", cal->
name);
690 if (!strcasecmp(v->
name,
"url")) {
692 }
else if (!strcasecmp(v->
name,
"user")) {
694 }
else if (!strcasecmp(v->
name,
"secret")) {
716 pvt->
uri.scheme =
"http";
719 if (pvt->
uri.port == 0) {
720 pvt->
uri.port = ne_uri_defaultport(pvt->
uri.scheme);
723 pvt->
session = ne_session_create(pvt->
uri.scheme, pvt->
uri.host, pvt->
uri.port);
724 ne_redirect_register(pvt->
session);
726 if (!strcasecmp(pvt->
uri.scheme,
"https")) {
727 ne_ssl_trust_default_ca(pvt->
session);
743 struct timespec ts = {0,};
756 ast_debug(10,
"Skipping refresh since we got a shutdown signal\n");
791 .
requires =
"res_calendar",
Asterisk main include file. File version handling, generic pbx functions.
#define ast_strdup(str)
A wrapper for strdup()
#define ast_calloc(num, len)
A wrapper for calloc()
#define ast_malloc(len)
A wrapper for malloc()
#define ao2_link(container, obj)
Add an object to a container.
#define ao2_callback(c, flags, cb_fn, arg)
ao2_callback() is a generic function that applies cb_fn() to all objects in a container,...
#define ao2_ref(o, delta)
Reference/unreference an object and return the old refcount.
#define ao2_alloc(data_size, destructor_fn)
A general API for managing calendar events with Asterisk.
void ast_calendar_unregister(struct ast_calendar_tech *tech)
Unregister a new calendar technology.
void ast_calendar_merge_events(struct ast_calendar *cal, struct ao2_container *new_events)
Add an event to the list of events for a calendar.
void ast_calendar_config_release(void)
Release the calendar config.
@ AST_CALENDAR_BS_BUSY_TENTATIVE
struct ao2_container * ast_calendar_event_container_alloc(void)
Allocate an astobj2 container for ast_calendar_event objects.
int ast_calendar_register(struct ast_calendar_tech *tech)
Register a new calendar technology.
struct ast_calendar_event * ast_calendar_event_alloc(struct ast_calendar *cal)
Allocate an astobj2 ast_calendar_event object.
struct ast_calendar_event * ast_calendar_unref_event(struct ast_calendar_event *event)
Unreference an ast_calendar_event.
const struct ast_config * ast_calendar_config_acquire(void)
Grab and lock pointer to the calendar config (read only)
General Asterisk PBX channel definitions.
static int len(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t buflen)
Configuration File Parser.
struct ast_variable * ast_variable_browse(const struct ast_config *config, const char *category_name)
#define ast_debug(level,...)
Log a DEBUG message.
#define AST_LIST_INSERT_TAIL(head, elm, field)
Appends a list entry to the tail of a list.
struct timeval ast_mktime(struct ast_tm *const tmp, const char *zone)
Timezone-independent version of mktime(3).
Asterisk locking-related definitions:
#define ast_cond_timedwait(cond, mutex, time)
#define ast_mutex_init(pmutex)
#define ast_mutex_unlock(a)
#define ast_mutex_lock(a)
enum ast_security_event_severity severity
Asterisk module definitions.
#define AST_MODULE_INFO(keystr, flags_to_set, desc, fields...)
@ AST_MODPRI_DEVSTATE_PLUGIN
@ AST_MODULE_SUPPORT_EXTENDED
#define ASTERISK_GPL_KEY
The text the key() function should return.
@ AST_MODULE_LOAD_SUCCESS
@ AST_MODULE_LOAD_DECLINE
Module has failed to load, may be in an inconsistent state.
static ast_mutex_t refreshlock
static struct ast_calendar_tech caldav_tech
static void handle_start_element(xmlTextReaderPtr reader, struct xmlstate *state)
static void * unref_caldav(void *obj)
static int update_caldav(struct caldav_pvt *pvt)
static struct ast_str * caldav_get_events_between(struct caldav_pvt *pvt, time_t start_time, time_t end_time)
static int debug_response_handler(void *userdata, ne_request *req, const ne_status *st)
static void * caldav_load_calendar(void *data)
static int verify_cert(void *userdata, int failures, const ne_ssl_certificate *cert)
static void caldav_destructor(void *obj)
static void caldav_add_event(icalcomponent *comp, struct icaltime_span *span, void *data)
static void handle_characters(xmlTextReaderPtr reader, struct xmlstate *state)
static const xmlChar * caldav_node_nsuri
static int auth_credentials(void *userdata, const char *realm, int attempts, char *username, char *secret)
static int fetch_response_reader(void *data, const char *block, size_t len)
static time_t icalfloat_to_timet(icaltimetype time)
static int caldav_write_event(struct ast_calendar_event *event)
static int load_module(void)
static void handle_end_element(xmlTextReaderPtr reader, struct xmlstate *state)
static void parse_error_handler(void *arg, const char *msg, xmlParserSeverities severity, xmlTextReaderLocatorPtr locator)
static int unload_module(void)
static struct ast_str * caldav_request(struct caldav_pvt *pvt, const char *method, struct ast_str *req_body, struct ast_str *subdir, const char *content_type)
static const xmlChar * caldav_node_localname
#define AST_DECLARE_STRING_FIELDS(field_list)
Declare the fields needed in a structure.
#define AST_STRING_FIELD(name)
Declare a string field.
#define ast_string_field_set(x, field, data)
Set a field to a simple string value.
#define ast_string_field_init(x, size)
Initialize a field pool and fields.
#define ast_string_field_build(x, field, fmt, args...)
Set a field to a complex (built) value.
#define ast_string_field_free_memory(x)
free all memory - to be called before destroying the object
int ast_str_append(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Append to a thread local dynamic string.
char * ast_str_buffer(const struct ast_str *buf)
Returns the string buffer within the ast_str buf.
static force_inline int attribute_pure ast_strlen_zero(const char *s)
void ast_str_reset(struct ast_str *buf)
Reset the content of a dynamic string. Useful before a series of ast_str_append.
#define ast_str_create(init_len)
Create a malloc'ed dynamic length string.
int ast_str_set(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Set a dynamic string using variable arguments.
size_t ast_str_strlen(const struct ast_str *buf)
Returns the current length of the string stored within buf.
struct ast_calendar_attendee * next
Individual calendaring technology data.
Asterisk calendar structure.
const ast_string_field name
Structure for mutex and tracking information.
Support for dynamic strings.
Structure for variables, used for configurations and for channel variables.
struct ast_variable * next
const ast_string_field url
struct ast_calendar * owner
const ast_string_field user
struct ao2_container * events
const ast_string_field secret
structure to hold users read from users.conf
struct association categories[]
int ast_time_t_to_string(time_t time, char *buf, size_t length)
Converts to a string representation of a time_t as decimal seconds since the epoch....
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
long int ast_random(void)