refactor(core): use renamed prefetch crate
This commit is contained in:
@@ -15,7 +15,7 @@ chanora_state = { path = "../../crates/chanora_state" }
|
|||||||
chanora_audio = { path = "../../crates/chanora_audio" }
|
chanora_audio = { path = "../../crates/chanora_audio" }
|
||||||
chanora_storage = { path = "../../crates/chanora_storage" }
|
chanora_storage = { path = "../../crates/chanora_storage" }
|
||||||
chanora_diagnostics = { path = "../../crates/chanora_diagnostics" }
|
chanora_diagnostics = { path = "../../crates/chanora_diagnostics" }
|
||||||
chanora_server_prefetch = { path = "../../crates/chanora_server_prefetch" }
|
chanora_prefetch = { path = "../../crates/chanora_prefetch" }
|
||||||
thiserror.workspace = true
|
thiserror.workspace = true
|
||||||
tracing.workspace = true
|
tracing.workspace = true
|
||||||
tokio = { version = "1", features = ["sync", "rt", "macros"] }
|
tokio = { version = "1", features = ["sync", "rt", "macros"] }
|
||||||
@@ -23,6 +23,6 @@ tokio = { version = "1", features = ["sync", "rt", "macros"] }
|
|||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
# Used by integration tests to inspect the bookmark DB row layout
|
# Used by integration tests to inspect the bookmark DB row layout
|
||||||
# without going through the public repository API.
|
# without going through the public repository API.
|
||||||
chanora_server_prefetch = { path = "../../crates/chanora_server_prefetch", features = ["test-support"] }
|
chanora_prefetch = { path = "../../crates/chanora_prefetch", features = ["test-support"] }
|
||||||
rusqlite = { version = "0.32", features = ["bundled"] }
|
rusqlite = { version = "0.32", features = ["bundled"] }
|
||||||
tokio = { version = "1", features = ["macros", "rt", "rt-multi-thread"] }
|
tokio = { version = "1", features = ["macros", "rt", "rt-multi-thread"] }
|
||||||
|
|||||||
@@ -46,7 +46,7 @@ use tokio::sync::{broadcast, oneshot, watch, Mutex};
|
|||||||
use tokio::task::JoinHandle;
|
use tokio::task::JoinHandle;
|
||||||
use tracing::{info, warn};
|
use tracing::{info, warn};
|
||||||
|
|
||||||
use chanora_server_prefetch::ServerPrefetcher;
|
use chanora_prefetch::ServerPrefetcher;
|
||||||
use chanora_state::channel_join::{
|
use chanora_state::channel_join::{
|
||||||
self, AuthoritativeSource, ChannelId as JoinChannelId, ChannelJoinEvent, ChannelJoinState,
|
self, AuthoritativeSource, ChannelId as JoinChannelId, ChannelJoinEvent, ChannelJoinState,
|
||||||
ConnectionEpoch, JoinFailureKind,
|
ConnectionEpoch, JoinFailureKind,
|
||||||
@@ -2506,9 +2506,7 @@ mod tests {
|
|||||||
.fail_next_prefetch_setup_for_test("resolver unavailable")
|
.fail_next_prefetch_setup_for_test("resolver unavailable")
|
||||||
.await;
|
.await;
|
||||||
|
|
||||||
let result = session
|
let result = session.prefetch_server(" Example.COM ".to_string()).await;
|
||||||
.prefetch_server(" Example.COM ".to_string())
|
|
||||||
.await;
|
|
||||||
|
|
||||||
assert!(result.is_ok());
|
assert!(result.is_ok());
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user