SIMS
/
scb-rtgs-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

`feat: updated config files, database connection, and rtgs service to support uat environment and encryption/decryption`

Browse Source
main
Josh 1 year ago
parent 8fcc5c21b5
commit d268570e1e
11 changed files with 23763 additions and 49 deletions
Show Stats Download Patch File Download Diff File

10
config/default.yml
Unescape Escape View File

@ -1,9 +1,9 @@
server: server:
port: 3100 port: 3100
db: db:
type: 'postgres' type: ''
port: '5434' port: ''
sid: 'appliq-dummy' sid: ''
jwt: jwt:
@ -15,5 +15,7 @@ otp:
crypto: crypto:
accessToken: 'accessToken@#123' accessToken: 'accessToken@#123'
refreshToken: 'refreshToken@#123' refreshToken: 'refreshToken@#123'
commonKey: 'APPLIQ' commonKey: 'RTGS'
sibKey : 'BPXEUYLSSLHUVETSJENXTCRAYNVEJBFRAV'
sibIv : 'IWUHTQDKCWEXWIJENXTCRAYNVEJBFRAV'

8
config/development.yml
Unescape Escape View File

@ -1,8 +1,8 @@
db: db:
host: '161.97.157.52' host: ''
username: 'postgres' username: ''
password: 'inv123' password: ''
sid: 'appliq-dummy' sid: ''
synchronize: false synchronize: false
jwt: jwt:

11
data/database.json
Unescape Escape View File

@ -1,12 +1,21 @@
[ [
{ {
"VAN": "KGZASCB", "VAN": "KGZASCB",
"tag": "scb-dev", "tag": "uat",
"host": "111.92.84.50", "host": "111.92.84.50",
"username": "corepacs", "username": "corepacs",
"password": "corepacs", "password": "corepacs",
"sid": "pacs", "sid": "pacs",
"port":1521, "port":1521,
"bankName":"KANGAZHA_SCB_UAT"
}, {
"VAN": "KGZASCB",
"tag": "live",
"host": "103.160.232.13",
"username": "corepacs",
"password": "corepacs",
"sid": "pacs",
"port":1521,
"bankName":"KANGAZHA_SCB" "bankName":"KANGAZHA_SCB"
} }
] ]

23599
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

1
package.json
Unescape Escape View File

@ -33,6 +33,7 @@
"@nestjs/typeorm": "^9.0.1", "@nestjs/typeorm": "^9.0.1",
"@types/passport-jwt": "^3.0.8", "@types/passport-jwt": "^3.0.8",
"config": "^3.3.9", "config": "^3.3.9",
"crypto-js": "^4.2.0",
"npm": "^9.8.1", "npm": "^9.8.1",
"oracledb": "^5.1.0", "oracledb": "^5.1.0",
"rimraf": "^3.0.2", "rimraf": "^3.0.2",

4
src/auth/auth.module.ts
Unescape Escape View File

@ -3,10 +3,6 @@ import { AuthController } from './auth.controller';
import { AuthService } from './auth.service'; import { AuthService } from './auth.service';
import * as config from 'config'; import * as config from 'config';
import { PassportModule } from '@nestjs/passport'; import { PassportModule } from '@nestjs/passport';
const jwtConfig = config.get('jwt');
@Module({ @Module({
imports: [], imports: [],
controllers: [AuthController], controllers: [AuthController],

48
src/auth/crypto.service.ts
Unescape Escape View File

@ -0,0 +1,48 @@
import { Injectable } from '@nestjs/common';
const crypto = require('crypto');
@Injectable()
export class CryptoService {
constructor() { }
encrypt(plainText, secretKey, iv) {
try {
if (typeof plainText !== 'string') {
plainText = JSON.stringify(plainText);
}
const cipher = crypto.createCipheriv('aes-256-cbc', Buffer.from(secretKey.substring(0, 32), 'utf8'), Buffer.from(iv.substring(0, 16), 'utf8'));
let encrypted = cipher.update(plainText, 'utf8', 'hex');
encrypted += cipher.final('hex');
return encrypted;
} catch (error) {
console.error('Encryption failed:', error.message); // Log any error during encryption
throw new Error('Encryption failed');
}
}
decrypt(encryptedValue, secretKey, iv) {
try {
// console.log("encryptedValue--",encryptedValue);
// console.log("secretKey--",secretKey);
// console.log("iv--",iv);
const key = Buffer.from(secretKey.substring(0, 32), 'utf-8'); // AES-256 key size
const ivBuffer = Buffer.from(iv.substring(0, 16), 'utf-8'); // AES-CBC IV size
const encryptedBuffer = Buffer.from(encryptedValue, 'hex');
const decipher = crypto.createDecipheriv('aes-256-cbc', key, ivBuffer);
let decrypted = decipher.update(encryptedBuffer);
decrypted = Buffer.concat([decrypted, decipher.final()]);
return decrypted.toString('utf-8');
} catch (error) {
console.error('Decryption failed:', error.message);
throw new Error('Decryption failed');
}
}
}

10
src/pipe/connection.pipe.ts
Unescape Escape View File

@ -1,15 +1,15 @@
import { BadRequestException } from '@nestjs/common'; import { BadRequestException } from '@nestjs/common';
import * as database from 'data/database.json'; import * as database from 'data/database.json';
const oracledb = require('oracledb'); const oracledb = require('oracledb');
export async function connectOraDatabase(VAN:string){ export async function connectOraDatabase(tag:string){
console.log('~~~~Bank Code',VAN); console.log('~~~~tag Code',tag);
let connection let connection
let config = database.filter(data => { let config = database.filter(data => {
return data.VAN == VAN return data.tag == tag
}); });
if (!config[0]) if (!config[0])
throw new BadRequestException('Invalid Bank Code') throw new BadRequestException('Invalid tag Code')
let dbConfig = config[0] let dbConfig = config[0]
try { try {
@ -18,7 +18,7 @@ export async function connectOraDatabase(VAN:string){
password: dbConfig.password, password: dbConfig.password,
connectString: `${dbConfig.host}/${dbConfig.sid}` connectString: `${dbConfig.host}/${dbConfig.sid}`
}); });
console.log(`created connection ${new Date} BANK:${VAN} NAME: ${dbConfig.tag}`); console.log(`created connection ${new Date} BANK:${dbConfig.bankName} NAME: ${dbConfig.tag}`);
} catch (err) { } catch (err) {

31
src/tables/rtgs/rtgs.controller.ts
Unescape Escape View File

@ -1,18 +1,43 @@
import { Body, Controller, Post } from '@nestjs/common'; import { Body, Controller, Post } from '@nestjs/common';
import { RtgsService } from './rtgs.service'; import { RtgsService } from './rtgs.service';
import { rtgsDto } from 'src/dto/rtgs.dto'; import { rtgsDto } from 'src/dto/rtgs.dto';
import { CryptoService } from 'src/auth/crypto.service';
import * as config from 'config';
@Controller('rtgs') @Controller('rtgs')
export class RtgsController { export class RtgsController {
constructor(private readonly rtgsService: RtgsService) {} constructor(
private readonly rtgsService: RtgsService,
private cryptoService : CryptoService
) {}
@Post() @Post()
async createRtgs(@Body() rtgsDto: rtgsDto): Promise<any>{ async createRtgs(@Body() rtgsDto: rtgsDto): Promise<any>{
return await this.rtgsService.rtgsEntryPosting(rtgsDto) return await this.rtgsService.rtgsEntryPosting(rtgsDto,"live")
} }
@Post('validation') @Post('validation')
async validatingRtgs(@Body() rtgsDto: rtgsDto): Promise<any>{ async validatingRtgs(@Body() rtgsDto: rtgsDto): Promise<any>{
return await this.rtgsService.validatingRtgs(rtgsDto) return await this.rtgsService.validatingRtgs(rtgsDto,"live")
}
@Post('uat')
async createRtgsUat(@Body() rtgsDto: rtgsDto): Promise<any>{
return await this.rtgsService.rtgsEntryPosting(rtgsDto,"uat")
}
@Post('validation/uat')
async validatingRtgsUat(@Body() rtgsDto: rtgsDto): Promise<any>{
return await this.rtgsService.validatingRtgs(rtgsDto,"uat")
}
@Post('encrypt')
async encryptRtgs(@Body() body: any): Promise<any>{
return await this.cryptoService.encrypt(body,config.get('crypto').sibKey,config.get('crypto').sibIv)
}
@Post('decrypt')
async decryptRtgs(@Body() body: any): Promise<any>{
return await this.cryptoService.decrypt(body.data,config.get('crypto').sibKey,config.get('crypto').sibIv)
} }
} }

3
src/tables/rtgs/rtgs.module.ts
Unescape Escape View File

@ -1,9 +1,10 @@
import { Module } from '@nestjs/common'; import { Module } from '@nestjs/common';
import { RtgsController } from './rtgs.controller'; import { RtgsController } from './rtgs.controller';
import { RtgsService } from './rtgs.service'; import { RtgsService } from './rtgs.service';
import { CryptoService } from 'src/auth/crypto.service';
@Module({ @Module({
controllers: [RtgsController], controllers: [RtgsController],
providers: [RtgsService] providers: [RtgsService,CryptoService]
}) })
export class RtgsModule {} export class RtgsModule {}

83
src/tables/rtgs/rtgs.service.ts
Unescape Escape View File

@ -1,23 +1,38 @@
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { CryptoService } from 'src/auth/crypto.service';
import { rtgsDto } from 'src/dto/rtgs.dto'; import { rtgsDto } from 'src/dto/rtgs.dto';
import { closeOraConnection, connectOraDatabase } from 'src/pipe/connection.pipe'; import { closeOraConnection, connectOraDatabase } from 'src/pipe/connection.pipe';
const oracledb = require('oracledb'); const oracledb = require('oracledb');
import * as config from 'config';
@Injectable() @Injectable()
export class RtgsService { export class RtgsService {
async rtgsEntryPosting(data: rtgsDto) { constructor(
const connection = await this.createConnection(data.VAN); private cryptoService : CryptoService
console.log("hereeeee", data.date); ){
}
async rtgsEntryPosting(data: rtgsDto , tag : string) {
let res = await this.cryptoService.decrypt(data['EncRequestData'],config.get('crypto').sibKey,config.get('crypto').sibIv);
let decryptedData = JSON.parse(res)
// console.log(decryptedData);
const connection = await this.createConnection(tag);
try { try {
let sql = `begin SIB_INWARD_INSERT( let sql = `begin SIB_INWARD_INSERT(
'${data.clientCode}','${data.VAN}','${data.vCode}','${data.bankUTR}',null,to_date('${data.date}', 'DD-MM-YYYY'),null,null,null,null, '${decryptedData.clientCode}','${decryptedData.VAN}','${decryptedData.vCode}','${decryptedData.bankUTR}',null,to_date('${decryptedData.date}', 'YYYY-MM-DD HH24:MI:SS'),null,null,null,null,
'${data.sendertoReceiverInformation}',null,'${data.remitterAccountnumber}','${data.remitterName}','${data.remitterIFSC}','${data.modeofTXN}','${data.amount}','${data.corpTXNID}','${data.corptxnStatus}','${data.statusCode}', '${decryptedData.sendertoReceiverInformation}',null,'${decryptedData.remitterAccountnumber}','${decryptedData.remitterName}','${decryptedData.remitterIFSC}','${decryptedData.modeofTXN}','${decryptedData.amount}','${decryptedData.corpTXNID}','${decryptedData.corptxnStatus}','${decryptedData.statusCode}',
'${data.statusMessage}',null,null,null,null,null,null,null,null,null, '${decryptedData.statusMessage}',null,null,null,null,null,null,null,null,null,
null,null,null, :OUT_IN_STATUS, :OUT_STATUS_CODE, :OUT_STATUS_MSG null,null,null, :OUT_IN_STATUS, :OUT_STATUS_CODE, :OUT_STATUS_MSG
); );
end;` end;`
console.log(sql);
// let res = await connection.execute(sql, [], { outFormat: oracledb.OBJECT }); // let res = await connection.execute(sql, [], { outFormat: oracledb.OBJECT });
let res = await connection.execute( let res = await connection.execute(
sql, sql,
@ -28,17 +43,29 @@ export class RtgsService {
], ],
{ outFormat: oracledb.OBJECT } { outFormat: oracledb.OBJECT }
); );
console.log("payload===== ",data);
console.log('OUT_IN_STATUS:', res.outBinds[0]); console.log('OUT_IN_STATUS:', res.outBinds[0]);
console.log('OUT_STATUS_CODE:', res.outBinds[1]); console.log('OUT_STATUS_CODE:', res.outBinds[1]);
console.log('OUT_STATUS_MSG:', res.outBinds[2]); console.log('OUT_STATUS_MSG:', res.outBinds[2]);
if(res){ if(res){
return { let result = {
OUT_IN_STATUS: res.outBinds[0], clientCode: decryptedData.clientCode,
OUT_STATUS_CODE: res.outBinds[1], VAN: decryptedData.VAN,
OUT_STATUS_MSG: res.outBinds[2] vCode: decryptedData.vCode,
bankUTR: decryptedData.bankUTR,
amount: decryptedData.amount,
modeofTXN: decryptedData.modeofTXN,
date: decryptedData.date,
remitterName: decryptedData.remitterName,
remitterAccountnumber: decryptedData.remitterAccountnumber,
sendertoReceiverInformation: decryptedData.sendertoReceiverInformation,
remitterIFSC: decryptedData.remitterIFSC,
corptxnStatus: res.outBinds[0],
statusCode: res.outBinds[1],
statusMessage: res.outBinds[2]
}; };
let encrypt = await this.cryptoService.encrypt(result,config.get('crypto').sibKey,config.get('crypto').sibIv)
return {ClientCode : decryptedData.clientCode,EncResponseData : encrypt}
} }
}catch(err){ }catch(err){
@ -53,8 +80,8 @@ export class RtgsService {
} }
async createConnection(VAN: string) { async createConnection(tag: string) {
return await connectOraDatabase(VAN); return await connectOraDatabase(tag);
} }
async closeConnection(connection) { async closeConnection(connection) {
@ -62,14 +89,18 @@ export class RtgsService {
} }
async validatingRtgs(data: rtgsDto) { async validatingRtgs(data: rtgsDto, tag : string) {
const connection = await this.createConnection(data.VAN);
let res = await this.cryptoService.decrypt(data['EncRequestData'],config.get('crypto').sibKey,config.get('crypto').sibIv);
let decryptedData = JSON.parse(res)
const connection = await this.createConnection(tag);
try { try {
let sql = `begin SIB_INWARD_validation_api( let sql = `begin SIB_INWARD_validation_api(
'${data.clientCode}','${data.VAN}','${data.vCode}',null,null,null,null,null,null,null, '${decryptedData.clientCode}','${decryptedData.VAN}','${decryptedData.vCode}',null,null,null,null,null,null,null,
null,null,null,null,null,null,'${data.amount}',null,null,null, null,null,null,null,null,null,'${decryptedData.amount}',null,null,null,
'${data.statusMessage}',null,null,null,null,null,null,null,null,null, '${decryptedData.statusMessage}',null,null,null,null,null,null,null,null,null,
null,null,null, :OUT_IN_STATUS, :OUT_STATUS_CODE, :OUT_STATUS_MSG null,null,null, :OUT_IN_STATUS, :OUT_STATUS_CODE, :OUT_STATUS_MSG
); );
end;` end;`
@ -83,21 +114,23 @@ export class RtgsService {
], ],
{ outFormat: oracledb.OBJECT } { outFormat: oracledb.OBJECT }
); );
console.log("payload===== ",data); // console.log("payload===== ",data);
console.log('OUT_IN_STATUS:', res.outBinds[0]); console.log('OUT_IN_STATUS:', res.outBinds[0]);
console.log('OUT_STATUS_CODE:', res.outBinds[1]); console.log('OUT_STATUS_CODE:', res.outBinds[1]);
console.log('OUT_STATUS_MSG:', res.outBinds[2]); console.log('OUT_STATUS_MSG:', res.outBinds[2]);
if(res){ if(res){
return { let result = {
clientCode : data.clientCode, clientCode : decryptedData.clientCode,
VAN : data.VAN, VAN : decryptedData.VAN,
vCode : data.vCode, vCode : decryptedData.vCode,
amount : data.amount, amount : decryptedData.amount,
corptxnStatus: res.outBinds[0], corptxnStatus: res.outBinds[0],
statusCode: res.outBinds[1], statusCode: res.outBinds[1],
statusMessage: res.outBinds[2] statusMessage: res.outBinds[2]
}; };
let encrypt = await this.cryptoService.encrypt(result,config.get('crypto').sibKey,config.get('crypto').sibIv)
return {ClientCode : decryptedData.clientCode,EncResponseData : encrypt}
} }
}catch(err){ }catch(err){

Write Preview
Loading…
Cancel
Save