Function deliverPushNotifsInEncryptionOrder

keyserver/src/push/send.js:532–584

(
  preparedPushNotifs: $ReadOnlyArray<PreparePushResult>,
)

}

async function deliverPushNotifsInEncryptionOrder(
  preparedPushNotifs: $ReadOnlyArray<PreparePushResult>,
): Promise<$ReadOnlyArray<PushResult>> {
  const deliveryPromises: Array<Promise<$ReadOnlyArray<PushResult>>> = [];

  const groupedByDevice = _groupBy(
    preparedPushNotif => preparedPushNotif.deviceToken,
  )(preparedPushNotifs);

  for (const preparedPushNotifsForDevice of values(groupedByDevice)) {
    const orderedPushNotifsForDevice = preparedPushNotifsForDevice.sort(
      compareEncryptionOrder,
    );

    const deviceDeliveryPromise = (async () => {
      const deliveries = [];
      for (const preparedPushNotif of orderedPushNotifsForDevice) {
        const { platform, notification, notificationInfo } = preparedPushNotif;
        let delivery: PushResult;
        if (platform === 'ios' || platform === 'macos') {
          delivery = await sendAPNsNotification(
            platform,
            [notification],
            notificationInfo,
          );
        } else if (platform === 'android') {
          delivery = await sendAndroidNotification(
            [notification],
            notificationInfo,
          );
        } else if (platform === 'web') {
          delivery = await sendWebNotifications(
            [notification],
            notificationInfo,
          );
        } else if (platform === 'windows') {
          delivery = await sendWNSNotification(
            [notification],
            notificationInfo,
          );
        }
        if (delivery) {
          deliveries.push(delivery);
        }
      }
      return deliveries;
    })();
    deliveryPromises.push(deviceDeliveryPromise);
  }

  const deliveryResults = await Promise.all(deliveryPromises);
  return deliveryResults.flat();
}

async function sendRescindNotifs(rescindInfo: PushInfo) {
  if (Object.keys(rescindInfo).length === 0) {