kiteticker-async-manager 0.4.0

High-performance async WebSocket client for Kite Connect API with multi-connection support, dynamic subscription management, and optimized data processing.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use crate::Exchange;
use serde::{Deserialize, Serialize};

use crate::parser::price;

#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
///
/// OHLC packet structure
///
pub struct OHLC {
  pub open: f64,
  pub high: f64,
  pub low: f64,
  pub close: f64,
}

impl OHLC {
  pub(crate) fn from(value: &[u8], exchange: &Exchange) -> Option<Self> {
    value.get(0..16).map(|bs| OHLC {
      open: price(&bs[0..=3], exchange).unwrap(),
      high: price(&bs[4..=7], exchange).unwrap(),
      low: price(&bs[8..=11], exchange).unwrap(),
      close: price(&bs[12..=15], exchange).unwrap(),
    })
  }

  /// Parse OHLC bytes for index instruments.
  ///
  /// The order of fields for indices is `high`, `low`, `open`, `close`.
  pub(crate) fn from_index(value: &[u8], exchange: &Exchange) -> Option<Self> {
    value.get(0..16).map(|bs| OHLC {
      open: price(&bs[8..=11], exchange).unwrap(),
      high: price(&bs[0..=3], exchange).unwrap(),
      low: price(&bs[4..=7], exchange).unwrap(),
      close: price(&bs[12..=15], exchange).unwrap(),
    })
  }
}