vincenzopalazzo
/
arti
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

tor-proto: Add imports for commonly used types.

This commit is contained in:
Gabriela Moldovan 2023-07-28 11:07:08 +01:00
parent 3d5c712c55
commit dc0b904492
No known key found for this signature in database
GPG Key ID: 3946E0ADE72BAC99
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
crates/tor-proto/src/stream/incoming.rs
View File

@ -34,7 +34,7 @@ pub struct IncomingStream {
#[non_exhaustive]
pub enum IncomingStreamRequest {
/// A begin cell, which requests a new data stream.
Begin(tor_cell::relaycell::msg::Begin),
Begin(msg::Begin),
// TODO: Eventually, add a BeginDir variant
// TODO: eventually, add a Resolve variant.
}
@ -47,12 +47,12 @@ impl IncomingStream {
/// Accept this stream as a new [`DataStream`], and send the client a
/// message letting them know the stream was accepted.
pub fn accept_data(self, message: tor_cell::relaycell::msg::Connected) -> DataStream {
pub fn accept_data(self, message: msg::Connected) -> DataStream {
todo!()
}
/// Reject this request and send an error message to the client.
pub fn reject(self, message: tor_cell::relaycell::msg::End) {
pub fn reject(self, message: msg::End) {
todo!() // TODO hss
}
@ -101,7 +101,7 @@ impl IncomingCmdChecker {
}
impl super::CmdChecker for IncomingCmdChecker {
fn check_msg(&mut self, msg: &tor_cell::relaycell::UnparsedRelayCell) -> Result<StreamStatus> {
fn check_msg(&mut self, msg: &UnparsedRelayCell) -> Result<StreamStatus> {
match msg.cmd() {
cmd if self.allow_commands.contains(&cmd) => Ok(StreamStatus::Open),
_ => Err(Error::StreamProto(format!(