Event-driven pings

RUN_ID="job-$(uuidgen)"
API="https://api.drumbeats.io/v1/ping/<monitor-id>"

curl -sf "$API/start?run_id=$RUN_ID"
python process_order.py
if [ $? -eq 0 ]; then
  curl -sf "$API/success?run_id=$RUN_ID"
else
  curl -sf "$API/failure?run_id=$RUN_ID"
fi

import requests, uuid

API = "https://api.drumbeats.io/v1/ping/<monitor-id>"

def run_job():
    run_id = f"job-{uuid.uuid4()}"
    requests.get(f"{API}/start", params={"run_id": run_id}, timeout=5)
    try:
        do_work()
        requests.get(f"{API}/success", params={"run_id": run_id}, timeout=5)
    except Exception as e:
        requests.post(
            f"{API}/failure",
            params={"run_id": run_id},
            json={"payload": str(e)},
            timeout=5,
        )
        raise

const API = "https://api.drumbeats.io/v1/ping/<monitor-id>";

async function runJob(jobId: string) {
  const runId = `job-${jobId}-${Date.now()}`;
  await fetch(`${API}/start?run_id=${runId}`);
  try {
    await doWork(jobId);
    await fetch(`${API}/success?run_id=${runId}`);
  } catch (err) {
    await fetch(`${API}/failure?run_id=${runId}`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ payload: err instanceof Error ? err.message : String(err) }),
    });
    throw err;
  }
}

package main

import (
    "fmt"
    "net/http"
    "time"
)

const api = "https://api.drumbeats.io/v1/ping/<monitor-id>"

func runJob(jobID string) error {
    runID := fmt.Sprintf("job-%s-%d", jobID, time.Now().UnixNano())
    client := &http.Client{Timeout: 5 * time.Second}

    resp, _ := client.Get(fmt.Sprintf("%s/start?run_id=%s", api, runID))
    if resp != nil {
        resp.Body.Close()
    }

    if err := doWork(jobID); err != nil {
        if r, _ := client.Get(fmt.Sprintf("%s/failure?run_id=%s", api, runID)); r != nil {
            r.Body.Close()
        }
        return err
    }

    if r, _ := client.Get(fmt.Sprintf("%s/success?run_id=%s", api, runID)); r != nil {
        r.Body.Close()
    }
    return nil
}

$api = 'https://api.drumbeats.io/v1/ping/<monitor-id>';
$runId = 'job-' . uniqid('', true);

@file_get_contents("$api/start?run_id=$runId");
try {
    doWork();
    @file_get_contents("$api/success?run_id=$runId");
} catch (Throwable $e) {
    $ctx = stream_context_create([
        'http' => [
            'method' => 'POST',
            'header' => 'Content-Type: application/json',
            'content' => json_encode(['payload' => $e->getMessage()]),
            'timeout' => 5,
        ],
    ]);
    @file_get_contents("$api/failure?run_id=$runId", false, $ctx);
    throw $e;
}