Nullable InteropTransfer columns (l2beat#11377)

Author: sdlyy

packages/database/prisma/migrations/20260318100210_nullable_interop_columns/migration.sql

@@ -0,0 +1,10 @@
+-- AlterTable
+ALTER TABLE "InteropTransfer" ALTER COLUMN "duration" DROP NOT NULL,
+ALTER COLUMN "srcTime" DROP NOT NULL,
+ALTER COLUMN "srcTxHash" DROP NOT NULL,
+ALTER COLUMN "srcLogIndex" DROP NOT NULL,
+ALTER COLUMN "srcEventId" DROP NOT NULL,
+ALTER COLUMN "dstTime" DROP NOT NULL,
+ALTER COLUMN "dstTxHash" DROP NOT NULL,
+ALTER COLUMN "dstLogIndex" DROP NOT NULL,
+ALTER COLUMN "dstEventId" DROP NOT NULL;

packages/database/prisma/schema.prisma

@@ -372,13 +372,13 @@ model InteropTransfer {
   bridgeType String?  @db.VarChar(32)
   timestamp  DateTime @db.Timestamp(6)
 
-  duration Int
+  duration Int?
 
-  srcTime         DateTime @db.Timestamp(6)
+  srcTime         DateTime? @db.Timestamp(6)
   srcChain        String   @db.VarChar(32)
-  srcTxHash       String   @db.VarChar(66)
-  srcLogIndex     Int
-  srcEventId      String   @db.VarChar(40)
+  srcTxHash       String?   @db.VarChar(66)
+  srcLogIndex     Int?
+  srcEventId      String?   @db.VarChar(40)
   srcTokenAddress String?  @db.VarChar(66)
   srcRawAmount    Decimal? @db.Decimal(80, 0)
 
@@ -389,11 +389,11 @@ model InteropTransfer {
   srcValueUsd        Float?   @db.Real
   srcWasBurned       Boolean?
 
-  dstTime         DateTime @db.Timestamp(6)
+  dstTime         DateTime? @db.Timestamp(6)
   dstChain        String   @db.VarChar(32)
-  dstTxHash       String   @db.VarChar(66)
-  dstLogIndex     Int
-  dstEventId      String   @db.VarChar(40)
+  dstTxHash       String?   @db.VarChar(66)
+  dstLogIndex     Int?
+  dstEventId      String?   @db.VarChar(40)
   dstTokenAddress String?  @db.VarChar(66)
   dstRawAmount    Decimal? @db.Decimal(80, 0)
 

packages/database/src/repositories/InteropTransferRepository.ts

@@ -96,6 +96,19 @@ export function toRecord(
     )
   }
 
+  // Remove me: Just to apply migration
+  assert(row.duration !== null)
+
+  assert(row.srcTime !== null)
+  assert(row.srcTxHash !== null)
+  assert(row.srcEventId !== null)
+  assert(row.srcLogIndex !== null)
+
+  assert(row.dstTime !== null)
+  assert(row.dstTxHash !== null)
+  assert(row.dstEventId !== null)
+  assert(row.dstLogIndex !== null)
+
   return {
     plugin: row.plugin,
     transferId: row.transferId,