Merge pull request #9 from shaaibu7/handle-donation-event

implement donation recieved event processing

prisma/schema.prisma

@@ -17,5 +17,6 @@ model Campaign {
   id               Int      @id
   campaign_address String
   campaign_owner   String
+  totalDonations   Int
   createdAt        DateTime
 }

src/app.module.ts

@@ -4,6 +4,7 @@ import { GraphQLModule } from '@nestjs/graphql';
 import { ApolloDriver, ApolloDriverConfig } from '@nestjs/apollo';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
+import { handleDonationReceivedService } from './donation.service';
 import { getEnvPath } from './common/utils';
 import { PrismaModule } from './prisma/prisma.module';
 import { SharedIndexerModule } from './shared-indexer/shared-indexer.module';
@@ -23,6 +24,6 @@ import { ResolversModule } from './resolvers/resolvers.module';
     ResolversModule,
   ],
   controllers: [AppController],
-  providers: [AppService],
+  providers: [AppService, handleDonationReceivedService],
 })
 export class AppModule {}

src/donation.service.ts

@@ -0,0 +1,59 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { PrismaService } from 'src/prisma/prisma.service';
+import { SharedIndexerService } from './shared-indexer/shared-indexer.service';
+import { Campaign } from './resolvers/models/campaign.model';
+import { num, hash } from 'starknet';
+
+@Injectable()
+export class handleDonationReceivedService {
+  private readonly logger = new Logger(handleDonationReceivedService.name);
+
+  constructor(
+    private readonly prismaService: PrismaService,
+    private readonly sharedIndexerService: SharedIndexerService,
+  ) {}
+
+  onModuleInit() {
+    const donationEventKey = num.toHex(hash.starknetKeccak('DonationCreated'));
+
+    this.sharedIndexerService.registerIndexer(
+      [donationEventKey],
+      this.handleDonationReceivedEvent.bind(this),
+    );
+  }
+
+  private async handleDonationReceivedEvent(
+    event: any,
+  ): Promise<Campaign | null> {
+    try {
+      // Extract donation details from the event
+      const [campaign_id, amount] = event.data;
+
+      this.logger.log(
+        `Processing DonationReceived event for campaign ${campaign_id}`,
+      );
+
+      //updating the specific campaign's donation total
+      const campaign = await this.prismaService.campaign.update({
+        where: { id: Number(campaign_id) },
+        data: {
+          totalDonations: {
+            increment: Number(amount),
+          },
+        },
+      });
+
+      this.logger.log(
+        `Donation of ${amount} successfully updated for campaign ${campaign_id}.`,
+      );
+
+      return campaign;
+    } catch (error) {
+      this.logger.error(
+        `Error processing DonationReceived event: ${error.message}`,
+        error.stack,
+      );
+      throw error;
+    }
+  }
+}

src/resolvers/models/campaign.model.ts

@@ -1,4 +1,4 @@
-import { Field, Int, ObjectType } from '@nestjs/graphql';
+import { Field, Float, Int, ObjectType } from '@nestjs/graphql';
 
 @ObjectType({ description: 'campaign' })
 export class Campaign {
@@ -12,6 +12,10 @@ export class Campaign {
   @Field()
   campaign_owner: string;
 
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  @Field((type) => Float)
+  totalDonations: number;
+
   @Field()
   createdAt: Date;
 }