#81: Expand on pathpayment strict send assertions, add path payment s…

…trict receive test

internal/services/ingest_test.go

@@ -289,7 +289,93 @@ func TestIngestPathPaymentsSend(t *testing.T) {
 		payments, _, _, err := models.Payments.GetPaymentsPaginated(context.Background(), srcAccount, "", "", data.ASC, 1)
 		require.NoError(t, err)
 		require.NotEmpty(t, payments, "Expected at least one payment")
-		assert.Equal(t, payments[0].TransactionHash, "efgh")
+		assert.Equal(t, payments[0].TransactionHash, *&ledgerTransaction.Hash)
+		assert.Equal(t, payments[0].SrcAmount, int64(100000000))
+		assert.Equal(t, payments[0].SrcAssetType, xdr.AssetTypeAssetTypeNative.String())
+		assert.Equal(t, payments[0].ToAddress, destAccount)
+		assert.Equal(t, payments[0].FromAddress, srcAccount)
+		assert.Equal(t, payments[0].SrcAssetCode, "XLM")
+		assert.Equal(t, payments[0].DestAssetCode, "XLM")
 	})
+}
+
+func TestIngestPathPaymentsReceive(t *testing.T) {
+	dbt := dbtest.Open(t)
+	defer dbt.Close()
+
+	dbConnectionPool, err := db.OpenDBConnectionPool(dbt.DSN)
+	require.NoError(t, err)
+	defer dbConnectionPool.Close()
+	models, _ := data.NewModels(dbConnectionPool)
+	mockAppTracker := apptracker.MockAppTracker{}
+	mockRPCService := RPCServiceMock{}
+	mockRouter := tssrouter.MockRouter{}
+	tssStore, _ := tssstore.NewStore(dbConnectionPool)
+	ingestService, _ := NewIngestService(models, "ingestionLedger", &mockAppTracker, &mockRPCService, &mockRouter, tssStore)
+	srcAccount := keypair.MustRandom().Address()
+	destAccount := keypair.MustRandom().Address()
+	usdIssuer := keypair.MustRandom().Address()
+	eurIssuer := keypair.MustRandom().Address()
+
+	t.Run("test_op_path_payment_receive", func(t *testing.T) {
+		err := models.Account.Insert(context.Background(), srcAccount)
+		require.NoError(t, err)
+
+		path := []txnbuild.Asset{
+			txnbuild.CreditAsset{Code: "USD", Issuer: usdIssuer},
+			txnbuild.CreditAsset{Code: "EUR", Issuer: eurIssuer},
+		}
+
+		pathPaymentOp := txnbuild.PathPaymentStrictReceive{
+			SourceAccount: srcAccount,
+			Destination:   destAccount,
+			SendMax:       "11",
+			DestAmount:    "10",
+			SendAsset:     txnbuild.NativeAsset{},
+			DestAsset:     txnbuild.NativeAsset{},
+			Path:          path,
+		}
+		transaction, err := txnbuild.NewTransaction(txnbuild.TransactionParams{
+			SourceAccount: &txnbuild.SimpleAccount{
+				AccountID: keypair.MustRandom().Address(),
+			},
+			Operations:    []txnbuild.Operation{&pathPaymentOp},
+			Preconditions: txnbuild.Preconditions{TimeBounds: txnbuild.NewTimeout(10)},
+		})
+		require.NoError(t, err)
+
+		signer := keypair.MustRandom()
+		errSigner := models.Account.Insert(context.Background(), signer.Address())
+		require.NoError(t, errSigner)
+
+		signedTx, err := transaction.Sign(network.TestNetworkPassphrase, signer)
+		require.NoError(t, err)
+
+		txEnvXDR, err := signedTx.Base64()
+		require.NoError(t, err)
 
+		ledgerTransaction := entities.Transaction{
+			Status:           entities.SuccessStatus,
+			Hash:             "efgh",
+			ApplicationOrder: 1,
+			FeeBump:          false,
+			EnvelopeXDR:      txEnvXDR,
+			ResultXDR:        "AAAAAAAAAGQAAAAAAAAAAQAAAAAAAAACAAAAAAAAAAAAAAAAjOiEfRh4kaFVQDu/CSTZLMtnyg0DbNowZ/G2nLES3KwAAAAAAAAAAAVdSoAAAAAA",
+			Ledger:           1,
+		}
+
+		ledgerTransactions := []entities.Transaction{ledgerTransaction}
+
+		err = ingestService.ingestPayments(context.Background(), ledgerTransactions)
+
+		payments, _, _, err := models.Payments.GetPaymentsPaginated(context.Background(), srcAccount, "", "", data.ASC, 1)
+		require.NoError(t, err)
+		require.NotEmpty(t, payments, "Expected at least one payment")
+		assert.Equal(t, payments[0].TransactionHash, *&ledgerTransaction.Hash)
+		assert.Equal(t, payments[0].SrcAssetType, xdr.AssetTypeAssetTypeNative.String())
+		assert.Equal(t, payments[0].ToAddress, destAccount)
+		assert.Equal(t, payments[0].FromAddress, srcAccount)
+		assert.Equal(t, payments[0].SrcAssetCode, "XLM")
+		assert.Equal(t, payments[0].DestAssetCode, "XLM")
+	})
 }