wire up a custom http client

.gitignore

@@ -2,3 +2,4 @@
 /node_modules
 .env
 .idea
+.wrangler

Cargo.toml

@@ -18,6 +18,7 @@ getrandom = { version = "0.2.14", features = ["js"] }
 serde_json = "1.0.116"
 opentelemetry-http = { version="0.11.1" }
 opentelemetry-otlp = { version="0.15.0", features = ["metrics", "http-proto"], default-features = false }
+http = { version = "0.2.12"}
 
 [profile.release]
 opt-level = "s" # optimize for size in release builds

src/http.rs

@@ -0,0 +1,42 @@
+use std::fmt::{Debug, Formatter};
+use std::future::Future;
+use opentelemetry_http::{Bytes, HttpClient, HttpError, Request, Response};
+use worker::async_trait::async_trait;
+use std::error::Error;
+
+pub struct MyClient {
+    inner: reqwest::Client,
+}
+
+impl MyClient {
+    pub fn new() -> MyClient {
+        let inner = reqwest::Client::new();
+        Self { inner }
+    }
+
+    pub fn execute(
+        &self,
+        request: reqwest::Request,
+    ) -> impl Future<Output = Result<reqwest::Response, reqwest::Error>> {
+        self.inner.execute(request)
+    }
+}
+
+impl Debug for MyClient {
+    fn fmt(&self, _f: &mut Formatter<'_>) -> std::fmt::Result {
+        todo!()
+    }
+}
+
+#[async_trait]
+impl HttpClient for MyClient {
+    async fn send(&self, request: Request<Vec<u8>>) -> Result<Response<Bytes>, HttpError> {
+        let res = Response::builder()
+            .status(200)
+            .body(Bytes::new())
+            .unwrap();
+        Ok(res)
+    }
+
+
+}

src/lib.rs

@@ -5,6 +5,7 @@ use opentelemetry_sdk::metrics::SdkMeterProvider;
 use worker::*;
 
 mod gql;
+mod http;
 
 fn init_metrics() ->
                   core::result::Result<SdkMeterProvider, MetricsError> {
@@ -17,6 +18,7 @@ fn init_metrics() ->
         .with_exporter(
             opentelemetry_otlp::new_exporter()
                 .http()
+                .with_http_client(http::MyClient::new())
                 .with_export_config(export_config),
         )
         .build();