feat: add operation state module

Signed-off-by: Anmol Sharma <anmolsharma0234@gmail.com>

src/app.module.ts

@@ -6,6 +6,7 @@ import { ConfigModule, ConfigService } from '@nestjs/config';
 import configuration from '@/configuration';
 import { TransactionsModule } from '@/transactions/transactions.module';
 import { commandHandlers } from '@/commands/handlers';
+import { OperationStateModule } from '@/operation-state/operation-state.module';
 
 @Module({
     imports: [
@@ -29,6 +30,7 @@ import { commandHandlers } from '@/commands/handlers';
             }),
         }),
         TransactionsModule,
+        OperationStateModule,
     ],
     controllers: [AppController],
     providers: [AppService, ...commandHandlers],

src/operation-state/operation-state.entity.ts

@@ -0,0 +1,10 @@
+import { Column, Entity, PrimaryColumn } from 'typeorm';
+
+@Entity()
+export class OperationState {
+    @PrimaryColumn('text')
+    id: string;
+
+    @Column('jsonb')
+    state: any;
+}

src/operation-state/operation-state.module.ts

@@ -0,0 +1,12 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { OperationState } from '@/operation-state/operation-state.entity';
+import { OperationStateService } from '@/operation-state/operation-state.service';
+
+@Module({
+    imports: [TypeOrmModule.forFeature([OperationState])],
+    controllers: [],
+    providers: [OperationStateService],
+    exports: [OperationStateService],
+})
+export class OperationStateModule {}

src/operation-state/operation-state.service.ts

@@ -0,0 +1,23 @@
+import { Injectable } from '@nestjs/common';
+import { Repository } from 'typeorm';
+import { OperationState } from '@/operation-state/operation-state.entity';
+import { InjectRepository } from '@nestjs/typeorm';
+
+@Injectable()
+export class OperationStateService {
+    constructor(
+        @InjectRepository(OperationState)
+        private readonly operationStateRepository: Repository<OperationState>,
+    ) {}
+
+    async getOperationState(id: string): Promise<OperationState> {
+        return this.operationStateRepository.findOneBy({ id: id });
+    }
+
+    async setOperationState(id: string, state: any): Promise<OperationState> {
+        const operationState = new OperationState();
+        operationState.id = id;
+        operationState.state = state;
+        return this.operationStateRepository.save(operationState);
+    }
+}