sologenic-xrpl-stream-js-non-redis v1.0.24

sologenic-xrpl-stream-js

install

$ npm install sologenic-xrpl-stream-js

Example

'use strict';
const ƨ = require('sologenic-xrpl-stream-js');

(async () => {
  try {
    const sologenic = await new ƨ.SologenicTxHandler(
      // RippleAPI Options
      {
        server: 'wss://testnet.xrpl-labs.com' // Kudos to Wietse Wind
      },
      // Sologenic Options, hash or redis
      {
        // queueType: "hash",
        // hash: {}

        queueType: 'redis',
        redis: {
          host: '127.0.0.1',
          port: 6379
        },
        verbose: true
      }
    ).connect();

    sologenic.on('queued', (id, tx) => {
      console.log('GLOBAL QUEUED: ', id, tx);
    });
    sologenic.on('dispatched', (id, tx) => {
      console.log('GLOBAL DISPATCHED:', id, tx);
    });
    sologenic.on('requeued', id => {
      console.log('GLOBAL requeued:', id);
    });
    sologenic.on('warning', (id, type, reason) => {
      console.log('GLOBAL WARNING:', id, type, reason);
    });
    sologenic.on('validated', (id, result) => {
      console.log('GLOBAL VALIDATED:', id, result);
    });
    sologenic.on('failed', (id, type, reason) => {
      console.log('GLOBAL FLAIED:', id, type, reason);
    });

    await sologenic.setAccount({
      address: 'rNbe8nh1K6nDC5XNsdAzHMtgYDXHZB486G',
      secret: 'ssH5SSKYvHBynnrYoCnmvsbxrNGEv'
    });

    const tx = sologenic.submit({
      TransactionType: 'Payment',
      Account: 'rNbe8nh1K6nDC5XNsdAzHMtgYDXHZB486G',
      Destination: 'rUwty6Pf4gzUmCLVuKwrRWPYaUiUiku8Rg',
      Amount: {
        currency: '534F4C4F00000000000000000000000000000000',
        issuer: 'rNbe8nh1K6nDC5XNsdAzHMtgYDXHZB486G',
        value: '100000000'
      }
    });

    tx.events
      .on('queued', tx => {
        console.log('QUEUED', tx);
      })
      .on('dispatched', (tx, dispatched) => {
        console.log('DISPATCHED', tx, dispatched);
      })
      .on('requeued', (tx, result) => {
        console.log('REQUEUED', tx, result);
      })
      .on('warning', (type, code) => {
        console.log('warning:', type, code);
      })
      .on('validated', (dispatched, result) => {
        console.log('VALIDATED', dispatched, result);
      })
      .on('failed', (type, code) => {
        console.log('failed:', type, code);
      });

    console.log(await tx.promise);
  } catch (error) {
    console.log('Error:', error);
  }
})();