add ClientHello encode implementaton

src/lib.rs

@@ -1,4 +1,5 @@
 mod types;
+use types::fcp_types;
 
 #[cfg(test)]
 mod tests {

src/types/client/fcp_types.rs

@@ -0,0 +1,152 @@
+use super::types::*;
+impl ClientHello {
+    fn new(name: String, exp_ver: f32) -> Self {
+        ClientHello {
+            name: name,
+            expected_version: exp_ver,
+        }
+    }
+    fn string(self) -> String {
+        return format!(
+            "ClientHello\n\
+             Name={}\n\
+             ExpectedVersion={}\n\
+             EndMessage\n\n",
+            self.name, self.expected_version
+        );
+    }
+}
+
+pub struct ClientHello {
+    name: String,
+    expected_version: f32,
+}
+
+#[test]
+fn client_hello_parses() {
+    let hello = ClientHello::new("user name".to_string(), 2.0);
+    assert_eq!(
+        hello.string(),
+        "ClientHello\nName=user name\nExpectedVersion=2\nEndMessage\n\n"
+    );
+}
+
+// TODO not implemented ListPeer
+pub struct ListPeer {
+    message_name: String,
+    node_identifier: NodeIdentifier,
+    with_volatile: Option<bool>,
+    with_metadata: Option<bool>,
+}
+pub struct ListPeers {
+    message_name: String,
+    with_volatile: Option<bool>,
+    with_metadata: Option<bool>,
+}
+
+pub struct ListPeerNotes {
+    message_name: String,
+    node_identifier: NodeIdentifier,
+}
+pub struct AddPeer {
+    message_name: String,
+    trust: TrustLevel,
+    visibility: VisibilityLevel,
+    file: Option<String>,
+    url: Option<String>,
+    raw: Option<String>,
+}
+pub struct ModifyPeer {
+    message_name: String,
+    node_identifier: NodeIdentifier,
+    allow_local_addresses: Option<bool>,
+    is_disabled: Option<bool>,
+    is_listen_only: Option<bool>,
+    is_burst_only: Option<bool>,
+    ignore_source_port: Option<bool>,
+}
+pub struct ModifyPeerNote {
+    message_name: String,
+    node_text: String,
+    peer_note_type: i32,
+}
+pub struct RemovePeer {
+    message_name: String,
+    node_identifier: NodeIdentifier,
+}
+
+pub struct GetNode {
+    message_name: String,
+    identifier: Option<bool>,
+    give_opennet_ref: Option<bool>,
+    with_private: Option<bool>,
+    with_volatile: Option<bool>,
+}
+
+pub struct GenerateSSK {
+    message_name: String,
+    identifier: Option<String>,
+}
+
+pub struct ClientPut {
+    message_name: String,
+    uri: String, //TODO create key type
+    content_type: Option<String>,
+    identifier: Option<String>,
+    verbosity: Option<VerbosityPut>,
+    max_retries: Option<Retry>,
+    priority_class: Option<i8>,
+    get_chk_only: Option<bool>,
+    global: Option<bool>,
+    dont_compress: Option<bool>,
+    codecs: Option<Vec<String>>,
+    client_token: Option<String>,
+    persistence: Option<Box<OsStr>>,
+    early_encode: Option<bool>,
+    upload_ffrom: Option<UploadForm>,
+    data_length: u64,
+    filename: String,
+    target_uri: Option<String>, // cloning  uri if does not exists
+    file_hash: Option<String>,  //TODO SHAA256 type
+    binary_blob: Option<bool>,
+    fork_on_cacheable: Option<bool>,
+    extra_inserts_single_block: Option<u32>,
+    extra_inserts_splitfile_header_block: Option<u32>,
+    compatibility_mode: Option<String>, //TODO create enum???
+    local_request_only: Option<bool>,
+    override_splitfile_crypto_key: Option<String>, //key in hex
+    real_time_flag: Option<String>,
+    metadata_threshold: Option<i64>,
+    data: Option<String>, // Data fromdirect
+}
+
+pub struct ClientGet {
+    message_name: String,
+    ignore_ds: Option<bool>,
+    ds_only: Option<bool>,
+    uri: String, //FIXME freenet uri type
+    identifier: String,
+    verbosity: Option<VerbosityGet>,
+    max_size: Option<u32>,
+    max_retries: Option<NumOrNone>,
+    priority_class: Option<Priority>,
+    persistence: Option<Persistence>,
+    client_token: Option<String>,
+    global: Option<bool>,
+    return_type: Option<ReturnType>,
+    binary_blob: Option<bool>,
+    filter_data: Option<bool>,
+    allowed_mime_types: Option<Vec<String>>,
+    filename: Option<Box<Path>>,
+    temp_filename: Option<Box<Path>>,
+    real_time_flag: Option<bool>,
+    initial_metadata_data_length: u64,
+}
+
+pub struct Disconnect {
+    message_name: String,
+}
+
+pub struct Shutdown {
+    message_name: String,
+}

src/types/client/mod.rs

@@ -1,2 +1,2 @@
-mod types;
-pub use types::*;
+pub mod fcp_types;
+pub mod types;

src/types/client/types.rs

@@ -1,6 +1,6 @@
-use std::ffi::OsStr;
-use std::net::Ipv4Addr;
-use std::path::Path;
+pub use std::ffi::OsStr;
+pub use std::net::Ipv4Addr;
+pub use std::path::Path;
 pub enum NodeIdentifier {
     Name(String),
     Identity(String),
@@ -71,128 +71,3 @@ pub enum Priority {
     F, // 5
     G, // 6
 }
-
-pub struct ClientHello {
-    message_name: String,
-    name: String,
-    expected_version: f32,
-}
-// TODO not implemented ListPeer
-pub struct ListPeer {
-    message_name: String,
-    node_identifier: NodeIdentifier,
-    with_volatile: Option<bool>,
-    with_metadata: Option<bool>,
-}
-pub struct ListPeers {
-    message_name: String,
-    with_volatile: Option<bool>,
-    with_metadata: Option<bool>,
-}
-
-pub struct ListPeerNotes {
-    message_name: String,
-    node_identifier: NodeIdentifier,
-}
-pub struct AddPeer {
-    message_name: String,
-    trust: TrustLevel,
-    visibility: VisibilityLevel,
-    file: Option<String>,
-    url: Option<String>,
-    raw: Option<String>,
-}
-pub struct ModifyPeer {
-    message_name: String,
-    node_identifier: NodeIdentifier,
-    allow_local_addresses: Option<bool>,
-    is_disabled: Option<bool>,
-    is_listen_only: Option<bool>,
-    is_burst_only: Option<bool>,
-    ignore_source_port: Option<bool>,
-}
-pub struct ModifyPeerNote {
-    message_name: String,
-    node_text: String,
-    peer_note_type: i32,
-}
-pub struct RemovePeer {
-    message_name: String,
-    node_identifier: NodeIdentifier,
-}
-
-pub struct GetNode {
-    message_name: String,
-    identifier: Option<bool>,
-    give_opennet_ref: Option<bool>,
-    with_private: Option<bool>,
-    with_volatile: Option<bool>,
-}
-
-pub struct GenerateSSK {
-    message_name: String,
-    identifier: Option<String>,
-}
-
-pub struct ClientPut {
-    message_name: String,
-    uri: String, //TODO create key type
-    content_type: Option<String>,
-    identifier: Option<String>,
-    verbosity: Option<VerbosityPut>,
-    max_retries: Option<Retry>,
-    priority_class: Option<i8>,
-    get_chk_only: Option<bool>,
-    global: Option<bool>,
-    dont_compress: Option<bool>,
-    codecs: Option<Vec<String>>,
-    client_token: Option<String>,
-    persistence: Option<Box<OsStr>>,
-    early_encode: Option<bool>,
-    upload_ffrom: Option<UploadForm>,
-    data_length: u64,
-    filename: String,
-    target_uri: Option<String>, // cloning  uri if does not exists
-    file_hash: Option<String>,  //TODO SHAA256 type
-    binary_blob: Option<bool>,
-    fork_on_cacheable: Option<bool>,
-    extra_inserts_single_block: Option<u32>,
-    extra_inserts_splitfile_header_block: Option<u32>,
-    compatibility_mode: Option<String>, //TODO create enum???
-    local_request_only: Option<bool>,
-    override_splitfile_crypto_key: Option<String>, //key in hex
-    real_time_flag: Option<String>,
-    metadata_threshold: Option<i64>,
-    data: Option<String>, // Data fromdirect
-}
-
-pub struct ClientGet {
-    message_name: String,
-    ignore_ds: Option<bool>,
-    ds_only: Option<bool>,
-    uri: String, //FIXME freenet uri type
-    identifier: String,
-    verbosity: Option<VerbosityGet>,
-    max_size: Option<u32>,
-    max_retries: Option<NumOrNone>,
-    priority_class: Option<Priority>,
-    persistence: Option<Persistence>,
-    client_token: Option<String>,
-    global: Option<bool>,
-    return_type: Option<ReturnType>,
-    binary_blob: Option<bool>,
-    filter_data: Option<bool>,
-    allowed_mime_types: Option<Vec<String>>,
-    filename: Option<Box<Path>>,
-    temp_filename: Option<Box<Path>>,
-    real_time_flag: Option<bool>,
-    initial_metadata_data_length: u64,
-}
-
-pub struct Disconnect {
-    message_name: String,
-}
-
-pub struct Shutdown {
-    message_name: String,
-}