All AI Tools Included

{
  "nodes": [
    {
      "parameters": {
        "path": "phone-rotation-sheet",
        "responseMode": "responseNode",
        "options": {}
      },
      "type": "n8n-nodes-base.webhook",
      "typeVersion": 2.1,
      "position": [-2800, 16],
      "id": "3aa8788c-0c4d-403c-805a-92cb00c28411",
      "name": "Webhook",
      "webhookId": "c65edec7-103e-4a7e-b1c6-bb8d26af32d8"
    },
    {
      "parameters": {
        "options": {
          "responseHeaders": {
            "entries": [
              {
                "name": "phoneNumbers",
                "value": "={{ $json.Phonenumber }}"
              }
            ]
          },
          "responseKey": "data"
        }
      },
      "type": "n8n-nodes-base.respondToWebhook",
      "typeVersion": 1.4,
      "position": [544, 0],
      "id": "0562b4cd-59bb-4871-ae60-7c72c6398c44",
      "name": "Respond to Webhook"
    },
    {
      "parameters": {
        "url": "https://api.retellai.com/list-phone-numbers",
        "authentication": "predefinedCredentialType",
        "nodeCredentialType": "httpBearerAuth",
        "options": {}
      },
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [-2592, 16],
      "id": "d97b6728-bcc2-484d-8ef9-1538edec8cf6",
      "name": "HTTP Request1",
      "credentials": {
        "httpBearerAuth": {
          "id": "vuYEQdSpNVAFaeys",
          "name": "Retell Api (Michael poggi)"
        }
      }
    },
    {
      "parameters": {
        "jsCode": "// Simplify Google Sheet data\n// items = all rows from Google Sheet node\nconst sheetData = items.map(row => ({\n  phoneNumber: String(row.json.Phonenumber).trim().startsWith('+') \n                 ? String(row.json.Phonenumber).trim() \n                 : '+' + String(row.json.Phonenumber).trim()\n}));\n\nreturn [\n  {\n    json: {\n      sheetData // output a single array of all sheet numbers\n    }\n  }\n];\n"
      },
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [-1968, 16],
      "id": "91707983-be81-4c47-9995-896ae2d5a7b8",
      "name": "simplify sheet data",
      "alwaysOutputData": false,
      "onError": "continueRegularOutput"
    },
    {
      "parameters": {
        "jsCode": "const apiData = $('Code').first().json.data || []; // API numbers\nconst sheetData = $input.first().json.sheetData || []; // sheet numbers\n\n// Normalize a phone number to digits only\nfunction normalize(num) {\n    return String(num || '').replace(/\\D/g, '');\n}\n\n// Extract existing sheet numbers as digits\nconst sheetNumbers = sheetData.map(row => normalize(row.phoneNumber)).filter(n => n);\n\n// Filter API numbers to only new numbers\nlet newNumbers = apiData\n    .map(n => ({ phoneNumber: n.phoneNumber }))\n    .filter(n => !sheetNumbers.includes(normalize(n.phoneNumber)));\n\n// Format with + sign\nnewNumbers = newNumbers.map(n => ({ json: { phoneNumber: '+' + normalize(n.phoneNumber), isNew: true } }));\n\n// If no new numbers, still pass something forward so flow continues\nif (newNumbers.length === 0) {\n    newNumbers.push({ json: { phoneNumber: null, isNew: false } });\n}\n\nreturn newNumbers;\n"
      },
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [-1760, 16],
      "id": "a5947021-c02c-4565-bfd3-cab6dd723e00",
      "name": "Filtering code",
      "alwaysOutputData": false,
      "retryOnFail": false,
      "onError": "continueRegularOutput"
    },
    {
      "parameters": {
        "jsCode": "// === CONFIG ===\nconst DAILY_LIMIT = 50;        // Max calls per number per day\nconst COOLDOWN_MINUTES = 8;    // Cooldown between calls (minutes)\n\n// Create 'now' in Eastern Time (ET) — automatically adjusts for daylight saving\nconst nowUTC = new Date();\nconst now = new Date(nowUTC.toLocaleString(\"en-US\", { timeZone: \"America/New_York\" }));\n\n// --- Helper: check if it's a new day (based on ET) ---\nfunction isNewDay(lastUsed) {\n    if (!lastUsed) return false;\n    const last = new Date(lastUsed);\n    // Compare only date strings in Eastern Time context\n    const lastET = new Date(last.toLocaleString(\"en-US\", { timeZone: \"America/New_York\" }));\n    return now.toDateString() !== lastET.toDateString();\n}\n\n// --- Map sheet rows into objects ---\nlet numbers = items.map(item => {\n    let callsToday = Number(item.json.callsToday || 0);\n    let disabled = item.json.disabled === true || item.json.disabled === 'TRUE';\n    let lastUsed = item.json.lastUsed ? new Date(item.json.lastUsed) : null;\n\n    // Reset callsToday and re-enable if a new day has started (in ET)\n    if (isNewDay(lastUsed)) {\n        callsToday = 0;\n        disabled = false;\n    }\n\n    // Auto-disable if daily limit reached\n    if (callsToday >= DAILY_LIMIT) disabled = true;\n\n    return {\n        rowIndex: item.json.rowIndex,\n        phoneNumber: item.json.Phonenumber,\n        callsToday,\n        lastUsed,\n        disabled\n    };\n});\n\n// --- Filter eligible numbers ---\nlet eligible = numbers.filter(n =>\n    !n.disabled &&\n    (!n.lastUsed || (now - n.lastUsed) / 60000 >= COOLDOWN_MINUTES)\n);\n\nlet output;\n\nif (eligible.length === 0) {\n    // No eligible numbers right now\n    output = [{\n        json: {\n            eligible: false,\n            chosenPhone: null,\n            callsToday: null,\n            lastUsed: null,\n            rowIndex: null,\n            disabled: null,\n            message: \"No eligible numbers available right now\"\n        }\n    }];\n} else {\n    // Pick the oldest lastUsed (FIFO)\n    eligible.sort((a, b) => (a.lastUsed || new Date(0)) - (b.lastUsed || new Date(0)));\n    const chosen = eligible[0];\n\n    // Increment callsToday and update lastUsed timestamp\n    chosen.callsToday += 1;\n    chosen.lastUsed = now;\n\n    // Disable if DAILY_LIMIT reached after increment\n    if (chosen.callsToday >= DAILY_LIMIT) chosen.disabled = true;\n\n    output = [{\n        json: {\n            eligible: true,\n            chosenPhone: chosen.phoneNumber,\n            callsToday: chosen.callsToday,\n            lastUsed: chosen.lastUsed.toISOString(),\n            rowIndex: chosen.rowIndex,\n            disabled: chosen.disabled,\n            message: \"Number selected successfully\"\n        }\n    }];\n}\n\nreturn output;\n"
      },
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [-512, 16],
      "id": "26f32b37-ba82-45df-b2c7-d73c40af005d",
      "name": "Code1"
    },
    {
      "parameters": {
        "operation": "appendOrUpdate",
        "documentId": {
          "__rl": true,
          "value": "1rHa3EMYFJ9w5hIrmLw8RZF-ky9J2O6e58d6Z45fZiv8",
          "mode": "list",
          "cachedResultName": "Retell AI Number Rotation Sheet The Millionaires Real-Estate Investment Group",
          "cachedResultUrl": "https://docs.google.com/spreadsheets/d/1rHa3EMYFJ9w5hIrmLw8RZF-ky9J2O6e58d6Z45fZiv8/edit?usp=drivesdk"
        },
        "sheetName": {
          "__rl": true,
          "value": "gid=0",
          "mode": "list",
          "cachedResultName": "Sheet1",
          "cachedResultUrl": "https://docs.google.com/spreadsheets/d/1rHa3EMYFJ9w5hIrmLw8RZF-ky9J2O6e58d6Z45fZiv8/edit#gid=0"
        },
        "columns": {
          "mappingMode": "defineBelow",
          "value": {
            "callsToday": "={{ $json.callsToday }}",
            "lastUsed": "={{ $json.lastUsed }}",
            "disabled": "={{ $json.disabled }}",
            "Phonenumber": "={{ $json.chosenPhone }}"
          },
          "matchingColumns": ["Phonenumber"]
        }
      },
      "type": "n8n-nodes-base.googleSheets",
      "typeVersion": 4.7,
      "position": [0, 0],
      "id": "65a58faa-8aa3-4ed5-95c8-3444f9ba2201",
      "name": "Append or update row in sheet",
      "credentials": {
        "googleSheetsOAuth2Api": {
          "id": "eJijuj4MtR5TdVsI",
          "name": "Google Sheets account"
        }
      }
    }
  ],
  "connections": {
    "Webhook": {
      "main": [[{ "node": "HTTP Request1", "type": "main", "index": 0 }]]
    },
    "HTTP Request1": {
      "main": [[{ "node": "Code", "type": "main", "index": 0 }]]
    }
  }
}