use Friendica\Model\User;
use Friendica\Protocol\DFRN;
use Friendica\Protocol\Diaspora;
-use Friendica\Util\Strings;
use Friendica\Util\Network;
+use Friendica\Util\Strings;
function dfrn_notify_post(App $a) {
Logger::log(__function__, Logger::TRACE);
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;
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');
}
+++ /dev/null
-<?php
-/**
- * @file mod/receive.php
- * @brief Diaspora endpoint
- */
-
-use Friendica\App;
-use Friendica\Core\Config;
-use Friendica\Core\Logger;
-use Friendica\Core\System;
-use Friendica\Database\DBA;
-use Friendica\Protocol\Diaspora;
-use Friendica\Util\Network;
-
-/**
- * @param App $a App
- * @return void
- * @throws ImagickException
- * @throws \Friendica\Network\HTTPException\InternalServerErrorException
- */
-function receive_post(App $a)
-{
- $enabled = intval(Config::get('system', 'diaspora_enabled'));
- if (!$enabled) {
- Logger::log('mod-diaspora: disabled');
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
-
- if (($a->argc == 2) && ($a->argv[1] === 'public')) {
- $public = true;
- $importer = [];
- } else {
- $public = false;
-
- if ($a->argc != 3 || $a->argv[1] !== 'users') {
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
- $guid = $a->argv[2];
-
- $importer = DBA::selectFirst('user', [], ['guid' => $guid, 'account_expired' => false, 'account_removed' => false]);
- if (!DBA::isResult($importer)) {
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
- }
-
- // It is an application/x-www-form-urlencoded
-
- Logger::log('mod-diaspora: receiving post', Logger::DEBUG);
-
- if (empty($_POST['xml'])) {
- $postdata = Network::postdata();
- if ($postdata == '') {
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
-
- Logger::log('mod-diaspora: message is in the new format', Logger::DEBUG);
- $msg = Diaspora::decodeRaw($importer, $postdata);
- } else {
- $xml = urldecode($_POST['xml']);
-
- Logger::log('mod-diaspora: decode message in the old format', Logger::DEBUG);
- $msg = Diaspora::decode($importer, $xml);
-
- if ($public && !$msg) {
- Logger::log('mod-diaspora: decode message in the new format', Logger::DEBUG);
- $msg = Diaspora::decodeRaw($importer, $xml);
- }
- }
-
- Logger::log('mod-diaspora: decoded', Logger::DEBUG);
-
- Logger::log('mod-diaspora: decoded msg: ' . print_r($msg, true), Logger::DATA);
-
- if (!is_array($msg)) {
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
-
- Logger::log('mod-diaspora: dispatching', Logger::DEBUG);
-
- $ret = true;
- if ($public) {
- Diaspora::dispatchPublic($msg);
- } else {
- $ret = Diaspora::dispatch($importer, $msg);
- }
-
- if ($ret) {
- throw new \Friendica\Network\HTTPException\OKException();
- } else {
- throw new \Friendica\Network\HTTPException\InternalServerErrorException();
- }
-}
use Friendica\Core\System;
use Friendica\Core\Worker;
use Friendica\Database\DBA;
-use Friendica\Model\Photo;
use Friendica\Model\TwoFactor\AppSpecificPassword;
use Friendica\Object\Image;
use Friendica\Util\Crypto;
return DBA::selectFirst('user', $fields, ['uid' => $uid]);
}
+ /**
+ * Returns a user record based on it's GUID
+ *
+ * @param string $guid The guid of the user
+ * @param array $fields The fields to retrieve
+ * @param bool $active True, if only active records are searched
+ *
+ * @return array|boolean User record if it exists, false otherwise
+ * @throws Exception
+ */
+ public static function getByGuid(string $guid, array $fields = [], bool $active = true)
+ {
+ if ($active) {
+ $cond = ['guid' => $guid, 'account_expired' => false, 'account_removed' => false];
+ } else {
+ $cond = ['guid' => $guid];
+ }
+
+ return DBA::selectFirst('user', $fields, $cond);
+ }
+
/**
* @param string $nickname
* @param array $fields
--- /dev/null
+<?php
+
+namespace Friendica\Module\Diaspora;
+
+use Friendica\App;
+use Friendica\BaseModule;
+use Friendica\Core\Config\Configuration;
+use Friendica\Model\User;
+use Friendica\Network\HTTPException;
+use Friendica\Protocol\Diaspora;
+use Friendica\Util\Network;
+use Psr\Log\LoggerInterface;
+
+/**
+ * This module is part of the Diaspora protocol.
+ * It is used for receiving single posts either for public or for a specific user.
+ */
+class Receive extends BaseModule
+{
+ /** @var LoggerInterface */
+ private static $logger;
+
+ public static function init()
+ {
+ /** @var LoggerInterface $logger */
+ self::$logger = self::getClass(LoggerInterface::class);
+ }
+
+ public static function post()
+ {
+ /** @var Configuration $config */
+ $config = self::getClass(Configuration::class);
+
+ $enabled = $config->get('system', 'diaspora_enabled', false);
+ if (!$enabled) {
+ self::$logger->info('Diaspora disabled.');
+ throw new HTTPException\InternalServerErrorException('Diaspora disabled.');
+ }
+
+ /** @var App\Arguments $args */
+ $args = self::getClass(App\Arguments::class);
+
+ $type = $args->get(1);
+
+ switch ($type) {
+ case 'public':
+ self::receivePublic();
+ break;
+ case 'users':
+ self::receiveUser($args->get(2));
+ break;
+ default:
+ self::$logger->info('Wrong call.');
+ throw new HTTPException\BadRequestException('wrong call.');
+ break;
+ }
+ }
+
+ /**
+ * Receive a public Diaspora posting
+ *
+ * @throws HTTPException\InternalServerErrorException
+ * @throws \ImagickException
+ */
+ private static function receivePublic()
+ {
+ self::$logger->info('Diaspora: Receiving post.');
+
+ $msg = self::decodePost();
+
+ self::$logger->info('Diaspora: Dispatching.');
+
+ Diaspora::dispatchPublic($msg);
+ }
+
+ /**
+ * Receive a Diaspora posting for a user
+ *
+ * @param string $guid The GUID of the importer
+ *
+ * @throws HTTPException\InternalServerErrorException
+ * @throws \ImagickException
+ */
+ private static function receiveUser(string $guid)
+ {
+ self::$logger->info('Diaspora: Receiving post.');
+
+ $importer = User::getByGuid($guid);
+
+ $msg = self::decodePost(false, $importer['prvkey'] ?? '');
+
+ self::$logger->info('Diaspora: Dispatching.');
+
+ if (Diaspora::dispatch($importer, $msg)) {
+ throw new HTTPException\OKException();
+ } else {
+ throw new HTTPException\InternalServerErrorException();
+ }
+ }
+
+ /**
+ * Decodes a Diaspora message based on the posted data
+ *
+ * @param string $privKey The private key of the importer
+ * @param bool $public True, if the post is public
+ *
+ * @return array
+ * @throws HTTPException\InternalServerErrorException
+ * @throws \ImagickException
+ */
+ private static function decodePost(bool $public = true, string $privKey = '')
+ {
+ if (empty($_POST['xml'])) {
+
+ $postdata = Network::postdata();
+
+ if (empty($postdata)) {
+ throw new HTTPException\InternalServerErrorException('Missing postdata.');
+ }
+
+ self::$logger->info('Diaspora: Message is in the new format.');
+
+ $msg = Diaspora::decodeRaw($postdata, $privKey);
+ } else {
+
+ $xml = urldecode($_POST['xml']);
+
+ self::$logger->info('Diaspora: Decode message in the old format.');
+ $msg = Diaspora::decode($xml, $privKey);
+
+ if ($public && !$msg) {
+ self::$logger->info('Diaspora: Decode message in the new format.');
+ $msg = Diaspora::decodeRaw($xml, $privKey);
+ }
+ }
+
+ self::$logger->info('Diaspora: Post decoded.');
+ self::$logger->debug('Diaspora: Decoded message.', ['msg' => print_r($msg, true)]);
+
+ if (!is_array($msg)) {
+ throw new HTTPException\InternalServerErrorException('Message is not an array.');
+ }
+
+ return $msg;
+ }
+}
/**
* @brief: Decodes incoming Diaspora message in the new format
*
- * @param array $importer Array of the importer user
* @param string $raw raw post message
+ * @param string $privKey The private key of the importer
* @param boolean $no_exit Don't do an http exit on error
*
* @return array
* @throws \Friendica\Network\HTTPException\InternalServerErrorException
* @throws \ImagickException
*/
- public static function decodeRaw(array $importer, $raw, $no_exit = false)
+ public static function decodeRaw(string $raw, string $privKey = '', bool $no_exit = false)
{
$data = json_decode($raw);
$ciphertext = base64_decode($data->encrypted_magic_envelope);
$outer_key_bundle = '';
- @openssl_private_decrypt($encrypted_aes_key_bundle, $outer_key_bundle, $importer['prvkey']);
+ @openssl_private_decrypt($encrypted_aes_key_bundle, $outer_key_bundle, $privKey);
$j_outer_key_bundle = json_decode($outer_key_bundle);
if (!is_object($j_outer_key_bundle)) {
/**
* @brief: Decodes incoming Diaspora message in the deprecated format
*
- * @param array $importer Array of the importer user
* @param string $xml urldecoded Diaspora salmon
+ * @param string $privKey The private key of the importer
*
* @return array
* 'message' -> decoded Diaspora XML message
* @throws \Friendica\Network\HTTPException\InternalServerErrorException
* @throws \ImagickException
*/
- public static function decode(array $importer, $xml)
+ public static function decode(string $xml, string $privKey = '')
{
$public = false;
$basedom = XML::parseString($xml);
$author_link = str_replace('acct:', '', $children->header->author_id);
} else {
// This happens with posts from a relais
- if (!$importer) {
+ if (empty($privKey)) {
Logger::log("This is no private post in the old format", Logger::DEBUG);
return false;
}
$ciphertext = base64_decode($encrypted_header->ciphertext);
$outer_key_bundle = '';
- openssl_private_decrypt($encrypted_aes_key_bundle, $outer_key_bundle, $importer['prvkey']);
+ openssl_private_decrypt($encrypted_aes_key_bundle, $outer_key_bundle, $privKey);
$j_outer_key_bundle = json_decode($outer_key_bundle);
'/saved/remove' => [Module\Search\Saved::class, [R::GET]],
],
+ '/receive' => [
+ '/public' => [Module\Diaspora\Receive::class, [R::POST]],
+ '/users/{guid}' => [Module\Diaspora\Receive::class, [R::POST]],
+ ],
+
'/settings' => [
'/2fa' => [
'[/]' => [Module\Settings\TwoFactor\Index::class, [R::GET, R::POST]],
projects / friendica.git / commitdiff