mirror of
https://github.com/aljazceru/cdk.git
synced 2026-02-08 06:35:52 +01:00
cdd59359b9
* pubsub: consolidate into Spec, adopt Arc<SubscriptionId>, and wire through wallet/mint/WS/FFI
Refactor the pub/sub engine to a single Spec trait, move Event alongside it,
and propagate Arc-backed subscription IDs across the stack. This simplifies
generics, clarifies responsibilities, and preserves coalescing +
latest-on-subscribe semantics.
- **Single source of truth:** `Spec` owns `Topic`, `Event`, `SubscriptionId`,
`Context`, new_instance, and fetch_events.
- **Lean & explicit API:** Remove Topic trait split;
`Subscriber::send(Event)` carries sub-ID internally.
- **Performance/ergonomics:** `Arc<SubscriptionId>` avoids heavy clones and
makes channel/task hops trivial.
- Introduce `pub_sub/typ.rs` with:
- trait `Spec`
- trait `Event` colocated with Spec.
- Remove `pub_sub/event.rs` fold `Event` into `typ.rs`.
- Make `Pubsub<S>` generic over `Spec` and store `Arc<S>`.
- The subscriber holds `Arc<SubscriptionId>` and deduplicates the latest
entry per subscription.
- SubscriptionRequest: rename SubscriptionName → SubscriptionId; return
`Arc<...>` from `subscription_name()`.
- Remote consumer (Transport) now parameterized by `Spec`; control types
updated:
- `StreamCtrl<S>`, `SubscribeMessage<S>`, internal caches keyed by
`S::Topic`.
- Mint/wallet:
- Mint: `MintPubSubSpec` (Context = `DynMintDatabase`),
`PubSubManager(Pubsub<MintPubSubSpec>)`.
- Wallet: lightweight MintSubTopics Spec with `Context = ()`.
- IDs go Arc end-to-end:
- cdk-axum WS maps `HashMap<Arc<SubId>, JoinHandle<()>>`, publisher sends
`(Arc<SubId>, NotificationPayload)`.
- `subscription::{Params, WalletParams}` now use `Arc<...>`.
- cdk-ffi conversions & wallet glue updated.
- Integration tests updated for new types.
- Coalescing unchanged: multiple local subs to the same topic are combined
into a single remote sub.
- Backfill via `Spec::fetch_events(topics, Subscriber)`; Subscriber enforces
latest-only dedupe per subscription.
**Result:** a slimmer, more maintainable pub/sub core that’s easier to embed
across mint, wallet, transports, and FFI without sacrificing performance or
semantics.
---------
Co-authored-by: thesimplekid <tsk@thesimplekid.com>
56 lines
1.5 KiB
TOML
56 lines
1.5 KiB
TOML
[package]
|
|
name = "cdk-common"
|
|
version.workspace = true
|
|
authors = ["CDK Developers"]
|
|
description = "CDK common types and traits"
|
|
homepage = "https://github.com/cashubtc/cdk"
|
|
repository = "https://github.com/cashubtc/cdk.git"
|
|
edition.workspace = true
|
|
rust-version.workspace = true # MSRV
|
|
license.workspace = true
|
|
readme = "README.md"
|
|
|
|
[features]
|
|
default = ["mint", "wallet"]
|
|
swagger = ["dep:utoipa", "cashu/swagger"]
|
|
test = []
|
|
bench = []
|
|
wallet = ["cashu/wallet"]
|
|
mint = ["cashu/mint", "dep:uuid"]
|
|
auth = ["cashu/auth"]
|
|
prometheus = ["cdk-prometheus/default"]
|
|
|
|
[dependencies]
|
|
async-trait.workspace = true
|
|
bitcoin.workspace = true
|
|
cashu.workspace = true
|
|
cbor-diag.workspace = true
|
|
ciborium.workspace = true
|
|
serde.workspace = true
|
|
lightning-invoice.workspace = true
|
|
lightning.workspace = true
|
|
thiserror.workspace = true
|
|
tracing.workspace = true
|
|
cdk-prometheus = { workspace = true, optional = true}
|
|
url.workspace = true
|
|
uuid = { workspace = true, optional = true }
|
|
utoipa = { workspace = true, optional = true }
|
|
futures.workspace = true
|
|
anyhow.workspace = true
|
|
serde_json.workspace = true
|
|
serde_with.workspace = true
|
|
web-time.workspace = true
|
|
tokio.workspace = true
|
|
parking_lot = "0.12.5"
|
|
|
|
[target.'cfg(target_arch = "wasm32")'.dependencies]
|
|
uuid = { workspace = true, features = ["js"], optional = true }
|
|
getrandom = { version = "0.2", features = ["js"] }
|
|
wasm-bindgen = "0.2"
|
|
wasm-bindgen-futures = "0.4"
|
|
|
|
[dev-dependencies]
|
|
rand.workspace = true
|
|
bip39.workspace = true
|
|
wasm-bindgen-test = "0.3"
|