fix(videoconf): add ios push deduplication state checks

Fixes stale duplicate notification handling on cold boot causing users to blindly navigate into ended video conference sessions infinitely.

Closes #7015

Author: deepak0x

app/index.tsx

@@ -139,7 +139,10 @@ export default class Root extends React.Component<{}, IState> {
 			if ('configured' in notification) {
 				return;
 			}
-			onNotification(notification);
+			const result = onNotification(notification);
+			if (result?.catch) {
+				result.catch(e => console.warn('app/index.tsx: onNotification error', e));
+			}
 			return;
 		}
 

app/lib/notifications/index.ts

@@ -1,5 +1,6 @@
 import EJSON from 'ejson';
 import { Platform } from 'react-native';
+import AsyncStorage from '@react-native-async-storage/async-storage';
 
 import { appInit } from '../../actions/app';
 import { deepLinkingClickCallPush, deepLinkingOpen } from '../../actions/deepLinking';
@@ -16,14 +17,22 @@ interface IEjson {
 	messageId: string;
 }
 
-export const onNotification = (push: INotification): void => {
+export const onNotification = async (push: INotification): Promise<void> => {
 	const identifier = String(push?.payload?.action?.identifier);
 
 	// Handle video conf notification actions (Accept/Decline buttons)
 	if (identifier === 'ACCEPT_ACTION' || identifier === 'DECLINE_ACTION') {
 		if (push?.payload?.ejson) {
 			try {
 				const notification = EJSON.parse(push.payload.ejson);
+				const lastId = await AsyncStorage.getItem('lastProcessedVideoConfNotificationId');
+				const currentId = push.identifier || push.payload?.notId;
+				if (currentId && lastId === currentId) {
+					return;
+				}
+				if (currentId) {
+					await AsyncStorage.setItem('lastProcessedVideoConfNotificationId', currentId);
+				}
 				store.dispatch(
 					deepLinkingClickCallPush({ ...notification, event: identifier === 'ACCEPT_ACTION' ? 'accept' : 'decline' })
 				);
@@ -40,6 +49,14 @@ export const onNotification = (push: INotification): void => {
 
 			// Handle video conf notification tap (default action) - treat as accept
 			if (notification?.notificationType === 'videoconf') {
+				const lastId = await AsyncStorage.getItem('lastProcessedVideoConfNotificationId');
+				const currentId = push.identifier || push.payload?.notId;
+				if (currentId && lastId === currentId) {
+					return;
+				}
+				if (currentId) {
+					await AsyncStorage.setItem('lastProcessedVideoConfNotificationId', currentId);
+				}
 				store.dispatch(deepLinkingClickCallPush({ ...notification, event: 'accept' }));
 				return;
 			}
@@ -122,7 +139,10 @@ export const checkPendingNotification = async (): Promise<void> => {
 							},
 							identifier: notificationData.notId || ''
 						};
-						onNotification(notification);
+						const result = onNotification(notification);
+						if (result?.catch) {
+							result.catch(e => console.warn('[notifications/index.ts] onNotification error:', e));
+						}
 					} catch (e) {
 						console.warn('[notifications/index.ts] Failed to parse pending notification:', e);
 					}

app/lib/notifications/push.ts

@@ -159,7 +159,9 @@ const registerForPushNotifications = async (): Promise<string | null> => {
 	}
 };
 
-export const pushNotificationConfigure = (onNotification: (notification: INotification) => void): Promise<any> => {
+export const pushNotificationConfigure = (
+	onNotification: (notification: INotification) => Promise<void> | void
+): Promise<any> => {
 	if (configured) {
 		return Promise.resolve({ configured: true });
 	}
@@ -207,10 +209,16 @@ export const pushNotificationConfigure = (onNotification: (notification: INotifi
 		if (isIOS) {
 			const { background } = reduxStore.getState().app;
 			if (background) {
-				onNotification(notification);
+				const result = onNotification(notification);
+				if (result?.catch) {
+					result.catch((e: any) => console.warn('[push.ts] Notification handler error:', e));
+				}
 			}
 		} else {
-			onNotification(notification);
+			const result = onNotification(notification);
+			if (result?.catch) {
+				result.catch((e: any) => console.warn('[push.ts] Notification handler error:', e));
+			}
 		}
 	});
 

app/lib/notifications/videoConf/getInitialNotification.ts

@@ -1,6 +1,7 @@
 import * as Notifications from 'expo-notifications';
 import EJSON from 'ejson';
 import { DeviceEventEmitter, Platform } from 'react-native';
+import AsyncStorage from '@react-native-async-storage/async-storage';
 
 import { deepLinkingClickCallPush } from '../../../actions/deepLinking';
 import { store } from '../../store/auxStore';
@@ -66,6 +67,14 @@ export const getInitialNotification = async (): Promise<boolean> => {
 				if (payload.ejson) {
 					const ejsonData = EJSON.parse(payload.ejson);
 					if (ejsonData?.notificationType === 'videoconf') {
+						const notificationId = notification.request.identifier;
+						const lastId = await AsyncStorage.getItem('lastProcessedVideoConfNotificationId');
+						if (notificationId && lastId === notificationId) {
+							return false;
+						}
+						if (notificationId) {
+							await AsyncStorage.setItem('lastProcessedVideoConfNotificationId', notificationId);
+						}
 						// Accept/Decline actions or default tap (treat as accept)
 						let event = 'accept';
 						if (actionIdentifier === 'DECLINE_ACTION') {

app/sagas/deepLinking.js

@@ -1,4 +1,5 @@
 import { all, call, delay, put, select, take, takeLatest } from 'redux-saga/effects';
+import AsyncStorage from '@react-native-async-storage/async-storage';
 
 import { shareSetParams } from '../actions/share';
 import * as types from '../actions/actionsTypes';
@@ -245,11 +246,20 @@ const handleNavigateCallRoom = function* handleNavigateCallRoom({ params }) {
 
 const handleClickCallPush = function* handleClickCallPush({ params }) {
 	let { host } = params;
+	const notId = params.notId || params.identifier || params.payload?.notId || params.push?.identifier || params.push?.payload?.notId;
 
 	if (!host) {
 		return;
 	}
 
+	const lastId = yield call(AsyncStorage.getItem, 'lastProcessedVideoConfNotificationId');
+	if (notId && lastId === notId) {
+		return;
+	}
+	if (notId) {
+		yield call(AsyncStorage.setItem, 'lastProcessedVideoConfNotificationId', notId);
+	}
+
 	if (host.slice(-1) === '/') {
 		host = host.slice(0, host.length - 1);
 	}