Method send_telemetry

chirpstack/src/integration/thingsboard.rs:67–90

(
        &self,
        vars: &HashMap<String, String>,
        telemetry: &Payload,
    )

    }

    async fn send_telemetry(
        &self,
        vars: &HashMap<String, String>,
        telemetry: &Payload,
    ) -> Result<()> {
        let access_token = vars.get("ThingsBoardAccessToken").cloned().ok_or_else(|| {
            anyhow!("Device does not have ThingsBoardAccessToken variable configured")
        })?;

        let endpoint = format!("{}/api/v1/{}/telemetry", self.server, access_token);
        let b = serde_json::to_string(&telemetry)?;

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

        let res = get_client()
            .post(endpoint)
            .body(b)
            .headers(headers)
            .send()
            .await?;
        let _ = res.error_for_status()?;
        Ok(())
    }
}

#[async_trait]