feat: upsert attendees

apps/peatix-adapter/src/peatix-order/peatix-order.service.ts

@@ -11,6 +11,7 @@ import { ScraperPage } from '../scraper-page/scraper-page'
 import { HttpService } from '@nestjs/axios'
 import { JSON_USAGE, PUPPETEER_USAGE } from '../features'
 import { SupabaseService } from 'src/supabase/supabase.service'
+import { AttendeeReceipt } from 'src/types/supabase'
 
 const { parse } = require('csv-parse/sync')
 
@@ -168,8 +169,18 @@ export class PeatixOrderService extends ScraperPage {
           const attendees = res
           this.logger.log(attendees)
 
+          const receipts: AttendeeReceipt[] = attendees.map((attendee) => {
+            const receiptId = attendee[Object.keys(attendee)[0]]
+            const ticketName = attendee[Object.keys(attendee)[4]]
+
+            // チケット名から参加者の種別を特定する
+
+            return { role: 'attendee', receipt_id: receiptId }
+          })
+          this.logger.log(receipts)
+
           // Peatix 購入情報を Supabase へ反映する
-          await this.supabaseService.updateAttendees()
+          // await this.supabaseService.updateAttendees(receipts)
         })
       }
 

apps/peatix-adapter/src/supabase/supabase.service.ts

@@ -1,6 +1,7 @@
 import { Injectable, Logger } from '@nestjs/common'
 import { SupabaseClient, createClient } from '@supabase/supabase-js'
 import { EnvService } from 'src/env/env.service'
+import { AttendeeReceipt } from 'src/types/supabase'
 
 @Injectable()
 export class SupabaseService {
@@ -32,7 +33,15 @@ export class SupabaseService {
   }
 
   // vuejs-jp/vuefes-2024-backside#226
-  public async updateAttendees() {
-    //
+  public async updateAttendees(targets: AttendeeReceipt[]) {
+    const targetData = [ ...targets ]
+
+    for (const target of targetData) {
+      const { data, error } = await this.client.from('attendees')
+        .upsert({ role: target.role, activated_at: new Date().toISOString() })
+        .eq('receipt_id', target.receipt_id)
+        .eq('activated_at', null)
+      if (error) break
+    }
   }
 }