Function get_for_phy_payload

chirpstack/src/storage/passive_roaming.rs:119–168

(
    phy: &lrwn::PhyPayload,
)

}

pub async fn get_for_phy_payload(
    phy: &lrwn::PhyPayload,
) -> Result<Vec<internal::PassiveRoamingDeviceSession>, Error> {
    // Clone the PhyPayload, as we will update the f_cnt to the full (32bit) frame-counter value
    // for calculating the MIC.
    let mut phy = phy.clone();

    let (dev_addr, f_cnt_orig) = if let lrwn::Payload::MACPayload(v) = &phy.payload {
        (v.fhdr.devaddr, v.fhdr.f_cnt)
    } else {
        return Err(Error::InvalidPayload("MacPayload".to_string()));
    };

    let sessions = get_sessions_for_dev_addr(dev_addr).await?;
    let mut out: Vec<internal::PassiveRoamingDeviceSession> = Vec::new();

    for ds in sessions {
        // We will not validate the MIC.
        if !ds.validate_mic {
            out.push(ds);
            continue;
        }

        let f_nwk_s_int_key = AES128Key::from_slice(&ds.f_nwk_s_int_key)?;

        // Set the full frame-counter.
        if let lrwn::Payload::MACPayload(pl) = &mut phy.payload {
            pl.fhdr.f_cnt = get_full_f_cnt_up(ds.f_cnt_up, f_cnt_orig);
        }

        let mic_ok = if ds.lorawan_1_1 {
            phy.validate_uplink_data_micf(&f_nwk_s_int_key)?
        } else {
            phy.validate_uplink_data_mic(
                lrwn::MACVersion::LoRaWAN1_0,
                0,
                0,
                0,
                &f_nwk_s_int_key,
                &f_nwk_s_int_key,
            )?
        };

        if mic_ok {
            out.push(ds);
        }
    }

    Ok(out)
}

async fn get_sessions_for_dev_addr(
    dev_addr: DevAddr,