feat(service/storage-server): has route

packages/service/storage-server/demo.http

@@ -45,6 +45,10 @@ Content-Type: application/json
   "message": "Salam ;)"
 }
 
+### Check document exists by storageName and docId
+GET {{apiUrl}}/{{apiVersion}}/has?storage=comments/page1&id=c1
+authorization: Bearer {{token}}
+
 ### Delete document
 DELETE {{apiUrl}}/{{apiVersion}}/?storage=comments/page1&id=c1
 authorization: Bearer {{token}}
@@ -71,6 +75,11 @@ GET {{apiUrl}}/{{apiVersion}}/?storage=comments/page1/page1&id=c1
 ### Page 404 (wrong method)
 TRACE {{apiUrl}}/{{apiVersion}}
 
+### Document not exists
+GET {{apiUrl}}/{{apiVersion}}/has?storage=comments/page1&id=foo
+authorization: Bearer {{token}}
+
+
 ### Get a document by storageName without id
 GET {{apiUrl}}/{{apiVersion}}/?storage=comments/page1
 authorization: Bearer {{token}}

packages/service/storage-server/src/index.ts

@@ -1,4 +1,5 @@
 import './route/get.js';
+import './route/has.js';
 import './route/patch.js';
 import './route/delete.js';
 import './route/keys.js';

packages/service/storage-server/src/route/has.ts

@@ -0,0 +1,33 @@
+import {config, logger} from '../lib/config.js';
+import {nanoServer} from '../lib/nano-server.js';
+import {storageProvider} from '../lib/storage-provider.js';
+
+import type {AlwatrConnection} from '@alwatr/nano-server';
+
+nanoServer.route('GET', '/has', has);
+
+async function has(connection: AlwatrConnection): Promise<void> {
+  logger.logMethod('has');
+
+  const token = connection.requireToken(config.token);
+  if (token == null) return;
+
+  const params = connection.requireQueryParams<{storage: string, id: string}>({storage: 'string', id: 'string'});
+  if (params == null) return;
+
+  const storage = storageProvider.get({name: params.storage});
+
+  if (!storage.has(params.id)) {
+    connection.reply({
+      ok: false,
+      errorCode: 'document_not_exists',
+      statusCode: 404,
+    });
+    return;
+  }
+
+  connection.reply({
+    ok: true,
+    data: {},
+  });
+}