weavedb-exm-sdk

--- package.json (entry) ---
{
  "name": "weavedb-exm-sdk",
  "version": "0.7.3",
  "description": "WeaveDB on Execution Machine.",
  "homepage": "https://weavedb.dev",
  "repository": {
    "type": "git",
    "url": "https://github.com/weavedb/weavedb"
  },
  "main": "index.js",
  "license": "MIT",
  "engines": {
    "node": "16"
  },
  "dependencies": {
    "@execution-machine/sdk": "^0.1.6",
    "arweave": "^1.11.4",
    "ramda": "^0.28.0",
    "weavedb-base": "^0.7.3"
  },
  "devDependencies": {
    "esbuild": "^0.14.50",
    "rimraf": "^3.0.2"
  }
}


--- index.js (entry) ---
const Base = require("weavedb-base")
const Arweave = require("arweave")
const { isNil, clone, keys } = require("ramda")
const { Exm } = require("@execution-machine/sdk")

class SDK extends Base {
  constructor({ arweave = {}, arweave_wallet, functionId, token }) {
    super()
    this.exm = new Exm({
      token,
    })
    this.functionId = functionId
    this.arweave_wallet = arweave_wallet
    this.arweave = Arweave.init(arweave)
    this.domain = { name: "weavedb", version: "1", verifyingContract: "exm" }
  }

  async request(func, ...query) {
    return this.viewState({
      function: func,
      query,
    })
  }

  async viewState(opt) {
    const tx = await this.exm.functions.write(this.functionId, [opt], true)
    if (
      isNil(tx.data.execution.result) ||
      tx.data.execution.result.success !== true
    ) {
      throw new Error()
    }
    return tx.data.execution.result.result
  }

  async getNonce(addr) {
    return (
      (await this.viewState({
        function: "nonce",
        address: addr,
      })) + 1
    )
  }

  async getIds(tx) {
    return this.viewState({
      function: "ids",
      tx: keys(tx.validity)[0],
    })
  }

  async _request(func, para