From 06a8c6bc02fddffcf226271cd48083de9835429f Mon Sep 17 00:00:00 2001
From: Karsten Dambekalns <karsten@dambekalns.de>
Date: Wed, 27 Oct 2021 10:35:01 +0200
Subject: [PATCH] Remove related OAuth authorization data upon user deletion

Fixes #12
---
 Classes/Package.php | 57 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100644 Classes/Package.php

diff --git a/Classes/Package.php b/Classes/Package.php
new file mode 100644
index 0000000..2ee5294
--- /dev/null
+++ b/Classes/Package.php
@@ -0,0 +1,57 @@
+<?php
+declare(strict_types=1);
+
+namespace Flownative\Canto;
+
+/*
+ * This file is part of the Flownative.Canto package.
+ *
+ * (c) Karsten Dambekalns, Flownative GmbH - www.flownative.com
+ *
+ * This package is Open Source Software. For the full copyright and license
+ * information, please view the LICENSE file which was distributed with this
+ * source code.
+ */
+
+use Doctrine\ORM\EntityManagerInterface;
+use Flownative\Canto\Domain\Repository\AccountAuthorizationRepository;
+use Flownative\OAuth2\Client\Authorization;
+use Neos\Flow\Core\Bootstrap;
+use Neos\Flow\Package\Package as BasePackage;
+use Neos\Neos\Domain\Model\User;
+use Neos\Neos\Domain\Service\UserService;
+
+class Package extends BasePackage
+{
+    /**
+     * @param Bootstrap $bootstrap The current bootstrap
+     * @return void
+     */
+    public function boot(Bootstrap $bootstrap)
+    {
+        $dispatcher = $bootstrap->getSignalSlotDispatcher();
+        $dispatcher->connect(
+            UserService::class,
+            'userDeleted',
+            function (User $user) use ($bootstrap) {
+                $accountAuthorizationRepository = $bootstrap->getObjectManager()->get(AccountAuthorizationRepository::class);
+                $entityManager = $bootstrap->getObjectManager()->get(EntityManagerInterface::class);
+
+                foreach ($user->getAccounts() as $account) {
+                    $accountAuthorization = $accountAuthorizationRepository->findOneByFlowAccountIdentifier($account->getAccountIdentifier());
+                    if ($accountAuthorization !== null) {
+                        $authorizationId = $accountAuthorization->getAuthorizationId();
+                        $authorization = $entityManager->find(Authorization::class, ['authorizationId' => $authorizationId]);
+                        if ($authorization instanceof Authorization) {
+                            $entityManager->remove($authorization);
+                        }
+
+                        $accountAuthorizationRepository->remove($accountAuthorization);
+                    }
+                }
+            },
+            '',
+            false
+        );
+    }
+}