DiscordForumGithub

Robonomics-js

Robonomics-js is a simple Javascript library for working with Robonomics Network.

Installation

npm install robonomics-js --save

or

yarn add robonomics-js

Dependencies

Usage

Creates a Robonomics instance

const options = {...};
const robonomics = new Robonomics(options);

options

The object of properties:

options.web3

An instance of web3.js:

// metamask
const options = {
  web3: new Web3(window.ethereum),
  ...
};

// infura
const options = {
  web3: new Web3(
    new Web3.providers.WebsocketProvider(
      "wss://mainnet.infura.io/ws/v3/0b2f2a5026264b57b6d698b480332e89"
    )
  ),
  ...
};
options.messageProvider

This is an instance of MessageProviderIpfs which uses a js-ipfs node with pubsub support

const ipfs = new Ipfs({
  repo: 'robonomics-example',
  relay: {
    enabled: true,
    hop: {
      enabled: true
    }
  },
  EXPERIMENTAL: {
    pubsub: true
  },
  config: {
    Addresses: {
      Swarm: [
        '/dns4/ws-star.discovery.libp2p.io/tcp/443/wss/p2p-websocket-star',
        '/dns4/1.wsstar.aira.life/tcp/443/wss/p2p-websocket-star/',
        '/dns4/2.wsstar.aira.life/tcp/443/wss/p2p-websocket-star/',
        '/dns4/3.wsstar.aira.life/tcp/443/wss/p2p-websocket-star/'
      ]
    },
    Bootstrap: [
      '/dns4/ams-1.bootstrap.libp2p.io/tcp/443/wss/ipfs/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd',
      '/dns4/lon-1.bootstrap.libp2p.io/tcp/443/wss/ipfs/QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3',
      '/dns4/nyc-1.bootstrap.libp2p.io/tcp/443/wss/ipfs/QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm',
      '/dns4/nyc-2.bootstrap.libp2p.io/tcp/443/wss/ipfs/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64',
      '/dns4/node0.preload.ipfs.io/tcp/443/wss/ipfs/QmZMxNdpMkewiVZLMRxaNxUeZpDUb34pWjZ1kZvsd16Zic',
      '/dns4/node1.preload.ipfs.io/tcp/443/wss/ipfs/Qmbut9Ywz9YEDrz8ySBSgWyJk41Uvm2QJPhwDJzJyGFsD6',
      '/dns4/1.pubsub.aira.life/tcp/443/wss/ipfs/QmdfQmbmXt6sqjZyowxPUsmvBsgSGQjm4VXrV7WGy62dv8',
      '/dns4/2.pubsub.aira.life/tcp/443/wss/ipfs/QmPTFt7GJ2MfDuVYwJJTULr6EnsQtGVp8ahYn9NSyoxmd9',
      '/dns4/3.pubsub.aira.life/tcp/443/wss/ipfs/QmWZSKTEQQ985mnNzMqhGCrwQ1aTA6sxVsorsycQz9cQrw'
    ]
  }
})

const options = {
  messageProvider: new MessageProviderIpfs(ipfs),
  ...
};
options.account

This is an account object which will be used to sign messages. It's necessary to specify either account address (that one must be unlocked) or a private key (the address will be recovered from the given private key).

Option isSignPrefix tells whether or not a prefix must be appended. Default is true.

const options = {
  account: {
    address: '0x0000000000000000000000000000000000000000',
    privateKey: '0x0000000000000000000000000000000000000000000000000000',
    isSignPrefix: true
  },
  ...
};
options.ens

This is a ens contract object. This one is not required. If it's necessary you may specify address of the contract if the network is not set to mainnet. suffix may be sid for sidechain or eth for mainnet. eth is default. version is the version of Robonomics Network. Default is the latest deployed version.

const options = {
  ens: {
    address: '0x314159265dD8dbb310642f98f50C066173C1259b',
    suffix: 'eth',
    version: 5
  },
  ...
};
options.lighthouse

ENS name of a lighthouse, not required. Default is airalab.lighthouse.5.robonomics.eth. It's possible to specify only the first part of the name, like airalab.

const options = {
  lighthouse: 'airalab.lighthouse.5.robonomics.eth',
  ...
};

It's necessary to wait until full initialization

const options = {...};
const robonomics = new Robonomics(options);
robonomics.ready().then(() => {
  console.log('Robonomics instance ready')
})

API

Messages

Demand

The message specification

const demand = {
  // REQUIRED
  model: "QmSt69qQqGka1qwRRHbdmAWk4nCbsV1mqJwd8cWbEyhf1M",      // ipfs hash of the model 
  objective: "QmSt69qQqGka1qwRRHbdmAWk4nCbsV1mqJwd8cWbEyhf2M",  // ipfs hash of the objective
  token: robonomics.xrt.address,                                // payment token address
  cost: 1,                                                      // cost
  deadline: 9999999,                                            // until which block demand is valid

  // NOT REQUIRED 
  lighthouse: "0x0000000000000000000000000000000000000000",     // lighthouse address, by default the initialization address
  validator: "0x0000000000000000000000000000000000000000",      // validator address if necessary
  validatorFee: 0,                                              // validator fee 
  nonce: 1                                                      // index number 
};

robonomics.sendDemand

Signing and broadcasting the demand message. A liability is returned as promise

robonomics.sendDemand(demand).then(liability => {
  console.log(liability.address);
});

robonomics.onDemand

Listens to demand messages with a defined model. If model is null returns any demand message.

robonomics.onDemand(model, message => {
  console.log(message);
});

Offer

The message specification

const offer = {
  // REQUIRED 
  model: "QmSt69qQqGka1qwRRHbdmAWk4nCbsV1mqJwd8cWbEyhf1M",      // ipfs hash of the model 
  objective: "QmSt69qQqGka1qwRRHbdmAWk4nCbsV1mqJwd8cWbEyhf2M",  // ipfs hash of the objective
  token: robonomics.xrt.address,                                // payment token address
  cost: 1,                                                      // cost 
  deadline: 9999999,                                            // until which block demand is valid

  // NOT REQUIRED
  lighthouse: "0x0000000000000000000000000000000000000000",     // lighthouse address, by default the initialization address
  lighthouseFee: 0,                                             // lighthouse fee
  validator: "0x0000000000000000000000000000000000000000",      // validator address if necessary
  nonce: 1                                                      // index number 
};

robonomics.sendOffer

Signs and broadcasts an offer message. A liability is returned as promise

robonomics.sendOffer(offer).then(liability => {
  console.log(liability.address);
});

robonomics.onOffer

Listens to offer messages with a defined model. If model is null returns any offer message

robonomics.onOffer(model, message => {
  console.log(message);
});

Result

The message specification

const result = {
  // REQUIRED 
  liability: "0x0000000000000000000000000000000000000000",  // liability contract address
  success: true,                                            // status of the task
  result: "QmWXk8D1Fh5XFJvBodcWbwgyw9htjc6FJg8qi1YYEoPnrg"  // ipfs hash of the rosbag log file
};

robonomics.sendResult

Signs and broadcasts a result message

robonomics.sendResult(result).then(() => {
  console.log("ok");
});

robonomics.onResult

Listens to result messages. These results may be not valid. Valid results are stored in a liability contract

robonomics.onResult(result => {
  console.log(result);
});

Smart Contracts

Liability

liability.getInfo

Return a property object of the contract

liability.getInfo().then(data => {
  console.log(data);
  /*
  {
    model,
    objective,
    result,
    token,
    cost,
    lighthouseFee,
    validatorFee,
    demandHash,
    offerHash,
    promisor,
    promisee,
    lighthouse,
    validator,
    isSuccess,
    isFinalized
  }
  */
});

liability.onResult

Waits until a liability is finished. Returns a result

liability.onResult().then(result => {
  console.log(result);
});

Lighthouse

robonomics.lighthouse.getInfo

Returns a property object of the contract

robonomics.lighthouse.getInfo().then(data => {
  console.log(data);
  /*
  {
    minimalStake,
    timeoutInBlocks,
    keepAliveBlock,
    marker,
    quota
  }
  */
});

robonomics.lighthouse.getProviders

Returns a list of providers on the lighthouse

robonomics.lighthouse.getProviders().then(list => {
  console.log(list);
});
Creation of a new lighthouse
const minimalFreeze = 1000      // Wn
const timeout = 25              // blocks
const name = 'mylighthouse'     // lighthouse name
robonomics.factory.methods.createLighthouse(minimalFreeze, timeout, name).send({ from: robonomics.account.address })
    .then((tx) => console.log(tx))

robonomics.factory.onLighthouse((lighthouse) => {
    console.log(lighthouse.name)
})
Become a provider

Preliminarily you must call approve for the tokens XRT

const name = "mylighthouse";    // lighthouse name
const stake = 1000;             // Wn
robonomics.lighthouse.methods
  .refill(stake)
  .send({ from: robonomics.account.address })
  .then(tx => console.log(tx));

Token

robonomics.xrt.getInfo

Returns property object of the token

robonomics.xrt.getInfo().then(data => {
  console.log(data);
  /*
  {
    name,
    totalSupply,
    decimals,
    symbol
  }
  */
});
Check balance
robonomics.xrt.methods
  .balanceOf(robonomics.account.address)
  .call()
  .then(balance => console.log(balance));
Check allowance
robonomics.xrt.methods
  .allowance(robonomics.account.address, robonomics.factory.address)
  .call()
  .then(allowance => console.log(allowance));
Approve
robonomics.xrt.methods
  .approve(robonomics.lighthouse.address, 100)
  .send({
    from: robonomics.account.address
  })
  .then(tx => console.log(tx));
← Datalog Glossary →