wip: reproduce timing issue

coordinator/src/bin/coordinator.rs

@@ -49,7 +49,7 @@ use tracing::metadata::LevelFilter;
 const PROCESS_PROMETHEUS_METRICS: Duration = Duration::from_secs(10);
 const PROCESS_INCOMING_DLC_MESSAGES_INTERVAL: Duration = Duration::from_millis(200);
 const EXPIRED_POSITION_SYNC_INTERVAL: Duration = Duration::from_secs(5 * 60);
-const CLOSED_POSITION_SYNC_INTERVAL: Duration = Duration::from_secs(30);
+const CLOSED_POSITION_SYNC_INTERVAL: Duration = Duration::from_secs(1);
 const UNREALIZED_PNL_SYNC_INTERVAL: Duration = Duration::from_secs(10 * 60);
 const CONNECTION_CHECK_INTERVAL: Duration = Duration::from_secs(30);
 

coordinator/src/node/closed_positions.rs

@@ -11,6 +11,7 @@ pub fn sync(node: Node) -> Result<()> {
             .context("Failed to load open and closing positions")?;
 
     for position in open_and_closing_positions {
+        tracing::debug!(position = position.id, "Checking position");
         let temporary_contract_id = match position.temporary_contract_id {
             None => {
                 tracing::trace!(position_id=%position.id, "Position does not have temporary contract id, skipping");
@@ -20,9 +21,13 @@ pub fn sync(node: Node) -> Result<()> {
         };
 
         let contract = match node.inner.get_closed_contract(temporary_contract_id) {
-            Ok(Some(closed_contract)) => closed_contract,
+            Ok(Some(closed_contract)) => {
+                tracing::debug!(position = position.id, "Position closed");
+
+                closed_contract
+            }
             Ok(None) => {
-                tracing::trace!(position_id=%position.id, "Position not closed yet, skipping");
+                tracing::debug!(position_id=%position.id, "Position not closed yet, skipping");
                 continue;
             }
             Err(e) => {

coordinator/src/node/resize.rs

@@ -98,7 +98,17 @@ impl Node {
             },
         )?;
 
-        db::positions::Position::set_open_position_to_resizing(conn, position.trader.to_string())?;
+        let pool = self.pool.clone();
+        tokio::spawn({
+            let string = position.trader.to_string();
+            let pool = pool.clone();
+            async move {
+                let mut conn = pool.get()?;
+                tokio::time::sleep(core::time::Duration::from_secs(10)).await;
+                db::positions::Position::set_open_position_to_resizing(&mut conn, string)?;
+                anyhow::Ok(())
+            }
+        });
 
         Ok(())
     }