apirouter

type APIAttempt struct {
	ID              string                 `json:"id"`
	TenantID        string                 `json:"tenant_id"`
	Status          string                 `json:"status"`
	Time            time.Time              `json:"time"`
	Code            string                 `json:"code,omitempty"`
	ResponseData    map[string]interface{} `json:"response_data,omitempty"`
	AttemptNumber   int                    `json:"attempt_number"`
	Manual          bool                   `json:"manual"`
	DestinationType string                 `json:"destination_type"`
	LatencyMs       *int64                 `json:"latency_ms"`

	EventID       string      `json:"event_id"`
	DestinationID string      `json:"destination_id"`
	Event         interface{} `json:"event,omitempty"`
	Destination   interface{} `json:"destination,omitempty"`
}

type APIAttemptDestination struct {
	*destregistry.DestinationDisplay
	Credentials *struct{} `json:"credentials,omitempty"` // shadows the embedded credentials
}

type APIEvent struct {
	ID                    string            `json:"id"`
	TenantID              string            `json:"tenant_id"`
	MatchedDestinationIDs []string          `json:"matched_destination_ids"`
	Topic                 string            `json:"topic"`
	Time                  time.Time         `json:"time"`
	EligibleForRetry      bool              `json:"eligible_for_retry"`
	Metadata              map[string]string `json:"metadata,omitempty"`
	Data                  json.RawMessage   `json:"data,omitempty"`
}

type APIEventFull struct {
	ID                    string            `json:"id"`
	TenantID              string            `json:"tenant_id"`
	MatchedDestinationIDs []string          `json:"matched_destination_ids,omitempty"`
	Topic                 string            `json:"topic"`
	Time                  time.Time         `json:"time"`
	EligibleForRetry      bool              `json:"eligible_for_retry"`
	Metadata              map[string]string `json:"metadata,omitempty"`
	Data                  json.RawMessage   `json:"data,omitempty"`
}

type APIEventSummary struct {
	ID                    string            `json:"id"`
	TenantID              string            `json:"tenant_id"`
	MatchedDestinationIDs []string          `json:"matched_destination_ids,omitempty"`
	Topic                 string            `json:"topic"`
	Time                  time.Time         `json:"time"`
	EligibleForRetry      bool              `json:"eligible_for_retry"`
	Metadata              map[string]string `json:"metadata,omitempty"`
}

type APIMetricsDataPoint struct {
	TimeBucket *time.Time     `json:"time_bucket,omitempty"`
	Dimensions map[string]any `json:"dimensions"`
	Metrics    map[string]any `json:"metrics"`
}

type APIMetricsMetadata struct {
	Granularity *string `json:"granularity,omitempty"`
	QueryTimeMs int64   `json:"query_time_ms"`
	RowCount    int     `json:"row_count"`
	RowLimit    int     `json:"row_limit"`
	Truncated   bool    `json:"truncated"`
}

type APIMetricsResponse struct {
	Data     []APIMetricsDataPoint `json:"data"`
	Metadata APIMetricsMetadata    `json:"metadata"`
}

type AttemptPaginatedResult struct {
	Models     []APIAttempt   `json:"models"`
	Pagination SeekPagination `json:"pagination"`
}

type AuthOptions struct {
	AdminOnly     bool
	RequireTenant bool
}

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

type CreateDestinationRequest struct {
	ID               string                  `json:"id" binding:"-"`
	Type             string                  `json:"type" binding:"required"`
	Topics           models.Topics           `json:"topics" binding:"required"`
	Filter           models.Filter           `json:"filter,omitempty" binding:"-"`
	Config           models.Config           `json:"config" binding:"-"`
	Credentials      models.Credentials      `json:"credentials" binding:"-"`
	DeliveryMetadata models.DeliveryMetadata `json:"delivery_metadata,omitempty" binding:"-"`
	Metadata         models.Metadata         `json:"metadata,omitempty" binding:"-"`
	CreatedAt        *time.Time              `json:"created_at,omitempty" binding:"-"`
	UpdatedAt        *time.Time              `json:"updated_at,omitempty" binding:"-"`
	DisabledAt       *time.Time              `json:"disabled_at,omitempty" binding:"-"`
}

type CursorParams struct {
	Next string
	Prev string
}

type DateFilterResult struct {
	GTE *time.Time // Greater than or equal (>=)
	LTE *time.Time // Less than or equal (<=)
	GT  *time.Time // Greater than (>)
	LT  *time.Time // Less than (<)
}

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

type ErrorResponse struct {
	Err     error       `json:"-"`
	Code    int         `json:"-"`
	Status  int         `json:"status"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type EventPaginatedResult struct {
	Models     []APIEvent     `json:"models"`
	Pagination SeekPagination `json:"pagination"`
}

type IncludeOptions struct {
	Event        bool
	EventData    bool
	ResponseData bool
	Destination  bool
}

type JWTClaims struct {
	TenantID     string
	DeploymentID string
}

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

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

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

type PublishedEvent struct {
	ID               string            `json:"id"`
	TenantID         string            `json:"tenant_id" binding:"required"`
	DestinationID    string            `json:"destination_id"`
	Topic            string            `json:"topic"`
	EligibleForRetry *bool             `json:"eligible_for_retry"`
	Time             time.Time         `json:"time"`
	Metadata         map[string]string `json:"metadata"`
	Data             json.RawMessage   `json:"data" binding:"required"`
}

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

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

type RouteDefinition struct {
	Method        string
	Path          string
	Handler       gin.HandlerFunc
	AdminOnly     bool
	RequireTenant bool
	Middlewares   []gin.HandlerFunc
}

type RouterConfig struct {
	ServiceName          string
	APIKey               string
	JWTSecret            string
	DeploymentID         string
	Topics               []string
	TopicsAllowWildcards bool
	Registry             destregistry.Registry
	PortalConfig         portal.PortalConfig
	GinMode              string
}

type RouterDeps struct {
	TenantStore         tenantstore.TenantStore
	LogStore            logstore.LogStore
	Logger              *logging.Logger
	DeliveryPublisher   deliveryPublisher
	EventHandler        eventHandler
	Telemetry           telemetry.Telemetry
	SubscriptionEmitter SubscriptionEmitter // optional — emits tenant.subscription.updated on destination mutations
}

type SeekPagination struct {
	OrderBy string  `json:"order_by"`
	Dir     string  `json:"dir"`
	Limit   int     `json:"limit"`
	Next    *string `json:"next"`
	Prev    *string `json:"prev"`
}

type SubscriptionEmitter interface {
	Emit(ctx context.Context, ev opevents.Event) error
}

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

type TenantRetriever interface {
	RetrieveTenant(ctx context.Context, tenantID string) (*models.Tenant, error)
}

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

type UpdateDestinationRequest struct {
	Type             string          `json:"type" binding:"-"`
	Topics           models.Topics   `json:"topics" binding:"-"`
	Filter           json.RawMessage `json:"filter" binding:"-"`
	Config           json.RawMessage `json:"config" binding:"-"`
	Credentials      json.RawMessage `json:"credentials" binding:"-"`
	DeliveryMetadata json.RawMessage `json:"delivery_metadata" binding:"-"`
	Metadata         json.RawMessage `json:"metadata" binding:"-"`
	DisabledAt       json.RawMessage `json:"disabled_at" binding:"-"`
}