feat(SPG-125) Logging

pull/37/head
Aswin Ashar Abdullah 2024-07-23 19:54:00 +07:00
parent aa550f9d38
commit d0163ae003
2 changed files with 26 additions and 6 deletions

View File

@ -1,9 +1,33 @@
import { EventsHandler, IEventHandler } from '@nestjs/cqrs'; import { EventsHandler, IEventHandler } from '@nestjs/cqrs';
import { RecordLog } from '../entities/log.event'; import { RecordLog } from '../entities/log.event';
import { LogService } from '../../data/services/log.service';
import { LogModel } from '../../data/models/log.model';
@EventsHandler(RecordLog) @EventsHandler(RecordLog)
export class RecordLogHandler implements IEventHandler<RecordLog> { export class RecordLogHandler implements IEventHandler<RecordLog> {
constructor(private dataService: LogService) {}
async handle(event: RecordLog) { async handle(event: RecordLog) {
// TODO: Implement logic here const data = event.data;
const queryRunner = this.dataService
.getRepository()
.manager.connection.createQueryRunner();
const log = new LogModel();
Object.assign(log, {
data_id: data.id,
module: data.module,
description: data.description,
process: data.op,
old_data: data.old,
data: data.data,
created_at: new Date().getTime(),
creator_name: data.user.name,
creator_id: data.user.id,
});
await this.dataService.create(queryRunner, LogModel, log);
} }
} }

View File

@ -31,11 +31,7 @@ export class RecordPosLogHandler implements IEventHandler<ChangeDocEvent> {
created_at: data.created_at, created_at: data.created_at,
}); });
await this.dataService.create( await this.dataService.create(queryRunner, PosLogModel, activity);
queryRunner,
PosLogModel,
activity,
);
} catch (error) { } catch (error) {
console.log('error handling pos activity couch'); console.log('error handling pos activity couch');
} }