Function call

crates/client-api/src/routes/database.rs:139–225

Call a reducer or procedure on the specified database module.

(
    State(worker_ctx): State<S>,
    Extension(auth): Extension<SpacetimeAuth>,
    Path(CallParams {
        name_or_identity,
        reducer,
    }): Path<CallParams>,
    TypedHeader(content_typ

/// Call a reducer or procedure on the specified database module.
pub async fn call<S: ControlStateDelegate + NodeDelegate>(
    State(worker_ctx): State<S>,
    Extension(auth): Extension<SpacetimeAuth>,
    Path(CallParams {
        name_or_identity,
        reducer,
    }): Path<CallParams>,
    TypedHeader(content_type): TypedHeader<headers::ContentType>,
    ByteStringBody(body): ByteStringBody,
) -> axum::response::Result<impl IntoResponse> {
    assert_content_type_json(content_type)?;

    let caller_identity = auth.claims.identity;

    let args = FunctionArgs::Json(body);

    // HTTP callers always need a connection ID to provide to connect/disconnect,
    // so generate one.
    let connection_id = generate_random_connection_id();

    let (module, Database { owner_identity, .. }) = find_module_and_database(&worker_ctx, name_or_identity).await?;

    // Call the database's `client_connected` reducer, if any.
    // If it fails or rejects the connection, bail.
    module
        .call_identity_connected(auth.into(), connection_id)
        .await
        .map_err(client_connected_error_to_response)?;

    let result = match module
        .call_reducer(
            caller_identity,
            Some(connection_id),
            None,
            None,
            None,
            &reducer,
            args.clone(),
        )
        .await
    {
        Ok(rcr) => Ok(CallResult::Reducer(rcr)),
        Err(ReducerCallError::NoSuchReducer | ReducerCallError::ScheduleReducerNotFound) => {
            // Not a reducer — try procedure instead
            match module
                .call_procedure(caller_identity, Some(connection_id), None, &reducer, args)
                .await
                .result
            {
                Ok(res) => Ok(CallResult::Procedure(res)),
                Err(e) => Err(map_procedure_error(e, &reducer)),
            }
        }
        Err(e) => Err(map_reducer_error(e, &reducer)),
    };

    module
        .call_identity_disconnected(caller_identity, connection_id)