models

type AggregationType int

type ApiStore struct {
	// contains filtered or unexported fields
}

type BillableMetric struct {
	ID              string          `gorm:"primaryKey;->"`
	OrganizationID  string          `gorm:"->"`
	Code            string          `gorm:"->"`
	AggregationType AggregationType `gorm:"->"`
	FieldName       string          `gorm:"->"`
	Expression      string          `gorm:"->"`
	CreatedAt       time.Time       `gorm:"->"`
	UpdatedAt       time.Time       `gorm:"->"`
	DeletedAt       gorm.DeletedAt  `gorm:"index;->"`
}

type CacheStore struct {
	// contains filtered or unexported fields
}

type Cacher interface {
	Close() error
	ExpireKey(key string) utils.Result[bool]
}

type ChargeCache struct {
	CacheStore Cacher
}

type EnrichedEvent struct {
	InitialEvent   *Event          `json:"-"`
	BillableMetric *BillableMetric `json:"-"`
	Subscription   *Subscription   `json:"-"`
	FlatFilter     *FlatFilter     `json:"-"`

	OrganizationID          string            `json:"organization_id"`
	ExternalSubscriptionID  string            `json:"external_subscription_id"`
	SubscriptionID          string            `json:"subscription_id"`
	PlanID                  string            `json:"plan_id"`
	TransactionID           string            `json:"transaction_id"`
	Code                    string            `json:"code"`
	AggregationType         string            `json:"aggregation_type"`
	Properties              map[string]any    `json:"properties"`
	PreciseTotalAmountCents string            `json:"precise_total_amount_cents"`
	Source                  string            `json:"source,omitempty"`
	Value                   *string           `json:"value"`
	Timestamp               float64           `json:"timestamp"`
	TimestampStr            string            `json:"-"`
	Time                    time.Time         `json:"-"`
	ChargeID                *string           `json:"charge_id"`
	ChargeUpdatedAt         *time.Time        `json:"charge_updated_at"`
	ChargeFilterID          *string           `json:"charge_filter_id"`
	ChargeFilterUpdatedAt   *time.Time        `json:"charge_filter_updated_at"`
	GroupedBy               map[string]string `json:"grouped_by"`
}

type Event struct {
	OrganizationID          string           `json:"organization_id"`
	ExternalSubscriptionID  string           `json:"external_subscription_id"`
	TransactionID           string           `json:"transaction_id"`
	Code                    string           `json:"code"`
	Properties              map[string]any   `json:"properties"`
	PreciseTotalAmountCents string           `json:"precise_total_amount_cents"`
	Source                  string           `json:"source,omitempty"`
	Timestamp               any              `json:"timestamp"`
	SourceMetadata          *SourceMetadata  `json:"source_metadata"`
	IngestedAt              utils.CustomTime `json:"ingested_at"`
}

type FailedEvent struct {
	Event               Event     `json:"event"`
	InitialErrorMessage string    `json:"initial_error_message"`
	ErrorMessage        string    `json:"error_message"`
	ErrorCode           string    `json:"error_code"`
	FailedAt            time.Time `json:"failed_at"`
}

type FlagStore struct {
	// contains filtered or unexported fields
}

type Flagger interface {
	Flag(value string) error
}

type FlatFilter struct {
	OrganizationID        string            `gorm:"->"`
	BillableMetricCode    string            `gorm:"->"`
	PlanID                string            `gorm:"->"`
	ChargeID              string            `gorm:"->"`
	ChargeUpdatedAt       time.Time         `gorm:"->"`
	ChargeFilterID        *string           `gorm:"->"`
	ChargeFilterUpdatedAt *time.Time        `gorm:"->"`
	Filters               *FlatFilterValues `gorm:"type:jsonb"`
	PricingGroupKeys      PricingGroupKeys  `gorm:"type:jsonb"`
	PayInAdvance          bool              `gorm:"type:boolean"`
}

type FlatFilterValues map[string][]string

type PricingGroupKeys []string

type SourceMetadata struct {
	ApiPostProcess bool `json:"api_post_processed"`
}

type Subscription struct {
	ID           string       `gorm:"primaryKey;->"`
	ExternalID   string       `gorm:"->"`
	PlanID       string       `gorm:"->"`
	CreatedAt    time.Time    `gorm:"->"`
	UpdatedAt    time.Time    `gorm:"->"`
	StartedAt    sql.NullTime `gorm:"->"`
	TerminatedAt sql.NullTime `gorm:"->"`
}