X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=mod%2Fdfrn_notify.php;h=8b14fe49ba88a521ac24e3b371c10246469c7823;hb=b1bc8ebbfa6d978a48c98c278d1b6081cbcd4ea8;hp=90d3fb2b5d8a5917563f2309b3c3d25babb8a60f;hpb=a0f65ca7a1b1fbc1a2d0f823940211377fc6e13e;p=friendica.git diff --git a/mod/dfrn_notify.php b/mod/dfrn_notify.php index 90d3fb2b5d..8b14fe49ba 100644 --- a/mod/dfrn_notify.php +++ b/mod/dfrn_notify.php @@ -1,36 +1,52 @@ . + * + * The dfrn notify endpoint + * + * @see PDF with dfrn specs: https://github.com/friendica/friendica/blob/stable/spec/dfrn2.pdf */ use Friendica\App; -use Friendica\Core\Config; use Friendica\Core\Logger; use Friendica\Core\System; use Friendica\Database\DBA; +use Friendica\DI; use Friendica\Model\Contact; +use Friendica\Model\User; use Friendica\Protocol\DFRN; use Friendica\Protocol\Diaspora; +use Friendica\Util\Network; use Friendica\Util\Strings; -require_once 'include/items.php'; - function dfrn_notify_post(App $a) { Logger::log(__function__, Logger::TRACE); - $postdata = file_get_contents('php://input'); + $postdata = Network::postdata(); if (empty($_POST) || !empty($postdata)) { $data = json_decode($postdata); if (is_object($data)) { - $nick = defaults($a->argv, 1, ''); + $nick = $a->argv[1] ?? ''; $user = DBA::selectFirst('user', [], ['nickname' => $nick, 'account_expired' => false, 'account_removed' => false]); if (!DBA::isResult($user)) { - System::httpExit(500); + throw new \Friendica\Network\HTTPException\InternalServerErrorException(); } dfrn_dispatch_private($user, $postdata); } elseif (!dfrn_dispatch_public($postdata)) { @@ -39,16 +55,16 @@ function dfrn_notify_post(App $a) { } } - $dfrn_id = ((x($_POST,'dfrn_id')) ? Strings::removeTags(trim($_POST['dfrn_id'])) : ''); - $dfrn_version = ((x($_POST,'dfrn_version')) ? (float) $_POST['dfrn_version'] : 2.0); - $challenge = ((x($_POST,'challenge')) ? Strings::removeTags(trim($_POST['challenge'])) : ''); - $data = ((x($_POST,'data')) ? $_POST['data'] : ''); - $key = ((x($_POST,'key')) ? $_POST['key'] : ''); - $rino_remote = ((x($_POST,'rino')) ? intval($_POST['rino']) : 0); - $dissolve = ((x($_POST,'dissolve')) ? intval($_POST['dissolve']) : 0); - $perm = ((x($_POST,'perm')) ? Strings::removeTags(trim($_POST['perm'])) : 'r'); - $ssl_policy = ((x($_POST,'ssl_policy')) ? Strings::removeTags(trim($_POST['ssl_policy'])): 'none'); - $page = ((x($_POST,'page')) ? intval($_POST['page']) : 0); + $dfrn_id = (!empty($_POST['dfrn_id']) ? Strings::escapeTags(trim($_POST['dfrn_id'])) : ''); + $dfrn_version = (!empty($_POST['dfrn_version']) ? (float) $_POST['dfrn_version'] : 2.0); + $challenge = (!empty($_POST['challenge']) ? Strings::escapeTags(trim($_POST['challenge'])) : ''); + $data = $_POST['data'] ?? ''; + $key = $_POST['key'] ?? ''; + $rino_remote = (!empty($_POST['rino']) ? intval($_POST['rino']) : 0); + $dissolve = (!empty($_POST['dissolve']) ? intval($_POST['dissolve']) : 0); + $perm = (!empty($_POST['perm']) ? Strings::escapeTags(trim($_POST['perm'])) : 'r'); + $ssl_policy = (!empty($_POST['ssl_policy']) ? Strings::escapeTags(trim($_POST['ssl_policy'])): 'none'); + $page = (!empty($_POST['page']) ? intval($_POST['page']) : 0); $forum = (($page == 1) ? 1 : 0); $prv = (($page == 2) ? 1 : 0); @@ -128,7 +144,7 @@ function dfrn_notify_post(App $a) { System::xmlExit(0, 'relationship dissolved'); } - $rino = Config::get('system', 'rino_encrypt'); + $rino = DI::config()->get('system', 'rino_encrypt'); $rino = intval($rino); if (strlen($key)) { @@ -184,20 +200,20 @@ function dfrn_notify_post(App $a) { function dfrn_dispatch_public($postdata) { - $msg = Diaspora::decodeRaw([], $postdata, true); + $msg = Diaspora::decodeRaw($postdata, '', true); if (!$msg) { // We have to fail silently to be able to hand it over to the salmon parser return false; } // Fetch the corresponding public contact - $contact = Contact::getDetailsByAddr($msg['author'], 0); - if (!$contact) { + $contact_id = Contact::getIdForURL($msg['author']); + if (empty($contact_id)) { Logger::log('Contact not found for address ' . $msg['author']); System::xmlExit(3, 'Contact ' . $msg['author'] . ' not found'); } - $importer = DFRN::getImporter($contact['id']); + $importer = DFRN::getImporter($contact_id); // This should never fail if (empty($importer)) { @@ -214,7 +230,7 @@ function dfrn_dispatch_public($postdata) function dfrn_dispatch_private($user, $postdata) { - $msg = Diaspora::decodeRaw($user, $postdata); + $msg = Diaspora::decodeRaw($postdata, $user['prvkey'] ?? ''); if (!$msg) { System::xmlExit(4, 'Unable to parse message'); } @@ -247,16 +263,15 @@ function dfrn_dispatch_private($user, $postdata) function dfrn_notify_content(App $a) { - if (x($_GET,'dfrn_id')) { + if (!empty($_GET['dfrn_id'])) { /* * initial communication from external contact, $direction is their direction. * If this is a duplex communication, ours will be the opposite. */ - $dfrn_id = Strings::removeTags(trim($_GET['dfrn_id'])); - $dfrn_version = (float) $_GET['dfrn_version']; - $rino_remote = ((x($_GET,'rino')) ? intval($_GET['rino']) : 0); + $dfrn_id = Strings::escapeTags(trim($_GET['dfrn_id'])); + $rino_remote = (!empty($_GET['rino']) ? intval($_GET['rino']) : 0); $type = ""; $last_update = ""; @@ -283,7 +298,7 @@ function dfrn_notify_content(App $a) { $user = DBA::selectFirst('user', ['uid'], ['nickname' => $a->argv[1]]); if (!DBA::isResult($user)) { Logger::log('User not found for nickname ' . $a->argv[1]); - killme(); + exit(); } $condition = []; @@ -302,6 +317,7 @@ function dfrn_notify_content(App $a) { break; default: $status = 1; + $my_id = ''; break; } @@ -315,7 +331,7 @@ function dfrn_notify_content(App $a) { $importer = DFRN::getImporter($contact['id'], $user['uid']); if (empty($importer)) { Logger::log('No importer data found for user ' . $a->argv[1] . ' and contact ' . $dfrn_id); - killme(); + exit(); } Logger::log("Remote rino version: ".$rino_remote." for ".$importer["url"], Logger::DATA); @@ -343,7 +359,7 @@ function dfrn_notify_content(App $a) { $encrypted_id = bin2hex($encrypted_id); - $rino = Config::get('system', 'rino_encrypt'); + $rino = DI::config()->get('system', 'rino_encrypt'); $rino = intval($rino); Logger::log("Local rino version: ". $rino, Logger::DATA); @@ -354,7 +370,7 @@ function dfrn_notify_content(App $a) { $rino = $rino_remote; } - if (($importer['rel'] && ($importer['rel'] != Contact::SHARING)) || ($importer['page-flags'] == Contact::PAGE_COMMUNITY)) { + if (($importer['rel'] && ($importer['rel'] != Contact::SHARING)) || ($importer['page-flags'] == User::PAGE_FLAGS_COMMUNITY)) { $perm = 'rw'; } else { $perm = 'r'; @@ -370,8 +386,8 @@ function dfrn_notify_content(App $a) { . "\t" . '' . $perm . '' . "\r\n" . "\t" . '' . $encrypted_id . '' . "\r\n" . "\t" . '' . $challenge . '' . "\r\n" - . '' . "\r\n" ; + . '' . "\r\n"; - killme(); + exit(); } }