Отправка событий с бэкенда

curl

test -n "$ACTIONPULSE_SERVER_KEY" || { echo "ACTIONPULSE_SERVER_KEY is required" >&2; exit 1; }

curl -X POST https://YOUR_ACTIONPULSE_HOST/v1/track \
  -H "Authorization: Bearer $ACTIONPULSE_SERVER_KEY" \
  -H "Content-Type: application/json" \
  -d '{"batch":[{
    "event_id":"8b0d3f2e-1c4a-4f0e-9b1d-2a3c4d5e6f70",
    "schema_version":1,
    "event":"order_created",
    "user_id":"YOUR_USER_ID",
    "time":"2026-07-27T12:00:00Z",
    "props":{"plan":"pro","total":990}
  }]}'

Node.js

import { randomUUID } from 'node:crypto';

const serverKey = process.env.ACTIONPULSE_SERVER_KEY;
if (!serverKey) throw new Error('ACTIONPULSE_SERVER_KEY is required');

const response = await fetch('https://YOUR_ACTIONPULSE_HOST/v1/track', {
  method: 'POST',
  headers: {
    Authorization: `Bearer ${serverKey}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    batch: [
      {
        event_id: randomUUID(),
        schema_version: 1,
        event: 'order_created',
        user_id: 'YOUR_USER_ID',
        time: new Date().toISOString(),
        props: { plan: 'pro', total: 990 },
      },
    ],
  }),
});

if (response.status !== 202) {
  throw new Error(`track failed: ${response.status}`);
}

const result = await response.json();
if (result.rejected.length > 0) {
  console.error('events rejected', result.rejected);
}

Go

serverKey := os.Getenv("ACTIONPULSE_SERVER_KEY")
if serverKey == "" {
    log.Fatal("ACTIONPULSE_SERVER_KEY is required")
}

body, err := json.Marshal(map[string]any{"batch": []map[string]any{{
    "event_id":       uuid.NewString(),
    "schema_version": 1,
    "event":          "order_created",
    "user_id":        "YOUR_USER_ID",
    "time":           time.Now().UTC().Format(time.RFC3339Nano),
    "props":          map[string]any{"plan": "pro", "total": 990},
}}})
if err != nil {
    return err
}

req, err := http.NewRequestWithContext(ctx, http.MethodPost,
    "https://YOUR_ACTIONPULSE_HOST/v1/track", bytes.NewReader(body))
if err != nil {
    return err
}
req.Header.Set("Authorization", "Bearer "+serverKey)
req.Header.Set("Content-Type", "application/json")

resp, err := http.DefaultClient.Do(req)
if err != nil {
    return err
}
defer resp.Body.Close()

if resp.StatusCode != http.StatusAccepted {
    return fmt.Errorf("track failed: %s", resp.Status)
}

Python

import datetime, os, uuid, requests

server_key = os.environ["ACTIONPULSE_SERVER_KEY"]

response = requests.post(
    "https://YOUR_ACTIONPULSE_HOST/v1/track",
    json={"batch": [{
        "event_id": str(uuid.uuid4()),
        "schema_version": 1,
        "event": "order_created",
        "user_id": "YOUR_USER_ID",
        "time": datetime.datetime.now(datetime.UTC).isoformat(),
        "props": {"plan": "pro", "total": 990},
    }]},
    headers={"Authorization": f"Bearer {server_key}"},
    timeout=5,
)
response.raise_for_status()

for item in response.json()["rejected"]:
    print("rejected", item)