Merge pull request #203 from vuejs-jp/chore/sentry

Sentry setup

Author: jiyuujin

apps/peatix-adapter/.env.example

@@ -6,3 +6,5 @@ PEATIX_BASIC_EMAIL=
 PEATIX_BASIC_PASSWORD=
 SUPABASE_URL=
 SUPABASE_KEY=
+
+SENTRY_DSN=

apps/peatix-adapter/package.json

@@ -34,6 +34,8 @@
     "@nestjs/config": "3.2.2",
     "@nestjs/schematics": "10.1.1",
     "@nestjs/testing": "10.3.7",
+    "@ntegral/nestjs-sentry": "4.0.1",
+    "@sentry/node": "8.18.0",
     "@types/express": "4.17.21",
     "@types/jest": "^29.5.12",
     "@types/node": "~18.19.0",

apps/peatix-adapter/src/app.module.ts

@@ -1,4 +1,28 @@
 import { Module } from '@nestjs/common'
+import { ConfigModule } from '@nestjs/config'
+import { configuration } from './env/utils'
+import { SentryModule } from '@ntegral/nestjs-sentry'
+import { EnvModule } from './env/env.module'
+import { EnvService } from './env/env.service'
 
-@Module({})
+@Module({
+  imports: [
+    ConfigModule.forRoot({
+      envFilePath: '.env',
+      expandVariables: true,
+      load: [configuration],
+    }),
+    SentryModule.forRootAsync({
+      imports: [EnvModule],
+      useFactory: (envService: EnvService) => ({
+        dsn: envService.SENTRY_DSN,
+        debug: false,
+        logLevels: ['error'],
+      }),
+      inject: [EnvService],
+    }),
+    EnvModule,
+
+  ]
+})
 export class AppModule {}

apps/peatix-adapter/src/cmd.ts

@@ -2,11 +2,13 @@ import { CommandFactory } from 'nest-commander'
 import { AfterPurchaseModule } from './after-purchase/after-purchase.module'
 
 async function bootstrap() {
-  await CommandFactory.run(AfterPurchaseModule, [
-    'warn',
-    'error',
-    'debug',
-    'log',
-  ])
+  await CommandFactory.run(AfterPurchaseModule, {
+    logger: ['warn', 'error', 'debug', 'log'],
+    serviceErrorHandler: (error) => {
+      console.error(error)
+    }
+  }).catch((error) => {
+    console.error(error)
+  })
 }
 bootstrap()

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

@@ -31,4 +31,8 @@ export class EnvService {
   get SUPABASE_KEY() {
     return this.configService.getOrThrow('supabaseKey')
   }
+
+  get SENTRY_DSN() {
+    return this.configService.getOrThrow('sentryDsn')
+  }
 }

apps/peatix-adapter/src/env/utils/configuration.ts

@@ -4,4 +4,5 @@ export const configuration = () => ({
   peatixBasicPassword: process.env.PEATIX_BASIC_PASSWORD || '',
   supabaseUrl: process.env.SUPABASE_URL || '',
   supabaseKey: process.env.SUPABASE_KEY || '',
+  sentryDsn: process.env.SENTRY_DSN || '',
 })

apps/peatix-adapter/src/main.ts

@@ -1,8 +1,24 @@
 import { NestFactory } from '@nestjs/core'
 import { AppModule } from './app.module'
+import { SentryInterceptor } from '@ntegral/nestjs-sentry'
+import { HttpException } from '@nestjs/common'
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule)
+
+  app.useGlobalInterceptors(
+    new SentryInterceptor({
+      filters: [
+        {
+          type: HttpException,
+          filter: (exception: HttpException) => {
+            return exception.getStatus() < 500
+          },
+        },
+      ],
+    }),
+  )
+
   await app.listen(3000)
 }
 bootstrap()

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

@@ -186,7 +186,11 @@ export class PeatixOrderService extends ScraperPage {
           this.logger.log(receipts)
 
           // Peatix 購入情報を Supabase へ反映する
-          // await this.supabaseService.updateAttendees(receipts)
+          for (const receipt of receipts) {
+            this.logger.log(receipt)
+            // const result = await this.supabaseService.updateAttendees(receipt)
+            // if (!result) break
+          }
         })
       }
 

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

@@ -33,17 +33,17 @@ export class SupabaseService {
   }
 
   // vuejs-jp/vuefes-2024-backside#226
-  public async updateAttendees(targets: AttendeeReceipt[]) {
+  public async updateAttendees(targets: AttendeeReceipt) {
     this.getClient()
 
-    const targetData = [ ...targets ]
+    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
-    }
+    const { data, error } = await this.client.from('attendees')
+      .upsert({ role: targetData.role, activated_at: new Date().toISOString() })
+      .eq('receipt_id', targetData.receipt_id)
+      .eq('activated_at', null)
+    if (error) false
+
+    return true
   }
 }