feat(inbox): Queue depth lambda fully working!

Author: m-szaf

.github/workflows/release.yml

@@ -1,6 +1,6 @@
 import { clickupCdk } from '@time-loop/clickup-projen';
 
-const name = 'cdk-lambda-eni-usage-metric-publisher';
+const name = 'cdk-redis-queue-depth-metric-publisher';
 const project = new clickupCdk.ClickUpCdkConstructLibrary({
   author: 'Andrew Hammond',
   authorAddress: 'ahammond@clickup.com',
@@ -15,7 +15,6 @@ const project = new clickupCdk.ClickUpCdkConstructLibrary({
   bundledDeps: [
     '@aws-lambda-powertools/metrics',
     '@aws-lambda-powertools/parameters',
-    '@aws-sdk/client-ssm', // Might not need this. Will we be pulling from SSM in lambda?
     '@aws-sdk/client-secrets-manager',
     'ioredis',
   ],

.projen/deps.json

@@ -88,7 +88,7 @@ export const handler = async () => {
       throw new Error('Error fetching ALL queue depths');
     }
 
-    publishMetrics(results, {
+    await publishMetrics(results, {
       namespace: cwNamespace,
       serviceName: cwService,
     });

.projen/tasks.json

@@ -1,9 +1,9 @@
 import { Duration, Stack, aws_ec2 } from 'aws-cdk-lib';
-import { PolicyStatement } from 'aws-cdk-lib/aws-iam';
-import { NodejsFunction } from 'aws-cdk-lib/aws-lambda-nodejs';
-import { Architecture, Runtime } from 'aws-cdk-lib/aws-lambda';
 import { Rule, Schedule } from 'aws-cdk-lib/aws-events';
 import { LambdaFunction } from 'aws-cdk-lib/aws-events-targets';
+import { PolicyStatement } from 'aws-cdk-lib/aws-iam';
+import { Architecture, Runtime } from 'aws-cdk-lib/aws-lambda';
+import { NodejsFunction } from 'aws-cdk-lib/aws-lambda-nodejs';
 import { RetentionDays } from 'aws-cdk-lib/aws-logs';
 import { Construct } from 'constructs';
 import { Namer } from 'multi-convention-namer';

.projenrc.ts

@@ -1 +1 @@
-export * from './construct'
+export * from './construct';

package.json

@@ -1,11 +1,11 @@
 // https://docs.powertools.aws.dev/lambda/typescript/latest/utilities/parameters/#fetching-secrets
+import { Metrics, MetricUnits } from '@aws-lambda-powertools/metrics';
+import { MetricsOptions } from '@aws-lambda-powertools/metrics/lib/types';
 import { getSecret } from '@aws-lambda-powertools/parameters/secrets';
 
 // https://docs.powertools.aws.dev/lambda/typescript/latest/core/metrics/#usage
-import { Metrics, MetricUnits } from '@aws-lambda-powertools/metrics';
 
 import { Redis, RedisOptions } from 'ioredis';
-import { MetricsOptions } from '@aws-lambda-powertools/metrics/lib/types';
 
 export interface GetSecretsProps {
   redisSecretArn: string;

src/construct.handler.ts

@@ -21,7 +21,7 @@ interface EnvVarTestCase {
 const defaultEnvVars: Record<string, any> = {
   REDIS_ADDR: 'fakeAddr',
   REDIS_PORT: '12345',
-  QUEUES: JSON.stringify(['fakeQueue']),
+  QUEUE_NAMES: JSON.stringify(['fakeQueue']),
   REDIS_SECRET_ARN: 'fakeArn',
   REDIS_SECRET_PASSWORD_PATH: 'fakePasswordPath',
   REDIS_SECRET_USERNAME_PATH: 'fakeUsernamePath',
@@ -49,7 +49,7 @@ describe('environment variable testing', () => {
       name: 'REDIS_ADDR',
       expectedError: 'REDIS_ADDR environment variable not set',
     },
-  ])('handler errors when required environment variable', ({ name, expectedError }) => {
+  ])('handler errors when required environment variable', async ({ name, expectedError }) => {
     // Mock in ALL the defaultEnvVars EXCEPT the one being tested
     Object.keys(defaultEnvVars).forEach((key) => {
       if (key === name) {
@@ -58,7 +58,7 @@ describe('environment variable testing', () => {
       process.env[key] = defaultEnvVars[key];
     });
 
-    expect(handler()).rejects.toThrow(expectedError);
+    await expect(handler()).rejects.toThrow(expectedError);
   });
 });