{ "edges": [ { "to": "f237ae01-ee10-446a-8e58-282537441177", "from": "a6a5dfb7-2433-4811-bad6-b7a200f8c5fb", "toPort": "0", "fromPort": "1" }, { "to": "1e90ce6e-bc35-4ce1-99e4-6ed2383ca0bc", "from": "c7a8f42f-9eb3-4e43-89ef-0c76537c4615", "toPort": "0", "fromPort": "0" }, { "to": "fb288916-ad61-4d6a-bba3-a957fb9026bf", "from": "86f33f87-089d-4681-beba-0e7330a0a875", "toPort": "0", "fromPort": "0" }, { "to": "2885478b-5607-467a-8626-4bb031c6d2f0", "from": "35c784a5-9e78-4458-af10-60fa3ba40868", "toPort": "0", "fromPort": "0" }, { "to": "e7335a47-6017-4b2d-a712-47c9b04db9f1", "from": "2ee0543f-fb0c-4c0b-8f2d-6117340b9cae", "toPort": "0", "fromPort": "0" }, { "to": "a6a5dfb7-2433-4811-bad6-b7a200f8c5fb", "from": "57e1bcea-03b3-412b-bb3f-978c3d967c8a", "toPort": "0", "fromPort": "1" }, { "to": "3315bc2d-0dc6-4838-a9b0-b4cf1a5c1696", "from": "e7335a47-6017-4b2d-a712-47c9b04db9f1", "toPort": "0", "fromPort": "0" }, { "to": "2ee0543f-fb0c-4c0b-8f2d-6117340b9cae", "from": "993a4a4f-3e92-4fea-bd99-f57528dc44c8", "toPort": "0", "fromPort": "0" }, { "to": "1ce770a8-8ffb-40f2-8275-9d1753099a5b", "from": "e254d82c-1c2d-4f3f-9e25-c366d17c0cba", "toPort": "0", "fromPort": "0" }, { "to": "86f33f87-089d-4681-beba-0e7330a0a875", "from": "e254d82c-1c2d-4f3f-9e25-c366d17c0cba", "toPort": "0", "fromPort": "1" }, { "to": "e254d82c-1c2d-4f3f-9e25-c366d17c0cba", "from": "2885478b-5607-467a-8626-4bb031c6d2f0", "toPort": "0", "fromPort": "0" }, { "to": "35c784a5-9e78-4458-af10-60fa3ba40868", "from": "f237ae01-ee10-446a-8e58-282537441177", "toPort": "0", "fromPort": "0" }, { "to": "c7a8f42f-9eb3-4e43-89ef-0c76537c4615", "from": "3315bc2d-0dc6-4838-a9b0-b4cf1a5c1696", "toPort": "0", "fromPort": "0" }, { "to": "993a4a4f-3e92-4fea-bd99-f57528dc44c8", "from": "fb288916-ad61-4d6a-bba3-a957fb9026bf", "toPort": "0", "fromPort": "0" }, { "to": "57e1bcea-03b3-412b-bb3f-978c3d967c8a", "from": "5f046833-986d-4b88-8047-e6bec5e006b6", "toPort": "0", "fromPort": "0" }, { "to": "993a4a4f-3e92-4fea-bd99-f57528dc44c8", "from": "1ce770a8-8ffb-40f2-8275-9d1753099a5b", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "5f046833-986d-4b88-8047-e6bec5e006b6", "name": "Keephub Form Webhook", "type": "trigger", "params": { "kind": "n8n-nodes-base.webhook", "path": "keephub-form-to-task", "options": {}, "httpMethod": "POST" }, "position": [ 3696, 3392 ] }, { "id": "57e1bcea-03b3-412b-bb3f-978c3d967c8a", "name": "Status Change?", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "cond-status", "operator": { "type": "boolean", "operation": "exists", "singleValue": true }, "leftValue": "={{ $json.body.data.statusChanged }}", "rightValue": "" } ] } }, "position": [ 3920, 3392 ] }, { "id": "a6a5dfb7-2433-4811-bad6-b7a200f8c5fb", "name": "Is Edit?", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "cond-edited", "operator": { "type": "boolean", "operation": "true", "singleValue": true }, "leftValue": "={{ $json.body.data.isEdited }}", "rightValue": "" } ] } }, "position": [ 4112, 3472 ] }, { "id": "f237ae01-ee10-446a-8e58-282537441177", "name": "Extract Form Data", "type": "code", "params": { "jsCode": "const raw = $json;\nconst body = raw.body ?? raw;\nconst data = body.data ?? body;\n\nif (!data || typeof data !== 'object') {\n throw new Error('Unexpected webhook payload. Got: ' + JSON.stringify(raw).substring(0, 300));\n}\n\nconst meta = {\n formSubmissionId: data._id ?? null,\n contentRef: data.contentRef ?? null,\n submittedById: data.updatedBy ?? null,\n submittedAt: data.updatedAt ?? null,\n};\n\nfunction normalize(field) {\n const el = field.element;\n const v = field.value;\n let value;\n if (v == null) {\n value = null;\n } else if (el === 'NodeSelector') {\n value = typeof v === 'object' && !Array.isArray(v)\n ? { id: v.value, label: v.label ?? null, descendants: v.descendants ?? [] }\n : v;\n } else if (['RadioButtons', 'CheckboxGroup', 'Dropdown'].includes(el)) {\n value = Array.isArray(v) ? v.map(o => o.value || o.text?.nl || o.key) : v;\n } else if (el === 'Stars' || el === 'Smileys') {\n value = typeof v === 'number' ? v : parseInt(v, 10) || v;\n } else {\n value = v;\n }\n return { ffId: field.ffId ?? null, element: el ?? 'Unknown', value, raw: v };\n}\n\nconst fields = (data.values ?? []).map(normalize);\nconst byFfId = Object.fromEntries(fields.filter(f => f.ffId).map(f => [f.ffId, f]));\n\nreturn [{ json: { ...meta, fields, byFfId } }];\n" }, "position": [ 4384, 3632 ] }, { "id": "35c784a5-9e78-4458-af10-60fa3ba40868", "name": "Get Submitter", "type": "integration", "params": { "userId": "={{ $json.submittedById }}", "service": "keephub", "resource": "user", "operation": "run", "__originalType": "n8n-nodes-keephub.keephub", "authentication": "loginCredentials" }, "position": [ 4624, 3632 ] }, { "id": "2885478b-5607-467a-8626-4bb031c6d2f0", "name": "Resolve Org Node", "type": "code", "params": { "jsCode": "const formData = $('Extract Form Data').first().json;\nconst userData = $input.first().json;\n\n// Strategy 1: first NodeSelector in form fields\nconst ns = formData.fields.find(f => f.element === 'NodeSelector');\nlet orgNodeId = null;\nlet resolvedFrom = null;\n\nif (ns && ns.raw) {\n orgNodeId = typeof ns.raw === 'object' ? ns.raw.value : String(ns.raw);\n resolvedFrom = 'NodeSelector';\n}\n\n// Strategy 2: submitter's first orgunit\nif (!orgNodeId && userData.orgunits && userData.orgunits.length > 0) {\n const first = userData.orgunits[0];\n orgNodeId = typeof first === 'string' ? first : (first._id || first.id || String(first));\n resolvedFrom = 'userProfile';\n}\n\nif (!orgNodeId) {\n throw new Error(\n 'No org node found. No NodeSelector in form and user ' +\n (userData._id || 'unknown') + ' has no orgunits.'\n );\n}\n\nreturn [{ json: { orgNodeId, resolvedFrom } }];\n" }, "position": [ 4864, 3632 ] }, { "id": "e254d82c-1c2d-4f3f-9e25-c366d17c0cba", "name": "Get Parent Node", "type": "integration", "params": { "nodeId": "={{ $json.orgNodeId }}", "service": "keephub", "resource": "orgchart", "operation": "getParent", "__originalType": "n8n-nodes-keephub.keephub", "authentication": "loginCredentials" }, "position": [ 5104, 3632 ] }, { "id": "993a4a4f-3e92-4fea-bd99-f57528dc44c8", "name": "Get Form Schema", "type": "integration", "params": { "service": "keephub", "contentId": "={{ $('Extract Form Data').item.json.contentRef }}", "operation": "getById", "__originalType": "n8n-nodes-keephub.keephub", "authentication": "loginCredentials" }, "position": [ 6304, 3552 ] }, { "id": "2ee0543f-fb0c-4c0b-8f2d-6117340b9cae", "name": "⚙️ Config", "type": "set", "params": { "options": {}, "assignments": { "assignments": [ { "id": "cfg-001", "name": "groupId", "type": "string", "value": "" }, { "id": "cfg-002", "name": "taskDueDaysFromNow", "type": "number", "value": 1 }, { "id": "cfg-003", "name": "workflow2WebhookUrl", "type": "string", "value": "" } ] } }, "position": [ 6768, 3552 ] }, { "id": "e7335a47-6017-4b2d-a712-47c9b04db9f1", "name": "Build AI Prompt", "type": "code", "params": { "jsCode": "const formData = $('Extract Form Data').first().json;\nconst schema = $('Get Form Schema').first().json;\n\nconst schemaFields = schema.form?.fields || schema.template?.form?.fields || [];\n\n// Lookup by ffId for precise matching\nconst schemaByFfId = {};\nschemaFields.forEach(sf => {\n const key = sf.ffId || sf.field_name;\n if (key) schemaByFfId[key] = sf;\n});\n\n// Fallback: sequential index over non-decorator fields\nconst inputFields = schemaFields.filter(\n sf => !['Paragraph', 'Header', 'Section'].includes(sf.element)\n);\n\nconst rawTitle = schema.title || schema.template?.title || {};\nconst formTitle = Object.values(rawTitle)[0] || 'Form submission';\n\nconst fieldLines = formData.fields.map((field, i) => {\n const sf = (field.ffId && schemaByFfId[field.ffId]) || inputFields[i];\n const label = sf?.label ? Object.values(sf.label)[0] : `Field ${i + 1}`;\n const el = field.element;\n let val;\n if (field.value == null) {\n val = '(not filled)';\n } else if (el === 'NodeSelector' && typeof field.value === 'object') {\n val = field.value.label || field.value.id;\n } else if (Array.isArray(field.value)) {\n val = field.value.join(', ');\n } else {\n val = String(field.value);\n }\n return `- ${label} [${el}]: ${val}`;\n}).join('\\n');\n\nconst prompt = `You are designing a follow-up task in Keephub for a retail manager.\\n\\nA \\\"${formTitle}\\\" was just submitted:\\n${fieldLines}\\n\\nDesign ONE actionable task the manager must complete in response.\\n\\nLanguage rules:\\n- Detect the language from the data (most likely \\\"nl\\\" or \\\"en\\\")\\n- Use the detected BCP-47 code as key in every title/label object\\n- All your text must be in that language\\n\\nTask design rules:\\n1. Title must reference specifics from this submission (name, store, form type) — never generic\\n2. First field must be a Paragraph briefly explaining what the manager must do\\n3. Only add fields the manager needs to fill in — never repeat submitted data\\n4. Labels must be specific and actionable (not \\\"Notes\\\" but \\\"Reason for approval\\\")\\n5. Match field types to content: RadioButtons for yes/no, DatePicker for dates, TextArea for justifications\\n6. 3–6 fields maximum\\n\\nAvailable elements (exact strings):\\n- \\\"TextInput\\\" \\\"TextArea\\\" \\\"NumberInput\\\" \\\"DatePicker\\\"\\n- \\\"RadioButtons\\\" \\\"Checkboxes\\\" \\\"Dropdown\\\" (these require options array)\\n- \\\"Stars\\\" \\\"Smileys\\\" \\\"Paragraph\\\" (Paragraph = static text, content goes in label)\\n\\nReturn ONLY valid JSON, no markdown fences:\\n{\\n \\\"title\\\": { \\\"\\\": \\\"...\\\" },\\n \\\"introText\\\": { \\\"\\\": \\\"One sentence context for the manager.\\\" },\\n \\\"fields\\\": [\\n { \\\"element\\\": \\\"Paragraph\\\", \\\"label\\\": { \\\"\\\": \\\"...\\\" } },\\n { \\\"element\\\": \\\"RadioButtons\\\", \\\"label\\\": { \\\"\\\": \\\"...\\\" }, \\\"required\\\": true, \\\"options\\\": [{ \\\"text\\\": { \\\"\\\": \\\"A\\\" } }, { \\\"text\\\": { \\\"\\\": \\\"B\\\" } }] }\\n ]\\n}`;\n\nreturn [{ json: { prompt } }];\n" }, "position": [ 7216, 3552 ] }, { "id": "3315bc2d-0dc6-4838-a9b0-b4cf1a5c1696", "name": "Design Task with AI", "type": "llm", "params": { "modelId": { "__rl": true, "mode": "list", "value": "gpt-4.1", "cachedResultName": "GPT-4.1" }, "options": {}, "provider": "openai", "responses": { "values": [ { "content": "={{ $json.prompt }}" } ] }, "builtInTools": {} }, "position": [ 7408, 3552 ] }, { "id": "c7a8f42f-9eb3-4e43-89ef-0c76537c4615", "name": "Compose Task", "type": "code", "params": { "jsCode": "const cfg = $('⚙️ Config').first().json;\nconst formData = $('Extract Form Data').first().json;\n\n// --- Parse AI response ---\n// Long extraction chain handles different OpenAI node output formats across versions\n// (structured output, message.content array, legacy choices[], raw text)\nconst aiContent = $input.first().json;\nconst aiRaw =\n aiContent?.output?.[0]?.content?.find(b => b.type === 'output_text')?.text ||\n aiContent?.output?.[0]?.content?.[0]?.text ||\n (Array.isArray(aiContent?.message?.content)\n ? aiContent.message.content.find(b => b.type === 'text')?.text\n : aiContent?.message?.content) ||\n aiContent?.choices?.[0]?.message?.content ||\n aiContent?.text ||\n null;\n\nif (!aiRaw) throw new Error('AI returned no content: ' + JSON.stringify(aiContent).substring(0, 300));\n\nlet aiTask;\ntry {\n aiTask = JSON.parse(aiRaw.replace(/```json|```/g, '').trim());\n} catch (e) {\n throw new Error('AI returned invalid JSON: ' + String(aiRaw).substring(0, 300));\n}\nif (Array.isArray(aiTask)) {\n aiTask = { title: { en: 'Review submission' }, introText: { en: 'Please review.' }, fields: aiTask };\n}\nif (!aiTask.title || typeof aiTask.title !== 'object') throw new Error('Missing title');\nif (!aiTask.introText || typeof aiTask.introText !== 'object') throw new Error('Missing introText');\nif (!Array.isArray(aiTask.fields) || !aiTask.fields.length) throw new Error('Missing fields');\n\n// --- Config validation ---\nconst OBJECT_ID = /^[a-f0-9]{24}$/i;\nconst dueDays = cfg.taskDueDaysFromNow ?? 1;\nif (typeof dueDays !== 'number' || dueDays < 0) {\n throw new Error(`taskDueDaysFromNow must be >= 0, got: ${dueDays}`);\n}\n\n// Validate groupId — invalid non-empty strings will broadcast org-wide\nlet groupId = null;\nif (cfg.groupId && typeof cfg.groupId === 'string' && cfg.groupId.trim()) {\n if (OBJECT_ID.test(cfg.groupId)) {\n groupId = cfg.groupId;\n } else {\n throw new Error(\n `Invalid groupId \"${cfg.groupId}\" — must be a 24-char hex ObjectID. ` +\n `Without a valid groupId, task targets EVERYONE on the node. ` +\n `Check Keephub admin for the correct group ID.`\n );\n }\n}\n\nconst webhookUrl = cfg.workflow2WebhookUrl || '';\n\nconst contentRef = formData.contentRef || '';\nconst formSubmissionId = formData.formSubmissionId || '';\n\n// --- Org target (from parent/root path) ---\n// Merge both paths: try Extract Parent Target first, fall back to Extract Root Target\nlet target;\ntry {\n target = $('Extract Parent Target').first().json;\n if (!target || !target.targetNodeId) throw new Error('No targetNodeId in parent');\n} catch {\n try {\n target = $('Extract Root Target').first().json;\n if (!target || !target.targetNodeId) throw new Error('No targetNodeId in root');\n } catch (err2) {\n throw new Error(\n 'No target node resolved from either parent or root path. ' +\n 'Check Get Parent Node / Get Root Node outputs.'\n );\n }\n}\nconst targetId = target.targetNodeId;\nconst targetDescendants = target.descendants || [];\nconst resolvedGroups = groupId ? [groupId] : [];\n\nif (!targetId) throw new Error('No target node resolved');\n\n// --- Dates (n8n global DateTime = Luxon) ---\nconst now = DateTime.now();\nconst startDate = now.startOf('day').plus({ minutes: 1 });\nconst dueDate = now.plus({ days: dueDays }).endOf('day');\nconst timezone = now.zoneName;\n\n// --- Helpers ---\n// Generate cryptographically strong ObjectID-like strings\nfunction objectId() {\n const buf = crypto.randomBytes(12);\n return buf.toString('hex');\n}\n\nconst langs = Object.keys(aiTask.title);\nconst linkLabels = { nl: 'Bekijk de originele inzending', en: 'View the original submission' };\n\n// --- Intro paragraph with link to submission (URL-encoded) ---\nconst encodedContentRef = encodeURIComponent(contentRef);\nconst encodedSubmissionId = encodeURIComponent(formSubmissionId);\nconst introField = {\n id: objectId(), required: false, element: 'Paragraph',\n static: true, bold: false, italic: false, content: '',\n text: Object.fromEntries(langs.map(lang => [\n lang,\n `

${aiTask.introText[lang] || ''} ${linkLabels[lang] || linkLabels.en}.

`\n ])),\n type: '', editingFieldId: '', sectionIndex: null, insideSection: null, orderIndex: 0\n};\n\n// --- Build dynamic fields with validation ---\nconst OPTION_ELEMENTS = ['RadioButtons', 'Checkboxes', 'Dropdown'];\n\nconst dynamicFields = aiTask.fields\n .filter(f => f.element && (f.label || f.element === 'Paragraph'))\n .map((f, index) => {\n const id = objectId();\n const isParagraph = f.element === 'Paragraph';\n \n // Validate Paragraph has label\n if (isParagraph && (!f.label || typeof f.label !== 'object' || !Object.keys(f.label).length)) {\n throw new Error(`AI returned Paragraph field at index ${index} with no label. All Paragraph fields must have a label object.`);\n }\n \n const field = {\n id, required: f.required ?? false, element: f.element,\n type: '', editingFieldId: '', sectionIndex: null, insideSection: null,\n orderIndex: index + 1\n };\n if (isParagraph) {\n Object.assign(field, { static: true, bold: false, italic: false, content: '', text: f.label });\n } else {\n field.field_name = id;\n field.label = f.label;\n }\n if (OPTION_ELEMENTS.includes(f.element)) {\n // Validate options array\n if (!Array.isArray(f.options) || !f.options.length) {\n throw new Error(\n `AI returned ${f.element} field at index ${index} with no options array. ` +\n `${f.element} requires at least one option.`\n );\n }\n // Validate each option has text object\n f.options.forEach((opt, i) => {\n if (!opt.text || typeof opt.text !== 'object' || !Object.keys(opt.text).length) {\n throw new Error(\n `AI returned ${f.element} field at index ${index}, option ${i} with malformed text. ` +\n `Expected {\"\": \"...\"}, got: ${JSON.stringify(opt.text)}`\n );\n }\n });\n field.shouldTranslate = false;\n field.hiddenValues = false;\n field.options = f.options.map(opt => ({\n value: '', text: opt.text, showRemark: false, remark: '', key: objectId()\n }));\n if (f.element !== 'Dropdown') field.hiddenRemarks = false;\n }\n if (f.element === 'TextArea') field.multiline = true;\n if (f.element === 'NumberInput') { if (f.min != null) field.min = f.min; if (f.max != null) field.max = f.max; }\n if (f.element === 'DatePicker') {\n Object.assign(field, {\n readOnly: false, defaultToday: false, dateFormat: 'MM/dd/yyyy',\n timeFormat: 'hh:mm aa', showTimeSelect: false, showTimeSelectOnly: false\n });\n }\n return field;\n });\n\n// --- Final payload (single task, no repeat) ---\nreturn [{ json: {\n sendPushNotification: true,\n orgchartSelection: { include: [targetId], exclude: targetDescendants },\n parentRef: null,\n orgchartAttrSelection: [],\n groups: resolvedGroups,\n type: 'single',\n template: {\n originLanguage: langs[0],\n startDate: startDate.toISO(),\n dueDate: dueDate.toISO(),\n completionType: 'group',\n timezone,\n endGroup: 'never',\n title: aiTask.title,\n attachments: Object.fromEntries(langs.map(l => [l, []])),\n relatedTags: [],\n form: { active: true, fields: [introField, ...dynamicFields] },\n hookurls: webhookUrl ? [{ url: webhookUrl, active: true }] : [],\n highlighted: false,\n templateEndDate: null\n }\n}}];\n" }, "position": [ 7696, 3552 ] }, { "id": "1e90ce6e-bc35-4ce1-99e4-6ed2383ca0bc", "name": "Create Task", "type": "integration", "params": { "service": "keephub", "resource": "task", "operation": "run", "taskJsonBody": "={{ $node[\"Compose Task\"].json }}", "__originalType": "n8n-nodes-keephub.keephub", "defineTaskInput": "json" }, "position": [ 7936, 3552 ] }, { "id": "86f33f87-089d-4681-beba-0e7330a0a875", "name": "Get Root Node", "type": "integration", "params": { "nodeId": "={{ $('Resolve Org Node').item.json.orgNodeId }}", "service": "keephub", "resource": "orgchart", "operation": "getAncestors", "__originalType": "n8n-nodes-keephub.keephub", "authentication": "loginCredentials", "additionalFields": {} }, "position": [ 5344, 3696 ] }, { "id": "1ce770a8-8ffb-40f2-8275-9d1753099a5b", "name": "Extract Parent Target", "type": "code", "params": { "jsCode": "const result = $input.first().json;\nconst parent = result.parent || result;\nif (!parent._id) throw new Error('Parent node has no _id');\nreturn [{ json: { targetNodeId: parent._id, descendants: parent.descendants || [], isRoot: false } }];\n" }, "position": [ 5344, 3552 ] }, { "id": "fb288916-ad61-4d6a-bba3-a957fb9026bf", "name": "Extract Root Target", "type": "code", "params": { "jsCode": "// Get ancestors returns array from current node up to root\n// The last item is the actual organizational root\nconst response = $input.first().json;\nlet root;\nif (Array.isArray(response)) {\n // If ancestors array is returned, take the last (topmost) ancestor as root\n root = response.length > 0 ? response[response.length - 1] : null;\n} else if (response.ancestors && Array.isArray(response.ancestors)) {\n root = response.ancestors.length > 0 ? response.ancestors[response.ancestors.length - 1] : null;\n} else {\n root = response;\n}\nif (!root || (!root._id && !root.id)) {\n throw new Error('No root node found in ancestors response');\n}\nreturn [{ json: { targetNodeId: root._id || root.id, descendants: root.descendants || [], isRoot: true } }];\n" }, "position": [ 5584, 3696 ] } ] }

Create manager tasks from Keephub form submissions with OpenAI GPT-4.1