socket: process?.env

Author: dynst

packages/socket/src/queueingstreamingsocket.spec.ts

@@ -1,9 +1,10 @@
 import { ConnectionStatus, QueueingStreamingSocket } from "./queueingstreamingsocket";
 
 function pendingWithoutSocketServer(): void {
-  if (!process.env.SOCKETSERVER_ENABLED) {
-    pending("Set SOCKETSERVER_ENABLED to enable socket tests");
+  if (typeof process !== "undefined" && process?.env.SOCKETSERVER_ENABLED) {
+    return;
   }
+  pending("Set SOCKETSERVER_ENABLED to enable socket tests");
 }
 
 describe("QueueingStreamingSocket", () => {

packages/socket/src/reconnectingsocket.spec.ts

@@ -12,9 +12,10 @@ const getExec = async (): Promise<Exec | undefined> => {
 };
 
 function pendingWithoutSocketServer(): void {
-  if (!process.env.SOCKETSERVER_ENABLED) {
-    pending("Set SOCKETSERVER_ENABLED to enable socket tests");
+  if (typeof process !== "undefined" && process?.env.SOCKETSERVER_ENABLED) {
+    return;
   }
+  pending("Set SOCKETSERVER_ENABLED to enable socket tests");
 }
 
 describe("ReconnectingSocket", () => {

packages/socket/src/socketwrapper.spec.ts

@@ -1,9 +1,10 @@
 import { SocketWrapper } from "./socketwrapper";
 
 function pendingWithoutSocketServer(): void {
-  if (!process.env.SOCKETSERVER_ENABLED) {
-    pending("Set SOCKETSERVER_ENABLED to enable socket tests");
+  if (typeof process !== "undefined" && process?.env.SOCKETSERVER_ENABLED) {
+    return;
   }
+  pending("Set SOCKETSERVER_ENABLED to enable socket tests");
 }
 
 describe("SocketWrapper", () => {

packages/socket/src/streamingsocket.spec.ts

@@ -2,14 +2,11 @@ import { toListPromise } from "@cosmjs/stream";
 
 import { StreamingSocket } from "./streamingsocket";
 
-function skipTests(): boolean {
-  return !process.env.SOCKETSERVER_ENABLED;
-}
-
 function pendingWithoutSocketServer(): void {
-  if (skipTests()) {
-    pending("Set SOCKETSERVER_ENABLED to enable socket tests");
+  if (typeof process !== "undefined" && process?.env.SOCKETSERVER_ENABLED) {
+    return;
   }
+  pending("Set SOCKETSERVER_ENABLED to enable socket tests");
 }
 
 describe("StreamingSocket", () => {