Skip to content

Commit 4fc36f3

Browse files
committed
libsql: Switch to hyper for local offline sync-switch-hyper
This commit switches our usage of reqwest to hyper. In the future, this will allow us to pass in configuration for the connector to support both custom TLS implementations (aka using the system tls impl over rustls) and connecting to the sqld network simulation for future testing. This also removes the extra dependency on reqwest which is not needed since we already pull in the dependencies needed to implement the new protocol for local offline writes.
1 parent 240eee8 commit 4fc36f3

File tree

4 files changed

+36
-217
lines changed

4 files changed

+36
-217
lines changed

Cargo.lock

Lines changed: 5 additions & 198 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

libsql/Cargo.toml

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ fallible-iterator = { version = "0.3", optional = true }
4242

4343
libsql_replication = { version = "0.6", path = "../libsql-replication", optional = true }
4444
async-stream = { version = "0.3.5", optional = true }
45-
reqwest = { version = "0.12.9", default-features = false, features = [ "rustls-tls", "json" ], optional = true }
4645

4746
[dev-dependencies]
4847
criterion = { version = "0.5", features = ["html_reports", "async", "async_futures", "async_tokio"] }
@@ -105,7 +104,6 @@ sync = [
105104
"dep:bytes",
106105
"dep:tokio",
107106
"dep:futures",
108-
"dep:reqwest",
109107
"dep:serde_json",
110108
]
111109
hrana = [

libsql/src/local/database.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,7 @@ impl Database {
412412
// frames the server already knows about, we need to update the
413413
// frame number to the one returned by the server.
414414
let max_frame_no = sync_ctx
415-
.push_one_frame(frame.to_vec(), generation, frame_no)
415+
.push_one_frame(frame.freeze(), generation, frame_no)
416416
.await?;
417417

418418
if max_frame_no > frame_no {

0 commit comments

Comments
 (0)