diff --git a/internal/jsonrpc/rpc_server.go b/internal/jsonrpc/router.go similarity index 94% rename from internal/jsonrpc/rpc_server.go rename to internal/jsonrpc/router.go index bdaef1b..616bd47 100644 --- a/internal/jsonrpc/rpc_server.go +++ b/internal/jsonrpc/router.go @@ -8,20 +8,20 @@ import ( "reflect" ) -type JSONRPCServer struct { +type JSONRPCRouter struct { writer io.Writer handlers map[string]*RPCHandler } -func NewJSONRPCServer(writer io.Writer, handlers map[string]*RPCHandler) *JSONRPCServer { - return &JSONRPCServer{ +func NewJSONRPCRouter(writer io.Writer, handlers map[string]*RPCHandler) *JSONRPCRouter { + return &JSONRPCRouter{ writer: writer, handlers: handlers, } } -func (s *JSONRPCServer) HandleMessage(data []byte) error { +func (s *JSONRPCRouter) HandleMessage(data []byte) error { var request JSONRPCRequest err := json.Unmarshal(data, &request) if err != nil { @@ -72,7 +72,7 @@ func (s *JSONRPCServer) HandleMessage(data []byte) error { return s.writeResponse(response) } -func (s *JSONRPCServer) writeResponse(response JSONRPCResponse) error { +func (s *JSONRPCRouter) writeResponse(response JSONRPCResponse) error { responseBytes, err := json.Marshal(response) if err != nil { return err diff --git a/jsonrpc.go b/jsonrpc.go index f3d7603..708a944 100644 --- a/jsonrpc.go +++ b/jsonrpc.go @@ -33,8 +33,8 @@ func (w *DataChannelWriter) Write(data []byte) (int, error) { return len(data), nil } -func NewDataChannelJsonRpcServer(dataChannel *webrtc.DataChannel) *jsonrpc.JSONRPCServer { - return jsonrpc.NewJSONRPCServer( +func NewDataChannelJsonRpcRouter(dataChannel *webrtc.DataChannel) *jsonrpc.JSONRPCRouter { + return jsonrpc.NewJSONRPCRouter( NewDataChannelWriter(dataChannel), rpcHandlers, ) diff --git a/webrtc.go b/webrtc.go index 8f070a8..49a7b41 100644 --- a/webrtc.go +++ b/webrtc.go @@ -75,7 +75,7 @@ func newSession() (*Session, error) { switch d.Label() { case "rpc": session.RPCChannel = d - rpcServer := NewDataChannelJsonRpcServer(d) + rpcServer := NewDataChannelJsonRpcRouter(d) d.OnMessage(func(msg webrtc.DataChannelMessage) { go rpcServer.HandleMessage(msg.Data) })