mosaicstack/stack
1
0
Fork 0
Code Issues 13 Pull Requests Actions Packages Projects Releases 11 Wiki Activity

fix: parse VALKEY_URL into RedisOptions for BullMQ — fixes ECONNREFUSED 6379 #336

Merged
jason.woltje merged 2 commits from fix/bullmq-valkey-url-port into main 2026-03-31 01:45:38 +00:00
Conversation 0 Commits 2 Files Changed 3 +47 -9
jason.woltje commented 2026-03-31 01:45:06 +00:00
Owner
Copy Link

Problem

BullMQ v5.71.0 RedisConnection constructor does:

Object.assign({ port: 6379, host: "127.0.0.1" }, opts)

When opts is a URL string ("redis://localhost:6380" via as unknown as ConnectionOptions), Object.assign only copies character-index properties from the string — the default port 6379 was never overridden, causing ECONNREFUSED 127.0.0.1:6379 on every startup despite VALKEY_URL=redis://localhost:6380 being set.

Fix

getConnection() in apps/gateway/src/queue/queue.service.ts now parses VALKEY_URL with new URL() and returns a plain { host, port, ... } RedisOptions object that Object.assign merges correctly.

Also includes

  • pnpm install was needed after monorepo consolidation (#331) added packages/forge — ran it and committed the missing plugins/macp prettier formatting that was blocking format:check.
## Problem BullMQ v5.71.0 `RedisConnection` constructor does: ```js Object.assign({ port: 6379, host: "127.0.0.1" }, opts) ``` When `opts` is a URL string (`"redis://localhost:6380"` via `as unknown as ConnectionOptions`), `Object.assign` only copies character-index properties from the string — the default port `6379` was never overridden, causing `ECONNREFUSED 127.0.0.1:6379` on every startup despite `VALKEY_URL=redis://localhost:6380` being set. ## Fix `getConnection()` in `apps/gateway/src/queue/queue.service.ts` now parses `VALKEY_URL` with `new URL()` and returns a plain `{ host, port, ... }` `RedisOptions` object that `Object.assign` merges correctly. ## Also includes - `pnpm install` was needed after monorepo consolidation (#331) added `packages/forge` — ran it and committed the missing `plugins/macp` prettier formatting that was blocking `format:check`.
jason.woltje added 2 commits 2026-03-31 01:45:06 +00:00
fix: parse VALKEY_URL into RedisOptions object for BullMQ connection 316807581c 
BullMQ v5 RedisConnection constructor does:
  Object.assign({ port: 6379, host: '127.0.0.1' }, opts)

When opts is a URL string (via 'as unknown as ConnectionOptions'),
Object.assign only copies character-index properties from the string,
so the default port 6379 was never overridden — causing ECONNREFUSED
against the wrong port instead of the configured 6380.

Fix: parse VALKEY_URL with new URL() and return a plain RedisOptions
object { host, port, ... } so Object.assign merges it correctly.
style: fix prettier formatting in plugins/macp (consolidation follow-up)
Some checks failed
ci/woodpecker/pr/ci Pipeline failed
Details
ci/woodpecker/push/ci Pipeline failed
Details
1b317e8a0a
jason.woltje merged commit fa43989cd5 into main 2026-03-31 01:45:38 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
jason.woltje
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: mosaicstack/stack#336
Delete Branch "fix/bullmq-valkey-url-port"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?