Bhakti v5.4.0 - UploadSessionJob.java 源代码

package com.smartlook.android.job.worker.session;

import A5.C;
import J5.g;
import L7.h;
import L7.v;
import android.app.job.JobInfo;
import android.app.job.JobParameters;
import android.app.job.JobService;
import android.content.ComponentName;
import android.content.Context;
import android.os.Handler;
import android.os.PersistableBundle;
import com.smartlook.b2;
import com.smartlook.b4;
import com.smartlook.c2;
import com.smartlook.i2;
import com.smartlook.i4;
import com.smartlook.k1;
import com.smartlook.k3;
import com.smartlook.m2;
import com.smartlook.q0;
import com.smartlook.sdk.storage.SessionRecordingStorage;
import com.smartlook.t0;
import com.smartlook.y;
import in.juspay.hyper.constants.LogCategory;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.collections.H;
import kotlin.collections.z;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.r;
import kotlin.text.StringsKt;
import mp.t;
import mp.u;
import org.json.JSONObject;
import z5.K;

@Metadata
public final class UploadSessionJob extends JobService implements i4 {
    public static final a b = new a(null);
    private Thread a;

    @Metadata
    public static final class a {
        public a(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }

        public final JobInfo.Builder a(Context context, int i, k3 k3Var) {
            Intrinsics.checkNotNullParameter(context, LogCategory.CONTEXT);
            Intrinsics.checkNotNullParameter(k3Var, "jobData");
            JobInfo.Builder builder = new JobInfo.Builder(i, new ComponentName(context, (Class<?>) UploadSessionJob.class));
            PersistableBundle persistableBundle = new PersistableBundle();
            persistableBundle.putString("DATA", k3Var.g().toString());
            JobInfo.Builder requiresCharging = builder.setExtras(persistableBundle).setRequiredNetworkType(k3Var.b() ? 1 : 2).setRequiresCharging(false);
            Intrinsics.checkNotNullExpressionValue(requiresCharging, "Builder(\n            job…etRequiresCharging(false)");
            return requiresCharging;
        }

        private a() {
        }
    }

    @Metadata
    public static final class b extends r implements Function0<m2<? extends Unit>> {
        final k3 b;
        final int c;

        public b(k3 k3Var, int i) {
            super(0);
            this.b = k3Var;
            this.c = i;
        }

        public final m2<Unit> invoke() {
            return UploadSessionJob.this.a(this.b, this.c);
        }
    }

    @Metadata
    public static final class c extends r implements Function0<String> {
        final k3 a;

        public c(k3 k3Var) {
            super(0);
            this.a = k3Var;
        }

        public final String invoke() {
            return "startUpload(): called with: sessionJobData = " + k1.a(this.a);
        }
    }

    @Metadata
    public static final class d extends r implements Function0<Unit> {
        final k3 b;
        final JobParameters c;

        @Metadata
        public static final class a extends r implements Function0<String> {
            final Exception a;
            final k3 b;

            public a(Exception exc, k3 k3Var) {
                super(0);
                this.a = exc;
                this.b = k3Var;
            }

            public final String invoke() {
                return "startUpload(): failed with exception: " + this.a + ", recordJobData = " + k1.a(this.b);
            }
        }

        public d(k3 k3Var, JobParameters jobParameters) {
            super(0);
            this.b = k3Var;
            this.c = jobParameters;
        }

        public final void a() {
            try {
                List<m2> a2 = UploadSessionJob.this.a(this.b);
                if (!(a2 instanceof Collection) || !a2.isEmpty()) {
                    for (m2 m2Var : a2) {
                        if ((m2Var instanceof m2.a) && !((m2.a) m2Var).c()) {
                            UploadSessionJob.this.jobFinished(this.c, true);
                            return;
                        }
                    }
                }
                UploadSessionJob.this.jobFinished(this.c, false);
            } catch (Exception e) {
                ArrayList arrayList = F7.d.a;
                a aVar = new a(e, this.b);
                Intrinsics.checkNotNullParameter("UploadSessionJob", "tag");
                Intrinsics.checkNotNullParameter(aVar, "message");
                F7.d.a(16777216L, true, 6, "UploadSessionJob", aVar, (Function0) null);
                UploadSessionJob.this.jobFinished(this.c, false);
            }
        }

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

    @Metadata
    public static final class e extends r implements Function1<m2<? extends Unit>, Unit> {
        final b4<m2<Unit>> a;
        final h b;

        public e(b4<m2<Unit>> b4Var, h hVar) {
            super(1);
            this.a = b4Var;
            this.b = hVar;
        }

        public final void a(m2<Unit> m2Var) {
            Intrinsics.checkNotNullParameter(m2Var, "it");
            this.a.a(m2Var);
            this.b.a();
        }

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

    private final SessionRecordingStorage c() {
        return y.a.C();
    }

    @Override
    public q0 b() {
        return y.a.D();
    }

    @Override
    public boolean onStartJob(JobParameters jobParameters) {
        a(jobParameters);
        return true;
    }

    @Override
    public boolean onStopJob(JobParameters jobParameters) {
        Thread thread = this.a;
        if (thread == null) {
            return true;
        }
        thread.interrupt();
        return true;
    }

    private final boolean b(String str, int i) {
        return c().isWireframeFileAvailable(str, i);
    }

    public void a(c2 c2Var, Function1<? super m2<Unit>, Unit> function1) {
        i4.a.a(this, c2Var, function1);
    }

    @Override
    public t0 a() {
        return y.a.K();
    }

    private final void a(JobParameters jobParameters) {
        Unit unit;
        PersistableBundle extras;
        String string;
        if (jobParameters == null || (extras = jobParameters.getExtras()) == null || (string = extras.getString("DATA")) == null) {
            unit = null;
        } else {
            k3 a2 = k3.g.a(new JSONObject(string));
            ArrayList arrayList = F7.d.a;
            F7.d.b(16777216L, "UploadSessionJob", new c(a2));
            this.a = v.a(new d(a2, jobParameters));
            unit = Unit.a;
        }
        if (unit == null) {
            jobFinished(jobParameters, false);
        }
    }

    public final List<m2<Unit>> a(k3 k3Var) {
        b2 j;
        List recordIndexes = c().getRecordIndexes(k3Var.d());
        ArrayList arrayList = new ArrayList();
        Iterator it = recordIndexes.iterator();
        while (true) {
            if (!it.hasNext()) {
                break;
            }
            String readRecord = c().readRecord(k3Var.d(), ((Number) it.next()).intValue());
            if (readRecord != null && !StringsKt.H(readRecord)) {
                try {
                    t tVar = mp.v.b;
                    j = b2.x.a(C.s(readRecord));
                } catch (Throwable th) {
                    t tVar2 = mp.v.b;
                    j = K.j(th);
                }
                r4 = j instanceof u ? null : j;
            }
            if (r4 != null) {
                arrayList.add(r4);
            }
        }
        ArrayList arrayList2 = new ArrayList();
        Iterator it2 = arrayList.iterator();
        while (it2.hasNext()) {
            b2 b2Var = (b2) it2.next();
            Integer valueOf = ((i2.b(b2Var.n()) ? a(k3Var.d(), b2Var.m()) : true) && (i2.a(b2Var.n()) ? b(k3Var.d(), b2Var.m()) : true)) ? Integer.valueOf(b2Var.m()) : null;
            if (valueOf != null) {
                arrayList2.add(valueOf);
            }
        }
        ArrayList arrayList3 = new ArrayList(z.q(arrayList2, 10));
        Iterator it3 = arrayList2.iterator();
        while (it3.hasNext()) {
            arrayList3.add(new b(k3Var, ((Number) it3.next()).intValue()));
        }
        Handler handler = v.a;
        Intrinsics.checkNotNullParameter(arrayList3, "tasks");
        ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(5);
        ArrayList arrayList4 = new ArrayList(z.q(arrayList3, 10));
        Iterator it4 = arrayList3.iterator();
        while (it4.hasNext()) {
            arrayList4.add(new g((Function0) it4.next(), 1));
        }
        Intrinsics.checkNotNullExpressionValue(newFixedThreadPool, "executors");
        Intrinsics.checkNotNullParameter(newFixedThreadPool, "<this>");
        Intrinsics.checkNotNullParameter(arrayList4, "tasks");
        ArrayList arrayList5 = new ArrayList(z.q(arrayList4, 10));
        Iterator it5 = arrayList4.iterator();
        while (it5.hasNext()) {
            arrayList5.add(new g((Callable) it5.next(), 2));
        }
        List invokeAll = newFixedThreadPool.invokeAll(arrayList5);
        Intrinsics.checkNotNullExpressionValue(invokeAll, "invokeAll(safeTasks)");
        ArrayList arrayList6 = new ArrayList(z.q(invokeAll, 10));
        Iterator it6 = invokeAll.iterator();
        while (it6.hasNext()) {
            arrayList6.add(((Future) it6.next()).get());
        }
        return arrayList6;
    }

    public final m2<Unit> a(k3 k3Var, int i) {
        b4 b4Var = new b4(null);
        h hVar = new h(1);
        a(new c2(k3Var.d(), i, k3Var.b(), k3Var.e(), k3Var.f(), k3Var.a(), k3Var.c()), new e(b4Var, hVar));
        hVar.d();
        m2<Unit> m2Var = (m2) b4Var.a();
        return m2Var == null ? new m2.a(500, H.a, null, null, 12, null) : m2Var;
    }

    private final boolean a(String str, int i) {
        return c().isVideoFileAvailable(str, i);
    }
}