strk/friendica
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Receiving was tested, sending is implemented and tested as well, currently unused

Browse source
This commit is contained in:
Michael 2018-04-02 12:53:48 +00:00
parent f51a254ed0
commit 0594f13c35
3 changed files with 42 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
mod/dfrn_notify.php
View file

@ -32,10 +32,10 @@ function dfrn_notify_post(App $a) {
$msg = Diaspora::decodeRaw($user, $postdata); $msg = Diaspora::decodeRaw($user, $postdata);
// Check if the user has got this contact // Check if the user has got this contact
$cid = getIdForURL($msg['author'], $user['uid']); $cid = Contact::getIdForURL($msg['author'], $user['uid']);
if (!$cid) { if (!$cid) {
// Otherwise there should be a public contact // Otherwise there should be a public contact
$cid = getIdForURL($msg['author']); $cid = Contact::getIdForURL($msg['author']);
if (!$cid) { if (!$cid) {
logger('Contact not found for address ' . $msg['author']); logger('Contact not found for address ' . $msg['author']);
System::xmlExit(3, 'Contact not found'); System::xmlExit(3, 'Contact not found');
@ -59,7 +59,7 @@ function dfrn_notify_post(App $a) {
// Now we should be able to import it // Now we should be able to import it
$ret = DFRN::import($msg['message'], $importer); $ret = DFRN::import($msg['message'], $importer);
System::xmlExit($ret, 'Processed'); System::xmlExit($ret, 'Done');
} else { } else {
require_once 'mod/salmon.php'; require_once 'mod/salmon.php';
salmon_post($a, $postdata); salmon_post($a, $postdata);

38
src/Protocol/DFRN.php
View file

@ -31,6 +31,7 @@ use Friendica\Util\Crypto;
use Friendica\Util\DateTimeFormat; use Friendica\Util\DateTimeFormat;
use Friendica\Util\Network; use Friendica\Util\Network;
use Friendica\Util\XML; use Friendica\Util\XML;
use Friendica\Protocol\Diaspora;
use dba; use dba;
use DOMDocument; use DOMDocument;
use DOMXPath; use DOMXPath;
@ -1368,6 +1369,43 @@ class DFRN
return intval($res->status); return intval($res->status);
} }
/**
* @brief Delivers items to the contacts via the Diaspora transport layer
*
* @param array $owner Owner record
* @param array $contact Contact record of the receiver
* @param array $items Items that will be transmitted
*
* @return int HTTP Deliver status
*/
public static function buildAndTransmit($owner, $contact, $items)
{
$a = get_app();
// Currently disabled, at first we will not use the batch delivery
// $public_batch = !$items[0]['private'];
$public_batch = false;
$msg = DFRN::entries($items, $owner);
$fcontact = Diaspora::personByHandle($contact['addr']);
if (empty($fcontact)) {
logger("unable to find contact details");
return;
}
$envelope = Diaspora::buildMessage($msg, $owner, $contact, $owner['uprvkey'], $fcontact['pubkey'], $public_batch);
$dest_url = ($public_batch ? $fcontact["batch"] : $contact["notify"]);
$content_type = ($public_batch ? "application/magic-envelope+xml" : "application/json");
$ret = Network::post($dest_url, $envelope, ["Content-Type: ".$content_type]);
/// @ToDo: Add better treating of return codes
return $a->get_curl_code();
}
/** /**
* @brief Add new birthday event for this person * @brief Add new birthday event for this person
* *

2
src/Protocol/Diaspora.php
View file

@ -3205,7 +3205,7 @@ class Diaspora
* *
* @return string The message that will be transmitted to other servers * @return string The message that will be transmitted to other servers
*/ */
private static function buildMessage($msg, $user, $contact, $prvkey, $pubkey, $public = false) public static function buildMessage($msg, $user, $contact, $prvkey, $pubkey, $public = false)
{ {
// The message is put into an envelope with the sender's signature // The message is put into an envelope with the sender's signature
$envelope = self::buildMagicEnvelope($msg, $user); $envelope = self::buildMagicEnvelope($msg, $user);