task

func NewExecutor ¶

func NewExecutor(
	accounts account.Store,
	chats chat.Store,
	messages messaging.Store,
	requests paymentrequest.Store,
	sender *messaging.Sender,
	ocpData ocp_data.Provider,
	chatEventBus *event.Bus[*commonpb.ChatId, *eventpb.ChatEvent],
) ocp_integration.TaskExecutor

NewExecutor constructs the task executor. messages is the messaging store, written to mark a payment's return offer returned (see sendReturnPaymentMessage); requests is the payment request store, written to mark a share paid by a requested payment, and chatEventBus the chat-keyed event bus the mark is announced on (see recordRequestedPayment).