Tasker v6.6.3 - u.java 源代码

package ne;

import android.content.Context;
import com.joaomgcd.taskerm.util.ExtensionsContextKt;
import com.joaomgcd.taskerm.util.b7;
import com.joaomgcd.taskerm.util.bi;
import com.joaomgcd.taskerm.util.l7;
import com.joaomgcd.taskerm.util.ph;
import java.io.File;
import java.io.OutputStream;
import java.net.ConnectException;
import java.net.Socket;
import java.nio.charset.Charset;
import java.util.List;
import java.util.concurrent.TimeUnit;
import ne.u;
import net.dinglisch.android.taskerm.o7;

public final class u {
    public static final c f = new c(null);
    public static final int g = 8;
    private static Boolean h;
    private final Context a;
    private final vj.j b;
    private final vj.j c;
    private final vj.j d;
    private final vj.j e;

    public static class a {
        private final String a;
        private final int b;

        public a(String str, int i) {
            jk.p.i(str, "ip");
            this.a = str;
            this.b = i;
        }

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

        public final int b() {
            return this.b;
        }
    }

    public static final class b extends a {
        private final String c;
        private final Integer d;
        private final boolean e;
        private final boolean f;
        private final String g;
        private final OutputStream h;
        private final ik.l<e, vj.e0> i;

        public b(String str, int i, String str2, Integer num, boolean z, boolean z2, String str3, OutputStream outputStream, ik.l<? super e, vj.e0> lVar) {
            super(str, i);
            jk.p.i(str, "ip");
            jk.p.i(str2, "command");
            this.c = str2;
            this.d = num;
            this.e = z;
            this.f = z2;
            this.g = str3;
            this.h = outputStream;
            this.i = lVar;
        }

        public final String c() {
            return this.c;
        }

        public final ik.l<e, vj.e0> d() {
            return this.i;
        }

        public final boolean e() {
            return this.e;
        }

        public final OutputStream f() {
            return this.h;
        }

        public final String g() {
            return this.g;
        }

        public final Integer h() {
            return this.d;
        }

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

        public b(String str, int i, String str2, Integer num, boolean z, boolean z2, String str3, OutputStream outputStream, ik.l lVar, int i2, jk.h hVar) {
            this(str, i, str2, (i2 & 8) != 0 ? 1000 : num, (i2 & 16) != 0 ? false : z, (i2 & 32) != 0 ? false : z2, (i2 & 64) != 0 ? null : str3, (i2 & 128) != 0 ? null : outputStream, (i2 & 256) != 0 ? null : lVar);
        }
    }

    public static final class c {
        public c(jk.h hVar) {
            this();
        }

        public final String a(String str, String str2) {
            jk.p.i(str, "packageName");
            jk.p.i(str2, "className");
            return "cmd package set-home-activity \"" + str + "/" + str2 + "\"";
        }

        public final ti.r<Boolean> b(Context context) {
            jk.p.i(context, "context");
            return new u(context).C();
        }

        public final boolean c(Context context) {
            jk.p.i(context, "context");
            return new u(context).D();
        }

        private c() {
        }
    }

    public static final class d extends RuntimeException {
        public d() {
            super("Can't connect to ADB Wifi. Check here: https://tasker.joaoapps.com/userguide/en/help/ah_adb_wifi.html");
        }
    }

    public interface e {
        void h();
    }

    public static final class f implements e {
        final jk.j0<q2> a;
        final jk.j0<n2> b;
        final b c;
        final boolean d;
        final u e;
        final zg.v f;

        f(jk.j0<q2> j0Var, jk.j0<n2> j0Var2, b bVar, boolean z, u uVar, zg.v vVar) {
            this.a = j0Var;
            this.b = j0Var2;
            this.c = bVar;
            this.d = z;
            this.e = uVar;
            this.f = vVar;
        }

        @Override
        public void h() {
            u.J(this.a, this.b, this.c, this.d, this.e, this.f);
        }
    }

    public u(Context context) {
        jk.p.i(context, "context");
        this.a = context;
        this.b = vj.k.a(new ik.a() {
            public final Object e() {
                File H;
                H = u.H(u.this);
                return H;
            }
        });
        this.c = vj.k.a(new ik.a() {
            public final Object e() {
                File G;
                G = u.G(u.this);
                return G;
            }
        });
        this.d = vj.k.a(new ik.a() {
            public final Object e() {
                m2 v;
                v = u.v();
                return v;
            }
        });
        this.e = vj.k.a(new ik.a() {
            public final Object e() {
                o2 x;
                x = u.x(u.this);
                return x;
            }
        });
    }

    private final File A() {
        return (File) this.c.getValue();
    }

    private final File B() {
        return (File) this.b.getValue();
    }

    public static void F(u uVar, String str, Throwable th, int i, Object obj) {
        if ((i & 1) != 0) {
            th = null;
        }
        uVar.E(str, th);
    }

    public static final File G(u uVar) {
        return ph.H(uVar.a, "priv.key", (String) null, 2, (Object) null);
    }

    public static final File H(u uVar) {
        return ph.H(uVar.a, "pub.key", (String) null, 2, (Object) null);
    }

    public static final void J(jk.j0<q2> j0Var, jk.j0<n2> j0Var2, b bVar, boolean z, u uVar, zg.v vVar) {
        try {
            R("0", z, uVar, vVar);
            q2 q2Var = (q2) j0Var.i;
            if (q2Var != null) {
                q2Var.close();
            }
            n2 n2Var = (n2) j0Var2.i;
            if (n2Var != null) {
                n2Var.close();
            }
            OutputStream f2 = bVar.f();
            if (f2 != null) {
                f2.close();
            }
        } catch (Throwable unused) {
        }
    }

    public static final ti.r K(final b bVar, final u uVar, final boolean z, final zg.v vVar, final jk.j0 j0Var, final jk.j0 j0Var2) {
        String a2 = bVar.a();
        int b2 = bVar.b();
        String c2 = bVar.c();
        ExtensionsContextKt.M4(uVar.a, 375).i();
        R("1", z, uVar, vVar);
        try {
            n2 L = n2.L(new Socket(a2, b2), uVar.z());
            j0Var.i = L;
            L.J();
            jk.p.g(L, "null cannot be cast to non-null type com.joaomgcd.taskerm.adblib.AdbConnection");
            final q2 Q = L.Q("shell:");
            j0Var2.i = Q;
            Q.s(c2 + "\n");
            final StringBuilder sb2 = new StringBuilder();
            ti.r y1 = xg.e2.y1(new ik.a() {
                public final Object e() {
                    String M;
                    M = u.M(q2.this, bVar, sb2, j0Var2, j0Var, z, uVar, vVar);
                    return M;
                }
            });
            if (bVar.h() != null) {
                y1 = y1.L(bVar.h().intValue(), TimeUnit.MILLISECONDS);
            }
            final ik.l lVar = new ik.l() {
                public final Object invoke(Object obj) {
                    ti.v N;
                    N = u.N(sb2, bVar, (Throwable) obj);
                    return N;
                }
            };
            ti.r n = y1.C(new yi.e() {
                public final Object a(Object obj) {
                    ti.v O;
                    O = u.O(lVar, obj);
                    return O;
                }
            }).n(new yi.a() {
                public final void run() {
                    u.P(j0Var2, j0Var, bVar, z, uVar, vVar);
                }
            });
            jk.p.h(n, "doFinally(...)");
            return n;
        } catch (ConnectException unused) {
            h = null;
            throw new d();
        }
    }

    private static final String L(StringBuilder sb2, b bVar) {
        String sb3 = sb2.toString();
        jk.p.h(sb3, "toString(...)");
        String N0 = l7.N0(l7.N0(sb3, "\r"), "^@");
        if (bVar.e()) {
            N0 = kotlin.collections.t.n0(kotlin.collections.t.a0(kotlin.collections.t.Z(sk.q.J0(N0, new String[]{"\n"}, false, 0, 6, (Object) null), 2), 1), "\n", (CharSequence) null, (CharSequence) null, 0, (CharSequence) null, (ik.l) null, 62, (Object) null);
        }
        h = Boolean.TRUE;
        return N0;
    }

    public static final String M(q2 q2Var, b bVar, StringBuilder sb2, jk.j0 j0Var, jk.j0 j0Var2, boolean z, u uVar, zg.v vVar) {
        String str = null;
        while (!q2Var.e()) {
            try {
                byte[] i = q2Var.i();
                jk.p.f(i);
                String g2 = bVar.g();
                if (g2 == null) {
                    g2 = "US-ASCII";
                }
                Charset forName = Charset.forName(g2);
                jk.p.h(forName, "forName(...)");
                String str2 = new String(i, forName);
                OutputStream f2 = bVar.f();
                if (f2 != null) {
                    f2.write(i);
                }
                if (bVar.f() == null || str == null) {
                    sb2.append(str2);
                }
                if (str != null && sk.q.U(str2, str, false, 2, (Object) null)) {
                    break;
                }
                if (str == null) {
                    String sb3 = sb2.toString();
                    jk.p.h(sb3, "toString(...)");
                    int i2 = 0;
                    for (int i3 = 0; i3 < sb3.length(); i3++) {
                        if (sb3.charAt(i3) == '\n') {
                            i2++;
                        }
                    }
                    if (i2 >= 2) {
                        String sb4 = sb2.toString();
                        jk.p.h(sb4, "toString(...)");
                        str = sk.q.a1(l7.N0((String) sk.q.J0(sb4, new String[]{"\n"}, false, 0, 6, (Object) null).get(1), "^@"), ":/", (String) null, 2, (Object) null) + ":/ $";
                        if (sk.q.U(str2, "|" + str, false, 2, (Object) null)) {
                            break;
                        }
                    } else {
                        continue;
                    }
                }
            } finally {
                try {
                    return L(sb2, bVar);
                } finally {
                }
            }
        }
        return L(sb2, bVar);
    }

    public static final ti.v N(StringBuilder sb2, b bVar, Throwable th) {
        jk.p.i(th, "it");
        return ti.r.w(L(sb2, bVar));
    }

    public static final ti.v O(ik.l lVar, Object obj) {
        jk.p.i(obj, "p0");
        return (ti.v) lVar.invoke(obj);
    }

    public static final void P(jk.j0 j0Var, jk.j0 j0Var2, b bVar, boolean z, u uVar, zg.v vVar) {
        J(j0Var, j0Var2, bVar, z, uVar, vVar);
    }

    public static final void Q(jk.j0 j0Var, jk.j0 j0Var2, b bVar, boolean z, u uVar, zg.v vVar) {
        J(j0Var, j0Var2, bVar, z, uVar, vVar);
    }

    private static final void R(String str, boolean z, final u uVar, zg.v vVar) {
        if (z) {
            zg.g2.s(uVar.a, new zg.h1(vVar, str)).f();
            bi.b0(250L);
            if (jk.p.d(str, "1")) {
                xg.e2.k2(xg.e2.s1(new ik.a() {
                    public final Object e() {
                        ti.r S;
                        S = u.S(u.this);
                        return S;
                    }
                }), 3, 1L, TimeUnit.SECONDS, (ik.l) null, 8, (Object) null).f();
            }
        }
    }

    public static final ti.r S(u uVar) {
        ti.r L = uVar.C().L(2L, TimeUnit.SECONDS);
        final ik.l lVar = new ik.l() {
            public final Object invoke(Object obj) {
                Boolean T;
                T = u.T((Boolean) obj);
                return T;
            }
        };
        ti.r x = L.x(new yi.e() {
            public final Object a(Object obj) {
                Boolean U;
                U = u.U(lVar, obj);
                return U;
            }
        });
        jk.p.h(x, "map(...)");
        return x;
    }

    public static final Boolean T(Boolean bool) {
        jk.p.i(bool, "it");
        if (bool.booleanValue()) {
            return bool;
        }
        throw new RuntimeException("Can't enable debugging");
    }

    public static final Boolean U(ik.l lVar, Object obj) {
        jk.p.i(obj, "p0");
        return (Boolean) lVar.invoke(obj);
    }

    public static ti.r W(u uVar, String str, int i, boolean z, int i2, String str2, boolean z2, int i3, Object obj) {
        if ((i3 & 2) != 0) {
            i = 1000;
        }
        int i4 = i;
        boolean z3 = (i3 & 4) != 0 ? false : z;
        if ((i3 & 8) != 0) {
            i2 = com.joaomgcd.taskerm.settings.d1.n(uVar.a);
        }
        int i5 = i2;
        if ((i3 & 16) != 0) {
            str2 = "localhost";
        }
        return uVar.V(str, i4, z3, i5, str2, (i3 & 32) != 0 ? false : z2);
    }

    public static ti.r Y(u uVar, String str, int i, boolean z, int i2, String str2, boolean z2, int i3, Object obj) {
        if ((i3 & 2) != 0) {
            i = 1000;
        }
        int i4 = i;
        boolean z3 = (i3 & 4) != 0 ? false : z;
        if ((i3 & 8) != 0) {
            i2 = com.joaomgcd.taskerm.settings.d1.n(uVar.a);
        }
        int i5 = i2;
        if ((i3 & 16) != 0) {
            str2 = "localhost";
        }
        return uVar.X(str, i4, z3, i5, str2, (i3 & 32) != 0 ? false : z2);
    }

    public static final List Z(String str) {
        jk.p.i(str, "it");
        return sk.q.J0(str, new String[]{"\n"}, false, 0, 6, (Object) null);
    }

    public static final List a0(ik.l lVar, Object obj) {
        jk.p.i(obj, "p0");
        return (List) lVar.invoke(obj);
    }

    public static ti.r c0(u uVar, String str, int i, int i2, Object obj) {
        if ((i2 & 2) != 0) {
            i = 1000;
        }
        return uVar.b0(str, i);
    }

    public static final Boolean d0(String str) {
        jk.p.i(str, "it");
        return Boolean.TRUE;
    }

    public static final Boolean e0(ik.l lVar, Object obj) {
        jk.p.i(obj, "p0");
        return (Boolean) lVar.invoke(obj);
    }

    public static final ti.v f0(Throwable th) {
        jk.p.i(th, "it");
        return ti.r.w(Boolean.FALSE);
    }

    public static final ti.v g0(ik.l lVar, Object obj) {
        jk.p.i(obj, "p0");
        return (ti.v) lVar.invoke(obj);
    }

    public static final m2 v() {
        return new m2() {
            @Override
            public final String a(byte[] bArr) {
                String w;
                w = u.w(bArr);
                return w;
            }
        };
    }

    public static final String w(byte[] bArr) {
        jk.p.f(bArr);
        return b7.E1(bArr);
    }

    public static final ne.o2 x(ne.u r5) {
        throw new UnsupportedOperationException("Method not decompiled: ne.u.x(ne.u):ne.o2");
    }

    private final m2 y() {
        return (m2) this.d.getValue();
    }

    private final o2 z() {
        return (o2) this.e.getValue();
    }

    public final ti.r<Boolean> C() {
        return c0(this, "test", 0, 2, null);
    }

    public final boolean D() {
        Boolean bool = h;
        if (bool != null) {
            boolean booleanValue = bool.booleanValue();
            o7.f("ADB", "isAdbWifiAvailableWithCacheIfNeeded with cache: " + booleanValue);
            return booleanValue;
        }
        if (xg.e2.T1()) {
            o7.f("ADB", "isAdbWifiAvailableWithCacheIfNeeded ui thread: true");
            return true;
        }
        Boolean bool2 = (Boolean) c0(this, "test", 0, 2, null).f();
        o7.f("ADB", "isAdbWifiAvailableWithCacheIfNeeded no cache: " + bool2);
        jk.p.f(bool2);
        return bool2.booleanValue();
    }

    public final void E(String str, Throwable th) {
        o7.g("ADB", str, th);
    }

    public final ti.r<String> I(final b bVar) {
        zg.v vVar;
        jk.p.i(bVar, "args");
        final jk.j0 j0Var = new jk.j0();
        final jk.j0 j0Var2 = new jk.j0();
        zg.v vVar2 = new zg.v(zg.f1.v, "adb_enabled", false, 0, 0, 28, (jk.h) null);
        final boolean z = bVar.i() && !jk.p.d(zg.g2.o(this.a, vVar2).f(), "1");
        ik.l<e, vj.e0> d2 = bVar.d();
        if (d2 != null) {
            vVar = vVar2;
            d2.invoke(new f(j0Var2, j0Var, bVar, z, this, vVar2));
        } else {
            vVar = vVar2;
        }
        final zg.v vVar3 = vVar;
        final zg.v vVar4 = vVar;
        ti.r<String> n = xg.e2.s1(new ik.a() {
            public final Object e() {
                ti.r K;
                K = u.K(u.b.this, this, z, vVar3, j0Var, j0Var2);
                return K;
            }
        }).n(new yi.a() {
            public final void run() {
                u.Q(j0Var2, j0Var, bVar, z, this, vVar4);
            }
        });
        jk.p.h(n, "doFinally(...)");
        return n;
    }

    public final ti.r<String> V(String str, int i, boolean z, int i2, String str2, boolean z2) {
        jk.p.i(str, "command");
        jk.p.i(str2, "host");
        return I(new b(str2, i2, str, Integer.valueOf(i), z, z2, null, null, null, 448, null));
    }

    public final ti.r<List<String>> X(String str, int i, boolean z, int i2, String str2, boolean z2) {
        jk.p.i(str, "command");
        jk.p.i(str2, "host");
        ti.r<String> V = V(str, i, z, i2, str2, z2);
        final ik.l lVar = new ik.l() {
            public final Object invoke(Object obj) {
                List Z;
                Z = u.Z((String) obj);
                return Z;
            }
        };
        ti.r<List<String>> x = V.x(new yi.e() {
            public final Object a(Object obj) {
                List a0;
                a0 = u.a0(lVar, obj);
                return a0;
            }
        });
        jk.p.h(x, "map(...)");
        return x;
    }

    public final ti.r<Boolean> b0(String str, int i) {
        jk.p.i(str, "command");
        try {
            ti.r W = W(this, str, i, false, 0, null, false, 60, null);
            final ik.l lVar = new ik.l() {
                public final Object invoke(Object obj) {
                    Boolean d0;
                    d0 = u.d0((String) obj);
                    return d0;
                }
            };
            ti.r x = W.x(new yi.e() {
                public final Object a(Object obj) {
                    Boolean e0;
                    e0 = u.e0(lVar, obj);
                    return e0;
                }
            });
            final ik.l lVar2 = new ik.l() {
                public final Object invoke(Object obj) {
                    ti.v f0;
                    f0 = u.f0((Throwable) obj);
                    return f0;
                }
            };
            ti.r<Boolean> C = x.C(new yi.e() {
                public final Object a(Object obj) {
                    ti.v g0;
                    g0 = u.g0(lVar2, obj);
                    return g0;
                }
            });
            jk.p.f(C);
            return C;
        } catch (Throwable unused) {
            ti.r<Boolean> w = ti.r.w(Boolean.FALSE);
            jk.p.f(w);
            return w;
        }
    }
}