mirror of
https://github.com/multica-ai/multica.git
synced 2026-07-27 21:33:41 +02:00
216aee5629
* feat(analytics): add daily client usage reporting (MUL-5125) Co-authored-by: multica-agent <github@multica.ai> * fix(analytics): clarify daily usage semantics (MUL-5125) Co-authored-by: multica-agent <github@multica.ai> * fix(analytics): resolve usage review blockers (MUL-5125) Co-authored-by: multica-agent <github@multica.ai> --------- Co-authored-by: Eve <eve@multica-ai.local> Co-authored-by: multica-agent <github@multica.ai>
115 lines
3.4 KiB
Go
115 lines
3.4 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.31.1
|
|
// source: client_usage.sql
|
|
|
|
package db
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/jackc/pgx/v5/pgtype"
|
|
)
|
|
|
|
const upsertClientUsageDaily = `-- name: UpsertClientUsageDaily :one
|
|
INSERT INTO client_usage_daily (
|
|
user_id,
|
|
client_type,
|
|
install_id,
|
|
activity_date,
|
|
workspace_id,
|
|
client_version,
|
|
os,
|
|
first_active_at,
|
|
last_active_at,
|
|
runtime_probed_at,
|
|
probe_result,
|
|
runtime_count,
|
|
provider_summary,
|
|
online_count,
|
|
offline_count
|
|
) VALUES (
|
|
$1,
|
|
$2,
|
|
$3,
|
|
(CURRENT_TIMESTAMP AT TIME ZONE 'UTC')::date,
|
|
$4,
|
|
$5,
|
|
$6,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP,
|
|
CASE WHEN $7::boolean THEN CURRENT_TIMESTAMP ELSE NULL END,
|
|
$8,
|
|
$9,
|
|
$10,
|
|
$11,
|
|
$12
|
|
)
|
|
ON CONFLICT (user_id, client_type, install_id, activity_date) DO UPDATE SET
|
|
workspace_id = COALESCE(EXCLUDED.workspace_id, client_usage_daily.workspace_id),
|
|
client_version = EXCLUDED.client_version,
|
|
os = EXCLUDED.os,
|
|
last_active_at = EXCLUDED.last_active_at,
|
|
runtime_probed_at = CASE WHEN $7::boolean THEN EXCLUDED.runtime_probed_at ELSE client_usage_daily.runtime_probed_at END,
|
|
probe_result = CASE WHEN $7::boolean THEN EXCLUDED.probe_result ELSE client_usage_daily.probe_result END,
|
|
runtime_count = CASE WHEN $7::boolean THEN EXCLUDED.runtime_count ELSE client_usage_daily.runtime_count END,
|
|
provider_summary = CASE WHEN $7::boolean THEN EXCLUDED.provider_summary ELSE client_usage_daily.provider_summary END,
|
|
online_count = CASE WHEN $7::boolean THEN EXCLUDED.online_count ELSE client_usage_daily.online_count END,
|
|
offline_count = CASE WHEN $7::boolean THEN EXCLUDED.offline_count ELSE client_usage_daily.offline_count END,
|
|
updated_at = CURRENT_TIMESTAMP
|
|
RETURNING user_id, client_type, install_id, activity_date, workspace_id, client_version, os, first_active_at, last_active_at, runtime_probed_at, probe_result, runtime_count, provider_summary, online_count, offline_count, created_at, updated_at
|
|
`
|
|
|
|
type UpsertClientUsageDailyParams struct {
|
|
UserID pgtype.UUID `json:"user_id"`
|
|
ClientType string `json:"client_type"`
|
|
InstallID pgtype.UUID `json:"install_id"`
|
|
WorkspaceID pgtype.UUID `json:"workspace_id"`
|
|
ClientVersion string `json:"client_version"`
|
|
Os string `json:"os"`
|
|
HasRuntimeProbe bool `json:"has_runtime_probe"`
|
|
ProbeResult pgtype.Text `json:"probe_result"`
|
|
RuntimeCount pgtype.Int4 `json:"runtime_count"`
|
|
ProviderSummary []byte `json:"provider_summary"`
|
|
OnlineCount pgtype.Int4 `json:"online_count"`
|
|
OfflineCount pgtype.Int4 `json:"offline_count"`
|
|
}
|
|
|
|
func (q *Queries) UpsertClientUsageDaily(ctx context.Context, arg UpsertClientUsageDailyParams) (ClientUsageDaily, error) {
|
|
row := q.db.QueryRow(ctx, upsertClientUsageDaily,
|
|
arg.UserID,
|
|
arg.ClientType,
|
|
arg.InstallID,
|
|
arg.WorkspaceID,
|
|
arg.ClientVersion,
|
|
arg.Os,
|
|
arg.HasRuntimeProbe,
|
|
arg.ProbeResult,
|
|
arg.RuntimeCount,
|
|
arg.ProviderSummary,
|
|
arg.OnlineCount,
|
|
arg.OfflineCount,
|
|
)
|
|
var i ClientUsageDaily
|
|
err := row.Scan(
|
|
&i.UserID,
|
|
&i.ClientType,
|
|
&i.InstallID,
|
|
&i.ActivityDate,
|
|
&i.WorkspaceID,
|
|
&i.ClientVersion,
|
|
&i.Os,
|
|
&i.FirstActiveAt,
|
|
&i.LastActiveAt,
|
|
&i.RuntimeProbedAt,
|
|
&i.ProbeResult,
|
|
&i.RuntimeCount,
|
|
&i.ProviderSummary,
|
|
&i.OnlineCount,
|
|
&i.OfflineCount,
|
|
&i.CreatedAt,
|
|
&i.UpdatedAt,
|
|
)
|
|
return i, err
|
|
}
|