Function TestProcessLineageFromOutbox

lineage_test.go:1248–1323

(t *testing.T)

}

func TestProcessLineageFromOutbox(t *testing.T) {
	ctx := context.Background()

	t.Run("Successfully processes outbox entry", func(t *testing.T) {
		mockDS := new(mocks.MockDataSource)

		txn := &model.Transaction{
			TransactionID: "txn_123",
			Source:        "bln_source",
			Destination:   "bln_dest",
			PreciseAmount: big.NewInt(10000),
			Currency:      "USD",
			MetaData:      map[string]interface{}{},
		}

		sourceBalance := &model.Balance{
			BalanceID:        "bln_source",
			TrackFundLineage: false,
		}
		destBalance := &model.Balance{
			BalanceID:        "bln_dest",
			TrackFundLineage: false,
		}

		entry := model.LineageOutbox{
			ID:                   1,
			TransactionID:        "txn_123",
			SourceBalanceID:      "bln_source",
			DestinationBalanceID: "bln_dest",
			LineageType:          "debit",
			Payload:              []byte(`{"amount":100,"currency":"USD"}`),
		}

		mockDS.On("GetTransaction", mock.Anything, "txn_123").Return(txn, nil)
		mockDS.On("GetBalanceByIDLite", "bln_source").Return(sourceBalance, nil)
		mockDS.On("GetBalanceByIDLite", "bln_dest").Return(destBalance, nil)

		ledgerforgeInstance := &LedgerForge{datasource: mockDS}

		err := ledgerforgeInstance.ProcessLineageFromOutbox(ctx, entry)
		assert.NoError(t, err)
	})

	t.Run("Handles missing source balance gracefully", func(t *testing.T) {
		mockDS := new(mocks.MockDataSource)

		txn := &model.Transaction{
			TransactionID: "txn_123",
			PreciseAmount: big.NewInt(10000),
			MetaData:      map[string]interface{}{},
		}

		destBalance := &model.Balance{
			BalanceID:        "bln_dest",
			TrackFundLineage: false,
		}

		entry := model.LineageOutbox{