DeDuplication Logic in v4

PhilDay · June 10, 2024, 1:00pm

Hi Folks,

Can someone point me to the message deduplication code in V4 please - I want to look at how the system handles messages from different gateways if some parts of the payload for what appears to be the same valid message (same devId, fCnt) but with different content in the payload.

Thanks
Phil

brocaar · July 2, 2024, 10:42am

Here you go:

github.com

chirpstack/chirpstack/blob/master/chirpstack/src/uplink/mod.rs#L159


      
                  Ok(ufl)
              }
          }
          
          #[derive(Clone)]
          pub struct RoamingMetaData {
              pub base_payload: backend::BasePayload,
              pub ul_meta_data: backend::ULMetaData,
          }
          
          pub async fn deduplicate_uplink(event: gw::UplinkFrame) {
              if let Err(e) = _deduplicate_uplink(event).await {
                  error!(error = %e.full(), "Deduplication error");
              }
          }
          
          async fn _deduplicate_uplink(event: gw::UplinkFrame) -> Result<()> {
              let phy_str = hex::encode(&event.phy_payload);
              let tx_info_str = match &event.tx_info {
                  Some(tx_info) => hex::encode(tx_info.encode_to_vec()),
                  None => "".to_string(),