feat: add timestamp

CHANGELOG.md

@@ -7,6 +7,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ## Unreleased
 
 ### Added
+- Added createdAt timestamp to block, batch and settlement models.[#502](https://github.com/proto-kit/framework/pull/502)
 - Added missing block detection and recovery in the indexer.[#488](https://github.com/proto-kit/framework/pull/488)
 - `@dependencyFactory` for static dependency factory type safety
 - Added Mempool sorting [#395](https://github.com/proto-kit/framework/pull/395)

packages/indexer/prisma/migrations/20260421115835_add_timestamp/migration.sql

@@ -0,0 +1,16 @@
+/*
+  Warnings:
+
+  - Added the required column `createdAt` to the `Batch` table without a default value. This is not possible if the table is not empty.
+  - Added the required column `createdAt` to the `Block` table without a default value. This is not possible if the table is not empty.
+  - Added the required column `createdAt` to the `Settlement` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "Batch" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL;
+
+-- AlterTable
+ALTER TABLE "Block" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL;
+
+-- AlterTable
+ALTER TABLE "Settlement" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL;

packages/indexer/prisma/schema.prisma

@@ -88,6 +88,7 @@ model Block {
   fromStateRoot               String
 
   beforeBlockStateTransitions Json @db.Json
+  createdAt DateTime
 
   parentHash String? @unique
   parent     Block?  @relation("Parent", fields: [parentHash], references: [hash])
@@ -104,6 +105,7 @@ model Batch {
   height Int @id
 
   proof Json @db.Json
+  createdAt DateTime
 
   blocks Block[]
 
@@ -128,6 +130,7 @@ model Settlement {
   // transaction String
   transactionHash      String @id
   promisedMessagesHash String
+  createdAt DateTime
 
   batches Batch[]
 }

packages/persistance/prisma/migrations/20260421120404_add_timestamp/migration.sql

@@ -0,0 +1,8 @@
+-- AlterTable
+ALTER TABLE "Batch" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP;
+
+-- AlterTable
+ALTER TABLE "Block" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP;
+
+-- AlterTable
+ALTER TABLE "Settlement" ADD COLUMN     "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP;

packages/persistance/prisma/schema.prisma

@@ -108,6 +108,7 @@ model Block {
   fromStateRoot               String
 
   beforeBlockStateTransitions Json @db.Json
+  createdAt DateTime @default(now())
 
   parentHash String? @unique
   parent     Block?  @relation("Parent", fields: [parentHash], references: [hash])
@@ -124,6 +125,7 @@ model Batch {
   height Int @id
 
   proof Json @db.Json
+  createdAt DateTime @default(now())
 
   blocks Block[]
 
@@ -148,6 +150,7 @@ model Settlement {
   // transaction String
   transactionHash      String @id
   promisedMessagesHash String
+  createdAt DateTime @default(now())
 
   batches Batch[]
 }

packages/persistance/src/services/prisma/PrismaBatchStore.ts

@@ -52,6 +52,7 @@ export class PrismaBatchStore implements BatchStorage {
       data: {
         proof: entity.proof as Prisma.InputJsonValue,
         height,
+        createdAt: new Date(batch.createdAt),
         blocks: {
           connect: batch.blockHashes.map((hash) => ({
             hash,

packages/persistance/src/services/prisma/mappers/BatchMapper.ts

@@ -15,6 +15,7 @@ export class BatchMapper implements ObjectMapper<
       blockHashes: input[1],
       proof: input[0].proof as JsonProof,
       height: input[0].height,
+      createdAt: input[0].createdAt.getTime(),
     };
   }
 
@@ -23,6 +24,7 @@ export class BatchMapper implements ObjectMapper<
       proof: input.proof,
       height: input.height,
       settlementTransactionHash: null,
+      createdAt: new Date(input.createdAt),
     };
     return [batch, []];
   }

packages/persistance/src/services/prisma/mappers/BlockMapper.ts

@@ -45,6 +45,7 @@ export class BlockMapper implements ObjectMapper<Block, PrismaBlock> {
       beforeBlockStateTransitions: this.stArrayMapper.mapIn(
         input.beforeBlockStateTransitions
       ),
+      createdAt: new Date(input.createdAt).getTime(),
     };
   }
 
@@ -68,6 +69,7 @@ export class BlockMapper implements ObjectMapper<Block, PrismaBlock> {
       beforeBlockStateTransitions: this.stArrayMapper.mapOut(
         input.beforeBlockStateTransitions
       ),
+      createdAt: new Date(input.createdAt),
     };
   }
 }

packages/persistance/src/services/prisma/mappers/SettlementMapper.ts

@@ -15,6 +15,7 @@ export class SettlementMapper implements ObjectMapper<
       batches,
       transactionHash: settlement.transactionHash,
       promisedMessagesHash: settlement.promisedMessagesHash,
+      createdAt: settlement.createdAt.getTime(),
     };
   }
 
@@ -23,6 +24,7 @@ export class SettlementMapper implements ObjectMapper<
       {
         promisedMessagesHash: input.promisedMessagesHash,
         transactionHash: input.transactionHash,
+        createdAt: new Date(input.createdAt),
       },
       input.batches,
     ];

packages/sdk/src/graphql/GraphqlTransactionSender.ts

@@ -24,7 +24,6 @@ export class GraphqlTransactionSender
       }
     `;
     const tx = transaction.toJSON();
-
     const queryResult = await this.graphqlClient.client
       .mutation(query, { tx })
       .toPromise();

packages/sequencer/src/protocol/production/BatchProducerModule.ts

@@ -120,6 +120,7 @@ export class BatchProducerModule extends SequencerModule {
         height,
         fromNetworkState: batch.fromNetworkState,
         toNetworkState: batch.toNetworkState,
+        createdAt: Date.now(),
       },
 
       changes: batch.changes,

packages/sequencer/src/protocol/production/sequencing/BlockProductionService.ts

@@ -186,6 +186,7 @@ export class BlockProductionService {
         during: networkState,
       },
       beforeBlockStateTransitions,
+      createdAt: Date.now(),
     };
 
     const hash = Block.hash(block);

packages/sequencer/src/settlement/interactions/bridging/BridgingSettlementInteraction.ts

@@ -121,6 +121,7 @@ export class BridgingSettlementInteraction implements SettleInteraction {
       batches: [batch.height],
       promisedMessagesHash: latestSequenceStateHash.toString(),
       transactionHash,
+      createdAt: Date.now(),
     };
   }
 }

packages/sequencer/src/settlement/interactions/vanilla/VanillaSettlementInteraction.ts

@@ -113,6 +113,7 @@ export class VanillaSettlementInteraction implements SettleInteraction {
       batches: [batch.height],
       promisedMessagesHash: latestSequenceStateHash.toString(),
       transactionHash,
+      createdAt: Date.now(),
     };
   }
 }

packages/sequencer/src/storage/model/Batch.ts

@@ -5,6 +5,7 @@ export interface Batch {
   proof: JsonProof;
   blockHashes: string[];
   height: number;
+  createdAt: number;
 }
 
 export interface SettleableBatch extends Batch {

packages/sequencer/src/storage/model/Block.ts

@@ -50,6 +50,7 @@ export interface Block {
   toMessagesHash: Field;
 
   beforeBlockStateTransitions: UntypedStateTransition[];
+  createdAt: number;
 }
 
 // eslint-disable-next-line @typescript-eslint/no-redeclare
@@ -106,6 +107,7 @@ export const BlockWithResult = {
         beforeBlockStateTransitions: [],
 
         previousBlockHash: undefined,
+        createdAt: Date.now(),
       },
       result: {
         afterNetworkState: NetworkState.empty(),

packages/sequencer/src/storage/model/Settlement.ts

@@ -2,4 +2,5 @@ export interface Settlement {
   transactionHash: string;
   promisedMessagesHash: string;
   batches: number[];
+  createdAt: number;
 }