Function enqueueTransactions

transaction.go:2098–2113

enqueueTransactions enqueues the original transaction or its split transactions into the provided queue. It starts by determining which transactions to enqueue, then iterates through them and enqueues each one. If an error occurs during enqueuing, it logs the error and sends a notification. Paramet

(ctx context.Context, queue *Queue, originalTransaction *model.Transaction, splitTransactions []*model.Transaction)

// Returns:
// - error: An error if any of the transactions could not be enqueued.
func enqueueTransactions(ctx context.Context, queue *Queue, originalTransaction *model.Transaction, splitTransactions []*model.Transaction) error {
	transactionsToEnqueue := splitTransactions
	if len(transactionsToEnqueue) == 0 {
		transactionsToEnqueue = []*model.Transaction{originalTransaction}
	}

	for _, txn := range transactionsToEnqueue {
		if err := queue.Enqueue(ctx, txn); err != nil {
			notification.NotifyError(err)
			logrus.WithError(err).Error("failed to queue transaction")
			return err
		}
	}

	return nil
}

// GetTransaction retrieves a transaction by its ID from the datasource.
// It starts a tracing span, fetches the transaction, and records relevant events and errors.