Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-20 07:16:31 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #342 from deltachat/rm_goto_cmdline

Browse Source 
rm GOTO: cmdline
This commit is contained in:
Jikstra
2019-08-13 02:09:14 +02:00
committed by GitHub
parent ab022ccc33 2dd3088f50
commit 2445b12898
1 changed files with 52 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

110
examples/repl/cmdline.rs
View File

@@ -125,7 +125,7 @@ unsafe fn poke_spec(context: &Context, spec: *const libc::c_char) -> libc::c_int
return 0; return 0;
} }
let mut current_block: u64; let ok_to_continue;
let mut success: libc::c_int = 0; let mut success: libc::c_int = 0;
let real_spec: *mut libc::c_char; let real_spec: *mut libc::c_char;
let mut suffix: *mut libc::c_char = 0 as *mut libc::c_char; let mut suffix: *mut libc::c_char = 0 as *mut libc::c_char;
@@ -138,77 +138,71 @@ unsafe fn poke_spec(context: &Context, spec: *const libc::c_char) -> libc::c_int
.sql .sql
.set_config(context, "import_spec", Some(as_str(real_spec))) .set_config(context, "import_spec", Some(as_str(real_spec)))
.unwrap(); .unwrap();
current_block = 7149356873433890176; ok_to_continue = true;
} else { } else {
let rs = context.sql.get_config(context, "import_spec"); let rs = context.sql.get_config(context, "import_spec");
if rs.is_none() { if rs.is_none() {
error!(context, 0, "Import: No file or folder given."); error!(context, 0, "Import: No file or folder given.");
current_block = 8522321847195001863; ok_to_continue = false;
} else { } else {
current_block = 7149356873433890176; ok_to_continue = true;
} }
real_spec = rs.unwrap_or_default().strdup(); real_spec = rs.unwrap_or_default().strdup();
} }
match current_block { if ok_to_continue {
8522321847195001863 => {} let ok_to_continue2;
_ => { suffix = dc_get_filesuffix_lc(real_spec);
suffix = dc_get_filesuffix_lc(real_spec); if !suffix.is_null() && strcmp(suffix, b"eml\x00" as *const u8 as *const libc::c_char) == 0
if !suffix.is_null() {
&& strcmp(suffix, b"eml\x00" as *const u8 as *const libc::c_char) == 0 if 0 != dc_poke_eml_file(context, real_spec) {
{ read_cnt += 1
if 0 != dc_poke_eml_file(context, real_spec) { }
read_cnt += 1 ok_to_continue2 = true;
} } else {
current_block = 1622411330066726685; /* import a directory */
let dir_name = std::path::Path::new(as_str(real_spec));
let dir = std::fs::read_dir(dir_name);
if dir.is_err() {
error!(
context,
0,
"Import: Cannot open directory \"{}\".",
as_str(real_spec),
);
ok_to_continue2 = false;
} else { } else {
/* import a directory */ let dir = dir.unwrap();
let dir_name = std::path::Path::new(as_str(real_spec)); for entry in dir {
let dir = std::fs::read_dir(dir_name); if entry.is_err() {
if dir.is_err() { break;
error!( }
context, let entry = entry.unwrap();
0, let name_f = entry.file_name();
"Import: Cannot open directory \"{}\".", let name = name_f.to_string_lossy();
as_str(real_spec), if name.ends_with(".eml") {
); let path_plus_name = format!("{}/{}", as_str(real_spec), name);
current_block = 8522321847195001863; info!(context, 0, "Import: {}", path_plus_name);
} else { let path_plus_name_c = CString::yolo(path_plus_name);
let dir = dir.unwrap(); if 0 != dc_poke_eml_file(context, path_plus_name_c.as_ptr()) {
for entry in dir { read_cnt += 1
if entry.is_err() {
break;
}
let entry = entry.unwrap();
let name_f = entry.file_name();
let name = name_f.to_string_lossy();
if name.ends_with(".eml") {
let path_plus_name = format!("{}/{}", as_str(real_spec), name);
info!(context, 0, "Import: {}", path_plus_name);
let path_plus_name_c = CString::yolo(path_plus_name);
if 0 != dc_poke_eml_file(context, path_plus_name_c.as_ptr()) {
read_cnt += 1
}
} }
} }
current_block = 1622411330066726685;
} }
ok_to_continue2 = true;
} }
match current_block { }
8522321847195001863 => {} if ok_to_continue2 {
_ => { info!(
info!( context,
context, 0,
0, "Import: {} items read from \"{}\".",
"Import: {} items read from \"{}\".", read_cnt,
read_cnt, as_str(real_spec)
as_str(real_spec) );
); if read_cnt > 0 {
if read_cnt > 0 { context.call_cb(Event::MSGS_CHANGED, 0 as uintptr_t, 0 as uintptr_t);
context.call_cb(Event::MSGS_CHANGED, 0 as uintptr_t, 0 as uintptr_t);
}
success = 1
}
} }
success = 1
} }
} }