feat: added tx to wagers column

Author: addegbenga

backend/.env.example

@@ -1,35 +1,36 @@
 # GENERAL CONFIG
+DB_SYNCHRONIZE=true
 NODE_ENV=development
-SERVER_PORT=8080
+PORT=8080
 
 # JWT CONFIG
-JWT_SECRET=
-REFRESH_TOKEN_SECRET=
+JWT_SECRET=superhotsecret
+REFRESH_TOKEN_SECRET=MYREFRESHTOKENSECRET
 JWT_ACCESS_EXPIRTY_TIME='15m'
 JWT_REFRESH_EXPIRTY_TIME='7d'
 JWT_INVITATION_EXPIRY_TIME='24h'
 
 # REDIS CONFIG
-REDIS_HOST=
-REDIS_PORT=
-REDIS_PASSWORD=
-REDIS_USERNAME=
+REDIS_HOST=redis-cache
+REDIS_PORT=6379        
+REDIS_PASSWORD=mystrongpassword
+REDIS_USERNAME=default
 
 # OTP CONFIG
 OTP_SECRET=
 
 # SENDGRID CONFIG
-SEND_GRID_HOST=
-SENDGRID_API_KEY=
-SEND_GRID_MAIL_FROM=
-SEND_GRID_PSD=
-SEND_GRID_USERNAME=
+SEND_GRID_HOST=dsdd
+SENDGRID_API_KEY=sddd
+SEND_GRID_MAIL_FROM=dsdd
+SEND_GRID_PSD=sddd
+SEND_GRID_USERNAME=sdddd
 
 # POSTGRES DB CONFIG
-POSTGRES_USER=postgres     ## DATABASE USERNAME
-POSTGRES_PASSWORD=strongpassword   ## DATABASE PASSWORD
-POSTGRES_DB_NAME=starkwager-backend_db  ## DATABASE NAME / DOCKER CONTAINER NAME
-POSTGRES_DB_SCHEMA=wager    ## POSTGRES SCHEMA NAME
+POSTGRES_USER=postgres
+POSTGRES_PASSWORD=strongpassword
+POSTGRES_DB_NAME=postgres_db
+POSTGRES_DB_SCHEMA=wager
 
 ## Use this when running on docker container.
 POSTGRES_DB_HOST=${POSTGRES_DB_NAME}

backend/prisma/migrations/20250603152651_added_tx_hash_and_tx_status_to_wager/migration.sql

@@ -0,0 +1,3 @@
+-- AlterTable
+ALTER TABLE "wagers" ADD COLUMN     "tx_hash" TEXT,
+ADD COLUMN     "tx_status" TEXT;

backend/prisma/schema.prisma

@@ -36,6 +36,9 @@ model Wager {
   createdAt   DateTime @default(now()) @map("created_at")
   updatedAt   DateTime @updatedAt @map("updated_at")
 
+  txHash       String?      @map("tx_hash")      // NEW: Transaction hash
+  txStatus     String?      @map("tx_status")    // NEW: "pending", "confirmed", "failed"
+
   // Relationships
   category    Category     @relation(fields: [categoryId], references: [id])
   createdBy   User         @relation(fields: [createdById], references: [id])

backend/src/wager/dtos/wager.dto.ts

@@ -15,6 +15,12 @@ enum WagerStatus {
   ACTIVE = 'active',
   COMPLETED = 'completed',
 }
+
+export enum TxStatus {
+  PENDING = 'pending',
+  CONFIRMED = 'confirmed',
+  FAILED = 'failed',
+}
 export default WagerStatus;
 
 export class CreateWagerDto {
@@ -45,6 +51,13 @@ export class CreateWagerDto {
   @IsOptional()
   createdById: string;
 
+  @IsString()
+  txHash: string;
+
+  @IsString()
+  @IsEnum(TxStatus)
+  txStatus: string;
+
   @IsOptional()
   @IsString({ each: true })
   hashtags?: string[];

backend/src/wager/services/wager.service.ts

@@ -76,32 +76,38 @@ export class WagerService {
   async bulkCreateWagers(payload: CreateWagerDto[]) {
     return this.prisma.$transaction(async (tx) => {
       const createdWagers = [];
-  
+
       for (const wager of payload) {
         // Check if a wager with the same name already exists
         const existingWager = await tx.wager.findFirst({
           where: { name: wager.name },
         });
-  
+
         if (existingWager) {
-          throw new BadRequestException(`Wager with name "${wager.name}" already exists.`);
+          throw new BadRequestException(
+            `Wager with name "${wager.name}" already exists.`,
+          );
         }
-  
+
         // Create the wager
         const newWager = await tx.wager.create({
           data: {
             ...wager,
             hashtags: wager.hashtags
-              ? { connectOrCreate: wager.hashtags.map((name) => ({ where: { name }, create: { name } })) }
+              ? {
+                  connectOrCreate: wager.hashtags.map((name) => ({
+                    where: { name },
+                    create: { name },
+                  })),
+                }
               : undefined,
           },
         });
-  
+
         createdWagers.push(newWager);
       }
-  
+
       return createdWagers;
     });
   }
-  
 }

backend/src/websocket/websocket.gateway.spec.ts

@@ -85,4 +85,4 @@ describe('WebsocketGateway', () => {
       expect(mockSocket.emit).toHaveBeenCalledWith('leftRoom', { room });
     });
   });
-});
+});

backend/src/websocket/websocket.gateway.ts

@@ -41,7 +41,9 @@ export class WebsocketGateway
 
   @SubscribeMessage('message')
   handleMessage(client: Socket, payload: any): void {
-    this.logger.log(`Received message from ${client.id}: ${JSON.stringify(payload)}`);
+    this.logger.log(
+      `Received message from ${client.id}: ${JSON.stringify(payload)}`,
+    );
     // Broadcast the message to all connected clients except the sender
     client.broadcast.emit('message', {
       senderId: client.id,

backend/src/websocket/websocket.module.ts

@@ -6,4 +6,4 @@ import { WebsocketService } from './websocket.service';
   providers: [WebsocketGateway, WebsocketService],
   exports: [WebsocketService],
 })
-export class WebsocketModule {}
+export class WebsocketModule {}

backend/src/websocket/websocket.service.spec.ts

@@ -52,10 +52,10 @@ describe('WebsocketService', () => {
     it('should broadcast to all connected clients', () => {
       const event = 'test-event';
       const payload = { message: 'test message' };
-      
+
       service.handleConnection(mockSocket);
       service.broadcastToAll(event, payload);
-      
+
       expect(mockSocket.emit).toHaveBeenCalledWith(event, payload);
     });
   });
@@ -65,11 +65,11 @@ describe('WebsocketService', () => {
       const room = 'test-room';
       const event = 'test-event';
       const payload = { message: 'test message' };
-      
+
       service.handleConnection(mockSocket);
       service.broadcastToRoom(room, event, payload);
-      
+
       expect(mockSocket.emit).toHaveBeenCalledWith(event, payload);
     });
   });
-});
+});

backend/src/websocket/websocket.service.ts

@@ -33,4 +33,4 @@ export class WebsocketService {
       }
     });
   }
-}
+}