%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD%EF%BF%BD.apk(点击下载) / cv.java


package com.xiaomi.push;

import android.app.ActivityManager;
import android.content.Context;
import android.content.pm.PackageInfo;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.net.Uri;
import android.os.Process;
import android.text.TextUtils;
import com.huawei.hms.push.constant.RemoteMessageConst;
import com.meizu.cloud.pushsdk.constants.PushConstants;
import com.umeng.analytics.pro.ak;
import com.umeng.analytics.pro.bz;
import com.xiaomi.mipush.sdk.Constants;
import com.xiaomi.push.service.module.PushChannelRegion;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.Closeable;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

public class cv {
    protected static Context a;

    /* renamed from: a  reason: collision with other field name */
    private static a f6823a;

    /* renamed from: a  reason: collision with other field name */
    private static cv f6824a;

    /* renamed from: a  reason: collision with other field name */
    protected static boolean f6825a = false;
    protected static final Map<String, cr> b = new HashMap();
    private static String c;
    private static String d;

    /* renamed from: a  reason: collision with other field name */
    private long f6826a;

    /* renamed from: a  reason: collision with other field name */
    private cu f6827a;

    /* renamed from: a  reason: collision with other field name */
    protected b f6828a;

    /* renamed from: a  reason: collision with other field name */
    private String f6829a;

    /* renamed from: a  reason: collision with other field name */
    protected final Map<String, cs> f6830a;

    /* renamed from: b  reason: collision with other field name */
    private final long f6831b;

    /* renamed from: b  reason: collision with other field name */
    private String f6832b;

    /* renamed from: c  reason: collision with other field name */
    private long f6833c;

    public interface a {
        cv a(Context context, cu cuVar, b bVar, String str);
    }

    public interface b {
        String a(String str);
    }

    protected cv(Context context, cu cuVar, b bVar, String str) {
        this(context, cuVar, bVar, str, null, null);
    }

    protected cv(Context context, cu cuVar, b bVar, String str, String str2, String str3) {
        this.f6830a = new HashMap();
        this.f6829a = PushConstants.PUSH_TYPE_NOTIFY;
        this.f6826a = 0;
        this.f6831b = 15;
        this.f6833c = 0;
        this.f6832b = "isp_prov_city_country_ip";
        this.f6828a = bVar;
        this.f6827a = cuVar == null ? new cw(this) : cuVar;
        this.f6829a = str;
        c = str2 == null ? context.getPackageName() : str2;
        d = str3 == null ? f() : str3;
    }

    public static synchronized cv a() {
        cv cvVar;
        synchronized (cv.class) {
            if (f6824a != null) {
                cvVar = f6824a;
            } else {
                throw new IllegalStateException("the host manager is not initialized yet.");
            }
        }
        return cvVar;
    }

    /* renamed from: a  reason: collision with other method in class */
    static String m9209a() {
        NetworkInfo activeNetworkInfo;
        Context context = a;
        if (context == null) {
            return "unknown";
        }
        try {
            ConnectivityManager connectivityManager = (ConnectivityManager) context.getSystemService("connectivity");
            if (connectivityManager == null || (activeNetworkInfo = connectivityManager.getActiveNetworkInfo()) == null) {
                return "unknown";
            }
            if (activeNetworkInfo.getType() == 1) {
                return "WIFI-UNKNOWN";
            }
            return activeNetworkInfo.getTypeName() + Constants.ACCEPT_TIME_SEPARATOR_SERVER + activeNetworkInfo.getSubtypeName();
        } catch (Throwable unused) {
            return "unknown";
        }
    }

    static String a(String str) {
        try {
            int length = str.length();
            byte[] bytes = str.getBytes("UTF-8");
            for (int i = 0; i < bytes.length; i++) {
                byte b2 = bytes[i];
                int i2 = b2 & 240;
                if (i2 != 240) {
                    bytes[i] = (byte) (((b2 & bz.m) ^ ((byte) (((b2 >> 4) + length) & 15))) | i2);
                }
            }
            return new String(bytes);
        } catch (UnsupportedEncodingException unused) {
            return str;
        }
    }

    private ArrayList<cr> a(ArrayList<String> arrayList) {
        JSONObject jSONObject;
        JSONObject jSONObject2;
        m9218d();
        synchronized (this.f6830a) {
            m9214a();
            for (String str : this.f6830a.keySet()) {
                if (!arrayList.contains(str)) {
                    arrayList.add(str);
                }
            }
        }
        synchronized (b) {
            for (Object obj : b.values().toArray()) {
                cr crVar = (cr) obj;
                if (!crVar.b()) {
                    b.remove(crVar.f6820b);
                }
            }
        }
        if (!arrayList.contains(b())) {
            arrayList.add(b());
        }
        ArrayList<cr> arrayList2 = new ArrayList<>(arrayList.size());
        for (int i = 0; i < arrayList.size(); i++) {
            arrayList2.add(null);
        }
        try {
            String str2 = bj.e(a) ? "wifi" : "wap";
            String a2 = a(arrayList, str2, this.f6829a, true);
            if (!TextUtils.isEmpty(a2)) {
                JSONObject jSONObject3 = new JSONObject(a2);
                com.xiaomi.channel.commonutils.logger.b.b(a2);
                if ("OK".equalsIgnoreCase(jSONObject3.getString("S"))) {
                    JSONObject jSONObject4 = jSONObject3.getJSONObject("R");
                    String string = jSONObject4.getString("province");
                    String string2 = jSONObject4.getString("city");
                    String string3 = jSONObject4.getString("isp");
                    String string4 = jSONObject4.getString("ip");
                    String string5 = jSONObject4.getString(ak.O);
                    JSONObject jSONObject5 = jSONObject4.getJSONObject(str2);
                    com.xiaomi.channel.commonutils.logger.b.c("get bucket: net=" + string3 + ", hosts=" + jSONObject5.toString());
                    int i2 = 0;
                    while (i2 < arrayList.size()) {
                        String str3 = arrayList.get(i2);
                        JSONArray optJSONArray = jSONObject5.optJSONArray(str3);
                        if (optJSONArray == null) {
                            com.xiaomi.channel.commonutils.logger.b.m9051a("no bucket found for " + str3);
                            jSONObject = jSONObject5;
                        } else {
                            cr crVar2 = new cr(str3);
                            int i3 = 0;
                            while (i3 < optJSONArray.length()) {
                                String string6 = optJSONArray.getString(i3);
                                if (!TextUtils.isEmpty(string6)) {
                                    jSONObject2 = jSONObject5;
                                    crVar2.a(new da(string6, optJSONArray.length() - i3));
                                } else {
                                    jSONObject2 = jSONObject5;
                                }
                                i3++;
                                jSONObject5 = jSONObject2;
                            }
                            jSONObject = jSONObject5;
                            arrayList2.set(i2, crVar2);
                            crVar2.g = string5;
                            crVar2.c = string;
                            crVar2.e = string3;
                            crVar2.f = string4;
                            crVar2.d = string2;
                            if (jSONObject4.has("stat-percent")) {
                                crVar2.a(jSONObject4.getDouble("stat-percent"));
                            }
                            if (jSONObject4.has("stat-domain")) {
                                crVar2.b(jSONObject4.getString("stat-domain"));
                            }
                            if (jSONObject4.has(RemoteMessageConst.TTL)) {
                                crVar2.a(((long) jSONObject4.getInt(RemoteMessageConst.TTL)) * 1000);
                            }
                            m9213a(crVar2.a());
                        }
                        i2++;
                        jSONObject5 = jSONObject;
                    }
                    JSONObject optJSONObject = jSONObject4.optJSONObject("reserved");
                    if (optJSONObject != null) {
                        long j = 604800000;
                        if (jSONObject4.has("reserved-ttl")) {
                            j = ((long) jSONObject4.getInt("reserved-ttl")) * 1000;
                        }
                        Iterator<String> keys = optJSONObject.keys();
                        while (keys.hasNext()) {
                            String next = keys.next();
                            JSONArray optJSONArray2 = optJSONObject.optJSONArray(next);
                            if (optJSONArray2 == null) {
                                com.xiaomi.channel.commonutils.logger.b.m9051a("no bucket found for " + next);
                            } else {
                                cr crVar3 = new cr(next);
                                crVar3.a(j);
                                for (int i4 = 0; i4 < optJSONArray2.length(); i4++) {
                                    String string7 = optJSONArray2.getString(i4);
                                    if (!TextUtils.isEmpty(string7)) {
                                        crVar3.a(new da(string7, optJSONArray2.length() - i4));
                                    }
                                }
                                synchronized (b) {
                                    if (this.f6827a.a(next)) {
                                        b.put(next, crVar3);
                                    }
                                }
                            }
                        }
                    }
                }
            }
        } catch (Exception e) {
            com.xiaomi.channel.commonutils.logger.b.m9051a("failed to get bucket " + e.getMessage());
        }
        for (int i5 = 0; i5 < arrayList.size(); i5++) {
            cr crVar4 = arrayList2.get(i5);
            if (crVar4 != null) {
                a(arrayList.get(i5), crVar4);
            }
        }
        m9217c();
        return arrayList2;
    }

    public static synchronized void a(Context context, cu cuVar, b bVar, String str, String str2, String str3) {
        synchronized (cv.class) {
            Context applicationContext = context.getApplicationContext();
            a = applicationContext;
            if (applicationContext == null) {
                a = context;
            }
            if (f6824a == null) {
                if (f6823a == null) {
                    f6824a = new cv(context, cuVar, bVar, str, str2, str3);
                    return;
                }
                f6824a = f6823a.a(context, cuVar, bVar, str);
            }
        }
    }

    public static synchronized void a(a aVar) {
        synchronized (cv.class) {
            f6823a = aVar;
            f6824a = null;
        }
    }

    public static void a(String str, String str2) {
        cr crVar = b.get(str);
        synchronized (b) {
            if (crVar == null) {
                cr crVar2 = new cr(str);
                crVar2.a(604800000L);
                crVar2.m9202a(str2);
                b.put(str, crVar2);
            } else {
                crVar.m9202a(str2);
            }
        }
    }

    private String f() {
        try {
            PackageInfo packageInfo = a.getPackageManager().getPackageInfo(a.getPackageName(), 16384);
            return packageInfo != null ? packageInfo.versionName : PushConstants.PUSH_TYPE_NOTIFY;
        } catch (Exception unused) {
            return PushConstants.PUSH_TYPE_NOTIFY;
        }
    }

    /* renamed from: a  reason: collision with other method in class */
    public cr m9210a(String str) {
        if (!TextUtils.isEmpty(str)) {
            return a(new URL(str).getHost(), true);
        }
        throw new IllegalArgumentException("the url is empty");
    }

    public cr a(String str, boolean z) {
        cr e;
        if (TextUtils.isEmpty(str)) {
            throw new IllegalArgumentException("the host is empty");
        } else if (!this.f6827a.a(str)) {
            return null;
        } else {
            cr c2 = c(str);
            return (c2 == null || !c2.b()) ? (!z || !bj.b(a) || (e = e(str)) == null) ? new cx(this, str, c2) : e : c2;
        }
    }

    public String a(ArrayList<String> arrayList, String str, String str2, boolean z) {
        ArrayList<String> arrayList2 = new ArrayList<>();
        ArrayList<bi> arrayList3 = new ArrayList();
        arrayList3.add(new bg("type", str));
        if (str.equals("wap")) {
            arrayList3.add(new bg("conpt", a(bj.m9153a(a))));
        }
        if (z) {
            arrayList3.add(new bg("reserved", "1"));
        }
        arrayList3.add(new bg("uuid", str2));
        arrayList3.add(new bg("list", bp.a(arrayList, Constants.ACCEPT_TIME_SEPARATOR_SP)));
        arrayList3.add(new bg("countrycode", com.xiaomi.push.service.a.a(a).b()));
        cr c2 = c(b());
        String format = String.format(Locale.US, "https://%1$s/gslb/?ver=4.0", b());
        if (c2 == null) {
            arrayList2.add(format);
            synchronized (b) {
                cr crVar = b.get("resolver.msg.xiaomi.net");
                if (crVar != null) {
                    Iterator<String> it = crVar.a(true).iterator();
                    while (it.hasNext()) {
                        arrayList2.add(String.format(Locale.US, "https://%1$s/gslb/?ver=4.0", it.next()));
                    }
                }
            }
        } else {
            arrayList2 = c2.a(format);
        }
        Iterator<String> it2 = arrayList2.iterator();
        IOException e = null;
        while (it2.hasNext()) {
            Uri.Builder buildUpon = Uri.parse(it2.next()).buildUpon();
            for (bi biVar : arrayList3) {
                buildUpon.appendQueryParameter(biVar.a(), biVar.b());
            }
            try {
                return this.f6828a == null ? bj.a(a, new URL(buildUpon.toString())) : this.f6828a.a(buildUpon.toString());
            } catch (IOException e2) {
                e = e2;
            }
        }
        if (e == null) {
            return null;
        }
        com.xiaomi.channel.commonutils.logger.b.m9051a("network exception: " + e.getMessage());
        throw e;
    }

    /* access modifiers changed from: protected */
    /* renamed from: a  reason: collision with other method in class */
    public JSONObject m9211a() {
        JSONObject jSONObject;
        synchronized (this.f6830a) {
            jSONObject = new JSONObject();
            jSONObject.put("ver", 2);
            JSONArray jSONArray = new JSONArray();
            for (cs csVar : this.f6830a.values()) {
                jSONArray.put(csVar.m9206a());
            }
            jSONObject.put(RemoteMessageConst.DATA, jSONArray);
            JSONArray jSONArray2 = new JSONArray();
            for (cr crVar : b.values()) {
                jSONArray2.put(crVar.m9201a());
            }
            jSONObject.put("reserved", jSONArray2);
        }
        return jSONObject;
    }

    /* renamed from: a  reason: collision with other method in class */
    public void m9212a() {
        synchronized (this.f6830a) {
            this.f6830a.clear();
        }
    }

    /* renamed from: a  reason: collision with other method in class */
    public void m9213a(String str) {
        this.f6832b = str;
    }

    public void a(String str, cr crVar) {
        if (TextUtils.isEmpty(str) || crVar == null) {
            throw new IllegalArgumentException("the argument is invalid " + str + ", " + crVar);
        } else if (this.f6827a.a(str)) {
            synchronized (this.f6830a) {
                m9214a();
                if (this.f6830a.containsKey(str)) {
                    this.f6830a.get(str).a(crVar);
                } else {
                    cs csVar = new cs(str);
                    csVar.a(crVar);
                    this.f6830a.put(str, csVar);
                }
            }
        }
    }

    /* access modifiers changed from: protected */
    /* renamed from: a  reason: collision with other method in class */
    public boolean m9214a() {
        synchronized (this.f6830a) {
            if (f6825a) {
                return true;
            }
            f6825a = true;
            this.f6830a.clear();
            try {
                String d2 = d();
                if (!TextUtils.isEmpty(d2)) {
                    m9216b(d2);
                    com.xiaomi.channel.commonutils.logger.b.b("loading the new hosts succeed");
                    return true;
                }
            } catch (Throwable th) {
                com.xiaomi.channel.commonutils.logger.b.m9051a("load bucket failure: " + th.getMessage());
            }
            return false;
        }
    }

    public cr b(String str) {
        return a(str, true);
    }

    /* access modifiers changed from: protected */
    public String b() {
        String a2 = com.xiaomi.push.service.a.a(a).a();
        return (TextUtils.isEmpty(a2) || PushChannelRegion.China.name().equals(a2)) ? "resolver.msg.xiaomi.net" : "resolver.msg.global.xiaomi.net";
    }

    /* renamed from: b  reason: collision with other method in class */
    public void m9215b() {
        ArrayList<String> arrayList;
        synchronized (this.f6830a) {
            m9214a();
            arrayList = new ArrayList<>(this.f6830a.keySet());
            for (int size = arrayList.size() - 1; size >= 0; size--) {
                cs csVar = this.f6830a.get(arrayList.get(size));
                if (!(csVar == null || csVar.a() == null)) {
                    arrayList.remove(size);
                }
            }
        }
        ArrayList<cr> a2 = a(arrayList);
        for (int i = 0; i < arrayList.size(); i++) {
            if (a2.get(i) != null) {
                a(arrayList.get(i), a2.get(i));
            }
        }
    }

    /* access modifiers changed from: protected */
    /* renamed from: b  reason: collision with other method in class */
    public void m9216b(String str) {
        synchronized (this.f6830a) {
            this.f6830a.clear();
            JSONObject jSONObject = new JSONObject(str);
            if (jSONObject.optInt("ver") == 2) {
                JSONArray optJSONArray = jSONObject.optJSONArray(RemoteMessageConst.DATA);
                if (optJSONArray != null) {
                    for (int i = 0; i < optJSONArray.length(); i++) {
                        cs a2 = new cs().a(optJSONArray.getJSONObject(i));
                        this.f6830a.put(a2.m9204a(), a2);
                    }
                }
                JSONArray optJSONArray2 = jSONObject.optJSONArray("reserved");
                if (optJSONArray2 != null) {
                    for (int i2 = 0; i2 < optJSONArray2.length(); i2++) {
                        JSONObject jSONObject2 = optJSONArray2.getJSONObject(i2);
                        String optString = jSONObject2.optString("host");
                        if (!TextUtils.isEmpty(optString)) {
                            try {
                                cr a3 = new cr(optString).a(jSONObject2);
                                b.put(a3.f6820b, a3);
                                com.xiaomi.channel.commonutils.logger.b.m9051a("load local reserved host for " + a3.f6820b);
                            } catch (JSONException unused) {
                                com.xiaomi.channel.commonutils.logger.b.m9051a("parse reserved host fail.");
                            }
                        }
                    }
                }
            } else {
                throw new JSONException("Bad version");
            }
        }
    }

    /* access modifiers changed from: protected */
    public cr c(String str) {
        cs csVar;
        cr a2;
        synchronized (this.f6830a) {
            m9214a();
            csVar = this.f6830a.get(str);
        }
        if (csVar == null || (a2 = csVar.a()) == null) {
            return null;
        }
        return a2;
    }

    public String c() {
        StringBuilder sb = new StringBuilder();
        synchronized (this.f6830a) {
            for (Map.Entry<String, cs> entry : this.f6830a.entrySet()) {
                sb.append(entry.getKey());
                sb.append(":\n");
                sb.append(entry.getValue().toString());
                sb.append("\n");
            }
        }
        return sb.toString();
    }

    /* renamed from: c  reason: collision with other method in class */
    public void m9217c() {
        synchronized (this.f6830a) {
            try {
                BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(a.openFileOutput(e(), 0)));
                String jSONObject = m9211a().toString();
                if (!TextUtils.isEmpty(jSONObject)) {
                    bufferedWriter.write(jSONObject);
                }
                bufferedWriter.close();
            } catch (Exception e) {
                com.xiaomi.channel.commonutils.logger.b.m9051a("persist bucket failure: " + e.getMessage());
            }
        }
    }

    public cr d(String str) {
        cr crVar;
        synchronized (b) {
            crVar = b.get(str);
        }
        return crVar;
    }

    /* access modifiers changed from: protected */
    public String d() {
        BufferedReader bufferedReader;
        Throwable th;
        try {
            File file = new File(a.getFilesDir(), e());
            if (file.isFile()) {
                bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(file)));
                try {
                    StringBuilder sb = new StringBuilder();
                    while (true) {
                        String readLine = bufferedReader.readLine();
                        if (readLine != null) {
                            sb.append(readLine);
                        } else {
                            String sb2 = sb.toString();
                            ab.a(bufferedReader);
                            return sb2;
                        }
                    }
                } catch (Throwable th2) {
                    th = th2;
                    try {
                        com.xiaomi.channel.commonutils.logger.b.m9051a("load host exception " + th.getMessage());
                        return null;
                    } finally {
                        ab.a(bufferedReader);
                    }
                }
            } else {
                ab.a((Closeable) null);
                return null;
            }
        } catch (Throwable th3) {
            th = th3;
            bufferedReader = null;
            com.xiaomi.channel.commonutils.logger.b.m9051a("load host exception " + th.getMessage());
            return null;
        }
    }

    /* renamed from: d  reason: collision with other method in class */
    public void m9218d() {
        synchronized (this.f6830a) {
            for (cs csVar : this.f6830a.values()) {
                csVar.a(true);
            }
            while (true) {
                for (boolean z = false; !z; z = true) {
                    for (String str : this.f6830a.keySet()) {
                        if (this.f6830a.get(str).m9205a().isEmpty()) {
                            this.f6830a.remove(str);
                        }
                    }
                }
            }
        }
    }

    /* access modifiers changed from: protected */
    public cr e(String str) {
        if (System.currentTimeMillis() - this.f6833c <= this.f6826a * 60 * 1000) {
            return null;
        }
        this.f6833c = System.currentTimeMillis();
        ArrayList<String> arrayList = new ArrayList<>();
        arrayList.add(str);
        cr crVar = a(arrayList).get(0);
        if (crVar != null) {
            this.f6826a = 0;
            return crVar;
        }
        long j = this.f6826a;
        if (j >= 15) {
            return null;
        }
        this.f6826a = j + 1;
        return null;
    }

    /* access modifiers changed from: protected */
    public String e() {
        List<ActivityManager.RunningAppProcessInfo> runningAppProcesses = ((ActivityManager) a.getSystemService(PushConstants.INTENT_ACTIVITY_NAME)).getRunningAppProcesses();
        if (runningAppProcesses == null) {
            return "com.xiaomi";
        }
        for (ActivityManager.RunningAppProcessInfo runningAppProcessInfo : runningAppProcesses) {
            if (runningAppProcessInfo.pid == Process.myPid()) {
                return runningAppProcessInfo.processName;
            }
        }
        return "com.xiaomi";
    }
}