REST API برای لاگ‌ها

curl -X POST https://trace.abrova.ir/api/logs/ingest \
  -H "x-api-key: $ABROVA_TRACE_SERVER_SECRET" \
  -H "Content-Type: application/json" \
  -d '{
    "sourceId": "api-server",
    "sourceName": "API Server",
    "level": "info",
    "message": "User login successful",
    "metadata": {
      "userId": "user_123",
      "ip": "192.168.1.1"
    }
  }'

curl -X POST https://trace.abrova.ir/api/logs/ingest/batch \
  -H "x-api-key: $ABROVA_TRACE_SERVER_SECRET" \
  -H "Content-Type: application/json" \
  -d '{
    "sourceId": "api-server",
    "logs": [
      { "level": "info", "message": "Request received: GET /api/users" },
      { "level": "debug", "message": "Querying database..." },
      { "level": "info", "message": "Response sent: 200 OK (45ms)" }
    ]
  }'

const ABROVA_TRACE_SERVER_SECRET = process.env.ABROVA_TRACE_SERVER_SECRET; // ab_srv_...
const ABROVA_TRACE_URL = 'https://trace.abrova.ir';

async function sendLog(sourceId, level, message, metadata = {}) {
await fetch(`${ABROVA_TRACE_URL}/api/logs/ingest`, {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'x-api-key': ABROVA_TRACE_SERVER_SECRET,
  },
  body: JSON.stringify({ sourceId, level, message, metadata }),
});
}

// Usage
sendLog('api-server', 'info', 'Server started on port 3000');
sendLog('api-server', 'error', 'Database connection failed', {
error: 'ECONNREFUSED',
});

import os
import requests

ABROVA_TRACE_SERVER_SECRET = os.environ.get('ABROVA_TRACE_SERVER_SECRET')  # ab_srv_...
ABROVA_TRACE_URL = 'https://trace.abrova.ir'

def send_log(source_id, level, message, metadata=None):
    requests.post(
        f'{ABROVA_TRACE_URL}/api/logs/ingest',
        json={
            'sourceId': source_id,
            'level': level,
            'message': message,
            'metadata': metadata or {},
        },
        headers={'x-api-key': ABROVA_TRACE_SERVER_SECRET},
        timeout=5,
    )

# Usage
send_log('worker', 'info', 'Job started')
send_log('worker', 'error', 'Job failed', {'job_id': '123'})

package main

import (
    "bytes"
    "encoding/json"
    "net/http"
    "os"
)

func sendLog(sourceId, level, message string, metadata map[string]interface{}) error {
    body, _ := json.Marshal(map[string]interface{}{
        "sourceId": sourceId,
        "level":    level,
        "message":  message,
        "metadata": metadata,
    })

    req, _ := http.NewRequest("POST",
        "https://trace.abrova.ir/api/logs/ingest",
        bytes.NewBuffer(body))
    req.Header.Set("Content-Type", "application/json")
    req.Header.Set("x-api-key", os.Getenv("ABROVA_TRACE_SERVER_SECRET"))

    _, err := http.DefaultClient.Do(req)
    return err
}

$ch = curl_init('https://trace.abrova.ir/api/logs/ingest');
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_HTTPHEADER => [
        'Content-Type: application/json',
        'x-api-key: ' . getenv('ABROVA_TRACE_SERVER_SECRET'),
    ],
    CURLOPT_POSTFIELDS => json_encode([
        'sourceId' => 'shop-backend',
        'level' => 'error',
        'message' => 'payment callback timeout order=ORD-8812',
    ]),
]);
curl_exec($ch);
curl_close($ch);