cleanup to remove nats client and swagger

Signed-off-by: Berend Sliedrecht <sliedrecht@berend.io>

apps/ssi-abstraction/src/agent/agent.service.ts

@@ -29,7 +29,6 @@ import {
   IndyVdrPoolConfig,
   IndyVdrSovDidResolver,
 } from '@aries-framework/indy-vdr';
-import { subscribe } from './utils/listener.js';
 import {
   LedgerIds,
   ledgerNamespaces,
@@ -37,8 +36,7 @@ import {
 } from './utils/ledgerConfig.js';
 import { AgentLogger } from './utils/logger.js';
 import { registerPublicDids } from './ledger/register.js';
-import { NatsClientService } from '../client/nats.client.js';
-import logger from '../globalUtils/logger.js';
+import { logger } from '../globalUtils/logger.js';
 
 export type AppAgent = Agent<AgentService['modules']>;
 
@@ -188,5 +186,3 @@ export class AgentService {
     await this.agent.shutdown();
   }
 }
-
-export default AgentService;

apps/ssi-abstraction/src/agent/connection/connection.service.ts

 import { ConnectionRecord } from '@aries-framework/core';
 import { Injectable } from '@nestjs/common';
-import AgentService, { AppAgent } from '../agent.service.js';
+import { AgentService, AppAgent } from '../agent.service.js';
 
 @Injectable()
 export class ConnectionService {

apps/ssi-abstraction/src/agent/ledger/register.ts

-import logger from '../../globalUtils/logger.js';
+import { logger } from '../../globalUtils/logger.js';
 import axios from 'axios';
 import { logAxiosError } from '../utils/helperFunctions.js';
 import { LedgerIds, ledgerNamespaces, NYM_URL } from '../utils/ledgerConfig.js';
@@ -57,5 +57,3 @@ export const registerPublicDids = async ({
   }
   return responses;
 };
-
-export default registerPublicDids;

apps/ssi-abstraction/src/agent/utils/helperFunctions.ts

 import { AxiosError } from 'axios';
-import logger from '../../globalUtils/logger.js';
+import { logger } from '../../globalUtils/logger.js';
 
 export function logAxiosError(err: AxiosError) {
   if (err.response) {
@@ -15,7 +15,3 @@ export function logAxiosError(err: AxiosError) {
     logger.error('Request error: ', err);
   }
 }
-
-export default {
-  logAxiosError,
-};

apps/ssi-abstraction/src/agent/utils/ledgerConfig.ts

@@ -31,7 +31,3 @@ export const ledgerNamespaces = {
   BCOVRIN_TEST: 'bcovrin:test',
   GREEN_LIGHT: 'bcovrin:greenlight',
 };
-
-export default {
-  LEDGER_GENESIS,
-};

apps/ssi-abstraction/src/agent/utils/listener.spec.ts

-import { subscribe } from './listener.js';
-
-describe('listener', () => {
-  it('should subscribe agent to available events', async () => {
-    const agent = {
-      events: {
-        on: (eventName: string, cb: () => void) => {},
-      },
-    };
-
-    const natsClient = {
-      publish: () => {},
-    };
-    const spyPublish = jest.spyOn(natsClient, 'publish');
-
-    let lastCb = null;
-
-    const spy = jest
-      .spyOn(agent.events, 'on')
-      .mockImplementation((eventName: string, cb: () => void) => {
-        lastCb = cb;
-      });
-    // @ts-ignore
-    subscribe(agent, natsClient);
-    expect(spy).toHaveBeenCalled();
-    expect(spy).toHaveBeenCalledTimes(7);
-    spy.mockRestore();
-
-    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
-    // @ts-ignore
-    lastCb({ payload: 'payload' });
-    expect(spyPublish).toHaveBeenCalled();
-    expect(spyPublish).toHaveBeenCalledTimes(1);
-  });
-});

apps/ssi-abstraction/src/agent/utils/listener.ts

-import { Agent } from '@aries-framework/core';
-import logger from '../../globalUtils/logger.js';
-import { NatsClientService } from '../../client/nats.client.js';
-import { listenerConfig } from './listenerConfig.js';
-
-/**
- * Subscribes to events on nats
- *
- * @param agent - the agent that has been initialized on startup
- * @param natsClient - the client that specifies how events are published
- */
-export const subscribe = (agent: Agent, natsClient: NatsClientService) => {
-  for (let i = 0; i < listenerConfig.length; i += 1) {
-    agent.events.on(listenerConfig[i], ({ payload }) => {
-      logger.info(
-        `${listenerConfig[i]} called. Payload: ${JSON.stringify(payload)}`,
-      );
-      natsClient.publish(listenerConfig[i], payload);
-    });
-  }
-};
-
-export default {
-  subscribe,
-};

apps/ssi-abstraction/src/agent/utils/listenerConfig.ts

-import {
-  BasicMessageEventTypes,
-  ConnectionEventTypes,
-  CredentialEventTypes,
-  ProofEventTypes,
-  RoutingEventTypes,
-  TransportEventTypes,
-} from '@aries-framework/core';
-
-export const listenerConfig = [
-  BasicMessageEventTypes.BasicMessageStateChanged,
-  ConnectionEventTypes.ConnectionStateChanged,
-  CredentialEventTypes.CredentialStateChanged,
-  ProofEventTypes.ProofStateChanged,
-  RoutingEventTypes.MediationStateChanged,
-  RoutingEventTypes.RecipientKeylistUpdated,
-  TransportEventTypes.OutboundWebSocketClosedEvent,
-];
-
-export default {
-  listenerConfig,
-};

apps/ssi-abstraction/src/agent/utils/logger.ts

 import { BaseLogger, LogLevel } from '@aries-framework/core';
-import logger from '../../globalUtils/logger.js';
+import { logger } from '../../globalUtils/logger.js';
 
 export class AgentLogger extends BaseLogger {
   public test(
@@ -58,5 +58,3 @@ export class AgentLogger extends BaseLogger {
     logger.error(message, data);
   }
 }
-
-export default AgentLogger;

apps/ssi-abstraction/src/client/nats.client.ts

-import { Inject, Injectable } from '@nestjs/common';
-import { ClientProxy } from '@nestjs/microservices';
-import { NATSServices } from '../common/constants.js';
-import logger from '../globalUtils/logger.js';
-
-@Injectable()
-export class NatsClientService {
-  constructor(@Inject(NATSServices.SERVICE_NAME) private client: ClientProxy) {}
-
-  /**
-   * Publishes events on nats
-   * Generates the event as an object with 'endpoint' key
-   * that specifies the ServiceName/eventName.
-   *
-   * @param eventName - the event name
-   * @param data - the data to be passed as payload of the event
-   */
-  publish<D = unknown>(eventName: string, data: D) {
-    logger.info(
-      `Publish nats event: ${NATSServices.SERVICE_NAME}/${eventName}`,
-    );
-
-    const event = {
-      endpoint: `${NATSServices.SERVICE_NAME}/${eventName}`,
-    };
-
-    this.client.emit(event, data);
-  }
-}
-
-export default { NatsClientService };

apps/ssi-abstraction/src/globalUtils/logger.ts

 import winston, { Logger } from 'winston';
 import ecsFormat from '@elastic/ecs-winston-format';
 
-const logger: Logger = winston.createLogger({
+export const logger: Logger = winston.createLogger({
   format: ecsFormat({ convertReqRes: true }),
   transports: [new winston.transports.Console()],
 });
@@ -9,5 +9,3 @@ const logger: Logger = winston.createLogger({
 logger.on('error', (error: Error) => {
   console.error('Error in logger caught', error);
 });
-
-export default logger;

apps/ssi-abstraction/src/globalUtils/swagger.ts

-import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
-import { INestApplication } from '@nestjs/common';
-
-/**
- * Setup for swagger endpoint documentation
- *
- *
- * @param app - Nest.js internal config object
- */
-export default function swaggerSetup(app: INestApplication): void {
-  const swaggerConfig = new DocumentBuilder()
-    .setTitle('Gaia-x SSI Abstraction service')
-    .setDescription('API documentation for GAIA-X SSI Abstraction service')
-    .setVersion('1.0')
-    .build();
-
-  const document = SwaggerModule.createDocument(app, swaggerConfig);
-
-  SwaggerModule.setup('/swagger', app, document);
-}

apps/ssi-abstraction/src/middleware/agentMid.middleware.ts

@@ -36,5 +36,3 @@ export class AgentMid implements NestMiddleware {
     next();
   }
 }
-
-export default { AgentMid };