use std::{path::PathBuf, time::Duration};
use clap::Parser;
-use jsonrpsee::core::client::{Subscription, SubscriptionClientT};
-use jsonrpsee::core::Error as RpcError;
-use serde_json::Value;
+use jsonrpsee::core::client::{Error as RpcError, Subscription, SubscriptionClientT};
+use serde_json::{Error, Value};
use tokio::{select, time::sleep};
use cli::Cli;
.await
.map_err(|e| RpcError::Custom(format!("JSON-RPC command startLink failed: {e:?}")))?
.device_link_uri;
- println!("{}", url);
+ println!("{url}");
client.finish_link(url, name).await
}
CliCommands::ListAccounts => client.list_accounts().await,
CliCommands::UpdateAccount {
device_name,
unrestricted_unidentified_sender,
+ discoverable_by_number,
+ number_sharing,
} => {
client
- .update_account(cli.account, device_name, unrestricted_unidentified_sender)
+ .update_account(
+ cli.account,
+ device_name,
+ unrestricted_unidentified_sender,
+ discoverable_by_number,
+ number_sharing,
+ )
.await
}
CliCommands::UpdateConfiguration {
.get_attachment(cli.account, id, recipient, group_id)
.await
}
+ CliCommands::GetAvatar {
+ contact,
+ profile,
+ group_id,
+ } => {
+ client
+ .get_avatar(cli.account, contact, profile, group_id)
+ .await
+ }
+ CliCommands::GetSticker {
+ pack_id,
+ sticker_id,
+ } => client.get_sticker(cli.account, pack_id, sticker_id).await,
CliCommands::StartChangeNumber {
number,
voice,
.start_change_number(cli.account, number, voice, captcha)
.await
}
+ CliCommands::SendMessageRequestResponse {
+ recipient,
+ group_id,
+ r#type,
+ } => {
+ client
+ .send_message_request_response(
+ cli.account,
+ recipient,
+ group_id,
+ match r#type {
+ cli::MessageRequestResponseType::Accept => "accept".to_owned(),
+ cli::MessageRequestResponseType::Delete => "delete".to_owned(),
+ },
+ )
+ .await
+ }
}
}
async fn stream_next(
timeout: f64,
stream: &mut Subscription<Value>,
-) -> Option<Result<Value, RpcError>> {
+) -> Option<Result<Value, Error>> {
if timeout < 0.0 {
stream.next().await
} else {