@@ -13,10 +13,9 @@ pub struct PythLazerAgentJrpcV1 {
13
13
14
14
#[ derive( Serialize , Deserialize , Debug , Eq , PartialEq ) ]
15
15
#[ serde( tag = "method" , content = "params" ) ]
16
+ #[ serde( rename_all = "snake_case" ) ]
16
17
pub enum JrpcCall {
17
- #[ serde( rename_all = "snake_case" ) ]
18
18
PushUpdate ( FeedUpdateParams ) ,
19
- #[ serde( rename = "get_symbols" ) ]
20
19
GetMetadata ( GetMetadataParams ) ,
21
20
}
22
21
@@ -134,11 +133,11 @@ mod tests {
134
133
use crate :: router:: { Price , PriceFeedId , Rate , TimestampUs } ;
135
134
136
135
#[ test]
137
- fn test_send_updates_price ( ) {
136
+ fn test_push_update_price ( ) {
138
137
let json = r#"
139
138
{
140
139
"jsonrpc": "2.0",
141
- "method": "send_updates ",
140
+ "method": "push_update ",
142
141
"params": {
143
142
"feed_id": 1,
144
143
"source_timestamp": 124214124124,
@@ -156,7 +155,7 @@ mod tests {
156
155
157
156
let expected = PythLazerAgentJrpcV1 {
158
157
jsonrpc : JsonRpcVersion :: V2 ,
159
- params : SendUpdates ( FeedUpdateParams {
158
+ params : PushUpdate ( FeedUpdateParams {
160
159
feed_id : PriceFeedId ( 1 ) ,
161
160
source_timestamp : TimestampUs ( 124214124124 ) ,
162
161
update : UpdateParams :: PriceUpdate {
@@ -175,11 +174,11 @@ mod tests {
175
174
}
176
175
177
176
#[ test]
178
- fn test_send_updates_funding_rate ( ) {
177
+ fn test_push_update_funding_rate ( ) {
179
178
let json = r#"
180
179
{
181
180
"jsonrpc": "2.0",
182
- "method": "send_updates ",
181
+ "method": "push_update ",
183
182
"params": {
184
183
"feed_id": 1,
185
184
"source_timestamp": 124214124124,
@@ -196,7 +195,7 @@ mod tests {
196
195
197
196
let expected = PythLazerAgentJrpcV1 {
198
197
jsonrpc : JsonRpcVersion :: V2 ,
199
- params : SendUpdates ( FeedUpdateParams {
198
+ params : PushUpdate ( FeedUpdateParams {
200
199
feed_id : PriceFeedId ( 1 ) ,
201
200
source_timestamp : TimestampUs ( 124214124124 ) ,
202
201
update : UpdateParams :: FundingRateUpdate {
@@ -213,16 +212,14 @@ mod tests {
213
212
) ;
214
213
}
215
214
#[ test]
216
- fn test_send_get_symbols ( ) {
215
+ fn test_send_get_metadata ( ) {
217
216
let json = r#"
218
217
{
219
218
"jsonrpc": "2.0",
220
- "method": "get_symbols ",
219
+ "method": "get_metadata ",
221
220
"params": {
222
- "filters": [
223
- {"name": "BTC/USD"},
224
- {"asset_type": "crypto"}
225
- ]
221
+ "names": ["BTC/USD"],
222
+ "asset_types": ["crypto"]
226
223
},
227
224
"id": 1
228
225
}
@@ -231,16 +228,8 @@ mod tests {
231
228
let expected = PythLazerAgentJrpcV1 {
232
229
jsonrpc : JsonRpcVersion :: V2 ,
233
230
params : GetMetadata ( GetMetadataParams {
234
- filters : Some ( vec ! [
235
- Filter {
236
- name: Some ( "BTC/USD" . to_string( ) ) ,
237
- asset_type: None ,
238
- } ,
239
- Filter {
240
- name: None ,
241
- asset_type: Some ( "crypto" . to_string( ) ) ,
242
- } ,
243
- ] ) ,
231
+ names : Some ( vec ! [ "BTC/USD" . to_string( ) ] ) ,
232
+ asset_types : Some ( vec ! [ "crypto" . to_string( ) ] ) ,
244
233
} ) ,
245
234
id : 1 ,
246
235
} ;
@@ -252,19 +241,19 @@ mod tests {
252
241
}
253
242
254
243
#[ test]
255
- fn test_get_symbols_without_filters ( ) {
244
+ fn test_get_metadata_without_filters ( ) {
256
245
let json = r#"
257
246
{
258
247
"jsonrpc": "2.0",
259
- "method": "get_symbols ",
248
+ "method": "get_metadata ",
260
249
"params": {},
261
250
"id": 1
262
251
}
263
252
"# ;
264
253
265
254
let expected = PythLazerAgentJrpcV1 {
266
255
jsonrpc : JsonRpcVersion :: V2 ,
267
- params : GetMetadata ( GetMetadataParams { filters : None } ) ,
256
+ params : GetMetadata ( GetMetadataParams { names : None , asset_types : None } ) ,
268
257
id : 1 ,
269
258
} ;
270
259
0 commit comments