Add Aurora Actions — user-defined background automations

client/src/app/api/actions/[id]/route.ts

@@ -0,0 +1,17 @@
+import { NextRequest } from 'next/server';
+import { forwardRequest } from '@/lib/backend-proxy';
+
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+  const { id } = await params;
+  return forwardRequest(request, 'GET', `/api/actions/${id}`, 'action-detail');
+}
+
+export async function PUT(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+  const { id } = await params;
+  return forwardRequest(request, 'PUT', `/api/actions/${id}`, 'action-update');
+}
+
+export async function DELETE(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+  const { id } = await params;
+  return forwardRequest(request, 'DELETE', `/api/actions/${id}`, 'action-delete');
+}

client/src/app/api/actions/[id]/run/route.ts

@@ -0,0 +1,7 @@
+import { NextRequest } from 'next/server';
+import { forwardRequest } from '@/lib/backend-proxy';
+
+export async function POST(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+  const { id } = await params;
+  return forwardRequest(request, 'POST', `/api/actions/${id}/trigger`, 'action-trigger');
+}

client/src/app/api/actions/[id]/runs/route.ts

@@ -0,0 +1,7 @@
+import { NextRequest } from 'next/server';
+import { forwardRequest } from '@/lib/backend-proxy';
+
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+  const { id } = await params;
+  return forwardRequest(request, 'GET', `/api/actions/${id}/runs`, 'action-runs');
+}

client/src/app/api/actions/route.ts

@@ -0,0 +1,10 @@
+import { NextRequest } from 'next/server';
+import { forwardRequest } from '@/lib/backend-proxy';
+
+export async function GET(request: NextRequest) {
+  return forwardRequest(request, 'GET', '/api/actions', 'actions-list');
+}
+
+export async function POST(request: NextRequest) {
+  return forwardRequest(request, 'POST', '/api/actions', 'actions-create');
+}

client/src/app/chat/components/ChatClient.tsx

@@ -31,6 +31,7 @@ import { useChatCancellation } from '@/hooks/useChatCancellation';
 import SessionUsagePanel from "@/components/SessionUsagePanel";
 import { useSessionUsage } from '@/hooks/useSessionUsage';
 import { useChatSendHandlers } from "./useChatSendHandlers";
+import { useQuery } from "@/lib/query";
 
 interface ChatClientProps {
   initialSessionId?: string;
@@ -68,6 +69,8 @@ export default function ChatClient({ initialSessionId, shouldStartNewChat, initi
   const lastLoadedSessionRef = useRef<string | null>(null);
   const initialMessageSentRef = useRef<boolean>(false);
   const [activeIncidentContext, setActiveIncidentContext] = useState<string | undefined>(incidentContext);
+  const [selectedAction, setSelectedAction] = useState<{ id: string; name: string } | null>(null);
+  const clearSelectedAction = useCallback(() => setSelectedAction(null), []);
 
 
   // Modular streaming message handling
@@ -117,6 +120,17 @@ export default function ChatClient({ initialSessionId, shouldStartNewChat, initi
     router.push('/chat');
   }, [router]);
 
+  const { data: actionsData } = useQuery<{ id: string; name: string }[] | { actions: { id: string; name: string }[] }>(
+    '/api/actions',
+    async (key: string, signal: AbortSignal) => {
+      const res = await fetch(key, { credentials: 'include', signal });
+      if (!res.ok) return { actions: [] };
+      return res.json();
+    },
+    { staleTime: 60_000, revalidateOnEvents: ['actionsStateChanged'] },
+  );
+  const availableActions = Array.isArray(actionsData) ? actionsData : (actionsData?.actions ?? []);
+
   const {
     selectedModel,
     setSelectedModel,
@@ -140,6 +154,9 @@ export default function ChatClient({ initialSessionId, shouldStartNewChat, initi
     justCreatedSessionRef,
     onSessionCreated: refreshChatHistory,
     images,
+    availableActions,
+    selectedAction,
+    clearSelectedAction,
   });
 
   const onSendingStateChange = useCallback((sending: boolean) => {
@@ -470,6 +487,9 @@ export default function ChatClient({ initialSessionId, shouldStartNewChat, initi
               onRemoveContext={() => setActiveIncidentContext(undefined)}
               images={images}
               onImagesChange={setImages}
+              actions={availableActions}
+              selectedAction={selectedAction}
+              onActionSelect={setSelectedAction}
             />
             )}
           </div>
@@ -510,6 +530,9 @@ export default function ChatClient({ initialSessionId, shouldStartNewChat, initi
             onRemoveContext={() => setActiveIncidentContext(undefined)}
             images={images}
             onImagesChange={setImages}
+            actions={availableActions}
+            selectedAction={selectedAction}
+            onActionSelect={setSelectedAction}
           />
 
           <div className="w-full max-w-3xl mt-6">

client/src/app/chat/components/useChatSendHandlers.ts

@@ -24,6 +24,9 @@ interface ChatSendHandlerParams {
   justCreatedSessionRef: MutableRefObject<string | null>;
   onSessionCreated?: (sessionId: string) => void;
   images?: Array<{file: File, preview: string}>;
+  availableActions?: { id: string; name: string }[];
+  selectedAction?: { id: string; name: string } | null;
+  clearSelectedAction?: () => void;
 }
 
 interface ChatSendHandlerResult {
@@ -61,6 +64,9 @@ export function useChatSendHandlers({
   justCreatedSessionRef,
   onSessionCreated,
   images = [],
+  availableActions = [],
+  selectedAction = null,
+  clearSelectedAction,
 }: ChatSendHandlerParams): ChatSendHandlerResult {
   const { toast } = useToast();
   const { providerIds, isProviderConnected } = useConnectedAccounts();
@@ -152,6 +158,40 @@ export function useChatSendHandlers({
     };
   }, [selectedMode, syncProvidersWithMode]);
 
+  // Extract action from text input (fallback when no chip-selected action)
+  const parseActionFromText = useCallback((text: string) => {
+    const lower = text.toLowerCase();
+    let prefix: string | null = null;
+    if (lower.startsWith('/actions ')) prefix = '/actions ';
+    else if (lower.startsWith('/action ')) prefix = '/action ';
+    if (!prefix) return null;
+    const name = text.slice(prefix.length).trim();
+    if (!name) return null;
+    return availableActions.find(a => a.name.toLowerCase() === name.toLowerCase()) || { id: '', name };
+  }, [availableActions]);
+
+  // Ensure a chat session exists, creating one if needed
+  const ensureSession = useCallback(async (title: string): Promise<string | undefined> => {
+    if (hasCreatedSession) return currentSessionId;
+    try {
+      const sessionTitle = title.length > 50 ? title.substring(0, 50).trimEnd() + '...' : title;
+      const newSessionId = await createSession(sessionTitle);
+      if (newSessionId) {
+        onSessionCreated?.(newSessionId);
+        setCurrentSessionId(newSessionId);
+        setHasCreatedSession(true);
+        justCreatedSessionRef.current = newSessionId;
+        startTransition(() => {
+          router.replace(`/chat?sessionId=${newSessionId}`);
+        });
+        return newSessionId;
+      }
+    } catch (error) {
+      console.error('Error creating session:', error);
+    }
+    return currentSessionId;
+  }, [createSession, currentSessionId, hasCreatedSession, justCreatedSessionRef, onSessionCreated, router, setCurrentSessionId, setHasCreatedSession]);
+
   const sendMessage = useCallback(async (
     messageText: string,
     socket: ChatWebSocket,
@@ -160,18 +200,51 @@ export function useChatSendHandlers({
     options?: { triggerRca?: boolean },
   ) => {
     const trimmed = messageText.trim();
-    if (!trimmed || isSending || !userId) return false;
+    if ((!trimmed && !selectedAction) || isSending || !userId) return false;
+
+    // Action trigger: chip-selected action takes priority, text fallback second
+    const actionToTrigger = selectedAction || parseActionFromText(trimmed);
+
+    if (actionToTrigger) {
+      if (!actionToTrigger.id) {
+        toast({ description: `Action "${actionToTrigger.name}" not found. Type /action to see suggestions.`, variant: 'destructive' });
+        return false;
+      }
+      if (!socket.isReady) {
+        toast({ description: 'Connection not ready. Please wait and try again.', variant: 'destructive' });
+        return false;
+      }
+
+      setIsSending(true);
+      const displayText = trimmed || `Run action: ${actionToTrigger.name}`;
+      onNewMessage({ id: Date.now(), sender: 'user', text: displayText });
+      const actualSessionId = await ensureSession(displayText);
+
+      socket.send({
+        type: 'message',
+        query: displayText,
+        user_id: userId,
+        session_id: actualSessionId || undefined,
+        model: selectedModel,
+        mode: 'agent',
+        trigger_action: actionToTrigger.id,
+      });
+      clearSelectedAction?.();
+      return true;
+    }
+
+    const bareCmd = trimmed.toLowerCase();
+    if (bareCmd === '/action' || bareCmd === '/actions') {
+      toast({ description: 'Usage: /action <name>. Type /action and see suggestions.' });
+      return false;
+    }
 
     const effectiveMode = normalizeMode(modeOverride || selectedMode);
-    const connectedProviders = getConnectedProviders();
     const providersForMode = providersOverride ?? selectedProviders;
     const finalProviders = syncProvidersWithMode(effectiveMode, providersForMode);
 
     if (!socket.isReady) {
-      toast({
-        description: "Connection not ready. Please wait a moment and try again.",
-        variant: "destructive"
-      });
+      toast({ description: "Connection not ready. Please wait a moment and try again.", variant: "destructive" });
       return false;
     }
 
@@ -189,34 +262,13 @@ export function useChatSendHandlers({
       })) : undefined
     };
 
-    let actualSessionId = currentSessionId;
-    if (!hasCreatedSession) {
-      try {
-        const title = trimmed.length > 50 ? trimmed.substring(0, 50).trimEnd() + '...' : trimmed;
-        const newSessionId = await createSession(title);
-        if (newSessionId) {
-          actualSessionId = newSessionId;
-          onSessionCreated?.(newSessionId);
-
-          setCurrentSessionId(newSessionId);
-          setHasCreatedSession(true);
-          justCreatedSessionRef.current = newSessionId;
-
-          startTransition(() => {
-            router.replace(`/chat?sessionId=${newSessionId}`);
-          });
-        }
-      } catch (error) {
-        console.error('Error creating session:', error);
-      }
-    }
-
+    const actualSessionId = await ensureSession(trimmed);
     onNewMessage(userMessage);
 
     // Convert images to attachments
     const attachments = await Promise.all(
       images.map(async (img) => {
-        const base64 = img.preview.split(',')[1]; // Remove data URL prefix
+        const base64 = img.preview.split(',')[1];
         return {
           file_type: img.file.type,
           file_data: base64,
@@ -244,15 +296,14 @@ export function useChatSendHandlers({
 
     return true;
   }, [
-    createSession, currentSessionId, hasCreatedSession, justCreatedSessionRef,
-    onNewMessage, router, selectedMode, selectedModel, selectedProviders,
-    syncProvidersWithMode, toast, userId, setCurrentSessionId, 
-    setHasCreatedSession, isSending, getConnectedProviders, images
+    ensureSession, parseActionFromText, onNewMessage, selectedMode, selectedModel,
+    selectedProviders, syncProvidersWithMode, toast, userId, isSending,
+    images, selectedAction, clearSelectedAction
   ]);
 
   const initiateSend = useCallback(async (messageText: string, socket: ChatWebSocket, modeOverride?: string, options?: { triggerRca?: boolean }) => {
     const trimmed = messageText.trim();
-    if (!trimmed) return false;
+    if (!trimmed && !selectedAction) return false;
 
     const targetMode = modeOverride || selectedMode;
     // Show warning if no providers connected
@@ -265,7 +316,7 @@ export function useChatSendHandlers({
 
     // Let sendMessage handle provider enforcement and normalization
     return await sendMessage(messageText, socket, targetMode, undefined, options);
-  }, [anyProviderConnected, selectedMode, sendMessage, toast]);
+  }, [anyProviderConnected, selectedMode, sendMessage, toast, selectedAction]);
 
   const handleSend = useCallback(async (messageText: string, socket: ChatWebSocket, overrideMode?: string, options?: { triggerRca?: boolean }) => {
     return await initiateSend(messageText, socket, overrideMode, options);