buzzert/Kordophone
Private
Public Access
1
0
Fork 0
Code Packages Activity

kpcli: fix for update data structure changes

Browse Source
This commit is contained in:
James Magahern
2025-05-14 17:43:28 -07:00
parent 83eb97fd9c
commit 77177e07aa
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
kpcli/src/client/mod.rs
View File

@@ -7,7 +7,7 @@ use kordophone::api::event_socket::EventSocket;
use anyhow::Result; use anyhow::Result;
use clap::Subcommand; use clap::Subcommand;
use crate::printers::{ConversationPrinter, MessagePrinter}; use crate::printers::{ConversationPrinter, MessagePrinter};
use kordophone::model::event::Event; use kordophone::model::event::EventData;
use kordophone::model::outgoing_message::OutgoingMessage; use kordophone::model::outgoing_message::OutgoingMessage;
use futures_util::StreamExt; use futures_util::StreamExt;
@@ -104,15 +104,15 @@ impl ClientCli {
} }
pub async fn print_events(&mut self) -> Result<()> { 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; let mut stream = socket.events().await;
while let Some(Ok(event)) = stream.next().await { while let Some(Ok(event)) = stream.next().await {
match event { match event.data {
Event::ConversationChanged(conversation) => { EventData::ConversationChanged(conversation) => {
println!("Conversation changed: {}", conversation.guid); println!("Conversation changed: {}", conversation.guid);
} }
Event::MessageReceived(conversation, message) => { EventData::MessageReceived(conversation, message) => {
println!("Message received: msg: {} conversation: {}", message.guid, conversation.guid); println!("Message received: msg: {} conversation: {}", message.guid, conversation.guid);
} }
} }
@@ -121,7 +121,7 @@ impl ClientCli {
} }
pub async fn print_raw_updates(&mut self) -> Result<()> { 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..."); println!("Listening for raw updates...");
let mut stream = socket.raw_updates().await; let mut stream = socket.raw_updates().await;