52 lines
2.3 KiB
Python
52 lines
2.3 KiB
Python
|
"""Verify v5 workflow correctness."""
|
||
|
|
import json
|
||
|
|
import re
|
||
|
|
from pathlib import Path
|
||
|
|
|
||
|
|
WF = Path("/Volumes/EXT/DEVELOPMENT/WFDASH_NEXTJS/n8n_workfows/WFDASH — Quote Email Monitor (v5 catch-and-create).json")
|
||
|
|
wf = json.loads(WF.read_text())
|
||
|
|
|
||
|
|
print("=== Verifying context-flow fixes ===")
|
||
|
|
for n in wf["nodes"]:
|
||
|
|
if n["name"] in ("Plan: Upload Attachments Early", "Collect Attachment IDs", "Parse PB Auth"):
|
||
|
|
code = n["parameters"]["jsCode"]
|
||
|
|
reads = re.findall(r"\$\(\s*['\"]([^'\"]+)['\"]", code)
|
||
|
|
print(f"\n{n['name']} reads from upstream nodes: {reads}")
|
||
|
|
if "binary:" in code or "binary " in code:
|
||
|
|
print(" preserves binary: yes")
|
||
|
|
else:
|
||
|
|
print(" preserves binary: NO")
|
||
|
|
|
||
|
|
print("\n=== Verifying Link Attachments to Quote ===")
|
||
|
|
for n in wf["nodes"]:
|
||
|
|
if n["name"] == "Link Attachments to Quote":
|
||
|
|
code = n["parameters"]["jsCode"]
|
||
|
|
print("Reads from upstream nodes:", re.findall(r"\$\(\s*['\"]([^'\"]+)['\"]", code))
|
||
|
|
print("Uses _attachment_record_ids:", "_attachment_record_ids" in code)
|
||
|
|
|
||
|
|
print("\n=== Connection sanity (Catch and Create branch) ===")
|
||
|
|
chain = ["PocketBase Admin Auth", "Plan: Upload Attachments Early", "Upload Attachment Early",
|
||
|
|
"Collect Attachment IDs", "Parse PB Auth"]
|
||
|
|
for i, src in enumerate(chain[:-1]):
|
||
|
|
nxt = chain[i + 1]
|
||
|
|
edges = wf["connections"].get(src, {}).get("main", [[]])
|
||
|
|
targets = [e.get("node") for e in (edges[0] if edges else [])]
|
||
|
|
ok = "✓" if nxt in targets else "✗"
|
||
|
|
print(f" {ok} {src} -> {targets} (expected {nxt})")
|
||
|
|
|
||
|
|
print("\n=== Connection sanity (Late link branch) ===")
|
||
|
|
chain2 = ["Create Quote Item", "Link Attachments to Quote", "PATCH Attachment (set quote)", "Mark has_attachments"]
|
||
|
|
for i, src in enumerate(chain2[:-1]):
|
||
|
|
nxt = chain2[i + 1]
|
||
|
|
edges = wf["connections"].get(src, {}).get("main", [[]])
|
||
|
|
targets = [e.get("node") for e in (edges[0] if edges else [])]
|
||
|
|
ok = "✓" if nxt in targets else "✗"
|
||
|
|
print(f" {ok} {src} -> {targets} (expected {nxt})")
|
||
|
|
|
||
|
|
print("\n=== Old broken nodes disabled & detached ===")
|
||
|
|
for n in wf["nodes"]:
|
||
|
|
if n["name"].startswith("DISABLED"):
|
||
|
|
in_conns = n["name"] in wf["connections"]
|
||
|
|
print(f" {'✓' if n.get('disabled') else '✗'} {n['name']} (disabled flag set)")
|
||
|
|
print(f" {'✓' if not in_conns else '✗'} not wired in connections map")
|