{ "edges": [ { "to": "afda275d-a83f-42ad-9817-849ca8f85491", "from": "b7c57bf4-351f-48e7-b87b-0d2310c95b41", "toPort": "0", "fromPort": "0" }, { "to": "7d8918e8-83d3-45c2-b963-390d7868d86b", "from": "afda275d-a83f-42ad-9817-849ca8f85491", "toPort": "0", "fromPort": "0" }, { "to": "c7cf5900-f1db-4527-87c3-2cad1c069fea", "from": "cdb7c087-ea94-4874-b803-4b7bae0bb8b2", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "57e98e9a-9d2a-4865-a956-a7b6747230f6", "from": "656803b3-9dbb-4eb7-9f68-fa19b2696421", "toPort": "0", "fromPort": "0" }, { "to": "0d635913-c3d8-45a1-93fb-1357e888983e", "from": "34f6c853-7829-4336-b531-83d2d425f3d9", "toPort": "0", "fromPort": "0" }, { "to": "c7cf5900-f1db-4527-87c3-2cad1c069fea", "from": "0d635913-c3d8-45a1-93fb-1357e888983e", "toPort": "0", "fromPort": "0" }, { "to": "656803b3-9dbb-4eb7-9f68-fa19b2696421", "from": "95d2d463-71fd-4102-9ab0-85b25ea82e18", "toPort": "0", "fromPort": "0" }, { "to": "a4c7fe64-b130-4f7c-a850-27c1fb77bd2d", "from": "0a9061cb-fd11-42e3-813e-33d1e04c7de0", "toPort": "0", "fromPort": "0" }, { "to": "14648e6a-5cba-40e2-a233-288d77851486", "from": "57e98e9a-9d2a-4865-a956-a7b6747230f6", "toPort": "0", "fromPort": "0" }, { "to": "34f6c853-7829-4336-b531-83d2d425f3d9", "from": "14648e6a-5cba-40e2-a233-288d77851486", "toPort": "0", "fromPort": "0" }, { "to": "b7c57bf4-351f-48e7-b87b-0d2310c95b41", "from": "c7cf5900-f1db-4527-87c3-2cad1c069fea", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "95d2d463-71fd-4102-9ab0-85b25ea82e18", "name": "Every Monday at 08:00", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "cronExpression", "expression": "0 8 * * 1" } ] } }, "position": [ 8736, 1808 ] }, { "id": "656803b3-9dbb-4eb7-9f68-fa19b2696421", "name": "Compute Date Windows", "type": "code", "params": { "jsCode": "// Timezone-aware date windows using Luxon (available in n8n >= 0.214).\n// Add REPORT_TIMEZONE to your n8n environment variables, e.g. 'Europe/Helsinki'.\n// Falls back to UTC if the env var is absent.\nconst { DateTime } = require('luxon');\nconst tz = $env.REPORT_TIMEZONE || 'UTC';\n\n// 'today' in the business timezone at the moment the workflow runs (Monday 08:00).\n// today.weekday === 1 (ISO Monday). startOf('week') gives this week's Monday,\n// minus({ weeks: 1 }) steps back to last week's Monday.\nconst today = DateTime.now().setZone(tz);\nconst lastMonday = today.startOf('week').minus({ weeks: 1 });\nconst lastSunday = lastMonday.endOf('week'); // Sun 23:59:59.999 in business TZ\n\nconst fmt = dt => dt.toISODate(); // YYYY-MM-DD in chosen TZ\nconst toUnix = dt => Math.floor(dt.toMillis() / 1000);\n\nreturn [{ json: {\n weekLabel: `${fmt(lastMonday)} to ${fmt(lastSunday)}`,\n timezone: tz,\n thisWeek: {\n start: lastMonday.toISO(),\n end: lastSunday.toISO(),\n startUnix: toUnix(lastMonday),\n endUnix: toUnix(lastSunday),\n startMs: lastMonday.toMillis(),\n endMs: lastSunday.toMillis()\n }\n} }];" }, "position": [ 8960, 1808 ] }, { "id": "57e98e9a-9d2a-4865-a956-a7b6747230f6", "name": "Stripe: This Week Revenue", "type": "code", "params": { "jsCode": "const startUnix = $('Compute Date Windows').first().json.thisWeek.startUnix;\nconst endUnix = $('Compute Date Windows').first().json.thisWeek.endUnix;\nconst apiKey = $env.STRIPE_SECRET_KEY;\nconst PAGE_SIZE = 100;\nlet allCharges = [];\nlet startingAfter = null;\nlet hasMore = true;\nwhile (hasMore) {\n let url = `https://api.stripe.com/v1/charges?created[gte]=${startUnix}&created[lte]=${endUnix}&limit=${PAGE_SIZE}`;\n if (startingAfter) url += `&starting_after=${startingAfter}`;\n const resp = await $http.request({ method: 'GET', url, headers: { Authorization: `Bearer ${apiKey}` }, json: true });\n const page = resp.data || [];\n allCharges = allCharges.concat(page);\n hasMore = resp.has_more === true;\n if (hasMore && page.length > 0) { startingAfter = page[page.length - 1].id; } else { hasMore = false; }\n}\nreturn [{ json: { data: allCharges, has_more: false, object: 'list' } }];" }, "position": [ 9200, 1808 ] }, { "id": "14648e6a-5cba-40e2-a233-288d77851486", "name": "Notion: Pipeline This Week", "type": "code", "params": { "jsCode": "const dbId = $env.NOTION_DEALS_DB_ID;\nconst apiKey = $env.NOTION_API_KEY;\nconst startIso = $('Compute Date Windows').first().json.thisWeek.start;\nconst endIso = $('Compute Date Windows').first().json.thisWeek.end;\nconst headers = { Authorization: `Bearer ${apiKey}`, 'Content-Type': 'application/json', 'Notion-Version': '2022-06-28' };\nlet allPages = [];\nlet startCursor = undefined;\nlet hasMore = true;\nwhile (hasMore) {\n const body = { filter: { and: [{ property: 'Created', date: { on_or_after: startIso } }, { property: 'Created', date: { on_or_before: endIso } }] }, page_size: 100 };\n if (startCursor) body.start_cursor = startCursor;\n const resp = await $http.request({ method: 'POST', url: `https://api.notion.com/v1/databases/${dbId}/query`, headers, body: JSON.stringify(body), json: true });\n allPages = allPages.concat(resp.results || []);\n hasMore = resp.has_more === true;\n startCursor = resp.next_cursor || undefined;\n if (hasMore) await new Promise(r => setTimeout(r, 350));\n}\nconst results = allPages.map(page => { const p = page.properties || {}; return { id: page.id, properties: { amount: p['Deal Value']?.number ?? 0, dealstage: p['Stage']?.select?.name ?? 'unknown', hs_deal_stage_probability: p['Probability']?.number ?? 0, dealname: p['Name']?.title?.[0]?.plain_text ?? '' } }; });\nreturn [{ json: { results, has_more: false, object: 'list' } }];" }, "position": [ 9424, 1808 ] }, { "id": "34f6c853-7829-4336-b531-83d2d425f3d9", "name": "GSheets: Ops Metrics", "type": "integration", "params": { "options": { "dataLocationOnSheet": { "values": { "range": "={{ $env.GSHEETS_LAST_ROW_RANGE }}", "rangeDefinition": "specifyRangeA1" } } }, "service": "googleSheets", "operation": "read", "sheetName": { "mode": "name", "value": "={{ $env.GSHEETS_SHEET_NAME }}" }, "documentId": { "mode": "id", "value": "={{ $env.GSHEETS_SPREADSHEET_ID }}" } }, "position": [ 9648, 1808 ] }, { "id": "0d635913-c3d8-45a1-93fb-1357e888983e", "name": "Aggregate All Metrics", "type": "code", "params": { "jsCode": "const dates = $('Compute Date Windows').first().json;\nconst stripeData = $('Stripe: This Week Revenue').first().json;\nconst notionData = $('Notion: Pipeline This Week').first().json;\nconst sheetsItems = $('GSheets: Ops Metrics').all();\nconst charges = stripeData.data || [];\nconst grossRevenue = charges.filter(c => c.status === 'succeeded' && !c.refunded).reduce((s, c) => s + c.amount, 0) / 100;\nconst refunds = charges.filter(c => c.refunded).reduce((s, c) => s + (c.amount_refunded || 0), 0) / 100;\nconst netRevenue = grossRevenue - refunds;\nconst newCharges = charges.filter(c => c.status === 'succeeded').length;\nconst deals = notionData.results || [];\nconst pipelineValue = deals.reduce((s, d) => s + (d.properties?.amount || 0), 0);\nconst weightedValue = deals.reduce((s, d) => { const amt = d.properties?.amount || 0; const prob = d.properties?.hs_deal_stage_probability || 0; return s + (amt * prob / 100); }, 0);\nconst dealsByStage = deals.reduce((acc, d) => { const stage = d.properties?.dealstage || 'unknown'; acc[stage] = (acc[stage] || 0) + 1; return acc; }, {});\nconst latestOps = sheetsItems.length > 0 ? sheetsItems[sheetsItems.length - 1].json : {};\nreturn [{ json: { weekLabel: dates.weekLabel, revenue: { gross: grossRevenue.toFixed(2), refunds: refunds.toFixed(2), net: netRevenue.toFixed(2), transactions: newCharges }, pipeline: { dealsCreated: deals.length, totalValue: pipelineValue.toFixed(2), weightedValue: weightedValue.toFixed(2), byStage: dealsByStage }, ops: { ticketsClosed: latestOps.tickets_closed || 'N/A', npsScore: latestOps.nps_score || 'N/A', uptimePct: latestOps.uptime_pct || 'N/A', supportHours: latestOps.support_hours || 'N/A' }, generatedAt: new Date().toISOString() } }];" }, "position": [ 10112, 1808 ] }, { "id": "c7cf5900-f1db-4527-87c3-2cad1c069fea", "name": "Claude: Write Executive Narrative", "type": "llm", "params": { "text": "=You are a senior business analyst. Write a concise 3-paragraph executive narrative for a weekly business report. Be direct, data-driven, and highlight the most important trend. Use plain prose only — no bullet points, no headers.\n\nData for week {{ $('Aggregate All Metrics').first().json.weekLabel }}:\n\nREVENUE: Gross €{{ $('Aggregate All Metrics').first().json.revenue.gross }}, Net €{{ $('Aggregate All Metrics').first().json.revenue.net }}, Refunds €{{ $('Aggregate All Metrics').first().json.revenue.refunds }}, Transactions {{ $('Aggregate All Metrics').first().json.revenue.transactions }}\n\nPIPELINE: {{ $('Aggregate All Metrics').first().json.pipeline.dealsCreated }} new deals, total value €{{ $('Aggregate All Metrics').first().json.pipeline.totalValue }}, weighted €{{ $('Aggregate All Metrics').first().json.pipeline.weightedValue }}, stages: {{ JSON.stringify($('Aggregate All Metrics').first().json.pipeline.byStage) }}\n\nOPS: Tickets closed {{ $('Aggregate All Metrics').first().json.ops.ticketsClosed }}, NPS {{ $('Aggregate All Metrics').first().json.ops.npsScore }}, Uptime {{ $('Aggregate All Metrics').first().json.ops.uptimePct }}%\n\nParagraph 1: Revenue performance. Paragraph 2: Pipeline health. Paragraph 3: Operational highlights + one forward-looking observation.", "prompt": "=You are a senior business analyst. Write a concise 3-paragraph executive narrative for a weekly business report. Be direct, data-driven, and highlight the most important trend. Use plain prose only — no bullet points, no headers.\n\nData for week {{ $('Aggregate All Metrics').first().json.weekLabel }}:\n\nREVENUE: Gross €{{ $('Aggregate All Metrics').first().json.revenue.gross }}, Net €{{ $('Aggregate All Metrics').first().json.revenue.net }}, Refunds €{{ $('Aggregate All Metrics').first().json.revenue.refunds }}, Transactions {{ $('Aggregate All Metrics').first().json.revenue.transactions }}\n\nPIPELINE: {{ $('Aggregate All Metrics').first().json.pipeline.dealsCreated }} new deals, total value €{{ $('Aggregate All Metrics').first().json.pipeline.totalValue }}, weighted €{{ $('Aggregate All Metrics').first().json.pipeline.weightedValue }}, stages: {{ JSON.stringify($('Aggregate All Metrics').first().json.pipeline.byStage) }}\n\nOPS: Tickets closed {{ $('Aggregate All Metrics').first().json.ops.ticketsClosed }}, NPS {{ $('Aggregate All Metrics').first().json.ops.npsScore }}, Uptime {{ $('Aggregate All Metrics').first().json.ops.uptimePct }}%\n\nParagraph 1: Revenue performance. Paragraph 2: Pipeline health. Paragraph 3: Operational highlights + one forward-looking observation.", "provider": "openai", "promptType": "define", "approximated": true }, "position": [ 10288, 1808 ] }, { "id": "cdb7c087-ea94-4874-b803-4b7bae0bb8b2", "name": "Anthropic Chat Model", "type": "llm", "params": { "model": "claude-sonnet-4-20250514", "options": { "temperature": 0 }, "provider": "anthropic", "temperature": 0 }, "position": [ 10288, 1952 ] }, { "id": "b7c57bf4-351f-48e7-b87b-0d2310c95b41", "name": "Build HTML Report", "type": "code", "params": { "jsCode": "const metrics = $('Aggregate All Metrics').first().json;\nconst narrative = $input.first().json.text || 'Narrative unavailable.';\nconst stageRows = Object.entries(metrics.pipeline.byStage || {}).map(([s, c]) => `${s}${c}`).join('');\nconst html = `Report for ${metrics.weekLabel}`;\nreturn [{ json: { ...metrics, narrative, html } }];" }, "position": [ 10928, 1808 ] }, { "id": "afda275d-a83f-42ad-9817-849ca8f85491", "name": "Send via SendGrid", "type": "integration", "params": { "service": "sendgrid", "subject": "=📊 Weekly Business Report — {{ $json.weekLabel }}", "toEmail": "={{ $env.REPORT_EMAIL_TO }}", "fromName": "ProFlow Weekly Report", "resource": "mail", "fromEmail": "={{ $env.REPORT_EMAIL_FROM }}", "operation": "run", "contentType": "html", "__originalType": "n8n-nodes-base.sendGrid", "additionalFields": {} }, "position": [ 11152, 1808 ] }, { "id": "7d8918e8-83d3-45c2-b963-390d7868d86b", "name": "Slack: Report Sent", "type": "integration", "params": { "text": "=📊 Weekly report sent", "select": "channel", "service": "slack", "channelId": { "__rl": true, "mode": "id", "value": "={{ $env.SLACK_CHANNEL_ID }}" }, "operation": "read", "otherOptions": {} }, "position": [ 11376, 1808 ] }, { "id": "0a9061cb-fd11-42e3-813e-33d1e04c7de0", "name": "Workflow Error Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.errorTrigger" }, "position": [ 8720, 2256 ] }, { "id": "a4c7fe64-b130-4f7c-a850-27c1fb77bd2d", "name": "Send Error Email", "type": "integration", "params": { "service": "sendgrid", "subject": "=❌ Weekly Report Generation Failed [{{ $json.execution.id }}]", "toEmail": "={{ $env.REPORT_ALERT_EMAIL || $env.REPORT_EMAIL_FROM }}", "fromName": "ProFlow Automations", "resource": "mail", "fromEmail": "={{ $env.REPORT_EMAIL_FROM }}", "operation": "run", "contentType": "text", "__originalType": "n8n-nodes-base.sendGrid", "additionalFields": {} }, "position": [ 8928, 2256 ] } ] }

Generate a weekly business metrics report with Stripe, Notion, Sheets, Claude, SendGrid, and Slack