Server-side events

curl -X POST https://api.productlense.app/api/v1/events \
  -H "Authorization: Bearer $PL_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"s":"SITE_ID","e":"Trial converted","u":"https://example.com/app/billing",
       "uid":"user_123","p":{"plan":"growth"},
       "ip":"203.0.113.7",
       "ua":"Mozilla/5.0 (Macintosh; Intel Mac OS X 14_6) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.6 Safari/605.1.15"}'

const res = await fetch('https://api.productlense.app/api/v1/events', {
  method: 'POST',
  headers: {
    Authorization: `Bearer ${process.env.PL_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    s: process.env.PL_SITE_ID,
    e: 'Trial converted',
    ip: req.ip, // the visitor's address, from the original request
    ua: req.get('user-agent'),
    u: 'https://example.com/app/billing',
    uid: user.id,
    p: { plan: 'growth' },
  }),
});
if (res.status !== 204) {
  const body = await res.json();
  throw new Error(`ProductLense rejected the event: ${body.error.code}: ${body.error.message}`);
}

import os
import requests

res = requests.post(
    "https://api.productlense.app/api/v1/events",
    headers={"Authorization": f"Bearer {os.environ['PL_API_KEY']}"},
    json={
        "s": os.environ["PL_SITE_ID"],
        "e": "Trial converted",
        "u": "https://example.com/app/billing",
        "ip": request.remote_addr,  # the visitor's address
        "ua": request.headers.get("User-Agent", ""),
        "uid": user.id,
        "p": {"plan": "growth"},
    },
    timeout=10,
)
if res.status_code != 204:
    err = res.json()["error"]
    raise RuntimeError(f"ProductLense rejected the event: {err['code']}: {err['message']}")

package productlense

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

type Event struct {
	Site   string            `json:"s"`
	Name   string            `json:"e"`
	URL    string            `json:"u"`
	UserID string            `json:"uid,omitempty"`
	IP     string            `json:"ip,omitempty"`
	UA     string            `json:"ua,omitempty"`
	Props  map[string]string `json:"p,omitempty"`
}

var client = &http.Client{Timeout: 10 * time.Second}

func Send(ev Event) error {
	body, err := json.Marshal(ev)
	if err != nil {
		return err
	}
	req, err := http.NewRequest(http.MethodPost, "https://api.productlense.app/api/v1/events", bytes.NewReader(body))
	if err != nil {
		return err
	}
	req.Header.Set("Authorization", "Bearer "+os.Getenv("PL_API_KEY"))
	req.Header.Set("Content-Type", "application/json")
	res, err := client.Do(req)
	if err != nil {
		return err
	}
	defer res.Body.Close()
	if res.StatusCode != http.StatusNoContent {
		return fmt.Errorf("productlense: events API returned %s", res.Status)
	}
	return nil
}