/arweave-synchronizer

Primary LanguageTypeScript

Arweave synchronizer node

A cool tool to process and sync all transactions from a custom GQL query in order to gather metrics for from a specific data protocol.

Documentation

Getting started

$ npm install arweave-synchronizer

or

$ yarn add arweave-synchronizer

Simple example

import Synchronizer from 'arweave-synchronizer';

const sync = new Synchronizer([
  { name: "Protocol-Name", values: "Account-0.2" },
  { name: "Signing-Client", values: "ArConnect" }
]);

sync.on('response', ({txs, txCounter}) => {
  // process the page of transactions here
});

sync.start(); // This must be called at the end

References

Constructor arguments

argument default
Tags array (GQLTagInterface[]) x
Txs per query 100
Delay between queries (ms) 5000

Event listeners

⚠️ Event listeners must be set before sync.start() method is called or it won't work.

In chronological order:

  • on start:
sync.on('start', () => console.log(" 🚦 Starting the synchronizer..."));
  • on request:
sync.on('request', () => console.log(" 🔄 Requesting transactions, waiting for response..."));
  • on exception:
sync.on('exception', (e) => console.log(` ❌ ${e.message}`));
  • on response:
sync.on('response', ({txs, txCounter, timestamp, cursor}) => {
  // process the transactions page 
});
  • on synchronized:
sync.on('synchronized', () => console.log(" ✅ The node has synchronized with the Blockweave."));

Status

You can get the current status:

console.log(sync.getStatus()) // return "stopped", "syncing" or "synced"

To do

  • Add optional caching that would store the txCounter in a flat file so stopping synchronization doesn't require to start over from the beginning