Compare commits
No commits in common. "261fe452c16e434b0e8af3209dcf065e8f72c564" and "411db01786d6c0776c0093ce0aa638bd9e83b2ec" have entirely different histories.
261fe452c1
...
411db01786
|
@ -236,7 +236,7 @@ checksum = "613afe47fcd5fac7ccf1db93babcb082c5994d996f20b8b159f2ad1658eb5724"
|
|||
|
||||
[[package]]
|
||||
name = "chorus"
|
||||
version = "0.16.0"
|
||||
version = "0.15.0"
|
||||
dependencies = [
|
||||
"async-trait",
|
||||
"base64 0.21.7",
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
[package]
|
||||
name = "chorus"
|
||||
description = "A library for interacting with multiple Spacebar-compatible Instances at once."
|
||||
version = "0.16.0"
|
||||
version = "0.15.0"
|
||||
license = "MPL-2.0"
|
||||
edition = "2021"
|
||||
repository = "https://github.com/polyphony-chat/chorus"
|
||||
|
|
|
@ -10,10 +10,9 @@ use std::fmt::Debug;
|
|||
use super::{events::Events, *};
|
||||
use crate::types::{self, Composite, Shared};
|
||||
|
||||
/// Represents a handle to a Gateway connection.
|
||||
///
|
||||
/// A Gateway connection will create observable [`Events`], which you can subscribe to.
|
||||
///
|
||||
/// Represents a handle to a Gateway connection. A Gateway connection will create observable
|
||||
/// [`GatewayEvents`](GatewayEvent), which you can subscribe to. Gateway events include all currently
|
||||
/// implemented types with the trait [`WebSocketEvent`]
|
||||
/// Using this handle you can also send Gateway Events directly.
|
||||
#[derive(Debug, Clone)]
|
||||
pub struct GatewayHandle {
|
||||
|
|
|
@ -128,10 +128,10 @@ pub trait Composite<T: Updateable + Clone + Debug> {
|
|||
pub trait IntoShared {
|
||||
/// Uses [`Shared`] to provide an ergonomic alternative to `Arc::new(RwLock::new(obj))`.
|
||||
///
|
||||
/// [`Shared<Self>`] can then be observed using the gateway, turning the underlying
|
||||
/// [`Shared<Self>`] can then be observed using the [`Gateway`], turning the underlying
|
||||
/// `dyn Composite<Self>` into a self-updating struct, which is a tracked variant of a chorus
|
||||
/// entity struct, updating its' held information when new information concerning itself arrives
|
||||
/// over the gateway connection, reducing the need for expensive network-API calls.
|
||||
/// over the [`Gateway`] connection, reducing the need for expensive network-API calls.
|
||||
fn into_shared(self) -> Shared<Self>;
|
||||
}
|
||||
|
||||
|
|
|
@ -70,11 +70,6 @@ pub struct UserModifySchema {
|
|||
/// # Note
|
||||
///
|
||||
/// This is not yet implemented on Spacebar
|
||||
///
|
||||
/// [UserFlags]: crate::types::UserFlags
|
||||
/// [UserFlags::PREMIUM_PROMO_DISMISSED]: crate::types::UserFlags::PREMIUM_PROMO_DISMISSED
|
||||
/// [UserFlags::HAS_UNREAD_URGENT_MESSAGES]:
|
||||
/// crate::types::UserFlags::HAS_UNREAD_URGENT_MESSAGES
|
||||
pub flags: Option<u64>,
|
||||
/// The user's date of birth, can only be set once
|
||||
///
|
||||
|
|
|
@ -26,7 +26,7 @@ impl Snowflake {
|
|||
const PROCESS_ID: u64 = 1;
|
||||
static INCREMENT: AtomicUsize = AtomicUsize::new(0);
|
||||
|
||||
let time = (Utc::now().naive_utc().and_utc().timestamp_millis() - EPOCH) << 22;
|
||||
let time = (Utc::now().naive_utc().timestamp_millis() - EPOCH) << 22;
|
||||
let worker = WORKER_ID << 17;
|
||||
let process = PROCESS_ID << 12;
|
||||
let increment = INCREMENT.fetch_add(1, Ordering::Relaxed) as u64 % 32;
|
||||
|
|
Loading…
Reference in New Issue