Skip to content

Commit

Permalink
set start block
Browse files Browse the repository at this point in the history
  • Loading branch information
DenisCarriere committed Aug 28, 2024
1 parent 78df9fd commit 38435d6
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions examples/antelope-common.mjs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,8 @@ const baseUrl = "https://eos.substreams.pinax.network:443";
// User parameters
const manifest = "https://spkg.io/pinax-network/antelope-common-v0.4.0.spkg";
const outputModule = "filtered_transactions";
const startBlockNum = -86400*4*2;
const startBlockNum = 390603353;
const stopBlockNum = startBlockNum + 86400*2*4;
const productionMode = true;
const params = [`filtered_transactions=code:eosio && (action:buyram || action:sellram || action:ramtransfer)`]

Expand All @@ -40,6 +41,7 @@ const request = createRequest({
substreamPackage,
outputModule,
startBlockNum,
stopBlockNum,
productionMode,
});

Expand All @@ -58,16 +60,16 @@ emitter.on("progress", (progress) => {
for ( const moduleStat of progress?.modulesStats ?? [] ) {
moduleStats[moduleStat.name] = moduleStat.totalProcessedBlockCount;
}
// console.dir({ runningJobs, ...processedBytes, moduleStats });
console.dir({ runningJobs, ...processedBytes, moduleStats });
});

emitter.on("clock", clock => {
console.log(clock.number);
// console.log(clock.number);
});

// Stream Blocks
emitter.on("anyMessage", (message, cursor, clock) => {
// console.dir(message);
console.dir(message);
// console.dir(cursor);
// console.dir(clock);
});
Expand Down

0 comments on commit 38435d6

Please sign in to comment.