sync: export SvStateVector

package.json

@@ -13,7 +13,7 @@
     "test": "vitest",
     "typedoc": "bash mk/typedoc.sh"
   },
-  "packageManager": "pnpm@8.9.0",
+  "packageManager": "pnpm@8.9.2",
   "devDependencies": {
     "@types/node": "^20.8.6",
     "@types/wtfnode": "^0.7.1",

packages/sync/src/svs/mod.ts

@@ -1,4 +1,5 @@
-export * from "./mapping-entry";
+export { SvMappingEntry, SvTimedMappingEntry } from "./mapping-entry";
+export { SvStateVector } from "./state-vector";
 export { SvSync } from "./sync";
 export { SvPublisher } from "./publisher";
 export { SvSubscriber } from "./subscriber";

packages/sync/tests/svs.t.ts

@@ -7,7 +7,7 @@ import DefaultMap from "mnemonist/default-map.js";
 import { filter } from "streaming-iterables";
 import { afterEach, expect, test } from "vitest";
 
-import { SvSync } from "..";
+import { SvStateVector, SvSync } from "..";
 
 class UpdateHandler {
   constructor(sync: SvSync) {
@@ -161,10 +161,11 @@ test("initialize", async () => {
   expect(v0.get(new Name("/C"))).toBe(13);
   expect(v0.get(new Name("/D"))).toBe(0);
 
+  const v1 = new SvStateVector(JSON.parse(JSON.stringify(v0)));
   const p1 = await SvSync.create({
     ...opts,
     describe: "1",
-    initialStateVector: v0,
+    initialStateVector: v1,
     async initialize(sync) {
       closers.push(sync);
       debugHandler.start(sync);

packages/sync/tests/svsps.t.ts

@@ -1,7 +1,5 @@
 import "@ndn/packet/test-fixture/expect";
 
-import { setMaxListeners } from "node:events";
-
 import { Endpoint } from "@ndn/endpoint";
 import { generateSigningKey } from "@ndn/keychain";
 import { Name, type NameLike } from "@ndn/packet";
@@ -17,8 +15,6 @@ let pubOpts: Partial<SvPublisher.Options>;
 let subOpts: Partial<SvSubscriber.Options>;
 
 beforeAll(async () => {
-  setMaxListeners(20);
-
   const [signerS, verifierS] = await generateSigningKey("/kS");
   const [signerI, verifierI] = await generateSigningKey("/kI");
   const [signerO, verifierO] = await generateSigningKey("/kO");