__dirname

Author: Daniel Del Core

packages/cli/src/index.ts

@@ -1,5 +1,6 @@
 import path from 'path';
 import { readFileSync } from 'fs';
+import { fileURLToPath } from 'url';
 import chalk from 'chalk';
 import { Command, Option, CommanderError } from 'commander';
 
@@ -9,6 +10,9 @@ import init from './init.js';
 import validate from './validate.js';
 import { InvalidUserInputError, InvalidConfigError } from './errors.js';
 
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+
 const packageJson = readFileSync(
   path.join(__dirname, '..', 'package.json'),
   'utf-8',

packages/cli/src/main.ts

@@ -3,6 +3,7 @@ import semver from 'semver';
 import chalk from 'chalk';
 import findUp from 'find-up';
 import inquirer from 'inquirer';
+import { fileURLToPath } from 'url';
 import { PluginManager, PluginManagerOptions } from 'live-plugin-manager';
 
 import * as core from '@hypermod/core';
@@ -21,6 +22,9 @@ import {
 import ModuleLoader from './utils/module-loader.js';
 import { getConfigPrompt, getMultiConfigPrompt } from './prompt.js';
 
+const filename = fileURLToPath(import.meta.url);
+const dirname = path.dirname(filename);
+
 export default async function main(
   paths: string[],
   flags: Partial<core.Flags>,
@@ -32,7 +36,7 @@ export default async function main(
   }
 
   const pluginManagerConfig: Partial<PluginManagerOptions> = {
-    pluginsPath: path.join(__dirname, '..', 'node_modules'),
+    pluginsPath: path.join(dirname, '..', 'node_modules'),
   };
 
   // If a registry is provided in the CLI flags, use it for the pluginManagers configuration.

packages/cli/src/utils/module-loader.ts

@@ -1,9 +1,13 @@
 import path from 'path';
 import fs from 'fs-extra';
+import { fileURLToPath } from 'url';
 import { installPackage } from '@antfu/install-pkg';
 
 import { ModuleLoader } from '@hypermod/fetcher';
 
+const filename = fileURLToPath(import.meta.url);
+const dirname = path.dirname(filename);
+
 /**
  * Register the TSX plugin to allow require TS(X) files.
  */
@@ -14,9 +18,13 @@ const ModuleLoader = (config: {
   npmRegistryUrl?: string;
   authToken?: string;
 }): ModuleLoader => {
-  const getInfo = (packageName: string) => {
-    const entryPath = require.resolve(packageName);
-    const location = entryPath.split(packageName)[0] + packageName;
+  const getInfo = async (packageName: string) => {
+    // @ts-expect-error - TS doesn't know about import.meta
+    const entryPath = await import.meta.resolve(packageName);
+    const location = (entryPath.split(packageName)[0] + packageName).replace(
+      'file://',
+      '',
+    );
     const pkgJsonRaw = fs.readFileSync(
       path.join(location, 'package.json'),
       'utf8',
@@ -32,7 +40,7 @@ const ModuleLoader = (config: {
 
   const install = async (packageName: string) => {
     await installPackage(packageName, {
-      cwd: __dirname,
+      cwd: dirname,
       packageManager: 'npm',
       additionalArgs: [
         '--force',
@@ -44,7 +52,7 @@ const ModuleLoader = (config: {
       ],
     });
 
-    const { pkgJson } = getInfo(packageName);
+    const { pkgJson } = await getInfo(packageName);
 
     // Install whitelisted devDependencies
     if (pkgJson?.hypermod?.dependencies) {
@@ -53,7 +61,7 @@ const ModuleLoader = (config: {
           const version = pkgJson.devDependencies[dep];
           if (!version) return;
           return installPackage(`${dep}@${version}`, {
-            cwd: __dirname,
+            cwd: dirname,
             packageManager: 'npm',
             additionalArgs: ['--force'],
           });

packages/core/lib/Worker.js

@@ -1,45 +1,47 @@
 /* eslint-disable @typescript-eslint/no-var-requires */
 'use strict';
 
-const path = require('path');
-const { EventEmitter } = require('events');
-const async = require('neo-async');
-const fs = require('graceful-fs');
-const writeFileAtomic = require('write-file-atomic');
-const { DEFAULT_EXTENSIONS } = require('@babel/core');
-
-const getParser = require('jscodeshift/src/getParser');
-const jscodeshift = require('jscodeshift/src/core');
-
-let presetEnv;
-try {
-  presetEnv = require('@babel/preset-env');
-} catch (_) {}
+import path from 'path';
+import { fileURLToPath } from 'url';
+import fs from 'graceful-fs';
+import { EventEmitter } from 'events';
+import async from 'neo-async';
+import writeFileAtomic from 'write-file-atomic';
+
+import getParser from 'jscodeshift/src/getParser.js';
+import jscodeshift from 'jscodeshift/src/core.js';
+
+/**
+ * Register the TSX plugin to allow require TS(X) files.
+ */
+import { register } from 'tsx/esm/api';
+register();
 
 let emitter;
 let finish;
 let notify;
 let transform;
 let parserFromTransform;
 
-if (module.parent) {
+if (import.meta.url.replace('file://', '') !== process.argv[1]) {
   emitter = new EventEmitter();
   // @ts-expect-error
   emitter.send = data => run(data);
   finish = () => emitter.emit('disconnect');
   notify = data => emitter.emit('message', data);
-
-  module.exports = args => {
-    setup(args[0], args[1]);
-    return emitter;
-  };
 } else {
   finish = () => setImmediate(() => process.disconnect());
   notify = data => process.send(data);
   process.on('message', data => run(data));
   setup(process.argv[2], process.argv[3]);
 }
 
+// Used by `run-in-band` to run the worker in the same process
+export default async function main(args) {
+  await setup(args[0], args[1]);
+  return emitter;
+}
+
 function prepareJscodeshift(options) {
   const parser =
     parserFromTransform || getParser(options.parser, options.parserConfig);
@@ -59,59 +61,34 @@ function retrievePath(str) {
 }
 
 function getModule(mod) {
-  return mod.hasOwnProperty('default') ? mod.default : mod;
+  return Boolean(mod.default) ? mod.default : mod;
 }
 
-function setup(entryPath, babel) {
-  if (babel === 'babel') {
-    const presets = [];
-    if (presetEnv) {
-      presets.push([presetEnv.default, { targets: { node: true } }]);
-    }
-
-    presets.push(require('@babel/preset-typescript').default);
-
-    require('@babel/register')({
-      configFile: false,
-      babelrc: false,
-      presets,
-      plugins: [
-        require('@babel/plugin-proposal-class-properties').default,
-        require('@babel/plugin-proposal-nullish-coalescing-operator').default,
-        require('@babel/plugin-proposal-optional-chaining').default,
-        require('@babel/plugin-transform-modules-commonjs').default,
-      ],
-      extensions: [...DEFAULT_EXTENSIONS, '.ts', '.tsx'],
-      // By default, babel register only compiles things inside the current working directory.
-      // https://github.com/babel/babel/blob/2a4f16236656178e84b05b8915aab9261c55782c/packages/babel-register/src/node.js#L140-L157
-      ignore: [
-        // Ignore parser related files
-        /@babel\/parser/,
-        /\/flow-parser\//,
-        /\/recast\//,
-        /\/ast-types\//,
-      ],
-    });
-  }
+async function getModuleName(path) {
+  const moduleName = retrievePath(path).split('node_modules/')[1];
+  const pkg = await import(moduleName);
+  return getModule(pkg);
+}
 
+async function setup(entryPath) {
   const transformId = retrieveTransformId(entryPath);
   const presetId = retrievePresetId(entryPath);
 
   let transformPkg;
   let transformModule;
 
   if (transformId) {
-    transformPkg = getModule(require(path.resolve(retrievePath(entryPath))));
+    transformPkg = await getModuleName(entryPath);
     transformModule = transformPkg.transforms[transformId];
   }
 
   if (presetId) {
-    transformPkg = getModule(require(path.resolve(retrievePath(entryPath))));
+    transformPkg = await getModuleName(entryPath);
     transformModule = transformPkg.presets[presetId];
   }
 
   if (!transformId && !presetId) {
-    transformModule = require(path.resolve(entryPath));
+    transformModule = await import(path.resolve(entryPath));
   }
 
   transform = getModule(transformModule);
@@ -141,6 +118,7 @@ function trimStackTrace(trace) {
   // Remove this file from the stack trace of an error thrown in the transformer
   const result = [];
   trace.split('\n').every(line => {
+    const __filename = fileURLToPath(import.meta.url);
     if (line.indexOf(__filename) === -1) {
       result.push(line);
       return true;