chore: remove luxon for native dates

Author: cino

package-lock.json

@@ -34,9 +34,6 @@
   },
   "homepage": "https://github.com/cino/aws-lambda-stubs#readme",
   "private": false,
-  "dependencies": {
-    "luxon": "^3.7.2"
-  },
   "devDependencies": {
     "@biomejs/biome": "2.3.1",
     "@commitlint/cli": "^20.1.0",

package.json

@@ -13,18 +13,18 @@ import type {
   APIGatewayProxyWithCognitoAuthorizerEvent,
   APIGatewayProxyWithLambdaAuthorizerEvent,
 } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import type { Merge } from 'type-fest';
 import {
   APIGatewayEventRequestContextV2Stub,
   APIGatewayEventRequestContextV2WithAuthorizerStub,
   APIGatewayEventRequestContextWithAuthorizerStub,
   DEFAULT_REGION,
+  eventParsedDateTime,
   type PartialAPIGatewayEventRequestContext,
   type PartialAPIGatewayEventRequestContextV2,
   randomIpAddress,
 } from './common';
-import { deepMerge } from './utils';
+import { currentEpochTime, deepMerge } from './utils';
 
 // V1
 
@@ -181,7 +181,7 @@ type PartialAPIGatewayProxyWebsocketEventV2 = Merge<
 export const APIGatewayProxyWebsocketEventV2Stub = (
   overrides: PartialAPIGatewayProxyWebsocketEventV2 = {}
 ): APIGatewayProxyWebsocketEventV2 => {
-  const now = DateTime.now();
+  const currentEpoch = currentEpochTime();
 
   return deepMerge<APIGatewayProxyWebsocketEventV2>(
     {
@@ -192,9 +192,9 @@ export const APIGatewayProxyWebsocketEventV2Stub = (
         extendedRequestId: crypto.randomUUID(),
         messageDirection: 'IN',
         stage: 'prod',
-        connectedAt: now.toUnixInteger(),
-        requestTime: now.toFormat('dd/MMM/yyyy:HH:mm:ss ZZZ'),
-        requestTimeEpoch: now.toUnixInteger(),
+        connectedAt: currentEpoch,
+        requestTime: eventParsedDateTime(new Date()),
+        requestTimeEpoch: currentEpoch,
         requestId: crypto.randomUUID(),
         domainName: `id.execute-api.${DEFAULT_REGION}.amazonaws.com`,
         connectionId: crypto.randomUUID(),

src/api-gateway-proxy.ts

@@ -1,9 +1,10 @@
 import type { CloudWatchLogsDecodedData, CloudWatchLogsEvent, CloudWatchLogsLogEvent } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import { DEFAULT_ACCOUNT_ID } from './common';
-import { deepMerge } from './utils';
+import { currentEpochTime, deepMerge } from './utils';
 
 export const CloudWatchLogsEventStub = (overrides: Partial<CloudWatchLogsDecodedData> = {}): CloudWatchLogsEvent => {
+  const currentEpoch = currentEpochTime();
+
   return {
     awslogs: {
       data: Buffer.from(
@@ -18,12 +19,12 @@ export const CloudWatchLogsEventStub = (overrides: Partial<CloudWatchLogsDecoded
               logEvents: [
                 {
                   id: 'eventId1',
-                  timestamp: DateTime.now().toUnixInteger(),
+                  timestamp: currentEpoch,
                   message: 'This is a sample log message 1',
                 },
                 {
                   id: 'eventId2',
-                  timestamp: DateTime.now().toUnixInteger(),
+                  timestamp: currentEpoch,
                   message: 'This is a sample log message 2',
                 },
               ],
@@ -39,7 +40,7 @@ export const CloudWatchLogsEventStub = (overrides: Partial<CloudWatchLogsDecoded
 export const CloudWatchLogsLogEventStub = (overrides: Partial<CloudWatchLogsLogEvent> = {}): CloudWatchLogsLogEvent => {
   return {
     id: 'eventId1',
-    timestamp: DateTime.now().toUnixInteger(),
+    timestamp: currentEpochTime(),
     message: 'This is a sample log message',
 
     ...overrides,

src/cloudwatch-logs.ts

@@ -3,9 +3,8 @@ import type {
   APIGatewayEventRequestContextV2,
   APIGatewayEventRequestContextWithAuthorizer,
 } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import type { Merge } from 'type-fest';
-import { deepMerge, randomIpAddress } from '../utils';
+import { currentEpochTime, deepMerge, randomIpAddress } from '../utils';
 import { DEFAULT_ACCOUNT_ID, DEFAULT_REGION } from './consts';
 
 export type PartialAPIGatewayEventRequestContext<TAuthorizer> = Merge<
@@ -16,6 +15,26 @@ export type PartialAPIGatewayEventRequestContext<TAuthorizer> = Merge<
   }
 >;
 
+export const eventParsedDateTime = (date: Date): string => {
+  const day = String(date.getDate()).padStart(2, '0');
+  const month = date.toLocaleString('en-US', { month: 'short' });
+  const year = date.getFullYear();
+  const hour = String(date.getHours());
+  const minute = String(date.getMinutes());
+  const second = String(date.getSeconds());
+
+  const offset = -date.getTimezoneOffset(); // Reverse the sign
+
+  const sign = offset >= 0 ? '+' : '-';
+  const absOffset = Math.abs(offset);
+  const hours = String(Math.floor(absOffset / 60)).padStart(2, '0');
+  const minutes = String(absOffset % 60).padStart(2, '0');
+
+  const formattedTz = `${sign}${hours}${minutes}`;
+
+  return `${day}/${month}/${year}:${hour}:${minute}:${second} ${formattedTz}`;
+};
+
 export const APIGatewayEventRequestContextWithAuthorizerStub = <TAuthorizer>(
   overrides: PartialAPIGatewayEventRequestContext<TAuthorizer> = {
     authorizer: undefined,
@@ -31,7 +50,7 @@ export const APIGatewayEventRequestContextWithAuthorizerStub = <TAuthorizer>(
       path: '/prod/resource',
       stage: 'prod',
       requestId: crypto.randomUUID(),
-      requestTimeEpoch: DateTime.now().toUnixInteger(),
+      requestTimeEpoch: currentEpochTime(),
       resourceId: 'resource-id',
       resourcePath: '/resource',
       authorizer: undefined as TAuthorizer, // Will be overridden by deepMerge
@@ -54,7 +73,6 @@ export type PartialAPIGatewayEventRequestContextV2 = Merge<
 export const APIGatewayEventRequestContextV2Stub = (
   overrides: PartialAPIGatewayEventRequestContextV2 = {}
 ): APIGatewayEventRequestContextV2 => {
-  const dateTime = DateTime.now();
 
   return deepMerge(
     {
@@ -72,8 +90,8 @@ export const APIGatewayEventRequestContextV2Stub = (
       requestId: crypto.randomUUID(),
       routeKey: '$default',
       stage: 'prod',
-      time: dateTime.toFormat('dd/MMM/yyyy:HH:mm:ss ZZZ'),
-      timeEpoch: dateTime.toUnixInteger(),
+      time: eventParsedDateTime(new Date()),
+      timeEpoch: currentEpochTime(),
     },
     overrides as Partial<APIGatewayEventRequestContextV2>
   );
@@ -92,7 +110,7 @@ export const APIGatewayEventRequestContextV2WithAuthorizerStub = <TAuthorizer>(
   >(
     {
       ...APIGatewayEventRequestContextV2Stub(overrides),
-      authorizer: undefined as TAuthorizer, // will be overwrtitten by deepMerge
+      authorizer: undefined as TAuthorizer, // will be overwritten by deepMerge
     },
     { authorizer }
   );

src/common/api-gateway.ts

@@ -1,13 +1,13 @@
 import type { FirehoseTransformationEvent, FirehoseTransformationEventRecord } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import { DEFAULT_ACCOUNT_ID, DEFAULT_REGION } from './common';
+import { currentEpochTime } from './utils';
 
 const FireHoseTransformationEventRecordStub = (
   overrides: Partial<FirehoseTransformationEventRecord> = {}
 ): FirehoseTransformationEventRecord => {
   return {
     recordId: 'record-id-123',
-    approximateArrivalTimestamp: DateTime.now().toUnixInteger(),
+    approximateArrivalTimestamp: currentEpochTime(),
     data: 'SGVsbG8sIHRoaXMgaXMgYSB0ZXN0IG1lc3NhZ2Uh', // "Hello, this is a test message!" in base64
     ...overrides,
   };

src/kinesis-firehose-transformation.ts

@@ -1,6 +1,6 @@
 import type { MSKEvent } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import { DEFAULT_ACCOUNT_ID, DEFAULT_REGION } from './common';
+import { currentEpochTime } from './utils';
 
 export const MSKEventStub = (overrides: Partial<MSKEvent> = {}): MSKEvent => {
   return {
@@ -13,7 +13,7 @@ export const MSKEventStub = (overrides: Partial<MSKEvent> = {}): MSKEvent => {
           topic: 'test-topic',
           partition: 0,
           offset: 123,
-          timestamp: DateTime.now().toUnixInteger(),
+          timestamp: currentEpochTime(),
           timestampType: 'CREATE_TIME',
           key: 'abcDEFghiJKLmnoPQRstuVWXyz1234==',
           value: 'SGVsbG8sIHRoaXMgaXMgYSB0ZXN0Lg==',

src/msk.ts

@@ -1,6 +1,6 @@
 import type { SelfManagedKafkaEvent } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import { DEFAULT_REGION } from './common';
+import { currentEpochTime } from './utils';
 
 export const SelfManagedKafkaStub = (overrides: Partial<SelfManagedKafkaEvent> = {}): SelfManagedKafkaEvent => {
   return {
@@ -12,7 +12,7 @@ export const SelfManagedKafkaStub = (overrides: Partial<SelfManagedKafkaEvent> =
           topic: 'test-topic',
           partition: 0,
           offset: 123,
-          timestamp: DateTime.now().toUnixInteger(),
+          timestamp: currentEpochTime(),
           timestampType: 'CREATE_TIME',
           key: 'abcDEFghiJKLmnoPQRstuVWXyz1234==',
           value: 'SGVsbG8sIHRoaXMgaXMgYSB0ZXN0Lg==',

src/self-managed-kafka.ts

@@ -1,6 +1,5 @@
 import crypto from 'node:crypto';
 import type { SQSEvent, SQSRecord } from 'aws-lambda';
-import { DateTime } from 'luxon';
 import { DEFAULT_ACCOUNT_ID, DEFAULT_REGION } from './common';
 import { deepMerge } from './utils';
 
@@ -14,7 +13,7 @@ interface PartialSQSRecord extends Omit<Partial<SQSRecord>, omittedKeys> {
 
 const SQSRecordStub = (overrides: PartialSQSRecord = {}): SQSRecord => {
   const region = overrides.awsRegion ?? DEFAULT_REGION;
-  const now = DateTime.now();
+  const nowIso = new Date().toISOString();
 
   const body = overrides.body || { key: 'value' };
   const stringifiedBody = JSON.stringify(body);
@@ -27,9 +26,9 @@ const SQSRecordStub = (overrides: PartialSQSRecord = {}): SQSRecord => {
       body: stringifiedBody,
       attributes: {
         ApproximateReceiveCount: '1',
-        SentTimestamp: now.toISO(),
+        SentTimestamp: nowIso,
         SenderId: 'sender-id',
-        ApproximateFirstReceiveTimestamp: now.toISO(),
+        ApproximateFirstReceiveTimestamp: nowIso,
       },
       messageAttributes: {},
       md5OfBody: crypto.createHash('md5').update(stringifiedBody).digest('hex'),

src/sqs.ts

@@ -0,0 +1,3 @@
+export const currentEpochTime = (): number => {
+  return Math.floor(Date.now() / 1000);
+};