feat(service/storage): add remove route

Alwatr · Nov 13, 2022 · d4452cd · d4452cd
1 parent cae77a3
commit d4452cd
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 3 deletions.
diff --git a/packages/core/nano-server/src/nano-server.ts b/packages/core/nano-server/src/nano-server.ts
@@ -409,7 +409,7 @@ export class AlwatrConnection {
         this.reply({
           ok: false,
           statusCode: 406,
-          errorCode: `${param}_QUERY_PARAMETER_REQUIRED`,
+          errorCode: `${param}_query_parameter_required`,
         });
         return null;
       }

diff --git a/packages/nanoservice/storage/demo.http b/packages/nanoservice/storage/demo.http
@@ -10,7 +10,7 @@ GET {{apiUrl}}/{{apiVersion}}/?storage=comments/page1&id=c1
 authorization: Bearer {{token}}
 
 ### Insert document
-PATCH {{apiUrl}}/{{apiVersion}}/?storage=comments/page1
+POST {{apiUrl}}/{{apiVersion}}/?storage=comments/page1
 authorization: Bearer {{token}}
 Content-Type: application/json
 
@@ -34,7 +34,7 @@ Content-Type: application/json
 }
 
 ### Remove document
-DELETE HTTP/1.1 {{apiUrl}}/{{apiVersion}}/?storage=comments/page1&id=c1
+DELETE {{apiUrl}}/{{apiVersion}}/?storage=comments/page1&id=c1
 authorization: Bearer {{token}}
 
 ### Get keys

diff --git a/packages/nanoservice/storage/src/index.ts b/packages/nanoservice/storage/src/index.ts
@@ -1,4 +1,5 @@
 import './route/update.js';
+import './route/remove.js';
 import './route/get.js';
 import {logger} from './lib/config.js';
 

diff --git a/packages/nanoservice/storage/src/route/remove.ts b/packages/nanoservice/storage/src/route/remove.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('DELETE', 'all', removeDocument);
+
+async function removeDocument(connection: AlwatrConnection): Promise<void> {
+  logger.logMethodArgs('updateDocument', {method: connection.method});
+
+  const token = connection.requireToken(config.token);
+  if (token == null) return;
+
+  const param = connection.requireQueryParams<{storage: string, id: string}>(['storage', 'id']);
+  if (param === null) return;
+
+  const storage = storageProvider.get({name: param.storage});
+
+  if (storage.remove(param.id) === true) {
+    connection.reply({
+      ok: true,
+      data: {},
+    });
+  }
+  else {
+    connection.reply({
+      ok: false,
+      statusCode: 404,
+      errorCode: 'document_not_found',
+    });
+  }
+}