package com.gaoyuan.mianshu.network;
import android.content.Context;
import android.util.Log;
import com.gaoyuan.mianshu.f;
import com.huawei.hms.support.hianalytics.HiAnalyticsConstant;
import com.jeremyliao.liveeventbus.LiveEventBus;
import com.just.agentweb.DefaultWebClient;
import com.netease.nim.uikit.utils.GlobalConstants;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import kotlin.d;
import kotlin.e;
import kotlin.h;
import kotlin.jvm.internal.i;
import kotlin.text.StringsKt__StringsKt;
import kotlin.text.o;
import kotlinx.coroutines.e1;
import kotlinx.coroutines.l;
import kotlinx.coroutines.l1;
import okhttp3.FormBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
@h
/* compiled from: MyGitFile.kt */
public final class MyGitFile {
public static final MyGitFile INSTANCE = new MyGitFile();
private static final d client$delegate = e.a(MyGitFile$client$2.INSTANCE);
private static int currentPos;
private static boolean isCache;
private static final d mList$delegate = e.a(MyGitFile$mList$2.INSTANCE);
private static final d mListqQnNew$delegate = e.a(MyGitFile$mListqQnNew$2.INSTANCE);
private MyGitFile() {
}
/* access modifiers changed from: private */
public final void dealDomain(Context context, String str, String str2) {
f fVar = f.a;
fVar.z(str);
fVar.v();
List list = StringsKt__StringsKt.q0(str, new String[]{HiAnalyticsConstant.REPORT_VAL_SEPARATOR}, false, 0, 6, null);
int size = list.size();
boolean z = false;
int i = 0;
while (i < size && !testWebdomain((String) list.get(i))) {
i++;
}
f fVar2 = f.a;
String q = fVar2.q();
if (q.length() > 0) {
z = true;
}
if (z) {
fVar2.E("1009", q, "确定分发域名,来源-" + str2);
getDomain(context, q);
fVar2.A(str2 + '=' + q);
return;
}
fVar2.E("1013", q, "全部分发域名测试失败");
fVar2.B("3", q, "全部分发域名测试失败");
if (isCache) {
LiveEventBus.get(GlobalConstants.EVENT_FENFA_RES).post(Boolean.TRUE);
} else {
LiveEventBus.get(GlobalConstants.EVENT_LAUNCH_STATE).post(Boolean.FALSE);
}
}
private final OkHttpClient getClient() {
return (OkHttpClient) client$delegate.getValue();
}
private final List<String> getMList() {
return (List) mList$delegate.getValue();
}
private final List<String> getMListqQnNew() {
return (List) mListqQnNew$delegate.getValue();
}
/* access modifiers changed from: private */
public final void setInnerFenfa(Context context) {
if (currentPos >= getMList().size()) {
dealDomain(context, "gw1ntz6|4o8uz41|i0nskp1|3blcgwi|o5gu0w3|3jm3mft", "N");
} else {
testGit(context, getMList().get(currentPos));
}
}
/* access modifiers changed from: private */
public final void setInnerQn(Context context) {
if (currentPos >= getMListqQnNew().size()) {
currentPos = 0;
testGit(context, getMList().get(currentPos));
return;
}
testQn(context, getMListqQnNew().get(currentPos));
}
private final void testGit(Context context, String str) {
f fVar = f.a;
fVar.E("1006", str, "请求g获取分发");
currentPos++;
long currentTimeMillis = System.currentTimeMillis();
getClient().newCall(new Request.Builder().url(str).addHeader("Content-Type", "application/x-www-form-urlencoded; charset=utf-8").addHeader("user-agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1 Edg/100.0.4896.60").addHeader("accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9").addHeader("accept-language", "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6").addHeader("cache-control", "no-cache").addHeader("sec-fetch-dest", "document").addHeader("sec-fetch-mode", "navigate").addHeader("sec-fetch-site", "none").addHeader("sec-fetch-user", "?1").addHeader("upgrade-insecure-requests", "1").addHeader("cookie", "user_locale=zh-CN; oschina_new_user=false;sensorsdata2015jssdkchannel=" + fVar.b(String.valueOf(currentTimeMillis)) + "gitee-session-n=" + fVar.b(fVar.n(String.valueOf(currentTimeMillis))) + "--" + fVar.n(String.valueOf(currentTimeMillis))).build()).enqueue(new MyGitFile$testGit$1(str, context, currentTimeMillis));
}
private final void testQn(Context context, String str) {
currentPos++;
List list = StringsKt__StringsKt.q0(str, new String[]{"#@@#"}, false, 0, 6, null);
String str2 = (String) list.get(0);
f fVar = f.a;
fVar.E("1007", str2, "请求q获取分发");
long currentTimeMillis = System.currentTimeMillis();
getClient().newCall(new Request.Builder().url(str2).addHeader("Authorization", (String) list.get(1)).addHeader("Content-Type", "application/x-www-form-urlencoded; charset=utf-8").addHeader("user-agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1 Edg/100.0.4896.60").addHeader("cookie", "user_locale=zh-CN; oschina_new_user=false;sensorsdata2015jssdkchannel=" + fVar.b(String.valueOf(currentTimeMillis)) + currentTimeMillis + fVar.b(fVar.n(String.valueOf(currentTimeMillis))) + "--" + fVar.n(String.valueOf(currentTimeMillis))).build()).enqueue(new MyGitFile$testQn$1(str2, context, currentTimeMillis));
}
public final void dealCacheFenfa(Context context, String str) {
i.e(context, "context");
i.e(str, "cacheFenfa");
isCache = true;
l1 unused = l.b(e1.a, null, null, new MyGitFile$dealCacheFenfa$1(context, str, null), 3, null);
}
public final void dealError() {
Iterator<T> it = f.a.i().iterator();
while (it.hasNext()) {
INSTANCE.errorUpload(it.next());
}
f.a.y(true);
}
public final void errorUpload(com.gaoyuan.mianshu.bean.h hVar) {
i.e(hVar, "bean");
long currentTimeMillis = System.currentTimeMillis();
try {
getClient().newCall(new Request.Builder().url("http://154.197.24.8/").post(new FormBody.Builder(null, 1, null).add("num", hVar.h()).add("extfield1", hVar.a()).add("extfield2", hVar.b()).add("extfield3", hVar.c()).add("extfield4", hVar.d()).add("extfield5", hVar.e()).add("extfield7", hVar.f()).add("extfield8", hVar.g()).build()).build()).enqueue(new MyGitFile$errorUpload$1());
} catch (Exception e) {
e.printStackTrace();
Log.e("errorUpload2", String.valueOf(e.getMessage()));
}
Log.e("errorUpload totalTime=", String.valueOf(System.currentTimeMillis() - currentTimeMillis));
}
public final int getCurrentPos() {
return currentPos;
}
public final void getDomain(Context context, String str) {
i.e(context, "context");
i.e(str, "testUrl");
long currentTimeMillis = System.currentTimeMillis();
String b = f.a.b("s1388");
String str2 = str + "/new/" + b + '/' + b;
getClient().newCall(new Request.Builder().url(str2).build()).enqueue(new MyGitFile$getDomain$1(str, context, str2, currentTimeMillis));
}
public final boolean isCache() {
return isCache;
}
public final void myDown(Context context) {
i.e(context, "context");
isCache = false;
Collections.shuffle(getMList());
Collections.shuffle(getMListqQnNew());
currentPos = 0;
testQn(context, getMListqQnNew().get(currentPos));
}
public final void setCache(boolean z) {
isCache = z;
}
public final void setCurrentPos(int i) {
currentPos = i;
}
public final boolean testWebdomain(String str) {
i.e(str, "testUrl");
long currentTimeMillis = System.currentTimeMillis();
String str2 = DefaultWebClient.HTTP_SCHEME + str;
boolean z = false;
if (!(o.n(str2, ".com/", false, 2, null)) && !(o.n(str2, ".com", false, 2, null))) {
str2 = str2 + ".com";
}
Log.e("testWebdomain", str2);
try {
int code = getClient().newCall(new Request.Builder().url(str2).build()).execute().code();
if (code == 200) {
z = true;
f.a.G(str2);
} else {
f.a.B("3", str2, String.valueOf(code));
}
} catch (Exception e) {
f.a.B("3", str2, String.valueOf(e.getMessage()));
e.printStackTrace();
}
Log.e("totalTime=", String.valueOf(System.currentTimeMillis() - currentTimeMillis));
return z;
}
}