Aptoide v9.22.5.3 - SystemNotificationShower.java 源代码

package cm.aptoide.pt.notification;

import android.app.Notification;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.ActivityNotFoundException;
import android.content.Context;
import android.content.Intent;
import android.net.Uri;
import android.os.Build;
import android.text.TextUtils;
import androidx.core.app.i;
import cm.aptoide.analytics.implementation.navigation.NavigationTracker;
import cm.aptoide.analytics.implementation.navigation.ScreenTagHistory;
import cm.aptoide.pt.NotificationApplicationView;
import cm.aptoide.pt.R;
import cm.aptoide.pt.crashreports.CrashReport;
import cm.aptoide.pt.database.room.RoomNotification;
import cm.aptoide.pt.install.installer.RootInstallErrorNotification;
import cm.aptoide.pt.networking.image.ImageLoader;
import cm.aptoide.pt.presenter.Presenter;
import cm.aptoide.pt.themes.NewFeatureManager;
import cm.aptoide.pt.themes.ThemeAnalytics;
import cm.aptoide.pt.view.MainActivity;
import java.util.Arrays;
import java.util.concurrent.Callable;
import rx.Single;
import rx.schedulers.Schedulers;

public class SystemNotificationShower implements Presenter {
    public static final String ANDROID_NOTIFICATION_CHANNEL_ID = "AndroidNotification";
    public static final String LOCAL_NOTIFICATION_CHANNEL_ID = "LocalNotification";
    public static final String NEW_FEATURE_NOTIFICATION_CHANNEL_ID = "NewFeatureNotification";
    public static final String NOTIFICATION_DISMISSED_ACTION = "PUSH_NOTIFICATION_DISMISSED";
    public static final String NOTIFICATION_NOTIFICATION_ID = "PUSH_NOTIFICATION_NOTIFICATION_ID";
    public static final String NOTIFICATION_PRESSED_ACTION = "NOTIFICATION_PRESSED_ACTION";
    public static final String NOTIFICATION_TARGET_URL = "PUSH_NOTIFICATION_TARGET_URL";
    public static final String NOTIFICATION_TRACK_URL = "PUSH_NOTIFICATION_TRACK_URL";
    private Context context;
    private CrashReport crashReport;
    private final NavigationTracker navigationTracker;
    private NewFeatureManager newFeatureManager;
    private NotificationAnalytics notificationAnalytics;
    private NotificationCenter notificationCenter;
    private NotificationIdsMapper notificationIdsMapper;
    private NotificationManager notificationManager;
    private NotificationProvider notificationProvider;
    private ReadyToInstallNotificationManager readyToInstallNotificationManager;
    private rx.t.b subscriptions;
    private ThemeAnalytics themeAnalytics;
    private NotificationApplicationView view;

    public SystemNotificationShower(Context context, NotificationManager notificationManager, NotificationIdsMapper notificationIdsMapper, NotificationCenter notificationCenter, NotificationAnalytics notificationAnalytics, CrashReport crashReport, NotificationProvider notificationProvider, NotificationApplicationView notificationApplicationView, rx.t.b bVar, NavigationTracker navigationTracker, NewFeatureManager newFeatureManager, ThemeAnalytics themeAnalytics, ReadyToInstallNotificationManager readyToInstallNotificationManager) {
        this.context = context;
        this.notificationManager = notificationManager;
        this.notificationIdsMapper = notificationIdsMapper;
        this.notificationCenter = notificationCenter;
        this.notificationAnalytics = notificationAnalytics;
        this.crashReport = crashReport;
        this.notificationProvider = notificationProvider;
        this.subscriptions = bVar;
        this.view = notificationApplicationView;
        this.navigationTracker = navigationTracker;
        this.newFeatureManager = newFeatureManager;
        this.themeAnalytics = themeAnalytics;
        this.readyToInstallNotificationManager = readyToInstallNotificationManager;
    }

    private Single<Notification> buildLocalNotification(final Context context, final String str, final String str2, final String str3, final PendingIntent pendingIntent, final PendingIntent pendingIntent2) {
        return Single.l(new Callable() {
            @Override
            public final Object call() {
                Notification c2;
                Context context2 = context;
                String str4 = str;
                String str5 = str2;
                c2 = new i.e(context2, SystemNotificationShower.LOCAL_NOTIFICATION_CHANNEL_ID).y(R.drawable.ic_stat_aptoide_notification).i(androidx.core.content.a.d(context2, 2131099784)).l(str4).k(str5).a(0, context2.getResources().getString(R.string.promo_update2appc_notification_dismiss_button), pendingIntent2).a(0, context2.getResources().getString(R.string.promo_update2appc_notification_claim_button), pendingIntent).p(com.bumptech.glide.c.t(context2).b().K0(str3).O0().get()).c();
                return c2;
            }
        }).v(Schedulers.computation()).p(rx.l.c.a.b());
    }

    private Single<Notification> buildNewFeatureNotification(final Context context, final String str, final String str2, final int i, final PendingIntent pendingIntent, final PendingIntent pendingIntent2) {
        return Single.l(new Callable() {
            @Override
            public final Object call() {
                Notification c2;
                Context context2 = context;
                PendingIntent pendingIntent3 = pendingIntent;
                String str3 = str;
                c2 = new i.e(context2, SystemNotificationShower.NEW_FEATURE_NOTIFICATION_CHANNEL_ID).j(pendingIntent3).y(R.drawable.ic_stat_aptoide_notification).i(androidx.core.content.a.d(context2, 2131099784)).l(str3).k(str2).a(0, context2.getResources().getString(R.string.updates_notification_dismiss_button), pendingIntent2).a(0, context2.getResources().getString(i), pendingIntent3).c();
                return c2;
            }
        }).v(Schedulers.computation()).p(rx.l.c.a.b());
    }

    private Single<Notification> buildNotification(final Context context, final String str, final String str2, final String str3, final PendingIntent pendingIntent, final PendingIntent pendingIntent2) {
        return Single.l(new Callable() {
            @Override
            public final Object call() {
                Notification c2;
                Context context2 = context;
                PendingIntent pendingIntent3 = pendingIntent;
                String str4 = str3;
                c2 = new i.e(context2, SystemNotificationShower.ANDROID_NOTIFICATION_CHANNEL_ID).j(pendingIntent3).t(false).u(true).y(R.drawable.ic_stat_aptoide_notification).p(ImageLoader.with(context2).loadBitmap(str4)).l(str).k(r4).n(pendingIntent2).A(new i.c().h(str2)).c();
                return c2;
            }
        }).v(Schedulers.computation()).p(rx.l.c.a.b());
    }

    private void callDeepLink(Context context, NotificationInfo notificationInfo) {
        Intent intent = new Intent("android.intent.action.VIEW", Uri.parse(notificationInfo.getNotificationUrl()));
        intent.setFlags(268435456);
        try {
            context.startActivity(intent);
        } catch (ActivityNotFoundException e2) {
            this.crashReport.log(e2);
        }
    }

    private rx.b dismissNotificationAfterAction(final int i) {
        return rx.b.i(new rx.m.d() {
            public final Object call() {
                return SystemNotificationShower.this.a(i);
            }
        });
    }

    private NotificationChannel getAndroidNotificationChannel() {
        NotificationChannel notificationChannel = new NotificationChannel(ANDROID_NOTIFICATION_CHANNEL_ID, "Aptoide Android System notifications", 3);
        notificationChannel.setDescription("Aptoide android notifications");
        return notificationChannel;
    }

    private NotificationChannel getLocalNotificationChannel() {
        NotificationChannel notificationChannel = new NotificationChannel(LOCAL_NOTIFICATION_CHANNEL_ID, "Local Aptoide System notifications", 3);
        notificationChannel.setDescription("Aptoide notifications");
        return notificationChannel;
    }

    private NotificationChannel getNewFeatureNotificationChannel() {
        NotificationChannel notificationChannel = new NotificationChannel(NEW_FEATURE_NOTIFICATION_CHANNEL_ID, "Aptoide New Feature System notifications", 3);
        notificationChannel.setDescription("Aptoide new feature notifications");
        return notificationChannel;
    }

    private Single<PendingIntent> getPressIntentAction(final String str, final String str2, final int i, final Context context) {
        return Single.l(new Callable() {
            @Override
            public final Object call() {
                return SystemNotificationShower.lambda$getPressIntentAction$8(context, i, str, str2);
            }
        }).v(Schedulers.computation());
    }

    public rx.b a(int i) {
        try {
            return this.notificationCenter.notificationDismissed(this.notificationIdsMapper.getNotificationType(i));
        } catch (RuntimeException e2) {
            return rx.b.s(e2);
        }
    }

    static PendingIntent lambda$getPressIntentAction$8(Context context, int i, String str, String str2) throws Exception {
        Intent intent = new Intent(context, (Class<?>) MainActivity.class);
        intent.setAction(NOTIFICATION_PRESSED_ACTION);
        intent.setFlags(0);
        intent.putExtra(NOTIFICATION_NOTIFICATION_ID, i);
        if (!TextUtils.isEmpty(str)) {
            intent.putExtra(NOTIFICATION_TRACK_URL, str);
        }
        if (!TextUtils.isEmpty(str2)) {
            intent.putExtra(NOTIFICATION_TARGET_URL, str2);
        }
        return PendingIntent.getActivity(context, i, intent, 167772160);
    }

    public void b(Notification notification) {
        this.readyToInstallNotificationManager.setIsNotificationDisplayed(true);
    }

    public Single c(AptoideNotification aptoideNotification, int i, PendingIntent pendingIntent) {
        if (aptoideNotification.getType() != 8) {
            return aptoideNotification.getType() == 9 ? this.readyToInstallNotificationManager.buildNotification(aptoideNotification, this.context).g(new rx.m.b() {
                @Override
                public final void call(Object obj) {
                    SystemNotificationShower.this.b((Notification) obj);
                }
            }) : buildLocalNotification(this.context, aptoideNotification.getTitle(), aptoideNotification.getBody(), aptoideNotification.getImg(), pendingIntent, getOnDismissAction(i));
        }
        this.newFeatureManager.setFeatureAsShown();
        return buildNewFeatureNotification(this.context, aptoideNotification.getTitle(), aptoideNotification.getBody(), aptoideNotification.getActionStringRes(), pendingIntent, getOnDismissAction(i));
    }

    public Single d(AptoideNotification aptoideNotification, int i, PendingIntent pendingIntent) {
        return buildNotification(this.context, aptoideNotification.getTitle(), aptoideNotification.getBody(), aptoideNotification.getImg(), pendingIntent, getOnDismissAction(i));
    }

    public void e(NotificationInfo notificationInfo) {
        this.notificationCenter.setup();
    }

    static void lambda$setNotificationBootCompletedSubscribe$14(NotificationInfo notificationInfo) {
    }

    public void f(Throwable th) {
        this.crashReport.log(th);
    }

    public void g(NotificationInfo notificationInfo) {
        if (this.notificationIdsMapper.getNotificationType(notificationInfo.getNotificationType())[0].equals(8)) {
            this.themeAnalytics.sendDarkThemeDismissClickEvent("Notification");
        }
        if (this.notificationIdsMapper.getNotificationType(notificationInfo.getNotificationType())[0].equals(9)) {
            this.readyToInstallNotificationManager.setIsNotificationDisplayed(false);
        }
    }

    public rx.b h(NotificationInfo notificationInfo) {
        return dismissNotificationAfterAction(notificationInfo.getNotificationType());
    }

    public Boolean i(NotificationInfo notificationInfo) {
        return Boolean.valueOf(this.notificationIdsMapper.getNotificationType(notificationInfo.getNotificationType())[0].equals(7));
    }

    public rx.b j(NotificationInfo notificationInfo) {
        return this.notificationProvider.deleteAllForType(7);
    }

    static void lambda$setNotificationDismissSubscribe$21() {
    }

    public void k(Throwable th) {
        this.crashReport.log(th);
    }

    public void l(NotificationInfo notificationInfo, RoomNotification roomNotification) {
        if (roomNotification.getType() != 7 && roomNotification.getType() != 8 && roomNotification.getType() != 9) {
            this.notificationAnalytics.sendPushNotificationPressedEvent(roomNotification.getType(), roomNotification.getAbTestingGroup(), roomNotification.getCampaignId(), roomNotification.getUrl());
            this.notificationAnalytics.sendNotificationTouchEvent(notificationInfo.getNotificationTrackUrl(), notificationInfo.getNotificationType(), notificationInfo.getNotificationUrl(), roomNotification.getCampaignId(), roomNotification.getAbTestingGroup());
        }
        if (roomNotification.getType() == 8) {
            this.themeAnalytics.sendDarkThemeDialogTurnItOnClickEvent("Notification");
        }
    }

    public void m(RoomNotification roomNotification) {
        this.navigationTracker.registerScreen(ScreenTagHistory.Builder.build("Notification"));
    }

    static NotificationInfo lambda$setNotificationPressSubscribe$25(NotificationInfo notificationInfo, RoomNotification roomNotification) {
        return notificationInfo;
    }

    public Single n(final NotificationInfo notificationInfo) {
        return this.notificationProvider.getLastShowed(this.notificationIdsMapper.getNotificationType(notificationInfo.getNotificationType())).g(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.l(notificationInfo, (RoomNotification) obj);
            }
        }).g(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.m((RoomNotification) obj);
            }
        }).n(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                NotificationInfo notificationInfo2 = NotificationInfo.this;
                SystemNotificationShower.lambda$setNotificationPressSubscribe$25(notificationInfo2, (RoomNotification) obj);
                return notificationInfo2;
            }
        });
    }

    public rx.b o(NotificationInfo notificationInfo) {
        callDeepLink(this.context, notificationInfo);
        return dismissNotificationAfterAction(notificationInfo.getNotificationType());
    }

    public Boolean p(NotificationInfo notificationInfo) {
        return Boolean.valueOf(this.notificationIdsMapper.getNotificationType(notificationInfo.getNotificationType())[0].equals(7));
    }

    public rx.b q(NotificationInfo notificationInfo) {
        return this.notificationProvider.deleteAllForType(7);
    }

    static void lambda$setNotificationPressSubscribe$30() {
    }

    public void r(Throwable th) {
        this.crashReport.log(th);
    }

    public void s(int i, Notification notification) {
        this.notificationManager.notify(i, notification);
    }

    public void t(int i, Notification notification) {
        this.notificationManager.notify(i, notification);
    }

    public rx.b u(AptoideNotification aptoideNotification) {
        setupChannels();
        final int notificationId = this.notificationIdsMapper.getNotificationId(aptoideNotification.getType());
        if (aptoideNotification.getType() == 7 || aptoideNotification.getType() == 8 || aptoideNotification.getType() == 9) {
            return mapLocalToAndroidNotification(aptoideNotification, notificationId).g(new rx.m.b() {
                @Override
                public final void call(Object obj) {
                    SystemNotificationShower.this.t(notificationId, (Notification) obj);
                }
            }).z();
        }
        this.notificationAnalytics.sendPushNotficationImpressionEvent(aptoideNotification.getType(), aptoideNotification.getAbTestingGroup(), aptoideNotification.getCampaignId(), aptoideNotification.getUrl());
        return mapToAndroidNotification(aptoideNotification, notificationId).g(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.s(notificationId, (Notification) obj);
            }
        }).z();
    }

    static void lambda$showNewNotification$3(AptoideNotification aptoideNotification) {
    }

    public void v(Throwable th) {
        this.crashReport.log(th);
    }

    private Single<Notification> mapLocalToAndroidNotification(final AptoideNotification aptoideNotification, final int i) {
        return getPressIntentAction(aptoideNotification.getUrlTrack(), aptoideNotification.getUrl(), i, this.context).i(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.c(aptoideNotification, i, (PendingIntent) obj);
            }
        });
    }

    private Single<Notification> mapToAndroidNotification(final AptoideNotification aptoideNotification, final int i) {
        return getPressIntentAction(aptoideNotification.getUrlTrack(), aptoideNotification.getUrl(), i, this.context).i(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.d(aptoideNotification, i, (PendingIntent) obj);
            }
        });
    }

    private void setNotificationBootCompletedSubscribe() {
        this.view.getActionBootCompleted().x(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.e((NotificationInfo) obj);
            }
        }).H0(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.lambda$setNotificationBootCompletedSubscribe$14((NotificationInfo) obj);
            }
        }, new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.f((Throwable) obj);
            }
        });
    }

    private void setNotificationDismissSubscribe() {
        this.view.getNotificationDismissed().D(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                Boolean valueOf;
                valueOf = Boolean.valueOf(r1.getNotificationType() < 9);
                return valueOf;
            }
        }).x(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.g((NotificationInfo) obj);
            }
        }).H(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.h((NotificationInfo) obj);
            }
        }).D(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.i((NotificationInfo) obj);
            }
        }).H(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.j((NotificationInfo) obj);
            }
        }).X0().I(new rx.m.a() {
            @Override
            public final void call() {
                SystemNotificationShower.lambda$setNotificationDismissSubscribe$21();
            }
        }, new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.k((Throwable) obj);
            }
        });
    }

    private void setNotificationPressSubscribe() {
        this.view.getNotificationClick().L(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.n((NotificationInfo) obj);
            }
        }).H(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.o((NotificationInfo) obj);
            }
        }).D(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.p((NotificationInfo) obj);
            }
        }).H(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.q((NotificationInfo) obj);
            }
        }).X0().I(new rx.m.a() {
            @Override
            public final void call() {
                SystemNotificationShower.lambda$setNotificationPressSubscribe$30();
            }
        }, new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.r((Throwable) obj);
            }
        });
    }

    private void setupChannels() {
        if (Build.VERSION.SDK_INT >= 26) {
            this.notificationManager.createNotificationChannels(Arrays.asList(getLocalNotificationChannel(), getAndroidNotificationChannel(), getNewFeatureNotificationChannel(), this.readyToInstallNotificationManager.getNotificationChannel()));
        }
    }

    private void showNewNotification() {
        this.subscriptions.a(this.notificationCenter.getNewNotifications().H(new rx.m.e() {
            @Override
            public final Object call(Object obj) {
                return SystemNotificationShower.this.u((AptoideNotification) obj);
            }
        }).s0().H0(new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.lambda$showNewNotification$3((AptoideNotification) obj);
            }
        }, new rx.m.b() {
            @Override
            public final void call(Object obj) {
                SystemNotificationShower.this.v((Throwable) obj);
            }
        }));
    }

    public void dismissNotification(int i) {
        this.notificationManager.cancel(i);
    }

    public PendingIntent getOnDismissAction(int i) {
        Intent intent = new Intent(this.context, (Class<?>) MainActivity.class);
        intent.setAction(NOTIFICATION_DISMISSED_ACTION);
        intent.putExtra(NOTIFICATION_NOTIFICATION_ID, i);
        return PendingIntent.getActivity(this.context, i, intent, 167772160);
    }

    @Override
    public void present() {
        setNotificationPressSubscribe();
        setNotificationDismissSubscribe();
        setNotificationBootCompletedSubscribe();
        showNewNotification();
    }

    public void showNotification(Context context, RootInstallErrorNotification rootInstallErrorNotification) {
        this.notificationManager.notify(rootInstallErrorNotification.getNotificationId(), mapToAndroidNotification(context, rootInstallErrorNotification));
    }

    private Notification mapToAndroidNotification(Context context, RootInstallErrorNotification rootInstallErrorNotification) {
        Notification c2 = new i.e(context).l(rootInstallErrorNotification.getMessage()).y(R.drawable.ic_stat_aptoide_notification).p(rootInstallErrorNotification.getIcon()).g(true).b(rootInstallErrorNotification.getAction()).n(rootInstallErrorNotification.getDeleteAction()).c();
        c2.flags = 20;
        return c2;
    }
}