Merge pull request #586 from tursodatabase/lucio/fix-cf-sender

libsql: make cf sender public
tursodatabase · Nov 7, 2023 · 3b2da5a · 3b2da5a
2 parents 94a388d + fd0c479
commit 3b2da5a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/libsql/src/wasm/cloudflare.rs b/libsql/src/wasm/cloudflare.rs
@@ -4,10 +4,14 @@ use std::future::Future;
 use std::pin::Pin;
 use worker::wasm_bindgen::JsValue;
 
-#[derive(Default, Debug, Copy, Clone)]
-pub(super) struct CloudflareSender(());
+#[derive(Debug, Copy, Clone)]
+pub struct CloudflareSender(());
 
 impl CloudflareSender {
+    pub(crate) fn new() -> Self {
+        CloudflareSender(())
+    }
+
     async fn send(url: String, auth: String, body: String) -> Result<ServerMsg> {
         use worker::*;
 

diff --git a/libsql/src/wasm/mod.rs b/libsql/src/wasm/mod.rs
@@ -36,6 +36,7 @@ use crate::{
 
 cfg_cloudflare! {
     mod cloudflare;
+    pub use cloudflare::CloudflareSender;
 }
 
 #[derive(Debug, Clone)]
@@ -44,12 +45,10 @@ pub struct Connection<T> {
 }
 
 cfg_cloudflare! {
-    use cloudflare::CloudflareSender;
-
     impl Connection<CloudflareSender> {
         pub fn open_cloudflare_worker(url: impl Into<String>, auth_token: impl Into<String>) -> Self    {
             Connection {
-                conn: HttpConnection::new(url.into(), auth_token.into(), CloudflareSender::default()),
+                conn: HttpConnection::new(url.into(), auth_token.into(), CloudflareSender::new()),
             }
         }
     }