{ "edges": [ { "to": "68b88e1e-ed76-4d23-ae32-fac1578d0d2b", "from": "add0d731-f79d-4cc8-9367-52f598f33fda", "toPort": "0", "fromPort": "0" }, { "to": "7c719819-a5e7-46a6-a9e6-819159131340", "from": "add0d731-f79d-4cc8-9367-52f598f33fda", "toPort": "0", "fromPort": "1" }, { "to": "7c719819-a5e7-46a6-a9e6-819159131340", "from": "e8d24aa9-a5da-4447-a431-b1290a57586f", "toPort": "0", "fromPort": "0" }, { "to": "add0d731-f79d-4cc8-9367-52f598f33fda", "from": "e8d24aa9-a5da-4447-a431-b1290a57586f", "toPort": "0", "fromPort": "1" }, { "to": "e887c975-9a33-4c0d-baef-3c059867ef4a", "from": "f5658180-ef3d-43c8-b16e-cf9dbde033be", "toPort": "0", "fromPort": "0" }, { "to": "2b7ec32c-3d7b-4685-b557-4b5011ec6ab2", "from": "f5658180-ef3d-43c8-b16e-cf9dbde033be", "toPort": "0", "fromPort": "1" }, { "to": "f5658180-ef3d-43c8-b16e-cf9dbde033be", "from": "caf7082e-9e9e-42ef-97f1-ac31ca0972b7", "toPort": "0", "fromPort": "0" }, { "to": "caf7082e-9e9e-42ef-97f1-ac31ca0972b7", "from": "2dadc5a3-dc81-4bef-af44-bbac5a5bcd04", "toPort": "0", "fromPort": "0" }, { "to": "add0d731-f79d-4cc8-9367-52f598f33fda", "from": "e887c975-9a33-4c0d-baef-3c059867ef4a", "toPort": "0", "fromPort": "0" }, { "to": "e8d24aa9-a5da-4447-a431-b1290a57586f", "from": "2b7ec32c-3d7b-4685-b557-4b5011ec6ab2", "toPort": "0", "fromPort": "0" }, { "to": "2dadc5a3-dc81-4bef-af44-bbac5a5bcd04", "from": "e971f4f2-0d7d-4f28-a8cb-ebec3c8c30ba", "toPort": "0", "fromPort": "0" }, { "to": "7c719819-a5e7-46a6-a9e6-819159131340", "from": "68b88e1e-ed76-4d23-ae32-fac1578d0d2b", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "e971f4f2-0d7d-4f28-a8cb-ebec3c8c30ba", "name": "When Telegram Message Received", "type": "trigger", "params": { "kind": "n8n-nodes-base.telegramTrigger", "updates": [ "message", "callback_query" ], "additionalFields": {} }, "position": [ -880, 128 ] }, { "id": "2dadc5a3-dc81-4bef-af44-bbac5a5bcd04", "name": "Get Session from Supabase", "type": "integration", "params": { "filters": { "conditions": [ { "keyName": "chat_id", "keyValue": "={{ $json.message?.chat?.id?.toString() || $json.callback_query?.message?.chat?.id?.toString() }}" } ] }, "service": "supabase", "tableId": "sessions", "operation": "get" }, "position": [ -656, 128 ] }, { "id": "caf7082e-9e9e-42ef-97f1-ac31ca0972b7", "name": "Evaluate Feedback Logic", "type": "code", "params": { "jsCode": "const triggerData = $('When Telegram Message Received').first().json;\nlet dbData = $('Get Session from Supabase').first().json || {};\n\nif (Array.isArray(dbData)) {\n dbData = dbData[0] || {};\n}\n\nlet chatId = \"\";\nlet msg = \"\";\nlet isCallback = false;\n\nif (triggerData.callback_query) {\n chatId = triggerData.callback_query.message?.chat?.id?.toString();\n msg = triggerData.callback_query.data || \"\";\n isCallback = true;\n} else {\n chatId = triggerData.message?.chat?.id?.toString();\n msg = triggerData.message?.text || \"\";\n}\n\nif (!chatId) return { json: { stop: true } };\n\nlet currentState = dbData.state || \"START\";\nlet mode = dbData.mode || \"\";\nlet p1 = dbData.p1_data || \"\";\nlet p2 = dbData.p2_data || \"\";\n\nlet reply = \"\";\nlet nextState = \"\";\nlet showButtons = false;\nlet isComplete = false; \n\nconst recordExists = !!(dbData && dbData.chat_id);\n\nif (msg.toLowerCase().includes(\"/start\")) {\n currentState = \"START\";\n}\n\nswitch (currentState) {\n case \"START\":\n reply = \"Welcome! Choose: 🔮 Chart or 💞 Synastry?\";\n nextState = \"AWAITING_CHOICE\";\n showButtons = true;\n p1 = \"\";\n p2 = \"\";\n mode = \"\";\n break;\n\n case \"AWAITING_CHOICE\":\n if (msg.toLowerCase().includes(\"natal\") || msg.toLowerCase().includes(\"chart\") || msg.toLowerCase().includes(\"btn_natal\")) {\n mode = \"natal\";\n reply = \"🔮 Personal Chart Mode\\nSend your birth data (City, DD/MM/YYYY HH:mm):\";\n nextState = \"AWAITING_NATAL_DATA\";\n } else {\n mode = \"synastry\";\n reply = \"💞 Synastry Mode\\nSend Person 1 data (City, DD/MM/YYYY HH:mm):\";\n nextState = \"AWAITING_P1\";\n }\n showButtons = false;\n break;\n\n case \"AWAITING_NATAL_DATA\":\n p1 = msg;\n reply = `✨ Reading stars for your chart:\\n${p1}... ✨`;\n nextState = \"START\";\n showButtons = false;\n isComplete = true;\n break;\n\n case \"AWAITING_P1\":\n p1 = msg;\n reply = \"✅ Got Person 1 details.\\n\\n👉 Now send Person 2 data (City, DD/MM/YYYY HH:mm):\";\n nextState = \"AWAITING_P2\";\n showButtons = false;\n break;\n\n case \"AWAITING_P2\":\n p2 = msg;\n reply = `🌌 Comparing souls 🌌\\n\\n👤 P1: ${p1}\\n👤 P2: ${p2}\\n\\nAnalyzing cosmic matrices... ✨`;\n nextState = \"START\";\n showButtons = false;\n isComplete = true;\n break;\n}\n\nreturn {\n json: {\n chatId,\n reply,\n nextState,\n mode,\n p1_data: p1,\n p2_data: p2,\n showButtons,\n recordExists,\n isComplete,\n callbackQueryId: isCallback ? triggerData.callback_query.id : null\n }\n};" }, "position": [ -448, 128 ] }, { "id": "f5658180-ef3d-43c8-b16e-cf9dbde033be", "name": "Check If Record Exists", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "check_exists", "operator": { "type": "boolean", "operation": "true", "singleValue": true }, "leftValue": "={{ $json.recordExists }}", "rightValue": "" } ] } }, "position": [ -224, 128 ] }, { "id": "e887c975-9a33-4c0d-baef-3c059867ef4a", "name": "Update Session in Supabase", "type": "integration", "params": { "filters": { "conditions": [ { "keyName": "chat_id", "keyValue": "={{ $json.chatId }}", "condition": "eq" } ] }, "service": "supabase", "tableId": "sessions", "fieldsUi": { "fieldValues": [ { "fieldId": "state", "fieldValue": "={{ $json.nextState }}" }, { "fieldId": "mode", "fieldValue": "={{ $json.mode }}" }, { "fieldId": "p1_data", "fieldValue": "={{ $json.p1_data }}" }, { "fieldId": "p2_data", "fieldValue": "={{ $json.p2_data }}" } ] }, "operation": "update" }, "position": [ 0, 0 ] }, { "id": "2b7ec32c-3d7b-4685-b557-4b5011ec6ab2", "name": "Insert Session into Supabase", "type": "integration", "params": { "service": "supabase", "tableId": "sessions", "fieldsUi": { "fieldValues": [ { "fieldId": "chat_id", "fieldValue": "={{ $json.chatId }}" }, { "fieldId": "state", "fieldValue": "={{ $json.nextState }}" }, { "fieldId": "mode", "fieldValue": "={{ $json.mode }}" }, { "fieldId": "p1_data", "fieldValue": "={{ $json.p1_data }}" }, { "fieldId": "p2_data", "fieldValue": "={{ $json.p2_data }}" } ] }, "operation": "read" }, "position": [ 0, 240 ] }, { "id": "7c719819-a5e7-46a6-a9e6-819159131340", "name": "Send Telegram Reply", "type": "integration", "params": { "text": "={{ $('Evaluate Feedback Logic').item.json.reply }}", "chatId": "={{ $('Evaluate Feedback Logic').item.json.chatId }}", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML" } }, "position": [ 976, 128 ] }, { "id": "e8d24aa9-a5da-4447-a431-b1290a57586f", "name": "Check If Run Complete", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "is_complete", "operator": { "type": "boolean", "operation": "true", "singleValue": true }, "leftValue": "={{ $('Check If Record Exists').item.json.isComplete }}", "rightValue": "" } ] } }, "position": [ 288, 240 ] }, { "id": "68b88e1e-ed76-4d23-ae32-fac1578d0d2b", "name": "Log Reading History in Supabase", "type": "integration", "params": { "service": "supabase", "tableId": "astrology_readings", "fieldsUi": { "fieldValues": [ { "fieldId": "chat_id", "fieldValue": "={{ $json.chat_id }}" }, { "fieldId": "mode", "fieldValue": "={{ $json.mode }}" }, { "fieldId": "p1_data", "fieldValue": "={{ $json.p1_data }}" }, { "fieldId": "p2_data", "fieldValue": "={{ $json.p2_data }}" } ] }, "operation": "read" }, "position": [ 752, -16 ] }, { "id": "add0d731-f79d-4cc8-9367-52f598f33fda", "name": "Check for User Input", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "is_complete", "operator": { "type": "string", "operation": "notEmpty", "singleValue": true }, "leftValue": "={{ $json.p1_data }}", "rightValue": "" } ] } }, "position": [ 512, 0 ] } ] }

Collect astrology feedback with Telegram and Supabase