chore: wip

odigos-io · May 30, 2024 · 41c189f · 41c189f
1 parent 5b6d6ba
commit 41c189f
Show file tree

Hide file tree

Showing 8 changed files with 83 additions and 10 deletions.
diff --git a/dist/index.d.mts b/dist/index.d.mts
@@ -396,6 +396,12 @@ interface Source {
     name: string;
     kind: string;
     namespace: string;
+    conditions?: {
+        type: string;
+        status: string;
+        message: string;
+        lastTransitionTime: string;
+    }[];
     languages: Array<{
         container_name: string;
         language: string;
@@ -411,6 +417,12 @@ interface Destination {
         logs: boolean;
     };
     fields: Record<string, any>;
+    conditions?: {
+        type: string;
+        status: string;
+        message: string;
+        lastTransitionTime: string;
+    }[];
     destination_type: {
         type: string;
         display_name: string;

diff --git a/dist/index.d.ts b/dist/index.d.ts
@@ -396,6 +396,12 @@ interface Source {
     name: string;
     kind: string;
     namespace: string;
+    conditions?: {
+        type: string;
+        status: string;
+        message: string;
+        lastTransitionTime: string;
+    }[];
     languages: Array<{
         container_name: string;
         language: string;
@@ -411,6 +417,12 @@ interface Destination {
         logs: boolean;
     };
     fields: Record<string, any>;
+    conditions?: {
+        type: string;
+        status: string;
+        message: string;
+        lastTransitionTime: string;
+    }[];
     destination_type: {
         type: string;
         display_name: string;

diff --git a/dist/index.js b/dist/index.js
diff --git a/dist/index.js.map b/dist/index.js.map
diff --git a/dist/index.mjs b/dist/index.mjs
@@ -3138,6 +3138,12 @@ var buildFlowNodesAndEdges = (sources2, destinations2, actions) => {
     data: { label: "Center Node" }
   });
   sources2.forEach((source, index) => {
+    let hasError = false;
+    if (source?.conditions) {
+      hasError = source.conditions.some(
+        (condition) => condition.status === "False"
+      );
+    }
     const namespaceNodeId = `namespace-${index}`;
     nodes2.push({
       id: namespaceNodeId,
@@ -3150,11 +3156,17 @@ var buildFlowNodesAndEdges = (sources2, destinations2, actions) => {
       source: namespaceNodeId,
       target: actions?.length > 0 ? `action-0` : centerNodeId,
       animated: true,
-      style: { stroke: "#96f3ff8e" },
+      style: { stroke: hasError ? "#ff0000" : "#96f3ff8e" },
       data: null
     });
   });
   destinations2.forEach((destination, index) => {
+    let isErrored = false;
+    if (destination?.conditions) {
+      isErrored = destination.conditions.some(
+        (condition) => condition.status === "False"
+      );
+    }
     const destinationNodeId = `destination-${index}`;
     nodes2.push({
       id: destinationNodeId,
@@ -3170,7 +3182,7 @@ var buildFlowNodesAndEdges = (sources2, destinations2, actions) => {
       source: centerNodeId,
       target: destinationNodeId,
       animated: true,
-      style: { stroke: "#96f3ff8e" },
+      style: { stroke: isErrored ? "#ff0000" : "#96f3ff8e" },
       data: null
     });
   });

diff --git a/dist/index.mjs.map b/dist/index.mjs.map
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@keyval-dev/design-system",
-  "version": "1.8.4",
+  "version": "1.8.7",
   "private": false,
   "scripts": {
     "dev": "next dev",

diff --git a/src/design.system/data.flow/builder.ts b/src/design.system/data.flow/builder.ts
@@ -214,6 +214,12 @@ interface Source {
   name: string;
   kind: string;
   namespace: string;
+  conditions?: {
+    type: string;
+    status: string;
+    message: string;
+    lastTransitionTime: string;
+  }[];
   languages: Array<{
     container_name: string;
     language: string;
@@ -230,6 +236,12 @@ interface Destination {
     logs: boolean;
   };
   fields: Record<string, any>;
+  conditions?: {
+    type: string;
+    status: string;
+    message: string;
+    lastTransitionTime: string;
+  }[];
   destination_type: {
     type: string;
     display_name: string;
@@ -323,6 +335,12 @@ export const buildFlowNodesAndEdges = (
 
   // Create namespace nodes from sources and edges to the center
   sources.forEach((source, index) => {
+    let hasError = false;
+    if (source?.conditions) {
+      hasError = source.conditions.some(
+        (condition) => condition.status === 'False'
+      );
+    }
     const namespaceNodeId = `namespace-${index}`;
     nodes.push({
       id: namespaceNodeId,
@@ -335,13 +353,19 @@ export const buildFlowNodesAndEdges = (
       source: namespaceNodeId,
       target: actions?.length > 0 ? `action-0` : centerNodeId,
       animated: true,
-      style: { stroke: '#96f3ff8e' },
+      style: { stroke: hasError ? '#ff0000' : '#96f3ff8e' },
       data: null,
     });
   });
 
   // Create destination nodes and edges from the center
   destinations.forEach((destination, index) => {
+    let isErrored = false;
+    if (destination?.conditions) {
+      isErrored = destination.conditions.some(
+        (condition) => condition.status === 'False'
+      );
+    }
     const destinationNodeId = `destination-${index}`;
     nodes.push({
       id: destinationNodeId,
@@ -357,7 +381,7 @@ export const buildFlowNodesAndEdges = (
       source: centerNodeId,
       target: destinationNodeId,
       animated: true,
-      style: { stroke: '#96f3ff8e' },
+      style: { stroke: isErrored ? '#ff0000' : '#96f3ff8e' },
       data: null,
     });
   });