Add region to series

Author: Vito0912

app/dtos/series.ts

@@ -15,6 +15,15 @@ export class MinimalSeriesDto extends BaseModelDto {
   @nameApiProperty()
   declare name: string
 
+  @ApiProperty({
+    description: 'The region of the book, e.g., "us", "ca", "uk".',
+    type: 'string',
+    enum: ['us', 'ca', 'uk', 'au', 'fr', 'de', 'jp', 'it', 'in', 'es', 'br'],
+    example: 'us',
+    nullable: true,
+  })
+  declare region: 'us' | 'ca' | 'uk' | 'au' | 'fr' | 'de' | 'jp' | 'it' | 'in' | 'es' | 'br' | null
+
   @ApiProperty({
     description: 'The position of the series in the list. Can be a string!',
     type: 'string',
@@ -32,6 +41,7 @@ export class MinimalSeriesDto extends BaseModelDto {
     if (!series) return
     this.asin = series.asin
     this.name = series.title ?? null
+    this.region = series.region ?? null
     if (series.$extras.pivot_position) {
       this.position = series.$extras.pivot_position
     } else {

app/helper/book.ts

@@ -52,7 +52,8 @@ export class BookHelper {
           (book.releaseDate <= DateTime.now() && book.releaseDate >= book.updatedAt) ||
           (!book.contentType && !book.contentDeliveryType) ||
           !book.sku ||
-          !book.skuGroup
+          !book.skuGroup ||
+          (book.series && book.series.some((s) => s.region === null || s.region === undefined))
       )
       .map((book) => book.asin)
 
@@ -220,6 +221,7 @@ export class BookHelper {
             const seriesModel = new Series()
             seriesModel.asin = seriesData.asin ? seriesData.asin.replace('\t', '').trim() : null
             seriesModel.title = seriesData.title ? seriesData.title.replace('\t', '').trim() : null
+            seriesModel.region = region
             seriesModel.description = seriesData.description ?? null
 
             if (seriesData.sequence && seriesData.sequence.length > 0) {
@@ -240,6 +242,7 @@ export class BookHelper {
             if (seriesData.asin && seriesData.title) {
               const seriesModel = new Series()
               seriesModel.asin = seriesData.asin ? seriesData.asin.replace('\t', '').trim() : null
+              seriesModel.region = region
               seriesModel.title = seriesData.title
                 ? seriesData.title.replace('\t', '').trim()
                 : null

app/helper/series.ts

@@ -77,7 +77,7 @@ export class SeriesHelper {
       series.fetchedDescription = true
       series.asin = json.product!.asin
       series.title = json.product!.title
-
+      series.region = payload.region
       return retryOnUniqueViolation(async () => {
         return await series!.save()
       })

app/models/series.ts

@@ -13,6 +13,10 @@ export default class Series extends BaseModel {
   @column()
   declare description: string
 
+  @column()
+  // @enum(us, ca, uk, au, fr, de, jp, it, in, es, br)
+  declare region: 'us' | 'ca' | 'uk' | 'au' | 'fr' | 'de' | 'jp' | 'it' | 'in' | 'es' | 'br'
+
   @manyToMany(() => Book)
   declare books: ManyToMany<typeof Book>
 

config/logger.ts

@@ -17,13 +17,15 @@ const loggerConfig = defineConfig({
       transport: {
         targets: [
           ...targets().pushIf(!app.inProduction, targets.pretty()).toArray(),
-          {
-            target: '@axiomhq/pino',
-            options: {
-              dataset: process.env.AXIOM_DATASET,
-              token: process.env.AXIOM_TOKEN,
-            },
-          },
+          ...targets()
+            .pushIf(!!process.env.AXIOM_DATASET && !!process.env.AXIOM_TOKEN, {
+              target: '@axiomhq/pino',
+              options: {
+                dataset: process.env.AXIOM_DATASET,
+                token: process.env.AXIOM_TOKEN,
+              },
+            })
+            .toArray(),
         ],
       },
     },

database/migrations/1764873945034_alter_series_table.ts

@@ -0,0 +1,19 @@
+import { BaseSchema } from '@adonisjs/lucid/schema'
+
+export default class extends BaseSchema {
+  protected tableName = 'series'
+
+  async up() {
+    this.schema.alterTable(this.tableName, (table) => {
+      table
+        .enum('region', ['us', 'ca', 'uk', 'au', 'fr', 'de', 'jp', 'it', 'in', 'es', 'br'])
+        .nullable()
+    })
+  }
+
+  async down() {
+    this.schema.alterTable(this.tableName, (table) => {
+      table.dropColumn('region')
+    })
+  }
+}

start/env.ts

@@ -35,9 +35,9 @@ export default await Env.create(new URL('../', import.meta.url), {
   REDIS_PORT: Env.schema.number(),
   REDIS_PASSWORD: Env.schema.string.optional(),
 
-  AXIOM_DATASET: Env.schema.string(),
+  AXIOM_DATASET: Env.schema.string.optional(),
 
-  AXIOM_TOKEN: Env.schema.string(),
+  AXIOM_TOKEN: Env.schema.string.optional(),
 
   /*
   |----------------------------------------------------------