July 2025 Update (#36)

* fixed wordings and typos

* Catch error if pods are not initilized for logs

* Changed how to get Version

* moved semphore to functions

* updated wording for pipelines

* fixed output for gathering logs

Author: ThatAmatoGuy

README.md

@@ -26,8 +26,8 @@ The binary is built on using `ubuntu-latest`.  You can find what is included in
 ### macOS - arm64
 
 ```shell
-# get the latest version or change to a specific version
-VERSION=$(curl --silent "https://api.github.com/repos/codefresh-support/codefresh-support-package/releases/latest" | jq -r ".tag_name")
+# Get the version at https://github.com/codefresh-support/codefresh-support-package/releases
+VERSION=v#.#.#
 
 # download and extract the binary
 curl -L --output - https://github.com/codefresh-support/codefresh-support-package/releases/download/$VERSION/cf-support_darwin_arm64.tar.gz | tar -zx -O cf-support_darwin_arm64 > cf-support
@@ -42,8 +42,8 @@ chmod +x cf-support
 ### macOS - amd64
 
 ```shell
-# get the latest version or change to a specific version
-VERSION=$(curl --silent "https://api.github.com/repos/codefresh-support/codefresh-support-package/releases/latest" | jq -r ".tag_name")
+# Get the version at https://github.com/codefresh-support/codefresh-support-package/releases
+VERSION=v#.#.#
 
 # download and extract the binary
 curl -L --output - https://github.com/codefresh-support/codefresh-support-package/releases/download/$VERSION/cf-support_darwin_amd64.tar.gz | tar -zx -O cf-support_darwin_amd64 > cf-support
@@ -58,8 +58,8 @@ chmod +x cf-support
 ### linux - arm64
 
 ```shell
-# get the latest version or change to a specific version
-VERSION=$(curl --silent "https://api.github.com/repos/codefresh-support/codefresh-support-package/releases/latest" | jq -r ".tag_name")
+# Get the version at https://github.com/codefresh-support/codefresh-support-package/releases
+VERSION=v#.#.#
 
 # download and extract the binary
 curl -L --output - https://github.com/codefresh-support/codefresh-support-package/releases/download/$VERSION/cf-support_linux_arm64.tar.gz | tar -zx -O cf-support_linux_arm64 > cf-support
@@ -74,8 +74,8 @@ chmod +x cf-support
 ### linux - amd64
 
 ```shell
-# get the latest version or change to a specific version
-VERSION=$(curl --silent "https://api.github.com/repos/codefresh-support/codefresh-support-package/releases/latest" | jq -r ".tag_name")
+# Get the version at https://github.com/codefresh-support/codefresh-support-package/releases
+VERSION=v#.#.#
 
 # download and extract the binary
 curl -L --output - https://github.com/codefresh-support/codefresh-support-package/releases/download/$VERSION/cf-support_linux_amd64.tar.gz | tar -zx -O cf-support_linux_amd64 > cf-support

src/gitops.js

@@ -9,7 +9,7 @@ export async function gitops(namespace) {
         namespace = selected;
     }
 
-    console.log(`Gatheing data in the '${namespace}' namespace for the GitOps Runtime`);
+    console.log(`Gathering data in the '${namespace}' namespace for the GitOps Runtime`);
     const k8sResources = getResources(namespace);
     await processData(dirPath, k8sResources);
     await preparePackage(dirPath);

src/logic/core.js

@@ -3,20 +3,16 @@ import { tgz } from '@deno-library/compress';
 import { getPodLogs } from './k8s.js';
 import { getSemaphore } from '@henrygd/semaphore';
 
-const semaphore = getSemaphore('supportPackageSemaphore', 10);
+
 
 export async function writeYaml(data, name, dirPath) {
-    await semaphore.acquire();
-    try {
-        await Deno.mkdir(dirPath, { recursive: true });
-        const filePath = `${dirPath}/${name}.yaml`;
-        await Deno.writeTextFile(filePath, toYaml(data, { skipInvalid: true }));
-    } finally {
-        semaphore.release();
-    }
+    await Deno.mkdir(dirPath, { recursive: true });
+    const filePath = `${dirPath}/${name}.yaml`;
+    await Deno.writeTextFile(filePath, toYaml(data, { skipInvalid: true }));
 }
 
 export async function preparePackage(dirPath) {
+    const semaphore = getSemaphore("zipfile", 10);
     await semaphore.acquire();
     try {
         const supportPackageZip = `${dirPath}.tar.gz`;
@@ -40,6 +36,9 @@ export async function processData(dirPath, k8sResources) {
             continue;
         }
 
+        const semaphore = getSemaphore(k8sType, 10);
+        console.log(`Processing Data for ${k8sType}`)
+
         if (k8sType == 'pods') {
             for (const pod of resources.items) {
                 await semaphore.acquire();
@@ -48,7 +47,8 @@ export async function processData(dirPath, k8sResources) {
 
                     await writeYaml(pod, `spec_${pod.metadata.name}`, `${dirPath}/${k8sType}/${pod.metadata.name}`);
 
-                    const logs = await getPodLogs(pod);
+                    const logs = await getPodLogs(pod.metadata.name);
+                    console.log(`Gathering logs for pod ${pod}`);
                     for (const [containerName, logData] of Object.entries(logs)) {
                         await Deno.writeTextFile(
                             `${dirPath}/${k8sType}/${pod.metadata.name}/log_${containerName}.log`,

src/logic/k8s.js

@@ -38,9 +38,14 @@ export async function getPodLogs(pod) {
 
     const logs = {};
     for (const container of containers) {
-        logs[container] = await coreApi
+        try {
+            logs[container] = await coreApi
             .namespace(namespace)
             .getPodLog(podName, { container: container, timestamps: true });
+        } catch (error) {
+            logs[container] = error
+        }
+        
     }
     return logs;
 }

src/pipelines.js

@@ -38,7 +38,7 @@ export async function pipelines(namespace, runtime) {
         }
     }
 
-    console.log(`Gathering data in the '${namespace}' namespace for Codefresh OnPrem`);
+    console.log(`Gathering data in the '${namespace}' namespace for Pipelines Runtime`);
     const k8sResources = getResources(namespace);
     await processData(dirPath, k8sResources);
     await preparePackage(dirPath);