Webhook интеграция

┌─────────────┐         ┌─────────────┐         ┌─────────────┐
│  Пользователь │  POST   │   Polydo    │  POST   │ Ваш n8n     │
│  нажимает    │ ──────> │   сервер    │ ──────> │ webhook     │
│  "Запустить" │         │             │         │             │
└─────────────┘         └─────────────┘         └─────────────┘
                                                      │
                                                      │ Обработка
                                                      v
┌─────────────┐         ┌─────────────┐         ┌─────────────┐
│  Пользователь │ <────── │   Polydo    │ <────── │ POST на     │
│  получает   │         │   сервер    │         │ callbackUrl │
│  результат  │         │             │         │             │
└─────────────┘         └─────────────┘         └─────────────┘

POST /your-webhook-path HTTP/1.1
Content-Type: application/json
X-Polydo-Signature: sha256=abc123...
X-Polydo-Execution-Id: exec_abc123

{
  "executionId": "exec_abc123def456",
  "skillId": "skill_xyz789",
  "userId": "user_123",
  "inputData": {
    "text": "Пример входных данных от пользователя",
    "option": true
  },
  "callbackUrl": "https://api.polydo.ru/v1/executions/exec_abc123def456/callback",
  "metadata": {
    "timestamp": "2024-01-15T10:30:00Z",
    "version": "1.0"
  }
}

POST {callbackUrl} HTTP/1.1
Content-Type: application/json

{
  "success": true,
  "output": {
    "result": "Обработанный текст",
    "count": 42,
    "fileUrl": "https://storage.example.com/file.pdf"
  }
}

{
  "success": false,
  "error": "Не удалось обработать файл: неподдерживаемый формат"
}

// Настройки Webhook ноды в n8n
{
  "httpMethod": "POST",
  "path": "your-skill-name",
  "responseMode": "responseNode", // или "lastNode"
  "options": {}
}

// Code нода для извлечения данных
const body = $input.first().json.body;
const { executionId, inputData, callbackUrl } = body;

// Ваша логика обработки
const result = processData(inputData);

return [{
  json: {
    callbackUrl,
    executionId,
    result
  }
}];

// HTTP Request нода
{
  "method": "POST",
  "url": "={{ $json.callbackUrl }}",
  "headers": {
    "Content-Type": "application/json"
  },
  "body": {
    "success": true,
    "output": "={{ $json.result }}"
  }
}

// Проверка подписи в n8n
const crypto = require('crypto');

const signature = $input.first().headers['x-polydo-signature'];
const body = JSON.stringify($input.first().json.body);
const secret = 'your_webhook_secret'; // из настроек навыка

const expectedSignature = 'sha256=' + crypto
  .createHmac('sha256', secret)
  .update(body)
  .digest('hex');

if (signature !== expectedSignature) {
  throw new Error('Invalid signature');
}

// n8n Code нода
const { inputData, callbackUrl } = $input.first().json.body;
const text = inputData.text || '';

// Обработка
const words = text.split(/\s+/).filter(w => w).length;
const chars = text.length;

// Отправка результата
const response = await fetch(callbackUrl, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    success: true,
    output: { words, chars }
  })
});

return [{ json: { sent: true } }];

// n8n Code нода
const { inputData, callbackUrl } = $input.first().json.body;
const fileUrl = inputData.file;

try {
  // Скачиваем файл
  const fileResponse = await fetch(fileUrl);
  const fileBuffer = await fileResponse.arrayBuffer();

  // Обрабатываем (пример: получаем размер)
  const fileSize = fileBuffer.byteLength;

  // Отправляем результат
  await fetch(callbackUrl, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      success: true,
      output: {
        fileSize,
        fileName: fileUrl.split('/').pop()
      }
    })
  });
} catch (error) {
  await fetch(callbackUrl, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      success: false,
      error: error.message
    })
  });
}

return [{ json: { processed: true } }];

const { executionId, callbackUrl } = $input.first().json.body;

// Отправка промежуточного статуса (опционально)
await fetch(callbackUrl, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    success: true,
    status: 'processing',
    progress: 50,
    message: 'Обрабатываем данные...'
  })
});

// ... длительная обработка ...

// Финальный результат
await fetch(callbackUrl, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    success: true,
    output: { /* результат */ }
  })
});

console.log('Received:', JSON.stringify($input.first().json, null, 2));

curl -X POST https://your-n8n.cloud/webhook/your-path \
  -H "Content-Type: application/json" \
  -d '{
    "executionId": "test_123",
    "skillId": "skill_test",
    "userId": "user_test",
    "inputData": {"text": "Hello"},
    "callbackUrl": "https://webhook.site/your-id"
  }'