Function webPush

keyserver/src/push/utils.js:242–288

(
  targetedNotifications: $ReadOnlyArray<TargetedWebNotification>,
)

  +error?: WebPushError,
};
async function webPush(
  targetedNotifications: $ReadOnlyArray<TargetedWebNotification>,
): Promise<WebPushResult> {
  await ensureWebPushInitialized();

  const pushResults: $ReadOnlyArray<WebPushAttempt> = await Promise.all(
    targetedNotifications.map(
      async ({ notification, deliveryID: deviceTokenString }) => {
        const deviceToken: PushSubscriptionJSON = JSON.parse(deviceTokenString);
        const notificationString = JSON.stringify(notification);
        try {
          await webpush.sendNotification(deviceToken, notificationString);
        } catch (error) {
          return ({ error }: WebPushAttempt);
        }
        return {};
      },
    ),
  );

  const errors = [];
  const invalidTokens = [];
  const deviceTokens = targetedNotifications.map(
    ({ deliveryID }) => deliveryID,
  );
  for (let i = 0; i < pushResults.length; i++) {
    const pushResult = pushResults[i];
    const { error } = pushResult;
    if (error) {
      errors.push(error);
      if (webInvalidTokenErrorCodes.includes(error.statusCode)) {
        invalidTokens.push(deviceTokens[i]);
      }
    }
  }

  const result: WritableWebPushResult = {};
  if (errors.length > 0) {
    result.errors = errors;
  } else {
    result.success = true;
  }
  if (invalidTokens.length > 0) {
    result.invalidTokens = invalidTokens;
  }
  return result;
}

export type WNSPushError = any | string | Response;
type WritableWNSPushResult = {