From 62c5a2b19b27c45eca9cb353e489a195f8c33c82 Mon Sep 17 00:00:00 2001 From: Ayush Date: Fri, 20 Mar 2026 03:15:40 +0530 Subject: [PATCH] chore: rename core package to @psyqueue/core for npm publishing --- benchmarks/k6/package.json | 2 +- benchmarks/k6/psyqueue-results.json | 178 ++++++++--------- benchmarks/package.json | 2 +- examples/basic/package.json | 2 +- examples/saas-multi-tenant/package.json | 2 +- examples/workflow-saga/package.json | 2 +- packages/backend-postgres/package.json | 2 +- packages/backend-postgres/src/adapter.ts | 2 +- packages/backend-postgres/src/index.ts | 2 +- .../backend-postgres/tests/adapter.test.ts | 2 +- packages/backend-redis/package.json | 2 +- packages/backend-redis/src/adapter.ts | 2 +- packages/backend-redis/src/index.ts | 2 +- packages/backend-redis/tests/adapter.test.ts | 2 +- packages/backend-sqlite/package.json | 2 +- packages/backend-sqlite/src/adapter.ts | 2 +- packages/backend-sqlite/src/index.ts | 2 +- packages/backend-sqlite/src/queries.ts | 2 +- packages/backend-sqlite/tests/adapter.test.ts | 2 +- packages/cli/package.json | 2 +- packages/core/package.json | 2 +- packages/dashboard/package.json | 2 +- packages/dashboard/src/plugin.ts | 2 +- packages/dashboard/src/server.ts | 2 +- packages/dashboard/tests/api.test.ts | 2 +- packages/plugin-audit-log/package.json | 2 +- packages/plugin-audit-log/src/index.ts | 2 +- .../plugin-audit-log/tests/audit-log.test.ts | 2 +- packages/plugin-backpressure/package.json | 2 +- packages/plugin-backpressure/src/index.ts | 2 +- .../tests/backpressure.test.ts | 2 +- packages/plugin-chaos/package.json | 2 +- packages/plugin-chaos/src/index.ts | 2 +- packages/plugin-chaos/src/scenarios.ts | 2 +- packages/plugin-chaos/tests/chaos.test.ts | 2 +- packages/plugin-circuit-breaker/package.json | 2 +- packages/plugin-circuit-breaker/src/index.ts | 2 +- .../tests/breaker.test.ts | 2 +- packages/plugin-crash-recovery/package.json | 2 +- packages/plugin-crash-recovery/src/index.ts | 2 +- .../plugin-deadline-priority/package.json | 2 +- .../plugin-deadline-priority/src/index.ts | 2 +- .../tests/deadline-priority.test.ts | 2 +- packages/plugin-exactly-once/package.json | 2 +- packages/plugin-exactly-once/src/index.ts | 4 +- .../tests/exactly-once.test.ts | 2 +- packages/plugin-grpc-workers/package.json | 2 +- packages/plugin-grpc-workers/src/index.ts | 2 +- packages/plugin-grpc-workers/src/server.ts | 2 +- .../tests/grpc-workers.test.ts | 2 +- packages/plugin-http-workers/package.json | 2 +- packages/plugin-http-workers/src/index.ts | 2 +- packages/plugin-http-workers/src/server.ts | 2 +- .../tests/http-workers.test.ts | 2 +- packages/plugin-job-fusion/package.json | 2 +- packages/plugin-job-fusion/src/batcher.ts | 2 +- packages/plugin-job-fusion/src/index.ts | 2 +- .../tests/job-fusion.test.ts | 4 +- packages/plugin-metrics/package.json | 2 +- packages/plugin-metrics/src/index.ts | 2 +- packages/plugin-metrics/tests/metrics.test.ts | 2 +- packages/plugin-offline-sync/package.json | 2 +- packages/plugin-offline-sync/src/index.ts | 2 +- .../plugin-offline-sync/src/sync-engine.ts | 2 +- .../tests/offline-sync.test.ts | 4 +- packages/plugin-otel-tracing/package.json | 2 +- packages/plugin-otel-tracing/src/index.ts | 2 +- .../tests/otel-tracing.test.ts | 2 +- packages/plugin-saga/package.json | 2 +- packages/plugin-saga/src/compensator.ts | 2 +- packages/plugin-saga/src/index.ts | 2 +- .../plugin-saga/tests/compensator.test.ts | 2 +- packages/plugin-scheduler/package.json | 2 +- packages/plugin-scheduler/src/cron.ts | 2 +- packages/plugin-scheduler/src/delayed.ts | 2 +- packages/plugin-scheduler/src/index.ts | 2 +- packages/plugin-scheduler/tests/cron.test.ts | 4 +- .../plugin-scheduler/tests/delayed.test.ts | 2 +- .../plugin-schema-versioning/package.json | 2 +- .../plugin-schema-versioning/src/index.ts | 2 +- .../plugin-schema-versioning/src/registry.ts | 2 +- .../tests/schema-versioning.test.ts | 4 +- packages/plugin-tenancy/package.json | 2 +- packages/plugin-tenancy/src/index.ts | 4 +- .../tests/fair-scheduler.test.ts | 2 +- packages/plugin-workflows/package.json | 2 +- packages/plugin-workflows/src/builder.ts | 2 +- packages/plugin-workflows/src/engine.ts | 4 +- packages/plugin-workflows/src/index.ts | 2 +- .../plugin-workflows/tests/builder.test.ts | 2 +- .../plugin-workflows/tests/engine.test.ts | 2 +- pnpm-lock.yaml | 188 +++++++++--------- 92 files changed, 284 insertions(+), 276 deletions(-) diff --git a/benchmarks/k6/package.json b/benchmarks/k6/package.json index f4598dc..5a09475 100644 --- a/benchmarks/k6/package.json +++ b/benchmarks/k6/package.json @@ -11,7 +11,7 @@ "@psyqueue/backend-redis": "workspace:*", "bullmq": "^5.0.0", "express": "^4.22.0", - "psyqueue": "workspace:*", + "@psyqueue/core": "workspace:*", "tsx": "^4.0.0" }, "devDependencies": { diff --git a/benchmarks/k6/psyqueue-results.json b/benchmarks/k6/psyqueue-results.json index 0f804bf..8aa7da1 100644 --- a/benchmarks/k6/psyqueue-results.json +++ b/benchmarks/k6/psyqueue-results.json @@ -1,6 +1,28 @@ { + "root_group": { + "name": "", + "path": "", + "id": "d41d8cd98f00b204e9800998ecf8427e", + "groups": {}, + "checks": { + "status 200": { + "name": "status 200", + "path": "::status 200", + "id": "fad9fa412b86fcb03bee97c80dcd61f1", + "passes": 0, + "fails": 1092248 + }, + "has id": { + "fails": 1092248, + "name": "has id", + "path": "::has id", + "id": "f56ba92d6920fd7482d71c788de1748b", + "passes": 0 + } + } + }, "metrics": { - "http_req_sending": { + "http_req_blocked": { "med": 0, "max": 0, "p(90)": 0, @@ -8,94 +30,97 @@ "avg": 0, "min": 0 }, - "errors": { - "passes": 1137297, - "fails": 0, - "thresholds": { - "rate<0.05": true - }, - "value": 1 - }, - "checks": { - "passes": 0, - "fails": 2274594, - "value": 0 - }, - "http_req_failed": { - "passes": 1137297, - "fails": 0, - "value": 1 + "http_req_receiving": { + "avg": 0, + "min": 0, + "med": 0, + "max": 0, + "p(90)": 0, + "p(95)": 0 }, - "iterations": { - "count": 1137297, - "rate": 18954.469851687874 + "vus_max": { + "min": 100, + "max": 100, + "value": 100 }, - "data_sent": { + "data_received": { "count": 0, "rate": 0 }, - "http_reqs": { - "count": 1137297, - "rate": 18954.469851687874 + "iterations": { + "count": 1092248, + "rate": 18203.986457502597 + }, + "vus": { + "max": 99, + "value": 1, + "min": 1 }, "http_req_waiting": { + "max": 0, "p(90)": 0, "p(95)": 0, "avg": 0, "min": 0, - "med": 0, - "max": 0 + "med": 0 }, "iteration_duration": { - "avg": 2.441084359934249, + "avg": 2.541639715980144, "min": 0, - "med": 2.1955, - "max": 42.4956, - "p(90)": 4.4314, - "p(95)": 5.0179 + "med": 2.199, + "max": 93.591, + "p(90)": 4.6231, + "p(95)": 5.6361 }, - "http_req_connecting": { - "p(95)": 0, + "errors": { + "passes": 1092248, + "fails": 0, + "thresholds": { + "rate<0.05": true + }, + "value": 1 + }, + "http_req_duration": { "avg": 0, "min": 0, "med": 0, "max": 0, - "p(90)": 0 + "p(90)": 0, + "p(95)": 0, + "thresholds": { + "p(95)<1000": false + } }, - "http_req_receiving": { + "http_req_failed": { + "passes": 1092248, + "fails": 0, + "value": 1 + }, + "enqueue_time": { + "avg": 0, + "min": 0, "med": 0, "max": 0, "p(90)": 0, - "p(95)": 0, - "avg": 0, - "min": 0 + "p(95)": 0 }, - "vus": { - "max": 99, - "value": 1, - "min": 1 - }, - "vus_max": { - "value": 100, - "min": 100, - "max": 100 + "http_reqs": { + "count": 1092248, + "rate": 18203.986457502597 }, - "data_received": { - "count": 0, - "rate": 0 + "data_sent": { + "rate": 0, + "count": 0 }, - "http_req_duration": { - "p(95)": 0, + "http_req_connecting": { "avg": 0, "min": 0, "med": 0, "max": 0, "p(90)": 0, - "thresholds": { - "p(95)<1000": false - } + "p(95)": 0 }, - "enqueue_time": { + "http_req_tls_handshaking": { "max": 0, "p(90)": 0, "p(95)": 0, @@ -103,43 +128,18 @@ "min": 0, "med": 0 }, - "http_req_blocked": { - "p(90)": 0, - "p(95)": 0, + "http_req_sending": { "avg": 0, - "min": 0, - "med": 0, - "max": 0 - }, - "http_req_tls_handshaking": { "min": 0, "med": 0, "max": 0, "p(90)": 0, - "p(95)": 0, - "avg": 0 - } - }, - "root_group": { - "checks": { - "status 200": { - "path": "::status 200", - "id": "fad9fa412b86fcb03bee97c80dcd61f1", - "passes": 0, - "fails": 1137297, - "name": "status 200" - }, - "has id": { - "name": "has id", - "path": "::has id", - "id": "f56ba92d6920fd7482d71c788de1748b", - "passes": 0, - "fails": 1137297 - } + "p(95)": 0 }, - "name": "", - "path": "", - "id": "d41d8cd98f00b204e9800998ecf8427e", - "groups": {} + "checks": { + "passes": 0, + "fails": 2184496, + "value": 0 + } } } \ No newline at end of file diff --git a/benchmarks/package.json b/benchmarks/package.json index 48600a8..49d6a30 100644 --- a/benchmarks/package.json +++ b/benchmarks/package.json @@ -26,7 +26,7 @@ "@psyqueue/plugin-workflows": "workspace:*", "express": "^4.22.0", "ioredis": "^5.4.0", - "psyqueue": "workspace:*", + "@psyqueue/core": "workspace:*", "tsx": "^4.0.0", "zod": "^3.24.0" }, diff --git a/examples/basic/package.json b/examples/basic/package.json index 7334a9f..748445b 100644 --- a/examples/basic/package.json +++ b/examples/basic/package.json @@ -7,7 +7,7 @@ "start": "npx tsx index.ts" }, "dependencies": { - "psyqueue": "workspace:*", + "@psyqueue/core": "workspace:*", "@psyqueue/backend-sqlite": "workspace:*" } } diff --git a/examples/saas-multi-tenant/package.json b/examples/saas-multi-tenant/package.json index 34f7634..f7574e8 100644 --- a/examples/saas-multi-tenant/package.json +++ b/examples/saas-multi-tenant/package.json @@ -7,7 +7,7 @@ "start": "npx tsx index.ts" }, "dependencies": { - "psyqueue": "workspace:*", + "@psyqueue/core": "workspace:*", "@psyqueue/backend-sqlite": "workspace:*", "@psyqueue/plugin-tenancy": "workspace:*" } diff --git a/examples/workflow-saga/package.json b/examples/workflow-saga/package.json index a2786f5..346e5f4 100644 --- a/examples/workflow-saga/package.json +++ b/examples/workflow-saga/package.json @@ -7,7 +7,7 @@ "start": "npx tsx index.ts" }, "dependencies": { - "psyqueue": "workspace:*", + "@psyqueue/core": "workspace:*", "@psyqueue/backend-sqlite": "workspace:*", "@psyqueue/plugin-workflows": "workspace:*", "@psyqueue/plugin-saga": "workspace:*" diff --git a/packages/backend-postgres/package.json b/packages/backend-postgres/package.json index 8c4b59c..94a8e43 100644 --- a/packages/backend-postgres/package.json +++ b/packages/backend-postgres/package.json @@ -23,6 +23,6 @@ "vitest": "^3.0.0" }, "peerDependencies": { - "psyqueue": "workspace:*" + "@psyqueue/core": "workspace:*" } } diff --git a/packages/backend-postgres/src/adapter.ts b/packages/backend-postgres/src/adapter.ts index 3f37239..52125a6 100644 --- a/packages/backend-postgres/src/adapter.ts +++ b/packages/backend-postgres/src/adapter.ts @@ -12,7 +12,7 @@ import type { AtomicOp, JobError, BackoffStrategy, -} from 'psyqueue' +} from '@psyqueue/core' export interface PostgresAdapterOpts { connectionString?: string diff --git a/packages/backend-postgres/src/index.ts b/packages/backend-postgres/src/index.ts index 23ca847..4cc8135 100644 --- a/packages/backend-postgres/src/index.ts +++ b/packages/backend-postgres/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { PostgresBackendAdapter } from './adapter.js' import type { PostgresAdapterOpts } from './adapter.js' diff --git a/packages/backend-postgres/tests/adapter.test.ts b/packages/backend-postgres/tests/adapter.test.ts index 9247248..2f6832f 100644 --- a/packages/backend-postgres/tests/adapter.test.ts +++ b/packages/backend-postgres/tests/adapter.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach, beforeAll } from 'vitest' import { Pool } from 'pg' import { PostgresBackendAdapter, serializeJobParams, deserializeJobRow } from '../src/adapter.js' -import type { Job, JobStatus } from 'psyqueue' +import type { Job, JobStatus } from '@psyqueue/core' // ─── Availability check ─────────────────────────────────────────────────────── diff --git a/packages/backend-redis/package.json b/packages/backend-redis/package.json index 6f45836..21ba280 100644 --- a/packages/backend-redis/package.json +++ b/packages/backend-redis/package.json @@ -22,6 +22,6 @@ "vitest": "^3.0.0" }, "peerDependencies": { - "psyqueue": "workspace:*" + "@psyqueue/core": "workspace:*" } } diff --git a/packages/backend-redis/src/adapter.ts b/packages/backend-redis/src/adapter.ts index fd0590c..4d1e682 100644 --- a/packages/backend-redis/src/adapter.ts +++ b/packages/backend-redis/src/adapter.ts @@ -13,7 +13,7 @@ import type { AtomicOp, JobError, BackoffStrategy, -} from 'psyqueue' +} from '@psyqueue/core' export interface RedisAdapterOpts { host?: string diff --git a/packages/backend-redis/src/index.ts b/packages/backend-redis/src/index.ts index e8b4aef..1ccee1a 100644 --- a/packages/backend-redis/src/index.ts +++ b/packages/backend-redis/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { RedisBackendAdapter } from './adapter.js' import type { RedisAdapterOpts } from './adapter.js' diff --git a/packages/backend-redis/tests/adapter.test.ts b/packages/backend-redis/tests/adapter.test.ts index 651b17d..80e6c90 100644 --- a/packages/backend-redis/tests/adapter.test.ts +++ b/packages/backend-redis/tests/adapter.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach, beforeAll } from 'vitest' import Redis from 'ioredis' import { RedisBackendAdapter, serializeJobToHash, deserializeJobFromHash, computePendingScore } from '../src/adapter.js' -import type { Job, JobStatus } from 'psyqueue' +import type { Job, JobStatus } from '@psyqueue/core' // ─── Availability check ─────────────────────────────────────────────────────── diff --git a/packages/backend-sqlite/package.json b/packages/backend-sqlite/package.json index e946799..f94c0ac 100644 --- a/packages/backend-sqlite/package.json +++ b/packages/backend-sqlite/package.json @@ -23,6 +23,6 @@ "vitest": "^3.0.0" }, "peerDependencies": { - "psyqueue": "workspace:*" + "@psyqueue/core": "workspace:*" } } diff --git a/packages/backend-sqlite/src/adapter.ts b/packages/backend-sqlite/src/adapter.ts index d9dc7c4..b325ea4 100644 --- a/packages/backend-sqlite/src/adapter.ts +++ b/packages/backend-sqlite/src/adapter.ts @@ -11,7 +11,7 @@ import type { AtomicOp, JobError, BackoffStrategy, -} from 'psyqueue' +} from '@psyqueue/core' import { SCHEMA_SQL } from './schema.js' import { INSERT_JOB, diff --git a/packages/backend-sqlite/src/index.ts b/packages/backend-sqlite/src/index.ts index 4ea93e9..09ca3e7 100644 --- a/packages/backend-sqlite/src/index.ts +++ b/packages/backend-sqlite/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { SQLiteBackendAdapter } from './adapter.js' export interface SQLiteOpts { diff --git a/packages/backend-sqlite/src/queries.ts b/packages/backend-sqlite/src/queries.ts index 92add4a..a6b8e1d 100644 --- a/packages/backend-sqlite/src/queries.ts +++ b/packages/backend-sqlite/src/queries.ts @@ -1,4 +1,4 @@ -import type { JobFilter } from 'psyqueue' +import type { JobFilter } from '@psyqueue/core' export const INSERT_JOB = ` INSERT INTO jobs ( diff --git a/packages/backend-sqlite/tests/adapter.test.ts b/packages/backend-sqlite/tests/adapter.test.ts index 191a4c2..198fcc3 100644 --- a/packages/backend-sqlite/tests/adapter.test.ts +++ b/packages/backend-sqlite/tests/adapter.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { SQLiteBackendAdapter } from '../src/adapter.js' -import type { Job, DequeuedJob, JobStatus } from 'psyqueue' +import type { Job, DequeuedJob, JobStatus } from '@psyqueue/core' function makeJob(overrides: Partial = {}): Job { const id = `job_${Math.random().toString(36).slice(2, 10)}` diff --git a/packages/cli/package.json b/packages/cli/package.json index 2c310a4..e183c58 100644 --- a/packages/cli/package.json +++ b/packages/cli/package.json @@ -25,6 +25,6 @@ "vitest": "^3.0.0" }, "peerDependencies": { - "psyqueue": "workspace:*" + "@psyqueue/core": "workspace:*" } } diff --git a/packages/core/package.json b/packages/core/package.json index 457c869..53df04b 100644 --- a/packages/core/package.json +++ b/packages/core/package.json @@ -1,5 +1,5 @@ { - "name": "psyqueue", + "name": "@psyqueue/core", "version": "0.1.0", "type": "module", "description": "Micro-kernel distributed job queue platform", diff --git a/packages/dashboard/package.json b/packages/dashboard/package.json index cb7a002..45842cc 100644 --- a/packages/dashboard/package.json +++ b/packages/dashboard/package.json @@ -32,6 +32,6 @@ "vitest": "^3.0.0" }, "peerDependencies": { - "psyqueue": "workspace:*" + "@psyqueue/core": "workspace:*" } } diff --git a/packages/dashboard/src/plugin.ts b/packages/dashboard/src/plugin.ts index 5318d93..7fefbfa 100644 --- a/packages/dashboard/src/plugin.ts +++ b/packages/dashboard/src/plugin.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, BackendAdapter } from 'psyqueue' +import type { PsyPlugin, Kernel, BackendAdapter } from '@psyqueue/core' import { createDashboardServer } from './server.js' export interface DashboardOpts { diff --git a/packages/dashboard/src/server.ts b/packages/dashboard/src/server.ts index 445b395..8861c28 100644 --- a/packages/dashboard/src/server.ts +++ b/packages/dashboard/src/server.ts @@ -2,7 +2,7 @@ import express, { type Request, type Response, type NextFunction } from 'express import path from 'node:path' import { fileURLToPath } from 'node:url' import fs from 'node:fs' -import type { BackendAdapter, JobFilter, JobStatus } from 'psyqueue' +import type { BackendAdapter, JobFilter, JobStatus } from '@psyqueue/core' import type http from 'node:http' export interface DashboardServerOpts { diff --git a/packages/dashboard/tests/api.test.ts b/packages/dashboard/tests/api.test.ts index 393573f..527d764 100644 --- a/packages/dashboard/tests/api.test.ts +++ b/packages/dashboard/tests/api.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, beforeAll, afterAll } from 'vitest' import type http from 'node:http' -import type { BackendAdapter, Job, PaginatedResult, JobFilter, DequeuedJob, AckResult, NackOpts, AtomicOp } from 'psyqueue' +import type { BackendAdapter, Job, PaginatedResult, JobFilter, DequeuedJob, AckResult, NackOpts, AtomicOp } from '@psyqueue/core' import { createDashboardServer } from '../src/server.js' // In-memory mock backend diff --git a/packages/plugin-audit-log/package.json b/packages/plugin-audit-log/package.json index 3b5519a..2b59eb7 100644 --- a/packages/plugin-audit-log/package.json +++ b/packages/plugin-audit-log/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-audit-log/src/index.ts b/packages/plugin-audit-log/src/index.ts index ae36522..a7aec08 100644 --- a/packages/plugin-audit-log/src/index.ts +++ b/packages/plugin-audit-log/src/index.ts @@ -1,7 +1,7 @@ import { randomUUID } from 'node:crypto' import { appendFileSync, mkdirSync, existsSync } from 'node:fs' import { dirname } from 'node:path' -import type { PsyPlugin, Kernel, LifecycleEvent } from 'psyqueue' +import type { PsyPlugin, Kernel, LifecycleEvent } from '@psyqueue/core' import type { AuditEntry, AuditFilter } from './types.js' import { computeHash, verifyChain } from './hash-chain.js' diff --git a/packages/plugin-audit-log/tests/audit-log.test.ts b/packages/plugin-audit-log/tests/audit-log.test.ts index 8522360..8c94a15 100644 --- a/packages/plugin-audit-log/tests/audit-log.test.ts +++ b/packages/plugin-audit-log/tests/audit-log.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { auditLog } from '../src/index.js' import { verifyChain } from '../src/hash-chain.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' function makeQueue(pluginOpts: Parameters[0]): { diff --git a/packages/plugin-backpressure/package.json b/packages/plugin-backpressure/package.json index 212f3ea..785d70e 100644 --- a/packages/plugin-backpressure/package.json +++ b/packages/plugin-backpressure/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-backpressure/src/index.ts b/packages/plugin-backpressure/src/index.ts index 952b85a..3df3ad9 100644 --- a/packages/plugin-backpressure/src/index.ts +++ b/packages/plugin-backpressure/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { SignalMonitor } from './signals.js' import { resolveActions } from './actions.js' import type { PressureState } from './signals.js' diff --git a/packages/plugin-backpressure/tests/backpressure.test.ts b/packages/plugin-backpressure/tests/backpressure.test.ts index fe9df8b..0377a20 100644 --- a/packages/plugin-backpressure/tests/backpressure.test.ts +++ b/packages/plugin-backpressure/tests/backpressure.test.ts @@ -2,7 +2,7 @@ import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest' import { SignalMonitor } from '../src/signals.js' import { resolveActions } from '../src/actions.js' import { backpressure } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' // ============================================================================ diff --git a/packages/plugin-chaos/package.json b/packages/plugin-chaos/package.json index 39d0cba..f062dc1 100644 --- a/packages/plugin-chaos/package.json +++ b/packages/plugin-chaos/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-chaos/src/index.ts b/packages/plugin-chaos/src/index.ts index e33c1fb..6d7d16f 100644 --- a/packages/plugin-chaos/src/index.ts +++ b/packages/plugin-chaos/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, Middleware } from 'psyqueue' +import type { PsyPlugin, Kernel, Middleware } from '@psyqueue/core' import { slowProcess, workerCrash, diff --git a/packages/plugin-chaos/src/scenarios.ts b/packages/plugin-chaos/src/scenarios.ts index a5a4c1e..b5df7fe 100644 --- a/packages/plugin-chaos/src/scenarios.ts +++ b/packages/plugin-chaos/src/scenarios.ts @@ -1,4 +1,4 @@ -import type { Middleware } from 'psyqueue' +import type { Middleware } from '@psyqueue/core' export interface ChaosScenarioConfig { probability: number diff --git a/packages/plugin-chaos/tests/chaos.test.ts b/packages/plugin-chaos/tests/chaos.test.ts index e78e007..4a9b029 100644 --- a/packages/plugin-chaos/tests/chaos.test.ts +++ b/packages/plugin-chaos/tests/chaos.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { chaosMode } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' describe('Chaos Plugin', () => { diff --git a/packages/plugin-circuit-breaker/package.json b/packages/plugin-circuit-breaker/package.json index 8ca1e72..fff7007 100644 --- a/packages/plugin-circuit-breaker/package.json +++ b/packages/plugin-circuit-breaker/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-circuit-breaker/src/index.ts b/packages/plugin-circuit-breaker/src/index.ts index 2176079..c15507b 100644 --- a/packages/plugin-circuit-breaker/src/index.ts +++ b/packages/plugin-circuit-breaker/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { Breaker } from './breaker.js' import type { BreakerConfig } from './breaker.js' diff --git a/packages/plugin-circuit-breaker/tests/breaker.test.ts b/packages/plugin-circuit-breaker/tests/breaker.test.ts index 24588e6..f5e41a2 100644 --- a/packages/plugin-circuit-breaker/tests/breaker.test.ts +++ b/packages/plugin-circuit-breaker/tests/breaker.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { Breaker } from '../src/breaker.js' import { circuitBreaker } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' // ============================================================================ diff --git a/packages/plugin-crash-recovery/package.json b/packages/plugin-crash-recovery/package.json index 258913f..3c46361 100644 --- a/packages/plugin-crash-recovery/package.json +++ b/packages/plugin-crash-recovery/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-crash-recovery/src/index.ts b/packages/plugin-crash-recovery/src/index.ts index 855c5df..e171e6f 100644 --- a/packages/plugin-crash-recovery/src/index.ts +++ b/packages/plugin-crash-recovery/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { WriteAheadLog } from './wal.js' import { recoverFromWal, type RecoveryBackend } from './recovery.js' diff --git a/packages/plugin-deadline-priority/package.json b/packages/plugin-deadline-priority/package.json index bd65e0b..505d5ab 100644 --- a/packages/plugin-deadline-priority/package.json +++ b/packages/plugin-deadline-priority/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-deadline-priority/src/index.ts b/packages/plugin-deadline-priority/src/index.ts index d27bcaf..9939370 100644 --- a/packages/plugin-deadline-priority/src/index.ts +++ b/packages/plugin-deadline-priority/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, Job } from 'psyqueue' +import type { PsyPlugin, Kernel, Job } from '@psyqueue/core' import { linearCurve, exponentialCurve, stepCurve } from './curves.js' export { linearCurve, exponentialCurve, stepCurve } from './curves.js' diff --git a/packages/plugin-deadline-priority/tests/deadline-priority.test.ts b/packages/plugin-deadline-priority/tests/deadline-priority.test.ts index e2a8a6f..063407e 100644 --- a/packages/plugin-deadline-priority/tests/deadline-priority.test.ts +++ b/packages/plugin-deadline-priority/tests/deadline-priority.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest' import { linearCurve, exponentialCurve, stepCurve } from '../src/curves.js' import { deadlinePriority } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' // ============================================================================ diff --git a/packages/plugin-exactly-once/package.json b/packages/plugin-exactly-once/package.json index 0126f65..b6182d3 100644 --- a/packages/plugin-exactly-once/package.json +++ b/packages/plugin-exactly-once/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-exactly-once/src/index.ts b/packages/plugin-exactly-once/src/index.ts index 1cff468..5560f90 100644 --- a/packages/plugin-exactly-once/src/index.ts +++ b/packages/plugin-exactly-once/src/index.ts @@ -1,5 +1,5 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' -import { DuplicateJobError } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' +import { DuplicateJobError } from '@psyqueue/core' import { DedupStore } from './dedup.js' export type { DedupStore } diff --git a/packages/plugin-exactly-once/tests/exactly-once.test.ts b/packages/plugin-exactly-once/tests/exactly-once.test.ts index 2356a84..19e9109 100644 --- a/packages/plugin-exactly-once/tests/exactly-once.test.ts +++ b/packages/plugin-exactly-once/tests/exactly-once.test.ts @@ -1,5 +1,5 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { exactlyOnce, parseWindow } from '../src/index.js' diff --git a/packages/plugin-grpc-workers/package.json b/packages/plugin-grpc-workers/package.json index f23b28b..17127de 100644 --- a/packages/plugin-grpc-workers/package.json +++ b/packages/plugin-grpc-workers/package.json @@ -13,5 +13,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-grpc-workers/src/index.ts b/packages/plugin-grpc-workers/src/index.ts index f0e958a..7a851d2 100644 --- a/packages/plugin-grpc-workers/src/index.ts +++ b/packages/plugin-grpc-workers/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { GrpcWorkerServer } from './server.js' export { GrpcWorkerServer } from './server.js' diff --git a/packages/plugin-grpc-workers/src/server.ts b/packages/plugin-grpc-workers/src/server.ts index 00b3485..1b56305 100644 --- a/packages/plugin-grpc-workers/src/server.ts +++ b/packages/plugin-grpc-workers/src/server.ts @@ -3,7 +3,7 @@ import * as protoLoader from '@grpc/proto-loader' import * as fs from 'node:fs' import * as os from 'node:os' import * as path from 'node:path' -import type { BackendAdapter, DequeuedJob } from 'psyqueue' +import type { BackendAdapter, DequeuedJob } from '@psyqueue/core' export interface GrpcServerOpts { port: number diff --git a/packages/plugin-grpc-workers/tests/grpc-workers.test.ts b/packages/plugin-grpc-workers/tests/grpc-workers.test.ts index 8a391cd..d7d7af9 100644 --- a/packages/plugin-grpc-workers/tests/grpc-workers.test.ts +++ b/packages/plugin-grpc-workers/tests/grpc-workers.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { grpcWorkers } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import * as grpc from '@grpc/grpc-js' import * as protoLoader from '@grpc/proto-loader' diff --git a/packages/plugin-http-workers/package.json b/packages/plugin-http-workers/package.json index 1d69f59..33d8cac 100644 --- a/packages/plugin-http-workers/package.json +++ b/packages/plugin-http-workers/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-http-workers/src/index.ts b/packages/plugin-http-workers/src/index.ts index 18096d1..0236862 100644 --- a/packages/plugin-http-workers/src/index.ts +++ b/packages/plugin-http-workers/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { HttpWorkerServer } from './server.js' export { HttpWorkerServer } from './server.js' diff --git a/packages/plugin-http-workers/src/server.ts b/packages/plugin-http-workers/src/server.ts index c1eb619..bca161c 100644 --- a/packages/plugin-http-workers/src/server.ts +++ b/packages/plugin-http-workers/src/server.ts @@ -1,5 +1,5 @@ import * as http from 'node:http' -import type { BackendAdapter, DequeuedJob } from 'psyqueue' +import type { BackendAdapter, DequeuedJob } from '@psyqueue/core' export interface HttpServerOpts { port: number diff --git a/packages/plugin-http-workers/tests/http-workers.test.ts b/packages/plugin-http-workers/tests/http-workers.test.ts index fadd9e2..bd01c05 100644 --- a/packages/plugin-http-workers/tests/http-workers.test.ts +++ b/packages/plugin-http-workers/tests/http-workers.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { httpWorkers } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' describe('HTTP Workers Plugin', () => { diff --git a/packages/plugin-job-fusion/package.json b/packages/plugin-job-fusion/package.json index 8eefed6..534550c 100644 --- a/packages/plugin-job-fusion/package.json +++ b/packages/plugin-job-fusion/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-job-fusion/src/batcher.ts b/packages/plugin-job-fusion/src/batcher.ts index a017bd5..ae0d461 100644 --- a/packages/plugin-job-fusion/src/batcher.ts +++ b/packages/plugin-job-fusion/src/batcher.ts @@ -1,4 +1,4 @@ -import type { Job } from 'psyqueue' +import type { Job } from '@psyqueue/core' export interface FusionRule { match: string diff --git a/packages/plugin-job-fusion/src/index.ts b/packages/plugin-job-fusion/src/index.ts index 88d0476..737b274 100644 --- a/packages/plugin-job-fusion/src/index.ts +++ b/packages/plugin-job-fusion/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, Job } from 'psyqueue' +import type { PsyPlugin, Kernel, Job } from '@psyqueue/core' import { BatchCollector } from './batcher.js' import type { FusionRule } from './batcher.js' diff --git a/packages/plugin-job-fusion/tests/job-fusion.test.ts b/packages/plugin-job-fusion/tests/job-fusion.test.ts index 455fda9..ac17f5e 100644 --- a/packages/plugin-job-fusion/tests/job-fusion.test.ts +++ b/packages/plugin-job-fusion/tests/job-fusion.test.ts @@ -1,9 +1,9 @@ import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest' import { BatchCollector } from '../src/batcher.js' import { jobFusion } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' -import type { Job } from 'psyqueue' +import type { Job } from '@psyqueue/core' // ============================================================================ // Helper: create a minimal mock job diff --git a/packages/plugin-metrics/package.json b/packages/plugin-metrics/package.json index 8526faa..41b3454 100644 --- a/packages/plugin-metrics/package.json +++ b/packages/plugin-metrics/package.json @@ -12,5 +12,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-metrics/src/index.ts b/packages/plugin-metrics/src/index.ts index 0d7c553..bd270c4 100644 --- a/packages/plugin-metrics/src/index.ts +++ b/packages/plugin-metrics/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { Registry, Counter, diff --git a/packages/plugin-metrics/tests/metrics.test.ts b/packages/plugin-metrics/tests/metrics.test.ts index 902860d..f83248e 100644 --- a/packages/plugin-metrics/tests/metrics.test.ts +++ b/packages/plugin-metrics/tests/metrics.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { Registry } from 'prom-client' import { metrics } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' function makeQueue(registry: Registry): PsyQueue { diff --git a/packages/plugin-offline-sync/package.json b/packages/plugin-offline-sync/package.json index 6425451..ed5e808 100644 --- a/packages/plugin-offline-sync/package.json +++ b/packages/plugin-offline-sync/package.json @@ -13,5 +13,5 @@ "@types/better-sqlite3": "^7.6.12", "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-offline-sync/src/index.ts b/packages/plugin-offline-sync/src/index.ts index 72be581..c78825f 100644 --- a/packages/plugin-offline-sync/src/index.ts +++ b/packages/plugin-offline-sync/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' import { SyncEngine } from './sync-engine.js' export { SyncEngine } from './sync-engine.js' diff --git a/packages/plugin-offline-sync/src/sync-engine.ts b/packages/plugin-offline-sync/src/sync-engine.ts index 2423185..86e3c43 100644 --- a/packages/plugin-offline-sync/src/sync-engine.ts +++ b/packages/plugin-offline-sync/src/sync-engine.ts @@ -1,5 +1,5 @@ import Database from 'better-sqlite3' -import type { BackendAdapter, Job } from 'psyqueue' +import type { BackendAdapter, Job } from '@psyqueue/core' export interface SyncEngineOpts { localPath: string diff --git a/packages/plugin-offline-sync/tests/offline-sync.test.ts b/packages/plugin-offline-sync/tests/offline-sync.test.ts index fadb197..e36ec51 100644 --- a/packages/plugin-offline-sync/tests/offline-sync.test.ts +++ b/packages/plugin-offline-sync/tests/offline-sync.test.ts @@ -1,9 +1,9 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { SyncEngine } from '../src/sync-engine.js' import { offlineSync } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' -import type { Job, BackendAdapter } from 'psyqueue' +import type { Job, BackendAdapter } from '@psyqueue/core' import * as fs from 'node:fs' import * as path from 'node:path' import * as os from 'node:os' diff --git a/packages/plugin-otel-tracing/package.json b/packages/plugin-otel-tracing/package.json index f03ee66..e66a65e 100644 --- a/packages/plugin-otel-tracing/package.json +++ b/packages/plugin-otel-tracing/package.json @@ -14,5 +14,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-otel-tracing/src/index.ts b/packages/plugin-otel-tracing/src/index.ts index ebdf442..cb3cc96 100644 --- a/packages/plugin-otel-tracing/src/index.ts +++ b/packages/plugin-otel-tracing/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, Job } from 'psyqueue' +import type { PsyPlugin, Kernel, Job } from '@psyqueue/core' import { trace, SpanStatusCode, diff --git a/packages/plugin-otel-tracing/tests/otel-tracing.test.ts b/packages/plugin-otel-tracing/tests/otel-tracing.test.ts index 3f70df9..a44b4cb 100644 --- a/packages/plugin-otel-tracing/tests/otel-tracing.test.ts +++ b/packages/plugin-otel-tracing/tests/otel-tracing.test.ts @@ -1,7 +1,7 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' import { InMemorySpanExporter } from '@opentelemetry/sdk-trace-base' import { otelTracing } from '../src/index.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' function makeQueue( diff --git a/packages/plugin-saga/package.json b/packages/plugin-saga/package.json index b41f4cf..8bca989 100644 --- a/packages/plugin-saga/package.json +++ b/packages/plugin-saga/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*", "@psyqueue/plugin-workflows": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*", "@psyqueue/plugin-workflows": "workspace:*" } } diff --git a/packages/plugin-saga/src/compensator.ts b/packages/plugin-saga/src/compensator.ts index c9bcb1d..c6a2c34 100644 --- a/packages/plugin-saga/src/compensator.ts +++ b/packages/plugin-saga/src/compensator.ts @@ -1,4 +1,4 @@ -import type { EventBusInterface } from 'psyqueue' +import type { EventBusInterface } from '@psyqueue/core' import type { WorkflowInstance } from '@psyqueue/plugin-workflows' import type { WorkflowDefinition } from '@psyqueue/plugin-workflows' diff --git a/packages/plugin-saga/src/index.ts b/packages/plugin-saga/src/index.ts index 3ffd962..89c460f 100644 --- a/packages/plugin-saga/src/index.ts +++ b/packages/plugin-saga/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, PsyEvent } from 'psyqueue' +import type { PsyPlugin, Kernel, PsyEvent } from '@psyqueue/core' import type { WorkflowEngine } from '@psyqueue/plugin-workflows' import { Compensator } from './compensator.js' diff --git a/packages/plugin-saga/tests/compensator.test.ts b/packages/plugin-saga/tests/compensator.test.ts index 1a8925c..f4443e8 100644 --- a/packages/plugin-saga/tests/compensator.test.ts +++ b/packages/plugin-saga/tests/compensator.test.ts @@ -1,5 +1,5 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { workflows, workflow } from '../../plugin-workflows/src/index.js' import type { WorkflowEngine } from '../../plugin-workflows/src/index.js' diff --git a/packages/plugin-scheduler/package.json b/packages/plugin-scheduler/package.json index d497b6c..0ab164f 100644 --- a/packages/plugin-scheduler/package.json +++ b/packages/plugin-scheduler/package.json @@ -10,5 +10,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-scheduler/src/cron.ts b/packages/plugin-scheduler/src/cron.ts index ff06c3d..a9c117a 100644 --- a/packages/plugin-scheduler/src/cron.ts +++ b/packages/plugin-scheduler/src/cron.ts @@ -1,4 +1,4 @@ -import type { BackendAdapter, Job } from 'psyqueue' +import type { BackendAdapter, Job } from '@psyqueue/core' // cron-parser v4 uses CommonJS default export import cronParser from 'cron-parser' diff --git a/packages/plugin-scheduler/src/delayed.ts b/packages/plugin-scheduler/src/delayed.ts index 02544a5..cf3e6fc 100644 --- a/packages/plugin-scheduler/src/delayed.ts +++ b/packages/plugin-scheduler/src/delayed.ts @@ -1,4 +1,4 @@ -import type { BackendAdapter, Job } from 'psyqueue' +import type { BackendAdapter, Job } from '@psyqueue/core' export interface DelayedJobPollerOpts { /** ms between polling for due scheduled jobs (default: 1000) */ diff --git a/packages/plugin-scheduler/src/index.ts b/packages/plugin-scheduler/src/index.ts index a65b979..f5bb231 100644 --- a/packages/plugin-scheduler/src/index.ts +++ b/packages/plugin-scheduler/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, Job } from 'psyqueue' +import type { PsyPlugin, Kernel, Job } from '@psyqueue/core' import { DelayedJobPoller } from './delayed.js' import { CronManager } from './cron.js' diff --git a/packages/plugin-scheduler/tests/cron.test.ts b/packages/plugin-scheduler/tests/cron.test.ts index 5c29c4c..e5ade3b 100644 --- a/packages/plugin-scheduler/tests/cron.test.ts +++ b/packages/plugin-scheduler/tests/cron.test.ts @@ -1,8 +1,8 @@ import { describe, it, expect, beforeEach, afterEach } from 'vitest' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { scheduler, computeNextRunAt } from '../src/index.js' -import type { BackendAdapter } from 'psyqueue' +import type { BackendAdapter } from '@psyqueue/core' // ------------------------------------------------------------------ // // Unit tests for computeNextRunAt (no I/O) // diff --git a/packages/plugin-scheduler/tests/delayed.test.ts b/packages/plugin-scheduler/tests/delayed.test.ts index eb39462..76031f1 100644 --- a/packages/plugin-scheduler/tests/delayed.test.ts +++ b/packages/plugin-scheduler/tests/delayed.test.ts @@ -1,5 +1,5 @@ import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { scheduler } from '../src/index.js' diff --git a/packages/plugin-schema-versioning/package.json b/packages/plugin-schema-versioning/package.json index fd9f224..5f99a6a 100644 --- a/packages/plugin-schema-versioning/package.json +++ b/packages/plugin-schema-versioning/package.json @@ -8,5 +8,5 @@ "scripts": { "build": "tsc", "test": "vitest run", "clean": "rm -rf dist" }, "dependencies": { "zod": "^3.24.0" }, "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-schema-versioning/src/index.ts b/packages/plugin-schema-versioning/src/index.ts index 6ba10bf..d1214c1 100644 --- a/packages/plugin-schema-versioning/src/index.ts +++ b/packages/plugin-schema-versioning/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, JobHandler, JobContext } from 'psyqueue' +import type { PsyPlugin, Kernel, JobHandler, JobContext } from '@psyqueue/core' import { VersionRegistry } from './registry.js' import { validatePayload } from './validator.js' import type { VersionedHandlerConfig, VersionConfig } from './registry.js' diff --git a/packages/plugin-schema-versioning/src/registry.ts b/packages/plugin-schema-versioning/src/registry.ts index 757d6c2..50244d8 100644 --- a/packages/plugin-schema-versioning/src/registry.ts +++ b/packages/plugin-schema-versioning/src/registry.ts @@ -1,5 +1,5 @@ import type { z } from 'zod' -import type { JobHandler } from 'psyqueue' +import type { JobHandler } from '@psyqueue/core' export interface VersionConfig { schema: z.ZodSchema diff --git a/packages/plugin-schema-versioning/tests/schema-versioning.test.ts b/packages/plugin-schema-versioning/tests/schema-versioning.test.ts index 7beefb2..de37416 100644 --- a/packages/plugin-schema-versioning/tests/schema-versioning.test.ts +++ b/packages/plugin-schema-versioning/tests/schema-versioning.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest' -import { PsyQueue, createJob } from 'psyqueue' -import type { JobContext } from 'psyqueue' +import { PsyQueue, createJob } from '@psyqueue/core' +import type { JobContext } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { schemaVersioning } from '../src/index.js' import { z } from 'zod' diff --git a/packages/plugin-tenancy/package.json b/packages/plugin-tenancy/package.json index f850029..36ae379 100644 --- a/packages/plugin-tenancy/package.json +++ b/packages/plugin-tenancy/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-tenancy/src/index.ts b/packages/plugin-tenancy/src/index.ts index ab70065..487fc46 100644 --- a/packages/plugin-tenancy/src/index.ts +++ b/packages/plugin-tenancy/src/index.ts @@ -1,5 +1,5 @@ -import type { PsyPlugin, Kernel } from 'psyqueue' -import { RateLimitError } from 'psyqueue' +import type { PsyPlugin, Kernel } from '@psyqueue/core' +import { RateLimitError } from '@psyqueue/core' import { TierManager, type TierConfig } from './tiers.js' import { SlidingWindowRateLimiter } from './rate-limiter.js' import { FairScheduler, type SchedulingMode } from './fair-scheduler.js' diff --git a/packages/plugin-tenancy/tests/fair-scheduler.test.ts b/packages/plugin-tenancy/tests/fair-scheduler.test.ts index 2ea5e6f..568bea1 100644 --- a/packages/plugin-tenancy/tests/fair-scheduler.test.ts +++ b/packages/plugin-tenancy/tests/fair-scheduler.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect } from 'vitest' import { FairScheduler } from '../src/fair-scheduler.js' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { tenancy } from '../src/index.js' diff --git a/packages/plugin-workflows/package.json b/packages/plugin-workflows/package.json index f6369db..fedd158 100644 --- a/packages/plugin-workflows/package.json +++ b/packages/plugin-workflows/package.json @@ -9,5 +9,5 @@ "devDependencies": { "vitest": "^3.0.0" }, - "peerDependencies": { "psyqueue": "workspace:*" } + "peerDependencies": { "@psyqueue/core": "workspace:*" } } diff --git a/packages/plugin-workflows/src/builder.ts b/packages/plugin-workflows/src/builder.ts index 8ee0a68..50869e9 100644 --- a/packages/plugin-workflows/src/builder.ts +++ b/packages/plugin-workflows/src/builder.ts @@ -1,4 +1,4 @@ -import type { JobHandler } from 'psyqueue' +import type { JobHandler } from '@psyqueue/core' // ─── Types ──────────────────────────────────────────────────────────────────── diff --git a/packages/plugin-workflows/src/engine.ts b/packages/plugin-workflows/src/engine.ts index 5764b24..4934a82 100644 --- a/packages/plugin-workflows/src/engine.ts +++ b/packages/plugin-workflows/src/engine.ts @@ -1,5 +1,5 @@ -import type { Kernel, BackendAdapter, Job, JobHandler, JobContext } from 'psyqueue' -import { generateId, createJob } from 'psyqueue' +import type { Kernel, BackendAdapter, Job, JobHandler, JobContext } from '@psyqueue/core' +import { generateId, createJob } from '@psyqueue/core' import type { WorkflowDefinition, StepDefinition } from './builder.js' import { WorkflowStore } from './state.js' import type { WorkflowInstance, StepState } from './state.js' diff --git a/packages/plugin-workflows/src/index.ts b/packages/plugin-workflows/src/index.ts index eff754f..7feaf82 100644 --- a/packages/plugin-workflows/src/index.ts +++ b/packages/plugin-workflows/src/index.ts @@ -1,4 +1,4 @@ -import type { PsyPlugin, Kernel, PsyEvent } from 'psyqueue' +import type { PsyPlugin, Kernel, PsyEvent } from '@psyqueue/core' import { WorkflowEngine } from './engine.js' export { workflow, WorkflowBuilder } from './builder.js' diff --git a/packages/plugin-workflows/tests/builder.test.ts b/packages/plugin-workflows/tests/builder.test.ts index c7ca1d5..0290296 100644 --- a/packages/plugin-workflows/tests/builder.test.ts +++ b/packages/plugin-workflows/tests/builder.test.ts @@ -1,6 +1,6 @@ import { describe, it, expect, vi } from 'vitest' import { workflow } from '../src/builder.js' -import type { JobContext } from 'psyqueue' +import type { JobContext } from '@psyqueue/core' const h = async (_ctx: JobContext) => 'ok' diff --git a/packages/plugin-workflows/tests/engine.test.ts b/packages/plugin-workflows/tests/engine.test.ts index 33d05d4..3483f51 100644 --- a/packages/plugin-workflows/tests/engine.test.ts +++ b/packages/plugin-workflows/tests/engine.test.ts @@ -1,5 +1,5 @@ import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest' -import { PsyQueue } from 'psyqueue' +import { PsyQueue } from '@psyqueue/core' import { sqlite } from '../../backend-sqlite/src/index.js' import { workflows, workflow } from '../src/index.js' import type { WorkflowDefinition } from '../src/builder.js' diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index e88bff9..7090aed 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -35,7 +35,7 @@ importers: version: 3.8.1 turbo: specifier: ^2.4.0 - version: 2.8.19 + version: 2.8.20 typescript: specifier: ^5.7.0 version: 5.9.3 @@ -51,6 +51,9 @@ importers: '@psyqueue/backend-sqlite': specifier: workspace:* version: link:../packages/backend-sqlite + '@psyqueue/core': + specifier: workspace:* + version: link:../packages/core '@psyqueue/dashboard': specifier: workspace:* version: link:../packages/dashboard @@ -92,10 +95,7 @@ importers: version: 4.22.1 ioredis: specifier: ^5.4.0 - version: 5.10.0 - psyqueue: - specifier: workspace:* - version: link:../packages/core + version: 5.10.1 tsx: specifier: ^4.0.0 version: 4.21.0 @@ -119,15 +119,15 @@ importers: '@psyqueue/backend-redis': specifier: workspace:* version: link:../../packages/backend-redis + '@psyqueue/core': + specifier: workspace:* + version: link:../../packages/core bullmq: specifier: ^5.0.0 version: 5.71.0 express: specifier: ^4.22.0 version: 4.22.1 - psyqueue: - specifier: workspace:* - version: link:../../packages/core tsx: specifier: ^4.0.0 version: 4.21.0 @@ -141,7 +141,7 @@ importers: '@psyqueue/backend-sqlite': specifier: workspace:* version: link:../../packages/backend-sqlite - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../../packages/core @@ -150,36 +150,36 @@ importers: '@psyqueue/backend-sqlite': specifier: workspace:* version: link:../../packages/backend-sqlite + '@psyqueue/core': + specifier: workspace:* + version: link:../../packages/core '@psyqueue/plugin-tenancy': specifier: workspace:* version: link:../../packages/plugin-tenancy - psyqueue: - specifier: workspace:* - version: link:../../packages/core examples/workflow-saga: dependencies: '@psyqueue/backend-sqlite': specifier: workspace:* version: link:../../packages/backend-sqlite + '@psyqueue/core': + specifier: workspace:* + version: link:../../packages/core '@psyqueue/plugin-saga': specifier: workspace:* version: link:../../packages/plugin-saga '@psyqueue/plugin-workflows': specifier: workspace:* version: link:../../packages/plugin-workflows - psyqueue: - specifier: workspace:* - version: link:../../packages/core packages/backend-postgres: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core pg: specifier: ^8.13.0 version: 8.20.0 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: '@types/pg': specifier: ^8.11.0 @@ -190,12 +190,12 @@ importers: packages/backend-redis: dependencies: - ioredis: - specifier: ^5.4.0 - version: 5.10.0 - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core + ioredis: + specifier: ^5.4.0 + version: 5.10.1 devDependencies: vitest: specifier: ^3.0.0 @@ -203,12 +203,12 @@ importers: packages/backend-sqlite: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core better-sqlite3: specifier: ^11.0.0 version: 11.10.0 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: '@types/better-sqlite3': specifier: ^7.6.0 @@ -219,12 +219,12 @@ importers: packages/cli: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core commander: specifier: ^12.1.0 version: 12.1.0 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: vitest: specifier: ^3.0.0 @@ -241,16 +241,16 @@ importers: version: 25.5.0 ioredis: specifier: ^5.4.0 - version: 5.10.0 + version: 5.10.1 packages/dashboard: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core express: specifier: ^4.21.0 version: 4.22.1 - psyqueue: - specifier: workspace:* - version: link:../core react: specifier: ^19.2.4 version: 19.2.4 @@ -282,7 +282,7 @@ importers: packages/plugin-audit-log: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -292,7 +292,7 @@ importers: packages/plugin-backpressure: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -302,7 +302,7 @@ importers: packages/plugin-chaos: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -312,7 +312,7 @@ importers: packages/plugin-circuit-breaker: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -322,7 +322,7 @@ importers: packages/plugin-crash-recovery: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -332,7 +332,7 @@ importers: packages/plugin-deadline-priority: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -342,7 +342,7 @@ importers: packages/plugin-exactly-once: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -358,7 +358,7 @@ importers: '@grpc/proto-loader': specifier: ^0.7.13 version: 0.7.15 - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -368,7 +368,7 @@ importers: packages/plugin-http-workers: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -378,7 +378,7 @@ importers: packages/plugin-job-fusion: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -388,12 +388,12 @@ importers: packages/plugin-metrics: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core prom-client: specifier: ^15.1.3 version: 15.1.3 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: vitest: specifier: ^3.0.0 @@ -401,12 +401,12 @@ importers: packages/plugin-offline-sync: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core better-sqlite3: specifier: ^11.0.0 version: 11.10.0 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: '@types/better-sqlite3': specifier: ^7.6.12 @@ -426,7 +426,7 @@ importers: '@opentelemetry/sdk-trace-node': specifier: ^1.30.0 version: 1.30.1(@opentelemetry/api@1.9.0) - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -436,12 +436,12 @@ importers: packages/plugin-saga: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core '@psyqueue/plugin-workflows': specifier: workspace:* version: link:../plugin-workflows - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: vitest: specifier: ^3.0.0 @@ -449,12 +449,12 @@ importers: packages/plugin-scheduler: dependencies: + '@psyqueue/core': + specifier: workspace:* + version: link:../core cron-parser: specifier: ^4.9.0 version: 4.9.0 - psyqueue: - specifier: workspace:* - version: link:../core devDependencies: vitest: specifier: ^3.0.0 @@ -462,7 +462,7 @@ importers: packages/plugin-schema-versioning: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core zod: @@ -475,7 +475,7 @@ importers: packages/plugin-tenancy: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -485,7 +485,7 @@ importers: packages/plugin-workflows: dependencies: - psyqueue: + '@psyqueue/core': specifier: workspace:* version: link:../core devDependencies: @@ -1129,33 +1129,33 @@ packages: cpu: [x64] os: [win32] - '@turbo/darwin-64@2.8.19': - resolution: {integrity: sha512-WNzpqJV7rO/oKmsxjtSFXuV87fZb/qxzeGWXJng4oHFz7iPOFSWrPb2gTazJgoTvXUfe1kOH2o0F+zFrerwzRw==} + '@turbo/darwin-64@2.8.20': + resolution: {integrity: sha512-FQ9EX1xMU5nbwjxXxM3yU88AQQ6Sqc6S44exPRroMcx9XZHqqppl5ymJF0Ig/z3nvQNwDmz1Gsnvxubo+nXWjQ==} cpu: [x64] os: [darwin] - '@turbo/darwin-arm64@2.8.19': - resolution: {integrity: sha512-KTq8/PH0/ml9bNFomZ2VjmOqW6RYPRqBqV5CfNeD5ekJMuNwJUdeQz0qXguxCzW4OkHCnTdPeKIehR0cdQObPg==} + '@turbo/darwin-arm64@2.8.20': + resolution: {integrity: sha512-Gpyh9ATFGThD6/s9L95YWY54cizg/VRWl2B67h0yofG8BpHf67DFAh9nuJVKG7bY0+SBJDAo5cMur+wOl9YOYw==} cpu: [arm64] os: [darwin] - '@turbo/linux-64@2.8.19': - resolution: {integrity: sha512-d0xcXiGUt1Q/HzMfgkqai5KyXrassLRuUZhxmUs4ZX99tQFbqRL2/CkSKCnMqyDv7c0K5eugLerVUY+DYr1DQg==} + '@turbo/linux-64@2.8.20': + resolution: {integrity: sha512-p2QxWUYyYUgUFG0b0kR+pPi8t7c9uaVlRtjTTI1AbCvVqkpjUfCcReBn6DgG/Hu8xrWdKLuyQFaLYFzQskZbcA==} cpu: [x64] os: [linux] - '@turbo/linux-arm64@2.8.19': - resolution: {integrity: sha512-UX3r1iwqsOK8dMgKFtZpDqZk7feqHXZJ/EQAknh0SVQrnc4vkm6mZqjX4j2j3DVoSo4Ho8xGITYlor9Xxsyomw==} + '@turbo/linux-arm64@2.8.20': + resolution: {integrity: sha512-Gn5yjlZGLRZWarLWqdQzv0wMqyBNIdq1QLi48F1oY5Lo9kiohuf7BPQWtWxeNVS2NgJ1+nb/DzK1JduYC4AWOA==} cpu: [arm64] os: [linux] - '@turbo/windows-64@2.8.19': - resolution: {integrity: sha512-3MrvD/gMYWfQKZVZOeilKm1629zPG0+KlErZbI0n9Nr3L32+5qrZOF/cgWErukLnOSR38whgf8t2WaPJQALqxg==} + '@turbo/windows-64@2.8.20': + resolution: {integrity: sha512-vyaDpYk/8T6Qz5V/X+ihKvKFEZFUoC0oxYpC1sZanK6gaESJlmV3cMRT3Qhcg4D2VxvtC2Jjs9IRkrZGL+exLw==} cpu: [x64] os: [win32] - '@turbo/windows-arm64@2.8.19': - resolution: {integrity: sha512-j+8mi7kyEgT7cUTPOtPJS8KbTWxu4+OQBiDIo+zklz/RKV4hoN+k4+J8iCM9Nj+o+SVnzc01xSI+s3eBG0MDSA==} + '@turbo/windows-arm64@2.8.20': + resolution: {integrity: sha512-voicVULvUV5yaGXo0Iue13BcHGYW3u0VgqSbfQwBaHbpj1zLjYV4KIe+7fYIo6DO8FVUJzxFps3ODCQG/Wy2Qw==} cpu: [arm64] os: [win32] @@ -1799,8 +1799,8 @@ packages: ini@1.3.8: resolution: {integrity: sha512-JV/yugV2uzW5iMRSiZAyDtQd+nxtUnjeLt0acNdw98kKLrvuRVyB80tsREOE7yvGVgalhZ6RNXCmEHkUKBKxew==} - ioredis@5.10.0: - resolution: {integrity: sha512-HVBe9OFuqs+Z6n64q09PQvP1/R4Bm+30PAyyD4wIEqssh3v9L21QjCVk4kRLucMBcDokJTcLjsGeVRlq/nH6DA==} + ioredis@5.10.1: + resolution: {integrity: sha512-HuEDBTI70aYdx1v6U97SbNx9F1+svQKBDo30o0b9fw055LMepzpOOd0Ccg9Q6tbqmBSJaMuY0fB7yw9/vjBYCA==} engines: {node: '>=12.22.0'} ioredis@5.9.3: @@ -2264,6 +2264,10 @@ packages: resolution: {integrity: sha512-V/yCWTTF7VJ9hIh18Ugr2zhJMP01MY7c5kh4J870L7imm6/DIzBsNLTXzMwUA3yZ5b/KBqLx8Kp3uRvd7xSe3Q==} engines: {node: '>=0.6'} + qs@6.15.0: + resolution: {integrity: sha512-mAZTtNCeetKMH+pSjrb76NAM8V9a05I9aBZOHztWy/UqcJdQYNsf59vrRKWnojAT9Y+GbIvoTBC++CPHqpDBhQ==} + engines: {node: '>=0.6'} + range-parser@1.2.1: resolution: {integrity: sha512-Hrgsx+orqoygnmhFbKaHE6c296J+HTAQXoxEF6gNupROmmGJRoyzfG3ccAveqCBrwr/2yxQ5BVd/GTl5agOwSg==} engines: {node: '>= 0.6'} @@ -2529,8 +2533,8 @@ packages: tunnel-agent@0.6.0: resolution: {integrity: sha512-McnNiV1l8RYeY8tBgEpuodCC1mLUdbSN+CYBL7kJsJNInOP8UjDDEwdk6Mw60vdLLrr5NHKZhMAOSrR2NZuQ+w==} - turbo@2.8.19: - resolution: {integrity: sha512-9NTKvQZ/02XnJCSU4mF5gvAPK+nuLbvCtft/NE8dJeOwaup0bJ14rYx7TxmSXp8JJuAN8nAjqfXWFsWwoQSFHg==} + turbo@2.8.20: + resolution: {integrity: sha512-Rb4qk5YT8RUwwdXtkLpkVhNEe/lor6+WV7S5tTlLpxSz6MjV5Qi8jGNn4gS6NAvrYGA/rNrE6YUQM85sCZUDbQ==} hasBin: true type-check@0.4.0: @@ -3206,22 +3210,22 @@ snapshots: '@rollup/rollup-win32-x64-msvc@4.59.0': optional: true - '@turbo/darwin-64@2.8.19': + '@turbo/darwin-64@2.8.20': optional: true - '@turbo/darwin-arm64@2.8.19': + '@turbo/darwin-arm64@2.8.20': optional: true - '@turbo/linux-64@2.8.19': + '@turbo/linux-64@2.8.20': optional: true - '@turbo/linux-arm64@2.8.19': + '@turbo/linux-arm64@2.8.20': optional: true - '@turbo/windows-64@2.8.19': + '@turbo/windows-64@2.8.20': optional: true - '@turbo/windows-arm64@2.8.19': + '@turbo/windows-arm64@2.8.20': optional: true '@tybys/wasm-util@0.10.1': @@ -3471,7 +3475,7 @@ snapshots: http-errors: 2.0.1 iconv-lite: 0.7.2 on-finished: 2.4.1 - qs: 6.14.2 + qs: 6.15.0 raw-body: 3.0.2 type-is: 2.0.1 transitivePeerDependencies: @@ -3822,7 +3826,7 @@ snapshots: once: 1.4.0 parseurl: 1.3.3 proxy-addr: 2.0.7 - qs: 6.14.2 + qs: 6.15.0 range-parser: 1.2.1 router: 2.2.0 send: 1.2.1 @@ -3986,7 +3990,7 @@ snapshots: ini@1.3.8: {} - ioredis@5.10.0: + ioredis@5.10.1: dependencies: '@ioredis/commands': 1.5.1 cluster-key-slot: 1.1.2 @@ -4423,6 +4427,10 @@ snapshots: dependencies: side-channel: 1.1.0 + qs@6.15.0: + dependencies: + side-channel: 1.1.0 + range-parser@1.2.1: {} raw-body@2.5.3: @@ -4773,14 +4781,14 @@ snapshots: dependencies: safe-buffer: 5.2.1 - turbo@2.8.19: + turbo@2.8.20: optionalDependencies: - '@turbo/darwin-64': 2.8.19 - '@turbo/darwin-arm64': 2.8.19 - '@turbo/linux-64': 2.8.19 - '@turbo/linux-arm64': 2.8.19 - '@turbo/windows-64': 2.8.19 - '@turbo/windows-arm64': 2.8.19 + '@turbo/darwin-64': 2.8.20 + '@turbo/darwin-arm64': 2.8.20 + '@turbo/linux-64': 2.8.20 + '@turbo/linux-arm64': 2.8.20 + '@turbo/windows-64': 2.8.20 + '@turbo/windows-arm64': 2.8.20 type-check@0.4.0: dependencies: