export async function handler()

in typescript/src/soft-opt-ins/acquisitions.ts [8:69]
46 lines of code
8 McCabe index (conditional complexity)

export async function handler(event: DynamoDBStreamEvent): Promise<any> {
  const dlqUrl = process.env.DLQUrl;

  if (!dlqUrl) {
    throw new Error('process.env.DLQUrl is undefined');
  }

  console.log(`dlqUrl: ${dlqUrl}`);

  const records = event.Records;

  let processedCount = 0;

  const processRecordPromises = records.map(async (record: DynamoDBRecord) => {
    const eventName = record.eventName;

    const identityId = record.dynamodb?.NewImage?.userId?.S || '';
    const subscriptionId = record.dynamodb?.NewImage?.subscriptionId?.S || '';

    if (eventName === 'INSERT') {
      processedCount++;

      console.log(
        `identityId: ${identityId}, subscriptionId: ${subscriptionId}`,
      );

      const itemToQuery = new SubscriptionEmpty();
      itemToQuery.setSubscriptionId(subscriptionId);

      let subscriptionRecord: Subscription;

      try {
        subscriptionRecord = await dynamoMapper.get(itemToQuery);
      } catch (error) {
        console.log(
          `Subscription ${subscriptionId} record not found in the subscriptions table. Error: `,
          error,
        );

        try {
          const timestamp = Date.now();
          await sendToSqs(dlqUrl, { subscriptionId, identityId, timestamp });
        } catch (e) {
          console.log(
            `could not send message to dead letter queue for identityId: ${identityId}, subscriptionId: ${subscriptionId}. Error: `,
            e,
          );
        }

        return false;
      }

      return processAcquisition(subscriptionRecord, identityId);
    }
  });

  await Promise.all(processRecordPromises);

  console.log(
    `Processed ${processedCount} newly inserted records from the link (mobile-purchases-${Stage}-user-subscriptions) DynamoDB table`,
  );
}