version 0.1.17

.eslintignore

@@ -5,3 +5,5 @@
 **/dist/**/*.js
 **/dist/**/*.cjs
 **/dist/**/*.mjs
+
+tailwind.out.css

.npmrc

@@ -4,3 +4,5 @@ save-workspace-protocol=rolling
 
 # pnpm deploy workaround https://github.com/pnpm/pnpm/issues/6437#issuecomment-1549409913
 dedupe-peer-dependents=false
+
+link-workspace-packages=deep

.prettierignore

@@ -8,10 +8,12 @@ pnpm-lock.yaml
 **/dist
 **/coverage
 **/es
+packages/**/static
 
 # generated code
 **/.dumi/tmp
 **/.dumi/tmp-production
+**/.umi-production
 **/.docusaurus
 **/.umi
 
@@ -27,3 +29,5 @@ tinyColor.less
 .changeset
 
 docker
+
+tailwind.out.css

.stylelintignore

@@ -1 +1,2 @@
 tinyColor.less
+tailwind.out.css

.vscode/settings.json

@@ -34,6 +34,14 @@
   "yaml.schemas": {
     "https://json.schemastore.org/github-issue-config.json": ".github/ISSUE_TEMPLATE/config.yml"
   },
+  "files.exclude": {
+    "**/.git": true,
+    "**/.svn": true,
+    "**/.hg": true,
+    "**/CVS": true,
+    "**/.DS_Store": true,
+    "**/Thumbs.db": true
+  },
   "[python]": {
     "editor.codeActionsOnSave": {
       "source.organizeImports": "never",

README.md

@@ -1,6 +1,6 @@
 # <img src="./docs/assets//logo.svg" width="30"> magent
 
-为智能体研发提供专业产品方案
+智能体研发产品方案
 
 ## magent-ui
 

api/requirements.txt

@@ -16,7 +16,7 @@ anyio==4.4.0
     # via httpx
     # via starlette
     # via watchfiles
-certifi==2024.6.2
+certifi==2024.7.4
     # via httpcore
     # via httpx
 click==8.1.7

packages/magent-ui/pyproject.toml

@@ -1,16 +1,16 @@
 [project]
 name = "magent-ui"
-version = "0.1.16"
+version = "0.1.16.dev6"
 description = ""
 authors = [
   { name = "shiyu", email = "[email protected]" },
   { name = "brokun", email = "[email protected]" },
 ]
 
 dependencies = [
-    "sse-starlette>=2.1.2",
-    "jinja2>=3.1.4",
-    "python-multipart>=0.0.9",
+  "sse-starlette>=2.1.2",
+  "jinja2>=3.1.4",
+  "python-multipart>=0.0.9",
 ]
 readme = "README.md"
 requires-python = ">= 3.10"

packages/magent-ui/src/magent_ui/routers/agents/router.py

@@ -4,7 +4,10 @@
 from typing import AsyncIterable, List
 from fastapi import APIRouter
 from agentuniverse_product.service.agent_service.agent_service import AgentService
+from agentuniverse_product.service.workflow_service.workflow_service import WorkflowService
 from agentuniverse_product.service.model.agent_dto import AgentDTO
+from agentuniverse_product.service.model.workflow_dto import WorkflowDTO
+from agentuniverse_product.service.model.planner_dto import PlannerDTO
 from pydantic import BaseModel
 from sse_starlette import EventSourceResponse, ServerSentEvent
 
@@ -26,6 +29,19 @@ async def get_agent_detail(agent_id):
 async def update_agent(agent_id, agent: AgentDTO):
     return AgentService.update_agent(agent)
 
+@router.post("/agents", response_model=str)
+async def create_agent(agent: AgentDTO):
+    return AgentService.create_agent(agent)
+
+
+@router.post("/agents/workflow", response_model=str)
+async def create_workflow_agent(agent: AgentDTO):
+    workflow_id = f"{agent.id}_workflow"
+    workflow_name = f"{agent.nickname}_workflow"
+    workflow = WorkflowDTO(id=workflow_id, name=workflow_name)
+    workflow_id = WorkflowService.create_workflow(workflow)
+    agent.planner = PlannerDTO(id='workflow_planner', workflow_id=workflow_id)
+    return AgentService.create_agent(agent)
 
 class MessageSenderType(enum.Enum):
     AI = "ai"

packages/magent-ui/src/magent_ui/routers/common/router.py

@@ -0,0 +1,12 @@
+from fastapi import APIRouter
+from agentuniverse_product.base.util.common_util import is_component_id_unique
+
+router = APIRouter()
+common_router = router
+
+
+@router.get("/common/is_id_unique", response_model=bool)
+async def is_id_unique(id:str, type:str):
+    result = is_component_id_unique(id,type)
+    return result
+

packages/magent-ui/src/magent_ui/routers/knowledge/router.py

@@ -1,5 +1,5 @@
-from typing import List
-from fastapi import APIRouter
+from typing import Annotated, List
+from fastapi import APIRouter, Body, File, UploadFile
 from agentuniverse_product.service.model.knowledge_dto import KnowledgeDTO
 from agentuniverse_product.service.knowledge_service.knowledge_service import KnowledgeService
 
@@ -10,3 +10,22 @@
 @router.get("/knowledge", response_model=List[KnowledgeDTO])
 async def get_knowledge():
     return KnowledgeService.get_knowledge_list()
+
+@router.post("/knowledge", response_model=str)
+async def create_knowledge(knowledge: KnowledgeDTO):
+    return KnowledgeService.create_knowledge(knowledge)
+
+@router.put("/knowledge/{knowledge_id}", response_model=str)
+async def update_knowledge(knowledge_id: str, knowledge: KnowledgeDTO):
+    knowledge.id = knowledge_id
+    return KnowledgeService.update_knowledge(knowledge)
+
+@router.delete("/knowledge/{knowledge_id}", response_model=bool)
+async def delete_knowledge(knowledge_id: str):
+    return KnowledgeService.delete_knowledge(knowledge_id)
+
+@router.post("/knowledge/upload")
+async def upload_knowledge_file(knowledge_id: Annotated[str, Body()], file: UploadFile = File(...)):
+    print('here')
+    return KnowledgeService.upload_knowledge_file(knowledge_id, file)
+

packages/magent-ui/src/magent_ui/routers/main.py

@@ -5,6 +5,9 @@
 from magent_ui.routers.sessions.router import sessions_router
 from magent_ui.routers.tools.router import tools_router
 from magent_ui.routers.resource.router import resource_router
+from magent_ui.routers.workflow.router import workflow_router
+from magent_ui.routers.common.router import common_router
+from magent_ui.routers.plugins.router import plugins_router
 
 api_router = APIRouter()
 
@@ -14,3 +17,8 @@
 api_router.include_router(sessions_router, prefix="/v1", tags=["session"])
 api_router.include_router(tools_router, prefix="/v1", tags=["tool"])
 api_router.include_router(resource_router, prefix="/v1", tags=["resource"])
+api_router.include_router(workflow_router, prefix="/v1", tags=["workflow"])
+api_router.include_router(common_router, prefix="/v1", tags=["common"])
+api_router.include_router(plugins_router, prefix="/v1", tags=["plugin"])
+
+

packages/magent-ui/src/magent_ui/routers/plugins/router.py

@@ -0,0 +1,16 @@
+from typing import List
+from fastapi import APIRouter
+from agentuniverse_product.service.plugin_service.plugin_service import PluginService
+from agentuniverse_product.service.model.plugin_dto import PluginDTO
+
+router = APIRouter()
+plugins_router = router
+
+
+@router.get("/plugins", response_model=List[PluginDTO])
+async def get_agents():
+    return PluginService.get_plugin_list()
+
+@router.post("/plugins/openapi", response_model=str)
+async def create_plugin_with_openapi(plugin: PluginDTO):
+    return PluginService.create_plugin_with_openapi(plugin)

packages/magent-ui/src/magent_ui/routers/workflow/router.py

@@ -0,0 +1,20 @@
+from fastapi import APIRouter
+from agentuniverse_product.service.workflow_service.workflow_service import WorkflowService
+from agentuniverse_product.service.model.workflow_dto import WorkflowDTO
+
+router = APIRouter()
+workflow_router = router
+
+
+@router.get("/workflows/{workflow_id}", response_model=WorkflowDTO | None)
+async def get_agent_detail(workflow_id):
+    return WorkflowService.get_workflow_detail(workflow_id)
+
+
+@router.put("/workflows/{workflow_id}", response_model=str | None)
+async def update_agent(workflow_id, workflow: WorkflowDTO):
+    return WorkflowService.update_workflow(workflow)
+
+@router.post("/workflows", response_model=WorkflowDTO)
+async def create_agent(workflow: WorkflowDTO):
+    return WorkflowService.create_workflow(workflow)

pnpm-workspace.yaml

@@ -1,5 +1,4 @@
 packages:
-  - 'web/platform'
-  - 'web/ui'
-  - 'web/packages/*'
+  - 'web-apps/*'
+  - 'web-packages/*'
   - 'docs/site'

web/platform/src/modules/chat/chat.ts → web-apps/platform/src/modules/chat/chat.ts

@@ -232,7 +232,11 @@ export class Chat extends AsyncModel<Chat, ChatOption> {
         const newMessageModel: ChatMessageModel = JSON.parse(e.data);
         const message = this.getOrCreateMessage(newMessageModel);
         this.messages = [...this.messages, message];
-        setImmediate(() => this.scrollToBottom(true, false));
+        setImmediate(() => {
+          if (!this.showToBottomBtn) {
+            this.scrollToBottom(true, false);
+          }
+        });
       }
 
       if (e.event === 'chunk') {
@@ -241,7 +245,11 @@ export class Chat extends AsyncModel<Chat, ChatOption> {
         if (msg) {
           this.processingChunk = msg;
           msg.appendChunk(chunk);
-          setImmediate(() => this.scrollToBottom(true, false));
+          setImmediate(() => {
+            if (!this.showToBottomBtn) {
+              this.scrollToBottom(true, false);
+            }
+          });
         }
       }
     } catch (e) {

web/ui/config/config.ts → web-apps/ui/config/config.ts

@@ -60,6 +60,11 @@ export default defineConfig({
   jsMinifier: 'none',
   alias: {
     '@/modules': path.join(__dirname, '../src/modules'),
+    '@difizen/magent-flow': path.resolve(
+      __dirname,
+      '../../../web-packages/magent-flow/src',
+    ),
+    '@flow': path.resolve(__dirname, '../../../web-packages/magent-flow/src'),
   },
   favicons: ['/favicon.ico'],
 });

web/ui/config/routes.ts → web-apps/ui/config/routes.ts

@@ -30,6 +30,14 @@ export default [
         path: '/agent/:agentId/dev',
         slot: 'magent-agent-dev-slot',
       },
+      {
+        path: '/agent/:agentId/flow',
+        slot: 'magent-agent-flow-dev-slot',
+      },
+      {
+        path: '/portal/knowledge/:knowledgeId/upload',
+        slot: 'magent-knowledge-upload-slot',
+      },
     ],
   },
 ];

web/ui/package.json → web-apps/ui/package.json

@@ -26,6 +26,7 @@
     "@difizen/libro-jupyter": "^0.2.1",
     "@difizen/libro-lab": "^0.2.1",
     "@difizen/libro-markdown": "^0.2.1",
+    "@difizen/magent-flow": "workspace:^",
     "@difizen/mana-app": "^0.1.8",
     "@difizen/mana-react": "^0.1.8",
     "@rjsf/antd": "^5.18.2",
@@ -37,6 +38,7 @@
     "copy-to-clipboard": "^3.3.3",
     "dayjs": "^1.11.10",
     "eventsource-parser": "^1.1.2",
+    "js-yaml": "^4.1.0",
     "lodash": "^4.17.21",
     "lodash.debounce": "^4.0.8",
     "query-string": "^9.0.0",
@@ -45,14 +47,16 @@
     "react-zoom-pan-pinch": "^3.6.1",
     "remark-breaks": "^4.0.0",
     "remark-gfm": "^4.0.0",
-    "umi": "^4.1.1"
+    "timeago.js": "^4.0.2",
+    "umi": "^4.3.18"
   },
   "devDependencies": {
     "@babel/plugin-proposal-decorators": "^7.23.7",
     "@babel/plugin-transform-class-properties": "^7.23.3",
     "@babel/plugin-transform-flow-strip-types": "^7.23.3",
     "@babel/plugin-transform-private-methods": "^7.23.3",
     "@babel/plugin-transform-private-property-in-object": "^7.23.4",
+    "@types/js-yaml": "^4.0.9",
     "@types/lodash.debounce": "^4.0.9",
     "@types/react": "^18.2.48",
     "@types/react-dom": "^18.2.18",

web-apps/ui/src/common/component/component-model.ts

@@ -0,0 +1,54 @@
+import { prop, transient } from '@difizen/mana-app';
+
+import { AsyncModel } from '../async-model.js';
+
+import type { ComponentMeta } from './protocol.js';
+
+@transient()
+export abstract class ComponentModel<T, O extends ComponentMeta> extends AsyncModel<
+  T,
+  O
+> {
+  id: string;
+
+  @prop()
+  avatar?: string;
+
+  @prop()
+  nickname: string;
+
+  @prop()
+  description: string;
+
+  get name(): string {
+    return this.nickname;
+  }
+  set name(v: string) {
+    this.nickname = v;
+  }
+
+  protected override fromMeta(option: O): void {
+    this.id = option.id;
+    if (option.nickname) {
+      this.nickname = option.nickname;
+    }
+    if (option.description) {
+      this.description = option.description;
+    }
+    if (option.avatar) {
+      this.avatar = option.avatar;
+    }
+  }
+
+  updateOption(option: O) {
+    this.fromMeta(option);
+  }
+
+  toMeta = (): ComponentMeta => {
+    return {
+      id: this.id,
+      nickname: this.nickname,
+      avatar: this.avatar,
+    };
+  };
+}

web-apps/ui/src/common/component/protocol.ts

@@ -0,0 +1,6 @@
+export interface ComponentMeta {
+  id: string;
+  avatar?: string;
+  nickname?: string;
+  description?: string;
+}