Differential D7094 Diff 24015 keyserver/src/push/send.js

Changeset View

Standalone View

keyserver/src/push/send.js

Show First 20 Lines • Show All 180 Lines • ▼ Show 20 Lines	for (const notifInfo of usersToCollapsableNotifInfo[userID]) {
userID,		userID,
threadID,		threadID,
messageID: firstMessageID,		messageID: firstMessageID,
collapseKey: notifInfo.collapseKey,		collapseKey: notifInfo.collapseKey,
};		};

const iosVersionsToTokens = byPlatform.get('ios');		const iosVersionsToTokens = byPlatform.get('ios');
if (iosVersionsToTokens) {		if (iosVersionsToTokens) {
for (const [codeVer, deviceTokens] of iosVersionsToTokens) {		for (const [codeVersion, deviceTokens] of iosVersionsToTokens) {
const codeVersion = parseInt(codeVer, 10); // only for Flow
const platformDetails = { platform: 'ios', codeVersion };		const platformDetails = { platform: 'ios', codeVersion };
const shimmedNewRawMessageInfos = shimUnsupportedRawMessageInfos(		const shimmedNewRawMessageInfos = shimUnsupportedRawMessageInfos(
newRawMessageInfos,		newRawMessageInfos,
platformDetails,		platformDetails,
);		);
const deliveryPromise = (async () => {		const deliveryPromise = (async () => {
const notification = await prepareAPNsNotification({		const notification = await prepareAPNsNotification({
notifTexts,		notifTexts,
Show All 14 Lines	for (const notifInfo of usersToCollapsableNotifInfo[userID]) {
},		},
);		);
})();		})();
deliveryPromises.push(deliveryPromise);		deliveryPromises.push(deliveryPromise);
}		}
}		}
const androidVersionsToTokens = byPlatform.get('android');		const androidVersionsToTokens = byPlatform.get('android');
if (androidVersionsToTokens) {		if (androidVersionsToTokens) {
for (const [codeVer, deviceTokens] of androidVersionsToTokens) {		for (const [codeVersion, deviceTokens] of androidVersionsToTokens) {
const codeVersion = parseInt(codeVer, 10); // only for Flow
const platformDetails = { platform: 'android', codeVersion };		const platformDetails = { platform: 'android', codeVersion };
const shimmedNewRawMessageInfos = shimUnsupportedRawMessageInfos(		const shimmedNewRawMessageInfos = shimUnsupportedRawMessageInfos(
newRawMessageInfos,		newRawMessageInfos,
platformDetails,		platformDetails,
);		);
const deliveryPromise = (async () => {		const deliveryPromise = (async () => {
const notification = await prepareAndroidNotification({		const notification = await prepareAndroidNotification({
notifTexts,		notifTexts,
▲ Show 20 Lines • Show All 763 Lines • ▼ Show 20 Lines	const devices = deviceTokenResult.map(row => ({
codeVersion: JSON.parse(row.versions)?.codeVersion,		codeVersion: JSON.parse(row.versions)?.codeVersion,
}));		}));
const byPlatform = getDevicesByPlatform(devices);		const byPlatform = getDevicesByPlatform(devices);

const deliveryPromises = [];		const deliveryPromises = [];

const iosVersionsToTokens = byPlatform.get('ios');		const iosVersionsToTokens = byPlatform.get('ios');
if (iosVersionsToTokens) {		if (iosVersionsToTokens) {
for (const [codeVer, deviceTokens] of iosVersionsToTokens) {		for (const [codeVersion, deviceTokens] of iosVersionsToTokens) {
const codeVersion = parseInt(codeVer, 10); // only for Flow
const notification = new apn.Notification();		const notification = new apn.Notification();
notification.topic = getAPNsNotificationTopic({		notification.topic = getAPNsNotificationTopic({
platform: 'ios',		platform: 'ios',
codeVersion,		codeVersion,
});		});
notification.badge = unreadCount;		notification.badge = unreadCount;
notification.pushType = 'alert';		notification.pushType = 'alert';
deliveryPromises.push(		deliveryPromises.push(
sendAPNsNotification('ios', notification, [...deviceTokens], {		sendAPNsNotification('ios', notification, [...deviceTokens], {
source,		source,
dbID,		dbID,
userID,		userID,
codeVersion,		codeVersion,
}),		}),
);		);
}		}
}		}

const androidVersionsToTokens = byPlatform.get('android');		const androidVersionsToTokens = byPlatform.get('android');
if (androidVersionsToTokens) {		if (androidVersionsToTokens) {
for (const [codeVer, deviceTokens] of androidVersionsToTokens) {		for (const [codeVersion, deviceTokens] of androidVersionsToTokens) {
const codeVersion = parseInt(codeVer, 10); // only for Flow
const notificationData =		const notificationData =
codeVersion < 69		codeVersion < 69
? { badge: unreadCount.toString() }		? { badge: unreadCount.toString() }
: { badge: unreadCount.toString(), badgeOnly: '1' };		: { badge: unreadCount.toString(), badgeOnly: '1' };
const notification = { data: notificationData };		const notification = { data: notificationData };
deliveryPromises.push(		deliveryPromises.push(
sendAndroidNotification(notification, [...deviceTokens], {		sendAndroidNotification(notification, [...deviceTokens], {
source,		source,
dbID,		dbID,
userID,		userID,
codeVersion,		codeVersion,
}),		}),
);		);
}		}
}		}

		const macosVersionsToTokens = byPlatform.get('macos');
		if (macosVersionsToTokens) {
		for (const [codeVersion, deviceTokens] of macosVersionsToTokens) {
		const notification = new apn.Notification();
		notification.topic = getAPNsNotificationTopic({
		platform: 'macos',
		codeVersion,
		});
		notification.badge = unreadCount;
		notification.pushType = 'alert';
		deliveryPromises.push(
		sendAPNsNotification('macos', notification, [...deviceTokens], {
		source,
		dbID,
		userID,
		codeVersion,
		}),
		);
		}
		}

const deliveryResults = await Promise.all(deliveryPromises);		const deliveryResults = await Promise.all(deliveryPromises);
await saveNotifResults(deliveryResults, new Map(), false);		await saveNotifResults(deliveryResults, new Map(), false);
}		}

export { sendPushNotifs, sendRescindNotifs, updateBadgeCount };		export { sendPushNotifs, sendRescindNotifs, updateBadgeCount };