formatting, use after second s

Author: Palashio

apps/web-v2/src/features/agent-inbox/contexts/ThreadContext.tsx

@@ -35,6 +35,7 @@ type ThreadContentType<
     _response: HumanResponse[],
     _options?: {
       stream?: TStream;
+      afterSeconds?: number;
     },
   ) => TStream extends true
     ?
@@ -406,6 +407,7 @@ function ThreadsProviderInternal<
     response: HumanResponse[],
     options?: {
       stream?: TStream;
+      afterSeconds?: number;
     },
   ): TStream extends true
     ?
@@ -432,19 +434,20 @@ function ThreadsProviderInternal<
     const client = createClient(deploymentId, session.accessToken);
 
     try {
+      const payload = {
+        command: {
+          resume: response,
+        },
+        ...(options?.afterSeconds && { afterSeconds: options.afterSeconds }),
+      };
+
       if (options?.stream) {
         return client.runs.stream(threadId, assistantId, {
-          command: {
-            resume: response,
-          },
+          ...payload,
           streamMode: "events",
         }) as any; // Type assertion needed due to conditional return type
       }
-      return client.runs.create(threadId, assistantId, {
-        command: {
-          resume: response,
-        },
-      }) as any; // Type assertion needed due to conditional return type
+      return client.runs.create(threadId, assistantId, payload) as any; // Type assertion needed due to conditional return type
     } catch (e: any) {
       logger.error("Error sending human response", e);
       throw e;

apps/web-v2/src/features/agent-inbox/hooks/use-interrupted-actions.tsx

@@ -396,20 +396,87 @@ export default function useInterruptedActions<
       toast.error("Thread data is not available");
       return;
     }
+    if (!humanResponse) {
+      toast.error("Please enter a response.");
+      return;
+    }
+    if (!selectedInbox) {
+      toast.error("No inbox selected");
+      return;
+    }
 
-    // For now, this is a placeholder that shows a success message
-    // In a real implementation, this would save the scheduled date to the backend
-    // and handle the scheduling logic
-    const formattedDate = scheduledDate.toLocaleDateString();
-    const formattedTime = scheduledDate.toLocaleTimeString();
+    // Calculate afterSeconds from the scheduled date
+    const now = new Date();
+    const afterSeconds = Math.max(
+      0,
+      Math.floor((scheduledDate.getTime() - now.getTime()) / 1000),
+    );
 
-    toast.success(`Thread scheduled successfully!`, {
-      description: `This interrupt will be processed on ${formattedDate} at ${formattedTime}`,
-      duration: 5000,
-    });
+    if (afterSeconds <= 0) {
+      toast.error("Scheduled time must be in the future");
+      return;
+    }
 
-    // Clear the selected thread ID to go back to inbox view
-    await setSelectedThreadId(null);
+    try {
+      // Create the human response similar to handleSubmit
+      const humanResponseInput: HumanResponse[] = humanResponse.flatMap((r) => {
+        if (r.type === "edit") {
+          if (r.acceptAllowed && !r.editsMade) {
+            return {
+              type: "accept",
+              args: r.args,
+            };
+          } else {
+            return {
+              type: "edit",
+              args: r.args,
+            };
+          }
+        }
+
+        if (r.type === "response" && !r.args) {
+          // If response was allowed but no response was given, do not include in the response
+          return [];
+        }
+        return {
+          type: r.type,
+          args: r.args,
+        };
+      });
+
+      const input = humanResponseInput.find(
+        (r) => r.type === selectedSubmitType,
+      );
+      if (!input) {
+        toast.error("No response found.");
+        return;
+      }
+
+      setLoading(true);
+
+      // Send the human response with afterSeconds for scheduling
+      await sendHumanResponse(threadData.thread.thread_id, [input], {
+        afterSeconds,
+      });
+
+      const formattedDate = scheduledDate.toLocaleDateString();
+      const formattedTime = scheduledDate.toLocaleTimeString();
+
+      toast.success(`Thread scheduled successfully!`, {
+        description: `This interrupt will be processed on ${formattedDate} at ${formattedTime}`,
+        duration: 5000,
+      });
+
+      // Clear the selected thread ID to go back to inbox view
+      await setSelectedThreadId(null);
+    } catch (e: any) {
+      logger.error("Error scheduling response", e);
+      toast.error("Failed to schedule response.", {
+        duration: 5000,
+      });
+    } finally {
+      setLoading(false);
+    }
   };
 
   return {