$item['protocol'] = Conversation::PARCEL_ACTIVITYPUB;
$item['conversation-href'] = $activity['context'] ?? '';
$item['conversation-uri'] = $activity['conversation'] ?? '';
+
+ if (isset($activity['push'])) {
+ $item['direction'] = $activity['push'] ? Conversation::PUSH : Conversation::PULL;
+ }
}
$isForum = false;
$ldactivity['thread-completion'] = true;
- ActivityPub\Receiver::processActivity($ldactivity);
+ ActivityPub\Receiver::processActivity($ldactivity, json_encode($activity));
+
Logger::notice('Activity had been fetched and processed.', ['url' => $url, 'object' => $activity['id']]);
return $activity['id'];