export async function parseAndStoreSubscriptionUpdate()

in typescript/src/update-subs/updatesub.ts [31:66]

• 36 lines of code
• 5 McCabe index (conditional complexity)

export async function parseAndStoreSubscriptionUpdate(
  sqsRecord: SQSRecord,
  fetchSubscriberDetails: (record: SQSRecord) => Promise<Subscription[]>,
): Promise<string> {
  try {
    const subscriptions = await fetchSubscriberDetails(sqsRecord); // Subscription[]
    await Promise.all(subscriptions.map(putSubscription));
    await Promise.all(subscriptions.map(queueHistoricalSubscription));
    console.log(
      `Processed ${subscriptions.length} subscriptions: ${subscriptions.map(
        (s) => s.subscriptionId,
      )}`,
    );
    return 'OK';
  } catch (error) {
    if (error instanceof ProcessingError) {
      console.error('Error processing the subscription update', error);
      if (error.shouldRetry) {
        console.error('Will throw an exception to retry this message');
        throw error;
      } else {
        console.error("The error wasn't retryable, giving up.");
        return 'Error, giving up';
      }
    } else if (error instanceof GracefulProcessingError) {
      console.warn(
        'Error processing the subscription update is being handled gracefully',
        error,
      );
      return 'OK';
    } else {
      console.error('Unexpected error, will throw to retry: ', error);
      throw error;
    }
  }
}