Added useHasApiTrigger hook to determine if workflows were triggered from the API

Author: iampearceman

apps/dashboard/src/components/workflow-editor/workflow-checklist.tsx

@@ -11,6 +11,7 @@ import {
 import { useNavigate } from 'react-router-dom';
 import { useEnvironment, useFetchEnvironments } from '@/context/environment/hooks';
 import { useFetchIntegrations } from '@/hooks/use-fetch-integrations';
+import { useHasApiTrigger } from '@/hooks/use-has-api-trigger';
 import { useTelemetry } from '@/hooks/use-telemetry';
 import { StepTypeEnum } from '@/utils/enums';
 import { buildRoute, ROUTES } from '@/utils/routes';
@@ -193,6 +194,10 @@ function useChecklistItems(steps: Step[]) {
   const { workflow } = useWorkflow();
   const { integrations } = useFetchIntegrations();
   const telemetry = useTelemetry();
+  const triggeredFromApi = useHasApiTrigger({
+    workflowId: workflow?._id,
+    lastTriggeredAt: workflow?.lastTriggeredAt,
+  });
 
   const foundInAppIntegration = integrations?.find(
     (integration) =>
@@ -257,7 +262,7 @@ function useChecklistItems(steps: Step[]) {
         key: 'trigger',
         title: 'Trigger workflow from your application',
         description: 'Trigger the workflow to test it in production',
-        isCompleted: () => !!workflow?.lastTriggeredAt,
+        isCompleted: () => !!workflow?.lastTriggeredAt && triggeredFromApi,
         onClick: () => {
           telemetry(TelemetryEvent.WORKFLOW_CHECKLIST_STEP_CLICKED, { stepTitle: 'Trigger workflow' });
           navigate(
@@ -273,7 +278,7 @@ function useChecklistItems(steps: Step[]) {
         },
       },
     ],
-    [currentEnvironment, workflow, foundInAppIntegration, navigate, steps, telemetry]
+    [currentEnvironment, workflow, foundInAppIntegration, navigate, steps, telemetry, triggeredFromApi]
   );
 }
 

apps/dashboard/src/components/workflow-row.tsx

@@ -13,7 +13,6 @@ import { FaCode } from 'react-icons/fa6';
 import { LuBookUp2 } from 'react-icons/lu';
 import {
   RiDeleteBin2Line,
-  RiErrorWarningLine,
   RiFlashlightLine,
   RiMore2Fill,
   RiPauseCircleLine,
@@ -49,6 +48,7 @@ import { useAuth } from '@/context/auth/hooks';
 import { useEnvironment, useFetchEnvironments } from '@/context/environment/hooks';
 import { useDeleteWorkflow } from '@/hooks/use-delete-workflow';
 import { useFeatureFlag } from '@/hooks/use-feature-flag';
+import { useHasApiTrigger } from '@/hooks/use-has-api-trigger';
 import { useHasPermission } from '@/hooks/use-has-permission';
 import { usePatchWorkflow } from '@/hooks/use-patch-workflow';
 import { useSyncWorkflow } from '@/hooks/use-sync-workflow';
@@ -120,6 +120,10 @@ export const WorkflowRow = ({ workflow }: WorkflowRowProps) => {
   const navigate = useNavigate();
   const { safeSync, PromoteConfirmModal } = useSyncWorkflow(workflow);
   const isHttpLogsPageEnabled = useFeatureFlag(FeatureFlagsKeysEnum.IS_HTTP_LOGS_PAGE_ENABLED, false);
+  const triggeredFromApi = useHasApiTrigger({
+    workflowId: workflow._id,
+    lastTriggeredAt: workflow.lastTriggeredAt,
+  });
   const isV0Workflow = workflow.origin === ResourceOriginEnum.NOVU_CLOUD_V1;
   const isDuplicable =
     workflow.origin === ResourceOriginEnum.NOVU_CLOUD && currentEnvironment?.type === EnvironmentTypeEnum.DEV;
@@ -355,7 +359,7 @@ export const WorkflowRow = ({ workflow }: WorkflowRowProps) => {
         </WorkflowLinkTableCell>
 
         <WorkflowLinkTableCell className="text-foreground-600 text-sm font-medium">
-          {workflow.lastTriggeredAt ? (
+          {workflow.lastTriggeredAt && triggeredFromApi ? (
             <TimeDisplayHoverCard date={new Date(workflow.lastTriggeredAt)}>
               {formatDateSimple(workflow.lastTriggeredAt)}
             </TimeDisplayHoverCard>
@@ -369,9 +373,8 @@ export const WorkflowRow = ({ workflow }: WorkflowRowProps) => {
                     return url.pathname + url.search;
                   })()}
                   reloadDocument={isV0Workflow}
-                  className="text-warning-base flex items-center gap-1 text-xs font-medium hover:underline"
+                  className="text-foreground-600 text-sm font-medium hover:underline"
                 >
-                  <RiErrorWarningLine className="size-3.5" />
                   Never triggered
                 </Link>
               </TooltipTrigger>

apps/dashboard/src/hooks/use-has-api-trigger.ts

@@ -0,0 +1,84 @@
+import { FeatureFlagsKeysEnum } from '@novu/shared';
+import { useQuery } from '@tanstack/react-query';
+import { getWorkflowRunsList } from '@/api/activity';
+import { useEnvironment } from '@/context/environment/hooks';
+import { useFeatureFlag } from '@/hooks/use-feature-flag';
+import { QueryKeys } from '@/utils/query-keys';
+
+const STORAGE_KEY = 'novu_api_trigger_';
+
+function getCacheKey(environmentId: string, workflowId: string): string {
+  return `${STORAGE_KEY}${environmentId}_${workflowId}`;
+}
+
+function getCachedApiTrigger(environmentId: string, workflowId: string): boolean | null {
+  try {
+    const cached = localStorage.getItem(getCacheKey(environmentId, workflowId));
+    return cached === 'true' ? true : null;
+  } catch {
+    return null;
+  }
+}
+
+function cacheApiTrigger(environmentId: string, workflowId: string): void {
+  try {
+    localStorage.setItem(getCacheKey(environmentId, workflowId), 'true');
+  } catch {
+    // Silently fail
+  }
+}
+
+function hasApiTrigger(runs: Array<{ payload?: Record<string, unknown> }>): boolean {
+  return runs.some((run) => {
+    const source = run.payload?.__source;
+    return !source || source !== 'dashboard';
+  });
+}
+
+type UseHasApiTriggerOptions = {
+  workflowId?: string;
+  lastTriggeredAt?: string;
+};
+
+export function useHasApiTrigger({ workflowId, lastTriggeredAt }: UseHasApiTriggerOptions) {
+  const { currentEnvironment } = useEnvironment();
+  const isWorkflowRunsEnabled = useFeatureFlag(FeatureFlagsKeysEnum.IS_WORKFLOW_RUN_PAGE_MIGRATION_ENABLED);
+
+  const { data: triggeredFromApi = false } = useQuery({
+    queryKey: [QueryKeys.hasApiTrigger, currentEnvironment?._id, workflowId],
+    queryFn: async ({ signal }) => {
+      if (!currentEnvironment?._id || !workflowId || !lastTriggeredAt) {
+        return false;
+      }
+
+      const cached = getCachedApiTrigger(currentEnvironment._id, workflowId);
+      if (cached) return true;
+
+      try {
+        const { data: runs } = await getWorkflowRunsList({
+          environment: currentEnvironment,
+          limit: 50,
+          filters: { workflows: [workflowId] },
+          signal,
+        });
+
+        if (!runs?.length) return false;
+
+        const isApiTriggered = hasApiTrigger(runs);
+        if (isApiTriggered) {
+          cacheApiTrigger(currentEnvironment._id, workflowId);
+        }
+
+        return isApiTriggered;
+      } catch {
+        return false;
+      }
+    },
+    enabled: isWorkflowRunsEnabled && !!currentEnvironment?._id && !!workflowId && !!lastTriggeredAt,
+    staleTime: 60_000,
+    gcTime: 300_000,
+    retry: false,
+  });
+
+  return triggeredFromApi;
+}

apps/dashboard/src/utils/query-keys.ts

@@ -12,6 +12,7 @@ export const QueryKeys = Object.freeze({
   fetchActivities: 'fetchActivities',
   fetchMostRecentWorkflowRun: 'fetchMostRecentWorkflowRun',
   fetchWorkflowRunsCount: 'fetchWorkflowRunsCount',
+  hasApiTrigger: 'hasApiTrigger',
   fetchSubscribers: 'fetchSubscribers',
   fetchSubscriber: 'fetchSubscriber',
   fetchSubscriberPreferences: 'fetchSubscriberPreferences',