add entrypoint test for exchange

0LNetworkCommunity · Dec 6, 2024 · 18e0061 · 18e0061
1 parent fb5cffc
commit 18e0061
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/src/analytics/enrich_account_funding.rs b/src/analytics/enrich_account_funding.rs
@@ -223,7 +223,7 @@ pub fn generate_cypher_query(map: String) -> String {
                 ul.total_outflows = account.total_outflows,
                 ul.daily_funding = account.daily_funding,
                 ul.daily_inflows = account.daily_inflows,
-                ul.daily_outflows = account.daily_outflows,
+                ul.daily_outflows = account.daily_outflows
             MERGE (sa)-[r:DailyLedger]->(ul)
             SET r.date = datetime(account.date)
             RETURN COUNT(r) as merged_relations

diff --git a/tests/test_enrich_exchange.rs b/tests/test_enrich_exchange.rs
@@ -174,3 +174,16 @@ async fn e2e_swap_data() -> Result<()> {
 
     Ok(())
 }
+
+#[tokio::test]
+async fn test_entry_point_exchange_load() -> Result<()>{
+    let c = start_neo4j_container();
+    let port = c.get_host_port_ipv4(7687);
+    let graph = get_neo4j_localhost_pool(port).await?;
+    maybe_create_indexes(&graph).await?;
+
+    let path = env!("CARGO_MANIFEST_DIR");
+    let buf = PathBuf::from(path).join("tests/fixtures/savedOlOrders2.json");
+    load_exchange_orders::load_from_json(&buf, &graph, 250).await?;
+    Ok(())
+}