orderLogic

type ActivateOrderLogic ¶

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

ActivateOrderLogic sequences the activation saga stages.

func NewActivateOrderLogic(deps Dependencies) *ActivateOrderLogic

func (l *ActivateOrderLogic) ProcessTask(ctx context.Context, task *asynq.Task) error

type CleanupOrderEventsLogic ¶ added in v1.14.19

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

CleanupOrderEventsLogic removes only events that have already reached Redis and are older than the replay contract. Unpublished events are never deleted, even if an outage lasts longer than the normal retention period.

func NewCleanupOrderEventsLogic(deps Dependencies) *CleanupOrderEventsLogic

func (l *CleanupOrderEventsLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error

type DailyOrderReportLogic ¶ added in v1.15.16

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

DailyOrderReportLogic posts the previous day's settlement summary into the admin group's notification topic. It reports yesterday because it runs after midnight, when the day it summarises is complete.

func NewDailyOrderReportLogic(deps Dependencies) *DailyOrderReportLogic

func (l *DailyOrderReportLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error

type DeferCloseOrderLogic ¶

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

func NewDeferCloseOrderLogic(deps Dependencies) *DeferCloseOrderLogic

func (l *DeferCloseOrderLogic) ProcessTask(ctx context.Context, task *asynq.Task) error

type Dependencies ¶ added in v1.19.0

type Dependencies struct {
	Store        repository.Store
	Redis        *redis.Client
	Queue        *asynqx.Client
	Inspector    *asynq.Inspector
	Billing      billing.Service
	Subscription subscription.Service
	Notification notification.Service
	Telegram     func() config.Telegram
}

type PublishOrderEventsLogic ¶ added in v1.14.19

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

PublishOrderEventsLogic drains the durable order event outbox. Publishing is intentionally separate from writing the event: a Redis outage may delay a notification but can never roll back a committed payment state.

func NewPublishOrderEventsLogic(deps Dependencies) *PublishOrderEventsLogic

func (l *PublishOrderEventsLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error

type ReconcilePaidOrdersLogic ¶ added in v1.14.0

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

ReconcilePaidOrdersLogic treats the durable Paid state as an activation outbox. It repairs the database/Redis gap if a callback committed payment but Redis was unavailable before the activation task could be inserted.

func NewReconcilePaidOrdersLogic(deps Dependencies) *ReconcilePaidOrdersLogic

func (l *ReconcilePaidOrdersLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error

type ReconcilePendingOrdersLogic ¶ added in v1.14.16

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

ReconcilePendingOrdersLogic is a durable fallback for deferred close tasks. State transitions in CloseOrder remain conditional, so a late callback can safely race this scan without turning a paid order back into a close order.

func NewReconcilePendingOrdersLogic(deps Dependencies) *ReconcilePendingOrdersLogic

func (l *ReconcilePendingOrdersLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error