conat -- more service unit tests

Author: williamstein

src/packages/backend/conat/test/service.test.ts

@@ -7,9 +7,15 @@ pnpm test ./service.test.ts
 */
 
 import { callConatService, createConatService } from "@cocalc/conat/service";
+import {
+  createServiceClient,
+  createServiceHandler,
+} from "@cocalc/conat/service/typed";
 import { once } from "@cocalc/util/async-utils";
 import { before, after } from "@cocalc/backend/conat/test/setup";
 import { wait } from "@cocalc/backend/conat/test/util";
+import { is_date as isDate } from "@cocalc/util/misc";
+import { delay } from "awaiting";
 
 beforeAll(before);
 
@@ -54,4 +60,62 @@ describe("verify that you can create a service AFTER calling it and things to st
   });
 });
 
+describe("create and test a more complicated service", () => {
+  let client, service;
+  it("defines the service", async () => {
+    interface Api {
+      add: (a: number, b: number) => Promise<number>;
+      concat: (a: Buffer, b: Buffer) => Promise<Buffer>;
+      now: () => Promise<Date>;
+      big: (n: number) => Promise<string>;
+      len: (s: string) => Promise<number>;
+    }
+
+    const name = "my-service";
+    service = await createServiceHandler<Api>({
+      service: name,
+      subject: name,
+      description: "My Service",
+      impl: {
+        // put any functions here that take/return MsgPack'able values
+        add: async (a, b) => a + b,
+        concat: async (a, b) => Buffer.concat([a, b]),
+        now: async () => {
+          await delay(5);
+          return new Date();
+        },
+        big: async (n: number) => "x".repeat(n),
+        len: async (s: string) => s.length,
+      },
+    });
+
+    client = createServiceClient<Api>({
+      service: name,
+      subject: name,
+    });
+  });
+
+  it("tests the service", async () => {
+    // these calls are all type checked using typescript
+    expect(await client.add(2, 3)).toBe(5);
+
+    const a = Buffer.from("hello");
+    const b = Buffer.from(" conat");
+    expect(await client.concat(a, b)).toEqual(Buffer.concat([a, b]));
+
+    const d = await client.now();
+    expect(isDate(d)).toBe(true);
+    expect(Math.abs(d.valueOf() - Date.now())).toBeLessThan(100);
+
+    const n = 10 * 1e6;
+    expect((await client.big(n)).length).toBe(n);
+
+    expect(await client.len("x".repeat(n))).toBe(n);
+  });
+
+  it("cleans up", () => {
+    service.close();
+  });
+});
+
 afterAll(after);