Webhooks

GET /restapi/v1/webhook/task

{
  "_status": "OK",
  "_schema": "/restapi/schemav1/webhooktasks",
  "_self": "/restapi/v1/webhook/task",
  "_next": "",
  "items": [
    {
      "event": "ProcessStepChange",
      "datetime": "2021-04-01 12:13:14",
      "response_body": "Server Error",
      "response_status": 500,
      "application": {
        "_self": "/restapi/v1/application/42"
      }
    }
  ]
}

from flask import Flask, request, jsonify
import requests

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def handle_webhook():
    # Récupérer les données du webhook
    data = request.json
    event_type = data.get('event')

    # Traiter selon le type d'événement
    if event_type == 'ProcessStepChange':
        application_url = data.get('application', {}).get('_self')

        # Récupérer les détails complets via l'API
        response = requests.get(
            f'https://jobaffinity.fr{application_url}',
            auth=('login', 'password')
        )

        application_details = response.json()

        # Votre logique métier ici
        process_application_change(application_details)

    # Répondre rapidement
    return jsonify({'status': 'received'}), 200

def process_application_change(application):
    # Traitement asynchrone
    pass

const express = require('express');
const axios = require('axios');

const app = express();
app.use(express.json());

app.post('/webhook', async (req, res) => {
  const { event, application } = req.body;

  // Répondre immédiatement
  res.status(200).json({ status: 'received' });

  // Traitement asynchrone
  if (event === 'ProcessStepChange') {
    try {
      const response = await axios.get(
        `https://jobaffinity.fr${application._self}`,
        {
          auth: {
            username: 'login',
            password: 'password'
          }
        }
      );

      await processApplicationChange(response.data);
    } catch (error) {
      console.error('Error processing webhook:', error);
    }
  }
});

async function processApplicationChange(application) {
  // Votre logique métier
}

app.listen(3000);