rpc_test.ts

import { assertNode, assertNodeThrows } from "./testutil.ts";
import { RPC } from "./rpc.ts";
import { Type } from "./type.ts";

Deno.test("RPC", async () => {
  const tt: [string, RPC][] = [
    [
      `rpc Foo (Req) returns (Res) {}`,
      new RPC(
        "Foo",
        { name: new Type("Req", [1, 10], [1, 12]) },
        { name: new Type("Res", [1, 24], [1, 26]) },
        [],
        [1, 1],
        [1, 30],
      ),
    ],
    [
      `rpc Foo (Req) returns (Res);`,
      new RPC(
        "Foo",
        { name: new Type("Req", [1, 10], [1, 12]) },
        { name: new Type("Res", [1, 24], [1, 26]) },
        null,
        [1, 1],
        [1, 28],
      ),
    ],
    [
      `rpc Foo (stream Req) returns (Res);`,
      new RPC(
        "Foo",
        { name: new Type("Req", [1, 17], [1, 19]), streaming: true },
        { name: new Type("Res", [1, 31], [1, 33]) },
        null,
        [1, 1],
        [1, 35],
      ),
    ],
    [
      `rpc Foo (Req) returns (stream Res);`,
      new RPC(
        "Foo",
        { name: new Type("Req", [1, 10], [1, 12]) },
        { name: new Type("Res", [1, 31], [1, 33]), streaming: true },
        null,
        [1, 1],
        [1, 35],
      ),
    ],
  ];
  for (const t of tt) await assertNode(RPC, ...t);
});

Deno.test("RPC errors", async () => {
  const tt: [string, string][] = [
    [`rpc Foo (Req) returns (Res) {`, "unexpected eof on line 1, column 29"],
    [
      `rpc _foo {}`,
      "unexpected token (_) on line 1, column 5; expected identifier",
    ],
    [
      `rpc 1foo {}`,
      "unexpected int (1) on line 1, column 5; expected identifier",
    ],
    [
      `rpc foo.bar {}`,
      "unexpected token (.) on line 1, column 8; expected identifier",
    ],
  ];
  for (const t of tt) await assertNodeThrows(RPC, ...t);
});