Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "pyth-lazer-solana-contract"
version = "0.7.1"
version = "0.7.2"
edition = "2021"
description = "Pyth Lazer Solana contract and SDK."
license = "Apache-2.0"
Expand All @@ -19,7 +19,7 @@ no-log-ix-name = []
idl-build = ["anchor-lang/idl-build"]

[dependencies]
pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.16.0" }
pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.17.0" }

anchor-lang = "0.31.1"
bytemuck = { version = "1.20.0", features = ["derive"] }
Expand Down
4 changes: 2 additions & 2 deletions lazer/publisher_sdk/rust/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
[package]
name = "pyth-lazer-publisher-sdk"
version = "0.14.0"
version = "0.15.0"
edition = "2021"
description = "Pyth Lazer Publisher SDK types."
license = "Apache-2.0"
repository = "https://github.com/pyth-network/pyth-crosschain"

[dependencies]
pyth-lazer-protocol = { version = "0.16.0", path = "../../sdk/rust/protocol" }
pyth-lazer-protocol = { version = "0.17.0", path = "../../sdk/rust/protocol" }
anyhow = "1.0.98"
protobuf = "3.7.2"
serde_json = "1.0.140"
Expand Down
4 changes: 2 additions & 2 deletions lazer/sdk/rust/client/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
[package]
name = "pyth-lazer-client"
version = "8.2.2"
version = "8.2.3"
edition = "2021"
description = "A Rust client for Pyth Lazer"
license = "Apache-2.0"

[dependencies]
pyth-lazer-protocol = { path = "../protocol", version = "0.16.0" }
pyth-lazer-protocol = { path = "../protocol", version = "0.17.0" }
tokio = { version = "1", features = ["full"] }
tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
futures-util = "0.3"
Expand Down
2 changes: 1 addition & 1 deletion lazer/sdk/rust/protocol/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "pyth-lazer-protocol"
version = "0.16.0"
version = "0.17.0"
edition = "2021"
description = "Pyth Lazer SDK - protocol types."
license = "Apache-2.0"
Expand Down
3 changes: 3 additions & 0 deletions lazer/sdk/rust/protocol/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,8 @@ mod feed_kind;
pub mod jrpc;
/// Types describing Lazer's verifiable messages containing signature and payload.
pub mod message;
/// Types describing Lazer's feed & asset metadata catalog APIs.
pub mod metadata;
/// Types describing Lazer's message payload.
pub mod payload;
mod price;
Expand All @@ -28,6 +30,7 @@ use serde::{Deserialize, Serialize};
pub use crate::{
dynamic_value::DynamicValue,
feed_kind::FeedKind,
metadata::{AssetClass, AssetResponseV3, FeedResponseV3, InstrumentType},
price::{Price, PriceError},
rate::{Rate, RateError},
symbol_state::SymbolState,
Expand Down
138 changes: 138 additions & 0 deletions lazer/sdk/rust/protocol/src/metadata.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,138 @@
//! Types describing Lazer's metadata APIs.

use crate::FeedKind;
use crate::{symbol_state::SymbolState, PriceFeedId};
use serde::{Deserialize, Serialize};

/// The pricing context or type of instrument for a feed.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum InstrumentType {
/// Spot price
Spot,
/// Redemption rate
#[serde(rename = "redemptionrate")]
RedemptionRate,
/// Funding rate
#[serde(rename = "fundingrate")]
FundingRate,
/// Future price
Future,
/// Net Asset Value
Nav,
/// Time-weighted average price
Twap,
}

/// High-level asset class.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(rename_all = "kebab-case")]
pub enum AssetClass {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

One of the reasons for opting in a dynamic metadata was to not go through a code change when new asset classes are added to the system. I know that users (on both sides) rely on these, and that's probably why you opted for explicit definition here. But if that's the case, you might actually remove any dynamic field and make everything very explicit. Being in the middle (some explicit metadata, some implicit dynamic) is probably worse.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think we should stick with our decision and use fully dynamic metadata in the protocols. In Rust that would be BTreeMap<String, serde_value::Value>. We can revisit it later if we feel like the metadata structure is very stable and future-proof, but I doubt that it will happen soon.

/// Cryptocurrency
Crypto,
/// Foreign exchange
Fx,
/// Equity
Equity,
/// Metal
Metal,
/// Rates
Rates,
/// Net Asset Value
Nav,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This also doesn't seem to be an asset class, it's a feed/instrument type.

/// Commodity
Commodity,
/// Funding rate
FundingRate,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is this really an asset class?

}

/// Feed metadata as returned by the v3 metadata API.
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub struct FeedResponseV3 {
/// Unique integer identifier for a feed. Known as `pyth_lazer_id` in V1 API.
/// Example: `1`
pub id: PriceFeedId,
/// Short feed name.
/// Example: `"Bitcoin / US Dollar"`
pub name: String,
/// Unique human-readable identifier for a feed.
/// Format: `source.instrument_type.base/quote`
/// Examples: `"pyth.spot.btc/usd"`, `"pyth.redemptionrate.alp/usd"`, `"binance.fundingrate.btc/usdt"`, `"pyth.future.emz5/usd"`
pub symbol: String,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

i recommend opting for a specific type with validation here to ensure it's correct.

q: what if the asset has no quote asset? (such as rates)

/// Description of the feed pair.
/// Example: `"Pyth Network Aggregate Price for spot BTC/USD"`
pub description: String,
/// The Asset ID of the base asset.
/// Example: `"BTC"`
pub base_asset_id: String,
/// The Asset ID of the quote asset.
/// Example: `"USD"`
pub quote_asset_id: String,
/// The pricing context.
/// Example: `"spot"`
pub instrument_type: InstrumentType,
/// Aggregator or producer of the prices.
/// Examples: `"pyth"`, `"binance"`
pub source: String,
/// The trading schedule of the feed's market, in Pythnet format.
/// Example: `"America/New_York;O,O,O,O,O,O,O;"`
pub schedule: String,
/// Power-of-ten exponent. Scale the `price` mantissa value by `10^exponent` to get the decimal representation.
/// Example: `-8`
pub exponent: i32,
/// Funding rate interval. Only applies to feeds with instrument type `funding_rate`.
/// Example: `10`
pub update_interval_seconds: i32,
/// The minimum number of publishers contributing component prices to the aggregate price.
/// Example: `3`
pub min_publishers: i32,
/// Status of the feed.
/// Example: `"active"`
pub state: SymbolState,
/// High-level asset class. One of crypto, fx, equity, metal, rates, nav, commodity, funding-rate.
/// Example: `"crypto"`
pub asset_type: AssetClass,
/// CoinMarketCap asset identifier.
/// Example: `"123"`
#[serde(skip_serializing_if = "Option::is_none")]
pub cmc_id: Option<String>,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

i wonder whether you considered @jayantk suggestion on having a nested struct as "external mappings". It's probably more difficult on the DB layer.

/// Pythnet feed identifier. 32 bytes, represented in hex.
/// Example: `"e62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415b43"`
pub pythnet_id: String,
/// Nasdaq symbol identifier.
/// Example: `"ADSK"`
#[serde(skip_serializing_if = "Option::is_none")]
pub nasdaq_symbol: Option<String>,
/// ISO datetime after which the feed will no longer produce prices because the underlying market has expired.
/// Example: `"2025-10-03T11:08:10.089998603Z"`
#[serde(skip_serializing_if = "Option::is_none")]
pub feed_expiry: Option<String>,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Use a datetime type or an integer based timestamp (i bet we should have something similar in our code)

/// The nature of the data produced by the feed.
/// Examples: `"price"`, `"fundingRate"`
pub feed_kind: FeedKind,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hmmm so we do have a feedkind and an instrument type. I wonder whether we can merge them.

}

/// Asset metadata as returned by the v3 metadata API.
#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub struct AssetResponseV3 {
/// Unique identifier for an asset.
/// Example: `"BTC"`
pub id: String,
/// A short, human-readable code that identifies an asset. Not guaranteed to be unique.
/// Example: `"BTC"`
pub ticker: String,
/// Full human-readable name of the asset.
/// Example: `"Bitcoin"`
pub full_name: String,
/// High-level asset class.
/// Example: `"crypto"`
pub class: AssetClass,
/// More granular categorization within class.
/// Example: `"stablecoin"`
#[serde(skip_serializing_if = "Option::is_none")]
pub subclass: Option<String>,
/// Primary or canonical listing exchange, when applicable.
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hmmm, what if there are multiple?
i suggest renaming the field to primary_exchange or something similar here. not sure listing_exchange is clear.

/// Example: `"NASDAQ"`
#[serde(skip_serializing_if = "Option::is_none")]
pub listing_exchange: Option<String>,
}