Content Moderation Workflow Demo

Runs the contentModerationWorkflow. Includes validation, safety analysis (toxicity, PII, spam), topic/sentiment analysis, conditional PII redaction, moderation decision (approve/reject/review), conditional insight extraction, data storage simulation, and conditional moderator notification.

\n\n\n\n

Execution Results

Workflow Result (Final Mapped Output)

— Waiting for execution —

\n\n

Execution Log (DEBUG level recommended)

\n ℹ️ Look for log entries like [DEBUG] [Agent:AgentName:Component] Executing agent \"AgentName\". The 'details' object in these log entries contains the specific input payload and config context passed to the agent during *this* execution. Check conditions and dependencies.\n

— Waiting for execution —

\n\n\n

Platform Configuration

\n\n

Available Agents

${JSON.stringify(availableAgents, null, 2)}

\n\n

Workflow Definition (`contentModerationWorkflow`)

\n ℹ️ This is the declarative JSON structure defining the workflow steps, dependencies, conditions, input/output mappings, and static agent configurations used by the engine. Note limitations in complex input construction and conditions.\n

${workflowDefinitionJson}

\n\n\n\n\n`;\n}\n\n// --- Val Town Entry Point / Server --- (Updated to use new workflow and HTML)\nexport default async function(req: Request): Promise {\n globalLogger.clear(); // Clear logs for each request\n const requestStartTime = Date.now();\n const preliminaryMandateId = `REQ-${requestStartTime}`; // Mandate ID before workflow starts\n const requestLog = globalLogger.createLogFunction(preliminaryMandateId, \"RequestHandler\");\n\n requestLog(\"INFO\", \"RequestReceived\", `Incoming ${req.method} request for ${req.url}`);\n\n try {\n if (req.method === \"GET\") {\n requestLog(\"DEBUG\", \"ServeHTML\", \"Serving Content Moderation HTML UI with config info\");\n\n // --- Get data for UI ---\n const availableAgents = agentRegistry.getRegisteredAgents();\n // Ensure workflow definition is treated as plain object for stringify\n const workflowDefObject = JSON.parse(JSON.stringify(contentModerationWorkflow)); // Use the NEW workflow\n const workflowDefinitionJson = JSON.stringify(workflowDefObject, null, 2);\n // --- End Get data ---\n\n return new Response(\n generateHtmlShellModeration(availableAgents, workflowDefinitionJson), // Use the NEW HTML generator\n { status: 200, headers: { \"Content-Type\": \"text/html\" } },\n );\n } else if (req.method === \"POST\") {\n // POST handler logic (mostly unchanged, uses the new workflow)\n let initialPayload: any;\n try {\n initialPayload = await req.json();\n requestLog(\"DEBUG\", \"ParsePayload\", \"Successfully parsed JSON payload\", { payload: initialPayload });\n } catch (e: any) {\n requestLog(\"ERROR\", \"ParsePayload\", \"Failed to parse request JSON\", e);\n return new Response(\n JSON.stringify({\n success: false,\n error: \"Invalid JSON payload\",\n details: e.message,\n debugLog: globalLogger.getLogs(),\n }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n requestLog(\"INFO\", \"WorkflowExecute\", `Executing workflow: ${contentModerationWorkflow.id}`); // Use the NEW workflow\n const result = await workflowEngine.execute(contentModerationWorkflow, initialPayload); // Use the NEW workflow\n\n // Log completion using the final mandateId from the result\n globalLogger.createLogFunction(result.mandateId, \"RequestHandler\")(\n \"INFO\",\n \"WorkflowComplete\",\n `Workflow execution finished`,\n { success: result.success, durationMs: Date.now() - requestStartTime },\n );\n\n return new Response(JSON.stringify(result), {\n status: result.success ? 200 : (result.error === \"Workflow input error.\" ? 400 : 500),\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" }, // Added CORS header\n });\n } else {\n // Method Not Allowed\n requestLog(\"WARN\", \"MethodNotAllowed\", `Method Not Allowed: ${req.method}`);\n return new Response(\n JSON.stringify({ success: false, error: \"Method Not Allowed\", debugLog: globalLogger.getLogs() }),\n { status: 405, headers: { \"Content-Type\": \"application/json\", \"Allow\": \"GET, POST\" } },\n );\n }\n } catch (e: any) {\n // Unhandled Exception\n requestLog(\"ERROR\", \"UnhandledException\", \"Unhandled error during request processing\", e);\n return new Response(\n JSON.stringify({\n success: false,\n error: \"Internal Server Error\",\n details: e.message,\n debugLog: globalLogger.getLogs(),\n }),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}","deleted","label",[99],"permalink","https://www.val.town/x/salon/quad/code/main.tsx","extension","actionData","errors"]

Content Moderation Workflow Demo

Run Workflow

Execution Results

Workflow Result (Final Mapped Output)

Execution Log (DEBUG level recommended)

Platform Configuration

Available Agents

Workflow Definition (contentModerationWorkflow)

Workflow Definition (`contentModerationWorkflow`)