Merge pull request 'fix: wire English Arr history nodes into merge inputs' (#5) from fix/handoff-en-history-wiring-20260916 into main

Der Workflow bekam serienen/videoen-Routen (sonarrEN/radarrEN) plus zwei
History-Nodes. Die Verdrahtung war falsch:

  History Sonarr EN [out0] -> Merge Sonarr(in0)   # in0 von UHD belegt
  History Radarr EN [out0] -> Merge Sonarr(in0)   # falscher Merge

Merge Sonarr/Radarr sind typeVersion 3.2 mit numberInputs=2. Ohne freien Input
wurden beide EN-Nodes NIE ausgefuehrt, waehrend Reconcile Jobs sie per
\$(nodeName).all() liest. Jeder Minuten-Lauf endete mit

  WrappedExecutionError: Node History Sonarr EN hasn t been executed

-> ntfy-Alarm jede Minute, und kein Lease wurde mehr reconciled. Webhook-Laeufe
waren nie betroffen, nur der Schedule-Trigger.

Fix:
- Merge Sonarr + Merge Radarr numberInputs 2 -> 3
- History Sonarr EN -> Merge Sonarr(in2), History Radarr EN -> Merge Radarr(in2)
- flatten() faengt einen nicht ausgefuehrten Node ab und liefert [] statt zu
  werfen; fehlende Historie darf den Reconcile nie wieder komplett blockieren

Verifiziert live: 7/7 Schedule-Laeufe nach dem Deploy success (vorher 9/9
error). Execution 125044 zeigt History Sonarr EN und History Radarr EN mit
executionStatus success, Reconcile Jobs liefert {ok:true,activeJobs:1}.
Webhook-Zyklus start->moved->fail erneut getestet: alle 200/ok.

workflows/media-handoff-orchestrator.json

@@ -20,7 +20,7 @@
     },
     {
       "parameters": {
-        "jsCode": "const body = $json.body ?? $json;\nconst action = String(body.action ?? '').toLowerCase();\nconst routes = {\n  serien4k: { service: 'sonarr', kind: 'episode' },\n  serien: { service: 'sonarr1080p', kind: 'episode' },\n  video4k: { service: 'radarr', kind: 'movie' },\n  video: { service: 'radarr1080p', kind: 'movie' },\n};\nconst now = Date.now();\nconst state = $getWorkflowStaticData('global');\nstate.jobs = state.jobs || {};\nconst jobs = state.jobs;\nconst norm = (v) => String(v ?? '').replace(/\\.nzb$/i, '').toLowerCase().replace(/[^a-z0-9]+/g, '');\nconst active = new Set(['registered', 'processing']);\nfor (const [id, job] of Object.entries(jobs)) {\n  const terminalAt = Date.parse(job.completedAt || job.failedAt || job.timeoutAt || 0);\n  if (!active.has(job.state) && terminalAt && now - terminalAt > 7 * 86400000) delete jobs[id];\n}\nconst fail = (error, extra = {}) => [{ json: { ok: false, error, ...extra } }];\nif (action === 'start') {\n  const category = String(body.category ?? '').toLowerCase();\n  const route = routes[category];\n  const directory = String(body.directory ?? '');\n  const release = String(body.release ?? '');\n  const cleanName = String(body.cleanName ?? '');\n  const expectedFiles = Number(body.expectedFiles ?? 1);\n  if (!route) return fail('unsupported_category', { category });\n  if (!directory.startsWith('/usenet/complete/' + category + '/')) return fail('invalid_directory');\n  if (!release || release.length > 500 || cleanName.length > 500) return fail('invalid_release');\n  if (!Number.isInteger(expectedFiles) || expectedFiles < 1 || expectedFiles > 100) return fail('invalid_expected_files');\n  const dedupeKey = category + ':' + norm(release || cleanName);\n  const prior = Object.values(jobs).find(j => active.has(j.state) && j.dedupeKey === dedupeKey);\n  if (prior) return [{ json: { ok: true, idempotent: true, jobId: prior.jobId, state: prior.state, service: prior.service } }];\n  const jobId = now.toString(36) + '-' + Math.random().toString(36).slice(2, 10);\n  jobs[jobId] = {\n    jobId, category, service: route.service, kind: route.kind, directory,\n    release, cleanName, expectedFiles, importedFiles: 0, dedupeKey, state: 'registered',\n    startedAt: new Date(now).toISOString(), updatedAt: new Date(now).toISOString(),\n  };\n  return [{ json: { ok: true, jobId, state: 'registered', service: route.service, kind: route.kind, expectedFiles } }];\n}\nconst jobId = String(body.jobId ?? '');\nconst job = jobs[jobId];\nif (!job) return fail('job_not_found', { jobId });\nif (action === 'moved') {\n  if (job.state === 'registered') {\n    job.state = 'processing'; job.movedAt = new Date(now).toISOString(); job.updatedAt = job.movedAt;\n  }\n  return [{ json: { ok: true, jobId, state: job.state, service: job.service } }];\n}\nif (action === 'fail') {\n  if (active.has(job.state)) {\n    job.state = 'failed'; job.reason = String(body.reason ?? 'handoff_failed').slice(0, 300);\n    job.failedAt = new Date(now).toISOString(); job.updatedAt = job.failedAt;\n  }\n  return [{ json: { ok: true, jobId, state: job.state } }];\n}\nif (action === 'status') {\n  return [{ json: { ok: true, jobId, state: job.state, category: job.category, service: job.service,\n    reason: job.reason ?? null, expectedFiles: job.expectedFiles ?? 1, importedFiles: job.importedFiles ?? 0,\n    startedAt: job.startedAt, updatedAt: job.updatedAt } }];\n}\nreturn fail('unsupported_action', { action });"
+        "jsCode": "const body = $json.body ?? $json;\nconst action = String(body.action ?? '').toLowerCase();\nconst routes = {\n  serien4k: { service: 'sonarr', kind: 'episode' },\n  serien: { service: 'sonarr1080p', kind: 'episode' },\n  video4k: { service: 'radarr', kind: 'movie' },\n  video: { service: 'radarr1080p', kind: 'movie' },\n  serienen: { service: 'sonarrEN', kind: 'episode' },\n  videoen: { service: 'radarrEN', kind: 'movie' },\n};\nconst now = Date.now();\nconst state = $getWorkflowStaticData('global');\nstate.jobs = state.jobs || {};\nconst jobs = state.jobs;\nconst norm = (v) => String(v ?? '').replace(/\\.nzb$/i, '').toLowerCase().replace(/[^a-z0-9]+/g, '');\nconst active = new Set(['registered', 'processing']);\nfor (const [id, job] of Object.entries(jobs)) {\n  const terminalAt = Date.parse(job.completedAt || job.failedAt || job.timeoutAt || 0);\n  if (!active.has(job.state) && terminalAt && now - terminalAt > 7 * 86400000) delete jobs[id];\n}\nconst fail = (error, extra = {}) => [{ json: { ok: false, error, ...extra } }];\nif (action === 'start') {\n  const category = String(body.category ?? '').toLowerCase();\n  const route = routes[category];\n  const directory = String(body.directory ?? '');\n  const release = String(body.release ?? '');\n  const cleanName = String(body.cleanName ?? '');\n  const expectedFiles = Number(body.expectedFiles ?? 1);\n  if (!route) return fail('unsupported_category', { category });\n  if (!directory.startsWith('/usenet/complete/' + category + '/')) return fail('invalid_directory');\n  if (!release || release.length > 500 || cleanName.length > 500) return fail('invalid_release');\n  if (!Number.isInteger(expectedFiles) || expectedFiles < 1 || expectedFiles > 100) return fail('invalid_expected_files');\n  const dedupeKey = category + ':' + norm(release || cleanName);\n  const prior = Object.values(jobs).find(j => active.has(j.state) && j.dedupeKey === dedupeKey);\n  if (prior) return [{ json: { ok: true, idempotent: true, jobId: prior.jobId, state: prior.state, service: prior.service } }];\n  const jobId = now.toString(36) + '-' + Math.random().toString(36).slice(2, 10);\n  jobs[jobId] = {\n    jobId, category, service: route.service, kind: route.kind, directory,\n    release, cleanName, expectedFiles, importedFiles: 0, dedupeKey, state: 'registered',\n    startedAt: new Date(now).toISOString(), updatedAt: new Date(now).toISOString(),\n  };\n  return [{ json: { ok: true, jobId, state: 'registered', service: route.service, kind: route.kind, expectedFiles } }];\n}\nconst jobId = String(body.jobId ?? '');\nconst job = jobs[jobId];\nif (!job) return fail('job_not_found', { jobId });\nif (action === 'moved') {\n  if (job.state === 'registered') {\n    job.state = 'processing'; job.movedAt = new Date(now).toISOString(); job.updatedAt = job.movedAt;\n  }\n  return [{ json: { ok: true, jobId, state: job.state, service: job.service } }];\n}\nif (action === 'fail') {\n  if (active.has(job.state)) {\n    job.state = 'failed'; job.reason = String(body.reason ?? 'handoff_failed').slice(0, 300);\n    job.failedAt = new Date(now).toISOString(); job.updatedAt = job.failedAt;\n  }\n  return [{ json: { ok: true, jobId, state: job.state } }];\n}\nif (action === 'status') {\n  return [{ json: { ok: true, jobId, state: job.state, category: job.category, service: job.service,\n    reason: job.reason ?? null, expectedFiles: job.expectedFiles ?? 1, importedFiles: job.importedFiles ?? 0,\n    startedAt: job.startedAt, updatedAt: job.updatedAt } }];\n}\nreturn fail('unsupported_action', { action });"
       },
       "id": "81546df2-b2c1-4753-b45c-8f8a6d223cf1",
       "name": "Handle API Request",
@@ -37,13 +37,13 @@
           "interval": [
             {
               "field": "cronExpression",
-              "expression": "*/2 * * * *"
+              "expression": "* * * * *"
             }
           ]
         }
       },
       "id": "9fdf3eb8-5e99-49e0-8a4a-ece3612ebbad",
-      "name": "Every 2 Minutes",
+      "name": "Every Minute",
       "type": "n8n-nodes-base.scheduleTrigger",
       "typeVersion": 1.2,
       "position": [
@@ -201,7 +201,8 @@
     },
     {
       "parameters": {
-        "mode": "append"
+        "mode": "append",
+        "numberInputs": 3
       },
       "id": "dcc19ebf-e267-4c4b-a20f-95e70794cbab",
       "name": "Merge Sonarr",
@@ -214,7 +215,8 @@
     },
     {
       "parameters": {
-        "mode": "append"
+        "mode": "append",
+        "numberInputs": 3
       },
       "id": "b905342e-3ff4-48c5-ab4c-a42b031af655",
       "name": "Merge Radarr",
@@ -240,7 +242,7 @@
     },
     {
       "parameters": {
-        "jsCode": "const state = $getWorkflowStaticData('global');\nstate.jobs = state.jobs || {};\nconst jobs = state.jobs;\nconst now = Date.now();\nconst norm = (v) => String(v ?? '').replace(/\\.nzb$/i, '').toLowerCase().replace(/[^a-z0-9]+/g, '');\nconst flatten = (nodeName) => {\n  const out = [];\n  for (const item of $(nodeName).all()) {\n    const value = item.json;\n    if (Array.isArray(value)) out.push(...value);\n    else if (Array.isArray(value?.records)) out.push(...value.records);\n    else if (value?.eventType) out.push(value);\n  }\n  return out;\n};\nconst sources = {\n  sonarr: flatten('History Sonarr UHD'),\n  sonarr1080p: flatten('History Sonarr FHD'),\n  radarr: flatten('History Radarr UHD'),\n  radarr1080p: flatten('History Radarr FHD'),\n};\nconst imported = new Set(['downloadFolderImported']);\nconst failed = new Set(['downloadFailed', 'downloadIgnored']);\nconst changed = [];\nfor (const job of Object.values(jobs)) {\n  if (!['registered', 'processing'].includes(job.state)) continue;\n  const start = Date.parse(job.startedAt);\n  const wanted = new Set([norm(job.release), norm(job.cleanName)].filter(Boolean));\n  const events = (sources[job.service] || []).filter(e => {\n    const at = Date.parse(e.date || 0);\n    return at >= start && wanted.has(norm(e.sourceTitle));\n  }).sort((a,b) => Date.parse(a.date) - Date.parse(b.date));\n  const terminals = events.filter(e => imported.has(e.eventType) || failed.has(e.eventType));\n  const latest = terminals.at(-1);\n  const importEvents = events.filter(e => imported.has(e.eventType));\n  const importedUnits = new Set(importEvents.map(e => String(\n    job.kind === 'episode' ? (e.episodeId ?? e.data?.fileId ?? e.id) : (e.movieId ?? e.data?.fileId ?? e.id)\n  )));\n  job.importedFiles = importedUnits.size;\n  const expectedFiles = Number(job.expectedFiles ?? 1);\n  if (importedUnits.size >= expectedFiles) {\n    const completed = importEvents.at(-1);\n    job.state = 'success'; job.completedAt = completed.date; job.updatedAt = new Date(now).toISOString();\n    job.importEventId = completed.id ?? null;\n    changed.push({ jobId: job.jobId, state: job.state, importedFiles: importedUnits.size }); continue;\n  }\n  if (latest && failed.has(latest.eventType)) {\n    job.state = 'failed'; job.failedAt = latest.date; job.updatedAt = new Date(now).toISOString();\n    job.reason = latest.eventType; changed.push({ jobId: job.jobId, state: job.state }); continue;\n  }\n  const wasRegistered = job.state === 'registered';\n  const maxAge = wasRegistered ? 15 * 60000 : 24 * 3600000;\n  if (now - start > maxAge) {\n    job.state = 'timeout'; job.timeoutAt = new Date(now).toISOString(); job.updatedAt = job.timeoutAt;\n    job.reason = wasRegistered ? 'move_not_confirmed' : 'import_timeout';\n    changed.push({ jobId: job.jobId, state: job.state });\n  }\n}\nreturn [{ json: { ok: true, activeJobs: Object.values(jobs).filter(j => ['registered','processing'].includes(j.state)).length, changed } }];"
+        "jsCode": "const state = $getWorkflowStaticData('global');\nstate.jobs = state.jobs || {};\nconst jobs = state.jobs;\nconst now = Date.now();\nconst norm = (v) => String(v ?? '').replace(/\\.nzb$/i, '').toLowerCase().replace(/[^a-z0-9]+/g, '');\nconst flatten = (nodeName) => {\n  const out = [];\n  let items = [];\n  try {\n    items = $(nodeName).all();\n  } catch (err) {\n    // Node wurde in diesem Lauf nicht ausgefuehrt (z.B. Verdrahtungsfehler oder\n    // onError-Skip). Fehlende Historie darf den Reconcile nicht abbrechen,\n    // sonst bleiben ALLE Leases haengen. 16.09.2026\n    return out;\n  }\n  for (const item of items) {\n    const value = item.json;\n    if (Array.isArray(value)) out.push(...value);\n    else if (Array.isArray(value?.records)) out.push(...value.records);\n    else if (value?.eventType) out.push(value);\n  }\n  return out;\n};\nconst sources = {\n  sonarr: flatten('History Sonarr UHD'),\n  sonarr1080p: flatten('History Sonarr FHD'),\n  radarr: flatten('History Radarr UHD'),\n  radarr1080p: flatten('History Radarr FHD'),\n  sonarrEN: flatten('History Sonarr EN'),\n  radarrEN: flatten('History Radarr EN'),\n};\nconst imported = new Set(['downloadFolderImported']);\nconst failed = new Set(['downloadFailed', 'downloadIgnored']);\nconst changed = [];\nfor (const job of Object.values(jobs)) {\n  if (!['registered', 'processing'].includes(job.state)) continue;\n  const start = Date.parse(job.startedAt);\n  const wanted = new Set([norm(job.release), norm(job.cleanName)].filter(Boolean));\n  const eventNames = (e) => {\n    const names = [e.sourceTitle];\n    const droppedPath = String(e.data?.droppedPath ?? '').replace(/\\\\/g, '/').replace(/\\/+$/, '');\n    if (droppedPath) {\n      const parts = droppedPath.split('/').filter(Boolean);\n      names.push(parts.at(-1));\n      if (parts.length > 1) names.push(parts.at(-2));\n    }\n    return names.map(norm).filter(Boolean);\n  };\n  const events = (sources[job.service] || []).filter(e => {\n    const at = Date.parse(e.date || 0);\n    return at >= start && eventNames(e).some(name => wanted.has(name));\n  }).sort((a,b) => Date.parse(a.date) - Date.parse(b.date));\n  const terminals = events.filter(e => imported.has(e.eventType) || failed.has(e.eventType));\n  const latest = terminals.at(-1);\n  const importEvents = events.filter(e => imported.has(e.eventType));\n  const importedUnits = new Set(importEvents.map(e => String(\n    job.kind === 'episode' ? (e.episodeId ?? e.data?.fileId ?? e.id) : (e.movieId ?? e.data?.fileId ?? e.id)\n  )));\n  job.importedFiles = importedUnits.size;\n  const expectedFiles = Number(job.expectedFiles ?? 1);\n  if (importedUnits.size >= expectedFiles) {\n    const completed = importEvents.at(-1);\n    job.state = 'success'; job.completedAt = completed.date; job.updatedAt = new Date(now).toISOString();\n    job.importEventId = completed.id ?? null;\n    changed.push({ jobId: job.jobId, state: job.state, importedFiles: importedUnits.size }); continue;\n  }\n  if (latest && failed.has(latest.eventType)) {\n    job.state = 'failed'; job.failedAt = latest.date; job.updatedAt = new Date(now).toISOString();\n    job.reason = latest.eventType; changed.push({ jobId: job.jobId, state: job.state }); continue;\n  }\n  const wasRegistered = job.state === 'registered';\n  const maxAge = wasRegistered ? 15 * 60000 : 24 * 3600000;\n  if (now - start > maxAge) {\n    job.state = 'timeout'; job.timeoutAt = new Date(now).toISOString(); job.updatedAt = job.timeoutAt;\n    job.reason = wasRegistered ? 'move_not_confirmed' : 'import_timeout';\n    changed.push({ jobId: job.jobId, state: job.state });\n  }\n}\nreturn [{ json: { ok: true, activeJobs: Object.values(jobs).filter(j => ['registered','processing'].includes(j.state)).length, changed } }];"
       },
       "id": "54c60ec7-6854-4916-a4e3-9a2b7d13b503",
       "name": "Reconcile Jobs",
@@ -250,6 +252,82 @@
         1120,
         520
       ]
+    },
+    {
+      "parameters": {
+        "url": "={{ 'http://10.5.85.2:8888/sonarrEN/api/v3/history/since?date=' + encodeURIComponent(new Date(Date.now() - 96 * 60 * 60 * 1000).toISOString()) + '&includeSeries=true&includeEpisode=true' }}",
+        "authentication": "genericCredentialType",
+        "genericAuthType": "httpHeaderAuth",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "Accept-Encoding",
+              "value": "none"
+            }
+          ]
+        },
+        "options": {
+          "response": {
+            "response": {
+              "responseFormat": "json"
+            }
+          }
+        }
+      },
+      "id": "en-sonarren",
+      "name": "History Sonarr EN",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [
+        380,
+        860
+      ],
+      "credentials": {
+        "httpHeaderAuth": {
+          "id": "1y7tu0UBjtoS8UZO",
+          "name": "Butler API v2"
+        }
+      },
+      "onError": "continueRegularOutput"
+    },
+    {
+      "parameters": {
+        "url": "={{ 'http://10.5.85.2:8888/radarrEN/api/v3/history/since?date=' + encodeURIComponent(new Date(Date.now() - 96 * 60 * 60 * 1000).toISOString()) + '&includeMovie=true' }}",
+        "authentication": "genericCredentialType",
+        "genericAuthType": "httpHeaderAuth",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "Accept-Encoding",
+              "value": "none"
+            }
+          ]
+        },
+        "options": {
+          "response": {
+            "response": {
+              "responseFormat": "json"
+            }
+          }
+        }
+      },
+      "id": "en-radarren",
+      "name": "History Radarr EN",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [
+        380,
+        980
+      ],
+      "credentials": {
+        "httpHeaderAuth": {
+          "id": "1y7tu0UBjtoS8UZO",
+          "name": "Butler API v2"
+        }
+      },
+      "onError": "continueRegularOutput"
     }
   ],
   "connections": {
@@ -264,32 +342,6 @@
         ]
       ]
     },
-    "Every 2 Minutes": {
-      "main": [
-        [
-          {
-            "node": "History Sonarr UHD",
-            "type": "main",
-            "index": 0
-          },
-          {
-            "node": "History Sonarr FHD",
-            "type": "main",
-            "index": 0
-          },
-          {
-            "node": "History Radarr UHD",
-            "type": "main",
-            "index": 0
-          },
-          {
-            "node": "History Radarr FHD",
-            "type": "main",
-            "index": 0
-          }
-        ]
-      ]
-    },
     "History Sonarr UHD": {
       "main": [
         [
@@ -366,10 +418,68 @@
           }
         ]
       ]
+    },
+    "Every Minute": {
+      "main": [
+        [
+          {
+            "node": "History Sonarr UHD",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "History Sonarr FHD",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "History Radarr UHD",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "History Radarr FHD",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "History Sonarr EN",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "History Radarr EN",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "History Sonarr EN": {
+      "main": [
+        [
+          {
+            "node": "Merge Sonarr",
+            "type": "main",
+            "index": 2
+          }
+        ]
+      ]
+    },
+    "History Radarr EN": {
+      "main": [
+        [
+          {
+            "node": "Merge Radarr",
+            "type": "main",
+            "index": 2
+          }
+        ]
+      ]
     }
   },
   "settings": {
-    "executionOrder": "v1",
+    "errorWorkflow": "AOZA96TZqhB2Dici",
-    "errorWorkflow": "AOZA96TZqhB2Dici"
+    "executionOrder": "v1"
   }
 }