macltok

//! a browser-side slice of macltok, login through to a live sync, exported for

//! wasm-bindgen so both the worker test and the size measurement reach the same code

use futures_channel::oneshot;

use macltok::{

    ConnectionState, EncryptedSessionStore, EngineConfig, Event, PasswordLogin, Session, StoreConfig,

};

use wasm_bindgen::prelude::*;

#[wasm_bindgen]

pub async fn smoke(

    homeserver: String,

    username: String,

    password: String,

    store_name: String,

) -> Result<(), JsError> {

    let sessions = EncryptedSessionStore::indexeddb(

        StoreConfig::indexeddb(store_name, "macltok-web").with_lock_holder("macltok-web-worker"),

    );

    let login = PasswordLogin::new(homeserver, username, password);

    let session = Session::login_password(login, &sessions).await?;

    let (engine, handle, mut events) = session.build(EngineConfig::default()).await?;

    let (done, running) = oneshot::channel();

    wasm_bindgen_futures::spawn_local(async move {

        let _ = done.send(engine.run().await);

    });

    let mut online = false;

    let mut rooms = false;

    while !(online && rooms) {

        match events.recv().await {

            Some(Event::ConnectionChanged(ConnectionState::Online)) => online = true,

            Some(Event::RoomsChanged) => rooms = true,

            Some(Event::Stopped) | None => {

                return Err(JsError::new("engine stopped before it came online"));

            }

            Some(_) => {}

        }

    }

    handle.shutdown().await?;

    while events.recv().await.is_some() {}

    running

        .await

        .map_err(|_| JsError::new("engine task vanished"))??;

    Ok(())

}