Method get_devices_summary

chirpstack/src/api/internal.rs:620–665

(
        &self,
        request: Request<api::GetDevicesSummaryRequest>,
    )

    }

    async fn get_devices_summary(
        &self,
        request: Request<api::GetDevicesSummaryRequest>,
    ) -> Result<Response<api::GetDevicesSummaryResponse>, Status> {
        let req = request.get_ref();

        let tenant_id = if req.tenant_id.is_empty() {
            None
        } else {
            Some(Uuid::from_str(&req.tenant_id).map_err(|e| e.status())?)
        };

        if tenant_id.is_none() {
            self.validator
                .validate(request.extensions(), validator::ValidateIsAdmin::new())
                .await?;
        } else {
            self.validator
                .validate(
                    request.extensions(),
                    validator::ValidateTenantAccess::new(
                        validator::Flag::Read,
                        *tenant_id.as_ref().unwrap(),
                    ),
                )
                .await?;
        }

        let active_inactive = device::get_active_inactive(&tenant_id)
            .await
            .map_err(|e| e.status())?;

        let dr_count = device::get_data_rates(&tenant_id)
            .await
            .map_err(|e| e.status())?;

        Ok(Response::new(api::GetDevicesSummaryResponse {
            active_count: active_inactive.active_count as u32,
            inactive_count: active_inactive.inactive_count as u32,
            never_seen_count: active_inactive.never_seen_count as u32,
            dr_count: dr_count
                .iter()
                .map(|i| (i.dr.unwrap() as u32, i.count as u32))
                .collect(),
        }))
    }

    async fn get_gateways_summary(
        &self,