selfsub

type CacheInvalidator interface {
	ClearSubscribeCache(ctx context.Context, data ...*usersub.Subscribe) error
}

type Deps struct {
	UserSubs UserSubscriptions
	Plans    repository.SubscribeRepo
	// Orders, Refunds, Logs and Inbox are ports onto the billing and
	// platform domains: the order a refund pays back, the refund stage of a
	// cancellation, the system log and the cancellation markers.
	Orders  OrderReader
	Refunds RefundSettler
	Cache   CacheInvalidator
	Logs    LogReader
	Inbox   MarkerReader
	Store   Store
	// SingleModel forbids holding more than one blocking subscription;
	// runtime-mutable, read per request.
	SingleModel func() bool
}

type LogReader interface {
	FilterSystemLog(ctx context.Context, filter *log.FilterParams) ([]*log.SystemLog, int64, error)
}

type MarkerReader interface {
	Find(ctx context.Context, consumer, eventKey string) (*inbox.Record, error)
}

type OrderReader interface {
	FindOneDetails(ctx context.Context, id int64) (*order.Details, error)
}

type RefundSettler interface {
	// UnsubscribeRefundSettled reports whether the subscription's refund was
	// settled.
	UnsubscribeRefundSettled(ctx context.Context, subscriptionID int64) (bool, error)
	// SettleUnsubscribeRefund settles it in a billing-domain transaction:
	// amount back to the user's wallet and the referral commission taken
	// back when the subscription has an order, and the refund marker; a
	// second settlement fails.
	SettleUnsubscribeRefund(ctx context.Context, userID, subscriptionID, orderID, amount int64) error
}

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

type Store interface {
	repository.SubscriptionTransactor
}

type UserSubscriptions interface {
	FindOneSubscribe(ctx context.Context, id int64) (*usersub.Subscribe, error)
	// FindOneUserSubscribe returns the subscription with its plan.
	FindOneUserSubscribe(ctx context.Context, id int64) (*usersub.SubscribeDetails, error)
	// QueryUserSubscribe lists the user's subscriptions with their plans;
	// given statuses, only those in one of them.
	QueryUserSubscribe(ctx context.Context, userID int64, statuses ...int64) ([]*usersub.SubscribeDetails, error)
	// UpdateSubscribeColumns writes only the named columns of data.Id.
	UpdateSubscribeColumns(ctx context.Context, data *usersub.Subscribe, columns ...string) error
}