feat(worker): Job queue environment cache

[scopsy]

What changed? Why was the change needed?

Introduced an LRU cache for fetching environment data from MongoDB within the execute-bridge-job use case in the worker. This change reduces database load and improves performance by caching frequently accessed environments, mirroring existing caching patterns for workflows.

Screenshots

Expand for optional sections

Related enterprise PR

Special notes for your reviewer

The cache has a 60-second TTL and a maximum size of 500 items. It is enabled via the IS_LRU_CACHE_ENABLED feature flag, specifically for the worker-environment component. The implementation pattern, including handling inflight requests, is consistent with existing LRU cache usage in the codebase.

---

Slack Thread

 

[cursor]

Cursor Agent can help with this pull request. Just @cursor in comments and I'll start working on changes in this branch.
_{Learn more about Cursor Agents}

[netlify]

✅ Deploy Preview for dashboard-v2-novu-staging canceled.

Name	Link
🔨 Latest commit	e4dc123
🔍 Latest deploy log	https://app.netlify.com/projects/dashboard-v2-novu-staging/deploys/6961113024ec0f00087ccafc

[github-actions]

Hey there and thank you for opening this pull request! 👋

We require pull request titles to follow specific formatting rules and it looks like your proposed title needs to be adjusted.

Your PR title is: feat(worker): Job queue environment cache

Requirements:

1. Follow the Conventional Commits specification
2. As a team member, include Linear ticket ID at the end: fixes TICKET-ID or include it in your branch name

Expected format: feat(scope): Add fancy new feature fixes NOV-123

Details:

PR title must end with 'fixes TICKET-ID' (e.g., 'fixes NOV-123') or include ticket ID in branch name

[coderabbitai]

Caution

Review failed

The pull request is closed.

Walkthrough

This change introduces a feature flag-driven caching mechanism for environment data retrieval in the ExecuteBridgeJob usecase. An LRU cache and in-flight request tracking were added to store and reuse environment lookup results, preventing duplicate fetches. A new private getEnvironment() method was created to conditionally apply caching when the corresponding feature flag is enabled. The method integrates with FeatureFlagsService and EnvironmentRepository, with environment retrieval in execute-paths updated to use this new caching layer.

---

📜 Recent review details

Configuration used: Repository UI

Review profile: CHILL

Plan: Pro

📥 Commits

Reviewing files that changed from the base of the PR and between 257f1f4 and e4dc123.

📒 Files selected for processing (1)

• apps/worker/src/app/workflow/usecases/execute-bridge-job/execute-bridge-job.usecase.ts

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}