Fix some warnings

diff --git a/src/Protocol/ATProtocol/Actor.php b/src/Protocol/ATProtocol/Actor.php
index db310813b31d94419def646756dce21977b6c7a2..38da819dfc4186008bba7d267761e14a9b9b25f6 100755 (executable)
--- a/src/Protocol/ATProtocol/Actor.php
+++ b/src/Protocol/ATProtocol/Actor.php
@@ -145,9 +145,11 @@ class Actor
                                $fields['gsid'] = GServer::getRealID($fields['baseurl'], true);
                        }
 
-                       foreach ($directory->verificationMethod as $method) {
-                               if (!empty($method->publicKeyMultibase)) {
-                                       $fields['pubkey'] = $method->publicKeyMultibase;
+                       if (!empty($directory->verificationMethod)) {
+                               foreach ($directory->verificationMethod as $method) {
+                                       if (!empty($method->publicKeyMultibase)) {
+                                               $fields['pubkey'] = $method->publicKeyMultibase;
+                                       }
                                }
                        }
                }

diff --git a/src/Protocol/ATProtocol/Jetstream.php b/src/Protocol/ATProtocol/Jetstream.php
index cb37fabeec0ec32439409d2308540c641ca93ed2..8051e47126830e9bbcea35e0a50b15130c1bb934 100755 (executable)
--- a/src/Protocol/ATProtocol/Jetstream.php
+++ b/src/Protocol/ATProtocol/Jetstream.php
@@ -105,8 +105,12 @@ class Jetstream
                        $last_timeout = time();
                        while (true) {
                                try {
-                                       $message = $this->client->receive();
-                                       $data    = json_decode($message);
+                                       $message = @$this->client->receive();
+                                       if (empty($message)) {
+                                               $this->logger->notice('Empty message received');
+                                               break;
+                                       }
+                                       $data = json_decode($message);
                                        if (is_object($data)) {
                                                $timestamp = $data->time_us;
                                                $this->route($data);

diff --git a/src/Protocol/ActivityPub/Receiver.php b/src/Protocol/ActivityPub/Receiver.php
index 76f4d31d3d2f56a45cbf32ed7c1a4cd6814c957b..c217d491ca94848ef5b3416ff58956386ba35e52 100644 (file)
--- a/src/Protocol/ActivityPub/Receiver.php
+++ b/src/Protocol/ActivityPub/Receiver.php
@@ -2065,7 +2065,7 @@ class Receiver
                }
 
                foreach ($object_data['tags'] as $tag) {
-                       if (HTTPSignature::isValidContentType($tag['mediaType'] ?? '', $tag['href'])) {
+                       if (HTTPSignature::isValidContentType($tag['mediaType'] ?? '', $tag['href'] ?? '')) {
                                $object_data['quote-url'] = $tag['href'];
                        }
                }