ZCode
34290b9371
Two blockers found while wiring OpenPanel for real:
- frontend/Dockerfile declared ARG for VITE_OPENPANEL_URL/CLIENT_ID/SENTRY_DSN but not
VITE_OPENPANEL_SCRIPT_URL, so passing it as a build arg was silently ignored and the
loader compiled out (import.meta.env value undefined).
- backend/app/services/analytics.py posted a flat {type, event, properties} body; the
Track API expects {type, payload:{event, properties, profileId}} (verified against the
SDK source in packages/sdks/sdk). The API answered 400 and the module swallows every
error by design, so all server-side events were being dropped without a trace.
Verified after deploy: the bundle carries the client id + op1.js URL + the queueing shim,
op1.js serves 200, and a track event posted with the real envelope lands in OpenPanel.
76 lines
3.0 KiB
Python
76 lines
3.0 KiB
Python
"""Server-side product analytics — OpenPanel Track API.
|
|
|
|
Fire-and-forget business events (quote lifecycle, receipts, logins) so the
|
|
OpenPanel dashboards show what actually happens inside the ERP, not just
|
|
page views. Never raises: analytics must not break a business flow.
|
|
|
|
Configuration (all optional — disabled when any is missing):
|
|
PROCUREMENT_OPENPANEL_API_URL e.g. http://openpanel-api:3333 (self-hosted)
|
|
PROCUREMENT_OPENPANEL_CLIENT_ID project client id (write mode)
|
|
PROCUREMENT_OPENPANEL_CLIENT_SECRET project client secret
|
|
|
|
Contract (OpenPanel Track API): POST {API_URL}/track with headers
|
|
``openpanel-client-id`` / ``openpanel-client-secret`` and a JSON body
|
|
``{"type": "track"|"identify", "profileId": ..., "event"/"properties": ...}``.
|
|
"""
|
|
import logging
|
|
from typing import Any
|
|
|
|
import httpx
|
|
|
|
from app.config import settings
|
|
|
|
logger = logging.getLogger("procurement.analytics")
|
|
|
|
_TIMEOUT = httpx.Timeout(3.0)
|
|
|
|
|
|
def _configured() -> bool:
|
|
return bool(
|
|
settings.OPENPANEL_API_URL
|
|
and settings.OPENPANEL_CLIENT_ID
|
|
and settings.OPENPANEL_CLIENT_SECRET
|
|
)
|
|
|
|
|
|
async def track(event: str, properties: dict[str, Any] | None = None, profile_id: str | None = None) -> None:
|
|
"""Record a named event; swallows every error."""
|
|
if not _configured():
|
|
return
|
|
# OpenPanel's Track API takes {type, payload:{…}} (same envelope the browser SDK
|
|
# sends) — a flat body is rejected with 400, which this module swallows by design.
|
|
inner: dict[str, Any] = {"event": event, "properties": properties or {}}
|
|
if profile_id:
|
|
inner["profileId"] = profile_id
|
|
body = {"type": "track", "payload": inner}
|
|
try:
|
|
async with httpx.AsyncClient(timeout=_TIMEOUT) as client:
|
|
await client.post(
|
|
f"{settings.OPENPANEL_API_URL.rstrip('/')}/track",
|
|
json=body,
|
|
headers={
|
|
"openpanel-client-id": settings.OPENPANEL_CLIENT_ID,
|
|
"openpanel-client-secret": settings.OPENPANEL_CLIENT_SECRET,
|
|
},
|
|
)
|
|
except Exception as exc: # noqa: BLE001 — analytics must never raise
|
|
logger.debug("analytics track failed (%s): %s", event, exc)
|
|
|
|
|
|
async def identify(profile_id: str, properties: dict[str, Any] | None = None) -> None:
|
|
"""Create/update a user profile (e.g. on login)."""
|
|
if not _configured():
|
|
return
|
|
try:
|
|
async with httpx.AsyncClient(timeout=_TIMEOUT) as client:
|
|
await client.post(
|
|
f"{settings.OPENPANEL_API_URL.rstrip('/')}/track",
|
|
json={"type": "identify", "payload": {"profileId": profile_id, "properties": properties or {}}},
|
|
headers={
|
|
"openpanel-client-id": settings.OPENPANEL_CLIENT_ID,
|
|
"openpanel-client-secret": settings.OPENPANEL_CLIENT_SECRET,
|
|
},
|
|
)
|
|
except Exception as exc: # noqa: BLE001
|
|
logger.debug("analytics identify failed: %s", exc)
|