release: v0.1.1 add WEBHOOK_OPENLIST_NAME and remove legacy refresh fallbacks

Author: syscc

README.md

@@ -179,6 +179,7 @@ services:
     user: "1000:1001"
     environment:
       - WEBHOOK_DELAY=60 # Webhook延迟触发秒数 取决是否需要等MoviePilot刮削完成后同步，如果不需要可以设置为3
+      # - WEBHOOK_OPENLIST_NAME=OpenList # Webhook 自动创建任务时使用的 OpenList 引擎备注名；若未配置或留空，默认使用第一个引擎
       - TVsource=/media/电视剧        # 电视剧源根目录
       - MOVsource=/media/电影        # 电影源根目录
       # DST开头变量适用于临时存放（如追新电视剧），整季完结后可删除并同步至SYNC路径，非必要不需要启用！
@@ -260,6 +261,8 @@ task_timeout=72
 
 | 变量 | 说明 | 示例 |
 |---|---|---|
+| `WEBHOOK_DELAY` | Webhook 延迟触发时间（秒） | `60` |
+| `WEBHOOK_OPENLIST_NAME` | Webhook 自动创建任务时使用的 OpenList 引擎备注名；若未配置或留空，默认使用第一个引擎 | `OpenList` |
 | `TVsource` | 电视剧源根 | `/media/电视剧` |
 | `MOVsource` | 电影源根 | `/media/电影` |
 | `DST_TV_TARGETS` / `DST_MOV_TARGETS` | 优先同步根集合（原样使用），存在同名目录时仅同步到这里；仅在末尾追加“名称(年份)”；支持 `,;:` 分隔 | 例如 `/shanct/电视剧` 或 `/shanct/电影` |

docker-compose.yaml

@@ -10,6 +10,7 @@ services:
     user: "1000:1001"
     environment:
       - WEBHOOK_DELAY=60 # Webhook延迟触发秒数 取决是否需要等MoviePilot刮削完成后同步，如果不需要可以设置为3
+      # - WEBHOOK_OPENLIST_NAME=OpenList # Webhook 自动创建任务时使用的 OpenList 引擎备注名；若未配置或留空，默认使用第一个引擎
       - TVsource=/media/电视剧        # 电视剧源根目录
       - MOVsource=/media/电影        # 电影源根目录
       # DST开头变量适用于临时存放（如追新），整季完结后可删除并同步至SYNC路径

service/webhook/refreshService.py

@@ -80,24 +80,6 @@ def _expand_targets(env_s, client):
         return arr
     raw = [p.strip() for p in re.split(r"[,;:]", env_s) if p and p.strip() != '']
 
-    # 获取 /ODC 下的默认 tv/mov 前缀，仅用于兼容 {odc_tv}/{odc_mov} 占位符
-    # 如果用户不使用这俩旧占位符，这里的查询其实是多余的，但为了保持对旧配置的兼容，还是保留比较稳妥
-    # 既然用户明确要求"不用兼容旧的"（可能是指不需要默认去搜根目录下的 tv/mov），
-    # 那么我们可以把这里写死的 '/' 改成 '/ODC' 或者干脆去掉这两个变量？
-    # 但下方代码还用到了 tv_prefix_default 和 mov_prefix_default 来替换 {odc_tv}/{odc_mov}
-    # 如果完全移除，旧占位符将失效。
-    # 用户意图应该是：不要写死搜索根目录 '/'。
-    # 之前的逻辑是搜索 '/ODC'，后来为了去硬编码改成了 '/'。
-    # 如果用户彻底不用 {odc_tv}，那这两行确实没用。
-    # 但为了代码健壮性（防止配置文件里还有旧占位符导致崩溃），建议保留变量定义，但可以设为空字符串或者不进行搜索？
-    # 或者，我们遵循用户的"写死的路径都删掉"，既然 {odc_tv} 本身就隐含了 ODC，
-    # 那么这里应该恢复成搜索 /ODC 吗？不，用户之前说要删掉 /ODC。
-    # 最彻底的做法：如果用户不再使用 {odc_tv}，那这两行和下面的 replace 都可以删掉。
-    # 但如果用户只是说"这里代码还有写死的"，是指 `_find_max_dir(client, '/', 'tv')` 里的 `'/'` 吗？
-    
-    # 让我们假设用户希望彻底移除对 {odc_tv} 的隐式支持逻辑，完全依赖 {max}。
-    # 那么我们可以移除这两个默认搜索。
-    
     for base in raw:
         # 1. 处理通用 {max} 语法
         def max_replacer(match):
@@ -147,7 +129,6 @@ def refresh_after_task(job, status):
     mov_src_norm = re.sub(r"/{2,}", "/", mov_src_env).rstrip('/') + '/' if mov_src_env else ''
     is_tv = bool(tv_src_norm and src_norm.startswith(tv_src_norm))
     logger.info(f"Refresh context: is_tv={is_tv}, src={src}, dsts={dsts}")
-    odc_prefix = None
     base_paths = []
     name = remark
     dedup = []
@@ -171,11 +152,10 @@ def refresh_after_task(job, status):
     if dst_used:
         env_refresh = os.getenv('DST_REFRESH_TV') if is_tv else os.getenv('DST_REFRESH_MOV')
     else:
-        # 尝试获取 SYNC_REFRESH_TV/MOV，如果为空则尝试获取 REFRESH_TV/MOV_TARGETS（兼容旧配置或用户习惯）
         if is_tv:
-            env_refresh = os.getenv('SYNC_REFRESH_TV') or os.getenv('REFRESH_TV_TARGETS')
+            env_refresh = os.getenv('SYNC_REFRESH_TV')
         else:
-            env_refresh = os.getenv('SYNC_REFRESH_MOV') or os.getenv('REFRESH_MOV_TARGETS')
+            env_refresh = os.getenv('SYNC_REFRESH_MOV')
 
     logger.info(f"Refresh env config: dst_used={dst_used}, env_refresh={env_refresh}")
 

service/webhook/webhookService.py

@@ -94,7 +94,33 @@ def _trigger():
                         except Exception:
                             pass
                         return
-                    openlistId = int(openlists[0]['id'])
+                    
+                    openlistId = None
+                    webhook_engine_name = os.getenv('WEBHOOK_OPENLIST_NAME')
+                    
+                    if webhook_engine_name:
+                        webhook_engine_name = webhook_engine_name.strip()
+                        target_op = next((op for op in openlists if op.get('remark') == webhook_engine_name), None)
+                        if target_op:
+                            openlistId = int(target_op['id'])
+                        else:
+                            # 如果指定了引擎但未找到，发送通知并停止
+                            try:
+                                lg.error(f"Webhook configured engine '{webhook_engine_name}' not found")
+                                notify_list = notifyService.getNotifyList(True)
+                                if notify_list:
+                                    for n in notify_list:
+                                        try:
+                                            notifyService.sendNotify(n, 'Webhook 错误', f"未找到名称为 '{webhook_engine_name}' 的OpenList引擎", False)
+                                        except Exception:
+                                            pass
+                            except Exception:
+                                pass
+                            return
+                    else:
+                        # 默认使用第一个引擎
+                        openlistId = int(openlists[0]['id'])
+
                     from service.openlist import openlistService
                     client = None
                     try:
@@ -189,19 +215,15 @@ def max_replacer(match):
 
                         return re.sub(r"(^|.*?/)([^/]*)\{max\}", max_replacer, path_str)
 
-                    odc_prefix = _pick('tv' if tv_flag else 'mov')
                     srcPath = f"{media_root.rstrip('/')}/{remark}/"
                     dst_env = os.getenv('DST_TV_TARGETS') if tv_flag else os.getenv('DST_MOV_TARGETS')
                     dsts = []
                     if dst_env and client is not None:
                         try:
                             raw_dst = [p.strip() for p in re.split(r"[,;:]", dst_env) if p and p.strip() != '']
-                            tv_prefix = _pick('tv')
-                            mov_prefix = _pick('mov')
                             for base in raw_dst:
                                 # 支持 {max} 语法
                                 base = _resolve_max_placeholder(base)
-                                base = base.replace('{odc_tv}', tv_prefix).replace('{odc_mov}', mov_prefix)
                                 if not base.startswith('/'):
                                     base = '/' + base
                                 base = re.sub(r"/{2,}", "/", base).rstrip('/')
@@ -216,12 +238,9 @@ def max_replacer(match):
                         sync_env = os.getenv('SYNC_TV_TARGETS') if tv_flag else os.getenv('SYNC_MOV_TARGETS')
                         if sync_env:
                             raw = [p.strip() for p in re.split(r"[,;:]", sync_env) if p and p.strip() != '']
-                            tv_prefix = _pick('tv')
-                            mov_prefix = _pick('mov')
                             for base in raw:
                                 # 支持 {max} 语法
                                 base = _resolve_max_placeholder(base)
-                                base = base.replace('{odc_tv}', tv_prefix).replace('{odc_mov}', mov_prefix)
                                 if not base.startswith('/'):
                                     base = '/' + base
                                 base = re.sub(r"/{2,}", "/", base).rstrip('/')

version.txt

@@ -1,6 +1,6 @@
-v0.1.0,latest
+v0.1.1,latest
 
 
 该文件仅第一行有效，表示打包的版本。
 如果要打包多个，以英文,分隔，例如【v1.0.0,latest】；
-打包多个仅用于docker镜像，其他情况只认第一个【v1.0.0】。
+打包多个仅用于docker镜像，其他情况只认第一个【v1.0.0】。