Bhakti v5.4.0 - FirebaseMessaging.java 源代码

package com.vlv.aravali.notifications;

import B.c0;
import Bi.k;
import C.StS.RxGHtG;
import I3.L;
import Ic.C0;
import Kp.E;
import Kp.J;
import Kp.V;
import Kp.p;
import N5.w;
import Qn.AbstractC0210b;
import Qn.e;
import W7.sD.tdGaoHZiSbko;
import android.app.NotificationManager;
import android.content.Context;
import android.media.RingtoneManager;
import android.net.Uri;
import android.os.Build;
import android.os.Bundle;
import android.os.SystemClock;
import android.widget.RemoteViews;
import androidx.core.app.C;
import androidx.core.app.M;
import androidx.core.app.U;
import androidx.core.app.n0;
import androidx.datastore.preferences.protobuf.o;
import com.bumptech.glide.c;
import com.google.android.material.navigationrail.mA.RDoLFqbSNk;
import com.google.firebase.messaging.FirebaseMessagingService;
import com.google.firebase.messaging.q;
import com.google.gson.d;
import com.vlv.aravali.KukuFMApplication;
import com.vlv.aravali.coins.data.responses.CoinSilentNotifData;
import com.vlv.aravali.model.TimerNotificationData;
import gk.AbstractC1973a;
import hj.EnumC1987d;
import ij.i;
import in.juspay.hyper.constants.LogCategory;
import io.sentry.u2;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import kotlin.Metadata;
import kotlin.jvm.internal.Intrinsics;
import kotlin.text.StringsKt;
import nl.C2198b;
import nl.a;
import oc.g;
import org.json.JSONObject;
import pl.AbstractC2244e;
import pl.AbstractC2252m;
import pl.C2239C;
import pl.C2245f;
import th.b;
import v0.f;

@Metadata
public final class FirebaseMessaging extends FirebaseMessagingService {
    public static final int b = 0;

    public final EnumC1987d c() {
        Object obj;
        EnumC1987d enumC1987d;
        n0 n0Var = new n0(getApplicationContext());
        Intrinsics.checkNotNullExpressionValue(n0Var, "from(...)");
        if (!n0Var.a()) {
            return EnumC1987d.BLOCKED;
        }
        int i = Build.VERSION.SDK_INT;
        if (i < 26) {
            return EnumC1987d.ENABLED;
        }
        List g = i >= 26 ? C.g(n0Var.b) : Collections.emptyList();
        Intrinsics.checkNotNullExpressionValue(g, "getNotificationChannels(...)");
        Iterator it = g.iterator();
        while (true) {
            if (!it.hasNext()) {
                obj = null;
                break;
            }
            obj = it.next();
            if (f.a(AbstractC1973a.d(obj)) == 0) {
                break;
            }
        }
        return (AbstractC1973a.d(obj) == null || (enumC1987d = EnumC1987d.PARTIALLY_BLOCKED) == null) ? EnumC1987d.ENABLED : enumC1987d;
    }

    public final void onMessageReceived(q qVar) {
        String str;
        String str2;
        String str3;
        String str4;
        String str5;
        b bVar;
        Intrinsics.checkNotNullParameter(qVar, "remoteMessage");
        c0 K0 = qVar.K0();
        Intrinsics.checkNotNullExpressionValue(K0, "getData(...)");
        if (K0.isEmpty()) {
            AbstractC0210b.v(KukuFMApplication.x, "notification_error", "error_message", "Empty payload");
            return;
        }
        String h = new d().h(qVar.K0());
        Intrinsics.checkNotNullExpressionValue(h, "toJson(...)");
        Intrinsics.checkNotNullParameter("FirebaseMessaging", "tag");
        Intrinsics.checkNotNullParameter(h, "log");
        Bundle bundle = new Bundle();
        B.f fVar = (B.f) K0;
        for (Map.Entry entry : fVar.entrySet()) {
            bundle.putString((String) entry.getKey(), (String) entry.getValue());
        }
        b bVar2 = b.b;
        if (bVar2 == null) {
            synchronized (b.class) {
                try {
                    bVar = b.b;
                    if (bVar == null) {
                        bVar = new b(0);
                    }
                    b.b = bVar;
                } catch (Throwable th) {
                    throw th;
                }
            }
            bVar2 = bVar;
        }
        Map K02 = qVar.K0();
        Intrinsics.checkNotNullExpressionValue(K02, "getData(...)");
        if (bVar2.x(K02)) {
            K0.put("from_ct", "true");
            bundle.putBoolean("from_ct", true);
            String str6 = (String) qVar.K0().get("notification_id");
            if (str6 == null) {
                str6 = String.valueOf(Calendar.getInstance().getTimeInMillis());
            }
            f(str6, (String) fVar.get("gcm_webUrl"), fVar.containsKey("ct_campaign") ? (String) fVar.get("ct_campaign") : "ct_notification", bundle);
            eg.b F = C0.F();
            Context applicationContext = getApplicationContext();
            Intrinsics.checkNotNullExpressionValue(applicationContext, "getApplicationContext(...)");
            Map K03 = qVar.K0();
            Intrinsics.checkNotNullExpressionValue(K03, "getData(...)");
            F.m(applicationContext, K03);
            return;
        }
        xq.b bVar3 = xq.d.a;
        bVar3.k("Notification 0 : Received", new Object[0]);
        String str7 = "";
        String str8 = (String) fVar.get("notification_id");
        if (str8 == null) {
            str8 = String.valueOf(Calendar.getInstance().getTimeInMillis());
            K0.put("notification_id", str8);
        }
        try {
            String str9 = fVar.containsKey("ct_campaign") ? (String) fVar.get("ct_campaign") : null;
            ArrayList arrayList = e.a;
            if (e.S(bundle.getString("delivery_medium", ""))) {
                str = bundle.getString("delivery_medium");
                if (str == null) {
                    str = "";
                }
            } else {
                str = "delivery_medium_fcm";
            }
            c0 c0Var = K0;
            c0Var.put("delivery_medium", str);
            if (bundle.containsKey("wzrk_pn")) {
                String string = bundle.getString("wzrk_pn");
                if (string == null) {
                    string = "";
                }
                c0Var.put("wzrk_pn", string);
            }
            if (bundle.containsKey("wzrk_id")) {
                String string2 = bundle.getString("wzrk_id");
                if (string2 != null) {
                    str7 = string2;
                }
                c0Var.put("wzrk_id", str7);
            }
            f(str8, (String) fVar.get("uri"), str9, bundle);
            if (fVar.containsKey("notification_type") && (str5 = (String) fVar.get("notification_type")) != null && str5.equals("timer")) {
                e(K0);
            } else if (fVar.containsKey("notification_type") && (str4 = (String) fVar.get("notification_type")) != null && str4.equals("silent")) {
                bVar3.k("Notification 1 : Silent", new Object[0]);
                d(K0);
            } else if (fVar.containsKey("notification_type") && (str3 = (String) fVar.get("notification_type")) != null && str3.equals("kukufm_carousel")) {
                AtomicInteger atomicInteger = AbstractC2244e.a;
                Context applicationContext2 = getApplicationContext();
                Intrinsics.checkNotNullExpressionValue(applicationContext2, "getApplicationContext(...)");
                AbstractC2244e.b(applicationContext2, K0);
            } else if (fVar.containsKey("notification_type") && (str2 = (String) fVar.get("notification_type")) != null && StringsKt.y(str2, "leaderboard", false)) {
                AtomicInteger atomicInteger2 = AbstractC2252m.a;
                Context applicationContext3 = getApplicationContext();
                Intrinsics.checkNotNullExpressionValue(applicationContext3, "getApplicationContext(...)");
                AbstractC2252m.a(applicationContext3, K0);
            } else {
                AtomicInteger atomicInteger3 = C2239C.e;
                C2239C I = c.I();
                Context applicationContext4 = getApplicationContext();
                Intrinsics.checkNotNullExpressionValue(applicationContext4, "getApplicationContext(...)");
                I.f(applicationContext4, K0);
            }
        } catch (Exception e) {
            k r = io.sentry.config.d.r(KukuFMApplication.x, "notification_error");
            r.c(e.getMessage(), "error_message");
            r.d();
        }
        Sp.f fVar2 = V.a;
        p.w(p.b(Sp.e.c), new w(E.a, 4), (J) null, new C2245f(2, null), 2);
    }

    public final void onNewToken(String str) {
        Intrinsics.checkNotNullParameter(str, "token");
        Ai.p pVar = KukuFMApplication.x;
        pVar.B().e();
        if (!il.f.g()) {
            pVar.B().e();
            if (!il.f.f()) {
                return;
            }
        }
        Object obj = cd.e.m;
        ((cd.e) g.d().b(cd.f.class)).d().addOnCompleteListener(new u2(str, 3));
    }

    public static void d(Map map) {
        String str = (String) map.get(LogCategory.ACTION);
        if (str != null && str.equals("send_event")) {
            try {
                String str2 = (String) map.get("event_name");
                String str3 = (String) map.get("event_params");
                if (str3 == null) {
                    str3 = "";
                }
                JSONObject jSONObject = new JSONObject(str3);
                ArrayList arrayList = e.a;
                Bundle d = e.d(jSONObject);
                if (str2 != null) {
                    k l = KukuFMApplication.x.B().d().l(str2);
                    l.a(d);
                    l.g(false);
                    return;
                }
                return;
            } catch (Exception unused) {
                o.r(KukuFMApplication.x, "send_event_exception");
                return;
            }
        }
        String str4 = (String) map.get(LogCategory.ACTION);
        if (str4 != null && str4.equals("user_became_premium")) {
            kp.b bVar = a.a;
            a.b(new C2198b(i.REFRESH_PLAYER_QUEUE, new Object[0]));
            return;
        }
        String str5 = (String) map.get(LogCategory.ACTION);
        if (str5 != null) {
            String str6 = RDoLFqbSNk.dzBgXNlYHx;
            if (str5.equals(str6)) {
                xq.d.a.k("Notification 2 : Coins credited", new Object[0]);
                String str7 = (String) map.get("notification_id");
                if (str7 == null) {
                    str7 = String.valueOf(Calendar.getInstance().getTimeInMillis());
                }
                CoinSilentNotifData coinSilentNotifData = new CoinSilentNotifData(str7, (String) map.get("message"), (String) map.get("description"), (String) map.get(str6), (String) map.get("link_type"), (String) map.get("cta_type"));
                kp.b bVar2 = a.a;
                a.b(new C2198b(i.SHOW_SILENT_COIN_RECEIVED_POPUP, coinSilentNotifData));
                k r = io.sentry.config.d.r(KukuFMApplication.x, tdGaoHZiSbko.ZrPAtqOrDXLMb);
                r.c(coinSilentNotifData.getCoins(), str6);
                r.d();
            }
        }
    }

    public final void e(Map map) {
        int i = Build.VERSION.SDK_INT;
        if (i < 24) {
            k r = io.sentry.config.d.r(KukuFMApplication.x, "timer_notification_error");
            r.c("Unsupported android version " + i, "error_message");
            r.d();
            return;
        }
        if (L.b == null) {
            L.b = new L(7);
        }
        L l = L.b;
        if (l == null) {
            Intrinsics.m("instance");
            throw null;
        }
        Context applicationContext = getApplicationContext();
        Intrinsics.checkNotNullExpressionValue(applicationContext, RDoLFqbSNk.UiqvkF);
        Intrinsics.checkNotNullParameter(applicationContext, LogCategory.CONTEXT);
        Intrinsics.checkNotNullParameter(map, "payload");
        try {
            TimerNotificationData j = L.j(map);
            Object systemService = applicationContext.getSystemService("notification");
            Intrinsics.f(systemService, "null cannot be cast to non-null type android.app.NotificationManager");
            NotificationManager notificationManager = (NotificationManager) systemService;
            if (i >= 26) {
                l.e(notificationManager, j);
            }
            boolean z = l.a;
            Uri defaultUri = z ? RingtoneManager.getDefaultUri(2) : null;
            M m = new M(applicationContext, j.getChannelId());
            m.l = z ? 2 : 1;
            m.Q.icon = 2131231538;
            m.f(16, true);
            m.M = j.getTimeToLive();
            m.g = L.g(applicationContext, j);
            m.f(2, true);
            m.h(defaultUri);
            RemoteViews remoteViews = new RemoteViews(applicationContext.getPackageName(), 2131559268);
            remoteViews.setTextViewText(2131364772, j.getTitle());
            remoteViews.setTextViewText(2131362760, j.getDescription());
            remoteViews.setChronometer(2131364760, SystemClock.elapsedRealtime() + j.getTimeToLive(), "%s", true);
            m1.a.q(remoteViews);
            m.G = remoteViews;
            m.H = L.f(applicationContext, j);
            m.i(new U());
            notificationManager.notify(1110911, m.b());
        } catch (Exception e) {
            k r2 = io.sentry.config.d.r(KukuFMApplication.x, "timer_notification_error");
            r2.c(e.getMessage(), "error_message");
            r2.d();
        }
    }

    public final void f(String str, String str2, String str3, Bundle bundle) {
        String queryParameter;
        k g = o.g(KukuFMApplication.x, "notification_received", "notification_uri", str2);
        g.c(str, "notification_id");
        g.c(bundle.get("delivery_medium"), "delivery_medium");
        g.c(bundle.get("notification_type"), "type");
        if (bundle.containsKey("message")) {
            g.c(bundle.get("message"), "message");
        }
        if (bundle.containsKey("description")) {
            g.c(bundle.get("description"), "description");
        }
        if (str3 != null && str3.length() != 0) {
            g.c(str3, "ct_campaign");
        }
        String str4 = RxGHtG.UyR;
        if (bundle.containsKey(str4)) {
            g.c(bundle.get(str4), str4);
        }
        try {
            g.c(c().getValue(), "notification_setting_status");
        } catch (Exception e) {
            e.printStackTrace();
        }
        try {
            Uri parse = Uri.parse(str2);
            if (parse != null && (queryParameter = parse.getQueryParameter("utm_source")) != null) {
                g.c(queryParameter, "utm_source");
            }
        } catch (Exception e2) {
            k r = io.sentry.config.d.r(KukuFMApplication.x, "invalid_notification_uri");
            r.c(e2.getMessage(), "error_message");
            r.d();
            e2.printStackTrace();
        }
        g.d();
    }
}