Author: NikolaRHristov

CODE_OF_CONDUCT.md

@@ -73,9 +73,9 @@ representative at an online or offline event.
 
 Instances of abusive, harassing, or otherwise unacceptable behavior may be
 reported to the community leaders responsible for enforcement at
-Community@Editor.Land. All complaints will be reviewed and investigated
-promptly and fairly. All community leaders are obligated to respect the privacy
-and security of the reporter of any incident.
+Community@Editor.Land. All complaints will be reviewed and investigated promptly
+and fairly. All community leaders are obligated to respect the privacy and
+security of the reporter of any incident.
 
 ## Enforcement Guidelines
 

Example/Common/Read.rs

@@ -1,5 +1,5 @@
 // Define actions for file reading and writing
-pub async fn Fn(Argument: Vec<Value>) -> Result<Value, Error> {
+pub async fn Fn(Argument:Vec<Value>) -> Result<Value, Error> {
 	let mut Content = String::new();
 
 	File::open(Argument[0].as_str().ok_or(Error::Execution("Invalid file path".to_string()))?)

Example/Common/Write.rs

@@ -1,4 +1,4 @@
-pub async fn Fn(Argument: Vec<Value>) -> Result<Value, Error> {
+pub async fn Fn(Argument:Vec<Value>) -> Result<Value, Error> {
 	OpenOptions::new()
 		.write(true)
 		.create(true)

Example/Sequence.rs

@@ -5,11 +5,7 @@ struct SimpleSite;
 
 #[async_trait::async_trait]
 impl Site for SimpleSite {
-	async fn Receive(
-		&self,
-		Action: Box<dyn Echo::Trait::Sequence::Action::Trait>,
-		Context: &Life,
-	) -> Result<(), Error> {
+	async fn Receive(&self, Action:Box<dyn Echo::Trait::Sequence::Action::Trait>, Context:&Life) -> Result<(), Error> {
 		Action.Execute(Context).await
 	}
 }
@@ -19,8 +15,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 	// Create a plan with file reading and writing actions
 	let Plan = Arc::new(
 		Echo::Struct::Sequence::Plan::Struct::New()
-			.WithSignature(Signature { Name: "Read".to_string() })
-			.WithSignature(Signature { Name: "Write".to_string() })
+			.WithSignature(Signature { Name:"Read".to_string() })
+			.WithSignature(Signature { Name:"Write".to_string() })
 			.WithFunction("Read", Common::Read::Fn)?
 			.WithFunction("Write", Common::Write::Fn)?
 			.Build(),
@@ -31,10 +27,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
 	// Create a life context
 	let Life = Life {
-		Span: Arc::new(DashMap::new()),
-		Fate: Arc::new(config::Config::default()),
-		Cache: Arc::new(tokio::sync::Mutex::new(DashMap::new())),
-		Karma: Arc::new(DashMap::new()),
+		Span:Arc::new(DashMap::new()),
+		Fate:Arc::new(config::Config::default()),
+		Cache:Arc::new(tokio::sync::Mutex::new(DashMap::new())),
+		Karma:Arc::new(DashMap::new()),
 	};
 
 	// Create a site

Example/Tauri.rs

@@ -4,7 +4,7 @@ struct SimpleSite;
 
 #[async_trait::async_trait]
 impl Site for SimpleSite {
-	async fn Receive(&self, Action: Box<dyn Sequence::Action::Trait>, Context: &Life) -> Result<(), Error> {
+	async fn Receive(&self, Action:Box<dyn Sequence::Action::Trait>, Context:&Life) -> Result<(), Error> {
 		Action.Execute(Context).await
 	}
 }
@@ -13,8 +13,8 @@ impl Site for SimpleSite {
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
 	let Plan = Arc::new(
 		Echo::Struct::Sequence::Plan::Struct::New()
-			.WithSignature(Action::Signature::Struct { Name: "Read".to_string() })
-			.WithSignature(Action::Signature::Struct { Name: "Write".to_string() })
+			.WithSignature(Action::Signature::Struct { Name:"Read".to_string() })
+			.WithSignature(Action::Signature::Struct { Name:"Write".to_string() })
 			.WithFunction("Read", Common::Read::Fn)?
 			.WithFunction("Write", Common::Write::Fn)?
 			.Build(),
@@ -23,10 +23,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 	let Production = Arc::new(Echo::Struct::Sequence::Production::Struct::New());
 
 	let Life = Life {
-		Span: Arc::new(dashmap::DashMap::new()),
-		Fate: Arc::new(config::Config::default()),
-		Cache: Arc::new(tokio::sync::Mutex::new(dashmap::DashMap::new())),
-		Karma: Arc::new(dashmap::DashMap::new()),
+		Span:Arc::new(dashmap::DashMap::new()),
+		Fate:Arc::new(config::Config::default()),
+		Cache:Arc::new(tokio::sync::Mutex::new(dashmap::DashMap::new())),
+		Karma:Arc::new(dashmap::DashMap::new()),
 	};
 
 	let Site = Arc::new(SimpleSite);

Example/WorkSteal.rs

@@ -2,19 +2,19 @@
 
 // Define a worker-stealing queue
 struct WorkerStealingQueue {
-	Queues: Vec<Arc<Mutex<Vec<Box<dyn Echo::Trait::Sequence::Action::Trait>>>>>,
+	Queues:Vec<Arc<Mutex<Vec<Box<dyn Echo::Trait::Sequence::Action::Trait>>>>>,
 }
 
 impl WorkerStealingQueue {
-	fn New(Force: usize) -> Self {
-		WorkerStealingQueue { Queues: (0..Force).map(|_| Arc::new(Mutex::new(Vec::new()))).collect() }
+	fn New(Force:usize) -> Self {
+		WorkerStealingQueue { Queues:(0..Force).map(|_| Arc::new(Mutex::new(Vec::new()))).collect() }
 	}
 
-	async fn Assign(&self, Identifier: usize, Action: Box<dyn Echo::Trait::Sequence::Action::Trait>) {
+	async fn Assign(&self, Identifier:usize, Action:Box<dyn Echo::Trait::Sequence::Action::Trait>) {
 		self.Queues[Identifier].lock().await.push(Action);
 	}
 
-	async fn Do(&self, Worker: usize) -> Option<Box<dyn Echo::Trait::Sequence::Action::Trait>> {
+	async fn Do(&self, Worker:usize) -> Option<Box<dyn Echo::Trait::Sequence::Action::Trait>> {
 		let mut Queue = self.Queues[Worker].lock().await;
 
 		if let Some(Action) = Queue.pop() {
@@ -23,7 +23,7 @@ impl WorkerStealingQueue {
 			// Try to steal from other queues
 			drop(Queue);
 
-			let mut QueuesOther: Vec<usize> = (0..self.Queues.len()).filter(|&i| i != Worker).collect();
+			let mut QueuesOther:Vec<usize> = (0..self.Queues.len()).filter(|&i| i != Worker).collect();
 
 			QueuesOther.shuffle(&mut rand::thread_rng());
 
@@ -42,24 +42,20 @@ impl WorkerStealingQueue {
 
 // Define a worker that implements the Worker trait
 struct StealingWorker {
-	Id: usize,
-	Queue: Arc<WorkerStealingQueue>,
+	Id:usize,
+	Queue:Arc<WorkerStealingQueue>,
 }
 
 #[async_trait]
 impl Worker for StealingWorker {
-	async fn Receive(
-		&self,
-		Action: Box<dyn Echo::Trait::Sequence::Action::Trait>,
-		Context: &Life,
-	) -> Result<(), Error> {
+	async fn Receive(&self, Action:Box<dyn Echo::Trait::Sequence::Action::Trait>, Context:&Life) -> Result<(), Error> {
 		self.Queue.Assign(self.Id, Action).await;
 
 		Ok(())
 	}
 }
 
-async fn worker_loop(Worker: Arc<StealingWorker>, Life: Arc<Life>, Running: Arc<Mutex<bool>>) {
+async fn worker_loop(Worker:Arc<StealingWorker>, Life:Arc<Life>, Running:Arc<Mutex<bool>>) {
 	while *Running.lock().await {
 		if let Some(Action) = Worker.Queue.Do(Worker.Id).await {
 			if let Err(_Error) = Action.Execute(&Life).await {
@@ -76,8 +72,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 	// Create a plan with file reading and writing actions
 	let Plan = Arc::new(
 		Echo::Struct::Sequence::Plan::Struct::New()
-			.WithSignature(Signature { Name: "Read".to_string() })
-			.WithSignature(Signature { Name: "Write".to_string() })
+			.WithSignature(Signature { Name:"Read".to_string() })
+			.WithSignature(Signature { Name:"Write".to_string() })
 			.WithFunction("Read", Common::Read::Fn)?
 			.WithFunction("Write", Common::Write::Fn)?
 			.Build(),
@@ -90,22 +86,22 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
 	// Create a life context
 	let Life = Arc::new(Life {
-		Span: Arc::new(dashmap::DashMap::new()),
-		Fate: Arc::new(config::Config::default()),
-		Cache: Arc::new(tokio::sync::Mutex::new(dashmap::DashMap::new())),
-		Karma: Arc::new(dashmap::DashMap::new()),
+		Span:Arc::new(dashmap::DashMap::new()),
+		Fate:Arc::new(config::Config::default()),
+		Cache:Arc::new(tokio::sync::Mutex::new(dashmap::DashMap::new())),
+		Karma:Arc::new(dashmap::DashMap::new()),
 	});
 
 	// Create workers
-	let Workers: Vec<Arc<StealingWorker>> = (0..Force)
-		.map(|Id| Arc::new(StealingWorker { Id, Queue: Queue.clone() }))
+	let Workers:Vec<Arc<StealingWorker>> = (0..Force)
+		.map(|Id| Arc::new(StealingWorker { Id, Queue:Queue.clone() }))
 		.collect();
 
 	// Create a flag to control worker loops
 	let Running = Arc::new(Mutex::new(true));
 
 	// Spawn worker tasks
-	let Handle: Vec<_> = Workers
+	let Handle:Vec<_> = Workers
 		.iter()
 		.map(|Worker| {
 			let Worker = Worker.clone();

Knowledge.dot

@@ -1,35 +1,40 @@
 digraph G {
-  newrank=true;
-  rankdir=LR;
-  splines=ortho;
-  overlap=false;
-  nodesep=0.5;
-  ranksep=0.5;
-  concentrate=true;
-  graph [bgcolor="#f9f9f9", color="#888888", penwidth=2, fontname="Arial"];
-  node [fontname="Arial", fontsize=14, style=filled, margin="0.3,0.2"];
-  edge [fontname="Arial", fontsize=10, color="#555555", fontcolor="gray"];
-  subgraph cluster_1 {
-    label="root";
-    style=filled; color="#5DADE2"; fillcolor="#5DADE220";
-    "n0" [label="root", shape=folder, fillcolor="#5DADE2", penwidth=1.5];
-    "n4" [label="npm (.): @codeeditorland/echo v0.0.1", shape=ellipse, fillcolor="#F4D03F", penwidth=1.5];
-    "n3" [label="cargo (.): Echo v0.0.1", shape=ellipse, fillcolor="#EB984E", penwidth=1.5];
-    "n2" [label="package.json", shape=note, fillcolor="#FADBD8", penwidth=1];
-    "n1" [label="Cargo.toml", shape=note, fillcolor="#FADBD8", penwidth=1];
-  }
-
-  "n0" -> "n1" [label="Contain", style=solid, color="blue", weight=2, arrowsize=0.8];
-  "n0" -> "n2" [label="Contain", style=solid, color="blue", weight=2, arrowsize=0.8];
-  "n0" -> "n3" [label="Contain", style=solid, color="blue", weight=2, arrowsize=0.8];
-  "n0" -> "n4" [label="Contain", style=solid, color="blue", weight=2, arrowsize=0.8];
-  subgraph cluster_legend {
-    label="Legend"; fontsize=14; style=dashed; color=gray;
-    "dir" [label="Directory", shape=folder, fillcolor="#5DADE2"];
-    "file" [label="File", shape=note, fillcolor="#FADBD8"];
-    "pkg" [label="Package", shape=ellipse, fillcolor="#EB984E"];
-    "ext" [label="External", shape=trapezium, fillcolor="#EC7063"];
-    "dir" -> "file" [label="Contain", style=solid, color=blue];
-    "pkg" -> "ext" [label="Dependency", style=dashed, color=red];
-  }
+    newrank = true;
+    rankdir = LR;
+    splines = ortho;
+    overlap = false;
+    nodesep = 0.5;
+    ranksep = 0.5;
+    concentrate = true;
+    graph [bgcolor = "#f9f9f9"; color = "#888888"; penwidth = 2; fontname = "Arial";];
+    node [fontname = "Arial"; fontsize = 14; style = filled; margin = "0.3,0.2";];
+    edge [fontname = "Arial"; fontsize = 10; color = "#555555"; fontcolor = "gray";];
+    subgraph cluster_1 {
+        label = "root";
+        style = filled;
+        color = "#5DADE2";
+        fillcolor = "#5DADE220";
+        "n0" [label = "root";shape = folder;fillcolor = "#5DADE2";penwidth = 1.5;];
+        "n4" [label = "npm (.): @codeeditorland/echo v0.0.1";shape = ellipse;fillcolor = "#F4D03F";penwidth = 1.5;];
+        "n3" [label = "cargo (.): Echo v0.0.1";shape = ellipse;fillcolor = "#EB984E";penwidth = 1.5;];
+        "n2" [label = "package.json";shape = note;fillcolor = "#FADBD8";penwidth = 1;];
+        "n1" [label = "Cargo.toml";shape = note;fillcolor = "#FADBD8";penwidth = 1;];
+    }
+    
+    "n0" -> "n1" [label = "Contain"; style = solid; color = "blue"; weight = 2; arrowsize = 0.8;];
+    "n0" -> "n2" [label = "Contain"; style = solid; color = "blue"; weight = 2; arrowsize = 0.8;];
+    "n0" -> "n3" [label = "Contain"; style = solid; color = "blue"; weight = 2; arrowsize = 0.8;];
+    "n0" -> "n4" [label = "Contain"; style = solid; color = "blue"; weight = 2; arrowsize = 0.8;];
+    subgraph cluster_legend {
+        label = "Legend";
+        fontsize = 14;
+        style = dashed;
+        color = gray;
+        "dir" [label = "Directory";shape = folder;fillcolor = "#5DADE2";];
+        "file" [label = "File";shape = note;fillcolor = "#FADBD8";];
+        "pkg" [label = "Package";shape = ellipse;fillcolor = "#EB984E";];
+        "ext" [label = "External";shape = trapezium;fillcolor = "#EC7063";];
+        "dir" -> "file" [label = "Contain"; style = solid; color = blue;];
+        "pkg" -> "ext" [label = "Dependency"; style = dashed; color = red;];
+    }
 }

README.md

@@ -161,47 +161,51 @@ used throughout the application, often via a shared context or runtime.
     application starts. It is typically wrapped in an `Arc` to be shared safely
     across your application.
 
-    ```rust
-// In your application's main function
-   
-    use std::sync::Arc;
-    use Echo::Scheduler::SchedulerBuilder;
-    use Echo::Task::Priority;
+        ```rust
+
+    // In your application's main function
+
+        use std::sync::Arc;
+        use Echo::Scheduler::SchedulerBuilder;
+        use Echo::Task::Priority;
 
 // Use the fluent builder to configure and build the scheduler
-   
+
     let Scheduler = Arc::new(SchedulerBuilder::Create().WithWorkerCount(8).Build());
     ```
 
 2.  **Submit Tasks:** Use the `Scheduler` instance to submit asynchronous work
     from anywhere in your application.
 
-    ```rust
-// An example async block to be run by the scheduler
-   
-    let MyTask = async {
-        println!("This is running on an Echo worker thread!");
-// ... perform some work ...
-       
-    };
+        ```rust
+
+    // An example async block to be run by the scheduler
+
+        let MyTask = async {
+            println!("This is running on an Echo worker thread!");
+
+    // ... perform some work ...
+
+        };
 
 // Submit the task with a desired priority
-   
+
     Scheduler.Submit(MyTask, Priority::Normal);
 
 // Another example with high priority
-   
+
     Scheduler.Submit(async { /* critical work */ }, Priority::High);
     ```
 
 3.  **Graceful Shutdown:** Before your application exits, ensure a clean
     shutdown of all worker threads.
 
-    ```rust
-// In your application's shutdown sequence
-   
+        ```rust
+
+    // In your application's shutdown sequence
+
 // Note: Arc::try_unwrap requires the Arc to have only one strong reference.
-   
+
     if let Ok(mut Scheduler) = Arc::try_unwrap(Scheduler) {
         Scheduler.Stop().await;
     }