Friendica/friendica-github
1
0
Fork 0
mirror of https://github.com/friendica/friendica synced 2025-04-26 03:50:12 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #10515 from annando/event-handling

Browse source 
Improved event storing / improved performance when fetching events
This commit is contained in:
Hypolite Petovan 2021-07-19 04:00:53 -04:00 • committed by GitHub
commit 0dd94e8fd5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 95 additions and 98 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/Protocol/ActivityPub/Processor.php
View file

@ -396,6 +396,8 @@ class Processor
*
* @param array $activity Activity array
* @param array $item
*
* @return int event id
* @throws \Exception
*/
public static function createEvent($activity, $item)
@ -419,14 +421,16 @@ class Processor
$event['direction'] = $item['direction'];
$event['source'] = $item['source'];
$condition = ['uri' => $item['uri'], 'uid' => $item['uid']];
$ev = DBA::selectFirst('event', ['id'], $condition);
$ev = DBA::selectFirst('event', ['id'], ['uri' => $item['uri'], 'uid' => $item['uid']]);
if (DBA::isResult($ev)) {
$event['id'] = $ev['id'];
}
$event_id = Event::store($event);
Logger::info('Event was stored', ['id' => $event_id]);
return $event_id;
}
/**
@ -625,7 +629,9 @@ class Processor
}
if (($item['gravity'] != GRAVITY_ACTIVITY) && ($activity['object_type'] == 'as:Event')) {
self::createEvent($activity, $item);
$event_id = self::createEvent($activity, $item);
$item = Event::getItemArrayForId($event_id, $item);
}
$item_id = Item::insert($item);