Crafto v9.3.3 - PreCacheService.java 源代码

package com.phonepe.intent.sdk.ui;

import B.d;
import C1.q;
import Xn.b;
import Xn.c;
import Xn.k;
import Xn.n;
import Xn.p;
import android.app.IntentService;
import android.content.Intent;
import android.text.TextUtils;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import jmjou.jmjou;
import org.json.JSONArray;
import org.json.JSONObject;
import xl.t;

public class PreCacheService extends IntentService {
    public jmjou a;

    public class a implements n {
        public final CountDownLatch a;

        public a(CountDownLatch countDownLatch) {
            this.a = countDownLatch;
        }

        public final void b(String str) {
            this.a.countDown();
        }

        public final void m(int i, String str) {
            this.a.countDown();
        }
    }

    public PreCacheService() {
        super("PreCacheService");
        xl.a.e("PreCacheService", "service is created");
    }

    @Override
    public final void onHandleIntent(Intent intent) {
        String a2;
        int i;
        jmjou parcelableExtra = intent.getParcelableExtra("data_factory");
        this.a = parcelableExtra;
        if (parcelableExtra == null) {
            return;
        }
        co.a d = parcelableExtra.d(co.a.class);
        if (!d.b.b().getBoolean("isPrecacheEnabled", true)) {
            xl.a.c("PreCacheService", "Precache has been disabled by config");
            return;
        }
        b d2 = this.a.d(b.class);
        if (!t.l(this.a)) {
            xl.a.b("PreCacheService", "service failed to set up http response cache. returning ..");
            return;
        }
        xl.a.a("PreCacheService", "fetching asset stats");
        if (d.b.b().getString("precacheUrl", null) == null || d.b.b().getString("precacheUrl", null).equals("")) {
            this.a.getClass();
            boolean j = t.j((Boolean) jmjou.f("com.phonepe.android.sdk.isUAT"));
            HashSet hashSet = p.a;
            a2 = d.a(new StringBuilder(), (j ? p.a.cqqlq : p.a.chmha).irjuc, "/app/asset-stats");
        } else {
            a2 = d.b.b().getString("precacheUrl", null);
        }
        jmjou jmjouVar = d2.a;
        jmjouVar.getClass();
        HashMap hashMap = new HashMap();
        jmjou.a d3 = jmjouVar.d(jmjou.a.class);
        d3.put("url", a2);
        Boolean bool = Boolean.FALSE;
        d3.put("isPost", bool);
        d3.put("useCache", bool);
        d3.put("defaultCache", bool);
        d3.put("headers", hashMap);
        d3.put("body", null);
        b.a b = jmjouVar.e(k.class, d3).b();
        if (!b.c) {
            xl.a.b("PreCacheService", "pre caching attempt failed, returning. network request failed, network response = {" + b.b + "}.");
            return;
        }
        String str = b.b;
        this.a.getClass();
        JSONObject b2 = jmjou.b(str);
        if (b2 == null || !b2.has("assetUrlList")) {
            xl.a.b("PreCacheService", "either asset stats is null or does not have any asset url");
            return;
        }
        JSONArray jSONArray = (JSONArray) co.b.get(b2, "assetUrlList");
        if (jSONArray == null || jSONArray.length() == 0) {
            xl.a.b("PreCacheService", "either assetUrlList is null or empty");
            return;
        }
        int length = jSONArray.length();
        CountDownLatch countDownLatch = new CountDownLatch(length);
        int i2 = 0;
        while (i2 < length) {
            String str2 = (String) co.b.get(jSONArray, i2);
            if (TextUtils.isEmpty(str2)) {
                xl.a.b("PreCacheService", "asset url is null or empty");
                countDownLatch.countDown();
                i = i2;
            } else {
                i = i2;
                new c(d2, str2, false, true, (Map) null, (String) null, new a(countDownLatch)).executeOnExecutor(d2.b, new Void[0]);
            }
            i2 = i + 1;
        }
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            xl.a.d("PreCacheService", q.a("thread got interrupted with message = {", e.getMessage(), "} , letch count = {", Long.toString(countDownLatch.getCount()), "}"), e);
        }
    }
}