feat: create necessart sql views on deploy

services/rotor/src/lib/pg-config-store.ts

@@ -41,30 +41,6 @@ export function createPg(): Pool | undefined {
   pool.on("error", error => {
     log.atError().withCause(error).log("Pool error");
   });
-  // TODO: remove this to console's prisma migration
-  setImmediate(() =>
-    pool.query(`create or replace view enriched_connections_push as select link.id as "id",
-       json_build_object('id', link.id,
-                         'workspaceId', ws.id,
-                         'destinationId', dst.id,
-                         'streamId', src.id,
-                         'usesBulker', link."data" ?& array['mode', 'dataLayout'] ,
-                         'type', dst."config" ->> 'destinationType',
-                         'options', link.data,
-                         'updatedAt', to_char(link."updatedAt", 'YYYY-MM-DD"T"HH24:MI:SS"Z"'),
-                         'credentials', dst.config,
-                         'credentialsHash', md5(dst.config::text)
-       )       as "enrichedConnection"
-from "ConfigurationObjectLink" link
-         join "Workspace" ws on link."workspaceId" = ws.id and ws.deleted = false
-         join "ConfigurationObject" dst
-              on dst.id = link."toId" and dst.type = 'destination' and dst."workspaceId" = link."workspaceId" and
-                 dst.deleted = false
-         join "ConfigurationObject" src
-              on src.id = link."fromId" and src.type = 'stream' and
-                 src."workspaceId" = link."workspaceId" and src.deleted = false
-where link.deleted = false`)
-  );
   return pool;
 }
 

webapps/console/package.json

@@ -19,8 +19,9 @@
     "compile": "tsc -p .",
     "tool:hash": "ts-node scripts/password-hash.ts",
     "db:code-gen": "prisma generate",
-    "db:update-schema": "dotenv -e ../../.env.local -- prisma db push",
-    "db:update-schema-force": "dotenv -e ../../.env.local -- prisma db push --accept-data-loss"
+    "db:post-update": "dotenv -e ../../.env.local -- ts-node ./scripts/sql-exec.ts ./prisma/sql",
+    "db:update-schema": "dotenv -e ../../.env.local -- prisma db push && pnpm run db:post-update",
+    "db:update-schema-force": "dotenv -e ../../.env.local -- prisma db push --accept-data-loss && pnpm run db:post-update"
   },
   "dependencies": {
     "@ant-design/cssinjs": "^1.5.6",