integration

type Antispam interface {
	AllowOpenAccounts(ctx context.Context, owner *common.Account, accountSet transactionpb.OpenAccountsMetadata_AccountSet) (bool, string, error)

	AllowSendPayment(ctx context.Context, owner, destination *common.Account, isPublic bool) (bool, string, error)

	AllowReceivePayments(ctx context.Context, owner *common.Account, isPublic bool) (bool, string, error)

	AllowDistribution(ctx context.Context, owner *common.Account, isPublic bool) (bool, string, error)

	AllowSwap(ctx context.Context, kind swap.Kind, fundingSource swap.FundingSource, owner, fromMint, toMint *common.Account, swapAmount, feeAmount uint64, initializesMint bool) (bool, string, error)

	AllowCurrencyLaunch(ctx context.Context, owner *common.Account, name, symbol string) (bool, string, error)
}

type Geyser interface {
	// OnDepositReceived allows for notifications for external deposits processed by Geyser
	OnDepositReceived(ctx context.Context, owner, mint *common.Account, currencyName string, usdMarketValue float64) error
}

type Moderation interface {
	// ValidateAttestation validates a moderation attestation for a piece of moderated content
	ValidateAttestation(ctx context.Context, owner *common.Account, rawAttestation []byte, content any) (bool, error)
}

type SubmitIntent interface {
	// AllowCreation determines whether the new intent creation should be allowed
	// with app-specific validation rules
	AllowCreation(ctx context.Context, intentRecord *intent.Record, metadata *transactionpb.Metadata, actions []*transactionpb.Action) error

	// GetTasksToSchedule returns app-defined tasks whose execution is
	// guaranteed once the intent is committed. Returned tasks are persisted in
	// the same DB transaction that commits the intent, so an error fails the
	// whole submission and no tasks are scheduled.
	//
	// Execution is delegated to the app's TaskExecutor and is at-least-once: a
	// best-effort attempt is made immediately after commit, with the background
	// worker retrying anything that fails. The same task may therefore execute
	// more than once and concurrently, so the TaskExecutor must be idempotent.
	GetTasksToSchedule(ctx context.Context, intentRecord *intent.Record) ([]*task.Record, error)

	// OnSuccess is a best-effort callback when an intent has been successfully
	// submitted
	OnSuccess(ctx context.Context, intentRecord *intent.Record) error
}

type Swap interface {
	// OnSwapSubmitted allows for notification when the swap for when a swap is submitted
	OnSwapSubmitted(ctx context.Context, owner *common.Account, fromMint, toMint *common.Account) error

	// OnSwapFinalized allows for notifications based on events processed by the swap worker
	OnSwapFinalized(ctx context.Context, owner *common.Account, isBuy bool, mint *common.Account, currencyName string, region currency.Code, valueReceived float64, isMintInit bool) error
}

type TaskExecutor interface {
	Execute(ctx context.Context, record *task.Record) error
}