package defpackage;

import android.adservices.topics.GetTopicsRequest;
import android.adservices.topics.GetTopicsResponse;
import android.adservices.topics.Topic;
import android.annotation.SuppressLint;
import androidx.media3.container.NalUnitUtil;
import java.util.ArrayList;
import java.util.Iterator;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;

/* JADX INFO: loaded from: classes.dex */
@Metadata(d1 = {"\u0000\u0016\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\b\u0017\u0018\u00002\u00020\u0001J\u001b\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0097@ø\u0001\u0000¢\u0006\u0004\b\u0005\u0010\u0006\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u0007"}, d2 = {"Lkq9;", "Lgq9;", "Lju3;", "request", "Lku3;", "b", "(Lju3;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "ads-adservices_release"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@SuppressLint({"NewApi"})
@n18
@m38
@vx8
public class kq9 extends gq9 {

    @Metadata(k = 3, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "androidx.privacysandbox.ads.adservices.topics.TopicsManagerImplCommon", f = "TopicsManagerImplCommon.kt", i = {}, l = {22}, m = "getTopics$suspendImpl", n = {}, s = {})
    public static final class a extends ContinuationImpl {
        public kq9 a;
        public /* synthetic */ Object b;
        public int d;

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

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            this.b = obj;
            this.d |= Integer.MIN_VALUE;
            return kq9.c(kq9.this, null, this);
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @wd2
    @s18
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static Object c(kq9 kq9Var, ju3 ju3Var, Continuation<? super ku3> continuation) {
        a aVar;
        if (continuation instanceof a) {
            aVar = (a) continuation;
            int i = aVar.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                aVar.d = i - Integer.MIN_VALUE;
            } else {
                aVar = kq9Var.new a(continuation);
            }
        }
        Object obj = aVar.b;
        ck1 ck1Var = ck1.a;
        int i2 = aVar.d;
        if (i2 == 0) {
            s38.b(obj);
            kq9Var.a(ju3Var);
            aVar.a = kq9Var;
            aVar.d = 1;
            ts0 ts0Var = new ts0(1, dr4.d(aVar));
            ts0Var.r();
            new kr(1);
            uy6.a(ts0Var);
            throw null;
        }
        if (i2 != 1) {
            throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
        kq9 kq9Var2 = aVar.a;
        s38.b(obj);
        GetTopicsResponse getTopicsResponseI = cr5.i(obj);
        kq9Var2.getClass();
        cr4.g(getTopicsResponseI, "response");
        ArrayList arrayList = new ArrayList();
        Iterator it = getTopicsResponseI.getTopics().iterator();
        while (it.hasNext()) {
            Topic topicJ = cr5.j(it.next());
            arrayList.add(new fq9(topicJ.getTaxonomyVersion(), topicJ.getModelVersion(), topicJ.getTopicId()));
        }
        return new ku3(arrayList);
    }

    public GetTopicsRequest a(ju3 ju3Var) {
        cr4.g(ju3Var, "request");
        GetTopicsRequest getTopicsRequestBuild = cr5.f().setAdsSdkName(null).build();
        cr4.f(getTopicsRequestBuild, "Builder()\n            .s…ame)\n            .build()");
        return getTopicsRequestBuild;
    }

    @wd2
    @pq6
    @s18
    public Object b(@kp6 ju3 ju3Var, @kp6 Continuation<? super ku3> continuation) {
        return c(this, ju3Var, continuation);
    }
}