Skip to content

Commit ca75770

Browse files
committed
add arkive id and version to metadata
1 parent 4136b36 commit ca75770

File tree

4 files changed

+19
-0
lines changed

4 files changed

+19
-0
lines changed

src/arkiver/arkive-metadata.ts

+6
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,9 @@ interface IArkiverMetadata {
66
eventHandlerCalls: number
77
blockHandlerCalls: number
88
errors: string[]
9+
arkiveId: number
10+
arkiveMajorVersion: number
11+
arkiveMinorVersion: number
912
}
1013

1114
const arkiverMetadataSchema = new mongoose.Schema<IArkiverMetadata>({
@@ -14,6 +17,9 @@ const arkiverMetadataSchema = new mongoose.Schema<IArkiverMetadata>({
1417
eventHandlerCalls: Number,
1518
blockHandlerCalls: Number,
1619
errors: [String],
20+
arkiveId: Number,
21+
arkiveMajorVersion: Number,
22+
arkiveMinorVersion: Number,
1723
})
1824

1925
export const ArkiverMetadata = mongoose.model<IArkiverMetadata>(

src/arkiver/data-source.ts

+6
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ export class DataSource {
4747
private readonly blockRange: bigint
4848
private readonly arkiveId: number
4949
private readonly arkiveVersion: number
50+
private readonly arkiveMinorVersion: number
5051
private readonly statusProvider: StatusProvider
5152
private readonly contracts: Contract[]
5253
private readonly blockSources: IBlockHandler[]
@@ -113,6 +114,7 @@ export class DataSource {
113114
blockRange: bigint
114115
arkiveId: number
115116
arkiveVersion: number
117+
arkiveMinorVersion: number
116118
blockSources: IBlockHandler[]
117119
noDb: boolean
118120
},
@@ -128,6 +130,7 @@ export class DataSource {
128130
})
129131
this.arkiveId = params.arkiveId
130132
this.arkiveVersion = params.arkiveVersion
133+
this.arkiveMinorVersion = params.arkiveMinorVersion
131134
this.statusProvider = new MongoStatusProvider()
132135
this.noDb = params.noDb
133136
}
@@ -659,6 +662,9 @@ export class DataSource {
659662
error,
660663
store: this.store,
661664
type: logOrBlock.type,
665+
arkiveId: this.arkiveId,
666+
arkiveMajorVersion: this.arkiveVersion,
667+
arkiveMinorVersion: this.arkiveMinorVersion,
662668
})
663669
}
664670
}

src/arkiver/providers/interfaces.ts

+3
Original file line numberDiff line numberDiff line change
@@ -21,4 +21,7 @@ export interface SaveArkiveMetadataParams {
2121
type: string
2222
error: string | undefined
2323
store: Store
24+
arkiveId: number
25+
arkiveMajorVersion: number
26+
arkiveMinorVersion: number
2427
}

src/arkiver/providers/mongodb.ts

+4
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,10 @@ export class MongoStatusProvider implements StatusProvider {
3333
chain: params.chain,
3434
blockHandlerCalls: 0,
3535
eventHandlerCalls: 0,
36+
errors: [],
37+
arkiveId: params.arkiveId,
38+
arkiveMajorVersion: params.arkiveMajorVersion,
39+
arkiveMinorVersion: params.arkiveMinorVersion,
3640
}),
3741
)
3842
arkiverMetadata.processedBlockHeight = Number(

0 commit comments

Comments
 (0)