Re-export itertools from tuwunel_core crate.
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
3
Cargo.lock
generated
3
Cargo.lock
generated
@@ -5151,7 +5151,6 @@ dependencies = [
|
|||||||
"http-body-util",
|
"http-body-util",
|
||||||
"hyper",
|
"hyper",
|
||||||
"ipaddress",
|
"ipaddress",
|
||||||
"itertools 0.14.0",
|
|
||||||
"log",
|
"log",
|
||||||
"rand 0.8.5",
|
"rand 0.8.5",
|
||||||
"reqwest",
|
"reqwest",
|
||||||
@@ -5237,7 +5236,6 @@ dependencies = [
|
|||||||
"criterion",
|
"criterion",
|
||||||
"ctor",
|
"ctor",
|
||||||
"futures",
|
"futures",
|
||||||
"itertools 0.14.0",
|
|
||||||
"log",
|
"log",
|
||||||
"minicbor",
|
"minicbor",
|
||||||
"minicbor-serde",
|
"minicbor-serde",
|
||||||
@@ -5309,7 +5307,6 @@ dependencies = [
|
|||||||
"http",
|
"http",
|
||||||
"image",
|
"image",
|
||||||
"ipaddress",
|
"ipaddress",
|
||||||
"itertools 0.14.0",
|
|
||||||
"ldap3",
|
"ldap3",
|
||||||
"log",
|
"log",
|
||||||
"loole",
|
"loole",
|
||||||
|
|||||||
@@ -88,7 +88,6 @@ http.workspace = true
|
|||||||
http-body-util.workspace = true
|
http-body-util.workspace = true
|
||||||
hyper.workspace = true
|
hyper.workspace = true
|
||||||
ipaddress.workspace = true
|
ipaddress.workspace = true
|
||||||
itertools.workspace = true
|
|
||||||
log.workspace = true
|
log.workspace = true
|
||||||
rand.workspace = true
|
rand.workspace = true
|
||||||
reqwest.workspace = true
|
reqwest.workspace = true
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ use std::{collections::BTreeMap, net::IpAddr, time::Instant};
|
|||||||
use axum::extract::State;
|
use axum::extract::State;
|
||||||
use axum_client_ip::InsecureClientIp;
|
use axum_client_ip::InsecureClientIp;
|
||||||
use futures::{FutureExt, Stream, StreamExt, TryFutureExt, TryStreamExt};
|
use futures::{FutureExt, Stream, StreamExt, TryFutureExt, TryStreamExt};
|
||||||
use itertools::Itertools;
|
|
||||||
use ruma::{
|
use ruma::{
|
||||||
CanonicalJsonObject, OwnedEventId, OwnedRoomId, OwnedUserId, RoomId, ServerName, UserId,
|
CanonicalJsonObject, OwnedEventId, OwnedRoomId, OwnedUserId, RoomId, ServerName, UserId,
|
||||||
api::{
|
api::{
|
||||||
@@ -25,6 +24,7 @@ use tuwunel_core::{
|
|||||||
Err, Error, Result, debug,
|
Err, Error, Result, debug,
|
||||||
debug::INFO_SPAN_LEVEL,
|
debug::INFO_SPAN_LEVEL,
|
||||||
debug_warn, err, error,
|
debug_warn, err, error,
|
||||||
|
itertools::Itertools,
|
||||||
result::LogErr,
|
result::LogErr,
|
||||||
trace,
|
trace,
|
||||||
utils::{
|
utils::{
|
||||||
|
|||||||
@@ -14,6 +14,7 @@ pub mod utils;
|
|||||||
|
|
||||||
pub use ::arrayvec;
|
pub use ::arrayvec;
|
||||||
pub use ::http;
|
pub use ::http;
|
||||||
|
pub use ::itertools;
|
||||||
pub use ::jsonwebtoken as jwt;
|
pub use ::jsonwebtoken as jwt;
|
||||||
pub use ::ruma;
|
pub use ::ruma;
|
||||||
pub use ::smallstr;
|
pub use ::smallstr;
|
||||||
|
|||||||
@@ -57,7 +57,6 @@ async-channel.workspace = true
|
|||||||
const-str.workspace = true
|
const-str.workspace = true
|
||||||
ctor.workspace = true
|
ctor.workspace = true
|
||||||
futures.workspace = true
|
futures.workspace = true
|
||||||
itertools.workspace = true
|
|
||||||
log.workspace = true
|
log.workspace = true
|
||||||
minicbor.workspace = true
|
minicbor.workspace = true
|
||||||
minicbor-serde.workspace = true
|
minicbor-serde.workspace = true
|
||||||
|
|||||||
@@ -4,9 +4,10 @@ use std::{
|
|||||||
sync::{Arc, atomic::AtomicU32},
|
sync::{Arc, atomic::AtomicU32},
|
||||||
};
|
};
|
||||||
|
|
||||||
use itertools::Itertools;
|
|
||||||
use rocksdb::{ColumnFamilyDescriptor, Options};
|
use rocksdb::{ColumnFamilyDescriptor, Options};
|
||||||
use tuwunel_core::{Result, debug, debug_warn, implement, info, trace, warn};
|
use tuwunel_core::{
|
||||||
|
Result, debug, debug_warn, implement, info, itertools::Itertools, trace, warn,
|
||||||
|
};
|
||||||
|
|
||||||
use super::{
|
use super::{
|
||||||
Db, Engine, cf_opts::cf_options, context, db_opts::db_options, descriptor,
|
Db, Engine, cf_opts::cf_options, context, db_opts::db_options, descriptor,
|
||||||
|
|||||||
@@ -97,7 +97,6 @@ http.workspace = true
|
|||||||
image.workspace = true
|
image.workspace = true
|
||||||
image.optional = true
|
image.optional = true
|
||||||
ipaddress.workspace = true
|
ipaddress.workspace = true
|
||||||
itertools.workspace = true
|
|
||||||
ldap3.workspace = true
|
ldap3.workspace = true
|
||||||
ldap3.optional = true
|
ldap3.optional = true
|
||||||
log.workspace = true
|
log.workspace = true
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
use std::cmp;
|
use std::cmp;
|
||||||
|
|
||||||
use futures::{FutureExt, StreamExt};
|
use futures::{FutureExt, StreamExt};
|
||||||
use itertools::Itertools;
|
|
||||||
use ruma::{
|
use ruma::{
|
||||||
OwnedUserId, RoomId, UserId,
|
OwnedUserId, RoomId, UserId,
|
||||||
events::{
|
events::{
|
||||||
@@ -11,6 +10,7 @@ use ruma::{
|
|||||||
};
|
};
|
||||||
use tuwunel_core::{
|
use tuwunel_core::{
|
||||||
Err, Result, debug, debug_info, debug_warn, error, info,
|
Err, Result, debug, debug_info, debug_warn, error, info,
|
||||||
|
itertools::Itertools,
|
||||||
matrix::PduCount,
|
matrix::PduCount,
|
||||||
result::NotFound,
|
result::NotFound,
|
||||||
utils::{
|
utils::{
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
use futures::{Stream, StreamExt, stream::iter};
|
use futures::{Stream, StreamExt, stream::iter};
|
||||||
use itertools::Itertools;
|
|
||||||
use ruma::{
|
use ruma::{
|
||||||
OwnedServerName, RoomId, ServerName,
|
OwnedServerName, RoomId, ServerName,
|
||||||
events::{StateEventType, room::power_levels::RoomPowerLevelsEventContent},
|
events::{StateEventType, room::power_levels::RoomPowerLevelsEventContent},
|
||||||
@@ -7,6 +6,7 @@ use ruma::{
|
|||||||
};
|
};
|
||||||
use tuwunel_core::{
|
use tuwunel_core::{
|
||||||
Result, implement,
|
Result, implement,
|
||||||
|
itertools::Itertools,
|
||||||
utils::{StreamTools, stream::TryIgnore},
|
utils::{StreamTools, stream::TryIgnore},
|
||||||
warn,
|
warn,
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user