AP: We now transmit and process events
This commit is contained in:
parent
dbfe5c9d2a
commit
cbc417114d
|
@ -10,6 +10,7 @@ use Friendica\Model\Conversation;
|
||||||
use Friendica\Model\Contact;
|
use Friendica\Model\Contact;
|
||||||
use Friendica\Model\APContact;
|
use Friendica\Model\APContact;
|
||||||
use Friendica\Model\Item;
|
use Friendica\Model\Item;
|
||||||
|
use Friendica\Model\Event;
|
||||||
use Friendica\Model\User;
|
use Friendica\Model\User;
|
||||||
use Friendica\Content\Text\HTML;
|
use Friendica\Content\Text\HTML;
|
||||||
use Friendica\Util\JsonLD;
|
use Friendica\Util\JsonLD;
|
||||||
|
@ -172,6 +173,38 @@ class Processor
|
||||||
self::postItem($activity, $item);
|
self::postItem($activity, $item);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Create an event
|
||||||
|
*
|
||||||
|
* @param array $activity Activity array
|
||||||
|
*/
|
||||||
|
public static function createEvent($activity, $item)
|
||||||
|
{
|
||||||
|
$event['summary'] = $activity['name'];
|
||||||
|
$event['desc'] = $activity['content'];
|
||||||
|
$event['start'] = $activity['start-time'];
|
||||||
|
$event['finish'] = $activity['end-time'];
|
||||||
|
$event['nofinish'] = empty($event['finish']);
|
||||||
|
$event['location'] = $activity['location'];
|
||||||
|
$event['adjust'] = true;
|
||||||
|
$event['cid'] = $item['contact-id'];
|
||||||
|
$event['uid'] = $item['uid'];
|
||||||
|
$event['uri'] = $item['uri'];
|
||||||
|
$event['edited'] = $item['edited'];
|
||||||
|
$event['private'] = $item['private'];
|
||||||
|
$event['guid'] = $item['guid'];
|
||||||
|
$event['plink'] = $item['plink'];
|
||||||
|
|
||||||
|
$condition = ['uri' => $item['uri'], 'uid' => $item['uid']];
|
||||||
|
$ev = DBA::selectFirst('event', ['id'], $condition);
|
||||||
|
if (DBA::isResult($ev)) {
|
||||||
|
$event['id'] = $ev['id'];
|
||||||
|
}
|
||||||
|
|
||||||
|
$event_id = Event::store($event);
|
||||||
|
logger('Event '.$event_id.' was stored', LOGGER_DEBUG);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates an item post
|
* Creates an item post
|
||||||
*
|
*
|
||||||
|
@ -238,6 +271,10 @@ class Processor
|
||||||
$item['contact-id'] = Contact::getIdForURL($activity['author'], 0, true);
|
$item['contact-id'] = Contact::getIdForURL($activity['author'], 0, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if ($activity['object_type'] == 'as:Event') {
|
||||||
|
self::createEvent($activity, $item);
|
||||||
|
}
|
||||||
|
|
||||||
$item_id = Item::insert($item);
|
$item_id = Item::insert($item);
|
||||||
logger('Storing for user ' . $item['uid'] . ': ' . $item_id);
|
logger('Storing for user ' . $item['uid'] . ': ' . $item_id);
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,8 +22,13 @@ use Friendica\Util\DateTimeFormat;
|
||||||
*
|
*
|
||||||
* To-Do:
|
* To-Do:
|
||||||
* - Update (Image, Video, Article, Note)
|
* - Update (Image, Video, Article, Note)
|
||||||
* - Event
|
|
||||||
* - Undo Announce
|
* - Undo Announce
|
||||||
|
* - Accept Event
|
||||||
|
* - Reject Event
|
||||||
|
* - TentativeAccept Even
|
||||||
|
* - Undo Accept Event
|
||||||
|
* - Undo Reject Event
|
||||||
|
* - Undo TentativeAccept Event
|
||||||
*
|
*
|
||||||
* Check what this is meant to do:
|
* Check what this is meant to do:
|
||||||
* - Add
|
* - Add
|
||||||
|
@ -31,7 +36,7 @@ use Friendica\Util\DateTimeFormat;
|
||||||
* - Flag
|
* - Flag
|
||||||
* - Remove
|
* - Remove
|
||||||
* - Undo Block
|
* - Undo Block
|
||||||
* - Undo Accept (Problem: This could invert a contact accept or an event accept)
|
* - Undo Accept Person
|
||||||
*/
|
*/
|
||||||
class Receiver
|
class Receiver
|
||||||
{
|
{
|
||||||
|
@ -687,6 +692,8 @@ class Receiver
|
||||||
$object_data['summary'] = JsonLD::fetchElement($object, 'as:summary');
|
$object_data['summary'] = JsonLD::fetchElement($object, 'as:summary');
|
||||||
$object_data['content'] = JsonLD::fetchElement($object, 'as:content');
|
$object_data['content'] = JsonLD::fetchElement($object, 'as:content');
|
||||||
$object_data['source'] = JsonLD::fetchElement($object, 'as:source', 'as:content', 'as:mediaType', 'text/bbcode');
|
$object_data['source'] = JsonLD::fetchElement($object, 'as:source', 'as:content', 'as:mediaType', 'text/bbcode');
|
||||||
|
$object_data['start-time'] = JsonLD::fetchElement($object, 'as:startTime', '@value');
|
||||||
|
$object_data['end-time'] = JsonLD::fetchElement($object, 'as:endTime', '@value');
|
||||||
$object_data['location'] = JsonLD::fetchElement($object, 'as:location', 'as:name', '@type', 'as:Place');
|
$object_data['location'] = JsonLD::fetchElement($object, 'as:location', 'as:name', '@type', 'as:Place');
|
||||||
$object_data['latitude'] = JsonLD::fetchElement($object, 'as:location', 'as:latitude', '@type', 'as:Place');
|
$object_data['latitude'] = JsonLD::fetchElement($object, 'as:location', 'as:latitude', '@type', 'as:Place');
|
||||||
$object_data['latitude'] = JsonLD::fetchElement($object_data, 'latitude', '@value');
|
$object_data['latitude'] = JsonLD::fetchElement($object_data, 'latitude', '@value');
|
||||||
|
|
|
@ -33,11 +33,6 @@ require_once 'include/api.php';
|
||||||
* @brief ActivityPub Transmitter Protocol class
|
* @brief ActivityPub Transmitter Protocol class
|
||||||
*
|
*
|
||||||
* To-Do:
|
* To-Do:
|
||||||
*
|
|
||||||
* Missing object types:
|
|
||||||
* - Event
|
|
||||||
*
|
|
||||||
* Complicated object types:
|
|
||||||
* - Undo Announce
|
* - Undo Announce
|
||||||
*/
|
*/
|
||||||
class Transmitter
|
class Transmitter
|
||||||
|
@ -853,6 +848,32 @@ class Transmitter
|
||||||
return DBA::exists('term', $condition);
|
return DBA::exists('term', $condition);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates event data
|
||||||
|
*
|
||||||
|
* @param array $item
|
||||||
|
*
|
||||||
|
* @return array with the event data
|
||||||
|
*/
|
||||||
|
public static function createEvent($item)
|
||||||
|
{
|
||||||
|
$event = [];
|
||||||
|
$event['name'] = $item['event-summary'];
|
||||||
|
$event['content'] = BBCode::convert($item['event-desc'], false, 7);
|
||||||
|
$event['startTime'] = DateTimeFormat::utc($item['event-start'] . '+00:00', DateTimeFormat::ATOM);
|
||||||
|
|
||||||
|
if (!$item['event-nofinish']) {
|
||||||
|
$event['endTime'] = DateTimeFormat::utc($item['event-finish'] . '+00:00', DateTimeFormat::ATOM);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!empty($item['event-location'])) {
|
||||||
|
$item['location'] = $item['event-location'];
|
||||||
|
$event['location'] = self::createLocation($item);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $event;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a note/article object array
|
* Creates a note/article object array
|
||||||
*
|
*
|
||||||
|
@ -862,7 +883,9 @@ class Transmitter
|
||||||
*/
|
*/
|
||||||
public static function createNote($item)
|
public static function createNote($item)
|
||||||
{
|
{
|
||||||
if (!empty($item['title'])) {
|
if ($item['event-type'] == 'event') {
|
||||||
|
$type = 'Event';
|
||||||
|
} elseif (!empty($item['title'])) {
|
||||||
$type = 'Article';
|
$type = 'Article';
|
||||||
} else {
|
} else {
|
||||||
$type = 'Note';
|
$type = 'Note';
|
||||||
|
@ -910,10 +933,15 @@ class Transmitter
|
||||||
$body = self::removePictures($body);
|
$body = self::removePictures($body);
|
||||||
}
|
}
|
||||||
|
|
||||||
$regexp = "/[@!]\[url\=([^\[\]]*)\].*?\[\/url\]/ism";
|
if ($type == 'Event') {
|
||||||
$body = preg_replace_callback($regexp, ['self', 'mentionCallback'], $body);
|
$data = array_merge($data, self::createEvent($item));
|
||||||
|
} else {
|
||||||
|
$regexp = "/[@!]\[url\=([^\[\]]*)\].*?\[\/url\]/ism";
|
||||||
|
$body = preg_replace_callback($regexp, ['self', 'mentionCallback'], $body);
|
||||||
|
|
||||||
|
$data['content'] = BBCode::convert($body, false, 7);
|
||||||
|
}
|
||||||
|
|
||||||
$data['content'] = BBCode::convert($body, false, 7);
|
|
||||||
$data['source'] = ['content' => $item['body'], 'mediaType' => "text/bbcode"];
|
$data['source'] = ['content' => $item['body'], 'mediaType' => "text/bbcode"];
|
||||||
|
|
||||||
if (!empty($item['signed_text']) && ($item['uri'] != $item['thr-parent'])) {
|
if (!empty($item['signed_text']) && ($item['uri'] != $item['thr-parent'])) {
|
||||||
|
@ -923,7 +951,7 @@ class Transmitter
|
||||||
$data['attachment'] = self::createAttachmentList($item, $type);
|
$data['attachment'] = self::createAttachmentList($item, $type);
|
||||||
$data['tag'] = self::createTagList($item);
|
$data['tag'] = self::createTagList($item);
|
||||||
|
|
||||||
if (!empty($item['coord']) || !empty($item['location'])) {
|
if (empty($data['location']) && (!empty($item['coord']) || !empty($item['location']))) {
|
||||||
$data['location'] = self::createLocation($item);
|
$data['location'] = self::createLocation($item);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user