refactor: do not use import path

RomainLanz · RomainLanz · commit ac2d041afbc0 · 2025-12-12T23:49:23.000+01:00
diff --git a/benchmark/boringnode/harness.ts b/benchmark/boringnode/harness.ts
@@ -1,11 +1,11 @@
 import { setTimeout } from 'node:timers/promises'
 import { Redis } from 'ioredis'
-import { Worker } from '#src/worker'
-import { Job } from '#src/job'
-import { Locator } from '#src/locator'
-import { redis } from '#drivers/redis_adapter'
+import { Worker } from '../../src/worker.js'
+import { Job } from '../../src/job.js'
+import { Locator } from '../../src/locator.js'
+import { redis } from '../../src/drivers/redis_adapter.js'
 import { barrier, type BenchmarkOptions, type BenchmarkResult } from '../helpers.js'
-import type { QueueManagerConfig } from '#types/main'
+import type { QueueManagerConfig } from '../../src/types/main.js'
 
 // Barrier callback and job duration - set before each benchmark run
 let onJobComplete: (() => boolean) | null = null
diff --git a/examples/app.ts b/examples/app.ts
@@ -1,5 +1,5 @@
 import { config } from './config.js'
-import { QueueManager } from '#src/queue_manager'
+import { QueueManager } from '../src/queue_manager.js'
 import SendEmailJob from './jobs/send_email_job.js'
 import SyncJob from './jobs/sync_job.js'
 
diff --git a/examples/config.ts b/examples/config.ts
@@ -1,7 +1,7 @@
-import { redis } from '#drivers/redis_adapter'
-import { sync } from '#drivers/sync_adapter'
-import { knex } from '#drivers/knex_adapter'
-import type { QueueManagerConfig } from '#types/main'
+import { redis } from '../src/drivers/redis_adapter.js'
+import { sync } from '../src/drivers/sync_adapter.js'
+import { knex } from '../src/drivers/knex_adapter.js'
+import type { QueueManagerConfig } from '../src/types/main.js'
 
 export const config: QueueManagerConfig = {
   default: 'knex',
diff --git a/examples/jobs/send_email_job.ts b/examples/jobs/send_email_job.ts
@@ -1,6 +1,6 @@
 import { setTimeout } from 'node:timers/promises'
-import { Job } from '#src/job'
-import type { JobOptions } from '#types/main'
+import { Job } from '../../src/job.js'
+import type { JobOptions } from '../../src/types/main.js'
 
 interface SendEmailPayload {
   to: string
diff --git a/examples/jobs/sync_job.ts b/examples/jobs/sync_job.ts
@@ -1,6 +1,6 @@
 import { setTimeout } from 'node:timers/promises'
-import { Job } from '#src/job'
-import type { JobOptions } from '#types/main'
+import { Job } from '../../src/job.js'
+import type { JobOptions } from '../../src/types/main.js'
 
 interface SyncJobPayload {
   source: string
diff --git a/examples/worker.ts b/examples/worker.ts
@@ -1,4 +1,4 @@
-import { Worker } from '#src/worker'
+import { Worker } from '../src/worker.js'
 import { config } from './config.js'
 
 const worker = new Worker(config)
diff --git a/package.json b/package.json
@@ -13,25 +13,17 @@
     "./contracts/*": "./build/src/contracts/*.js",
     "./types/*": "./build/src/types/*.js"
   },
-  "imports": {
-    "#src/*": "./src/*.ts",
-    "#drivers/*": "./src/drivers/*.ts",
-    "#lease_managers/*": "./src/lease_managers/*.ts",
-    "#contracts/*": "./src/contracts/*.ts",
-    "#strategies/*": "./src/strategies/*.ts",
-    "#types/*": "./src/types/*.ts"
-  },
   "scripts": {
-    "benchmark": "node benchmark/run.ts",
-    "benchmark:quick": "node benchmark/run.ts --quick",
-    "benchmark:full": "node benchmark/run.ts --full",
+    "benchmark": "node --import=@poppinss/ts-exec benchmark/run.ts",
+    "benchmark:quick": "node --import=@poppinss/ts-exec benchmark/run.ts --quick",
+    "benchmark:full": "node --import=@poppinss/ts-exec benchmark/run.ts --full",
     "build": "yarn clean && tsup-node",
     "clean": "del-cli build",
     "format": "prettier --write .",
     "lint": "eslint .",
     "prepublishOnly": "yarn build",
     "release": "yarn dlx release-it",
-    "test": "c8 node --enable-source-maps bin/test.ts",
+    "test": "c8 node --import=@poppinss/ts-exec --enable-source-maps bin/test.ts",
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
@@ -41,11 +33,12 @@
   "devDependencies": {
     "@adonisjs/eslint-config": "^2.1.2",
     "@adonisjs/prettier-config": "^1.4.5",
-    "@adonisjs/tsconfig": "^1.4.1",
+    "@adonisjs/tsconfig": "^2.0.0-next.3",
     "@japa/assert": "^4.1.1",
     "@japa/expect-type": "^2.0.3",
     "@japa/file-system": "^2.3.2",
     "@japa/runner": "^4.4.0",
+    "@poppinss/ts-exec": "^1.4.1",
     "@types/better-sqlite3": "^7.6.13",
     "@types/node": "^24.3.1",
     "@types/pg": "^8",
diff --git a/src/contracts/adapter.ts b/src/contracts/adapter.ts
@@ -1,4 +1,4 @@
-import type { JobData } from '#types/main'
+import type { JobData } from '../types/main.js'
 
 export interface AcquiredJob extends JobData {
   acquiredAt: number
diff --git a/src/drivers/knex_adapter.ts b/src/drivers/knex_adapter.ts
@@ -1,7 +1,7 @@
 import KnexPkg from 'knex'
 import type { Knex } from 'knex'
-import type { Adapter, AcquiredJob } from '#contracts/adapter'
-import type { JobData } from '#types/main'
+import type { Adapter, AcquiredJob } from '../contracts/adapter.js'
+import type { JobData } from '../types/main.js'
 
 export interface KnexAdapterOptions {
   connection: Knex
diff --git a/src/drivers/redis_adapter.ts b/src/drivers/redis_adapter.ts
@@ -1,6 +1,6 @@
 import { Redis, type RedisOptions } from 'ioredis'
-import type { Adapter, AcquiredJob } from '#contracts/adapter'
-import type { JobData } from '#types/main'
+import type { Adapter, AcquiredJob } from '../contracts/adapter.js'
+import type { JobData } from '../types/main.js'
 
 const redisKey = 'jobs'
 type RedisConfig = Redis | RedisOptions
diff --git a/src/drivers/sync_adapter.ts b/src/drivers/sync_adapter.ts
@@ -1,6 +1,6 @@
-import { Locator } from '#src/locator'
-import type { Adapter, AcquiredJob } from '#contracts/adapter'
-import type { JobData } from '#types/main'
+import { Locator } from '../locator.js'
+import type { Adapter, AcquiredJob } from '../contracts/adapter.js'
+import type { JobData } from '../types/main.js'
 
 export function sync() {
   return () => new SyncAdapter()
diff --git a/src/job.ts b/src/job.ts
@@ -1,5 +1,5 @@
-import { JobDispatcher } from '#src/job_dispatcher'
-import type { JobOptions } from '#types/main'
+import { JobDispatcher } from './job_dispatcher.js'
+import type { JobOptions } from './types/main.js'
 
 export abstract class Job<Payload = any> {
   readonly #payload: Payload
diff --git a/src/job_dispatcher.ts b/src/job_dispatcher.ts
@@ -1,9 +1,9 @@
-import debug from '#src/debug'
+import debug from './debug.js'
 import { randomUUID } from 'node:crypto'
-import { QueueManager } from '#src/queue_manager'
-import type { Adapter } from '#contracts/adapter'
-import type { Duration } from '#types/main'
-import { parse } from '#src/utils'
+import { QueueManager } from './queue_manager.js'
+import type { Adapter } from './contracts/adapter.js'
+import type { Duration } from './types/main.js'
+import { parse } from './utils.js'
 
 export class JobDispatcher<T> {
   readonly #name: string
diff --git a/src/job_pool.ts b/src/job_pool.ts
@@ -1,4 +1,4 @@
-import type { AcquiredJob } from '#contracts/adapter'
+import type { AcquiredJob } from './contracts/adapter.js'
 
 interface PoolEntry {
   promise: Promise<void>
diff --git a/src/locator.ts b/src/locator.ts
@@ -1,7 +1,7 @@
-import { Job } from '#src/job'
-import * as errors from '#src/exceptions'
-import type { JobClass } from '#types/main'
-import debug from '#src/debug'
+import { Job } from './job.js'
+import * as errors from './exceptions.js'
+import type { JobClass } from './types/main.js'
+import debug from './debug.js'
 import { glob } from 'node:fs/promises'
 import { resolve } from 'node:path'
 
diff --git a/src/queue_manager.ts b/src/queue_manager.ts
@@ -1,8 +1,8 @@
-import * as errors from '#src/exceptions'
-import debug from '#src/debug'
-import { Locator } from '#src/locator'
-import type { Adapter } from '#contracts/adapter'
-import type { AdapterFactory, QueueConfig, QueueManagerConfig, RetryConfig } from '#types/main'
+import * as errors from './exceptions.js'
+import debug from './debug.js'
+import { Locator } from './locator.js'
+import type { Adapter } from './contracts/adapter.js'
+import type { AdapterFactory, QueueConfig, QueueManagerConfig, RetryConfig } from './types/main.js'
 
 class QueueManagerSingleton {
   #defaultAdapter!: string
diff --git a/src/strategies/backoff_strategy.ts b/src/strategies/backoff_strategy.ts
@@ -1,6 +1,6 @@
-import type { BackoffConfig, Duration } from '#types/main'
-import * as errors from '#src/exceptions'
-import { parse } from '#src/utils'
+import type { BackoffConfig, Duration } from '../types/main.js'
+import * as errors from '../exceptions.js'
+import { parse } from '../utils.js'
 import { RuntimeException } from '@poppinss/utils'
 import { assertUnreachable } from '@poppinss/utils/assert'
 
diff --git a/src/types/main.ts b/src/types/main.ts
@@ -1,6 +1,6 @@
-import type { BackoffStrategy as BackoffStrategyClass } from '#strategies/backoff_strategy'
-import type { Adapter } from '#contracts/adapter'
-import { Job } from '#src/job'
+import type { BackoffStrategy as BackoffStrategyClass } from '../strategies/backoff_strategy.js'
+import type { Adapter } from '../contracts/adapter.js'
+import { Job } from '../job.js'
 
 export type Duration = number | string
 
diff --git a/src/utils.ts b/src/utils.ts
@@ -1,6 +1,6 @@
 import { parse as parseDuration } from '@lukeed/ms'
-import type { Duration } from '#types/main'
-import * as errors from '#src/exceptions'
+import type { Duration } from './types/main.js'
+import * as errors from './exceptions.js'
 
 export function parse(duration: Duration): number {
   if (typeof duration === 'number') {
diff --git a/src/worker.ts b/src/worker.ts
@@ -1,15 +1,15 @@
 import { randomUUID } from 'node:crypto'
 import { setTimeout } from 'node:timers/promises'
-import debug from '#src/debug'
-import { parse } from '#src/utils'
-import * as errors from '#src/exceptions'
-import { QueueManager } from '#src/queue_manager'
-import { JobPool } from '#src/job_pool'
-import type { Adapter, AcquiredJob } from '#contracts/adapter'
-import type { QueueManagerConfig, WorkerCycle } from '#types/main'
-import { Locator } from '#src/locator'
-import type { JobOptions } from '#types/main'
-import type { Job } from '#src/job'
+import debug from './debug.js'
+import { parse } from './utils.js'
+import * as errors from './exceptions.js'
+import { QueueManager } from './queue_manager.js'
+import { JobPool } from './job_pool.js'
+import type { Adapter, AcquiredJob } from './contracts/adapter.js'
+import type { QueueManagerConfig, WorkerCycle } from './types/main.js'
+import { Locator } from './locator.js'
+import type { JobOptions } from './types/main.js'
+import type { Job } from './job.js'
 
 export class Worker {
   readonly #id: string
diff --git a/tests/_mocks/chaos_adapter.ts b/tests/_mocks/chaos_adapter.ts
@@ -1,5 +1,5 @@
 import { MemoryAdapter } from './memory_adapter.js'
-import type { AcquiredJob } from '#contracts/adapter'
+import type { AcquiredJob } from '../../src/contracts/adapter.js'
 
 export class ChaosAdapter extends MemoryAdapter {
   #throwProbability = 0
diff --git a/tests/_mocks/memory_adapter.ts b/tests/_mocks/memory_adapter.ts
@@ -1,5 +1,5 @@
-import type { Adapter, AcquiredJob } from '#contracts/adapter'
-import type { JobData } from '#types/main'
+import type { Adapter, AcquiredJob } from '../../src/contracts/adapter.js'
+import type { JobData } from '../../src/types/main.js'
 
 interface ActiveJob {
   job: JobData
diff --git a/tests/_utils/register_driver_test_suite.ts b/tests/_utils/register_driver_test_suite.ts
@@ -1,5 +1,5 @@
 import { test as JapaTest } from '@japa/runner'
-import type { Adapter } from '#contracts/adapter'
+import type { Adapter } from '../../src/contracts/adapter.js'
 
 interface DriverTestSuiteOptions {
   test: typeof JapaTest
diff --git a/tests/adapter.spec.ts b/tests/adapter.spec.ts
@@ -2,8 +2,8 @@ import Knex from 'knex'
 import { test } from '@japa/runner'
 import { Redis } from 'ioredis'
 import { MemoryAdapter } from './_mocks/memory_adapter.js'
-import { RedisAdapter } from '#drivers/redis_adapter'
-import { KnexAdapter } from '#drivers/knex_adapter'
+import { RedisAdapter } from '../src/drivers/redis_adapter.js'
+import { KnexAdapter } from '../src/drivers/knex_adapter.js'
 import { registerDriverTestSuite } from './_utils/register_driver_test_suite.js'
 
 const KEY_PREFIX = 'boringnode::queue::test::'
diff --git a/tests/backoff_strategy.spec.ts b/tests/backoff_strategy.spec.ts
@@ -5,8 +5,8 @@ import {
   exponentialBackoff,
   fixedBackoff,
   linearBackoff,
-} from '#strategies/backoff_strategy'
-import * as errors from '#src/exceptions'
+} from '../src/strategies/backoff_strategy.js'
+import * as errors from '../src/exceptions.js'
 
 test.group('BackoffStrategy', () => {
   test('should validate negative baseDelay', ({ assert }) => {
diff --git a/tests/drivers/sync_adapter.spec.ts b/tests/drivers/sync_adapter.spec.ts
diff --git a/tests/job_dispatcher.spec.ts b/tests/job_dispatcher.spec.ts
@@ -1,8 +1,8 @@
 import { setTimeout } from 'node:timers/promises'
 import { test } from '@japa/runner'
 import { memory } from './_mocks/memory_adapter.js'
-import { QueueManager } from '#src/queue_manager'
-import { JobDispatcher } from '#src/job_dispatcher'
+import { QueueManager } from '../src/queue_manager.js'
+import { JobDispatcher } from '../src/job_dispatcher.js'
 
 test.group('JobDispatcher', () => {
   test('should dispatch job correctly', async ({ assert }) => {
diff --git a/tests/job_pool.spec.ts b/tests/job_pool.spec.ts
@@ -1,7 +1,7 @@
 import { setTimeout } from 'node:timers/promises'
 import { test } from '@japa/runner'
-import { JobPool } from '#src/job_pool'
-import type { AcquiredJob } from '#contracts/adapter'
+import { JobPool } from '../src/job_pool.js'
+import type { AcquiredJob } from '../src/contracts/adapter.js'
 
 function createJob(id: string): AcquiredJob {
   return {
diff --git a/tests/locator.spec.ts b/tests/locator.spec.ts
@@ -1,7 +1,7 @@
 import { test } from '@japa/runner'
-import { Job } from '#src/job'
-import { Locator } from '#src/locator'
-import * as errors from '#src/exceptions'
+import { Job } from '../src/job.js'
+import { Locator } from '../src/locator.js'
+import * as errors from '../src/exceptions.js'
 import SendEmailJob from '../examples/jobs/send_email_job.js'
 
 class TestJob extends Job<{ message: string }> {
@@ -41,7 +41,7 @@ test.group('Locator', (group) => {
   })
 
   test('should register a job class from glob pattern', async ({ assert }) => {
-    await Locator.registerFromGlob(['./examples/jobs/*.js'])
+    await Locator.registerFromGlob(['./examples/jobs/*.ts'])
 
     assert.equal(Locator.get('SendEmailJob'), SendEmailJob)
   })
diff --git a/tests/queue_manager.spec.ts b/tests/queue_manager.spec.ts
@@ -1,8 +1,8 @@
 import { test } from '@japa/runner'
-import * as errors from '#src/exceptions'
-import { QueueManager } from '#src/queue_manager'
-import { sync } from '#drivers/sync_adapter'
-import { exponentialBackoff } from '#strategies/backoff_strategy'
+import * as errors from '../src/exceptions.js'
+import { QueueManager } from '../src/queue_manager.js'
+import { sync } from '../src/drivers/sync_adapter.js'
+import { exponentialBackoff } from '../src/strategies/backoff_strategy.js'
 
 test.group('QueueManager', () => {
   test('should validate adapter presence', async ({ assert }) => {
diff --git a/tests/utils.spec.ts b/tests/utils.spec.ts
@@ -1,6 +1,6 @@
 import { test } from '@japa/runner'
-import { parse } from '#src/utils'
-import { E_INVALID_DURATION_EXPRESSION } from '#src/exceptions'
+import { parse } from '../src/utils.js'
+import { E_INVALID_DURATION_EXPRESSION } from '../src/exceptions.js'
 
 test.group('Utils', () => {
   test('parse should return number when input is number', ({ assert, expectTypeOf }) => {
diff --git a/tests/worker.spec.ts b/tests/worker.spec.ts
@@ -1,12 +1,12 @@
 import { test } from '@japa/runner'
 import { setTimeout } from 'node:timers/promises'
-import { Worker } from '#src/worker'
+import { Worker } from '../src/worker.js'
 import { memory } from './_mocks/memory_adapter.js'
 import { ChaosAdapter } from './_mocks/chaos_adapter.js'
-import type { QueueManagerConfig } from '#types/main'
-import { Locator } from '#src/locator'
-import { Job } from '#src/job'
-import * as errors from '#src/exceptions'
+import type { QueueManagerConfig } from '../src/types/main.js'
+import { Locator } from '../src/locator.js'
+import { Job } from '../src/job.js'
+import * as errors from '../src/exceptions.js'
 
 const config = {
   default: 'memory',
diff --git a/tsconfig.json b/tsconfig.json
@@ -1,8 +1,7 @@
 {
   "extends": "@adonisjs/tsconfig/tsconfig.package.json",
   "compilerOptions": {
-    "allowImportingTsExtensions": true,
     "rootDir": "./",
     "outDir": "./build"
   }
-}
+}
diff --git a/yarn.lock b/yarn.lock

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import { Worker } from '#src/worker'`
	`1`	`+import { Worker } from '../src/worker.js'`
`2`	`2`	`import { config } from './config.js'`
`3`	`3`
`4`	`4`	`const worker = new Worker(config)`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import type { JobData } from '#types/main'`
	`1`	`+import type { JobData } from '../types/main.js'`
`2`	`2`
`3`	`3`	`export interface AcquiredJob extends JobData {`
`4`	`4`	`acquiredAt: number`