chore: format parser package

Author: dreamorosi

packages/parser/src/envelopes/index.ts

@@ -4,11 +4,11 @@ export { CloudWatchEnvelope } from './cloudwatch.js';
 export { DynamoDBStreamEnvelope } from './dynamodb.js';
 export { EventBridgeEnvelope } from './eventbridge.js';
 export { KafkaEnvelope } from './kafka.js';
-export { KinesisFirehoseEnvelope } from './kinesis-firehose.js';
 export { KinesisEnvelope } from './kinesis.js';
+export { KinesisFirehoseEnvelope } from './kinesis-firehose.js';
 export { LambdaFunctionUrlEnvelope } from './lambda.js';
-export { SnsSqsEnvelope } from './sns-sqs.js';
 export { SnsEnvelope } from './sns.js';
+export { SnsSqsEnvelope } from './sns-sqs.js';
 export { SqsEnvelope } from './sqs.js';
 export { VpcLatticeEnvelope } from './vpc-lattice.js';
 export { VpcLatticeV2Envelope } from './vpc-latticev2.js';

packages/parser/src/helpers/dynamodb.ts

@@ -70,7 +70,7 @@ const DynamoDBMarshalled = <T extends ZodTypeAny>(schema: T) =>
     .transform((str, ctx) => {
       try {
         return unmarshallDynamoDB(str);
-      } catch (err) {
+      } catch {
         ctx.addIssue({
           code: 'custom',
           message: 'Could not unmarshall DynamoDB stream record',

packages/parser/src/helpers/index.ts

@@ -44,7 +44,7 @@ const JSONStringified = <T extends ZodTypeAny>(schema: T) =>
     .transform((str, ctx) => {
       try {
         return JSON.parse(str);
-      } catch (err) {
+      } catch {
         ctx.addIssue({
           code: 'custom',
           message: 'Invalid JSON',

packages/parser/src/index.ts

@@ -1,2 +1,2 @@
-export { parser } from './parserDecorator.js';
 export { ParseError } from './errors.js';
+export { parser } from './parserDecorator.js';

packages/parser/src/schemas/api-gateway-websocket.ts

@@ -67,14 +67,17 @@ export const APIGatewayProxyWebsocketEventSchema = z.object({
   headers: z.record(z.string()),
   multiValueHeaders: z.record(z.array(z.string())),
   queryStringParameters: z.record(z.string()).nullable().optional(),
-  multiValueQueryStringParameters: z.record(z.array(z.string())).nullable().optional(),
+  multiValueQueryStringParameters: z
+    .record(z.array(z.string()))
+    .nullable()
+    .optional(),
   stageVariables: z.record(z.string()).nullable().optional(),
   requestContext: z.object({
     routeKey: z.string(),
-    eventType: z.enum(["CONNECT", "DISCONNECT", "MESSAGE"]),
+    eventType: z.enum(['CONNECT', 'DISCONNECT', 'MESSAGE']),
     extendedRequestId: z.string(),
     requestTime: z.string(),
-    messageDirection: z.enum(["IN", "OUT"]),
+    messageDirection: z.enum(['IN', 'OUT']),
     stage: z.string(),
     connectedAt: z.number(),
     requestTimeEpoch: z.number(),
@@ -89,4 +92,4 @@ export const APIGatewayProxyWebsocketEventSchema = z.object({
   }),
   isBase64Encoded: z.boolean(),
   body: z.string().optional().nullable(),
-});
+});

packages/parser/src/schemas/cloudwatch.ts

@@ -26,7 +26,7 @@ const decompressRecordToJSON = (
     );
 
     return CloudWatchLogsDecodeSchema.parse(JSON.parse(uncompressed));
-  } catch (error) {
+  } catch {
     throw new DecompressError('Failed to decompress CloudWatch log data');
   }
 };

packages/parser/src/schemas/dynamodb.ts

@@ -40,7 +40,7 @@ const unmarshallDynamoDBTransform = (
     try {
       // @ts-expect-error
       return unmarshallDynamoDB(image) as Record<string, unknown>;
-    } catch (err) {
+    } catch {
       ctx.addIssue({
         code: 'custom',
         message: `Could not unmarshall ${imageName} in DynamoDB stream record`,

packages/parser/src/schemas/index.ts

@@ -1,28 +1,28 @@
-export { AlbSchema, AlbMultiValueHeadersSchema } from './alb.js';
+export { AlbMultiValueHeadersSchema, AlbSchema } from './alb.js';
 export {
+  APIGatewayEventRequestContextSchema,
   APIGatewayProxyEventSchema,
   APIGatewayRequestAuthorizerEventSchema,
   APIGatewayTokenAuthorizerEventSchema,
-  APIGatewayEventRequestContextSchema,
 } from './api-gateway.js';
 export { APIGatewayProxyWebsocketEventSchema } from './api-gateway-websocket.js';
 export {
-  AppSyncResolverSchema,
+  APIGatewayProxyEventV2Schema,
+  APIGatewayRequestAuthorizerEventV2Schema,
+  APIGatewayRequestAuthorizerV2Schema,
+  APIGatewayRequestContextV2Schema,
+} from './api-gatewayv2.js';
+export {
   AppSyncBatchResolverSchema,
+  AppSyncResolverSchema,
 } from './appsync.js';
 export {
   AppSyncEventsBaseSchema,
-  AppSyncEventsRequestSchema,
   AppSyncEventsInfoSchema,
   AppSyncEventsPublishSchema,
+  AppSyncEventsRequestSchema,
   AppSyncEventsSubscribeSchema,
 } from './appsync-events.js';
-export {
-  APIGatewayProxyEventV2Schema,
-  APIGatewayRequestAuthorizerEventV2Schema,
-  APIGatewayRequestAuthorizerV2Schema,
-  APIGatewayRequestContextV2Schema,
-} from './api-gatewayv2.js';
 export {
   CloudFormationCustomResourceCreateSchema,
   CloudFormationCustomResourceDeleteSchema,
@@ -34,18 +34,18 @@ export {
   CloudWatchLogsSchema,
 } from './cloudwatch.js';
 export {
-  PreSignupTriggerSchema,
+  CreateAuthChallengeTriggerSchema,
+  CustomEmailSenderTriggerSchema,
+  CustomMessageTriggerSchema,
+  CustomSMSSenderTriggerSchema,
+  DefineAuthChallengeTriggerSchema,
+  MigrateUserTriggerSchema,
+  PostAuthenticationTriggerSchema,
   PostConfirmationTriggerSchema,
   PreAuthenticationTriggerSchema,
-  PostAuthenticationTriggerSchema,
+  PreSignupTriggerSchema,
   PreTokenGenerationTriggerSchemaV1,
   PreTokenGenerationTriggerSchemaV2AndV3,
-  MigrateUserTriggerSchema,
-  CustomMessageTriggerSchema,
-  CustomEmailSenderTriggerSchema,
-  CustomSMSSenderTriggerSchema,
-  DefineAuthChallengeTriggerSchema,
-  CreateAuthChallengeTriggerSchema,
   VerifyAuthChallengeTriggerSchema,
 } from './cognito.js';
 export {
@@ -55,40 +55,40 @@ export {
 export { EventBridgeSchema } from './eventbridge.js';
 export {
   KafkaMskEventSchema,
-  KafkaSelfManagedEventSchema,
   KafkaRecordSchema,
+  KafkaSelfManagedEventSchema,
 } from './kafka.js';
 export {
+  KinesisDataStreamRecord,
   KinesisDataStreamSchema,
   KinesisDynamoDBStreamSchema,
-  KinesisDataStreamRecord,
 } from './kinesis.js';
 export {
-  KinesisFirehoseSchema,
-  KinesisFirehoseSqsSchema,
   KinesisFirehoseRecordSchema,
+  KinesisFirehoseSchema,
   KinesisFirehoseSqsRecordSchema,
+  KinesisFirehoseSqsSchema,
 } from './kinesis-firehose.js';
 export { LambdaFunctionUrlSchema } from './lambda.js';
 export {
-  S3SqsEventNotificationSchema,
   S3EventNotificationEventBridgeSchema,
   S3ObjectLambdaEventSchema,
   S3Schema,
+  S3SqsEventNotificationSchema,
 } from './s3.js';
-export { SesSchema, SesRecordSchema } from './ses.js';
+export { SesRecordSchema, SesSchema } from './ses.js';
 export {
-  SnsSchema,
+  SnsNotificationSchema,
   SnsRecordSchema,
+  SnsSchema,
   SnsSqsNotificationSchema,
-  SnsNotificationSchema,
 } from './sns.js';
 export {
-  SqsSchema,
-  SqsRecordSchema,
-  SqsMsgAttributeSchema,
-  SqsMsgAttributeDataTypeSchema,
   SqsAttributesSchema,
+  SqsMsgAttributeDataTypeSchema,
+  SqsMsgAttributeSchema,
+  SqsRecordSchema,
+  SqsSchema,
 } from './sqs.js';
 export { TransferFamilySchema } from './transfer-family.js';
 export { VpcLatticeSchema } from './vpc-lattice.js';

packages/parser/src/schemas/kinesis-firehose.ts

@@ -40,7 +40,7 @@ const KinesisFirehoseSqsRecordSchema = KinesisFireHoseRecordBase.extend({
       return SqsRecordSchema.parse(
         JSON.parse(Buffer.from(data, 'base64').toString('utf8'))
       );
-    } catch (e) {
+    } catch {
       ctx.addIssue({
         code: z.ZodIssueCode.custom,
         message: 'Failed to parse SQS record',

packages/parser/src/schemas/kinesis.ts

@@ -16,7 +16,7 @@ const KinesisDataStreamRecordPayload = z.object({
     try {
       // If data was not compressed, try to parse it as JSON otherwise it must be string
       return decompressed === data ? JSON.parse(decoded) : decompressed;
-    } catch (e) {
+    } catch {
       return decoded;
     }
   }),
@@ -25,7 +25,7 @@ const KinesisDataStreamRecordPayload = z.object({
 const decompress = (data: string): string => {
   try {
     return JSON.parse(gunzipSync(fromBase64(data, 'base64')).toString('utf8'));
-  } catch (e) {
+  } catch {
     return data;
   }
 };