feat: schedule and webhook triggers

backend/pyproject.toml

@@ -21,6 +21,7 @@ dependencies = [
     "nodejs-wheel>=22.18.0",
     "numpy>=1.23.0,<2.0.0",
     "debugpy>=1.8.17",
+    "camel-ai>=0.2.82",
 ]
 
 

electron/main/index.ts

@@ -1255,7 +1255,7 @@ async function createWindow() {
     transparent: true,
     vibrancy: 'sidebar',
     visualEffectState: 'active',
-    backgroundColor: '#f5f5f580',
+    backgroundColor: '#F5F5F5',
     titleBarStyle: isMac ? 'hidden' : undefined,
     trafficLightPosition: isMac ? { x: 10, y: 10 } : undefined,
     icon: path.join(VITE_PUBLIC, 'favicon.ico'),

package.json

@@ -54,6 +54,7 @@
     "@radix-ui/react-toggle-group": "^1.1.10",
     "@radix-ui/react-tooltip": "^1.2.7",
     "@stackframe/react": "file:package/@stackframe/react",
+    "@tanstack/react-query": "^5.90.19",
     "@xterm/addon-fit": "^0.10.0",
     "@xterm/addon-web-links": "^0.11.0",
     "@xterm/xterm": "^5.5.0",
@@ -65,6 +66,7 @@
     "clsx": "^2.1.1",
     "cmdk": "^1.1.1",
     "csv-parser": "^3.2.0",
+    "date-fns": "^3.6.0",
     "dompurify": "^3.2.7",
     "electron-log": "^5.4.0",
     "electron-updater": "^6.3.9",

server/alembic/env.py

@@ -29,6 +29,7 @@
 auto_import("app.model.config")
 auto_import("app.model.chat")
 auto_import("app.model.provider")
+auto_import("app.model.trigger")
 
 
 # target_metadata = mymodel.Base.metadata

src/App.tsx

@@ -6,16 +6,30 @@ import { useNavigate } from "react-router-dom";
 import { AnimationJson } from "@/components/AnimationJson";
 import animationData from "@/assets/animation/openning_animaiton.json";
 import { useAuthStore } from "./store/authStore";
+import { useTriggerStore } from "./store/triggerStore";
+import { useExecutionSubscription } from "./hooks/useExecutionSubscription";
+import { useTriggerTaskExecutor } from "./hooks/useTriggerTaskExecutor";
 import { Toaster } from "sonner";
 import { hasStackKeys } from "./lib";
+import { QueryClientProvider } from "@tanstack/react-query";
+import { queryClient } from "@/lib/queryClient";
 
 const HAS_STACK_KEYS = hasStackKeys();
 
 function App() {
 	const navigate = useNavigate();
 	const { setInitState } = useAuthStore();
 	const [animationFinished, setAnimationFinished] = useState(false);
-	const { isFirstLaunch } = useAuthStore();
+	const { isFirstLaunch, token } = useAuthStore();
+	const { triggers } = useTriggerStore();
+
+	// Subscribe to execution events when user is authenticated
+	// Note: Removed triggers.length check to prevent reconnection on every trigger update
+	const shouldSubscribe = !!token;
+	useExecutionSubscription(shouldSubscribe);
+
+	// Execute triggered tasks automatically when WebSocket events are received
+	useTriggerTaskExecutor();
 
 	useEffect(() => {
 		const handleShareCode = (event: any, share_token: string) => {
@@ -68,20 +82,23 @@ function App() {
 
 	// render wrapper
 	const renderWrapper = (children: React.ReactNode) => {
-		if (HAS_STACK_KEYS) {
-			return (
-				<StackProvider app={stackClientApp}>
-					<StackTheme>{children}</StackTheme>
-					<Toaster style={{ zIndex: '999999 !important', position: "fixed" }} />
-				</StackProvider>
-			);
-		}
-		return (
+		const content = HAS_STACK_KEYS ? (
+			<StackProvider app={stackClientApp}>
+				<StackTheme>{children}</StackTheme>
+				<Toaster style={{ zIndex: '999999 !important', position: "fixed" }} />
+			</StackProvider>
+		) : (
 			<>
 				{children}
 				<Toaster style={{ zIndex: "999999 !important", position: "fixed" }} />
 			</>
 		);
+
+		return (
+			<QueryClientProvider client={queryClient}>
+				{content}
+			</QueryClientProvider>
+		);
 	};
 
 	return renderWrapper(renderMainContent());

src/components/AddWorker/index.tsx

@@ -23,6 +23,8 @@ import { fetchPost } from "@/api/http";
 import { useAuthStore, useWorkerList } from "@/store/authStore";
 import { useTranslation } from "react-i18next";
 import useChatStoreAdapter from "@/hooks/useChatStoreAdapter";
+import { MenuToggleGroup, MenuToggleItem } from "@/components/MenuButton/MenuButton";
+import { TooltipSimple } from "@/components/ui/tooltip";
 
 interface EnvValue {
 	value: string;
@@ -49,12 +51,23 @@ interface McpItem {
 export function AddWorker({
 	edit = false,
 	workerInfo = null,
+	variant = "default",
+	isOpen,
+	onOpenChange,
 }: {
 	edit?: boolean;
 	workerInfo?: Agent | null;
+	variant?: "default" | "icon";
+	isOpen?: boolean;
+	onOpenChange?: (open: boolean) => void;
 }) {
 	const { t } = useTranslation();
-	const [dialogOpen, setDialogOpen] = useState(false);
+	const [internalOpen, setInternalOpen] = useState(false);
+
+	// Use controlled state if provided, otherwise internal state
+	const isControlled = typeof isOpen !== 'undefined' && typeof onOpenChange !== 'undefined';
+	const dialogOpen = isControlled ? isOpen : internalOpen;
+	const setDialogOpen = isControlled ? onOpenChange : setInternalOpen;
 	const { chatStore, projectStore } = useChatStoreAdapter();
 	if (!chatStore) {
 		return <div>Loading...</div>;
@@ -76,7 +89,7 @@ export function AddWorker({
 	const [workerName, setWorkerName] = useState("");
 	const [workerDescription, setWorkerDescription] = useState("");
 	const [selectedTools, setSelectedTools] = useState<McpItem[]>([]);
-	
+
 	// error status management
 	const [nameError, setNameError] = useState<string>("");
 
@@ -242,7 +255,7 @@ export function AddWorker({
 	const handleAddWorker = async () => {
 		// clear previous errors
 		setNameError("");
-		
+
 		if (!workerName) {
 			setNameError(t("workforce.worker-name-cannot-be-empty"));
 			return;
@@ -267,7 +280,7 @@ export function AddWorker({
 		});
 		console.log("mcpLocal.mcpServers", mcpLocal.mcpServers);
 		if (mcpLocal.mcpServers && typeof mcpLocal.mcpServers === 'object') {
-			for(const key of Object.keys(mcpLocal.mcpServers)) {
+			for (const key of Object.keys(mcpLocal.mcpServers)) {
 				if (!mcpList.includes(key)) {
 					delete mcpLocal.mcpServers[key];
 				}
@@ -357,32 +370,46 @@ export function AddWorker({
 	return (
 		<Dialog open={dialogOpen} onOpenChange={setDialogOpen}>
 			<form>
-				<DialogTrigger asChild>
-					{edit ? (
-						<Button
-							variant="ghost"
-							size="sm"
-							className="w-full"
-							onClick={(e) => {
-								e.stopPropagation();
-								setDialogOpen(true);
-								setWorkerName(workerInfo?.workerInfo?.name || "");
-								setWorkerDescription(workerInfo?.workerInfo?.description || "");
-								setSelectedTools(workerInfo?.workerInfo?.selectedTools || []);
-							}}
-						>
-							<Edit size={16} />
-							{t("workforce.edit")}
-						</Button>
-					) : (
-						<Button onClick={() => setDialogOpen(true)} variant="ghost">
-							<Plus className="w-6 h-6 text-icon-primary" />
-							<span className="text-text-body text-[13px] leading-13 font-bold">
-								{t("workforce.new-worker")}
-							</span>
-						</Button>
-					)}
-				</DialogTrigger>
+				{!isControlled && (
+					<DialogTrigger asChild>
+						{edit ? (
+							<Button
+								variant="ghost"
+								size="sm"
+								className="w-full"
+								onClick={(e) => {
+									e.stopPropagation();
+									setDialogOpen(true);
+									setWorkerName(workerInfo?.workerInfo?.name || "");
+									setWorkerDescription(workerInfo?.workerInfo?.description || "");
+									setSelectedTools(workerInfo?.workerInfo?.selectedTools || []);
+								}}
+							>
+								<Edit size={16} />
+								{t("workforce.edit")}
+							</Button>
+						) : variant === "icon" ? (
+							<Button
+								variant="ghost"
+								size="icon"
+								className="h-6 w-6 rounded-full bg-surface-tertiary hover:bg-surface-tertiary-hover"
+								onClick={() => setDialogOpen(true)}
+							>
+								<Plus size={12} />
+							</Button>
+						) : (
+							<MenuToggleGroup type="single" value="add-worker">
+								<MenuToggleItem
+									value="add-worker"
+									variant="clear"
+									size="md"
+									icon={<Plus />}
+									onClick={() => setDialogOpen(true)}
+								/>
+							</MenuToggleGroup>
+						)}
+					</DialogTrigger>
+				)}
 				<DialogContent
 					size="sm"
 					className="p-0 gap-0"
@@ -460,7 +487,7 @@ export function AddWorker({
 									))}
 								</div>
 							</DialogContentSection>
-							<DialogFooter 
+							<DialogFooter
 								className="bg-white-100% !rounded-b-xl p-md"
 								showCancelButton={true}
 								showConfirmButton={true}
@@ -489,7 +516,7 @@ export function AddWorker({
 								<div className="flex flex-col gap-4">
 									<div className="flex items-center gap-sm">
 										<div className="flex w-16 h-16 items-center justify-center">
-										<Bot size={32} className="text-icon-primary" />
+											<Bot size={32} className="text-icon-primary" />
 										</div>
 										<Input
 											size="sm"
@@ -509,12 +536,12 @@ export function AddWorker({
 								</div>
 
 								<Textarea
-									  variant="enhanced"
-										size="sm"
-										title={t("workforce.description-optional")}
-										placeholder={t("layout.im-an-agent-specially-designed-for")}
-										value={workerDescription}
-										onChange={(e) => setWorkerDescription(e.target.value)}
+									variant="enhanced"
+									size="sm"
+									title={t("workforce.description-optional")}
+									placeholder={t("layout.im-an-agent-specially-designed-for")}
+									value={workerDescription}
+									onChange={(e) => setWorkerDescription(e.target.value)}
 								/>
 
 								<ToolSelect
@@ -524,7 +551,7 @@ export function AddWorker({
 									ref={toolSelectRef}
 								/>
 							</DialogContentSection>
-							<DialogFooter 
+							<DialogFooter
 								className="bg-white-100% !rounded-b-xl p-md"
 								showCancelButton={true}
 								showConfirmButton={true}

src/components/BottomBar/index.tsx

@@ -1,9 +1,50 @@
 import { WorkSpaceMenu } from "@/components/WorkSpaceMenu";
+import { MenuToggleGroup, MenuToggleItem } from "@/components/MenuButton/MenuButton";
+import { Inbox } from "lucide-react";
+import { TooltipSimple } from "@/components/ui/tooltip";
+import useChatStoreAdapter from "@/hooks/useChatStoreAdapter";
+import { useTranslation } from "react-i18next";
+
+interface BottomBarProps {
+	onToggleChatBox?: () => void;
+	isChatBoxVisible?: boolean;
+}
+
+// Red dot notification indicator
+const RedDotIcon = () => (
+	<div className="w-2 h-2 bg-red-500 rounded-full shrink-0" />
+);
+
+function BottomBar({ onToggleChatBox, isChatBoxVisible }: BottomBarProps) {
+	const { t } = useTranslation();
+	const { chatStore } = useChatStoreAdapter();
+
+	// Check if there are new files
+	const nuwFileNum = chatStore?.activeTaskId
+		? (chatStore.tasks[chatStore.activeTaskId]?.nuwFileNum || 0)
+		: 0;
+	const hasNewFiles = nuwFileNum > 0;
+
+	// Handle inbox click and reset notification
+	const handleInboxClick = () => {
+		if (chatStore?.activeTaskId) {
+			// Reset the new file counter when user views inbox
+			chatStore.setNuwFileNum(chatStore.activeTaskId, 0);
+			// Set active workspace to inbox
+			chatStore.setActiveWorkSpace(chatStore.activeTaskId, "inbox");
+		}
+	};
+
+	const activeWorkspace = chatStore?.activeTaskId
+		? chatStore.tasks[chatStore.activeTaskId]?.activeWorkSpace
+		: null;
 
-function BottomBar() {
 	return (
-		<div className="flex h-12 items-center justify-center pb-2 z-50 relative">
-			<WorkSpaceMenu />
+		<div className="flex h-12 items-center justify-center z-50 relative pt-2">
+			<WorkSpaceMenu
+				onToggleChatBox={onToggleChatBox}
+				isChatBoxVisible={isChatBoxVisible}
+			/>
 		</div>
 	);
 }