feat: runtime validation

_tasks/dnt.ts

@@ -8,33 +8,20 @@ await fs.emptyDir(outDir);
 
 await Promise.all([
   build({
-    entryPoints: ["mod.ts", {
-      name: "./frame_metadata",
-      path: "frame_metadata/mod.ts",
-    }, {
-      name: "./effect",
-      path: "effect/mod.ts",
-    }, {
-      name: "./known",
-      path: "known/mod.ts",
-    }, {
-      name: "./rpc",
-      path: "rpc/mod.ts",
-    }],
+    entryPoints: ["mod.ts"],
     outDir,
     mappings: {
-      "https://deno.land/x/[email protected].0/mod.ts": {
+      "https://deno.land/x/[email protected].1/mod.ts": {
         name: "scale-codec",
-        version: "^0.9.0",
+        version: "^0.9.1",
       },
-      "https://deno.land/x/[email protected].6/mod.ts": {
+      "https://deno.land/x/[email protected].12/mod.ts": {
         name: "zones",
-        version: "0.1.0-beta.6",
+        version: "0.1.0-beta.12",
       },
-      "deps/smoldot_phantom.ts": {
+      "https://deno.land/x/[email protected]/index-deno.js": {
         name: "@substrate/smoldot-light",
         version: "0.6.20",
-        peerDependency: true,
       },
     },
     package: {

deps/scale.ts

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

effects/extrinsic.ts

@@ -53,11 +53,15 @@ export class SignedExtrinsic<
     const metadata_ = metadata(this.props.client)();
     const deriveCodec_ = deriveCodec(metadata_);
     const addrPrefix = const_(this.props.client)("System", "SS58Prefix")
-      .access("value").as<number>();
+      .access("value")
+      .as<number>();
     const $extrinsic_ = $extrinsic(deriveCodec_, metadata_, this.sign, addrPrefix);
-    const versions = const_(this.props.client)("System", "Version").access("value");
-    const specVersion = versions.access("spec_version").as<number>();
-    const transactionVersion = versions.access("transaction_version").as<number>();
+    const versions = const_(this.props.client)("System", "Version")
+      .access("value");
+    const specVersion = versions
+      .access("spec_version").as<number>();
+    const transactionVersion = versions
+      .access("transaction_version").as<number>();
     // TODO: create match effect in zones and use here
     // TODO: MultiAddress conversion utils
     const senderSs58 = Z.ls(addrPrefix, this.props.sender).next(([addrPrefix, sender]) => {
@@ -76,24 +80,26 @@ export class SignedExtrinsic<
     const checkpointHash = this.props.checkpoint
       ? Z.option(this.props.checkpoint, U.hex.decode)
       : genesisHash;
+    const mortality = Z
+      .lift(this.props.mortality)
+      .next((mortality) => {
+        return mortality
+          ? M.era.mortal(mortality[0], mortality[1])
+          : M.era.immortal;
+      });
+    const extra = Z.ls(mortality, nonce, this.props.tip || 0);
+    const additional = Z.ls(specVersion, transactionVersion, checkpointHash, genesisHash);
+    const signature = Z.rec({ address: this.props.sender, extra, additional });
     const $extrinsicProps = Z.rec({
       protocolVersion: 4,
       palletName: this.props.palletName,
       methodName: this.props.methodName,
       args: this.props.args,
-      signature: Z.rec({
-        address: this.props.sender,
-        extra: Z.ls(
-          this.props.mortality
-            ? Z.rec({ type: "Mortal", value: this.props.mortality })
-            : { type: "Immortal" },
-          nonce,
-          this.props.tip || 0,
-        ),
-        additional: Z.ls(specVersion, transactionVersion, checkpointHash, genesisHash),
-      }),
+      signature,
     });
-    this.extrinsic = e$.scaleEncoded($extrinsic_, $extrinsicProps, true).next(U.hex.encode);
+    this.extrinsic = e$
+      .scaleEncoded($extrinsic_, $extrinsicProps, true)
+      .next(U.hex.encode);
   }
 
   watch<Listener extends Z.$<U.Listener<known.TransactionStatus, rpc.ClientSubscribeContext>>>(

frame_metadata/Era.ts

@@ -2,16 +2,15 @@ import * as $ from "../deps/scale.ts";
 
 export type Era = { type: "Immortal" } | { type: "Mortal"; period: bigint; phase: bigint };
 
-export function immortalEra(): Era {
-  return { type: "Immortal" };
-}
-
-export function mortalEra(period: bigint, current: bigint): Era {
-  const adjustedPeriod = minN(maxN(nextPowerOfTwo(period), 4n), 1n << 16n);
-  const phase = current % adjustedPeriod;
-  const quantizeFactor = maxN(adjustedPeriod >> 12n, 1n);
-  const quantizedPhase = phase / quantizeFactor * quantizeFactor;
-  return { type: "Mortal", period: adjustedPeriod, phase: quantizedPhase };
+export namespace era {
+  export const immortal: Era = { type: "Immortal" };
+  export function mortal(period: bigint, current: bigint): Era {
+    const adjustedPeriod = minN(maxN(nextPowerOfTwo(period), 4n), 1n << 16n);
+    const phase = current % adjustedPeriod;
+    const quantizeFactor = maxN(adjustedPeriod >> 12n, 1n);
+    const quantizedPhase = phase / quantizeFactor * quantizeFactor;
+    return { type: "Mortal", period: adjustedPeriod, phase: quantizedPhase };
+  }
 }
 
 export const $era: $.Codec<Era> = $.createCodec({
@@ -43,9 +42,12 @@ export const $era: $.Codec<Era> = $.createCodec({
       }
     }
   },
-  _assert() {
-    // TODO
-  },
+  _assert: $
+    .taggedUnion("type", [
+      ["Immortal"],
+      ["Mortal", ["period", $.u64], ["phase", $.u64]],
+    ])
+    ._assert,
 });
 
 function maxN(a: bigint, b: bigint) {

frame_metadata/Extrinsic.ts

@@ -163,8 +163,33 @@ export function $extrinsic(props: ExtrinsicCodecProps): $.Codec<Extrinsic> {
       const { type: palletName, value: { type: methodName, ...args } } = call;
       return { protocolVersion, signature, palletName, methodName, args };
     },
-    _assert() {
-      // TODO
+    _assert(assert) {
+      assert.typeof(this, "object");
+      assert
+        .key(this, "protocolVersion")
+        .equals($.u8, 4);
+      const value_ = assert.value as any;
+      // TODO: use `assert.key(this, "call")` upon merging https://github.com/paritytech/capi/pull/368
+      $call._assert(
+        new $.AssertState({
+          type: value_.palletName,
+          value: {
+            type: value_.methodName,
+            ...value_.args,
+          },
+        }),
+      );
+      if (value_.signature) {
+        const signatureAssertState = assert.key(this, "signature");
+        signatureAssertState.key($address, "address");
+        signatureAssertState.key($extra, "extra");
+        if ("additional" in signatureAssertState) {
+          signatureAssertState.key($additional, "additional");
+        }
+        if ("sig" in signatureAssertState) {
+          signatureAssertState.key($sig, "sig");
+        }
+      }
     },
   });
 

frame_metadata/Key.ts

@@ -53,8 +53,11 @@ export function $storageKey(props: StorageKeyProps): $.Codec<unknown[]> {
       buffer.index += 32;
       return $keys[Object.values($keys).length - 1]!._decode(buffer);
     },
-    _assert() {
-      // TODO #362
+    _assert(assert) {
+      assert.instanceof(this, Array);
+      const value = assert.value as unknown[];
+      if (value.length === 0) return;
+      $keys[value.length]!._assert(assert);
     },
   });
 }

frame_metadata/scale_info.ts

@@ -20,24 +20,24 @@ export const $tys: $.Codec<Ty[]> = $.createCodec({
     }
     return tys;
   },
-  _assert() {
-    // TODO #362
+  _assert(assert) {
+    $.array($ty)._assert(assert);
   },
 });
 
 export const $tyId: $.Codec<Ty> = $.createCodec({
   _metadata: $.metadata("$tyId"),
   _staticSize: $compactU32._staticSize,
   _encode(buffer, value) {
-    $.compact($.u32)._encode(buffer, value.id);
+    $compactU32._encode(buffer, value.id);
   },
   _decode(buffer) {
     const ctx = buffer.context.get(TyDecodeCtx);
     const id = $compactU32._decode(buffer);
     return ctx.tys?.[id] ?? { id } as any;
   },
-  _assert() {
-    // TODO #362
+  _assert(assert) {
+    $compactU32._assert(assert.key(this, "id"));
   },
 });