src/modules/configuration/midtrans/data/services/midtrans.service.ts

@@ -1,25 +1,12 @@
 import { Injectable } from '@nestjs/common';
+import { EventBus } from '@nestjs/cqrs';
 import { mappingMidtransTransaction } from '../../domain/usecases/helpers/mapping-transaction.helper';
 import { Snap } from 'midtrans-client';
 import { MidtransStatus } from '../../domain/entities/midtrans-callback.event';
-import { TransactionReadService } from 'src/modules/transaction/transaction/data/services/transaction-read.service';
-
-import * as moment from 'moment';
 
 @Injectable()
 export class MidtransService {
-  constructor(private transaction: TransactionReadService) {}
-
-  isMoreThan24HoursAgo(dateString) {
-    const date = moment(dateString, 'YYYY-MM-DD', true);
-    if (!date.isValid()) {
-      return false;
-    }
-
-    const now = moment();
-    const diffInHours = now.diff(date, 'hours');
-    return diffInHours > 24;
-  }
+  constructor(private eventBus: EventBus) {}
 
   get midtransInstance() {
     return new Snap({
@@ -33,28 +20,6 @@ export class MidtransService {
     return await this.midtransInstance.transaction.status(orderId);
   }
 
-  async syncPendingStatus(): Promise<any[]> {
-    const pendingIds = await this.transaction.getPendingOrderId();
-    const responses = [];
-
-    for (const transaction of pendingIds) {
-      const { id, invoice_date } = transaction;
-      let status;
-      try {
-        status = await this.getStatus(id);
-      } catch (error) {
-        status = {
-          order_id: id,
-          transaction_status: this.isMoreThan24HoursAgo(invoice_date)
-            ? 'cancel'
-            : 'pending',
-        };
-      }
-      responses.push(status);
-    }
-    return responses;
-  }
-
   async changeStatus(orderId: string, action: MidtransStatus): Promise<any> {
     return await this.midtransInstance.transaction[action](orderId);
   }

src/modules/configuration/midtrans/infrastructure/midtrans.controller.ts

@@ -46,27 +46,6 @@ export class MidtransController {
     }
   }
 
-  @Get('sync')
-  async syncStatus() {
-    try {
-      const results = await this.dataService.syncPendingStatus();
-
-      for (const data of results) {
-        this.eventBus.publishAll([
-          new MidtransCallbackEvent({
-            id: data.order_id,
-            data: data,
-          }),
-        ]);
-      }
-
-      return 'Berhasil update status transaksi';
-    } catch (error) {
-      console.log(error.message);
-      throw new Error('Gagal update status transaksi');
-    }
-  }
-
   @Get(':id/change-status')
   @ApiQuery({ name: 'status', enum: MidtransStatus })
   async cancel(

src/modules/configuration/midtrans/midtrans.module.ts

@@ -3,20 +3,12 @@ import { CqrsModule } from '@nestjs/cqrs';
 import { MidtransController } from './infrastructure/midtrans.controller';
 import { MidtransService } from './data/services/midtrans.service';
 import { Global, Module } from '@nestjs/common';
-import { TransactionReadService } from 'src/modules/transaction/transaction/data/services/transaction-read.service';
-import { TypeOrmModule } from '@nestjs/typeorm';
-import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
-import { TransactionModel } from 'src/modules/transaction/transaction/data/models/transaction.model';
 
 @Global()
 @Module({
-  imports: [
-    ConfigModule.forRoot(),
-    CqrsModule,
-    TypeOrmModule.forFeature([TransactionModel], CONNECTION_NAME.DEFAULT),
-  ],
+  imports: [ConfigModule.forRoot(), CqrsModule],
   controllers: [MidtransController],
-  providers: [MidtransService, TransactionReadService],
+  providers: [MidtransService],
   exports: [MidtransService],
 })
 export class MidtransModule {}

src/modules/transaction/transaction/data/services/transaction-read.service.ts

@@ -2,13 +2,9 @@ import { Injectable } from '@nestjs/common';
 import { TransactionEntity } from '../../domain/entities/transaction.entity';
 import { InjectRepository } from '@nestjs/typeorm';
 import { TransactionModel } from '../models/transaction.model';
-import {
-  CONNECTION_NAME,
-  STATUS,
-} from 'src/core/strings/constants/base.constants';
+import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
 import { Repository } from 'typeorm';
 import { BaseReadService } from 'src/core/modules/data/service/base-read.service';
-import { TransactionPaymentType } from '../../constants';
 
 @Injectable()
 export class TransactionReadService extends BaseReadService<TransactionEntity> {
@@ -18,16 +14,4 @@ export class TransactionReadService extends BaseReadService<TransactionEntity> {
   ) {
     super(repo);
   }
-
-  async getPendingOrderId() {
-    const transactions = await this.repo.find({
-      where: {
-        status: STATUS.PENDING,
-        payment_type: TransactionPaymentType.MIDTRANS,
-      },
-      select: ['id', 'invoice_date'],
-    });
-
-    return transactions;
-  }
 }

src/modules/transaction/transaction/transaction.module.ts

@@ -37,7 +37,6 @@ import { PaymentMethodDataService } from '../payment-method/data/services/paymen
 import { PaymentMethodModel } from '../payment-method/data/models/payment-method.model';
 
 @Module({
-  exports: [TransactionReadService],
   imports: [
     ConfigModule.forRoot(),
     TypeOrmModule.forFeature(