bump build

Author: SteffenDE

priv/static/phoenix.cjs.js

@@ -1054,6 +1054,7 @@ var Phoenix = (() => {
       this.channels = [];
       this.sendBuffer = [];
       this.ref = 0;
+      this.fallbackRef = null;
       this.timeout = opts.timeout || DEFAULT_TIMEOUT;
       this.transport = opts.transport || global.WebSocket || LongPoll;
       this.primaryPassedHealthCheck = false;
@@ -1067,6 +1068,7 @@ var Phoenix = (() => {
       this.disconnecting = false;
       this.binaryType = opts.binaryType || "arraybuffer";
       this.connectClock = 1;
+      this.pageHidden = false;
       if (this.transport !== LongPoll) {
         this.encode = opts.encode || this.defaultEncoder;
         this.decode = opts.decode || this.defaultDecoder;
@@ -1088,6 +1090,16 @@ var Phoenix = (() => {
             this.connect();
           }
         });
+        phxWindow.addEventListener("visibilitychange", () => {
+          if (document.visibilityState === "hidden") {
+            this.pageHidden = true;
+          } else {
+            this.pageHidden = false;
+            if (!this.isConnected()) {
+              this.teardown(() => this.connect());
+            }
+          }
+        });
       }
       this.heartbeatIntervalMs = opts.heartbeatIntervalMs || 3e4;
       this.rejoinAfterMs = (tries) => {
@@ -1118,6 +1130,11 @@ var Phoenix = (() => {
       this.heartbeatTimer = null;
       this.pendingHeartbeatRef = null;
       this.reconnectTimer = new Timer(() => {
+        if (this.pageHidden) {
+          this.log("Not reconnecting as page is hidden!");
+          this.teardown();
+          return;
+        }
         this.teardown(() => this.connect());
       }, this.reconnectAfterMs);
       this.authToken = opts.authToken;
@@ -1337,7 +1354,10 @@ var Phoenix = (() => {
           fallback(reason);
         }
       });
-      this.onOpen(() => {
+      if (this.fallbackRef) {
+        this.off([this.fallbackRef]);
+      }
+      this.fallbackRef = this.onOpen(() => {
         established = true;
         if (!primaryTransport) {
           if (!this.primaryPassedHealthCheck) {
@@ -1445,6 +1465,8 @@ var Phoenix = (() => {
       }, 150 * tries);
     }
     onConnClose(event) {
+      this.conn.onclose = () => {
+      };
       let closeCode = event && event.code;
       if (this.hasLogger()) this.log("transport", "close", event);
       this.triggerChanError();

priv/static/phoenix.cjs.js.map

@@ -1025,6 +1025,7 @@ var Socket = class {
     this.channels = [];
     this.sendBuffer = [];
     this.ref = 0;
+    this.fallbackRef = null;
     this.timeout = opts.timeout || DEFAULT_TIMEOUT;
     this.transport = opts.transport || global.WebSocket || LongPoll;
     this.primaryPassedHealthCheck = false;
@@ -1038,6 +1039,7 @@ var Socket = class {
     this.disconnecting = false;
     this.binaryType = opts.binaryType || "arraybuffer";
     this.connectClock = 1;
+    this.pageHidden = false;
     if (this.transport !== LongPoll) {
       this.encode = opts.encode || this.defaultEncoder;
       this.decode = opts.decode || this.defaultDecoder;
@@ -1059,6 +1061,16 @@ var Socket = class {
           this.connect();
         }
       });
+      phxWindow.addEventListener("visibilitychange", () => {
+        if (document.visibilityState === "hidden") {
+          this.pageHidden = true;
+        } else {
+          this.pageHidden = false;
+          if (!this.isConnected()) {
+            this.teardown(() => this.connect());
+          }
+        }
+      });
     }
     this.heartbeatIntervalMs = opts.heartbeatIntervalMs || 3e4;
     this.rejoinAfterMs = (tries) => {
@@ -1089,6 +1101,11 @@ var Socket = class {
     this.heartbeatTimer = null;
     this.pendingHeartbeatRef = null;
     this.reconnectTimer = new Timer(() => {
+      if (this.pageHidden) {
+        this.log("Not reconnecting as page is hidden!");
+        this.teardown();
+        return;
+      }
       this.teardown(() => this.connect());
     }, this.reconnectAfterMs);
     this.authToken = opts.authToken;
@@ -1308,7 +1325,10 @@ var Socket = class {
         fallback(reason);
       }
     });
-    this.onOpen(() => {
+    if (this.fallbackRef) {
+      this.off([this.fallbackRef]);
+    }
+    this.fallbackRef = this.onOpen(() => {
       established = true;
       if (!primaryTransport) {
         if (!this.primaryPassedHealthCheck) {
@@ -1416,6 +1436,8 @@ var Socket = class {
     }, 150 * tries);
   }
   onConnClose(event) {
+    this.conn.onclose = () => {
+    };
     let closeCode = event && event.code;
     if (this.hasLogger()) this.log("transport", "close", event);
     this.triggerChanError();