package b7;

import android.app.job.JobInfo;
import android.app.job.JobScheduler;
import android.content.ComponentName;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.os.PersistableBundle;
import android.util.Base64;
import android.util.Log;
import com.google.android.datatransport.Priority;
import com.google.android.datatransport.runtime.scheduling.jobscheduling.JobInfoSchedulerService;
import com.google.android.datatransport.runtime.scheduling.jobscheduling.SchedulerConfig$Flag;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Set;
import java.util.zip.Adler32;
import v6.l;
import v6.v;

/* JADX INFO: loaded from: classes2.dex */
public final class d implements j {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Context f4738a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final c7.d f4739b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final b f4740c;

    public d(Context context, c7.d dVar, b bVar) {
        this.f4738a = context;
        this.f4739b = dVar;
        this.f4740c = bVar;
    }

    public final void a(v vVar, int i10, boolean z10) {
        Context context = this.f4738a;
        ComponentName componentName = new ComponentName(context, (Class<?>) JobInfoSchedulerService.class);
        JobScheduler jobScheduler = (JobScheduler) context.getSystemService("jobscheduler");
        Adler32 adler32 = new Adler32();
        adler32.update(context.getPackageName().getBytes(Charset.forName("UTF-8")));
        l lVar = (l) vVar;
        adler32.update(lVar.f33708a.getBytes(Charset.forName("UTF-8")));
        adler32.update(ByteBuffer.allocate(4).putInt(f7.a.a(lVar.f33710c)).array());
        if (vVar.getExtras() != null) {
            adler32.update(vVar.getExtras());
        }
        int value = (int) adler32.getValue();
        if (!z10) {
            Iterator<JobInfo> it = jobScheduler.getAllPendingJobs().iterator();
            while (true) {
                if (!it.hasNext()) {
                    break;
                }
                JobInfo next = it.next();
                int i11 = next.getExtras().getInt("attemptNumber");
                if (next.getId() == value) {
                    if (i11 >= i10) {
                        com.bumptech.glide.g.c("JobInfoScheduler", "Upload for context %s is already scheduled. Returning...", vVar);
                        return;
                    }
                }
            }
        }
        SQLiteDatabase sQLiteDatabaseP = ((c7.l) this.f4739b).p();
        l lVar2 = (l) vVar;
        Priority priority = lVar2.f33710c;
        String strValueOf = String.valueOf(f7.a.a(priority));
        String str = lVar2.f33708a;
        long jLongValue = ((Long) c7.l.N(sQLiteDatabaseP.rawQuery("SELECT next_request_ms FROM transport_contexts WHERE backend_name = ? and priority = ?", new String[]{str, strValueOf}), new c7.g(1))).longValue();
        JobInfo.Builder builder = new JobInfo.Builder(value, componentName);
        b bVar = this.f4740c;
        builder.setMinimumLatency(bVar.a(priority, jLongValue, i10));
        Set set = ((c) bVar.f4734b.get(priority)).f4737c;
        if (set.contains(SchedulerConfig$Flag.f7763a)) {
            builder.setRequiredNetworkType(2);
        } else {
            builder.setRequiredNetworkType(1);
        }
        if (set.contains(SchedulerConfig$Flag.f7765c)) {
            builder.setRequiresCharging(true);
        }
        if (set.contains(SchedulerConfig$Flag.f7764b)) {
            builder.setRequiresDeviceIdle(true);
        }
        PersistableBundle persistableBundle = new PersistableBundle();
        persistableBundle.putInt("attemptNumber", i10);
        persistableBundle.putString("backendName", str);
        persistableBundle.putInt("priority", f7.a.a(priority));
        if (vVar.getExtras() != null) {
            persistableBundle.putString("extras", Base64.encodeToString(vVar.getExtras(), 0));
        }
        builder.setExtras(persistableBundle);
        Object[] objArr = {vVar, Integer.valueOf(value), Long.valueOf(bVar.a(priority, jLongValue, i10)), Long.valueOf(jLongValue), Integer.valueOf(i10)};
        if (Log.isLoggable(com.bumptech.glide.g.k("JobInfoScheduler"), 3)) {
            String.format("Scheduling upload for context %s with jobId=%d in %dms(Backend next call timestamp %d). Attempt %d", objArr);
        }
        jobScheduler.schedule(builder.build());
    }
}