Closed #8, add use coupon api

Author: elct9620

api/command/useCoupon.ts

@@ -1,14 +1,31 @@
-import { Command } from '@/core'
+import { Repository, Command } from '@/core'
+import { Status } from '@/puzzle'
+import { PuzzleReceiverNotFoundError } from './errors'
 
 export type UseCouponInput = {
-  token: string
-  eventId: string
+  publicToken: string
 }
 
 export class UseCouponCommand implements Command<UseCouponInput, boolean> {
-  constructor() {}
+  private readonly statuses: Repository<Status>
+
+  constructor(status: Repository<Status>) {
+    this.statuses = status
+  }
+
+  public async execute({ publicToken }: UseCouponInput): Promise<boolean> {
+    const status = await this.statuses.findById(publicToken)
+    if (!status) {
+      throw new PuzzleReceiverNotFoundError()
+    }
+
+    if (status.isNew()) {
+      return false
+    }
+
+    status.redeem()
+    await this.statuses.save(status)
 
-  public async execute(_input: UseCouponInput): Promise<boolean> {
     return true
   }
 }

api/repository/puzzleStatuses.ts

@@ -1,7 +1,14 @@
 import { type D1Database } from '@cloudflare/workers-types'
 import { type Class } from '@/core/utils'
 import { Repository } from '@/core'
-import { Status, ActivityEvent, AttendeeInitialized, PuzzleCollected, Revoked } from '@/puzzle'
+import {
+  Status,
+  ActivityEvent,
+  AttendeeInitialized,
+  PuzzleCollected,
+  Revoked,
+  Redeemed,
+} from '@/puzzle'
 
 type EventSchema = {
   id: string
@@ -16,6 +23,7 @@ const eventConstructors: Record<string, Class<ActivityEvent>> = {
   AttendeeInitialized: AttendeeInitialized,
   PuzzleCollected: PuzzleCollected,
   Revoked: Revoked,
+  Redeemed: Redeemed,
 }
 
 export class D1PuzzleStatusRepository implements Repository<Status> {

features/puzzle_coupon.feature

@@ -1,12 +1,12 @@
 Feature: Puzzle Coupon
   Scenario: PUT /event/puzzle/coupon to redeem a puzzle coupon
-    Given there have some booths
-      | token                                | name   | event_id |
-      | 1024914b-ee65-4728-b687-8341f5affa89 | COSCUP | SITCON   |
-    And there have some attendees
+    Given there have some attendees
       | token                                | event_id | display_name |
       | f185f505-d8c0-43ce-9e7b-bb9e8909072d | SITCON   | Aotoki       |
-    When I make a PUT request to "/event/puzzle/coupon?token=1024914b-ee65-4728-b687-8341f5affa89&event_id=SITCON":
+    And there have some puzzle activity events
+      | id                                   | type                | aggregate_id                         | version | payload                                | occurred_at         |
+      | b44845bd-8bd2-428d-ad65-f6a619bf8a96 | AttendeeInitialized | f185f505-d8c0-43ce-9e7b-bb9e8909072d | 0       | { "displayName": "Aotoki" }            | 2023-09-10 20:48:00 |
+    When I make a PUT request to "/event/puzzle/coupon?token=f185f505-d8c0-43ce-9e7b-bb9e8909072d&event_id=SITCON":
       """
       {}
       """
@@ -17,3 +17,27 @@ Feature: Puzzle Coupon
       }
       """
     And the response status should be 200
+
+  Scenario: PUT /event/puzzle/coupon to redeem a puzzle coupon and status is updated
+    Given there have some attendees
+      | token                                | event_id | display_name |
+      | f185f505-d8c0-43ce-9e7b-bb9e8909072d | SITCON   | Aotoki       |
+    And there have some puzzle activity events
+      | id                                   | type                | aggregate_id                         | version | payload                                | occurred_at         |
+      | b44845bd-8bd2-428d-ad65-f6a619bf8a96 | AttendeeInitialized | f185f505-d8c0-43ce-9e7b-bb9e8909072d | 0       | { "displayName": "Aotoki" }            | 2023-09-10 20:48:00 |
+    When I make a PUT request to "/event/puzzle/coupon?token=f185f505-d8c0-43ce-9e7b-bb9e8909072d&event_id=SITCON":
+      """
+      {}
+      """
+    And I make a GET request to "/event/puzzle?token=f185f505-d8c0-43ce-9e7b-bb9e8909072d"
+    Then the response json should be:
+      """
+      {
+        "user_id": "Aotoki",
+        "puzzles": [],
+        "deliverers": [],
+        "valid": null,
+        "coupon": 1693065600
+      }
+      """
+    And the response status should be 200

src/puzzle/event.ts

@@ -33,6 +33,7 @@ export class PuzzleCollected extends ActivityEvent {
 }
 
 export class Revoked extends ActivityEvent {}
+export class Redeemed extends ActivityEvent {}
 
 export abstract class StatEvent implements DomainEvent {
   public readonly id: string

src/puzzle/status.ts

@@ -1,5 +1,5 @@
 import { AggregateRoot, Replayable, getCurrentTime } from '@/core'
-import { ActivityEvent, AttendeeInitialized, PuzzleCollected, Revoked } from './event'
+import { ActivityEvent, AttendeeInitialized, PuzzleCollected, Revoked, Redeemed } from './event'
 import { Piece } from './piece'
 
 @Replayable
@@ -46,6 +46,10 @@ export class Status extends AggregateRoot<string, ActivityEvent> {
     this.apply(new Revoked(crypto.randomUUID(), this.id, getCurrentTime()))
   }
 
+  redeem(): void {
+    this.apply(new Redeemed(crypto.randomUUID(), this.id, getCurrentTime()))
+  }
+
   collectPiece(name: string, giverName: string): void {
     this.apply(new PuzzleCollected(crypto.randomUUID(), this.id, getCurrentTime(), name, giverName))
   }
@@ -72,4 +76,8 @@ export class Status extends AggregateRoot<string, ActivityEvent> {
       this._completedAt = this._revokedAt
     }
   }
+
+  private _onRedeemed(event: Redeemed) {
+    this._redeemedAt = new Date(event.occurredAt)
+  }
 }

worker/controller/useCoupon.ts

@@ -16,7 +16,6 @@ export class UseCoupon extends OpenAPIRoute {
     tags: ['Puzzle'],
     requestBody: {},
     parameters: {
-      event_id: schema.EventIdQuery,
       token: schema.OptionalAttendeeTokenQuery,
     },
     responses: {
@@ -28,10 +27,8 @@ export class UseCoupon extends OpenAPIRoute {
   }
 
   async handle(request: UseCouponRequest, _env: unknown, _context: unknown) {
-    const token = request.query.token as string
-    const eventId = request.query.event_id as string
-
-    const success = await request.useCoupon.execute({ token, eventId })
+    const publicToken = request.query.token as string
+    const success = await request.useCoupon.execute({ publicToken })
 
     if (!success) {
       throw new StatusError(400, 'Failed to redeem coupon')

worker/middlewares/command.ts

@@ -31,7 +31,7 @@ export const withCommands = (request: IRequest, env: Env) => {
     puzzleStatusRepository,
     puzzleStatsRepository
   )
-  const useCoupon = new Command.UseCouponCommand()
+  const useCoupon = new Command.UseCouponCommand(puzzleStatusRepository)
 
   Object.assign(request, {
     createAnnouncementCommand,