import { OcelloidsClient, xcm } from "@sodazone/ocelloids-client";

const client = new OcelloidsClient({
  httpUrl: "http://127.0.0.1:3000",
  wsUrl: "ws://127.0.0.1:3000"
});

// subscribe on-demand
const ws = client.subscribe<xcm.XcmInputs>({
  agent: "xcm",
  args: {
    origin: "urn:ocn:polkadot:2004",
    senders: "*",
    events: "*",
    destinations: [ 
      "urn:ocn:polkadot:0",
      "urn:ocn:polkadot:1000",
      "urn:ocn:polkadot:2000",
      "urn:ocn:polkadot:2034",
      "urn:ocn:polkadot:2104"
    ]
  }
 }, {
  onMessage: msg => {
    if(xcm.isXcmReceived(msg)) {
      console.log("RECV", msg.subscriptionId);
    } else if(xcm.isXcmSent(msg)) {
      console.log("SENT", msg.subscriptionId)
    }
    console.log(msg);
  },
  onError: error => console.log(error),
  onClose: event => console.log(event.reason)
});