From e53e3cf92c545e00cc12db909433c60720623b58 Mon Sep 17 00:00:00 2001
From: lborv <m@m.lv>
Date: Mon, 29 Sep 2025 21:03:49 +0300
Subject: [PATCH] refactor: simplify plugin registration by removing
 unnecessary object structure

---
 src/query/executer/query.executer.service.ts |  4 +---
 src/vm/vm.constants.ts                       | 21 +++++++++-----------
 2 files changed, 10 insertions(+), 15 deletions(-)

diff --git a/src/query/executer/query.executer.service.ts b/src/query/executer/query.executer.service.ts
index 8deda2d..c3fcd6f 100644
--- a/src/query/executer/query.executer.service.ts
+++ b/src/query/executer/query.executer.service.ts
@@ -81,9 +81,7 @@ export class QueryExecuterService {
         throw new Error(`Plugin ${plugin.name} not found`);
       }
 
-      plugins.push(
-        await registeredPlugins[plugin.name].initMethod(this, query)
-      );
+      plugins.push(await registeredPlugins[plugin.name](this, query));
     }
 
     const vm = new Vm({
diff --git a/src/vm/vm.constants.ts b/src/vm/vm.constants.ts
index ff2c475..3567856 100644
--- a/src/vm/vm.constants.ts
+++ b/src/vm/vm.constants.ts
@@ -3,20 +3,17 @@ import { DatabasePlugin } from "./plugins/database.plugin";
 import { Query } from "src/query/entities/query.entity";
 
 export const registeredPlugins = {
-  db: {
-    class: DatabasePlugin,
-    initMethod: async (service: QueryExecuterService, query: Query) => {
-      const databaseConnection =
-        await service.databaseManagerService.getConnectionOptions(
-          query.project.id
-        );
+  db: async (service: QueryExecuterService, query: Query) => {
+    const databaseConnection =
+      await service.databaseManagerService.getConnectionOptions(
+        query.project.id
+      );
 
-      if (!databaseConnection) {
-        throw new Error("Database connection not found");
-      }
+    if (!databaseConnection) {
+      throw new Error("Database connection not found");
+    }
 
-      return DatabasePlugin.init("db", databaseConnection);
-    },
+    return DatabasePlugin.init("db", databaseConnection);
   },
 };