Function RegisterClientSessionAPIHandlers

go/rpc/zrpc.go:18406–18711

RegisterClientSessionAPIHandlers registers handlers for server-to-client session API calls.

(client *jsonrpc2.Client, getHandlers func(sessionID string) *ClientSessionAPIHandlers)

// RegisterClientSessionAPIHandlers registers handlers for server-to-client session API
// calls.
func RegisterClientSessionAPIHandlers(client *jsonrpc2.Client, getHandlers func(sessionID string) *ClientSessionAPIHandlers) {
	client.SetRequestHandler("canvas.close", func(params json.RawMessage) (json.RawMessage, *jsonrpc2.Error) {
		var request CanvasProviderCloseRequest
		if err := json.Unmarshal(params, &request); err != nil {
			return nil, &jsonrpc2.Error{Code: -32602, Message: fmt.Sprintf("Invalid params: %v", err)}
		}
		handlers := getHandlers(request.SessionID)
		if handlers == nil || handlers.Canvas == nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("No canvas handler registered for session: %s", request.SessionID)}
		}
		result, err := handlers.Canvas.Close(&request)
		if err != nil {
			return nil, clientSessionHandlerError(err)
		}
		raw, err := json.Marshal(result)
		if err != nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("Failed to marshal response: %v", err)}
		}
		return raw, nil
	})
	client.SetRequestHandler("canvas.action.invoke", func(params json.RawMessage) (json.RawMessage, *jsonrpc2.Error) {
		var request CanvasProviderInvokeActionRequest
		if err := json.Unmarshal(params, &request); err != nil {
			return nil, &jsonrpc2.Error{Code: -32602, Message: fmt.Sprintf("Invalid params: %v", err)}
		}
		handlers := getHandlers(request.SessionID)
		if handlers == nil || handlers.Canvas == nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("No canvas handler registered for session: %s", request.SessionID)}
		}
		result, err := handlers.Canvas.Invoke(&request)
		if err != nil {
			return nil, clientSessionHandlerError(err)
		}
		raw, err := json.Marshal(result)
		if err != nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("Failed to marshal response: %v", err)}
		}
		return raw, nil
	})
	client.SetRequestHandler("canvas.open", func(params json.RawMessage) (json.RawMessage, *jsonrpc2.Error) {
		var request CanvasProviderOpenRequest
		if err := json.Unmarshal(params, &request); err != nil {
			return nil, &jsonrpc2.Error{Code: -32602, Message: fmt.Sprintf("Invalid params: %v", err)}
		}
		handlers := getHandlers(request.SessionID)
		if handlers == nil || handlers.Canvas == nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("No canvas handler registered for session: %s", request.SessionID)}
		}
		result, err := handlers.Canvas.Open(&request)
		if err != nil {
			return nil, clientSessionHandlerError(err)
		}
		raw, err := json.Marshal(result)
		if err != nil {
			return nil, &jsonrpc2.Error{Code: -32603, Message: fmt.Sprintf("Failed to marshal response: %v", err)}
		}
		return raw, nil
	})