31 lines
1.1 KiB
JavaScript
31 lines
1.1 KiB
JavaScript
"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;
|