package com.strmr.ps.data.service;

import android.content.Context;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.strmr.ps.data.local.dao.MediaDao;
import com.strmr.ps.data.local.entity.MediaEnrichmentEntity;
import com.strmr.ps.data.model.tmdb.TMDBCast;
import com.strmr.ps.data.model.tmdb.TMDBContentRating;
import com.strmr.ps.data.model.tmdb.TMDBContentRatingsResponse;
import com.strmr.ps.data.model.tmdb.TMDBCredits;
import com.strmr.ps.data.model.tmdb.TMDBGenre;
import com.strmr.ps.data.model.tmdb.TMDBImagesKt;
import com.strmr.ps.data.model.tmdb.TMDBMovieDetails;
import com.strmr.ps.data.model.tmdb.TMDBReleaseDate;
import com.strmr.ps.data.model.tmdb.TMDBReleaseDateInfo;
import com.strmr.ps.data.model.tmdb.TMDBReleaseDatesResponse;
import com.strmr.ps.data.model.tmdb.TMDBShowDetails;
import com.strmr.ps.data.remote.api.TMDBApiService;
import dagger.hilt.android.qualifiers.ApplicationContext;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.fr;
import defpackage.gr3;
import defpackage.hf5;
import defpackage.hn2;
import defpackage.jn2;
import defpackage.kp6;
import defpackage.m02;
import defpackage.m12;
import defpackage.n41;
import defpackage.ov0;
import defpackage.q78;
import defpackage.q81;
import defpackage.qo9;
import defpackage.rg6;
import defpackage.s38;
import defpackage.sc2;
import defpackage.vx8;
import defpackage.wj0;
import defpackage.y41;
import defpackage.zg0;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
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\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0007\u0018\u00002\u00020\u0001:\u0002\f\rB-\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\b\b\u0001\u0010\u0007\u001a\u00020\u0006\u0012\b\b\u0001\u0010\t\u001a\u00020\b¢\u0006\u0004\b\n\u0010\u000b¨\u0006\u000e"}, d2 = {"Lcom/strmr/ps/data/service/TmdbEnrichmentService;", "", "Lcom/strmr/ps/data/remote/api/TMDBApiService;", "tmdbApi", "Lcom/strmr/ps/data/local/dao/MediaDao;", "mediaDao", "Lak1;", "scope", "Landroid/content/Context;", "context", "<init>", "(Lcom/strmr/ps/data/remote/api/TMDBApiService;Lcom/strmr/ps/data/local/dao/MediaDao;Lak1;Landroid/content/Context;)V", "b", "c", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class TmdbEnrichmentService {
    public final TMDBApiService a;
    public final MediaDao b;
    public final ak1 c;
    public final Context d;
    public final ConcurrentHashMap e;
    public final zg0 f;

    @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.service.TmdbEnrichmentService$1", f = "TmdbEnrichmentService.kt", i = {0, 1, 2}, l = {50, 52, 62}, m = "invokeSuspend", n = {"buffer", "buffer", "buffer"}, s = {"L$0", "L$0", "L$0"})
    public static final class a extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        public List a;
        public int b;

        public a(Continuation continuation) {
            super(2, continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation create(Object obj, Continuation continuation) {
            return TmdbEnrichmentService.this.new a(continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(Object obj, Object obj2) throws Throwable {
            ((a) create((ak1) obj, (Continuation) obj2)).invokeSuspend(e6a.a);
            return ck1.a;
        }

        /* JADX WARN: Code restructure failed: missing block: B:16:0x004f, code lost:
        
            if (r10 == r0) goto L35;
         */
        /* JADX WARN: Code restructure failed: missing block: B:20:0x0067, code lost:
        
            if (r10 == r0) goto L35;
         */
        /* JADX WARN: Code restructure failed: missing block: B:34:0x00a6, code lost:
        
            if (defpackage.e6a.a != r0) goto L36;
         */
        /* JADX WARN: Code restructure failed: missing block: B:37:0x00a9, code lost:
        
            if (r10 != r0) goto L36;
         */
        /* JADX WARN: Path cross not found for [B:26:0x0073, B:28:0x007b], limit reached: 35 */
        /* JADX WARN: Removed duplicated region for block: B:15:0x0042  */
        /* JADX WARN: Removed duplicated region for block: B:19:0x0055  */
        /* JADX WARN: Removed duplicated region for block: B:24:0x006e  */
        /* JADX WARN: Removed duplicated region for block: B:33:0x00a4  */
        /* JADX WARN: Removed duplicated region for block: B:34:0x00a6  */
        /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:27:0x0079 -> B:13:0x003c). Please report as a decompilation issue!!! */
        /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:29:0x0082 -> B:13:0x003c). Please report as a decompilation issue!!! */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) throws Throwable {
            List arrayList;
            c cVar;
            Object objF;
            ck1 ck1Var = ck1.a;
            int i = this.b;
            TmdbEnrichmentService tmdbEnrichmentService = TmdbEnrichmentService.this;
            if (i == 0) {
                s38.b(obj);
                arrayList = new ArrayList();
                if (arrayList.isEmpty()) {
                }
                return ck1Var;
            }
            if (i == 1) {
                arrayList = this.a;
                s38.b(obj);
                cVar = (c) obj;
                if (cVar != null) {
                }
                if (cVar != null) {
                }
                List listBo = y41.bo(arrayList);
                this.a = arrayList;
                this.b = 3;
                m12 m12Var = sc2.a;
                objF = wj0.f(m02.c, new ag(listBo, tmdbEnrichmentService, null), this);
                if (objF != ck1.a) {
                }
                if (arrayList.isEmpty()) {
                }
                return ck1Var;
            }
            if (i != 2) {
                if (i != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                arrayList = this.a;
                s38.b(obj);
                arrayList.clear();
                if (arrayList.isEmpty()) {
                    zg0 zg0Var = tmdbEnrichmentService.f;
                    this.a = arrayList;
                    this.b = 1;
                    obj = zg0Var.ah(this);
                } else {
                    z zVar = new z(tmdbEnrichmentService, null);
                    this.a = arrayList;
                    this.b = 2;
                    obj = qo9.c(75L, zVar, this);
                }
                return ck1Var;
            }
            arrayList = this.a;
            s38.b(obj);
            cVar = (c) obj;
            if (cVar != null) {
                arrayList.add(cVar);
            }
            if ((cVar != null || arrayList.size() >= 15) && !arrayList.isEmpty()) {
                List listBo2 = y41.bo(arrayList);
                this.a = arrayList;
                this.b = 3;
                m12 m12Var2 = sc2.a;
                objF = wj0.f(m02.c, new ag(listBo2, tmdbEnrichmentService, null), this);
                if (objF != ck1.a) {
                }
                if (arrayList.isEmpty()) {
                }
            } else if (arrayList.isEmpty()) {
            }
            return ck1Var;
        }
    }

    /* JADX WARN: Failed to restore enum class, 'enum' modifier and super class removed */
    /* JADX WARN: Unknown enum class pattern. Please report as an issue! */
    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0010\n\u0000\b\u0086\u0081\u0002\u0018\u00002\b\u0012\u0004\u0012\u00020\u00000\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/service/TmdbEnrichmentService$b;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class b {
        public static final /* synthetic */ b[] a;
        public static final /* synthetic */ hn2 b;

        static {
            b[] bVarArr = {new b("MOVIE", 0), new b("TV_SHOW", 1)};
            a = bVarArr;
            b = jn2.a(bVarArr);
        }

        public static b valueOf(String str) {
            return (b) Enum.valueOf(b.class, str);
        }

        public static b[] values() {
            return (b[]) a.clone();
        }
    }

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

        public c(int i, b bVar, q81 q81Var) {
            cr4.g(bVar, SessionDescription.ATTR_TYPE);
            this.a = i;
            this.b = bVar;
            this.c = q81Var;
        }

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

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

        public final String toString() {
            return "EnrichmentRequest(tmdbId=" + this.a + ", type=" + this.b + ", deferred=" + this.c + ")";
        }
    }

    @Inject
    public TmdbEnrichmentService(@kp6 TMDBApiService tMDBApiService, @kp6 MediaDao mediaDao, @fr @kp6 ak1 ak1Var, @ApplicationContext @kp6 Context context) {
        cr4.g(tMDBApiService, "tmdbApi");
        cr4.g(mediaDao, "mediaDao");
        cr4.g(ak1Var, "scope");
        cr4.g(context, "context");
        this.a = tMDBApiService;
        this.b = mediaDao;
        this.c = ak1Var;
        this.d = context;
        this.e = new ConcurrentHashMap();
        this.f = ov0.a(-2, 6, null);
        rg6.a();
        wj0.c(ak1Var, null, null, new a(null), 3);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object a(TmdbEnrichmentService tmdbEnrichmentService, int i, ContinuationImpl continuationImpl) {
        ab abVar;
        String str;
        List<TMDBReleaseDate> results;
        Object next;
        List<TMDBReleaseDateInfo> releaseDates;
        TMDBReleaseDateInfo tMDBReleaseDateInfo;
        List<TMDBCast> cast;
        tmdbEnrichmentService.getClass();
        if (continuationImpl instanceof ab) {
            abVar = (ab) continuationImpl;
            int i2 = abVar.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                abVar.e = i2 - Integer.MIN_VALUE;
            } else {
                abVar = new ab(tmdbEnrichmentService, continuationImpl);
            }
        }
        Object movieDetails = abVar.c;
        ck1 ck1Var = ck1.a;
        int i3 = abVar.e;
        if (i3 == 0) {
            s38.b(movieDetails);
            TMDBApiService tMDBApiService = tmdbEnrichmentService.a;
            abVar.a = tmdbEnrichmentService;
            abVar.b = i;
            abVar.e = 1;
            movieDetails = tMDBApiService.getMovieDetails(i, "images,credits,release_dates", abVar);
            if (movieDetails == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i3 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i = abVar.b;
            tmdbEnrichmentService = abVar.a;
            s38.b(movieDetails);
        }
        int i4 = i;
        TMDBMovieDetails tMDBMovieDetails = (TMDBMovieDetails) movieDetails;
        String posterUrl = tMDBMovieDetails.getPosterUrl(tmdbEnrichmentService.c());
        String preferredBackdropPath = TMDBImagesKt.getPreferredBackdropPath(tMDBMovieDetails.getImages(), tmdbEnrichmentService.c());
        if (preferredBackdropPath == null) {
            preferredBackdropPath = tMDBMovieDetails.getBackdropPath();
        }
        String certification = null;
        String strConcat = preferredBackdropPath != null ? "https://image.tmdb.org/t/p/w1280".concat(preferredBackdropPath) : null;
        String logoUrl = tMDBMovieDetails.getLogoUrl(tmdbEnrichmentService.c());
        List<TMDBGenre> genres = tMDBMovieDetails.getGenres();
        String strAi = genres != null ? y41.ai(genres, ", ", null, null, new q78(14), 30) : null;
        TMDBCredits credits = tMDBMovieDetails.getCredits();
        String strAi2 = (credits == null || (cast = credits.getCast()) == null) ? null : y41.ai(y41.bk(cast, 5), ", ", null, null, new q78(15), 30);
        Integer runtime = tMDBMovieDetails.getRuntime();
        if (runtime != null) {
            int iIntValue = runtime.intValue();
            str = (iIntValue / 60) + "h " + (iIntValue % 60) + CmcdData.OBJECT_TYPE_MANIFEST;
        } else {
            str = null;
        }
        TMDBReleaseDatesResponse releaseDates2 = tMDBMovieDetails.getReleaseDates();
        if (releaseDates2 != null && (results = releaseDates2.getResults()) != null) {
            Iterator<T> it = results.iterator();
            while (true) {
                if (!it.hasNext()) {
                    next = null;
                    break;
                }
                next = it.next();
                if (cr4.b(((TMDBReleaseDate) next).getIso31661(), "US")) {
                    break;
                }
            }
            TMDBReleaseDate tMDBReleaseDate = (TMDBReleaseDate) next;
            if (tMDBReleaseDate != null && (releaseDates = tMDBReleaseDate.getReleaseDates()) != null && (tMDBReleaseDateInfo = (TMDBReleaseDateInfo) y41.ab(releaseDates)) != null) {
                certification = tMDBReleaseDateInfo.getCertification();
            }
        }
        return new MediaEnrichmentEntity(i4, posterUrl, strConcat, logoUrl, strAi, strAi2, str, certification, 0L, 256, null);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object b(TmdbEnrichmentService tmdbEnrichmentService, int i, ContinuationImpl continuationImpl) {
        ac acVar;
        List<TMDBContentRating> results;
        Object next;
        Integer num;
        List<TMDBCast> cast;
        tmdbEnrichmentService.getClass();
        if (continuationImpl instanceof ac) {
            acVar = (ac) continuationImpl;
            int i2 = acVar.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                acVar.e = i2 - Integer.MIN_VALUE;
            } else {
                acVar = new ac(tmdbEnrichmentService, continuationImpl);
            }
        }
        Object showDetails = acVar.c;
        ck1 ck1Var = ck1.a;
        int i3 = acVar.e;
        if (i3 == 0) {
            s38.b(showDetails);
            TMDBApiService tMDBApiService = tmdbEnrichmentService.a;
            acVar.a = tmdbEnrichmentService;
            acVar.b = i;
            acVar.e = 1;
            showDetails = tMDBApiService.getShowDetails(i, "images,credits,content_ratings", acVar);
            if (showDetails == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i3 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i = acVar.b;
            tmdbEnrichmentService = acVar.a;
            s38.b(showDetails);
        }
        int i4 = i;
        TMDBShowDetails tMDBShowDetails = (TMDBShowDetails) showDetails;
        String posterUrl = tMDBShowDetails.getPosterUrl(tmdbEnrichmentService.c());
        String preferredBackdropPath = TMDBImagesKt.getPreferredBackdropPath(tMDBShowDetails.getImages(), tmdbEnrichmentService.c());
        if (preferredBackdropPath == null) {
            preferredBackdropPath = tMDBShowDetails.getBackdropPath();
        }
        String rating = null;
        String strConcat = preferredBackdropPath != null ? "https://image.tmdb.org/t/p/w1280".concat(preferredBackdropPath) : null;
        String logoUrl = tMDBShowDetails.getLogoUrl(tmdbEnrichmentService.c());
        List<TMDBGenre> genres = tMDBShowDetails.getGenres();
        String strAi = genres != null ? y41.ai(genres, ", ", null, null, new q78(16), 30) : null;
        TMDBCredits credits = tMDBShowDetails.getCredits();
        String strAi2 = (credits == null || (cast = credits.getCast()) == null) ? null : y41.ai(y41.bk(cast, 5), ", ", null, null, new q78(17), 30);
        List<Integer> episodeRunTime = tMDBShowDetails.getEpisodeRunTime();
        String strH = (episodeRunTime == null || (num = (Integer) y41.ab(episodeRunTime)) == null) ? null : n41.h(num.intValue(), CmcdData.OBJECT_TYPE_MANIFEST);
        TMDBContentRatingsResponse contentRatings = tMDBShowDetails.getContentRatings();
        if (contentRatings != null && (results = contentRatings.getResults()) != null) {
            Iterator<T> it = results.iterator();
            while (true) {
                if (!it.hasNext()) {
                    next = null;
                    break;
                }
                next = it.next();
                if (cr4.b(((TMDBContentRating) next).getIso31661(), "US")) {
                    break;
                }
            }
            TMDBContentRating tMDBContentRating = (TMDBContentRating) next;
            if (tMDBContentRating != null) {
                rating = tMDBContentRating.getRating();
            }
        }
        return new MediaEnrichmentEntity(i4, posterUrl, strConcat, logoUrl, strAi, strAi2, strH, rating, 0L, 256, null);
    }

    public final String c() {
        LinkedHashMap linkedHashMap = hf5.a;
        return hf5.d(this.d);
    }
}