y-sweet 0.6.3

A standalone Yjs CRDT server with built-in persistence and auth.
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

use anyhow::Result;
use std::sync::Arc;
use y_sweet_core::{doc_connection::DOC_NAME, store::Store, sync_kv::SyncKv};
use yrs_kvstore::DocOps;

/// Convert a Yjs document (encoded as a v1 update) to a .ysweet store.
pub async fn convert(store: Box<dyn Store>, doc_as_update: &[u8], doc_id: &str) -> Result<()> {
    let store = Some(Arc::new(store));

    let sync_kv = SyncKv::new(store, doc_id, || ()).await?;

    let sync_kv = Arc::new(sync_kv);

    sync_kv
        .push_update(DOC_NAME, doc_as_update)
        .map_err(|_| anyhow::anyhow!("Failed to push update"))?;

    sync_kv
        .flush_doc_with(DOC_NAME, yrs::Options::default())
        .map_err(|err| anyhow::anyhow!("Failed to flush doc {:?}", err))?;

    sync_kv
        .persist()
        .await
        .map_err(|e| anyhow::anyhow!("Failed to persist: {:?}", e))?;

    Ok(())
}