Method onTts

app/src/main/java/eu/faircode/email/ServiceTTS.java:143–269

(Intent intent)

    }

    void onTts(Intent intent) {
        final boolean flush = intent.getBooleanExtra(EXTRA_FLUSH, false);
        final String text = intent.getStringExtra(EXTRA_TEXT);
        final String language = intent.getStringExtra(EXTRA_LANGUAGE);
        final String utteranceId = intent.getStringExtra(EXTRA_UTTERANCE_ID);
        final long group = intent.getLongExtra(EXTRA_GROUP, 0);
        final long message = intent.getLongExtra(EXTRA_MESSAGE, -1L);

        final Locale locale = (language == null ? Locale.getDefault() : new Locale(language));

        if (message > 0) {
            String tag = "unseen." + group + "." + message;
            NotificationManager nm = Helper.getSystemService(this, NotificationManager.class);
            nm.cancel(tag, NotificationHelper.NOTIFICATION_TAGGED);

            Helper.getSerialExecutor().submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        String body = Helper.readText(EntityMessage.getFile(ServiceTTS.this, message));
                        String text = HtmlHelper.getFullText(ServiceTTS.this, body);

                        // Avoid: Not enough namespace quota ... for ...
                        text = HtmlHelper.truncate(text, getMaxTextSize() / 3);

                        intent.putExtra(EXTRA_TEXT, text);
                        intent.removeExtra(EXTRA_GROUP);
                        intent.removeExtra(EXTRA_MESSAGE);
                        onTts(intent);
                    } catch (Throwable ex) {
                        Log.e(ex);
                    }
                }
            });

            return;
        }

        final Runnable speak = new RunnableEx("tts") {
            @Override
            public void delegate() {
                boolean available = (instance.setLanguage(locale) >= 0);
                EntityLog.log(ServiceTTS.this, "TTS queued" +
                        " language=" + locale +
                        " available=" + available +
                        " utterance=" + utteranceId +
                        " text=" + text);
                int error = instance.speak(text, flush ? TextToSpeech.QUEUE_FLUSH : TextToSpeech.QUEUE_ADD, null, utteranceId);
                if (error != TextToSpeech.SUCCESS)
                    throw new OperationCanceledException("TTS error=" + error);
            }
        };

        final LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(ServiceTTS.this);

        synchronized (lock) {
            if (status == null) {
                queue.add(speak);