back round 2 view raw

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

merged

opened by

evan.jarrett.net 1 month ago targeting master from evan.jarrett.net/core: spindle

Signed-off-by: Evan Jarrett evan@evanjarrett.com

options

unified split

Changed files

spindle

stream.go

spindle/stream.go

···

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

     

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

     

       215
        
       			}

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       216
        
       		}

     

       217
        
       	}

     

       218
        
       }

···

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

     

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

     

       215
        
       			}

     

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

     

       217
       +
       			// send a keep-alive

     

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

     

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

     

       220
       +
       			}

     

       221
        
       		}

     

       222
        
       	}

     

       223
        
       }