campaign.cycle_completed

from flask import Flask, request, jsonify

app = Flask(__name__)

@app.post("/webhooks/altur/campaign-cycle")
def on_campaign_cycle_completed():
    signature = request.headers.get("X-Altur-Signature")
    if not is_valid_signature(SHARED_SECRET, request.get_json(), signature):
        return jsonify(error="invalid signature"), 401

    event = request.get_json()
    data = event["data"]
    campaign = data["campaign"]

    snapshot_cycle_metrics(
        campaign_id=campaign["id"],
        iteration=data["cycle_iteration"],
        next_at=data["next_cycle_at"],
    )

    if data["next_cycle_at"] is None and campaign["status"] != "finished":
        alert_stalled_campaign(campaign["id"])

    return "", 200

import express from "express";

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

app.post("/webhooks/altur/campaign-cycle", (req, res) => {
  const signature = req.headers["x-altur-signature"];
  if (!isValidSignature(SHARED_SECRET, req.body, signature)) {
    return res.status(401).json({ error: "invalid signature" });
  }

  const { data } = req.body;
  const { campaign, cycle_iteration, next_cycle_at } = data;

  snapshotCycleMetrics(campaign.id, cycle_iteration, next_cycle_at);

  if (next_cycle_at === null && campaign.status !== "finished") {
    alertStalledCampaign(campaign.id);
  }

  res.status(200).send();
});

<?php
$raw = file_get_contents("php://input");
$signature = $_SERVER["HTTP_X_ALTUR_SIGNATURE"] ?? "";
$event = json_decode($raw, true);

if (!isValidSignature($sharedSecret, $event, $signature)) {
    http_response_code(401);
    exit;
}

$data = $event["data"];
$campaign = $data["campaign"];

snapshot_cycle_metrics(
    $campaign["id"],
    $data["cycle_iteration"],
    $data["next_cycle_at"]
);

if ($data["next_cycle_at"] === null && $campaign["status"] !== "finished") {
    alert_stalled_campaign($campaign["id"]);
}

http_response_code(200);