Configuration module is added

Author: mehmetsefabalik

README.md

@@ -0,0 +1,19 @@
+## Configurations
+
+### Gateway Configuration
+
+#### Get Configurations of a Gateway
+
+```
+const gatewayName = 'customGatewayName';
+socket.on(`configurations.gateway.${gatewayName}`, response => console.log('gateway configs: ', response.data));
+socket.emit('configurations.gateway.get', {name: gatewayName});
+```
+
+#### Get Configurations of a Storefront
+
+```
+const storefrontName = 'customStorefrontName';
+socket.on(`configurations.storefront.${storefrontName}`, response => console.log('storefront configs: ', response.data));
+socket.emit('configurations.storefront.get', {name: storefrontName});
+```

src/app.module.ts

@@ -5,6 +5,8 @@ import { FragmentModule } from './fragment/fragment.module';
 import { ServeStaticModule } from '@nestjs/serve-static';
 import { dirname } from 'path';
 import { CouchbaseModule } from './couchbase/couchbase.module';
+import { ConfigurationModule } from './configuration/configuration.module';
+import { ConfigurationGateway } from './configuration/configuration.gateway';
 
 const sentryUi = dirname(require.resolve('@puzzle-js/sentry-ui'));
 
@@ -17,6 +19,7 @@ const sentryUi = dirname(require.resolve('@puzzle-js/sentry-ui'));
     PageModule,
     FragmentModule,
     CouchbaseModule,
+    ConfigurationModule,
   ],
 })
 export class AppModule { }

src/configuration/configuration.gateway.ts

@@ -0,0 +1,44 @@
+import { SubscribeMessage, WebSocketGateway, MessageBody, WebSocketServer } from '@nestjs/websockets';
+import { ConfigurationService } from './configuration.service';
+import { Server } from 'socket.io';
+import { Configuration } from './configuration.interface';
+import { PlatformTypes } from '../enums';
+
+@WebSocketGateway()
+export class ConfigurationGateway {
+  constructor(private readonly configurationService: ConfigurationService) { }
+  @WebSocketServer() server: Server;
+
+  @SubscribeMessage('panel.configurations.storefronts.get')
+  async getStorefrontConfigsForPanel() {
+    const configs = await this.configurationService.getAll(PlatformTypes.Storefront);
+    return { event: `panel.configurations.storefronts`, data: configs };
+  }
+
+  @SubscribeMessage('panel.configurations.gateways.get')
+  async getGatewayConfigsForPanel() {
+    const configs = await this.configurationService.getAll(PlatformTypes.Gateway);
+    return { event: `panel.configurations.gateways`, data: configs };
+  }
+
+  @SubscribeMessage('panel.configurations.storefront.add')
+  async addStorefrontConfigs(@MessageBody() body: { configurations: Configuration[], name: string }) {
+    if (!body.configurations) return null;
+    const configs = await this.configurationService.add(PlatformTypes.Storefront, body.name, body.configurations);
+    this.server.emit(`panel.configurations.storefront.${body.name}`, configs);
+  }
+
+  @SubscribeMessage('configurations.storefront.get')
+  async getStorefrontConfigs(@MessageBody() body: { name: string }) {
+    if (!body.name) return null;
+    const configs = await this.configurationService.get(PlatformTypes.Storefront, body.name);
+    return { event: `configurations.storefront.${body.name}`, data: configs };
+  }
+
+  @SubscribeMessage('configurations.gateway.get')
+  async getGatewayConfigs(@MessageBody() body: { name: string }) {
+    if (!body.name) return null;
+    const configs = await this.configurationService.get(PlatformTypes.Gateway, body.name);
+    return { event: `configurations.gateway.${body.name}`, data: configs };
+  }
+}

src/configuration/configuration.interface.ts

@@ -0,0 +1 @@
+export type Configuration = Record<string, string>;

src/configuration/configuration.module.ts

@@ -0,0 +1,8 @@
+import { Module } from '@nestjs/common';
+import { ConfigurationService } from './configuration.service';
+import { ConfigurationGateway } from './configuration.gateway';
+
+@Module({
+  providers: [ConfigurationGateway, ConfigurationService],
+})
+export class ConfigurationModule {}

src/configuration/configuration.service.ts

@@ -0,0 +1,58 @@
+import { Injectable } from '@nestjs/common';
+import { CouchbaseService } from '../couchbase/couchbase.service';
+import { Configuration } from './configuration.interface';
+import { ViewQuery } from 'couchbase';
+
+@Injectable()
+export class ConfigurationService {
+  constructor(private readonly couchbaseService: CouchbaseService) { }
+
+  add(type: PlatformTypes, name: string, configuration: Configuration[]) {
+    return new Promise((resolve, reject) => {
+      this.couchbaseService.getBucket().insert(`configuration_${type}_${name}`, {configuration, type: `configuration_${type}`}, (err, data) => {
+        if (err) return reject(null);
+        resolve(data);
+      });
+    });
+  }
+
+  delete(type: PlatformTypes, name: string) {
+    return new Promise((resolve, reject) => {
+      this.couchbaseService.getBucket().remove(`configuration_${type}_${name}`, (err, data) => {
+        if (err) return reject(null);
+        resolve(data);
+      });
+    });
+  }
+
+  update(type: PlatformTypes, name: string, configuration: Configuration) {
+    return new Promise((resolve, reject) => {
+      this.couchbaseService.getBucket().upsert(`configuration_${type}_${name}`, {configuration, type: `configuration_${type}`}, (err, data) => {
+        if (err) return reject(null);
+        resolve(data);
+      });
+    });
+  }
+
+  get(type: PlatformTypes, name: string) {
+    return new Promise((resolve, reject) => {
+      this.couchbaseService.getBucket().get(`configuration_${type}_${name}`, (err, data) => {
+        if (err) return reject(null);
+        console.log("get data: ", data);
+        resolve(data.map((g) => g.value));
+      });
+    });
+  }
+
+  getAll(type: PlatformTypes) {
+    return new Promise((resolve, reject) => {
+      const query = ViewQuery
+        .from(`configuration_${type}`, 'getAll')
+        .stale(ViewQuery.Update.BEFORE);
+      this.couchbaseService.getBucket().query(query, (err, data) => {
+        if (err) return reject(null);
+        resolve(data.map((g) => g.value));
+      });
+    });
+  }
+}

src/configuration/test/configuration.gateway.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { ConfigurationGateway } from '../configuration.gateway';
+
+describe('ConfigurationGateway', () => {
+  let gateway: ConfigurationGateway;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [ConfigurationGateway],
+    }).compile();
+
+    gateway = module.get<ConfigurationGateway>(ConfigurationGateway);
+  });
+
+  it('should be defined', () => {
+    expect(gateway).toBeDefined();
+  });
+});

src/configuration/test/configuration.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { ConfigurationService } from '../configuration.service';
+
+describe('ConfigurationService', () => {
+  let service: ConfigurationService;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [ConfigurationService],
+    }).compile();
+
+    service = module.get<ConfigurationService>(ConfigurationService);
+  });
+
+  it('should be defined', () => {
+    expect(service).toBeDefined();
+  });
+});

src/enums.ts

@@ -0,0 +1,4 @@
+export enum PlatformTypes  {
+  Storefront = 'storefront',
+  Gateway = 'gateway',
+}