Method post_event

chirpstack/src/integration/http.rs:51–89

(&self, event: &str, b: Vec<u8>)

    }

    async fn post_event(&self, event: &str, b: Vec<u8>) -> Result<()> {
        let mut headers = HeaderMap::new();

        for (k, v) in &self.headers {
            headers.insert(HeaderName::try_from(k)?, v.parse()?);
        }

        if self.json {
            headers.insert(CONTENT_TYPE, "application/json".parse().unwrap());
        } else {
            headers.insert(CONTENT_TYPE, "application/octet-stream".parse().unwrap());
        }

        for url in &self.endpoints {
            info!(event = %event, url = %url, "Posting event");
            let res = get_client()
                .post(url)
                .body(b.clone())
                .query(&[("event", event)])
                .headers(headers.clone())
                .send()
                .await;

            // We log the errors as warn as these endpoints are user-defined.
            match res {
                Ok(res) => match res.error_for_status() {
                    Ok(_) => {}
                    Err(e) => {
                        warn!(event = %event, url = %url, error = %e, "Posting event failed");
                    }
                },
                Err(e) => {
                    warn!(event = %event, url = %url, error = %e, "Posting event failed");
                }
            }
        }

        Ok(())
    }
}

#[async_trait]