Resolve PR comments

econia-labs · Jul 25, 2024 · dc26c0f · dc26c0f
1 parent e979092
commit dc26c0f
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/doc/doc-site/docs/off-chain/dss/mqtt.md b/doc/doc-site/docs/off-chain/dss/mqtt.md
@@ -45,10 +45,15 @@ A payload for this event looks like this:
 ```json
 {
   "price": 12345,
-  "size": 12345
+  "size": 12345,
+  "txn_version": 12345
 }
 ```
 
+*Remember to set `MQTT_PRICE_LEVELS=yes` in the `.env` file for docker compose
+(if running with docker compose, otherwise the `mqtt-publisher` executable must
+have that variable exported) if you wish to get price levels over MQTT.*
+
 ### PlaceLimitOrderEvents
 
 `place_limit_order/MARKET_ID/USER_ADDRESS/CUSTODIAN_ID/INTEGRATOR`

diff --git a/...ublisher/sqlx_queries/get_txn_version.sql → ...ies/get_user_history_last_indexed_txn.sql b/...ublisher/sqlx_queries/get_txn_version.sql → ...ies/get_user_history_last_indexed_txn.sql
diff --git a/src/rust/mqtt-publisher/src/main.rs b/src/rust/mqtt-publisher/src/main.rs
@@ -150,7 +150,7 @@ async fn price_level_loop(db_url: &str, mqtt_client: Arc<RwLock<AsyncClient>>) -
         let data = sqlx::query_file!("sqlx_queries/get_price_levels.sql")
             .fetch_all(&mut tx as &mut PgConnection)
             .await?;
-        let txn_version = sqlx::query_file!("sqlx_queries/get_txn_version.sql")
+        let txn_version = sqlx::query_file!("sqlx_queries/get_user_history_last_indexed_txn.sql")
             .fetch_one(&mut tx as &mut PgConnection)
             .await?
             .txn_version