diff --git a/src/modules/configuration/log/domain/handlers/log.handler.ts b/src/modules/configuration/log/domain/handlers/log.handler.ts index 1e4fafb..73817e9 100644 --- a/src/modules/configuration/log/domain/handlers/log.handler.ts +++ b/src/modules/configuration/log/domain/handlers/log.handler.ts @@ -1,9 +1,33 @@ import { EventsHandler, IEventHandler } from '@nestjs/cqrs'; import { RecordLog } from '../entities/log.event'; +import { LogService } from '../../data/services/log.service'; +import { LogModel } from '../../data/models/log.model'; @EventsHandler(RecordLog) export class RecordLogHandler implements IEventHandler { + constructor(private dataService: LogService) {} + 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); } } diff --git a/src/modules/configuration/log/domain/handlers/pos-log.handler.ts b/src/modules/configuration/log/domain/handlers/pos-log.handler.ts index 7b794ff..57f7e07 100644 --- a/src/modules/configuration/log/domain/handlers/pos-log.handler.ts +++ b/src/modules/configuration/log/domain/handlers/pos-log.handler.ts @@ -31,11 +31,7 @@ export class RecordPosLogHandler implements IEventHandler { created_at: data.created_at, }); - await this.dataService.create( - queryRunner, - PosLogModel, - activity, - ); + await this.dataService.create(queryRunner, PosLogModel, activity); } catch (error) { console.log('error handling pos activity couch'); }