server: collect body

[hippotat.git] / src / prelude.rs

diff --git a/src/prelude.rs b/src/prelude.rs
index ceb57d1a4166938c2c02aca687a372bf9a8e7c18..10746786cae1a2ea1f0d6781acea29610a94e000 100644 (file)
--- a/src/prelude.rs
+++ b/src/prelude.rs
@@ -28,21 +28,24 @@ pub use std::time::{SystemTime, UNIX_EPOCH};
 pub use cervine::Cow as Cervine;
 pub use extend::ext;
 pub use fehler::{throw, throws};
-pub use futures::{poll, future, StreamExt as _};
+pub use futures::{poll, future, StreamExt, TryStreamExt};
 pub use hyper::body::{Bytes, Buf as _};
-pub use hyper::Uri;
+pub use hyper::{Method, Uri};
 pub use hyper_tls::HttpsConnector;
 pub use ipnet::IpNet;
 pub use itertools::{iproduct, Itertools};
 pub use lazy_regex::{regex_captures, regex_is_match, regex_replace_all};
 pub use lazy_static::lazy_static;
 pub use log::{trace, debug, info, warn, error};
+pub use memchr::memmem;
 pub use structopt::StructOpt;
+pub use subtle::ConstantTimeEq;
 pub use thiserror::Error;
 pub use tokio::io::{AsyncBufReadExt, AsyncWriteExt};
 pub use tokio::pin;
 pub use tokio::select;
-pub use tokio::task;
+pub use tokio::sync::{mpsc, oneshot};
+pub use tokio::task::{self, JoinHandle};
 pub use tokio::time::{Duration, Instant};
 pub use void::{self, Void, ResultVoidExt, ResultVoidErrExt};
 
@@ -54,6 +57,7 @@ pub use eyre::Error as AE;
 pub use crate::config::{self, InstanceConfig, u32Ext as _};
 pub use crate::ini;
 pub use crate::ipif::Ipif;
+pub use crate::multipart::{self, PartName, MetadataFieldIterator};
 pub use crate::utils::*;
 pub use crate::queue::*;
 pub use crate::reporter::*;
@@ -73,6 +77,8 @@ pub const SLIP_ESC_END: u8 = 0o334; // dc
 pub const SLIP_ESC_ESC: u8 = 0o335; // dd
 pub const SLIP_MIME_ESC: u8 = b'-'; // 2d
 
+pub const MAX_OVERHEAD: usize = 2_000;
+
 pub use base64::STANDARD as BASE64_CONFIG;
 
 pub fn default<T:Default>() -> T { Default::default() }