Example to implement json rpc 2 with net/rpc/jsonrpc #141

Activity

1. clarkmcc commented on May 17, 2023

   

   clarkmcc

   on May 17, 2023

   More actions

   I know this is late, but in case it's useful for others, something like this should do the trick. Disclaimer: untested.

   jsonrpc.ServeConn(&WebSocketWrapper{conn})

   type WebSocketWrapper struct {
   	*websocket.Conn
   }
   
   func (w *WebSocketWrapper) Read(p []byte) (n int, err error) {
   	_, msg, err := w.ReadMessage()
   	if err != nil {
   		return 0, err
   	}
   	if len(msg) > len(p) {
   		return 0, io.ErrShortBuffer
   	}
   	copy(p, msg)
   	return len(msg), err
   }
   
   func (w *WebSocketWrapper) Write(p []byte) (n int, err error) {
   	return len(p), w.WriteMessage(websocket.BinaryMessage, p)
   }
   
   func (w *WebSocketWrapper) Close() error {
   	return w.Conn.Close()
   }