Function handle_zscore

nodedb/src/control/server/resp/handler_sorted.rs:221–252

ZSCORE key member — returns score as bulk string.

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

/// ZSCORE key member — returns score as bulk string.
pub(super) async fn handle_zscore(
    cmd: &RespCommand,
    session: &RespSession,
    state: &SharedState,
) -> RespValue {
    let Some(member) = cmd.arg(0) else {
        return RespValue::err("ERR wrong number of arguments for 'zscore' command");
    };

    let plan = PhysicalPlan::Kv(KvOp::SortedIndexScore {
        index_name: session.collection.clone(),
        primary_key: member.to_vec(),
    });

    match dispatch_kv(state, session, plan).await {
        Ok(resp) if resp.status == Status::Ok => {
            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(serde_json::Value::String(score)) = json.get("score")
            {
                if score == "null" {
                    return RespValue::nil();
                }
                return RespValue::bulk(score.as_bytes().to_vec());
            }
            RespValue::nil()
        }
        Ok(_) => RespValue::nil(),
        Err(e) => RespValue::err(format!("ERR {e}")),
    }
}