NekoX/TMessagesProj/src/main/java/org/telegram/messenger/NotificationCenter.java

527 lines
23 KiB
Java

/*
* This is the source code of Telegram for Android v. 5.x.x.
* It is licensed under GNU GPL v. 2 or later.
* You should have received a copy of the license in this archive (see LICENSE).
*
* Copyright Nikolai Kudashov, 2013-2018.
*/
package org.telegram.messenger;
import androidx.annotation.UiThread;
import android.util.SparseArray;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
public class NotificationCenter {
private static int totalEvents = 1;
public static final int didReceiveNewMessages = totalEvents++;
public static final int updateInterfaces = totalEvents++;
public static final int dialogsNeedReload = totalEvents++;
public static final int closeChats = totalEvents++;
public static final int messagesDeleted = totalEvents++;
public static final int historyCleared = totalEvents++;
public static final int messagesRead = totalEvents++;
public static final int threadMessagesRead = totalEvents++;
public static final int commentsRead = totalEvents++;
public static final int changeRepliesCounter = totalEvents++;
public static final int messagesDidLoad = totalEvents++;
public static final int loadingMessagesFailed = totalEvents++;
public static final int messageReceivedByAck = totalEvents++;
public static final int messageReceivedByServer = totalEvents++;
public static final int messageSendError = totalEvents++;
public static final int contactsDidLoad = totalEvents++;
public static final int contactsImported = totalEvents++;
public static final int hasNewContactsToImport = totalEvents++;
public static final int chatDidCreated = totalEvents++;
public static final int chatDidFailCreate = totalEvents++;
public static final int chatInfoDidLoad = totalEvents++;
public static final int chatInfoCantLoad = totalEvents++;
public static final int mediaDidLoad = totalEvents++;
public static final int mediaCountDidLoad = totalEvents++;
public static final int mediaCountsDidLoad = totalEvents++;
public static final int encryptedChatUpdated = totalEvents++;
public static final int messagesReadEncrypted = totalEvents++;
public static final int encryptedChatCreated = totalEvents++;
public static final int dialogPhotosLoaded = totalEvents++;
public static final int reloadDialogPhotos = totalEvents++;
public static final int folderBecomeEmpty = totalEvents++;
public static final int removeAllMessagesFromDialog = totalEvents++;
public static final int notificationsSettingsUpdated = totalEvents++;
public static final int blockedUsersDidLoad = totalEvents++;
public static final int openedChatChanged = totalEvents++;
public static final int didCreatedNewDeleteTask = totalEvents++;
public static final int mainUserInfoChanged = totalEvents++;
public static final int privacyRulesUpdated = totalEvents++;
public static final int updateMessageMedia = totalEvents++;
public static final int replaceMessagesObjects = totalEvents++;
public static final int didSetPasscode = totalEvents++;
public static final int twoStepPasswordChanged = totalEvents++;
public static final int didSetOrRemoveTwoStepPassword = totalEvents++;
public static final int didRemoveTwoStepPassword = totalEvents++;
public static final int replyMessagesDidLoad = totalEvents++;
public static final int didLoadPinnedMessages = totalEvents++;
public static final int newSessionReceived = totalEvents++;
public static final int didReceivedWebpages = totalEvents++;
public static final int didReceivedWebpagesInUpdates = totalEvents++;
public static final int stickersDidLoad = totalEvents++;
public static final int diceStickersDidLoad = totalEvents++;
public static final int featuredStickersDidLoad = totalEvents++;
public static final int groupStickersDidLoad = totalEvents++;
public static final int messagesReadContent = totalEvents++;
public static final int botInfoDidLoad = totalEvents++;
public static final int userInfoDidLoad = totalEvents++;
public static final int pinnedInfoDidLoad = totalEvents++;
public static final int botKeyboardDidLoad = totalEvents++;
public static final int chatSearchResultsAvailable = totalEvents++;
public static final int chatSearchResultsLoading = totalEvents++;
public static final int musicDidLoad = totalEvents++;
public static final int moreMusicDidLoad = totalEvents++;
public static final int needShowAlert = totalEvents++;
public static final int needShowPlayServicesAlert = totalEvents++;
public static final int didUpdateMessagesViews = totalEvents++;
public static final int needReloadRecentDialogsSearch = totalEvents++;
public static final int peerSettingsDidLoad = totalEvents++;
public static final int wasUnableToFindCurrentLocation = totalEvents++;
public static final int reloadHints = totalEvents++;
public static final int reloadInlineHints = totalEvents++;
public static final int newDraftReceived = totalEvents++;
public static final int recentDocumentsDidLoad = totalEvents++;
public static final int needAddArchivedStickers = totalEvents++;
public static final int archivedStickersCountDidLoad = totalEvents++;
public static final int paymentFinished = totalEvents++;
public static final int channelRightsUpdated = totalEvents++;
public static final int openArticle = totalEvents++;
public static final int updateMentionsCount = totalEvents++;
public static final int didUpdatePollResults = totalEvents++;
public static final int chatOnlineCountDidLoad = totalEvents++;
public static final int videoLoadingStateChanged = totalEvents++;
public static final int newPeopleNearbyAvailable = totalEvents++;
public static final int stopAllHeavyOperations = totalEvents++;
public static final int startAllHeavyOperations = totalEvents++;
public static final int sendingMessagesChanged = totalEvents++;
public static final int didUpdateReactions = totalEvents++;
public static final int didVerifyMessagesStickers = totalEvents++;
public static final int scheduledMessagesUpdated = totalEvents++;
public static final int newSuggestionsAvailable = totalEvents++;
public static final int walletPendingTransactionsChanged = totalEvents++;
public static final int walletSyncProgressChanged = totalEvents++;
public static final int httpFileDidLoad = totalEvents++;
public static final int httpFileDidFailedLoad = totalEvents++;
public static final int didUpdateConnectionState = totalEvents++;
public static final int FileDidUpload = totalEvents++;
public static final int FileDidFailUpload = totalEvents++;
public static final int FileUploadProgressChanged = totalEvents++;
public static final int FileLoadProgressChanged = totalEvents++;
public static final int fileDidLoad = totalEvents++;
public static final int fileDidFailToLoad = totalEvents++;
public static final int filePreparingStarted = totalEvents++;
public static final int fileNewChunkAvailable = totalEvents++;
public static final int filePreparingFailed = totalEvents++;
public static final int dialogsUnreadCounterChanged = totalEvents++;
public static final int messagePlayingProgressDidChanged = totalEvents++;
public static final int messagePlayingDidReset = totalEvents++;
public static final int messagePlayingPlayStateChanged = totalEvents++;
public static final int messagePlayingDidStart = totalEvents++;
public static final int messagePlayingDidSeek = totalEvents++;
public static final int messagePlayingGoingToStop = totalEvents++;
public static final int recordProgressChanged = totalEvents++;
public static final int recordStarted = totalEvents++;
public static final int recordStartError = totalEvents++;
public static final int recordStopped = totalEvents++;
public static final int screenshotTook = totalEvents++;
public static final int albumsDidLoad = totalEvents++;
public static final int audioDidSent = totalEvents++;
public static final int audioRecordTooShort = totalEvents++;
public static final int audioRouteChanged = totalEvents++;
public static final int didStartedCall = totalEvents++;
public static final int didEndCall = totalEvents++;
public static final int closeInCallActivity = totalEvents++;
public static final int appDidLogout = totalEvents++;
public static final int configLoaded = totalEvents++;
public static final int needDeleteDialog = totalEvents++;
public static final int newEmojiSuggestionsAvailable = totalEvents++;
public static final int themeUploadedToServer = totalEvents++;
public static final int themeUploadError = totalEvents++;
public static final int dialogFiltersUpdated = totalEvents++;
public static final int filterSettingsUpdated = totalEvents++;
public static final int suggestedFiltersLoaded = totalEvents++;
//global
public static final int pushMessagesUpdated = totalEvents++;
public static final int stopEncodingService = totalEvents++;
public static final int wallpapersDidLoad = totalEvents++;
public static final int wallpapersNeedReload = totalEvents++;
public static final int didReceiveSmsCode = totalEvents++;
public static final int didReceiveCall = totalEvents++;
public static final int emojiDidLoad = totalEvents++;
public static final int closeOtherAppActivities = totalEvents++;
public static final int cameraInitied = totalEvents++;
public static final int didReplacedPhotoInMemCache = totalEvents++;
public static final int didSetNewTheme = totalEvents++;
public static final int themeListUpdated = totalEvents++;
public static final int didApplyNewTheme = totalEvents++;
public static final int themeAccentListUpdated = totalEvents++;
public static final int needCheckSystemBarColors = totalEvents++;
public static final int needShareTheme = totalEvents++;
public static final int needSetDayNightTheme = totalEvents++;
public static final int goingToPreviewTheme = totalEvents++;
public static final int locationPermissionGranted = totalEvents++;
public static final int reloadInterface = totalEvents++;
public static final int suggestedLangpack = totalEvents++;
public static final int didSetNewWallpapper = totalEvents++;
public static final int proxySettingsChanged = totalEvents++;
public static final int proxyCheckDone = totalEvents++;
public static final int liveLocationsChanged = totalEvents++;
public static final int newLocationAvailable = totalEvents++;
public static final int liveLocationsCacheChanged = totalEvents++;
public static final int notificationsCountUpdated = totalEvents++;
public static final int playerDidStartPlaying = totalEvents++;
public static final int closeSearchByActiveAction = totalEvents++;
public static final int messagePlayingSpeedChanged = totalEvents++;
public static final int screenStateChanged = totalEvents++;
public static final int voipServiceCreated = totalEvents++;
// custom
public static final int updateUserStatus = totalEvents++;
private SparseArray<ArrayList<NotificationCenterDelegate>> observers = new SparseArray<>();
private SparseArray<ArrayList<NotificationCenterDelegate>> removeAfterBroadcast = new SparseArray<>();
private SparseArray<ArrayList<NotificationCenterDelegate>> addAfterBroadcast = new SparseArray<>();
private ArrayList<DelayedPost> delayedPosts = new ArrayList<>(10);
private ArrayList<Runnable> delayedRunnables = new ArrayList<>(10);
private ArrayList<Runnable> delayedRunnablesTmp = new ArrayList<>(10);
private ArrayList<DelayedPost> delayedPostsTmp = new ArrayList<>(10);
private ArrayList<PostponeNotificationCallback> postponeCallbackList = new ArrayList<>(10);
private int broadcasting = 0;
private int animationInProgressCount;
private int animationInProgressPointer = 1;
HashSet<Integer> heavyOperationsCounter = new HashSet<>();
private final HashMap<Integer, int[]> allowedNotifications = new HashMap<>();
public interface NotificationCenterDelegate {
void didReceivedNotification(int id, int account, Object... args);
}
private static class DelayedPost {
private DelayedPost(int id, Object[] args) {
this.id = id;
this.args = args;
}
private int id;
private Object[] args;
}
private int currentAccount;
private int currentHeavyOperationFlags;
private static volatile NotificationCenter[] Instance = new NotificationCenter[UserConfig.MAX_ACCOUNT_COUNT];
private static volatile NotificationCenter globalInstance;
@UiThread
public static NotificationCenter getInstance(int num) {
NotificationCenter localInstance = Instance[num];
if (localInstance == null) {
synchronized (NotificationCenter.class) {
localInstance = Instance[num];
if (localInstance == null) {
Instance[num] = localInstance = new NotificationCenter(num);
}
}
}
return localInstance;
}
@UiThread
public static NotificationCenter getGlobalInstance() {
NotificationCenter localInstance = globalInstance;
if (localInstance == null) {
synchronized (NotificationCenter.class) {
localInstance = globalInstance;
if (localInstance == null) {
globalInstance = localInstance = new NotificationCenter(-1);
}
}
}
return localInstance;
}
public NotificationCenter(int account) {
currentAccount = account;
}
public int setAnimationInProgress(int oldIndex, int[] allowedNotifications) {
return setAnimationInProgress(oldIndex, allowedNotifications, true);
}
public int setAnimationInProgress(int oldIndex, int[] allowedNotifications, boolean stopHeavyOperations) {
onAnimationFinish(oldIndex);
if (heavyOperationsCounter.isEmpty() && stopHeavyOperations) {
NotificationCenter.getGlobalInstance().postNotificationName(stopAllHeavyOperations, 512);
}
animationInProgressCount++;
animationInProgressPointer++;
if (stopHeavyOperations) {
heavyOperationsCounter.add(animationInProgressPointer);
}
if (allowedNotifications == null) {
allowedNotifications = new int[0];
}
this.allowedNotifications.put(animationInProgressPointer, allowedNotifications);
return animationInProgressPointer;
}
public void updateAllowedNotifications(int transitionAnimationIndex, int[] allowedNotifications) {
if (this.allowedNotifications.containsKey(transitionAnimationIndex)) {
if (allowedNotifications == null) {
allowedNotifications = new int[0];
}
this.allowedNotifications.put(transitionAnimationIndex, allowedNotifications);
}
}
public void onAnimationFinish(int index) {
int[] notifications = allowedNotifications.remove(index);
if (notifications != null) {
animationInProgressCount--;
if (!heavyOperationsCounter.isEmpty()) {
heavyOperationsCounter.remove(index);
if (heavyOperationsCounter.isEmpty()) {
NotificationCenter.getGlobalInstance().postNotificationName(startAllHeavyOperations, 512);
}
}
if (animationInProgressCount == 0) {
runDelayedNotifications();
}
}
}
public void runDelayedNotifications() {
if (!delayedPosts.isEmpty()) {
delayedPostsTmp.clear();
delayedPostsTmp.addAll(delayedPosts);
delayedPosts.clear();
for (int a = 0; a < delayedPostsTmp.size(); a++) {
DelayedPost delayedPost = delayedPostsTmp.get(a);
postNotificationNameInternal(delayedPost.id, true, delayedPost.args);
}
delayedPostsTmp.clear();
}
if (!delayedRunnables.isEmpty()) {
delayedRunnablesTmp.clear();
delayedRunnablesTmp.addAll(delayedRunnables);
delayedRunnables.clear();
for (int a = 0; a < delayedRunnablesTmp.size(); a++) {
delayedRunnablesTmp.get(a).run();
}
delayedRunnablesTmp.clear();
}
}
public boolean isAnimationInProgress() {
return animationInProgressCount > 0;
}
public int getCurrentHeavyOperationFlags() {
return currentHeavyOperationFlags;
}
public void postNotificationName(int id, Object... args) {
boolean allowDuringAnimation = id == startAllHeavyOperations || id == stopAllHeavyOperations || id == didReplacedPhotoInMemCache;
if (!allowDuringAnimation && !allowedNotifications.isEmpty()) {
int size = allowedNotifications.size();
int allowedCount = 0;
for (Integer key : allowedNotifications.keySet()) {
int[] allowed = allowedNotifications.get(key);
if (allowed != null) {
for (int a = 0; a < allowed.length; a++) {
if (allowed[a] == id) {
allowedCount++;
break;
}
}
} else {
break;
}
}
allowDuringAnimation = size == allowedCount;
}
if (id == startAllHeavyOperations) {
Integer flags = (Integer) args[0];
currentHeavyOperationFlags &= ~flags;
} else if (id == stopAllHeavyOperations) {
Integer flags = (Integer) args[0];
currentHeavyOperationFlags |= flags;
}
postNotificationNameInternal(id, allowDuringAnimation, args);
}
@UiThread
public void postNotificationNameInternal(int id, boolean allowDuringAnimation, Object... args) {
if (BuildVars.DEBUG_VERSION) {
if (Thread.currentThread() != ApplicationLoader.applicationHandler.getLooper().getThread()) {
throw new RuntimeException("postNotificationName allowed only from MAIN thread");
}
}
if (!allowDuringAnimation && isAnimationInProgress()) {
DelayedPost delayedPost = new DelayedPost(id, args);
delayedPosts.add(delayedPost);
if (BuildVars.LOGS_ENABLED) {
FileLog.e("delay post notification " + id + " with args count = " + args.length);
}
return;
}
if (!postponeCallbackList.isEmpty()) {
for (int i = 0; i < postponeCallbackList.size(); i++) {
if (postponeCallbackList.get(i).needPostpone(id, currentAccount, args)) {
delayedPosts.add(new DelayedPost(id, args));
return;
}
}
}
broadcasting++;
ArrayList<NotificationCenterDelegate> objects = observers.get(id);
if (objects != null && !objects.isEmpty()) {
for (int a = 0; a < objects.size(); a++) {
NotificationCenterDelegate obj = objects.get(a);
obj.didReceivedNotification(id, currentAccount, args);
}
}
broadcasting--;
if (broadcasting == 0) {
if (removeAfterBroadcast.size() != 0) {
for (int a = 0; a < removeAfterBroadcast.size(); a++) {
int key = removeAfterBroadcast.keyAt(a);
ArrayList<NotificationCenterDelegate> arrayList = removeAfterBroadcast.get(key);
for (int b = 0; b < arrayList.size(); b++) {
removeObserver(arrayList.get(b), key);
}
}
removeAfterBroadcast.clear();
}
if (addAfterBroadcast.size() != 0) {
for (int a = 0; a < addAfterBroadcast.size(); a++) {
int key = addAfterBroadcast.keyAt(a);
ArrayList<NotificationCenterDelegate> arrayList = addAfterBroadcast.get(key);
for (int b = 0; b < arrayList.size(); b++) {
addObserver(arrayList.get(b), key);
}
}
addAfterBroadcast.clear();
}
}
}
public void addObserver(NotificationCenterDelegate observer, int id) {
if (BuildVars.DEBUG_VERSION) {
if (Thread.currentThread() != ApplicationLoader.applicationHandler.getLooper().getThread()) {
throw new RuntimeException("addObserver allowed only from MAIN thread");
}
}
if (broadcasting != 0) {
ArrayList<NotificationCenterDelegate> arrayList = addAfterBroadcast.get(id);
if (arrayList == null) {
arrayList = new ArrayList<>();
addAfterBroadcast.put(id, arrayList);
}
arrayList.add(observer);
return;
}
ArrayList<NotificationCenterDelegate> objects = observers.get(id);
if (objects == null) {
observers.put(id, (objects = new ArrayList<>()));
}
if (objects.contains(observer)) {
return;
}
objects.add(observer);
}
public void removeObserver(NotificationCenterDelegate observer, int id) {
if (BuildVars.DEBUG_VERSION) {
if (Thread.currentThread() != ApplicationLoader.applicationHandler.getLooper().getThread()) {
throw new RuntimeException("removeObserver allowed only from MAIN thread");
}
}
if (broadcasting != 0) {
ArrayList<NotificationCenterDelegate> arrayList = removeAfterBroadcast.get(id);
if (arrayList == null) {
arrayList = new ArrayList<>();
removeAfterBroadcast.put(id, arrayList);
}
arrayList.add(observer);
return;
}
ArrayList<NotificationCenterDelegate> objects = observers.get(id);
if (objects != null) {
objects.remove(observer);
}
}
public boolean hasObservers(int id) {
return observers.indexOfKey(id) >= 0;
}
public void addPostponeNotificationsCallback(PostponeNotificationCallback callback) {
if (BuildVars.DEBUG_VERSION) {
if (Thread.currentThread() != ApplicationLoader.applicationHandler.getLooper().getThread()) {
throw new RuntimeException("PostponeNotificationsCallback allowed only from MAIN thread");
}
}
if (!postponeCallbackList.contains(callback)) {
postponeCallbackList.add(callback);
}
}
public void removePostponeNotificationsCallback(PostponeNotificationCallback callback) {
if (BuildVars.DEBUG_VERSION) {
if (Thread.currentThread() != ApplicationLoader.applicationHandler.getLooper().getThread()) {
throw new RuntimeException("removePostponeNotificationsCallback allowed only from MAIN thread");
}
}
if (postponeCallbackList.remove(callback)) {
runDelayedNotifications();
}
}
public interface PostponeNotificationCallback {
boolean needPostpone(int id, int currentAccount, Object[] args);
}
public void doOnIdle(Runnable runnable) {
if (isAnimationInProgress()) {
delayedRunnables.add(runnable);
} else {
runnable.run();
}
}
}