setTriggerWarning({ ...triggerWarning, open })}
- triggerName={triggerWarning.triggerName}
- type={triggerWarning.type}
- />
+ {/* Notifications display */}
+
{/* Trigger list for empty workflows - only show after workflow has loaded and hydrated */}
{isWorkflowReady && isWorkflowEmpty && effectivePermissions.canEdit && }
diff --git a/apps/sim/app/workspace/[workspaceId]/w/components/sidebar/components-new/workspace-header/workspace-header.tsx b/apps/sim/app/workspace/[workspaceId]/w/components/sidebar/components-new/workspace-header/workspace-header.tsx
index b6000160a..2c507da37 100644
--- a/apps/sim/app/workspace/[workspaceId]/w/components/sidebar/components-new/workspace-header/workspace-header.tsx
+++ b/apps/sim/app/workspace/[workspaceId]/w/components/sidebar/components-new/workspace-header/workspace-header.tsx
@@ -1,7 +1,7 @@
'use client'
import { useEffect, useRef, useState } from 'react'
-import { ArrowDown, Plus, RefreshCw } from 'lucide-react'
+import { ArrowDown, Plus } from 'lucide-react'
import {
Badge,
Button,
@@ -173,13 +173,6 @@ export function WorkspaceHeader({
const activeWorkspaceFull = workspaces.find((w) => w.id === workspaceId) || null
- /**
- * Handles page refresh when disconnected
- */
- const handleRefresh = () => {
- window.location.reload()
- }
-
/**
* Handle right-click context menu
*/
@@ -272,23 +265,6 @@ export function WorkspaceHeader({
{/* Workspace Actions */}
- {/* Disconnection Indicator */}
- {userPermissions.isOfflineMode && (
-
-
-
-
- Connection lost - refresh
-
- )}
{/* Invite */}
setIsInviteModalOpen(true)}>
Invite
diff --git a/apps/sim/components/emcn/components/popover/popover.tsx b/apps/sim/components/emcn/components/popover/popover.tsx
index 7d42a0d5f..eb6199370 100644
--- a/apps/sim/components/emcn/components/popover/popover.tsx
+++ b/apps/sim/components/emcn/components/popover/popover.tsx
@@ -51,7 +51,7 @@
import * as React from 'react'
import * as PopoverPrimitive from '@radix-ui/react-popover'
-import { ChevronLeft, ChevronRight, Search } from 'lucide-react'
+import { Check, ChevronLeft, ChevronRight, Search } from 'lucide-react'
import { cn } from '@/lib/utils'
/**
@@ -364,6 +364,11 @@ export interface PopoverItemProps extends React.HTMLAttributes {
* Whether this item is disabled
*/
disabled?: boolean
+ /**
+ * Whether to show a checkmark when active
+ * @default false
+ */
+ showCheck?: boolean
}
/**
@@ -378,7 +383,7 @@ export interface PopoverItemProps extends React.HTMLAttributes {
* ```
*/
const PopoverItem = React.forwardRef(
- ({ className, active, rootOnly, disabled, ...props }, ref) => {
+ ({ className, active, rootOnly, disabled, showCheck = false, children, ...props }, ref) => {
// Try to get context - if not available, we're outside Popover (shouldn't happen)
const context = React.useContext(PopoverContext)
const variant = context?.variant || 'default'
@@ -401,7 +406,10 @@ const PopoverItem = React.forwardRef(
aria-selected={active}
aria-disabled={disabled}
{...props}
- />
+ >
+ {children}
+ {showCheck && active && }
+
)
}
)
diff --git a/apps/sim/stores/notifications/index.ts b/apps/sim/stores/notifications/index.ts
new file mode 100644
index 000000000..3c97363da
--- /dev/null
+++ b/apps/sim/stores/notifications/index.ts
@@ -0,0 +1,7 @@
+export type {
+ AddNotificationParams,
+ Notification,
+ NotificationAction,
+} from './store'
+export { useNotificationStore } from './store'
+export { openCopilotWithMessage } from './utils'
diff --git a/apps/sim/stores/notifications/store.ts b/apps/sim/stores/notifications/store.ts
new file mode 100644
index 000000000..5aec5eb95
--- /dev/null
+++ b/apps/sim/stores/notifications/store.ts
@@ -0,0 +1,155 @@
+import { create } from 'zustand'
+import { persist } from 'zustand/middleware'
+import { createLogger } from '@/lib/logs/console/logger'
+
+const logger = createLogger('NotificationStore')
+
+/**
+ * Notification action configuration
+ * Stores serializable data - handlers are reconstructed at runtime
+ */
+export interface NotificationAction {
+ /**
+ * Action type identifier for handler reconstruction
+ */
+ type: 'copilot' | 'refresh'
+
+ /**
+ * Message or data to pass to the action handler.
+ *
+ * For:
+ * - {@link NotificationAction.type} = `copilot` - message sent to Copilot
+ * - {@link NotificationAction.type} = `refresh` - optional context, not required for the action
+ */
+ message: string
+}
+
+/**
+ * Core notification data structure
+ */
+export interface Notification {
+ /**
+ * Unique identifier for the notification
+ */
+ id: string
+
+ /**
+ * Notification severity level
+ */
+ level: 'info' | 'error'
+
+ /**
+ * Message to display to the user
+ */
+ message: string
+
+ /**
+ * Optional action to execute when user clicks the action button
+ */
+ action?: NotificationAction
+
+ /**
+ * Timestamp when notification was created
+ */
+ createdAt: number
+
+ /**
+ * Optional workflow ID - if provided, notification is workflow-specific
+ * If omitted, notification is shown across all workflows
+ */
+ workflowId?: string
+}
+
+/**
+ * Parameters for adding a new notification
+ * Omits auto-generated fields (id, createdAt)
+ */
+export type AddNotificationParams = Omit
+
+interface NotificationStore {
+ /**
+ * Array of active notifications (newest first)
+ */
+ notifications: Notification[]
+
+ /**
+ * Adds a new notification to the stack
+ *
+ * @param params - Notification parameters
+ * @returns The created notification ID
+ */
+ addNotification: (params: AddNotificationParams) => string
+
+ /**
+ * Removes a notification by ID
+ *
+ * @param id - Notification ID to remove
+ */
+ removeNotification: (id: string) => void
+
+ /**
+ * Gets notifications for a specific workflow
+ * Returns both global notifications (no workflowId) and workflow-specific notifications
+ *
+ * @param workflowId - The workflow ID to filter by
+ * @returns Array of notifications for the workflow
+ */
+ getNotificationsForWorkflow: (workflowId: string) => Notification[]
+}
+
+export const useNotificationStore = create()(
+ persist(
+ (set, get) => ({
+ notifications: [],
+
+ addNotification: (params: AddNotificationParams) => {
+ const id = crypto.randomUUID()
+
+ const notification: Notification = {
+ id,
+ level: params.level,
+ message: params.message,
+ action: params.action,
+ createdAt: Date.now(),
+ workflowId: params.workflowId,
+ }
+
+ set((state) => ({
+ notifications: [notification, ...state.notifications],
+ }))
+
+ logger.info('Notification added', {
+ id,
+ level: params.level,
+ message: params.message,
+ workflowId: params.workflowId,
+ actionType: params.action?.type,
+ })
+
+ return id
+ },
+
+ removeNotification: (id: string) => {
+ set((state) => ({
+ notifications: state.notifications.filter((n) => n.id !== id),
+ }))
+
+ logger.info('Notification removed', { id })
+ },
+
+ getNotificationsForWorkflow: (workflowId: string) => {
+ return get().notifications.filter((n) => !n.workflowId || n.workflowId === workflowId)
+ },
+ }),
+ {
+ name: 'notification-storage',
+ /**
+ * Only persist workflow-level notifications.
+ * Global notifications (without a workflowId) are kept in memory only.
+ */
+ partialize: (state): Pick => ({
+ notifications: state.notifications.filter((notification) => !!notification.workflowId),
+ }),
+ }
+ )
+)
diff --git a/apps/sim/stores/notifications/utils.ts b/apps/sim/stores/notifications/utils.ts
new file mode 100644
index 000000000..1c522e81c
--- /dev/null
+++ b/apps/sim/stores/notifications/utils.ts
@@ -0,0 +1,55 @@
+import { createLogger } from '@/lib/logs/console/logger'
+import { useCopilotStore } from '@/stores/panel-new/copilot/store'
+import { usePanelStore } from '@/stores/panel-new/store'
+
+const logger = createLogger('NotificationUtils')
+
+/**
+ * Opens the copilot panel and directly sends the message.
+ *
+ * @param message - The message to send in the copilot.
+ */
+export function openCopilotWithMessage(message: string): void {
+ try {
+ const trimmedMessage = message.trim()
+
+ // Avoid sending empty/whitespace messages
+ if (!trimmedMessage) {
+ logger.warn('openCopilotWithMessage called with empty message')
+ return
+ }
+
+ // Switch to copilot tab
+ const panelStore = usePanelStore.getState()
+ panelStore.setActiveTab('copilot')
+
+ // Read current copilot state
+ const copilotStore = useCopilotStore.getState()
+
+ // If workflowId is not set, sendMessage will early-return; surface that explicitly
+ if (!copilotStore.workflowId) {
+ logger.warn('Copilot workflowId is not set, skipping sendMessage', {
+ messageLength: trimmedMessage.length,
+ })
+ return
+ }
+
+ // Avoid overlapping sends; let existing stream finish/abort first
+ if (copilotStore.isSendingMessage) {
+ logger.warn('Copilot is already sending a message, skipping new send', {
+ messageLength: trimmedMessage.length,
+ })
+ return
+ }
+
+ const messageWithInstructions = `${trimmedMessage}\n\nPlease fix this.`
+
+ void copilotStore.sendMessage(messageWithInstructions, { stream: true }).catch((error) => {
+ logger.error('Failed to send message to copilot', { error })
+ })
+
+ logger.info('Opened copilot and sent message', { messageLength: trimmedMessage.length })
+ } catch (error) {
+ logger.error('Failed to open copilot with message', { error })
+ }
+}
diff --git a/apps/sim/stores/terminal/console/store.ts b/apps/sim/stores/terminal/console/store.ts
index 36a8a0f39..9d375b348 100644
--- a/apps/sim/stores/terminal/console/store.ts
+++ b/apps/sim/stores/terminal/console/store.ts
@@ -1,10 +1,14 @@
import { create } from 'zustand'
import { devtools, persist } from 'zustand/middleware'
+import { createLogger } from '@/lib/logs/console/logger'
import { redactApiKeys } from '@/lib/utils'
import type { NormalizedBlockOutput } from '@/executor/types'
import { useExecutionStore } from '@/stores/execution/store'
+import { useNotificationStore } from '@/stores/notifications'
import type { ConsoleEntry, ConsoleStore, ConsoleUpdate } from './types'
+const logger = createLogger('TerminalConsoleStore')
+
/**
* Updates a NormalizedBlockOutput with new content
*/
@@ -95,7 +99,31 @@ export const useTerminalConsoleStore = create()(
return { entries: [newEntry, ...state.entries] }
})
- return get().entries[0]
+ const newEntry = get().entries[0]
+
+ // Surface error notifications immediately when error entries are added
+ if (newEntry?.error) {
+ try {
+ const errorMessage = String(newEntry.error)
+
+ useNotificationStore.getState().addNotification({
+ level: 'error',
+ message: errorMessage,
+ workflowId: entry.workflowId,
+ action: {
+ type: 'copilot',
+ message: errorMessage,
+ },
+ })
+ } catch (notificationError) {
+ logger.error('Failed to create block error notification', {
+ entryId: newEntry.id,
+ error: notificationError,
+ })
+ }
+ }
+
+ return newEntry
},
/**
diff --git a/apps/sim/stores/terminal/index.ts b/apps/sim/stores/terminal/index.ts
index f771a5a91..fc88ce281 100644
--- a/apps/sim/stores/terminal/index.ts
+++ b/apps/sim/stores/terminal/index.ts
@@ -1,3 +1,3 @@
export type { ConsoleEntry, ConsoleStore, ConsoleUpdate } from './console'
export { useTerminalConsoleStore } from './console'
-export { DEFAULT_TERMINAL_HEIGHT, useTerminalStore } from './store'
+export { DEFAULT_TERMINAL_HEIGHT, MIN_TERMINAL_HEIGHT, useTerminalStore } from './store'
diff --git a/apps/sim/stores/terminal/store.ts b/apps/sim/stores/terminal/store.ts
index e556a671c..65c99366e 100644
--- a/apps/sim/stores/terminal/store.ts
+++ b/apps/sim/stores/terminal/store.ts
@@ -14,6 +14,8 @@ interface TerminalState {
setTerminalHeight: (height: number) => void
outputPanelWidth: number
setOutputPanelWidth: (width: number) => void
+ openOnRun: boolean
+ setOpenOnRun: (open: boolean) => void
// displayMode: DisplayMode
// setDisplayMode: (mode: DisplayMode) => void
_hasHydrated: boolean
@@ -24,7 +26,7 @@ interface TerminalState {
* Terminal height constraints
* Note: Maximum height is enforced dynamically at 70% of viewport height in the resize hook
*/
-const MIN_TERMINAL_HEIGHT = 30
+export const MIN_TERMINAL_HEIGHT = 30
export const DEFAULT_TERMINAL_HEIGHT = 196
/**
@@ -56,6 +58,10 @@ export const useTerminalStore = create()(
const clampedWidth = Math.max(MIN_OUTPUT_PANEL_WIDTH, width)
set({ outputPanelWidth: clampedWidth })
},
+ openOnRun: true,
+ setOpenOnRun: (open) => {
+ set({ openOnRun: open })
+ },
// displayMode: DEFAULT_DISPLAY_MODE,
// setDisplayMode: (mode) => {
// set({ displayMode: mode })