]> git.mxchange.org Git - friendica.git/commitdiff
Improved logging
authorMichael <heluecht@pirati.ca>
Sat, 12 Mar 2022 07:34:30 +0000 (07:34 +0000)
committerMichael <heluecht@pirati.ca>
Sat, 12 Mar 2022 07:34:30 +0000 (07:34 +0000)
src/Protocol/ActivityPub/Processor.php
src/Protocol/DFRN.php
src/Protocol/Diaspora.php

index 2e2d18b3916a34e601c36b85b06297aca312f63d..3778a0aa894271864bc265bbe74543d0e3690f34 100644 (file)
@@ -192,8 +192,8 @@ class Processor
        /**
         * Update an existing event
         *
-        * @param int $event_id 
-        * @param array $activity 
+        * @param int $event_id
+        * @param array $activity
         */
        private static function updateEvent(int $event_id, array $activity)
        {
@@ -593,7 +593,7 @@ class Processor
                        Logger::debug('Message is private - accepted', ['uri-id' => $item['uri-id'], 'guid' => $item['guid'], 'url' => $item['uri']]);
                        return true;
                }
-               
+
                if (!empty($activity['from-relay'])) {
                        // We check relay posts at another place. When it arrived here, the message is already checked.
                        Logger::debug('Message is a relay post that is already checked - accepted', ['uri-id' => $item['uri-id'], 'guid' => $item['guid'], 'url' => $item['uri']]);
@@ -616,7 +616,12 @@ class Processor
                }
 
                $tags = array_column(Tag::getByURIId($item['uri-id'], [Tag::HASHTAG]), 'name');
-               return Relay::isSolicitedPost($tags, $item['body'], $item['author-id'], $item['uri'], Protocol::ACTIVITYPUB);
+               if (Relay::isSolicitedPost($tags, $item['body'], $item['author-id'], $item['uri'], Protocol::ACTIVITYPUB)) {
+                       Logger::debug('Post is accepted because of the relay settings', ['uri-id' => $item['uri-id'], 'guid' => $item['guid'], 'url' => $item['uri']]);
+                       return true;
+               } else {
+                       return false;
+               }
        }
 
        /**
index a20d54fb6454ce2896c6eba4d4e9bc5f0663d6c5..db7eadac95aa9c601b86cf0fe16cd23a433df161 100644 (file)
@@ -1769,9 +1769,10 @@ class DFRN
         * Checks if an incoming message is wanted
         *
         * @param array $item
+        * @param array $imporer
         * @return boolean Is the message wanted?
         */
-       private static function isSolicitedMessage(array $item)
+       private static function isSolicitedMessage(array $item, array $importer)
        {
                if (DBA::exists('contact', ["`nurl` = ? AND `uid` != ? AND `rel` IN (?, ?)",
                        Strings::normaliseLink($item["author-link"]), 0, Contact::FRIEND, Contact::SHARING])) {
@@ -1779,8 +1780,23 @@ class DFRN
                        return true;
                }
 
+               if ($importer['importer_uid'] != 0) {
+                       Logger::debug('Message is directed to a user - accepted', ['uri-id' => $item['uri-id'], 'guid' => $item['guid'], 'url' => $item['uri'], 'importer' => $importer['importer_uid']]);
+                       return true;
+               }
+
+               if ($item['uri'] != $item['thr-parent']) {
+                       Logger::debug('Message is no parent - accepted', ['uri-id' => $item['uri-id'], 'guid' => $item['guid'], 'url' => $item['uri']]);
+                       return true;
+               }
+
                $tags = array_column(Tag::getByURIId($item['uri-id'], [Tag::HASHTAG]), 'name');
-               return Relay::isSolicitedPost($tags, $item['body'], $item['author-id'], $item['uri'], Protocol::DFRN);
+               if (Relay::isSolicitedPost($tags, $item['body'], $item['author-id'], $item['uri'], Protocol::DFRN)) {
+                       Logger::debug('Post is accepted because of the relay settings', ['uri' => $item['uri'], 'author' => $item["author-link"]]);
+                       return true;
+               } else {
+                       return false;
+               }
        }
 
        /**
@@ -1981,11 +1997,9 @@ class DFRN
                }
 
                // Check if the message is wanted
-               if (($importer['importer_uid'] == 0) && ($item['uri'] == $item['thr-parent'])) {
-                       if (!self::isSolicitedMessage($item)) {
-                               DBA::delete('item-uri', ['uri' => $item['uri']]);
-                               return 403;
-                       }
+               if (!self::isSolicitedMessage($item, $importer)) {
+                       DBA::delete('item-uri', ['uri' => $item['uri']]);
+                       return 403;
                }
 
                // Get the type of the item (Top level post, reply or remote reply)
index 7b2b03f55b588b44827f1621320aa94cc22b28d1..7ca01f9966abb4074558d87a13c2cc047b257c8c 100644 (file)
@@ -2639,7 +2639,12 @@ class Diaspora
                }
 
                $tags = array_column(Tag::getByURIId($uriid, [Tag::HASHTAG]), 'name');
-               return Relay::isSolicitedPost($tags, $body, $contact['id'], $url, Protocol::DIASPORA);
+               if (Relay::isSolicitedPost($tags, $body, $contact['id'], $url, Protocol::DIASPORA)) {
+                       Logger::debug('Post is accepted because of the relay settings', ['url' => $url, 'author' => $author]);
+                       return true;
+               } else {
+                       return false;
+               }
        }
 
        /**
@@ -2669,7 +2674,7 @@ class Diaspora
         * @param SimpleXMLElement $data      The message object
         * @param string           $xml       The original XML of the message
         * @param int              $direction Indicates if the message had been fetched or pushed
-        * 
+        *
         * @return int The message id of the newly created item
         * @throws \Friendica\Network\HTTPException\InternalServerErrorException
         * @throws \ImagickException