|
|
@@ -246,11 +246,15 @@ class WebhookService:
|
|
|
group_key=group_key,
|
|
|
)
|
|
|
|
|
|
- # Handle paired_input active fetching
|
|
|
- paired_input = output_config.get("paired_input")
|
|
|
- if paired_input:
|
|
|
- extract_regex = paired_input.get("extract_regex")
|
|
|
- path_template = paired_input.get("path_template")
|
|
|
+ # Handle paired_inputs active fetching
|
|
|
+ paired_inputs = output_config.get("paired_inputs", [])
|
|
|
+ # For backward compatibility with the singular config we just added
|
|
|
+ if "paired_input" in output_config:
|
|
|
+ paired_inputs.append(output_config["paired_input"])
|
|
|
+
|
|
|
+ for paired_config in paired_inputs:
|
|
|
+ extract_regex = paired_config.get("extract_regex")
|
|
|
+ path_template = paired_config.get("path_template")
|
|
|
if extract_regex and path_template:
|
|
|
match = re.search(extract_regex, file_path)
|
|
|
if match:
|
|
|
@@ -267,9 +271,9 @@ class WebhookService:
|
|
|
if paired_info:
|
|
|
paired_changed = await self.storage.process_file_with_sha(
|
|
|
version, paired_path, paired_info.get("sha"), owner, repo_name,
|
|
|
- direction=paired_input.get("direction", "input"),
|
|
|
- label=paired_input.get("label"),
|
|
|
- extract_json_key=paired_input.get("extract_json_key"),
|
|
|
+ direction=paired_config.get("direction", "input"),
|
|
|
+ label=paired_config.get("label"),
|
|
|
+ extract_json_key=paired_config.get("extract_json_key"),
|
|
|
group_key=group_key, # Link them together!
|
|
|
)
|
|
|
has_change = has_change or paired_changed
|
tanjingyu