operate/adapter/bob.js

const { URL, URLSearchParams } = require('url')
const fetch = require('node-fetch')
const binary = require('bops')
const Adapter = require('./../adapter')

const baseUrl = 'https://bob.planaria.network/q/1GgmC7Cg782YtQ6R9QkM58voyWeQJmJJzG/'


/**
 * Adapter module for loading tapes and Ops from [BOB](https://bob.planaria.network).
 *
 * @class
 * @extends Adapter
 * @category Adapters
 * @hideconstructor
 */
class BobAdapter extends Adapter {

  /**
   * Fetches a transaction by the given txid, and returns a Promise.
   *
   * @static
   * @param {String} txid Transaction id
   * @param {Object} opts Options
   * @return {Promise}
   */
  static fetchTx(txid, opts = {}) {
    opts = {
      apiKey: 'op_test',
      ...opts
    }
    const path = this._encodeQuery({
      "v": "3",
      "q": {
        "find": {
          "tx.h": txid,
          "out.tape": {
            "$elemMatch": {
              "i": 0,
              "cell.op": 106
            }
          }
        },
        "limit": 1
      }
    })
    const url = new URL(baseUrl + path)
    const headers = { key: opts.apiKey }

    return fetch(url, { headers })
      .then(r => r.json())
      .then(data => this._toBPU(data)[0])
  }

  /**
   * Fetches a list of transactions by the given query object, and returns a Promise.
   *
   * The `query` parameter should be a valid Bitquery. The `project` attribute
   * cannot be used and unless otherwise specified, `limit` defaults to `10`.
   *
   * @static
   * @param {Object} query Query object
   * @param {Object} opts Options
   * @return {Promise}
   */
  static fetchTxBy(query, opts = {}) {
    opts = {
      apiKey: 'op_test',
      ...opts
    }

    delete query.project

    const path = this._encodeQuery({
      "v": "3",
      "q": {
        "limit": 10,
        ...query
      }
    })
    const url = new URL(baseUrl + path)
    const headers = { key: opts.apiKey }

    return fetch(url, { headers })
      .then(r => r.json())
      .then(data => this._toBPU(data))
  }


  /**
   * Normalise response in standard BPU format
   * @private
   */
  static _toBPU(data) {
    return data.c
      .concat(data.u)
      .map(tx => {
        tx.txid = tx.tx.h
        delete tx.tx
        tx.out.forEach(o => {
          if (o.e && o.e.a === "false")
            o.e.a = null;
        })
        return tx
      })
  }

  /**
   * Encodes map into Fat URI path
   * @private
   */
  static _encodeQuery(query) {
    const str = JSON.stringify(query),
          buf = binary.from(str);
    return binary.to(buf, 'base64')
  }

}

module.exports = BobAdapter