From 787faa7f6c2b1289b3377d54fc9bee0cc2c0395c Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Mon, 13 Jan 2025 16:57:36 -0500
Subject: [PATCH 1/8] initial workflow run collect data

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 .gitignore                         |   1 +
 package-lock.json                  |  13 +++
 package.json                       |   2 +
 scripts/_download.js               | 168 ++++++++++++++++++++++++++++-
 scripts/_util.js                   |  74 +++++++++++++
 scripts/collect-assets-workflow.js |  45 ++++++++
 6 files changed, 302 insertions(+), 1 deletion(-)
 create mode 100755 scripts/collect-assets-workflow.js

diff --git a/.gitignore b/.gitignore
index 5c12f71e..45f3738f 100644
--- a/.gitignore
+++ b/.gitignore
@@ -4,6 +4,7 @@ build/
 dist/
 downloaded_assets/
 *.vsix
+.env
 
 # TypeScript build info
 **/tsconfig.tsbuildinfo
diff --git a/package-lock.json b/package-lock.json
index decd8214..305e6a19 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -15,6 +15,7 @@
         "vscode"
       ],
       "dependencies": {
+        "dotenv": "^16.4.7",
         "fs-extra": "^11.2.0",
         "globby": "^14.0.2",
         "immer": "10.1.1",
@@ -4691,6 +4692,18 @@
         "url": "https://github.com/fb55/domutils?sponsor=1"
       }
     },
+    "node_modules/dotenv": {
+      "version": "16.4.7",
+      "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-16.4.7.tgz",
+      "integrity": "sha512-47qPchRCykZC03FhkYAhrvwU4xDBFIj1QPqaarj6mdM/hgUzfPHcpkHJOn3mJAufFeeAxAzeGsr5X0M4k6fLZQ==",
+      "license": "BSD-2-Clause",
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://dotenvx.com"
+      }
+    },
     "node_modules/duplexer2": {
       "version": "0.1.4",
       "resolved": "https://registry.npmjs.org/duplexer2/-/duplexer2-0.1.4.tgz",
diff --git a/package.json b/package.json
index 867714d0..2acf6c7b 100644
--- a/package.json
+++ b/package.json
@@ -52,6 +52,7 @@
     "dev:vscode": "npm run dev -w vscode",
     "build": "npm run build --workspaces --if-present",
     "collect-assets": "rimraf ./downloaded_assets && node ./scripts/collect-assets.js",
+    "collect-assets-workflow": "rimraf ./downloaded_assets && node ./scripts/collect-assets-workflow.js",
     "dist": "rimraf ./dist && node ./scripts/copy-dist.js",
     "package": "cd dist && vsce package",
     "test": "npm run lint && npm run build && npm run test --workspaces --if-present"
@@ -90,6 +91,7 @@
     "unzipper": "^0.12.3"
   },
   "dependencies": {
+    "dotenv": "^16.4.7",
     "fs-extra": "^11.2.0",
     "globby": "^14.0.2",
     "immer": "10.1.1",
diff --git a/scripts/_download.js b/scripts/_download.js
index ebd2a2d6..d8f03563 100644
--- a/scripts/_download.js
+++ b/scripts/_download.js
@@ -6,7 +6,7 @@ import fs from "fs-extra";
 import unzipper from "unzipper";
 import * as tar from "tar";
 import { bold, green, yellow } from "colorette";
-import { chmodOwnerPlusX } from "./_util.js";
+import { chmodOwnerPlusX, fetchFirstSuccessfulRun, fetchArtifactsForRun } from "./_util.js";
 
 const GITHUB_API = "https://api.github.com";
 
@@ -203,3 +203,169 @@ export async function downloadAndExtractTarGz({ targetDirectory, url, sha256 })
     console.groupEnd();
   }
 }
+
+/**
+ * Download a workflow artifact from GitHub
+ *
+ * @param {string} url - Download URL for the artifact
+ * @param {string} name - Name of the artifact file
+ * @param {string} outputDir - Directory to save the downloaded artifact
+ * @returns {Promise<string>} - Path to the downloaded artifact file
+ */
+export async function downloadArtifact(url, name, outputDir, token) {
+  try {
+    const assetDir = join(outputDir);
+    const assetFileName = join(assetDir, `${name}`);
+    await fs.ensureDir(assetDir);
+
+    console.log(`Downloading asset: ${name}`);
+    const response = await fetch(url, {
+      headers: {
+        Accept: "application/vnd.github.v3+json",
+        Authorization: `Bearer ${token}`,
+      },
+    });
+
+    if (!response.ok) {
+      throw new Error(`Failed to download ${name}: ${response.statusText}`);
+    }
+
+    const sha256 = await streamResponseToFile(assetFileName, response);
+    console.log(`Verifying download of: ${name}`);
+    console.log(`Asset sha256: ${green(sha256)}`);
+
+    console.log(`Downloaded ${name} to ${assetFileName}`);
+    return assetFileName;
+  } catch (error) {
+    console.error(`Error downloading artifact ${name}:`, error.message);
+    throw error;
+  }
+}
+
+/**
+ * Extract an artifact ZIP file.
+ *
+ * @param {string} filePath - Path to the ZIP file
+ * @param {string} tempDir - Temporary directory for extraction
+ * @param {string} finalDir - Final directory for extracted files
+ */
+export async function extractArtifact(filePath, tempDir, finalDir) {
+  try {
+    console.log(`Checking if ${filePath} is a valid ZIP archive.`);
+
+    // First extraction to temporary directory
+    console.log(`Extracting ${filePath} to temporary directory: ${tempDir}`);
+    await unzipper.Open.file(filePath).then((d) => d.extract({ path: tempDir }));
+
+    // Find and extract any nested zip files in the temp directory
+    const files = await fs.readdir(tempDir);
+    for (const file of files) {
+      if (file.endsWith(".zip")) {
+        const nestedZipPath = join(tempDir, file);
+        console.log(`Extracting nested zip: ${nestedZipPath} to ${finalDir}`);
+        await unzipper.Open.file(nestedZipPath).then((d) => d.extract({ path: finalDir }));
+        console.log(`Deleting nested zip: ${nestedZipPath}`);
+        await fs.unlink(nestedZipPath);
+      }
+    }
+
+    // Cleanup temporary directory
+    console.log(`Cleaning up temporary directory: ${tempDir}`);
+    await fs.rm(tempDir, { recursive: true, force: true });
+
+    // Cleanup the original zip file
+    console.log(`Deleting original zip file: ${filePath}`);
+    await fs.unlink(filePath);
+
+    console.log(`Extraction complete: ${filePath} -> ${finalDir}`);
+  } catch (error) {
+    console.error(`Error extracting artifact ${filePath}:`, error.message);
+    throw error;
+  }
+}
+
+/**
+ * Download and process workflow artifacts.
+ *
+ * @param {string} targetDirectory - Directory to store downloaded artifacts
+ * @param {string} metaFile - Path to the metadata file
+ * @param {string} url - Base URL of the GitHub repository
+ * @param {string} workflow - Name of the workflow file
+ * @param {Array} assets - List of assets to downloa
+ */
+export async function downloadWorkflowArtifacts({
+  targetDirectory,
+  metaFile,
+  url,
+  workflow,
+  assets,
+}) {
+  const GITHUB_TOKEN = process.env.GITHUB_TOKEN;
+
+  if (!GITHUB_TOKEN) {
+    console.error("Error: GITHUB_TOKEN environment variable is not set.");
+    process.exit(1);
+  }
+
+  try {
+    console.log("Fetching first successful workflow run...");
+    const workflowRunId = await fetchFirstSuccessfulRun(url, workflow, GITHUB_TOKEN);
+
+    if (!workflowRunId) {
+      throw new Error("No successful workflow runs found.");
+    }
+
+    console.log(`Workflow Run ID: ${workflowRunId}`);
+    const artifactUrls = await fetchArtifactsForRun(url, workflowRunId, GITHUB_TOKEN);
+
+    if (!artifactUrls || artifactUrls.length === 0) {
+      throw new Error("No artifacts found for the workflow run.");
+    }
+
+    const metadata = {
+      workflowRunId,
+      collectedAt: new Date().toISOString(),
+      assets: [],
+    };
+
+    for (const asset of assets) {
+      const { name } = asset;
+      const artifact = artifactUrls.find((a) => a.name === name);
+
+      if (!artifact) {
+        console.warn(`Asset [${name}] was not found in the workflow artifacts.`);
+        continue;
+      }
+
+      try {
+        console.log(`Processing artifact: ${name}`);
+
+        const downloadedFilePath = await downloadArtifact(
+          artifact.url,
+          name,
+          targetDirectory,
+          GITHUB_TOKEN,
+        );
+
+        // Extract the artifact
+        const tempDir = join(targetDirectory, "temp");
+        const extractionDir = join(targetDirectory, name.replace(/\.zip$/, ""));
+        await extractArtifact(downloadedFilePath, tempDir, extractionDir);
+
+        metadata.assets.push({
+          name,
+          extractionDir,
+          downloadedAt: new Date().toISOString(),
+        });
+      } catch (error) {
+        console.error(`Error processing artifact [${name}]:`, error.message);
+      }
+    }
+
+    await fs.writeJson(metaFile, metadata, { spaces: 2 });
+    console.log(`Metadata written to ${metaFile}`);
+  } catch (error) {
+    console.error("Error downloading workflow artifacts:", error.message);
+    process.exit(1);
+  }
+}
diff --git a/scripts/_util.js b/scripts/_util.js
index a1eb23e3..6350de34 100644
--- a/scripts/_util.js
+++ b/scripts/_util.js
@@ -23,3 +23,77 @@ export function chmodOwnerPlusX(path) {
   const { mode = fs.constants.S_IRUSR } = fs.statSync(path);
   fs.chmodSync(path, mode | fs.constants.S_IXUSR);
 }
+
+/**
+ * Fetch the first successful workflow run ID.
+ *
+ * @param {string} baseUrl - Base URL of the GitHub repository.
+ * @param {string} workflowFile - Name of the workflow file.
+ * @param {string} token - GitHub personal access token.
+ * @returns {Promise<string|null>} - ID of the first successful workflow run.
+ */
+export async function fetchFirstSuccessfulRun(baseUrl, workflowFile, token) {
+  try {
+    const response = await fetch(
+      `${baseUrl}/actions/workflows/${workflowFile}/runs?branch=main&status=success`,
+      {
+        headers: {
+          Authorization: `Bearer ${token}`,
+          Accept: "application/vnd.github.v3+json",
+        },
+      },
+    );
+
+    if (!response.ok) {
+      throw new Error(`Failed to fetch workflow runs: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    const runs = data.workflow_runs;
+    if (runs.length === 0) {
+      console.log("No successful runs found.");
+      return null;
+    }
+
+    const firstRun = runs[0];
+    console.log(`First Successful Workflow Run ID: ${firstRun.id}`);
+    return firstRun.id;
+  } catch (error) {
+    console.error("Error fetching workflow runs:", error.message);
+    return null;
+  }
+}
+
+/**
+ * Fetch artifacts for a specific workflow run.
+ *
+ * @param {string} baseUrl - Base URL of the GitHub repository.
+ * @param {string} runId - ID of the workflow run.
+ * @param {string} token - GitHub personal access token.
+ * @returns {Promise<Array>} - List of artifacts with download URLs.
+ */
+export async function fetchArtifactsForRun(baseUrl, runId, token) {
+  try {
+    const response = await fetch(`${baseUrl}/actions/runs/${runId}/artifacts`, {
+      headers: {
+        Authorization: `Bearer ${token}`,
+        Accept: "application/vnd.github.v3+json",
+      },
+    });
+
+    if (!response.ok) {
+      throw new Error(`Failed to fetch artifacts: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    const downloadUrls = data.artifacts.map((artifact) => ({
+      name: artifact.name,
+      url: artifact.archive_download_url,
+    }));
+    console.log("Artifact Download URLs:", downloadUrls);
+    return downloadUrls;
+  } catch (error) {
+    console.error("Error fetching artifacts:", error.message);
+    return [];
+  }
+}
diff --git a/scripts/collect-assets-workflow.js b/scripts/collect-assets-workflow.js
new file mode 100755
index 00000000..1fc4c180
--- /dev/null
+++ b/scripts/collect-assets-workflow.js
@@ -0,0 +1,45 @@
+#! /usr/bin/env node
+import { ensureDir } from "fs-extra/esm";
+import { resolve, join } from "path";
+import { cwdToProjectRoot } from "./_util.js";
+import { downloadWorkflowArtifacts, downloadAndExtractTarGz } from "./_download.js";
+import dotenv from "dotenv";
+dotenv.config();
+
+const REPO_OWNER = "konveyor";
+const REPO_NAME = "kai";
+const WORKFLOW_FILE = "build-and-push-binaries.yml";
+
+const GITHUB_API = "https://api.github.com";
+const BASE_URL = `${GITHUB_API}/repos/${REPO_OWNER}/${REPO_NAME}`;
+const DOWNLOAD_DIR = resolve("downloaded_assets");
+const META_FILE = join(DOWNLOAD_DIR, "kai", "collect.json");
+
+cwdToProjectRoot();
+
+await ensureDir(DOWNLOAD_DIR);
+
+// Download Kai assets via workflow artifacts
+await downloadWorkflowArtifacts({
+  targetDirectory: join(DOWNLOAD_DIR, "kai/"),
+  metaFile: META_FILE,
+  url: BASE_URL,
+  workflow: WORKFLOW_FILE,
+  assets: [
+    { name: "java-deps.zip" },
+    { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
+    { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
+    { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
+    { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
+    { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64" },
+    { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64" },
+  ],
+});
+
+// Download jdt.ls
+// Base release url: https://download.eclipse.org/jdtls/milestones/1.38.0/
+await downloadAndExtractTarGz({
+  targetDirectory: join(DOWNLOAD_DIR, "jdt.ls-1.38.0/"),
+  url: "https://download.eclipse.org/jdtls/milestones/1.38.0/jdt-language-server-1.38.0-202408011337.tar.gz",
+  sha256: "ba697788a19f2ba57b16302aba6b343c649928c95f76b0d170494ac12d17ac78",
+});

From 0907f88f81687767647d175c8d88aaa6e35eddee Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Thu, 16 Jan 2025 14:39:40 -0500
Subject: [PATCH 2/8] adding review fedback

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/_download.js               | 49 ++++++++++-----
 scripts/_github.js                 | 99 ++++++++++++++++++++++++++++++
 scripts/_util.js                   | 75 +---------------------
 scripts/collect-assets-workflow.js | 20 +++---
 4 files changed, 142 insertions(+), 101 deletions(-)
 create mode 100644 scripts/_github.js

diff --git a/scripts/_download.js b/scripts/_download.js
index d8f03563..23c23d73 100644
--- a/scripts/_download.js
+++ b/scripts/_download.js
@@ -6,7 +6,10 @@ import fs from "fs-extra";
 import unzipper from "unzipper";
 import * as tar from "tar";
 import { bold, green, yellow } from "colorette";
-import { chmodOwnerPlusX, fetchFirstSuccessfulRun, fetchArtifactsForRun } from "./_util.js";
+import { chmodOwnerPlusX } from "./_util.js";
+import { fetchFirstSuccessfulRun, fetchArtifactsForRun } from "./_github.js";
+
+import { globby } from "globby";
 
 const GITHUB_API = "https://api.github.com";
 
@@ -255,18 +258,20 @@ export async function extractArtifact(filePath, tempDir, finalDir) {
 
     // First extraction to temporary directory
     console.log(`Extracting ${filePath} to temporary directory: ${tempDir}`);
-    await unzipper.Open.file(filePath).then((d) => d.extract({ path: tempDir }));
+    const unzipArtifact = await unzipper.Open.file(filePath);
+    await unzipArtifact.extract({ path: tempDir });
 
     // Find and extract any nested zip files in the temp directory
-    const files = await fs.readdir(tempDir);
-    for (const file of files) {
-      if (file.endsWith(".zip")) {
-        const nestedZipPath = join(tempDir, file);
-        console.log(`Extracting nested zip: ${nestedZipPath} to ${finalDir}`);
-        await unzipper.Open.file(nestedZipPath).then((d) => d.extract({ path: finalDir }));
-        console.log(`Deleting nested zip: ${nestedZipPath}`);
-        await fs.unlink(nestedZipPath);
-      }
+    const zipFiles = await globby("*.zip", { cwd: tempDir });
+    for (const file of zipFiles) {
+      const nestedZipPath = join(tempDir, file);
+      console.log(`Extracting nested zip: ${nestedZipPath} to ${finalDir}`);
+
+      const unzipNestedArtifact = await unzipper.Open.file(nestedZipPath);
+      await unzipNestedArtifact.extract({ path: finalDir });
+
+      console.log(`Deleting nested zip: ${nestedZipPath}`);
+      await fs.unlink(nestedZipPath);
     }
 
     // Cleanup temporary directory
@@ -296,7 +301,8 @@ export async function extractArtifact(filePath, tempDir, finalDir) {
 export async function downloadWorkflowArtifacts({
   targetDirectory,
   metaFile,
-  url,
+  org,
+  repo,
   workflow,
   assets,
 }) {
@@ -309,21 +315,25 @@ export async function downloadWorkflowArtifacts({
 
   try {
     console.log("Fetching first successful workflow run...");
-    const workflowRunId = await fetchFirstSuccessfulRun(url, workflow, GITHUB_TOKEN);
+    const { workflowRunId, headSha } = await fetchFirstSuccessfulRun(org, repo, workflow);
 
     if (!workflowRunId) {
       throw new Error("No successful workflow runs found.");
     }
 
     console.log(`Workflow Run ID: ${workflowRunId}`);
-    const artifactUrls = await fetchArtifactsForRun(url, workflowRunId, GITHUB_TOKEN);
+    const artifactUrls = await fetchArtifactsForRun(org, repo, workflowRunId);
 
     if (!artifactUrls || artifactUrls.length === 0) {
       throw new Error("No artifacts found for the workflow run.");
     }
 
     const metadata = {
+      org,
+      repo,
+      workflow,
       workflowRunId,
+      commitId: headSha,
       collectedAt: new Date().toISOString(),
       assets: [],
     };
@@ -352,6 +362,17 @@ export async function downloadWorkflowArtifacts({
         const extractionDir = join(targetDirectory, name.replace(/\.zip$/, ""));
         await extractArtifact(downloadedFilePath, tempDir, extractionDir);
 
+        // for (const file of await globby(["*", "!*.zip"], { cwd: extractionDir, absolute: true })) {
+        //   chmodOwnerPlusX(file);
+        // }
+
+        const extractedFiles = await fs.readdir(extractionDir);
+        extractedFiles.forEach(async (file) => {
+          if (asset.chmod && !file.endsWith(".zip")) {
+            chmodOwnerPlusX(join(extractionDir, file));
+          }
+        });
+
         metadata.assets.push({
           name,
           extractionDir,
diff --git a/scripts/_github.js b/scripts/_github.js
new file mode 100644
index 00000000..fb82cfa1
--- /dev/null
+++ b/scripts/_github.js
@@ -0,0 +1,99 @@
+/**
+ * Fetch the most recent successful workflow run for the branch head.
+ *
+ * @param {string} org - GitHub organization or user.
+ * @param {string} repo - GitHub repository name.
+ * @param {string} workflowFile - Name of the workflow file.
+ * @returns {Promise<{runId: string, headSha: string} | null>} - Object containing the workflow run ID and head SHA, or null if not found.
+ */
+export async function fetchFirstSuccessfulRun(org, repo, workflowFile) {
+  try {
+    console.log(`Fetching head commit SHA for branch: main`);
+    const res = await fetch(`https://api.github.com/repos/${org}/${repo}/branches/main`, {
+      headers: {
+        Accept: "application/vnd.github.v3+json",
+      },
+    });
+
+    if (!res.ok) {
+      throw new Error(`Failed to fetch branch head SHA: ${res.statusText}`);
+    }
+
+    const data = await res.json();
+    const headSha = data.commit.sha;
+    console.log(`Head commit SHA: ${headSha}`);
+
+    console.log(`Fetching workflow runs for head SHA: ${headSha}`);
+    const workflowResponse = await fetch(
+      `https://api.github.com/repos/${org}/${repo}/actions/workflows/${workflowFile}/runs?head_sha=${headSha}&per_page=1`,
+      {
+        headers: {
+          Accept: "application/vnd.github.v3+json",
+        },
+      },
+    );
+
+    if (!workflowResponse.ok) {
+      throw new Error(`Failed to fetch workflow runs: ${workflowResponse.statusText}`);
+    }
+
+    const workflowData = await workflowResponse.json();
+    if (workflowData.workflow_runs.length === 0) {
+      console.log("No successful workflow runs found for the head commit.");
+      return null;
+    }
+
+    const workflowRun = workflowData.workflow_runs[0];
+    if (workflowRun.status !== "completed" || workflowRun.conclusion !== "success") {
+      console.log(
+        `Workflow run for head commit is not successful: Status = ${workflowRun.status}, Conclusion = ${workflowRun.conclusion}`,
+      );
+      return null;
+    }
+
+    console.log(`First Successful Workflow Run ID for head commit: ${workflowRun.id}`);
+    return {
+      workflowRunId: workflowRun.id,
+      headSha: headSha,
+    };
+  } catch (error) {
+    console.error("Error fetching workflow runs:", error.message);
+    return null;
+  }
+}
+
+/**
+ * Fetch artifacts for a specific workflow run.
+ *
+ * @param {string} org - GitHub organization or user.
+ * @param {string} repo - GitHub repository name.
+ * @param {string} runId - ID of the workflow run.
+ * @returns {Promise<Array>} - List of artifacts with download URLs.
+ */
+export async function fetchArtifactsForRun(org, repo, runId) {
+  try {
+    const response = await fetch(
+      `https://api.github.com/repos/${org}/${repo}/actions/runs/${runId}/artifacts`,
+      {
+        headers: {
+          Accept: "application/vnd.github.v3+json",
+        },
+      },
+    );
+
+    if (!response.ok) {
+      throw new Error(`Failed to fetch artifacts: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    const downloadUrls = data.artifacts.map((artifact) => ({
+      name: artifact.name,
+      url: artifact.archive_download_url,
+    }));
+    console.log("Artifact Download URLs:", downloadUrls);
+    return downloadUrls;
+  } catch (error) {
+    console.error("Error fetching artifacts:", error.message);
+    return [];
+  }
+}
diff --git a/scripts/_util.js b/scripts/_util.js
index 6350de34..38833715 100644
--- a/scripts/_util.js
+++ b/scripts/_util.js
@@ -21,79 +21,6 @@ export function cwdToProjectRoot() {
  */
 export function chmodOwnerPlusX(path) {
   const { mode = fs.constants.S_IRUSR } = fs.statSync(path);
+  console.log(`Setting executable permissions for: ${path}:${mode}`);
   fs.chmodSync(path, mode | fs.constants.S_IXUSR);
 }
-
-/**
- * Fetch the first successful workflow run ID.
- *
- * @param {string} baseUrl - Base URL of the GitHub repository.
- * @param {string} workflowFile - Name of the workflow file.
- * @param {string} token - GitHub personal access token.
- * @returns {Promise<string|null>} - ID of the first successful workflow run.
- */
-export async function fetchFirstSuccessfulRun(baseUrl, workflowFile, token) {
-  try {
-    const response = await fetch(
-      `${baseUrl}/actions/workflows/${workflowFile}/runs?branch=main&status=success`,
-      {
-        headers: {
-          Authorization: `Bearer ${token}`,
-          Accept: "application/vnd.github.v3+json",
-        },
-      },
-    );
-
-    if (!response.ok) {
-      throw new Error(`Failed to fetch workflow runs: ${response.statusText}`);
-    }
-
-    const data = await response.json();
-    const runs = data.workflow_runs;
-    if (runs.length === 0) {
-      console.log("No successful runs found.");
-      return null;
-    }
-
-    const firstRun = runs[0];
-    console.log(`First Successful Workflow Run ID: ${firstRun.id}`);
-    return firstRun.id;
-  } catch (error) {
-    console.error("Error fetching workflow runs:", error.message);
-    return null;
-  }
-}
-
-/**
- * Fetch artifacts for a specific workflow run.
- *
- * @param {string} baseUrl - Base URL of the GitHub repository.
- * @param {string} runId - ID of the workflow run.
- * @param {string} token - GitHub personal access token.
- * @returns {Promise<Array>} - List of artifacts with download URLs.
- */
-export async function fetchArtifactsForRun(baseUrl, runId, token) {
-  try {
-    const response = await fetch(`${baseUrl}/actions/runs/${runId}/artifacts`, {
-      headers: {
-        Authorization: `Bearer ${token}`,
-        Accept: "application/vnd.github.v3+json",
-      },
-    });
-
-    if (!response.ok) {
-      throw new Error(`Failed to fetch artifacts: ${response.statusText}`);
-    }
-
-    const data = await response.json();
-    const downloadUrls = data.artifacts.map((artifact) => ({
-      name: artifact.name,
-      url: artifact.archive_download_url,
-    }));
-    console.log("Artifact Download URLs:", downloadUrls);
-    return downloadUrls;
-  } catch (error) {
-    console.error("Error fetching artifacts:", error.message);
-    return [];
-  }
-}
diff --git a/scripts/collect-assets-workflow.js b/scripts/collect-assets-workflow.js
index 1fc4c180..7337490b 100755
--- a/scripts/collect-assets-workflow.js
+++ b/scripts/collect-assets-workflow.js
@@ -6,14 +6,7 @@ import { downloadWorkflowArtifacts, downloadAndExtractTarGz } from "./_download.
 import dotenv from "dotenv";
 dotenv.config();
 
-const REPO_OWNER = "konveyor";
-const REPO_NAME = "kai";
-const WORKFLOW_FILE = "build-and-push-binaries.yml";
-
-const GITHUB_API = "https://api.github.com";
-const BASE_URL = `${GITHUB_API}/repos/${REPO_OWNER}/${REPO_NAME}`;
 const DOWNLOAD_DIR = resolve("downloaded_assets");
-const META_FILE = join(DOWNLOAD_DIR, "kai", "collect.json");
 
 cwdToProjectRoot();
 
@@ -22,17 +15,18 @@ await ensureDir(DOWNLOAD_DIR);
 // Download Kai assets via workflow artifacts
 await downloadWorkflowArtifacts({
   targetDirectory: join(DOWNLOAD_DIR, "kai/"),
-  metaFile: META_FILE,
-  url: BASE_URL,
-  workflow: WORKFLOW_FILE,
+  metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+  org: "konveyor",
+  repo: "kai",
+  workflow: "build-and-push-binaries.yml",
   assets: [
-    { name: "java-deps.zip" },
+    { name: "java-deps.zip", chmod: false },
     { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
     { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
     { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
     { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-    { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64" },
-    { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64" },
+    { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64", chmod: false },
+    { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
   ],
 });
 

From 072719cdcb137ee1a43f539e02849b578278e3d6 Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Thu, 16 Jan 2025 15:03:37 -0500
Subject: [PATCH 3/8] use env variables to select workflow/release

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 .gitignore                         |  1 -
 package.json                       |  1 -
 scripts/collect-assets-workflow.js | 39 -----------------
 scripts/collect-assets.js          | 70 +++++++++++++++++++++---------
 4 files changed, 50 insertions(+), 61 deletions(-)
 delete mode 100755 scripts/collect-assets-workflow.js

diff --git a/.gitignore b/.gitignore
index 45f3738f..5c12f71e 100644
--- a/.gitignore
+++ b/.gitignore
@@ -4,7 +4,6 @@ build/
 dist/
 downloaded_assets/
 *.vsix
-.env
 
 # TypeScript build info
 **/tsconfig.tsbuildinfo
diff --git a/package.json b/package.json
index 2acf6c7b..75299e9d 100644
--- a/package.json
+++ b/package.json
@@ -52,7 +52,6 @@
     "dev:vscode": "npm run dev -w vscode",
     "build": "npm run build --workspaces --if-present",
     "collect-assets": "rimraf ./downloaded_assets && node ./scripts/collect-assets.js",
-    "collect-assets-workflow": "rimraf ./downloaded_assets && node ./scripts/collect-assets-workflow.js",
     "dist": "rimraf ./dist && node ./scripts/copy-dist.js",
     "package": "cd dist && vsce package",
     "test": "npm run lint && npm run build && npm run test --workspaces --if-present"
diff --git a/scripts/collect-assets-workflow.js b/scripts/collect-assets-workflow.js
deleted file mode 100755
index 7337490b..00000000
--- a/scripts/collect-assets-workflow.js
+++ /dev/null
@@ -1,39 +0,0 @@
-#! /usr/bin/env node
-import { ensureDir } from "fs-extra/esm";
-import { resolve, join } from "path";
-import { cwdToProjectRoot } from "./_util.js";
-import { downloadWorkflowArtifacts, downloadAndExtractTarGz } from "./_download.js";
-import dotenv from "dotenv";
-dotenv.config();
-
-const DOWNLOAD_DIR = resolve("downloaded_assets");
-
-cwdToProjectRoot();
-
-await ensureDir(DOWNLOAD_DIR);
-
-// Download Kai assets via workflow artifacts
-await downloadWorkflowArtifacts({
-  targetDirectory: join(DOWNLOAD_DIR, "kai/"),
-  metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
-  org: "konveyor",
-  repo: "kai",
-  workflow: "build-and-push-binaries.yml",
-  assets: [
-    { name: "java-deps.zip", chmod: false },
-    { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
-    { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
-    { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
-    { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-    { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64", chmod: false },
-    { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
-  ],
-});
-
-// Download jdt.ls
-// Base release url: https://download.eclipse.org/jdtls/milestones/1.38.0/
-await downloadAndExtractTarGz({
-  targetDirectory: join(DOWNLOAD_DIR, "jdt.ls-1.38.0/"),
-  url: "https://download.eclipse.org/jdtls/milestones/1.38.0/jdt-language-server-1.38.0-202408011337.tar.gz",
-  sha256: "ba697788a19f2ba57b16302aba6b343c649928c95f76b0d170494ac12d17ac78",
-});
diff --git a/scripts/collect-assets.js b/scripts/collect-assets.js
index 80b2688c..5130365e 100755
--- a/scripts/collect-assets.js
+++ b/scripts/collect-assets.js
@@ -2,7 +2,13 @@
 import { ensureDir } from "fs-extra/esm";
 import { resolve, join } from "path";
 import { cwdToProjectRoot } from "./_util.js";
-import { downloadAndExtractTarGz, downloadGitHubRelease } from "./_download.js";
+import {
+  downloadAndExtractTarGz,
+  downloadGitHubRelease,
+  downloadWorkflowArtifacts,
+} from "./_download.js";
+import dotenv from "dotenv";
+dotenv.config();
 
 cwdToProjectRoot();
 
@@ -10,29 +16,53 @@ cwdToProjectRoot();
 const DOWNLOAD_DIR = resolve("downloaded_assets");
 await ensureDir(DOWNLOAD_DIR);
 
-// Download Kai assets
-await downloadGitHubRelease({
-  targetDirectory: join(DOWNLOAD_DIR, "kai/"),
-  metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+if (process.env.WORKFLOW && process.env.WORKFLOW !== "False") {
+  console.log("WORKFLOW environment variable is set. Downloading workflow artifacts...");
 
-  org: "konveyor",
-  repo: "kai",
-  releaseTag: "v0.0.4",
+  // Download Kai assets via workflow artifacts
+  await downloadWorkflowArtifacts({
+    targetDirectory: join(DOWNLOAD_DIR, "kai/"),
+    metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+    org: "konveyor",
+    repo: "kai",
+    workflow: "build-and-push-binaries.yml",
+    assets: [
+      { name: "java-deps.zip", chmod: false },
+      { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
+      { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
+      { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
+      { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
+      { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64", chmod: false },
+      { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
+    ],
+  });
+} else {
+  console.log("WORKFLOW environment variable is not set. Downloading GitHub release assets...");
 
-  /*
-    Release asset filenames and nodejs equivalent platform/arch
+  // Download Kai assets from GitHub release
+  await downloadGitHubRelease({
+    targetDirectory: join(DOWNLOAD_DIR, "kai/"),
+    metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+
+    org: "konveyor",
+    repo: "kai",
+    releaseTag: "v0.0.4",
+
+    /*
+      Release asset filenames and nodejs equivalent platform/arch
       platform: https://nodejs.org/docs/latest-v22.x/api/process.html#processplatform
       arch: https://nodejs.org/docs/latest-v22.x/api/process.html#processarch
-  */
-  assets: [
-    { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
-    { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
-    { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-    { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
-    { name: "kai-rpc-server.windows-x64.zip", platform: "win32", arch: "x64" },
-    { name: "kai-rpc-server.windows-arm64.zip", platform: "win32", arch: "arm64" },
-  ],
-});
+    */
+    assets: [
+      { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
+      { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
+      { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
+      { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
+      { name: "kai-rpc-server.windows-x64.zip", platform: "win32", arch: "x64" },
+      { name: "kai-rpc-server.windows-arm64.zip", platform: "win32", arch: "arm64" },
+    ],
+  });
+}
 
 // Download jdt.ls
 // Base release url: https://download.eclipse.org/jdtls/milestones/1.38.0/

From 81f4c51417afad87c9718b8e4a525a9570321885 Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Fri, 17 Jan 2025 11:09:25 -0500
Subject: [PATCH 4/8] setting exe bit

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/_download.js | 13 +++----------
 scripts/_util.js     |  9 ++++++---
 2 files changed, 9 insertions(+), 13 deletions(-)

diff --git a/scripts/_download.js b/scripts/_download.js
index 23c23d73..53320165 100644
--- a/scripts/_download.js
+++ b/scripts/_download.js
@@ -362,16 +362,9 @@ export async function downloadWorkflowArtifacts({
         const extractionDir = join(targetDirectory, name.replace(/\.zip$/, ""));
         await extractArtifact(downloadedFilePath, tempDir, extractionDir);
 
-        // for (const file of await globby(["*", "!*.zip"], { cwd: extractionDir, absolute: true })) {
-        //   chmodOwnerPlusX(file);
-        // }
-
-        const extractedFiles = await fs.readdir(extractionDir);
-        extractedFiles.forEach(async (file) => {
-          if (asset.chmod && !file.endsWith(".zip")) {
-            chmodOwnerPlusX(join(extractionDir, file));
-          }
-        });
+        for (const file of await globby(["*", "!*.zip"], { cwd: extractionDir, absolute: true })) {
+          chmodOwnerPlusX(file);
+        }
 
         metadata.assets.push({
           name,
diff --git a/scripts/_util.js b/scripts/_util.js
index 38833715..77553bef 100644
--- a/scripts/_util.js
+++ b/scripts/_util.js
@@ -20,7 +20,10 @@ export function cwdToProjectRoot() {
  * @param {string} path File or directory to chmod
  */
 export function chmodOwnerPlusX(path) {
-  const { mode = fs.constants.S_IRUSR } = fs.statSync(path);
-  console.log(`Setting executable permissions for: ${path}:${mode}`);
-  fs.chmodSync(path, mode | fs.constants.S_IXUSR);
+  try {
+    const { mode = fs.constants.S_IRUSR } = fs.statSync(path);
+    fs.chmodSync(path, mode | fs.constants.S_IXUSR);
+  } catch (error) {
+    console.error(`Failed to set executable permissions for ${path}:`, error.message);
+  }
 }

From 026b5772f4a5cdd63be45749ce9b166f3f9a7380 Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Mon, 20 Jan 2025 16:40:14 -0500
Subject: [PATCH 5/8] updating the list to match latest kai workflow artfacts

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/collect-assets.js | 1 -
 1 file changed, 1 deletion(-)

diff --git a/scripts/collect-assets.js b/scripts/collect-assets.js
index 5130365e..44e5126e 100755
--- a/scripts/collect-assets.js
+++ b/scripts/collect-assets.js
@@ -32,7 +32,6 @@ if (process.env.WORKFLOW && process.env.WORKFLOW !== "False") {
       { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
       { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
       { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-      { name: "kai-rpc-server.windows-Arm64.zip", platform: "win32", arch: "arm64", chmod: false },
       { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
     ],
   });

From b42043da76d2856023209b1bef7f9c4a59d78411 Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Tue, 21 Jan 2025 11:23:17 -0500
Subject: [PATCH 6/8] updating the list to add java-deps to release artifacts
 download

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/collect-assets.js | 1 +
 1 file changed, 1 insertion(+)

diff --git a/scripts/collect-assets.js b/scripts/collect-assets.js
index 44e5126e..d595a53a 100755
--- a/scripts/collect-assets.js
+++ b/scripts/collect-assets.js
@@ -53,6 +53,7 @@ if (process.env.WORKFLOW && process.env.WORKFLOW !== "False") {
       arch: https://nodejs.org/docs/latest-v22.x/api/process.html#processarch
     */
     assets: [
+      { name: "java-deps.zip" },
       { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
       { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
       { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },

From d06c02cc7d2fdadfa6784459d77e4bb290ba54e4 Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Tue, 21 Jan 2025 15:04:21 -0500
Subject: [PATCH 7/8] update error handling

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/_download.js      | 154 +++++++++++++++++++++-----------------
 scripts/collect-assets.js |  99 ++++++++++++------------
 2 files changed, 135 insertions(+), 118 deletions(-)

diff --git a/scripts/_download.js b/scripts/_download.js
index 53320165..cd64ece7 100644
--- a/scripts/_download.js
+++ b/scripts/_download.js
@@ -22,17 +22,21 @@ const GITHUB_API = "https://api.github.com";
  * @returns {object}
  */
 export async function getGitHubReleaseMetadata(org, repo, releaseTag) {
-  const url = `${GITHUB_API}/repos/${org}/${repo}/releases/tags/${releaseTag}`;
-  console.log(
-    `Fetching GitHub release metadata for ${yellow(`${org}/${repo}`)} release: ${yellow(releaseTag)}`,
-  );
-
-  const response = await fetch(url);
-  if (!response.ok) {
-    throw new Error(`Failed to fetch release metadata: ${response.statusText}`);
-  }
+  try {
+    const url = `${GITHUB_API}/repos/${org}/${repo}/releases/tags/${releaseTag}`;
+    console.log(
+      `Fetching GitHub release metadata for ${yellow(`${org}/${repo}`)} release: ${yellow(releaseTag)}`,
+    );
 
-  return await response.json();
+    const response = await fetch(url);
+    if (!response.ok) {
+      throw new Error(`Failed to fetch release metadata: ${response.statusText}`);
+    }
+
+    return await response.json();
+  } catch (error) {
+    throw new Error(`Error in getGitHubReleaseMetadata: ${error.message}`);
+  }
 }
 
 /**
@@ -44,14 +48,22 @@ export async function getGitHubReleaseMetadata(org, repo, releaseTag) {
  * @returns The release tag's commit sha
  */
 export async function getGitHubReleaseTagSha(org, repo, releaseTag) {
-  const url = `${GITHUB_API}/repos/${org}/${repo}/commits/${releaseTag}`;
-  const response = await fetch(url, {
-    headers: {
-      Accept: "application/vnd.github.sha",
-    },
-  });
-
-  return await response.text();
+  try {
+    const url = `${GITHUB_API}/repos/${org}/${repo}/commits/${releaseTag}`;
+    const response = await fetch(url, {
+      headers: {
+        Accept: "application/vnd.github.sha",
+      },
+    });
+
+    if (!response.ok) {
+      throw new Error(`Failed to fetch release tag sha: ${response.statusText}`);
+    }
+
+    return await response.text();
+  } catch (error) {
+    throw new Error(`Error in getGitHubReleaseTagSha: ${error.message}`);
+  }
 }
 
 /**
@@ -60,22 +72,22 @@ export async function getGitHubReleaseTagSha(org, repo, releaseTag) {
  * @returns {Promise<string>} sha256 hash of the response data
  */
 async function streamResponseToFile(targetFile, fetchResponse) {
-  const reader = Readable.fromWeb(fetchResponse.body);
+  try {
+    const reader = Readable.fromWeb(fetchResponse.body);
 
-  // setup stream to file
-  const fileStream = fs.createWriteStream(targetFile);
-  const pipeToFile = pipeline(reader, fileStream);
+    // setup stream to file
+    const fileStream = fs.createWriteStream(targetFile);
+    const pipeToFile = pipeline(reader, fileStream);
 
-  // setup stream to calculate the sha256 hash of the file
-  const hash = createHash("sha256");
-  const pipeToHash = pipeline(reader, hash);
+    // setup stream to calculate the sha256 hash of the file
+    const hash = createHash("sha256");
+    const pipeToHash = pipeline(reader, hash);
 
-  // run them both, reject if either rejects, resolve with the hash
-  try {
+    // run them both, reject if either rejects, resolve with the hash
     await Promise.all([pipeToFile, pipeToHash]);
-    return Promise.resolve(hash.digest("hex"));
-  } catch (e) {
-    return Promise.reject(e);
+    return hash.digest("hex");
+  } catch (error) {
+    throw new Error(`Error in streamResponseToFile: ${error.message}`);
   }
 }
 
@@ -86,31 +98,35 @@ export async function downloadAndExtractGitHubAsset(
   arch,
   chmod = false,
 ) {
-  const assetDir = join(target, `${platform}-${arch}`);
-  const assetFileName = join(assetDir, gitHubReleaseAsset.name);
-
-  await fs.ensureDir(assetDir);
+  try {
+    const assetDir = join(target, `${platform}-${arch}`);
+    const assetFileName = join(assetDir, gitHubReleaseAsset.name);
 
-  console.log(`Downloading asset: ${gitHubReleaseAsset.name}`);
-  const response = await fetch(gitHubReleaseAsset.browser_download_url);
-  if (!response.ok) {
-    throw new Error(`Failed to download ${gitHubReleaseAsset.name}: ${response.statusText}`);
-  }
-  const sha256 = await streamResponseToFile(assetFileName, response);
+    await fs.ensureDir(assetDir);
 
-  console.log(`Asset sha256: ${green(sha256)}`);
-  console.log(`Extracting to: ${assetDir}`);
-  const zipFile = await unzipper.Open.file(assetFileName);
-  await zipFile.extract({ path: assetDir });
+    console.log(`Downloading asset: ${gitHubReleaseAsset.name}`);
+    const response = await fetch(gitHubReleaseAsset.browser_download_url);
+    if (!response.ok) {
+      throw new Error(`Failed to download ${gitHubReleaseAsset.name}: ${response.statusText}`);
+    }
+    const sha256 = await streamResponseToFile(assetFileName, response);
 
-  const extractedFiles = await fs.readdir(assetDir);
-  extractedFiles.forEach(async (file) => {
-    if (chmod && extname(file) !== ".zip") {
-      chmodOwnerPlusX(join(assetDir, file));
+    console.log(`Asset sha256: ${green(sha256)}`);
+    console.log(`Extracting to: ${assetDir}`);
+    const zipFile = await unzipper.Open.file(assetFileName);
+    await zipFile.extract({ path: assetDir });
+
+    const extractedFiles = await fs.readdir(assetDir);
+    for (const file of extractedFiles) {
+      if (chmod && extname(file) !== ".zip") {
+        chmodOwnerPlusX(join(assetDir, file));
+      }
     }
-  });
 
-  console.log(`Extracted: ${gitHubReleaseAsset.name}`);
+    console.log(`Extracted: ${gitHubReleaseAsset.name}`);
+  } catch (error) {
+    throw new Error(`Error in downloadAndExtractGitHubAsset: ${error.message}`);
+  }
 }
 
 export async function downloadGitHubRelease({
@@ -160,7 +176,7 @@ export async function downloadGitHubRelease({
     console.log(`Metadata written to ${metaFile}`);
     console.log(`All assets downloaded to: ${targetDirectory}`);
   } catch (error) {
-    console.error("Error downloading the release:", error.message);
+    throw new Error(`Error in downloadGitHubRelease: ${error.message}`);
   }
 }
 
@@ -183,25 +199,21 @@ export async function downloadAndExtractTarGz({ targetDirectory, url, sha256 })
 
     // If a sha256 is provided, verify against the downloaded file
     console.log(`Asset sha256: ${green(downloadSha256)}`);
-    if (sha256) {
-      if (downloadSha256 === sha256) {
-        console.log(`${green("Verified!")} Asset's sha256 matches expected`);
-      } else {
-        throw new Error(
-          `Downloaded file ${targetFile} sha256 ${downloadSha256} does not match the expected sha256 ${sha256}`,
-        );
-      }
+    if (sha256 && downloadSha256 !== sha256) {
+      throw new Error(
+        `Downloaded file ${targetFile} sha256 ${downloadSha256} does not match the expected sha256 ${sha256}`,
+      );
     }
 
     // Extract the tar.gz file
     console.log(`Extracting to ${targetDirectory}`);
-    tar.extract({
+    await tar.extract({
       f: targetFile,
       z: true,
       cwd: targetDirectory,
     });
   } catch (error) {
-    console.error("Error downloading/extracting tar.gz:", error);
+    throw new Error(`Error in downloadAndExtractTarGz: ${error.message}`);
   } finally {
     console.groupEnd();
   }
@@ -240,8 +252,7 @@ export async function downloadArtifact(url, name, outputDir, token) {
     console.log(`Downloaded ${name} to ${assetFileName}`);
     return assetFileName;
   } catch (error) {
-    console.error(`Error downloading artifact ${name}:`, error.message);
-    throw error;
+    throw new Error(`Error in downloadArtifact: ${error.message}`);
   }
 }
 
@@ -284,8 +295,8 @@ export async function extractArtifact(filePath, tempDir, finalDir) {
 
     console.log(`Extraction complete: ${filePath} -> ${finalDir}`);
   } catch (error) {
-    console.error(`Error extracting artifact ${filePath}:`, error.message);
-    throw error;
+    console.error(`Error extracting artifact at ${filePath}:`, error.message);
+    throw new Error(`Failed to extract artifact: ${error.message}`);
   }
 }
 
@@ -294,9 +305,10 @@ export async function extractArtifact(filePath, tempDir, finalDir) {
  *
  * @param {string} targetDirectory - Directory to store downloaded artifacts
  * @param {string} metaFile - Path to the metadata file
- * @param {string} url - Base URL of the GitHub repository
+ * @param {string} org - GH org
+ * @param {string} repo - GH repo
  * @param {string} workflow - Name of the workflow file
- * @param {Array} assets - List of assets to downloa
+ * @param {Array} assets - List of assets to download
  */
 export async function downloadWorkflowArtifacts({
   targetDirectory,
@@ -309,8 +321,9 @@ export async function downloadWorkflowArtifacts({
   const GITHUB_TOKEN = process.env.GITHUB_TOKEN;
 
   if (!GITHUB_TOKEN) {
-    console.error("Error: GITHUB_TOKEN environment variable is not set.");
-    process.exit(1);
+    const errorMessage = "GITHUB_TOKEN environment variable is not set.";
+    console.error(errorMessage);
+    throw new Error(errorMessage);
   }
 
   try {
@@ -373,6 +386,7 @@ export async function downloadWorkflowArtifacts({
         });
       } catch (error) {
         console.error(`Error processing artifact [${name}]:`, error.message);
+        throw new Error(`Failed to process artifact ${name}: ${error.message}`);
       }
     }
 
@@ -380,6 +394,6 @@ export async function downloadWorkflowArtifacts({
     console.log(`Metadata written to ${metaFile}`);
   } catch (error) {
     console.error("Error downloading workflow artifacts:", error.message);
-    process.exit(1);
+    throw new Error(`Failed to download workflow artifacts: ${error.message}`);
   }
 }
diff --git a/scripts/collect-assets.js b/scripts/collect-assets.js
index d595a53a..286e56ca 100755
--- a/scripts/collect-assets.js
+++ b/scripts/collect-assets.js
@@ -16,58 +16,61 @@ cwdToProjectRoot();
 const DOWNLOAD_DIR = resolve("downloaded_assets");
 await ensureDir(DOWNLOAD_DIR);
 
-if (process.env.WORKFLOW && process.env.WORKFLOW !== "False") {
-  console.log("WORKFLOW environment variable is set. Downloading workflow artifacts...");
+try {
+  if (process.env.WORKFLOW && process.env.WORKFLOW !== "False") {
+    console.log("WORKFLOW environment variable is set. Downloading workflow artifacts...");
 
-  // Download Kai assets via workflow artifacts
-  await downloadWorkflowArtifacts({
-    targetDirectory: join(DOWNLOAD_DIR, "kai/"),
-    metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
-    org: "konveyor",
-    repo: "kai",
-    workflow: "build-and-push-binaries.yml",
-    assets: [
-      { name: "java-deps.zip", chmod: false },
-      { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
-      { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
-      { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
-      { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-      { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
-    ],
-  });
-} else {
-  console.log("WORKFLOW environment variable is not set. Downloading GitHub release assets...");
-
-  // Download Kai assets from GitHub release
-  await downloadGitHubRelease({
-    targetDirectory: join(DOWNLOAD_DIR, "kai/"),
-    metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
-
-    org: "konveyor",
-    repo: "kai",
-    releaseTag: "v0.0.4",
+    // Download Kai assets via workflow artifacts
+    await downloadWorkflowArtifacts({
+      targetDirectory: join(DOWNLOAD_DIR, "kai/"),
+      metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+      org: "konveyor",
+      repo: "kai",
+      workflow: "build-and-push-binaries.yml",
+      assets: [
+        { name: "java-deps.zip", chmod: false },
+        { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
+        { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
+        { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
+        { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
+        { name: "kai-rpc-server.windows-X64.zip", platform: "win32", arch: "x64", chmod: false },
+      ],
+    });
+  } else {
+    console.log("WORKFLOW environment variable is not set. Downloading GitHub release assets...");
 
-    /*
+    // Download Kai assets from GitHub release
+    await downloadGitHubRelease({
+      targetDirectory: join(DOWNLOAD_DIR, "kai/"),
+      metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
+      org: "konveyor",
+      repo: "kai",
+      releaseTag: "v0.0.5",
+      /*
       Release asset filenames and nodejs equivalent platform/arch
       platform: https://nodejs.org/docs/latest-v22.x/api/process.html#processplatform
       arch: https://nodejs.org/docs/latest-v22.x/api/process.html#processarch
-    */
-    assets: [
-      { name: "java-deps.zip" },
-      { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
-      { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
-      { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
-      { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
-      { name: "kai-rpc-server.windows-x64.zip", platform: "win32", arch: "x64" },
-      { name: "kai-rpc-server.windows-arm64.zip", platform: "win32", arch: "arm64" },
-    ],
+      */
+      assets: [
+        { name: "java-deps.zip" },
+        { name: "kai-rpc-server.linux-x86_64.zip", platform: "linux", arch: "x64", chmod: true },
+        { name: "kai-rpc-server.linux-aarch64.zip", platform: "linux", arch: "arm64", chmod: true },
+        { name: "kai-rpc-server.macos-x86_64.zip", platform: "darwin", arch: "x64", chmod: true },
+        { name: "kai-rpc-server.macos-arm64.zip", platform: "darwin", arch: "arm64", chmod: true },
+        { name: "kai-rpc-server.windows-x64.zip", platform: "win32", arch: "x64" },
+        { name: "kai-rpc-server.windows-arm64.zip", platform: "win32", arch: "arm64" },
+      ],
+    });
+  }
+
+  // Download jdt.ls
+  // Base release url: https://download.eclipse.org/jdtls/milestones/1.38.0/
+  await downloadAndExtractTarGz({
+    targetDirectory: join(DOWNLOAD_DIR, "jdt.ls-1.38.0/"),
+    url: "https://download.eclipse.org/jdtls/milestones/1.38.0/jdt-language-server-1.38.0-202408011337.tar.gz",
+    sha256: "ba697788a19f2ba57b16302aba6b343c649928c95f76b0d170494ac12d17ac78",
   });
+} catch (error) {
+  console.error("Error during asset collection:", error.message);
+  process.exit(1);
 }
-
-// Download jdt.ls
-// Base release url: https://download.eclipse.org/jdtls/milestones/1.38.0/
-await downloadAndExtractTarGz({
-  targetDirectory: join(DOWNLOAD_DIR, "jdt.ls-1.38.0/"),
-  url: "https://download.eclipse.org/jdtls/milestones/1.38.0/jdt-language-server-1.38.0-202408011337.tar.gz",
-  sha256: "ba697788a19f2ba57b16302aba6b343c649928c95f76b0d170494ac12d17ac78",
-});

From 29c91423bfe888ea775b5263db45a90c40ecf99d Mon Sep 17 00:00:00 2001
From: Savitha Raghunathan <saveetha13@gmail.com>
Date: Tue, 21 Jan 2025 15:23:49 -0500
Subject: [PATCH 8/8] reset download tag to 0.0.4

Signed-off-by: Savitha Raghunathan <saveetha13@gmail.com>
---
 scripts/collect-assets.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/scripts/collect-assets.js b/scripts/collect-assets.js
index 286e56ca..c0dc3c89 100755
--- a/scripts/collect-assets.js
+++ b/scripts/collect-assets.js
@@ -45,7 +45,7 @@ try {
       metaFile: join(DOWNLOAD_DIR, "kai", "collect.json"),
       org: "konveyor",
       repo: "kai",
-      releaseTag: "v0.0.5",
+      releaseTag: "v0.0.4",
       /*
       Release asset filenames and nodejs equivalent platform/arch
       platform: https://nodejs.org/docs/latest-v22.x/api/process.html#processplatform