jingrowlocal/jingrow-framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加get_jingrow_root函数

Browse Source
This commit is contained in:
jingrow 2025-11-03 03:21:14 +08:00
parent 6b4c403113
commit a964723dd2
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/jingrow/jingrow/api/node_management.py
View File

@ -13,7 +13,7 @@ from jingrow.utils.fs import atomic_write_json
from jingrow.utils.jingrow_api import get_record_id, create_record, update_record, get_record_list
from jingrow.utils.auth import get_jingrow_cloud_url, get_jingrow_cloud_api_headers
from jingrow.config import Config
from jingrow.utils.path import get_root_path, get_apps_path
from jingrow.utils.path import get_root_path, get_jingrow_root
logger = logging.getLogger(__name__)
@ -34,7 +34,7 @@ async def export_node_definition(payload: Dict[str, Any]):
export_data = {"metadata": metadata, **(schema or {})}
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
new_root = jingrow_root / "ai" / "nodes"
target = new_root / node_type / f"{node_type}.json"
atomic_write_json(target, export_data)
@ -49,7 +49,7 @@ async def import_local_node_definitions():
扫描本地节点定义目录，按 metadata 去重后导入到 Local Ai Node。
"""
try:
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
if not nodes_root.exists():
return {"success": True, "matched": 0, "imported": 0, "skipped_existing": 0}
@ -127,7 +127,7 @@ async def get_all_node_metadata():
获取所有节点的元数据，用于流程编排界面
"""
try:
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
if not nodes_root.exists():
@ -175,7 +175,7 @@ async def get_node_schema(node_type: str):
获取指定节点类型的Schema配置
"""
try:
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
json_file = nodes_root / node_type / f"{node_type}.json"
@ -306,7 +306,7 @@ async def get_installed_node_types():
"""
try:
# 确定节点目录路径：apps/jingrow/jingrow/ai/nodes
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
node_types = []
@ -527,7 +527,7 @@ def _install_single_node_directory(node_dir: str) -> Dict[str, Any]:
return {'success': False, 'error': '节点定义中缺少 metadata.type'}
# 确定目标目录：apps/jingrow/jingrow/ai/nodes
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
nodes_root.mkdir(parents=True, exist_ok=True)
@ -589,7 +589,7 @@ async def package_node(node_type: str):
try:
from datetime import datetime
jingrow_root = get_apps_path() / "jingrow" / "jingrow"
jingrow_root = get_jingrow_root()
nodes_root = jingrow_root / "ai" / "nodes"
node_dir = nodes_root / node_type

5
apps/jingrow/jingrow/utils/path.py
View File

@ -16,3 +16,8 @@ def get_apps_path() -> Path:
return get_root_path() / "apps"
@lru_cache(maxsize=1)
def get_jingrow_root() -> Path:
"""返回 jingrow 模块根目录路径：apps/jingrow/jingrow"""
return get_root_path() / "apps" / "jingrow" / "jingrow"