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

package com.olxgroup.panamera.app.common.services;

import android.os.Bundle;
import android.util.Log;
import com.clevertap.android.sdk.b0;
import com.google.firebase.messaging.RemoteMessage;
import com.olxgroup.panamera.app.common.infra.m2;
import com.olxgroup.panamera.data.common.DispatcherProviderImpl;
import com.olxgroup.panamera.domain.shell.LoggerDomainContract;
import java.util.List;
import java.util.Map;
import kotlin.Lazy;
import kotlin.LazyKt;
import kotlin.Metadata;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.collections.CollectionsKt;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.coroutines.intrinsics.IntrinsicsKt;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.SourceDebugExtension;
import kotlin.text.StringsKt;
import kotlinx.coroutines.o0;
import kotlinx.coroutines.p0;
import kotlinx.coroutines.q0;
import kotlinx.coroutines.q2;
import kotlinx.coroutines.x1;

@Metadata
@SourceDebugExtension
public final class CleverTapFirebaseMessagingService extends com.olx.plush.data.source.d {
    private final Lazy d = LazyKt.b(new Function0() {
        public final Object invoke() {
            LoggerDomainContract p;
            p = CleverTapFirebaseMessagingService.p();
            return p;
        }
    });
    private final o0 e = p0.a(DispatcherProviderImpl.INSTANCE.getIo().plus(q2.b((x1) null, 1, (Object) null)).plus(m2.a.X1()));

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

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

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

        public final Object invokeSuspend(Object obj) {
            CleverTapFirebaseMessagingService cleverTapFirebaseMessagingService;
            String str;
            Object g = IntrinsicsKt.g();
            int i = this.c;
            if (i == 0) {
                ResultKt.b(obj);
                x1 initialize = m2.a.w2().initialize();
                if (initialize == null) {
                    CleverTapFirebaseMessagingService.this.o().logException(new Exception("Plush initialization job is null"));
                    return Unit.a;
                }
                cleverTapFirebaseMessagingService = CleverTapFirebaseMessagingService.this;
                String str2 = this.e;
                this.a = cleverTapFirebaseMessagingService;
                this.b = str2;
                this.c = 1;
                if (initialize.P0(this) == g) {
                    return g;
                }
                str = str2;
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                str = (String) this.b;
                cleverTapFirebaseMessagingService = (CleverTapFirebaseMessagingService) this.a;
                ResultKt.b(obj);
            }
            CleverTapFirebaseMessagingService.super.onNewToken(str);
            return Unit.a;
        }

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

    public final LoggerDomainContract o() {
        return (LoggerDomainContract) this.d.getValue();
    }

    public static final LoggerDomainContract p() {
        return m2.a.G2().c();
    }

    @Override
    public void onMessageReceived(RemoteMessage remoteMessage) {
        List H0;
        if (!m2.a.x1().isNotificationsEnabled()) {
            Log.d("TAG", "Notifications disabled CleverTapFirebaseMessagingService");
            return;
        }
        try {
            if (!remoteMessage.getData().isEmpty()) {
                Bundle bundle = new Bundle();
                for (Map.Entry entry : remoteMessage.getData().entrySet()) {
                    bundle.putString((String) entry.getKey(), (String) entry.getValue());
                }
                com.olxgroup.panamera.app.common.tracking.q z = com.olxgroup.panamera.app.common.tracking.q.z();
                String string = bundle.getString("wzrk_id");
                z.D0((string == null || (H0 = StringsKt.H0(string, new String[]{"_"}, false, 0, 6, (Object) null)) == null) ? null : (String) CollectionsKt.g0(H0));
                com.olxgroup.panamera.app.common.tracking.q.z().I0(bundle.getString("wzrk_dl"));
                if (b0.H(bundle).a) {
                    new com.clevertap.android.sdk.pushnotification.fcm.a().a(getApplicationContext(), remoteMessage);
                } else {
                    super.onMessageReceived(remoteMessage);
                }
            }
        } catch (Throwable th) {
            Log.d("CleverTapFCMService", "Error parsing FCM message", th);
        }
    }

    @Override
    public void onNewToken(String str) {
        kotlinx.coroutines.i.d(this.e, (CoroutineContext) null, (q0) null, new a(str, null), 3, (Object) null);
    }
}