feat(service/commenting): add route

packages/service/commenting/demo.http

@@ -4,3 +4,13 @@
 
 ### home
 GET {{apiUrl}}/
+
+### Add comment
+PUT {{apiUrl}}/add?path=product/test
+Authorization: Bearer {{token}}
+Content-Type: application/json
+
+{
+  "userName": "njfamirm",
+  "text": "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua."
+}

packages/service/commenting/package.json

@@ -65,6 +65,7 @@
   "dependencies": {
     "@alwatr/logger": "^0.24.1",
     "@alwatr/nano-server": "^0.24.1",
+    "@alwatr/storage-client": "^0.24.1",
     "@alwatr/storage-engine": "^0.24.1"
   },
   "devDependencies": {

packages/service/commenting/src/index.ts

@@ -1,4 +1,5 @@
-import './route/home.js'
+import './route/home.js';
+import './route/add.js';
 import {logger} from './lib/config.js';
 
 logger.logOther('..:: Alwatr Storage Nanoservice API ::..');

packages/service/commenting/src/lib/config.ts

@@ -3,10 +3,17 @@ import {createLogger} from '@alwatr/logger';
 export const logger = createLogger('storage-server');
 
 export const config = {
-  host: process.env.HOST ?? '0.0.0.0',
-  port: process.env.PORT != null ? +process.env.PORT : 8000,
-  storagePath: process.env.STORAGE_PATH ?? 'db',
-  token: process.env.TOKEN ?? 'YOUR_SECRET_TOKEN',
+  nanoServer: {
+    host: process.env.HOST ?? '0.0.0.0',
+    port: process.env.PORT != null ? +process.env.PORT : 8000,
+    token: process.env.TOKEN ?? 'YOUR_SECRET_TOKEN',
+  },
+  storage: {
+    host: process.env.STORAGE_HOST ?? '127.0.0.1',
+    port: process.env.STORAGE_PORT != null ? +process.env.STORAGE_PORT : 9000,
+    name: process.env.STORAGE_NAME ?? 'comment',
+    token: process.env.STORAGE_TOKEN ?? 'YOUR_SECRET_TOKEN',
+  },
 };
 
 logger.logProperty('config', {...config, token: '***'});

packages/service/commenting/src/lib/nano-server.ts

@@ -2,4 +2,8 @@ import {AlwatrNanoServer} from '@alwatr/nano-server';
 
 import {config} from './config.js';
 
-export const nanoServer = new AlwatrNanoServer({host: config.host, port: config.port, allowAllOrigin: true});
+export const nanoServer = new AlwatrNanoServer({
+  host: config.nanoServer.host,
+  port: config.nanoServer.port,
+  allowAllOrigin: true,
+});

packages/service/commenting/src/lib/storage.ts

@@ -0,0 +1,6 @@
+import {AlwatrStorageClient} from '@alwatr/storage-client';
+
+import {config} from './config.js';
+import {Comment} from './type.js';
+
+export const storage = new AlwatrStorageClient<Comment>(config.storage);

packages/service/commenting/src/lib/type.ts

@@ -0,0 +1,6 @@
+import {AlwatrDocumentObject} from '@alwatr/storage-engine';
+
+export type Comment = AlwatrDocumentObject & {
+  userName: string;
+  text: string;
+}

packages/service/commenting/src/route/add.ts

@@ -0,0 +1,35 @@
+import {logger} from 'src/lib/config.js';
+
+import {nanoServer} from '../lib/nano-server.js';
+import {storage} from '../lib/storage.js';
+import {Comment} from '../lib/type.js';
+
+
+import type {AlwatrConnection} from '@alwatr/nano-server';
+
+nanoServer.route('PUT', '/add', addComment);
+
+async function addComment(connection: AlwatrConnection): Promise<void> {
+  const params = await connection.requireQueryParams<{path: string}>({path: 'string'});
+  if (params == null) return;
+
+  const bodyJson = await connection.requireJsonBody<Comment>();
+  if (bodyJson == null) return;
+
+  storage.config.name = params.path;
+
+  try {
+    connection.reply({
+      ok: true,
+      data: await storage.set({...bodyJson, id: 'auto_increment'}),
+    });
+  }
+  catch (err) {
+    logger.error('newJob', (err as Error).message ?? 'storage_error', (err as Error).stack ?? err);
+    connection.reply({
+      ok: false,
+      statusCode: 500,
+      errorCode: 'storage_error',
+    });
+  }
+}