Method post

chirpstack/src/integration/ifttt.rs:61–97

(&self, event: &str, v: &T)

    }

    async fn post<T>(&self, event: &str, v: &T) -> Result<()>
    where
        T: Serialize,
    {
        let event = if self.event_prefix.is_empty() {
            event.to_string()
        } else {
            format!("{}_{}", self.event_prefix, event)
        };

        let url = if self.arbitrary_json {
            format!(
                "{}/trigger/{}/json/with/key/{}",
                self.server, event, self.key
            )
        } else {
            format!("{}/trigger/{}/with/key/{}", self.server, event, self.key)
        };

        let mut headers = HeaderMap::new();
        headers.insert(CONTENT_TYPE, "application/json".parse().unwrap());

        info!(event = %event, "Sending event to IFTTT");
        let res = get_client()
            .post(url)
            .json(&v)
            .headers(headers)
            .send()
            .await?;
        match res.error_for_status() {
            Ok(_) => Ok(()),
            Err(e) => {
                warn!(event = %event, error = %e, "Sending event to IFTTT failed");
                Err(anyhow::Error::new(e))
            }
        }
    }
}

#[async_trait]