X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=mod%2Freceive.php;h=950bf0bd388e80ed20fd69541bd46b7e5765c99e;hb=a9ec56ace1756726517650d96192df5320f445fe;hp=c3738c1431c20e28221e24ad79bdc31cf96648e3;hpb=b465d1f30bf100f67614e0765c4c5f8588908e26;p=friendica.git diff --git a/mod/receive.php b/mod/receive.php index c3738c1431..950bf0bd38 100644 --- a/mod/receive.php +++ b/mod/receive.php @@ -12,20 +12,26 @@ require_once('include/diaspora.php'); function receive_post(&$a) { - if($a->argc != 3 || $a->argv[1] !== 'users') - http_status_exit(500); + $public = false; - logger('receive: raw input: ' . file_get_contents('php://input'), LOGGER_DATA); + if(($a->argc == 2) && ($a->argv[1] === 'public')) { + $public = true; + } + else { - $guid = $a->argv[2]; + if($a->argc != 3 || $a->argv[1] !== 'users') + http_status_exit(500); - $r = q("SELECT * FROM `user` WHERE `guid` = '%s' LIMIT 1", - dbesc($guid) - ); - if(! count($r)) - http_status_exit(500); + $guid = $a->argv[2]; - $importer = $r[0]; + $r = q("SELECT * FROM `user` WHERE `guid` = '%s' AND `account_expired` = 0 LIMIT 1", + dbesc($guid) + ); + if(! count($r)) + http_status_exit(500); + + $importer = $r[0]; + } // It is an application/x-www-form-urlencoded @@ -43,31 +49,13 @@ function receive_post(&$a) { if(! is_array($msg)) http_status_exit(500); + $ret = 0; + if($public) + diaspora_dispatch_public($msg); + else + $ret = diaspora_dispatch($importer,$msg); - $parsed_xml = parse_xml_string($msg['message'],false); - - $xmlbase = $parsed_xml->post; - - 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,$msg); - } - elseif($xmlbase->like) { - diaspora_like($importer,$xmlbase->like,$msg); - } - elseif($xmlbase->retraction) { - diaspora_retraction($importer,$xmlbase->retraction,$msg); - } - else { - logger('mod-diaspora: unknown message type: ' . print_r($xmlbase,true)); - } - - http_status_exit(200); + http_status_exit(($ret) ? $ret : 200); // NOTREACHED }