Method runTransactionPostCommitWorkWithHooks

transaction.go:1112–1132

runTransactionPostCommitWorkWithHooks executes monitor checks, post-hooks, and post-transaction actions for persisted work items, optionally reusing a preloaded hook set.

(ctx context.Context, span trace.Span, orderedBalances []*model.Balance, postCommitWork []queuedBatchPostCommitWork, postHooks []*ledgerforgehooks.Hook)

// runTransactionPostCommitWorkWithHooks executes monitor checks, post-hooks, and
// post-transaction actions for persisted work items, optionally reusing a preloaded hook set.
func (l *LedgerForge) runTransactionPostCommitWorkWithHooks(ctx context.Context, span trace.Span, orderedBalances []*model.Balance, postCommitWork []queuedBatchPostCommitWork, postHooks []*ledgerforgehooks.Hook) {
	for _, balance := range orderedBalances {
		go l.checkBalanceMonitors(ctx, balance)
	}

	for _, work := range postCommitWork {
		if l.Hooks != nil {
			var err error
			if postHooks != nil {
				err = l.Hooks.ExecuteHooks(ctx, postHooks, ledgerforgehooks.PostTransaction, work.transaction.TransactionID, work.transaction)
			} else {
				err = l.Hooks.ExecutePostHooks(ctx, work.transaction.TransactionID, work.transaction)
			}
			if err != nil {
				span.RecordError(err)
				logrus.WithError(err).Error("post-transaction hooks failed")
			}
		}
		l.postTransactionActions(ctx, work.transaction, work.sourceBalance, work.destinationBalance)
	}
}

// listHooksForExecution returns the current hook set for the requested type, or nil when
// hook execution is not configured for the current LedgerForge instance.