Bhakti v5.4.0 - UploadInternalLogJob.java 源代码

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

import A5.C;
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.PersistableBundle;
import com.smartlook.c1;
import com.smartlook.e1;
import com.smartlook.g4;
import com.smartlook.k1;
import com.smartlook.m2;
import com.smartlook.y;
import in.juspay.hyper.constants.LogCategory;
import java.util.ArrayList;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.Unit;
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 mp.m;
import mp.o;

@Metadata
public final class UploadInternalLogJob extends JobService {
    public static final a c = new a(null);
    private static final long d = TimeUnit.DAYS.toMillis(1);
    private final m a = o.b(b.a);
    private final m b = o.b(c.a);

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

        public final JobInfo.Builder a(Context context, g4 g4Var) {
            Intrinsics.checkNotNullParameter(context, LogCategory.CONTEXT);
            Intrinsics.checkNotNullParameter(g4Var, "jobData");
            JobInfo.Builder builder = new JobInfo.Builder(2147483646, new ComponentName(context, (Class<?>) UploadInternalLogJob.class));
            builder.setRequiredNetworkType(1);
            builder.setRequiresCharging(false);
            builder.setPeriodic(UploadInternalLogJob.d);
            PersistableBundle persistableBundle = new PersistableBundle();
            persistableBundle.putString("DATA", g4Var.c().toString());
            builder.setExtras(persistableBundle);
            return builder;
        }

        private a() {
        }
    }

    @Metadata
    public static final class b extends r implements Function0<c1> {
        public static final b a = new b();

        public b() {
            super(0);
        }

        public final c1 invoke() {
            return y.a.m();
        }
    }

    @Metadata
    public static final class c extends r implements Function0<e1> {
        public static final c a = new c();

        public c() {
            super(0);
        }

        public final e1 invoke() {
            return y.a.n();
        }
    }

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

        public d(JobParameters jobParameters) {
            super(0);
            this.a = jobParameters;
        }

        public final String invoke() {
            return "onStartJob() called with: params = " + this.a;
        }
    }

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

        public e(JobParameters jobParameters) {
            super(0);
            this.a = jobParameters;
        }

        public final String invoke() {
            return "onStopJob() called with: params = " + this.a;
        }
    }

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

        public f(String str) {
            super(0);
            this.a = str;
        }

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

    @Metadata
    public static final class g extends r implements Function1<m2<? extends Unit>, Unit> {
        final JobParameters b;

        public g(JobParameters jobParameters) {
            super(1);
            this.b = jobParameters;
        }

        public final void a(m2<Unit> m2Var) {
            Intrinsics.checkNotNullParameter(m2Var, "result");
            UploadInternalLogJob.this.jobFinished(this.b, (m2Var instanceof m2.a) && !((m2.a) m2Var).c());
        }

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

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

        @Metadata
        public static final class a extends r implements Function0<String> {
            public static final a a = new a();

            public a() {
                super(0);
            }

            public final String invoke() {
                return "upload(): successful";
            }
        }

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

            public b(m2<Unit> m2Var) {
                super(0);
                this.a = m2Var;
            }

            public final String invoke() {
                return "upload(): failed: response = " + k1.a((m2.a) this.a);
            }
        }

        @Metadata
        public static final class c extends r implements Function0<String> {
            public static final c a = new c();

            public c() {
                super(0);
            }

            public final String invoke() {
                return "upload(): failed and cannot be recovered -> deleting internal logs";
            }
        }

        public h(Function1<? super m2<Unit>, Unit> function1) {
            super(1);
            this.b = function1;
        }

        public final void a(m2<Unit> m2Var) {
            Intrinsics.checkNotNullParameter(m2Var, "it");
            if (m2Var instanceof m2.b) {
                ArrayList arrayList = F7.d.a;
                F7.d.b(8388608L, "UploadInternalLogJob", a.a);
                UploadInternalLogJob.this.c().c();
                this.b.invoke(m2Var);
                return;
            }
            if (m2Var instanceof m2.a) {
                ArrayList arrayList2 = F7.d.a;
                F7.d.b(8388608L, "UploadInternalLogJob", new b(m2Var));
                if (((m2.a) m2Var).c()) {
                    F7.d.b(8388608L, "UploadInternalLogJob", c.a);
                    UploadInternalLogJob.this.c().c();
                }
                this.b.invoke(m2Var);
            }
        }

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

    private final c1 b() {
        return (c1) this.a.getValue();
    }

    public final e1 c() {
        return (e1) this.b.getValue();
    }

    @Override
    public boolean onStartJob(JobParameters jobParameters) {
        ArrayList arrayList = F7.d.a;
        F7.d.b(8388608L, "UploadInternalLogJob", new d(jobParameters));
        a(jobParameters);
        return true;
    }

    @Override
    public boolean onStopJob(JobParameters jobParameters) {
        ArrayList arrayList = F7.d.a;
        F7.d.b(8388608L, "UploadInternalLogJob", new e(jobParameters));
        return true;
    }

    private final void a(JobParameters jobParameters) {
        PersistableBundle extras;
        String string;
        Unit unit = null;
        if (jobParameters != null && (extras = jobParameters.getExtras()) != null && (string = extras.getString("DATA")) != null) {
            g4 a2 = g4.c.a(C.s(string));
            String e2 = c().e();
            if (e2 != null) {
                ArrayList arrayList = F7.d.a;
                F7.d.b(8388608L, "UploadInternalLogJob", new f(e2));
                a(a2.b(), e2, a2.a(), new g(jobParameters));
                unit = Unit.a;
            }
            if (unit == null) {
                jobFinished(jobParameters, false);
            }
            unit = Unit.a;
        }
        if (unit == null) {
            jobFinished(jobParameters, false);
        }
    }

    private final void a(String str, String str2, String str3, Function1<? super m2<Unit>, Unit> function1) {
        b().a(str, str2, str3, new h(function1));
    }
}