Webhooks

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

app.use(express.json());

app.post('/webhook/reap', (req, res) => {
  const { projectId, projectType, source, status } = req.body;

  // Return 200 immediately with empty body
  res.status(200).send('');

  // Process the event asynchronously
  handleProjectUpdate(projectId, projectType, source, status);
});

async function handleProjectUpdate(projectId, projectType, source, status) {
  if (status === 'completed') {
    // Fetch clips or project details from the API
    console.log(`Project ${projectId} completed. Fetching results...`);
  } else if (status === 'invalid') {
    console.log(`Project ${projectId} failed with status: ${status}`);
  } else if (status === 'expired') {
    console.log(`Project ${projectId} expired.`);
  }
}

app.listen(3000, () => console.log('Webhook receiver running on port 3000'));

from flask import Flask, request

app = Flask(__name__)

@app.route('/webhook/reap', methods=['POST'])
def handle_webhook():
    data = request.json
    project_id = data['projectId']
    status = data['status']

    # Process asynchronously in production (e.g. Celery task)
    if status == 'completed':
        print(f'Project {project_id} completed. Fetching results...')
    elif status == 'invalid':
        print(f'Project {project_id} failed with status: {status}')
    elif status == 'expired':
        print(f'Project {project_id} expired.')

    # Return 200 with empty body
    return '', 200

if __name__ == '__main__':
    app.run(port=3000)

package main

import (
	"encoding/json"
	"fmt"
	"net/http"
)

type WebhookPayload struct {
	ProjectID   string `json:"projectId"`
	ProjectType string `json:"projectType"`
	Source      string `json:"source"`
	Status      string `json:"status"`
}

func webhookHandler(w http.ResponseWriter, r *http.Request) {
	var payload WebhookPayload
	json.NewDecoder(r.Body).Decode(&payload)

	// Return 200 with empty body immediately
	w.WriteHeader(http.StatusOK)

	// Process the event
	go func() {
		if payload.Status == "completed" {
			fmt.Printf("Project %s completed. Fetching results...\n", payload.ProjectID)
		}
	}()
}

func main() {
	http.HandleFunc("/webhook/reap", webhookHandler)
	fmt.Println("Webhook receiver running on port 3000")
	http.ListenAndServe(":3000", nil)
}