Method list_integrations

chirpstack/src/api/application.rs:217–267

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

    }

    async fn list_integrations(
        &self,
        request: Request<api::ListIntegrationsRequest>,
    ) -> Result<Response<api::ListIntegrationsResponse>, Status> {
        let req = request.get_ref();
        let app_id = Uuid::from_str(&req.application_id).map_err(|e| e.status())?;

        self.validator
            .validate(
                request.extensions(),
                validator::ValidateApplicationAccess::new(validator::Flag::Read, app_id),
            )
            .await?;

        let result = application::get_integrations_for_application(&app_id)
            .await
            .map_err(|e| e.status())?;

        let mut items: Vec<api::IntegrationListItem> = result
            .iter()
            .map(|i| api::IntegrationListItem {
                kind: match i.kind {
                    application::IntegrationKind::Http => api::IntegrationKind::Http,
                    application::IntegrationKind::InfluxDb => api::IntegrationKind::InfluxDb,
                    application::IntegrationKind::ThingsBoard => api::IntegrationKind::ThingsBoard,
                    application::IntegrationKind::MyDevices => api::IntegrationKind::MyDevices,
                    application::IntegrationKind::GcpPubSub => api::IntegrationKind::GcpPubSub,
                    application::IntegrationKind::AwsSns => api::IntegrationKind::AwsSns,
                    application::IntegrationKind::AzureServiceBus => {
                        api::IntegrationKind::AzureServiceBus
                    }
                    application::IntegrationKind::PilotThings => api::IntegrationKind::PilotThings,
                    application::IntegrationKind::Ifttt => api::IntegrationKind::Ifttt,
                    application::IntegrationKind::Blynk => api::IntegrationKind::Blynk,
                }
                .into(),
            })
            .collect();
        items.push(api::IntegrationListItem {
            kind: api::IntegrationKind::MqttGlobal.into(),
        });

        let mut resp = Response::new(api::ListIntegrationsResponse {
            total_count: (result.len() + 1) as u32,
            result: items,
        });
        resp.metadata_mut()
            .insert("x-log-application_id", req.application_id.parse().unwrap());

        Ok(resp)
    }

    async fn create_http_integration(
        &self,