chore: update the orchestrator workflow overview api (#3328)

* chore: update the workflow overview api to include the success ratio for a worfklow.  Also add the total runs(for the last 30 days) for each workflow

* squash: add changeset

* squash: change changeset to be a patch

* squash: small refactor

* squash: return total count, error count, success count.  this will be needed for RHIDP-14335

* squash: add a workflowRunStats object to return the stats in

* squash: build api reports

* squash: build api reports

* squash: add the stats for the detail page of the workflow.  fixes RHIDP-14335

* squash: only count success and error in the total count and success ratio

Author: lholmquist

workspaces/orchestrator/.changeset/silly-sheep-trade.md

@@ -0,0 +1,6 @@
+---
+'@red-hat-developer-hub/backstage-plugin-orchestrator-backend': patch
+'@red-hat-developer-hub/backstage-plugin-orchestrator-common': patch
+---
+
+update the workflow overview api to include the success ratio for a worfklow. Also add the total runs(for the last 30 days) for each workflow

workspaces/orchestrator/plugins/orchestrator-backend/src/service/Helper.ts

@@ -19,6 +19,11 @@ import type { Config } from '@backstage/config';
 
 import fs from 'fs-extra';
 
+import {
+  ProcessInstance,
+  ProcessInstanceState,
+} from '@red-hat-developer-hub/backstage-plugin-orchestrator-common';
+
 import os from 'os';
 
 export async function retryAsyncFunction<T>(args: {
@@ -90,3 +95,37 @@ export async function executeWithRetry(
 export function delay(time: number) {
   return new Promise(r => setTimeout(r, time));
 }
+
+export function groupByProcessIdAndVersion(instances: ProcessInstance[]) {
+  return instances.reduce<Record<string, ProcessInstance[]>>((acc, item) => {
+    acc[`${item.processId}-${item.version}`] ??= [];
+    acc[`${item.processId}-${item.version}`].push(item);
+    return acc;
+  }, {});
+}
+
+export function getWorkflowRunStats(
+  groupedData: Record<string, ProcessInstance[]>,
+) {
+  return Object.entries(groupedData).map(([processIdVersion, items]) => {
+    const successCount = items.filter(
+      item => item.state === ProcessInstanceState.Completed,
+    ).length;
+    const errorCount = items.filter(
+      item => item.state === ProcessInstanceState.Error,
+    ).length;
+    const runsLastMonth = items.filter(
+      item =>
+        item.start &&
+        new Date(item.start) > new Date(Date.now() - 30 * 24 * 60 * 60 * 1000),
+    );
+    return {
+      processIdVersion,
+      successCount,
+      errorCount,
+      totalCount: successCount + errorCount,
+      successRatio: successCount / (successCount + errorCount),
+      runsLastMonth: runsLastMonth.length,
+    };
+  });
+}