Finish up connection implementation

Author: stevebauman

src/Connection/ConnectionInterface.php

@@ -128,22 +128,22 @@ public function appendMessage(string $folder, string $message, ?array $flags = n
     /**
      * Copy message set from current folder to other folder.
      */
-    public function copyMessage(string $folder, $from, ?int $to = null): ResponseCollection;
+    public function copyMessage(string $folder, $from, ?int $to = null): void;
 
     /**
      * Copy multiple messages to the target folder.
      */
-    public function copyManyMessages(array $messages, string $folder): ResponseCollection;
+    public function copyManyMessages(array $messages, string $folder): void;
 
     /**
      * Move a message set from current folder to another folder.
      */
-    public function moveMessage(string $folder, $from, ?int $to = null): ResponseCollection;
+    public function moveMessage(string $folder, $from, ?int $to = null): void;
 
     /**
      * Move multiple messages to the target folder.
      */
-    public function moveManyMessages(array $messages, string $folder): ResponseCollection;
+    public function moveManyMessages(array $messages, string $folder): void;
 
     /**
      * Create a new folder.

src/Connection/ImapConnection.php

@@ -117,7 +117,13 @@ public function folderStatus(string $folder = 'INBOX', array $arguments = ['MESS
      */
     public function createFolder(string $folder): ResponseCollection
     {
-        $this->send('CREATE', [$this->escapeString($folder)]);
+        $this->send('CREATE', [$this->escapeString($folder)], $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to create folder'));
+
+        return $this->result->responses()->untagged()->filter(
+            fn (UntaggedResponse $response) => $response->type()->is('LIST')
+        );
     }
 
     /**
@@ -193,52 +199,66 @@ public function appendMessage(string $folder, string $message, ?array $flags = n
 
         $tokens[] = $this->escapeString($message);
 
-        return $this->send('APPEND', $tokens);
+        $this->send('APPEND', $tokens, tag: $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to append message'));
+
+        return $this->result->responses()->untagged()->filter(
+            fn (UntaggedResponse $response) => $response->type()->is('LIST')
+        );
     }
 
     /**
      * {@inheritDoc}
      */
-    public function copyMessage(string $folder, $from, ?int $to = null): ResponseCollection
+    public function copyMessage(string $folder, $from, ?int $to = null): void
     {
-        return $this->send('UID COPY', [
+        $this->send('UID COPY', [
             $this->buildSet($from, $to),
             $this->escapeString($folder),
-        ]);
+        ], $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to copy message'));
     }
 
     /**
      * {@inheritDoc}
      */
-    public function copyManyMessages(array $messages, string $folder): ResponseCollection
+    public function copyManyMessages(array $messages, string $folder): void
     {
         $set = implode(',', $messages);
 
         $tokens = [$set, $this->escapeString($folder)];
 
-        $this->send('UID COPY', $tokens);
+        $this->send('UID COPY', $tokens, $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to copy messages'));
     }
 
     /**
      * {@inheritDoc}
      */
-    public function moveMessage(string $folder, $from, ?int $to = null): ResponseCollection
+    public function moveMessage(string $folder, $from, ?int $to = null): void
     {
         $set = $this->buildSet($from, $to);
 
-        return $this->send('UID MOVE', [$set, $this->escapeString($folder)]);
+        $this->send('UID MOVE', [$set, $this->escapeString($folder)], $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to move message'));
     }
 
     /**
      * {@inheritDoc}
      */
-    public function moveManyMessages(array $messages, string $folder): ResponseCollection
+    public function moveManyMessages(array $messages, string $folder): void
     {
         $set = implode(',', $messages);
 
         $tokens = [$set, $this->escapeString($folder)];
 
-        return $this->send('UID MOVE', $tokens);
+        $this->send('UID MOVE', $tokens, $tag);
+
+        $this->assertTaggedResponse($tag, fn () => new RuntimeException('Failed to move messages'));
     }
 
     /**