Renamed from gotham to Juno

Author: rakshith-ravi

Cargo.toml

@@ -1,12 +1,12 @@
 [package]
 authors = ["Rakshith Ravi <[email protected]>"]
 edition = "2018"
-name = "gotham"
+name = "juno"
 version = "0.1.0"
 license = "MIT"
-description = "A helper rust library for the gotham microservices framework"
-homepage = "https://github.com/bytesonus/gotham-rust"
-repository = "https://github.com/bytesonus/gotham-rust"
+description = "A helper rust library for the juno microservices framework"
+homepage = "https://github.com/bytesonus/juno-rust"
+repository = "https://github.com/bytesonus/juno-rust"
 
 [dependencies]
 async-std = "1.5.0"

README.md

@@ -1,6 +1,6 @@
-# Gotham Rust
+# Juno Rust
 
-This is a library that provides you with helper methods for interfacing with the microservices framework, [gotham](https://github.com/bytesonus/gotham).
+This is a library that provides you with helper methods for interfacing with the microservices framework, [juno](https://github.com/bytesonus/juno).
 
 ## How to use:
 
@@ -14,12 +14,12 @@ For all other basic needs, you can get away without worrying about any of that.
 
 ```rust
 use async_std::task;
-use gotham::{models::Value, GothamModule};
+use juno::{models::Value, JunoModule};
 use std::{time::Duration, collections::HashMap};
 
 #[async_std::main]
 async fn main() {
-    let mut module = GothamModule::default("./path/to/gotham.sock");
+    let mut module = JunoModule::default("./path/to/juno.sock");
     // The hashmap below is used to mark dependencies
     module
         .initialize("module-name", "1.0.0", HashMap::new())

src/gotham_module.rs renamed to src/juno_module.rs

@@ -34,7 +34,7 @@ type ArcRequestList = Arc<Mutex<HashMap<String, Sender<Result<Value>>>>>;
 type ArcFunctionList = Arc<Mutex<HashMap<String, fn(HashMap<String, Value>) -> Value>>>;
 type ArcHookListenerList = Arc<Mutex<HashMap<String, Vec<fn(Value)>>>>;
 
-pub struct GothamModule {
+pub struct JunoModule {
 	protocol: BaseProtocol,
 	connection: Box<dyn BaseConnection>,
 	requests: ArcRequestList,
@@ -44,7 +44,7 @@ pub struct GothamModule {
 	registered: bool,
 }
 
-impl GothamModule {
+impl JunoModule {
 	pub fn default(connection_path: &str) -> Self {
 		let is_ip: std::result::Result<SocketAddr, AddrParseError> =
 			connection_path.to_string().parse();
@@ -62,7 +62,7 @@ impl GothamModule {
 
 	#[cfg(target_family = "unix")]
 	pub fn from_unix_socket(socket_path: &str) -> Self {
-		GothamModule {
+		JunoModule {
 			protocol: BaseProtocol::default(),
 			connection: Box::new(UnixSocketConnection::new(socket_path.to_string())),
 			requests: Arc::new(Mutex::new(HashMap::new())),
@@ -74,7 +74,7 @@ impl GothamModule {
 	}
 
 	pub fn from_inet_socket(host: &str, port: u16) -> Self {
-		GothamModule {
+		JunoModule {
 			protocol: BaseProtocol::default(),
 			connection: Box::new(InetSocketConnection::new(format!("{}:{}", host, port))),
 			requests: Arc::new(Mutex::new(HashMap::new())),
@@ -86,7 +86,7 @@ impl GothamModule {
 	}
 
 	pub fn new(protocol: BaseProtocol, connection: Box<dyn BaseConnection>) -> Self {
-		GothamModule {
+		JunoModule {
 			protocol,
 			connection,
 			requests: Arc::new(Mutex::new(HashMap::new())),
@@ -267,7 +267,7 @@ async fn on_data_listener(
 						request_id: request_id.clone(),
 						error: match error {
 							Error::Internal(_) => 0,
-							Error::FromGotham(error_code) => error_code,
+							Error::FromJuno(error_code) => error_code,
 						},
 					}),
 				};
@@ -279,7 +279,7 @@ async fn on_data_listener(
 			BaseMessage::TriggerHookRequest { .. } => {
 				execute_hook_triggered(message, &hook_listeners).await
 			}
-			BaseMessage::Error { error, .. } => Err(Error::FromGotham(error)),
+			BaseMessage::Error { error, .. } => Err(Error::FromJuno(error)),
 			_ => Ok(Value::Null),
 		};
 
@@ -303,7 +303,7 @@ async fn execute_function_call(message: BaseMessage, functions: &ArcFunctionList
 	{
 		let functions = functions.lock().await;
 		if !functions.contains_key(&function) {
-			return Err(Error::FromGotham(utils::errors::UNKNOWN_FUNCTION));
+			return Err(Error::FromJuno(utils::errors::UNKNOWN_FUNCTION));
 		}
 		Ok(functions[&function](arguments))
 	} else {

src/lib.rs

@@ -1,4 +1,4 @@
-mod gotham_module;
+mod juno_module;
 mod utils;
 
 pub mod connection;
@@ -8,5 +8,5 @@ pub mod protocol;
 #[macro_use]
 pub mod macros;
 
-pub use gotham_module::json;
-pub use gotham_module::GothamModule;
+pub use juno_module::json;
+pub use juno_module::JunoModule;

src/utils/error.rs

@@ -3,14 +3,14 @@ use std::fmt::*;
 #[derive(Debug)]
 pub enum Error {
 	Internal(String),
-	FromGotham(u32),
+	FromJuno(u32),
 }
 
 impl Display for Error {
 	fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
 		match self {
 			Error::Internal(string) => write!(f, "Module internal error: {}", string),
-			Error::FromGotham(num) => write!(f, "Gotham error code: {}", num),
+			Error::FromJuno(num) => write!(f, "Juno error code: {}", num),
 		}
 	}
 }

tests/connection/unix_socket_connection.rs

@@ -1,6 +1,6 @@
 use async_std::{fs::remove_file, io::Result, os::unix::net::UnixListener, prelude::*, task};
 use futures_util::sink::SinkExt;
-use gotham::connection::{BaseConnection, UnixSocketConnection};
+use juno::connection::{BaseConnection, UnixSocketConnection};
 
 #[test]
 fn connection_object_should_create_successfully() {

tests/models/messages.rs

@@ -1,4 +1,4 @@
-use gotham::models::{BaseMessage, Value};
+use juno::models::{BaseMessage, Value};
 use std::collections::HashMap;
 
 #[test]

tests/sample.rs

@@ -1,11 +1,11 @@
 use async_std::task;
-use gotham::{models::Value, GothamModule};
+use juno::{models::Value, JunoModule};
 use std::collections::HashMap;
 
 #[test]
 fn sample() {
 	let module1 = async {
-		let mut module = GothamModule::from_unix_socket("../gotham.sock");
+		let mut module = JunoModule::from_unix_socket("../juno.sock");
 		module
 			.initialize("module1", "1.0.0", HashMap::new())
 			.await
@@ -23,7 +23,7 @@ fn sample() {
 		}
 	};
 	let module2 = async {
-		let mut module = GothamModule::from_unix_socket("../gotham.sock");
+		let mut module = JunoModule::from_unix_socket("../juno.sock");
 		module
 			.initialize("module2", "1.0.0", HashMap::new())
 			.await