feat(notification): add notification when update is available for installed plugin

implements #9

Author: jankal

src/Action/LoadPluginAction.php

@@ -5,15 +5,18 @@
 namespace NuonicPluginInstaller\Action;
 
 use Composer\Semver\Semver;
+use NuonicPluginInstaller\Core\Framework\Plugin\AvailableOpensourcePlugin\AvailableOpensourcePluginCollection;
 use NuonicPluginInstaller\Core\Framework\Plugin\AvailableOpensourcePlugin\AvailableOpensourcePluginEntity;
 use NuonicPluginInstaller\Service\IndexFileServiceInterface;
 use NuonicPluginInstaller\Struct\PackageIndexEntry;
+use Shopware\Administration\Notification\NotificationCollection;
 use Shopware\Core\Framework\Adapter\Cache\CacheValueCompressor;
 use Shopware\Core\Framework\Context;
 use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
 use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
 use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
 use Shopware\Core\Framework\Uuid\Uuid;
+use Shopware\Core\System\Language\LanguageCollection;
 use Symfony\Component\Yaml\Yaml;
 use Symfony\Contracts\Cache\CacheInterface;
 use Symfony\Contracts\Cache\ItemInterface;
@@ -25,17 +28,24 @@
 
 readonly class LoadPluginAction
 {
+
+    /**
+     * @param EntityRepository<AvailableOpensourcePluginCollection> $availableOpensourcePluginRepository
+     * @param EntityRepository<LanguageCollection> $languageRepository
+     * @param EntityRepository<NotificationCollection> $notificationRepository
+     */
     public function __construct(
         private EntityRepository $availableOpensourcePluginRepository,
         private IndexFileServiceInterface $indexFileService,
         private HttpClientInterface $httpClient,
         private CacheInterface $cache,
         private EntityRepository $languageRepository,
+        private EntityRepository $notificationRepository,
         private string $shopwareVersion,
     ) {
     }
 
-    public function execute(string|PackageIndexEntry $packageInformation, \DateTimeInterface $now): void
+    public function execute(string|PackageIndexEntry $packageInformation, \DateTimeInterface $now, Context $context): void
     {
         if (!$packageInformation instanceof PackageIndexEntry) {
             $packageInformation = $this->indexFileService->getPackageInformation($packageInformation);
@@ -104,8 +114,10 @@ public function execute(string|PackageIndexEntry $packageInformation, \DateTimeI
 
         /** @var AvailableOpensourcePluginEntity|null $plugin */
         $plugin = $this->availableOpensourcePluginRepository->search(
-            (new Criteria())->addFilter(new EqualsFilter('packageName', $packageInformation->packageName)),
-            Context::createDefaultContext()
+            (new Criteria())
+                ->addFilter(new EqualsFilter('packageName', $packageInformation->packageName))
+                ->addAssociation('plugin'),
+            $context
         )->first();
 
         $id = $plugin?->getId() ?? Uuid::randomHex();
@@ -114,7 +126,15 @@ public function execute(string|PackageIndexEntry $packageInformation, \DateTimeI
         $pluginData['lastSeenAt'] = $now;
         $pluginData['lastCommitTime'] = $packageInformation->latestCommitTime;
 
-        $this->availableOpensourcePluginRepository->upsert([$pluginData], Context::createDefaultContext());
+        $this->availableOpensourcePluginRepository->upsert([$pluginData], $context);
+
+        if (!is_null($plugin)) {
+            $this->handleUpdateNotification(
+                $plugin,
+                $pluginData,
+                $context
+            );
+        }
     }
 
     private function fetchExtensionYmlData(string $mainExtensionYmlUrl, string $githubUrl): array
@@ -227,4 +247,27 @@ private function loadLanguageId(string $locale): string
 
         return CacheValueCompressor::uncompress($value);
     }
+
+    private function handleUpdateNotification(
+        AvailableOpensourcePluginEntity $plugin,
+        array $pluginData,
+        Context $context
+    ): void {
+        if (is_null($swPlugin = $plugin->getPlugin()) || is_null($swPlugin->getInstalledAt())) {
+            return;
+        }
+
+        if (version_compare($pluginData['availableVersion'], $swPlugin->getVersion()) !== 1) {
+            return;
+        }
+
+        $context->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($swPlugin): void {
+            $this->notificationRepository->create([[
+                'id' => Uuid::randomHex(),
+                'status' => 'info',
+                'message' => 'Update available for plugin ' . $swPlugin->getName(),
+                'requiredPrivileges' => [],
+            ]], $context);
+        });
+    }
 }

src/Action/RefreshAction.php

@@ -39,7 +39,7 @@ public function execute(Context $context, bool $async = true): void
                 continue;
             }
 
-            $this->loadPluginAction->execute($package, new \DateTime());
+            $this->loadPluginAction->execute($package, new \DateTime(), $context);
         }
     }
 }

src/Infrastructure/Handler/LoadSinglePluginInfoHandler.php

@@ -6,6 +6,7 @@
 
 use NuonicPluginInstaller\Action\LoadPluginAction;
 use NuonicPluginInstaller\Infrastructure\Message\LoadSinglePluginInfoMessage;
+use Shopware\Core\Framework\Context;
 use Symfony\Component\Messenger\Attribute\AsMessageHandler;
 
 #[AsMessageHandler(handles: LoadSinglePluginInfoMessage::class)]
@@ -18,6 +19,6 @@ public function __construct(
 
     public function __invoke(LoadSinglePluginInfoMessage $message): void
     {
-        $this->loadPluginAction->execute($message->package, $message->now);
+        $this->loadPluginAction->execute($message->package, $message->now, Context::createCLIContext());
     }
 }

src/Resources/config/services.xml

@@ -26,6 +26,7 @@
             <argument type="service" id="http_client" />
             <argument type="service" id="cache.app"/>
             <argument type="service" id="language.repository"/>
+            <argument type="service" id="notification.repository" />
             <argument>%kernel.shopware_version%</argument>
         </service>