mirror of
https://github.com/hanzomsg/nats.js.git
synced 2026-10-30 20:31:36 +00:00
Alberto RicartandGitHub
6966b17e8a
- Replaced `jsr:@std/*` imports with `@std/*` as per deno linter changes. - Updated `@types/node` to `^24.3.1` and `typescript` to `^5.9.2`. - Synchronized dependency versions across modules for alignment. - Adjusted `deno.json` to reflect resolved import paths as per deno linter Signed-off-by: Alberto Ricart <[email protected]>
92 lines
2.5 KiB
TypeScript
92 lines
2.5 KiB
TypeScript
/*
|
|
* Copyright 2018-2023 The NATS Authors
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
import {
|
|
Empty,
|
|
extractProtocolMessage,
|
|
MuxSubscription,
|
|
protoLen,
|
|
RequestOne,
|
|
SubscriptionImpl,
|
|
Subscriptions,
|
|
} from "../src/internal_mod.ts";
|
|
import type { Msg, ProtocolHandler } from "../src/internal_mod.ts";
|
|
import { assertEquals, assertRejects, equal } from "@std/assert";
|
|
import { errors } from "../src/errors.ts";
|
|
|
|
Deno.test("protocol - mux subscription cancel", async () => {
|
|
const mux = new MuxSubscription();
|
|
mux.init();
|
|
|
|
const r = new RequestOne(mux, "");
|
|
r.token = "alberto";
|
|
mux.add(r);
|
|
assertEquals(mux.size(), 1);
|
|
assertEquals(mux.get("alberto"), r);
|
|
assertEquals(mux.getToken({ subject: "" } as Msg), null);
|
|
|
|
const check = assertRejects(
|
|
() => {
|
|
return Promise.race([r.deferred, r.timer]);
|
|
},
|
|
errors.RequestError,
|
|
"cancelled",
|
|
);
|
|
|
|
r.cancel();
|
|
|
|
await check;
|
|
assertEquals(mux.size(), 0);
|
|
});
|
|
|
|
Deno.test("protocol - bad dispatch is noop", () => {
|
|
const mux = new MuxSubscription();
|
|
mux.init();
|
|
mux.dispatcher()(null, { subject: "foo" } as Msg);
|
|
});
|
|
|
|
Deno.test("protocol - subs all", () => {
|
|
const subs = new Subscriptions();
|
|
|
|
const s = new SubscriptionImpl({
|
|
unsubscribe(_s: SubscriptionImpl, _max?: number) {},
|
|
} as ProtocolHandler, "hello");
|
|
subs.add(s);
|
|
assertEquals(subs.size(), 1);
|
|
assertEquals(s.sid, 1);
|
|
assertEquals(subs.sidCounter, 1);
|
|
equal(subs.get(0), s);
|
|
const a = subs.all();
|
|
assertEquals(a.length, 1);
|
|
subs.cancel(a[0]);
|
|
assertEquals(subs.size(), 0);
|
|
});
|
|
|
|
Deno.test("protocol - cancel unknown sub", () => {
|
|
const subs = new Subscriptions();
|
|
const s = new SubscriptionImpl({
|
|
unsubscribe(_s: SubscriptionImpl, _max?: number) {},
|
|
} as ProtocolHandler, "hello");
|
|
assertEquals(subs.size(), 0);
|
|
subs.add(s);
|
|
assertEquals(subs.size(), 1);
|
|
subs.cancel(s);
|
|
assertEquals(subs.size(), 0);
|
|
});
|
|
|
|
Deno.test("protocol - protolen -1 on empty", () => {
|
|
assertEquals(protoLen(Empty), 0);
|
|
assertEquals(extractProtocolMessage(Empty), "");
|
|
});
|