ca2462f987
#### PR Dependency Tree * **PR #14243** 👈 This tree was auto-generated by [Charcoal](https://github.com/danerwilliams/charcoal) <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit * **New Features** * Batch management API for coordinated document mutations and change tracking. * New document accessors (IDs, state snapshots, change/delete set queries) and subscriber count. * **Chores** * Upgraded Rust edition across packages to 2024. * Repository-wide formatting, stylistic cleanups and test adjustments. * **Breaking Changes** * Removed the Node native bindings package and its JS/TS declarations and tests (no longer published/available). <sub>✏️ Tip: You can customize this high-level summary in your review settings.</sub> <!-- end of auto-generated comment: release notes by coderabbit.ai -->
67 lines
2.3 KiB
Rust
67 lines
2.3 KiB
Rust
#[forbid(unsafe_code)]
|
|
mod codec;
|
|
mod doc;
|
|
mod protocol;
|
|
mod sync;
|
|
|
|
pub use codec::*;
|
|
pub use doc::{
|
|
Any, Array, Awareness, AwarenessEvent, Batch, Client, ClientMap, Clock, CrdtRead, CrdtReader, CrdtWrite, CrdtWriter,
|
|
Doc, DocOptions, HashMap as AHashMap, HashMapExt, History, HistoryOptions, Id, Map, RawDecoder, RawEncoder,
|
|
StateVector, StoreHistory, Text, TextAttributes, TextDelta, TextDeltaOp, TextInsert, Update, Value, batch_commit,
|
|
encode_awareness_as_message, encode_update_as_message, merge_updates_v1,
|
|
};
|
|
pub(crate) use doc::{Content, Item};
|
|
use log::{debug, warn};
|
|
use nom::IResult;
|
|
pub use protocol::{
|
|
AwarenessState, AwarenessStates, DocMessage, SyncMessage, SyncMessageScanner, read_sync_message, write_sync_message,
|
|
};
|
|
use thiserror::Error;
|
|
|
|
#[derive(Debug, Error, PartialEq)]
|
|
pub enum JwstCodecError {
|
|
#[error("Unexpected Scenario")]
|
|
Unexpected,
|
|
#[error("Damaged document: corrupt json data")]
|
|
DamagedDocumentJson,
|
|
#[error("Incomplete document: {0}")]
|
|
IncompleteDocument(String),
|
|
#[error("Invalid write buffer: {0}")]
|
|
InvalidWriteBuffer(String),
|
|
#[error("Content does not support splitting in {0}")]
|
|
ContentSplitNotSupport(u64),
|
|
#[error("GC or Skip does not support splitting")]
|
|
ItemSplitNotSupport,
|
|
#[error("update is empty")]
|
|
UpdateIsEmpty,
|
|
#[error("invalid update")]
|
|
UpdateInvalid(#[from] nom::Err<nom::error::Error<usize>>),
|
|
#[error("update not fully consumed: {0}")]
|
|
UpdateNotFullyConsumed(usize),
|
|
#[error("invalid struct clock, expect {expect}, actually {actually}")]
|
|
StructClockInvalid { expect: u64, actually: u64 },
|
|
#[error("cannot find struct {clock} in {client_id}")]
|
|
StructSequenceInvalid { client_id: u64, clock: u64 },
|
|
#[error("struct {0} not exists")]
|
|
StructSequenceNotExists(u64),
|
|
#[error("Invalid parent")]
|
|
InvalidParent,
|
|
#[error("Parent not found")]
|
|
ParentNotFound,
|
|
#[error("Invalid struct type, expect item, actually {0}")]
|
|
InvalidStructType(&'static str),
|
|
#[error("Can not cast known type to {0}")]
|
|
TypeCastError(&'static str),
|
|
#[error("Can not found root struct with name: {0}")]
|
|
RootStructNotFound(String),
|
|
#[error("Index {0} out of bound")]
|
|
IndexOutOfBound(u64),
|
|
#[error("Document has been released")]
|
|
DocReleased,
|
|
#[error("Unexpected type, expect {0}")]
|
|
UnexpectedType(&'static str),
|
|
}
|
|
|
|
pub type JwstCodecResult<T = ()> = Result<T, JwstCodecError>;
|