fix tests

moleculerjs · Dec 3, 2023 · 9305930 · 9305930
1 parent fef5716
commit 9305930
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 7 deletions.
diff --git a/src/tracing/span.js b/src/tracing/span.js
@@ -27,8 +27,8 @@ function defProp(instance, propName, value, readOnly = false) {
 /**
  * Trace Span class
  *
- * @property {Tracer} tracer
  * @class Span
+ * @property {Tracer} tracer
  * @implements {SpanClass}
  */
 class Span {

diff --git a/src/transporters/tcp.js b/src/transporters/tcp.js
@@ -413,6 +413,7 @@ class TcpTransporter extends Transporter {
 	processGossipHello(msg, socket) {
 		try {
 			const packet = this.deserialize(P.PACKET_GOSSIP_HELLO, msg);
+			/** @type {Record<string, any>} */
 			const payload = packet.payload;
 			const nodeID = payload.sender;
 
@@ -522,6 +523,7 @@ class TcpTransporter extends Transporter {
 
 		try {
 			const packet = this.deserialize(P.PACKET_GOSSIP_REQ, msg);
+			/** @type {Record<string, any>} */
 			const payload = packet.payload;
 
 			if (this.GOSSIP_DEBUG)
@@ -639,6 +641,7 @@ class TcpTransporter extends Transporter {
 	processGossipResponse(msg) {
 		try {
 			const packet = this.deserialize(P.PACKET_GOSSIP_RES, msg);
+			/** @type {Record<string, any>} */
 			const payload = packet.payload;
 
 			if (this.GOSSIP_DEBUG)

diff --git a/test/unit/registry/registry.spec.js b/test/unit/registry/registry.spec.js
@@ -20,7 +20,8 @@ describe("Test Registry constructor", () => {
 		expect(registry.opts).toEqual({
 			preferLocal: true,
 			stopDelay: 100,
-			strategy: "RoundRobin"
+			strategy: "RoundRobin",
+			discoverer: "Local"
 		});
 		expect(registry.StrategyFactory).toBe(Strategies.RoundRobin);
 		expect(registry.discoverer).toBeInstanceOf(Discoverers.Local);
@@ -44,7 +45,8 @@ describe("Test Registry constructor", () => {
 		expect(registry.opts).toEqual({
 			preferLocal: false,
 			stopDelay: 100,
-			strategy: "Random"
+			strategy: "Random",
+			discoverer: "Local"
 		});
 		expect(registry.StrategyFactory).toBe(Strategies.Random);
 	});

diff --git a/test/unit/service-broker.spec.js b/test/unit/service-broker.spec.js
@@ -133,7 +133,7 @@ describe("Test ServiceBroker constructor", () => {
 
 		expect(broker.registry).toBeInstanceOf(Registry);
 		expect(broker.registry.init).toBeCalledTimes(1);
-		expect(broker.registry.init).toBeCalledWith(broker);
+		expect(broker.registry.init).toBeCalledWith();
 
 		expect(broker.middlewares).toBeInstanceOf(MiddlewareHandler);
 
@@ -247,7 +247,8 @@ describe("Test ServiceBroker constructor", () => {
 			registry: {
 				strategy: Strategies.Random,
 				preferLocal: false,
-				stopDelay: 100
+				stopDelay: 100,
+				discoverer: "Local"
 			},
 
 			circuitBreaker: {
@@ -3940,7 +3941,7 @@ describe("Test broker getHealthStatus", () => {
 		broker.getHealthStatus();
 
 		expect(H.getHealthStatus).toHaveBeenCalledTimes(1);
-		expect(H.getHealthStatus).toHaveBeenCalledWith(broker);
+		expect(H.getHealthStatus).toHaveBeenCalledWith();
 	});
 });
 

diff --git a/test/unit/transporters/tcp/udp-broadcaster.spec.js b/test/unit/transporters/tcp/udp-broadcaster.spec.js
@@ -109,7 +109,7 @@ describe("Test UdpServer.startServer", () => {
 
 				expect(server.bind).toHaveBeenCalledTimes(1);
 				expect(server.bind).toHaveBeenCalledWith(
-					{ exclusive: true, address: "10.0.0.4", port: 4567 },
+					{ exclusive: true, port: 4567 },
 					expect.any(Function)
 				);