rpctypes

type Context struct {
	// json-rpc request
	JSONReq *RPCRequest
	// websocket connection
	WSConn WSRPCConnection
	// http request
	HTTPReq *http.Request
}

type JSONRPCID interface {
	String() string
}

type JSONRPCIntID int

type JSONRPCStringID string

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Data    string `json:"data,omitempty"`
}

type RPCRequest struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      JSONRPCID       `json:"id"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params"` // must be map[string]interface{} or []interface{}
}

type RPCRequests []RPCRequest

type RPCResponse struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      JSONRPCID       `json:"id"`
	Result  json.RawMessage `json:"result,omitempty"`
	Error   *RPCError       `json:"error,omitempty"`
}

type RPCResponses []RPCResponse

type WSRPCConnection interface {
	// GetRemoteAddr returns a remote address of the connection.
	GetRemoteAddr() string
	// WriteRPCResponses writes the resp onto connection (BLOCKING).
	WriteRPCResponses(resp RPCResponses)
	// TryWriteRPCResponses tries to write the resp onto connection (NON-BLOCKING).
	TryWriteRPCResponses(resp RPCResponses) bool
	// Context returns the connection's context.
	Context() context.Context
}