Bhakti v5.4.0 - KukuFMMedia3Service.java 源代码

package com.vlv.aravali.playerMedia3.service;

import B4.v;
import D3.l;
import I5.s;
import Kp.J;
import Kp.L0;
import Kp.V;
import Kp.p;
import Lp.e;
import Ml.C0;
import Np.D0;
import Np.F0;
import Np.G0;
import Np.k;
import Np.m0;
import Np.n0;
import Qf.h;
import Qp.c;
import Qp.m;
import Tl.C0213a;
import Tl.C0217c;
import Tl.C0219d;
import Tl.C0224f0;
import Tl.C0235l;
import Tl.C0253z;
import Tl.J0;
import Tl.N;
import Tl.u0;
import Tl.v0;
import Tl.w0;
import Vl.C0801c;
import Zm.f;
import android.app.PendingIntent;
import android.content.Context;
import android.content.Intent;
import android.os.Build;
import android.os.Bundle;
import android.os.CountDownTimer;
import androidx.media3.exoplayer.ExoPlayer;
import androidx.media3.session.MediaSessionService;
import b3.G;
import b3.X;
import b3.f0;
import b3.g0;
import b3.i0;
import cc.B0;
import cc.U;
import cc.Y;
import com.vlv.aravali.KukuFMApplication;
import com.vlv.aravali.common.models.CUPart;
import com.vlv.aravali.common.models.Show;
import com.vlv.aravali.common.models.User;
import com.vlv.aravali.common.models.user.UserResponse;
import com.vlv.aravali.model.AudioVariant;
import com.vlv.aravali.network.rx.RxEvent;
import com.vlv.aravali.playerMedia3.data.db.PlayerStateWorker;
import com.vlv.aravali.playerMedia3.data.db.models.EpisodeContainer;
import com.vlv.aravali.views.fragments.C1810k;
import fm.AbstractC1929a;
import in.juspay.hyper.constants.LogCategory;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.CancellationException;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.Unit;
import kotlin.collections.C;
import kotlin.collections.CollectionsKt;
import kotlin.collections.H;
import kotlin.coroutines.CoroutineContext;
import kotlin.jvm.internal.Intrinsics;
import l3.D;
import mp.o;
import mp.y;
import mp.z;
import nl.C2198b;
import ol.a;
import rp.i;
import s4.h0;
import s4.z0;
import t4.b0;
import x6.b;
import xq.d;
import z5.A;
import z5.j;

@Metadata
public final class KukuFMMedia3Service extends Hilt_KukuFMMedia3Service {
    public static final F0 C0;
    public static final m0 D0;
    public static final F0 E0;
    public static final F0 F0;
    public static final m0 G0;
    public CountDownTimer A0;
    public final f B0;
    public final c H;
    public float L;
    public C0 M;
    public final y Q;
    public final y X;
    public final y Y;
    public final y Z;
    public final y i0;
    public final y j0;
    public h0 k;
    public final y k0;
    public final y l0;
    public final y m0;
    public final y n0;
    public final k o0;
    public final y p0;
    public final y q0;
    public v r;
    public final y r0;
    public boolean s0;
    public int t0;
    public boolean u0;
    public boolean v0;
    public boolean w0;
    public final L0 x;
    public boolean x0;
    public final a y;
    public boolean y0;
    public int z0;
    public final y p = o.b(new C0217c(this, 6));
    public final y v = o.b(new h(8));
    public final y w = o.b(new C0217c(this, 13));

    static {
        F0 a = G0.a(H.a);
        C0 = a;
        D0 = new m0(a);
        E0 = G0.a(Boolean.FALSE);
        F0 a2 = G0.a(0L);
        F0 = a2;
        G0 = new m0(a2);
    }

    public KukuFMMedia3Service() {
        UserResponse.SettingsData.CurrentPlaybackSpeed currentPlaybackSpeed;
        int i = 7;
        int i2 = 8;
        L0 e = p.e();
        this.x = e;
        this.y = new a();
        Sp.f fVar = V.a;
        e eVar = m.a;
        eVar.getClass();
        this.H = p.b(kotlin.coroutines.e.c(eVar, e));
        UserResponse.SettingsData q = KukuFMApplication.x.B().h().q();
        this.L = (q == null || (currentPlaybackSpeed = q.getCurrentPlaybackSpeed()) == null) ? 1.0f : currentPlaybackSpeed.getValue();
        this.Q = o.b(new h(6));
        this.X = o.b(new h(7));
        this.Y = o.b(new C0217c(this, 0));
        this.Z = o.b(new C0217c(this, 1));
        this.i0 = o.b(new C0217c(this, 2));
        this.j0 = o.b(new C0217c(this, 3));
        this.k0 = o.b(new C0217c(this, 4));
        this.l0 = o.b(new C0217c(this, i));
        this.m0 = o.b(new C0217c(this, i2));
        this.n0 = o.b(new C0217c(this, 9));
        this.o0 = Np.v.e(new n0(new v0(this, null)), -1);
        this.p0 = o.b(new C0217c(this, 10));
        this.q0 = o.b(new C0217c(this, 11));
        this.r0 = o.b(new C0217c(this, 12));
        this.B0 = new f();
    }

    public static void A(KukuFMMedia3Service kukuFMMedia3Service, String str, String str2, String str3, CUPart cUPart, boolean z, int i) {
        CUPart cUPart2;
        long g0;
        long E;
        Integer id;
        long g02;
        long E2;
        String str4;
        Object obj;
        String str5 = (i & 1) != 0 ? "auto" : str;
        String str6 = (i & 2) != 0 ? "auto" : str2;
        if ((i & 8) != 0) {
            G T0 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).T0();
            CUPart cUPart3 = null;
            if (T0 != null && (str4 = T0.a) != null) {
                Iterator it = ((Iterable) kukuFMMedia3Service.t().getValue()).iterator();
                while (true) {
                    if (!it.hasNext()) {
                        obj = null;
                        break;
                    } else {
                        obj = it.next();
                        if (Intrinsics.c(String.valueOf(((EpisodeContainer) obj).getEpisodeId()), str4)) {
                            break;
                        }
                    }
                }
                EpisodeContainer episodeContainer = (EpisodeContainer) obj;
                if (episodeContainer != null) {
                    cUPart3 = episodeContainer.getCuPart();
                }
            }
            cUPart2 = cUPart3;
        } else {
            cUPart2 = cUPart;
        }
        boolean z2 = (i & 16) != 0 ? false : z;
        kukuFMMedia3Service.getClass();
        Intrinsics.checkNotNullParameter(str5, "actionSource");
        Intrinsics.checkNotNullParameter(str6, "playingSource");
        Intrinsics.checkNotNullParameter(str3, "eventName");
        if (cUPart2 != null && (id = cUPart2.getId()) != null && id.intValue() == -1) {
            Show show = cUPart2.getShow();
            if (Intrinsics.c(str3, "episode_play_completed")) {
                g02 = (cUPart2.getDurationS() != null ? r6.intValue() : 0) * 1000;
            } else {
                g02 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).g0();
            }
            if (Intrinsics.c(str3, "episode_play_completed")) {
                E2 = (cUPart2.getDurationS() != null ? r0.intValue() : 0) * 1000;
            } else {
                E2 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).E();
            }
            C0213a.b("dynamic_audio_que_next_show", show, g02, E2, cUPart2, z2, Float.valueOf(((X) ((Cp.c) kukuFMMedia3Service.x()).b).k().a), str5, str6, null);
            return;
        }
        if (cUPart2 == null || cUPart2.isPlayLocked()) {
            return;
        }
        Show show2 = (Show) kukuFMMedia3Service.y().getValue();
        if (show2 != null ? Intrinsics.c(show2.isRadio(), Boolean.TRUE) : false) {
            return;
        }
        Show show3 = (Show) kukuFMMedia3Service.y().getValue();
        if (Intrinsics.c(str3, "episode_play_completed")) {
            g0 = (cUPart2.getDurationS() != null ? r6.intValue() : 0) * 1000;
        } else {
            g0 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).g0();
        }
        if (Intrinsics.c(str3, "episode_play_completed")) {
            E = (cUPart2.getDurationS() != null ? r1.intValue() : 0) * 1000;
        } else {
            E = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).E();
        }
        C0213a.b(str3, show3, g0, E, cUPart2, z2, Float.valueOf(((X) ((Cp.c) kukuFMMedia3Service.x()).b).k().a), str5, str6, null);
    }

    public static void C(KukuFMMedia3Service kukuFMMedia3Service, G g, boolean z, int i) {
        if ((i & 1) != 0) {
            g = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).T0();
        }
        if ((i & 2) != 0) {
            z = false;
        }
        c cVar = kukuFMMedia3Service.H;
        Sp.f fVar = V.a;
        p.w(cVar, m.a, (J) null, new N(kukuFMMedia3Service, g, z, null), 2);
    }

    public static final long l(KukuFMMedia3Service kukuFMMedia3Service) {
        g0 C02 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).e1(17) ? ((X) ((Cp.c) kukuFMMedia3Service.x()).b).C0() : g0.a;
        Intrinsics.e(C02);
        if (C02.p()) {
            return ((X) ((Cp.c) kukuFMMedia3Service.x()).b).E();
        }
        int u0 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).u0();
        f0 f0Var = new f0();
        C02.n(u0, f0Var);
        long j = f0Var.m;
        return j != -9223372036854775807L ? (j == -9223372036854775807L || j == Long.MIN_VALUE) ? j : j / 1000 : ((X) ((Cp.c) kukuFMMedia3Service.x()).b).E();
    }

    public static final Object m(KukuFMMedia3Service kukuFMMedia3Service, i iVar) {
        kukuFMMedia3Service.x0 = false;
        Sp.f fVar = V.a;
        Object C = p.C(m.a, new C0253z(kukuFMMedia3Service, null), iVar);
        return C == qp.a.COROUTINE_SUSPENDED ? C : Unit.a;
    }

    public static final java.lang.Object n(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service r18, com.vlv.aravali.playerMedia3.data.db.models.EpisodeContainer r19, com.vlv.aravali.common.models.Show r20, rp.c r21) {
        throw new UnsupportedOperationException("Method not decompiled: com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service.n(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service, com.vlv.aravali.playerMedia3.data.db.models.EpisodeContainer, com.vlv.aravali.common.models.Show, rp.c):java.lang.Object");
    }

    public static final java.lang.Object o(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service r5, com.vlv.aravali.model.response.EpisodesForShowResponse r6, java.lang.String r7, boolean r8, rp.c r9) {
        throw new UnsupportedOperationException("Method not decompiled: com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service.o(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service, com.vlv.aravali.model.response.EpisodesForShowResponse, java.lang.String, boolean, rp.c):java.lang.Object");
    }

    public static final java.lang.Object p(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service r10, rp.c r11) {
        throw new UnsupportedOperationException("Method not decompiled: com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service.p(com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service, rp.c):java.lang.Object");
    }

    public static void q(KukuFMMedia3Service kukuFMMedia3Service) {
        long currentPosition = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).getCurrentPosition();
        G T0 = ((X) ((Cp.c) kukuFMMedia3Service.x()).b).T0();
        String str = T0 != null ? T0.a : null;
        Show show = (Show) kukuFMMedia3Service.y().getValue();
        if (show != null ? Intrinsics.c(show.isRadio(), Boolean.TRUE) : false) {
            return;
        }
        d.a.k("Caching Position episodeId " + str + " seekPosition " + currentPosition, new Object[0]);
        LinkedHashMap linkedHashMap = new LinkedHashMap();
        Intrinsics.checkNotNullParameter("seek_position", "key");
        linkedHashMap.put("seek_position", Long.valueOf(currentPosition));
        Intrinsics.checkNotNullParameter("episode_id", "key");
        linkedHashMap.put("episode_id", str);
        Show show2 = (Show) kukuFMMedia3Service.y().getValue();
        String valueOf = String.valueOf(show2 != null ? show2.getId() : null);
        Intrinsics.checkNotNullParameter("show_id", "key");
        linkedHashMap.put("show_id", valueOf);
        Intrinsics.checkNotNullParameter("last_played_type", "key");
        linkedHashMap.put("last_played_type", 1);
        j jVar = new j(linkedHashMap);
        b.f(jVar);
        Fe.e eVar = new Fe.e(PlayerStateWorker.class);
        eVar.k(z5.a.LINEAR, TimeUnit.MILLISECONDS);
        Intrinsics.checkNotNullParameter(jVar, "inputData");
        ((s) eVar.c).e = jVar;
        A e = eVar.e();
        Context applicationContext = KukuFMApplication.x.B().getApplicationContext();
        Intrinsics.checkNotNullExpressionValue(applicationContext, "getApplicationContext(...)");
        Intrinsics.checkNotNullParameter(applicationContext, LogCategory.CONTEXT);
        A5.A A = A5.A.A(applicationContext);
        Intrinsics.checkNotNullExpressionValue(A, "getInstance(context)");
        A.o(e);
    }

    public final void B(java.lang.String r11) {
        throw new UnsupportedOperationException("Method not decompiled: com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service.B(java.lang.String):void");
    }

    public final void D() {
        x().d(0L);
        x().pause();
    }

    public final void E() {
        L0 l0 = this.x;
        if (!l0.isCancelled()) {
            l0.cancel((CancellationException) null);
        }
        h0 h0Var = this.k;
        if (h0Var != null) {
            h0Var.c().a();
            h0Var.d();
            this.k = null;
        }
        d.a.k("released so we are good", new Object[0]);
        synchronized (((MediaSessionService) this).a) {
        }
    }

    public final void F(EpisodeContainer episodeContainer, Show show) {
        Intrinsics.checkNotNullParameter(episodeContainer, "currentEpisode");
        Intrinsics.checkNotNullParameter(show, "currentShow");
        if (this.y0) {
            return;
        }
        episodeContainer.getCuPart();
        h0 h0Var = this.k;
        if (h0Var != null) {
            h0Var.e(w());
        }
        p.w(this.H, (CoroutineContext) null, (J) null, new w0(show, episodeContainer, this, null), 3);
    }

    public final void G() {
        UserResponse.SettingsData q;
        Object obj;
        Ai.p pVar = KukuFMApplication.x;
        User t = io.sentry.config.d.t(pVar);
        if (t == null || !t.isPremium() || (q = pVar.B().h().q()) == null) {
            return;
        }
        Iterator it = ((Iterable) D0.a.getValue()).iterator();
        while (true) {
            if (it.hasNext()) {
                obj = it.next();
                if (Intrinsics.c(((AudioVariant) obj).getQuality().getAlternateName(), q.getAudioQuality().getValue())) {
                    break;
                }
            } else {
                obj = null;
                break;
            }
        }
        AudioVariant audioVariant = (AudioVariant) obj;
        if (audioVariant == null) {
            audioVariant = new AudioVariant(ij.b.AUTO, H.a);
        }
        ArrayList arrayList = new ArrayList();
        ArrayList arrayList2 = new ArrayList();
        Y<b3.n0> y = u().l0().a;
        Intrinsics.checkNotNullExpressionValue(y, "getGroups(...)");
        for (b3.n0 n0Var : y) {
            int i = n0Var.b.c;
            int i2 = n0Var.a;
            if (i != 1) {
                if (i == 2) {
                    Fp.h a = Fp.p.p(0, i2).a();
                    while (a.c) {
                        int a2 = a.a();
                        b3.p b = n0Var.b(a2);
                        Intrinsics.checkNotNullExpressionValue(b, "getTrackFormat(...)");
                        arrayList.add(new z(n0Var, b, Integer.valueOf(a2)));
                    }
                }
            } else if (audioVariant.getQuality() != ij.b.AUTO) {
                Fp.h a3 = Fp.p.p(0, i2).a();
                while (a3.c) {
                    int a4 = a3.a();
                    b3.p b2 = n0Var.b(a4);
                    Intrinsics.checkNotNullExpressionValue(b2, "getTrackFormat(...)");
                    if (CollectionsKt.I(audioVariant.getFormatIds(), b2.a)) {
                        arrayList2.add(new Pair(n0Var, Integer.valueOf(a4)));
                    }
                }
            }
        }
        if (arrayList.size() > 1) {
            C.s(arrayList, new C0235l(4));
        }
        z zVar = (z) CollectionsKt.P(1, arrayList);
        D u = u();
        l G02 = u().G0();
        G02.getClass();
        D3.k kVar = new D3.k(G02);
        kVar.c();
        Iterator it2 = arrayList2.iterator();
        while (it2.hasNext()) {
            Pair pair = (Pair) it2.next();
            kVar.h(new i0(((b3.n0) pair.a).b, ((Number) pair.b).intValue()));
        }
        if (zVar != null) {
            kVar.h(new i0(((b3.n0) zVar.a).b, ((Number) zVar.c).intValue()));
        }
        u.p0(new l(kVar));
    }

    public final h0 g(z0 z0Var) {
        Intrinsics.checkNotNullParameter(z0Var, "controllerInfo");
        b0 b0Var = z0Var.a;
        if (!"android.media.session.MediaController".equals(b0Var.a.a)) {
            v vVar = this.r;
            if (vVar == null) {
                Intrinsics.m("packageValidator");
                throw null;
            }
            String str = b0Var.a.a;
            Intrinsics.checkNotNullExpressionValue(str, "getPackageName(...)");
            if (!vVar.V(b0Var.a.c, str)) {
                return null;
            }
        }
        return this.k;
    }

    @Override
    public final void onCreate() {
        super.onCreate();
        this.r = new v(this);
        String str = "com.vlv.aravali.bhakti.playerMedia3.service.media_session_" + UUID.randomUUID();
        C0224f0 x = x();
        C0 v = v();
        v vVar = this.r;
        if (vVar == null) {
            Intrinsics.m("packageValidator");
            throw null;
        }
        J0 j0 = new J0(this, v, vVar, (Ul.p) this.j0.getValue());
        x.getClass();
        e3.d.b(((X) ((Cp.c) x).b).X0());
        Bundle bundle = new Bundle();
        Bundle bundle2 = new Bundle();
        U u = Y.b;
        B0 b0 = B0.e;
        str.getClass();
        this.k = new h0(this, str, x, (PendingIntent) null, b0, b0, b0, j0, bundle, bundle2, new C1810k(new h3.i(this)), 1);
        C0801c c0801c = new C0801c(this);
        synchronized (((MediaSessionService) this).a) {
            c(c0801c).h = c0801c;
        }
        h0 h0Var = this.k;
        if (h0Var != null) {
            h0Var.e(s());
        }
        p.w(this.H, (CoroutineContext) null, (J) null, new u0(this, new C0217c(this, 5), null), 3);
        Qo.b subscribe = nl.a.a(C2198b.class).observeOn(Po.b.a()).subscribe(new Qk.b(new C0219d(this, 0), 2));
        Intrinsics.checkNotNullExpressionValue(subscribe, "subscribe(...)");
        a aVar = this.y;
        aVar.a(subscribe);
        Qo.b subscribe2 = nl.a.a(RxEvent.NetworkConnectivity.class).observeOn(Po.b.a()).subscribe(new Qk.b(new C0219d(this, 1), 3), new Qk.b(new Si.a(2), 4));
        Intrinsics.checkNotNullExpressionValue(subscribe2, "subscribe(...)");
        aVar.a(subscribe2);
    }

    public final void onDestroy() {
        this.y.b();
        E();
        super/*androidx.media3.session.MediaSessionService*/.onDestroy();
    }

    public final int onStartCommand(Intent intent, int i, int i2) {
        super/*androidx.media3.session.MediaSessionService*/.onStartCommand(intent, i, i2);
        return 1;
    }

    public final void onTaskRemoved(Intent intent) {
        super/*androidx.media3.session.MediaSessionService*/.onTaskRemoved(intent);
        ji.a.c = false;
        if (this.A0 != null) {
            KukuFMApplication.x.B().h().m0("", 0L);
            CountDownTimer countDownTimer = this.A0;
            if (countDownTimer != null) {
                countDownTimer.cancel();
            }
            this.A0 = null;
        }
        d.a.k("Task removed", new Object[0]);
        if (((X) ((Cp.c) x()).b).g() == 3) {
            q(this);
        }
        E();
        stopSelf();
    }

    public final java.lang.Object r(com.vlv.aravali.common.models.Show r8, int r9, kotlin.jvm.functions.Function2 r10, kotlin.jvm.functions.Function1 r11, rp.c r12) {
        throw new UnsupportedOperationException("Method not decompiled: com.vlv.aravali.playerMedia3.service.KukuFMMedia3Service.r(com.vlv.aravali.common.models.Show, int, kotlin.jvm.functions.Function2, kotlin.jvm.functions.Function1, rp.c):java.lang.Object");
    }

    public final List s() {
        return kotlin.collections.y.l(new String[]{"OnePlus", "realme", "Oppo", "vivo"}).contains(Build.MANUFACTURER) ? kotlin.collections.y.l(new s4.b[]{AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.previous", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.next", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.forward", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.stop", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.back", null)}) : kotlin.collections.y.l(new s4.b[]{AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.back", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.forward", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.next", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.stop", null)});
    }

    public final D0 t() {
        return (D0) this.Z.getValue();
    }

    public final ExoPlayer u() {
        return (ExoPlayer) this.q0.getValue();
    }

    public final C0 v() {
        C0 c0 = this.M;
        if (c0 != null) {
            return c0;
        }
        Intrinsics.m("media3PlayerRepo");
        throw null;
    }

    public final List w() {
        return kotlin.collections.y.l(new s4.b[]{AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.back_disabled", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.forward_disabled", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.next_disabled", null), AbstractC1929a.a(this, "com.vlv.aravali.playerMedia3.stop", null)});
    }

    public final C0224f0 x() {
        return (C0224f0) this.r0.getValue();
    }

    public final D0 y() {
        return (D0) this.Y.getValue();
    }

    public final void z() {
        Show show = (Show) y().getValue();
        if (show == null) {
            return;
        }
        x().pause();
        if (this.x0) {
            return;
        }
        this.x0 = true;
        d.a.k("loadNextShow", new Object[0]);
        p.w(this.H, (CoroutineContext) null, (J) null, new Tl.J(this, show, null), 3);
    }
}