Agent framework Plugins architechture

.gitignore

@@ -163,4 +163,7 @@ cython_debug/
 #.idea/
 .DS_Store
 
-*.pem
+*.pem
+
+examples/
+new_examples/

naptha_sdk/cli.py

@@ -7,6 +7,11 @@
 from rich.table import Table
 from rich import box
 import json
+import importlib.metadata
+import shutil
+from git import Repo
+from pathlib import Path
+from naptha_sdk.client.plugin import PluginCLI
 
 from naptha_sdk.client.hub import user_setup_flow
 from naptha_sdk.client.naptha import Naptha
@@ -22,6 +27,7 @@
 from naptha_sdk.utils import url_to_node, get_env_data, get_logger
 from naptha_sdk.secrets import create_secret, verify_and_reconstruct_rsa_key
 
+load_dotenv(override=True)
 logger = get_logger(__name__)
 
 async def list_nodes(naptha):
@@ -727,6 +733,17 @@ async def main():
     personas_parser.add_argument("-u", '--update', type=str, help='Metadata in "key=value" format')
     personas_parser.add_argument('-d', '--delete', action='store_true', help='Delete a persona')
 
+    # Plugin parser
+    plugin_parser = subparsers.add_parser("plugins", help="Manage plugins")
+    plugin_subparsers = plugin_parser.add_subparsers(dest="plugin_cmd", required=True)
+    add_parser = plugin_subparsers.add_parser("add", help="Add a plugin from Git repository")
+    add_parser.add_argument("-u", "--url", required=True, help="Git repository URL")
+    remove_parser = plugin_subparsers.add_parser("remove", help="Remove an installed plugin")
+    remove_parser.add_argument("-n", "--name", required=True, help="Plugin name to remove")
+    update_parser = plugin_subparsers.add_parser("update", help="Update plugins")
+    update_parser.add_argument("-n", "--name", help="Specific plugin to update (omit for all)")
+    list_parser = plugin_subparsers.add_parser("list", help="List installed plugins")
+
     # Tool parser
     tools_parser = subparsers.add_parser("tools", help="List available tools.")
     tools_parser.add_argument('module_name', nargs='?', help='Optional tool name')
@@ -811,6 +828,7 @@ async def main():
                               const=True,
                               metavar="URL")
     publish_parser.add_argument("-s", "--subdeployments", help="Publish subdeployments", action="store_true")
+    publish_parser.add_argument("-gh", "--github", help="Publish to GitHub", action="store_true")
 
     # Add API Key Command
     deploy_secrets_parser = subparsers.add_parser("deploy-secrets", help="Add API keys or tokens.")
@@ -830,7 +848,7 @@ async def main():
         elif args.command in [
             "nodes", "agents", "orchestrators", "environments", 
             "personas", "kbs", "memories", "tools", "run", "inference", 
-            "publish", "create", "storage", "deploy-secrets"
+            "publish", "create", "storage", "deploy-secrets", "plugins"
         ]:
             if not naptha.hub.is_authenticated:
                 if not hub_username or not hub_password:
@@ -877,6 +895,18 @@ async def main():
                         await naptha.hub.create_module("orchestrator", module_config)
                 else:
                     print("Invalid command.")
+
+            elif args.command == "plugins":
+                if args.plugin_cmd == "add":
+                    await PluginCLI.add_plugin(naptha, args.url)
+                elif args.plugin_cmd == "remove":
+                    await PluginCLI.remove_plugin(naptha, args.name)
+                elif args.plugin_cmd == "update":
+                    await PluginCLI.update_plugin(naptha, args.name)
+                elif args.plugin_cmd == "list":
+                    await PluginCLI.list_plugins(naptha) 
+                else:
+                    print("Invalid command.")
             elif args.command == "environments":
                 if not args.module_name:
                     await list_modules(naptha, module_type='environment')
@@ -986,7 +1016,7 @@ async def main():
                     file=args.file
                 )
             elif args.command == "publish":
-                await naptha.publish_modules(args.decorator, args.register, args.subdeployments)
+                await naptha.publish_modules(args.decorator, args.register, args.subdeployments, args.github)
             elif args.command == "deploy-secrets":
                 public_key = await get_server_public_key(naptha)
                 existing_secrets = await list_secrets(naptha)

naptha_sdk/client/plugin.py

@@ -0,0 +1,108 @@
+from pathlib import Path
+import shutil
+from git import Repo
+from rich.table import Table
+from rich.console import Console
+import json
+from naptha_sdk.module_manager import plugin_manager
+
+class PluginCLI:
+    @staticmethod
+    async def add_plugin(naptha, url: str):
+        """Add a plugin from Git repository URL"""
+        try:
+            plugin_dir = Path("~/.naptha/plugins").expanduser()
+            plugin_dir.mkdir(parents=True, exist_ok=True)
+
+            repo_name = url.split("/")[-1].replace(".git", "")
+            dest_path = plugin_dir / repo_name
+
+            if dest_path.exists():
+                print(f"Plugin {repo_name} already exists. Use 'update' to refresh.")
+                return
+
+            print(f"Cloning plugin from {url}...")
+            Repo.clone_from(url, str(dest_path))
+            print(f"Successfully added plugin: {repo_name}")
+
+            # Reload plugins after addition
+            plugin_manager.load_plugins()
+
+        except Exception as e:
+            print(f"Plugin addition failed: {str(e)}")
+
+    @staticmethod
+    async def remove_plugin(naptha, name: str):
+        """Remove an installed plugin"""
+        try:
+            plugin_dir = Path("~/.naptha/plugins").expanduser() / name
+
+            if not plugin_dir.exists():
+                print(f"Plugin {name} not found")
+                return
+
+            shutil.rmtree(plugin_dir)
+            print(f"Successfully removed plugin: {name}")
+
+            # Reload plugins after removal
+            plugin_manager.load_plugins()
+
+        except Exception as e:
+            print(f"Plugin removal failed: {str(e)}")
+
+    @staticmethod
+    async def update_plugin(naptha, name: str = None):
+        """Update one or all plugins"""
+        try:
+            plugin_base = Path("~/.naptha/plugins").expanduser()
+
+            if name:
+                plugins = [plugin_base / name]
+            else:
+                plugins = [d for d in plugin_base.iterdir() if d.is_dir()]
+
+            updated = []
+            for plugin_dir in plugins:
+                if not (plugin_dir / ".git").exists():
+                    print(f"Skipping {plugin_dir.name} (not a Git repository)")
+                    continue
+
+                print(f"Updating {plugin_dir.name}...")
+                repo = Repo(plugin_dir)
+                repo.remotes.origin.pull()
+                updated.append(plugin_dir.name)
+
+            if updated:
+                print(f"Successfully updated: {', '.join(updated)}")
+                plugin_manager.load_plugins()
+            else:
+                print("No plugins updated")
+
+        except Exception as e:
+            print(f"Plugin update failed: {str(e)}")
+
+    @staticmethod
+    async def list_plugins(naptha):
+        """List all installed plugins"""
+        table = Table(title="Installed Plugins")
+        table.add_column("Name", style="cyan")
+        table.add_column("Type", style="magenta")
+        table.add_column("Version", style="green")
+        table.add_column("Path", style="yellow")
+
+        plugin_dir = Path("~/.naptha/plugins").expanduser()
+
+        for plugin_path in plugin_dir.iterdir():
+            if plugin_path.is_dir():
+                metadata_path = plugin_path / "metadata.json"
+                if metadata_path.exists():
+                    with open(metadata_path) as f:
+                        metadata = json.load(f)
+                    table.add_row(
+                        plugin_path.name,
+                        metadata.get("plugin_type", "unknown"),
+                        metadata.get("sdk_version", "unknown"),
+                        str(plugin_path)
+                    )
+
+        Console().print(table)