subscriptionsync

type Adapter interface {
	SyncStateAdapter

	entutils.TxCreator
}

type EventHandler interface {
	HandleCancelledEvent(ctx context.Context, event *subscription.CancelledEvent) error
	HandleSubscriptionSyncEvent(ctx context.Context, event *subscription.SubscriptionSyncEvent) error
	HandleInvoiceCreation(ctx context.Context, event *billing.InvoiceCreatedEvent) error
}

type GetSyncStatesInput = []models.NamespacedID

type InvalidateSyncStateInput = models.NamespacedID

type Service interface {
	EventHandler
	SyncService
	SyncStateService
}

type SyncService interface {
	SynchronizeSubscriptionAndInvoiceCustomer(ctx context.Context, subs subscription.SubscriptionView, asOf time.Time) error
	SynchronizeSubscription(ctx context.Context, subs subscription.SubscriptionView, asOf time.Time) error
}

type SyncState struct {
	SubscriptionID models.NamespacedID
	HasBillables   bool
	SyncedAt       time.Time
	NextSyncAfter  *time.Time
}

type SyncStateAdapter interface {
	InvalidateSyncState(ctx context.Context, input InvalidateSyncStateInput) error
	GetSyncStates(ctx context.Context, input GetSyncStatesInput) ([]SyncState, error)
	UpsertSyncState(ctx context.Context, input UpsertSyncStateInput) error
}

type SyncStateService interface {
	GetSyncStates(ctx context.Context, input GetSyncStatesInput) ([]SyncState, error)
}

type UpsertSyncStateInput = SyncState