{ "edges": [ { "to": "93de7d46-3e11-4903-ab93-8c58f9b3efa5", "from": "7cde8f21-7e07-410c-b2f1-7ca204b9042d", "toPort": "0", "fromPort": "0" }, { "to": "bcb59745-6c33-420e-a70e-15fef91900f9", "from": "6ac0e86a-5336-4326-a1b0-5db73ee2f924", "toPort": "0", "fromPort": "0" }, { "to": "78e17588-e44e-4b86-8571-d945004d9943", "from": "93de7d46-3e11-4903-ab93-8c58f9b3efa5", "toPort": "0", "fromPort": "0" }, { "to": "7cde8f21-7e07-410c-b2f1-7ca204b9042d", "from": "8387c800-bf91-4158-9bb9-e8254c60b405", "toPort": "0", "fromPort": "0" }, { "to": "415e89f6-fc09-4a80-ba09-66b0ab337b72", "from": "52f9fe22-75d3-4658-b1fc-91bf6f353c38", "toPort": "0", "fromPort": "0" }, { "to": "52f9fe22-75d3-4658-b1fc-91bf6f353c38", "from": "78e17588-e44e-4b86-8571-d945004d9943", "toPort": "0", "fromPort": "0" }, { "to": "6ac0e86a-5336-4326-a1b0-5db73ee2f924", "from": "c12f903e-7915-47f8-b3e4-f8b802f288e6", "toPort": "0", "fromPort": "0" }, { "to": "8387c800-bf91-4158-9bb9-e8254c60b405", "from": "bcb59745-6c33-420e-a70e-15fef91900f9", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "bcb59745-6c33-420e-a70e-15fef91900f9", "name": "📝 Prepare Messages", "type": "code", "params": { "jsCode": "// ═══════════════════════════════════════════\n// PREPARE STANDUP MESSAGES + READ HISTORY\n// One item per team member\n// ═══════════════════════════════════════════\n\nconst config = $input.first().json;\nconst chatIds = config.team_chat_ids.split(',').map(s => s.trim()).filter(Boolean);\nconst names = config.team_names.split(',').map(s => s.trim()).filter(Boolean);\n\nconst today = new Date();\nconst standupId = 'standup_' + today.toISOString().substring(0, 10).replace(/-/g, '');\nconst standupDate = today.toISOString();\nconst dateStr = today.toLocaleDateString('en-US', {\n weekday: 'long', year: 'numeric', month: 'long', day: 'numeric',\n});\n\nconst message = [\n `📋 Weekly Standup — ${dateStr}\\n`,\n `Hi! Please reply to this message with your update:\\n`,\n `1. ${config.question_1}`,\n `2. ${config.question_2}`,\n `3. ${config.question_3}\\n`,\n `Reply directly in this chat. Have a great week! 💪`,\n].join('\\n');\n\nreturn chatIds.map((id, i) => ({\n json: {\n standup_id: standupId,\n standup_date: standupDate,\n chat_id: id,\n name: names[i] || `Member ${i + 1}`,\n message: message,\n }\n}));" }, "position": [ 1056, 2192 ] }, { "id": "8387c800-bf91-4158-9bb9-e8254c60b405", "name": "📲 Send to Team", "type": "integration", "params": { "text": "={{ $json.message }}", "chatId": "={{ $json.chat_id }}", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML" } }, "position": [ 1280, 2192 ] }, { "id": "7cde8f21-7e07-410c-b2f1-7ca204b9042d", "name": "💾 Log Sent", "type": "integration", "params": { "columns": { "value": {}, "schema": [ { "id": "standup_id", "type": "string", "display": true, "removed": false, "required": false, "displayName": "standup_id", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "date", "type": "string", "display": true, "removed": false, "required": false, "displayName": "date", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "chat_id", "type": "string", "display": true, "removed": false, "required": false, "displayName": "chat_id", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "name", "type": "string", "display": true, "removed": false, "required": false, "displayName": "name", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "sent", "type": "string", "display": true, "removed": false, "required": false, "displayName": "sent", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "ok", "type": "string", "display": true, "removed": false, "required": false, "displayName": "ok", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "result", "type": "string", "display": true, "removed": false, "required": false, "displayName": "result", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "autoMapInputData", "matchingColumns": [], "attemptToConvertTypes": false, "convertFieldsToString": false }, "options": {}, "service": "googleSheets", "operation": "append", "sheetName": { "__rl": true, "mode": "name", "value": "Standup_Log" }, "documentId": { "__rl": true, "mode": "url", "value": "" } }, "position": [ 1504, 2192 ] }, { "id": "93de7d46-3e11-4903-ab93-8c58f9b3efa5", "name": "⏳ Wait 4 Hours", "type": "passthrough", "params": { "mode": "noOp", "unit": "hours", "amount": 4 }, "position": [ 1728, 2192 ] }, { "id": "78e17588-e44e-4b86-8571-d945004d9943", "name": "📥 Fetch Responses", "type": "code", "params": { "jsCode": "// ═══════════════════════════════════════════\n// FETCH RECENT MESSAGES FROM TELEGRAM\n// Uses getUpdates to find replies sent\n// during the wait period\n// ═══════════════════════════════════════════\n\nconst config = $('⚙️ Settings').first().json;\nconst chatIds = config.team_chat_ids.split(',').map(s => s.trim());\nconst names = config.team_names.split(',').map(s => s.trim());\n\nconst prepared = $('📝 Prepare Messages').all();\nconst standupId = prepared[0]?.json?.standup_id || 'unknown';\nconst standupDate = prepared[0]?.json?.standup_date || new Date().toISOString();\nconst standupTime = new Date(standupDate);\n\nlet botToken = '';\ntry {\n botToken = config.telegram_bot_token || '';\n} catch (e) {}\n\nif (!botToken) {\n return [{ json: {\n standup_id: standupId,\n standup_date: standupDate,\n responses: [],\n missing: names,\n total_team: chatIds.length,\n response_count: 0,\n note: 'Add telegram_bot_token to Settings to auto-collect responses, or just send the AI summary based on what is in the chat manually.',\n } }];\n}\n\ntry {\n const r = await this.helpers.httpRequest({\n method: 'GET',\n url: `https://api.telegram.org/bot${botToken}/getUpdates`,\n qs: { limit: 100, timeout: 0 },\n timeout: 10000,\n });\n \n const updates = r.result || [];\n const responses = [];\n const responded = new Set();\n \n for (let i = updates.length - 1; i >= 0; i--) {\n const u = updates[i];\n const msg = u.message;\n if (!msg || !msg.text) continue;\n \n const fromId = String(msg.from?.id || '');\n const idx = chatIds.indexOf(fromId);\n if (idx === -1 || responded.has(fromId)) continue;\n \n const msgDate = new Date((msg.date || 0) * 1000);\n if (msgDate < standupTime) continue;\n \n if (msg.text.startsWith('/')) continue;\n if (msg.text.includes('Weekly Standup') && msg.text.includes('Reply directly')) continue;\n \n responded.add(fromId);\n responses.push({\n name: names[idx] || `Member ${idx + 1}`,\n response: msg.text,\n responded_at: msgDate.toISOString(),\n });\n }\n \n const missing = chatIds\n .map((id, i) => ({ id, name: names[i] || id }))\n .filter(m => !responded.has(m.id))\n .map(m => m.name);\n \n return [{ json: {\n standup_id: standupId,\n standup_date: standupDate,\n responses: responses,\n missing: missing,\n total_team: chatIds.length,\n response_count: responses.length,\n } }];\n \n} catch (err) {\n return [{ json: {\n standup_id: standupId,\n standup_date: standupDate,\n responses: [],\n missing: names,\n total_team: chatIds.length,\n response_count: 0,\n error: err.message,\n } }];\n}" }, "position": [ 1952, 2192 ] }, { "id": "c12f903e-7915-47f8-b3e4-f8b802f288e6", "name": "⏰ Every Monday 9 AM", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "cronExpression", "expression": "0 9 * * 1" } ] } }, "position": [ 608, 2192 ] }, { "id": "6ac0e86a-5336-4326-a1b0-5db73ee2f924", "name": "⚙️ Settings", "type": "set", "params": { "options": {}, "assignments": { "assignments": [ { "id": "field-team-ids", "name": "team_chat_ids", "type": "string", "value": "123456789,987654321,555555555" }, { "id": "field-team-names", "name": "team_names", "type": "string", "value": "Ahmad,Sarah" }, { "id": "field-lead-id", "name": "team_lead_chat_id", "type": "string", "value": "123456789" }, { "id": "field-q1", "name": "question_1", "type": "string", "value": "✅ What did you accomplish last week?" }, { "id": "field-q2", "name": "question_2", "type": "string", "value": "📋 What's planned for this week?" }, { "id": "field-q3", "name": "question_3", "type": "string", "value": "🚧 Any blockers or issues?" }, { "id": "field-groq-key", "name": "groq_api_key", "type": "string", "value": "PASTE_YOUR_GROQ_KEY_HERE" }, { "id": "987aa1ca-3995-4f53-a29d-dac09d816fe1", "name": "telegram_bot_token", "type": "string", "value": "PASTE_YOUR_BOT_TOKEN_HERE" } ] } }, "position": [ 832, 2192 ] }, { "id": "52f9fe22-75d3-4658-b1fc-91bf6f353c38", "name": "🤖 AI Summarize", "type": "code", "params": { "jsCode": "// ═══════════════════════════════════════════\n// AI SUMMARIZE STANDUP via Groq\n// Smart retry on rate limit\n// ═══════════════════════════════════════════\n\nconst config = $('⚙️ Settings').first().json;\nconst data = $input.first().json;\nconst responses = data.responses || [];\nconst missing = data.missing || [];\n\nlet aiSummary = '';\nlet retriesUsed = 0;\n\nif (responses.length === 0) {\n aiSummary = `⚠️ No responses collected this week.\\n\\nMissing: ${missing.join(', ')}\\n\\nNote: ${data.note || 'Team members may not have replied yet.'}`;\n} else {\n let context = '';\n for (const r of responses) {\n context += `\\n${r.name}:\\n${r.response}\\n`;\n }\n\n const prompt = `You are a team standup summarizer. Below are individual standup updates from ${responses.length} team members. Create a concise executive summary in this exact format:\\n\\n📌 KEY ACCOMPLISHMENTS LAST WEEK\\n- [bullet point 1]\\n- [bullet point 2]\\n- [bullet point 3]\\n\\n🎯 THIS WEEK'S PLAN\\n- [bullet point 1]\\n- [bullet point 2]\\n- [bullet point 3]\\n\\n🚧 BLOCKERS & RISKS\\n- [list any blockers, or write \\\"None reported\\\"]\\n\\n💪 TEAM HEALTH\\n[One sentence assessment: on track / needs attention / at risk]\\n\\nIndividual updates:\\n${context}`;\n\n const maxRetries = 2;\n for (let attempt = 0; attempt <= maxRetries; attempt++) {\n try {\n const r = await this.helpers.httpRequest({\n method: 'POST',\n url: 'https://api.groq.com/openai/v1/chat/completions',\n headers: {\n 'Authorization': 'Bearer ' + config.groq_api_key,\n 'Content-Type': 'application/json',\n },\n body: {\n model: 'llama-3.1-8b-instant',\n messages: [{ role: 'user', content: prompt }],\n temperature: 0.3,\n max_tokens: 800,\n },\n timeout: 30000,\n });\n aiSummary = r.choices?.[0]?.message?.content || 'AI summary generation failed.';\n break;\n } catch (err) {\n retriesUsed = attempt + 1;\n const is429 = (err.message || '').includes('429');\n if (is429 && attempt < maxRetries) {\n await new Promise(r => setTimeout(r, 5000));\n continue;\n }\n aiSummary = `⚠️ AI summary unavailable.\\n\\nRaw responses:\\n${context}`;\n break;\n }\n }\n}\n\nconst dateStr = new Date(data.standup_date).toLocaleDateString('en-US', {\n weekday: 'long', year: 'numeric', month: 'long', day: 'numeric',\n});\n\nlet finalMessage = `📋 Weekly Standup Summary\\n`;\nfinalMessage += `📅 ${dateStr}\\n`;\nfinalMessage += `👥 Responded: ${responses.length}/${data.total_team}\\n`;\nif (missing.length > 0 && responses.length > 0) {\n finalMessage += `⚠️ Missing: ${missing.join(', ')}\\n`;\n}\nfinalMessage += `\\n${aiSummary}`;\n\nreturn [{ json: {\n ...data,\n ai_summary: aiSummary,\n final_message: finalMessage,\n team_lead_chat_id: config.team_lead_chat_id,\n} }];" }, "position": [ 2176, 2192 ] }, { "id": "415e89f6-fc09-4a80-ba09-66b0ab337b72", "name": "📲 Send Summary to Lead", "type": "integration", "params": { "text": "={{ $json.final_message }}", "chatId": "={{ $json.team_lead_chat_id }}", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML" } }, "position": [ 2400, 2192 ] } ] }

Run weekly standups with Groq AI summaries via Telegram and Google Sheets