Webhook-Dokumentation

from flask import Flask, request, jsonify
import os

app = Flask(__name__)
WEBHOOK_TOKEN = os.environ.get('CONTENTO_WEBHOOK_TOKEN')

@app.route('/contento/webhook', methods=['POST'])
def webhook():
    # Zugriffstoken prüfen
    auth_header = request.headers.get('Authorization', '')
    if WEBHOOK_TOKEN and auth_header != f'Bearer {WEBHOOK_TOKEN}':
        return jsonify({'error': 'Unauthorized'}), 401

    payload = request.get_json()

    # Verbindungstest
    if payload.get('data', {}).get('verify'):
        return jsonify({'status': 'ok'}), 200

    # Artikel verarbeiten
    articles = payload['data']['articles']
    for article in articles:
        print(f"Artikel empfangen: {article['title']}")
        # Artikel in der Datenbank speichern, auf der Website veröffentlichen usw.

    return jsonify({'status': 'received'}), 200

<?php
$webhookToken = getenv('CONTENTO_WEBHOOK_TOKEN');

// Zugriffstoken prüfen
$authHeader = $_SERVER['HTTP_AUTHORIZATION'] ?? '';
if ($webhookToken && $authHeader !== "Bearer $webhookToken") {
    http_response_code(401);
    echo json_encode(['error' => 'Unauthorized']);
    exit;
}

$payload = json_decode(file_get_contents('php://input'), true);

// Verbindungstest
if (!empty($payload['data']['verify'])) {
    http_response_code(200);
    echo json_encode(['status' => 'ok']);
    exit;
}

// Artikel verarbeiten
foreach ($payload['data']['articles'] as $article) {
    error_log("Artikel empfangen: " . $article['title']);
    // Artikel in der Datenbank speichern, auf der Website veröffentlichen usw.
}

http_response_code(200);
echo json_encode(['status' => 'received']);

require 'sinatra'
require 'json'

WEBHOOK_TOKEN = ENV['CONTENTO_WEBHOOK_TOKEN']

post '/contento/webhook' do
  content_type :json

  # Zugriffstoken prüfen
  if WEBHOOK_TOKEN
    auth_header = request.env['HTTP_AUTHORIZATION'] || ''
    unless auth_header == "Bearer #{WEBHOOK_TOKEN}"
      halt 401, { error: 'Unauthorized' }.to_json
    end
  end

  payload = JSON.parse(request.body.read)

  # Verbindungstest
  if payload.dig('data', 'verify')
    return { status: 'ok' }.to_json
  end

  # Artikel verarbeiten
  payload['data']['articles'].each do |article|
    puts "Artikel empfangen: #{article['title']}"
    puts "Slug: #{article['slug']}"
    # Artikel in der Datenbank speichern, auf der Website veröffentlichen usw.
  end

  { status: 'received' }.to_json
end

package main

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

type Article struct {
	ID              string  `json:"id"`
	Title           string  `json:"title"`
	ContentMarkdown string  `json:"content_markdown"`
	ContentHTML     string  `json:"content_html"`
	MetaDescription string  `json:"meta_description"`
	CreatedAt       string  `json:"created_at"`
	Slug            string  `json:"slug"`
	ImageURL        *string `json:"image_url"`
}

type Payload struct {
	Timestamp string `json:"timestamp"`
	Data      struct {
		Verify   bool      `json:"verify,omitempty"`
		Articles []Article `json:"articles,omitempty"`
	} `json:"data"`
}

func webhookHandler(w http.ResponseWriter, r *http.Request) {
	webhookToken := os.Getenv("CONTENTO_WEBHOOK_TOKEN")
	w.Header().Set("Content-Type", "application/json")

	// Zugriffstoken prüfen
	if webhookToken != "" {
		auth := r.Header.Get("Authorization")
		if !strings.HasPrefix(auth, "Bearer ") || auth[7:] != webhookToken {
			w.WriteHeader(http.StatusUnauthorized)
			json.NewEncoder(w).Encode(map[string]string{"error": "Unauthorized"})
			return
		}
	}

	var payload Payload
	json.NewDecoder(r.Body).Decode(&payload)

	// Verbindungstest
	if payload.Data.Verify {
		json.NewEncoder(w).Encode(map[string]string{"status": "ok"})
		return
	}

	// Artikel verarbeiten
	for _, article := range payload.Data.Articles {
		fmt.Printf("Artikel empfangen: %s\n", article.Title)
		fmt.Printf("Slug: %s\n", article.Slug)
		// Artikel in der Datenbank speichern, auf der Website veröffentlichen usw.
	}

	json.NewEncoder(w).Encode(map[string]string{"status": "received"})
}

func main() {
	http.HandleFunc("/contento/webhook", webhookHandler)
	http.ListenAndServe(":8080", nil)
}