Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

chain-syncer

Package Overview
Dependencies
Maintainers
1
Versions
52
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

chain-syncer

chain-syncer is a JS module which allows you to synchronize your app with any ethereum-compatible blockchain/contract state. Fast. Flexible. Reliable.

  • 2.0.6
  • Source
  • npm
  • Socket score

Version published
Weekly downloads
6
decreased by-90.91%
Maintainers
1
Weekly downloads
 
Created
Source

Project Presentation

Chain Syncer

Chain Syncer is a JS module which allows you to synchronize your app with any ethereum-compatible blockchain/contract state. Fast. Flexible. Reliable.


Install

Works only with ethers package, so don't forget to install it:

$ npm i chain-syncer ethers

Example usage

Using Ethers package:

const { ChainSyncer, InMemoryAdapter } = require('chain-syncer');

const default_adapter = new InMemoryAdapter(); // change it to any other adapter

const ethersjs_provider = new Ethers.providers.JsonRpcProvider('https://data-seed-prebsc-1-s1.binance.org:8545'); // BSC testnet rpc

const contracts = {
  'Items': {
    abi: [ /* ... */ ],
    network: {
      address: '0xe9e7CEA3DedcA5984780Bafc599bD69ADd087D56', 
      deployed_transaction: '0x0f01fc521030f178115c880e200b09a40c9510f49de227aa880276f92670a3d6' // scanner will start from this tx
    }
  }
}

const syncer = new ChainSyncer(default_adapter, {

  tick_interval: 3000,
  
  query_block_limit: 1000,
  
  verbose: true,
  
  block_time: 3500,
  
  ethers_provider: ethersjs_provider,
  
  async contractsGetter(contract_name) {
    const contract = contracts[contract_name];
    return {
      inst: new Ethers.Contract(contract.network.address, contract.abi, ethersjs_provider),
      deployed_transaction_hash: contract.network.deployed_transaction,
    };
  },
});

syncer.on('Items.Transfer', async (
  from, 
  to, 
  token_id, 
  { global_index, from_address, block_number, block_timestamp, transaction_hash }
) => {

  // global_index is a uniq id of event which is created from block number and logIndex padded with zeros
  // example - if block_number is 234 and logIndex of the event is 4 so global_index will be 234000004

  const item = await Item.findOne({ _id: token_id });

  if(!item) { // postpone until item created locally
    return false;
  }

  item.owner = to;
  item.updatedAt = new Date(block_timestamp * 1000);
  await item.save();
  
  // Best practise is doing something like that, so you are sure that you have the latest state of 'owner' field
  //
  // await Item.updateOne({
  //   _id: token_id,
  //   'syncdata.owner': { $lt: global_index }
  // }, {
  //   'syncdata.owner': global_index,
  //   owner: to,
  // })
  
  // you can notify user that he has new items
}));

await syncer.start();


API

constructor(adapter, options)

NameDescriptionRequiredExample
adapterAn adapter interface for storing event data. As a test you can use built-in InMemoryAdapter, but better build your own adapter to any DB.requirednew InMemoryAdapter()
optionsAn options objectrequired-
options.tick_intervaldeterminates how often will process unprocessed eventsoptional (default: 2000)3000 (every 3 seconds)
options.query_block_limitMaximum amount of blocks that can be scanned per tick. For example official BSC RPC allows up to 2000 blocks per request.optional (default: 100)2000
options.verboseA flag which enables debug mode and loggingoptional (default: false)true
options.modeModule mode. Possible: 'mono' or 'scanner'. 'mono' mode is made for monolith applications - processing and scanning happens on the same app. 'scanner' mode is made for microservices arch - app is only scanning for new events, processing happens on the client nodes (currently we are building client package, but dont be shy to contribute)optional (default: 'mono')'scanner'
options.block_timeBlock time of a network you are working with. For example 3500 for BSC.required3500 (BSC network)
options.ethers_providerEthers.js providerrequirednew Ethers.providers.JsonRpcProvider('https://data-seed-prebsc-1-s1.binance.org:8545')
options.contractsGetterAn async function that returns object with ethers.js contract instance and tx hash of its deployrequiredasync () => ({ inst: new Ethers.Contract(contracts[contract_name].network.address, contracts[contract_name].abi, ethersjs_provider), deployed_transaction_hash: contracts[contract_name].network.deployed_transaction })
options.archive_ethers_providerThis provider activates if scanning_block_number < max_block_height - options.blocks_amount_to_activate_archive_rpc. Useful if you have two types of RPCs (Fast and Archive)optional (default: options.ethers_provider)new Ethers.providers.JsonRpcProvider('https://data-seed-prebsc-1-s1.binance.org:8545')
options.blocks_amount_to_activate_archive_rpcAmount of blocks to activate options.archive_ethers_provideroptional (default: 100)50
options.safe_rescan_every_n_blockBecause of unreliability of most of the RPCs, the syncer may miss some events from the latest blocks, so the syncer will rescan previous options.safe_rescan_every_n_block * 2 blocks every options.safe_rescan_every_n_block block.optional: (default: 100)50

on(event, listener)

⚠️ MUST BE CALLED ONLY BEFORE SYNCER STARTS

NameDescriptionRequiredExample
eventEvent is a string which contains contract and eventrequired'Items.Transfer'
listenerListener function (handler), last argument is always object of event parameters. If false returned from listener - event will be postponed till next processing tickrequiredasync ({ global_index, from_address, block_number, block_timestamp, transaction_hash }) => { ... }

start()

Starts scanner and processor

stop()

Stops scanner and processor


License

Chain Syncer is released under the MIT license. © 2022 Miroslaw Shpak

Keywords

FAQs

Package last updated on 18 Sep 2022

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc