Method get_gateways_summary

chirpstack/src/api/internal.rs:667–704

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

    }

    async fn get_gateways_summary(
        &self,
        request: Request<api::GetGatewaysSummaryRequest>,
    ) -> Result<Response<api::GetGatewaysSummaryResponse>, 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 counts = gateway::get_counts_by_state(&tenant_id)
            .await
            .map_err(|e| e.status())?;

        Ok(Response::new(api::GetGatewaysSummaryResponse {
            online_count: counts.online_count as u32,
            offline_count: counts.offline_count as u32,
            never_seen_count: counts.never_seen_count as u32,
        }))
    }

    type StreamGatewayFramesStream = DropReceiver<Result<api::LogItem, Status>>;