Function handle_incrbyfloat

nodedb/src/control/server/resp/handler_kv.rs:347–386

INCRBYFLOAT key delta

(
    cmd: &RespCommand,
    session: &RespSession,
    state: &SharedState,
)

/// INCRBYFLOAT key delta
pub(super) async fn handle_incrbyfloat(
    cmd: &RespCommand,
    session: &RespSession,
    state: &SharedState,
) -> RespValue {
    if cmd.argc() < 2 {
        return RespValue::err("ERR wrong number of arguments for 'incrbyfloat' command");
    }

    let key = cmd.args[0].clone();
    let delta_str = match cmd.arg_str(1) {
        Some(s) => s,
        None => return RespValue::err("ERR value is not a valid float"),
    };
    let delta: f64 = match delta_str.parse() {
        Ok(v) => v,
        Err(_) => return RespValue::err("ERR value is not a valid float"),
    };

    let plan = PhysicalPlan::Kv(KvOp::IncrFloat {
        collection: session.collection.clone(),
        key,
        delta,
    });

    match dispatch_kv_write(state, session, plan).await {
        Ok(resp) => {
            // Return the new value as a bulk string (Redis convention).
            let payload_text =
                crate::data::executor::response_codec::decode_payload_to_json(&resp.payload);
            if let Ok(json) = sonic_rs::from_str::<serde_json::Value>(&payload_text)
                && let Some(v) = json.get("value")
            {
                return RespValue::bulk(v.to_string().into_bytes());
            }
            RespValue::bulk(payload_text.into_bytes())
        }
        Err(e) => RespValue::err(format!("ERR {e}")),
    }
}

/// GETSET key value — atomically set new value and return old.
pub(super) async fn handle_getset(