Method post_event

chirpstack/src/integration/blynk.rs:130–156

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

    }

    async fn post_event<T>(&self, event: &str, pl: &T) -> Result<()>
    where
        T: ?Sized + Serialize,
    {
        let (integration_url, integration_token) = self.parse_token()?;
        let b = serde_json::to_vec(pl)?;

        info!(event = %event, url = %integration_url, "Posting event");

        let mut headers = HeaderMap::new();
        headers.insert(CONTENT_TYPE, "application/json".parse().unwrap());
        headers.insert(
            AUTHORIZATION,
            format!("Bearer {}", integration_token).parse().unwrap(),
        );

        get_client()
            .post(&integration_url)
            .body(b.to_vec())
            .query(&[("event", event)])
            .headers(headers)
            .send()
            .await?
            .error_for_status()?;

        Ok(())
    }
}

#[async_trait]