Method RecordAndCheck

internal/usage/usage.go:23–56

(ctx context.Context, userID, agentID, domain, direction string)

}

func (t *LiveUsageTracker) RecordAndCheck(ctx context.Context, userID, agentID, domain, direction string) (bool, error) {
	// Metering gate: resolve the account class once and short-circuit
	// non-standard accounts (internal/system/demo) BEFORE any write, so probe
	// and internal traffic never lands in usage_events/usage_summaries and thus
	// never counts against quota. On a lookup error we fail toward metering
	// (GetAccountClass returns ClassStandard) — a real customer is never
	// silently exempted from billing.
	class, err := t.store.GetAccountClass(ctx, userID)
	if err != nil {
		log.Printf("[billing] account class lookup failed for user %s, metering as standard: %v", userID, err)
	}
	if !PolicyFor(class).Meter {
		return true, nil
	}

	// Record the event
	event := &UsageEvent{
		UserID:    userID,
		AgentID:   agentID,
		Domain:    domain,
		Direction: direction,
	}
	if err := t.store.RecordUsageEvent(ctx, event); err != nil {
		log.Printf("[billing] failed to record usage event: %v", err)
		// Don't block on recording failure
	}

	bucketDate := CurrentDate()
	if err := t.store.IncrementUsageSummary(ctx, userID, bucketDate, direction); err != nil {
		log.Printf("[billing] failed to increment usage summary: %v", err)
	}

	return true, nil
}

// NoopUsageTracker always allows everything. Used when billing is disabled.
type NoopUsageTracker struct{}