Function handle_ttl

nodedb/src/control/server/resp/handler.rs:194–228

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

}

async fn handle_ttl(
    cmd: &RespCommand,
    session: &RespSession,
    state: &SharedState,
    is_pttl: bool,
) -> RespValue {
    let Some(key) = cmd.arg(0) else {
        let name = if is_pttl { "pttl" } else { "ttl" };
        return RespValue::err(format!(
            "ERR wrong number of arguments for '{name}' command"
        ));
    };

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

    match dispatch_kv(state, session, plan).await {
        Ok(resp) if resp.status == Status::Ok => {
            let ttl_ms = parse_json_field_i64(&resp.payload, "ttl_ms").unwrap_or(-2);
            if ttl_ms < 0 {
                // -1 (no TTL) or -2 (not found) — same for both TTL and PTTL.
                RespValue::integer(ttl_ms)
            } else if is_pttl {
                RespValue::integer(ttl_ms)
            } else {
                // TTL returns seconds, round up to avoid reporting 0 for sub-second TTLs.
                RespValue::integer((ttl_ms + 999) / 1000)
            }
        }
        Ok(_) => RespValue::integer(-2),
        Err(e) => RespValue::err(format!("ERR {e}")),
    }
}

async fn handle_persist(
    cmd: &RespCommand,