From ccfd63b84f1e0c4d241831e25a77a85b80c36463 Mon Sep 17 00:00:00 2001
From: tutman96 <11356668+tutman96@users.noreply.github.com>
Date: Sun, 19 Jan 2025 23:12:24 +0000
Subject: [PATCH] Rename JSONRPCServer to JSONRPCRouter
---
internal/jsonrpc/{rpc_server.go => router.go} | 10 +++++-----
jsonrpc.go | 4 ++--
webrtc.go | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
rename internal/jsonrpc/{rpc_server.go => router.go} (94%)
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)
})