DS - Update Rust SDK imports to use official crates (#2613)

* update Rust SDK imports to use official crates

* update Rust SDK imports to use official crates

Author: khadni

src/content/data-streams/reference/streams-direct/streams-direct-rust-sdk.mdx

@@ -53,8 +53,8 @@ Add the SDK to your project by including it in your `Cargo.toml`:
 
 ```toml
 [dependencies]
-data-streams-sdk = { git = "https://github.com/smartcontractkit/data-streams-sdk.git", subdir = "rust/crates/sdk" }
-data-streams-report = { git = "https://github.com/smartcontractkit/data-streams-sdk.git", subdir = "rust/crates/report" }
+chainlink-data-streams-sdk = "1.0.0"
+chainlink-data-streams-report = "1.0.0"
 ```
 
 ### Feature Flags
@@ -78,7 +78,7 @@ Below are basic code snippets for decoding these reports with the SDK:
 ### V3 Reports (Crypto Streams)
 
 ```rust
-use data_streams_report::report::v3::ReportDataV3;
+use chainlink_data_streams_report::report::{ decode_full_report, v3::ReportDataV3 };
 
 // After you get 'report_blob' (for example, from 'decode_full_report' or a contract call):
 let report_data = ReportDataV3::decode(&report_blob)?;
@@ -96,7 +96,7 @@ For more details on every field in V3 (Crypto) reports, see the [V3 report schem
 ### V4 Reports (RWA Streams)
 
 ```rust
-use data_streams_report::report::v4::ReportDataV4;
+use chainlink_data_streams_report::report::v4::ReportDataV4;
 
 let report_data = ReportDataV4::decode(&report_blob)?;
 
@@ -113,7 +113,7 @@ For more details on every field in V4 (RWA) reports, see the [V4 report schema p
 The SDK uses HMAC authentication for all API requests. Configure your credentials:
 
 ```rust
-use data_streams_sdk::config::Config;
+use chainlink_data_streams_sdk::config::Config;
 use std::env;
 
 let api_key = env::var("API_KEY").expect("API_KEY must be set");
@@ -140,7 +140,7 @@ Security best practices:
 ### High Availability Mode
 
 ```rust
-use data_streams_sdk::config::{Config, WebSocketHighAvailability};
+use chainlink_data_streams_sdk::config::{Config, WebSocketHighAvailability};
 
 let ws_urls = "wss://ws1.dataengine.chain.link,wss://ws2.dataengine.chain.link";
 let config = Config::new(api_key, api_secret, rest_url, ws_urls)
@@ -166,7 +166,7 @@ The SDK allows you to:
 Example:
 
 ```rust
-use data_streams_sdk::config::{Config, InsecureSkipVerify, WebSocketHighAvailability};
+use chainlink_data_streams_sdk::config::{Config, InsecureSkipVerify, WebSocketHighAvailability};
 
 let ws_urls = "wss://ws.testnet-dataengine.chain.link";
 
@@ -192,8 +192,8 @@ The SDK defines distinct error types:
 Example:
 
 ```rust
-use data_streams_sdk::client::Client;
-use data_streams_sdk::client::ClientError;
+use chainlink_data_streams_sdk::client::Client;
+use chainlink_data_streams_sdk::client::ClientError;
 
 match client.get_latest_report(feed_id).await {
     Ok(report_response) => {

src/content/data-streams/tutorials/streams-direct/streams-direct-api-rust.mdx

@@ -46,7 +46,6 @@ In this guide, you'll learn how to use Chainlink Data Streams with the _[Streams
 
 ## Requirements
 
-- **Git**: Make sure you have Git installed. You can check your current version by running <CopyText text="git --version" code/> in your terminal and download the latest version from the official [Git website](https://git-scm.com/book/en/v2/Getting-Started-Installing-Git) if necessary.
 - **Rust**: Make sure you have Rust installed. You can install Rust by following the instructions on the official [Rust website](https://www.rust-lang.org/tools/install).
 - **API Credentials**: Access to the Streams Direct implementation requires API credentials. If you haven't already, [contact us](https://chainlinkcommunity.typeform.com/datastreams?typeform-source=docs.chain.link#ref_id=docs) to request mainnet or testnet access.
 
@@ -68,12 +67,12 @@ You'll start with the set up of your Rust project. Next, you'll fetch and decode
    cargo init
    ```
 
-1. Add the Data Streams SDK to your `Cargo.toml`:
+1. Add the following dependencies to your `Cargo.toml` file:
 
    ```toml
    [dependencies]
-   data-streams-sdk = { git = "https://github.com/smartcontractkit/data-streams-sdk.git", subdir = "rust/crates/sdk" }
-   data-streams-report = { git = "https://github.com/smartcontractkit/data-streams-sdk.git", subdir = "rust/crates/report" }
+   chainlink-data-streams-sdk = "1.0.0"
+   chainlink-data-streams-report = "1.0.0"
    tokio = { version = "1.4", features = ["full"] }
    hex = "0.4"
    ```
@@ -83,65 +82,64 @@ You'll start with the set up of your Rust project. Next, you'll fetch and decode
 1. Replace the contents of `src/main.rs` with the following code:
 
    ```rust
-   use data_streams_report::feed_id::ID;
-   use data_streams_report::report::{decode_full_report, v3::ReportDataV3};
-   use data_streams_sdk::client::Client;
-   use data_streams_sdk::config::Config;
+   use chainlink_data_streams_report::feed_id::ID;
+   use chainlink_data_streams_report::report::{ decode_full_report, v3::ReportDataV3 };
+   use chainlink_data_streams_sdk::client::Client;
+   use chainlink_data_streams_sdk::config::Config;
    use std::env;
    use std::error::Error;
 
    #[tokio::main]
    async fn main() -> Result<(), Box<dyn Error>> {
-       // Get feed ID from command line arguments
-       let args: Vec<String> = env::args().collect();
-       if args.len() < 2 {
-           eprintln!("Usage: cargo run [FeedID]");
-           std::process::exit(1);
-       }
-       let feed_id_input = &args[1];
-
-       // Get API credentials from environment variables
-       let api_key = env::var("API_KEY").expect("API_KEY must be set");
-       let api_secret = env::var("API_SECRET").expect("API_SECRET must be set");
-
-       // Initialize the configuration
-       let config = Config::new(
-           api_key,
-           api_secret,
-           "https://api.testnet-dataengine.chain.link".to_string(),
-           "wss://api.testnet-dataengine.chain.link/ws".to_string(),
-       )
-       .build()?;
-
-       // Initialize the client
-       let client = Client::new(config)?;
-
-       // Parse the feed ID
-       let feed_id = ID::from_hex_str(feed_id_input)?;
-
-       // Fetch the latest report
-       let response = client.get_latest_report(feed_id).await?;
-       println!("\nRaw report data: {:?}\n", response.report);
-
-       // Decode the report
-       let full_report = hex::decode(&response.report.full_report[2..])?;
-       let (_report_context, report_blob) = decode_full_report(&full_report)?;
-       let report_data = ReportDataV3::decode(&report_blob)?;
-
-       // Print decoded report details
-       println!("\nDecoded Report for Stream ID {}:", feed_id_input);
-       println!("------------------------------------------");
-       println!("Observations Timestamp: {}", response.report.observations_timestamp);
-       println!("Benchmark Price       : {}", report_data.benchmark_price);
-       println!("Bid                   : {}", report_data.bid);
-       println!("Ask                   : {}", report_data.ask);
-       println!("Valid From Timestamp  : {}", response.report.valid_from_timestamp);
-       println!("Expires At            : {}", report_data.expires_at);
-       println!("Link Fee              : {}", report_data.link_fee);
-       println!("Native Fee            : {}", report_data.native_fee);
-       println!("------------------------------------------");
-
-       Ok(())
+      // Get feed ID from command line arguments
+      let args: Vec<String> = env::args().collect();
+      if args.len() < 2 {
+         eprintln!("Usage: cargo run [FeedID]");
+         std::process::exit(1);
+      }
+      let feed_id_input = &args[1];
+
+      // Get API credentials from environment variables
+      let api_key = env::var("API_KEY").expect("API_KEY must be set");
+      let api_secret = env::var("API_SECRET").expect("API_SECRET must be set");
+
+      // Initialize the configuration
+      let config = Config::new(
+         api_key,
+         api_secret,
+         "https://api.testnet-dataengine.chain.link".to_string(),
+         "wss://api.testnet-dataengine.chain.link/ws".to_string()
+      ).build()?;
+
+      // Initialize the client
+      let client = Client::new(config)?;
+
+      // Parse the feed ID
+      let feed_id = ID::from_hex_str(feed_id_input)?;
+
+      // Fetch the latest report
+      let response = client.get_latest_report(feed_id).await?;
+      println!("\nRaw report data: {:?}\n", response.report);
+
+      // Decode the report
+      let full_report = hex::decode(&response.report.full_report[2..])?;
+      let (_report_context, report_blob) = decode_full_report(&full_report)?;
+      let report_data = ReportDataV3::decode(&report_blob)?;
+
+      // Print decoded report details
+      println!("\nDecoded Report for Stream ID {}:", feed_id_input);
+      println!("------------------------------------------");
+      println!("Observations Timestamp: {}", response.report.observations_timestamp);
+      println!("Benchmark Price       : {}", report_data.benchmark_price);
+      println!("Bid                   : {}", report_data.bid);
+      println!("Ask                   : {}", report_data.ask);
+      println!("Valid From Timestamp  : {}", response.report.valid_from_timestamp);
+      println!("Expires At            : {}", report_data.expires_at);
+      println!("Link Fee              : {}", report_data.link_fee);
+      println!("Native Fee            : {}", report_data.native_fee);
+      println!("------------------------------------------");
+
+      Ok(())
    }
    ```
 
@@ -215,7 +213,7 @@ The API client is initialized in two steps:
    - Sets up the REST API endpoint for data retrieval
    - Configures optional settings like TLS verification
 
-2. [`Client::new`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/sdk/src/client.rs#L131) creates the HTTP client with your configuration. This client:
+1. [`Client::new`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/sdk/src/client.rs#L131) creates the HTTP client with your configuration. This client:
    - Handles authentication automatically
    - Manages HTTP connections
    - Implements retry logic for failed requests
@@ -230,7 +228,7 @@ The SDK provides several methods to fetch reports through the REST API:
    - Returns a single report with the latest timestamp
    - Useful for applications that need the most current data
 
-2. Historical report: [`get_report`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/sdk/src/client.rs#L242) fetches a report at a specific timestamp:
+1. Historical report: [`get_report`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/sdk/src/client.rs#L242) fetches a report at a specific timestamp:
    - Takes both feed ID and timestamp
    - Returns the report closest to the requested timestamp
    - Helpful for historical analysis or verification
@@ -252,13 +250,13 @@ Reports are decoded in three stages:
    let full_report = hex::decode(&response.report.full_report[2..])?;
    ```
 
-2. Report separation: [`decode_full_report`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/report/src/report.rs#L77) splits the binary data:
+1. Report separation: [`decode_full_report`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/report/src/report.rs#L77) splits the binary data:
 
    - Extracts the report context (metadata)
    - Isolates the report blob (actual data)
    - Validates the report format
 
-3. Data extraction: [`ReportDataV3::decode`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/report/src/report/v3.rs#L80) parses the report blob into structured data:
+1. Data extraction: [`ReportDataV3::decode`](https://github.com/smartcontractkit/data-streams-sdk/blob/main/rust/crates/report/src/report/v3.rs#L80) parses the report blob into structured data:
    - Benchmark price (18 decimal places)
    - Bid and ask prices for [liquidity-weighted pricing](/data-streams/concepts/liquidity-weighted-prices)
    - Fee information for onchain verification
@@ -274,13 +272,13 @@ The example demonstrates Rust's robust error handling:
    - Implements the `Error` trait for proper error propagation
    - Provides detailed error messages for debugging
 
-2. Error propagation:
+1. Error propagation:
 
    - Uses the `?` operator for clean error handling
    - Converts errors between types when needed
    - Bubbles up errors to the main function
 
-3. Input validation:
+1. Input validation:
    - Checks command-line arguments
    - Validates environment variables
    - Verifies feed ID format