feat: add worker API endpoint

Author: moonrailgun

src/client/routes/worker/$workerId/index.tsx

@@ -13,7 +13,7 @@ import { Tabs, TabsContent, TabsList, TabsTrigger } from '@/components/ui/tabs';
 import { CodeEditor } from '@/components/CodeEditor';
 import { trpc } from '@/api/trpc';
 import { defaultErrorHandler } from '@/api/trpc';
-import { LuPlay, LuPencil, LuTrash, LuActivity } from 'react-icons/lu';
+import { LuPlay, LuPencil, LuTrash, LuActivity, LuGlobe } from 'react-icons/lu';
 import { useState } from 'react';
 import { AlertConfirm } from '@/components/AlertConfirm';
 import { Loading } from '@/components/Loading';
@@ -32,6 +32,8 @@ import {
 } from '@/components/ui/sheet';
 import { WorkerExecutionsTable } from '@/components/worker/WorkerExecutionsTable';
 import { WorkerExecutionDetail } from '@/components/worker/WorkerExecutionDetail';
+import { toast } from 'sonner';
+import { CodeBlock } from '@/components/CodeBlock';
 
 export const Route = createFileRoute('/worker/$workerId/')({
   beforeLoad: routeAuthBeforeLoad,
@@ -217,6 +219,28 @@ function PageComponent() {
           </TabsList>
 
           <TabsContent value="code" className="space-y-4">
+            {/* API Calling Guide */}
+            <Card className="border-blue-200 bg-blue-50/50 dark:border-blue-800 dark:bg-blue-950/50">
+              <CardHeader>
+                <CardTitle className="flex items-center space-x-2 text-blue-700 dark:text-blue-300">
+                  <LuGlobe className="h-5 w-5" />
+                  <span>{t('API Endpoint')}</span>
+                </CardTitle>
+              </CardHeader>
+              <CardContent className="space-y-4">
+                <div className="space-y-2">
+                  <p className="text-sm text-blue-600 dark:text-blue-400">
+                    {t(
+                      'You can call this worker function directly via HTTP API:'
+                    )}
+                  </p>
+                  <CodeBlock
+                    code={`${window.location.origin}/api/worker/${workspaceId}/${workerId}`}
+                  />
+                </div>
+              </CardContent>
+            </Card>
+
             <Card>
               <CardHeader>
                 <CardTitle>{t('Worker Code')}</CardTitle>

src/client/vite.config.ts

@@ -55,6 +55,9 @@ export default defineConfig({
       '/api/push': {
         target: 'http://localhost:12345',
       },
+      '/api/worker': {
+        target: 'http://localhost:12345',
+      },
       '^/monitor/.*/badge\\.svg(\\?.*)?$': {
         target: 'http://localhost:12345',
       },

src/server/app.ts

@@ -26,6 +26,7 @@ import { prometheusApiVersion } from './middleware/prometheus/index.js';
 import { billingRouter } from './router/billing.js';
 import { aiGatewayRouter } from './router/aiGateway.js';
 import { pushRouter } from './router/push.js';
+import { workerRouter } from './router/worker.js';
 
 const app = express();
 
@@ -62,6 +63,7 @@ app.use('/api/application', applicationRouter);
 app.use('/api/ai', aiGatewayRouter);
 app.use('/api/billing', billingRouter);
 app.use('/api/push', pushRouter);
+app.use('/api/worker', workerRouter);
 app.use('/monitor', monitorRouter);
 app.use('/telemetry', telemetryRouter);
 app.use('/serverStatus', serverStatusRouter);

src/server/router/worker.ts

@@ -0,0 +1,61 @@
+import { Router } from 'express';
+import { param, validate } from '../middleware/validate.js';
+import { execWorker } from '../model/worker/index.js';
+import { prisma } from '../model/_client.js';
+import { logger } from '../utils/logger.js';
+
+export const workerRouter = Router();
+
+/**
+ * Execute a worker by ID
+ */
+workerRouter.all(
+  '/:workspaceId/:workerId',
+  validate(param('workspaceId').isString(), param('workerId').isString()),
+  async (req, res) => {
+    try {
+      const { workspaceId, workerId } = req.params;
+      // const { requestPayload = {} } = req.body;
+
+      // Verify worker exists and belongs to workspace
+      const worker = await prisma.functionWorker.findUnique({
+        where: {
+          id: workerId,
+          workspaceId,
+        },
+      });
+
+      if (!worker) {
+        return res.status(404).json({
+          success: false,
+          error: 'Worker not found or does not belong to this workspace',
+        });
+      }
+
+      if (!worker.active) {
+        return res.status(400).json({
+          success: false,
+          error: 'Worker is not active',
+        });
+      }
+
+      // Execute the worker
+      const execution = await execWorker(workerId);
+
+      const response = execution.responsePayload;
+
+      if (typeof response === 'object') {
+        res.json(response);
+      } else {
+        res.send(response);
+      }
+    } catch (error) {
+      logger.error('Worker execution error:', error);
+      res.status(500).json({
+        success: false,
+        error: 'Internal server error during worker execution',
+        message: error instanceof Error ? error.message : 'Unknown error',
+      });
+    }
+  }
+);