package com.strmr.ps.data.repository;

import androidx.media3.container.NalUnitUtil;
import com.google.android.gms.actions.SearchIntents;
import com.strmr.ps.data.local.entity.PlaybackProgress;
import com.strmr.ps.data.model.ContentItem;
import com.strmr.ps.data.model.tmdb.TMDBSearchResponse;
import com.strmr.ps.data.model.tmdb.TMDBSearchResult;
import com.strmr.ps.data.remote.api.TMDBApiService;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.hx9;
import defpackage.ik2;
import defpackage.kp6;
import defpackage.n89;
import defpackage.pq6;
import defpackage.s38;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
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;

/* 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\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0007\u0018\u00002\u00020\u0001B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J<\u0010\u000b\u001a&\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t0\b2\u0006\u0010\u0007\u001a\u00020\u0006H\u0086@¢\u0006\u0004\b\u000b\u0010\fR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\r¨\u0006\u000e"}, d2 = {"Lcom/strmr/ps/data/repository/SearchRepository;", "", "Lcom/strmr/ps/data/remote/api/TMDBApiService;", "tmdbApiService", "<init>", "(Lcom/strmr/ps/data/remote/api/TMDBApiService;)V", "", SearchIntents.EXTRA_QUERY, "Lhx9;", "", "Lcom/strmr/ps/data/model/ContentItem;", "search", "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lcom/strmr/ps/data/remote/api/TMDBApiService;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class SearchRepository {

    @kp6
    private final TMDBApiService tmdbApiService;

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SearchRepository$search$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.SearchRepository", f = "SearchRepository.kt", i = {}, l = {15}, m = "search", n = {}, s = {})
    public static final class AnonymousClass1 extends ContinuationImpl {
        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 SearchRepository.this.search(null, this);
        }
    }

    @Inject
    public SearchRepository(@kp6 TMDBApiService tMDBApiService) {
        cr4.g(tMDBApiService, "tmdbApiService");
        this.tmdbApiService = tMDBApiService;
    }

    /* JADX WARN: Removed duplicated region for block: B:8:0x0018  */
    @pq6
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object search(@kp6 String str, @kp6 Continuation<? super hx9<? extends List<ContentItem>, ? extends List<ContentItem>, ? extends List<ContentItem>>> continuation) {
        AnonymousClass1 anonymousClass1;
        if (continuation instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) continuation;
            int i = anonymousClass1.label;
            if ((i & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i - Integer.MIN_VALUE;
            } else {
                anonymousClass1 = new AnonymousClass1(continuation);
            }
        }
        AnonymousClass1 anonymousClass12 = anonymousClass1;
        Object objMultiSearch$default = anonymousClass12.result;
        ck1 ck1Var = ck1.a;
        int i2 = anonymousClass12.label;
        List<TMDBSearchResult> list = ik2.a;
        if (i2 == 0) {
            s38.b(objMultiSearch$default);
            if (n89.ab(str)) {
                return new hx9(list, list, list);
            }
            TMDBApiService tMDBApiService = this.tmdbApiService;
            anonymousClass12.label = 1;
            objMultiSearch$default = TMDBApiService.DefaultImpls.multiSearch$default(tMDBApiService, str, 0, false, anonymousClass12, 6, null);
            if (objMultiSearch$default == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(objMultiSearch$default);
        }
        List<TMDBSearchResult> results = ((TMDBSearchResponse) objMultiSearch$default).getResults();
        if (results != null) {
            list = results;
        }
        List<TMDBSearchResult> list2 = list;
        ArrayList arrayList = new ArrayList();
        for (Object obj : list2) {
            if (cr4.b(((TMDBSearchResult) obj).getMediaType(), PlaybackProgress.TYPE_MOVIE)) {
                arrayList.add(obj);
            }
        }
        ArrayList arrayList2 = new ArrayList(y41.p(arrayList, 10));
        Iterator it = arrayList.iterator();
        while (it.hasNext()) {
            arrayList2.add(SearchRepositoryKt.toContentItem((TMDBSearchResult) it.next(), ContentItem.ItemType.MOVIE));
        }
        ArrayList arrayList3 = new ArrayList();
        for (Object obj2 : list2) {
            if (cr4.b(((TMDBSearchResult) obj2).getMediaType(), "tv")) {
                arrayList3.add(obj2);
            }
        }
        ArrayList arrayList4 = new ArrayList(y41.p(arrayList3, 10));
        Iterator it2 = arrayList3.iterator();
        while (it2.hasNext()) {
            arrayList4.add(SearchRepositoryKt.toContentItem((TMDBSearchResult) it2.next(), ContentItem.ItemType.TV_SHOW));
        }
        ArrayList<TMDBSearchResult> arrayList5 = new ArrayList();
        for (Object obj3 : list2) {
            if (cr4.b(((TMDBSearchResult) obj3).getMediaType(), "person")) {
                arrayList5.add(obj3);
            }
        }
        ArrayList arrayList6 = new ArrayList(y41.p(arrayList5, 10));
        for (TMDBSearchResult tMDBSearchResult : arrayList5) {
            int id = tMDBSearchResult.getId();
            ContentItem.ItemType itemType = ContentItem.ItemType.PERSON;
            int id2 = tMDBSearchResult.getId();
            String name = tMDBSearchResult.getName();
            if (name == null) {
                name = "";
            }
            arrayList6.add(new ContentItem(id, itemType, id2, null, name, null, tMDBSearchResult.getProfileUrl(), tMDBSearchResult.getBackdropUrl(), null, null, null, null, null, null, null, "__PERSON__", null, null, null, null, null, null, null, null, false, null, null, null, null, null, 0, null, null, null, null, null, null, null, null, null, null, null, null, -1048064, 2047, null));
        }
        return new hx9(arrayList2, arrayList4, arrayList6);
    }
}