package com.strmr.ps.ui;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.strmr.ps.data.model.ContentItem;
import com.strmr.ps.data.repository.WatchStatusProvider;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.k63;
import defpackage.kp6;
import defpackage.up8;
import defpackage.vp8;
import defpackage.xp8;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0007\u0018\u00002\u00020\u0001:\u0001\u0006B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005¨\u0006\u0007"}, d2 = {"Lcom/strmr/ps/ui/WatchedBadgeManager;", "", "Lcom/strmr/ps/data/repository/WatchStatusProvider;", "watchStatusProvider", "<init>", "(Lcom/strmr/ps/data/repository/WatchStatusProvider;)V", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class WatchedBadgeManager {
    public final WatchStatusProvider a;
    public final vp8 b;
    public final up8 c;

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\b\u0086\b\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/ui/WatchedBadgeManager$a;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final /* data */ class a {
        public final int a;
        public final ContentItem.ItemType b;
        public final boolean c;

        public a(int i, ContentItem.ItemType itemType, boolean z) {
            cr4.g(itemType, "itemType");
            this.a = i;
            this.b = itemType;
            this.c = z;
        }

        public final boolean equals(Object obj) {
            if (this == obj) {
                return true;
            }
            if (!(obj instanceof a)) {
                return false;
            }
            a aVar = (a) obj;
            return this.a == aVar.a && this.b == aVar.b && this.c == aVar.c;
        }

        public final int hashCode() {
            return Boolean.hashCode(this.c) + ((this.b.hashCode() + (Integer.hashCode(this.a) * 31)) * 31);
        }

        public final String toString() {
            return "BadgeUpdate(tmdbId=" + this.a + ", itemType=" + this.b + ", isWatched=" + this.c + ")";
        }
    }

    @Inject
    public WatchedBadgeManager(@kp6 WatchStatusProvider watchStatusProvider) {
        cr4.g(watchStatusProvider, "watchStatusProvider");
        this.a = watchStatusProvider;
        vp8 vp8VarB = xp8.b(0, 10, 4);
        this.b = vp8VarB;
        this.c = k63.a(vp8VarB);
    }

    public final Object a(int i, ContentItem.ItemType itemType, boolean z, Continuation continuation) throws Throwable {
        WatchStatusProvider watchStatusProvider = this.a;
        if (z) {
            watchStatusProvider.setProgressDirect(i, itemType, 1.0d);
        } else {
            watchStatusProvider.removeProgressDirect(i, itemType);
        }
        Object objEmit = this.b.emit(new a(i, itemType, z), continuation);
        return objEmit == ck1.a ? objEmit : e6a.a;
    }
}