Bhakti v5.4.0 - e.java 源代码

package ol;

import Bi.k;
import Bi.t;
import com.google.gson.o;
import com.vlv.aravali.audiobooks.ui.fragments.p;
import com.vlv.aravali.common.analytics.data.AnalyticsEvent;
import com.vlv.aravali.network.data.RestError;
import in.juspay.hyper.constants.LogLevel;
import java.io.IOException;
import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.Iterator;
import java.util.Map;
import kotlin.Pair;
import kotlin.collections.S;
import kotlin.jvm.internal.Intrinsics;
import kotlin.text.Charsets;
import kotlin.text.y;
import nl.C2198b;
import okhttp3.ResponseBody;
import org.json.JSONObject;
import retrofit2.HttpException;
import retrofit2.Response;

public abstract class e extends hp.a {
    public static String a(ResponseBody responseBody) {
        try {
            Intrinsics.e(responseBody);
            JSONObject jSONObject = new JSONObject(responseBody.string());
            if (jSONObject.has(LogLevel.ERROR) && (jSONObject.get(LogLevel.ERROR) instanceof JSONObject)) {
                JSONObject jSONObject2 = jSONObject.getJSONObject(LogLevel.ERROR);
                Intrinsics.checkNotNullExpressionValue(jSONObject2, "getJSONObject(...)");
                if (jSONObject2.has("message")) {
                    return jSONObject2.getString("message");
                }
            }
            if (jSONObject.has("error_code") && y.h(jSONObject.getString("error_code"), "SUSPENDED_USER", true)) {
                kp.b bVar = nl.a.a;
                nl.a.b(new C2198b(ij.i.SUSPENDED_USER, new Object[0]));
            }
            return jSONObject.has("error_message") ? jSONObject.getString("error_message") : jSONObject.has("error_code") ? jSONObject.getString("error_code") : jSONObject.getString("message");
        } catch (Exception e) {
            return e.getMessage();
        }
    }

    public final void b(int i, String str) {
        Intrinsics.checkNotNullParameter("API Failure: CallbackWrapper", "tag");
        Intrinsics.checkNotNullParameter(str, "log");
        c(i, str);
    }

    public abstract void c(int i, String str);

    public abstract void d(Object obj);

    public final void onError(Throwable th) {
        Intrinsics.checkNotNullParameter(th, "e");
        if (th instanceof HttpException) {
            HttpException httpException = (HttpException) th;
            Response response = httpException.response();
            b(httpException.code(), String.valueOf(a(response != null ? response.errorBody() : null)));
            return;
        }
        if ((th instanceof SocketTimeoutException) || (th instanceof UnknownHostException)) {
            ij.e eVar = ij.e.SOCKET_TIMEOUT;
            b(eVar.getCode(), eVar.getMessage());
            return;
        }
        if (th instanceof IOException) {
            ij.e eVar2 = ij.e.SOCKET_TIMEOUT;
            b(eVar2.getCode(), eVar2.getMessage());
            return;
        }
        if (!(th instanceof o)) {
            b(ij.e.BAD_REQUEST.getCode(), String.valueOf(th.getMessage()));
            return;
        }
        ij.e eVar3 = ij.e.JSON_SYNTAX_ERROR;
        AnalyticsEvent analyticsEvent = new AnalyticsEvent("json_syntax", S.f(new Pair[]{new Pair("network_error", eVar3.getMessage().toString()), new Pair("http_api", "https://kukufm.com")}));
        Intrinsics.checkNotNullParameter(analyticsEvent, "event");
        A5.y yVar = D8.i.f;
        if (yVar != null) {
            Intrinsics.checkNotNullParameter(analyticsEvent, "event");
            k l = ((t) yVar.b).l(analyticsEvent.getName());
            Iterator l2 = p.l(analyticsEvent);
            while (l2.hasNext()) {
                Map.Entry entry = (Map.Entry) l2.next();
                p.v(entry, l, (String) entry.getKey());
            }
            l.d();
        }
        b(eVar3.getCode(), eVar3.getMessage());
    }

    public final void onNext(Object obj) {
        Intrinsics.checkNotNullParameter(obj, "t");
        Response response = (Response) obj;
        int code = response.code();
        if (200 <= code && code < 300) {
            d(obj);
            return;
        }
        int code2 = response.code();
        String a = a(response.errorBody());
        if (a != null && a.length() != 0) {
            b(response.code(), a);
            return;
        }
        ij.e eVar = ij.e.NOT_FOUND;
        if (code2 == eVar.getCode()) {
            b(eVar.getCode(), eVar.getMessage());
            return;
        }
        ij.e eVar2 = ij.e.SERVER_ERROR;
        if (code2 == eVar2.getCode()) {
            b(eVar2.getCode(), eVar2.getMessage());
            return;
        }
        ResponseBody errorBody = response.errorBody();
        RestError restError = new RestError(null, null, 3, null);
        restError.setErrorMessage("Something Went Wrong!");
        if (errorBody != null) {
            try {
                restError = (RestError) new com.google.gson.d().c(RestError.class, new String(errorBody.bytes(), Charsets.UTF_8));
            } catch (IllegalStateException e) {
                e.printStackTrace();
                restError.setErrorMessage("IllegalStateException Occurred");
            } catch (Ro.g e2) {
                e2.printStackTrace();
                restError.setErrorMessage("UndeliverableException Occurred");
            } catch (o e3) {
                e3.printStackTrace();
                restError.setErrorMessage("JsonSyntaxException Occurred");
            }
        }
        b(ij.e.BAD_REQUEST.getCode(), restError.getErrorMessage());
    }

    public final void onComplete() {
    }
}