feat(subscriber): cancel auction service

chainhook-subscriber/src/modules/auctionhistory/auction.history.module.ts

@@ -14,6 +14,7 @@ import { AuctionEntityRepositoryProvider } from '../auctions/providers/auction.r
 import { AuctionBidEntityRepositoryProvider } from '../auctions/providers/auction.bid.repository.provider';
 import { AuctionBidHistoryEntityRepositoryProvider } from './providers/auction.bid.history.repository.provider';
 import { AuctionHistoryEntityRepositoryProvider } from './providers/auction.history.repository.provider';
+import { CancelAuctionService } from './services/cancel.auction.service';
 
 @Module({
   imports: [
@@ -30,8 +31,9 @@ import { AuctionHistoryEntityRepositoryProvider } from './providers/auction.hist
     RabbitMQHealthService,
     RabbitmqService,
     StartAuctionService,
+    CancelAuctionService,
     AuctionHistoryService,
-    
+
     AuctionEntityRepositoryProvider,
     AuctionBidEntityRepositoryProvider,
     AuctionBidHistoryEntityRepositoryProvider,

chainhook-subscriber/src/modules/auctionhistory/services/cancel.auction.service.ts

@@ -0,0 +1,31 @@
+import { Inject, Injectable } from "@nestjs/common";
+import { StartAuction } from "src/models";
+import { AuctionEntityRepository } from "src/modules/auctions/repositories/auction.repository";
+import { AuctionEntityRepositoryToken } from "src/modules/auctions/providers/auction.repository.provider";
+import { Transactional } from "src/common/transaction/transaction";
+import { runOnTransactionComplete, runOnTransactionRollback } from "src/common/transaction/hook";
+import { AuctionEntity } from "src/modules/auctions/entities/auction.entity";
+
+@Injectable()
+export class CancelAuctionService {
+  constructor(
+    @Inject(AuctionEntityRepositoryToken)
+    private auctionRepository: AuctionEntityRepository
+  ) {}
+
+  @Transactional()
+  public async startAuction(startAuctionModel: StartAuction): Promise<void> {
+
+    runOnTransactionRollback((cb) =>
+      console.log('Rollback error ' + cb.message),
+    );
+
+    runOnTransactionComplete((_) => console.log('Transaction Complete'));
+
+    const auction = await this.auctionRepository.findOneOrFail({auctionId: Number(startAuctionModel["auction-id"].value)})
+
+    auction.status = startAuctionModel["auction-status"].value;
+
+    await this.auctionRepository.save(auction);
+  }
+}