Function get

chirpstack/src/storage/passive_roaming.rs:91–105

(id: Uuid)

}

pub async fn get(id: Uuid) -> Result<internal::PassiveRoamingDeviceSession, Error> {
    let key = redis_key(format!("pr:sess:{{{}}}", id));

    let v: Vec<u8> = redis::cmd("GET")
        .arg(key)
        .query_async(&mut get_async_redis_conn().await?)
        .await
        .context("Get passive-roaming device-session")?;
    if v.is_empty() {
        return Err(Error::NotFound(id.to_string()));
    }
    let ds = internal::PassiveRoamingDeviceSession::decode(&mut Cursor::new(v))
        .context("Decode passive-roaming device-session")?;
    Ok(ds)
}

pub async fn delete(id: Uuid) -> Result<()> {
    let key = redis_key(format!("pr:sess:{{{}}}", id));