dev: ghost prototype atom developing

Author: thirdgerb

examples/jetarm_demo/jetarm_agent.py

@@ -20,7 +20,7 @@
 async def run_agent(address: str = ADDRESS, container: Container | None = None):
     container = container or get_container()
     # 创建 Shell
-    shell = new_ctml_shell(container=container)
+    shell = new_ctml_shell(parent_container=container)
 
     jetarm_chan = ZMQChannelProxy(
         name="jetarm",

examples/miku/main.py

@@ -86,7 +86,7 @@ async def run_agent(container: Container, speech: Speech | None = None):
     loop = asyncio.get_running_loop()
 
     # 创建 Shell
-    shell = new_ctml_shell(container=container)
+    shell = new_ctml_shell(parent_container=container)
 
     async def speaking():
         try:

examples/moss_agent.py

@@ -82,7 +82,7 @@ def run_moss_agent(container: Container):
     )
 
     speech = get_example_speech(container)
-    shell = new_ctml_shell(container=container, speech=speech, experimental=False)
+    shell = new_ctml_shell(parent_container=container, speech=speech, experimental=False)
     shell.main_channel.import_channels(
         zmq_hub.as_channel(),
         # 浏览器

pyproject.toml

@@ -1,7 +1,7 @@
 [project]
 name = "ghoshell-moss"
-version = "0.1.0-alpha"
-description = "LLM-oriented operating system shell, providing interpreter for llm to control everything"
+version = "0.1.0-beta"
+description = "LLM-oriented operating system with streaming interpreting shell, and Intelligent Ghost inside it"
 authors = [{ name = "thirdgerb" }, { name = "17wang" }]
 license = { text = "Apache License 2.0" }
 readme = "README.md"
@@ -50,6 +50,7 @@ audio = ["pulsectl>=24.12.0", "pyaudio>=0.2.14", "scipy>=1.15.3"]
 host = [
     "circus>=0.19.0",
     "eclipse-zenoh>=1.8.0",
+    "pydantic-ai>=1.90.0",
     "uv>=0.11.8",
     "uvloop>=0.22.1",
 ]

src/ghoshell_moss/cli/main.py

@@ -2,7 +2,7 @@
 import sys
 from typing import Optional
 from ghoshell_moss.cli.utils import (
-    print_error, print_info,
+    print_error,
     print_panel, echo
 )
 from ghoshell_moss.cli import codex_cli

src/ghoshell_moss/cli/manifests_cli.py

@@ -334,7 +334,8 @@ def _display_channel_table(channels: dict, is_filtered: bool):
 @manifest_app.command(name="primitives")
 def list_primitives(
         search: str = typer.Argument("", help="Search pattern for command name."),
-        json_out: bool = typer.Option(False, "--json", help="Output as raw JSON for AI.")
+        json_out: bool = typer.Option(False, "--json", help="Output as raw JSON for AI."),
+        json_schema: bool = typer.Option(False, "--json-schema", help="Output with json schema")
 ):
     """
     Explore MOSS Primitives (Commands).
@@ -351,23 +352,29 @@ def list_primitives(
             "description": cmd.meta().description,
             "params": cmd.meta().json_schema
         } for name, cmd in results.items()}
-        console.json(data=data)
+        console.print_json(data=data)
         return
-
-    _display_command_detail(list(results.values())[0])
+    if len(primitives) == 0:
+        console.print("no primitive found")
+        return
+    for key, cmd in results.items():
+        _display_command_detail(cmd, json_schema)
 
 
-def _display_command_detail(cmd):
+def _display_command_detail(cmd, with_json_schema: bool):
     meta = cmd.meta()
-    console.print(f"\n[bold green]Command:[/bold green] {meta.name}")
+    console.print(f"\n[bold green]==== Command:[/bold green] {meta.name} ====")
     console.print(f"[dim]Dynamic: {cmd.is_dynamic()}[/dim]\n")
 
     # 重点展示接口定义
-    console.print(Panel(cmd.meta().interface, title="Interface Prompt", border_style="yellow"))
+    console.print(f"[dim]Interface:[/dim]\n")
+    console.print(Syntax(cmd.meta().interface, 'python'))
 
     # 展示 JSON Schema
-    console.print("\n[bold]Arguments Schema:[/bold]")
-    console.json(data=meta.json_schema)
+    if with_json_schema and meta.json_schema is not None:
+        console.print("\n[bold]Arguments Schema:[/bold]")
+        console.print_json(data=meta.json_schema)
+    console.print("")
 
 
 @manifest_app.command(name="contracts")

src/ghoshell_moss/cli/workspace_cli.py

@@ -123,16 +123,16 @@ def init_workspace(
     # 1. 路径选择逻辑 (极简命令行模式)
     if path is None:
         rprint("\n[bold cyan]MOSS Workspace Setup[/bold cyan]")
-        rprint(f" 1) Home directory: [dim]{home_path}[/dim]")
-        rprint(f" 2) Current directory: [dim]{cwd_path}[/dim]")
+        rprint(f" 1) Current directory: [dim]{cwd_path}[/dim]")
+        rprint(f" 2) Home directory: [dim]{home_path}[/dim]")
         rprint(f" 3) Custom path")
 
         choice = typer.prompt("\nSelect an option", default="1", type=str)
 
         if choice == "1":
-            target_path = home_path
-        elif choice == "2":
             target_path = cwd_path
+        elif choice == "2":
+            target_path = home_path
         elif choice == "3":
             custom_path = typer.prompt("Enter custom path", type=Path)
             target_path = custom_path.resolve()

src/ghoshell_moss/core/blueprint/channel_builder.py

@@ -19,7 +19,7 @@
     "MessageType",
     "Builder",
     "MutableChannel",
-    "new_channel"
+    "new_channel", "new_command",
 ]
 
 """

src/ghoshell_moss/core/blueprint/conversation.py

@@ -13,7 +13,7 @@
 __all__ = [
     'Conversation', 'ConversationStore',
     'Reaction', 'Moment', 'ConversationMeta',
-    'ArticulateContext',
+    'ModelContext',
 ]
 
 
@@ -80,6 +80,20 @@ class Moment(BaseModel, WithAdditional):
         description="与本轮思考决策相关的提示讯息. 只在当前轮次生效",
     )
 
+    def to_json(self, *, exclude_perspectives: bool = True) -> str:
+        """
+        标准的序列化方式, 也方便存储.
+        """
+        exclude = None
+        if exclude_perspectives:
+            exclude = {'perspectives'}
+        return self.model_dump_json(
+            exclude=exclude,
+            ensure_ascii=False,
+            exclude_none=True,
+            exclude_defaults=True,
+        )
+
     def new_reaction(self) -> Reaction:
         """生成下轮的接收池"""
         return Reaction(
@@ -194,7 +208,7 @@ class ConversationMeta(BaseModel, WithAdditional):
 _Logos = str
 
 
-class ArticulateContext(BaseModel, WithAdditional):
+class ModelContext(BaseModel, WithAdditional):
     """
     为给大模型使用设计的数据结构.
     这个数据结构考虑可以存储, 方便调试还原每一个 AI 思考的关键帧.
@@ -317,11 +331,13 @@ def get_effective_messages(self) -> Iterable[Message]:
         pass
 
     @abstractmethod
-    def save(self) -> asyncio.Future[ConversationMeta]:
+    def save(self, compact: bool | None = None) -> asyncio.Future[ConversationMeta]:
         """
-        保存当前 conversation, 可以不阻塞当前流程. 返回更新后的 meta 信息. 可能实际上变更了 id.
+        保存当前 conversation.
+        可以不阻塞当前流程. 返回更新后的 meta 信息. 可能实际上变更了 id.
         更新逻辑实际上会排队. 此外, Conversation 之所以是一个抽象类, 就是考虑内部实际上实现了 conversation policy.
-        更新完毕后, Conversation 抽象内容物可能会变化.
+        更新完毕后, Conversation 抽象内容物可能会变化. 具体的 Policy 由 Conversation 实现决定.
+        :param compact: 为 None 表示 auto compact. 为 True 表示必须 Compact.
         """
         pass
 

src/ghoshell_moss/core/blueprint/ghost.py

@@ -1,8 +1,8 @@
 from ghoshell_container import IoCContainer, Contracts
 from typing_extensions import Self
 from abc import ABC, abstractmethod
-from ghoshell_moss.core.blueprint.mindflow import Logos, Mindflow, Nucleus
-from ghoshell_moss.core.blueprint.conversation import ArticulateContext
+from ghoshell_moss.core.blueprint.mindflow import Logos, Mindflow, Nucleus, NucleusMeta, Articulator
+from ghoshell_moss.core.blueprint.conversation import ConversationStore, Conversation
 from ghoshell_moss.core.concepts.channel import Channel
 from ghoshell_moss.message import Message
 
@@ -23,6 +23,10 @@ def name(self) -> str:
         """
         pass
 
+    @abstractmethod
+    def nuclei_metas(self) -> list[NucleusMeta]:
+        pass
+
     @classmethod
     def version(cls) -> str:
         """
@@ -35,7 +39,10 @@ def prototype(cls) -> str:
         """
         返回 Ghost 型号.
         """
-        return cls.__name__
+        prototype_name = cls.__name__
+        if prototype_name.endswith('Meta'):
+            prototype_name = prototype_name[:-4]
+        return prototype_name
 
     @property
     def identifier(self) -> str:
@@ -76,6 +83,8 @@ class Ghost(ABC):
     Ghost 的运行时.
     它基于环境提供的依赖启动, 启动后要提供
     能够被 moss 架构所使用的关键 API.
+
+    系统启动的时候, Ghost 和 GhostMeta 都应该设置到全局 IoC 容器里.
     """
 
     @property
@@ -123,6 +132,20 @@ def nuclei(self) -> list[Nucleus]:
         """
         return []
 
+    @abstractmethod
+    def conversation(self) -> Conversation:
+        """
+        当前进行中的会话.
+        """
+        pass
+
+    @abstractmethod
+    def convos(self) -> ConversationStore:
+        """
+        当前 Ghost 实例下存储的会话历史.
+        """
+        pass
+
     def mindflow(self) -> Mindflow | None:
         """
         Ghost 定义自身的 Mindflow. 如果返回 None 的话, 会使用 MOSS 架构提供的默认 mindflow 实现.
@@ -131,7 +154,7 @@ def mindflow(self) -> Mindflow | None:
         return None
 
     @abstractmethod
-    def articulate(self, context: ArticulateContext) -> Logos:
+    def articulate(self, articulator: Articulator) -> Logos:
         """
         articulate the logos from context
         """