feat: Scheduled Jobs

frontend/src/components/PrivateRoute/index.jsx

@@ -126,6 +126,25 @@ export function ManagerRoute({ Component }) {
   );
 }
 
+// Allows access only in single user mode — redirects to home in multi-user mode
+export function SingleUserRoute({ Component }) {
+  const { isAuthd, shouldRedirectToOnboarding, multiUserMode } =
+    useIsAuthenticated();
+  if (isAuthd === null) return <FullScreenLoader />;
+
+  if (shouldRedirectToOnboarding) {
+    return <Navigate to={paths.onboarding.home()} />;
+  }
+
+  return isAuthd && !multiUserMode ? (
+    <KeyboardShortcutWrapper>
+      <Component />
+    </KeyboardShortcutWrapper>
+  ) : (
+    <Navigate to={paths.home()} />
+  );
+}
+
 export default function PrivateRoute({ Component }) {
   const { isAuthd, shouldRedirectToOnboarding } = useIsAuthenticated();
   if (isAuthd === null) return <FullScreenLoader />;

frontend/src/components/SettingsSidebar/index.jsx

@@ -395,6 +395,12 @@ const SidebarOptions = ({ user = null, t }) => (
               flex: true,
               roles: ["admin"],
             },
+            {
+              btnText: "Scheduled Jobs",
+              href: paths.settings.scheduledJobs(),
+              flex: true,
+              hidden: !!user,
+            },
             {
               btnText: t("settings.api-keys"),
               href: paths.settings.apiKeys(),

frontend/src/main.jsx

@@ -5,6 +5,7 @@ import App from "@/App.jsx";
 import PrivateRoute, {
   AdminRoute,
   ManagerRoute,
+  SingleUserRoute,
 } from "@/components/PrivateRoute";
 import Login from "@/pages/Login";
 import SimpleSSOPassthrough from "@/pages/Login/SSO/simple";
@@ -381,6 +382,35 @@ const router = createBrowserRouter([
           return { element: <AdminRoute Component={TelegramBotSettings} /> };
         },
       },
+      {
+        path: "/settings/scheduled-jobs",
+        lazy: async () => {
+          const { default: ScheduledJobs } = await import(
+            "@/pages/GeneralSettings/ScheduledJobs"
+          );
+          return { element: <SingleUserRoute Component={ScheduledJobs} /> };
+        },
+      },
+      {
+        path: "/settings/scheduled-jobs/:id/runs",
+        lazy: async () => {
+          const { default: ScheduledJobRuns } = await import(
+            "@/pages/GeneralSettings/ScheduledJobs/RunHistoryPage"
+          );
+          return { element: <SingleUserRoute Component={ScheduledJobRuns} /> };
+        },
+      },
+      {
+        path: "/settings/scheduled-jobs/:id/runs/:runId",
+        lazy: async () => {
+          const { default: ScheduledJobRunDetail } = await import(
+            "@/pages/GeneralSettings/ScheduledJobs/RunDetailPage"
+          );
+          return {
+            element: <SingleUserRoute Component={ScheduledJobRunDetail} />,
+          };
+        },
+      },
       // Catch-all route for 404s
       {
         path: "*",

frontend/src/models/scheduledJobs.js

@@ -0,0 +1,147 @@
+import { API_BASE } from "@/utils/constants";
+import { baseHeaders } from "@/utils/request";
+
+const ScheduledJobs = {
+  list: async function () {
+    return await fetch(`${API_BASE}/scheduled-jobs`, {
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { jobs: [] };
+      });
+  },
+
+  create: async function (data) {
+    return await fetch(`${API_BASE}/scheduled-jobs/new`, {
+      method: "POST",
+      headers: baseHeaders(),
+      body: JSON.stringify(data),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { job: null, error: e.message };
+      });
+  },
+
+  get: async function (id) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}`, {
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { job: null };
+      });
+  },
+
+  update: async function (id, data) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}`, {
+      method: "PUT",
+      headers: baseHeaders(),
+      body: JSON.stringify(data),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { job: null, error: e.message };
+      });
+  },
+
+  delete: async function (id) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}`, {
+      method: "DELETE",
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { success: false };
+      });
+  },
+
+  toggle: async function (id) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}/toggle`, {
+      method: "POST",
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { job: null };
+      });
+  },
+
+  trigger: async function (id) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}/trigger`, {
+      method: "POST",
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { success: false, error: e.message };
+      });
+  },
+
+  runs: async function (id) {
+    return await fetch(`${API_BASE}/scheduled-jobs/${id}/runs`, {
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { runs: [] };
+      });
+  },
+
+  getRun: async function (runId) {
+    return await fetch(`${API_BASE}/scheduled-jobs/runs/${runId}`, {
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { run: null, job: null };
+      });
+  },
+
+  markRunRead: async function (runId) {
+    return await fetch(`${API_BASE}/scheduled-jobs/runs/${runId}/read`, {
+      method: "POST",
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { success: false };
+      });
+  },
+
+  continueInThread: async function (runId) {
+    return await fetch(`${API_BASE}/scheduled-jobs/runs/${runId}/continue`, {
+      method: "POST",
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { workspaceSlug: null, threadSlug: null, error: e.message };
+      });
+  },
+
+  availableTools: async function () {
+    return await fetch(`${API_BASE}/scheduled-jobs/available-tools`, {
+      headers: baseHeaders(),
+    })
+      .then((res) => res.json())
+      .catch((e) => {
+        console.error(e);
+        return { tools: [] };
+      });
+  },
+};
+
+export default ScheduledJobs;