spindle/stream: add keep alive ping to log streaming. #780

···

       
213
       
213
       
 
       
			if err := conn.WriteMessage(websocket.TextMessage, []byte(line.Text)); err != nil {

     

       
214
       
214
       
 
       
				return fmt.Errorf("failed to write to websocket: %w", err)

     

       
215
       
215
       
 
       
			}

     

       
216
       
216
       
+
       
		case <-time.After(30 * time.Second):

     

       
217
       
217
       
+
       
			// send a keep-alive

     

       
218
       
218
       
+
       
			if err := conn.WriteControl(websocket.PingMessage, []byte{}, time.Now().Add(time.Second)); err != nil {

     

       
219
       
219
       
+
       
				return fmt.Errorf("failed to write control: %w", err)

     

       
220
       
220
       
+
       
			}

     

       
216
       
221
       
 
       
		}

     

       
217
       
222
       
 
       
	}

     

       
218
       
223
       
 
       
}