From f29a30820986855b3102670945a9e4faf6ee0678 Mon Sep 17 00:00:00 2001
From: Horhik <horhik@tuta.io>
Date: Tue, 5 Jan 2021 15:58:18 +0200
Subject: [PATCH] start crating wrap over fcp api

---
 src/fcp/basic.rs |  0
 src/fcp/mod.rs   |  2 ++
 src/fcp/types.rs | 68 ++++++++++++++++++++++++++++++++++++++++++++++++
 src/main.rs      |  4 ++-
 4 files changed, 73 insertions(+), 1 deletion(-)
 create mode 100644 src/fcp/basic.rs
 create mode 100644 src/fcp/mod.rs
 create mode 100644 src/fcp/types.rs

diff --git a/src/fcp/basic.rs b/src/fcp/basic.rs
new file mode 100644
index 0000000..e69de29
diff --git a/src/fcp/mod.rs b/src/fcp/mod.rs
new file mode 100644
index 0000000..e15769a
--- /dev/null
+++ b/src/fcp/mod.rs
@@ -0,0 +1,2 @@
+pub mod basic;
+pub mod types;
diff --git a/src/fcp/types.rs b/src/fcp/types.rs
new file mode 100644
index 0000000..09dc1fb
--- /dev/null
+++ b/src/fcp/types.rs
@@ -0,0 +1,68 @@
+use std::error::Error;
+use std::io;
+use std::net::{IpAddr, SocketAddr, TcpListener};
+use tokio::net::TcpStream;
+use tokio::prelude::*;
+struct Fcp {
+    connected: bool,
+    stream: TcpStream,
+    addr: SocketAddr,
+    name: str,
+}
+
+trait FcpConnection {
+    fn new(addr: str, port: str, name: str) -> Result<Self, Box<dyn Error>>;
+}
+
+// TODO add error if freenet not connected
+impl Fcp for FcpConnection {
+    fn new(addr: str, port: str, name: str) -> Result<Self, Box<dyn Error>> {
+        let socket = SocketAddr::new(IpAddr::V4(addr.parse().unwrap()), port);
+        match TcpStream::connect(&socket) {
+            Ok(mut stream) => {
+                let _ = stream
+                    .write(
+                        (format!(
+                            "ClientHello\nName={}\nExpectedVersion=2.0\nEndMessage\n\n",
+                            name
+                        ),)
+                            .as_bytes(),
+                    )
+                    .await?;
+                let mut buffer = [0; 1024];
+                stream.read(&mut buffer).await?;
+                let responce = String::from_utf8_lossy(&buffer[..]);
+                println!("response");
+                Ok(stream)
+            }
+            Error(e) => {
+                println!("error: {}", e);
+                Error::new(ErrorKind::Other, e)
+            }
+        }
+    }
+}
+/*
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
+    // Connect to a peer
+    let mut stream = TcpStream::connect("127.0.0.1:9481").await?;
+    let _ = stream
+        .write(("ClientHello\nName=ggg\nExpectedVersion=2.0\nEndMessage\n\n").as_bytes())
+        .await?;
+    println!("Reading response...");
+
+    let mut buffer = [0; 1024];
+    stream.read(&mut buffer).await?;
+    let received = String::from_utf8_lossy(&buffer[..]);
+    print!("<<< {}", received);
+    let _ = stream.write(
+        ("ClientHello\n
+          Name=ggg\n
+          ExpectedVersion=2.0\n
+          EndMessage\n\n")
+            .as_bytes(),
+    );
+}
+*/
diff --git a/src/main.rs b/src/main.rs
index f0a8055..4cd7435 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -2,6 +2,7 @@ mod chat;
 
 mod db;
 mod encrypting;
+mod fcp;
 use async_std::io;
 use chat::front_conn::listen_client;
 use chat::types::PackedMessage;
@@ -14,7 +15,6 @@ use std::{
     thread,
 };
 /*
-
                         +-----------------------------------------------------------------------------------+
                         |                                  Client                                           |
                         |                                                                                   |
@@ -41,6 +41,7 @@ use std::{
                         |                                                                                   |
                         +-----------------------------------------------------------------------------------+
 */
+
 fn main() -> io::Result<()> {
     let (server_sender, server_receiver): (Sender<PackedMessage>, Receiver<PackedMessage>) =
         mpsc::channel();
@@ -63,6 +64,7 @@ fn main() -> io::Result<()> {
     client_thread.join();
     Ok(())
 }
+
 /*
 fn main() {
     let server = TcpListener::bind("127.0.0.1:9001").unwrap();