X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModule%2FInbox.php;h=7d25c8b71d39488a8b70b40e8abc3f673bcbef25;hb=bb1517a74c6252a89812929e98910d9e293664a9;hp=891211186aa9d667f7d59c4ff1ff2976e08429bb;hpb=c083ae047c4259dcfa1c61a3795679bbf1b08d8c;p=friendica.git diff --git a/src/Module/Inbox.php b/src/Module/Inbox.php index 891211186a..7d25c8b71d 100644 --- a/src/Module/Inbox.php +++ b/src/Module/Inbox.php @@ -1,53 +1,73 @@ . + * */ + namespace Friendica\Module; use Friendica\BaseModule; -use Friendica\Protocol\ActivityPub; -use Friendica\Core\System; +use Friendica\Core\Logger; use Friendica\Database\DBA; +use Friendica\DI; +use Friendica\Protocol\ActivityPub; use Friendica\Util\HTTPSignature; +use Friendica\Util\Network; /** * ActivityPub Inbox */ class Inbox extends BaseModule { - public static function init() + public static function rawContent(array $parameters = []) { - $a = self::getApp(); + $a = DI::app(); - $postdata = file_get_contents('php://input'); + $postdata = Network::postdata(); if (empty($postdata)) { - System::httpExit(400); + throw new \Friendica\Network\HTTPException\BadRequestException(); } - if (HTTPSignature::getSigner($postdata, $_SERVER)) { - $filename = 'signed-activitypub'; - } else { - $filename = 'failed-activitypub'; + if (DI::config()->get('debug', 'ap_inbox_log')) { + if (HTTPSignature::getSigner($postdata, $_SERVER)) { + $filename = 'signed-activitypub'; + } else { + $filename = 'failed-activitypub'; + } + $tempfile = tempnam(get_temppath(), $filename); + file_put_contents($tempfile, json_encode(['argv' => $a->argv, 'header' => $_SERVER, 'body' => $postdata], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE)); + Logger::log('Incoming message stored under ' . $tempfile); } - $tempfile = tempnam(get_temppath(), $filename); - file_put_contents($tempfile, json_encode(['argv' => $a->argv, 'header' => $_SERVER, 'body' => $postdata], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE)); - - logger('Incoming message stored under ' . $tempfile); - + // @TODO: Replace with parameter from router if (!empty($a->argv[1])) { $user = DBA::selectFirst('user', ['uid'], ['nickname' => $a->argv[1]]); if (!DBA::isResult($user)) { - System::httpExit(404); + throw new \Friendica\Network\HTTPException\NotFoundException(); } $uid = $user['uid']; } else { $uid = 0; } - ActivityPub::processInbox($postdata, $_SERVER, $uid); + ActivityPub\Receiver::processInbox($postdata, $_SERVER, $uid); - System::httpExit(202); + throw new \Friendica\Network\HTTPException\AcceptedException(); } }