OLX India v19.42.007 - a.java 源代码

package com.olxgroup.panamera.app.buyers.featuredAdStories.viewmodels;

import androidx.lifecycle.LiveData;
import androidx.lifecycle.MutableLiveData;
import androidx.lifecycle.SavedStateHandle;
import androidx.lifecycle.ViewModel;
import androidx.lifecycle.ViewModelKt;
import com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a;
import com.olxgroup.panamera.app.buyers.featuredAdStories.utils.b;
import com.olxgroup.panamera.app.buyers.featuredAdStories.utils.d;
import com.olxgroup.panamera.domain.buyers.common.repository.BuyersABTestRepository;
import com.olxgroup.panamera.domain.buyers.featuredAdStories.repository.FeaturedAdStoryRepository;
import com.olxgroup.panamera.domain.common.DispatcherProvider;
import com.olxgroup.panamera.domain.common.tracking.repository.TrackingService;
import java.util.List;
import java.util.concurrent.CancellationException;
import kotlin.NoWhenBranchMatchedException;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.collections.CollectionsKt;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.IntrinsicsKt;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlinx.coroutines.flow.a0;
import kotlinx.coroutines.flow.k0;
import kotlinx.coroutines.flow.o0;
import kotlinx.coroutines.q0;

public final class a extends ViewModel {
    public static final C0199a j = new C0199a(null);
    public static final int k = 8;
    private final DispatcherProvider a;
    private final FeaturedAdStoryRepository b;
    private final SavedStateHandle c;
    private final BuyersABTestRepository d;
    private final TrackingService e;
    private final a0 f;
    private final o0 g;
    private final MutableLiveData h;
    private final LiveData i;

    public static final class C0199a {
        public C0199a(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }

        private C0199a() {
        }
    }

    static final class b extends SuspendLambda implements Function2 {
        int a;
        final String c;
        final int d;

        b(String str, int i, Continuation continuation) {
            super(2, continuation);
            this.c = str;
            this.d = i;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new b(this.c, this.d, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            IntrinsicsKt.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            a.this.e.trackAdOpenFromStory(this.c, a.this.G0(), a.this.E0(), this.d);
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class c extends SuspendLambda implements Function2 {
        int a;
        final String c;

        c(String str, Continuation continuation) {
            super(2, continuation);
            this.c = str;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new c(this.c, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            IntrinsicsKt.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            a.this.h.postValue(new b.a(a.this.I0(this.c)));
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class d extends ContinuationImpl {
        Object a;
        Object b;
        int c;
        boolean d;
        Object e;
        int g;

        d(Continuation continuation) {
            super(continuation);
        }

        public final Object invokeSuspend(Object obj) {
            this.e = obj;
            this.g |= Integer.MIN_VALUE;
            return a.this.L0(null, 0, false, this);
        }
    }

    static final class e extends SuspendLambda implements Function2 {
        int a;
        final com.olx.compose_hub.ui.story.utils.a c;
        final boolean d;
        final int e;

        e(com.olx.compose_hub.ui.story.utils.a aVar, boolean z, int i, Continuation continuation) {
            super(2, continuation);
            this.c = aVar;
            this.d = z;
            this.e = i;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new e(this.c, this.d, this.e, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            IntrinsicsKt.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            a.this.e.trackStorySeenForAd(this.c.a(), this.d ? "listings" : a.this.G0(), a.this.E0(), this.c.c(), this.e);
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class f extends ContinuationImpl {
        Object a;
        Object b;
        int c;
        Object d;
        int f;

        f(Continuation continuation) {
            super(continuation);
        }

        public final Object invokeSuspend(Object obj) {
            this.d = obj;
            this.f |= Integer.MIN_VALUE;
            return a.this.M0(null, 0, this);
        }
    }

    static final class g extends SuspendLambda implements Function2 {
        int a;
        final com.olx.compose_hub.ui.story.utils.a c;
        final int d;

        g(com.olx.compose_hub.ui.story.utils.a aVar, int i, Continuation continuation) {
            super(2, continuation);
            this.c = aVar;
            this.d = i;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new g(this.c, this.d, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            IntrinsicsKt.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            a.this.e.trackStoryImageShown(this.c.a(), a.this.G0(), a.this.E0(), this.d);
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class h extends SuspendLambda implements Function2 {
        int a;
        final String c;
        final String d;
        final boolean e;

        h(String str, String str2, boolean z, Continuation continuation) {
            super(2, continuation);
            this.c = str;
            this.d = str2;
            this.e = z;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new h(this.c, this.d, this.e, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            Object g = IntrinsicsKt.g();
            int i = this.a;
            try {
                if (i == 0) {
                    ResultKt.b(obj);
                    FeaturedAdStoryRepository featuredAdStoryRepository = a.this.b;
                    String str = this.c;
                    String str2 = this.d;
                    boolean z = this.e;
                    this.a = 1;
                    obj = featuredAdStoryRepository.getFeaturedAds(str, str2, z, this);
                    if (obj == g) {
                        return g;
                    }
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    ResultKt.b(obj);
                }
                a.this.R0(new d.c((List) obj));
            } catch (Exception e) {
                if (e instanceof CancellationException) {
                    throw e;
                }
                a.this.R0(d.a.a);
            }
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class i extends SuspendLambda implements Function2 {
        int a;
        final com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a c;

        i(com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a aVar, Continuation continuation) {
            super(2, continuation);
            this.c = aVar;
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new i(this.c, continuation);
        }

        public final Object invokeSuspend(Object obj) {
            Object g = IntrinsicsKt.g();
            int i = this.a;
            if (i == 0) {
                ResultKt.b(obj);
                a aVar = a.this;
                com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a aVar2 = this.c;
                this.a = 1;
                if (aVar.J0(aVar2, this) == g) {
                    return g;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                ResultKt.b(obj);
            }
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
            return create(o0Var, continuation).invokeSuspend(Unit.a);
        }
    }

    static final class j extends SuspendLambda implements Function2 {
        int a;

        static final class C0200a extends SuspendLambda implements Function2 {
            int a;
            final a b;

            C0200a(a aVar, Continuation continuation) {
                super(2, continuation);
                this.b = aVar;
            }

            public final Continuation create(Object obj, Continuation continuation) {
                return new C0200a(this.b, continuation);
            }

            public final Object invokeSuspend(Object obj) {
                IntrinsicsKt.g();
                if (this.a != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                ResultKt.b(obj);
                a aVar = this.b;
                aVar.P0(aVar.E0(), this.b.F0(), this.b.O0());
                return Unit.a;
            }

            public final Object invoke(kotlinx.coroutines.o0 o0Var, Continuation continuation) {
                return create(o0Var, continuation).invokeSuspend(Unit.a);
            }
        }

        j(Continuation continuation) {
            super(2, continuation);
        }

        public final Continuation create(Object obj, Continuation continuation) {
            return a.this.new j(continuation);
        }

        public final Object invokeSuspend(Object obj) {
            IntrinsicsKt.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            kotlinx.coroutines.i.d(ViewModelKt.getViewModelScope(a.this), a.this.a.getIo(), (q0) null, new C0200a(a.this, null), 2, (Object) null);
            return Unit.a;
        }

        public final Object invoke(kotlinx.coroutines.flow.g gVar, Continuation continuation) {
            return create(gVar, continuation).invokeSuspend(Unit.a);
        }
    }

    public a(DispatcherProvider dispatcherProvider, FeaturedAdStoryRepository featuredAdStoryRepository, SavedStateHandle savedStateHandle, BuyersABTestRepository buyersABTestRepository, TrackingService trackingService) {
        this.a = dispatcherProvider;
        this.b = featuredAdStoryRepository;
        this.c = savedStateHandle;
        this.d = buyersABTestRepository;
        this.e = trackingService;
        d.b bVar = d.b.a;
        a0 a = kotlinx.coroutines.flow.q0.a(bVar);
        this.f = a;
        this.g = kotlinx.coroutines.flow.h.I(kotlinx.coroutines.flow.h.G(a, new j(null)), ViewModelKt.getViewModelScope(this), k0.a.b(k0.a, 5000L, 0L, 2, (Object) null), bVar);
        MutableLiveData mutableLiveData = new MutableLiveData();
        this.h = mutableLiveData;
        this.i = mutableLiveData;
    }

    public final String E0() {
        return (String) this.c.get("category_id");
    }

    public final String F0() {
        return (String) this.c.get("search_filters");
    }

    public final String G0() {
        return "story";
    }

    public final String I0(String str) {
        return "https://www.olx.in/item/" + str;
    }

    public final Object J0(com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a aVar, Continuation continuation) {
        if (aVar instanceof a.b) {
            a.b bVar = (a.b) aVar;
            Object L0 = L0(bVar.b(), bVar.a(), bVar.c(), continuation);
            return L0 == IntrinsicsKt.g() ? L0 : Unit.a;
        }
        if (aVar instanceof a.C0197a) {
            a.C0197a c0197a = (a.C0197a) aVar;
            Object K0 = K0(c0197a.a(), c0197a.b(), continuation);
            return K0 == IntrinsicsKt.g() ? K0 : Unit.a;
        }
        if (aVar instanceof a.c) {
            a.c cVar = (a.c) aVar;
            Object M0 = M0(cVar.b(), cVar.a(), continuation);
            return M0 == IntrinsicsKt.g() ? M0 : Unit.a;
        }
        if (!Intrinsics.d(aVar, a.d.a)) {
            throw new NoWhenBranchMatchedException();
        }
        N0();
        return Unit.a;
    }

    private final Object K0(String str, int i2, Continuation continuation) {
        kotlinx.coroutines.i.d(ViewModelKt.getViewModelScope(this), this.a.getIo(), (q0) null, new b(str, i2, null), 2, (Object) null);
        Object g2 = kotlinx.coroutines.i.g(this.a.getMain(), new c(str, null), continuation);
        return g2 == IntrinsicsKt.g() ? g2 : Unit.a;
    }

    public final java.lang.Object L0(com.olx.compose_hub.ui.story.utils.a r17, int r18, boolean r19, kotlin.coroutines.Continuation r20) {
        throw new UnsupportedOperationException("Method not decompiled: com.olxgroup.panamera.app.buyers.featuredAdStories.viewmodels.a.L0(com.olx.compose_hub.ui.story.utils.a, int, boolean, kotlin.coroutines.Continuation):java.lang.Object");
    }

    public final java.lang.Object M0(com.olx.compose_hub.ui.story.utils.a r8, int r9, kotlin.coroutines.Continuation r10) {
        throw new UnsupportedOperationException("Method not decompiled: com.olxgroup.panamera.app.buyers.featuredAdStories.viewmodels.a.M0(com.olx.compose_hub.ui.story.utils.a, int, kotlin.coroutines.Continuation):java.lang.Object");
    }

    private final void N0() {
        this.e.trackStoryClose(G0(), E0());
        this.h.postValue(b.C0198b.a);
    }

    public final boolean O0() {
        Boolean bool = (Boolean) this.c.get("is_from_listing");
        if (bool != null) {
            return bool.booleanValue();
        }
        return false;
    }

    public final void P0(String str, String str2, boolean z) {
        if (this.d.isStoryViewEnabled()) {
            kotlinx.coroutines.i.d(ViewModelKt.getViewModelScope(this), this.a.getIo(), (q0) null, new h(str, str2, z, null), 2, (Object) null);
        } else {
            R0(new d.c(CollectionsKt.k()));
        }
    }

    public final void R0(com.olxgroup.panamera.app.buyers.featuredAdStories.utils.d dVar) {
        Object value;
        a0 a0Var = this.f;
        do {
            value = a0Var.getValue();
        } while (!a0Var.a(value, dVar));
    }

    public o0 H0() {
        return this.g;
    }

    public void Q0(com.olxgroup.panamera.app.buyers.featuredAdStories.utils.a aVar) {
        kotlinx.coroutines.i.d(ViewModelKt.getViewModelScope(this), this.a.getIo(), (q0) null, new i(aVar, null), 2, (Object) null);
    }

    public final LiveData e() {
        return this.i;
    }
}