X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=mod%2Freceive.php;h=ee15ebe8a379936e52e9d9c7153da4b4170b26f7;hb=a4ecf74a5d0559bfd71ce31b48eea36ba13efaeb;hp=1a99a9aeda390a6d0ad6244b50b48e78c173cbf7;hpb=c7197b99f919bee81fa2a8f46a3ef744c76bec6c;p=friendica.git diff --git a/mod/receive.php b/mod/receive.php index 1a99a9aeda..ee15ebe8a3 100644 --- a/mod/receive.php +++ b/mod/receive.php @@ -12,21 +12,38 @@ require_once('include/diaspora.php'); function receive_post(&$a) { - if($a->argc != 3 || $a->argv[1] !== 'users') + + $enabled = intval(get_config('system','diaspora_enabled')); + if(! $enabled) { + logger('mod-diaspora: disabled'); http_status_exit(500); + } - $guid = $a->argv[2]; + $public = false; - $r = q("SELECT * FROM `user` WHERE `guid` = '%s' LIMIT 1", - dbesc($guid) - ); - if(! count($r)) - http_status_exit(500); + if(($a->argc == 2) && ($a->argv[1] === 'public')) { + $public = true; + } + else { + + if($a->argc != 3 || $a->argv[1] !== 'users') + http_status_exit(500); - $importer = $r[0]; + $guid = $a->argv[2]; + + $r = q("SELECT * FROM `user` WHERE `guid` = '%s' AND `account_expired` = 0 AND `account_removed` = 0 LIMIT 1", + dbesc($guid) + ); + if(! count($r)) + http_status_exit(500); + + $importer = $r[0]; + } // It is an application/x-www-form-urlencoded + logger('mod-diaspora: receiving post', LOGGER_DEBUG); + $xml = urldecode($_POST['xml']); logger('mod-diaspora: new salmon ' . $xml, LOGGER_DATA); @@ -34,38 +51,26 @@ function receive_post(&$a) { if(! $xml) http_status_exit(500); - $msg = diaspora_decode($importer,$xml); + logger('mod-diaspora: message is okay', LOGGER_DEBUG); - logger('mod-diaspora: decoded msg: ' . $msg, LOGGER_DATA); + $msg = diaspora_decode($importer,$xml); - if(! $msg) - http_status_exit(500); + logger('mod-diaspora: decoded', LOGGER_DEBUG); + logger('mod-diaspora: decoded msg: ' . print_r($msg,true), LOGGER_DATA); - $parsed_xml = parse_xml_string($msg,false); + if(! is_array($msg)) + http_status_exit(500); - $xmlbase = $parsed_xml->post; + logger('mod-diaspora: dispatching', LOGGER_DEBUG); - if($xmlbase->request) { - diaspora_request($importer,$xmlbase->request); - } - elseif($xmlbase->status_message) { - diaspora_post($importer,$xmlbase->status_message); - } - elseif($xmlbase->comment) { - diaspora_comment($importer,$xmlbase->comment); - } - elseif($xmlbase->like) { - diaspora_like($importer,$xmlbase->like); - } - elseif($xmlbase->retraction) { - diaspora_retraction($importer,$xmlbase->retraction); - } - else { - logger('mod-diaspora: unknown message type: ' . print_r($xmlbase,true)); - } + $ret = 0; + if($public) + diaspora_dispatch_public($msg); + else + $ret = diaspora_dispatch($importer,$msg); - http_status_exit(200); + http_status_exit(($ret) ? $ret : 200); // NOTREACHED }