feat(billboard): add /qf-finalize and remove clear-auction-and-distribute-tax handler

.github/workflows/deploy.yml

@@ -2,8 +2,8 @@ name: Build & Deploy
 
 on:
   pull_request:
-    branches: [ main, master, develop, stage ]
-    types: [ closed ]
+    branches: [main, master, develop, stage]
+    types: [closed]
 
 env:
   AWS_ACCESS_KEY_ID: ${{ secrets.AWS_ACCESS_KEY_ID }}
@@ -258,7 +258,7 @@ jobs:
             --image-uri ${{ steps.login-ecr.outputs.registry }}/$ECR_REPOSITORY:$IMAGE_TAG
         env:
           IMAGE_TAG: v${{ needs.build-and-publish.outputs.package-version }}
-          
+
   deploy-daily-summary-email-dev:
     runs-on: 'ubuntu-latest'
     environment: 'dev'
@@ -275,7 +275,7 @@ jobs:
         env:
           IMAGE_TAG: v${{ needs.build-and-publish.outputs.package-version }}
 
-  deploy-billboard-clear-auction-and-distribute-tax-dev:
+  deploy-billboard-clear-auctions-dev:
     runs-on: 'ubuntu-latest'
     environment: 'dev'
     needs: build-and-publish
@@ -286,7 +286,7 @@ jobs:
 
       - name: re-deploy Lambda to dev
         run: |
-          aws lambda update-function-code --function-name billboard-clear-auction-and-distribute-tax-dev \
+          aws lambda update-function-code --function-name billboard-clear-auctions-dev \
             --image-uri ${{ steps.login-ecr.outputs.registry }}/$ECR_REPOSITORY:$IMAGE_TAG
         env:
           IMAGE_TAG: v${{ needs.build-and-publish.outputs.package-version }}

handlers/clear-auctions.ts

@@ -0,0 +1,76 @@
+import { SimulateContractErrorType } from 'viem'
+import { Context, APIGatewayProxyResult, APIGatewayEvent } from 'aws-lambda'
+
+import {
+  billboardContract,
+  publicClient,
+  walletClient,
+} from '../lib/billboard/index.js'
+
+type RequestBody = {
+  accessToken: string // to access this API
+  tokenIds: string[] // bigint
+  epochs: string[] // bigint
+}
+
+export const handler = async (
+  event: APIGatewayEvent,
+  context: Context
+): Promise<APIGatewayProxyResult> => {
+  console.log(`Event: ${JSON.stringify(event, null, 2)}`)
+  console.log(`Context: ${JSON.stringify(context, null, 2)}`)
+
+  const { tokenIds, epochs, accessToken } = (
+    event.body ? JSON.parse(event.body) : {}
+  ) as RequestBody
+  console.log(new Date(), `from input:`, {
+    tokenIds: tokenIds,
+    epochs: epochs,
+  })
+
+  if (accessToken !== process.env.ACCESS_TOKEN) {
+    return {
+      statusCode: 403,
+      body: JSON.stringify({ message: 'invalid access token' }),
+    }
+  }
+
+  try {
+    const clearAuctionsResult = await publicClient.simulateContract({
+      ...billboardContract,
+      functionName: 'clearAuctions',
+      args: [tokenIds.map((i) => BigInt(i)), epochs.map((i) => BigInt(i))],
+    })
+    await walletClient.writeContract(clearAuctionsResult.request)
+
+    const bidders = clearAuctionsResult.result.map((r) => r[0])
+    const prices = clearAuctionsResult.result.map((r) => r[1])
+    const taxes = clearAuctionsResult.result.map((r) => r[2])
+
+    const data = {
+      tokenIds,
+      epochs,
+      bidders,
+      prices,
+      taxes,
+    }
+    return {
+      statusCode: 200,
+      body: JSON.stringify({ message: 'done.', data }),
+    }
+  } catch (err) {
+    const error = err as SimulateContractErrorType
+    console.error(error.name, err)
+
+    const data = {
+      name: error.name,
+      message: error.message,
+      cause: error.cause,
+    }
+
+    return {
+      statusCode: 500,
+      body: JSON.stringify({ data, message: error.name }),
+    }
+  }
+}