{ "edges": [ { "to": "7dbd4170-84e1-4e77-898c-7971cf8ce1b2", "from": "77ec08f8-209f-46af-a6b0-d25cd2b42ff8", "toPort": "0", "fromPort": "0" }, { "to": "b676b860-df5a-4bf8-bcf3-577de8f51d92", "from": "cf86ebd3-a3ac-4cef-abff-22feb7dcae25", "toPort": "0", "fromPort": "0" }, { "to": "34659554-53c2-4765-b445-8d5e29d15902", "from": "cf86ebd3-a3ac-4cef-abff-22feb7dcae25", "toPort": "0", "fromPort": "1" }, { "to": "cf86ebd3-a3ac-4cef-abff-22feb7dcae25", "from": "7e283ac8-8198-4adb-8a55-4ea15d9702f7", "toPort": "0", "fromPort": "0" }, { "to": "e5114a0a-febf-49a4-9f52-1838f4f1888d", "from": "6961f6ce-7802-4d71-9f6c-2c323fa93e97", "toPort": "0", "fromPort": "0" }, { "to": "6961f6ce-7802-4d71-9f6c-2c323fa93e97", "from": "c1335f24-0b2b-4d7e-8f0c-9a7f47f9ac31", "toPort": "0", "fromPort": "0" }, { "to": "77ec08f8-209f-46af-a6b0-d25cd2b42ff8", "from": "34659554-53c2-4765-b445-8d5e29d15902", "toPort": "0", "fromPort": "0" }, { "to": "77ec08f8-209f-46af-a6b0-d25cd2b42ff8", "from": "b676b860-df5a-4bf8-bcf3-577de8f51d92", "toPort": "0", "fromPort": "0" }, { "to": "c1335f24-0b2b-4d7e-8f0c-9a7f47f9ac31", "from": "c3888f4d-8abf-47a9-a09a-146707e151ce", "toPort": "1", "fromPort": "0" }, { "to": "3055e0a3-9cfb-4bf3-895c-2c1426188ed5", "from": "7dbd4170-84e1-4e77-898c-7971cf8ce1b2", "toPort": "0", "fromPort": "0" }, { "to": "df26a763-2db1-4101-a865-106025b2aee8", "from": "3055e0a3-9cfb-4bf3-895c-2c1426188ed5", "toPort": "0", "fromPort": "0" }, { "to": "c3888f4d-8abf-47a9-a09a-146707e151ce", "from": "3055e0a3-9cfb-4bf3-895c-2c1426188ed5", "toPort": "0", "fromPort": "0" }, { "to": "e3b2b041-172c-4128-aa89-70325128209b", "from": "e5114a0a-febf-49a4-9f52-1838f4f1888d", "toPort": "0", "fromPort": "0" }, { "to": "c1335f24-0b2b-4d7e-8f0c-9a7f47f9ac31", "from": "df26a763-2db1-4101-a865-106025b2aee8", "toPort": "0", "fromPort": "0" }, { "to": "7e283ac8-8198-4adb-8a55-4ea15d9702f7", "from": "84049e24-09cd-4b16-bc39-81682181df61", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "84049e24-09cd-4b16-bc39-81682181df61", "name": "Webhook - Receive Property Photo", "type": "trigger", "params": { "kind": "n8n-nodes-base.webhook", "path": "property-photo-publish", "options": { "allowedOrigins": "*" }, "httpMethod": "POST", "responseMode": "responseNode" }, "position": [ 672, 960 ] }, { "id": "7e283ac8-8198-4adb-8a55-4ea15d9702f7", "name": "Validate Payload", "type": "code", "params": { "jsCode": "const body = $input.first().json.body || $input.first().json;\n\n// ── Required fields ───────────────────────────────────────────\nconst listingId = String(body.listingId || '').trim();\nif (!listingId) throw new Error('listingId is required (e.g. LST-2025-0042).');\n\nconst address = String(body.address || '').trim();\nif (!address) throw new Error('address is required.');\n\nif (!body.fileUrl && !body.filename) {\n throw new Error('Provide fileUrl (remote photo) or filename (binary upload).');\n}\n\n// ── File type validation ──────────────────────────────────────\nconst filename = body.filename ||\n body.fileUrl?.split('?')[0].split('/').pop() ||\n 'photo.jpg';\nconst ext = filename.split('.').pop()?.toLowerCase() || 'jpg';\nconst allowedExts = ['jpg', 'jpeg', 'png', 'webp', 'heic', 'mp4', 'mov'];\nif (!allowedExts.includes(ext)) {\n throw new Error(`File type .${ext} not allowed. Accepted: ${allowedExts.join(', ')}`);\n}\nconst isVideo = ['mp4', 'mov'].includes(ext);\n\n// ── Price normalisation ───────────────────────────────────────\nconst price = parseFloat(String(body.price || '0').replace(/[^0-9.]/g, '')) || null;\n\n// ── Photo label: allow agent to tag what room this is ─────────\nconst photoLabel = String(body.photoLabel || '').trim() || null;\n\n// ── Structured filename for CDN ───────────────────────────────\nconst safeAddress = address.replace(/[^a-zA-Z0-9]/g, '-').slice(0, 40).toLowerCase();\nconst structuredFilename = `${listingId}_${safeAddress}_${Date.now()}.${ext}`;\n\nconst s = v => String(v || '').trim().slice(0, 500);\n\nreturn [{\n json: {\n listingId,\n address,\n price,\n propertyType: s(body.propertyType) || 'Residential',\n bedrooms: parseInt(body.bedrooms, 10) || null,\n bathrooms: parseFloat(body.bathrooms) || null,\n sqft: parseInt(body.sqft, 10) || null,\n photoLabel,\n isVideo,\n ext,\n filename,\n structuredFilename,\n fileUrl: body.fileUrl || null,\n agentName: s(body.agentName) || 'Unknown Agent',\n agentTelegram: s(body.agentTelegram),\n notes: s(body.notes),\n receivedAt: new Date().toISOString()\n }\n}];" }, "position": [ 816, 960 ] }, { "id": "cf86ebd3-a3ac-4cef-abff-22feb7dcae25", "name": "Has Remote URL?", "type": "if", "params": { "options": {}, "conditions": { "options": { "caseSensitive": false, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "cond-url", "operator": { "type": "string", "operation": "notEmpty" }, "leftValue": "={{ $json.fileUrl }}", "rightValue": "" } ] } }, "position": [ 944, 960 ] }, { "id": "b676b860-df5a-4bf8-bcf3-577de8f51d92", "name": "Upload to URL - Remote", "type": "integration", "params": { "service": "uploadtourl", "operation": "uploadFile", "__originalType": "n8n-nodes-uploadtourl.uploadToUrl" }, "position": [ 1104, 864 ] }, { "id": "34659554-53c2-4765-b445-8d5e29d15902", "name": "Upload to URL - Binary", "type": "integration", "params": { "service": "uploadtourl", "operation": "uploadFile", "__originalType": "n8n-nodes-uploadtourl.uploadToUrl" }, "position": [ 1104, 1024 ] }, { "id": "77ec08f8-209f-46af-a6b0-d25cd2b42ff8", "name": "Extract CDN URL", "type": "code", "params": { "jsCode": "const uploadResp = $input.first().json;\nconst meta = $('Validate Payload').first().json;\n\nconst cdnUrl =\n uploadResp.url ||\n uploadResp.link ||\n uploadResp.data?.url ||\n uploadResp.file?.url ||\n uploadResp.shortUrl;\n\nif (!cdnUrl) {\n throw new Error('UploadToURL returned no public URL. Raw: ' + JSON.stringify(uploadResp).slice(0, 300));\n}\n\nreturn [{\n json: {\n ...meta,\n cdnUrl: cdnUrl.replace(/^http:\\/\\//, 'https://'),\n uploadId: uploadResp.id || uploadResp.data?.id || null,\n fileSizeBytes: uploadResp.size || uploadResp.data?.size || null\n }\n}];" }, "position": [ 1264, 960 ] }, { "id": "7dbd4170-84e1-4e77-898c-7971cf8ce1b2", "name": "GPT-4o Vision - MLS Analysis", "type": "llm", "params": { "modelId": { "__rl": true, "mode": "list", "value": "ft:gpt-3.5-turbo-0125:bar-juice::91x6k9Fc", "cachedResultName": "FT:GPT-3.5-TURBO-0125:BAR-JUICE::91X6K9FC" }, "options": { "maxTokens": 700, "temperature": 0.3 }, "messages": { "values": [ { "role": "system", "content": "You are a licensed real estate appraiser and MLS listing specialist. Your job is to analyse property photos and produce structured, MLS-compliant descriptions. Return ONLY a valid JSON object — no markdown, no preamble." }, { "content": "=Analyse this property photo for a real estate MLS listing.\n\nPhoto URL: {{ $json.cdnUrl }}\nProperty Type: {{ $json.propertyType }}\nAddress: {{ $json.address }}\nAgent-provided room label (may be empty): {{ $json.photoLabel || 'Not provided' }}\nIs video walkthrough: {{ $json.isVideo }}\n\nReturn ONLY this JSON:\n{\n \"roomType\": \"Exact room name: Kitchen, Master Bedroom, Living Room, Exterior Front, Backyard, Bathroom, Garage, etc.\",\n \"conditionScore\": 8,\n \"conditionLabel\": \"Excellent | Good | Fair | Poor\",\n \"mlsDescription\": \"2-3 sentence MLS-ready room description using professional real estate language\",\n \"featureTags\": [\"hardwood floors\", \"crown molding\", \"natural light\"],\n \"pricingSignals\": [\"premium finishes\", \"updated appliances\"],\n \"lightingType\": \"Natural | Artificial | Mixed\",\n \"lightingQuality\": \"Poor | Fair | Good | Excellent\",\n \"altText\": \"SEO-optimised alt text for this photo\",\n \"isExterior\": false,\n \"featuredImageScore\": 7,\n \"renovationVisible\": false,\n \"estimatedRenovationAge\": \"5-10 years | Recent | Original | Unknown\"\n}" } ] }, "provider": "openai", "maxTokens": 700, "temperature": 0.3 }, "position": [ 1392, 960 ] }, { "id": "3055e0a3-9cfb-4bf3-895c-2c1426188ed5", "name": "Parse Vision & Build Payloads", "type": "code", "params": { "jsCode": "const aiRaw = $input.first().json;\nconst meta = $('Extract CDN URL').first().json;\n\n// ── Parse Vision response ─────────────────────────────────────\nlet vision;\ntry {\n const raw =\n aiRaw.message?.content ||\n aiRaw.choices?.[0]?.message?.content ||\n aiRaw.content ||\n aiRaw.text;\n vision = typeof raw === 'string' ? JSON.parse(raw) : raw;\n} catch (e) {\n throw new Error('Failed to parse GPT-4o Vision JSON: ' + e.message);\n}\n\nif (!vision.roomType) throw new Error('Vision did not return a room type.');\n\n// ── Price formatter ───────────────────────────────────────────\nconst priceFormatted = meta.price\n ? meta.price.toLocaleString('en-US', { style: 'currency', currency: 'USD', maximumFractionDigits: 0 })\n : 'Price on request';\n\n// ── WordPress post title & content ───────────────────────────\nconst wpTitle = `${meta.propertyType} — ${meta.address}${meta.price ? ' — ' + priceFormatted : ''}`;\n\nconst wpContent = [\n `\\n

${vision.roomType}

\\n`,\n `\\n

${vision.mlsDescription}

\\n`,\n vision.featureTags?.length\n ? `\\n

${f}

\\n`\n : '',\n `\\n

\"${vision.altText}\" — ${vision.roomType} — ${meta.address}

\\n`,\n meta.notes ? `\\n

Agent notes: ${meta.notes}

\\n` : ''\n].filter(Boolean).join('\\n\\n');\n\n// ── Airtable fields ───────────────────────────────────────────\nconst airtableRecord = {\n 'Listing ID': meta.listingId,\n 'Address': meta.address,\n 'Price': meta.price,\n 'Price Formatted': priceFormatted,\n 'Property Type': meta.propertyType,\n 'Bedrooms': meta.bedrooms,\n 'Bathrooms': meta.bathrooms,\n 'Sqft': meta.sqft,\n 'Room Type': vision.roomType,\n 'Condition Score': vision.conditionScore,\n 'Condition Label': vision.conditionLabel,\n 'MLS Description': vision.mlsDescription,\n 'Feature Tags': (vision.featureTags || []).join(', '),\n 'Pricing Signals': (vision.pricingSignals || []).join(', '),\n 'Lighting Type': vision.lightingType,\n 'Lighting Quality': vision.lightingQuality,\n 'Photo URL': meta.cdnUrl,\n 'Alt Text': vision.altText,\n 'Is Exterior': vision.isExterior || false,\n 'Featured Score': vision.featuredImageScore,\n 'Renovation Visible': vision.renovationVisible || false,\n 'Renovation Age': vision.estimatedRenovationAge || 'Unknown',\n 'Agent': meta.agentName,\n 'Status': 'Draft',\n 'Created At': meta.receivedAt\n};\n\nreturn [{\n json: {\n ...meta,\n // Vision output\n roomType: vision.roomType,\n conditionScore: vision.conditionScore,\n conditionLabel: vision.conditionLabel,\n mlsDescription: vision.mlsDescription,\n featureTags: vision.featureTags || [],\n pricingSignals: vision.pricingSignals || [],\n lightingType: vision.lightingType,\n lightingQuality: vision.lightingQuality,\n altText: vision.altText,\n isExterior: vision.isExterior || false,\n featuredImageScore: vision.featuredImageScore,\n renovationVisible: vision.renovationVisible || false,\n // Computed\n priceFormatted,\n wpTitle,\n wpContent,\n airtableRecord\n }\n}];" }, "position": [ 1664, 960 ] }, { "id": "df26a763-2db1-4101-a865-106025b2aee8", "name": "WordPress - Create Draft Post", "type": "http", "params": { "url": "={{ $vars.WP_BASE_URL }}/wp-json/wp/v2/posts", "method": "POST", "options": { "timeout": 15000, "response": { "response": { "responseFormat": "json" } } }, "jsonBody": "={\n \"title\": {{ JSON.stringify($json.wpTitle) }},\n \"content\": {{ JSON.stringify($json.wpContent) }},\n \"status\": \"draft\",\n \"meta\": {\n \"listing_id\": {{ JSON.stringify($json.listingId) }},\n \"property_address\": {{ JSON.stringify($json.address) }},\n \"property_price\": {{ JSON.stringify($json.priceFormatted) }},\n \"property_type\": {{ JSON.stringify($json.propertyType) }},\n \"room_type\": {{ JSON.stringify($json.roomType) }},\n \"condition_score\": {{ JSON.stringify(String($json.conditionScore || '')) }},\n \"feature_tags\": {{ JSON.stringify($json.featureTags.join(', ')) }},\n \"photo_cdn_url\": {{ JSON.stringify($json.cdnUrl) }},\n \"agent_name\": {{ JSON.stringify($json.agentName) }}\n }\n}", "sendBody": true, "specifyBody": "json", "authentication": "genericCredentialType", "genericAuthType": "httpBasicAuth" }, "position": [ 1904, 848 ] }, { "id": "c3888f4d-8abf-47a9-a09a-146707e151ce", "name": "Airtable - Create MLS Record", "type": "integration", "params": { "base": { "__rl": true, "mode": "list", "value": "" }, "table": { "__rl": true, "mode": "list", "value": "" }, "columns": { "value": "={{ $json.airtableRecord }}", "mappingMode": "autoMapInputData" }, "options": {}, "service": "airtable", "operation": "create" }, "position": [ 1920, 1056 ] }, { "id": "c1335f24-0b2b-4d7e-8f0c-9a7f47f9ac31", "name": "Merge Platform Results", "type": "merge", "params": { "mode": "combine", "options": {} }, "position": [ 2224, 960 ] }, { "id": "6961f6ce-7802-4d71-9f6c-2c323fa93e97", "name": "Build Unified Response", "type": "code", "params": { "jsCode": "// Both inputs arrive as a combined item from Merge\nconst merged = $input.first().json;\n\n// WordPress result is in input[0], Airtable in input[1]\n// With multiplex merge both are accessible\nconst wpResult = $('WordPress - Create Draft Post').first().json;\nconst atResult = $('Airtable - Create MLS Record').first().json;\nconst vision = $('Parse Vision & Build Payloads').first().json;\n\n// ── WordPress ─────────────────────────────────────────────────\nconst wpPostId = wpResult.id || null;\nconst wpEditUrl = wpPostId\n ? `${$vars.WP_BASE_URL}/wp-admin/post.php?post=${wpPostId}&action=edit`\n : null;\nconst wpPreviewUrl = wpResult.link || null;\n\n// ── Airtable ──────────────────────────────────────────────────\nconst airtableRecordId = atResult.id || null;\nconst airtableUrl = airtableRecordId\n ? `https://airtable.com/${$vars.AIRTABLE_BASE_ID}/${$vars.AIRTABLE_TABLE_NAME}/${airtableRecordId}`\n : null;\n\nreturn [{\n json: {\n success: true,\n listingId: vision.listingId,\n address: vision.address,\n priceFormatted: vision.priceFormatted,\n propertyType: vision.propertyType,\n agentName: vision.agentName,\n agentTelegram: vision.agentTelegram,\n // Photo\n cdnUrl: vision.cdnUrl,\n roomType: vision.roomType,\n conditionScore: vision.conditionScore,\n conditionLabel: vision.conditionLabel,\n featureTags: vision.featureTags,\n mlsDescription: vision.mlsDescription,\n lightingType: vision.lightingType,\n lightingQuality: vision.lightingQuality,\n isExterior: vision.isExterior,\n // WordPress\n wpPostId,\n wpEditUrl,\n wpPreviewUrl,\n // Airtable\n airtableRecordId,\n airtableUrl,\n // Meta\n publishedAt: new Date().toISOString()\n }\n}];" }, "position": [ 2400, 1008 ] }, { "id": "e5114a0a-febf-49a4-9f52-1838f4f1888d", "name": "Telegram - Agent Confirmation", "type": "integration", "params": { "text": "=🏠 *Property Photo Published*\n\n📍 *{{ $json.address }}*\n🏷 Listing ID: `{{ $json.listingId }}`\n💰 {{ $json.priceFormatted }} · {{ $json.propertyType }}\n\n📸 *Room Analysis*\n🛋 Room: {{ $json.roomType }}{{ $json.isExterior ? ' (Exterior)' : '' }}\n⭐ Condition: {{ $json.conditionScore }}/10 — {{ $json.conditionLabel }}\n💡 Lighting: {{ $json.lightingType }} / {{ $json.lightingQuality }}\n🏷 Tags: {{ $json.featureTags.slice(0, 4).join(', ') }}\n\n📝 _{{ $json.mlsDescription }}_\n\n🔗 *Published to:*\n• [WordPress Draft]({{ $json.wpEditUrl }})\n• [Airtable MLS Record]({{ $json.airtableUrl }})\n• [Photo CDN]({{ $json.cdnUrl }})\n\n👤 {{ $json.agentName }}{{ $json.agentTelegram ? ' (' + $json.agentTelegram + ')' : '' }}", "chatId": "={{ $vars.TELEGRAM_CHAT_ID }}", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "Markdown", "disable_web_page_preview": false } }, "position": [ 2560, 960 ] }, { "id": "e3b2b041-172c-4128-aa89-70325128209b", "name": "Respond to Webhook", "type": "passthrough", "params": { "mode": "noOp", "options": { "responseCode": 201, "responseHeaders": { "entries": [ { "name": "Content-Type", "value": "application/json" } ] } }, "respondWith": "json", "responseBody": "={{ $('Build Unified Response').first().json }}" }, "position": [ 2736, 960 ] } ] }

List properties instantly with UploadToURL, OpenAI Vision, WordPress and Airtable