Streams/streams
Streams/streams
1
0
Fork 0
mirror of https://codeberg.org/streams/streams.git synced 2024-09-19 21:55:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions
streams/include/event.php
Mike Macgirvin dae31497ef Merge branch 'dev' into nomadic
2024-06-13 20:05:03 +10:00

1522 lines
47 KiB
PHP
Raw Blame History

<?php
/**
* @file include/event.php
* @brief Event related functions.
*/
use Code\Lib\Time;
use Sabre\VObject;
use Code\Lib\Libsync;
use Code\Lib\Activity;
use Code\Lib\Channel;
use Code\Access\AccessControl;
use Code\Extend\Hook;
use Symfony\Component\Uid\Uuid;
use Code\Render\Theme;
require_once('include/bbcode.php');
/**
* @brief Returns an event as HTML.
*
* @param array $ev
* @return string HTML formatted event
*/
function format_event_html($ev)
{
logger('event: ' . print_r($ev, true));
logger('timezone: ' . date_default_timezone_get());
if (! ((is_array($ev)) && count($ev))) {
return '';
}
$bd_format = t('l F d, Y \@ g:i A') ; // Friday January 18, 2011 @ 8:01 AM
/// @TODO move this to template
$o = '<div class="vevent">' . "\r\n";
$o .= '<div class="event-title"><h3><i class="fa fa-calendar"></i>&nbsp;' . zidify_links(smilies(bbcode($ev['summary']))) . '</h3></div>' . "\r\n";
$o .= '<div class="event-start"><span class="event-label">' . t('Starts:') . '</span>&nbsp;<span class="dtstart" title="'
. Time::convert('UTC', 'UTC', $ev['dtstart'], (($ev['adjust']) ? ISO8601 : 'Y-m-d\TH:i:s' ))
. '" >'
. (($ev['adjust']) ? day_translate(Time::convert(
'UTC',
date_default_timezone_get(),
$ev['dtstart'],
$bd_format
))
: day_translate(Time::convert(
'UTC',
'UTC',
$ev['dtstart'],
$bd_format
)))
. '</span></div>' . "\r\n";
if (! $ev['nofinish']) {
$o .= '<div class="event-end" ><span class="event-label">' . t('Finishes:') . '</span>&nbsp;<span class="dtend" title="'
. Time::convert('UTC', 'UTC', $ev['dtend'], (($ev['adjust']) ? ISO8601 : 'Y-m-d\TH:i:s' ))
. '" >'
. (($ev['adjust']) ? day_translate(Time::convert(
'UTC',
date_default_timezone_get(),
$ev['dtend'],
$bd_format
))
: day_translate(Time::convert(
'UTC',
'UTC',
$ev['dtend'],
$bd_format
)))
. '</span></div>' . "\r\n";
}
$o .= '<div class="event-description">' . zidify_links(smilies(bbcode($ev['description']))) . '</div>' . "\r\n";
if (isset($ev['location']) && strlen($ev['location'])) {
$o .= '<div class="event-location"><span class="event-label"> ' . t('Location:') . '</span>&nbsp;<span class="location">'
. zidify_links(smilies(bbcode($ev['location'])))
. '</span></div>' . "\r\n";
}
$o .= '</div>' . "\r\n";
return $o;
}
function format_event_obj($jobject)
{
$event = [];
if (is_array($jobject)) {
$object = $jobject;
}
else {
$object = json_decode($jobject, true);
}
/*******
This is our encoded format
$x = [
'type' => 'Event',
'id' => z_root() . '/event/' . $r[0]['resource_id'],
'summary' => bbcode($arr['summary']),
// RFC3339 Section 4.3
'startTime' => (($arr['adjust']) ? Time::convert('UTC','UTC',$arr['dtstart'], ISO8601) : Time::convert('UTC','UTC',$arr['dtstart'],'Y-m-d\\TH:i:s-00:00')),
'content' => bbcode($arr['description']),
'location' => [ 'type' => 'Place', 'content' => $arr['location'] ],
'source' => [ 'content' => format_event_bbcode($arr), 'mediaType' => 'text/x-multicode' ],
'url' => [ [ 'mediaType' => 'text/calendar', 'href' => z_root() . '/events/ical/' . $event['event_hash'] ] ],
'actor' => Activity::encode_person($r[0],false),
];
if(! $arr['nofinish']) {
$x['endTime'] = (($arr['adjust']) ? Time::convert('UTC','UTC',$arr['dtend'], ISO8601) : Time::convert('UTC','UTC',$arr['dtend'],'Y-m-d\\TH:i:s-00:00'));
}
******/
if (is_array($object) && (array_key_exists('summary', $object) || array_key_exists('name', $object))) {
$bd_format = t('l F d, Y \@ g:i A'); // Friday January 18, 2011 @ 8:01 AM
$dtend = ((array_key_exists('endTime', $object)) ? $object['endTime'] : NULL_DATE);
$title = ((isset($object['summary']) && $object['summary']) ? zidify_links(smilies(bbcode($object['summary']))) : $object['name']);
$event['header'] = replace_macros(Theme::get_template('event_item_header.tpl'), [
'$title' => $title,
'$dtstart_label' => t('Starts:'),
'$dtstart_title' => Time::convert('UTC', 'UTC', $object['startTime'], ((strpos($object['startTime'], 'Z')) ? ISO8601 : 'Y-m-d\TH:i:s' )),
'$dtstart_dt' => ((strpos($object['startTime'], 'Z')) ? day_translate(Time::convert('UTC', date_default_timezone_get(), $object['startTime'], $bd_format)) : day_translate(Time::convert('UTC', 'UTC', $object['startTime'], $bd_format))),
'$finish' => array_key_exists('endTime', $object),
'$dtend_label' => t('Finishes:'),
'$dtend_title' => Time::convert('UTC', 'UTC', $dtend, ((strpos($object['startTime'], 'Z')) ? ISO8601 : 'Y-m-d\TH:i:s' )),
'$dtend_dt' => ((strpos($object['startTime'], 'Z')) ? day_translate(Time::convert('UTC', date_default_timezone_get(), $dtend, $bd_format)) : day_translate(Time::convert('UTC', 'UTC', $dtend, $bd_format)))
]);
$event['content'] = replace_macros(Theme::get_template('event_item_content.tpl'), [
'$description' => (($title) ? '<strong>' . $title . '</strong><br>' : '') . $object['content'],
'$location_label' => t('Location:'),
'$location' => ((array_path_exists('location/content', $object)) ? zidify_links(smilies(bbcode($object['location']['content']))) : EMPTY_STR)
]);
}
return $event;
}
function ical_wrapper($ev)
{
if (! ((is_array($ev)) && count($ev))) {
return '';
}
$o .= "BEGIN:VCALENDAR";
$o .= "\r\nVERSION:2.0";
$o .= "\r\nMETHOD:PUBLISH";
$o .= "\r\nPRODID:-//" . get_config('system', 'sitename') . "//" . Code\Lib\System::get_platform_name() . "//" . strtoupper(App::$language) . "\r\n";
if (array_key_exists('dtstart', $ev)) {
$o .= format_event_ical($ev);
} else {
foreach ($ev as $e) {
$o .= format_event_ical($e);
}
}
$o .= "\r\nEND:VCALENDAR\r\n";
return $o;
}
function format_event_ical($ev)
{
if ($ev['etype'] === 'task') {
return format_todo_ical($ev);
}
$o = "\r\nBEGIN:VEVENT";
$o .= "\r\nCREATED:" . Time::convert('UTC', 'UTC', $ev['created'], 'Ymd\\THis\\Z');
$o .= "\r\nLAST-MODIFIED:" . Time::convert('UTC', 'UTC', $ev['edited'], 'Ymd\\THis\\Z');
$o .= "\r\nDTSTAMP:" . Time::convert('UTC', 'UTC', $ev['edited'], 'Ymd\\THis\\Z');
if ($ev['dtstart']) {
$o .= "\r\nDTSTART:" . Time::convert('UTC', 'UTC', $ev['dtstart'], 'Ymd\\THis' . (($ev['adjust']) ? '\\Z' : ''));
}
if ($ev['dtend'] && ! $ev['nofinish']) {
$o .= "\r\nDTEND:" . Time::convert('UTC', 'UTC', $ev['dtend'], 'Ymd\\THis' . (($ev['adjust']) ? '\\Z' : ''));
}
if ($ev['summary']) {
$o .= "\r\nSUMMARY:" . format_ical_text($ev['summary']);
$o .= "\r\nX-ZOT-SUMMARY:" . format_ical_sourcetext($ev['summary']);
}
if ($ev['location']) {
$o .= "\r\nLOCATION:" . format_ical_text($ev['location']);
$o .= "\r\nX-ZOT-LOCATION:" . format_ical_sourcetext($ev['location']);
}
if ($ev['description']) {
$o .= "\r\nDESCRIPTION:" . format_ical_text($ev['description']);
$o .= "\r\nX-ZOT-DESCRIPTION:" . format_ical_sourcetext($ev['description']);
}
if ($ev['event_priority']) {
$o .= "\r\nPRIORITY:" . intval($ev['event_priority']);
}
$o .= "\r\nUID:" . $ev['event_hash'] ;
$o .= "\r\nEND:VEVENT\r\n";
return $o;
}
function format_todo_ical($ev)
{
$o = '';
$o .= "\r\nBEGIN:VTODO";
$o .= "\r\nCREATED:" . Time::convert('UTC', 'UTC', $ev['created'], 'Ymd\\THis\\Z');
$o .= "\r\nLAST-MODIFIED:" . Time::convert('UTC', 'UTC', $ev['edited'], 'Ymd\\THis\\Z');
$o .= "\r\nDTSTAMP:" . Time::convert('UTC', 'UTC', $ev['edited'], 'Ymd\\THis\\Z');
if ($ev['dtstart']) {
$o .= "\r\nDTSTART:" . Time::convert('UTC', 'UTC', $ev['dtstart'], 'Ymd\\THis' . (($ev['adjust']) ? '\\Z' : ''));
}
if ($ev['dtend'] && ! $ev['nofinish']) {
$o .= "\r\nDUE:" . Time::convert('UTC', 'UTC', $ev['dtend'], 'Ymd\\THis' . (($ev['adjust']) ? '\\Z' : ''));
}
if ($ev['summary']) {
$o .= "\r\nSUMMARY:" . format_ical_text($ev['summary']);
$o .= "\r\nX-ZOT-SUMMARY:" . format_ical_sourcetext($ev['summary']);
}
if ($ev['event_status']) {
$o .= "\r\nSTATUS:" . $ev['event_status'];
if ($ev['event_status'] === 'COMPLETED') {
$o .= "\r\nCOMPLETED:" . Time::convert('UTC', 'UTC', $ev['event_status_date'], 'Ymd\\THis\\Z');
}
}
if (intval($ev['event_percent'])) {
$o .= "\r\nPERCENT-COMPLETE:" . $ev['event_percent'];
}
if (intval($ev['event_sequence'])) {
$o .= "\r\nSEQUENCE:" . $ev['event_sequence'];
}
if ($ev['location']) {
$o .= "\r\nLOCATION:" . format_ical_text($ev['location']);
$o .= "\r\nX-ZOT-LOCATION:" . format_ical_sourcetext($ev['location']);
}
if ($ev['description']) {
$o .= "\r\nDESCRIPTION:" . format_ical_text($ev['description']);
$o .= "\r\nX-ZOT-DESCRIPTION:" . format_ical_sourcetext($ev['description']);
}
$o .= "\r\nUID:" . $ev['event_hash'] ;
if ($ev['event_priority']) {
$o .= "\r\nPRIORITY:" . intval($ev['event_priority']);
}
$o .= "\r\nEND:VTODO\r\n";
return $o;
}
function format_ical_text($s)
{
require_once('include/html2plain.php');
$s = html2plain(bbcode($s));
$s = str_replace(["\r\n","\n"], ["",""], $s);
return(wordwrap(str_replace(['\\',',',';'], ['\\\\','\\,','\\;'], $s), 72, "\r\n ", true));
}
function format_ical_sourcetext($s)
{
$s = base64_encode($s);
return(wordwrap(str_replace(['\\',',',';'], ['\\\\','\\,','\\;'], $s), 72, "\r\n ", true));
}
function format_event_bbcode($ev)
{
$o = '';
if ($ev['event_vdata']) {
$o .= '[event]' . $ev['event_vdata'] . '[/event]';
}
if ($ev['summary']) {
$o .= '[event-summary]' . $ev['summary'] . '[/event-summary]';
}
if ($ev['description']) {
$o .= '[event-description]' . $ev['description'] . '[/event-description]';
}
if ($ev['dtstart']) {
$o .= '[event-start]' . $ev['dtstart'] . '[/event-start]';
}
if (($ev['dtend']) && (! $ev['nofinish'])) {
$o .= '[event-finish]' . $ev['dtend'] . '[/event-finish]';
}
if ($ev['location']) {
$o .= '[event-location]' . $ev['location'] . '[/event-location]';
}
if ($ev['event_repeat']) {
$o .= '[event-repeat]' . $ev['event_repeat'] . '[/event-repeat]';
}
if ($ev['event_hash']) {
$o .= '[event-id]' . $ev['event_hash'] . '[/event-id]';
}
if ($ev['adjust']) {
$o .= '[event-adjust]' . $ev['adjust'] . '[/event-adjust]';
}
// Hubzilla compatibility
$o .= '[event-timezone]UTC[/event-timezone]';
return $o;
}
function bbtovcal($s)
{
$o = '';
$ev = bbtoevent($s);
if ($ev['description']) {
$o = format_event_html($ev);
}
return $o;
}
function bbtoevent($s)
{
$ev = [];
$match = '';
if (preg_match("/\[event\](.*?)\[\/event\]/is", $s, $match)) {
// only parse one object per event tag
// @fixme disabled for now - ical_to_event() expects a VCALENDAR wrapper
// and our VEVENT does not current include it.
// $x = ical_to_ev($match[1]);
// if($x)
// $ev = $x[0];
}
$match = '';
if (preg_match("/\[event\-summary\](.*?)\[\/event\-summary\]/is", $s, $match)) {
$ev['summary'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-description\](.*?)\[\/event\-description\]/is", $s, $match)) {
$ev['description'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-start\](.*?)\[\/event\-start\]/is", $s, $match)) {
$ev['dtstart'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-finish\](.*?)\[\/event\-finish\]/is", $s, $match)) {
$ev['dtend'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-location\](.*?)\[\/event\-location\]/is", $s, $match)) {
$ev['location'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-repeat\](.*?)\[\/event\-repeat\]/is", $s, $match)) {
$ev['event_repeat'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-id\](.*?)\[\/event\-id\]/is", $s, $match)) {
$ev['event_hash'] = $match[1];
}
$match = '';
if (preg_match("/\[event\-adjust\](.*?)\[\/event\-adjust\]/is", $s, $match)) {
$ev['adjust'] = $match[1];
}
if (array_key_exists('dtstart', $ev)) {
if (array_key_exists('dtend', $ev)) {
if ($ev['dtend'] === $ev['dtstart']) {
$ev['nofinish'] = 1;
} elseif ($ev['dtend']) {
$ev['nofinish'] = 0;
} else {
$ev['nofinish'] = 1;
}
} else {
$ev['nofinish'] = 1;
}
}
if (preg_match("/\[event\-timezone\](.*?)\[\/event\-timezone\]/is", $s, $match)) {
$tz = $match[1];
if (array_key_exists('dtstart', $ev)) {
$ev['dtstart'] = Time::convert($tz, 'UTC', $ev['dtstart']);
}
if (array_key_exists('dtend', $ev)) {
$ev['dtend'] = Time::convert($tz, 'UTC', $ev['dtend']);
}
}
// logger('bbtoevent: ' . print_r($ev,true));
return $ev;
}
/**
* @brief Sorts the given array of events by date.
*
* @see ev_compare()
* @param array $arr
* @return array Date sorted array of events
*/
function sort_by_date($arr)
{
if (is_array($arr)) {
usort($arr, 'ev_compare');
}
return $arr;
}
/**
* @brief Compare function for events.
*
* This function can be used in usort() to sort events by date.
*
* @see sort_by_date()
* @param array $a
* @param array $b
* @return number return values like strcmp()
*/
function ev_compare($a, $b)
{
$date_a = (($a['adjust']) ? Time::convert('UTC', date_default_timezone_get(), $a['dtstart']) : $a['dtstart']);
$date_b = (($b['adjust']) ? Time::convert('UTC', date_default_timezone_get(), $b['dtstart']) : $b['dtstart']);
if ($date_a === $date_b) {
return strcasecmp($a['description'], $b['description']);
}
return strcmp($date_a, $date_b);
}
function event_store_event($arr)
{
$arr['created'] = (($arr['created']) ? $arr['created'] : Time::convert());
$arr['edited'] = (($arr['edited']) ? $arr['edited'] : Time::convert());
$arr['etype'] = (($arr['etype']) ? $arr['etype'] : 'event' );
$arr['event_xchan'] = (($arr['event_xchan']) ? $arr['event_xchan'] : '');
$arr['event_priority'] = (($arr['event_priority']) ? $arr['event_priority'] : 0);
if (! $arr['dtend']) {
$arr['dtend'] = NULL_DATE;
$arr['nofinish'] = 1;
}
if (array_key_exists('event_status_date', $arr)) {
$arr['event_status_date'] = Time::convert('UTC', 'UTC', $arr['event_status_date']);
} else {
$arr['event_status_date'] = NULL_DATE;
}
$existing_event = null;
if ($arr['event_hash']) {
$r = q(
"SELECT * FROM event WHERE event_hash = '%s' AND uid = %d LIMIT 1",
dbesc($arr['event_hash']),
intval($arr['uid'])
);
if ($r) {
$existing_event = $r[0];
}
}
if ($arr['id']) {
$r = q(
"SELECT * FROM event WHERE id = %d AND uid = %d LIMIT 1",
intval($arr['id']),
intval($arr['uid'])
);
if ($r) {
$existing_event = $r[0];
} else {
return false;
}
}
$hook_info = [
'event' => $arr,
'existing_event' => $existing_event,
'cancel' => false
];
/**
* @hooks event_store_event
* Called when an event record is created or updated.
* * \e array \b event
* * \e array \b existing_event
* * \e boolean \b cancel - default false
*/
Hook::call('event_store_event', $hook_info);
if ($hook_info['cancel']) {
return false;
}
$arr = $hook_info['event'];
$existing_event = $hook_info['existing_event'];
if ($existing_event) {
if ($existing_event['edited'] >= $arr['edited']) {
// Nothing has changed.
return $existing_event;
}
$hash = $existing_event['event_hash'];
// The event changed. Update it.
$r = q(
"UPDATE event SET
edited = '%s',
dtstart = '%s',
dtend = '%s',
summary = '%s',
description = '%s',
location = '%s',
etype = '%s',
adjust = %d,
nofinish = %d,
event_status = '%s',
event_status_date = '%s',
event_percent = %d,
event_repeat = '%s',
event_sequence = %d,
event_priority = %d,
event_vdata = '%s',
allow_cid = '%s',
allow_gid = '%s',
deny_cid = '%s',
deny_gid = '%s'
WHERE id = %d AND uid = %d",
dbesc(Time::convert('UTC', 'UTC', $arr['edited'])),
dbesc(Time::convert('UTC', 'UTC', $arr['dtstart'])),
dbesc(Time::convert('UTC', 'UTC', $arr['dtend'])),
dbesc($arr['summary']),
dbesc($arr['description']),
dbesc($arr['location']),
dbesc($arr['etype']),
intval($arr['adjust']),
intval($arr['nofinish']),
dbesc($arr['event_status']),
dbesc(Time::convert('UTC', 'UTC', $arr['event_status_date'])),
intval($arr['event_percent']),
dbesc($arr['event_repeat']),
intval($arr['event_sequence']),
intval($arr['event_priority']),
dbesc($arr['event_vdata']),
dbesc($arr['allow_cid']),
dbesc($arr['allow_gid']),
dbesc($arr['deny_cid']),
dbesc($arr['deny_gid']),
intval($existing_event['id']),
intval($arr['uid'])
);
} else {
// New event. Store it.
if (array_key_exists('external_id', $arr)) {
$hash = $arr['external_id'];
}
elseif (array_key_exists('event_hash', $arr)) {
$hash = $arr['event_hash'];
}
else {
$hash = (string) Uuid::v4();
}
if (!$hash) {
$hash = random_string(48);
}
$r = q(
"INSERT INTO event ( uid,aid,event_xchan,event_hash,created,edited,dtstart,dtend,summary,description,location,etype,
adjust,nofinish, event_status, event_status_date, event_percent, event_repeat, event_sequence, event_priority, event_vdata, allow_cid,allow_gid,deny_cid,deny_gid)
VALUES ( %d, %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s', '%s', %d, '%s', %d, %d, '%s', '%s', '%s', '%s', '%s' ) ",
intval($arr['uid']),
intval($arr['account']),
dbesc($arr['event_xchan']),
dbesc($hash),
dbesc(Time::convert('UTC', 'UTC', $arr['created'])),
dbesc(Time::convert('UTC', 'UTC', $arr['edited'])),
dbesc(Time::convert('UTC', 'UTC', $arr['dtstart'])),
dbesc(Time::convert('UTC', 'UTC', $arr['dtend'])),
dbesc($arr['summary']),
dbesc($arr['description']),
dbesc($arr['location']),
dbesc($arr['etype']),
intval($arr['adjust']),
intval($arr['nofinish']),
dbesc($arr['event_status']),
dbesc(Time::convert('UTC', 'UTC', $arr['event_status_date'])),
intval($arr['event_percent']),
dbesc($arr['event_repeat']),
intval($arr['event_sequence']),
intval($arr['event_priority']),
dbesc($arr['event_vdata']),
dbesc($arr['allow_cid']),
dbesc($arr['allow_gid']),
dbesc($arr['deny_cid']),
dbesc($arr['deny_gid'])
);
}
$r = q(
"SELECT * FROM event WHERE event_hash = '%s' AND uid = %d LIMIT 1",
dbesc($hash),
intval($arr['uid'])
);
if ($r) {
return array_shift($r);
}
return false;
}
function event_addtocal($item_id, $uid)
{
$c = q(
"select * from channel where channel_id = %d limit 1",
intval($uid)
);
if (! $c) {
return false;
}
$channel = $c[0];
$r = q(
"select * from item where id = %d and uid = %d limit 1",
intval($item_id),
intval($channel['channel_id'])
);
if ((! $r) || ($r[0]['obj_type'] !== ACTIVITY_OBJ_EVENT)) {
return false;
}
$item = $r[0];
$ev = bbtoevent($r[0]['body']);
if (x($ev, 'summary') && x($ev, 'dtstart')) {
$ev['event_xchan'] = $item['author_xchan'];
$ev['uid'] = $channel['channel_id'];
$ev['account'] = $channel['channel_account_id'];
$ev['edited'] = $item['edited'];
$ev['mid'] = $item['mid'];
$ev['private'] = $item['item_private'];
// is this an edit?
if ($item['resource_type'] === 'event' && (! $ev['event_hash'])) {
$ev['event_hash'] = $item['resource_id'];
}
if ($ev['private']) {
$ev['allow_cid'] = '<' . $channel['channel_hash'] . '>';
} else {
$acl = new AccessControl($channel);
$x = $acl->get();
$ev['allow_cid'] = $x['allow_cid'];
$ev['allow_gid'] = $x['allow_gid'];
$ev['deny_cid'] = $x['deny_cid'];
$ev['deny_gid'] = $x['deny_gid'];
}
$event = event_store_event($ev);
if ($event) {
$r = q(
"update item set resource_id = '%s', resource_type = 'event' where id = %d and uid = %d",
dbesc($event['event_hash']),
intval($item['id']),
intval($channel['channel_id'])
);
$item['resource_id'] = $event['event_hash'];
$item['resource_type'] = 'event';
$i = [$item];
xchan_query($i);
$sync_item = fetch_post_tags($i);
$z = q(
"select * from event where event_hash = '%s' and uid = %d limit 1",
dbesc($event['event_hash']),
intval($channel['channel_id'])
);
if ($z) {
Libsync::build_sync_packet($channel['channel_id'], ['event_item' => [encode_item($sync_item[0], true)],'event' => $z]);
}
return true;
}
}
return false;
}
function ical_to_ev($s)
{
require_once('vendor/autoload.php');
$saved_timezone = date_default_timezone_get();
date_default_timezone_set('Australia/Sydney');
$ical = VObject\Reader::read($s);
$ev = [];
if ($ical) {
if ($ical->VEVENT) {
foreach ($ical->VEVENT as $event) {
$ev[] = parse_vobject($event, 'event');
}
}
if ($ical->VTODO) {
foreach ($ical->VTODO as $event) {
$ev[] = parse_vobject($event, 'task');
}
}
}
date_default_timezone_set($saved_timezone);
return $ev;
}
function parse_vobject($ical, $type)
{
$ev = [];
if (! isset($ical->DTSTART)) {
logger('no event start');
return $ev;
}
$ev['etype'] = $type;
$dtstart = $ical->DTSTART->getDateTime();
$ev['adjust'] = (($ical->DTSTART->isFloating()) ? 0 : 1);
$ev['dtstart'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtstart->format(DateTimeInterface::W3C)
);
if (isset($ical->DUE)) {
$dtend = $ical->DUE->getDateTime();
$ev['dtend'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtend->format(DateTimeInterface::W3C)
);
} elseif (isset($ical->DTEND)) {
$dtend = $ical->DTEND->getDateTime();
$ev['dtend'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtend->format(DateTimeInterface::W3C)
);
} else {
$ev['nofinish'] = 1;
}
if ($ev['dtstart'] === $ev['dtend']) {
$ev['nofinish'] = 1;
}
if (isset($ical->CREATED)) {
$created = $ical->CREATED->getDateTime();
$ev['created'] = Time::convert('UTC', 'UTC', $created->format(DateTimeInterface::W3C));
}
if (isset($ical->{'DTSTAMP'})) {
$edited = $ical->{'DTSTAMP'}->getDateTime();
$ev['edited'] = Time::convert('UTC', 'UTC', $edited->format(DateTimeInterface::W3C));
}
if (isset($ical->{'LAST-MODIFIED'})) {
$edited = $ical->{'LAST-MODIFIED'}->getDateTime();
$ev['edited'] = Time::convert('UTC', 'UTC', $edited->format(DateTimeInterface::W3C));
}
if (isset($ical->{'X-ZOT-LOCATION'})) {
$ev['location'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-LOCATION'});
} elseif (isset($ical->LOCATION)) {
$ev['location'] = (string) $ical->LOCATION;
}
if (isset($ical->{'X-ZOT-DESCRIPTION'})) {
$ev['description'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-DESCRIPTION'});
} elseif (isset($ical->DESCRIPTION)) {
$ev['description'] = (string) $ical->DESCRIPTION;
}
if (isset($ical->{'X-ZOT-SUMMARY'})) {
$ev['summary'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-SUMMARY'});
} elseif (isset($ical->SUMMARY)) {
$ev['summary'] = (string) $ical->SUMMARY;
}
if (isset($ical->PRIORITY)) {
$ev['event_priority'] = intval((string) $ical->PRIORITY);
}
if (isset($ical->UID)) {
$evuid = (string) $ical->UID;
$ev['event_hash'] = $evuid;
}
if (isset($ical->SEQUENCE)) {
$ev['event_sequence'] = (string) $ical->SEQUENCE;
}
if (isset($ical->STATUS)) {
$ev['event_status'] = (string) $ical->STATUS;
}
if (isset($ical->{'COMPLETED'})) {
$completed = $ical->{'COMPLETED'}->getDateTime();
$ev['event_status_date'] = Time::convert('UTC', 'UTC', $completed->format(DateTimeInterface::W3C));
}
if (isset($ical->{'PERCENT-COMPLETE'})) {
$ev['event_percent'] = (string) $ical->{'PERCENT-COMPLETE'} ;
}
$ev['event_vdata'] = $ical->serialize();
return $ev;
}
function parse_ical_file($f, $uid)
{
require_once('vendor/autoload.php');
$s = @file_get_contents($f);
$ical = VObject\Reader::read($s);
if ($ical) {
if ($ical->VEVENT) {
foreach ($ical->VEVENT as $event) {
event_import_ical($event, $uid);
}
}
if ($ical->VTODO) {
foreach ($ical->VTODO as $event) {
event_import_ical_task($event, $uid);
}
}
}
if ($ical) {
return true;
}
return false;
}
function event_import_ical($ical, $uid)
{
$c = q(
"select * from channel where channel_id = %d limit 1",
intval($uid)
);
if (! $c) {
return false;
}
$channel = $c[0];
$ev = [];
if (! isset($ical->DTSTART)) {
logger('no event start');
return false;
}
$dtstart = $ical->DTSTART->getDateTime();
$ev['adjust'] = (($ical->DTSTART->isFloating()) ? 0 : 1);
// logger('dtstart: ' . var_export($dtstart,true));
$ev['dtstart'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtstart->format(DateTimeInterface::W3C)
);
if (isset($ical->DTEND)) {
$dtend = $ical->DTEND->getDateTime();
$ev['dtend'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtend->format(DateTimeInterface::W3C)
);
} else {
$ev['nofinish'] = 1;
}
if ($ev['dtstart'] === $ev['dtend']) {
$ev['nofinish'] = 1;
}
if (isset($ical->CREATED)) {
$created = $ical->CREATED->getDateTime();
$ev['created'] = Time::convert('UTC', 'UTC', $created->format(DateTimeInterface::W3C));
}
if (isset($ical->{'LAST-MODIFIED'})) {
$edited = $ical->{'LAST-MODIFIED'}->getDateTime();
$ev['edited'] = Time::convert('UTC', 'UTC', $edited->format(DateTimeInterface::W3C));
}
if (isset($ical->{'X-ZOT-LOCATION'})) {
$ev['location'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-LOCATION'});
} elseif (isset($ical->LOCATION)) {
$ev['location'] = (string) $ical->LOCATION;
}
if (isset($ical->{'X-ZOT-DESCRIPTION'})) {
$ev['description'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-DESCRIPTION'});
} elseif (isset($ical->DESCRIPTION)) {
$ev['description'] = (string) $ical->DESCRIPTION;
}
if (isset($ical->{'X-ZOT-SUMMARY'})) {
$ev['summary'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-SUMMARY'});
} elseif (isset($ical->SUMMARY)) {
$ev['summary'] = (string) $ical->SUMMARY;
}
if (isset($ical->PRIORITY)) {
$ev['event_priority'] = intval((string) $ical->PRIORITY);
}
if (isset($ical->UID)) {
$evuid = (string) $ical->UID;
$r = q(
"SELECT * FROM event WHERE event_hash = '%s' AND uid = %d LIMIT 1",
dbesc($evuid),
intval($uid)
);
if ($r) {
$ev['event_hash'] = $evuid;
} else {
$ev['external_id'] = $evuid;
}
}
if ($ev['summary'] && $ev['dtstart']) {
$ev['event_xchan'] = $channel['channel_hash'];
$ev['uid'] = $channel['channel_id'];
$ev['account'] = $channel['channel_account_id'];
$ev['private'] = 1;
$ev['allow_cid'] = '<' . $channel['channel_hash'] . '>';
logger('storing event: ' . print_r($ev, true), LOGGER_ALL);
$event = event_store_event($ev);
if ($event) {
event_store_item($ev, $event, deliver: false, addAndSync: false);
return true;
}
}
return false;
}
function event_ical_get_sourcetext($s)
{
return base64_decode($s);
}
function event_import_ical_task($ical, $uid)
{
$c = q(
"select * from channel where channel_id = %d limit 1",
intval($uid)
);
if (! $c) {
return false;
}
$channel = $c[0];
$ev = [];
if (! isset($ical->DTSTART)) {
logger('no event start');
return false;
}
$dtstart = $ical->DTSTART->getDateTime();
$ev['adjust'] = (($ical->DTSTART->isFloating()) ? 0 : 1);
// logger('dtstart: ' . var_export($dtstart,true));
$ev['dtstart'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtstart->format(DateTimeInterface::W3C)
);
if (isset($ical->DUE)) {
$dtend = $ical->DUE->getDateTime();
$ev['dtend'] = Time::convert(
(($ev['adjust']) ? 'UTC' : date_default_timezone_get()),
'UTC',
$dtend->format(DateTimeInterface::W3C)
);
} else {
$ev['nofinish'] = 1;
}
if ($ev['dtstart'] === $ev['dtend']) {
$ev['nofinish'] = 1;
}
if (isset($ical->CREATED)) {
$created = $ical->CREATED->getDateTime();
$ev['created'] = Time::convert('UTC', 'UTC', $created->format(DateTimeInterface::W3C));
}
if (isset($ical->{'DTSTAMP'})) {
$edited = $ical->{'DTSTAMP'}->getDateTime();
$ev['edited'] = Time::convert('UTC', 'UTC', $edited->format(DateTimeInterface::W3C));
}
if (isset($ical->{'LAST-MODIFIED'})) {
$edited = $ical->{'LAST-MODIFIED'}->getDateTime();
$ev['edited'] = Time::convert('UTC', 'UTC', $edited->format(DateTimeInterface::W3C));
}
if (isset($ical->{'X-ZOT-LOCATION'})) {
$ev['location'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-LOCATION'});
} elseif (isset($ical->LOCATION)) {
$ev['location'] = (string) $ical->LOCATION;
}
if (isset($ical->{'X-ZOT-DESCRIPTION'})) {
$ev['description'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-DESCRIPTION'});
} elseif (isset($ical->DESCRIPTION)) {
$ev['description'] = (string) $ical->DESCRIPTION;
}
if (isset($ical->{'X-ZOT-SUMMARY'})) {
$ev['summary'] = event_ical_get_sourcetext((string) $ical->{'X-ZOT-SUMMARY'});
} elseif (isset($ical->SUMMARY)) {
$ev['summary'] = (string) $ical->SUMMARY;
}
if (isset($ical->PRIORITY)) {
$ev['event_priority'] = intval((string) $ical->PRIORITY);
}
$stored_event = null;
if (isset($ical->UID)) {
$evuid = (string) $ical->UID;
$r = q(
"SELECT * FROM event WHERE event_hash = '%s' AND uid = %d LIMIT 1",
dbesc($evuid),
intval($uid)
);
if ($r) {
$ev['event_hash'] = $evuid;
$stored_event = $r[0];
} else {
$ev['external_id'] = $evuid;
}
}
if (isset($ical->SEQUENCE)) {
$ev['event_sequence'] = (string) $ical->SEQUENCE;
// see if our stored event is more current than the one we're importing
if (
(intval($ev['event_sequence']) <= intval($stored_event['event_sequence']))
&& ($ev['edited'] <= $stored_event['edited'])
) {
return false;
}
}
if (isset($ical->STATUS)) {
$ev['event_status'] = (string) $ical->STATUS;
}
if (isset($ical->{'COMPLETED'})) {
$completed = $ical->{'COMPLETED'}->getDateTime();
$ev['event_status_date'] = Time::convert('UTC', 'UTC', $completed->format(DateTimeInterface::W3C));
}
if (isset($ical->{'PERCENT-COMPLETE'})) {
$ev['event_percent'] = (string) $ical->{'PERCENT-COMPLETE'} ;
}
$ev['etype'] = 'task';
if ($ev['summary'] && $ev['dtstart']) {
$ev['event_xchan'] = $channel['channel_hash'];
$ev['uid'] = $channel['channel_id'];
$ev['account'] = $channel['channel_account_id'];
$ev['private'] = 1;
$ev['allow_cid'] = '<' . $channel['channel_hash'] . '>';
logger('storing task event: ' . print_r($ev, true), LOGGER_ALL);
$event = event_store_event($ev);
if ($event) {
event_store_item($ev, $event, deliver: false, addAndSync: false);
return true;
}
}
return false;
}
function event_store_item($arr, $event, $deliver = true, $addAndSync = true)
{
require_once('include/datetime.php');
require_once('include/items.php');
$item = null;
if ($arr['mid'] && $arr['uid']) {
$i = q(
"select * from item where mid = '%s' and uid = %d limit 1",
dbesc($arr['mid']),
intval($arr['uid'])
);
if ($i) {
xchan_query($i);
$item = fetch_post_tags($i);
}
}
$item_arr = [];
$prefix = '';
if (($event) && array_key_exists('event_hash', $event) && (! array_key_exists('event_hash', $arr))) {
$arr['event_hash'] = $event['event_hash'];
}
if ($event['etype'] === 'birthday') {
if (! Channel::is_system($arr['uid'])) {
$prefix = t('This event has been added to your calendar.');
}
// The event is created on your own site by the system, but appears to belong
// to the birthday person. It also isn't propagated - so we need to prevent
// folks from trying to comment on it. If you're looking at this and trying to
// fix it, you'll need to completely change the way birthday events are created
// and send them out from the source. This has its own issues.
$item_arr['comment_policy'] = 'none';
}
$r = q(
"SELECT * FROM item left join xchan on author_xchan = xchan_hash WHERE resource_id = '%s' AND resource_type = 'event' and uid = %d LIMIT 1",
dbesc($event['event_hash']),
intval($arr['uid'])
);
if ($r) {
$x = [
'type' => 'Event',
'id' => z_root() . '/event/' . $r[0]['resource_id'],
'name' => $arr['summary'],
// RFC3339 Section 4.3
'startTime' => (($arr['adjust']) ? Time::convert('UTC', 'UTC', $arr['dtstart'], ISO8601) : Time::convert('UTC', 'UTC', $arr['dtstart'], 'Y-m-d\\TH:i:s-00:00')),
'content' => bbcode($arr['description']),
'location' => [ 'type' => 'Place', 'content' => $arr['location'] ],
'source' => [ 'content' => format_event_bbcode($arr), 'mediaType' => 'text/x-multicode' ],
'url' => [ [ 'mediaType' => 'text/calendar', 'href' => z_root() . '/events/ical/' . $event['event_hash'] ] ],
'attributedTo' => Activity::actorEncode($r[0], false),
'attachment' => Activity::encode_attachment($r[0]),
'tag' => Activity::encode_taxonomy($r[0])
];
if (! $arr['nofinish']) {
$x['endTime'] = (($arr['adjust']) ? Time::convert('UTC', 'UTC', $arr['dtend'], ISO8601) : Time::convert('UTC', 'UTC', $arr['dtend'], 'Y-m-d\\TH:i:s-00:00'));
}
if ($event['event_repeat']) {
$x['eventRepeat'] = $event['event_repeat'];
}
$object = json_encode($x);
$item_arr = [];
$item_arr['obj'] = $object;
$item_arr['edited'] = $arr['edited'];
$item_arr['allow_cid'] = $arr['allow_cid'];
$item_arr['allow_gid'] = $arr['allow_gid'];
$item_arr['deny_cid'] = $arr['deny_cid'];
$item_arr['deny_gid'] = $arr['deny_gid'];
$item_arr['item_private'] = (($arr['allow_cid'] || $arr['allow_gid'] || $arr['deny_cid'] || $arr['deny_gid']) ? 1 : 0);
$item_arr['title'] = $arr['summary'];
$item_arr['sig'] = '';
$item_arr['id'] = $r[0]['id'];
$item_arr['body'] = $prefix . format_event_bbcode($arr);
$item_arr['term'] = $arr['term'];
$post = item_store_update($item_arr, $deliver, $addAndSync);
/**
* @hooks event_updated
* Called when an event record is modified.
*/
Hook::call('event_updated', $event['id']);
return $post;
} else {
$z = Channel::from_id($arr['uid']);
$private = (($arr['allow_cid'] || $arr['allow_gid'] || $arr['deny_cid'] || $arr['deny_gid']) ? 1 : 0);
$item_wall = 0;
$item_origin = 0;
$item_thread_top = 0;
if ($item) {
$item_arr['id'] = $item['id'];
} else {
$wall = (($z['channel_hash'] == $event['event_xchan']) ? true : false);
$item_thread_top = 1;
if ($wall) {
$item_wall = 1;
$item_origin = 1;
}
}
if (! $arr['mid']) {
$arr['mid'] = z_root() . '/item/' . $event['event_hash'];
}
$item_arr['aid'] = $z['channel_account_id'];
$item_arr['uid'] = $arr['uid'];
$item_arr['mid'] = $arr['mid'];
$item_arr['parent_mid'] = $arr['mid'];
$item_arr['uuid'] = $event['event_hash'];
$item_arr['owner_xchan'] = (($wall) ? $z['channel_hash'] : $arr['event_xchan']);
$item_arr['author_xchan'] = $arr['event_xchan'];
$item_arr['summary'] = $arr['summary'];
$item_arr['allow_cid'] = $arr['allow_cid'];
$item_arr['allow_gid'] = $arr['allow_gid'];
$item_arr['deny_cid'] = $arr['deny_cid'];
$item_arr['deny_gid'] = $arr['deny_gid'];
$item_arr['item_private'] = $private;
$item_arr['verb'] = 'Invite';
$item_arr['item_wall'] = $item_wall;
$item_arr['item_origin'] = $item_origin;
$item_arr['item_thread_top'] = $item_thread_top;
$attach = [
[
'href' => z_root() . '/calendar/ical/' . urlencode($event['event_hash']),
'length' => 0,
'type' => 'text/calendar',
'title' => t('event') . '-' . $event['event_hash'],
'revision' => ''
]
];
$item_arr['attach'] = $attach;
if (array_key_exists('term', $arr)) {
$item_arr['term'] = $arr['term'];
}
$item_arr['resource_type'] = 'event';
$item_arr['resource_id'] = $event['event_hash'];
$item_arr['obj_type'] = ACTIVITY_OBJ_EVENT;
$item_arr['body'] = $prefix . format_event_bbcode($arr);
// if it's local send the permalink to the channel page.
// otherwise we'll fallback to /display/$message_id
if ($wall) {
$item_arr['plink'] = z_root() . '/channel/' . $z['channel_address'] . '/?f=&mid=' . gen_link_id($item_arr['mid']);
} else {
$item_arr['plink'] = z_root() . '/display/?mid=' . gen_link_id($item_arr['mid']);
}
$x = q(
"select * from xchan where xchan_hash = '%s' limit 1",
dbesc($arr['event_xchan'])
);
if ($x) {
$y = [
'type' => 'Event',
'id' => z_root() . '/event/' . $event['event_hash'],
'name' => $arr['summary'],
// RFC3339 Section 4.3
'startTime' => (($arr['adjust']) ? Time::convert('UTC', 'UTC', $arr['dtstart'], ISO8601) : Time::convert('UTC', 'UTC', $arr['dtstart'], 'Y-m-d\\TH:i:s-00:00')),
'content' => bbcode($arr['description']),
'location' => [ 'type' => 'Place', 'content' => bbcode($arr['location']) ],
'source' => [ 'content' => format_event_bbcode($arr), 'mediaType' => 'text/x-multicode' ],
'url' => [ [ 'mediaType' => 'text/calendar', 'href' => z_root() . '/events/ical/' . $event['event_hash'] ] ],
'attributedTo' => Activity::actorEncode($z, false),
'attachment' => Activity::encode_attachment($item_arr),
'tag' => Activity::encode_taxonomy($item_arr)
];
if (! $arr['nofinish']) {
$y['endTime'] = (($arr['adjust']) ? Time::convert('UTC', 'UTC', $arr['dtend'], ISO8601) : Time::convert('UTC', 'UTC', $arr['dtend'], 'Y-m-d\\TH:i:s-00:00'));
}
if ($arr['event_repeat']) {
$y['eventRepeat'] = $arr['event_repeat'];
}
$item_arr['obj'] = json_encode($y);
}
$item_arr['target'] = [
'id' => str_replace('/item/', '/conversation/', $item_arr['parent_mid']),
'type' => 'Collection',
'attributedTo' => z_root() . '/channel/' . $z['channel_address'],
];
$item_arr['tgt_type'] = 'Collection';
// propagate the event resource_id so that posts containing it are easily searchable in downstream copies
// of the item which have not stored the actual event. Required for Diaspora event federation as Diaspora
// event_participation messages refer to the event resource_id as a parent, while out own event attendance
// activities refer to the item message_id as the parent.
set_iconfig($item_arr, 'system', 'event_id', $event['event_hash'], true);
$post = item_store($item_arr, $deliver, $addAndSync);
/**
* @hooks event_created
* Called when an event record is created.
*/
Hook::call('event_created', $event['id']);
return $post;
}
}
function todo_stat()
{
return [
'' => t('Not specified'),
'NEEDS-ACTION' => t('Needs Action'),
'COMPLETED' => t('Completed'),
'IN-PROCESS' => t('In Process'),
'CANCELLED' => t('Cancelled')
];
}
function tasks_fetch($arr)
{
if (! local_channel()) {
return;
}
$ret = [];
$sql_extra = " and event_status != 'COMPLETED' ";
if ($arr && $arr['all'] == 1) {
$sql_extra = '';
}
$r = q(
"select * from event where etype = 'task' and uid = %d $sql_extra order by created desc",
intval(local_channel())
);
$ret['success'] = (($r) ? true : false);
if ($r) {
$ret['tasks'] = $r;
}
return $ret;
}
function cdav_principal($uri)
{
$r = q(
"SELECT uri FROM principals WHERE uri = '%s' LIMIT 1",
dbesc($uri)
);
if ($r[0]['uri'] === $uri) {
return true;
} else {
return false;
}
}
function cdav_perms($needle, $haystack, $check_rw = false)
{
if ($needle === 'calendar') {
return true;
}
foreach ($haystack as $item) {
if ($check_rw) {
if (is_array($item['id'])) {
if ($item['id'][0] == $needle && $item['share-access'] != 2) {
return $item['{DAV:}displayname'];
}
} else {
if ($item['id'] == $needle && $item['share-access'] != 2) {
return $item['{DAV:}displayname'];
}
}
} else {
if (is_array($item['id'])) {
if ($item['id'][0] == $needle) {
return $item['{DAV:}displayname'];
}
} else {
if ($item['id'] == $needle) {
return $item['{DAV:}displayname'];
}
}
}
}
return false;
}
function translate_type($type)
{
if (!$type) {
return;
}
$type = strtoupper($type);
$map = [
'CELL' => t('Mobile'),
'HOME' => t('Home'),
'HOME,VOICE' => t('Home, Voice'),
'HOME,FAX' => t('Home, Fax'),
'WORK' => t('Work'),
'WORK,VOICE' => t('Work, Voice'),
'WORK,FAX' => t('Work, Fax'),
'OTHER' => t('Other')
];
if (array_key_exists($type, $map)) {
return [$type, $map[$type]];
} else {
return [$type, t('Other') . ' (' . $type . ')'];
}
}
function cal_store_lowlevel($arr)
{
$store = [
'cal_aid' => ((array_key_exists('cal_aid', $arr)) ? $arr['cal_aid'] : 0),
'cal_uid' => ((array_key_exists('cal_uid', $arr)) ? $arr['cal_uid'] : 0),
'cal_hash' => ((array_key_exists('cal_hash', $arr)) ? $arr['cal_hash'] : ''),
'cal_name' => ((array_key_exists('cal_name', $arr)) ? $arr['cal_name'] : ''),
'uri' => ((array_key_exists('uri', $arr)) ? $arr['uri'] : ''),
'logname' => ((array_key_exists('logname', $arr)) ? $arr['logname'] : ''),
'pass' => ((array_key_exists('pass', $arr)) ? $arr['pass'] : ''),
'ctag' => ((array_key_exists('ctag', $arr)) ? $arr['ctag'] : ''),
'synctoken' => ((array_key_exists('synctoken', $arr)) ? $arr['synctoken'] : ''),
'cal_types' => ((array_key_exists('cal_types', $arr)) ? $arr['cal_types'] : ''),
];
return create_table_from_array('cal', $store);
}
Reference in a new issue View git blame Copy permalink