feat!: Add new column to invalid_receipts table

packages/indexer-agent/src/db/migrations/16-modify-invalid-receipts-table.ts

@@ -0,0 +1,51 @@
+import { Logger } from '@graphprotocol/common-ts'
+import { QueryInterface, DataTypes } from 'sequelize'
+
+interface MigrationContext {
+  queryInterface: QueryInterface
+  logger: Logger
+}
+
+interface Context {
+  context: MigrationContext
+}
+
+export async function up({ context }: Context): Promise<void> {
+  const { queryInterface, logger } = context
+
+  const tables = await queryInterface.showAllTables()
+  logger.debug(
+    `Modifying tables scalar_tap_receipts_invalid to add extra column`,
+  )
+
+  if (tables.includes('scalar_tap_receipts_invalid')) {
+    await queryInterface.addColumn('scalar_tap_receipts_invalid', 'error_log', {
+      type: DataTypes.TEXT,
+      allowNull: false,
+    })
+  }
+}
+
+export async function down({ context }: Context): Promise<void> {
+  const { queryInterface, logger } = context
+  // Drop the scalar_tap_ravs table
+  logger.info(`Drop table`)
+  await queryInterface.dropTable('scalar_tap_ravs')
+
+  logger.info(`Drop function, trigger, indices, and table`)
+  await queryInterface.sequelize.query(
+    'DROP TRIGGER IF EXISTS receipt_update ON scalar_tap_receipts',
+  )
+  await queryInterface.sequelize.query(
+    'DROP FUNCTION IF EXISTS scalar_tap_receipt_notify',
+  )
+  await queryInterface.removeIndex(
+    'scalar_tap_receipts',
+    'scalar_tap_receipts_allocation_id_idx',
+  )
+  await queryInterface.removeIndex(
+    'scalar_tap_receipts',
+    'scalar_tap_receipts_timestamp_ns_idx',
+  )
+  await queryInterface.dropTable('scalar_tap_receipts')
+}

packages/indexer-common/src/query-fees/models.ts

@@ -11,6 +11,7 @@ export interface ScalarTapReceiptsAttributes {
   timestamp_ns: bigint
   nonce: bigint
   value: bigint
+  error_log?: string
 }
 export class ScalarTapReceipts
   extends Model<ScalarTapReceiptsAttributes>
@@ -39,6 +40,7 @@ export class ScalarTapReceiptsInvalid
   public nonce!: bigint
   public value!: bigint
   public signature!: Uint8Array
+  public error_log!: string
 
   declare createdAt: CreationOptional<Date>
   declare updatedAt: CreationOptional<Date>
@@ -657,6 +659,10 @@ export function defineQueryFeeModels(sequelize: Sequelize): QueryFeeModels {
         type: DataTypes.BLOB,
         allowNull: false,
       },
+      error_log: {
+        type: DataTypes.TEXT,
+        allowNull: false,
+      },
     },
     {
       underscored: true,