net module reorg

This commit is contained in:
debris 2016-09-20 15:49:09 +02:00
parent d569f90f58
commit e5da98b224
14 changed files with 35 additions and 31 deletions

View File

@ -3,7 +3,7 @@ use ser::{
Stream, Serializable, Stream, Serializable,
Reader, Deserializable, Error as ReaderError, deserialize, Reader, Deserializable, Error as ReaderError, deserialize,
}; };
use {Port, IpAddress, ServiceFlags}; use common::{Port, IpAddress, ServiceFlags};
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub struct NetAddress { pub struct NetAddress {
@ -42,7 +42,7 @@ impl From<&'static str> for NetAddress {
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use ser::{serialize, deserialize}; use ser::{serialize, deserialize};
use ServiceFlags; use common::ServiceFlags;
use super::NetAddress; use super::NetAddress;
#[test] #[test]

View File

@ -2,7 +2,7 @@ use std::{str, fmt};
use std::ascii::AsciiExt; use std::ascii::AsciiExt;
use hash::H96; use hash::H96;
use ser::{Serializable, Stream, Deserializable, Reader, Error as ReaderError}; use ser::{Serializable, Stream, Deserializable, Reader, Error as ReaderError};
use Error; use common::Error;
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub struct Command(H96); pub struct Command(H96);

15
net/src/common/mod.rs Normal file
View File

@ -0,0 +1,15 @@
mod address;
mod command;
mod error;
mod inventory;
mod ip;
mod port;
mod service;
pub use self::address::NetAddress;
pub use self::command::Command;
pub use self::error::Error;
pub use self::inventory::{InventoryVector, InventoryType};
pub use self::ip::IpAddress;
pub use self::port::Port;
pub use self::service::ServiceFlags;

View File

@ -3,28 +3,7 @@ extern crate bitcrypto as crypto;
extern crate primitives; extern crate primitives;
extern crate serialization as ser; extern crate serialization as ser;
mod address; mod common;
mod command; mod messages;
mod error;
mod inventory;
mod ip;
mod message;
mod message_header;
mod payload;
mod port;
mod service;
mod version;
pub use primitives::{hash, bytes}; pub use primitives::{hash, bytes};
pub use self::address::NetAddress;
pub use self::command::Command;
pub use self::error::Error;
pub use self::inventory::{InventoryVector, InventoryType};
pub use self::ip::IpAddress;
pub use self::message::Message;
pub use self::message_header::MessageHeader;
pub use self::payload::Payload;
pub use self::port::Port;
pub use self::service::ServiceFlags;
pub use self::version::{Version, Simple, V106, V70001};

View File

@ -3,7 +3,7 @@ use ser::{
Deserializable, Reader, Error as ReaderError, Deserializable, Reader, Error as ReaderError,
Serializable, Stream, serialize Serializable, Stream, serialize
}; };
use {MessageHeader, Payload}; use messages::{MessageHeader, Payload};
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub struct Message { pub struct Message {
@ -59,7 +59,7 @@ impl Deserializable for Message {
mod tests { mod tests {
use bytes::Bytes; use bytes::Bytes;
use ser::{serialize, deserialize}; use ser::{serialize, deserialize};
use {Version, Payload}; use messages::{Payload, Version};
use super::Message; use super::Message;
#[test] #[test]

View File

@ -3,7 +3,7 @@ use ser::{
Serializable, Stream, Serializable, Stream,
Deserializable, Reader, Error as ReaderError Deserializable, Reader, Error as ReaderError
}; };
use Command; use common::Command;
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub struct MessageHeader { pub struct MessageHeader {

9
net/src/messages/mod.rs Normal file
View File

@ -0,0 +1,9 @@
mod message;
mod message_header;
mod payload;
mod version;
pub use self::message::Message;
pub use self::message_header::MessageHeader;
pub use self::payload::Payload;
pub use self::version::{Version, Simple, V106, V70001};

View File

@ -2,7 +2,8 @@ use ser::{
Serializable, Stream, Serializable, Stream,
Reader, Error as ReaderError Reader, Error as ReaderError
}; };
use {Version, Command}; use common::Command;
use messages::{Version};
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub enum Payload { pub enum Payload {

View File

@ -3,7 +3,7 @@ use ser::{
Serializable, Stream, Serializable, Stream,
Deserializable, Reader, Error as ReaderError, deserialize Deserializable, Reader, Error as ReaderError, deserialize
}; };
use {ServiceFlags, NetAddress}; use common::{NetAddress, ServiceFlags};
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
pub enum Version { pub enum Version {