Node.js: –experimental-vm-modules

// user-service.js
const { db } = require('./database.js');
exports.getUser = (id) => db.query('SELECT * FROM users WHERE id = ?', id);

// user-service.test.js
jest.mock('./database.js', () => ({ db: { query: jest.fn() } }));

const { db } = require('./database.js');
const { getUser } = require('./user-service.js');

beforeEach(() => jest.resetAllMocks());

...

test('id로 유저 한 명을 조회한다', async () => {
  db.query.mockResolvedValue([{ id: 42, name: '홍길동', email: 'a@b.com' }]);

  const rows = await getUser(42);

  expect(rows).toEqual([{ id: 42, name: '홍길동', email: 'a@b.com' }]);
  expect(db.query).toHaveBeenCalledWith('SELECT * FROM users WHERE id = ?', 42);
});

> node -v
v26.0.0

> node -e "console.log(require('node:module').wrapper)"
Proxy([
  '(function (exports, require, module, __filename, __dirname) { ',
  '\n});'
])

> node -e "console.log(require('node:module'))"
<ref *1> [Function: Module] {
...
}

Proxy([
  '(function (exports, require, module, __filename, __dirname) { ',
  '\n});'
])

// greeting.js
const name = 'world';
module.exports = 'hello, ' + name;

(function (exports, require, module, __filename, __dirname) { const name = 'world';
module.exports = 'hello, ' + name;

});

┌──────────────────────────────────────────────────────────────┐
│ (function (exports, require, module, __filename, __dirname) {│  ← Node가 추가
├──────────────────────────────────────────────────────────────┤
│ const name = 'world';                                        │
│ module.exports = 'hello, ' + name;                           │  ← 내가 작성한 코드
├──────────────────────────────────────────────────────────────┤
│ });                                                          │  ← Node가 추가
└──────────────────────────────────────────────────────────────┘

// my-require.js
const fs = require('fs');

function myRequire(filename) {
  // 1. 대상이 되는 파일을 텍스트로 읽어오기
  const yourCode = fs.readFileSync(filename, 'utf8');

  // 2. 앞, 뒤로 wrapper 코드 붙이기
  const wrapped =
    '(function (exports, require, module, __filename, __dirname) {' +
    yourCode +
    '\n})';

  // 3. 실행 가능한 함수로 변환
  const fn = eval(wrapped);

  // 4. 매개변수를 정의하고 호출하기
  const module = { exports: {} };
  // require 파라미터에 myRequire를 전달함!!!!!
  fn(module.exports, myRequire, module, filename, __dirname);

  // 5. module.exports 값을 리턴
  return module.exports;
}

console.log(myRequire('./greeting.js'));   // hello, world

> node my-require.js                                                 
hello, world

import { db } from './database.js';
export function getUser(id) { return db.query('...', id); }

> node -e "const vm=require('node:vm'); console.log(typeof vm.SourceTextModule)"
undefined

> node --experimental-vm-modules -e "const vm=require('node:vm'); console.log(typeof vm.SourceTextModule)"
function

// esm-3steps.js
import vm from 'node:vm';

// vm.createContext는 독립적인 코드 실행공간(샌드박스)을 생성합니다.
// 새로 생성된 context에는 console 조차도 없기 때문에 주입해줘야 합니다.
const context = vm.createContext({ console });

// 1단계 - 분석. 코드를 컴파일하면서 import와 export를 추출합니다.
// 아직 코드는 실행되지 않습니다.
const module = new vm.SourceTextModule(
  `export const greeting = 'hello world';`,
  { context, identifier: 'hello.mjs' },
);
console.log(module.status);            // 'unlinked'

// 2단계 - 연결. 모든 import, export에서 로드할 모듈을 결정합니다.
// hello.mjs는 다른 모듈을 import하지 않기 때문에, linker는 아무 일도 하지 않습니다.
await module.link(() => { throw new Error('no imports'); });
console.log(module.status);            // 'linked'

// 3단계 - 실행. 이제 코드가 실행됩니다.
await module.evaluate();
console.log(module.status);            // 'evaluated'

console.log(module.namespace.greeting); // 'hello world'

> node --experimental-vm-modules esm-3steps.js
unlinked
linked
evaluated
hello world
(node:68009) ExperimentalWarning: VM Modules is an experimental feature and might change at any time
(Use `node --trace-warnings ...` to show where the warning was created)

> node --experimental-vm-modules esm-loadMock.js
{ id: 42, name: '홍길동' }
(node:81468) ExperimentalWarning: VM Modules is an experimental feature and might change at any time
(Use `node --trace-warnings ...` to show where the warning was created)

// database.js
// 코드가 실행되기 전에 import로 인해 실행됩니다!
console.log('  [database.js] connecting to postgres://prod...');

export const db = {
  query(sql, id) {
    throw new Error('REAL DATABASE HIT');
  },
};

// user-service.js
// 팩토리 패턴을 사용해서 import를 하나도 선언하지 않습니다.
// db 파라미터에는 실제 DB나 fake DB가 사용될 수 있죠.
export function createUserService({ db }) {
  return {
    getUser(id) {
      return db.query('SELECT * FROM users WHERE id = ?', id);
    },
  };
}

// 실제 코드를 실행하는 진입점입니다.
import { db } from './database.js';
import { createUserService } from './user-service.js';

export const userService = createUserService({ db });

// user-service.test.mjs
// 실행 방법:  node --test
// node:test는 vm 모듈을 사용하지 않기 때문에 --experimental-vm-modules 플래그가 필요 없습니다!

import { test } from 'node:test';
import assert from 'node:assert';

// fake DB를 만드는 함수
function createFakeDb(rows = {}) {
  const calls = [];
  return {
    calls,
    query(sql, id) {
      calls.push({ sql, id });
      return rows[id] ?? null;
    },
  };
}

test('fake DB로 서비스를 생성하기', async () => {
  const { createUserService } = await import('./user-service.js');
  const fakeDb = createFakeDb({ 42: { id: 42, name: '홍길동' } });

  const service = createUserService({ db: fakeDb });
  const user = service.getUser(42);

  assert.deepStrictEqual(user, { id: 42, name: '홍길동' });
  assert.deepStrictEqual(fakeDb.calls, [
    { sql: 'SELECT * FROM users WHERE id = ?', id: 42 },
  ]);
});

test('찾을 수 없는 데이터 테스트', async () => {
  const { createUserService } = await import('./user-service.js');
  const service = createUserService({ db: createFakeDb() });

  assert.strictEqual(service.getUser(999), null);
});

test('db 오류가 전파되는지 확인하는 테스트', async () => {
  const { createUserService } = await import('./user-service.js');
  const service = createUserService({
    db: { query() { throw new Error('connection reset'); } },
  });

  assert.throws(() => service.getUser(42), /connection reset/);
});

> node --test                                   
✔ fake DB로 서비스를 생성하기 (1.105083ms)
✔ 찾을 수 없는 데이터 테스트 (0.085625ms)
✔ db 오류가 전파되는지 확인하는 테스트 (0.432792ms)
ℹ tests 3
ℹ suites 0
ℹ pass 3
ℹ fail 0
ℹ cancelled 0
ℹ skipped 0
ℹ todo 0
ℹ duration_ms 42.566208