rpcbackend

type Backend interface {
	BatchRPC
	SyncRequest(ctx context.Context, rpcReq *RPCRequest) (rpcRes *RPCResponse, err error)
}

type BatchRPC interface {
	RPC
	CallRPCBatch(ctx context.Context, ops ...*RPCBatchOp) []*RPCError
}

type RPC interface {
	CallRPC(ctx context.Context, result interface{}, method string, params ...interface{}) *RPCError
}

type RPCBatchOp struct {
	Result interface{}
	Method string
	Params []interface{}
}

type RPCBatchOpTyped[T any] struct {
	Result *T
	Method string
	Params []interface{}
}

type RPCClient struct {
	// contains filtered or unexported fields
}

type RPCClientOptions struct {
	MaxConcurrentRequest int64
}

type RPCCode int64

type RPCError struct {
	Code    int64           `json:"code"`
	Message string          `json:"message"`
	Data    fftypes.JSONAny `json:"data,omitempty"`
}

type RPCRequest struct {
	JSONRpc string             `json:"jsonrpc"`
	ID      *fftypes.JSONAny   `json:"id"`
	Method  string             `json:"method"`
	Params  []*fftypes.JSONAny `json:"params,omitempty"`
}

type RPCResponse = RPCResponseTyped[*fftypes.JSONAny]

type RPCResponseTyped[T any] struct {
	JSONRpc string           `json:"jsonrpc"`
	ID      *fftypes.JSONAny `json:"id"`
	Result  T                `json:"result,omitempty"`
	Error   *RPCError        `json:"error,omitempty"`
	// Only for subscription notifications
	Method string           `json:"method,omitempty"`
	Params *fftypes.JSONAny `json:"params,omitempty"`
}

type RPCSubscriptionNotification struct {
	CurrentSubID string // will change on each reconnect
	Result       *fftypes.JSONAny
}

type Subscription interface {
	LocalID() *fftypes.UUID // does not change through reconnects
	Notifications() chan *RPCSubscriptionNotification
	Unsubscribe(ctx context.Context) *RPCError
}

type WebSocketRPCClient interface {
	RPC
	Subscribe(ctx context.Context, params ...interface{}) (sub Subscription, error *RPCError)
	Subscriptions() []Subscription
	UnsubscribeAll(ctx context.Context) (error *RPCError)
	Connect(ctx context.Context) error
	Close()
}