MX Player v1.97.8 - CTFirebaseMessagingReceiver.java 源代码

package com.clevertap.android.sdk.pushnotification.fcm;

import android.annotation.SuppressLint;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.CountDownTimer;
import com.clevertap.android.sdk.CleverTapAPI;
import com.google.firebase.messaging.RemoteMessage;
import defpackage.k5i;
import defpackage.l8e;
import defpackage.mw1;
import defpackage.oz5;
import defpackage.toc;
import defpackage.tqa;
import java.util.concurrent.TimeUnit;

public class CTFirebaseMessagingReceiver extends BroadcastReceiver implements toc {
    public static final int h = 0;
    public a b;
    public String c = "";
    public boolean d;
    public BroadcastReceiver.PendingResult f;
    public long g;

    @Override
    @SuppressLint({"RestrictedApi"})
    public final void a() {
        tqa.j("CTRM", "push impression sent successfully by core, i should inform OS to kill receiver. my callback key is " + this.c);
        b("push impression sent successfully by core");
    }

    public final void b(String str) {
        try {
            tqa.j("CTRM", "got a signal to kill receiver and timer because ".concat(str));
            if (!this.c.trim().isEmpty()) {
                CleverTapAPI.g.remove(this.c);
            }
            long nanoTime = System.nanoTime();
            if (this.f == null || this.d) {
                tqa.j("CTRM", "have already informed OS to kill receiver, can not inform again else OS will get angry :-O");
                return;
            }
            tqa.j("CTRM", "informing OS to kill receiver...");
            this.f.finish();
            this.d = true;
            a aVar = this.b;
            if (aVar != null) {
                aVar.cancel();
            }
            tqa.j("CTRM", "informed OS to kill receiver...");
            tqa.j("CTRM", "receiver was alive for " + TimeUnit.NANOSECONDS.toSeconds(nanoTime - this.g) + " seconds");
        } catch (Exception unused) {
        }
    }

    @Override
    @SuppressLint({"RestrictedApi"})
    public final void onReceive(Context context, Intent intent) {
        RemoteMessage remoteMessage;
        Bundle a2;
        this.g = System.nanoTime();
        tqa.b("CTRM", "received a message from Firebase");
        if (context == null || intent == null || (a2 = oz5.a((remoteMessage = new RemoteMessage(intent.getExtras())))) == null) {
            return;
        }
        if (remoteMessage.getPriority() != 2) {
            tqa.b("CTRM", "returning from CTRM because message priority is not normal");
            return;
        }
        long parseLong = Long.parseLong(a2.getString("ctrmt", "4500"));
        this.f = goAsync();
        if (!CleverTapAPI.i(a2).a) {
            tqa.j("CTRM", "Notification payload is not from CleverTap.");
            b("push is not from CleverTap.");
            return;
        }
        boolean z = k5i.a;
        boolean parseBoolean = Boolean.parseBoolean((String) remoteMessage.getData().get("wzrk_tsr_fb"));
        boolean parseBoolean2 = Boolean.parseBoolean((String) remoteMessage.getData().get("wzrk_fallback"));
        if (parseBoolean || !parseBoolean2) {
            tqa.j("CTRM", "Notification payload does not have a fallback key.");
            b("isRenderFallback is false");
            return;
        }
        String b = h7.b(l8e.a(a2), "_", a2.getString("wzrk_pid", ""));
        this.c = b;
        CleverTapAPI.g.put(b, this);
        a aVar = new a(parseLong);
        this.b = aVar;
        aVar.start();
        new Thread(new mw1(this, context, a2, 0)).start();
    }

    public class a extends CountDownTimer {
        public a(long j) {
            super(j, 1000L);
        }

        @Override
        public final void onFinish() {
            int i = CTFirebaseMessagingReceiver.h;
            CTFirebaseMessagingReceiver.this.b("receiver life time is expired");
        }

        @Override
        public final void onTick(long j) {
        }
    }
}