"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.sendToN8n = void 0;
const axios_1 = __importDefault(require("axios"));
const sendToN8n = async (data) => {
    const n8nWebhookUrl = process.env.N8N_WEBHOOK_URL;
    if (!n8nWebhookUrl) {
        console.error('N8N_WEBHOOK_URL is not defined in environment variables.');
        return;
    }
    try {
        console.log(`Forwarding payload to n8n at ${n8nWebhookUrl}...`);
        const response = await axios_1.default.post(n8nWebhookUrl, data, {
            headers: {
                'Content-Type': 'application/json'
            }
        });
        console.log(`Successfully forwarded to n8n. Status: ${response.status}`);
    }
    catch (error) {
        console.error('Failed to forward payload to n8n.', error.message);
        if (error.response) {
            console.error('n8n Response:', error.response.status, error.response.data);
        }
    }
};
exports.sendToN8n = sendToN8n;