Housing v14.7.8 - n4.java 源代码

package f7;

import com.contentsquare.android.internal.core.logmonitor.processing.LogMessage;
import java.util.ArrayList;
import java.util.Iterator;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.jvm.internal.SourceDebugExtension;
import kotlinx.serialization.json.b;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;

@DebugMetadata(c = "com.contentsquare.android.internal.core.logmonitor.processing.LogProcessor$sendLogs$1", f = "LogProcessor.kt", i = {}, l = {}, m = "invokeSuspend", n = {}, s = {})
@SourceDebugExtension({"SMAP\nLogProcessor.kt\nKotlin\n*S Kotlin\n*F\n+ 1 LogProcessor.kt\ncom/contentsquare/android/internal/core/logmonitor/processing/LogProcessor$sendLogs$1\n+ 2 SerialFormat.kt\nkotlinx/serialization/SerialFormatKt\n*L\n1#1,93:1\n113#2:94\n*S KotlinDebug\n*F\n+ 1 LogProcessor.kt\ncom/contentsquare/android/internal/core/logmonitor/processing/LogProcessor$sendLogs$1\n*L\n74#1:94\n*E\n"})
public final class n4 extends eq.i implements kq.p<kotlinx.coroutines.j0, kotlin.coroutines.d<? super zp.j0>, Object> {
    public final y4 a;

    public n4(y4 y4Var, kotlin.coroutines.d<? super n4> dVar) {
        super(2, dVar);
        this.a = y4Var;
    }

    @NotNull
    public final kotlin.coroutines.d<zp.j0> create(@Nullable Object obj, @NotNull kotlin.coroutines.d<?> dVar) {
        return new n4(this.a, dVar);
    }

    public final Object invoke(Object obj, Object obj2) {
        return new n4(this.a, (kotlin.coroutines.d) obj2).invokeSuspend(zp.j0.INSTANCE);
    }

    @Nullable
    public final Object invokeSuspend(@NotNull Object obj) {
        ArrayList arrayList;
        q6.d e;
        kotlin.coroutines.intrinsics.a aVar = kotlin.coroutines.intrinsics.a.COROUTINE_SUSPENDED;
        zp.u.b(obj);
        n5 n5Var = this.a.b;
        n5Var.getClass();
        try {
            ArrayList i = n5Var.b.i(n5Var.e);
            arrayList = new ArrayList(kotlin.collections.t.u(i, 10));
            Iterator it = i.iterator();
            while (it.hasNext()) {
                String str = (String) it.next();
                b.a aVar2 = kotlinx.serialization.json.b.Default;
                aVar2.getClass();
                arrayList.add((LogMessage) aVar2.a(str, LogMessage.Companion.serializer()));
            }
        } catch (Throwable th) {
            n5Var.c.h("Failed to read log file at path: " + n5Var.e + " | error message: " + th.getMessage());
            arrayList = kotlin.collections.g0.INSTANCE;
        }
        if (!arrayList.isEmpty()) {
            this.a.d.f("Sending " + arrayList.size() + " log events");
            b.a aVar3 = kotlinx.serialization.json.b.Default;
            aVar3.getClass();
            e = this.a.a.e("https://l.contentsquare.net/log/android", aVar3.b(new kotlinx.serialization.internal.f(LogMessage.Companion.serializer()), arrayList), kotlin.collections.t0.d());
            if (e.p()) {
                this.a.d.f("Log events successfully sent.");
                this.a.b.a();
                this.a.e.set(0);
            } else {
                this.a.d.h("Could not send the logs. HTTP status:" + e.getStatus() + " response:" + e.getException());
            }
        }
        return zp.j0.INSTANCE;
    }
}