Notifications over WebSockets, see #105

Author: michielbdejong

solid/appinfo/routes.php

@@ -55,7 +55,7 @@
         ['name' => 'solidWebhook#register', 'url' => '/webhook/register', 'verb' => 'POST'],
         ['name' => 'solidWebhook#unregister', 'url' => '/webhook/unregister', 'verb' => 'POST'],
 
-        ['name' => 'solidWebsocket#register', 'url' => '/websocket/register', 'verb' => 'POST'],
+        ['name' => 'solidWebhook#registerWs', 'url' => '/websocket/register', 'verb' => 'POST'],
 
         ['name' => 'app#appLauncher', 'url' => '/', 'verb' => 'GET'],
     ]

solid/composer.lock

@@ -83,6 +83,31 @@ public function listWebhooks(): DataResponse {
 		return new DataResponse($this->webhookService->findAll($this->webId));
 	}
 
+	/**
+	 * @PublicPage
+	 * @NoAdminRequired
+	 * @NoCSRFRequired
+	 */
+	public function registerWs(string $topic): DataResponse {
+		$toSub = "http://pubsub:8081";
+		$toPub = "http://pubsub:8082";
+		// FIXME: is this secure enough?
+		// https://www.php.net/manual/en/function.random-bytes.php says it
+		// generates "cryptographically secure pseudo-random bytes"
+		$token = bin2hex(random_bytes(20));
+		$target = "$toPub/$token?" . urlencode($topic);
+		if ($this->checkReadAccess($topic)) {
+			$webhook = $this->webhookService->create($this->webId, $topic, $target);
+			return new DataResponse([
+				"@context" => "https://www.w3.org/ns/solid/notification/v1",
+				"type" => "WebSocketSubscription2021",
+				"source" => "$toSub/$token"
+			]);
+		} else {
+			return new DataResponse("Error: denied access", 401);
+		}
+	}
+
 	/**
 	 * @PublicPage
 	 * @NoAdminRequired