OpenCodeCo Enhancements (#64)

src/Listener/CommandListener.php

@@ -46,7 +46,6 @@ public function process(object $event): void
                 $process->exec($executable, $args);
             });
             $this->process->start();
-            sleep(1);
         }
     }
 }

src/MongoClient/Type/UpdateResult.php

@@ -12,6 +12,7 @@
 
 namespace Hyperf\GoTask\MongoClient\Type;
 
+use MongoDB\BSON\ObjectId;
 use MongoDB\BSON\Unserializable;
 
 class UpdateResult implements Unserializable
@@ -22,7 +23,7 @@ class UpdateResult implements Unserializable
 
     private int $upsertedCount;
 
-    private ?string $upsertedId;
+    private ObjectId|string|null $upsertedId;
 
     public function bsonUnserialize(array $data): void
     {
@@ -32,10 +33,7 @@ public function bsonUnserialize(array $data): void
         $this->upsertedId = $data['upsertedid'];
     }
 
-    /**
-     * @return mixed
-     */
-    public function getUpsertedId(): ?string
+    public function getUpsertedId(): ObjectId|string|null
     {
         return $this->upsertedId;
     }

src/Relay/CoroutineSocketRelay.php

@@ -118,12 +118,14 @@ public function connect(): bool
 
         $this->socket = $this->createSocket();
         try {
-            // Port type needs to be int, so we convert null to 0
-            if ($this->socket->connect($this->address, $this->port ?? 0) === false) {
-                throw new RelayException(sprintf('%s (%s)', $this->socket->errMsg, $this->socket->errCode));
-            }
+            \Hyperf\Support\retry(20, function(): void {
+                // Port type needs to be int, so we convert null to 0
+                if ($this->socket->connect($this->address, $this->port ?? 0) === false) {
+                    throw new RelayException(sprintf('%s (%s)', $this->socket->errMsg, $this->socket->errCode));
+                }
+            }, 100);
         } catch (Exception $e) {
-            throw new RelayException("unable to establish connection {$this}: {$e->getMessage()}", 0, $e);
+            throw new RelayException("unable to establish connection (20x) {$this}: {$e->getMessage()}", 0, $e);
         }
 
         return true;

src/Wrapper/LoggerWrapper.php

@@ -21,7 +21,7 @@ public function __construct(
     ) {
     }
 
-    public function log(array $payload): ?mixed
+    public function log(array $payload): mixed
     {
         $this->logger->log($payload['level'], $payload['message'], $payload['context']);
         return null;