Namma Yatri v3.3.7 - UploadSessionJob.java 源代码

package com.microsoft.clarity.jobs;

import android.app.job.JobParameters;
import android.app.job.JobService;
import android.content.Context;
import android.os.PersistableBundle;
import com.microsoft.clarity.b.a;
import com.microsoft.clarity.g.A;
import com.microsoft.clarity.g.L;
import com.microsoft.clarity.g.O;
import com.microsoft.clarity.g.P;
import com.microsoft.clarity.h.d;
import com.microsoft.clarity.h.e;
import com.microsoft.clarity.models.LogLevel;
import com.microsoft.clarity.models.SessionMetadata;
import com.microsoft.clarity.models.telemetry.ErrorType;
import com.microsoft.clarity.n.c;
import com.microsoft.clarity.q.l;
import java.io.FileNotFoundException;
import kotlin.jvm.internal.m;

public final class UploadSessionJob extends JobService {
    public static final int a = 0;

    public static final void a(UploadSessionJob uploadSessionJob, String projectId, PersistableBundle persistableBundle) {
        O o;
        uploadSessionJob.getClass();
        String sessionId = persistableBundle.getString("clarity_session_id");
        boolean z = persistableBundle.getBoolean("clarity_is_fallback");
        Object obj = a.a;
        Context applicationContext = uploadSessionJob.getApplicationContext();
        m.h(applicationContext, "applicationContext");
        A networkUsageTracker = a.a(applicationContext, persistableBundle.containsKey("clarity_max_daily_network_usage_mb") ? Long.valueOf(persistableBundle.getLong("clarity_max_daily_network_usage_mb", 0L)) : null);
        Context context = uploadSessionJob.getApplicationContext();
        m.h(context, "applicationContext");
        m.i(context, "context");
        m.i(projectId, "projectId");
        m.i(networkUsageTracker, "networkUsageTracker");
        synchronized (a.a) {
            try {
                if (a.j == null) {
                    a.j = new O(context, networkUsageTracker, projectId);
                }
                o = a.j;
                m.f(o);
            } catch (Throwable th) {
                throw th;
            }
        }
        if (sessionId == null) {
            l.d("Upload job started for all sessions.");
            o.a(!z);
            return;
        }
        LogLevel logLevel = l.a;
        l.d("Upload job started for session '" + sessionId + "'.");
        boolean z2 = z ^ true;
        o.getClass();
        m.i(sessionId, "sessionId");
        m.i(sessionId, "sessionId");
        SessionMetadata a2 = ((c) o.e).a(sessionId);
        if (a2 == null) {
            return;
        }
        try {
            String sessionId2 = a2.getSessionId();
            O.a(sessionId2, new L(o, a2, sessionId2, z2));
        } catch (Exception e) {
            if (e instanceof FileNotFoundException) {
                return;
            }
            o.c.a(e, ErrorType.UploadSession, null);
        }
    }

    @Override
    public final boolean onStartJob(JobParameters jobParameters) {
        PersistableBundle extras = jobParameters != null ? jobParameters.getExtras() : null;
        String string = extras != null ? extras.getString("clarity_project_id") : null;
        if (string == null) {
            jobFinished(jobParameters, false);
            return false;
        }
        P a2 = a.a();
        kotlin.jvm.internal.A a3 = new kotlin.jvm.internal.A();
        a2.a(new com.microsoft.clarity.h.c(this, extras, a3, string), new d(a3), new e(a3, this, jobParameters));
        return true;
    }

    @Override
    public final boolean onStopJob(JobParameters jobParameters) {
        return true;
    }
}