// create_whatsapp_workflow.js — Prisa Yachts WhatsApp Bot for n8n
const https = require('https');

const N8N_BASE  = process.env.N8N_BASE_URL || 'https://n8n.crewinghunters.com';
const API_KEY   = process.env.N8N_API_KEY;
if (!API_KEY) { console.error('ERROR: N8N_API_KEY environment variable is required'); process.exit(1); }

/* ─────────────────────────────────────────────────────────── helpers */
function apiCall(method, path, body) {
  return new Promise((resolve, reject) => {
    const data = body ? JSON.stringify(body) : null;
    const opts = {
      hostname: 'n8n.crewinghunters.com',
      path: '/api/v1' + path,
      method,
      headers: {
        'X-N8N-API-KEY': API_KEY,
        'Content-Type': 'application/json',
        'Accept':        'application/json',
        ...(data ? { 'Content-Length': Buffer.byteLength(data) } : {})
      }
    };
    const req = https.request(opts, res => {
      let buf = '';
      res.on('data', c => buf += c);
      res.on('end', () => {
        try { resolve({ status: res.statusCode, data: JSON.parse(buf) }); }
        catch  { resolve({ status: res.statusCode, data: buf }); }
      });
    });
    req.on('error', reject);
    if (data) req.write(data);
    req.end();
  });
}

/* ─────────────────────────────────────── state-machine code (runs inside n8n) */
const STATE_MACHINE_CODE = `
const WELCOME = \`👋 Welcome to Prisa Yachts LLC!
Bienvenido a Prisa Yachts LLC

Safe Command ♦ Luxury Maintenance and Care

Select your service / Selecciona tu servicio:

1️⃣ Engines & Mechanical
2️⃣ Electrical & Electronics / NMEA
3️⃣ Teak Deck Recovery
4️⃣ Captaining & Crewing
5️⃣ Yacht Care & Detailing
6️⃣ Crew Placement & Staffing
7️⃣ Other / Otro

Reply 1–7 / Responde 1–7\`;

const CAT_MSGS = {
  1:\`🔧 Engines & Mechanical

1. Vessel name & type?
2. Engine brand & approx. year?
3. Briefly describe the issue:
   (noise, leak, won't start, overheating,
   routine service, fuel system, etc.)
4. Current location / Marina?
5. When do you need service?
   · Flexible · This week · ASAP

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our specialist will
contact you within 2 hours. 🛥️\`,

  2:\`⚡ Electrical & Electronics / NMEA

1. Vessel name & type?
2. Briefly describe the issue or installation:
   (wiring, shore power, panel, NMEA 2000,
   AIS, chartplotter, VHF, autopilot, etc.)
3. Is it a new installation or a repair?
   · New install · Repair · Diagnosis
4. Current location / Marina?
5. When do you need service?
   · Flexible · This week · ASAP

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our specialist will
contact you within 2 hours. 🛥️\`,

  3:\`🪵 Teak Deck Recovery

1. Vessel name & LOA (feet)?
2. Teak condition:
   · Cleaning needed · Caulking damaged
   · Planks cracked · Full replacement
3. Which deck areas?
   (cockpit, flybridge, side decks, all)
4. Briefly describe the current condition:
5. Current location / Marina?
6. When do you need service?
   · Flexible · This week · ASAP

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our specialist will
contact you within 2 hours. 🛥️\`,

  4:\`⚓ Captaining & Crewing

1. Vessel name, type & LOA (feet)?
2. Service needed:
   · Day trip · Charter · Vessel delivery
   · Offshore passage · Event crew
3. Departure & destination?
4. Date & duration?
5. Number of crew needed?
6. Any special requirements?

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our captain will
contact you within 2 hours. 🛥️\`,

  5:\`🛥️ Yacht Care & Detailing

1. Vessel name, type & LOA (feet)?
2. Service needed:
   · Full wash & wax · Hull polish
   · Interior cleaning · Brightwork
   · Antifouling prep · Full detail
3. Briefly describe current condition:
4. Current location / Marina?
5. When do you need service?
   · Flexible · This week · ASAP

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our team will
contact you within 2 hours. 🛥️\`,

  6:\`👥 Crew Placement & Staffing

1. Vessel name, type & LOA (feet)?
2. Position(s) needed:
   · Captain · Chief Mate / Deck Officer
   · Deckhand · Chief Engineer
   · Stewardess / Interior crew
   · Chef · Other
3. Contract type:
   · Permanent · Seasonal · One-way delivery
   · Day work · Relief / Temporary
4. Start date & duration?
5. Vessel flag & trading area?
6. Any certifications required?
   (STCW, license type, experience level)

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
- Company (if applicable):
─────────────────
Thank you! Our crewing team will
contact you within 2 hours. 🛥️\`,

  7:\`📋 Other / Otro

1. Vessel name & type?
2. Briefly describe what you need:
3. Current location / Marina?
4. When do you need service?
   · Flexible · This week · ASAP

─────────────────
Your contact info:
- Full name:
- Phone:
- Email:
─────────────────
Thank you! Our team will
contact you within 2 hours. 🛥️\`
};

const CONFIRMATION = \`✅ Request received! / ¡Solicitud recibida!

We have all your information and a
Prisa Yachts specialist will contact
you within 2 hours.

📞 (786) 396-3315
📧 info@prisayachts.com
🌐 prisayachts.com
📸 @prisayachts

Safe Command ♦ Luxury Maintenance and Care\`;

const CAT_NAMES = {
  1:'Engines & Mechanical', 2:'Electrical & Electronics / NMEA',
  3:'Teak Deck Recovery',   4:'Captaining & Crewing',
  5:'Yacht Care & Detailing', 6:'Crew Placement & Staffing', 7:'Other / Otro'
};

const ROUTING    = {1:'alvaro',2:'alvaro',3:'federico',4:'federico',5:'federico',6:'federico',7:'both'};
const ALVARO     = '19546554084';
const FEDERICO   = '17542093375';
const RESET_WORDS = ['menu','start','hola','hello','hi'];
const TIMEOUT_MS  = 24 * 60 * 60 * 1000;

// ── parse webhook payload ──────────────────────────────────────────
const raw = $input.first().json;

// Meta GET verification
const q = raw.query || {};
if (q['hub.challenge']) {
  return [{ json: { action: 'webhook_verify', challenge: String(q['hub.challenge']) } }];
}

const body  = raw.body || raw;
const msg   = body?.entry?.[0]?.changes?.[0]?.value?.messages?.[0];
if (!msg || msg.type !== 'text') {
  return [{ json: { action: 'ignore' } }];
}

const from    = msg.from;
const msgText = msg.text.body.trim();
const msgLow  = msgText.toLowerCase();

// ── state machine ─────────────────────────────────────────────────
const sd = $getWorkflowStaticData('global');
if (!sd.states) sd.states = {};

const now   = Date.now();
let   state = sd.states[from] || { step: 'new', lastActivity: 0, data: {} };
if (now - state.lastActivity > TIMEOUT_MS) state = { step: 'new', lastActivity: now, data: {} };
state.lastActivity = now;

const reply = (messageText, extra={}) => {
  sd.states[from] = state;
  return [{ json: { action: 'send_to_client', to: from, messageText, notifySpecialist: false, ...extra } }];
};

if (RESET_WORDS.includes(msgLow) || state.step === 'new') {
  state.step = 'waiting_category'; state.data = {};
  return reply(WELCOME);
}

if (state.step === 'waiting_category') {
  const cat = parseInt(msgText, 10);
  if (cat >= 1 && cat <= 7) {
    state.step = 'collecting_info'; state.data.category = cat;
    return reply(CAT_MSGS[cat]);
  }
  return reply(WELCOME);
}

if (state.step === 'collecting_info') {
  const cat    = state.data.category;
  const ts     = new Date().toLocaleString('en-US', { timeZone: 'America/New_York' });
  const specMsg = \`🔔 NEW SERVICE REQUEST — Prisa Yachts

📋 Category: \${CAT_NAMES[cat]}
👤 Client WhatsApp: +\${from}

📝 Info received:
\${msgText}

🕐 Received: \${ts} ET\`;

  state.step = 'complete';
  return reply(CONFIRMATION, {
    notifySpecialist: true,
    routing:       ROUTING[cat],
    specialistMsg: specMsg,
    alvaroPhone:   ALVARO,
    federicoPhone: FEDERICO
  });
}

// complete → restart
state.step = 'waiting_category'; state.data = {};
return reply(WELCOME);
`;

/* ────────────────────────────────────────── build workflow JSON */
function buildWorkflow(credId) {
  const credential = { httpHeaderAuth: { id: String(credId), name: 'WhatsApp_Prisa' } };
  const waUrl      = 'https://graph.facebook.com/v18.0/PLACEHOLDER_PHONE_NUMBER_ID/messages';

  const ifStrNode = (id, name, pos, left, right) => ({
    id, name,
    type: 'n8n-nodes-base.if', typeVersion: 2,
    position: pos,
    parameters: {
      conditions: { combinator:'and', conditions:[{
        leftValue: left, rightValue: right,
        operator:  { type:'string', operation:'equals' }
      }]},
      options: {}
    }
  });

  const httpNode = (id, name, pos, jsonBody) => ({
    id, name,
    type: 'n8n-nodes-base.httpRequest', typeVersion: 4.2,
    position: pos,
    credentials: credential,
    parameters: {
      method: 'POST', url: waUrl,
      authentication: 'genericCredentialType',
      genericAuthType: 'httpHeaderAuth',
      sendBody: true, specifyBody: 'json',
      jsonBody, options: {}
    }
  });

  const clientBody  = `={{ JSON.stringify({messaging_product:"whatsapp",to:$json.to,type:"text",text:{body:$json.messageText}}) }}`;
  const alvaroBody  = `={{ JSON.stringify({messaging_product:"whatsapp",to:$json.alvaroPhone,type:"text",text:{body:$json.specialistMsg}}) }}`;
  const fedBody     = `={{ JSON.stringify({messaging_product:"whatsapp",to:$json.federicoPhone,type:"text",text:{body:$json.specialistMsg}}) }}`;

  return {
    name: 'Prisa Yachts — WhatsApp Bot',
    nodes: [
      // 1 Webhook
      {
        id: 'n-wh', name: 'WhatsApp Webhook',
        type: 'n8n-nodes-base.webhook', typeVersion: 2,
        position: [200, 300],
        parameters: { httpMethod:'POST', path:'prisa-whatsapp', responseMode:'onReceived', options:{} }
      },
      // 2 State machine
      {
        id: 'n-sm', name: 'State Machine',
        type: 'n8n-nodes-base.code', typeVersion: 2,
        position: [450, 300],
        parameters: { mode:'runOnceForAllItems', jsCode: STATE_MACHINE_CODE }
      },
      // 3 IF: is webhook_verify?
      ifStrNode('n-ifv', 'Is Verify?', [700, 300], '={{ $json.action }}', 'webhook_verify'),
      // 4 Respond with challenge
      {
        id: 'n-respond', name: 'Respond — Verify',
        type: 'n8n-nodes-base.respondToWebhook', typeVersion: 1.1,
        position: [950, 140],
        parameters: {
          respondWith: 'text',
          responseBody: '={{ $json.challenge }}',
          options: { responseCode: 200 }
        }
      },
      // 5 IF: is send_to_client?
      ifStrNode('n-ifs', 'Is Send?', [950, 380], '={{ $json.action }}', 'send_to_client'),
      // 6 Send to client
      httpNode('n-hsc', 'Send WhatsApp — Client', [1200, 280], clientBody),
      // 7 Ignore (no-op)
      { id:'n-nop', name:'Ignore', type:'n8n-nodes-base.noOp', typeVersion:1, position:[1200,520], parameters:{} },
      // 8 IF notifySpecialist
      {
        id: 'n-ifn', name: 'Notify Specialist?',
        type: 'n8n-nodes-base.if', typeVersion: 2,
        position: [1450, 280],
        parameters: {
          conditions: { combinator:'and', conditions:[{
            leftValue:'={{ $json.notifySpecialist }}', rightValue: true,
            operator:{ type:'boolean', operation:'equals' }
          }]},
          options: {}
        }
      },
      // 9 IF routing === 'both'  → true: both, false: check alvaro/fed
      ifStrNode('n-ifb', 'Is Both?', [1700, 200], '={{ $json.routing }}', 'both'),
      // 10 IF routing === 'alvaro'  → true: alvaro only, false: federico only
      ifStrNode('n-ifa', 'Is Alvaro?', [1700, 420], '={{ $json.routing }}', 'alvaro'),
      // 11,12 HTTP nodes
      httpNode('n-hal', 'Send WhatsApp — Alvaro',   [1950, 180], alvaroBody),
      httpNode('n-hfe', 'Send WhatsApp — Federico', [1950, 420], fedBody),
    ],
    connections: {
      'WhatsApp Webhook': { main: [[{ node:'State Machine',  type:'main', index:0 }]] },
      'State Machine':    { main: [[{ node:'Is Verify?',     type:'main', index:0 }]] },
      'Is Verify?': { main: [
        [{ node:'Respond — Verify',       type:'main', index:0 }],   // true
        [{ node:'Is Send?',               type:'main', index:0 }]    // false
      ]},
      'Is Send?': { main: [
        [{ node:'Send WhatsApp — Client', type:'main', index:0 }],   // true
        [{ node:'Ignore',                 type:'main', index:0 }]    // false
      ]},
      'Send WhatsApp — Client': { main: [[{ node:'Notify Specialist?', type:'main', index:0 }]] },
      'Notify Specialist?': { main: [
        [{ node:'Is Both?',  type:'main', index:0 }],  // true → route
        []                                              // false → end
      ]},
      'Is Both?': { main: [
        // true → send to BOTH simultaneously
        [{ node:'Send WhatsApp — Alvaro', type:'main', index:0 }, { node:'Send WhatsApp — Federico', type:'main', index:0 }],
        [{ node:'Is Alvaro?', type:'main', index:0 }]  // false → check which one
      ]},
      'Is Alvaro?': { main: [
        [{ node:'Send WhatsApp — Alvaro',   type:'main', index:0 }],  // true
        [{ node:'Send WhatsApp — Federico', type:'main', index:0 }]   // false (must be federico)
      ]}
    },
    settings: { executionOrder: 'v1' }
  };
}

/* ──────────────────────────────────────────────────────────── main */
async function cleanup() {
  const wfs = await apiCall('GET', '/workflows?limit=50');
  for (const wf of (wfs.data?.data || [])) {
    if (wf.name && wf.name.includes('Prisa Yachts')) {
      await apiCall('DELETE', `/workflows/${wf.id}`);
      console.log(`     🗑  Deleted workflow: ${wf.id}`);
    }
  }
  const creds = await apiCall('GET', '/credentials?limit=50');
  for (const c of (creds.data?.data || [])) {
    if (c.name === 'WhatsApp_Prisa') {
      await apiCall('DELETE', `/credentials/${c.id}`);
      console.log(`     🗑  Deleted credential: ${c.id}`);
    }
  }
}

async function main() {
  console.log('\n🚀  Prisa Yachts — WhatsApp Bot Deployment\n');

  console.log('0/4  Cleaning up previous attempts...');
  await cleanup();
  console.log('     ✅ Clean');

  // 1. Credential
  console.log('1/4  Creating WhatsApp credential...');
  const credRes = await apiCall('POST', '/credentials', {
    name: 'WhatsApp_Prisa',
    type: 'httpHeaderAuth',
    data: { name: 'Authorization', value: 'Bearer PLACEHOLDER_PENDING_META_APPROVAL' }
  });
  if (![200,201].includes(credRes.status)) {
    console.error('     ❌ Credential error:', JSON.stringify(credRes.data, null, 2));
    process.exit(1);
  }
  const credId = credRes.data.id;
  console.log(`     ✅ Credential created  id=${credId}`);

  // 2. Workflow
  console.log('2/4  Creating workflow...');
  const wfRes = await apiCall('POST', '/workflows', buildWorkflow(credId));
  if (![200,201].includes(wfRes.status)) {
    console.error('     ❌ Workflow error:', JSON.stringify(wfRes.data, null, 2));
    process.exit(1);
  }
  const wfId = wfRes.data.id;
  console.log(`     ✅ Workflow created    id=${wfId}`);

  // 3. Activate
  console.log('3/4  Activating workflow...');
  const actRes = await apiCall('POST', `/workflows/${wfId}/activate`);
  if (actRes.status !== 200) {
    console.warn('     ⚠️  Activation returned', actRes.status, JSON.stringify(actRes.data));
  } else {
    console.log('     ✅ Workflow ACTIVE');
  }

  // 4. Confirm
  console.log('4/4  Verifying...');
  const chk = await apiCall('GET', `/workflows/${wfId}`);
  console.log(`     ✅ active = ${chk.data?.active}`);

  console.log(`
══════════════════════════════════════════════════════
  ✅  DEPLOYMENT COMPLETE
══════════════════════════════════════════════════════

  Webhook URL  →  https://n8n.crewinghunters.com/webhook/prisa-whatsapp
  Workflow ID  →  ${wfId}
  Credential   →  WhatsApp_Prisa  (id=${credId})

══════════════════════════════════════════════════════
  NEXT STEPS — after Meta approves your WhatsApp account
══════════════════════════════════════════════════════

  1. n8n → Settings → Credentials → WhatsApp_Prisa
     Change value from  PLACEHOLDER_PENDING_META_APPROVAL
     to                 Bearer <YOUR_ACCESS_TOKEN>

  2. Open workflow "Prisa Yachts — WhatsApp Bot"
     In these 3 nodes, change the URL:
       • Send WhatsApp — Client
       • Send WhatsApp — Alvaro
       • Send WhatsApp — Federico
     Replace  PLACEHOLDER_PHONE_NUMBER_ID
     With     <YOUR_PHONE_NUMBER_ID>

  3. Meta Developer Portal → WhatsApp → Configuration
     Webhook URL   : https://n8n.crewinghunters.com/webhook/prisa-whatsapp
     Verify Token  : any string (e.g. "prisayachts2025")
     Subscribe to  : messages

  4. Send "hola" to +17863963315 from any WhatsApp to test.

══════════════════════════════════════════════════════
  ROUTING
══════════════════════════════════════════════════════
  1 Engines & Mechanical      → Alvaro   +19546554084
  2 Electrical & Electronics  → Alvaro   +19546554084
  3 Teak Deck Recovery        → Federico +17542093375
  4 Captaining & Crewing      → Federico +17542093375
  5 Yacht Care & Detailing    → Federico +17542093375
  6 Crew Placement & Staffing → Federico +17542093375
  7 Other / Otro              → BOTH
══════════════════════════════════════════════════════
`);
}

main().catch(e => { console.error('Fatal:', e); process.exit(1); });