feat: workflow crud

Author: jonathanlab

src/api/posthogClient.ts

@@ -214,4 +214,121 @@ export class PostHogAPIClient {
       repository: repoName,
     }));
   }
+
+  async createWorkflow(data: {
+    name: string;
+    description?: string;
+    color?: string;
+    is_default?: boolean;
+  }) {
+    const teamId = await this.getTeamId();
+    return await this.api.post("/api/projects/{project_id}/workflows/", {
+      path: { project_id: teamId.toString() },
+      body: {
+        name: data.name,
+        description: data.description,
+        color: data.color,
+        is_default: data.is_default ?? false,
+        is_active: true,
+      } as Schemas.TaskWorkflow,
+    });
+  }
+
+  async updateWorkflow(
+    workflowId: string,
+    data: {
+      name?: string;
+      description?: string;
+      color?: string;
+      is_default?: boolean;
+      is_active?: boolean;
+    },
+  ) {
+    const teamId = await this.getTeamId();
+    return await this.api.patch("/api/projects/{project_id}/workflows/{id}/", {
+      path: { project_id: teamId.toString(), id: workflowId },
+      body: data,
+    });
+  }
+
+  async deactivateWorkflow(workflowId: string) {
+    const teamId = await this.getTeamId();
+    return await this.api.post(
+      "/api/projects/{project_id}/workflows/{id}/deactivate/",
+      {
+        path: { project_id: teamId.toString(), id: workflowId },
+      },
+    );
+  }
+
+  async createStage(
+    workflowId: string,
+    data: {
+      name: string;
+      key: string;
+      position: number;
+      color?: string;
+      agent_name?: string | null;
+      is_manual_only?: boolean;
+    },
+  ) {
+    const teamId = await this.getTeamId();
+    return await this.api.post(
+      "/api/projects/{project_id}/workflows/{workflow_id}/stages/",
+      {
+        path: {
+          project_id: teamId.toString(),
+          workflow_id: workflowId,
+        },
+        body: {
+          ...data,
+          workflow: workflowId,
+        } as Schemas.WorkflowStage,
+      },
+    );
+  }
+
+  async updateStage(
+    workflowId: string,
+    stageId: string,
+    data: {
+      name?: string;
+      key?: string;
+      position?: number;
+      color?: string;
+      agent_name?: string | null;
+      is_manual_only?: boolean;
+      is_archived?: boolean;
+    },
+  ) {
+    const teamId = await this.getTeamId();
+    return await this.api.patch(
+      "/api/projects/{project_id}/workflows/{workflow_id}/stages/{id}/",
+      {
+        path: {
+          project_id: teamId.toString(),
+          workflow_id: workflowId,
+          id: stageId,
+        },
+        body: data,
+      },
+    );
+  }
+
+  async getAgents() {
+    const teamId = await this.getTeamId();
+    const url = new URL(`${this.api.baseUrl}/api/projects/${teamId}/agents/`);
+    const response = await this.api.fetcher.fetch({
+      method: "get",
+      url,
+      path: `/api/projects/${teamId}/agents/`,
+    });
+
+    if (!response.ok) {
+      throw new Error(`Failed to fetch agents: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    return data.results ?? data ?? [];
+  }
 }

src/renderer/components/MainLayout.tsx

@@ -10,13 +10,15 @@ import { TabBar } from "./TabBar";
 import { TaskCreate } from "./TaskCreate";
 import { TaskDetail } from "./TaskDetail";
 import { TaskList } from "./TaskList";
+import { WorkflowForm } from "./WorkflowForm";
 import { WorkflowView } from "./WorkflowView";
 
 export function MainLayout() {
   const { activeTabId, tabs, createTab, setActiveTab } = useTabStore();
   const { fetchIntegrations } = useIntegrationStore();
   const [commandMenuOpen, setCommandMenuOpen] = useState(false);
   const [taskCreateOpen, setTaskCreateOpen] = useState(false);
+  const [workflowCreateOpen, setWorkflowCreateOpen] = useState(false);
 
   useEffect(() => {
     fetchIntegrations();
@@ -32,6 +34,7 @@ export function MainLayout() {
     enabled: !commandMenuOpen,
   });
   useHotkeys("mod+n", () => setTaskCreateOpen(true));
+  useHotkeys("mod+shift+n", () => setWorkflowCreateOpen(true));
 
   const handleSelectTask = (task: Task) => {
     // Check if task is already open in a tab
@@ -66,6 +69,7 @@ export function MainLayout() {
           <TaskList
             onSelectTask={handleSelectTask}
             onNewTask={() => setTaskCreateOpen(true)}
+            onNewWorkflow={() => setWorkflowCreateOpen(true)}
           />
         )}
 
@@ -86,6 +90,10 @@ export function MainLayout() {
         onCreateTask={() => setTaskCreateOpen(true)}
       />
       <TaskCreate open={taskCreateOpen} onOpenChange={setTaskCreateOpen} />
+      <WorkflowForm
+        open={workflowCreateOpen}
+        onOpenChange={setWorkflowCreateOpen}
+      />
     </Flex>
   );
 }

src/renderer/components/TaskList.tsx

@@ -24,9 +24,14 @@ interface TaskListProps {
 
 interface TaskListInternalProps extends TaskListProps {
   onNewTask?: () => void;
+  onNewWorkflow?: () => void;
 }
 
-export function TaskList({ onSelectTask, onNewTask }: TaskListInternalProps) {
+export function TaskList({
+  onSelectTask,
+  onNewTask,
+  onNewWorkflow,
+}: TaskListInternalProps) {
   const tasks = useTaskStore((state) => state.tasks);
   const taskOrder = useTaskStore((state) => state.taskOrder);
   const filter = useTaskStore((state) => state.filter);
@@ -386,6 +391,19 @@ export function TaskList({ onSelectTask, onNewTask }: TaskListInternalProps) {
                   ]}
                 />
               </Box>
+              {onNewWorkflow && (
+                <Box onClick={onNewWorkflow}>
+                  <ShortcutCard
+                    icon={<FileTextIcon className="h-4 w-4 text-gray-11" />}
+                    title="New workflow"
+                    keys={[
+                      navigator.platform.includes("Mac") ? "⌘" : "Ctrl",
+                      "⇧",
+                      "N",
+                    ]}
+                  />
+                </Box>
+              )}
             </Flex>
           </Box>
         </Box>