From 3f3374356fc68304bb67b4e929542d44d7ed15f5 Mon Sep 17 00:00:00 2001
From: Konstantin Tsabolov <konstantin.tsabolov@spherity.com>
Date: Wed, 13 Dec 2023 17:27:36 +0100
Subject: [PATCH] feat: add supporting types and modules

---
 apps/schema-manager/src/application.ts        | 10 ++++
 .../response-format.interceptor.spec.ts       | 49 +++++++++++++++++++
 .../src/common/response-format.interceptor.ts | 28 +++++++++++
 .../src/health/health.controller.ts           |  2 +-
 .../src/interfaces/response.interface.ts      |  6 +++
 5 files changed, 94 insertions(+), 1 deletion(-)
 create mode 100644 apps/schema-manager/src/common/__tests__/response-format.interceptor.spec.ts
 create mode 100644 apps/schema-manager/src/common/response-format.interceptor.ts
 create mode 100644 apps/schema-manager/src/interfaces/response.interface.ts

diff --git a/apps/schema-manager/src/application.ts b/apps/schema-manager/src/application.ts
index f255cc8..9b9f46f 100644
--- a/apps/schema-manager/src/application.ts
+++ b/apps/schema-manager/src/application.ts
@@ -2,6 +2,7 @@ import type { ConfigType } from '@nestjs/config';
 
 import { Module } from '@nestjs/common';
 import { ConfigModule } from '@nestjs/config';
+import { RouterModule } from '@nestjs/core';
 import { ClientsModule, Transport } from '@nestjs/microservices';
 
 import { NATS_CLIENT } from './common/constants.js';
@@ -9,6 +10,7 @@ import { httpConfig } from './config/http.config.js';
 import { natsConfig } from './config/nats.config.js';
 import { ssiConfig } from './config/ssi.config.js';
 import { validationSchema } from './config/validation.js';
+import { CredentialDefinitionsModule } from './credential-definitions/credential-definitions.module.js';
 import { HealthModule } from './health/health.module.js';
 import { SchemasModule } from './schemas/schemas.module.js';
 
@@ -43,7 +45,15 @@ import { SchemasModule } from './schemas/schemas.module.js';
     }),
 
     HealthModule,
+
     SchemasModule,
+    CredentialDefinitionsModule,
+
+    RouterModule.register([
+      { module: HealthModule, path: '/health' },
+      { module: SchemasModule, path: '/schemas' },
+      { module: CredentialDefinitionsModule, path: '/credential-definitions' },
+    ]),
   ],
 })
 export class Application {}
diff --git a/apps/schema-manager/src/common/__tests__/response-format.interceptor.spec.ts b/apps/schema-manager/src/common/__tests__/response-format.interceptor.spec.ts
new file mode 100644
index 0000000..4584333
--- /dev/null
+++ b/apps/schema-manager/src/common/__tests__/response-format.interceptor.spec.ts
@@ -0,0 +1,49 @@
+import type { ExecutionContext } from '@nestjs/common';
+import type { TestingModule } from '@nestjs/testing';
+
+import { Test } from '@nestjs/testing';
+import { of } from 'rxjs';
+
+import { ResponseFormatInterceptor } from '../response-format.interceptor.js';
+
+describe('ResponseFormatInterceptor', () => {
+  let interceptor: ResponseFormatInterceptor;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [ResponseFormatInterceptor],
+    }).compile();
+
+    interceptor = module.get<ResponseFormatInterceptor>(
+      ResponseFormatInterceptor,
+    );
+  });
+
+  it('should be defined', () => {
+    expect(interceptor).toBeDefined();
+    expect(interceptor).toBeInstanceOf(ResponseFormatInterceptor);
+  });
+
+  it('should intercept the request and format the response', (done) => {
+    const context: ExecutionContext = {
+      switchToHttp: () => ({
+        getResponse: () => ({
+          statusCode: 200,
+        }),
+      }),
+    } as ExecutionContext;
+    const next = {
+      handle: jest.fn().mockReturnValue(of('Hello World')),
+    };
+
+    const result = interceptor.intercept(context, next);
+
+    expect(result).toBeDefined();
+    expect(next.handle).toHaveBeenCalled();
+
+    result.subscribe((response) => {
+      expect(response).toEqual({ statusCode: 200, data: 'Hello World' });
+      done();
+    });
+  });
+});
diff --git a/apps/schema-manager/src/common/response-format.interceptor.ts b/apps/schema-manager/src/common/response-format.interceptor.ts
new file mode 100644
index 0000000..9d85a0e
--- /dev/null
+++ b/apps/schema-manager/src/common/response-format.interceptor.ts
@@ -0,0 +1,28 @@
+import type {
+  CallHandler,
+  ExecutionContext,
+  NestInterceptor,
+} from '@nestjs/common';
+
+import { Injectable } from '@nestjs/common';
+import { map, type Observable } from 'rxjs';
+
+@Injectable()
+export class ResponseFormatInterceptor implements NestInterceptor {
+  public intercept(
+    context: ExecutionContext,
+    next: CallHandler,
+  ): Observable<unknown> {
+    const ctx = context.switchToHttp();
+    const response = ctx.getResponse();
+
+    return next.handle().pipe(
+      map((data) => {
+        return {
+          statusCode: response.statusCode,
+          data,
+        };
+      }),
+    );
+  }
+}
diff --git a/apps/schema-manager/src/health/health.controller.ts b/apps/schema-manager/src/health/health.controller.ts
index 9f2454e..70092f2 100644
--- a/apps/schema-manager/src/health/health.controller.ts
+++ b/apps/schema-manager/src/health/health.controller.ts
@@ -8,7 +8,7 @@ import {
   HttpHealthIndicator,
 } from '@nestjs/terminus';
 
-@Controller('health')
+@Controller()
 export class HealthController {
   public constructor(
     private readonly config: ConfigService,
diff --git a/apps/schema-manager/src/interfaces/response.interface.ts b/apps/schema-manager/src/interfaces/response.interface.ts
new file mode 100644
index 0000000..2bb8cc7
--- /dev/null
+++ b/apps/schema-manager/src/interfaces/response.interface.ts
@@ -0,0 +1,6 @@
+export interface Response<T = unknown> {
+  statusCode: number;
+  message: string;
+  data?: T;
+  error?: unknown;
+}
-- 
GitLab