Clean Center v0.5.5 - LambdaFirebaseMessagingService.java 源代码

package com.lambda.push.service;

import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.Task;
import com.google.firebase.messaging.FirebaseMessaging;
import com.google.firebase.messaging.FirebaseMessagingService;
import com.google.firebase.messaging.RemoteMessage;
import com.lambda.common.utils.utilcode.util.AppUtils;
import com.lambda.common.utils.utilcode.util.LogUtils;
import com.lambda.common.utils.utilcode.util.SPUtils;
import com.lambda.push.Constants;
import com.lambda.push.LambdaPush;
import com.lambda.push.service.LambdaFirebaseMessagingService;
import com.lambda.push.utils.NotificationUtil;
import com.lambda.push.utils.PackageUtils;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;

@Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0016\u0018\u0000 \u000b2\u00020\u0001:\u0001\u000bB\u0005¢\u0006\u0002\u0010\u0002J\u0012\u0010\u0003\u001a\u00020\u00042\b\u0010\u0005\u001a\u0004\u0018\u00010\u0006H\u0016J\b\u0010\u0007\u001a\u00020\u0004H\u0016J\u0010\u0010\b\u001a\u00020\u00042\u0006\u0010\t\u001a\u00020\nH\u0016¨\u0006\f"}, d2 = {"Lcom/lambda/push/service/LambdaFirebaseMessagingService;", "Lcom/google/firebase/messaging/FirebaseMessagingService;", "()V", "handleIntent", "", "intent", "Landroid/content/Intent;", "onDeletedMessages", "onMessageReceived", "message", "Lcom/google/firebase/messaging/RemoteMessage;", "Companion", "lib_release"}, k = 1, mv = {1, 9, 0}, xi = 48)
public class LambdaFirebaseMessagingService extends FirebaseMessagingService {
    private static boolean mIsSubscribed;

    public static final Companion INSTANCE = new Companion(null);
    private static long mTopicId = SPUtils.getInstance("LambdaPush").getLong(Constants.SpConfig.PREF_A3L_TOPIC_ID, -1);

    @Override
    public void handleIntent(Intent intent) {
        super.handleIntent(intent);
        LogUtils.d("LambdaPush", "LambdaFirebaseMessagingService handleIntent");
    }

    @Override
    public void onMessageReceived(RemoteMessage message) {
        Intrinsics.checkNotNullParameter(message, "message");
        super.onMessageReceived(message);
        if (LambdaPush.INSTANCE.getMIsPaused()) {
            return;
        }
        LogUtils.d("LambdaPush", "LambdaFirebaseMessagingService onMessageReceived " + message + ", mTopicId: all" + mTopicId);
        Function2<String, Bundle, Unit> mEventCallback = LambdaPush.INSTANCE.getMEventCallback();
        if (mEventCallback != null) {
            mEventCallback.invoke("mNotiProcess", new Bundle());
        }
        NotificationUtil.sendRewardNotify$default(NotificationUtil.INSTANCE, "hb", null, 2, null);
    }

    @Override
    public void onDeletedMessages() {
        super.onDeletedMessages();
        LogUtils.d("LambdaPush", "LambdaFirebaseMessagingService onDeletedMessages");
    }

    @Metadata(d1 = {"\u0000&\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J\u000e\u0010\u0007\u001a\u00020\b2\u0006\u0010\t\u001a\u00020\nJ\u0006\u0010\u000b\u001a\u00020\bR\u000e\u0010\u0003\u001a\u00020\u0004X\u0082\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082\u000e¢\u0006\u0002\n\u0000¨\u0006\f"}, d2 = {"Lcom/lambda/push/service/LambdaFirebaseMessagingService$Companion;", "", "()V", "mIsSubscribed", "", "mTopicId", "", "subscribeToTopic", "", "context", "Landroid/content/Context;", "unsubscribeFromTopic", "lib_release"}, k = 1, mv = {1, 9, 0}, xi = 48)
    public static final class Companion {
        public Companion(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }

        private Companion() {
        }

        public final void unsubscribeFromTopic() {
            FirebaseMessaging.getInstance().unsubscribeFromTopic("all" + LambdaFirebaseMessagingService.mTopicId);
        }

        public final void subscribeToTopic(Context context) {
            Intrinsics.checkNotNullParameter(context, "context");
            if (LambdaFirebaseMessagingService.mIsSubscribed) {
                return;
            }
            if (LambdaFirebaseMessagingService.mTopicId < 0) {
                LambdaFirebaseMessagingService.mTopicId = AppUtils.isAppDebug() ? 1L : PackageUtils.INSTANCE.getFirstInstallTime(context) % 10;
            }
            FirebaseMessaging.getInstance().subscribeToTopic("all" + LambdaFirebaseMessagingService.mTopicId).addOnCompleteListener(new OnCompleteListener() {
                @Override
                public final void onComplete(Task task) {
                    LambdaFirebaseMessagingService.Companion.subscribeToTopic$lambda$0(task);
                }
            });
        }

        public static final void subscribeToTopic$lambda$0(Task task) {
            Intrinsics.checkNotNullParameter(task, "it");
            LogUtils.d("LambdaPush", "LambdaFirebaseMessagingService subscribeToTopic: " + task.isSuccessful() + ", mTopicId: all" + LambdaFirebaseMessagingService.mTopicId);
            Companion companion = LambdaFirebaseMessagingService.INSTANCE;
            LambdaFirebaseMessagingService.mIsSubscribed = task.isSuccessful();
        }
    }
}