feat(lazer): add ignoreInvalidFeedIds flag to SDK

lazer/sdk/js/src/protocol.ts

@@ -20,6 +20,7 @@ export type Request =
       deliveryFormat?: DeliveryFormat;
       jsonBinaryEncoding?: JsonBinaryEncoding;
       parsed?: boolean;
+      ignoreInvalidFeedIds?: boolean;
       channel: Channel;
     }
   | {
@@ -47,6 +48,12 @@ export type JsonBinaryData = {
   data: string;
 };
 
+export type InvalidFeedSubscriptionDetails = {
+  unknownIds: number[];
+  unsupportedChannels: number[];
+  unstable: number[];
+};
+
 export type Response =
   | {
       type: "error";
@@ -56,6 +63,12 @@ export type Response =
       type: "subscribed";
       subscriptionId: number;
     }
+  | {
+      type: "subscribedWithIgnoredFailures";
+      subscriptionId: number;
+      successfulFeeds: number[];
+      failedFeeds: InvalidFeedSubscriptionDetails;
+    }
   | {
       type: "unsubscribed";
       subscriptionId: number;

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

@@ -49,6 +49,7 @@ async fn main() -> anyhow::Result<()> {
                 ),
             })
             .expect("invalid subscription params"),
+            ignore_invalid_feed_ids: Some(false),
         },
         // Example subscription: binary feed targeting Solana and EVM
         SubscribeRequest {
@@ -70,6 +71,7 @@ async fn main() -> anyhow::Result<()> {
                 ),
             })
             .expect("invalid subscription params"),
+            ignore_invalid_feed_ids: Some(false),
         },
     ];
 

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

@@ -25,6 +25,8 @@ pub struct SubscribeRequest {
     pub subscription_id: SubscriptionId,
     #[serde(flatten)]
     pub params: SubscriptionParams,
+    #[serde(default)]
+    pub ignore_invalid_feed_ids: Option<bool>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -50,6 +52,10 @@ pub enum Response {
 #[serde(rename_all = "camelCase")]
 pub struct SubscribedResponse {
     pub subscription_id: SubscriptionId,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub successful_feeds: Option<Vec<u32>>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub failed_feeds: Option<serde_json::Value>,
 }
 
 #[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]