feat: add support for bullmq v6 and postgresql

[manast]

No description provided.

[manast]

@copilot resolve the merge conflicts in this pull request

[Copilot]

Pull request overview

Adds BullMQ v6 support (including PostgreSQL-backed BullMQ) to the connector, extending the existing queue discovery/command responder pipeline to handle a new BullMQ major version and a non-Redis backend.

Changes:

• Introduces BullMQ v6 responders plus queue factories for Redis and PostgreSQL backends.
• Adds PostgreSQL schema validation, queue discovery, and “info”/queue-type querying; wires PG support through CLI and socket handling.
• Updates queue caching/factory dispatch and bumps dependencies/TypeScript configuration to support the new integrations.

Reviewed changes

Copilot reviewed 18 out of 20 changed files in this pull request and generated 8 comments.

Show a summary per file

File	Description
tsconfig.json	Adjusts TS compilation root/output settings for updated build layout.
package.json	Adds pg + bullmq-v6 alias and updates dependency versions.
lib/ws-autoreconnect.ts	Updates WS/chalk imports and tightens instance field initialization.
lib/utils.ts	Hardens URL parsing and error typing in Redis URL helper.
lib/socket.ts	Adds PG-aware authorization handling, queue cache refresh, and info/queue-type routing.
lib/responders/index.ts	Exposes the new BullMQ v6 responders via the responders barrel.
lib/responders/bullmqv6-responders.ts	Implements command responders for BullMQ v6 queue/job operations.
lib/responders/bullmq-responders.ts	Adds “job not found” handling parity with other responders.
lib/responders/bull-responders.ts	Adds “job not found” handling and aligns respond() usage.
lib/queues-cache.ts	Extends queue cache update to support PG-discovered queues and v6 PG factory.
lib/queue-factory/bullmqv6-factory.ts	Adds BullMQ v6 Redis-backed queue creation.
lib/queue-factory/bullmqv6-postgres-factory.ts	Adds BullMQ v6 PostgreSQL-backed queue creation.
lib/queue-factory.ts	Adds BullMQ v6 factory dispatch and improves missing-queue log labeling.
lib/postgres-validator.ts	Adds PG schema validation, queue discovery, info, and queue-type helpers.
lib/interfaces/integration.ts	Allows integrations to accept redisOpts being undefined (for non-Redis backends).
lib/cmd.ts	Adds CLI options and validation for PostgreSQL backend selection.
tests/postgres-validator.spec.js	Adds unit tests for PG schema validation and queue discovery.
tests/bullmqv6-responders.spec.js	Adds unit tests for BullMQ v6 responder behavior.
tests/bullmqv6-factory.spec.js	Adds unit tests for BullMQ v6 factory output wiring.

Suppressed comments (2)

lib/responders/bullmqv6-responders.ts:112

• case "getJobLogs" is missing a break, so it will fall through and also execute getJobSchedulersCount, causing multiple responses for a single request (and potentially the wrong payload).

    case "getJobLogs":
      const logs = await queue.getJobLogs(data.jobId, data.start, data.end);
      respond(ws, startTime, msg.id, logs);

    case "getJobSchedulersCount": {
      const count = await queue.getJobSchedulersCount();
      respond(ws, startTime, msg.id, count);

lib/queue-factory.ts:337

• In the foundQueue.type === "bullmq" branch, if majorVersion is not one of the handled cases, the code logs an error but then falls through to the outer case "bull" and returns a Bull queue. That’s incorrect behavior for an unsupported BullMQ version and can mask configuration issues.

        default:
          console.error(
            chalk.red(`ERROR:`) +
              `Unexpected major version: ${foundQueue.majorVersion} for queue ${foundQueue.name}`
          );
      }

---

💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

[Copilot]

@copilot resolve the merge conflicts in this pull request

Addressed in 005800f.

[github-actions]

🎉 This PR is included in version 1.39.0 🎉

The release is available on:

• npm package (@latest dist-tag)
• GitHub release

Your semantic-release bot 📦🚀