add lsub subscribe unsubscribe commands

Author: Mikhail Sazanov

src/Commands/LsubCommand.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Sazanof\PhpImapSockets\Commands;
+
+class LsubCommand extends ListCommand
+{
+	protected string $name = 'LSUB';
+}

src/Commands/SubscribeCommand.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace Sazanof\PhpImapSockets\Commands;
+
+use Sazanof\PhpImapSockets\Traits\PrepareArgument;
+
+class SubscribeCommand extends Command
+{
+	protected string $name = 'SUBSCRIBE';
+
+	public function __construct(string $name)
+	{
+		$this->setArguments($name);
+	}
+}

src/Commands/UnsubscribeCommand.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace Sazanof\PhpImapSockets\Commands;
+
+use Sazanof\PhpImapSockets\Traits\PrepareArgument;
+
+class UnsubscribeCommand extends Command
+{
+	protected string $name = 'UNSUBSCRIBE';
+
+	public function __construct(string $name)
+	{
+		$this->setArguments($name);
+	}
+}

src/Connection.php

@@ -18,9 +18,12 @@
 use Sazanof\PhpImapSockets\Commands\ListCommand;
 use Sazanof\PhpImapSockets\Commands\LoginCommand;
 use Sazanof\PhpImapSockets\Commands\LogoutCommand;
+use Sazanof\PhpImapSockets\Commands\LsubCommand;
 use Sazanof\PhpImapSockets\Commands\NoopCommand;
 use Sazanof\PhpImapSockets\Commands\RenameCommand;
 use Sazanof\PhpImapSockets\Commands\SelectCommand;
+use Sazanof\PhpImapSockets\Commands\SubscribeCommand;
+use Sazanof\PhpImapSockets\Commands\UnsubscribeCommand;
 use Sazanof\PhpImapSockets\Exceptions\ConnectionException;
 use Sazanof\PhpImapSockets\Exceptions\MailboxOperationException;
 use Sazanof\PhpImapSockets\Exceptions\LoginFailedException;
@@ -322,6 +325,18 @@ public function listMailboxes(string $root = '', string $searchQuery = '*'): Mai
 		return new MailboxCollection($this->command(ListCommand::class, [$root, $searchQuery]), $this);
 	}
 
+	/**
+	 * @param string $root
+	 * @param string $searchQuery
+	 * @return MailboxCollection
+	 * @throws ConnectionException
+	 * @throws ReflectionException
+	 */
+	public function lsubMailboxes(string $root = '', string $searchQuery = '*'): MailboxCollection
+	{
+		return new MailboxCollection($this->command(LsubCommand::class, [$root, $searchQuery]), $this);
+	}
+
 	/**
 	 * @param string $path
 	 * @return Mailbox|null
@@ -373,7 +388,12 @@ public function noop(): bool
 		return $this->command(NoopCommand::class)->isOk();
 	}
 
-	public function examine(string $path)
+	/**
+	 * @param string $path
+	 * @return ExamineResponse
+	 * @throws ReflectionException
+	 */
+	public function examine(string $path): ExamineResponse
 	{
 		return $this->command(ExamineCommand::class, [$path])->asCollection(ExamineResponse::class);
 	}
@@ -423,4 +443,34 @@ public function renameMailbox(string $currentName, string $newName): bool
 		}
 		return $response->isOk();
 	}
+
+	/**
+	 * @param string $name
+	 * @return bool
+	 * @throws MailboxOperationException
+	 * @throws ReflectionException
+	 */
+	public function subscribeMailbox(string $name): bool
+	{
+		$response = $this->command(SubscribeCommand::class, [$name]);
+		if ($response->isNotOk()) {
+			throw new MailboxOperationException($response->lastLine());
+		}
+		return $response->isOk();
+	}
+
+	/**
+	 * @param string $name
+	 * @return bool
+	 * @throws MailboxOperationException
+	 * @throws ReflectionException
+	 */
+	public function unsubscribeMailbox(string $name): bool
+	{
+		$response = $this->command(UnsubscribeCommand::class, [$name]);
+		if ($response->isNotOk()) {
+			throw new MailboxOperationException($response->lastLine());
+		}
+		return $response->isOk();
+	}
 }

src/Models/Mailbox.php

@@ -147,7 +147,7 @@ public function create(string $folder, bool $insideCurrent = false): bool
 	 */
 	public function delete(string $folder, bool $insideCurrent = false): bool
 	{
-		$name = $insideCurrent ? $this->getPath() . $this->getDelimiter() . $folder : $folder;
+		$name = $insideCurrent ? $this->getOriginalPath() . $this->getDelimiter() . $folder : $folder;
 		return $this->getConnection()->deleteMailbox($name);
 	}
 
@@ -163,6 +163,24 @@ public function rename(string $currentName, string $newName): bool
 		return $this->getConnection()->renameMailbox($currentName, $newName);
 	}
 
+	/**
+	 * @param string|null $name
+	 * @return bool
+	 * @throws MailboxOperationException
+	 * @throws ReflectionException
+	 */
+	public function subscribe(string $name = null): bool
+	{
+		$name = is_null($name) ? $this->getOriginalPath() : $name;
+		return $this->getConnection()->subscribeMailbox($name);
+	}
+
+	public function unsubscribe(string $name = null): bool
+	{
+		$name = is_null($name) ? $this->getOriginalPath() : $name;
+		return $this->getConnection()->unsubscribeMailbox($name);
+	}
+
 	/**
 	 * @param SearchQuery $query
 	 * @return SearchResponse