remove worker agent adn admin agent

ceylonai · Jan 23, 2025 · d0dea26 · d0dea26
1 parent e87bdff
commit d0dea26
Show file tree

Hide file tree

Showing 15 changed files with 271 additions and 1,935 deletions.
diff --git a/bindings/ceylon/ceylon/__init__.py b/bindings/ceylon/ceylon/__init__.py
@@ -3,8 +3,8 @@
 #
 
 from .ceylon import version
-from .ceylon import AgentDetail, AdminAgentConfig, AdminAgent, WorkerAgentConfig, WorkerAgent, MessageHandler, \
-    EventHandler, Processor
+from .ceylon import AgentDetail, MessageHandler, \
+    EventHandler, Processor, UnifiedAgent, UnifiedAgentConfig, PeerMode
 from .ceylon import enable_log
 
 print(f"ceylon version: {version()}")

diff --git a/bindings/ceylon/src/ceylon.udl b/bindings/ceylon/src/ceylon.udl
@@ -5,65 +5,12 @@ namespace ceylon {
   void cprint(string message);
 };
 
-dictionary AdminAgentConfig {
-    string name;
-    u16 port;
-    u16 buffer_size;
-};
-
 dictionary AgentDetail{
     string name;
     string id;
     string role;
 };
 
-
-interface AdminAgent{
-    constructor(AdminAgentConfig config,MessageHandler on_message, Processor processor, EventHandler on_event);
-    [Async]
-    void start(bytes inputs, sequence<WorkerAgent> workers);
-
-    [Async]
-    void stop();
-
-
-    [Async]
-    void broadcast(bytes message);
-
-    [Async]
-    void send_direct(string to_peer, bytes message);
-
-    AgentDetail details();
-};
-
-dictionary WorkerAgentConfig {
-    string name;
-    string? conf_file =".ceylon_network";
-    string work_space_id;
-    string admin_peer;
-    string role;
-    u16 admin_port;
-    string admin_ip;
-    u16 buffer_size;
-};
-interface WorkerAgent{
-    constructor(WorkerAgentConfig config,MessageHandler on_message, Processor processor, EventHandler on_event);
-    [Async]
-    void start(bytes inputs);
-
-    [Async]
-    void stop();
-
-    [Async]
-    void broadcast(bytes message);
-
-    [Async]
-    void send_direct(string to_peer, bytes message);
-
-    AgentDetail details();
-
-};
-
 // Handle Agents behaviours
 [Trait,WithForeign]
 interface MessageHandler {

diff --git a/bindings/ceylon/src/lib.rs b/bindings/ceylon/src/lib.rs
@@ -23,8 +23,8 @@ fn enable_log(level: String) {
 }
 
 use ceylon_core::{
-    AdminAgent, AdminAgentConfig, AgentDetail, EventHandler, MessageHandler, PeerMode, Processor,
-    UnifiedAgent, UnifiedAgentConfig, WorkerAgent, WorkerAgentConfig,
+    AgentDetail, EventHandler, MessageHandler, PeerMode, Processor, UnifiedAgent,
+    UnifiedAgentConfig,
 };
 use std::str::FromStr;
 use tracing::{info, Level};

diff --git a/bindings/ceylon/tests/agent/test_message_speed.py b/bindings/ceylon/tests/agent/test_message_speed.py
@@ -12,9 +12,8 @@
 from loguru import logger
 
 from ceylon import AgentDetail
-from ceylon.base.agents import Admin, Worker
 from ceylon.base.uni_agent import BaseAgent
-from ceylon.ceylon import PeerMode
+from ceylon import PeerMode
 from ceylon.static_val import DEFAULT_WORKSPACE_ID, DEFAULT_CONF_FILE, DEFAULT_WORKSPACE_PORT, DEFAULT_WORKSPACE_IP
 
 

diff --git a/libs/ceylon-core/src/lib.rs b/libs/ceylon-core/src/lib.rs
@@ -8,10 +8,6 @@ mod utils;
 mod workspace;
 
 pub use workspace::{
-    AdminAgent,
-    AdminAgentConfig,
-    WorkerAgent,
-    WorkerAgentConfig,
     Processor,
     MessageHandler,
     EventHandler,

diff --git a/libs/ceylon-core/src/workspace.rs b/libs/ceylon-core/src/workspace.rs
@@ -4,16 +4,10 @@
  *
  */
 
-mod admin_agent;
 mod agent;
 mod message;
 mod uniffied_agent;
-mod worker_agent;
 
 pub use agent::{AgentDetail, EventHandler, MessageHandler, Processor};
 
-pub use admin_agent::{AdminAgent, AdminAgentConfig};
-
-pub use worker_agent::{WorkerAgent, WorkerAgentConfig};
-
 pub use uniffied_agent::{UnifiedAgent, UnifiedAgentConfig};