diff --git a/examples/repl/cmdline.rs b/examples/repl/cmdline.rs index 8df9358a9..58cf4582f 100644 --- a/examples/repl/cmdline.rs +++ b/examples/repl/cmdline.rs @@ -17,7 +17,7 @@ use deltachat::message::{self, Message, MessageState, MsgId}; use deltachat::peerstate::*; use deltachat::qr::*; use deltachat::sql; -use deltachat::Event; +use deltachat::EventType; use deltachat::{config, provider}; /// Reset database tables. @@ -86,7 +86,7 @@ async fn reset_tables(context: &Context, bits: i32) { println!("(8) Rest but server config reset."); } - context.emit_event(Event::MsgsChanged { + context.emit_event(EventType::MsgsChanged { chat_id: ChatId::new(0), msg_id: MsgId::new(0), }); @@ -157,7 +157,7 @@ async fn poke_spec(context: &Context, spec: Option<&str>) -> bool { } println!("Import: {} items read from \"{}\".", read_cnt, &real_spec); if read_cnt > 0 { - context.emit_event(Event::MsgsChanged { + context.emit_event(EventType::MsgsChanged { chat_id: ChatId::new(0), msg_id: MsgId::new(0), }); @@ -1059,7 +1059,7 @@ pub async fn cmdline(context: Context, line: &str, chat_id: &mut ChatId) -> Resu // "event" => { // ensure!(!arg1.is_empty(), "Argument missing."); // let event = arg1.parse()?; - // let event = Event::from_u32(event).ok_or(format_err!("Event::from_u32({})", event))?; + // let event = EventType::from_u32(event).ok_or(format_err!("EventType::from_u32({})", event))?; // let r = context.emit_event(event, 0 as libc::uintptr_t, 0 as libc::uintptr_t); // println!( // "Sending event {:?}({}), received value {}.", diff --git a/examples/repl/main.rs b/examples/repl/main.rs index 7be1c9bea..1cddc9266 100644 --- a/examples/repl/main.rs +++ b/examples/repl/main.rs @@ -19,7 +19,7 @@ use deltachat::config; use deltachat::context::*; use deltachat::oauth2::*; use deltachat::securejoin::*; -use deltachat::Event; +use deltachat::EventType; use log::{error, info, warn}; use rustyline::completion::{Completer, FilenameCompleter, Pair}; use rustyline::config::OutputStreamType; @@ -34,35 +34,35 @@ mod cmdline; use self::cmdline::*; /// Event Handler -fn receive_event(event: Event) { +fn receive_event(event: EventType) { let yellow = Color::Yellow.normal(); match event { - Event::Info(msg) => { + EventType::Info(msg) => { /* do not show the event as this would fill the screen */ info!("{}", msg); } - Event::SmtpConnected(msg) => { + EventType::SmtpConnected(msg) => { info!("[SMTP_CONNECTED] {}", msg); } - Event::ImapConnected(msg) => { + EventType::ImapConnected(msg) => { info!("[IMAP_CONNECTED] {}", msg); } - Event::SmtpMessageSent(msg) => { + EventType::SmtpMessageSent(msg) => { info!("[SMTP_MESSAGE_SENT] {}", msg); } - Event::Warning(msg) => { + EventType::Warning(msg) => { warn!("{}", msg); } - Event::Error(msg) => { + EventType::Error(msg) => { error!("{}", msg); } - Event::ErrorNetwork(msg) => { + EventType::ErrorNetwork(msg) => { error!("[NETWORK] msg={}", msg); } - Event::ErrorSelfNotInGroup(msg) => { + EventType::ErrorSelfNotInGroup(msg) => { error!("[SELF_NOT_IN_GROUP] {}", msg); } - Event::MsgsChanged { chat_id, msg_id } => { + EventType::MsgsChanged { chat_id, msg_id } => { info!( "{}", yellow.paint(format!( @@ -71,34 +71,34 @@ fn receive_event(event: Event) { )) ); } - Event::ContactsChanged(_) => { + EventType::ContactsChanged(_) => { info!("{}", yellow.paint("Received CONTACTS_CHANGED()")); } - Event::LocationChanged(contact) => { + EventType::LocationChanged(contact) => { info!( "{}", yellow.paint(format!("Received LOCATION_CHANGED(contact={:?})", contact)) ); } - Event::ConfigureProgress(progress) => { + EventType::ConfigureProgress(progress) => { info!( "{}", yellow.paint(format!("Received CONFIGURE_PROGRESS({} ‰)", progress)) ); } - Event::ImexProgress(progress) => { + EventType::ImexProgress(progress) => { info!( "{}", yellow.paint(format!("Received IMEX_PROGRESS({} ‰)", progress)) ); } - Event::ImexFileWritten(file) => { + EventType::ImexFileWritten(file) => { info!( "{}", yellow.paint(format!("Received IMEX_FILE_WRITTEN({})", file.display())) ); } - Event::ChatModified(chat) => { + EventType::ChatModified(chat) => { info!( "{}", yellow.paint(format!("Received CHAT_MODIFIED({})", chat)) @@ -272,12 +272,12 @@ async fn start(args: Vec) -> Result<(), Error> { println!("Error: Bad arguments, expected [db-name]."); bail!("No db-name specified"); } - let context = Context::new("CLI".into(), Path::new(&args[1]).to_path_buf()).await?; + let context = Context::new("CLI".into(), Path::new(&args[1]).to_path_buf(), 0).await?; let events = context.get_event_emitter(); async_std::task::spawn(async move { while let Some(event) = events.recv().await { - receive_event(event); + receive_event(event.typ); } }); diff --git a/examples/simple.rs b/examples/simple.rs index 2d37769ad..863960ea3 100644 --- a/examples/simple.rs +++ b/examples/simple.rs @@ -6,20 +6,20 @@ use deltachat::config; use deltachat::contact::*; use deltachat::context::*; use deltachat::message::Message; -use deltachat::Event; +use deltachat::EventType; -fn cb(event: Event) { +fn cb(event: EventType) { match event { - Event::ConfigureProgress(progress) => { + EventType::ConfigureProgress(progress) => { log::info!("progress: {}", progress); } - Event::Info(msg) => { + EventType::Info(msg) => { log::info!("{}", msg); } - Event::Warning(msg) => { + EventType::Warning(msg) => { log::warn!("{}", msg); } - Event::Error(msg) | Event::ErrorNetwork(msg) => { + EventType::Error(msg) | EventType::ErrorNetwork(msg) => { log::error!("{}", msg); } event => { @@ -36,7 +36,7 @@ async fn main() { let dir = tempdir().unwrap(); let dbfile = dir.path().join("db.sqlite"); log::info!("creating database {:?}", dbfile); - let ctx = Context::new("FakeOs".into(), dbfile.into()) + let ctx = Context::new("FakeOs".into(), dbfile.into(), 0) .await .expect("Failed to create context"); let info = ctx.get_info().await; @@ -45,7 +45,7 @@ async fn main() { let events = ctx.get_event_emitter(); let events_spawn = async_std::task::spawn(async move { while let Some(event) = events.recv().await { - cb(event); + cb(event.typ); } });