@@ -27,14 +27,10 @@ pub async fn execute_orders_info(order_ids: &[Uuid], ctx: &Context) -> Result<()
2727 // Create payload with the order IDs
2828 let payload = Payload :: Ids ( order_ids. to_vec ( ) ) ;
2929
30- // Create message using the proper Message structure
31- let message = Message :: new_order (
32- None ,
33- Some ( request_id) ,
34- Some ( ctx. trade_index ) ,
35- Action :: Orders ,
36- Some ( payload) ,
37- ) ;
30+ // Orders info is account-scoped — Mostro indexes users by their identity
31+ // pubkey, so the message carries no trade_index and the whole exchange
32+ // (send, wait, decrypt) runs on `identity_keys`.
33+ let message = Message :: new_order ( None , Some ( request_id) , None , Action :: Orders , Some ( payload) ) ;
3834
3935 // Serialize the message
4036 let message_json = message
@@ -44,18 +40,19 @@ pub async fn execute_orders_info(order_ids: &[Uuid], ctx: &Context) -> Result<()
4440 // Send the DM
4541 let sent_message = send_dm (
4642 & ctx. client ,
47- & ctx. trade_keys ,
43+ & ctx. identity_keys ,
44+ & ctx. identity_keys ,
4845 & ctx. mostro_pubkey ,
4946 message_json,
5047 None ,
5148 false ,
5249 ) ;
5350
5451 // Wait for the DM response from mostro
55- let recv_event = wait_for_dm ( ctx, None , sent_message) . await ?;
52+ let recv_event = wait_for_dm ( ctx, Some ( & ctx . identity_keys ) , sent_message) . await ?;
5653
5754 // Parse the incoming DM and handle the response
58- let messages = crate :: parser:: dms:: parse_dm_events ( recv_event, & ctx. trade_keys , None ) . await ;
55+ let messages = crate :: parser:: dms:: parse_dm_events ( recv_event, & ctx. identity_keys , None ) . await ;
5956 if let Some ( ( message, _, _) ) = messages. first ( ) {
6057 let message_kind = message. get_inner_message_kind ( ) ;
6158
0 commit comments