Superminaren
/
kvm
mirror of https://github.com/jetkvm/kvm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename JSONRPCServer to JSONRPCRouter

This commit is contained in:
tutman96 2025-01-19 23:12:24 +00:00
parent be319f38d7
commit ccfd63b84f
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/jsonrpc/rpc_server.go → internal/jsonrpc/router.go
View File

@ -8,20 +8,20 @@ import (
"reflect" "reflect"
) )
type JSONRPCServer struct { type JSONRPCRouter struct {
writer io.Writer writer io.Writer
handlers map[string]*RPCHandler handlers map[string]*RPCHandler
} }
func NewJSONRPCServer(writer io.Writer, handlers map[string]*RPCHandler) *JSONRPCServer { func NewJSONRPCRouter(writer io.Writer, handlers map[string]*RPCHandler) *JSONRPCRouter {
return &JSONRPCServer{ return &JSONRPCRouter{
writer: writer, writer: writer,
handlers: handlers, handlers: handlers,
} }
} }
func (s *JSONRPCServer) HandleMessage(data []byte) error { func (s *JSONRPCRouter) HandleMessage(data []byte) error {
var request JSONRPCRequest var request JSONRPCRequest
err := json.Unmarshal(data, &request) err := json.Unmarshal(data, &request)
if err != nil { if err != nil {
@ -72,7 +72,7 @@ func (s *JSONRPCServer) HandleMessage(data []byte) error {
return s.writeResponse(response) return s.writeResponse(response)
} }
func (s *JSONRPCServer) writeResponse(response JSONRPCResponse) error { func (s *JSONRPCRouter) writeResponse(response JSONRPCResponse) error {
responseBytes, err := json.Marshal(response) responseBytes, err := json.Marshal(response)
if err != nil { if err != nil {
return err return err

4
jsonrpc.go
View File

@ -33,8 +33,8 @@ func (w *DataChannelWriter) Write(data []byte) (int, error) {
return len(data), nil return len(data), nil
} }
func NewDataChannelJsonRpcServer(dataChannel *webrtc.DataChannel) *jsonrpc.JSONRPCServer { func NewDataChannelJsonRpcRouter(dataChannel *webrtc.DataChannel) *jsonrpc.JSONRPCRouter {
return jsonrpc.NewJSONRPCServer( return jsonrpc.NewJSONRPCRouter(
NewDataChannelWriter(dataChannel), NewDataChannelWriter(dataChannel),
rpcHandlers, rpcHandlers,
) )

2
webrtc.go
View File

@ -75,7 +75,7 @@ func newSession() (*Session, error) {
switch d.Label() { switch d.Label() {
case "rpc": case "rpc":
session.RPCChannel = d session.RPCChannel = d
rpcServer := NewDataChannelJsonRpcServer(d) rpcServer := NewDataChannelJsonRpcRouter(d)
d.OnMessage(func(msg webrtc.DataChannelMessage) { d.OnMessage(func(msg webrtc.DataChannelMessage) {
go rpcServer.HandleMessage(msg.Data) go rpcServer.HandleMessage(msg.Data)
}) })