feat: Window support (#92)

Author: ServerlessLife

src/frameworks/cdkFramework.ts

@@ -1,6 +1,7 @@
 import * as esbuild from 'esbuild';
 import * as fs from 'fs/promises';
 import * as path from 'path';
+import { pathToFileURL } from 'url';
 import { BundlingType, LambdaResource } from '../types/resourcesDiscovery.js';
 import { outputFolder } from '../constants.js';
 import { findPackageJson } from '../utils/findPackageJson.js';
@@ -287,7 +288,11 @@ export class CdkFramework implements IFramework {
               ? 'js'
               : (fileExtension as esbuild.Loader);
           // Inject code to get the file path of the Lambda function and CDK hierarchy
-          if (args.path.includes('aws-cdk-lib/aws-lambda/lib/function.')) {
+          if (
+            args.path.includes(
+              path.join('aws-cdk-lib', 'aws-lambda', 'lib', 'function.'),
+            )
+          ) {
             const codeToFind =
               'try{jsiiDeprecationWarnings().aws_cdk_lib_aws_lambda_FunctionProps(props)}';
 
@@ -487,20 +492,21 @@ export class CdkFramework implements IFramework {
     compileCodeFile: string;
   }) {
     const lambdas: any[] = await new Promise((resolve, reject) => {
-      const worker = new Worker(
+      const workerPath = pathToFileURL(
         path.resolve(
           path.join(getModuleDirname(), 'frameworks/cdkFrameworkWorker.mjs'),
         ),
-        {
-          workerData: {
-            verbose: config.verbose,
-            awsCdkLibPath,
-            projectDirname: getProjectDirname(),
-            moduleDirname: getModuleDirname(),
-            subfolder: config.subfolder,
-          },
+      ).href;
+
+      const worker = new Worker(new URL(workerPath), {
+        workerData: {
+          verbose: config.verbose,
+          awsCdkLibPath,
+          projectDirname: getProjectDirname(),
+          moduleDirname: getModuleDirname(),
+          subfolder: config.subfolder,
         },
-      );
+      });
 
       worker.on('message', async (message) => {
         resolve(message);

src/frameworks/cdkFrameworkWorker.mjs

@@ -1,5 +1,6 @@
 // @ts-nocheck
 import { workerData, parentPort } from 'node:worker_threads';
+import { pathToFileURL } from 'url';
 import { Logger } from '../logger.mjs';
 
 Logger.setVerbose(workerData.verbose);
@@ -14,7 +15,7 @@ parentPort.on('message', async (data) => {
     Logger.verbose(`[Worker] Received message`, data);
 
     // execute code to get the data into global.lambdas
-    await import(data.compileOutput);
+    await import(pathToFileURL(data.compileOutput).href);
 
     if (!global.lambdas || global.lambdas?.length === 0) {
       throw new Error('No Lambda functions found in the CDK code');

src/nodeWorker.ts

@@ -1,6 +1,7 @@
 import { Worker } from 'node:worker_threads';
 import { FuctionRequest } from './ioTService.js';
 import * as path from 'path';
+import { pathToFileURL } from 'url';
 import { Configuration } from './configuration.js';
 import { getModuleDirname, getProjectDirname } from './getDirname.js';
 import { Logger } from './logger.js';
@@ -125,22 +126,23 @@ function startWorker(input: WorkerRequest) {
 
   const localProjectDir = getProjectDirname();
 
-  const worker: MyWorker = new Worker(
+  const workerPath = pathToFileURL(
     path.resolve(path.join(getModuleDirname(), `./nodeWorkerRunner.mjs`)),
-    {
-      env: {
-        ...input.environment,
-        IS_LOCAL: 'true',
-        LOCAL_PROJECT_DIR: localProjectDir,
-      },
-      execArgv: ['--enable-source-maps'],
-      workerData: input,
-      stderr: true,
-      stdin: true,
-      stdout: true,
-      //type: "module",
+  ).href;
+
+  const worker: MyWorker = new Worker(workerPath, {
+    env: {
+      ...input.environment,
+      IS_LOCAL: 'true',
+      LOCAL_PROJECT_DIR: localProjectDir,
     },
-  );
+    execArgv: ['--enable-source-maps'],
+    workerData: input,
+    stderr: true,
+    stdin: true,
+    stdout: true,
+    //type: "module",
+  });
 
   worker.stdout.on('data', (data: Buffer) => {
     Logger.log(`[Function ${input.functionId}]`, data.toString());

src/nodeWorkerRunner.mjs

@@ -1,5 +1,6 @@
 // @ts-nocheck
 import { createRequire as topLevelCreateRequire } from 'module';
+import { pathToFileURL } from 'url';
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 const require = topLevelCreateRequire(import.meta.url);
 
@@ -14,7 +15,8 @@ Logger.verbose(
 parentPort.on('message', async (data) => {
   Logger.verbose(`[Worker ${workerData.workerId}] Received message`, data);
   try {
-    const mod = await import(workerData.artifactFile);
+    const artifactFile = pathToFileURL(workerData.artifactFile).href;
+    const mod = await import(artifactFile);
     const fn = mod[workerData.handler];
 
     if (!fn) {