package eu.faircode.email; /* This file is part of FairEmail. FairEmail is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. FairEmail is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with FairEmail. If not, see . Copyright 2018-2019 by Marcel Bokhorst (M66B) */ import android.Manifest; import android.app.Dialog; import android.app.Notification; import android.app.NotificationChannel; import android.app.NotificationChannelGroup; import android.app.NotificationManager; import android.content.BroadcastReceiver; import android.content.ContentResolver; import android.content.Context; import android.content.DialogInterface; import android.content.Intent; import android.content.IntentFilter; import android.content.SharedPreferences; import android.content.res.AssetFileDescriptor; import android.content.res.Configuration; import android.graphics.Rect; import android.graphics.drawable.Drawable; import android.media.Ringtone; import android.media.RingtoneManager; import android.net.Uri; import android.os.Build; import android.os.Bundle; import android.text.TextUtils; import android.view.LayoutInflater; import android.view.MenuItem; import android.view.View; import android.widget.TextView; import android.widget.Toast; import androidx.annotation.NonNull; import androidx.annotation.Nullable; import androidx.annotation.RequiresApi; import androidx.appcompat.app.ActionBarDrawerToggle; import androidx.appcompat.app.AlertDialog; import androidx.constraintlayout.widget.ConstraintLayout; import androidx.documentfile.provider.DocumentFile; import androidx.drawerlayout.widget.DrawerLayout; import androidx.fragment.app.FragmentManager; import androidx.fragment.app.FragmentTransaction; import androidx.lifecycle.Lifecycle; import androidx.lifecycle.Observer; import androidx.localbroadcastmanager.content.LocalBroadcastManager; import androidx.preference.PreferenceManager; import androidx.recyclerview.widget.DividerItemDecoration; import androidx.recyclerview.widget.LinearLayoutManager; import androidx.recyclerview.widget.RecyclerView; import com.google.android.material.textfield.TextInputLayout; import com.microsoft.identity.client.AuthenticationCallback; import com.microsoft.identity.client.IAuthenticationResult; import com.microsoft.identity.client.IMultipleAccountPublicClientApplication; import com.microsoft.identity.client.IPublicClientApplication; import com.microsoft.identity.client.PublicClientApplication; import com.microsoft.identity.client.exception.MsalException; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.nio.charset.StandardCharsets; import java.security.SecureRandom; import java.security.spec.KeySpec; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; import javax.crypto.BadPaddingException; import javax.crypto.Cipher; import javax.crypto.CipherInputStream; import javax.crypto.CipherOutputStream; import javax.crypto.IllegalBlockSizeException; import javax.crypto.SecretKey; import javax.crypto.SecretKeyFactory; import javax.crypto.spec.IvParameterSpec; import javax.crypto.spec.PBEKeySpec; public class ActivitySetup extends ActivityBase implements FragmentManager.OnBackStackChangedListener { private View view; private DrawerLayout drawerLayout; private ActionBarDrawerToggle drawerToggle; private ConstraintLayout drawerContainer; private RecyclerView rvMenu; private boolean hasAccount; private String password; private static final int KEY_ITERATIONS = 65536; private static final int KEY_LENGTH = 256; static final int REQUEST_PERMISSION = 1; static final int REQUEST_SOUND = 2; static final int REQUEST_EXPORT = 3; static final int REQUEST_IMPORT = 4; static final int REQUEST_IMPORT_OAUTH = 5; static final int REQUEST_CHOOSE_ACCOUNT = 6; static final int REQUEST_DONE = 7; static final String ACTION_QUICK_GMAIL = BuildConfig.APPLICATION_ID + ".ACTION_QUICK_GMAIL"; static final String ACTION_QUICK_OUTLOOK = BuildConfig.APPLICATION_ID + ".ACTION_QUICK_OUTLOOK"; static final String ACTION_QUICK_SETUP = BuildConfig.APPLICATION_ID + ".ACTION_QUICK_SETUP"; static final String ACTION_VIEW_ACCOUNTS = BuildConfig.APPLICATION_ID + ".ACTION_VIEW_ACCOUNTS"; static final String ACTION_VIEW_IDENTITIES = BuildConfig.APPLICATION_ID + ".ACTION_VIEW_IDENTITIES"; static final String ACTION_EDIT_ACCOUNT = BuildConfig.APPLICATION_ID + ".EDIT_ACCOUNT"; static final String ACTION_EDIT_IDENTITY = BuildConfig.APPLICATION_ID + ".EDIT_IDENTITY"; static final String ACTION_MANAGE_LOCAL_CONTACTS = BuildConfig.APPLICATION_ID + ".LOCAL_CONTACTS"; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); view = LayoutInflater.from(this).inflate(R.layout.activity_setup, null); setContentView(view); getSupportActionBar().setDisplayHomeAsUpEnabled(true); drawerLayout = findViewById(R.id.drawer_layout); drawerLayout.setScrimColor(Helper.resolveColor(this, R.attr.colorDrawerScrim)); drawerToggle = new ActionBarDrawerToggle(this, drawerLayout, R.string.app_name, R.string.app_name) { public void onDrawerClosed(View view) { super.onDrawerClosed(view); } public void onDrawerOpened(View drawerView) { super.onDrawerOpened(drawerView); } }; drawerLayout.addDrawerListener(drawerToggle); drawerContainer = findViewById(R.id.drawer_container); rvMenu = drawerContainer.findViewById(R.id.rvMenu); LinearLayoutManager llm = new LinearLayoutManager(this); rvMenu.setLayoutManager(llm); final AdapterNavMenu adapter = new AdapterNavMenu(this, this); rvMenu.setAdapter(adapter); final Drawable d = getDrawable(R.drawable.divider); DividerItemDecoration itemDecorator = new DividerItemDecoration(this, llm.getOrientation()) { @Override public void getItemOffsets(Rect outRect, View view, RecyclerView parent, RecyclerView.State state) { int pos = parent.getChildAdapterPosition(view); NavMenuItem menu = adapter.get(pos); outRect.set(0, 0, 0, menu != null && menu.isSeparated() ? d.getIntrinsicHeight() : 0); } }; itemDecorator.setDrawable(d); rvMenu.addItemDecoration(itemDecorator); final List menus = new ArrayList<>(); menus.add(new NavMenuItem(R.drawable.baseline_archive_24, R.string.title_setup_export, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuExport(); } })); menus.add(new NavMenuItem(R.drawable.baseline_unarchive_24, R.string.title_setup_import, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuImport(); } }).setSeparated()); menus.add(new NavMenuItem(R.drawable.baseline_reorder_24, R.string.title_setup_reorder_accounts, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuOrder(R.string.title_setup_reorder_accounts, EntityAccount.class); } })); NavMenuItem order = new NavMenuItem(R.drawable.baseline_reorder_24, R.string.title_setup_reorder_folders, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuOrder(R.string.title_setup_reorder_folders, TupleFolderSort.class); } }).setSeparated(); menus.add(order); menus.add(new NavMenuItem(R.drawable.baseline_help_24, R.string.menu_legend, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuLegend(); } })); menus.add(new NavMenuItem(R.drawable.baseline_question_answer_24, R.string.menu_faq, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuFAQ(); } }).setExternal(true)); menus.add(new NavMenuItem(R.drawable.baseline_account_box_24, R.string.menu_privacy, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuPrivacy(); } })); menus.add(new NavMenuItem(R.drawable.baseline_info_24, R.string.menu_about, new Runnable() { @Override public void run() { drawerLayout.closeDrawer(drawerContainer); onMenuAbout(); } })); adapter.set(menus); getSupportFragmentManager().addOnBackStackChangedListener(this); if (getSupportFragmentManager().getFragments().size() == 0) { Intent intent = getIntent(); String target = intent.getStringExtra("target"); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); if ("accounts".equals(target)) fragmentTransaction.replace(R.id.content_frame, new FragmentAccounts()).addToBackStack("accounts"); else fragmentTransaction.replace(R.id.content_frame, new FragmentOptions()).addToBackStack("options"); fragmentTransaction.commit(); if (intent.hasExtra("target")) { intent.removeExtra("target"); setIntent(intent); } } if (savedInstanceState != null) drawerToggle.setDrawerIndicatorEnabled(savedInstanceState.getBoolean("fair:toggle")); DB.getInstance(this).account().liveSynchronizingAccounts().observe(this, new Observer>() { @Override public void onChanged(List accounts) { hasAccount = (accounts != null && accounts.size() > 0); } }); } @Override protected void onSaveInstanceState(Bundle outState) { outState.putBoolean("fair:toggle", drawerToggle.isDrawerIndicatorEnabled()); super.onSaveInstanceState(outState); } @Override protected void onPostCreate(Bundle savedInstanceState) { super.onPostCreate(savedInstanceState); drawerToggle.syncState(); } @Override protected void onResume() { super.onResume(); LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(this); IntentFilter iff = new IntentFilter(); iff.addAction(ACTION_QUICK_GMAIL); iff.addAction(ACTION_QUICK_OUTLOOK); iff.addAction(ACTION_QUICK_SETUP); iff.addAction(ACTION_VIEW_ACCOUNTS); iff.addAction(ACTION_VIEW_IDENTITIES); iff.addAction(ACTION_EDIT_ACCOUNT); iff.addAction(ACTION_EDIT_IDENTITY); iff.addAction(ACTION_MANAGE_LOCAL_CONTACTS); lbm.registerReceiver(receiver, iff); } @Override protected void onPause() { super.onPause(); LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(this); lbm.unregisterReceiver(receiver); } @Override public void onConfigurationChanged(Configuration newConfig) { super.onConfigurationChanged(newConfig); drawerToggle.onConfigurationChanged(newConfig); } @Override public void onBackPressed() { if (drawerLayout.isDrawerOpen(drawerContainer)) drawerLayout.closeDrawer(drawerContainer); else super.onBackPressed(); } @Override public void onBackStackChanged() { int count = getSupportFragmentManager().getBackStackEntryCount(); if (count == 0) { if (hasAccount) startActivity(new Intent(this, ActivityView.class)); finish(); } else { if (drawerLayout.isDrawerOpen(drawerContainer)) drawerLayout.closeDrawer(drawerContainer); drawerToggle.setDrawerIndicatorEnabled(count == 1); } } @Override public boolean onOptionsItemSelected(MenuItem item) { if (drawerToggle.onOptionsItemSelected(item)) return true; return super.onOptionsItemSelected(item); } @Override public void onActivityResult(int requestCode, int resultCode, Intent data) { super.onActivityResult(requestCode, resultCode, data); try { switch (requestCode) { case REQUEST_EXPORT: if (resultCode == RESULT_OK && data != null) handleExport(data, this.password); break; case REQUEST_IMPORT: if (resultCode == RESULT_OK && data != null) handleImport(data, this.password); break; case REQUEST_IMPORT_OAUTH: ServiceSynchronize.reload(this, "oauth"); break; } } catch (Throwable ex) { Log.e(ex); } } private void onMenuExport() { if (ActivityBilling.isPro(this)) { try { askPassword(true); } catch (Throwable ex) { Helper.unexpectedError(getSupportFragmentManager(), ex); } } else startActivity(new Intent(this, ActivityBilling.class)); } private void onMenuImport() { try { askPassword(false); } catch (Throwable ex) { Helper.unexpectedError(getSupportFragmentManager(), ex); } } private void askPassword(final boolean export) { Bundle args = new Bundle(); args.putBoolean("export", export); FragmentDialogPassword fragment = new FragmentDialogPassword(); fragment.setArguments(args); fragment.show(getSupportFragmentManager(), "password"); } private void onMenuOrder(int title, Class clazz) { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED)) getSupportFragmentManager().popBackStack("order", FragmentManager.POP_BACK_STACK_INCLUSIVE); Bundle args = new Bundle(); args.putInt("title", title); args.putString("class", clazz.getName()); FragmentOrder fragment = new FragmentOrder(); fragment.setArguments(args); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, fragment).addToBackStack("order"); fragmentTransaction.commit(); } private void onMenuLegend() { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED)) getSupportFragmentManager().popBackStack("legend", FragmentManager.POP_BACK_STACK_INCLUSIVE); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentLegend()).addToBackStack("legend"); fragmentTransaction.commit(); } private void onMenuFAQ() { Helper.viewFAQ(this, 0); } private void onMenuPrivacy() { Bundle args = new Bundle(); args.putString("name", "PRIVACY.md"); FragmentDialogMarkdown fragment = new FragmentDialogMarkdown(); fragment.setArguments(args); fragment.show(getSupportFragmentManager(), "privacy"); } private void onMenuAbout() { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED)) getSupportFragmentManager().popBackStack("about", FragmentManager.POP_BACK_STACK_INCLUSIVE); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentAbout()).addToBackStack("about"); fragmentTransaction.commit(); } private void handleExport(Intent data, String password) { Bundle args = new Bundle(); args.putParcelable("uri", data.getData()); args.putString("password", password); new SimpleTask() { @Override protected void onPreExecute(Bundle args) { ToastEx.makeText(ActivitySetup.this, R.string.title_executing, Toast.LENGTH_LONG).show(); } @Override protected Void onExecute(Context context, Bundle args) throws Throwable { Uri uri = args.getParcelable("uri"); String password = args.getString("password"); if (!"content".equals(uri.getScheme())) { Log.w("Export uri=" + uri); throw new IllegalArgumentException(context.getString(R.string.title_no_stream)); } Log.i("Collecting data"); DB db = DB.getInstance(context); NotificationManager nm = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE); // Accounts JSONArray jaccounts = new JSONArray(); for (EntityAccount account : db.account().getAccounts()) { // Account JSONObject jaccount = account.toJSON(); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { if (account.notify) { NotificationChannel channel = nm.getNotificationChannel( EntityAccount.getNotificationChannelId(account.id)); if (channel != null && channel.getImportance() != NotificationManager.IMPORTANCE_NONE) { JSONObject jchannel = channelToJSON(channel); jaccount.put("channel", jchannel); Log.i("Exported account channel=" + jchannel); } } } // Identities JSONArray jidentities = new JSONArray(); for (EntityIdentity identity : db.identity().getIdentities(account.id)) jidentities.put(identity.toJSON()); jaccount.put("identities", jidentities); // Folders JSONArray jfolders = new JSONArray(); for (EntityFolder folder : db.folder().getFolders(account.id, false, true)) { JSONObject jfolder = folder.toJSON(); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { NotificationChannel channel = nm.getNotificationChannel( EntityFolder.getNotificationChannelId(folder.id)); if (channel != null && channel.getImportance() != NotificationManager.IMPORTANCE_NONE) { JSONObject jchannel = channelToJSON(channel); jfolder.put("channel", jchannel); Log.i("Exported folder channel=" + jchannel); } } JSONArray jrules = new JSONArray(); for (EntityRule rule : db.rule().getRules(folder.id)) jrules.put(rule.toJSON()); jfolder.put("rules", jrules); jfolders.put(jfolder); } jaccount.put("folders", jfolders); // Contacts JSONArray jcontacts = new JSONArray(); for (EntityContact contact : db.contact().getContacts(account.id)) jcontacts.put(contact.toJSON()); jaccount.put("contacts", jcontacts); jaccounts.put(jaccount); } // Answers JSONArray janswers = new JSONArray(); for (EntityAnswer answer : db.answer().getAnswers(true)) janswers.put(answer.toJSON()); // Settings SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(context); JSONArray jsettings = new JSONArray(); for (String key : prefs.getAll().keySet()) { JSONObject jsetting = new JSONObject(); Object value = prefs.getAll().get(key); jsetting.put("key", key); jsetting.put("value", value); if (value instanceof Boolean) jsetting.put("type", "bool"); else if (value instanceof Integer) jsetting.put("type", "int"); else if (value instanceof Long) jsetting.put("type", "long"); else if (value instanceof String) jsetting.put("type", "string"); else if (value != null) { String type = value.getClass().getName(); Log.w("Unknown type=" + type); jsetting.put("type", type); } jsettings.put(jsetting); } JSONObject jexport = new JSONObject(); jexport.put("accounts", jaccounts); jexport.put("answers", janswers); jexport.put("settings", jsettings); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { JSONArray jchannels = new JSONArray(); for (NotificationChannel channel : nm.getNotificationChannels()) { String id = channel.getId(); if (id.startsWith("notification.") && id.contains("@") && channel.getImportance() != NotificationManager.IMPORTANCE_NONE) { JSONObject jchannel = channelToJSON(channel); jchannels.put(jchannel); Log.i("Exported contact channel=" + jchannel); } } jexport.put("channels", jchannels); } ContentResolver resolver = context.getContentResolver(); DocumentFile file = DocumentFile.fromSingleUri(context, uri); try (OutputStream raw = resolver.openOutputStream(uri)) { Log.i("Writing URI=" + uri + " name=" + file.getName() + " virtual=" + file.isVirtual()); if (TextUtils.isEmpty(password)) raw.write(jexport.toString(2).getBytes()); else { byte[] salt = new byte[16]; SecureRandom random = new SecureRandom(); random.nextBytes(salt); // https://docs.oracle.com/javase/7/docs/technotes/guides/security/StandardNames.html#Cipher SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("PBKDF2WithHmacSHA1"); KeySpec keySpec = new PBEKeySpec(password.toCharArray(), salt, KEY_ITERATIONS, KEY_LENGTH); SecretKey secret = keyFactory.generateSecret(keySpec); Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding"); cipher.init(Cipher.ENCRYPT_MODE, secret); raw.write(salt); raw.write(cipher.getIV()); OutputStream cout = new CipherOutputStream(raw, cipher); cout.write(jexport.toString(2).getBytes()); cout.flush(); raw.write(cipher.doFinal()); } Log.i("Exported data"); } return null; } @Override protected void onExecuted(Bundle args, Void data) { ToastEx.makeText(ActivitySetup.this, R.string.title_setup_exported, Toast.LENGTH_LONG).show(); } @Override protected void onException(Bundle args, Throwable ex) { if (ex instanceof IllegalArgumentException) ToastEx.makeText(ActivitySetup.this, ex.getMessage(), Toast.LENGTH_LONG).show(); else Helper.unexpectedError(getSupportFragmentManager(), ex); } }.execute(this, args, "setup:export"); } private void handleImport(Intent data, String password) { Bundle args = new Bundle(); args.putParcelable("uri", data.getData()); args.putString("password", password); new SimpleTask() { @Override protected void onPreExecute(Bundle args) { ToastEx.makeText(ActivitySetup.this, R.string.title_executing, Toast.LENGTH_LONG).show(); } @Override protected Boolean onExecute(Context context, Bundle args) throws Throwable { Uri uri = args.getParcelable("uri"); String password = args.getString("password"); if (!"content".equals(uri.getScheme())) { Log.w("Import uri=" + uri); throw new IllegalArgumentException(context.getString(R.string.title_no_stream)); } boolean oauth = false; StringBuilder data = new StringBuilder(); Log.i("Reading URI=" + uri); ContentResolver resolver = context.getContentResolver(); AssetFileDescriptor descriptor = resolver.openTypedAssetFileDescriptor(uri, "*/*", null); try (InputStream raw = new BufferedInputStream(descriptor.createInputStream())) { InputStream in; if (TextUtils.isEmpty(password)) in = raw; else { byte[] salt = new byte[16]; byte[] prefix = new byte[16]; if (raw.read(salt) != salt.length) throw new IOException("length"); if (raw.read(prefix) != prefix.length) throw new IOException("length"); SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("PBKDF2WithHmacSHA1"); KeySpec keySpec = new PBEKeySpec(password.toCharArray(), salt, KEY_ITERATIONS, KEY_LENGTH); SecretKey secret = keyFactory.generateSecret(keySpec); Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding"); IvParameterSpec iv = new IvParameterSpec(prefix); cipher.init(Cipher.DECRYPT_MODE, secret, iv); in = new CipherInputStream(raw, cipher); } BufferedReader reader = new BufferedReader(new InputStreamReader(in)); String line; while ((line = reader.readLine()) != null) data.append(line); } Log.i("Importing data"); JSONObject jimport = new JSONObject(data.toString()); DB db = DB.getInstance(context); NotificationManager nm = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE); try { db.beginTransaction(); // Answers Map xAnswer = new HashMap<>(); JSONArray janswers = jimport.getJSONArray("answers"); for (int a = 0; a < janswers.length(); a++) { JSONObject janswer = (JSONObject) janswers.get(a); EntityAnswer answer = EntityAnswer.fromJSON(janswer); long id = answer.id; answer.id = null; answer.id = db.answer().insertAnswer(answer); xAnswer.put(id, answer.id); Log.i("Imported answer=" + answer.name + " id=" + answer.id + " (" + id + ")"); } EntityAccount primary = db.account().getPrimaryAccount(); // Accounts JSONArray jaccounts = jimport.getJSONArray("accounts"); for (int a = 0; a < jaccounts.length(); a++) { JSONObject jaccount = (JSONObject) jaccounts.get(a); EntityAccount account = EntityAccount.fromJSON(jaccount); Long aid = account.id; account.id = null; if (account.auth_type != MailService.AUTH_TYPE_PASSWORD) oauth = true; if (primary != null) account.primary = false; // Forward referenced Long swipe_left = account.swipe_left; Long swipe_right = account.swipe_right; Long move_to = account.move_to; if (account.swipe_left != null && account.swipe_left > 0) account.swipe_left = null; if (account.swipe_right != null && account.swipe_right > 0) account.swipe_right = null; account.move_to = null; account.created = new Date().getTime(); account.id = db.account().insertAccount(account); Log.i("Imported account=" + account.name + " id=" + account.id + " (" + aid + ")"); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { account.deleteNotificationChannel(context); if (account.notify) if (jaccount.has("channel")) { NotificationChannelGroup group = new NotificationChannelGroup("group." + account.id, account.name); nm.createNotificationChannelGroup(group); JSONObject jchannel = (JSONObject) jaccount.get("channel"); jchannel.put("id", EntityAccount.getNotificationChannelId(account.id)); jchannel.put("group", group.getId()); nm.createNotificationChannel(channelFromJSON(context, jchannel)); Log.i("Imported account channel=" + jchannel); } else account.createNotificationChannel(context); } Map xIdentity = new HashMap<>(); JSONArray jidentities = (JSONArray) jaccount.get("identities"); for (int i = 0; i < jidentities.length(); i++) { JSONObject jidentity = (JSONObject) jidentities.get(i); EntityIdentity identity = EntityIdentity.fromJSON(jidentity); long id = identity.id; identity.id = null; identity.account = account.id; identity.id = db.identity().insertIdentity(identity); xIdentity.put(id, identity.id); Log.i("Imported identity=" + identity.email + " id=" + identity + id + " (" + id + ")"); } Map xFolder = new HashMap<>(); List rules = new ArrayList<>(); JSONArray jfolders = (JSONArray) jaccount.get("folders"); for (int f = 0; f < jfolders.length(); f++) { JSONObject jfolder = (JSONObject) jfolders.get(f); EntityFolder folder = EntityFolder.fromJSON(jfolder); long id = folder.id; folder.id = null; folder.account = account.id; folder.id = db.folder().insertFolder(folder); xFolder.put(id, folder.id); if (Objects.equals(swipe_left, id)) account.swipe_left = folder.id; if (Objects.equals(swipe_right, id)) account.swipe_right = folder.id; if (Objects.equals(move_to, id)) account.move_to = folder.id; if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { String channelId = EntityFolder.getNotificationChannelId(folder.id); nm.deleteNotificationChannel(channelId); if (jfolder.has("channel")) { NotificationChannelGroup group = new NotificationChannelGroup("group." + account.id, account.name); nm.createNotificationChannelGroup(group); JSONObject jchannel = (JSONObject) jfolder.get("channel"); jchannel.put("id", channelId); jchannel.put("group", group.getId()); nm.createNotificationChannel(channelFromJSON(context, jchannel)); Log.i("Imported folder channel=" + jchannel); } } if (jfolder.has("rules")) { JSONArray jrules = jfolder.getJSONArray("rules"); for (int r = 0; r < jrules.length(); r++) { JSONObject jrule = (JSONObject) jrules.get(r); EntityRule rule = EntityRule.fromJSON(jrule); rule.folder = folder.id; rules.add(rule); } } Log.i("Imported folder=" + folder.name + " id=" + folder.id + " (" + id + ")"); } for (EntityRule rule : rules) { try { JSONObject jaction = new JSONObject(rule.action); int type = jaction.getInt("type"); switch (type) { case EntityRule.TYPE_MOVE: case EntityRule.TYPE_COPY: long target = jaction.getLong("target"); Log.i("XLAT target " + target + " > " + xFolder.get(target)); jaction.put("target", xFolder.get(target)); break; case EntityRule.TYPE_ANSWER: long identity = jaction.getLong("identity"); long answer = jaction.getLong("answer"); Log.i("XLAT identity " + identity + " > " + xIdentity.get(identity)); Log.i("XLAT answer " + answer + " > " + xAnswer.get(answer)); jaction.put("identity", xIdentity.get(identity)); jaction.put("answer", xAnswer.get(answer)); break; } rule.action = jaction.toString(); } catch (JSONException ex) { Log.e(ex); } db.rule().insertRule(rule); } // Contacts if (jaccount.has("contacts")) { JSONArray jcontacts = jaccount.getJSONArray("contacts"); for (int c = 0; c < jcontacts.length(); c++) { JSONObject jcontact = (JSONObject) jcontacts.get(c); EntityContact contact = EntityContact.fromJSON(jcontact); contact.account = account.id; if (db.contact().getContact(contact.account, contact.type, contact.email) == null) contact.id = db.contact().insertContact(contact); } Log.i("Imported contacts=" + jcontacts.length()); } // Update swipe left/right db.account().updateAccount(account); } // Settings SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(context); SharedPreferences.Editor editor = prefs.edit(); JSONArray jsettings = jimport.getJSONArray("settings"); for (int s = 0; s < jsettings.length(); s++) { JSONObject jsetting = (JSONObject) jsettings.get(s); String key = jsetting.getString("key"); if ("pro".equals(key) && !BuildConfig.DEBUG) continue; if ("biometrics".equals(key) || "pin".equals(key)) continue; if ("alert_once".equals(key)) continue; if (key != null && key.startsWith("widget.")) continue; Object value = jsetting.get("value"); String type = jsetting.optString("type"); Log.i("Setting name=" + key + " value=" + value + " type=" + type); switch (type) { case "bool": editor.putBoolean(key, (Boolean) value); break; case "int": editor.putInt(key, (Integer) value); break; case "long": if (value instanceof Integer) editor.putLong(key, Long.valueOf((Integer) value)); else editor.putLong(key, (Long) value); break; case "string": editor.putString(key, (String) value); break; default: Log.w("Inferring type of value=" + value); if (value instanceof Boolean) editor.putBoolean(key, (Boolean) value); else if (value instanceof Integer) { Integer i = (Integer) value; if (key.endsWith(".account")) editor.putLong(key, Long.valueOf(i)); else editor.putInt(key, i); } else if (value instanceof Long) editor.putLong(key, (Long) value); else if (value instanceof String) editor.putString(key, (String) value); else throw new IllegalArgumentException("Unknown settings type key=" + key); } Log.i("Imported setting=" + key); } editor.apply(); ApplicationEx.upgrade(context); if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) { if (jimport.has("channels")) { JSONArray jchannels = jimport.getJSONArray("channels"); for (int i = 0; i < jchannels.length(); i++) { JSONObject jchannel = (JSONObject) jchannels.get(i); String channelId = jchannel.getString("id"); nm.deleteNotificationChannel(channelId); nm.createNotificationChannel(channelFromJSON(context, jchannel)); Log.i("Imported contact channel=" + jchannel); } } } db.setTransactionSuccessful(); } finally { db.endTransaction(); } Log.i("Imported data"); ServiceSynchronize.reload(context, "import"); return oauth; } @Override protected void onExecuted(Bundle args, Boolean oauth) { ToastEx.makeText(ActivitySetup.this, R.string.title_setup_imported, Toast.LENGTH_LONG).show(); if (oauth && Build.VERSION.SDK_INT >= Build.VERSION_CODES.M && getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED)) { List permissions = new ArrayList<>(); permissions.add(Manifest.permission.READ_CONTACTS); // profile if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) permissions.add(Manifest.permission.GET_ACCOUNTS); for (String permission : permissions) if (!hasPermission(permission)) { requestPermissions(permissions.toArray(new String[0]), REQUEST_IMPORT_OAUTH); break; } } } @Override protected void onException(Bundle args, Throwable ex) { if (ex.getCause() instanceof BadPaddingException) ToastEx.makeText(ActivitySetup.this, R.string.title_setup_password_invalid, Toast.LENGTH_LONG).show(); else if (ex instanceof IOException && ex.getCause() instanceof IllegalBlockSizeException) ToastEx.makeText(ActivitySetup.this, R.string.title_setup_import_invalid, Toast.LENGTH_LONG).show(); else if (ex instanceof IllegalArgumentException) ToastEx.makeText(ActivitySetup.this, ex.getMessage(), Toast.LENGTH_LONG).show(); else Helper.unexpectedError(getSupportFragmentManager(), ex); } }.execute(this, args, "setup:import"); } @RequiresApi(api = Build.VERSION_CODES.O) private JSONObject channelToJSON(NotificationChannel channel) throws JSONException { JSONObject jchannel = new JSONObject(); jchannel.put("id", channel.getId()); jchannel.put("group", channel.getGroup()); jchannel.put("name", channel.getName()); jchannel.put("description", channel.getDescription()); jchannel.put("importance", channel.getImportance()); jchannel.put("dnd", channel.canBypassDnd()); jchannel.put("visibility", channel.getLockscreenVisibility()); jchannel.put("badge", channel.canShowBadge()); Uri sound = channel.getSound(); if (sound != null) jchannel.put("sound", sound.toString()); // audio attributes jchannel.put("light", channel.shouldShowLights()); // color jchannel.put("vibrate", channel.shouldVibrate()); // pattern return jchannel; } @RequiresApi(api = Build.VERSION_CODES.O) static NotificationChannel channelFromJSON(Context context, JSONObject jchannel) throws JSONException { NotificationChannel channel = new NotificationChannel( jchannel.getString("id"), jchannel.getString("name"), jchannel.getInt("importance")); String group = jchannel.optString("group"); if (!TextUtils.isEmpty(group)) channel.setGroup(group); if (jchannel.has("description") && !jchannel.isNull("description")) channel.setDescription(jchannel.getString("description")); channel.setBypassDnd(jchannel.getBoolean("dnd")); channel.setLockscreenVisibility(jchannel.getInt("visibility")); channel.setShowBadge(jchannel.getBoolean("badge")); if (jchannel.has("sound") && !jchannel.isNull("sound")) { Uri uri = Uri.parse(jchannel.getString("sound")); Ringtone ringtone = RingtoneManager.getRingtone(context, uri); if (ringtone != null) channel.setSound(uri, Notification.AUDIO_ATTRIBUTES_DEFAULT); } channel.enableLights(jchannel.getBoolean("light")); channel.enableVibration(jchannel.getBoolean("vibrate")); return channel; } private void onGmail(Intent intent) { FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentGmail()).addToBackStack("quick"); fragmentTransaction.commit(); } private void onOutlook(Intent intent) { PublicClientApplication.createMultipleAccountPublicClientApplication( this, R.raw.msal_config, new IPublicClientApplication.IMultipleAccountApplicationCreatedListener() { @Override public void onCreated(IMultipleAccountPublicClientApplication msal) { Log.i("MSAL app created"); msal.acquireToken( ActivitySetup.this, // "openid", "offline_access", "profile", "email" // https://docs.microsoft.com/en-us/graph/permissions-reference new String[]{ "openid", "offline_access", "profile", "email", "User.Read", "Mail.ReadWrite", "Mail.Send", "MailboxSettings.ReadWrite"}, new AuthenticationCallback() { @Override public void onSuccess(IAuthenticationResult result) { Log.i("MSAL got token"); Bundle args = new Bundle(); args.putString("token", result.getAccessToken()); args.putString("id", result.getAccount().getId()); args.putString("tenant", result.getAccount().getTenantId()); Log.logBundle(args); Map claims = result.getAccount().getClaims(); if (claims != null) for (String key : claims.keySet()) Log.i(key + "=" + claims.get(key)); new SimpleTask() { @Override protected JSONObject onExecute(Context context, Bundle args) throws Throwable { String token = args.getString("token"); // https://docs.microsoft.com/en-us/graph/api/user-get?view=graph-rest-1.0&tabs=http#http-request URL url = new URL("https://graph.microsoft.com/v1.0/me" + "?$select=displayName,otherMails"); Log.i("MSAL fetching " + url); HttpURLConnection request = (HttpURLConnection) url.openConnection(); request.setReadTimeout(15 * 1000); request.setConnectTimeout(15 * 1000); request.setRequestMethod("GET"); request.setDoInput(true); request.setRequestProperty("Authorization", "Bearer " + token); request.setRequestProperty("Content-Type", "application/json"); request.connect(); try { Log.i("MSAL getting response"); String json = Helper.readStream(request.getInputStream(), StandardCharsets.UTF_8.name()); return new JSONObject(json); } finally { request.disconnect(); } } @Override protected void onExecuted(Bundle args, JSONObject data) { Log.i("MSAL " + data); try { JSONArray otherMails = data.getJSONArray("otherMails"); args.putString("displayName", data.getString("displayName")); args.putString("email", (String) otherMails.get(0)); new SimpleTask() { @Override protected Void onExecute(Context context, Bundle args) throws Throwable { String token = args.getString("token"); String email = args.getString("email"); String displayName = args.getString("displayName"); List folders; // https://msdn.microsoft.com/en-us/windows/desktop/dn440163 String host = "imap-mail.outlook.com"; int port = 993; boolean starttls = false; String user = email; String password = token; try (MailService iservice = new MailService(context, "imaps", null, false, true, true)) { iservice.connect(host, port, MailService.AUTH_TYPE_OUTLOOK, user, password); folders = iservice.getFolders(); DB db = DB.getInstance(context); try { db.beginTransaction(); EntityAccount primary = db.account().getPrimaryAccount(); // Create account EntityAccount account = new EntityAccount(); account.host = host; account.starttls = starttls; account.port = port; account.auth_type = MailService.AUTH_TYPE_OUTLOOK; account.user = user; account.password = password; account.name = "OutLook"; account.synchronize = true; account.primary = (primary == null); account.created = new Date().getTime(); account.last_connected = account.created; account.id = db.account().insertAccount(account); args.putLong("account", account.id); EntityLog.log(context, "OutLook account=" + account.name); // Create folders for (EntityFolder folder : folders) { folder.account = account.id; folder.id = db.folder().insertFolder(folder); EntityLog.log(context, "OutLook folder=" + folder.name + " type=" + folder.type); } // Set swipe left/right folder for (EntityFolder folder : folders) if (EntityFolder.TRASH.equals(folder.type)) account.swipe_left = folder.id; else if (EntityFolder.ARCHIVE.equals(folder.type)) account.swipe_right = folder.id; db.account().updateAccount(account); // Create identity EntityIdentity identity = new EntityIdentity(); identity.name = displayName; identity.email = user; identity.account = account.id; identity.host = "smtp-mail.outlook.com"; identity.starttls = true; identity.port = 587; identity.auth_type = MailService.AUTH_TYPE_OUTLOOK; identity.user = user; identity.password = password; identity.synchronize = true; identity.primary = true; identity.id = db.identity().insertIdentity(identity); args.putLong("identity", identity.id); EntityLog.log(context, "Gmail identity=" + identity.name + " email=" + identity.email); db.setTransactionSuccessful(); } finally { db.endTransaction(); } } return null; } @Override protected void onException(Bundle args, Throwable ex) { } }.execute(ActivitySetup.this, args, "outlook:account"); } catch (JSONException ex) { Log.e(ex); } } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getSupportFragmentManager(), ex); } }.execute(ActivitySetup.this, args, "graph:profile"); } @Override public void onError(MsalException ex) { Log.e(ex); } @Override public void onCancel() { Log.w("MSAL cancelled"); } }); } @Override public void onError(MsalException ex) { Log.e("MSAL", ex); } }); } private void onViewQuickSetup(Intent intent) { FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentQuickSetup()).addToBackStack("quick"); fragmentTransaction.commit(); } private void onViewAccounts(Intent intent) { FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentAccounts()).addToBackStack("accounts"); fragmentTransaction.commit(); } private void onViewIdentities(Intent intent) { FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentIdentities()).addToBackStack("identities"); fragmentTransaction.commit(); } private void onEditAccount(Intent intent) { boolean pop = intent.getBooleanExtra("pop", false); FragmentBase fragment = pop ? new FragmentPop() : new FragmentAccount(); fragment.setArguments(intent.getExtras()); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, fragment).addToBackStack("account"); fragmentTransaction.commit(); } private void onEditIdentity(Intent intent) { FragmentIdentity fragment = new FragmentIdentity(); fragment.setArguments(intent.getExtras()); FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, fragment).addToBackStack("identity"); fragmentTransaction.commit(); } private void onManageLocalContacts(Intent intent) { FragmentTransaction fragmentTransaction = getSupportFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentContacts()).addToBackStack("contacts"); fragmentTransaction.commit(); } private static Intent getIntentExport() { Intent intent = new Intent(Intent.ACTION_CREATE_DOCUMENT); intent.addCategory(Intent.CATEGORY_OPENABLE); intent.setType("*/*"); intent.putExtra(Intent.EXTRA_TITLE, "fairemail_" + new SimpleDateFormat("yyyyMMdd").format(new Date().getTime()) + ".backup"); return intent; } private static Intent getIntentImport() { Intent intent = new Intent(Intent.ACTION_OPEN_DOCUMENT); intent.addCategory(Intent.CATEGORY_OPENABLE); intent.setType("*/*"); return intent; } public static class FragmentDialogPassword extends FragmentDialogBase { private TextInputLayout etPassword1; private TextInputLayout etPassword2; @Override public void onSaveInstanceState(@NonNull Bundle outState) { outState.putString("fair:password1", etPassword1.getEditText().getText().toString()); outState.putString("fair:password2", etPassword2.getEditText().getText().toString()); super.onSaveInstanceState(outState); } @NonNull @Override public Dialog onCreateDialog(@Nullable Bundle savedInstanceState) { final boolean export = getArguments().getBoolean("export"); View dview = LayoutInflater.from(getContext()).inflate(R.layout.dialog_password, null); etPassword1 = dview.findViewById(R.id.tilPassword1); etPassword2 = dview.findViewById(R.id.tilPassword2); TextView tvImportHint = dview.findViewById(R.id.tvImporthint); if (savedInstanceState != null) { etPassword1.getEditText().setText(savedInstanceState.getString("fair:password1")); etPassword2.getEditText().setText(savedInstanceState.getString("fair:password2")); } etPassword2.setVisibility(export ? View.VISIBLE : View.GONE); tvImportHint.setVisibility(export ? View.GONE : View.VISIBLE); return new AlertDialog.Builder(getContext()) .setView(dview) .setPositiveButton(android.R.string.ok, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { String password1 = etPassword1.getEditText().getText().toString(); String password2 = etPassword2.getEditText().getText().toString(); if (!BuildConfig.DEBUG && TextUtils.isEmpty(password1)) ToastEx.makeText(getContext(), R.string.title_setup_password_missing, Toast.LENGTH_LONG).show(); else { if (!export || password1.equals(password2)) { ((ActivitySetup) getActivity()).password = password1; getActivity().startActivityForResult( Helper.getChooser(getContext(), export ? getIntentExport() : getIntentImport()), export ? REQUEST_EXPORT : REQUEST_IMPORT); } else ToastEx.makeText(getContext(), R.string.title_setup_password_different, Toast.LENGTH_LONG).show(); } } }) .setNegativeButton(android.R.string.cancel, null) .create(); } } private BroadcastReceiver receiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED)) { String action = intent.getAction(); if (ACTION_QUICK_GMAIL.equals(action)) onGmail(intent); else if (ACTION_QUICK_OUTLOOK.equals(action)) onOutlook(intent); else if (ACTION_QUICK_SETUP.equals(action)) onViewQuickSetup(intent); else if (ACTION_VIEW_ACCOUNTS.equals(action)) onViewAccounts(intent); else if (ACTION_VIEW_IDENTITIES.equals(action)) onViewIdentities(intent); else if (ACTION_EDIT_ACCOUNT.equals(action)) onEditAccount(intent); else if (ACTION_EDIT_IDENTITY.equals(action)) onEditIdentity(intent); else if (ACTION_MANAGE_LOCAL_CONTACTS.equals(action)) onManageLocalContacts(intent); } } }; }