Fast Orange v3.5.3版本的 MD5 值为:33b91aba50c566533dfd683a85f79158
以下内容为反编译后的 mq1.java 源代码,内容仅作参考
package com.free.vpn.proxy.hotspot;
import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.concurrent.atomic.AtomicInteger;
import kotlin.Result;
import kotlin.ResultKt;
import kotlin.coroutines.Continuation;
import kotlinx.coroutines.CancellableContinuationImpl;
import kotlinx.coroutines.flow.Flow;
import kotlinx.coroutines.flow.FlowKt;
public final class mq1 {
public static final mq1 a = new mq1();
public static final ArrayList b = zm2.b("http://ip-api.com/line/?fields=query");
public static final Flow c;
static {
AtomicInteger atomicInteger = new AtomicInteger(0);
c = FlowKt.retryWhen(FlowKt.flow(new kq1(atomicInteger, null)), new lq1(0, atomicInteger, null));
}
public static final Object a(mq1 mq1Var, String str, Continuation continuation) {
jq1 jq1Var;
int i;
BufferedInputStream bufferedInputStream;
Exception e;
HttpURLConnection httpURLConnection;
Object m4425constructorimpl;
mq1Var.getClass();
if (continuation instanceof jq1) {
jq1Var = (jq1) continuation;
int i2 = jq1Var.c;
if ((i2 & Integer.MIN_VALUE) != 0) {
jq1Var.c = i2 - Integer.MIN_VALUE;
Object obj = jq1Var.a;
m70 m70Var = m70.a;
i = jq1Var.c;
boolean z = true;
if (i == 0) {
if (i == 1) {
ResultKt.throwOnFailure(obj);
} else {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
} else {
ResultKt.throwOnFailure(obj);
jq1Var.getClass();
jq1Var.c = 1;
CancellableContinuationImpl cancellableContinuationImpl = new CancellableContinuationImpl(zs4.W(jq1Var), 1);
cancellableContinuationImpl.initCancellability();
HttpURLConnection httpURLConnection2 = null;
r0 = null;
r0 = null;
BufferedInputStream bufferedInputStream2 = null;
httpURLConnection2 = null;
try {
URLConnection openConnection = new URL(str).openConnection();
if (openConnection != null) {
httpURLConnection = (HttpURLConnection) openConnection;
httpURLConnection.setReadTimeout(5000);
httpURLConnection.setConnectTimeout(5000);
} else {
httpURLConnection = null;
}
if (httpURLConnection != null) {
try {
bufferedInputStream2 = new BufferedInputStream(httpURLConnection.getInputStream());
} catch (Exception e2) {
e = e2;
BufferedInputStream bufferedInputStream3 = bufferedInputStream2;
httpURLConnection2 = httpURLConnection;
bufferedInputStream = bufferedInputStream3;
try {
ye4.b(e);
Result.Companion companion = Result.INSTANCE;
cancellableContinuationImpl.resumeWith(Result.m4425constructorimpl(Result.m4424boximpl(Result.m4425constructorimpl(ResultKt.createFailure(new IOException())))));
if (httpURLConnection2 != null) {
httpURLConnection2.disconnect();
}
if (bufferedInputStream != null) {
bufferedInputStream.close();
}
obj = cancellableContinuationImpl.getResult();
m70 m70Var2 = m70.a;
if (obj == m70Var) {
}
return ((Result) obj).getValue();
} catch (Throwable th) {
th = th;
if (httpURLConnection2 != null) {
httpURLConnection2.disconnect();
}
if (bufferedInputStream != null) {
bufferedInputStream.close();
}
throw th;
}
} catch (Throwable th2) {
th = th2;
BufferedInputStream bufferedInputStream4 = bufferedInputStream2;
httpURLConnection2 = httpURLConnection;
bufferedInputStream = bufferedInputStream4;
if (httpURLConnection2 != null) {
}
if (bufferedInputStream != null) {
}
throw th;
}
}
if (httpURLConnection == null || httpURLConnection.getResponseCode() != 200) {
z = false;
}
if (z) {
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream2));
StringBuffer stringBuffer = new StringBuffer();
while (true) {
String readLine = bufferedReader.readLine();
if (readLine == null) {
break;
}
stringBuffer.append(readLine);
}
String stringBuffer2 = stringBuffer.toString();
zs4.n(stringBuffer2, "sb.toString()");
ye4.a("Current Ip: " + stringBuffer2, new Object[0]);
m4425constructorimpl = Result.m4425constructorimpl(stringBuffer2);
} else {
Result.Companion companion2 = Result.INSTANCE;
m4425constructorimpl = Result.m4425constructorimpl(ResultKt.createFailure(new IOException()));
}
cancellableContinuationImpl.resumeWith(Result.m4425constructorimpl(Result.m4424boximpl(m4425constructorimpl)));
if (httpURLConnection != null) {
httpURLConnection.disconnect();
}
if (bufferedInputStream2 != null) {
bufferedInputStream2.close();
}
} catch (Exception e3) {
e = e3;
bufferedInputStream = null;
} catch (Throwable th3) {
th = th3;
bufferedInputStream = null;
}
obj = cancellableContinuationImpl.getResult();
m70 m70Var22 = m70.a;
if (obj == m70Var) {
return m70Var;
}
}
return ((Result) obj).getValue();
}
}
jq1Var = new jq1(mq1Var, continuation);
Object obj2 = jq1Var.a;
m70 m70Var3 = m70.a;
i = jq1Var.c;
boolean z2 = true;
if (i == 0) {
}
return ((Result) obj2).getValue();
}
}