From ed3229683b3b8d2f8baa8bd6637db16facf221df Mon Sep 17 00:00:00 2001 From: jingrow Date: Mon, 3 Nov 2025 01:03:30 +0800 Subject: [PATCH] =?UTF-8?q?get=5Flocal=5Fapps=E9=87=8D=E5=91=BD=E5=90=8D?= =?UTF-8?q?=E4=B8=BAget=5Flocal=5Fapp=5Flist?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- jcloud/api/local_app.py | 210 +++++++++++++++++++++++++++++++++++++++- 1 file changed, 209 insertions(+), 1 deletion(-) diff --git a/jcloud/api/local_app.py b/jcloud/api/local_app.py index bd83588..612b86f 100644 --- a/jcloud/api/local_app.py +++ b/jcloud/api/local_app.py @@ -50,7 +50,7 @@ def _get_team_user_names(apps): @jingrow.whitelist(allow_guest=True) -def get_local_apps(filters=None, order_by=None, limit_start=None, limit_page_length=None): +def get_local_app_list(filters=None, order_by=None, limit_start=None, limit_page_length=None): """获取本地应用列表""" # 构建查询条件 @@ -359,6 +359,110 @@ def get_my_local_node_list(filters=None, order_by=None, limit_start=None, limit_ return result +@jingrow.whitelist(allow_guest=True) +def get_local_node(name): + """获取本地节点详情""" + + if not jingrow.db.exists("Local Node", name): + return {"success": False, "message": "节点不存在"} + + node = jingrow.get_pg("Local Node", name) + + # 获取团队关联用户的名称 + team_user_names = _get_team_user_names([node]) + + node_data = { + "name": node.name, + "node_type": node.node_type, + "title": node.title, + "subtitle": node.subtitle, + "description": node.description, + "enabled": node.enabled, + "public": node.public, + "team": team_user_names.get(node.team), + "status": node.status, + "repository_url": node.repository_url, + "file_url": node.file_url, + "node_image": node.node_image, + "creation": node.creation, + "modified": node.modified + } + + return node_data + + +@dashboard_whitelist() +def create_local_node(node_data): + """创建本地节点""" + team = get_current_team() + + if isinstance(node_data, str): + import json + node_data = json.loads(node_data) + + # 检查节点类型是否已存在 + existing_node = jingrow.db.exists("Local Node", {"node_type": node_data["node_type"]}) + if existing_node: + return {"error": "节点类型已存在，请使用其他类型"} + + # 创建节点 + node = jingrow.get_pg({ + "pagetype": "Local Node", + "node_type": node_data["node_type"], + "title": node_data["title"], + "subtitle": node_data.get("subtitle", ""), + "description": node_data.get("description", ""), + "team": team, + "repository_url": node_data.get("repository_url"), + "file_url": node_data.get("file_url"), + "node_image": node_data.get("node_image") + }) + + node.insert() + return {"success": True, "name": node.name, "message": "节点创建成功"} + + +@dashboard_whitelist() +def update_local_node(name, node_data): + """更新本地节点""" + + team = get_current_team() + if not team: + return {"success": False, "message": "未找到当前团队信息"} + + if not jingrow.db.exists("Local Node", name): + return {"success": False, "message": "节点不存在"} + + node = jingrow.get_pg("Local Node", name) + + # 验证权限：只能更新自己团队的节点 + if node.team != team: + return {"success": False, "message": "您没有权限操作此节点"} + + # 解析 JSON 数据 + if isinstance(node_data, str): + try: + import json + node_data = json.loads(node_data) + except json.JSONDecodeError: + return {"success": False, "message": "JSON 数据格式错误"} + + # 更新字段 + updated_fields = [] + for field, value in node_data.items(): + if hasattr(node, field): + setattr(node, field, value) + updated_fields.append(field) + + # 检查是否有字段被更新 + if not updated_fields: + return {"success": False, "message": "没有有效的字段被更新"} + + # 使用 ignore_permissions=True 因为我们已经手动验证了团队权限 + node.save(ignore_permissions=True) + return {"success": True, "name": node.name, "updated_fields": updated_fields, "message": "节点更新成功"} + + @dashboard_whitelist() def get_my_local_agent_list(filters=None, order_by=None, limit_start=None, limit_page_length=None): """获取当前团队的Agent列表""" @@ -420,6 +524,110 @@ def get_my_local_agent_list(filters=None, order_by=None, limit_start=None, limit return result +@jingrow.whitelist(allow_guest=True) +def get_local_agent(name): + """获取本地Agent详情""" + + if not jingrow.db.exists("Local Agent", name): + return {"success": False, "message": "Agent不存在"} + + agent = jingrow.get_pg("Local Agent", name) + + # 获取团队关联用户的名称 + team_user_names = _get_team_user_names([agent]) + + agent_data = { + "name": agent.name, + "agent_name": agent.agent_name, + "title": agent.title, + "subtitle": agent.subtitle, + "description": agent.description, + "enabled": agent.enabled, + "public": agent.public, + "team": team_user_names.get(agent.team), + "status": agent.status, + "repository_url": agent.repository_url, + "file_url": agent.file_url, + "agent_image": agent.agent_image, + "creation": agent.creation, + "modified": agent.modified + } + + return agent_data + + +@dashboard_whitelist() +def create_local_agent(agent_data): + """创建本地Agent""" + team = get_current_team() + + if isinstance(agent_data, str): + import json + agent_data = json.loads(agent_data) + + # 检查Agent名称是否已存在 + existing_agent = jingrow.db.exists("Local Agent", {"agent_name": agent_data["agent_name"]}) + if existing_agent: + return {"error": "Agent名称已存在，请使用其他名称"} + + # 创建Agent + agent = jingrow.get_pg({ + "pagetype": "Local Agent", + "agent_name": agent_data["agent_name"], + "title": agent_data["title"], + "subtitle": agent_data.get("subtitle", ""), + "description": agent_data.get("description", ""), + "team": team, + "repository_url": agent_data.get("repository_url"), + "file_url": agent_data.get("file_url"), + "agent_image": agent_data.get("agent_image") + }) + + agent.insert() + return {"success": True, "name": agent.name, "message": "Agent创建成功"} + + +@dashboard_whitelist() +def update_local_agent(name, agent_data): + """更新本地Agent""" + + team = get_current_team() + if not team: + return {"success": False, "message": "未找到当前团队信息"} + + if not jingrow.db.exists("Local Agent", name): + return {"success": False, "message": "Agent不存在"} + + agent = jingrow.get_pg("Local Agent", name) + + # 验证权限：只能更新自己团队的Agent + if agent.team != team: + return {"success": False, "message": "您没有权限操作此Agent"} + + # 解析 JSON 数据 + if isinstance(agent_data, str): + try: + import json + agent_data = json.loads(agent_data) + except json.JSONDecodeError: + return {"success": False, "message": "JSON 数据格式错误"} + + # 更新字段 + updated_fields = [] + for field, value in agent_data.items(): + if hasattr(agent, field): + setattr(agent, field, value) + updated_fields.append(field) + + # 检查是否有字段被更新 + if not updated_fields: + return {"success": False, "message": "没有有效的字段被更新"} + + # 使用 ignore_permissions=True 因为我们已经手动验证了团队权限 + agent.save(ignore_permissions=True) + return {"success": True, "name": agent.name, "updated_fields": updated_fields, "message": "Agent更新成功"} + + @dashboard_whitelist() def delete_local_node(name): """删除本地节点"""