chore: remove fluent api and clean up examples

deps/polkadot/types.ts

@@ -0,0 +1 @@
+export * from "https://deno.land/x/[email protected]/types/mod.ts";

effect/extrinsic.test.ts

@@ -34,7 +34,7 @@ Deno.test({
       fn: async () => {
         const root = C.readEntry(config, "System", "Account", [t.bob.publicKey]);
 
-        const state = U.throwIfError(await root.run());
+        const state = await root.run();
 
         assertObjectMatch(state, { value: { data: { free: 10000000000012345n } } });
       },

examples/balance.ts

@@ -1,15 +1,15 @@
 import * as C from "../mod.ts";
 import * as t from "../test-util/mod.ts";
-import * as U from "../util/mod.ts";
 
 const config = await t.config();
 
-const root = C
-  .chain(config)
-  .pallet("System")
-  .entry("Account", t.alice.publicKey)
-  .read();
+const root = C.readEntry(config, "System", "Account", [t.alice.publicKey]);
 
-console.log(U.throwIfError(await root.run()));
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result);
 
 config.close();

effect/examples/derived.ts → examples/derived.ts

@@ -1,12 +1,17 @@
-import * as C from "../../mod.ts";
-import * as U from "../../util/mod.ts";
+import * as C from "../mod.ts";
 
 const ids = C.readEntry(C.polkadot, "Paras", "Parachains", []);
+
 const root = C.into([ids], ({ value }) => {
   const heads = value.map((id: number) => {
     return C.readEntry(C.polkadot, "Paras", "Heads", [id]);
   });
   return C.all(...heads);
 });
 
-console.log(U.throwIfError(await root.run()));
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result);

examples/first_ten_keys.ts

@@ -1,16 +1,15 @@
 import * as C from "../mod.ts";
 import * as t from "../test-util/mod.ts";
-import * as U from "../util/mod.ts";
 
 const config = await t.config();
 
-const root = C
-  .chain(config)
-  .pallet("System")
-  .entry("Account")
-  .keyPage(10)
-  .read();
+const root = C.readKeyPage(config, "System", "Account", 10);
 
-console.log(U.throwIfError(await root.run()));
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result.keys);
 
 config.close();

examples/metadata.ts

@@ -1,14 +1,15 @@
 import * as C from "../mod.ts";
 import * as t from "../test-util/mod.ts";
-import * as U from "../util/mod.ts";
 
 const config = await t.config();
 
-const root = C
-  .chain(config)
-  .metadata()
-  .read();
+const root = C.metadata(config);
 
-console.log(U.throwIfError(await root.run()));
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result);
 
 config.close();

examples/polkadot_signer.ts

@@ -1,39 +1,36 @@
-import { TypeRegistry } from "https://deno.land/x/polkadot@0.0.8/types/mod.ts";
+import { TypeRegistry } from "../deps/polkadot/types.ts";
 import * as C from "../mod.ts";
 import * as t from "../test-util/mod.ts";
-import * as U from "../util/mod.ts";
 
-const config = await t.config();
+const config = await t.config({ altRuntime: "westend" });
 
-const root = C
-  .chain(config)
-  .pallet("Balances")
-  .extrinsic("transfer")
-  .call({
+const root = C.sendAndWatchExtrinsic({
+  config,
+  sender: {
+    type: "Id",
+    value: t.alice.publicKey,
+  },
+  palletName: "Balances",
+  methodName: "transfer",
+  args: {
     value: 12345n,
     dest: {
       type: "Id",
       value: t.bob.publicKey,
     },
-  })
-  .signed(
-    {
-      type: "Id",
-      value: t.alice.publicKey,
-    },
-    {
-      signPayload(payload: any) {
-        const tr = new TypeRegistry();
-        tr.setSignedExtensions(payload.signedExtensions);
-        return Promise.resolve(
-          tr
-            .createType("ExtrinsicPayload", payload, { version: payload.version })
-            .sign(t.alice),
-        );
-      },
+  },
+  sign: {
+    signPayload(payload) {
+      const tr = new TypeRegistry();
+      tr.setSignedExtensions(payload.signedExtensions);
+      return Promise.resolve(
+        tr
+          .createType("ExtrinsicPayload", payload, { version: payload.version })
+          .sign(t.alice),
+      );
     },
-  )
-  .sendAndWatch((stop) => {
+  },
+  createWatchHandler(stop) {
     return (event) => {
       if (typeof event.params.result === "string") {
         console.log("Extrinsic", event.params.result);
@@ -45,9 +42,17 @@ const root = C
           stop();
         } else {
           console.log("Misc", event.params.result);
+          stop();
         }
       }
     };
-  });
+  },
+});
+
+const maybeError = await root.run();
+
+if (maybeError instanceof Error) {
+  throw maybeError;
+}
 
-U.throwIfError(await root.run());
+config.close();

examples/raw_rpc_client/call.ts

@@ -0,0 +1,13 @@
+import * as C from "../../mod.ts";
+import * as rpc from "../../rpc/mod.ts";
+
+const client = await rpc.stdClient(C.westend);
+if (client instanceof Error) {
+  throw client;
+}
+
+const result = await client.call("state_getMetadata", []);
+
+console.log(result);
+
+await client.close();

examples/raw_rpc_client/subscription.ts

@@ -0,0 +1,22 @@
+import * as C from "../../mod.ts";
+import * as rpc from "../../rpc/mod.ts";
+
+const client = await rpc.stdClient(C.westend);
+if (client instanceof Error) {
+  throw client;
+}
+
+const maybeError = await client.subscribe("chain_subscribeAllHeads", [], (stop) => {
+  let i = 1;
+  return async (message) => {
+    console.log({ [i++]: message.params.result });
+    if (i > 5) {
+      stop();
+      await client.close();
+    }
+  };
+});
+
+if (maybeError) {
+  console.log(maybeError);
+}

examples/read_block.ts

@@ -0,0 +1,10 @@
+import * as C from "../mod.ts";
+
+const root = C.readBlock(C.polkadot);
+
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result);

examples/read_events.ts

@@ -0,0 +1,10 @@
+import * as C from "../mod.ts";
+
+const root = C.readEntry(C.westend, "System", "Events", []);
+
+const result = await root.run();
+
+if (result instanceof Error) {
+  throw result;
+}
+console.log(result);