feat: yape challenge solution

.gitignore

@@ -1,104 +1,56 @@
+# compiled output
+/dist
+/node_modules
+/build
+
 # Logs
 logs
 *.log
 npm-debug.log*
+pnpm-debug.log*
 yarn-debug.log*
 yarn-error.log*
 lerna-debug.log*
 
-# Diagnostic reports (https://nodejs.org/api/report.html)
-report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+# OS
+.DS_Store
+
+# Tests
+/coverage
+/.nyc_output
+
+# IDEs and editors
+/.idea
+.project
+.classpath
+.c9/
+*.launch
+.settings/
+*.sublime-workspace
+
+# IDE - VSCode
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+
+# dotenv environment variable files
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# temp directory
+.temp
+.tmp
 
 # Runtime data
 pids
 *.pid
 *.seed
 *.pid.lock
 
-# Directory for instrumented libs generated by jscoverage/JSCover
-lib-cov
-
-# Coverage directory used by tools like istanbul
-coverage
-*.lcov
-
-# nyc test coverage
-.nyc_output
-
-# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
-.grunt
-
-# Bower dependency directory (https://bower.io/)
-bower_components
-
-# node-waf configuration
-.lock-wscript
-
-# Compiled binary addons (https://nodejs.org/api/addons.html)
-build/Release
-
-# Dependency directories
-node_modules/
-jspm_packages/
-
-# TypeScript v1 declaration files
-typings/
-
-# TypeScript cache
-*.tsbuildinfo
-
-# Optional npm cache directory
-.npm
-
-# Optional eslint cache
-.eslintcache
-
-# Microbundle cache
-.rpt2_cache/
-.rts2_cache_cjs/
-.rts2_cache_es/
-.rts2_cache_umd/
-
-# Optional REPL history
-.node_repl_history
-
-# Output of 'npm pack'
-*.tgz
-
-# Yarn Integrity file
-.yarn-integrity
-
-# dotenv environment variables file
-.env
-.env.test
-
-# parcel-bundler cache (https://parceljs.org/)
-.cache
-
-# Next.js build output
-.next
-
-# Nuxt.js build / generate output
-.nuxt
-dist
-
-# Gatsby files
-.cache/
-# Comment in the public line in if your project uses Gatsby and *not* Next.js
-# https://nextjs.org/blog/next-9-1#public-directory-support
-# public
-
-# vuepress build output
-.vuepress/dist
-
-# Serverless directories
-.serverless/
-
-# FuseBox cache
-.fusebox/
-
-# DynamoDB Local files
-.dynamodb/
-
-# TernJS port file
-.tern-port
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json

.prettierrc

@@ -0,0 +1,4 @@
+{
+  "singleQuote": true,
+  "trailingComma": "all"
+}

Dockerfile

@@ -0,0 +1,12 @@
+FROM node:18-alpine
+
+WORKDIR /app
+
+COPY package*.json ./
+RUN npm install
+
+COPY . .
+
+RUN npm run build
+
+RUN npm run build anti-fraud

apps/anti-fraud/src/anti-fraud.controller.spec.ts

@@ -0,0 +1,22 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { AntiFraudController } from './anti-fraud.controller';
+import { AntiFraudService } from './anti-fraud.service';
+
+describe('AntiFraudController', () => {
+  let antiFraudController: AntiFraudController;
+
+  beforeEach(async () => {
+    const app: TestingModule = await Test.createTestingModule({
+      controllers: [AntiFraudController],
+      providers: [AntiFraudService],
+    }).compile();
+
+    antiFraudController = app.get<AntiFraudController>(AntiFraudController);
+  });
+
+  describe('root', () => {
+    it('should return "Hello World!"', () => {
+      expect(antiFraudController.getHello()).toBe('Hello World!');
+    });
+  });
+});

apps/anti-fraud/src/anti-fraud.controller.ts

@@ -0,0 +1,14 @@
+import { Controller, Get } from '@nestjs/common';
+import { AntiFraudService } from './anti-fraud.service';
+import { EventPattern, Payload } from '@nestjs/microservices';
+
+@Controller()
+export class AntiFraudController {
+  constructor(private readonly antiFraudService: AntiFraudService) {}
+
+  @EventPattern('transaction_created')
+  handleTransactionCreated(@Payload() message: any) {
+    const transactionData = message.value ? message.value : message;
+    this.antiFraudService.handleTransactionValidation(transactionData);
+  }
+}

apps/anti-fraud/src/anti-fraud.module.ts

@@ -0,0 +1,31 @@
+import { Module } from '@nestjs/common';
+import { AntiFraudController } from './anti-fraud.controller';
+import { AntiFraudService } from './anti-fraud.service';
+import { ConfigModule } from '@nestjs/config';
+import { ClientsModule, Transport } from '@nestjs/microservices';
+
+@Module({
+  imports: [
+    ConfigModule.forRoot({ isGlobal: true }),
+    ClientsModule.register([
+      {
+        name: 'KAFKA_SERVICE',
+        transport: Transport.KAFKA,
+        options: {
+          client: {
+            brokers: [process.env.KAFKA_BROKER || 'kafka:9092'],
+          },
+          consumer: {
+            groupId: 'anti-fraud-consumer',
+          },
+          subscribe: {
+            fromBeginning: true,
+          },
+        },
+      },
+    ]),
+  ],
+  controllers: [AntiFraudController],
+  providers: [AntiFraudService],
+})
+export class AntiFraudModule {}

apps/anti-fraud/src/anti-fraud.service.ts

@@ -0,0 +1,27 @@
+import { Inject, Injectable, OnModuleInit } from '@nestjs/common';
+import { ClientKafka } from '@nestjs/microservices';
+
+@Injectable()
+export class AntiFraudService implements OnModuleInit {
+  constructor(
+    @Inject('KAFKA_SERVICE') private readonly kafkaClient: ClientKafka,
+  ) {}
+
+  async onModuleInit() {
+    await this.kafkaClient.connect();
+  }
+
+  handleTransactionValidation(data: any) {
+    const { transactionExternalId, transactionValue } = data;
+    const status = transactionValue > 1000 ? 'rejected' : 'approved';
+
+    console.log(`Transaction ${transactionExternalId} with value ${transactionValue}. Status: ${status}`);
+
+    const payload = {
+      transactionExternalId,
+      status,
+    };
+
+    this.kafkaClient.emit('transaction_status_updated', JSON.stringify(payload));
+  }
+}

apps/anti-fraud/src/main.ts

@@ -0,0 +1,25 @@
+import { NestFactory } from '@nestjs/core';
+import { AntiFraudModule } from './anti-fraud.module';
+import { MicroserviceOptions } from '@nestjs/microservices';
+import { Transport } from '@nestjs/microservices';
+
+async function bootstrap() {
+  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
+    AntiFraudModule,
+    {
+      transport: Transport.KAFKA,
+      options: {
+        client: {
+          brokers: [process.env.KAFKA_BROKER || 'kafka:9092'],
+        },
+        consumer: {
+          groupId: 'anti-fraud-consumer',
+        },
+      },
+    },
+  );
+
+  await app.listen();
+}
+
+bootstrap();

apps/anti-fraud/test/app.e2e-spec.ts

@@ -0,0 +1,24 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { INestApplication } from '@nestjs/common';
+import * as request from 'supertest';
+import { AntiFraudModule } from './../src/anti-fraud.module';
+
+describe('AntiFraudController (e2e)', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const moduleFixture: TestingModule = await Test.createTestingModule({
+      imports: [AntiFraudModule],
+    }).compile();
+
+    app = moduleFixture.createNestApplication();
+    await app.init();
+  });
+
+  it('/ (GET)', () => {
+    return request(app.getHttpServer())
+      .get('/')
+      .expect(200)
+      .expect('Hello World!');
+  });
+});

apps/anti-fraud/test/jest-e2e.json

@@ -0,0 +1,9 @@
+{
+  "moduleFileExtensions": ["js", "json", "ts"],
+  "rootDir": ".",
+  "testEnvironment": "node",
+  "testRegex": ".e2e-spec.ts$",
+  "transform": {
+    "^.+\\.(t|j)s$": "ts-jest"
+  }
+}

apps/anti-fraud/tsconfig.app.json

@@ -0,0 +1,9 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "declaration": false,
+    "outDir": "../../dist/apps/anti-fraud"
+  },
+  "include": ["src/**/*"],
+  "exclude": ["node_modules", "dist", "test", "**/*spec.ts"]
+}

apps/yape-challenge/src/app.controller.spec.ts

@@ -0,0 +1,22 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { AppController } from './app.controller';
+import { AppService } from './app.service';
+
+describe('AppController', () => {
+  let appController: AppController;
+
+  beforeEach(async () => {
+    const app: TestingModule = await Test.createTestingModule({
+      controllers: [AppController],
+      providers: [AppService],
+    }).compile();
+
+    appController = app.get<AppController>(AppController);
+  });
+
+  describe('root', () => {
+    it('should return "Hello World!"', () => {
+      expect(appController.getHello()).toBe('Hello World!');
+    });
+  });
+});

apps/yape-challenge/src/app.controller.ts

@@ -0,0 +1,28 @@
+import { Body, Controller, Get, Param, Post } from '@nestjs/common';
+import { AppService } from './app.service';
+import { CreateTransactionDto } from './dto/create-transaction.dto';
+import { EventPattern, Payload } from '@nestjs/microservices';
+
+@Controller('transactions')
+export class AppController {
+  constructor(private readonly appService: AppService,) {}
+
+  @Post()
+  create(@Body() createTransactionDto: CreateTransactionDto) {
+    return this.appService.createTransaction(createTransactionDto);
+  }
+
+  @Get(':id')
+  findOne(@Param('id') id: string) {
+    return this.appService.findTransaction(id);
+  }
+
+  @EventPattern('transaction_status_updated')
+  async handleTransactionStatusUpdated(@Payload() message: any) {
+    const data = message.value ? message.value : message;
+
+    console.log(`Update Request Received for: ${data.transactionExternalId} with status ${data.status}`);
+
+    await this.appService.updateStatus(data.transactionExternalId, data.status);
+  }
+}