Method postTransactionActions

transaction.go:333–370

postTransactionActions performs post-processing actions for a transaction. It starts a tracing span, queues the transaction and balance data for indexing in dependency order, sends a webhook notification, and processes fund lineage if applicable. Parameters: - ctx context.Context: The context for t

(ctx context.Context, transaction *model.Transaction, sourceBalance, destinationBalance *model.Balance)

// - sourceBalance *model.Balance: The source balance (can be nil for rejected transactions).
// - destinationBalance *model.Balance: The destination balance (can be nil for rejected transactions).
func (l *LedgerForge) postTransactionActions(ctx context.Context, transaction *model.Transaction, sourceBalance, destinationBalance *model.Balance) {
	_, span := tracer.Start(ctx, "Post Transaction Actions")
	defer span.End()
	go func() {
		// Create an index batch to ensure balances are indexed before the transaction
		batch := search.NewIndexBatch(transaction.TransactionID)

		// Add balances as dependencies (indexed first) if they exist
		if sourceBalance != nil {
			batch.AddDependency("balances", sourceBalance.BalanceID, sourceBalance)
		}
		if destinationBalance != nil {
			batch.AddDependency("balances", destinationBalance.BalanceID, destinationBalance)
		}

		// Set transaction as the primary item (indexed after dependencies)
		batch.SetPrimary(l.Config().Transaction.IndexQueuePrefix, transaction.TransactionID, transaction)

		// Queue the batch for indexing
		err := l.queue.queueIndexBatch(batch)
		if err != nil {
			span.RecordError(err)
			notification.NotifyError(err)
		}

		// Send webhook notification
		err = l.SendWebhook(NewWebhook{
			Event:   getEventFromStatus(transaction.Status),
			Payload: transaction,
		})
		if err != nil {
			span.RecordError(err)
			notification.NotifyError(err)
		}

		span.AddEvent("Post-transaction actions completed")
	}()
}

// validateTxn validates a transaction by checking if its reference has already been used.
// It starts a tracing span, checks the existence of the transaction reference, and records relevant events and errors.