package com.strmr.ps.data.repository;

import androidx.media3.container.NalUnitUtil;
import com.strmr.ps.data.model.ContentItem;
import defpackage.cr4;
import defpackage.kg4;
import defpackage.kp6;
import defpackage.pq6;
import defpackage.uz1;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000,\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0006\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0007\u0018\u0000 \u00142\u00020\u0001:\u0001\u0014B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u001f\u0010\u000b\u001a\u0004\u0018\u00010\n2\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\b¢\u0006\u0004\b\u000b\u0010\fJ%\u0010\u000f\u001a\u00020\u000e2\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\r\u001a\u00020\n¢\u0006\u0004\b\u000f\u0010\u0010J\u001d\u0010\u0011\u001a\u00020\u000e2\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\b¢\u0006\u0004\b\u0011\u0010\u0012R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u0013¨\u0006\u0015"}, d2 = {"Lcom/strmr/ps/data/repository/WatchStatusProvider;", "", "Lkg4;", "repository", "<init>", "(Lkg4;)V", "", "tmdbId", "Lcom/strmr/ps/data/model/ContentItem$ItemType;", "itemType", "", "getProgressDirect", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;)Ljava/lang/Double;", "progress", "Le6a;", "setProgressDirect", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;D)V", "removeProgressDirect", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;)V", "Lkg4;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class WatchStatusProvider {

    /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */
    @kp6
    public static final Companion INSTANCE = new Companion(null);

    @pq6
    private static volatile WatchStatusProvider instance;

    @kp6
    private final kg4 repository;

    @Metadata(d1 = {"\u00000\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0006\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\b\u0086\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003J\u001f\u0010\t\u001a\u0004\u0018\u00010\b2\u0006\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u0006¢\u0006\u0004\b\t\u0010\nJ%\u0010\r\u001a\u00020\f2\u0006\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u000b\u001a\u00020\b¢\u0006\u0004\b\r\u0010\u000eJ\u001d\u0010\u000f\u001a\u00020\f2\u0006\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u0006¢\u0006\u0004\b\u000f\u0010\u0010R\u0018\u0010\u0012\u001a\u0004\u0018\u00010\u00118\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0012\u0010\u0013¨\u0006\u0014"}, d2 = {"Lcom/strmr/ps/data/repository/WatchStatusProvider$Companion;", "", "<init>", "()V", "", "tmdbId", "Lcom/strmr/ps/data/model/ContentItem$ItemType;", "itemType", "", "getProgress", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;)Ljava/lang/Double;", "progress", "Le6a;", "setProgress", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;D)V", "removeProgress", "(ILcom/strmr/ps/data/model/ContentItem$ItemType;)V", "Lcom/strmr/ps/data/repository/WatchStatusProvider;", "instance", "Lcom/strmr/ps/data/repository/WatchStatusProvider;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class Companion {
        public /* synthetic */ Companion(uz1 uz1Var) {
            this();
        }

        @pq6
        public final Double getProgress(int tmdbId, @kp6 ContentItem.ItemType itemType) {
            cr4.g(itemType, "itemType");
            WatchStatusProvider watchStatusProvider = WatchStatusProvider.instance;
            if (watchStatusProvider != null) {
                return watchStatusProvider.getProgressDirect(tmdbId, itemType);
            }
            return null;
        }

        public final void removeProgress(int tmdbId, @kp6 ContentItem.ItemType itemType) {
            cr4.g(itemType, "itemType");
            WatchStatusProvider watchStatusProvider = WatchStatusProvider.instance;
            if (watchStatusProvider != null) {
                watchStatusProvider.removeProgressDirect(tmdbId, itemType);
            }
        }

        public final void setProgress(int tmdbId, @kp6 ContentItem.ItemType itemType, double progress) {
            cr4.g(itemType, "itemType");
            WatchStatusProvider watchStatusProvider = WatchStatusProvider.instance;
            if (watchStatusProvider != null) {
                watchStatusProvider.setProgressDirect(tmdbId, itemType, progress);
            }
        }

        private Companion() {
        }
    }

    @Inject
    public WatchStatusProvider(@kp6 kg4 kg4Var) {
        cr4.g(kg4Var, "repository");
        this.repository = kg4Var;
        instance = this;
    }

    @pq6
    public final Double getProgressDirect(int tmdbId, @kp6 ContentItem.ItemType itemType) {
        cr4.g(itemType, "itemType");
        return this.repository.getProgress(tmdbId, itemType);
    }

    public final void removeProgressDirect(int tmdbId, @kp6 ContentItem.ItemType itemType) {
        cr4.g(itemType, "itemType");
        this.repository.removeProgressSync(tmdbId, itemType);
    }

    public final void setProgressDirect(int tmdbId, @kp6 ContentItem.ItemType itemType, double progress) {
        cr4.g(itemType, "itemType");
        this.repository.setProgressSync(tmdbId, itemType, progress);
    }
}