update styling for schedules to show visual indication that schedule is active, fix cron job to execute scheduled workflows not running (#147)

Author: waleedlatif1

sim/app/api/scheduled/[id]/route.ts

@@ -0,0 +1,65 @@
+import { NextRequest, NextResponse } from 'next/server'
+import crypto from 'crypto'
+import { and, eq } from 'drizzle-orm'
+import { getSession } from '@/lib/auth'
+import { createLogger } from '@/lib/logs/console-logger'
+import { db } from '@/db'
+import { workflow, workflowSchedule } from '@/db/schema'
+
+const logger = createLogger('ScheduleDeleteAPI')
+
+export const dynamic = 'force-dynamic'
+
+/**
+ * Delete a schedule
+ */
+export async function DELETE(
+  request: NextRequest,
+  { params }: { params: Promise<{ id: string }> }
+) {
+  const requestId = crypto.randomUUID().slice(0, 8)
+
+  try {
+    const { id } = await params
+    logger.debug(`[${requestId}] Deleting schedule with ID: ${id}`)
+
+    const session = await getSession()
+    if (!session?.user?.id) {
+      logger.warn(`[${requestId}] Unauthorized schedule deletion attempt`)
+      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+    }
+
+    // Find the schedule and check ownership
+    const schedules = await db
+      .select({
+        schedule: workflowSchedule,
+        workflow: {
+          id: workflow.id,
+          userId: workflow.userId,
+        },
+      })
+      .from(workflowSchedule)
+      .innerJoin(workflow, eq(workflowSchedule.workflowId, workflow.id))
+      .where(eq(workflowSchedule.id, id))
+      .limit(1)
+
+    if (schedules.length === 0) {
+      logger.warn(`[${requestId}] Schedule not found: ${id}`)
+      return NextResponse.json({ error: 'Schedule not found' }, { status: 404 })
+    }
+
+    if (schedules[0].workflow.userId !== session.user.id) {
+      logger.warn(`[${requestId}] Unauthorized schedule deletion attempt for schedule: ${id}`)
+      return NextResponse.json({ error: 'Unauthorized' }, { status: 403 })
+    }
+
+    // Delete the schedule
+    await db.delete(workflowSchedule).where(eq(workflowSchedule.id, id))
+
+    logger.info(`[${requestId}] Successfully deleted schedule: ${id}`)
+    return NextResponse.json({ success: true }, { status: 200 })
+  } catch (error) {
+    logger.error(`[${requestId}] Error deleting schedule`, error)
+    return NextResponse.json({ error: 'Internal server error' }, { status: 500 })
+  }
+}

sim/app/api/scheduled/execute/route.ts

@@ -13,6 +13,9 @@ import { environment, workflow, workflowSchedule } from '@/db/schema'
 import { Executor } from '@/executor'
 import { Serializer } from '@/serializer'
 
+// Add dynamic export to prevent caching
+export const dynamic = 'force-dynamic'
+
 const logger = createLogger('ScheduledExecuteAPI')
 
 interface SubBlockValue {
@@ -144,16 +147,12 @@ function calculateNextRunTime(
 // Define the schema for environment variables
 const EnvVarsSchema = z.record(z.string())
 
-export const config = {
-  runtime: 'nodejs',
-  schedule: '*/1 * * * *',
-}
-
 // Keep track of running executions to prevent overlap
 const runningExecutions = new Set<string>()
 
 // Add GET handler for cron job
 export async function GET(req: NextRequest) {
+  logger.info(`Scheduled execution triggered at ${new Date().toISOString()}`)
   const requestId = crypto.randomUUID().slice(0, 8)
   const now = new Date()
 

sim/app/api/scheduled/route.ts

@@ -0,0 +1,48 @@
+import { NextRequest, NextResponse } from 'next/server'
+import crypto from 'crypto'
+import { eq } from 'drizzle-orm'
+import { getSession } from '@/lib/auth'
+import { createLogger } from '@/lib/logs/console-logger'
+import { db } from '@/db'
+import { workflowSchedule } from '@/db/schema'
+
+const logger = createLogger('Scheduled API')
+
+/**
+ * Get schedule information for a workflow
+ */
+export async function GET(req: NextRequest) {
+  const requestId = crypto.randomUUID().slice(0, 8)
+  const url = new URL(req.url)
+  const workflowId = url.searchParams.get('workflowId')
+
+  try {
+    const session = await getSession()
+    if (!session?.user?.id) {
+      logger.warn(`[${requestId}] Unauthorized schedule query attempt`)
+      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+    }
+
+    if (!workflowId) {
+      return NextResponse.json({ error: 'Missing workflowId parameter' }, { status: 400 })
+    }
+
+    logger.info(`[${requestId}] Getting schedule for workflow ${workflowId}`)
+
+    // Find the schedule for this workflow
+    const schedule = await db
+      .select()
+      .from(workflowSchedule)
+      .where(eq(workflowSchedule.workflowId, workflowId))
+      .limit(1)
+
+    if (schedule.length === 0) {
+      return NextResponse.json({ schedule: null })
+    }
+
+    return NextResponse.json({ schedule: schedule[0] })
+  } catch (error) {
+    logger.error(`[${requestId}] Error retrieving workflow schedule`, error)
+    return NextResponse.json({ error: 'Failed to retrieve workflow schedule' }, { status: 500 })
+  }
+}

sim/app/w/[id]/components/workflow-block/components/action-bar/schedule-status.tsx

@@ -0,0 +1,76 @@
+import { useEffect, useState } from 'react'
+import { useParams } from 'next/navigation'
+import { Calendar } from 'lucide-react'
+import { Badge } from '@/components/ui/badge'
+import { Tooltip, TooltipContent, TooltipTrigger } from '@/components/ui/tooltip'
+import { createLogger } from '@/lib/logs/console-logger'
+import { formatDateTime } from '@/lib/utils'
+
+const logger = createLogger('ScheduleStatus')
+
+interface ScheduleStatusProps {
+  blockId: string
+}
+
+export function ScheduleStatus({ blockId }: ScheduleStatusProps) {
+  const [scheduleId, setScheduleId] = useState<string | null>(null)
+  const [nextRunAt, setNextRunAt] = useState<string | null>(null)
+  const [isLoading, setIsLoading] = useState(true)
+  const params = useParams()
+  const workflowId = params.id as string
+
+  // Check if schedule exists in the database
+  useEffect(() => {
+    const checkSchedule = async () => {
+      setIsLoading(true)
+      try {
+        // Check if there's a schedule for this workflow
+        const response = await fetch(`/api/scheduled?workflowId=${workflowId}`)
+        if (response.ok) {
+          const data = await response.json()
+          if (data.schedule) {
+            setScheduleId(data.schedule.id)
+            setNextRunAt(data.schedule.nextRunAt)
+          } else {
+            setScheduleId(null)
+            setNextRunAt(null)
+          }
+        }
+      } catch (error) {
+        logger.error('Error checking schedule:', { error })
+      } finally {
+        setIsLoading(false)
+      }
+    }
+
+    checkSchedule()
+  }, [workflowId])
+
+  if (isLoading || !scheduleId || !nextRunAt) {
+    return null
+  }
+
+  return (
+    <Tooltip>
+      <TooltipTrigger asChild>
+        <Badge
+          variant="outline"
+          className="ml-auto bg-green-100 text-green-700 border-green-200 
+                    dark:bg-green-900 dark:text-green-300 dark:border-green-800 
+                    px-2 py-0.5 flex items-center"
+        >
+          <Calendar className="h-3.5 w-3.5 mr-1" />
+          <span className="text-xs">Active</span>
+        </Badge>
+      </TooltipTrigger>
+      <TooltipContent side="right">
+        <div className="text-xs">
+          <div>
+            <strong>Schedule Active</strong>
+          </div>
+          <div>Next run: {formatDateTime(new Date(nextRunAt))}</div>
+        </div>
+      </TooltipContent>
+    </Tooltip>
+  )
+}