Merge pull request #24 from jabibamman/feat/server-client-connection

Feat(Server) - client/server connexion + write message

client/Cargo.toml

@@ -10,3 +10,4 @@ edition = "2021"
 image = { version = "0.24.7", features = [] }
 complex = { path = "../complex" }
 shared = { path = "../shared" }
+server = { path = "../server" }

client/src/client.rs

@@ -1 +1,32 @@
+use server::services::{connect::connect, write::write};
 
+/// Connect to the server and send a message
+///
+/// # Arguments
+///
+/// * `host` - Hostname
+/// * `port` - Port
+///
+/// # Return
+///
+/// * `Result<TcpStream, std::io::Error>` - TcpStream
+///
+/// # Example
+///
+/// ```
+/// use client::client::connect_server;
+///
+/// let stream = connect_server("localhost", "8080");
+/// ```
+///
+/// # Panic
+///
+/// * `std::io::Error` - If the connection failed
+///
+pub fn connect_server(host: &str, port: &str) -> std::io::Result<std::net::TcpStream> {
+    let stream = connect(format!("{}:{}", host, port))?;
+
+    write(stream, "Hello World !")?;
+
+    Ok(())
+}

server/Cargo.toml

@@ -9,3 +9,6 @@ edition = "2021"
 [dependencies]
 complex = { path = "../complex" }
 shared = { path = "../shared" }
+
+[lib]
+path = "src/lib.rs"

server/src/mod.rs → server/src/lib.rs

@@ -1,2 +1,3 @@
 pub mod handler;
 pub mod image;
+pub mod services;

server/src/services/connect.rs

@@ -0,0 +1,17 @@
+use std::io::Result;
+use std::net::TcpStream;
+
+/// Connect to a server
+///
+/// # Arguments
+///
+/// * `address` - Address
+///
+/// # Return
+///
+/// * `Result<TcpStream, std::io::Error>` - TcpStream
+pub fn connect(address: &str) -> Result<TcpStream> {
+    let stream = TcpStream::connect(address)?;
+
+    Ok(stream)
+}

server/src/services/mod.rs

@@ -0,0 +1,2 @@
+pub mod connect;
+pub mod write;

server/src/services/write.rs

@@ -0,0 +1,19 @@
+use std::io::Result;
+use std::io::Write;
+use std::net::TcpStream;
+
+/// Write a string to a stream
+///
+/// # Arguments
+///
+/// * `stream` - TcpStream
+/// * `message` - String
+///
+/// # Return
+///
+/// * `Result<TcpStream, std::io::Error>` - TcpStream
+pub fn write(mut stream: TcpStream, message: &str) -> Result<TcpStream> {
+    stream.write(format!("${}", message).as_bytes())?;
+
+    Ok(stream)
+}