From 77177e07aa1b2a39fdd4525c5b487f89f0ae5526 Mon Sep 17 00:00:00 2001 From: James Magahern Date: Wed, 14 May 2025 17:43:28 -0700 Subject: [PATCH] kpcli: fix for update data structure changes --- kpcli/src/client/mod.rs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/kpcli/src/client/mod.rs b/kpcli/src/client/mod.rs index 9356d33..7438868 100644 --- a/kpcli/src/client/mod.rs +++ b/kpcli/src/client/mod.rs @@ -7,7 +7,7 @@ use kordophone::api::event_socket::EventSocket; use anyhow::Result; use clap::Subcommand; use crate::printers::{ConversationPrinter, MessagePrinter}; -use kordophone::model::event::Event; +use kordophone::model::event::EventData; use kordophone::model::outgoing_message::OutgoingMessage; use futures_util::StreamExt; @@ -104,15 +104,15 @@ impl ClientCli { } pub async fn print_events(&mut self) -> Result<()> { - let socket = self.api.open_event_socket().await?; + let socket = self.api.open_event_socket(None).await?; let mut stream = socket.events().await; while let Some(Ok(event)) = stream.next().await { - match event { - Event::ConversationChanged(conversation) => { + match event.data { + EventData::ConversationChanged(conversation) => { println!("Conversation changed: {}", conversation.guid); } - Event::MessageReceived(conversation, message) => { + EventData::MessageReceived(conversation, message) => { println!("Message received: msg: {} conversation: {}", message.guid, conversation.guid); } } @@ -121,7 +121,7 @@ impl ClientCli { } pub async fn print_raw_updates(&mut self) -> Result<()> { - let socket = self.api.open_event_socket().await?; + let socket = self.api.open_event_socket(None).await?; println!("Listening for raw updates..."); let mut stream = socket.raw_updates().await;