Method create_entity

autokuma/src/sync.rs:35–109

(&self, kuma: &Client, id: &String, entity: &Entity)

    }

    async fn create_entity(&self, kuma: &Client, id: &String, entity: &Entity) -> Result<()> {
        info!("Creating new {}: {}", entity.entity_type(), id);
        match entity.clone() {
            Entity::Monitor(monitor) => {
                match kuma.add_monitor(monitor).await {
                    Ok(monitor) => {
                        let db_id = monitor.common().id().ok_or_else(|| {
                            KumaError::CommunicationError(
                                "Did not receive an id from Uptime Kuma".to_owned(),
                            )
                        })?;

                        self.app_state
                            .db
                            .store_id(Name::Monitor(id.clone()), db_id)?;

                        Ok(())
                    }
                    Err(err) => Err(err),
                }?;
            }
            Entity::DockerHost(docker_host) => {
                let db_id = kuma.add_docker_host(docker_host).await?.id.ok_or_else(|| {
                    KumaError::CommunicationError(
                        "Did not receive an id from Uptime Kuma".to_owned(),
                    )
                })?;

                self.app_state
                    .db
                    .store_id(Name::DockerHost(id.clone()), db_id)?;
            }
            Entity::Notification(notification) => {
                let db_id = kuma
                    .add_notification(notification)
                    .await?
                    .id
                    .ok_or_else(|| {
                        KumaError::CommunicationError(
                            "Did not receive an id from Uptime Kuma".to_owned(),
                        )
                    })?;

                self.app_state
                    .db
                    .store_id(Name::Notification(id.clone()), db_id)?;
            }
            Entity::StatusPage(status_page) => {
                let db_id = kuma
                    .add_status_page(status_page)
                    .await?
                    .slug
                    .ok_or_else(|| {
                        KumaError::CommunicationError(
                            "Did not receive an id from Uptime Kuma".to_owned(),
                        )
                    })?;