Skip to content

Commit ba09a52

Browse files
devin-ai-integration[bot]darunrs
devin-ai-integration[bot]
and
darunrs
authored
feat(lazer): add ignoreInvalidFeedIds flag to SDK (#2529)
* feat(lazer): add ignoreInvalidFeeds flag to SDK Co-Authored-By: Darun Seethammagari <[email protected]> * feat(lazer): update protocol types for ignore_invalid_feeds Co-Authored-By: Darun Seethammagari <[email protected]> * fix: update example to include ignore_invalid_feeds field Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename ignore_invalid_feeds to ignore_invalid_feed_ids Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename FailedFeedsDetails to InvalidFeedSubscriptionDetails Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename comingSoon to unstable in InvalidFeedSubscriptionDetails Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: change successful_feeds type from Vec<u64> to Vec<u32> Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: add subscribedWithIgnoredFailures response type Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename subscribedWithIgnoredFailures to subscribedWithInvalidFeeds Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename subscribedWithInvalidFeeds to subscribedWithIgnoredInvalidFeedIds Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename response types to subscribedWithInvalidFeedIdsIgnored Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename fields to subscribedFeedIds and ignoredInvalidFeedIds Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: rename enum variant to SubscribedWithInvalidFeedIdsIgnored Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: move ignore_invalid_feed_ids to SubscriptionParamsRepr Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: change ignore_invalid_feed_ids from Option<bool> to bool Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: update InvalidFeedSubscriptionDetails to use proper types Co-Authored-By: Darun Seethammagari <[email protected]> * refactor: use local SymbolState instead of external dependency Co-Authored-By: Darun Seethammagari <[email protected]> * fix: update protocol.ts formatting to fix CI Co-Authored-By: Darun Seethammagari <[email protected]> * Undo change ot returned ignored ids --------- Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> Co-authored-by: Darun Seethammagari <[email protected]> Co-authored-by: Darun Seethammagari <[email protected]>
1 parent b8f388e commit ba09a52

File tree

11 files changed

+61
-6
lines changed

11 files changed

+61
-6
lines changed

‎lazer/Cargo.lock‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎lazer/contracts/solana/programs/pyth-lazer-solana-contract/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ no-log-ix-name = []
1919
idl-build = ["anchor-lang/idl-build"]
2020

2121
[dependencies]
22-
pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.6.0" }
22+
pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.7.0" }
2323

2424
anchor-lang = "0.30.1"
2525
bytemuck = "1.20.0"

‎lazer/sdk/js/package.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@pythnetwork/pyth-lazer-sdk",
3-
"version": "0.4.0",
3+
"version": "0.5.0",
44
"description": "Pyth Lazer SDK",
55
"publishConfig": {
66
"access": "public"

‎lazer/sdk/js/src/protocol.ts‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ export type Request =
2020
deliveryFormat?: DeliveryFormat;
2121
jsonBinaryEncoding?: JsonBinaryEncoding;
2222
parsed?: boolean;
23+
ignoreInvalidFeedIds?: boolean;
2324
channel: Channel;
2425
}
2526
| {
@@ -47,6 +48,12 @@ export type JsonBinaryData = {
4748
data: string;
4849
};
4950

51+
export type InvalidFeedSubscriptionDetails = {
52+
unknownIds: number[];
53+
unsupportedChannels: number[];
54+
unstable: number[];
55+
};
56+
5057
export type Response =
5158
| {
5259
type: "error";
@@ -56,6 +63,12 @@ export type Response =
5663
type: "subscribed";
5764
subscriptionId: number;
5865
}
66+
| {
67+
type: "subscribedWithInvalidFeedIdsIgnored";
68+
subscriptionId: number;
69+
subscribedFeedIds: number[];
70+
ignoredInvalidFeedIds: InvalidFeedSubscriptionDetails;
71+
}
5972
| {
6073
type: "unsubscribed";
6174
subscriptionId: number;

‎lazer/sdk/rust/client/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ description = "A Rust client for Pyth Lazer"
66
license = "Apache-2.0"
77

88
[dependencies]
9-
pyth-lazer-protocol = { path = "../protocol", version = "0.6.0" }
9+
pyth-lazer-protocol = { path = "../protocol", version = "0.7.0" }
1010
tokio = { version = "1", features = ["full"] }
1111
tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
1212
futures-util = "0.3"

‎lazer/sdk/rust/client/examples/subscribe_price_feeds.rs‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ async fn main() -> anyhow::Result<()> {
4747
channel: Channel::FixedRate(
4848
FixedRate::from_ms(200).expect("unsupported update rate"),
4949
),
50+
ignore_invalid_feed_ids: false,
5051
})
5152
.expect("invalid subscription params"),
5253
},
@@ -68,6 +69,7 @@ async fn main() -> anyhow::Result<()> {
6869
channel: Channel::FixedRate(
6970
FixedRate::from_ms(50).expect("unsupported update rate"),
7071
),
72+
ignore_invalid_feed_ids: false,
7173
})
7274
.expect("invalid subscription params"),
7375
},

‎lazer/sdk/rust/protocol/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "pyth-lazer-protocol"
3-
version = "0.6.2"
3+
version = "0.7.0"
44
edition = "2021"
55
description = "Pyth Lazer SDK - protocol types."
66
license = "Apache-2.0"

‎lazer/sdk/rust/protocol/src/lib.rs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ pub mod router;
99
mod serde_price_as_i64;
1010
mod serde_str;
1111
pub mod subscription;
12+
pub mod symbol_state;
1213

1314
#[test]
1415
fn magics_in_big_endian() {

‎lazer/sdk/rust/protocol/src/router.rs‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -358,6 +358,8 @@ pub struct SubscriptionParamsRepr {
358358
#[serde(default = "default_parsed")]
359359
pub parsed: bool,
360360
pub channel: Channel,
361+
#[serde(default)]
362+
pub ignore_invalid_feed_ids: bool,
361363
}
362364

363365
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize)]

‎lazer/sdk/rust/protocol/src/subscription.rs‎

Lines changed: 18 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
//! used across publishers, agents and routers.
33
44
use {
5-
crate::router::{JsonUpdate, SubscriptionParams},
5+
crate::router::{JsonUpdate, PriceFeedId, SubscriptionParams},
66
derive_more::From,
77
serde::{Deserialize, Serialize},
88
};
@@ -40,6 +40,7 @@ pub struct UnsubscribeRequest {
4040
pub enum Response {
4141
Error(ErrorResponse),
4242
Subscribed(SubscribedResponse),
43+
SubscribedWithInvalidFeedIdsIgnored(SubscribedWithInvalidFeedIdsIgnoredResponse),
4344
Unsubscribed(UnsubscribedResponse),
4445
SubscriptionError(SubscriptionErrorResponse),
4546
StreamUpdated(StreamUpdatedResponse),
@@ -52,6 +53,22 @@ pub struct SubscribedResponse {
5253
pub subscription_id: SubscriptionId,
5354
}
5455

56+
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
57+
#[serde(rename_all = "camelCase")]
58+
pub struct InvalidFeedSubscriptionDetails {
59+
pub unknown_ids: Vec<PriceFeedId>,
60+
pub unsupported_channels: Vec<PriceFeedId>,
61+
pub unstable: Vec<PriceFeedId>,
62+
}
63+
64+
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
65+
#[serde(rename_all = "camelCase")]
66+
pub struct SubscribedWithInvalidFeedIdsIgnoredResponse {
67+
pub subscription_id: SubscriptionId,
68+
pub subscribed_feed_ids: Vec<PriceFeedId>,
69+
pub ignored_invalid_feed_ids: InvalidFeedSubscriptionDetails,
70+
}
71+
5572
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
5673
#[serde(rename_all = "camelCase")]
5774
pub struct UnsubscribedResponse {

0 commit comments

Comments
 (0)