Kandidaten-Engagement-Sequenz mit n8n

{
  "name": "Candidate engagement sequence",
  "nodes": [
    {
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 9 * * 1-5"
            }
          ]
        }
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000001",
      "name": "Daily Cron — 9am Mon-Fri",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1,
      "position": [240, 300],
      "notesInFlow": true,
      "notes": "Set the timezone explicitly in workflow Settings — default is UTC."
    },
    {
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT\n  candidate_id,\n  sequence_name,\n  current_step,\n  candidate_email,\n  recruiter_owner,\n  context_payload\nFROM candidate_sequence_state\nWHERE next_due_at <= now()\n  AND status = 'active'\n  AND opted_out_at IS NULL\nLIMIT 100;",
        "options": {}
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000002",
      "name": "Pull Due Candidates",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2.4,
      "position": [460, 300],
      "credentials": {
        "postgres": {
          "id": "PLACEHOLDER_POSTGRES_CRED_ID",
          "name": "Postgres — sequence-state"
        }
      }
    },
    {
      "parameters": {
        "method": "GET",
        "url": "=https://api.ashbyhq.com/candidate.info?id={{ $json.candidate_id }}",
        "authentication": "predefinedCredentialType",
        "nodeCredentialType": "httpBasicAuth",
        "sendQuery": false,
        "options": {
          "response": {
            "response": {
              "fullResponse": false
            }
          }
        }
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000003",
      "name": "Ashby — Candidate Snapshot",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [680, 300],
      "credentials": {
        "httpBasicAuth": {
          "id": "PLACEHOLDER_ASHBY_CRED_ID",
          "name": "Ashby — API"
        }
      },
      "notesInFlow": true,
      "notes": "Returns latest candidate state, recent activity, applicationCount."
    },
    {
      "parameters": {
        "conditions": {
          "options": {
            "caseSensitive": true,
            "leftValue": "",
            "typeValidation": "strict"
          },
          "conditions": [
            {
              "id": "skip-recent-reply",
              "leftValue": "={{ $json.results.recentReplyAt }}",
              "rightValue": "",
              "operator": {
                "type": "string",
                "operation": "notExists"
              }
            },
            {
              "id": "skip-recent-app",
              "leftValue": "={{ $json.results.lastApplicationAt }}",
              "rightValue": "={{ $now.minus({days: 30}).toISO() }}",
              "operator": {
                "type": "dateTime",
                "operation": "before"
              }
            },
            {
              "id": "skip-opted-out",
              "leftValue": "={{ $json.results.optedOut }}",
              "rightValue": false,
              "operator": {
                "type": "boolean",
                "operation": "equal"
              }
            }
          ],
          "combinator": "and"
        },
        "options": {}
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000004",
      "name": "Skip-Condition Check",
      "type": "n8n-nodes-base.if",
      "typeVersion": 2.2,
      "position": [900, 300]
    },
    {
      "parameters": {
        "method": "POST",
        "url": "https://api.anthropic.com/v1/messages",
        "sendHeaders": true,
        "headerParameters": {
          "parameters": [
            { "name": "anthropic-version", "value": "2023-06-01" },
            { "name": "content-type", "value": "application/json" }
          ]
        },
        "authentication": "predefinedCredentialType",
        "nodeCredentialType": "httpHeaderAuth",
        "sendBody": true,
        "specifyBody": "json",
        "jsonBody": "={\n  \"model\": \"claude-sonnet-4-6\",\n  \"max_tokens\": 1024,\n  \"system\": \"You are writing the next outreach message in a multi-touch recruiting sequence. The candidate has been previously contacted and has not opted out. Your message must reference the candidate's actual context (recent role change, public talk, mentioned project) — never generic 'I came across your profile'. Length: 80-120 words. Tone: peer-to-peer, no marketing voice. End with a single specific question. Never claim a personal connection that does not exist.\",\n  \"messages\": [\n    {\n      \"role\": \"user\",\n      \"content\": \"Sequence: {{ $('Pull Due Candidates').item.json.sequence_name }}. Step: {{ $('Pull Due Candidates').item.json.current_step }}. Candidate snapshot: {{ JSON.stringify($json.results) }}. Context payload: {{ $('Pull Due Candidates').item.json.context_payload }}.\"\n    }\n  ]\n}",
        "options": {}
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000005",
      "name": "Claude — Personalize Message",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [1120, 200],
      "credentials": {
        "httpHeaderAuth": {
          "id": "PLACEHOLDER_ANTHROPIC_CRED_ID",
          "name": "Anthropic — x-api-key"
        }
      }
    },
    {
      "parameters": {
        "resource": "message",
        "operation": "send",
        "sendTo": "={{ $('Pull Due Candidates').item.json.candidate_email }}",
        "subject": "=Quick thought — {{ $('Pull Due Candidates').item.json.sequence_name }}",
        "emailType": "text",
        "message": "={{ $json.content[0].text }}\n\n—\nReply STOP to opt out: https://example.com/optout?token={{ $('Pull Due Candidates').item.json.candidate_id }}",
        "options": {}
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000006",
      "name": "Gmail — Send",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2.1,
      "position": [1340, 200],
      "credentials": {
        "gmailOAuth2": {
          "id": "PLACEHOLDER_GMAIL_CRED_ID",
          "name": "Gmail — sender mailbox"
        }
      },
      "notesInFlow": true,
      "notes": "For volume above ~50/day per mailbox, swap for a dedicated outreach platform (Smartlead/Instantly) with proper deliverability."
    },
    {
      "parameters": {
        "operation": "executeQuery",
        "query": "UPDATE candidate_sequence_state\nSET\n  current_step = current_step + 1,\n  last_touched_at = now(),\n  next_due_at = CASE\n    WHEN current_step + 1 >= total_steps THEN NULL\n    ELSE now() + interval_per_step\n  END,\n  status = CASE\n    WHEN current_step + 1 >= total_steps THEN 'completed'\n    ELSE 'active'\n  END\nWHERE candidate_id = $1\nRETURNING current_step, status, next_due_at;",
        "options": {
          "queryReplacement": "={{ $('Pull Due Candidates').item.json.candidate_id }}"
        }
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000007",
      "name": "Update Sequence State",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2.4,
      "position": [1560, 200],
      "credentials": {
        "postgres": {
          "id": "PLACEHOLDER_POSTGRES_CRED_ID",
          "name": "Postgres — sequence-state"
        }
      }
    },
    {
      "parameters": {
        "pollTimes": {
          "item": [
            {
              "mode": "everyMinute"
            }
          ]
        },
        "filters": {
          "labelIds": ["INBOX"],
          "q": "in:inbox -from:me -label:sequence-replied newer_than:1d"
        },
        "options": {
          "downloadAttachments": false
        }
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000008",
      "name": "Reply Trigger — Gmail Inbox Poll",
      "type": "n8n-nodes-base.gmailTrigger",
      "typeVersion": 1.2,
      "position": [240, 600],
      "credentials": {
        "gmailOAuth2": {
          "id": "PLACEHOLDER_GMAIL_CRED_ID",
          "name": "Gmail — sender mailbox"
        }
      },
      "notesInFlow": true,
      "notes": "Independent trigger. Fires on every new inbound email and routes to Slack."
    },
    {
      "parameters": {
        "jsCode": "// Match inbound message to a candidate by email address.\nconst sender = ($json.from || '').match(/<([^>]+)>/)?.[1]\n  || ($json.from || '').trim();\nconst subject = $json.subject || '';\nconst snippet = $json.snippet || '';\n\nreturn [{\n  json: {\n    candidate_email: sender,\n    subject,\n    snippet,\n    received_at: $json.internalDate ? new Date(Number($json.internalDate)).toISOString() : new Date().toISOString(),\n    gmail_thread_id: $json.threadId,\n  }\n}];"
      },
      "id": "1c1c1c1c-0001-0000-0000-000000000009",
      "name": "Normalize Reply",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [460, 600]
    },
    {
      "parameters": {
        "operation": "executeQuery",
        "query": "UPDATE candidate_sequence_state\nSET status = 'replied', replied_at = now(), next_due_at = NULL\nWHERE candidate_email = $1 AND status = 'active'\nRETURNING candidate_id, recruiter_owner, sequence_name, current_step;",
        "options": {
          "queryReplacement": "={{ $json.candidate_email }}"
        }
      },
      "id": "1c1c1c1c-0001-0000-0000-00000000000a",
      "name": "Mark Replied + Lookup Owner",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2.4,
      "position": [680, 600],
      "credentials": {
        "postgres": {
          "id": "PLACEHOLDER_POSTGRES_CRED_ID",
          "name": "Postgres — sequence-state"
        }
      }
    },
    {
      "parameters": {
        "method": "POST",
        "url": "=https://slack.com/api/chat.postMessage",
        "authentication": "predefinedCredentialType",
        "nodeCredentialType": "httpHeaderAuth",
        "sendHeaders": true,
        "headerParameters": {
          "parameters": [
            { "name": "content-type", "value": "application/json" }
          ]
        },
        "sendBody": true,
        "specifyBody": "json",
        "jsonBody": "={\n  \"channel\": \"@{{ $json.recruiter_owner }}\",\n  \"text\": \"Reply from {{ $('Normalize Reply').item.json.candidate_email }} on sequence *{{ $json.sequence_name }}* (step {{ $json.current_step }}).\\n> {{ $('Normalize Reply').item.json.snippet }}\"\n}",
        "options": {}
      },
      "id": "1c1c1c1c-0001-0000-0000-00000000000b",
      "name": "Slack — Notify Recruiter",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [900, 600],
      "credentials": {
        "httpHeaderAuth": {
          "id": "PLACEHOLDER_SLACK_CRED_ID",
          "name": "Slack — bot token"
        }
      }
    }
  ],
  "connections": {
    "Daily Cron — 9am Mon-Fri": {
      "main": [
        [{ "node": "Pull Due Candidates", "type": "main", "index": 0 }]
      ]
    },
    "Pull Due Candidates": {
      "main": [
        [{ "node": "Ashby — Candidate Snapshot", "type": "main", "index": 0 }]
      ]
    },
    "Ashby — Candidate Snapshot": {
      "main": [
        [{ "node": "Skip-Condition Check", "type": "main", "index": 0 }]
      ]
    },
    "Skip-Condition Check": {
      "main": [
        [{ "node": "Claude — Personalize Message", "type": "main", "index": 0 }],
        []
      ]
    },
    "Claude — Personalize Message": {
      "main": [
        [{ "node": "Gmail — Send", "type": "main", "index": 0 }]
      ]
    },
    "Gmail — Send": {
      "main": [
        [{ "node": "Update Sequence State", "type": "main", "index": 0 }]
      ]
    },
    "Reply Trigger — Gmail Inbox Poll": {
      "main": [
        [{ "node": "Normalize Reply", "type": "main", "index": 0 }]
      ]
    },
    "Normalize Reply": {
      "main": [
        [{ "node": "Mark Replied + Lookup Owner", "type": "main", "index": 0 }]
      ]
    },
    "Mark Replied + Lookup Owner": {
      "main": [
        [{ "node": "Slack — Notify Recruiter", "type": "main", "index": 0 }]
      ]
    }
  },
  "active": false,
  "settings": {
    "executionOrder": "v1",
    "timezone": "America/New_York"
  },
  "versionId": "1c1c1c1c-0001-0000-0000-0000000000ff",
  "meta": {
    "templateCreatedBy": "ooligo",
    "instanceId": "ooligo-pilot"
  },
  "id": "candidate-engagement-sequence",
  "tags": [
    { "name": "recruiting" },
    { "name": "outbound" }
  ]
}