-
Notifications
You must be signed in to change notification settings - Fork 1
/
eosio.token.ts
37 lines (33 loc) · 1.11 KB
/
eosio.token.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
import { Substreams, download, PrometheusOperations } from "../src";
// User input
const url = "QmTMejWjo44yxSD7Vzbtcmo6GfgV5d3Y4z85SkRp9VC3b7"
const outputModule = "map_transfers";
const param = "to=swap.defi&symcode=EOS";
const params = {[outputModule]: param};
const startBlockNum = "300000000";
const stopBlockNum = "+1000";
const host = 'https://eos.firehose.eosnation.io:9001';
const authorization = process.env.SUBSTREAMS_API_TOKEN;
(async () => {
const spkg = await download(url);
const substreams = new Substreams(spkg, outputModule, {
host,
startBlockNum,
stopBlockNum,
authorization,
productionMode: true,
});
substreams.on("start", (cursor, clock) => {
console.log({status: "start", cursor, clock});
});
substreams.on("anyMessage", (messages: any) => {
for ( const message of messages.items ) {
console.log(message);
}
});
// add single param (defaults to current `outputModule`)
substreams.param(param);
// add params to various map modules
substreams.params(params);
substreams.start();
})();