Method processLineageCredit

lineage.go:237–275

processLineageCredit processes a credit transaction for fund lineage tracking. It creates shadow balances and queues a shadow transaction to track the provider's funds. Parameters: - ctx context.Context: The context for the operation. - txn *model.Transaction: The credit transaction being processed

(ctx context.Context, txn *model.Transaction, destBalance *model.Balance, provider string)

// Returns:
// - error: An error if the credit processing fails.
func (l *LedgerForge) processLineageCredit(ctx context.Context, txn *model.Transaction, destBalance *model.Balance, provider string) error {
	ctx, span := tracer.Start(ctx, "ProcessLineageCredit")
	defer span.End()

	identityID := destBalance.IdentityID
	if identityID == "" {
		return fmt.Errorf("destination balance %s has no identity_id for lineage tracking", destBalance.BalanceID)
	}

	// Get or create the shadow and aggregate balances first (before locking)
	shadowBalance, aggregateBalance, err := l.getOrCreateLineageBalances(ctx, identityID, provider, txn.Currency)
	if err != nil {
		return err
	}

	// Use MultiLocker to lock both shadow and aggregate balances
	locker, err := l.acquireLineageLocks(ctx, []string{shadowBalance.BalanceID, aggregateBalance.BalanceID})
	if err != nil {
		span.RecordError(err)
		return err
	}
	defer l.releaseLock(ctx, locker)

	if err := l.queueShadowCreditTransaction(ctx, txn, destBalance, provider, shadowBalance, aggregateBalance, identityID); err != nil {
		return err
	}

	if err := l.upsertCreditLineageMapping(ctx, destBalance, provider, shadowBalance, aggregateBalance, identityID); err != nil {
		logrus.Errorf("failed to create lineage mapping after shadow transaction: %v (txn: %s, provider: %s)", err, txn.TransactionID, provider)
		span.RecordError(err)
		// Don't return error - shadow transaction succeeded, mapping is for optimization
	}

	span.AddEvent("Lineage credit processed", trace.WithAttributes(
		attribute.String("provider", provider),
		attribute.String("shadow_balance", shadowBalance.BalanceID),
	))
	return nil
}

// getOrCreateLineageBalances retrieves or creates the shadow and aggregate balances for lineage tracking.
//