feat: reconnection. BRUTE FORCE

packages/client/src/components/framework/MonitorView.vue

@@ -29,10 +29,14 @@ async function tryConnect() {
   }
   socket = await api.controller()
   socket.onclose = () => {
+    console.log('close!')
     socket = null
+    setTimeout(() => {
+      tryConnect()
+    }, 100)
   }
   socket.onmessage = async ev => {
-    console.log('got image')
+    // console.log('got image')
     fr += 1
     const cur = fr
 
@@ -43,11 +47,11 @@ async function tryConnect() {
     const image = new Image(1280, 720)
     image.onload = () => {
       if (cur < prefr) {
-        console.log('skip image')
+        // console.log('skip image')
         return
       }
       prefr = cur
-      console.log('draw image')
+      // console.log('draw image')
       ctx.drawImage(image, 0, 0, 1280, 720, 0, 0, props.width, props.height)
     }
     image.src = url

packages/server/src/index.ts

@@ -123,11 +123,18 @@ async function main() {
     let pending = false
     let quit = false
 
+    let skipCount = 0
+
     const timer = setInterval(async () => {
       if (controller) {
-        console.log(`/api/controller ${id} start push`)
+        // console.log(`/api/controller ${id} start push`)
         if (pending) {
-          console.log(`/api/controller ${id} skipped`)
+          // console.log(`/api/controller ${id} skipped`)
+          skipCount += 1
+          if (skipCount > 10) {
+            console.log(`/api/controller ${id} skip too much`)
+            ws.close()
+          }
           return
         }
         pending = true
@@ -138,19 +145,19 @@ async function main() {
           if (quit) {
             return
           }
-          console.log(`/api/controller ${id} get image`)
+          // console.log(`/api/controller ${id} get image`)
           const buffer = controller.image()
           pending = false
           if (buffer) {
-            console.log(`/api/controller ${id} push image`)
+            // console.log(`/api/controller ${id} push image`)
             ws.send(buffer)
           }
         } else {
-          console.log(`/api/controller ${id} screencap failed`)
+          // console.log(`/api/controller ${id} screencap failed`)
           pending = false
         }
       }
-    }, 500)
+    }, 100)
     ws.on('close', () => {
       quit = true
       console.log(`/api/controller ${id} closed`)