code quality

moleculerjs · Nov 25, 2023 · 7cfc1be · 7cfc1be
1 parent 509233a
commit 7cfc1be
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 8 deletions.
diff --git a/src/registry/event-catalog.js b/src/registry/event-catalog.js
@@ -178,7 +178,7 @@ class EventCatalog {
 			if (!utils.match(ctx.eventName, list.name)) return;
 			if (
 				ctx.eventGroups == null ||
-				ctx.eventGroups.length == 0 ||
+				ctx.eventGroups.length === 0 ||
 				ctx.eventGroups.indexOf(list.group) !== -1
 			) {
 				if (isBroadcast) {

diff --git a/src/tracing/exporters/console.js b/src/tracing/exporters/console.js
@@ -178,8 +178,8 @@ class ConsoleTraceExporter extends BaseTraceExporter {
 			if (item.children.length > 0) {
 				item.children.forEach((spanID, idx) => {
 					const span = this.spans[spanID];
-					span.first = idx == 0;
-					span.last = idx == item.children.length - 1;
+					span.first = idx === 0;
+					span.last = idx === item.children.length - 1;
 					check(span, item.level + 1, [].concat(item.parents, [item]));
 				});
 			}
@@ -250,8 +250,8 @@ class ConsoleTraceExporter extends BaseTraceExporter {
 		if (spanItem.children.length > 0)
 			spanItem.children.forEach((spanID, idx) =>
 				this.printSpanTime(this.spans[spanID], mainItem, level + 1, spanItem, {
-					first: idx == 0,
-					last: idx == spanItem.children.length - 1
+					first: idx === 0,
+					last: idx === spanItem.children.length - 1
 				})
 			);
 	}

diff --git a/src/tracing/tracer.js b/src/tracing/tracer.js
@@ -172,7 +172,7 @@ class Tracer {
 
 		if (this.opts.sampling.rate === 0) return false;
 
-		if (this.opts.sampling.rate == 1) return true;
+		if (this.opts.sampling.rate === 1) return true;
 
 		if (++this.sampleCounter * this.opts.sampling.rate >= 1.0) {
 			this.sampleCounter = 0;

diff --git a/src/transit.js b/src/transit.js
@@ -639,7 +639,7 @@ class Transit {
 			}
 		}
 
-		return stream && payload.seq == 0 ? stream : null;
+		return stream && payload.seq === 0 ? stream : null;
 	}
 
 	/**

diff --git a/src/transporters/tcp.js b/src/transporters/tcp.js
@@ -219,7 +219,7 @@ class TcpTransporter extends Transporter {
 						if (s.startsWith("tcp://")) s = s.replace("tcp://", "");
 
 						const p = s.split("/");
-						if (p.length != 2) {
+						if (p.length !== 2) {
 							this.logger.warn("Invalid endpoint URL. Missing nodeID. URL:", s);
 							return;
 						}
-Original file line number
+Diff line change
@@ Expand Up / @@ -639,7 +639,7 @@ class Transit { @@
     			}
     		}
-    		return stream && payload.seq == 0 ? stream : null;
+    		return stream && payload.seq === 0 ? stream : null;
     	}
     	/**
@@ Expand Down @@