dbui-client 0.0.64

WASM web client sources for dbui
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

use crate::socket::ws::ClientSocket;

use anyhow::Result;
use dbui_core::profile::UserProfile;
use dbui_core::RequestMessage;
use std::rc::Rc;
use std::sync::RwLock;
use uuid::Uuid;
use web_sys::{Document, Window};

#[derive(Debug)]
pub(crate) struct ClientContext {
  window: Window,
  document: Document,
  tabs: crate::tabs::TabService,
  socket: ClientSocket,
  connection_id: Option<Uuid>,
  user_id: Option<Uuid>,
  user_profile: UserProfile
}

impl ClientContext {
  pub(crate) fn new() -> Result<Rc<RwLock<ClientContext>>> {
    let binary = true;
    let window = web_sys::window().ok_or_else(|| anyhow::anyhow!("Can't find [window]"))?;
    let document = window.document().ok_or_else(|| anyhow::anyhow!("Can't find [document]"))?;
    let loc = &document.location().ok_or_else(|| anyhow::anyhow!("Can't find [location]"))?;
    let url = loc.href().map_err(|_| anyhow::anyhow!("Can't find [href]"))?;
    let tabs = crate::tabs::TabService::new();
    let socket = ClientSocket::new(&url, binary)?;
    let user_profile = UserProfile::default();

    let rc = Rc::new(RwLock::new(ClientContext {
      window,
      document,
      tabs,
      socket,
      connection_id: None,
      user_id: None,
      user_profile
    }));

    crate::socket::ws_events::wire_socket(Rc::clone(&rc));
    crate::socket::ws_events::on_load(&Rc::clone(&rc).read().unwrap())?;

    debug!("[{}] has started", dbui_core::APPNAME);

    Ok(rc)
  }

  pub(crate) fn document(&self) -> &Document {
    &self.document
  }

  pub(crate) fn tabs(&self) -> &crate::tabs::TabService {
    &self.tabs
  }

  pub(crate) fn socket(&self) -> &ClientSocket {
    &self.socket
  }

  pub(crate) fn user_profile(&self) -> &UserProfile {
    &self.user_profile
  }

  pub(crate) fn on_connected(&mut self, connection_id: Uuid, user_id: Uuid, user_profile: UserProfile, binary: bool) {
    self.socket.set_binary(binary);
    self.connection_id = Some(connection_id);
    self.user_id = Some(user_id);
    self.user_profile = user_profile;
  }

  pub(crate) fn on_open(&self) -> Result<()> {
    Ok(())
  }

  pub(crate) fn send(&self, rm: RequestMessage) {
    self.socket.send(rm);
  }

  pub(crate) fn on_event(&mut self, t: &str, k: &str, v: &str) -> Result<()> {
    crate::event_handler::EventHandler::handle(self, t, k, v)
  }

  pub(crate) fn on_error(&self) -> Result<()> {
    Ok(())
  }

  pub(crate) fn on_close(&self) -> Result<()> {
    Ok(())
  }
}