package com.strmr.ps.data.repository;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.extractor.ts.TsExtractor;
import com.google.android.gms.common.internal.ImagesContract;
import com.strmr.ps.data.local.dao.EpisodeWatchStatusDao;
import com.strmr.ps.data.local.entity.EpisodeWatchStatus;
import com.strmr.ps.data.local.entity.PlaybackProgress;
import com.strmr.ps.data.model.trakt.TraktEpisodeProgress;
import com.strmr.ps.data.model.trakt.TraktSeasonProgress;
import com.strmr.ps.data.model.trakt.TraktShowProgress;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.fi7;
import defpackage.gr3;
import defpackage.io6;
import defpackage.kp6;
import defpackage.pq6;
import defpackage.s38;
import defpackage.uz1;
import defpackage.vw2;
import defpackage.vx8;
import defpackage.wo5;
import defpackage.y41;
import java.time.OffsetDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeParseException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
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.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000X\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0007\u0018\u0000 #2\u00020\u0001:\u0002#$B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J1\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\b2\b\u0010\u000b\u001a\u0004\u0018\u00010\n2\u0006\u0010\f\u001a\u00020\nH\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ\u001b\u0010\u0012\u001a\u0004\u0018\u00010\n2\b\u0010\u0011\u001a\u0004\u0018\u00010\u0010H\u0002¢\u0006\u0004\b\u0012\u0010\u0013J&\u0010\u0019\u001a\b\u0012\u0004\u0012\u00020\r0\u00182\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0017\u001a\u00020\u0016H\u0086@¢\u0006\u0004\b\u0019\u0010\u001aJB\u0010 \u001a\u00020\u001e2\f\u0010\u001b\u001a\b\u0012\u0004\u0012\u00020\r0\u00182\"\u0010\u001f\u001a\u001e\b\u0001\u0012\u0004\u0012\u00020\u0006\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u001e0\u001d\u0012\u0006\u0012\u0004\u0018\u00010\u00010\u001cH\u0086@¢\u0006\u0004\b \u0010!R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\"¨\u0006%"}, d2 = {"Lcom/strmr/ps/data/repository/SyncConflictResolver;", "", "Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;", "episodeWatchStatusDao", "<init>", "(Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;)V", "Lcom/strmr/ps/data/local/entity/EpisodeWatchStatus;", ImagesContract.LOCAL, "", "remoteWatched", "", "remoteTimestamp", "localTimestamp", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", "resolveByTimestamp", "(Lcom/strmr/ps/data/local/entity/EpisodeWatchStatus;ZLjava/lang/Long;J)Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", "", "raw", "parseDateMillis", "(Ljava/lang/String;)Ljava/lang/Long;", "", "showTmdbId", "Lcom/strmr/ps/data/model/trakt/TraktShowProgress;", "remoteProgress", "", "resolveEpisodeConflicts", "(ILcom/strmr/ps/data/model/trakt/TraktShowProgress;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "conflicts", "Lkotlin/Function2;", "Lkotlin/coroutines/Continuation;", "Le6a;", "onPushToRemote", "applyResolutions", "(Ljava/util/List;Lgr3;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;", "Companion", "ConflictResult", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class SyncConflictResolver {

    @kp6
    private static final String TAG = "SyncConflictResolver";

    @kp6
    private final EpisodeWatchStatusDao episodeWatchStatusDao;

    @Metadata(d1 = {"\u0000\u001a\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b6\u0018\u00002\u00020\u0001:\u0003\u0004\u0005\u0006B\t\b\u0004¢\u0006\u0004\b\u0002\u0010\u0003\u0082\u0001\u0003\u0007\b\t¨\u0006\n"}, d2 = {"Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", "", "<init>", "()V", "KeepLocal", "UseRemote", "NoConflict", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$KeepLocal;", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$NoConflict;", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$UseRemote;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static abstract class ConflictResult {

        @Metadata(d1 = {"\u0000*\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000e\n\u0000\b\u0086\b\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0004\b\u0004\u0010\u0005J\t\u0010\b\u001a\u00020\u0003HÆ\u0003J\u0013\u0010\t\u001a\u00020\u00002\b\b\u0002\u0010\u0002\u001a\u00020\u0003HÆ\u0001J\u0013\u0010\n\u001a\u00020\u000b2\b\u0010\f\u001a\u0004\u0018\u00010\rHÖ\u0003J\t\u0010\u000e\u001a\u00020\u000fHÖ\u0001J\t\u0010\u0010\u001a\u00020\u0011HÖ\u0001R\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\u0006\u0010\u0007¨\u0006\u0012"}, d2 = {"Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$KeepLocal;", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", PlaybackProgress.TYPE_EPISODE, "Lcom/strmr/ps/data/local/entity/EpisodeWatchStatus;", "<init>", "(Lcom/strmr/ps/data/local/entity/EpisodeWatchStatus;)V", "getEpisode", "()Lcom/strmr/ps/data/local/entity/EpisodeWatchStatus;", "component1", "copy", "equals", "", "other", "", "hashCode", "", "toString", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final /* data */ class KeepLocal extends ConflictResult {

            @kp6
            private final EpisodeWatchStatus episode;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public KeepLocal(@kp6 EpisodeWatchStatus episodeWatchStatus) {
                super(null);
                cr4.g(episodeWatchStatus, PlaybackProgress.TYPE_EPISODE);
                this.episode = episodeWatchStatus;
            }

            public static /* synthetic */ KeepLocal copy$default(KeepLocal keepLocal, EpisodeWatchStatus episodeWatchStatus, int i, Object obj) {
                if ((i & 1) != 0) {
                    episodeWatchStatus = keepLocal.episode;
                }
                return keepLocal.copy(episodeWatchStatus);
            }

            @kp6
            /* JADX INFO: renamed from: component1, reason: from getter */
            public final EpisodeWatchStatus getEpisode() {
                return this.episode;
            }

            @kp6
            public final KeepLocal copy(@kp6 EpisodeWatchStatus episode) {
                cr4.g(episode, PlaybackProgress.TYPE_EPISODE);
                return new KeepLocal(episode);
            }

            public boolean equals(@pq6 Object other) {
                if (this == other) {
                    return true;
                }
                return (other instanceof KeepLocal) && cr4.b(this.episode, ((KeepLocal) other).episode);
            }

            @kp6
            public final EpisodeWatchStatus getEpisode() {
                return this.episode;
            }

            public int hashCode() {
                return this.episode.hashCode();
            }

            @kp6
            public String toString() {
                return "KeepLocal(episode=" + this.episode + ")";
            }
        }

        @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\bÆ\u0002\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003¨\u0006\u0004"}, d2 = {"Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$NoConflict;", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", "<init>", "()V", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final class NoConflict extends ConflictResult {

            @kp6
            public static final NoConflict INSTANCE = new NoConflict();

            private NoConflict() {
                super(null);
            }
        }

        @Metadata(d1 = {"\u0000.\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\t\n\u0002\b\u0014\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0000\b\u0086\b\u0018\u00002\u00020\u0001B1\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\u0006\u0010\u0005\u001a\u00020\u0003\u0012\u0006\u0010\u0006\u001a\u00020\u0007\u0012\b\u0010\b\u001a\u0004\u0018\u00010\t¢\u0006\u0004\b\n\u0010\u000bJ\t\u0010\u0015\u001a\u00020\u0003HÆ\u0003J\t\u0010\u0016\u001a\u00020\u0003HÆ\u0003J\t\u0010\u0017\u001a\u00020\u0003HÆ\u0003J\t\u0010\u0018\u001a\u00020\u0007HÆ\u0003J\u0010\u0010\u0019\u001a\u0004\u0018\u00010\tHÆ\u0003¢\u0006\u0002\u0010\u0013JB\u0010\u001a\u001a\u00020\u00002\b\b\u0002\u0010\u0002\u001a\u00020\u00032\b\b\u0002\u0010\u0004\u001a\u00020\u00032\b\b\u0002\u0010\u0005\u001a\u00020\u00032\b\b\u0002\u0010\u0006\u001a\u00020\u00072\n\b\u0002\u0010\b\u001a\u0004\u0018\u00010\tHÆ\u0001¢\u0006\u0002\u0010\u001bJ\u0013\u0010\u001c\u001a\u00020\u00072\b\u0010\u001d\u001a\u0004\u0018\u00010\u001eHÖ\u0003J\t\u0010\u001f\u001a\u00020\u0003HÖ\u0001J\t\u0010 \u001a\u00020!HÖ\u0001R\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\f\u0010\rR\u0011\u0010\u0004\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\u000e\u0010\rR\u0011\u0010\u0005\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\u000f\u0010\rR\u0011\u0010\u0006\u001a\u00020\u0007¢\u0006\b\n\u0000\u001a\u0004\b\u0010\u0010\u0011R\u0015\u0010\b\u001a\u0004\u0018\u00010\t¢\u0006\n\n\u0002\u0010\u0014\u001a\u0004\b\u0012\u0010\u0013¨\u0006\""}, d2 = {"Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$UseRemote;", "Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult;", "showTmdbId", "", "season", PlaybackProgress.TYPE_EPISODE, "watched", "", "remoteTimestamp", "", "<init>", "(IIIZLjava/lang/Long;)V", "getShowTmdbId", "()I", "getSeason", "getEpisode", "getWatched", "()Z", "getRemoteTimestamp", "()Ljava/lang/Long;", "Ljava/lang/Long;", "component1", "component2", "component3", "component4", "component5", "copy", "(IIIZLjava/lang/Long;)Lcom/strmr/ps/data/repository/SyncConflictResolver$ConflictResult$UseRemote;", "equals", "other", "", "hashCode", "toString", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final /* data */ class UseRemote extends ConflictResult {
            private final int episode;

            @pq6
            private final Long remoteTimestamp;
            private final int season;
            private final int showTmdbId;
            private final boolean watched;

            public UseRemote(int i, int i2, int i3, boolean z, @pq6 Long l) {
                super(null);
                this.showTmdbId = i;
                this.season = i2;
                this.episode = i3;
                this.watched = z;
                this.remoteTimestamp = l;
            }

            public static /* synthetic */ UseRemote copy$default(UseRemote useRemote, int i, int i2, int i3, boolean z, Long l, int i4, Object obj) {
                if ((i4 & 1) != 0) {
                    i = useRemote.showTmdbId;
                }
                if ((i4 & 2) != 0) {
                    i2 = useRemote.season;
                }
                if ((i4 & 4) != 0) {
                    i3 = useRemote.episode;
                }
                if ((i4 & 8) != 0) {
                    z = useRemote.watched;
                }
                if ((i4 & 16) != 0) {
                    l = useRemote.remoteTimestamp;
                }
                Long l2 = l;
                int i5 = i3;
                return useRemote.copy(i, i2, i5, z, l2);
            }

            /* JADX INFO: renamed from: component1, reason: from getter */
            public final int getShowTmdbId() {
                return this.showTmdbId;
            }

            /* JADX INFO: renamed from: component2, reason: from getter */
            public final int getSeason() {
                return this.season;
            }

            /* JADX INFO: renamed from: component3, reason: from getter */
            public final int getEpisode() {
                return this.episode;
            }

            /* JADX INFO: renamed from: component4, reason: from getter */
            public final boolean getWatched() {
                return this.watched;
            }

            @pq6
            /* JADX INFO: renamed from: component5, reason: from getter */
            public final Long getRemoteTimestamp() {
                return this.remoteTimestamp;
            }

            @kp6
            public final UseRemote copy(int showTmdbId, int season, int episode, boolean watched, @pq6 Long remoteTimestamp) {
                return new UseRemote(showTmdbId, season, episode, watched, remoteTimestamp);
            }

            public boolean equals(@pq6 Object other) {
                if (this == other) {
                    return true;
                }
                if (!(other instanceof UseRemote)) {
                    return false;
                }
                UseRemote useRemote = (UseRemote) other;
                return this.showTmdbId == useRemote.showTmdbId && this.season == useRemote.season && this.episode == useRemote.episode && this.watched == useRemote.watched && cr4.b(this.remoteTimestamp, useRemote.remoteTimestamp);
            }

            public final int getEpisode() {
                return this.episode;
            }

            @pq6
            public final Long getRemoteTimestamp() {
                return this.remoteTimestamp;
            }

            public final int getSeason() {
                return this.season;
            }

            public final int getShowTmdbId() {
                return this.showTmdbId;
            }

            public final boolean getWatched() {
                return this.watched;
            }

            public int hashCode() {
                int iC = fi7.c(fi7.a(this.episode, fi7.a(this.season, Integer.hashCode(this.showTmdbId) * 31, 31), 31), 31, this.watched);
                Long l = this.remoteTimestamp;
                return iC + (l == null ? 0 : l.hashCode());
            }

            @kp6
            public String toString() {
                int i = this.showTmdbId;
                int i2 = this.season;
                int i3 = this.episode;
                boolean z = this.watched;
                Long l = this.remoteTimestamp;
                StringBuilder sbR = vw2.r("UseRemote(showTmdbId=", i, ", season=", ", episode=", i2);
                sbR.append(i3);
                sbR.append(", watched=");
                sbR.append(z);
                sbR.append(", remoteTimestamp=");
                sbR.append(l);
                sbR.append(")");
                return sbR.toString();
            }
        }

        public /* synthetic */ ConflictResult(uz1 uz1Var) {
            this();
        }

        private ConflictResult() {
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncConflictResolver$applyResolutions$1, reason: invalid class name */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncConflictResolver", f = "SyncConflictResolver.kt", i = {0, 0, 1, 1, 1, 1, 2, 2, 3, 3, 4, 4}, l = {166, TsExtractor.TS_STREAM_TYPE_AC4, 176, 184, 197}, m = "applyResolutions", n = {"this", "onPushToRemote", "this", "onPushToRemote", "conflict", "now", "this", "onPushToRemote", "this", "onPushToRemote", "this", "onPushToRemote"}, s = {"L$0", "L$1", "L$0", "L$1", "L$3", "J$0", "L$0", "L$1", "L$0", "L$1", "L$0", "L$1"})
    public static final class AnonymousClass1 extends ContinuationImpl {
        long J$0;
        Object L$0;
        Object L$1;
        Object L$2;
        Object L$3;
        int label;
        /* synthetic */ Object result;

        public AnonymousClass1(Continuation<? super AnonymousClass1> continuation) {
            super(continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        @pq6
        public final Object invokeSuspend(@kp6 Object obj) {
            this.result = obj;
            this.label |= Integer.MIN_VALUE;
            return SyncConflictResolver.this.applyResolutions(null, null, this);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SyncConflictResolver$resolveEpisodeConflicts$1, reason: invalid class name and case insensitive filesystem */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.SyncConflictResolver", f = "SyncConflictResolver.kt", i = {0, 0, 0, 0}, l = {59}, m = "resolveEpisodeConflicts", n = {"this", "remoteProgress", "conflicts", "showTmdbId"}, s = {"L$0", "L$1", "L$2", "I$0"})
    public static final class C04091 extends ContinuationImpl {
        int I$0;
        Object L$0;
        Object L$1;
        Object L$2;
        int label;
        /* synthetic */ Object result;

        public C04091(Continuation<? super C04091> continuation) {
            super(continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        @pq6
        public final Object invokeSuspend(@kp6 Object obj) {
            this.result = obj;
            this.label |= Integer.MIN_VALUE;
            return SyncConflictResolver.this.resolveEpisodeConflicts(0, null, this);
        }
    }

    @Inject
    public SyncConflictResolver(@kp6 EpisodeWatchStatusDao episodeWatchStatusDao) {
        cr4.g(episodeWatchStatusDao, "episodeWatchStatusDao");
        this.episodeWatchStatusDao = episodeWatchStatusDao;
    }

    private final Long parseDateMillis(String raw) {
        if (raw == null) {
            return null;
        }
        try {
            return Long.valueOf(OffsetDateTime.parse(raw, DateTimeFormatter.ISO_OFFSET_DATE_TIME).toInstant().toEpochMilli());
        } catch (DateTimeParseException unused) {
            return null;
        }
    }

    private final ConflictResult resolveByTimestamp(EpisodeWatchStatus local, boolean remoteWatched, Long remoteTimestamp, long localTimestamp) {
        if (localTimestamp > (remoteTimestamp != null ? remoteTimestamp.longValue() : 0L)) {
            local.getSeason();
            local.getEpisode();
            return new ConflictResult.KeepLocal(local);
        }
        local.getSeason();
        local.getEpisode();
        return new ConflictResult.UseRemote(local.getShowTmdbId(), local.getSeason(), local.getEpisode(), remoteWatched, remoteTimestamp);
    }

    /* JADX WARN: Code restructure failed: missing block: B:44:0x013a, code lost:
    
        if (r0.markWatched(r12, r13, r12, r34, r15, r17) == r3) goto L58;
     */
    /* JADX WARN: Code restructure failed: missing block: B:46:0x013e, code lost:
    
        r10 = r0;
        r0 = r1;
        r4 = r5;
        r1 = r9;
     */
    /* JADX WARN: Code restructure failed: missing block: B:47:0x0142, code lost:
    
        r5 = 5;
     */
    /* JADX WARN: Code restructure failed: missing block: B:54:0x0190, code lost:
    
        if (r10.upsert(r19, r9) == r3) goto L58;
     */
    /* JADX WARN: Removed duplicated region for block: B:24:0x00a2  */
    /* JADX WARN: Removed duplicated region for block: B:39:0x0100  */
    /* JADX WARN: Removed duplicated region for block: B:49:0x0146  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:59:0x01bb -> B:60:0x01be). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:63:0x01cc -> B:48:0x0143). Please report as a decompilation issue!!! */
    @pq6
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object applyResolutions(@kp6 List<? extends ConflictResult> list, @kp6 gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var, @kp6 Continuation<? super e6a> continuation) {
        AnonymousClass1 anonymousClass1;
        SyncConflictResolver syncConflictResolver;
        Iterator<? extends ConflictResult> it;
        SyncConflictResolver syncConflictResolver2;
        gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var2;
        long j;
        gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var3;
        SyncConflictResolver syncConflictResolver3;
        Iterator<? extends ConflictResult> it2;
        ConflictResult conflictResult;
        SyncConflictResolver syncConflictResolver4;
        AnonymousClass1 anonymousClass12;
        gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var4;
        char c;
        if (continuation instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) continuation;
            int i = anonymousClass1.label;
            if ((i & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i - Integer.MIN_VALUE;
                syncConflictResolver = this;
            } else {
                syncConflictResolver = this;
                anonymousClass1 = syncConflictResolver.new AnonymousClass1(continuation);
            }
        }
        Object obj = anonymousClass1.result;
        ck1 ck1Var = ck1.a;
        int i2 = anonymousClass1.label;
        char c2 = 5;
        int i3 = 1;
        if (i2 == 0) {
            s38.b(obj);
            it = list.iterator();
            syncConflictResolver2 = syncConflictResolver;
            gr3Var2 = gr3Var;
        } else if (i2 == 1) {
            it = (Iterator) anonymousClass1.L$2;
            gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var5 = (gr3) anonymousClass1.L$1;
            SyncConflictResolver syncConflictResolver5 = (SyncConflictResolver) anonymousClass1.L$0;
            s38.b(obj);
            gr3Var2 = gr3Var5;
            syncConflictResolver2 = syncConflictResolver5;
        } else if (i2 == 2) {
            long j2 = anonymousClass1.J$0;
            conflictResult = (ConflictResult) anonymousClass1.L$3;
            Iterator<? extends ConflictResult> it3 = (Iterator) anonymousClass1.L$2;
            gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var6 = (gr3) anonymousClass1.L$1;
            SyncConflictResolver syncConflictResolver6 = (SyncConflictResolver) anonymousClass1.L$0;
            s38.b(obj);
            j = j2;
            it2 = it3;
            gr3Var3 = gr3Var6;
            syncConflictResolver3 = syncConflictResolver6;
            if (((EpisodeWatchStatus) obj) == null) {
                EpisodeWatchStatusDao episodeWatchStatusDao = syncConflictResolver3.episodeWatchStatusDao;
                ConflictResult.UseRemote useRemote = (ConflictResult.UseRemote) conflictResult;
                int showTmdbId = useRemote.getShowTmdbId();
                int season = useRemote.getSeason();
                int episode = useRemote.getEpisode();
                Long remoteTimestamp = useRemote.getRemoteTimestamp();
                long jLongValue = remoteTimestamp != null ? remoteTimestamp.longValue() : j;
                anonymousClass1.L$0 = syncConflictResolver3;
                anonymousClass1.L$1 = gr3Var3;
                anonymousClass1.L$2 = it2;
                anonymousClass1.L$3 = null;
                anonymousClass1.label = 3;
                syncConflictResolver4 = syncConflictResolver3;
                long j3 = jLongValue;
                AnonymousClass1 anonymousClass13 = anonymousClass1;
                gr3Var4 = gr3Var3;
                anonymousClass12 = anonymousClass13;
            } else {
                syncConflictResolver4 = syncConflictResolver3;
                anonymousClass12 = anonymousClass1;
                gr3Var4 = gr3Var3;
                EpisodeWatchStatusDao episodeWatchStatusDao2 = syncConflictResolver4.episodeWatchStatusDao;
                ConflictResult.UseRemote useRemote2 = (ConflictResult.UseRemote) conflictResult;
                int showTmdbId2 = useRemote2.getShowTmdbId();
                int season2 = useRemote2.getSeason();
                int episode2 = useRemote2.getEpisode();
                Long remoteTimestamp2 = useRemote2.getRemoteTimestamp();
                EpisodeWatchStatus episodeWatchStatus = new EpisodeWatchStatus(showTmdbId2, season2, episode2, null, null, true, 1, Boxing.boxLong(remoteTimestamp2 != null ? remoteTimestamp2.longValue() : j), null, null, j, 792, null);
                anonymousClass12.L$0 = syncConflictResolver4;
                anonymousClass12.L$1 = gr3Var4;
                anonymousClass12.L$2 = it2;
                anonymousClass12.L$3 = null;
                anonymousClass12.label = 4;
            }
            i3 = 1;
        } else if (i2 == 3 || i2 == 4) {
            it = (Iterator) anonymousClass1.L$2;
            gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var7 = (gr3) anonymousClass1.L$1;
            SyncConflictResolver syncConflictResolver7 = (SyncConflictResolver) anonymousClass1.L$0;
            s38.b(obj);
            gr3Var2 = gr3Var7;
            syncConflictResolver2 = syncConflictResolver7;
            c2 = 5;
            i3 = 1;
        } else {
            if (i2 != 5) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            it = (Iterator) anonymousClass1.L$2;
            gr3<? super EpisodeWatchStatus, ? super Continuation<? super e6a>, ? extends Object> gr3Var8 = (gr3) anonymousClass1.L$1;
            SyncConflictResolver syncConflictResolver8 = (SyncConflictResolver) anonymousClass1.L$0;
            s38.b(obj);
            c = 5;
            gr3Var2 = gr3Var8;
            syncConflictResolver2 = syncConflictResolver8;
            c2 = c;
            i3 = 1;
        }
        while (it.hasNext()) {
            ConflictResult next = it.next();
            if (next instanceof ConflictResult.KeepLocal) {
                EpisodeWatchStatus episode3 = ((ConflictResult.KeepLocal) next).getEpisode();
                anonymousClass1.L$0 = syncConflictResolver2;
                anonymousClass1.L$1 = gr3Var2;
                anonymousClass1.L$2 = it;
                anonymousClass1.label = i3;
                if (gr3Var2.invoke(episode3, anonymousClass1) == ck1Var) {
                }
            } else if (next instanceof ConflictResult.UseRemote) {
                long jCurrentTimeMillis = System.currentTimeMillis();
                ConflictResult.UseRemote useRemote3 = (ConflictResult.UseRemote) next;
                if (useRemote3.getWatched()) {
                    EpisodeWatchStatusDao episodeWatchStatusDao3 = syncConflictResolver2.episodeWatchStatusDao;
                    int showTmdbId3 = useRemote3.getShowTmdbId();
                    int season3 = useRemote3.getSeason();
                    int episode4 = useRemote3.getEpisode();
                    anonymousClass1.L$0 = syncConflictResolver2;
                    anonymousClass1.L$1 = gr3Var2;
                    anonymousClass1.L$2 = it;
                    anonymousClass1.L$3 = next;
                    anonymousClass1.J$0 = jCurrentTimeMillis;
                    anonymousClass1.label = 2;
                    Object episodeStatus = episodeWatchStatusDao3.getEpisodeStatus(showTmdbId3, season3, episode4, anonymousClass1);
                    if (episodeStatus != ck1Var) {
                        syncConflictResolver3 = syncConflictResolver2;
                        j = jCurrentTimeMillis;
                        gr3Var3 = gr3Var2;
                        obj = episodeStatus;
                        it2 = it;
                        conflictResult = next;
                        if (((EpisodeWatchStatus) obj) == null) {
                        }
                        i3 = 1;
                        while (it.hasNext()) {
                        }
                    }
                } else {
                    EpisodeWatchStatusDao episodeWatchStatusDao4 = syncConflictResolver2.episodeWatchStatusDao;
                    int showTmdbId4 = useRemote3.getShowTmdbId();
                    int season4 = useRemote3.getSeason();
                    int episode5 = useRemote3.getEpisode();
                    anonymousClass1.L$0 = syncConflictResolver2;
                    anonymousClass1.L$1 = gr3Var2;
                    anonymousClass1.L$2 = it;
                    c = 5;
                    anonymousClass1.label = 5;
                    AnonymousClass1 anonymousClass14 = anonymousClass1;
                    SyncConflictResolver syncConflictResolver9 = syncConflictResolver2;
                    if (EpisodeWatchStatusDao.DefaultImpls.markUnwatched$default(episodeWatchStatusDao4, showTmdbId4, season4, episode5, 0L, anonymousClass14, 8, null) != ck1Var) {
                        syncConflictResolver2 = syncConflictResolver9;
                        anonymousClass1 = anonymousClass14;
                        c2 = c;
                        i3 = 1;
                        while (it.hasNext()) {
                        }
                    }
                }
            } else {
                AnonymousClass1 anonymousClass15 = anonymousClass1;
                char c3 = c2;
                SyncConflictResolver syncConflictResolver10 = syncConflictResolver2;
                if (!cr4.b(next, ConflictResult.NoConflict.INSTANCE)) {
                    throw new io6();
                }
                syncConflictResolver2 = syncConflictResolver10;
                c2 = c3;
                anonymousClass1 = anonymousClass15;
                i3 = 1;
                while (it.hasNext()) {
                }
            }
            return ck1Var;
        }
        return e6a.a;
    }

    /* JADX WARN: Removed duplicated region for block: B:52:0x0161  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0019  */
    @pq6
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object resolveEpisodeConflicts(int i, @kp6 TraktShowProgress traktShowProgress, @kp6 Continuation<? super List<? extends ConflictResult>> continuation) {
        C04091 c04091;
        List list;
        TraktShowProgress traktShowProgress2;
        SyncConflictResolver syncConflictResolver;
        String str;
        Object next;
        List<TraktEpisodeProgress> episodes;
        int i2;
        SyncConflictResolver syncConflictResolver2;
        String str2;
        int i3 = i;
        if (continuation instanceof C04091) {
            c04091 = (C04091) continuation;
            int i4 = c04091.label;
            if ((i4 & Integer.MIN_VALUE) != 0) {
                c04091.label = i4 - Integer.MIN_VALUE;
            } else {
                c04091 = new C04091(continuation);
            }
        }
        Object obj = c04091.result;
        ck1 ck1Var = ck1.a;
        int i5 = c04091.label;
        if (i5 == 0) {
            s38.b(obj);
            ArrayList arrayList = new ArrayList();
            EpisodeWatchStatusDao episodeWatchStatusDao = this.episodeWatchStatusDao;
            c04091.L$0 = this;
            c04091.L$1 = traktShowProgress;
            c04091.L$2 = arrayList;
            c04091.I$0 = i3;
            c04091.label = 1;
            Object allEpisodes = episodeWatchStatusDao.getAllEpisodes(i3, c04091);
            if (allEpisodes == ck1Var) {
                return ck1Var;
            }
            list = arrayList;
            obj = allEpisodes;
            traktShowProgress2 = traktShowProgress;
            syncConflictResolver = this;
        } else {
            if (i5 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i3 = c04091.I$0;
            list = (List) c04091.L$2;
            traktShowProgress2 = (TraktShowProgress) c04091.L$1;
            syncConflictResolver = (SyncConflictResolver) c04091.L$0;
            s38.b(obj);
        }
        int i6 = i3;
        List list2 = (List) obj;
        int iH = wo5.h(y41.p(list2, 10));
        if (iH < 16) {
            iH = 16;
        }
        LinkedHashMap linkedHashMap = new LinkedHashMap(iH);
        Iterator it = list2.iterator();
        while (true) {
            str = "-";
            if (!it.hasNext()) {
                break;
            }
            Object next2 = it.next();
            EpisodeWatchStatus episodeWatchStatus = (EpisodeWatchStatus) next2;
            linkedHashMap.put(episodeWatchStatus.getSeason() + "-" + episodeWatchStatus.getEpisode(), next2);
        }
        List<TraktSeasonProgress> seasons = traktShowProgress2.getSeasons();
        if (seasons != null) {
            for (TraktSeasonProgress traktSeasonProgress : seasons) {
                Integer number = traktSeasonProgress.getNumber();
                if (number != null) {
                    int iIntValue = number.intValue();
                    List<TraktEpisodeProgress> episodes2 = traktSeasonProgress.getEpisodes();
                    if (episodes2 != null) {
                        for (TraktEpisodeProgress traktEpisodeProgress : episodes2) {
                            Integer number2 = traktEpisodeProgress.getNumber();
                            if (number2 != null) {
                                int iIntValue2 = number2.intValue();
                                EpisodeWatchStatus episodeWatchStatus2 = (EpisodeWatchStatus) linkedHashMap.get(iIntValue + str + iIntValue2);
                                boolean zB = cr4.b(traktEpisodeProgress.getCompleted(), Boxing.boxBoolean(true));
                                Long dateMillis = syncConflictResolver.parseDateMillis(traktEpisodeProgress.getLastWatchedAt());
                                if (episodeWatchStatus2 != null) {
                                    i2 = iIntValue;
                                    if (episodeWatchStatus2.getWatched() != zB) {
                                        Long watchedAt = episodeWatchStatus2.getWatchedAt();
                                        syncConflictResolver2 = syncConflictResolver;
                                        str2 = str;
                                        Boxing.boxBoolean(list.add(syncConflictResolver2.resolveByTimestamp(episodeWatchStatus2, zB, dateMillis, watchedAt != null ? watchedAt.longValue() : episodeWatchStatus2.getUpdatedAt())));
                                    }
                                } else if (zB) {
                                    ConflictResult.UseRemote useRemote = new ConflictResult.UseRemote(i6, iIntValue, iIntValue2, true, dateMillis);
                                    i2 = iIntValue;
                                    list.add(useRemote);
                                } else {
                                    i2 = iIntValue;
                                }
                                syncConflictResolver2 = syncConflictResolver;
                                str2 = str;
                            }
                            str = str2;
                            syncConflictResolver = syncConflictResolver2;
                            iIntValue = i2;
                        }
                    }
                }
                str = str;
                syncConflictResolver = syncConflictResolver;
            }
        }
        ArrayList<EpisodeWatchStatus> arrayList2 = new ArrayList();
        for (Object obj2 : list2) {
            EpisodeWatchStatus episodeWatchStatus3 = (EpisodeWatchStatus) obj2;
            int season = episodeWatchStatus3.getSeason();
            int episode = episodeWatchStatus3.getEpisode();
            List<TraktSeasonProgress> seasons2 = traktShowProgress2.getSeasons();
            Object obj3 = null;
            if (seasons2 != null) {
                Iterator<T> it2 = seasons2.iterator();
                while (true) {
                    if (!it2.hasNext()) {
                        next = null;
                        break;
                    }
                    next = it2.next();
                    Integer number3 = ((TraktSeasonProgress) next).getNumber();
                    if (number3 != null && number3.intValue() == season) {
                        break;
                    }
                }
                TraktSeasonProgress traktSeasonProgress2 = (TraktSeasonProgress) next;
                if (traktSeasonProgress2 != null && (episodes = traktSeasonProgress2.getEpisodes()) != null) {
                    Iterator<T> it3 = episodes.iterator();
                    while (true) {
                        if (!it3.hasNext()) {
                            break;
                        }
                        Object next3 = it3.next();
                        Integer number4 = ((TraktEpisodeProgress) next3).getNumber();
                        if (number4 != null && number4.intValue() == episode) {
                            obj3 = next3;
                            break;
                        }
                    }
                    obj3 = (TraktEpisodeProgress) obj3;
                }
            }
            if (obj3 == null) {
                arrayList2.add(obj2);
            }
        }
        for (EpisodeWatchStatus episodeWatchStatus4 : arrayList2) {
            if (episodeWatchStatus4.getWatched()) {
                list.add(new ConflictResult.KeepLocal(episodeWatchStatus4));
            }
        }
        list.size();
        return list;
    }
}