package com.strmr.ps.data.repository;

import androidx.media3.container.NalUnitUtil;
import com.strmr.ps.data.local.dao.SyncMetadataDao;
import com.strmr.ps.data.local.entity.SyncMetadataEntity;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.kp6;
import defpackage.m02;
import defpackage.m12;
import defpackage.pq6;
import defpackage.s38;
import defpackage.sc2;
import defpackage.wj0;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* 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\u000e\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\n\b\u0007\u0018\u0000 \u00182\u00020\u0001:\u0001\u0018B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0018\u0010\t\u001a\u00020\b2\u0006\u0010\u0007\u001a\u00020\u0006H\u0086@¢\u0006\u0004\b\t\u0010\nJ$\u0010\r\u001a\u00020\f2\u0006\u0010\u0007\u001a\u00020\u00062\n\b\u0002\u0010\u000b\u001a\u0004\u0018\u00010\u0006H\u0086@¢\u0006\u0004\b\r\u0010\u000eJ \u0010\u0011\u001a\u00020\b2\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u0010\u001a\u00020\u000fH\u0086@¢\u0006\u0004\b\u0011\u0010\u0012J\u001a\u0010\u0013\u001a\u0004\u0018\u00010\u00062\u0006\u0010\u0007\u001a\u00020\u0006H\u0086@¢\u0006\u0004\b\u0013\u0010\nJ\u0018\u0010\u0014\u001a\u00020\f2\u0006\u0010\u0007\u001a\u00020\u0006H\u0086@¢\u0006\u0004\b\u0014\u0010\nJ\u0010\u0010\u0015\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0015\u0010\u0016R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u0017¨\u0006\u0019"}, d2 = {"Lcom/strmr/ps/data/repository/SyncMetadataRepository;", "", "Lcom/strmr/ps/data/local/dao/SyncMetadataDao;", "syncMetadataDao", "<init>", "(Lcom/strmr/ps/data/local/dao/SyncMetadataDao;)V", "", "key", "", "isStale", "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "traktTimestamp", "Le6a;", "markSynced", "(Ljava/lang/String;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "", "thresholdMs", "isSyncedWithin", "(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "getTraktTimestamp", "clearSyncData", "clearAll", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lcom/strmr/ps/data/local/dao/SyncMetadataDao;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class SyncMetadataRepository {
    private static final long STALE_THRESHOLD_MS = 86400000;

    @kp6
    private final SyncMetadataDao syncMetadataDao;

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$clearAll$2, reason: invalid class name */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$clearAll$2", f = "SyncMetadataRepository.kt", i = {}, l = {47}, m = "invokeSuspend", n = {}, s = {})
    public static final class AnonymousClass2 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        int label;

        public AnonymousClass2(Continuation<? super AnonymousClass2> continuation) {
            super(2, continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new AnonymousClass2(continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((AnonymousClass2) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                this.label = 1;
                if (syncMetadataDao.clearAll(this) == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            return e6a.a;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$clearSyncData$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$clearSyncData$2", f = "SyncMetadataRepository.kt", i = {}, l = {43}, m = "invokeSuspend", n = {}, s = {})
    public static final class C04102 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $key;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C04102(String str, Continuation<? super C04102> continuation) {
            super(2, continuation);
            this.$key = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new C04102(this.$key, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C04102) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                String str = this.$key;
                this.label = 1;
                if (syncMetadataDao.delete(str, this) == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            return e6a.a;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$getTraktTimestamp$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\u0010\u0002\u001a\u0004\u0018\u00010\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "<anonymous>", "(Lak1;)Ljava/lang/String;"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$getTraktTimestamp$2", f = "SyncMetadataRepository.kt", i = {}, l = {NalUnitUtil.H265_NAL_UNIT_TYPE_PREFIX_SEI}, m = "invokeSuspend", n = {}, s = {})
    public static final class C04112 extends SuspendLambda implements gr3<ak1, Continuation<? super String>, Object> {
        final /* synthetic */ String $key;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C04112(String str, Continuation<? super C04112> continuation) {
            super(2, continuation);
            this.$key = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new C04112(this.$key, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super String> continuation) {
            return ((C04112) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                String str = this.$key;
                this.label = 1;
                obj = syncMetadataDao.get(str, this);
                if (obj == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            SyncMetadataEntity syncMetadataEntity = (SyncMetadataEntity) obj;
            if (syncMetadataEntity != null) {
                return syncMetadataEntity.getTraktActivityTimestamp();
            }
            return null;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$isStale$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "<anonymous>", "(Lak1;)Z"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$isStale$2", f = "SyncMetadataRepository.kt", i = {}, l = {19}, m = "invokeSuspend", n = {}, s = {})
    public static final class C04122 extends SuspendLambda implements gr3<ak1, Continuation<? super Boolean>, Object> {
        final /* synthetic */ String $key;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C04122(String str, Continuation<? super C04122> continuation) {
            super(2, continuation);
            this.$key = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new C04122(this.$key, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super Boolean> continuation) {
            return ((C04122) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                String str = this.$key;
                this.label = 1;
                obj = syncMetadataDao.getLastSyncTime(str, this);
                if (obj == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            Long l = (Long) obj;
            if (l != null) {
                return Boxing.boxBoolean(System.currentTimeMillis() - l.longValue() > SyncMetadataRepository.STALE_THRESHOLD_MS);
            }
            return Boxing.boxBoolean(true);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$isSyncedWithin$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "<anonymous>", "(Lak1;)Z"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$isSyncedWithin$2", f = "SyncMetadataRepository.kt", i = {}, l = {34}, m = "invokeSuspend", n = {}, s = {})
    public static final class C04132 extends SuspendLambda implements gr3<ak1, Continuation<? super Boolean>, Object> {
        final /* synthetic */ String $key;
        final /* synthetic */ long $thresholdMs;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C04132(String str, long j, Continuation<? super C04132> continuation) {
            super(2, continuation);
            this.$key = str;
            this.$thresholdMs = j;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new C04132(this.$key, this.$thresholdMs, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super Boolean> continuation) {
            return ((C04132) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                String str = this.$key;
                this.label = 1;
                obj = syncMetadataDao.getLastSyncTime(str, this);
                if (obj == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            Long l = (Long) obj;
            if (l != null) {
                return Boxing.boxBoolean(System.currentTimeMillis() - l.longValue() <= this.$thresholdMs);
            }
            return Boxing.boxBoolean(false);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncMetadataRepository$markSynced$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncMetadataRepository$markSynced$2", f = "SyncMetadataRepository.kt", i = {}, l = {24}, m = "invokeSuspend", n = {}, s = {})
    public static final class C04142 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $key;
        final /* synthetic */ String $traktTimestamp;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C04142(String str, String str2, Continuation<? super C04142> continuation) {
            super(2, continuation);
            this.$key = str;
            this.$traktTimestamp = str2;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return SyncMetadataRepository.this.new C04142(this.$key, this.$traktTimestamp, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C04142) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                SyncMetadataDao syncMetadataDao = SyncMetadataRepository.this.syncMetadataDao;
                SyncMetadataEntity syncMetadataEntity = new SyncMetadataEntity(this.$key, System.currentTimeMillis(), this.$traktTimestamp);
                this.label = 1;
                if (syncMetadataDao.upsert(syncMetadataEntity, this) == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            return e6a.a;
        }
    }

    @Inject
    public SyncMetadataRepository(@kp6 SyncMetadataDao syncMetadataDao) {
        cr4.g(syncMetadataDao, "syncMetadataDao");
        this.syncMetadataDao = syncMetadataDao;
    }

    public static /* synthetic */ Object markSynced$default(SyncMetadataRepository syncMetadataRepository, String str, String str2, Continuation continuation, int i, Object obj) {
        if ((i & 2) != 0) {
            str2 = null;
        }
        return syncMetadataRepository.markSynced(str, str2, continuation);
    }

    @pq6
    public final Object clearAll(@kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new AnonymousClass2(null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object clearSyncData(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C04102(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object getTraktTimestamp(@kp6 String str, @kp6 Continuation<? super String> continuation) {
        m12 m12Var = sc2.a;
        return wj0.f(m02.c, new C04112(str, null), continuation);
    }

    @pq6
    public final Object isStale(@kp6 String str, @kp6 Continuation<? super Boolean> continuation) {
        m12 m12Var = sc2.a;
        return wj0.f(m02.c, new C04122(str, null), continuation);
    }

    @pq6
    public final Object isSyncedWithin(@kp6 String str, long j, @kp6 Continuation<? super Boolean> continuation) {
        m12 m12Var = sc2.a;
        return wj0.f(m02.c, new C04132(str, j, null), continuation);
    }

    @pq6
    public final Object markSynced(@kp6 String str, @pq6 String str2, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C04142(str, str2, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }
}