正在查看: Bhakti v5.4.0 应用的 AbstractC4927f.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
正在查看: Bhakti v5.4.0 应用的 AbstractC4927f.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
package hl;
import A5.y;
import Bi.k;
import Bi.t;
import D8.i;
import Kp.AbstractC0778p;
import Kp.V;
import android.content.Context;
import android.content.SharedPreferences;
import android.os.Build;
import com.vlv.aravali.audiobooks.ui.fragments.p;
import com.vlv.aravali.common.analytics.data.AnalyticsEvent;
import com.vlv.aravali.common.models.User;
import il.C5113f;
import j.AbstractC5459e;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import jj.AbstractC5536a;
import kotlin.Pair;
import kotlin.collections.C5697y;
import kotlin.collections.S;
import kotlin.coroutines.g;
import kotlin.jvm.internal.Intrinsics;
import kp.C5717b;
import ml.C5927a;
import nl.AbstractC6060a;
import nl.C6061b;
import okhttp3.HttpUrl;
import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Protocol;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import org.json.JSONObject;
import vj.AbstractC7140a;
public abstract class AbstractC4927f {
public static String f55793a = "";
public static final List f55794b = C5697y.l("https://events.kukufm.com/events/", "https://web-events.kukufm.com/events/");
public static OkHttpClient a(long j10, final Context context, final C5113f firebaseAuthUserManagerV2) {
Intrinsics.checkNotNullParameter(context, "context");
Intrinsics.checkNotNullParameter(firebaseAuthUserManagerV2, "firebaseAuthUserManagerV2");
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.addInterceptor(new C4922a(context));
builder.addInterceptor(new Interceptor() {
@Override
public final Response intercept(Interceptor.Chain chain) {
Response build;
Intrinsics.checkNotNullParameter(chain, "chain");
long currentTimeMillis = System.currentTimeMillis();
Request.Builder newBuilder = chain.request().newBuilder();
newBuilder.addHeader("content-type", "application/json");
Context context2 = context;
newBuilder.addHeader("client-country", AbstractC7140a.a(context2));
boolean b2 = new C5927a(context2).b();
C5113f c5113f = firebaseAuthUserManagerV2;
if (b2) {
String str = (String) AbstractC0778p.z(g.f60976a, new C4926e(c5113f, null));
if (str.length() > 0) {
newBuilder.addHeader("Authorization", str);
}
}
newBuilder.addHeader("install-source", "google_play");
Intrinsics.checkNotNullParameter(context2, "context");
Intrinsics.checkNotNullParameter(context2, "context");
SharedPreferences sharedPreferences = context2.getSharedPreferences("com.vlv.aravali.bhakti", 0);
Intrinsics.checkNotNullExpressionValue(sharedPreferences, "getSharedPreferences(...)");
Intrinsics.checkNotNullParameter(context2, "context");
Intrinsics.checkNotNullExpressionValue(context2.getSharedPreferences("PersistentSharedPref", 0), "getSharedPreferences(...)");
ij.g gVar = ij.g.ENGLISH;
String string = sharedPreferences.getString("locale_code", gVar.getCode());
if (string == null) {
string = gVar.getCode();
}
ij.g.Companion.getClass();
newBuilder.addHeader("lang", ij.f.a(string).getSlug());
newBuilder.addHeader("app-version", String.valueOf(AbstractC5536a.f60013a));
newBuilder.addHeader("User-Agent", "kukufm-android-bhakti/5.4.0");
newBuilder.addHeader("package-name", "com.vlv.aravali.bhakti");
Request build2 = newBuilder.build();
AbstractC4927f.f55793a = build2.url().toString();
try {
if (!new C5927a(context2).b()) {
Response.Builder builder2 = new Response.Builder();
ij.e eVar = ij.e.SERVER_UNAVAILABLE;
builder2.code(eVar.getCode()).protocol(Protocol.HTTP_1_1).request(chain.request()).message(eVar.getMessage()).body(ResponseBody.Companion.create(HttpUrl.FRAGMENT_ENCODE_SET, MediaType.Companion.get("application/json"))).addHeader("content-type", "application/json").build();
}
build = chain.proceed(build2);
} catch (IOException e4) {
build = new Response.Builder().code(ij.e.SERVER_UNAVAILABLE.getCode()).protocol(Protocol.HTTP_1_1).request(chain.request()).message(String.valueOf(e4.getMessage())).body(ResponseBody.Companion.create(HttpUrl.FRAGMENT_ENCODE_SET, MediaType.Companion.get("application/json"))).addHeader("content-type", "application/json").build();
} catch (Exception e10) {
throw new IOException(e10.getMessage(), e10);
}
long currentTimeMillis2 = System.currentTimeMillis() - currentTimeMillis;
if (currentTimeMillis2 > 500 && !AbstractC4927f.f55794b.contains(AbstractC4927f.f55793a)) {
AnalyticsEvent event = new AnalyticsEvent("api_time_more_than_500ms", S.f(new Pair("api", build2.url().toString()), new Pair("duration", String.valueOf(currentTimeMillis2))));
Intrinsics.checkNotNullParameter(event, "event");
y yVar = i.f5026f;
if (yVar != null) {
Intrinsics.checkNotNullParameter(event, "event");
k l10 = ((t) yVar.f805b).l(event.getName());
Iterator l11 = p.l(event);
while (l11.hasNext()) {
Map.Entry entry = (Map.Entry) l11.next();
p.v(entry, l10, (String) entry.getKey());
}
l10.d();
}
}
int code = build.code();
if (code == 401) {
Sp.f fVar = V.f12364a;
AbstractC0778p.w(AbstractC0778p.b(Sp.e.f20223c), null, null, new C4925d(c5113f, null), 3);
} else {
String str2 = AbstractC4927f.f55793a;
if (code == 456) {
AbstractC4927f.c(build, context2);
} else if (code == ij.e.SYSTEM_UPGRADE.getCode()) {
AbstractC4927f.d(build);
}
}
return build;
}
});
TimeUnit timeUnit = TimeUnit.SECONDS;
builder.readTimeout(j10, timeUnit);
builder.connectTimeout(j10, timeUnit);
builder.writeTimeout(j10, timeUnit);
return builder.build();
}
public static OkHttpClient b(Context context) {
Intrinsics.checkNotNullParameter(context, "context");
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.addInterceptor(new C4922a(context));
builder.addInterceptor(new C4923b(context));
TimeUnit timeUnit = TimeUnit.SECONDS;
builder.readTimeout(60L, timeUnit);
builder.connectTimeout(60L, timeUnit);
return builder.build();
}
public static void c(Response response, Context context) {
Object obj;
User z10 = new uj.d(context).z();
if (z10 == null || (obj = z10.getId()) == null) {
obj = HttpUrl.FRAGMENT_ENCODE_SET;
}
AnalyticsEvent event = new AnalyticsEvent("multi_device_logout", S.f(new Pair("user_id", String.valueOf(obj)), new Pair("device_name", AbstractC5459e.f(Build.MANUFACTURER, " ", Build.MODEL)), new Pair("current_time", Long.valueOf(System.currentTimeMillis()))));
Intrinsics.checkNotNullParameter(event, "event");
y yVar = i.f5026f;
if (yVar != null) {
Intrinsics.checkNotNullParameter(event, "event");
k l10 = ((t) yVar.f805b).l(event.getName());
Iterator l11 = p.l(event);
while (l11.hasNext()) {
Map.Entry entry = (Map.Entry) l11.next();
p.v(entry, l10, (String) entry.getKey());
}
l10.d();
}
C5717b c5717b = AbstractC6060a.f63692a;
AbstractC6060a.b(new C6061b(ij.i.LOGOUT, Integer.valueOf(response.code()), response.message()));
}
public static void d(Response response) {
String str = "Our systems are temporarily offline as we implement essential upgrades. We'll be up and running shortly!";
try {
ResponseBody body = response.body();
String string = new JSONObject(String.valueOf(body != null ? body.string() : null)).getString("error_message");
if (string != null) {
str = string;
}
} catch (Exception unused) {
}
C5717b c5717b = AbstractC6060a.f63692a;
AbstractC6060a.b(new C6061b(ij.i.SYSTEM_UPGRADE, str));
}
}