feat: create @objectql/plugin-query package with query modules from core

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

Author: Copilot

packages/foundation/plugin-query/package.json

@@ -0,0 +1,28 @@
+{
+  "name": "@objectql/plugin-query",
+  "version": "4.2.0",
+  "description": "Query execution and analysis plugin for ObjectQL - query service, builder, and analyzer",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "sideEffects": false,
+  "exports": {
+    ".": {
+      "types": "./dist/index.d.ts",
+      "default": "./dist/index.js"
+    }
+  },
+  "files": ["dist"],
+  "scripts": {
+    "build": "tsc",
+    "test": "vitest run"
+  },
+  "dependencies": {
+    "@objectql/types": "workspace:*",
+    "@objectql/plugin-optimizations": "workspace:*",
+    "@objectstack/core": "^2.0.6",
+    "@objectstack/spec": "^2.0.6"
+  },
+  "devDependencies": {
+    "typescript": "^5.3.0"
+  }
+}

packages/foundation/plugin-query/src/filter-translator.ts

@@ -0,0 +1,38 @@
+/**
+ * ObjectQL
+ * Copyright (c) 2026-present ObjectStack Inc.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE file in the root directory of this source tree.
+ */
+
+import type { Filter } from '@objectql/types';
+
+/**
+ * Filter Translator
+ * 
+ * Translates ObjectQL Filter to ObjectStack FilterCondition format.
+ * Since both now use the same format, this is mostly a pass-through.
+ * 
+ * @example
+ * Input:  { age: { $gte: 18 }, $or: [{ status: "active" }, { role: "admin" }] }
+ * Output: { age: { $gte: 18 }, $or: [{ status: "active" }, { role: "admin" }] }
+ */
+export class FilterTranslator {
+    /**
+     * Translate filters from ObjectQL format to ObjectStack FilterCondition format
+     */
+    translate(filters?: Filter): Filter | undefined {
+        if (!filters) {
+            return undefined;
+        }
+
+        // If it's an empty object, return undefined
+        if (typeof filters === 'object' && Object.keys(filters).length === 0) {
+            return undefined;
+        }
+
+        // Both ObjectQL Filter and ObjectStack FilterCondition use the same format now
+        return filters;
+    }
+}

packages/foundation/plugin-query/src/index.ts

@@ -0,0 +1,22 @@
+/**
+ * @objectql/plugin-query
+ * Copyright (c) 2026-present ObjectStack Inc.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE file in the root directory of this source tree.
+ */
+
+/**
+ * Query Plugin
+ * 
+ * Provides query execution and analysis capabilities:
+ * - QueryService — query execution with profiling support
+ * - QueryBuilder — builds ObjectStack QueryAST from ObjectQL UnifiedQuery
+ * - QueryAnalyzer — query performance analysis and optimization suggestions
+ */
+
+export { QueryPlugin } from './plugin';
+export { QueryService, type QueryOptions, type QueryResult, type QueryProfile } from './query-service';
+export { QueryBuilder } from './query-builder';
+export { QueryAnalyzer, type QueryPlan, type ProfileResult, type QueryStats } from './query-analyzer';
+export { FilterTranslator } from './filter-translator';

packages/foundation/plugin-query/src/plugin.ts

@@ -0,0 +1,91 @@
+/**
+ * @objectql/plugin-query
+ * Copyright (c) 2026-present ObjectStack Inc.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE file in the root directory of this source tree.
+ */
+
+import type { RuntimePlugin, RuntimeContext } from '@objectql/types';
+import { ConsoleLogger } from '@objectql/types';
+import type { Logger, Driver } from '@objectql/types';
+import { QueryService } from './query-service';
+import { QueryAnalyzer } from './query-analyzer';
+
+/**
+ * Configuration for the Query Plugin
+ */
+export interface QueryPluginConfig {
+  /**
+   * Datasources for query service
+   */
+  datasources?: Record<string, Driver>;
+
+  /**
+   * Enable query analyzer
+   * @default true
+   */
+  enableAnalyzer?: boolean;
+}
+
+/**
+ * Query Plugin
+ * 
+ * Provides query execution and analysis capabilities for the ObjectQL kernel.
+ * Registers QueryService and QueryAnalyzer on the kernel for consumer access.
+ */
+export class QueryPlugin implements RuntimePlugin {
+  name = '@objectql/plugin-query';
+  version = '4.2.0';
+  private logger: Logger;
+
+  constructor(private config: QueryPluginConfig = {}) {
+    this.config = {
+      enableAnalyzer: true,
+      ...config,
+    };
+    this.logger = new ConsoleLogger({ name: this.name, level: 'info' });
+  }
+
+  async install(ctx: RuntimeContext): Promise<void> {
+    this.logger.info('Installing query plugin...');
+
+    const kernel = ctx.engine as any;
+
+    // Get datasources - either from config or from kernel drivers
+    let datasources = this.config.datasources;
+    if (!datasources) {
+      const drivers = kernel.getAllDrivers?.();
+      if (drivers && drivers.length > 0) {
+        datasources = {};
+        drivers.forEach((driver: any, index: number) => {
+          const driverName = driver.name || (index === 0 ? 'default' : `driver_${index + 1}`);
+          datasources![driverName] = driver;
+        });
+      }
+    }
+
+    if (!datasources) {
+      this.logger.warn('No datasources available. QueryService will not be registered.');
+      return;
+    }
+
+    // Create QueryService
+    const queryService = new QueryService(datasources, kernel.metadata);
+    kernel.queryService = queryService;
+    this.logger.debug('QueryService registered');
+
+    // Create QueryAnalyzer if enabled
+    if (this.config.enableAnalyzer !== false) {
+      const queryAnalyzer = new QueryAnalyzer(queryService, kernel.metadata);
+      kernel.queryAnalyzer = queryAnalyzer;
+      this.logger.debug('QueryAnalyzer registered');
+    }
+
+    this.logger.info('Query plugin installed successfully');
+  }
+
+  async onStart(_ctx: RuntimeContext): Promise<void> {
+    this.logger.debug('Query plugin started');
+  }
+}