Only use ObjectQL storage when broker is available (fixes tests)

Co-authored-by: hotlong <50353452+hotlong@users.noreply.github.com>

Author: Copilot

packages/audit/src/plugin.ts

@@ -62,9 +62,9 @@ export class AuditLogPlugin implements Plugin {
         this.context = context;
         this.startedAt = Date.now();
 
-        // Upgrade storage to ObjectQL if not explicitly provided
+        // Upgrade storage to ObjectQL if not explicitly provided and broker is available
         // We do this in init because we need the context
-        if (!this.config.storage) {
+        if (!this.config.storage && (context as any).broker) {
             this.storage = new ObjectQLAuditStorage(context);
             context.logger.info('[Audit Log] Upgraded to ObjectQL storage');
         }

packages/automation/src/plugin.ts

@@ -82,9 +82,9 @@ export class AutomationPlugin implements Plugin, IAutomationService {
         this.context = context;
         this.startedAt = Date.now();
 
-        // Upgrade storage to ObjectQL if not explicitly provided
+        // Upgrade storage to ObjectQL if not explicitly provided and broker is available
         // We do this in init because we need the context
-        if (!this.config.storage) {
+        if (!this.config.storage && (context as any).broker) {
             this.storage = new ObjectQLAutomationStorage(context);
             context.logger.info('[Automation Plugin] Upgraded to ObjectQL storage');
         }

packages/jobs/src/plugin.ts

@@ -87,9 +87,9 @@ export class JobsPlugin implements Plugin, IJobService {
         this.context = context;
         this.startedAt = Date.now();
 
-        // Upgrade storage to ObjectQL if not explicitly provided
+        // Upgrade storage to ObjectQL if not explicitly provided and broker is available
         // We do this in init because we need the context
-        if (!this.config.storage) {
+        if (!this.config.storage && (context as any).broker) {
             this.storage = new ObjectQLJobStorage(context);
             // Reinitialize queue and scheduler with new storage
             this.queue = new JobQueue({

packages/permissions/src/plugin.ts

@@ -75,9 +75,9 @@ export class PermissionsPlugin implements Plugin {
         this.context = context;
         this.startedAt = Date.now();
 
-        // Upgrade storage to ObjectQL if not explicitly provided
+        // Upgrade storage to ObjectQL if not explicitly provided and broker is available
         // We do this in init because we need the context
-        if (!this.config.storage) {
+        if (!this.config.storage && (context as any).broker) {
             this.storage = new ObjectQLPermissionStorage(context);
             this.engine = new PermissionEngine(this.storage, {
                 defaultDeny: this.config.defaultDeny,

packages/workflow/src/plugin.ts

@@ -66,11 +66,11 @@ export class WorkflowPlugin implements Plugin, IWorkflowService {
         this.logger = context.logger;
         this.startedAt = Date.now();
 
-        // Upgrade storage to ObjectQL if not explicitly provided
+        // Upgrade storage to ObjectQL if not explicitly provided and broker is available
         // We do this in init because we need the context
-        if (!this.config.storage) {
+        if (!this.config.storage && (context as any).broker) {
              this.storage = new ObjectQLWorkflowStorage(context);
-             this.logger.info('[Workflow Plugin] Upgraded to ObjectQL storage');
+             context.logger.info('[Workflow Plugin] Upgraded to ObjectQL storage');
              // Re-initialize API with new storage
              this.api = new WorkflowAPI(this.storage, this.engine);
         }