delete connection implemented

Author: Hanashi

files/lib/bootstrap/dev.hanashi.wsdb.connection.php

@@ -1,8 +1,10 @@
 <?php
 
 use wcf\command\wsdb\database\SetConnectionDatabasePages;
+use wcf\event\endpoint\ControllerCollecting;
 use wcf\event\wsdb\database\DatabaseCreated;
 use wcf\event\wsdb\interaction\user\RecordInteractionCollecting;
+use wcf\system\endpoint\controller\hanashi\wsdb\records\connections\DeleteConnection;
 use wcf\system\event\EventHandler;
 use wcf\system\event\listener\ConnectionWsdbRecordInteractionCollectingListener;
 
@@ -15,4 +17,11 @@
     EventHandler::getInstance()->register(DatabaseCreated::class, static function (DatabaseCreated $event): void {
         (new SetConnectionDatabasePages($event->database))();
     });
+
+    EventHandler::getInstance()->register(
+        ControllerCollecting::class,
+        static function (ControllerCollecting $event): void {
+            $event->register(new DeleteConnection());
+        }
+    );
 };

files/lib/data/wsdb/record/connection/RecordConnectionAction.class.php

@@ -3,6 +3,7 @@
 namespace wcf\data\wsdb\record\connection;
 
 use wcf\data\AbstractDatabaseObjectAction;
+use wcf\system\WCF;
 
 /**
  * @extends AbstractDatabaseObjectAction<RecordConnection, RecordConnectionEditor>
@@ -26,4 +27,17 @@ public function create(): RecordConnection
 
         return parent::create();
     }
+
+    #[\Override]
+    public function delete(): int
+    {
+        $sql = "DELETE FROM wcf1_wsdb_record_connection WHERE recordID = ? AND referencedRecordID = ?";
+        $statement = WCF::getDB()->prepare($sql);
+
+        foreach ($this->getObjects() as $object) {
+            $statement->execute([$object->referencedRecordID, $object->recordID]);
+        }
+
+        return parent::delete();
+    }
 }

files/lib/event/wsdb/gridView/user/ConnectionGridViewInitialized.class.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace wcf\event\wsdb\gridView\user;
+
+use wcf\event\IPsr14Event;
+use wcf\system\wsdb\gridView\user\ConnectionGridView;
+
+final class ConnectionGridViewInitialized implements IPsr14Event
+{
+    public function __construct(public readonly ConnectionGridView $gridView)
+    {
+    }
+}

files/lib/event/wsdb/interaction/user/ConnectionInteractionCollecting.class.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace wcf\event\wsdb\interaction\user;
+
+use wcf\event\IPsr14Event;
+use wcf\system\wsdb\interaction\user\ConnectionInteractions;
+
+final class ConnectionInteractionCollecting implements IPsr14Event
+{
+    public function __construct(public readonly ConnectionInteractions $provider)
+    {
+    }
+}

files/lib/system/endpoint/controller/hanashi/wsdb/records/connections/DeleteConnection.class.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace wcf\system\endpoint\controller\hanashi\wsdb\records\connections;
+
+use Laminas\Diactoros\Response\JsonResponse;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use wcf\data\wsdb\record\connection\RecordConnection;
+use wcf\data\wsdb\record\connection\RecordConnectionAction;
+use wcf\http\Helper;
+use wcf\system\endpoint\DeleteRequest;
+use wcf\system\endpoint\IController;
+use wcf\system\exception\PermissionDeniedException;
+
+#[DeleteRequest("/hanashi/wsdb/records/connections/{id:\\d+}")]
+final class DeleteConnection implements IController
+{
+    #[\Override]
+    public function __invoke(ServerRequestInterface $request, array $variables): ResponseInterface
+    {
+        $connection = Helper::fetchObjectFromRequestParameter($variables['id'], RecordConnection::class);
+
+        if (!$connection->getRecord()->canEdit()) {
+            throw new PermissionDeniedException();
+        }
+
+        (new RecordConnectionAction([$connection], 'delete'))->executeAction();
+
+        return new JsonResponse([]);
+    }
+}

files/lib/system/wsdb/gridView/user/ConnectionGridView.class.php

@@ -8,6 +8,7 @@
 use wcf\data\wsdb\record\connection\RecordConnection;
 use wcf\data\wsdb\record\connection\RecordConnectionList;
 use wcf\data\wsdb\record\Record;
+use wcf\event\wsdb\gridView\user\ConnectionGridViewInitialized;
 use wcf\form\WsdbConnectionAddForm;
 use wcf\system\gridView\AbstractGridView;
 use wcf\system\gridView\AbstractGridViewRowLink;
@@ -20,6 +21,7 @@
 use wcf\system\view\filter\TextFilter;
 use wcf\system\WCF;
 use wcf\system\wsdb\cache\runtime\RecordRuntimeCache;
+use wcf\system\wsdb\interaction\user\ConnectionInteractions;
 use wcf\util\StringUtil;
 
 /**
@@ -86,6 +88,9 @@ public function render(mixed $value, DatabaseObject $row, bool $isPrimaryColumn
             }
         );
 
+        $provider = new ConnectionInteractions();
+        $this->setInteractionProvider($provider);
+
         $this->setDefaultSortField('title');
     }
 
@@ -127,6 +132,12 @@ protected function createObjectList(): DatabaseObjectList
         return $list;
     }
 
+    #[\Override]
+    protected function getInitializedEvent(): ConnectionGridViewInitialized
+    {
+        return new ConnectionGridViewInitialized($this);
+    }
+
     public function getConnectionAddFormLink(): string
     {
         return LinkHandler::getInstance()->getControllerLink(

files/lib/system/wsdb/interaction/user/ConnectionInteractions.class.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace wcf\system\wsdb\interaction\user;
+
+use wcf\data\wsdb\record\connection\RecordConnection;
+use wcf\event\wsdb\interaction\user\ConnectionInteractionCollecting;
+use wcf\system\event\EventHandler;
+use wcf\system\interaction\AbstractInteractionProvider;
+use wcf\system\interaction\DeleteInteraction;
+
+final class ConnectionInteractions extends AbstractInteractionProvider
+{
+    public function __construct()
+    {
+        $this->addInteractions([
+            new DeleteInteraction("hanashi/wsdb/records/connections/%s"),
+        ]);
+
+        EventHandler::getInstance()->fire(
+            new ConnectionInteractionCollecting($this)
+        );
+    }
+
+    #[\Override]
+    public function getObjectClassName(): string
+    {
+        return RecordConnection::class;
+    }
+}