Tasker v6.5.11 - ServiceVoiceInteractionTasker.java 源代码

package com.joaomgcd.taskerm.assistant;

import android.annotation.TargetApi;
import android.app.Activity;
import android.app.assist.AssistContent;
import android.app.assist.AssistStructure;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.net.Uri;
import android.os.Bundle;
import android.service.voice.VoiceInteractionService;
import androidx.annotation.Keep;
import com.joaomgcd.taskerm.action.system.a0;
import com.joaomgcd.taskerm.action.system.b0;
import com.joaomgcd.taskerm.action.system.p1;
import com.joaomgcd.taskerm.action.system.u;
import com.joaomgcd.taskerm.assistant.ServiceVoiceInteractionTasker;
import com.joaomgcd.taskerm.rx.EventBusRxSubscription;
import com.joaomgcd.taskerm.util.ExtensionsContextKt;
import com.joaomgcd.taskerm.util.s6;
import com.joaomgcd.taskerm.util.u6;
import com.joaomgcd.taskerm.util.v6;
import com.joaomgcd.taskerm.util.x2;
import com.joaomgcd.taskerm.util.x6;
import com.joaomgcd.taskerm.util.z2;
import hg.h;
import hg.k;
import hg.v0;
import hg.z1;
import java.util.concurrent.TimeUnit;
import ji.n;
import ji.r;
import lj.e0;
import net.dinglisch.android.taskerm.ActionEdit;
import net.dinglisch.android.taskerm.k2;
import net.dinglisch.android.taskerm.r7;
import net.dinglisch.android.taskerm.sd;
import oi.g;
import pg.d;
import pg.w0;
import we.l0;
import xj.l;
import yj.p;
import yj.q;

@TargetApi(23)
public final class ServiceVoiceInteractionTasker extends VoiceInteractionService {
    public static final a q = new a(null);
    private final com.joaomgcd.taskerm.assistant.a i = new com.joaomgcd.taskerm.assistant.a(this);

    public static final class a {

        static final class C0200a extends q implements l<z1, e0> {
            final Context i;

            C0200a(Context context) {
                super(1);
                this.i = context;
            }

            public final void a(z1 z1Var) {
                p.i(z1Var, "$this$warnWithNotification");
                v0 i = z1Var.i();
                hg.c kVar = new k(this.i);
                Context context = this.i;
                i.addAll(new v0(new hg.c[]{kVar, new h(context, "https://tasker.joaoapps.com/userguide/en/help/ah_secure_setting_grant.html", false, x2.Q4(2131887517, context, new Object[0]), 4, (yj.h) null)}));
            }

            public Object invoke(Object obj) {
                a((z1) obj);
                return e0.a;
            }
        }

        static final class b extends q implements xj.a<s6> {
            final VoiceAssistantRequest i;

            static final class C0201a extends q implements xj.a<c> {
                final VoiceAssistantRequest i;

                public static final class C0202a<T> implements g {
                    public static final C0202a<T> a = new C0202a<>();

                    public final boolean a(Object obj) {
                        p.i(obj, "it");
                        return obj instanceof c;
                    }
                }

                public static final class C0203b extends q implements l<c, e0> {
                    public static final C0203b i = new C0203b();

                    public C0203b() {
                        super(1);
                    }

                    public final void a(c cVar) {
                    }

                    public Object invoke(Object obj) {
                        a(obj);
                        return e0.a;
                    }
                }

                C0201a(VoiceAssistantRequest voiceAssistantRequest) {
                    super(0);
                    this.i = voiceAssistantRequest;
                }

                public final c invoke() {
                    VoiceAssistantRequest voiceAssistantRequest = this.i;
                    n E = pg.d.a.h().E(C0202a.a);
                    p.g(E, "null cannot be cast to non-null type io.reactivex.Observable<T of com.joaomgcd.taskerm.rx.EventBusRx.forType>");
                    r g = E.G().g();
                    p.g(g, "null cannot be cast to non-null type io.reactivex.Single<T of com.joaomgcd.taskerm.rx.EventBusRx.waitFor>");
                    r L = g.L(5000L, TimeUnit.MILLISECONDS);
                    p.h(L, "timeout(...)");
                    p.h(L.I(new d.f(C0203b.i), new d.f(pg.e.i)), "subscribe(...)");
                    pg.d.j(voiceAssistantRequest);
                    return (c) L.f();
                }
            }

            b(VoiceAssistantRequest voiceAssistantRequest) {
                super(0);
                this.i = voiceAssistantRequest;
            }

            public final s6 invoke() {
                s6 a;
                c cVar = (c) x2.U4((l) null, new C0201a(this.i), 1, (Object) null);
                return (cVar == null || (a = cVar.a()) == null) ? u6.c("Couldn't do action with assistant") : a;
            }
        }

        static final class c extends q implements xj.a<s6> {
            final Context i;
            final b0 q;
            final String r;
            final p1 s;

            static final class C0204a extends q implements xj.a<b> {
                final r<b> i;

                C0204a(r<b> rVar) {
                    super(0);
                    this.i = rVar;
                }

                public final b invoke() {
                    return (b) this.i.f();
                }
            }

            public static final class b<T> implements g {
                public static final b<T> a = new b<>();

                public final boolean a(Object obj) {
                    p.i(obj, "it");
                    return obj instanceof b;
                }
            }

            public static final class C0205c extends q implements l<b, e0> {
                public static final C0205c i = new C0205c();

                public C0205c() {
                    super(1);
                }

                public final void a(b bVar) {
                }

                public Object invoke(Object obj) {
                    a(obj);
                    return e0.a;
                }
            }

            c(Context context, b0 b0Var, String str, p1 p1Var) {
                super(0);
                this.i = context;
                this.q = b0Var;
                this.r = str;
                this.s = p1Var;
            }

            public final s6 invoke() {
                r rVar;
                String packageName = this.i.getPackageName();
                if (p.d(this.q.getPackageName(), this.r)) {
                    r7.f("ServiceVoiceInteractionTasker", "No need to change assistant, alread " + this.r);
                    return a.h(this.q);
                }
                r7.f("ServiceVoiceInteractionTasker", "Changing assistant from " + this.q + " to " + this.r);
                if (p.d(this.r, packageName)) {
                    n E = pg.d.a.h().E(b.a);
                    p.g(E, "null cannot be cast to non-null type io.reactivex.Observable<T of com.joaomgcd.taskerm.rx.EventBusRx.forType>");
                    r g = E.G().g();
                    p.g(g, "null cannot be cast to non-null type io.reactivex.Single<T of com.joaomgcd.taskerm.rx.EventBusRx.waitFor>");
                    rVar = g.L(3000L, TimeUnit.MILLISECONDS);
                    p.h(rVar, "timeout(...)");
                    p.h(rVar.I(new d.f(C0205c.i), new d.f(pg.e.i)), "subscribe(...)");
                } else {
                    rVar = null;
                }
                s6 s6Var = (s6) this.s.a(this.i).f();
                if (!s6Var.b()) {
                    return s6Var;
                }
                if (rVar == null || ((b) x2.U4((l) null, new C0204a(rVar), 1, (Object) null)) != null) {
                    return a.h(this.q);
                }
                return u6.c("Couldn't set " + this.r + " as an assistant");
            }
        }

        static final class d extends q implements l<s6, e0> {
            final String i;

            d(String str) {
                super(1);
                this.i = str;
            }

            public final void a(s6 s6Var) {
                if (s6Var.b()) {
                    r7.f("ServiceVoiceInteractionTasker", "Set assistant to " + this.i + "!");
                    return;
                }
                r7.f("ServiceVoiceInteractionTasker", "Couldn't set assistant to " + this.i + ": " + s6Var.a());
            }

            public Object invoke(Object obj) {
                a((s6) obj);
                return e0.a;
            }
        }

        static final class e extends q implements l<l0, e0> {
            final Activity i;

            e(Activity activity) {
                super(1);
                this.i = activity;
            }

            public final void a(l0 l0Var) {
                p.i(l0Var, "dialogMessage");
                if (l0Var.k()) {
                    ActionEdit.q5(this.i, "secure_setting_grant", (String) null);
                }
                if (l0Var.o()) {
                    this.i.startActivity(sd.c());
                }
            }

            public Object invoke(Object obj) {
                a((l0) obj);
                return e0.a;
            }
        }

        public a(yj.h hVar) {
            this();
        }

        public static r g(a aVar, Context context, p1 p1Var, boolean z, int i, Object obj) {
            if ((i & 4) != 0) {
                z = true;
            }
            return aVar.f(context, p1Var, z);
        }

        public static final s6 h(b0 b0Var) {
            return u6.f(b0Var);
        }

        public static final void i(l lVar, Object obj) {
            p.i(lVar, "$tmp0");
            lVar.invoke(obj);
        }

        public final s6 c(Context context, VoiceAssistantRequest voiceAssistantRequest) {
            String str;
            p.i(context, "context");
            p.i(voiceAssistantRequest, "request");
            String packageName = context.getPackageName();
            p.f(packageName);
            Object f = g(this, context, new a0(context, packageName), false, 4, null).f();
            x6 x6Var = f instanceof x6 ? (x6) f : null;
            if (x6Var == null) {
                return u6.c("Could set Tasker as assistant");
            }
            if (!x6Var.b()) {
                r7.f("ServiceVoiceInteractionTasker", "Couldn't set assistant to " + packageName + ": " + x6Var.a());
                return x6Var;
            }
            r7.f("ServiceVoiceInteractionTasker", "Set assistant to " + packageName + " before assistant command!");
            p1 p1Var = (p1) x6Var.d();
            if (p1Var == null) {
                return u6.c("Couldn't check which app is assistant");
            }
            boolean z = !p.d(p1Var.getPackageName(), packageName);
            s6 s6Var = (s6) e(context, voiceAssistantRequest).f();
            if (!s6Var.b()) {
                Intent intent = voiceAssistantRequest.getIntent();
                str = intent != null ? intent.getAction() : null;
                r7.f("ServiceVoiceInteractionTasker", "Couldn't send assistant request " + str + " to " + packageName + ": " + x6Var.a());
                p.f(s6Var);
                return s6Var;
            }
            r7.f("ServiceVoiceInteractionTasker", "Sent assistant request with action " + voiceAssistantRequest.getAction() + "!");
            Object f2 = f(context, p1Var, z).f();
            str = f2 instanceof x6 ? (x6) f2 : null;
            if (str == null) {
                return u6.c("Could not set " + p1Var + " back as assistant");
            }
            if (str.b()) {
                r7.f("ServiceVoiceInteractionTasker", "Set assistant back to " + p1Var + " after assistant command!");
                return new v6();
            }
            r7.f("ServiceVoiceInteractionTasker", "Couldn't set assistant back to " + p1Var + ": " + x6Var.a());
            return str;
        }

        public final s6 d(Context context, int i, VoiceAssistantRequest voiceAssistantRequest) {
            p.i(context, "context");
            p.i(voiceAssistantRequest, "request");
            if (!com.joaomgcd.taskerm.util.k.a.F()) {
                return u6.c("Can only request with assistant on Marshmallow or above");
            }
            if (u.j(context) || ExtensionsContextKt.k0(context)) {
                return c(context, voiceAssistantRequest);
            }
            z1.A.m(context, "airplanemodeassistant", x2.Q4(i, context, new Object[0]), x2.Q4(2131890230, context, new Object[0]), new C0200a(context)).h();
            return u6.c("Couldn't request with assistant. Notification posted.");
        }

        public final r<s6> e(Context context, VoiceAssistantRequest voiceAssistantRequest) {
            p.i(context, "context");
            p.i(voiceAssistantRequest, "request");
            if (u.j(context)) {
                return w0.K0(new b(voiceAssistantRequest));
            }
            r<s6> w = r.w(u6.c("This app must be the current assistant app to do this"));
            p.h(w, "just(...)");
            return w;
        }

        public final r<s6> f(Context context, p1 p1Var, boolean z) {
            p.i(context, "context");
            p.i(p1Var, "assistantApp");
            b0 b0Var = new b0(context);
            String packageName = p1Var.getPackageName();
            r7.f("ServiceVoiceInteractionTasker", "Request to set assistant to " + packageName + "; currently: " + b0Var);
            if (!z) {
                r<s6> w = r.w(h(b0Var));
                p.h(w, "just(...)");
                return w;
            }
            r K0 = w0.K0(new c(context, b0Var, packageName, p1Var));
            final d dVar = new d(packageName);
            r<s6> m = K0.m(new oi.d() {
                public final void accept(Object obj) {
                    ServiceVoiceInteractionTasker.a.i(dVar, obj);
                }
            });
            p.h(m, "doAfterSuccess(...)");
            return m;
        }

        public final void j(Activity activity, int i) {
            p.i(activity, "context");
            if (com.joaomgcd.taskerm.util.k.a.n() || u.i(activity) || ExtensionsContextKt.k0(activity)) {
                return;
            }
            String Q4 = x2.Q4(i, activity, new Object[0]);
            if (jg.c.t(activity, z2.m(Q4), (SharedPreferences) null, 2, (Object) null)) {
                return;
            }
            w0.F1(com.joaomgcd.taskerm.dialog.a.t1(activity, i, 2131890230, 2131887517, 2131888744, Q4), activity, new e(activity));
        }

        private a() {
        }
    }

    public static final class b {
    }

    public static final class c {
        private final s6 a;

        public c(s6 s6Var) {
            p.i(s6Var, "simpleResult");
            this.a = s6Var;
        }

        public final s6 a() {
            return this.a;
        }
    }

    public static final class d {
        private final Context a;
        private final Bundle b;
        private final AssistStructure c;
        private final AssistContent d;
        private final Bundle e;

        public d(Context context, Bundle bundle, AssistStructure assistStructure, AssistContent assistContent, Bundle bundle2) {
            p.i(context, "context");
            this.a = context;
            this.b = bundle;
            this.c = assistStructure;
            this.d = assistContent;
            this.e = bundle2;
        }

        public final java.lang.String a() {
            throw new UnsupportedOperationException("Method not decompiled: com.joaomgcd.taskerm.assistant.ServiceVoiceInteractionTasker.d.a():java.lang.String");
        }

        public final java.lang.String b() {
            throw new UnsupportedOperationException("Method not decompiled: com.joaomgcd.taskerm.assistant.ServiceVoiceInteractionTasker.d.b():java.lang.String");
        }

        public final android.content.ComponentName c() {
            throw new UnsupportedOperationException("Method not decompiled: com.joaomgcd.taskerm.assistant.ServiceVoiceInteractionTasker.d.c():android.content.ComponentName");
        }

        public final k2 d() {
            k2 k2Var = new k2(201);
            ComponentName c = c();
            if (c != null) {
                k2Var.s1(0, c.getPackageName(), c.getClassName(), "");
            }
            Uri e = e();
            if (e != null) {
                k2Var.k0(1, e.toString());
            }
            String a = a();
            if (a != null) {
                k2Var.k0(3, a);
            }
            String b = b();
            if (b != null) {
                k2Var.k0(2, b);
            }
            return k2Var;
        }

        public final Uri e() {
            Uri webUri;
            AssistContent assistContent = this.d;
            if (assistContent == null) {
                return null;
            }
            webUri = assistContent.getWebUri();
            return webUri;
        }

        public d(Context context, Bundle bundle, AssistStructure assistStructure, AssistContent assistContent, Bundle bundle2, int i, yj.h hVar) {
            this(context, (i & 2) != 0 ? null : bundle, (i & 4) != 0 ? null : assistStructure, (i & 8) != 0 ? null : assistContent, (i & 16) != 0 ? null : bundle2);
        }
    }

    static final class e extends q implements xj.a<e0> {
        public static final e i = new e();

        e() {
            super(0);
        }

        public final void a() {
            pg.d.j(new b());
        }

        public Object invoke() {
            a();
            return e0.a;
        }
    }

    @Override
    public void onCreate() {
        super.onCreate();
        this.i.I();
    }

    @Override
    public void onDestroy() {
        pg.d.l(this);
        this.i.J();
        super.onDestroy();
    }

    @Override
    public void onReady() {
        super.onReady();
        this.i.O(pg.d.k(this), e.i);
    }

    @EventBusRxSubscription
    @Keep
    public final void onRequest(VoiceAssistantRequest voiceAssistantRequest) {
        p.i(voiceAssistantRequest, "request");
        if (voiceAssistantRequest instanceof VoiceAssistantRequestAssistInfo) {
            return;
        }
        Bundle bundle = new Bundle();
        bundle.putParcelable("request", voiceAssistantRequest);
        showSession(bundle, 0);
    }

    @EventBusRxSubscription
    @Keep
    public final void onRequestAssistInfo(VoiceAssistantRequestAssistInfo voiceAssistantRequestAssistInfo) {
        p.i(voiceAssistantRequestAssistInfo, "request");
        Bundle bundle = new Bundle();
        bundle.putParcelable("request", voiceAssistantRequestAssistInfo);
        showSession(bundle, 1);
    }
}