libsql: add tls hyper support for offline writes

Author: LucioFranco

libsql/src/database/builder.rs

@@ -424,7 +424,17 @@ cfg_sync! {
 
             let path = path.to_str().ok_or(crate::Error::InvalidUTF8Path)?.to_owned();
 
+            let https = super::connector()?;
+            use tower::ServiceExt;
+
+            let svc = https
+                .map_err(|e| e.into())
+                .map_response(|s| Box::new(s) as Box<dyn crate::util::Socket>);
+
+            let connector = crate::util::ConnectorService::new(svc);
+
             let db = crate::local::Database::open_local_with_offline_writes(
+                connector,
                 path,
                 flags,
                 url,

libsql/src/local/database.rs

@@ -131,6 +131,7 @@ impl Database {
     #[cfg(feature = "sync")]
     #[doc(hidden)]
     pub async fn open_local_with_offline_writes(
+        connector: crate::util::ConnectorService,
         db_path: impl Into<String>,
         flags: OpenFlags,
         endpoint: String,
@@ -144,6 +145,7 @@ impl Database {
         };
         let mut db = Database::open(&db_path, flags)?;
         db.sync_ctx = Some(tokio::sync::Mutex::new(SyncContext::new(
+            connector,
             endpoint,
             Some(auth_token),
         )));

libsql/src/sync.rs

@@ -1,6 +1,6 @@
-use crate::Result;
+use crate::{util::ConnectorService, Result};
 use bytes::Bytes;
-use hyper::{client::HttpConnector, Body};
+use hyper::Body;
 
 const DEFAULT_MAX_RETRIES: usize = 5;
 
@@ -9,13 +9,13 @@ pub struct SyncContext {
     auth_token: Option<String>,
     max_retries: usize,
     durable_frame_num: u32,
-    client: hyper::Client<HttpConnector, Body>,
+    client: hyper::Client<ConnectorService, Body>,
 }
 
 impl SyncContext {
-    pub fn new(sync_url: String, auth_token: Option<String>) -> Self {
+    pub fn new(connector: ConnectorService, sync_url: String, auth_token: Option<String>) -> Self {
         // TODO(lucio): add custom connector + tls support here
-        let client = hyper::client::Client::builder().build_http::<hyper::Body>();
+        let client = hyper::client::Client::builder().build::<_, hyper::Body>(connector);
 
         Self {
             sync_url,