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.Activity; import android.app.PendingIntent; import android.content.ClipData; import android.content.ClipboardManager; import android.content.Context; import android.content.DialogInterface; import android.content.Intent; import android.content.IntentSender; import android.content.SharedPreferences; import android.content.pm.PackageManager; import android.content.res.Resources; import android.database.Cursor; import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.graphics.Typeface; import android.graphics.drawable.Drawable; import android.graphics.drawable.LevelListDrawable; import android.net.ConnectivityManager; import android.net.Network; import android.net.NetworkCapabilities; import android.net.NetworkRequest; import android.net.Uri; import android.os.Bundle; import android.os.Handler; import android.os.Looper; import android.preference.PreferenceManager; import android.provider.ContactsContract; import android.provider.OpenableColumns; import android.text.Editable; import android.text.Html; import android.text.Spannable; import android.text.SpannableString; import android.text.SpannableStringBuilder; import android.text.Spanned; import android.text.TextUtils; import android.text.TextWatcher; import android.text.style.ImageSpan; import android.text.style.QuoteSpan; import android.text.style.StyleSpan; import android.text.style.URLSpan; import android.text.style.UnderlineSpan; import android.util.TypedValue; import android.view.LayoutInflater; import android.view.Menu; import android.view.MenuInflater; import android.view.MenuItem; import android.view.View; import android.view.ViewGroup; import android.view.ViewTreeObserver; import android.webkit.MimeTypeMap; import android.widget.AdapterView; import android.widget.ArrayAdapter; import android.widget.CheckBox; import android.widget.EditText; import android.widget.FilterQueryProvider; import android.widget.ImageButton; import android.widget.ImageView; import android.widget.MultiAutoCompleteTextView; import android.widget.Spinner; import android.widget.TextView; import android.widget.Toast; import com.google.android.material.bottomnavigation.BottomNavigationView; import com.google.android.material.bottomnavigation.LabelVisibilityMode; import com.google.android.material.snackbar.Snackbar; import org.jsoup.Jsoup; import org.jsoup.nodes.Element; import org.openintents.openpgp.OpenPgpError; import org.openintents.openpgp.util.OpenPgpApi; import org.openintents.openpgp.util.OpenPgpServiceConnection; import java.io.BufferedOutputStream; import java.io.BufferedWriter; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.FileWriter; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.Comparator; import java.util.Date; import java.util.List; import java.util.Objects; import java.util.Properties; import javax.mail.Address; import javax.mail.MessageRemovedException; import javax.mail.Part; import javax.mail.Session; import javax.mail.internet.AddressException; import javax.mail.internet.InternetAddress; import javax.mail.internet.MimeMessage; import androidx.annotation.NonNull; import androidx.annotation.Nullable; import androidx.constraintlayout.widget.Group; import androidx.cursoradapter.widget.SimpleCursorAdapter; import androidx.fragment.app.FragmentTransaction; import androidx.lifecycle.Lifecycle; import androidx.lifecycle.Observer; import androidx.recyclerview.widget.LinearLayoutManager; import androidx.recyclerview.widget.RecyclerView; import static android.app.Activity.RESULT_OK; public class FragmentCompose extends FragmentBase { private enum State {NONE, LOADING, LOADED} private ViewGroup view; private Spinner spIdentity; private EditText etExtra; private TextView tvDomain; private MultiAutoCompleteTextView etTo; private ImageView ivToAdd; private MultiAutoCompleteTextView etCc; private ImageView ivCcAdd; private MultiAutoCompleteTextView etBcc; private ImageView ivBccAdd; private EditText etSubject; private RecyclerView rvAttachment; private TextView tvNoInternetAttachments; private EditText etBody; private TextView tvNoInternet; private TextView tvSignature; private TextView tvReference; private ImageButton ibReferenceEdit; private ImageButton ibReferenceImages; private BottomNavigationView edit_bar; private BottomNavigationView bottom_navigation; private ContentLoadingProgressBar pbWait; private Group grpHeader; private Group grpExtra; private Group grpAddresses; private Group grpAttachments; private Group grpBody; private Group grpSignature; private Group grpReference; private AdapterAttachment adapter; private boolean pro; private long working = -1; private State state = State.NONE; private boolean show_images = false; private boolean autosave = false; private boolean busy = false; private boolean encrypt = false; private OpenPgpServiceConnection pgpService; private static final int REDUCED_IMAGE_SIZE = 1280; private static final int REDUCED_IMAGE_QUALITY = 90; @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); pro = Helper.isPro(getContext()); } @Override @Nullable public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) { view = (ViewGroup) inflater.inflate(R.layout.fragment_compose, container, false); // Get controls spIdentity = view.findViewById(R.id.spIdentity); etExtra = view.findViewById(R.id.etExtra); tvDomain = view.findViewById(R.id.tvDomain); etTo = view.findViewById(R.id.etTo); ivToAdd = view.findViewById(R.id.ivToAdd); etCc = view.findViewById(R.id.etCc); ivCcAdd = view.findViewById(R.id.ivCcAdd); etBcc = view.findViewById(R.id.etBcc); ivBccAdd = view.findViewById(R.id.ivBccAdd); etSubject = view.findViewById(R.id.etSubject); rvAttachment = view.findViewById(R.id.rvAttachment); tvNoInternetAttachments = view.findViewById(R.id.tvNoInternetAttachments); etBody = view.findViewById(R.id.etBody); tvNoInternet = view.findViewById(R.id.tvNoInternet); tvSignature = view.findViewById(R.id.tvSignature); tvReference = view.findViewById(R.id.tvReference); ibReferenceEdit = view.findViewById(R.id.ibReferenceEdit); ibReferenceImages = view.findViewById(R.id.ibReferenceImages); edit_bar = view.findViewById(R.id.edit_bar); bottom_navigation = view.findViewById(R.id.bottom_navigation); pbWait = view.findViewById(R.id.pbWait); grpHeader = view.findViewById(R.id.grpHeader); grpExtra = view.findViewById(R.id.grpExtra); grpAddresses = view.findViewById(R.id.grpAddresses); grpAttachments = view.findViewById(R.id.grpAttachments); grpBody = view.findViewById(R.id.grpBody); grpSignature = view.findViewById(R.id.grpSignature); grpReference = view.findViewById(R.id.grpReference); // Wire controls spIdentity.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() { @Override public void onItemSelected(AdapterView parent, View view, int position, long id) { EntityIdentity identity = (EntityIdentity) parent.getAdapter().getItem(position); encrypt = (identity != null && identity.encrypt); getActivity().invalidateOptionsMenu(); int at = (identity == null ? -1 : identity.email.indexOf('@')); etExtra.setHint(at < 0 ? null : identity.email.substring(0, at)); tvDomain.setText(at < 0 ? null : identity.email.substring(at)); Spanned signature = null; if (pro) { if (identity != null && !TextUtils.isEmpty(identity.signature)) signature = HtmlHelper.fromHtml(identity.signature, new Html.ImageGetter() { @Override public Drawable getDrawable(String source) { int px = Helper.dp2pixels(getContext(), 24); Drawable d = getContext().getResources() .getDrawable(R.drawable.baseline_image_24, getContext().getTheme()); d.setBounds(0, 0, px, px); return d; } }, null); } tvSignature.setText(signature); grpSignature.setVisibility(signature == null ? View.GONE : View.VISIBLE); } @Override public void onNothingSelected(AdapterView parent) { encrypt = false; getActivity().invalidateOptionsMenu(); etExtra.setHint(""); tvDomain.setText(null); tvSignature.setText(null); grpSignature.setVisibility(View.GONE); } }); etTo.setMaxLines(Integer.MAX_VALUE); etTo.setHorizontallyScrolling(false); etCc.setMaxLines(Integer.MAX_VALUE); etCc.setHorizontallyScrolling(false); etBcc.setMaxLines(Integer.MAX_VALUE); etBcc.setHorizontallyScrolling(false); etSubject.setMaxLines(Integer.MAX_VALUE); etSubject.setHorizontallyScrolling(false); View.OnClickListener onPick = new View.OnClickListener() { @Override public void onClick(View view) { int request; switch (view.getId()) { case R.id.ivToAdd: request = ActivityCompose.REQUEST_CONTACT_TO; break; case R.id.ivCcAdd: request = ActivityCompose.REQUEST_CONTACT_CC; break; case R.id.ivBccAdd: request = ActivityCompose.REQUEST_CONTACT_BCC; break; default: return; } Intent pick = new Intent(Intent.ACTION_PICK, ContactsContract.CommonDataKinds.Email.CONTENT_URI); if (pick.resolveActivity(getContext().getPackageManager()) == null) Snackbar.make(view, R.string.title_no_contacts, Snackbar.LENGTH_LONG).show(); else startActivityForResult(Helper.getChooser(getContext(), pick), request); } }; ivToAdd.setOnClickListener(onPick); ivCcAdd.setOnClickListener(onPick); ivBccAdd.setOnClickListener(onPick); setZoom(); ibReferenceEdit.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { onReferenceEdit(); } }); ibReferenceImages.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { onReferenceImages(); } }); edit_bar.setOnNavigationItemSelectedListener(new BottomNavigationView.OnNavigationItemSelectedListener() { @Override public boolean onNavigationItemSelected(@NonNull MenuItem item) { int action = item.getItemId(); switch (action) { case R.id.menu_bold: case R.id.menu_italic: case R.id.menu_clear: case R.id.menu_link: onMenuStyle(item.getItemId()); return true; case R.id.menu_image: onMenuImage(); return true; case R.id.menu_attachment: onMenuAttachment(); return true; default: return false; } } }); bottom_navigation.setOnNavigationItemSelectedListener(new BottomNavigationView.OnNavigationItemSelectedListener() { @Override public boolean onNavigationItemSelected(@NonNull MenuItem item) { final int action = item.getItemId(); switch (action) { case R.id.action_delete: onActionDelete(); break; case R.id.action_send: onActionSend(); break; default: onAction(action); } return true; } }); view.getViewTreeObserver().addOnGlobalLayoutListener(new ViewTreeObserver.OnGlobalLayoutListener() { @Override public void onGlobalLayout() { int bottom = view.getBottom() - edit_bar.getHeight() - Helper.dp2pixels(view.getContext(), 56); // full bottom navigation int remain = bottom - etBody.getTop(); int threshold = Helper.dp2pixels(view.getContext(), 100); Log.i("Reduce remain=" + remain + " threshold=" + threshold); boolean reduce = (remain < threshold); boolean reduced = (bottom_navigation.getLabelVisibilityMode() == LabelVisibilityMode.LABEL_VISIBILITY_UNLABELED); if (reduce != reduced) { bottom_navigation.setLabelVisibilityMode(reduce ? LabelVisibilityMode.LABEL_VISIBILITY_UNLABELED : LabelVisibilityMode.LABEL_VISIBILITY_LABELED); ViewGroup.LayoutParams params = bottom_navigation.getLayoutParams(); params.height = Helper.dp2pixels(view.getContext(), reduce ? 36 : 56); bottom_navigation.setLayoutParams(params); } } }); ((ActivityBase) getActivity()).addBackPressedListener(onBackPressedListener); setHasOptionsMenu(true); // Initialize setSubtitle(R.string.title_compose); etExtra.setHint(""); tvDomain.setText(null); grpHeader.setVisibility(View.GONE); grpExtra.setVisibility(View.GONE); grpAddresses.setVisibility(View.GONE); grpAttachments.setVisibility(View.GONE); tvNoInternet.setVisibility(View.GONE); grpBody.setVisibility(View.GONE); grpSignature.setVisibility(View.GONE); grpReference.setVisibility(View.GONE); ibReferenceEdit.setVisibility(View.GONE); ibReferenceImages.setVisibility(View.GONE); edit_bar.setVisibility(View.GONE); bottom_navigation.setVisibility(View.GONE); pbWait.setVisibility(View.VISIBLE); getActivity().invalidateOptionsMenu(); Helper.setViewsEnabled(view, false); final DB db = DB.getInstance(getContext()); final boolean contacts = Helper.hasPermission(getContext(), Manifest.permission.READ_CONTACTS); SimpleCursorAdapter cadapter = new SimpleCursorAdapter( getContext(), R.layout.spinner_contact, null, contacts ? new String[]{ ContactsContract.Contacts.DISPLAY_NAME, ContactsContract.CommonDataKinds.Email.DATA } : new String[]{ "name", "email", "type" }, contacts ? new int[]{android.R.id.text1, android.R.id.text2} : new int[]{android.R.id.text1, android.R.id.text2, R.id.tvType}, 0); etTo.setAdapter(cadapter); etCc.setAdapter(cadapter); etBcc.setAdapter(cadapter); etTo.setTokenizer(new MultiAutoCompleteTextView.CommaTokenizer()); etCc.setTokenizer(new MultiAutoCompleteTextView.CommaTokenizer()); etBcc.setTokenizer(new MultiAutoCompleteTextView.CommaTokenizer()); if (contacts) cadapter.setFilterQueryProvider(new FilterQueryProvider() { public Cursor runQuery(CharSequence typed) { Log.i("Searching provided contact=" + typed); return getContext().getContentResolver().query( ContactsContract.CommonDataKinds.Email.CONTENT_URI, new String[]{ ContactsContract.RawContacts._ID, ContactsContract.Contacts.DISPLAY_NAME, ContactsContract.CommonDataKinds.Email.DATA }, ContactsContract.CommonDataKinds.Email.DATA + " <> ''" + " AND (" + ContactsContract.Contacts.DISPLAY_NAME + " LIKE '%" + typed + "%'" + " OR " + ContactsContract.CommonDataKinds.Email.DATA + " LIKE '%" + typed + "%')", null, "CASE WHEN " + ContactsContract.Contacts.DISPLAY_NAME + " NOT LIKE '%@%' THEN 0 ELSE 1 END" + ", " + ContactsContract.Contacts.DISPLAY_NAME + ", " + ContactsContract.CommonDataKinds.Email.DATA + " COLLATE NOCASE"); } }); else cadapter.setFilterQueryProvider(new FilterQueryProvider() { @Override public Cursor runQuery(CharSequence typed) { Log.i("Searching local contact=" + typed); return db.contact().searchContacts(null, "%" + typed + "%"); } }); cadapter.setCursorToStringConverter(new SimpleCursorAdapter.CursorToStringConverter() { public CharSequence convertToString(Cursor cursor) { int colName = cursor.getColumnIndex(contacts ? ContactsContract.Contacts.DISPLAY_NAME : "name"); int colEmail = cursor.getColumnIndex(contacts ? ContactsContract.CommonDataKinds.Email.DATA : "email"); String name = cursor.getString(colName); String email = cursor.getString(colEmail); StringBuilder sb = new StringBuilder(); if (name == null) sb.append(email); else { sb.append("\"").append(name).append("\" "); sb.append("<").append(email).append(">"); } return sb.toString(); } }); rvAttachment.setHasFixedSize(false); LinearLayoutManager llm = new LinearLayoutManager(getContext()); rvAttachment.setLayoutManager(llm); rvAttachment.setItemAnimator(null); adapter = new AdapterAttachment(getContext(), getViewLifecycleOwner(), false); rvAttachment.setAdapter(adapter); tvNoInternetAttachments.setVisibility(View.GONE); pgpService = new OpenPgpServiceConnection(getContext(), "org.sufficientlysecure.keychain"); pgpService.bindToService(); return view; } private void onReferenceEdit() { final SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(getContext()); if (prefs.getBoolean("edit_ref_confirmed", false)) { onReferenceEditConfirmed(); return; } final View dview = LayoutInflater.from(getContext()).inflate(R.layout.dialog_ask_again, null); final TextView tvMessage = dview.findViewById(R.id.tvMessage); final CheckBox cbNotAgain = dview.findViewById(R.id.cbNotAgain); tvMessage.setText(getText(R.string.title_ask_edit_ref)); new DialogBuilderLifecycle(getContext(), getViewLifecycleOwner()) .setView(dview) .setPositiveButton(android.R.string.ok, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { if (cbNotAgain.isChecked()) prefs.edit().putBoolean("edit_ref_confirmed", true).apply(); onReferenceEditConfirmed(); } }) .setNegativeButton(android.R.string.cancel, null) .show(); } private void onReferenceEditConfirmed() { Bundle args = new Bundle(); args.putLong("id", working); args.putString("body", HtmlHelper.toHtml(etBody.getText())); new SimpleTask() { @Override protected void onPreExecute(Bundle args) { ibReferenceEdit.setEnabled(false); } @Override protected void onPostExecute(Bundle args) { ibReferenceEdit.setEnabled(true); } @Override protected Void onExecute(Context context, Bundle args) throws Throwable { long id = args.getLong("id"); String body = args.getString("body"); DB db = DB.getInstance(context); EntityMessage draft = db.message().getMessage(id); if (draft == null) return null; File file = draft.getFile(context); File refFile = draft.getRefFile(context); String ref = Helper.readText(refFile); String plain = HtmlHelper.getText(ref); String html = "

" + plain.replaceAll("\\r?\\n", "
" + "

"); try (BufferedWriter out = new BufferedWriter(new FileWriter(file))) { out.write(body); out.write(html); } refFile.delete(); return null; } @Override protected void onExecuted(Bundle args, Void data) { showDraft(working); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, args, "compose:refedit"); } private void onReferenceImages() { show_images = true; onAction(R.id.action_save); showDraft(working); } @Override public void onDestroyView() { adapter = null; if (pgpService != null) pgpService.unbindFromService(); ((ActivityBase) getActivity()).removeBackPressedListener(onBackPressedListener); super.onDestroyView(); } @Override public void onSaveInstanceState(Bundle outState) { super.onSaveInstanceState(outState); outState.putLong("fair:working", working); outState.putBoolean("fair:show_images", show_images); } @Override public void onActivityCreated(@Nullable Bundle savedInstanceState) { super.onActivityCreated(savedInstanceState); if (savedInstanceState == null) { if (working < 0) { Bundle args = new Bundle(); args.putString("action", getArguments().getString("action")); args.putLong("id", getArguments().getLong("id", -1)); args.putLong("account", getArguments().getLong("account", -1)); args.putLong("reference", getArguments().getLong("reference", -1)); args.putBoolean("raw", getArguments().getBoolean("raw", false)); args.putLong("answer", getArguments().getLong("answer", -1)); args.putString("to", getArguments().getString("to")); args.putString("cc", getArguments().getString("cc")); args.putString("bcc", getArguments().getString("bcc")); args.putString("subject", getArguments().getString("subject")); args.putString("body", getArguments().getString("body")); args.putParcelableArrayList("attachments", getArguments().getParcelableArrayList("attachments")); draftLoader.execute(this, args, "compose:new"); } else { Bundle args = new Bundle(); args.putString("action", "edit"); args.putLong("id", working); args.putLong("account", -1); args.putLong("reference", -1); args.putLong("answer", -1); draftLoader.execute(this, args, "compose:edit"); } } else { working = savedInstanceState.getLong("fair:working"); show_images = savedInstanceState.getBoolean("fair:show_images"); Bundle args = new Bundle(); args.putString("action", working < 0 ? "new" : "edit"); args.putLong("id", working); args.putLong("account", -1); args.putLong("reference", -1); args.putLong("answer", -1); draftLoader.execute(this, args, "compose:instance"); } } @Override public void onResume() { super.onResume(); ConnectivityManager cm = (ConnectivityManager) getContext().getSystemService(Context.CONNECTIVITY_SERVICE); NetworkRequest.Builder builder = new NetworkRequest.Builder(); builder.addCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET); cm.registerNetworkCallback(builder.build(), networkCallback); if (!pgpService.isBound()) pgpService.bindToService(); } @Override public void onPause() { if (autosave) onAction(R.id.action_save); ConnectivityManager cm = (ConnectivityManager) getContext().getSystemService(Context.CONNECTIVITY_SERVICE); cm.unregisterNetworkCallback(networkCallback); super.onPause(); } ConnectivityManager.NetworkCallback networkCallback = new ConnectivityManager.NetworkCallback() { @Override public void onAvailable(Network network) { check(); } @Override public void onCapabilitiesChanged(Network network, NetworkCapabilities networkCapabilities) { check(); } @Override public void onLost(Network network) { check(); } private void check() { Activity activity = getActivity(); if (activity != null) activity.runOnUiThread(new Runnable() { @Override public void run() { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.RESUMED)) checkInternet(); } }); } }; private void checkInternet() { boolean internet = Helper.suitableNetwork(getContext(), false); Boolean content = (Boolean) tvNoInternet.getTag(); tvNoInternet.setVisibility(!internet && content != null && !content ? View.VISIBLE : View.GONE); Boolean downloading = (Boolean) rvAttachment.getTag(); tvNoInternetAttachments.setVisibility(!internet && downloading != null && downloading ? View.VISIBLE : View.GONE); } @Override public void onCreateOptionsMenu(Menu menu, MenuInflater inflater) { inflater.inflate(R.menu.menu_compose, menu); super.onCreateOptionsMenu(menu, inflater); } @Override public void onPrepareOptionsMenu(Menu menu) { super.onPrepareOptionsMenu(menu); menu.findItem(R.id.menu_addresses).setVisible(working >= 0); menu.findItem(R.id.menu_zoom).setVisible(state == State.LOADED); menu.findItem(R.id.menu_clear).setVisible(state == State.LOADED); menu.findItem(R.id.menu_encrypt).setVisible(state == State.LOADED); menu.findItem(R.id.menu_send_after).setVisible(state == State.LOADED); menu.findItem(R.id.menu_zoom).setEnabled(!busy); menu.findItem(R.id.menu_clear).setEnabled(!busy); menu.findItem(R.id.menu_encrypt).setEnabled(!busy); menu.findItem(R.id.menu_send_after).setEnabled(!busy); menu.findItem(R.id.menu_encrypt).setChecked(encrypt); bottom_navigation.getMenu().findItem(R.id.action_send) .setTitle(encrypt ? R.string.title_encrypt : R.string.title_send); } @Override public boolean onOptionsItemSelected(MenuItem item) { switch (item.getItemId()) { case android.R.id.home: if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.RESUMED)) handleExit(); return true; case R.id.menu_addresses: onMenuAddresses(); return true; case R.id.menu_zoom: onMenuZoom(); return true; case R.id.menu_clear: onMenuStyle(item.getItemId()); return true; case R.id.menu_encrypt: encrypt = !encrypt; getActivity().invalidateOptionsMenu(); return true; case R.id.menu_send_after: onMenuSendAfter(); return true; default: return super.onOptionsItemSelected(item); } } private void onMenuStyle(int id) { int s = etBody.getSelectionStart(); int e = etBody.getSelectionEnd(); if (s < 0) s = 0; if (e < 0) e = 0; if (s > e) { int tmp = s; s = e; e = tmp; } final int start = s; final int end = e; final SpannableString ss = new SpannableString(etBody.getText()); switch (id) { case R.id.menu_bold: case R.id.menu_italic: if (start == end) Snackbar.make(view, R.string.title_no_selection, Snackbar.LENGTH_LONG).show(); else { int style = (id == R.id.menu_bold ? Typeface.BOLD : Typeface.ITALIC); boolean has = false; for (StyleSpan span : ss.getSpans(start, end, StyleSpan.class)) if (span.getStyle() == style) { has = true; ss.removeSpan(span); } if (!has) ss.setSpan(new StyleSpan(style), start, end, Spanned.SPAN_EXCLUSIVE_EXCLUSIVE); } break; case R.id.menu_clear: for (Object span : ss.getSpans(0, ss.length(), Object.class)) if (!(span instanceof ImageSpan)) ss.removeSpan(span); break; case R.id.menu_link: Uri uri = null; ClipboardManager cbm = (ClipboardManager) getContext().getSystemService(Context.CLIPBOARD_SERVICE); if (cbm.hasPrimaryClip()) { String link = cbm.getPrimaryClip().getItemAt(0).coerceToText(getContext()).toString(); uri = Uri.parse(link); if (uri.getScheme() == null) uri = null; } View view = LayoutInflater.from(getContext()).inflate(R.layout.dialog_link, null); final EditText etLink = view.findViewById(R.id.etLink); final TextView tvInsecure = view.findViewById(R.id.tvInsecure); etLink.setText(uri == null ? "https://" : uri.toString()); tvInsecure.setVisibility(View.GONE); etLink.addTextChangedListener(new TextWatcher() { @Override public void beforeTextChanged(CharSequence s, int start, int count, int after) { } @Override public void onTextChanged(CharSequence s, int start, int before, int count) { tvInsecure.setVisibility("http".equals(Uri.parse(s.toString()).getScheme()) ? View.VISIBLE : View.GONE); } @Override public void afterTextChanged(Editable s) { } }); new DialogBuilderLifecycle(getContext(), getViewLifecycleOwner()) .setView(view) .setPositiveButton(android.R.string.ok, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { ss.setSpan(new URLSpan(etLink.getText().toString()), start, end, Spanned.SPAN_EXCLUSIVE_EXCLUSIVE); etBody.setText(ss); etBody.setSelection(end); } }) .show(); new Handler().post(new Runnable() { @Override public void run() { etLink.requestFocus(); } }); return; } etBody.setText(ss); etBody.setSelection(end); } private void onMenuSendAfter() { DialogDuration.show(getContext(), getViewLifecycleOwner(), R.string.title_send_at, new DialogDuration.IDialogDuration() { @Override public void onDurationSelected(long duration, long time) { Bundle args = new Bundle(); args.putLong("id", working); args.putLong("wakeup", time); new SimpleTask() { @Override protected Void onExecute(Context context, Bundle args) { long id = args.getLong("id"); Long wakeup = args.getLong("wakeup"); DB db = DB.getInstance(context); db.message().setMessageSnoozed(id, wakeup); return null; } @Override protected void onExecuted(Bundle args, Void data) { onAction(R.id.action_send); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, args, "compose:send:after"); } @Override public void onDismiss() { } }); } private void onMenuZoom() { SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(getContext()); boolean compact = prefs.getBoolean("compact", false); int zoom = prefs.getInt("zoom", compact ? 0 : 1); zoom = ++zoom % 3; prefs.edit().putInt("zoom", zoom).apply(); setZoom(); } private void setZoom() { SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(getContext()); boolean compact = prefs.getBoolean("compact", false); int zoom = prefs.getInt("zoom", compact ? 0 : 1); setZoom(zoom); } private void setZoom(int zoom) { float textSize = Helper.getTextSize(getContext(), zoom); if (textSize != 0) { etBody.setTextSize(TypedValue.COMPLEX_UNIT_PX, textSize); tvReference.setTextSize(TypedValue.COMPLEX_UNIT_PX, textSize); } } private void onMenuImage() { Intent intent = new Intent(Intent.ACTION_OPEN_DOCUMENT); intent.addCategory(Intent.CATEGORY_OPENABLE); intent.setType("image/*"); PackageManager pm = getContext().getPackageManager(); if (intent.resolveActivity(pm) == null) Snackbar.make(view, R.string.title_no_saf, Snackbar.LENGTH_LONG).show(); else startActivityForResult(Helper.getChooser(getContext(), intent), ActivityCompose.REQUEST_IMAGE); } private void onMenuAttachment() { Intent intent = new Intent(Intent.ACTION_OPEN_DOCUMENT); intent.addCategory(Intent.CATEGORY_OPENABLE); intent.setType("*/*"); intent.putExtra(Intent.EXTRA_ALLOW_MULTIPLE, true); PackageManager pm = getContext().getPackageManager(); if (intent.resolveActivity(pm) == null) Snackbar.make(view, R.string.title_no_saf, Snackbar.LENGTH_LONG).show(); else startActivityForResult(Helper.getChooser(getContext(), intent), ActivityCompose.REQUEST_ATTACHMENT); } private void onMenuAddresses() { grpAddresses.setVisibility(grpAddresses.getVisibility() == View.GONE ? View.VISIBLE : View.GONE); } private void onActionDelete() { new DialogBuilderLifecycle(getContext(), getViewLifecycleOwner()) .setMessage(R.string.title_ask_discard) .setPositiveButton(android.R.string.ok, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { onAction(R.id.action_delete); } }) .setNegativeButton(android.R.string.cancel, null) .show(); } private void onActionSend() { final SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(getContext()); boolean autosend = prefs.getBoolean("autosend", false); if (autosend) { onActionSendConfirmed(); return; } try { EntityIdentity ident = (EntityIdentity) spIdentity.getSelectedItem(); if (ident == null) throw new IllegalArgumentException(getString(R.string.title_from_missing)); String to = etTo.getText().toString(); String cc = etCc.getText().toString(); String bcc = etBcc.getText().toString(); InternetAddress ato[] = new InternetAddress[0]; InternetAddress acc[] = new InternetAddress[0]; InternetAddress abcc[] = new InternetAddress[0]; if (!TextUtils.isEmpty(to)) ato = InternetAddress.parse(to); if (!TextUtils.isEmpty(cc)) acc = InternetAddress.parse(cc); if (!TextUtils.isEmpty(bcc)) abcc = InternetAddress.parse(bcc); if (ato.length == 0) throw new IllegalArgumentException(getString(R.string.title_to_missing)); final View dview = LayoutInflater.from(getContext()).inflate(R.layout.dialog_ask_again, null); final TextView tvMessage = dview.findViewById(R.id.tvMessage); final CheckBox cbNotAgain = dview.findViewById(R.id.cbNotAgain); int plus = acc.length + abcc.length; tvMessage.setText(getString(R.string.title_ask_send_via, MessageHelper.formatAddressesShort(ato) + (plus > 0 ? " +" + plus : ""), ident.email)); new DialogBuilderLifecycle(getContext(), getViewLifecycleOwner()) .setView(dview) .setPositiveButton(android.R.string.ok, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { if (cbNotAgain.isChecked()) prefs.edit().putBoolean("autosend", true).apply(); onActionSendConfirmed(); } }) .setNegativeButton(android.R.string.cancel, null) .show(); } catch (Throwable ex) { onActionSendConfirmed(); } } private void onActionSendConfirmed() { if (encrypt) onAction(R.id.menu_encrypt); else onAction(R.id.action_send); } private void onEncrypt() { if (Helper.isPro(getContext())) { if (pgpService.isBound()) try { String to = etTo.getText().toString(); InternetAddress ato[] = (TextUtils.isEmpty(to) ? new InternetAddress[0] : InternetAddress.parse(to)); if (ato.length == 0) throw new IllegalArgumentException(getString(R.string.title_to_missing)); String[] tos = new String[ato.length]; for (int i = 0; i < ato.length; i++) tos[i] = ato[i].getAddress(); Intent data = new Intent(); data.setAction(OpenPgpApi.ACTION_SIGN_AND_ENCRYPT); data.putExtra(OpenPgpApi.EXTRA_USER_IDS, tos); data.putExtra(OpenPgpApi.EXTRA_REQUEST_ASCII_ARMOR, true); encrypt(data); } catch (Throwable ex) { if (ex instanceof IllegalArgumentException) Snackbar.make(view, ex.getMessage(), Snackbar.LENGTH_LONG).show(); else Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } else { Snackbar snackbar = Snackbar.make(view, R.string.title_no_openpgp, Snackbar.LENGTH_LONG); if (Helper.getIntentOpenKeychain().resolveActivity(getContext().getPackageManager()) != null) snackbar.setAction(R.string.title_fix, new View.OnClickListener() { @Override public void onClick(View v) { startActivity(Helper.getIntentOpenKeychain()); } }); snackbar.show(); } } else { FragmentTransaction fragmentTransaction = getFragmentManager().beginTransaction(); fragmentTransaction.replace(R.id.content_frame, new FragmentPro()).addToBackStack("pro"); fragmentTransaction.commit(); } } private void encrypt(Intent data) { final Bundle args = new Bundle(); args.putLong("id", working); args.putParcelable("data", data); new SimpleTask() { @Override protected PendingIntent onExecute(Context context, Bundle args) throws Throwable { // Get arguments long id = args.getLong("id"); Intent data = args.getParcelable("data"); DB db = DB.getInstance(context); // Get attachments EntityMessage message = db.message().getMessage(id); List attachments = db.attachment().getAttachments(id); for (EntityAttachment attachment : new ArrayList<>(attachments)) if (attachment.encryption != null) attachments.remove(attachment); EntityIdentity identity = (message.identity == null ? null : db.identity().getIdentity(message.identity)); // Build message Properties props = MessageHelper.getSessionProperties(Helper.AUTH_TYPE_PASSWORD, null, false); Session isession = Session.getInstance(props, null); MimeMessage imessage = new MimeMessage(isession); MessageHelper.build(context, message, imessage, identity == null ? false : identity.plain_only); // Serialize message ByteArrayOutputStream os = new ByteArrayOutputStream(); imessage.writeTo(os); ByteArrayInputStream decrypted = new ByteArrayInputStream(os.toByteArray()); ByteArrayOutputStream encrypted = new ByteArrayOutputStream(); // Encrypt message OpenPgpApi api = new OpenPgpApi(context, pgpService.getService()); Intent result = api.executeApi(data, decrypted, encrypted); switch (result.getIntExtra(OpenPgpApi.RESULT_CODE, OpenPgpApi.RESULT_CODE_ERROR)) { case OpenPgpApi.RESULT_CODE_SUCCESS: // Get public signature Intent keyRequest = new Intent(); keyRequest.setAction(OpenPgpApi.ACTION_DETACHED_SIGN); keyRequest.putExtra(OpenPgpApi.EXTRA_SIGN_KEY_ID, data.getLongExtra(OpenPgpApi.EXTRA_SIGN_KEY_ID, -1)); Intent key = api.executeApi(keyRequest, decrypted, null); int r = key.getIntExtra(OpenPgpApi.RESULT_CODE, OpenPgpApi.RESULT_CODE_ERROR); if (r != OpenPgpApi.RESULT_CODE_SUCCESS) { OpenPgpError error = key.getParcelableExtra(OpenPgpApi.RESULT_ERROR); throw new IllegalArgumentException(error.getMessage()); } // Attach encrypted data try { db.beginTransaction(); // Delete previously encrypted data for (EntityAttachment attachment : db.attachment().getAttachments(id)) if (attachment.encryption != null) db.attachment().deleteAttachment(attachment.id); int seq = db.attachment().getAttachmentSequence(id); EntityAttachment attachment1 = new EntityAttachment(); attachment1.message = id; attachment1.sequence = seq + 1; attachment1.name = "encrypted.asc"; attachment1.type = "application/octet-stream"; attachment1.encryption = EntityAttachment.PGP_MESSAGE; attachment1.id = db.attachment().insertAttachment(attachment1); File file1 = attachment1.getFile(context); byte[] bytes1 = encrypted.toByteArray(); try (OutputStream os1 = new BufferedOutputStream(new FileOutputStream(file1))) { os1.write(bytes1); db.attachment().setDownloaded(attachment1.id, (long) bytes1.length); } EntityAttachment attachment2 = new EntityAttachment(); attachment2.message = id; attachment2.sequence = seq + 2; attachment2.name = "signature.asc"; attachment2.type = "application/octet-stream"; attachment2.encryption = EntityAttachment.PGP_SIGNATURE; attachment2.id = db.attachment().insertAttachment(attachment2); File file2 = attachment2.getFile(context); byte[] bytes2 = key.getByteArrayExtra(OpenPgpApi.RESULT_DETACHED_SIGNATURE); try (OutputStream os2 = new BufferedOutputStream(new FileOutputStream(file2))) { os2.write(bytes2); db.attachment().setDownloaded(attachment2.id, (long) bytes2.length); } db.setTransactionSuccessful(); } finally { db.endTransaction(); } break; case OpenPgpApi.RESULT_CODE_USER_INTERACTION_REQUIRED: return result.getParcelableExtra(OpenPgpApi.RESULT_INTENT); case OpenPgpApi.RESULT_CODE_ERROR: OpenPgpError error = result.getParcelableExtra(OpenPgpApi.RESULT_ERROR); throw new IllegalArgumentException(error.getMessage()); } return null; } @Override protected void onExecuted(Bundle args, PendingIntent pi) { if (pi == null) onAction(R.id.action_send); else try { startIntentSenderForResult( pi.getIntentSender(), ActivityCompose.REQUEST_ENCRYPT, null, 0, 0, 0, null); } catch (IntentSender.SendIntentException ex) { Log.e(ex); Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } } @Override protected void onException(Bundle args, Throwable ex) { if (ex instanceof IllegalArgumentException) Snackbar.make(view, ex.getMessage(), Snackbar.LENGTH_LONG).show(); else Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(this, args, "compose:encrypt"); } @Override public void onActivityResult(int requestCode, int resultCode, Intent data) { if (resultCode == RESULT_OK) { if (requestCode == ActivityCompose.REQUEST_IMAGE) { if (data != null) { Uri uri = data.getData(); if (uri != null) handleAddAttachment(uri, true); } } else if (requestCode == ActivityCompose.REQUEST_ATTACHMENT) { if (data != null) { ClipData clipData = data.getClipData(); if (clipData == null) { Uri uri = data.getData(); if (uri != null) handleAddAttachment(uri, false); } else { for (int i = 0; i < clipData.getItemCount(); i++) { ClipData.Item item = clipData.getItemAt(i); Uri uri = item.getUri(); if (uri != null) handleAddAttachment(uri, false); } } } } else if (requestCode == ActivityCompose.REQUEST_ENCRYPT) { if (data != null) { data.setAction(OpenPgpApi.ACTION_SIGN_AND_ENCRYPT); encrypt(data); } } else { if (data != null) handlePickContact(requestCode, data); } } } private void handlePickContact(int requestCode, Intent data) { Cursor cursor = null; try { Uri uri = data.getData(); if (uri != null) cursor = getContext().getContentResolver().query(uri, new String[]{ ContactsContract.CommonDataKinds.Email.ADDRESS, ContactsContract.Contacts.DISPLAY_NAME }, null, null, null); if (cursor != null && cursor.moveToFirst()) { int colEmail = cursor.getColumnIndex(ContactsContract.CommonDataKinds.Email.ADDRESS); int colName = cursor.getColumnIndex(ContactsContract.Contacts.DISPLAY_NAME); String email = cursor.getString(colEmail); String name = cursor.getString(colName); String text = null; if (requestCode == ActivityCompose.REQUEST_CONTACT_TO) text = etTo.getText().toString(); else if (requestCode == ActivityCompose.REQUEST_CONTACT_CC) text = etCc.getText().toString(); else if (requestCode == ActivityCompose.REQUEST_CONTACT_BCC) text = etBcc.getText().toString(); StringBuilder sb = new StringBuilder(text); sb.append("\"").append(name).append("\" <").append(email).append(">, "); if (requestCode == ActivityCompose.REQUEST_CONTACT_TO) etTo.setText(sb.toString()); else if (requestCode == ActivityCompose.REQUEST_CONTACT_CC) etCc.setText(sb.toString()); else if (requestCode == ActivityCompose.REQUEST_CONTACT_BCC) etBcc.setText(sb.toString()); } } catch (Throwable ex) { Log.e(ex); Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } finally { if (cursor != null) cursor.close(); } } private void handleAddAttachment(Uri uri, final boolean image) { Bundle args = new Bundle(); args.putLong("id", working); args.putParcelable("uri", uri); new SimpleTask() { @Override protected EntityAttachment onExecute(Context context, Bundle args) throws IOException { Long id = args.getLong("id"); Uri uri = args.getParcelable("uri"); return addAttachment(context, id, uri, image); } @Override protected void onExecuted(Bundle args, final EntityAttachment attachment) { if (image) { File file = attachment.getFile(getContext()); Drawable d = Drawable.createFromPath(file.getAbsolutePath()); d.setBounds(0, 0, d.getIntrinsicWidth(), d.getIntrinsicHeight()); int start = etBody.getSelectionStart(); etBody.getText().insert(start, " "); SpannableString s = new SpannableString(etBody.getText()); ImageSpan is = new ImageSpan(getContext(), Uri.parse("cid:" + BuildConfig.APPLICATION_ID + "." + attachment.id), ImageSpan.ALIGN_BASELINE); s.setSpan(is, start, start + 1, Spanned.SPAN_EXCLUSIVE_EXCLUSIVE); String html = HtmlHelper.toHtml(s); etBody.setText(HtmlHelper.fromHtml(html, cidGetter, null)); } onAction(R.id.action_save); } @Override protected void onException(Bundle args, Throwable ex) { // External app sending absolute file if (ex instanceof SecurityException) handleFileShare(); else Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(this, args, "compose:attachment:add"); } private void handleExit() { if (state != State.LOADED) finish(); else if (isEmpty()) onAction(R.id.action_delete); else { autosave = false; onAction(R.id.action_save); finish(); } } private boolean isEmpty() { if (!TextUtils.isEmpty(etExtra.getText().toString().trim())) return false; if (!etTo.getText().toString().trim().equals(etTo.getTag())) return false; if (!TextUtils.isEmpty(etCc.getText().toString().trim())) return false; if (!TextUtils.isEmpty(etBcc.getText().toString().trim())) return false; if (!etSubject.getText().toString().trim().equals(etSubject.getTag())) return false; if (!TextUtils.isEmpty(Jsoup.parse(HtmlHelper.toHtml(etBody.getText())).text().trim())) return false; if (rvAttachment.getAdapter().getItemCount() > 0) return false; return true; } private void onAction(int action) { EntityIdentity identity = (EntityIdentity) spIdentity.getSelectedItem(); // Workaround underlines left by Android Spannable spannable = etBody.getText(); UnderlineSpan[] uspans = spannable.getSpans(0, spannable.length(), UnderlineSpan.class); for (UnderlineSpan uspan : uspans) spannable.removeSpan(uspan); Bundle args = new Bundle(); args.putLong("id", working); args.putInt("action", action); args.putLong("account", identity == null ? -1 : identity.account); args.putLong("identity", identity == null ? -1 : identity.id); args.putString("extra", etExtra.getText().toString().trim()); args.putString("to", etTo.getText().toString().trim()); args.putString("cc", etCc.getText().toString().trim()); args.putString("bcc", etBcc.getText().toString().trim()); args.putString("subject", etSubject.getText().toString().trim()); args.putString("body", HtmlHelper.toHtml(spannable)); args.putBoolean("empty", isEmpty()); Log.i("Run execute id=" + working); actionLoader.execute(this, args, "compose:action:" + action); } private static EntityAttachment addAttachment(Context context, long id, Uri uri, boolean image) throws IOException { if ("file".equals(uri.getScheme()) && !Helper.hasPermission(context, Manifest.permission.READ_EXTERNAL_STORAGE)) { Log.w("Add attachment uri=" + uri); throw new SecurityException(); } EntityAttachment attachment = new EntityAttachment(); String name = uri.getLastPathSegment(); String s = null; try (Cursor cursor = context.getContentResolver().query(uri, null, null, null, null, null)) { if (cursor != null && cursor.moveToFirst()) { name = cursor.getString(cursor.getColumnIndex(OpenableColumns.DISPLAY_NAME)); s = cursor.getString(cursor.getColumnIndex(OpenableColumns.SIZE)); } } DB db = DB.getInstance(context); try { db.beginTransaction(); EntityMessage draft = db.message().getMessage(id); Log.i("Attaching to id=" + id); attachment.message = draft.id; attachment.sequence = db.attachment().getAttachmentSequence(draft.id) + 1; attachment.name = name; String extension = Helper.getExtension(attachment.name); if (extension != null) attachment.type = MimeTypeMap.getSingleton().getMimeTypeFromExtension(extension.toLowerCase()); if (attachment.type == null) attachment.type = "application/octet-stream"; if (image) attachment.disposition = Part.INLINE; attachment.size = (s == null ? null : Long.parseLong(s)); attachment.progress = 0; attachment.id = db.attachment().insertAttachment(attachment); Log.i("Created attachment=" + attachment.name + ":" + attachment.sequence + " type=" + attachment.type); db.setTransactionSuccessful(); } finally { db.endTransaction(); } long size = 0; try { File file = attachment.getFile(context); InputStream is = null; OutputStream os = null; try { is = context.getContentResolver().openInputStream(uri); os = new BufferedOutputStream(new FileOutputStream(file)); byte[] buffer = new byte[MessageHelper.ATTACHMENT_BUFFER_SIZE]; for (int len = is.read(buffer); len != -1; len = is.read(buffer)) { size += len; os.write(buffer, 0, len); // Update progress if (attachment.size != null && attachment.size > 0) db.attachment().setProgress(attachment.id, (int) (size * 100 / attachment.size)); } if (image) { attachment.cid = "<" + BuildConfig.APPLICATION_ID + "." + attachment.id + ">"; db.attachment().setCid(attachment.id, attachment.cid); } } finally { try { if (is != null) is.close(); } finally { if (os != null) os.close(); } } SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(context); boolean autoresize = prefs.getBoolean("autoresize", true); if ((image || autoresize) && ("image/jpeg".equals(attachment.type) || "image/png".equals(attachment.type))) { BitmapFactory.Options options = new BitmapFactory.Options(); options.inJustDecodeBounds = true; BitmapFactory.decodeFile(file.getAbsolutePath(), options); int factor = 1; while (options.outWidth / factor > REDUCED_IMAGE_SIZE || options.outHeight / factor > REDUCED_IMAGE_SIZE) factor *= 2; if (factor > 1) { options.inJustDecodeBounds = false; options.inSampleSize = factor; Bitmap scaled = BitmapFactory.decodeFile(file.getAbsolutePath(), options); if (scaled != null) { Log.i("Image target size=" + scaled.getWidth() + "x" + scaled.getHeight()); try (OutputStream out = new BufferedOutputStream(new FileOutputStream(file))) { scaled.compress("image/jpeg".equals(attachment.type) ? Bitmap.CompressFormat.JPEG : Bitmap.CompressFormat.PNG, REDUCED_IMAGE_QUALITY, out); } finally { scaled.recycle(); } size = file.length(); } } } db.attachment().setDownloaded(attachment.id, size); } catch (IOException ex) { // Reset progress on failure db.attachment().setProgress(attachment.id, null); throw ex; } return attachment; } private SimpleTask draftLoader = new SimpleTask() { @Override protected EntityMessage onExecute(Context context, Bundle args) throws IOException { String action = args.getString("action"); long id = args.getLong("id", -1); long reference = args.getLong("reference", -1); long answer = args.getLong("answer", -1); Log.i("Load draft action=" + action + " id=" + id + " reference=" + reference); EntityMessage draft; DB db = DB.getInstance(context); try { db.beginTransaction(); draft = db.message().getMessage(id); if (draft == null || draft.ui_hide) { // New draft if ("edit".equals(action)) throw new IllegalStateException("Draft not found hide=" + (draft != null)); List identities = db.identity().getComposableIdentities(null); EntityFolder drafts; EntityMessage ref = db.message().getMessage(reference); if (ref == null) { long aid = args.getLong("account", -1); if (aid < 0) drafts = db.folder().getPrimaryDrafts(); else { drafts = db.folder().getFolderByType(aid, EntityFolder.DRAFTS); if (drafts == null) drafts = db.folder().getPrimaryDrafts(); } if (drafts == null) throw new IllegalArgumentException(context.getString(R.string.title_no_primary_drafts)); } else { drafts = db.folder().getFolderByType(ref.account, EntityFolder.DRAFTS); if (drafts == null) drafts = db.folder().getPrimaryDrafts(); if (drafts == null) throw new IllegalArgumentException(context.getString(R.string.title_no_primary_drafts)); // Reply to recipient, not to known self if (ref.reply != null && ref.reply.length > 0) { String reply = Helper.canonicalAddress(((InternetAddress) ref.reply[0]).getAddress()); for (EntityIdentity identity : identities) { String email = Helper.canonicalAddress(identity.email); if (reply.equals(email)) { ref.reply = null; break; } } } if (ref.deliveredto != null && (ref.to == null || ref.to.length == 0)) { try { Log.i("Setting delivered to=" + ref.deliveredto); ref.to = InternetAddress.parse(ref.deliveredto); } catch (AddressException ex) { Log.w(ex); } } if (ref.from != null && ref.from.length > 0) { String from = Helper.canonicalAddress(((InternetAddress) ref.from[0]).getAddress()); Log.i("From=" + from + " to=" + MessageHelper.formatAddressesShort(ref.to)); for (EntityIdentity identity : identities) { String email = Helper.canonicalAddress(identity.email); if (from.equals(email)) { Log.i("Swapping from/to"); Address[] tmp = ref.to; ref.to = ref.from; ref.from = tmp; break; } } } } String body = ""; draft = new EntityMessage(); draft.account = drafts.account; draft.folder = drafts.id; draft.msgid = EntityMessage.generateMessageId(); if (ref == null) { draft.thread = draft.msgid; try { String to = args.getString("to"); draft.to = (TextUtils.isEmpty(to) ? null : InternetAddress.parse(to)); } catch (AddressException ex) { Log.w(ex); } try { String cc = args.getString("cc"); draft.cc = (TextUtils.isEmpty(cc) ? null : InternetAddress.parse(cc)); } catch (AddressException ex) { Log.w(ex); } try { String bcc = args.getString("bcc"); draft.bcc = (TextUtils.isEmpty(bcc) ? null : InternetAddress.parse(bcc)); } catch (AddressException ex) { Log.w(ex); } draft.subject = args.getString("subject", ""); body = args.getString("body", ""); body = body.replaceAll("\\r?\\n", "
"); if (answer > 0) body = EntityAnswer.getAnswerText(db, answer, null) + body; } else { if ("reply".equals(action) || "reply_all".equals(action)) { draft.references = (ref.references == null ? "" : ref.references + " ") + ref.msgid; draft.inreplyto = ref.msgid; draft.thread = ref.thread; draft.to = (ref.reply == null || ref.reply.length == 0 ? ref.from : ref.reply); draft.from = ref.to; if ("reply_all".equals(action)) { List
addresses = new ArrayList<>(); if (ref.to != null) addresses.addAll(Arrays.asList(ref.to)); if (ref.cc != null) addresses.addAll(Arrays.asList(ref.cc)); for (Address address : new ArrayList<>(addresses)) { String cc = Helper.canonicalAddress(((InternetAddress) address).getAddress()); for (EntityIdentity identity : identities) { String email = Helper.canonicalAddress(identity.email); if (cc.equals(email)) addresses.remove(address); } } draft.cc = addresses.toArray(new Address[0]); } } else if ("forward".equals(action)) { draft.thread = draft.msgid; // new thread draft.from = ref.to; } if ("reply".equals(action) || "reply_all".equals(action)) draft.subject = context.getString(R.string.title_subject_reply, ref.subject == null ? "" : ref.subject); else if ("forward".equals(action)) draft.subject = context.getString(R.string.title_subject_forward, ref.subject == null ? "" : ref.subject); if (answer > 0 && ("reply".equals(action) || "reply_all".equals(action))) body = EntityAnswer.getAnswerText(db, answer, draft.to) + body; } // Select identity matching from address int icount = 0; EntityIdentity first = null; EntityIdentity primary = null; int iindex = -1; do { String from = null; if (iindex >= 0) from = Helper.canonicalAddress(((InternetAddress) draft.from[iindex]).getAddress()); for (EntityIdentity identity : identities) { String email = Helper.canonicalAddress(identity.email); if (email.equals(from)) { draft.identity = identity.id; draft.from = new InternetAddress[]{new InternetAddress(identity.email, identity.name)}; break; } if (identity.account.equals(draft.account)) { icount++; if (identity.primary) primary = identity; if (first == null) first = identity; } } if (draft.identity != null) break; iindex++; } while (iindex < (draft.from == null ? -1 : draft.from.length)); // Select identity if (draft.identity == null) { if (primary != null) { draft.identity = primary.id; draft.from = new InternetAddress[]{new InternetAddress(primary.email, primary.name)}; } else if (first != null && icount == 1) { draft.identity = first.id; draft.from = new InternetAddress[]{new InternetAddress(first.email, first.name)}; } } draft.sender = MessageHelper.getSortKey(draft.from); draft.received = new Date().getTime(); draft.id = db.message().insertMessage(draft); Helper.writeText(draft.getFile(context), body); db.message().setMessageContent(draft.id, true, HtmlHelper.getPreview(body), null); // Write reference text if (ref != null && ref.content) { String refBody = String.format("

%s %s:

\n
%s
", Html.escapeHtml(new Date(ref.received).toString()), Html.escapeHtml(MessageHelper.formatAddresses(ref.from)), Helper.readText(ref.getFile(context))); Helper.writeText(draft.getRefFile(context), refBody); } if ("new".equals(action)) { ArrayList uris = args.getParcelableArrayList("attachments"); if (uris != null) for (Uri uri : uris) addAttachment(context, draft.id, uri, false); } else { int sequence = 0; List attachments = db.attachment().getAttachments(ref.id); for (EntityAttachment attachment : attachments) if (attachment.available && ("forward".equals(action) || attachment.isInline())) { File source = attachment.getFile(context); attachment.id = null; attachment.message = draft.id; attachment.sequence = ++sequence; attachment.id = db.attachment().insertAttachment(attachment); File target = attachment.getFile(context); Helper.copy(source, target); } } EntityOperation.queue(context, db, draft, EntityOperation.ADD); } else { if (!draft.content) { if (draft.uid == null) throw new IllegalStateException("Draft without uid"); EntityOperation.queue(context, db, draft, EntityOperation.BODY); } List attachments = db.attachment().getAttachments(draft.id); for (EntityAttachment attachment : attachments) if (!attachment.available) EntityOperation.queue(context, db, draft, EntityOperation.ATTACHMENT, attachment.sequence); } db.setTransactionSuccessful(); } finally { db.endTransaction(); } return draft; } @Override protected void onExecuted(Bundle args, final EntityMessage draft) { working = draft.id; final String action = getArguments().getString("action"); Log.i("Loaded draft id=" + draft.id + " action=" + action); etExtra.setText(draft.extra); etTo.setText(MessageHelper.formatAddressesCompose(draft.to)); etCc.setText(MessageHelper.formatAddressesCompose(draft.cc)); etBcc.setText(MessageHelper.formatAddressesCompose(draft.bcc)); etSubject.setText(draft.subject); long reference = args.getLong("reference", -1); etTo.setTag(reference < 0 ? "" : etTo.getText().toString()); etSubject.setTag(reference < 0 ? "" : etSubject.getText().toString()); boolean sender = PreferenceManager.getDefaultSharedPreferences(getContext()).getBoolean("sender", false); grpHeader.setVisibility(View.VISIBLE); grpExtra.setVisibility(sender ? View.VISIBLE : View.GONE); grpAddresses.setVisibility("reply_all".equals(action) ? View.VISIBLE : View.GONE); getActivity().invalidateOptionsMenu(); new SimpleTask>() { @Override protected List onExecute(Context context, Bundle args) { DB db = DB.getInstance(context); List identities = db.identity().getComposableIdentities(null); if (identities == null) identities = new ArrayList<>(); // Sort identities Collections.sort(identities, new Comparator() { @Override public int compare(TupleIdentityEx i1, TupleIdentityEx i2) { int a = i1.accountName.compareTo(i2.accountName); if (a != 0) return a; int d = i1.getDisplayName().compareTo(i2.getDisplayName()); if (d != 0) return d; return i1.email.compareTo(i2.email); } }); return identities; } @Override protected void onExecuted(Bundle args, List identities) { Log.i("Set identities=" + identities.size()); // Show identities IdentityAdapter adapter = new IdentityAdapter(getContext(), identities); adapter.setDropDownViewResource(R.layout.spinner_item1_dropdown); spIdentity.setAdapter(adapter); // Select identity if (draft.identity != null) for (int pos = 0; pos < identities.size(); pos++) { if (identities.get(pos).id.equals(draft.identity)) { spIdentity.setSelection(pos); break; } } } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, new Bundle(), "compose:identities"); DB db = DB.getInstance(getContext()); db.attachment().liveAttachments(draft.id).observe(getViewLifecycleOwner(), new Observer>() { private int last_available = 0; @Override public void onChanged(@Nullable List attachments) { if (attachments == null) attachments = new ArrayList<>(); adapter.set(attachments); grpAttachments.setVisibility(attachments.size() > 0 ? View.VISIBLE : View.GONE); int available = 0; boolean downloading = false; for (EntityAttachment attachment : attachments) { if (attachment.available) available++; if (attachment.progress != null) { downloading = true; break; } } // Attachment deleted if (available < last_available) onAction(R.id.action_save); last_available = available; rvAttachment.setTag(downloading); checkInternet(); checkDraft(draft.id); } }); db.message().liveMessage(draft.id).observe(getViewLifecycleOwner(), new Observer() { @Override public void onChanged(EntityMessage draft) { // Draft was deleted if (draft == null || draft.ui_hide) finish(); else { tvNoInternet.setTag(draft.content); checkInternet(); checkDraft(draft.id); } } }); } @Override protected void onException(Bundle args, Throwable ex) { pbWait.setVisibility(View.GONE); // External app sending absolute file if (ex instanceof SecurityException) handleFileShare(); else if (ex instanceof IllegalArgumentException) Snackbar.make(view, ex.getMessage(), Snackbar.LENGTH_LONG).show(); else Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }; void handleFileShare() { final Intent intent = new Intent(Intent.ACTION_VIEW); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); intent.setData(Uri.parse(Helper.FAQ_URI + "#user-content-faq49")); boolean resolves = (intent.resolveActivity(getContext().getPackageManager()) != null); Snackbar sb = Snackbar.make(view, R.string.title_no_stream, resolves ? Snackbar.LENGTH_INDEFINITE : Snackbar.LENGTH_LONG); if (resolves) sb.setAction(R.string.title_info, new View.OnClickListener() { @Override public void onClick(View v) { startActivity(intent); finish(); } }); sb.show(); } private SimpleTask actionLoader = new SimpleTask() { int last_available = 0; @Override protected void onPreExecute(Bundle args) { busy = true; Helper.setViewsEnabled(view, false); getActivity().invalidateOptionsMenu(); } @Override protected void onPostExecute(Bundle args) { busy = false; Helper.setViewsEnabled(view, true); getActivity().invalidateOptionsMenu(); } @Override protected EntityMessage onExecute(final Context context, Bundle args) throws Throwable { // Get data long id = args.getLong("id"); int action = args.getInt("action"); long aid = args.getLong("account"); long iid = args.getLong("identity"); String extra = args.getString("extra"); String to = args.getString("to"); String cc = args.getString("cc"); String bcc = args.getString("bcc"); String subject = args.getString("subject"); String body = args.getString("body"); boolean empty = args.getBoolean("empty"); EntityMessage draft; DB db = DB.getInstance(context); try { db.beginTransaction(); // Get draft & selected identity draft = db.message().getMessage(id); EntityIdentity identity = db.identity().getIdentity(iid); // Draft deleted by server if (draft == null) throw new MessageRemovedException("Draft for action was deleted"); Log.i("Load action id=" + draft.id + " action=" + action); // Move draft to new account if (draft.account != aid && aid >= 0) { Long uid = draft.uid; String msgid = draft.msgid; // To prevent violating constraints draft.uid = null; draft.msgid = null; db.message().updateMessage(draft); // Create copy to delete draft.id = null; draft.uid = uid; draft.msgid = msgid; draft.content = false; draft.ui_hide = true; draft.id = db.message().insertMessage(draft); EntityOperation.queue(context, db, draft, EntityOperation.DELETE); // by msgid // Restore original with new account, no uid and new msgid draft.id = id; draft.account = aid; draft.folder = db.folder().getFolderByType(aid, EntityFolder.DRAFTS).id; draft.uid = null; draft.msgid = EntityMessage.generateMessageId(); draft.content = true; draft.ui_hide = false; EntityOperation.queue(context, db, draft, EntityOperation.ADD); } List attachments = db.attachment().getAttachments(draft.id); // Get data InternetAddress afrom[] = (identity == null ? null : new InternetAddress[]{new InternetAddress(identity.email, identity.name)}); InternetAddress ato[] = null; InternetAddress acc[] = null; InternetAddress abcc[] = null; if (!TextUtils.isEmpty(to)) ato = InternetAddress.parse(to); if (!TextUtils.isEmpty(cc)) acc = InternetAddress.parse(cc); if (!TextUtils.isEmpty(bcc)) abcc = InternetAddress.parse(bcc); if (TextUtils.isEmpty(extra)) extra = null; int available = 0; for (EntityAttachment attachment : attachments) if (attachment.available) available++; Long ident = (identity == null ? null : identity.id); boolean dirty = (!Objects.equals(draft.identity, ident) || !Objects.equals(draft.extra, extra) || !MessageHelper.equal(draft.from, afrom) || !MessageHelper.equal(draft.to, ato) || !MessageHelper.equal(draft.cc, acc) || !MessageHelper.equal(draft.bcc, abcc) || !Objects.equals(draft.subject, subject) || last_available != available || !body.equals(Helper.readText(draft.getFile(context)))); last_available = available; if (dirty) { // Update draft draft.identity = ident; draft.extra = extra; draft.sender = MessageHelper.getSortKey(afrom); draft.from = afrom; draft.to = ato; draft.cc = acc; draft.bcc = abcc; draft.subject = subject; draft.received = new Date().getTime(); db.message().updateMessage(draft); Helper.writeText(draft.getFile(context), body); db.message().setMessageContent(draft.id, true, HtmlHelper.getPreview(body), null); } // Remove unused inline images StringBuilder sb = new StringBuilder(); sb.append(body); File rfile = draft.getRefFile(context); if (rfile.exists()) sb.append(Helper.readText(rfile)); List cids = new ArrayList<>(); for (Element element : Jsoup.parse(sb.toString()).select("img")) { String src = element.attr("src"); if (src.startsWith("cid:")) cids.add("<" + src.substring(4) + ">"); } for (EntityAttachment attachment : new ArrayList<>(attachments)) if (attachment.isInline() && attachment.cid != null && !cids.contains(attachment.cid)) { Log.i("Removing unused inline attachment cid=" + attachment.cid); db.attachment().deleteAttachment(attachment.id); } // Execute action if (action == R.id.action_delete) { EntityFolder trash = db.folder().getFolderByType(draft.account, EntityFolder.TRASH); if (empty || trash == null) EntityOperation.queue(context, db, draft, EntityOperation.DELETE); else { EntityOperation.queue(context, db, draft, EntityOperation.SEEN, true); draft.ui_seen = true; EntityOperation.queue(context, db, draft, EntityOperation.MOVE, trash.id); } if (!empty) { Handler handler = new Handler(context.getMainLooper()); handler.post(new Runnable() { public void run() { Toast.makeText(context, R.string.title_draft_deleted, Toast.LENGTH_LONG).show(); } }); } } else if (action == R.id.action_save || action == R.id.menu_encrypt) { if (!BuildConfig.DEBUG || dirty) { EntityOperation.queue(context, db, draft, EntityOperation.ADD); Handler handler = new Handler(context.getMainLooper()); handler.post(new Runnable() { public void run() { Toast.makeText(context, R.string.title_draft_saved, Toast.LENGTH_LONG).show(); } }); } } else if (action == R.id.action_send) { // Check data if (draft.identity == null) throw new IllegalArgumentException(context.getString(R.string.title_from_missing)); if (draft.to == null && draft.cc == null && draft.bcc == null) throw new IllegalArgumentException(context.getString(R.string.title_to_missing)); // Save attachments for (EntityAttachment attachment : attachments) if (!attachment.available) throw new IllegalArgumentException(context.getString(R.string.title_attachments_missing)); // Delete draft (cannot move to outbox) EntityOperation.queue(context, db, draft, EntityOperation.DELETE); File refDraftFile = draft.getRefFile(context); // Copy message to outbox draft.id = null; draft.folder = db.folder().getOutbox().id; draft.uid = null; draft.ui_hide = false; draft.id = db.message().insertMessage(draft); Helper.writeText(draft.getFile(context), body); if (refDraftFile.exists()) { File refFile = draft.getRefFile(context); refDraftFile.renameTo(refFile); } // Move attachments for (EntityAttachment attachment : attachments) db.attachment().setMessage(attachment.id, draft.id); if (draft.ui_snoozed == null) EntityOperation.queue(context, db, draft, EntityOperation.SEND); if (draft.ui_snoozed == null) { Handler handler = new Handler(context.getMainLooper()); handler.post(new Runnable() { public void run() { Toast.makeText(context, R.string.title_queued, Toast.LENGTH_LONG).show(); } }); } } db.setTransactionSuccessful(); } finally { db.endTransaction(); } if (action == R.id.action_send && draft.ui_snoozed != null) { Log.i("Delayed send id=" + draft.id + " at " + new Date(draft.ui_snoozed)); EntityMessage.snooze(getContext(), draft.id, draft.ui_snoozed); } return draft; } @Override protected void onExecuted(Bundle args, EntityMessage draft) { int action = args.getInt("action"); Log.i("Loaded action id=" + (draft == null ? null : draft.id) + " action=" + action); etTo.setText(MessageHelper.formatAddressesCompose(draft.to)); etCc.setText(MessageHelper.formatAddressesCompose(draft.cc)); etBcc.setText(MessageHelper.formatAddressesCompose(draft.bcc)); if (action == R.id.action_delete) { autosave = false; finish(); } else if (action == R.id.action_save) { // Do nothing } else if (action == R.id.menu_encrypt) { onEncrypt(); } else if (action == R.id.action_send) { autosave = false; finish(); } } @Override protected void onException(Bundle args, Throwable ex) { if (ex instanceof MessageRemovedException) finish(); else if (ex instanceof IllegalArgumentException || ex instanceof AddressException) Snackbar.make(view, ex.getMessage(), Snackbar.LENGTH_LONG).show(); else Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }; private void checkDraft(long id) { Bundle args = new Bundle(); args.putLong("id", id); new SimpleTask() { @Override protected EntityMessage onExecute(Context context, Bundle args) { long id = args.getLong("id"); DB db = DB.getInstance(context); EntityMessage draft = db.message().getMessage(id); if (!draft.content) return null; List attachments = db.attachment().getAttachments(id); for (EntityAttachment attachment : attachments) if (!attachment.available) return null; return draft; } @Override protected void onExecuted(Bundle args, EntityMessage draft) { if (draft != null && state == State.NONE) showDraft(draft); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(this, args, "compose:check"); } private void showDraft(long id) { Bundle args = new Bundle(); args.putLong("id", id); new SimpleTask() { @Override protected EntityMessage onExecute(Context context, Bundle args) { long id = args.getLong("id"); return DB.getInstance(context).message().getMessage(id); } @Override protected void onExecuted(Bundle args, EntityMessage draft) { showDraft(draft); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, args, "compose:show"); } private void showDraft(EntityMessage draft) { Bundle args = new Bundle(); args.putLong("id", draft.id); args.putBoolean("show_images", show_images); new SimpleTask() { @Override protected void onPostExecute(Bundle args) { state = State.LOADED; autosave = true; pbWait.setVisibility(View.GONE); edit_bar.setVisibility(View.VISIBLE); bottom_navigation.setVisibility(View.VISIBLE); Helper.setViewsEnabled(view, true); getActivity().invalidateOptionsMenu(); } @Override protected Spanned[] onExecute(final Context context, Bundle args) throws Throwable { final long id = args.getLong("id"); final boolean show_images = args.getBoolean("show_images", false); DB db = DB.getInstance(context); EntityMessage draft = db.message().getMessage(id); if (draft == null) throw new FileNotFoundException(); String body = Helper.readText(draft.getFile(context)); Spanned spannedBody = HtmlHelper.fromHtml(body, cidGetter, null); Spanned spannedReference = null; File refFile = draft.getRefFile(context); if (refFile.exists()) { String quote = HtmlHelper.sanitize(context, Helper.readText(refFile), true); Spanned spannedQuote = HtmlHelper.fromHtml(quote, new Html.ImageGetter() { @Override public Drawable getDrawable(String source) { Drawable image = HtmlHelper.decodeImage(source, context, id, show_images); float width = context.getResources().getDisplayMetrics().widthPixels - Helper.dp2pixels(context, 12); // margins; if (image.getIntrinsicWidth() > width) { float scale = width / image.getIntrinsicWidth(); image.setBounds(0, 0, Math.round(image.getIntrinsicWidth() * scale), Math.round(image.getIntrinsicHeight() * scale)); } return image; } }, null); int colorPrimary = Helper.resolveColor(context, R.attr.colorPrimary); SpannableStringBuilder builder = new SpannableStringBuilder(spannedQuote); QuoteSpan[] quoteSpans = builder.getSpans(0, builder.length(), QuoteSpan.class); for (QuoteSpan quoteSpan : quoteSpans) { builder.setSpan( new StyledQuoteSpan(colorPrimary), builder.getSpanStart(quoteSpan), builder.getSpanEnd(quoteSpan), builder.getSpanFlags(quoteSpan)); builder.removeSpan(quoteSpan); } spannedReference = builder; } return new Spanned[]{spannedBody, spannedReference}; } @Override protected void onExecuted(Bundle args, Spanned[] text) { etBody.setText(text[0]); etBody.setSelection(0); grpBody.setVisibility(View.VISIBLE); boolean has_images = (text[1] != null && text[1].getSpans(0, text[1].length(), ImageSpan.class).length > 0); tvReference.setText(text[1]); grpReference.setVisibility(text[1] == null ? View.GONE : View.VISIBLE); ibReferenceEdit.setVisibility(text[1] == null ? View.GONE : View.VISIBLE); ibReferenceImages.setVisibility(has_images && !show_images ? View.VISIBLE : View.GONE); new Handler().post(new Runnable() { @Override public void run() { if (TextUtils.isEmpty(etTo.getText().toString().trim())) etTo.requestFocus(); else if (TextUtils.isEmpty(etSubject.getText().toString())) etSubject.requestFocus(); else etBody.requestFocus(); } }); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, args, "compose:show"); } private Html.ImageGetter cidGetter = new Html.ImageGetter() { @Override public Drawable getDrawable(final String source) { final LevelListDrawable lld = new LevelListDrawable(); Resources res = getContext().getResources(); int px = Helper.dp2pixels(getContext(), 48); // Level 0: broken image Drawable broken = res.getDrawable(R.drawable.baseline_broken_image_24, getContext().getTheme()); broken.setBounds(0, 0, px, px); lld.addLevel(0, 0, broken); // Level 1: place holder Drawable placeholder = res.getDrawable(R.drawable.baseline_image_24, getContext().getTheme()); placeholder.setBounds(0, 0, px, px); lld.addLevel(1, 1, placeholder); lld.setBounds(0, 0, px, px); if (source != null && source.startsWith("cid:")) { lld.setLevel(1); // placeholder new Handler(Looper.getMainLooper()).post(new Runnable() { @Override public void run() { Bundle args = new Bundle(); args.putLong("id", working); args.putString("cid", "<" + source.substring(4) + ">"); new SimpleTask() { @Override protected Drawable onExecute(Context context, Bundle args) { long id = args.getLong("id"); String cid = args.getString("cid"); DB db = DB.getInstance(context); EntityAttachment attachment = db.attachment().getAttachment(id, cid); if (attachment == null) return null; File file = attachment.getFile(context); return Drawable.createFromPath(file.getAbsolutePath()); } @Override protected void onExecuted(Bundle args, Drawable image) { if (image == null) lld.setLevel(0); // broken else { lld.addLevel(2, 2, image); lld.setLevel(2); // image float scale = 1.0f; float width = getContext().getResources().getDisplayMetrics().widthPixels - Helper.dp2pixels(getContext(), 12); // margins; if (image.getIntrinsicWidth() > width) scale = width / image.getIntrinsicWidth(); lld.setBounds(0, 0, Math.round(image.getIntrinsicWidth() * scale), Math.round(image.getIntrinsicHeight() * scale)); } etBody.requestLayout(); } @Override protected void onException(Bundle args, Throwable ex) { Helper.unexpectedError(getContext(), getViewLifecycleOwner(), ex); } }.execute(FragmentCompose.this, args, "compose:cid:" + source); } }); } else lld.setLevel(1); // image place holder return lld; } }; public class IdentityAdapter extends ArrayAdapter { private Context context; private List identities; IdentityAdapter(@NonNull Context context, List identities) { super(context, 0, identities); this.context = context; this.identities = identities; } @NonNull @Override public View getView(int position, @Nullable View convertView, @NonNull ViewGroup parent) { return getLayout(position, convertView, parent, R.layout.spinner_item2); } @Override public View getDropDownView(int position, View convertView, ViewGroup parent) { return getLayout(position, convertView, parent, R.layout.spinner_item2_dropdown); } View getLayout(int position, View convertView, ViewGroup parent, int resid) { View view = LayoutInflater.from(context).inflate(resid, parent, false); TupleIdentityEx identity = identities.get(position); TextView text1 = view.findViewById(android.R.id.text1); text1.setText(identity.accountName + "/" + identity.getDisplayName() + (identity.primary ? " ★" : "")); TextView text2 = view.findViewById(android.R.id.text2); text2.setText(identity.email); return view; } } private ActivityBase.IBackPressedListener onBackPressedListener = new ActivityBase.IBackPressedListener() { @Override public boolean onBackPressed() { if (getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.RESUMED)) handleExit(); return true; } }; }