Method create_mc_group

chirpstack/src/applayer/fuota/flow.rs:105–161

(&mut self)

    }

    async fn create_mc_group(&mut self) -> Result<Option<(FuotaJob, DateTime<Utc>)>> {
        // If this job fails, then there is no need to execute the others.
        if self.job.attempt_count > self.job.max_retry_count {
            return Ok(None);
        }

        info!("Creating multicast-group for FUOTA deployment");
        self.job.attempt_count += 1;

        // Get McAppSKey + McNwkSKey.
        let (mc_app_s_key, mc_nwk_s_key) = match self.device_profile.app_layer_params.ts005_version
        {
            Some(Ts005Version::V100) => (
                multicastsetup::v1::get_mc_app_s_key(
                    self.fuota_deployment.multicast_key,
                    self.fuota_deployment.multicast_addr,
                )?,
                multicastsetup::v1::get_mc_net_s_key(
                    self.fuota_deployment.multicast_key,
                    self.fuota_deployment.multicast_addr,
                )?,
            ),
            Some(Ts005Version::V200) => (
                multicastsetup::v2::get_mc_app_s_key(
                    self.fuota_deployment.multicast_key,
                    self.fuota_deployment.multicast_addr,
                )?,
                multicastsetup::v2::get_mc_net_s_key(
                    self.fuota_deployment.multicast_key,
                    self.fuota_deployment.multicast_addr,
                )?,
            ),
            None => return Err(anyhow!("Device-profile does not support TS005")),
        };

        let _ = multicast::create(multicast::MulticastGroup {
            id: self.fuota_deployment.id,
            application_id: self.fuota_deployment.application_id,
            name: format!("fuota-{}", self.fuota_deployment.id),
            region: self.device_profile.region,
            mc_addr: self.fuota_deployment.multicast_addr,
            mc_nwk_s_key,
            mc_app_s_key,
            f_cnt: 0,
            group_type: self.fuota_deployment.multicast_group_type.clone(),
            frequency: self.fuota_deployment.multicast_frequency,
            dr: self.fuota_deployment.multicast_dr,
            class_b_ping_slot_periodicity: self
                .fuota_deployment
                .multicast_class_b_ping_slot_periodicity,
            class_c_scheduling_type: self.fuota_deployment.multicast_class_c_scheduling_type,
            ..Default::default()
        })
        .await?;

        Ok(Some((FuotaJob::AddDevsToMcGroup, Utc::now())))
    }