qinstagram 0.1.1

Enterprise-grade IG Private API Architecture & Protocol Engineering toolkit with 100% Async-GraphQL & Websocket integration.
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use crate::error::{InstagramError, Result};
#[cfg(feature = "websocket")]
use crate::ws::InstagramWsEvent;
#[cfg(feature = "websocket")]
use tokio::sync::broadcast;

pub struct RealtimeClient {
    #[cfg(feature = "websocket")]
    pub broadcaster: Option<broadcast::Sender<InstagramWsEvent>>,
}

impl Default for RealtimeClient {
    fn default() -> Self {
        Self::new()
    }
}

impl RealtimeClient {
    pub fn new() -> Self {
        Self {
            #[cfg(feature = "websocket")]
            broadcaster: None,
        }
    }

    #[cfg(feature = "websocket")]
    pub fn with_broadcaster(mut self, tx: broadcast::Sender<InstagramWsEvent>) -> Self {
        self.broadcaster = Some(tx);
        self
    }
    
    pub async fn connect(&mut self) -> Result<()> {
        // Architecture Placeholder for rumqttc loop.
        // let mut eventloop = ...
        // while let Ok(notification) = eventloop.poll().await {
        //     match notification {
        //         Event::Incoming(Incoming::Publish(p)) => {
        //             let event = parse_skywalker_binary(&p.payload)?;
        //             if let Some(ref tx) = self.broadcaster {
        //                  let _ = tx.send(event);
        //             }
        //         }
        //         _ => {}
        //     }
        // }
        Err(InstagramError::NotImplemented("MQTT Connect / Thrift Binary Parsing missing".into()))
    }
}

#[cfg(feature = "websocket")]
pub fn parse_skywalker_binary(_bytes: &[u8]) -> Result<InstagramWsEvent> {
    // Advanced Thrift decoding maps here corresponding to IG protobufs.
    Err(InstagramError::NotImplemented("Thrift Decode".into()))
}