Function TestLineageE2E_GetTransactionLineage_API

lineage_test.go:1040–1106

(t *testing.T)

}

func TestLineageE2E_GetTransactionLineage_API(t *testing.T) {
	ctx := context.Background()
	mockDS := new(mocks.MockDataSource)

	mainTxn := &model.Transaction{
		TransactionID: "txn_main_123",
		Source:        "bln_alice_main",
		Destination:   "bln_merchant",
		Amount:        70,
		Currency:      "USD",
		Status:        "APPLIED",
		MetaData: map[string]interface{}{
			"LEDGERFORGE_FUND_ALLOCATION": []interface{}{
				map[string]interface{}{"provider": "stripe", "amount": float64(50)},
				map[string]interface{}{"provider": "paypal", "amount": float64(20)},
			},
		},
	}

	shadowTxns := []model.Transaction{
		{
			TransactionID: "txn_shadow_1",
			Source:        "bln_alice_aggregate",
			Destination:   "bln_stripe_shadow",
			Amount:        50,
			MetaData: map[string]interface{}{
				"_shadow_for":   "txn_main_123",
				"_provider":     "stripe",
				"_lineage_type": "release",
			},
		},
		{
			TransactionID: "txn_shadow_2",
			Source:        "bln_alice_aggregate",
			Destination:   "bln_paypal_shadow",
			Amount:        20,
			MetaData: map[string]interface{}{
				"_shadow_for":   "txn_main_123",
				"_provider":     "paypal",
				"_lineage_type": "release",
			},
		},
	}

	mockDS.On("GetTransaction", mock.Anything, "txn_main_123").Return(mainTxn, nil)
	mockDS.On("GetTransactionsByShadowFor", mock.Anything, "txn_main_123").Return(shadowTxns, nil)

	ledgerforgeInstance := &LedgerForge{datasource: mockDS}

	t.Run("Get transaction lineage returns fund allocation and shadow txns", func(t *testing.T) {
		lineage, err := ledgerforgeInstance.GetTransactionLineage(ctx, "txn_main_123")
		assert.NoError(t, err)
		assert.NotNil(t, lineage)

		assert.Equal(t, "txn_main_123", lineage.TransactionID)

		assert.Len(t, lineage.FundAllocation, 2)
		assert.Equal(t, "stripe", lineage.FundAllocation[0]["provider"])