Feature/copilot trigger creation (#274)

* feat: Add Copilot trigger creation support

- Add support for One-Time and Recurring triggers in Copilot
- Extend CopilotAssistantMessageActionPart schema with trigger config types
- Update Copilot instructions with trigger creation examples and guidelines
- Implement trigger action handling in messages.tsx component
- Add trigger icons (⏰ for one-time, 🔄 for recurring) in action cards
- Update workflow reducer to handle trigger creation via existing APIs
- Fix action parser to recognize trigger config types in comment format
- Add async trigger processing using createScheduledJobRule and createRecurringJobRule APIs

Users can now ask Copilot to create triggers with natural language requests like:
'Create a daily report trigger at 9 AM' or 'Set up a one-time reminder for next Friday'

* feat: Enhance Copilot message handling and trigger actions

- Pass projectId to Messages and AssistantMessage components for better context
- Refactor applyAction to handle one-time and recurring triggers with improved error handling
- Update handleApplyAll and handleSingleApply to support async action processing
- Remove deprecated pending trigger logic from workflow editor

This update improves the Copilot's ability to manage triggers and enhances the overall message processing flow.

* refactor: route trigger actions via copilot helper

Keep workflow reducer synchronous by removing trigger jobs from the switch and moving job rule API calls into a dedicated helper in messages.tsx. Cache dynamic imports and guard types so Copilot Apply/Apply All handle trigger creation without touching reducer state.

* feat: Add current time to the copilot context

* added conext of triggers to the copilot along with being able to edit and delete triggers

* bug fix for deleting composio triggers

* Add the edit function that allows editing triggers and lets copilot edit triggers too without losing previous jobs
feat: Add update functionality for recurring and scheduled job rules

- Implemented update actions for recurring job rules and scheduled job rules, allowing users to modify existing rules with new input and scheduling configurations.
- Enhanced the UI components to support editing of job rules, including forms for both creating and updating rules.
- Updated the repository interfaces and MongoDB implementations to handle the new update operations for job rules.

This update improves the flexibility of managing job rules within the application.

* Add trigger context to copilot
feat: Enhance trigger management in Copilot

- Added functionality to search for relevant external triggers using the new `search_relevant_triggers` tool, allowing users to discover available triggers based on toolkit slugs and optional query keywords.
- Updated the Copilot context to include detailed descriptions of various external trigger toolkits, enhancing user guidance for trigger creation.
- Improved the overall trigger handling process, ensuring that users can effectively integrate external triggers into their workflows.

This update significantly enhances the Copilot's capabilities in managing and utilizing external triggers.

* Let copilot add external triggers
feat: Enhance external trigger handling in Copilot

- Added support for flexible schemas in external triggers, allowing configuration changes without stripping any data.
- Introduced a new `onRequestTriggerSetup` callback in the Action component to facilitate trigger setup requests.
- Implemented a modal for trigger configuration, improving user experience when setting up external triggers.
- Updated the ComposioTriggerTypesPanel to auto-select trigger types based on initial configuration.

This update significantly improves the management and setup of external triggers within the Copilot interface.

* External trigger cant be edited so we delete and recreate for this
feat: Improve external trigger handling in Copilot

- Added validation for editing external triggers, ensuring users are informed that existing triggers must be deleted and recreated for changes.
- Updated documentation to clarify the limitations of external trigger modifications.

This update enhances user experience by providing clear guidance on managing external triggers within the Copilot interface.

* preventing message.tsx from ballooning up in size
feat: Refactor Copilot message handling and trigger actions

- Removed deprecated logic for loading scheduled and recurring job actions, streamlining the trigger action process.
- Integrated `useCopilotTriggerActions` hook to manage trigger setup and actions more efficiently.
- Enhanced parsing of action parts to improve handling of triggers and their configurations.
- Updated the UI to reflect changes in action handling, ensuring a smoother user experience.

This update optimizes the Copilot's ability to manage triggers and enhances the overall message processing flow.

* refactor: Simplify trigger filtering in Copilot

- Removed unnecessary filtering logic for triggers based on user queries, streamlining the search process.
- Updated response messages to clarify the context of displayed triggers, enhancing user understanding.

This update improves the efficiency of the trigger search functionality within the Copilot interface.

* Revert "refactor: Simplify trigger filtering in Copilot"

This reverts commit b3d0416.

* simplify the filtering logic for triggers in copilot
feat: Enhance external trigger creation and search functionality in Copilot

- Introduced a critical flow for adding external triggers, emphasizing minimal user input and UI configuration.
- Updated documentation to clarify the external trigger creation process and provided examples for better guidance.
- Simplified the trigger search logic, ensuring users receive relevant results while maintaining clarity in response messages.

This update improves the user experience by streamlining external trigger management and enhancing the search capabilities within the Copilot interface.

---------

Co-authored-by: tusharmagar <[email protected]>

Author: ramnique

apps/rowboat/app/actions/composio.actions.ts

@@ -157,6 +157,7 @@ export async function createComposioTriggerDeployment(request: {
 export async function listComposioTriggerDeployments(request: {
     projectId: string,
     cursor?: string,
+    limit?: number,
 }) {
     const user = await authCheck();
 
@@ -166,6 +167,7 @@ export async function listComposioTriggerDeployments(request: {
         userId: user.id,
         projectId: request.projectId,
         cursor: request.cursor,
+        limit: request.limit,
     });
 }
 
@@ -191,4 +193,4 @@ export async function fetchComposioTriggerDeployment(request: { deploymentId: st
         userId: user.id,
         deploymentId: request.deploymentId,
     });
-}
+}

apps/rowboat/app/actions/copilot.actions.ts

@@ -3,6 +3,7 @@ import {
     CopilotAPIRequest,
     CopilotChatContext, CopilotMessage,
     DataSourceSchemaForCopilot,
+    TriggerSchemaForCopilot,
 } from "../../src/entities/models/copilot";
 import { 
     Workflow} from "../lib/types/workflow_types";
@@ -26,7 +27,8 @@ export async function getCopilotResponseStream(
     messages: z.infer<typeof CopilotMessage>[],
     current_workflow_config: z.infer<typeof Workflow>,
     context: z.infer<typeof CopilotChatContext> | null,
-    dataSources?: z.infer<typeof DataSourceSchemaForCopilot>[]
+    dataSources?: z.infer<typeof DataSourceSchemaForCopilot>[],
+    triggers?: z.infer<typeof TriggerSchemaForCopilot>[]
 ): Promise<{
     streamId: string;
 } | { billingError: string }> {
@@ -42,6 +44,7 @@ export async function getCopilotResponseStream(
                 workflow: current_workflow_config,
                 context,
                 dataSources,
+                triggers,
             }
         });
         return {

apps/rowboat/app/actions/recurring-job-rules.actions.ts

@@ -6,6 +6,7 @@ import { IListRecurringJobRulesController } from "@/src/interface-adapters/contr
 import { IFetchRecurringJobRuleController } from "@/src/interface-adapters/controllers/recurring-job-rules/fetch-recurring-job-rule.controller";
 import { IToggleRecurringJobRuleController } from "@/src/interface-adapters/controllers/recurring-job-rules/toggle-recurring-job-rule.controller";
 import { IDeleteRecurringJobRuleController } from "@/src/interface-adapters/controllers/recurring-job-rules/delete-recurring-job-rule.controller";
+import { IUpdateRecurringJobRuleController } from "@/src/interface-adapters/controllers/recurring-job-rules/update-recurring-job-rule.controller";
 import { authCheck } from "./auth.actions";
 import { z } from "zod";
 import { Message } from "@/app/lib/types/types";
@@ -15,6 +16,7 @@ const listRecurringJobRulesController = container.resolve<IListRecurringJobRules
 const fetchRecurringJobRuleController = container.resolve<IFetchRecurringJobRuleController>('fetchRecurringJobRuleController');
 const toggleRecurringJobRuleController = container.resolve<IToggleRecurringJobRuleController>('toggleRecurringJobRuleController');
 const deleteRecurringJobRuleController = container.resolve<IDeleteRecurringJobRuleController>('deleteRecurringJobRuleController');
+const updateRecurringJobRuleController = container.resolve<IUpdateRecurringJobRuleController>('updateRecurringJobRuleController');
 
 export async function createRecurringJobRule(request: {
     projectId: string,
@@ -89,3 +91,23 @@ export async function deleteRecurringJobRule(request: {
         ruleId: request.ruleId,
     });
 }
+
+export async function updateRecurringJobRule(request: {
+    projectId: string,
+    ruleId: string,
+    input: {
+        messages: z.infer<typeof Message>[],
+    },
+    cron: string,
+}) {
+    const user = await authCheck();
+
+    return await updateRecurringJobRuleController.execute({
+        caller: 'user',
+        userId: user.id,
+        projectId: request.projectId,
+        ruleId: request.ruleId,
+        input: request.input,
+        cron: request.cron,
+    });
+}

apps/rowboat/app/actions/scheduled-job-rules.actions.ts

@@ -5,6 +5,7 @@ import { ICreateScheduledJobRuleController } from "@/src/interface-adapters/cont
 import { IListScheduledJobRulesController } from "@/src/interface-adapters/controllers/scheduled-job-rules/list-scheduled-job-rules.controller";
 import { IFetchScheduledJobRuleController } from "@/src/interface-adapters/controllers/scheduled-job-rules/fetch-scheduled-job-rule.controller";
 import { IDeleteScheduledJobRuleController } from "@/src/interface-adapters/controllers/scheduled-job-rules/delete-scheduled-job-rule.controller";
+import { IUpdateScheduledJobRuleController } from "@/src/interface-adapters/controllers/scheduled-job-rules/update-scheduled-job-rule.controller";
 import { authCheck } from "./auth.actions";
 import { z } from "zod";
 import { Message } from "@/app/lib/types/types";
@@ -13,6 +14,7 @@ const createScheduledJobRuleController = container.resolve<ICreateScheduledJobRu
 const listScheduledJobRulesController = container.resolve<IListScheduledJobRulesController>('listScheduledJobRulesController');
 const fetchScheduledJobRuleController = container.resolve<IFetchScheduledJobRuleController>('fetchScheduledJobRuleController');
 const deleteScheduledJobRuleController = container.resolve<IDeleteScheduledJobRuleController>('deleteScheduledJobRuleController');
+const updateScheduledJobRuleController = container.resolve<IUpdateScheduledJobRuleController>('updateScheduledJobRuleController');
 
 export async function createScheduledJobRule(request: {
     projectId: string,
@@ -72,4 +74,24 @@ export async function deleteScheduledJobRule(request: {
         projectId: request.projectId,
         ruleId: request.ruleId,
     });
-}
+}
+
+export async function updateScheduledJobRule(request: {
+    projectId: string,
+    ruleId: string,
+    input: {
+        messages: z.infer<typeof Message>[],
+    },
+    scheduledTime: string,
+}) {
+    const user = await authCheck();
+
+    return await updateScheduledJobRuleController.execute({
+        caller: 'user',
+        userId: user.id,
+        projectId: request.projectId,
+        ruleId: request.ruleId,
+        input: request.input,
+        scheduledTime: request.scheduledTime,
+    });
+}

apps/rowboat/app/lib/client_utils.ts

@@ -1,4 +1,5 @@
 import { WorkflowTool, WorkflowAgent, WorkflowPrompt, WorkflowPipeline } from "./types/workflow_types";
+import { Message } from "./types/types";
 import { z } from "zod";
 
 const ZFallbackSchema = z.object({}).passthrough();
@@ -62,6 +63,40 @@ export function validateConfigChanges(configType: string, configChanges: Record<
             testObject = {};
             break;
         }
+        case 'one_time_trigger': {
+            testObject = {
+                scheduledTime: new Date(0).toISOString(),
+                input: {
+                    messages: [],
+                },
+            };
+            schema = z.object({
+                scheduledTime: z.string().min(1),
+                input: z.object({
+                    messages: z.array(Message),
+                }),
+            }).passthrough();
+            break;
+        }
+        case 'recurring_trigger': {
+            testObject = {
+                cron: '* * * * *',
+                input: {
+                    messages: [],
+                },
+            };
+            schema = z.object({
+                cron: z.string().min(1),
+                input: z.object({
+                    messages: z.array(Message),
+                }),
+            }).passthrough();
+            break;
+        }
+        case 'external_trigger': {
+            // External triggers have flexible schemas per provider; do not strip any config.
+            return { changes: configChanges };
+        }
         default:
             return { error: `Unknown config type: ${configType}` };
     }

apps/rowboat/app/projects/[projectId]/copilot/app.tsx

@@ -2,7 +2,7 @@
 import { Button } from "@/components/ui/button";
 import { Dropdown, DropdownItem, DropdownMenu, DropdownSection, DropdownTrigger, Spinner, Tooltip } from "@heroui/react";
 import { useRef, useState, createContext, useContext, useCallback, forwardRef, useImperativeHandle, useEffect, Ref } from "react";
-import { CopilotChatContext } from "../../../../src/entities/models/copilot";
+import { CopilotChatContext, TriggerSchemaForCopilot } from "../../../../src/entities/models/copilot";
 import { CopilotMessage } from "../../../../src/entities/models/copilot";
 import { Workflow } from "@/app/lib/types/workflow_types";
 import { DataSource } from "@/src/entities/models/data-source";
@@ -36,6 +36,8 @@ interface AppProps {
     onMessagesChange?: (messages: z.infer<typeof CopilotMessage>[]) => void;
     isInitialState?: boolean;
     dataSources?: z.infer<typeof DataSource>[];
+    triggers?: z.infer<typeof TriggerSchemaForCopilot>[];
+    onTriggersUpdated?: () => Promise<void> | void;
 }
 
 const App = forwardRef<{ handleCopyChat: () => void; handleUserMessage: (message: string) => void }, AppProps>(function App({
@@ -47,6 +49,8 @@ const App = forwardRef<{ handleCopyChat: () => void; handleUserMessage: (message
     onMessagesChange,
     isInitialState = false,
     dataSources,
+    triggers,
+    onTriggersUpdated,
 }, ref) {
 
 
@@ -85,7 +89,8 @@ const App = forwardRef<{ handleCopyChat: () => void; handleUserMessage: (message
         projectId,
         workflow: workflowRef.current,
         context: effectiveContext,
-        dataSources: dataSources
+        dataSources: dataSources,
+        triggers: triggers
     });
 
     // Store latest start/cancel functions in refs
@@ -255,6 +260,7 @@ const App = forwardRef<{ handleCopyChat: () => void; handleUserMessage: (message
                         </div>
                     )}
                     <Messages
+                        projectId={projectId}
                         messages={messages}
                         streamingResponse={streamingResponse}
                         loadingResponse={loadingResponse}
@@ -263,6 +269,8 @@ const App = forwardRef<{ handleCopyChat: () => void; handleUserMessage: (message
                         onStatusBarChange={handleStatusBarChange}
                         toolCalling={toolCalling}
                         toolQuery={toolQuery}
+                        triggers={triggers}
+                        onTriggersUpdated={onTriggersUpdated}
                     />
                 </div>
                 <div className="shrink-0 px-0 pb-10">
@@ -318,17 +326,21 @@ export const Copilot = forwardRef<{ handleUserMessage: (message: string) => void
     dispatch: (action: WorkflowDispatch) => void;
     isInitialState?: boolean;
     dataSources?: z.infer<typeof DataSource>[];
+    triggers?: z.infer<typeof TriggerSchemaForCopilot>[];
     activePanel?: 'playground' | 'copilot';
     onTogglePanel?: () => void;
+    onTriggersUpdated?: () => Promise<void> | void;
 }>(({
     projectId,
     workflow,
     chatContext = undefined,
     dispatch,
     isInitialState = false,
     dataSources,
+    triggers,
     activePanel,
     onTogglePanel,
+    onTriggersUpdated,
 }, ref) => {
     console.log('🎪 Copilot wrapper component mounted:', {
         projectId,
@@ -414,6 +426,8 @@ export const Copilot = forwardRef<{ handleUserMessage: (message: string) => void
                         onMessagesChange={setMessages}
                         isInitialState={isInitialState}
                         dataSources={dataSources}
+                        triggers={triggers}
+                        onTriggersUpdated={onTriggersUpdated}
                     />
                 </div>
             </Panel>