Configure monitors

async function processWebhookWithRetry(
  payload: any,
  maxRetries: number = 3
): Promise<boolean> {
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    try {
      // Your processing logic
      await processRecords(payload.records);
      return true;
    } catch (error) {
      if (attempt < maxRetries - 1) {
        const waitTime = Math.pow(2, attempt) * 1000; // 1s, 2s, 4s
        await new Promise((resolve) => setTimeout(resolve, waitTime));
        continue;
      } else {
        // Log failure after all retries
        await logWebhookFailure(payload, error.message);
        return false;
      }
    }
  }
  return false;
}

import java.util.Map;
import java.util.List;

public boolean processWebhookWithRetry(Map<String, Object> payload, int maxRetries) {
    for (int attempt = 0; attempt < maxRetries; attempt++) {
        try {
            // Your processing logic
            processRecords((List<?>) payload.get("records"));
            return true;

        } catch (Exception e) {
            if (attempt < maxRetries - 1) {
                long waitTime = (long) Math.pow(2, attempt) * 1000; // 1s, 2s, 4s
                try {
                    Thread.sleep(waitTime);
                } catch (InterruptedException ie) {
                    Thread.currentThread().interrupt();
                    return false;
                }
            } else {
                // Log failure after all retries
                logWebhookFailure(payload, e.getMessage());
                return false;
            }
        }
    }
    return false;
}

import * as fs from "fs";

function logWebhook(payload: any, status: string): void {
  const logEntry = {
    timestamp: new Date().toISOString(),
    monitor_id: payload.monitor_id,
    latest_job_id: payload.latest_job_id,
    records_count: payload.records_count,
    status: status,
  };

  fs.appendFileSync(
    "webhook_log.jsonl",
    JSON.stringify(logEntry) + "\n",
    "utf8"
  );
}

import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.FileWriter;
import java.io.IOException;
import java.time.Instant;
import java.util.HashMap;
import java.util.Map;

public void logWebhook(Map<String, Object> payload, String status) {
    Map<String, Object> logEntry = new HashMap<>();
    logEntry.put("timestamp", Instant.now().toString());
    logEntry.put("monitor_id", payload.get("monitor_id"));
    logEntry.put("latest_job_id", payload.get("latest_job_id"));
    logEntry.put("records_count", payload.get("records_count"));
    logEntry.put("status", status);

    try (FileWriter writer = new FileWriter("webhook_log.jsonl", true)) {
        ObjectMapper mapper = new ObjectMapper();
        writer.write(mapper.writeValueAsString(logEntry) + "\n");
    } catch (IOException e) {
        logger.error("Failed to write webhook log", e);
    }
}