feat: catch buckets events

packages/common/config/load-config.js

@@ -1,6 +1,7 @@
 const os = require("os")
 const path = require("path")
 const { mkdtemp } = require("fs/promises")
+const { v4: uuidv4 } = require("uuid")
 
 const { satisfies } = require("compare-versions")
 const fs = require("fs-extra")
@@ -241,6 +242,9 @@ const loadConfig = async (
       env: "KS_FORCE_NEW_DEPLOY",
       envParser: envParserYaml,
     },
+    pipelineUUID: {
+      defaultFunction: () => uuidv4(),
+    },
     pipelineId: {
       defaultFunction: (config) => {
         const {

packages/common/package.json

@@ -31,6 +31,7 @@
     "slugify": "^1.6.5",
     "sonic-boom": "^3.0.0",
     "tiged": "^2.12.4",
+    "uuid": "^10.0.0",
     "which": "^3.0.0",
     "yaml": "^2.3.1",
     "zx": "^7.1.1"

packages/common/utils/flatten-aggregate-error.js

@@ -1,11 +1,13 @@
 const indent = require("./indent")
 
-module.exports = (aggregateError) =>
-  new Error(
+module.exports = (aggregateError) => {
+  console.log("aggregateError", aggregateError)
+  return new Error(
     `${aggregateError.name} ${aggregateError.message}: \n${indent(
       aggregateError.errors
         .map((error) => `${error.stack.toString()}`)
         .join("\n"),
       2
     )}`
   )
+}

plugins/kontinuous-ui/deploy-sidecars/kontinuous-ui.js

@@ -0,0 +1,109 @@
+const { setTimeout: sleep } = require("timers/promises")
+const supabase = require("../lib/supabase")
+
+module.exports = async (_options, { config, dryRun, ctx }) => {
+  if (dryRun) {
+    return
+  }
+
+  const {
+    gitSha,
+    projectName,
+    environment,
+    gitBranch,
+    repositoryName,
+    gitRepositoryUrl,
+    pipelineUUID,
+  } = config
+
+  const values = {
+    uuid: pipelineUUID,
+    commit_hash: gitSha,
+    project: projectName,
+    environment,
+    branch: gitBranch,
+    repository: repositoryName,
+    repository_url: gitRepositoryUrl,
+  }
+
+  const eventsBucket = ctx.require("eventsBucket")
+  // const abortController = ctx.require("abortController")
+
+  // resource:waiting
+  // resource:failed
+  // resource:ready
+  // resource:closed
+
+  async function insertValues(data) {
+    const { error } = await supabase.from("deployments_logs").insert([data])
+    if (error) throw error
+  }
+
+  const waitingFor = []
+  eventsBucket.on("resource:waiting", () => {
+    waitingFor.push(
+      new Promise(async (resolve, reject) => {
+        try {
+          const valuesToInsert = { ...values, status: "waiting" }
+          await insertValues(valuesToInsert)
+          resolve()
+        } catch (e) {
+          reject(e)
+        }
+        // await
+      })
+    )
+  })
+
+  eventsBucket.on("resource:ready", () => {
+    waitingFor.push(
+      new Promise(async (resolve, reject) => {
+        try {
+          const valuesToInsert = { ...values, status: "ready" }
+          await insertValues(valuesToInsert)
+          resolve()
+        } catch (e) {
+          reject(e)
+        }
+        // await
+      })
+    )
+  })
+
+  eventsBucket.on("resource:failed", () => {
+    waitingFor.push(
+      new Promise(async (resolve, reject) => {
+        try {
+          const valuesToInsert = { ...values, status: "failed" }
+          await insertValues(valuesToInsert)
+          resolve()
+        } catch (e) {
+          reject(e)
+        }
+        // await
+      })
+    )
+  })
+
+  let finished
+  eventsBucket.on("deploy-with:finish", () => {
+    finished = true
+  })
+
+  return new Promise(async (res, rej) => {
+    while (true) {
+      if (finished) {
+        console.log("WAITING FOR...")
+        try {
+          await Promise.all(waitingFor)
+          res()
+        } catch (err) {
+          console.log("ERROR", err)
+          rej(err)
+        }
+        return
+      }
+      await sleep(1)
+    }
+  })
+}

plugins/kontinuous-ui/lib/supabase.js

@@ -0,0 +1,7 @@
+const { createClient } = require("@supabase/supabase-js")
+
+const { SUPABASE_URL: supabaseUrl, SUPABASE_KEY: supabaseKey } = process.env
+
+const supabase = createClient(supabaseUrl, supabaseKey)
+
+module.exports = supabase

plugins/kontinuous-ui/pre-deploy/01-deployment_event.js

@@ -1,30 +1,30 @@
-const { createClient } = require("@supabase/supabase-js")
-
-module.exports = async (_manifests, _options, { config, ctx }) => {
-  const processEnv = ctx.get("env") || process.env
-  const { SUPABASE_URL: supabaseUrl, SUPABASE_KEY: supabaseKey } = processEnv
+const supabase = require("../lib/supabase")
 
+module.exports = async (_manifests, _options, { config, logger }) => {
   const {
     gitSha,
     projectName,
     environment,
-    refLabelValue,
+    gitBranch,
     repositoryName,
-    actionCommandName,
+    gitRepositoryUrl,
+    pipelineUUID,
   } = config
 
-  const supabase = createClient(supabaseUrl, supabaseKey)
+  const values = {
+    uuid: pipelineUUID,
+    status: "pre-deploy",
+    commit_hash: gitSha,
+    project: projectName,
+    environment,
+    branch: gitBranch,
+    repository: repositoryName,
+    repository_url: gitRepositoryUrl,
+  }
 
-  const { error } = await supabase.from("deployments_logs").insert([
-    {
-      status: actionCommandName,
-      commit_hash: gitSha,
-      project: projectName,
-      environment,
-      branch: refLabelValue,
-      repository: repositoryName,
-    },
-  ])
+  const { error } = await supabase.from("deployments_logs").insert([values])
 
   if (error) throw error
+
+  logger.info(values, "FINISHED")
 }

yarn.lock

@@ -15698,6 +15698,15 @@ __metadata:
   languageName: node
   linkType: hard
 
+"uuid@npm:^10.0.0":
+  version: 10.0.0
+  resolution: "uuid@npm:10.0.0"
+  bin:
+    uuid: dist/bin/uuid
+  checksum: 9ea91ef753d88b03746de0a22192251c355bbe595d9cb3a67520aacf693c793df7e85c4ad0378aecb133c372a5e7bb7ec0f3b14db477ab7e3b6ff29792e047b9
+  languageName: node
+  linkType: hard
+
 "uuid@npm:^9.0.0":
   version: 9.0.0
   resolution: "uuid@npm:9.0.0"
@@ -16253,6 +16262,7 @@ __metadata:
     slugify: "npm:^1.6.5"
     sonic-boom: "npm:^3.0.0"
     tiged: "npm:^2.12.4"
+    uuid: "npm:^10.0.0"
     which: "npm:^3.0.0"
     yaml: "npm:^2.3.1"
     zx: "npm:^7.1.1"