Implement new JSON-RPC API

bin/wasm-node/javascript/test/chainHead.js

@@ -0,0 +1,90 @@
+// Smoldot
+// Copyright (C) 2019-2021  Parity Technologies (UK) Ltd.
+// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0
+
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+import test from 'ava';
+import * as fs from 'fs';
+import { start } from "../src/index.js";
+
+const westendSpec = fs.readFileSync('./test/westend.json', 'utf8');
+
+test('chainHead_unstable_follow works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  let subscriptionId = null;
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+
+        if (parsed.id == 1) {
+          subscriptionId = parsed.result;
+        } else if (parsed.method == "chainHead_unstable_followEvent" && parsed.params.subscription == subscriptionId) {
+          if (parsed.params.result.event == "initialized") {
+            if (parsed.params.result.finalizedBlockHash.toLowerCase() == "0x9d34c5a7a8ad8d73c7690a41f7a9d1a7c46e21dc8fb1638aee6ef07f45b65158" && !parsed.params.result.finalizedBlockRuntime)
+              promiseResolve();
+            else
+              promiseReject(resp);
+          }
+        } else {
+          promiseReject(resp);
+        }
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"chainHead_unstable_follow","params":[false]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('chainHead_unstable_unfollow works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  let chain;
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+
+        if (parsed.id == 1) {
+          chain.sendJsonRpc('{"jsonrpc":"2.0","id":2,"method":"chainHead_unstable_unfollow","params":[' + JSON.stringify(parsed.result) + ']}', 0, 0);
+        } else if (parsed.id == 2 && parsed.result == null) {
+          promiseResolve();
+        } else if (parsed.method != "chainHead_unstable_followEvent") { // Don't fail the promise on follow event
+          promiseReject(resp);
+        }
+      }
+    })
+    .then((c) => {
+      chain = c;
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"chainHead_unstable_follow","params":[false]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});

bin/wasm-node/javascript/test/chainSpec.js

@@ -0,0 +1,97 @@
+// Smoldot
+// Copyright (C) 2019-2021  Parity Technologies (UK) Ltd.
+// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0
+
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+import test from 'ava';
+import * as fs from 'fs';
+import { start } from "../src/index.js";
+
+const westendSpec = fs.readFileSync('./test/westend.json', 'utf8');
+
+test('chainSpec_chainName works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.result == "Westend")
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"chainSpec_unstable_chainName","params":[]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('chainSpec_unstable_genesisHash works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.result.toLowerCase() == "0xe143f23803ac50e8f6f8e62695d1ce9e4e1d68aa36c1cd2cfd15340213f3423e")
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"chainSpec_unstable_genesisHash","params":[]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('chainSpec_unstable_properties works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.result.ss58Format == 42 && parsed.result.tokenDecimals == 12 && parsed.result.tokenSymbol == "WND")
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"chainSpec_unstable_properties","params":[]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});

bin/wasm-node/javascript/test/sudo.js

@@ -0,0 +1,122 @@
+// Smoldot
+// Copyright (C) 2019-2021  Parity Technologies (UK) Ltd.
+// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0
+
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+import test from 'ava';
+import * as fs from 'fs';
+import { start } from "../src/index.js";
+
+const westendSpec = fs.readFileSync('./test/westend.json', 'utf8');
+
+test('sudo_unstable_p2pDiscover is available', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.id == 1 && parsed.result === null)
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"sudo_unstable_p2pDiscover","params":["/ip4/1.2.3.4/tcp/30333/p2p/12D3KooWDmQPkBvQGg9wjBdFThtWj3QCDVQyHJ1apfWrHvjwbYS8"]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('sudo_unstable_p2pDiscover returns error on invalid multiaddr', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.id == 1 && !!parsed.error)
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"sudo_unstable_p2pDiscover","params":["/hello/world"]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('sudo_unstable_p2pDiscover returns error if multiaddr doesn\'t end with /p2p', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.id == 1 && !!parsed.error)
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"sudo_unstable_p2pDiscover","params":["/ip4/127.0.0.1/tcp/30333/ws"]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});
+
+test('sudo_unstable_version works', async t => {
+  let promiseResolve;
+  let promiseReject;
+  const promise = new Promise((resolve, reject) => { promiseResolve = resolve; promiseReject = reject; });
+
+  const client = start({ logCallback: () => { } });
+  await client
+    .addChain({
+      chainSpec: westendSpec,
+      jsonRpcCallback: (resp) => {
+        const parsed = JSON.parse(resp);
+        if (parsed.result.includes("smoldot"))
+          promiseResolve();
+        else
+          promiseReject(resp);
+      }
+    })
+    .then((chain) => {
+      chain.sendJsonRpc('{"jsonrpc":"2.0","id":1,"method":"sudo_unstable_version","params":[]}', 0, 0);
+    })
+    .then(() => promise)
+    .then(() => t.pass())
+    .then(() => client.terminate());
+});

bin/wasm-node/javascript/test/test.js

@@ -19,7 +19,7 @@ import test from 'ava';
 import * as fs from 'fs';
 import { start } from "../src/index.js";
 
-const westendSpec = fs.readFileSync('../../westend.json', 'utf8');
+const westendSpec = fs.readFileSync('./test/westend.json', 'utf8');
 
 test('invalid chain spec throws error', async t => {
   const client = start({ logCallback: () => { } });