mirror of
				https://github.com/TriliumNext/Notes.git
				synced 2025-10-31 04:51:31 +08:00 
			
		
		
		
	fixed websocket reconnection
This commit is contained in:
		
							parent
							
								
									bf3360572a
								
							
						
					
					
						commit
						2b44f3bc76
					
				| @ -67,12 +67,9 @@ function connectWebSocket() { | |||||||
| 
 | 
 | ||||||
|     // use wss for secure messaging
 |     // use wss for secure messaging
 | ||||||
|     const ws = new WebSocket(protocol + "://" + location.host); |     const ws = new WebSocket(protocol + "://" + location.host); | ||||||
|     ws.onopen = event => console.debug(utils.now(), "Connected to server with WebSocket"); |     ws.onopen = () => console.debug(utils.now(), "Connected to server with WebSocket"); | ||||||
|     ws.onmessage = handleMessage; |     ws.onmessage = handleMessage; | ||||||
|     ws.onclose = function(){ |     // we're not handling ws.onclose here because reconnection is done in sendPing()
 | ||||||
|         // Try to reconnect in 5 seconds
 |  | ||||||
|         setTimeout(() => connectWebSocket(), 5000); |  | ||||||
|     }; |  | ||||||
| 
 | 
 | ||||||
|     return ws; |     return ws; | ||||||
| } | } | ||||||
| @ -88,13 +85,17 @@ setTimeout(() => { | |||||||
|             console.log("Lost connection to server"); |             console.log("Lost connection to server"); | ||||||
|         } |         } | ||||||
| 
 | 
 | ||||||
|         try { |         if (ws.readyState === ws.OPEN) { | ||||||
|             ws.send(JSON.stringify({ |             ws.send(JSON.stringify({ | ||||||
|                 type: 'ping', |                 type: 'ping', | ||||||
|                 lastSyncId: lastSyncId |                 lastSyncId: lastSyncId | ||||||
|             })); |             })); | ||||||
|         } |         } | ||||||
|         catch (e) {} // if the connection is closed then this produces a lot of messages
 |         else if (ws.readyState === ws.CLOSED || ws.readyState === ws.CLOSING) { | ||||||
|  |             console.log("WS closed or closing, trying to reconnect"); | ||||||
|  | 
 | ||||||
|  |             ws = connectWebSocket(); | ||||||
|  |         } | ||||||
|     }, 1000); |     }, 1000); | ||||||
| }, 0); | }, 0); | ||||||
| 
 | 
 | ||||||
|  | |||||||
| @ -96,7 +96,7 @@ class TabContext { | |||||||
|         this.$unprotectButton = this.$tabContent.find(".unprotect-button"); |         this.$unprotectButton = this.$tabContent.find(".unprotect-button"); | ||||||
|         this.$unprotectButton.click(protectedSessionService.unprotectNoteAndSendToServer); |         this.$unprotectButton.click(protectedSessionService.unprotectNoteAndSendToServer); | ||||||
| 
 | 
 | ||||||
|         console.log(`Created note tab ${this.tabId}`); |         console.debug(`Created note tab ${this.tabId}`); | ||||||
|     } |     } | ||||||
| 
 | 
 | ||||||
|     setNote(note, notePath) { |     setNote(note, notePath) { | ||||||
| @ -131,7 +131,7 @@ class TabContext { | |||||||
| 
 | 
 | ||||||
|         this.showPaths(); |         this.showPaths(); | ||||||
| 
 | 
 | ||||||
|         console.log(`Switched tab ${this.tabId} to ${this.noteId}`); |         console.debug(`Switched tab ${this.tabId} to ${this.noteId}`); | ||||||
|     } |     } | ||||||
| 
 | 
 | ||||||
|     show() { |     show() { | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user
	 zadam
						zadam