chore(deps): update dependency symfony/mime to v7.4.18

Signed-off-by: Sebastian Krupinski <krupinski01@gmail.com>

composer.lock

@@ -273,16 +273,16 @@
         },
         {
             "name": "symfony/mime",
-            "version": "v7.4.15",
+            "version": "v7.4.18",
             "source": {
                 "type": "git",
                 "url": "https://github.com/symfony/mime.git",
-                "reference": "0c1daf58bc931628df0bea26840d1fc8b9a3d34b"
+                "reference": "bf328d82105831db3e409195db0540ff57f27c80"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/symfony/mime/zipball/0c1daf58bc931628df0bea26840d1fc8b9a3d34b",
+                "url": "https://api.github.com/repos/symfony/mime/zipball/bf328d82105831db3e409195db0540ff57f27c80",
-                "reference": "0c1daf58bc931628df0bea26840d1fc8b9a3d34b",
+                "reference": "bf328d82105831db3e409195db0540ff57f27c80",
                 "shasum": ""
             },
             "require": {
@@ -306,7 +306,7 @@
                 "symfony/process": "^6.4|^7.0|^8.0",
                 "symfony/property-access": "^6.4|^7.0|^8.0",
                 "symfony/property-info": "^6.4|^7.0|^8.0",
-                "symfony/serializer": "^6.4.3|^7.0.3|^8.0"
+                "symfony/serializer": "^6.4.44|^7.4.17|^8.1.5"
             },
             "type": "library",
             "autoload": {
@@ -338,7 +338,7 @@
                 "mime-type"
             ],
             "support": {
-                "source": "https://github.com/symfony/mime/tree/v7.4.15"
+                "source": "https://github.com/symfony/mime/tree/v7.4.18"
             },
             "funding": [
                 {
@@ -358,7 +358,7 @@
                     "type": "tidelift"
                 }
             ],
-            "time": "2026-07-29T07:59:49+00:00"
+            "time": "2026-08-22T09:04:42+00:00"
         },
         {
             "name": "symfony/polyfill-intl-idn",

lib/Listeners/UserEventListener.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace KTXM\ProviderImap\Listeners;
+
+use KTXC\User\Event\UserCreatedEvent;
+use KTXC\User\Event\UserDeletingEvent;
+use KTXM\ProviderImap\Stores\MessageStore;
+use KTXM\ProviderImap\Stores\ServiceStore;
+
+final class UserEventListener
+{
+    public function __construct(
+        private readonly ServiceStore $serviceStore,
+        private readonly MessageStore $messageStore,
+    ) {
+    }
+
+    public function onUserCreated(UserCreatedEvent $event): void
+    {
+        // TODO: implement provisioning configuration
+    }
+
+    public function onUserDeleting(UserDeletingEvent $event): void
+    {
+        $tenantId = $event->tenantIdentifier();
+        $userId = $event->userIdentifier();
+
+        foreach (array_keys($this->serviceStore->list($tenantId, $userId)) as $serviceId) {
+            $this->messageStore->deleteByServiceId((string) $serviceId);
+        }
+
+        $this->serviceStore->deleteByUser($tenantId, $userId);
+    }
+}

lib/Module.php

@@ -10,6 +10,10 @@ declare(strict_types=1);
 namespace KTXM\ProviderImap;
 
 use KTXC\Resource\ProviderManager;
+use KTXC\User\Event\UserCreatedEvent;
+use KTXC\User\Event\UserDeletingEvent;
+use KTXF\Event\DeliveryMode;
+use KTXF\Event\EventListenerRegistrarInterface;
 use KTXF\Module\ModuleBrowserInterface;
 use KTXF\Module\ModuleConsoleInterface;
 use KTXF\Module\ModuleInstanceAbstract;
@@ -18,6 +22,7 @@ use KTXM\ProviderImap\Console\ConnectCommand;
 use KTXM\ProviderImap\Console\DiscoverCommand;
 use KTXM\ProviderImap\Console\DisconnectCommand;
 use KTXM\ProviderImap\Console\TestCommand;
+use KTXM\ProviderImap\Listeners\UserEventListener;
 use KTXM\ProviderImap\Providers\Provider as MailProvider;
 
 /**
@@ -29,6 +34,7 @@ class Module extends ModuleInstanceAbstract implements ModuleConsoleInterface, M
 {
     public function __construct(
         private readonly ProviderManager $providerManager,
+        private readonly EventListenerRegistrarInterface $events,
     ) {}
 
     public function handle(): string
@@ -69,6 +75,10 @@ class Module extends ModuleInstanceAbstract implements ModuleConsoleInterface, M
 
     public function boot(): void
     {
+        // Register listeners
+        $this->events->listen($this->handle(), UserCreatedEvent::class, UserEventListener::class, 'onUserCreated', DeliveryMode::Deferred);
+        $this->events->listen($this->handle(), UserDeletingEvent::class, UserEventListener::class, 'onUserDeleting', DeliveryMode::Deferred);
+        // Register providers
         $this->providerManager->register(ProviderInterface::TYPE_MAIL, 'imap', MailProvider::class);
     }
 

lib/Providers/EntityResource.php

@@ -11,6 +11,7 @@ namespace KTXM\ProviderImap\Providers;
 
 use KTXM\ProviderImap\Client\Message;
 use KTXF\Mail\Entity\EntityMutableAbstract;
+use KTXF\Mail\Object\MessagePropertiesMutableInterface;
 
 /**
  * Mail Entity Resource Implementation
@@ -42,6 +43,26 @@ class EntityResource extends EntityMutableAbstract {
         return $this;
     }
 
+    /**
+     * Populate an entity returned by a create or replacement operation.
+     */
+    public function fromMutation(
+        string $mailbox,
+        string|int $identifier,
+        MessagePropertiesMutableInterface $properties,
+    ): static {
+        $this->data['collection'] = $mailbox;
+        $this->data['identifier'] = $identifier;
+
+        if ($properties instanceof MessageProperties) {
+            $this->setProperties($properties);
+        } else {
+            $this->getProperties()->jsonDeserialize($properties->jsonSerialize());
+        }
+
+        return $this;
+    }
+
     /**
      * @inheritDoc
      */

lib/Providers/Service.php

@@ -102,8 +102,8 @@ class Service implements ServiceBaseInterface, ServiceMutableInterface, ServiceC
         ],
         self::CAPABILITY_ENTITY_FETCH => true,
         self::CAPABILITY_ENTITY_EXTANT => true,
-        self::CAPABILITY_ENTITY_CREATE => false,
+        self::CAPABILITY_ENTITY_CREATE => true,
-        self::CAPABILITY_ENTITY_MODIFY => false,
+        self::CAPABILITY_ENTITY_MODIFY => true,
         self::CAPABILITY_ENTITY_PATCH => true,
         self::CAPABILITY_ENTITY_DELETE => true,
         self::CAPABILITY_ENTITY_MOVE => true,
@@ -675,10 +675,27 @@ class Service implements ServiceBaseInterface, ServiceMutableInterface, ServiceC
             // ignore — the message was already delivered
         }
 
+        // Best-effort: IMAP has no native "submit existing draft" operation, so the
+        // message above was always sent fresh. If it originated from a synced draft,
+        // remove the now-superseded draft UID. A failure here must not turn a
+        // successful delivery into an error; the draft is simply left for a later
+        // discard or retry.
+        if ($source !== null
+            && $source->provider() === $this->provider()
+            && $source->service() === $this->identifier()) {
+            try {
+                $this->initialize();
+                $this->remoteService->entityDestroy($source->collection(), (int) $source->entity());
+            } catch (\Throwable) {
+                // ignore — the message was already delivered
+            }
+        }
+
         return new EntitySubmitResult(
             disposition: EntitySubmitResult::DISPOSITION_SENT,
             transportId: $queueId !== '' ? $queueId : null,
             sentEntity: $sentEntity,
+            sourceDraft: $source instanceof EntityIdentifier ? $source : null,
         );
     }
 
@@ -701,12 +718,45 @@ class Service implements ServiceBaseInterface, ServiceMutableInterface, ServiceC
 
     public function entityCreate(CollectionIdentifier $target, MessagePropertiesMutableInterface $properties, array $options = []): EntityResource
     {
-        throw new \RuntimeException('Entity creation is not supported in this service');
+        if ($target->provider() !== $this->provider() || (string)$target->service() !== (string)$this->identifier()) {
+            throw new \InvalidArgumentException('Target collection does not belong to this service: ' . (string)$target);
+        }
+
+        $this->initialize();
+
+        [$nativeMessage, $nativeFlags] = $this->messagePayload($properties, $options);
+        $created = $this->remoteService->entityCreate(
+            (string)$target->collection(),
+            $nativeMessage,
+            $nativeFlags,
+        );
+        if ($created === null || $created <= 0) {
+            throw new \RuntimeException('IMAP APPEND did not return a valid UID');
+        }
+
+        return $this->entityFresh()->fromMutation((string)$target->collection(), $created, $properties);
     }
 
     public function entityModify(EntityIdentifier $target, MessagePropertiesMutableInterface $properties): EntityResource
     {
-        throw new \RuntimeException('Entity modification is not supported in this service');
+        if ($target->provider() !== $this->provider() || (string)$target->service() !== (string)$this->identifier()) {
+            throw new \InvalidArgumentException('Target entity does not belong to this service: ' . (string)$target);
+        }
+
+        $this->initialize();
+
+        [$nativeMessage, $nativeFlags] = $this->messagePayload($properties);
+        $modified = $this->remoteService->entityReplace(
+            (string)$target->collection(),
+            (int)$target->entity(),
+            $nativeMessage,
+            $nativeFlags,
+        );
+        if ($modified === null || $modified <= 0) {
+            throw new \RuntimeException('IMAP replacement did not return a valid UID');
+        }
+
+        return $this->entityFresh()->fromMutation((string)$target->collection(), $modified, $properties);
     }
 
     public function entityPatch(MessagePropertiesMutableInterface $properties, EntityIdentifier ...$targets): array
@@ -892,4 +942,45 @@ class Service implements ServiceBaseInterface, ServiceMutableInterface, ServiceC
         return $list;
     }
 
+    /**
+     * Convert canonical message flags to IMAP system flags.
+     *
+     * @return string[]
+     */
+    private function messageFlags(MessagePropertiesMutableInterface $properties): array
+    {
+        $flags = [];
+        foreach ($properties->getFlags() as $flag => $enabled) {
+            if ($enabled !== true) {
+                continue;
+            }
+
+            $flags[] = match (strtolower((string)$flag)) {
+                'seen' => '\\Seen',
+                'flagged' => '\\Flagged',
+                'answered' => '\\Answered',
+                'draft' => '\\Draft',
+                'deleted' => '\\Deleted',
+                default => (string)$flag,
+            };
+        }
+
+        return array_values(array_unique($flags));
+    }
+
+    /**
+     * Convert message properties into the native IMAP append payload.
+     *
+     * @return array{0: string, 1: string[]}
+     */
+    private function messagePayload(MessagePropertiesMutableInterface $properties, array $options = []): array
+    {
+        $flags = $this->messageFlags($properties);
+        if (isset($options['flags']) && is_array($options['flags'])) {
+            $flags = array_values(array_unique([...$flags, ...$options['flags']]));
+        }
+
+        return [(new MessageBuilder())->build($properties), $flags];
+    }
+    
 }

lib/Service/Remote/RemoteMailService.php

@@ -131,7 +131,7 @@ class RemoteMailService
             return null;
         }
 
-        $logDir = dirname(__DIR__, 5) . '/var/log';
+        $logDir = dirname(__DIR__, 5) . '/var/logs/provider_imap';
 
         return new PlainFileLogger($logDir . '/' . $channel, $this->service->identifier());
     }
@@ -490,6 +490,44 @@ class RemoteMailService
         return $this->imapClient()->perform(new AppendCommand($collection, $rawMessage, $flags));
     }
 
+    /**
+     * Append a replacement message, then permanently remove the superseded UID.
+     * The replacement is removed on cleanup failure so the old UID remains
+     * authoritative for a later retry.
+     *
+     * @param string[] $flags
+     */
+    public function entityReplace(
+        string $collection,
+        int $identifier,
+        string $rawMessage,
+        array $flags = [],
+    ): ?int {
+        if ($identifier <= 0) {
+            throw new RuntimeException('A valid IMAP UID is required for replacement');
+        }
+
+        $replacement = $this->entityCreate($collection, $rawMessage, $flags);
+        if ($replacement === null || $replacement <= 0) {
+            throw new RuntimeException('IMAP replacement append did not return a valid UID');
+        }
+
+        try {
+            $deleted = $this->entityDestroy($collection, $identifier);
+            if (($deleted[$identifier] ?? false) !== true) {
+                throw new RuntimeException('Failed to delete the superseded IMAP entity');
+            }
+        } catch (\Throwable $error) {
+            try {
+                $this->entityDestroy($collection, $replacement);
+            } catch (\Throwable) {
+            }
+            throw $error;
+        }
+
+        return $replacement;
+    }
+
     /**
      * Modify message flags for one or more messages.
      *

lib/Stores/ServiceStore.php

@@ -177,4 +177,15 @@ class ServiceStore
         return $result->getDeletedCount() > 0;
     }
 
+    /**
+     * Delete every service owned by a user.
+     */
+    public function deleteByUser(string $tenantId, string $userId): void
+    {
+        $this->dataStore->selectCollection(self::COLLECTION_NAME)->deleteMany([
+            'tid' => $tenantId,
+            'uid' => $userId,
+        ]);
+    }
+
 }

tests/php/Unit/RemoteMailServiceTest.php

@@ -0,0 +1,68 @@
+<?php
+
+declare(strict_types=1);
+
+namespace KTXT\ProviderImap\Tests\Unit;
+
+use KTXM\ProviderImap\Providers\Service;
+use KTXM\ProviderImap\Service\Remote\RemoteMailService;
+use PHPUnit\Framework\TestCase;
+use RuntimeException;
+
+final class RemoteMailServiceTest extends TestCase {
+
+    public function testEntityReplaceReturnsAuthoritativeReplacementUid(): void {
+        $service = new RemoteMailServiceStub($this->createStub(Service::class));
+        $service->appendUid = 202;
+        $service->destroyResults = [[101 => true]];
+
+        $result = $service->entityReplace('Drafts', 101, 'raw message', ['\\Draft']);
+
+        $this->assertSame(202, $result);
+        $this->assertSame([
+            ['Drafts', 'raw message', ['\\Draft']],
+        ], $service->createCalls);
+        $this->assertSame([
+            ['Drafts', [101]],
+        ], $service->destroyCalls);
+    }
+
+    public function testEntityReplaceRemovesReplacementWhenOldUidCannotBeDeleted(): void {
+        $service = new RemoteMailServiceStub($this->createStub(Service::class));
+        $service->appendUid = 202;
+        $service->destroyResults = [
+            [101 => false],
+            [202 => true],
+        ];
+
+        try {
+            $service->entityReplace('Drafts', 101, 'raw message', ['\\Draft']);
+            $this->fail('Expected superseded message cleanup failure');
+        } catch (RuntimeException $exception) {
+            $this->assertSame('Failed to delete the superseded IMAP entity', $exception->getMessage());
+        }
+
+        $this->assertSame([
+            ['Drafts', [101]],
+            ['Drafts', [202]],
+        ], $service->destroyCalls);
+    }
+}
+
+final class RemoteMailServiceStub extends RemoteMailService {
+
+    public ?int $appendUid = null;
+    public array $createCalls = [];
+    public array $destroyCalls = [];
+    public array $destroyResults = [];
+
+    public function entityCreate(string $collection, string $rawMessage, array $flags = []): ?int {
+        $this->createCalls[] = [$collection, $rawMessage, $flags];
+        return $this->appendUid;
+    }
+
+    public function entityDestroy(string $collection, int ...$uids): array {
+        $this->destroyCalls[] = [$collection, $uids];
+        return array_shift($this->destroyResults) ?? [];
+    }
+}