@@ -5,7 +5,7 @@ use chrono::Utc;
5
5
use prometheus:: { register_int_counter, IntCounter } ;
6
6
use serde:: { Deserialize , Serialize } ;
7
7
use std:: sync:: Arc ;
8
- use tracing:: { info , error, warn} ;
8
+ use tracing:: { debug , error, warn} ;
9
9
10
10
lazy_static:: lazy_static! {
11
11
static ref PROCESSED_ORDERS_TOTAL : IntCounter = register_int_counter!(
@@ -43,7 +43,7 @@ pub async fn handle_order_event(
43
43
event : PangeaOrderEvent ,
44
44
) {
45
45
if let Some ( ref et) = event. event_type {
46
- info ! (
46
+ debug ! (
47
47
target: "pangea_events" ,
48
48
">> handle_order_event: event_type = {:?}, order_id = {}, block = {}, tx = {}, log_index = {}" ,
49
49
et,
@@ -53,7 +53,7 @@ pub async fn handle_order_event(
53
53
event. log_index
54
54
) ;
55
55
} else {
56
- info ! (
56
+ debug ! (
57
57
target: "pangea_events" ,
58
58
">> handle_order_event: NO event_type, order_id = {}, block = {}, tx = {}, log_index = {}" ,
59
59
event. order_id,
@@ -67,12 +67,12 @@ pub async fn handle_order_event(
67
67
match event_type {
68
68
"Open" => {
69
69
if let Some ( order) = create_new_order_from_event ( & event) {
70
- info ! (
70
+ debug ! (
71
71
">> Adding new order to order_book: id = {}, amount = {}, price = {}, limit_type = {:?}" ,
72
72
order. id, order. amount, order. price, order. limit_type
73
73
) ;
74
74
order_book. add_order ( order) ;
75
- info ! ( "🟢 New order added (id: {})" , event. order_id) ;
75
+ debug ! ( "🟢 New order added (id: {})" , event. order_id) ;
76
76
} else {
77
77
warn ! (
78
78
"Open event received but could not create SpotOrder (fields missing?) for order_id = {}" ,
@@ -82,15 +82,15 @@ pub async fn handle_order_event(
82
82
}
83
83
"Trade" => {
84
84
matching_orders. remove ( & event. order_id ) ;
85
- info ! (
85
+ debug ! (
86
86
"🔄 Order {} removed from matching_orders (Trade event)" ,
87
87
& event. order_id
88
88
) ;
89
89
if let Some ( match_size) = event. amount {
90
90
let o_type = event. order_type_to_enum ( ) ;
91
91
let l_type = event. limit_type_to_enum ( ) ;
92
92
93
- info ! (
93
+ debug ! (
94
94
">> process_trade called. event_tx_id = {:?}, order_id = {}, match_size = {}, order_type = {:?}, limit_type = {:?}" ,
95
95
event. transaction_hash, event. order_id, match_size, o_type, l_type
96
96
) ;
@@ -105,12 +105,12 @@ pub async fn handle_order_event(
105
105
}
106
106
"Cancel" => {
107
107
matching_orders. remove ( & event. order_id ) ;
108
- info ! (
108
+ debug ! (
109
109
"🔄 Order {} removed from matching_orders (Cancel event)" ,
110
110
& event. order_id
111
111
) ;
112
112
order_book. remove_order ( & event. order_id , event. order_type_to_enum ( ) ) ;
113
- info ! (
113
+ debug ! (
114
114
"Removed order with id: {} due to Cancel event" ,
115
115
event. order_id
116
116
) ;
@@ -172,15 +172,10 @@ pub fn process_trade(
172
172
}
173
173
} ;
174
174
175
- info ! (
176
- "process_trade START: order_id = {}, trade_amount = {}, order_type = {:?}, limit_type = {:?}" ,
177
- order_id, trade_amount, order_type, limit_type
178
- ) ;
179
-
180
175
match limit_type {
181
176
LimitType :: GTC | LimitType :: MKT => {
182
177
if let Some ( mut order) = order_book. get_order ( order_id, order_type) {
183
- info ! (
178
+ debug ! (
184
179
">> Found order in order_book: id = {}, current_amount = {}, status = {:?}" ,
185
180
order. id, order. amount, order. status
186
181
) ;
@@ -190,15 +185,15 @@ pub fn process_trade(
190
185
order. status = Some ( OrderStatus :: PartiallyMatched ) ;
191
186
order_book. update_order ( order. clone ( ) ) ;
192
187
193
- info ! (
188
+ debug ! (
194
189
"🟡 Order {} partially matched. Trade amount: {}, remaining amount: {}" ,
195
190
order_id, trade_amount, order. amount
196
191
) ;
197
192
} else {
198
193
order. status = Some ( OrderStatus :: Matched ) ;
199
194
order_book. remove_order ( order_id, Some ( order_type) ) ;
200
195
201
- info ! (
196
+ debug ! (
202
197
"✅ Order {} fully matched and removed. Trade amount: {}, previous amount: {}" ,
203
198
order_id,
204
199
trade_amount,
@@ -211,15 +206,14 @@ pub fn process_trade(
211
206
}
212
207
LimitType :: FOK | LimitType :: IOC => {
213
208
order_book. remove_order ( order_id, Some ( order_type) ) ;
214
- info ! (
209
+ debug ! (
215
210
"🗑️ Order {} removed (FOK/IOC). trade_amount = {}" ,
216
211
order_id, trade_amount
217
212
) ;
218
213
}
219
214
}
220
215
221
- // Дополнительный лог, когда выходим
222
- info ! (
216
+ debug ! (
223
217
"process_trade END: order_id = {}, limit_type = {:?}" ,
224
218
order_id, limit_type
225
219
) ;
0 commit comments