diff --git a/deltachat-jsonrpc/src/api/mod.rs b/deltachat-jsonrpc/src/api/mod.rs index 6f7c1353a..825925378 100644 --- a/deltachat-jsonrpc/src/api/mod.rs +++ b/deltachat-jsonrpc/src/api/mod.rs @@ -35,13 +35,13 @@ use tokio::sync::{watch, Mutex, RwLock}; use walkdir::WalkDir; use yerpc::rpc; -pub mod events; pub mod types; use num_traits::FromPrimitive; use types::account::Account; use types::chat::FullChat; use types::contact::ContactObject; +use types::events::Event; use types::http::HttpResponse; use types::message::MessageData; use types::message::MessageObject; @@ -49,7 +49,6 @@ use types::provider_info::ProviderInfo; use types::reactions::JSONRPCReactions; use types::webxdc::WebxdcMessageInfo; -use self::events::Event; use self::types::message::MessageLoadResult; use self::types::{ chat::{BasicChat, JSONRPCChatVisibility, MuteDuration}, diff --git a/deltachat-jsonrpc/src/api/events.rs b/deltachat-jsonrpc/src/api/types/events.rs similarity index 99% rename from deltachat-jsonrpc/src/api/events.rs rename to deltachat-jsonrpc/src/api/types/events.rs index 9c36e5b53..37e8c6317 100644 --- a/deltachat-jsonrpc/src/api/events.rs +++ b/deltachat-jsonrpc/src/api/types/events.rs @@ -3,6 +3,7 @@ use serde::Serialize; use typescript_type_def::TypeDef; #[derive(Serialize, TypeDef)] +#[serde(rename_all = "camelCase")] pub struct Event { /// Event payload. event: EventType, diff --git a/deltachat-jsonrpc/src/api/types/mod.rs b/deltachat-jsonrpc/src/api/types/mod.rs index ace49f14e..8143be73d 100644 --- a/deltachat-jsonrpc/src/api/types/mod.rs +++ b/deltachat-jsonrpc/src/api/types/mod.rs @@ -2,6 +2,7 @@ pub mod account; pub mod chat; pub mod chat_list; pub mod contact; +pub mod events; pub mod http; pub mod location; pub mod message; diff --git a/deltachat-jsonrpc/src/lib.rs b/deltachat-jsonrpc/src/lib.rs index bb4ea9cf6..16592bd88 100644 --- a/deltachat-jsonrpc/src/lib.rs +++ b/deltachat-jsonrpc/src/lib.rs @@ -1,5 +1,4 @@ pub mod api; -pub use api::events; pub use yerpc; #[cfg(test)] diff --git a/deltachat-jsonrpc/typescript/src/client.ts b/deltachat-jsonrpc/typescript/src/client.ts index 97c4a8364..d2065cba3 100644 --- a/deltachat-jsonrpc/typescript/src/client.ts +++ b/deltachat-jsonrpc/typescript/src/client.ts @@ -50,16 +50,16 @@ export class BaseDeltaChat< async eventLoop(): Promise { while (true) { const event = await this.rpc.getNextEvent(); - this.emit(event.event.type, event.context_id, event.event as any); - this.emit("ALL", event.context_id, event.event as any); + this.emit(event.event.type, event.contextId, event.event as any); + this.emit("ALL", event.contextId, event.event as any); - if (this.contextEmitters[event.context_id]) { - this.contextEmitters[event.context_id].emit( + if (this.contextEmitters[event.contextId]) { + this.contextEmitters[event.contextId].emit( event.event.type, //@ts-ignore event.event as any ); - this.contextEmitters[event.context_id].emit("ALL", event.event as any); + this.contextEmitters[event.contextId].emit("ALL", event.event as any); } } } diff --git a/deltachat-rpc-client/src/deltachat_rpc_client/rpc.py b/deltachat-rpc-client/src/deltachat_rpc_client/rpc.py index 57e26dd0b..72642625f 100644 --- a/deltachat-rpc-client/src/deltachat_rpc_client/rpc.py +++ b/deltachat-rpc-client/src/deltachat_rpc_client/rpc.py @@ -79,7 +79,7 @@ class Rpc: if self.closing: return event = await self.get_next_event() - account_id = event["context_id"] + account_id = event["contextId"] queue = await self.get_queue(account_id) await queue.put(event["event"])