From c3f4aebe46e1b7019d25053d908e76eee6e10d7b Mon Sep 17 00:00:00 2001
From: ElasticBottle <winstonyeo99@yahoo.com>
Date: Mon, 23 Feb 2026 19:45:59 +0800
Subject: [PATCH 1/3] chore: fix workflow generations

---
 apps/seo/src/routeTree.gen.ts                 |  21 ++
 apps/seo/src/routes/_authed/admin/route.tsx   | 161 ++++++++++++
 .../api-seo/src/lib/ai/arktype-json-schema.ts |  60 +++++
 .../ai/tools/google-search-console-tool.ts    |   7 +-
 .../src/lib/ai/tools/settings-tools.ts        |   9 +-
 packages/api-seo/src/routes/admin.ts          | 110 ++++++++
 packages/api-seo/src/routes/index.ts          |   1 +
 .../src/workflows/onboarding-workflow.ts      |  20 +-
 .../api-seo/src/workflows/planner-workflow.ts |   5 +-
 .../strategy-phase-generation-workflow.ts     |   3 +-
 .../strategy-suggestions-workflow.ts          | 236 ++++++++++--------
 .../api-seo/src/workflows/writer-workflow.ts  |  17 +-
 .../schema/arktype-json-schema-transformer.ts |  38 +++
 packages/core/src/schemas/strategy-parsers.ts |   2 +-
 14 files changed, 554 insertions(+), 136 deletions(-)
 create mode 100644 apps/seo/src/routes/_authed/admin/route.tsx
 create mode 100644 packages/api-seo/src/lib/ai/arktype-json-schema.ts
 create mode 100644 packages/api-seo/src/routes/admin.ts
 create mode 100644 packages/core/src/schema/arktype-json-schema-transformer.ts

diff --git a/apps/seo/src/routeTree.gen.ts b/apps/seo/src/routeTree.gen.ts
index 8887313d1..9a28944a5 100644
--- a/apps/seo/src/routeTree.gen.ts
+++ b/apps/seo/src/routeTree.gen.ts
@@ -13,6 +13,7 @@ import { Route as LoginRouteImport } from './routes/login'
 import { Route as AuthedRouteRouteImport } from './routes/_authed/route'
 import { Route as IndexRouteImport } from './routes/index'
 import { Route as ApiSplatRouteImport } from './routes/api/$'
+import { Route as AuthedAdminRouteRouteImport } from './routes/_authed/admin/route'
 import { Route as AuthedOrganizationSlugRouteRouteImport } from './routes/_authed/$organizationSlug/route'
 import { Route as AuthedOnboardingIndexRouteImport } from './routes/_authed/onboarding/index'
 import { Route as AuthedOrganizationSlugIndexRouteImport } from './routes/_authed/$organizationSlug/index'
@@ -54,6 +55,11 @@ const ApiSplatRoute = ApiSplatRouteImport.update({
   path: '/api/$',
   getParentRoute: () => rootRouteImport,
 } as any)
+const AuthedAdminRouteRoute = AuthedAdminRouteRouteImport.update({
+  id: '/admin',
+  path: '/admin',
+  getParentRoute: () => AuthedRouteRoute,
+} as any)
 const AuthedOrganizationSlugRouteRoute =
   AuthedOrganizationSlugRouteRouteImport.update({
     id: '/$organizationSlug',
@@ -187,6 +193,7 @@ export interface FileRoutesByFullPath {
   '/': typeof IndexRoute
   '/login': typeof LoginRoute
   '/$organizationSlug': typeof AuthedOrganizationSlugRouteRouteWithChildren
+  '/admin': typeof AuthedAdminRouteRoute
   '/api/$': typeof ApiSplatRoute
   '/$organizationSlug/$projectSlug': typeof AuthedOrganizationSlugProjectSlugRouteRouteWithChildren
   '/invite/$invitationId': typeof AuthedInviteInvitationIdRoute
@@ -212,6 +219,7 @@ export interface FileRoutesByFullPath {
 export interface FileRoutesByTo {
   '/': typeof IndexRoute
   '/login': typeof LoginRoute
+  '/admin': typeof AuthedAdminRouteRoute
   '/api/$': typeof ApiSplatRoute
   '/invite/$invitationId': typeof AuthedInviteInvitationIdRoute
   '/api/rpc/$': typeof ApiRpcSplatRoute
@@ -238,6 +246,7 @@ export interface FileRoutesById {
   '/_authed': typeof AuthedRouteRouteWithChildren
   '/login': typeof LoginRoute
   '/_authed/$organizationSlug': typeof AuthedOrganizationSlugRouteRouteWithChildren
+  '/_authed/admin': typeof AuthedAdminRouteRoute
   '/api/$': typeof ApiSplatRoute
   '/_authed/$organizationSlug/$projectSlug': typeof AuthedOrganizationSlugProjectSlugRouteRouteWithChildren
   '/_authed/invite/$invitationId': typeof AuthedInviteInvitationIdRoute
@@ -266,6 +275,7 @@ export interface FileRouteTypes {
     | '/'
     | '/login'
     | '/$organizationSlug'
+    | '/admin'
     | '/api/$'
     | '/$organizationSlug/$projectSlug'
     | '/invite/$invitationId'
@@ -291,6 +301,7 @@ export interface FileRouteTypes {
   to:
     | '/'
     | '/login'
+    | '/admin'
     | '/api/$'
     | '/invite/$invitationId'
     | '/api/rpc/$'
@@ -316,6 +327,7 @@ export interface FileRouteTypes {
     | '/_authed'
     | '/login'
     | '/_authed/$organizationSlug'
+    | '/_authed/admin'
     | '/api/$'
     | '/_authed/$organizationSlug/$projectSlug'
     | '/_authed/invite/$invitationId'
@@ -377,6 +389,13 @@ declare module '@tanstack/react-router' {
       preLoaderRoute: typeof ApiSplatRouteImport
       parentRoute: typeof rootRouteImport
     }
+    '/_authed/admin': {
+      id: '/_authed/admin'
+      path: '/admin'
+      fullPath: '/admin'
+      preLoaderRoute: typeof AuthedAdminRouteRouteImport
+      parentRoute: typeof AuthedRouteRoute
+    }
     '/_authed/$organizationSlug': {
       id: '/_authed/$organizationSlug'
       path: '/$organizationSlug'
@@ -615,6 +634,7 @@ const AuthedOrganizationSlugRouteRouteWithChildren =
 
 interface AuthedRouteRouteChildren {
   AuthedOrganizationSlugRouteRoute: typeof AuthedOrganizationSlugRouteRouteWithChildren
+  AuthedAdminRouteRoute: typeof AuthedAdminRouteRoute
   AuthedInviteInvitationIdRoute: typeof AuthedInviteInvitationIdRoute
   AuthedOnboardingIndexRoute: typeof AuthedOnboardingIndexRoute
 }
@@ -622,6 +642,7 @@ interface AuthedRouteRouteChildren {
 const AuthedRouteRouteChildren: AuthedRouteRouteChildren = {
   AuthedOrganizationSlugRouteRoute:
     AuthedOrganizationSlugRouteRouteWithChildren,
+  AuthedAdminRouteRoute: AuthedAdminRouteRoute,
   AuthedInviteInvitationIdRoute: AuthedInviteInvitationIdRoute,
   AuthedOnboardingIndexRoute: AuthedOnboardingIndexRoute,
 }
diff --git a/apps/seo/src/routes/_authed/admin/route.tsx b/apps/seo/src/routes/_authed/admin/route.tsx
new file mode 100644
index 000000000..01872c82b
--- /dev/null
+++ b/apps/seo/src/routes/_authed/admin/route.tsx
@@ -0,0 +1,161 @@
+import { Button } from "@rectangular-labs/ui/components/ui/button";
+import { Input } from "@rectangular-labs/ui/components/ui/input";
+import { Label } from "@rectangular-labs/ui/components/ui/label";
+import { toast } from "@rectangular-labs/ui/components/ui/sonner";
+import { Textarea } from "@rectangular-labs/ui/components/ui/textarea";
+import { useMutation } from "@tanstack/react-query";
+import { createFileRoute, notFound } from "@tanstack/react-router";
+import { useState } from "react";
+import { getApiClientRq } from "~/lib/api";
+
+export const Route = createFileRoute("/_authed/admin")({
+  beforeLoad: ({ context }) => {
+    if (!context.user?.email?.endsWith("fluidposts.com")) {
+      throw notFound();
+    }
+  },
+  component: RouteComponent,
+});
+
+function RouteComponent() {
+  const api = getApiClientRq();
+  const [projectSlug, setProjectSlug] = useState("");
+
+  const { mutate: triggerOnboarding, isPending } = useMutation(
+    api.admin.triggerOnboardingTask.mutationOptions({
+      onSuccess: () => {
+        toast.success("Triggered onboarding workflow successfully.");
+        setProjectSlug("");
+      },
+      onError: (error) => {
+        toast.error(error.message);
+      },
+    }),
+  );
+
+  const [instructions, setInstructions] = useState("");
+
+  const { mutate: triggerStrategySuggestions, isPending: isPendingStrategy } =
+    useMutation(
+      api.admin.triggerStrategySuggestionsTask.mutationOptions({
+        onSuccess: () => {
+          toast.success(
+            "Triggered strategy suggestions workflow successfully.",
+          );
+          setProjectSlug("");
+          setInstructions("");
+        },
+        onError: (error) => {
+          toast.error(error.message);
+        },
+      }),
+    );
+
+  const handleSubmit = (e: React.FormEvent) => {
+    e.preventDefault();
+    if (!projectSlug.trim()) {
+      toast.error("Please enter a project slug");
+      return;
+    }
+    triggerOnboarding({ projectSlug });
+  };
+
+  const handleStrategySubmit = (e: React.FormEvent) => {
+    e.preventDefault();
+    if (!projectSlug.trim()) {
+      toast.error("Please enter a project slug");
+      return;
+    }
+    triggerStrategySuggestions({
+      projectSlug,
+      instructions,
+    });
+  };
+
+  return (
+    <main className="mx-auto flex w-full max-w-3xl flex-col items-center space-y-6 p-6">
+      <div className="flex w-full max-w-md flex-col gap-2">
+        <h1 className="font-bold text-3xl tracking-tight">Admin</h1>
+        <p className="text-muted-foreground">
+          Internal tools for the fluidposts team.
+        </p>
+      </div>
+
+      <div className="w-full max-w-md rounded-lg border bg-card text-card-foreground shadow-sm">
+        <div className="flex flex-col space-y-1.5 p-6">
+          <h3 className="font-semibold leading-none tracking-tight">
+            Trigger Onboarding Task
+          </h3>
+          <p className="text-muted-foreground text-sm">
+            Trigger the onboarding workflow in the api-seo package for a
+            specific project.
+          </p>
+        </div>
+        <div className="p-6 pt-0">
+          <form className="space-y-4" onSubmit={handleSubmit}>
+            <div className="space-y-2">
+              <Label htmlFor="projectSlug">Project Slug</Label>
+              <Input
+                disabled={isPending}
+                id="projectSlug"
+                onChange={(e) => setProjectSlug(e.target.value)}
+                placeholder="e.g. acme-corp"
+                value={projectSlug}
+              />
+            </div>
+            <Button
+              disabled={!projectSlug.trim() || isPending}
+              isLoading={isPending}
+              type="submit"
+            >
+              Trigger Workflow
+            </Button>
+          </form>
+        </div>
+      </div>
+
+      <div className="w-full max-w-md rounded-lg border bg-card text-card-foreground shadow-sm">
+        <div className="flex flex-col space-y-1.5 p-6">
+          <h3 className="font-semibold leading-none tracking-tight">
+            Trigger Strategy Suggestions Task
+          </h3>
+          <p className="text-muted-foreground text-sm">
+            Trigger the strategy suggestions workflow in the api-seo package for
+            a specific project.
+          </p>
+        </div>
+        <div className="p-6 pt-0">
+          <form className="space-y-4" onSubmit={handleStrategySubmit}>
+            <div className="space-y-2">
+              <Label htmlFor="strategyProjectSlug">Project Slug</Label>
+              <Input
+                disabled={isPendingStrategy}
+                id="strategyProjectSlug"
+                onChange={(e) => setProjectSlug(e.target.value)}
+                placeholder="e.g. acme-corp"
+                value={projectSlug}
+              />
+            </div>
+            <div className="space-y-2">
+              <Label htmlFor="instructions">Instructions</Label>
+              <Textarea
+                disabled={isPendingStrategy}
+                id="instructions"
+                onChange={(e) => setInstructions(e.target.value)}
+                placeholder="Enter instructions for strategy generation..."
+                value={instructions}
+              />
+            </div>
+            <Button
+              disabled={!projectSlug.trim() || isPendingStrategy}
+              isLoading={isPendingStrategy}
+              type="submit"
+            >
+              Trigger Strategy Suggestions
+            </Button>
+          </form>
+        </div>
+      </div>
+    </main>
+  );
+}
diff --git a/packages/api-seo/src/lib/ai/arktype-json-schema.ts b/packages/api-seo/src/lib/ai/arktype-json-schema.ts
new file mode 100644
index 000000000..646fa8356
--- /dev/null
+++ b/packages/api-seo/src/lib/ai/arktype-json-schema.ts
@@ -0,0 +1,60 @@
+import { arkTypeJsonSchemaTransformer } from "@rectangular-labs/core/schema/arktype-json-schema-transformer";
+import { type JSONSchema7, jsonSchema } from "ai";
+
+type ArkTypeWithInfer = {
+  infer: unknown;
+  toJsonSchema: () => unknown;
+};
+
+function addAdditionalPropertiesToJsonSchema(
+  jsonSchema: JSONSchema7,
+): JSONSchema7 {
+  if (jsonSchema.type === "object") {
+    jsonSchema.additionalProperties = false;
+    const properties = jsonSchema.properties;
+    if (properties != null) {
+      for (const property in properties) {
+        properties[property] = addAdditionalPropertiesToJsonSchema(
+          properties[property] as JSONSchema7,
+        );
+      }
+    }
+  }
+  if (jsonSchema.type === "array" && jsonSchema.items != null) {
+    if (Array.isArray(jsonSchema.items)) {
+      jsonSchema.items = jsonSchema.items.map((item) =>
+        addAdditionalPropertiesToJsonSchema(item as JSONSchema7),
+      );
+    } else {
+      jsonSchema.items = addAdditionalPropertiesToJsonSchema(
+        jsonSchema.items as JSONSchema7,
+      );
+    }
+  }
+  if (jsonSchema.anyOf != null) {
+    jsonSchema.anyOf = jsonSchema.anyOf.map((schema) =>
+      addAdditionalPropertiesToJsonSchema(schema as JSONSchema7),
+    );
+  }
+  if (jsonSchema.allOf != null) {
+    jsonSchema.allOf = jsonSchema.allOf.map((schema) =>
+      addAdditionalPropertiesToJsonSchema(schema as JSONSchema7),
+    );
+  }
+  if (jsonSchema.oneOf != null) {
+    jsonSchema.oneOf = jsonSchema.oneOf.map((schema) =>
+      addAdditionalPropertiesToJsonSchema(schema as JSONSchema7),
+    );
+  }
+  return jsonSchema;
+}
+
+export function arktypeToAiJsonSchema<TSchema extends ArkTypeWithInfer>(
+  schema: TSchema,
+) {
+  const intermediate = arkTypeJsonSchemaTransformer(schema) as JSONSchema7;
+  const result = jsonSchema<TSchema["infer"]>(
+    addAdditionalPropertiesToJsonSchema(intermediate),
+  );
+  return result;
+}
diff --git a/packages/api-seo/src/lib/ai/tools/google-search-console-tool.ts b/packages/api-seo/src/lib/ai/tools/google-search-console-tool.ts
index d00593535..e4b2422f2 100644
--- a/packages/api-seo/src/lib/ai/tools/google-search-console-tool.ts
+++ b/packages/api-seo/src/lib/ai/tools/google-search-console-tool.ts
@@ -4,7 +4,8 @@ import {
   type seoGscPropertyTypeSchema,
 } from "@rectangular-labs/core/schemas/gsc-property-parsers";
 import { getSearchAnalytics } from "@rectangular-labs/google-apis/google-search-console";
-import { type JSONSchema7, jsonSchema, tool } from "ai";
+import { tool } from "ai";
+import { arktypeToAiJsonSchema } from "../arktype-json-schema";
 import type { AgentToolDefinition } from "./utils";
 
 const gscQueryInputSchema = getSearchAnalyticsArgsSchema.omit(
@@ -24,9 +25,7 @@ export function createGscToolWithMetadata({
   const gscTool = tool({
     description:
       "Query the project's Google Search Console account for searchAnalytics for a given date range.",
-    inputSchema: jsonSchema<typeof gscQueryInputSchema.infer>(
-      gscQueryInputSchema.toJsonSchema() as JSONSchema7,
-    ),
+    inputSchema: arktypeToAiJsonSchema(gscQueryInputSchema),
     async execute(props) {
       console.log("getSearchAnalytics", {
         siteUrl,
diff --git a/packages/api-seo/src/lib/ai/tools/settings-tools.ts b/packages/api-seo/src/lib/ai/tools/settings-tools.ts
index d859da5be..77008a999 100644
--- a/packages/api-seo/src/lib/ai/tools/settings-tools.ts
+++ b/packages/api-seo/src/lib/ai/tools/settings-tools.ts
@@ -13,6 +13,7 @@ import {
 import { generateText, Output, tool } from "ai";
 import { type } from "arktype";
 import type { ChatContext } from "../../../types";
+import { arktypeToAiJsonSchema } from "../arktype-json-schema";
 import type { AgentToolDefinition } from "./utils";
 
 export function createSettingsToolsWithMetadata(args: {
@@ -87,7 +88,7 @@ Respond with the new object matching the schema.`;
           const result = await generateText({
             model: openai("gpt-5.1-codex-mini"),
             output: Output.object({
-              schema: businessBackgroundSchema,
+              schema: arktypeToAiJsonSchema(businessBackgroundSchema),
             }),
             prompt,
           });
@@ -97,7 +98,7 @@ Respond with the new object matching the schema.`;
           const result = await generateText({
             model: openai("gpt-5.1-codex-mini"),
             output: Output.object({
-              schema: imageSettingsSchema,
+              schema: arktypeToAiJsonSchema(imageSettingsSchema),
             }),
             prompt,
           });
@@ -107,7 +108,7 @@ Respond with the new object matching the schema.`;
           const result = await generateText({
             model: openai("gpt-5.1-codex-mini"),
             output: Output.object({
-              schema: writingSettingsSchema,
+              schema: arktypeToAiJsonSchema(writingSettingsSchema),
             }),
             prompt,
           });
@@ -116,7 +117,7 @@ Respond with the new object matching the schema.`;
         const result = await generateText({
           model: openai("gpt-5.1-codex-mini"),
           output: Output.object({
-            schema: publishingSettingsSchema,
+            schema: arktypeToAiJsonSchema(publishingSettingsSchema),
           }),
           prompt,
         });
diff --git a/packages/api-seo/src/routes/admin.ts b/packages/api-seo/src/routes/admin.ts
new file mode 100644
index 000000000..a726651b4
--- /dev/null
+++ b/packages/api-seo/src/routes/admin.ts
@@ -0,0 +1,110 @@
+import { ORPCError } from "@orpc/server";
+import { eq, schema } from "@rectangular-labs/db";
+import { updateSeoProject } from "@rectangular-labs/db/operations";
+import { type } from "arktype";
+import { protectedBase } from "../context";
+import { createTask } from "../lib/task";
+
+const triggerOnboardingTask = protectedBase
+  .route({ method: "POST", path: "/trigger-onboarding-task" })
+  .input(type({ projectSlug: "string" }))
+  .output(
+    type({
+      projectId: "string",
+      organizationId: "string",
+      taskId: "string",
+    }),
+  )
+  .handler(async ({ context, input }) => {
+    if (!context.user.email?.endsWith("fluidposts.com")) {
+      throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
+    }
+
+    const db = context.db;
+    const projectResult = await db.query.seoProject.findFirst({
+      where: eq(schema.seoProject.slug, input.projectSlug),
+    });
+
+    if (!projectResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Project not found" });
+    }
+
+    const createTaskResult = await createTask({
+      db,
+      userId: context.user.id,
+      input: {
+        type: "seo-understand-site",
+        projectId: projectResult.id,
+      },
+    });
+
+    if (!createTaskResult.ok) {
+      throw new ORPCError("INTERNAL_SERVER_ERROR", {
+        message: createTaskResult.error.message,
+      });
+    }
+
+    await updateSeoProject(db, {
+      id: projectResult.id,
+      organizationId: projectResult.organizationId,
+      projectResearchWorkflowId: createTaskResult.value.id,
+    });
+
+    return {
+      projectId: projectResult.id,
+      organizationId: projectResult.organizationId,
+      taskId: createTaskResult.value.id,
+    };
+  });
+
+const triggerStrategySuggestionsTask = protectedBase
+  .route({ method: "POST", path: "/trigger-strategy-suggestions-task" })
+  .input(type({ projectSlug: "string", instructions: "string" }))
+  .output(
+    type({
+      projectId: "string",
+      organizationId: "string",
+      taskId: "string",
+    }),
+  )
+  .handler(async ({ context, input }) => {
+    if (!context.user.email?.endsWith("fluidposts.com")) {
+      throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
+    }
+
+    const db = context.db;
+    const projectResult = await db.query.seoProject.findFirst({
+      where: eq(schema.seoProject.slug, input.projectSlug),
+    });
+
+    if (!projectResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Project not found" });
+    }
+
+    const createTaskResult = await createTask({
+      db,
+      userId: context.user.id,
+      input: {
+        type: "seo-generate-strategy-suggestions",
+        projectId: projectResult.id,
+        instructions: input.instructions,
+      },
+    });
+
+    if (!createTaskResult.ok) {
+      throw new ORPCError("INTERNAL_SERVER_ERROR", {
+        message: createTaskResult.error.message,
+      });
+    }
+
+    return {
+      projectId: projectResult.id,
+      organizationId: projectResult.organizationId,
+      taskId: createTaskResult.value.id,
+    };
+  });
+
+export default protectedBase.prefix("/admin").router({
+  triggerOnboardingTask,
+  triggerStrategySuggestionsTask,
+});
diff --git a/packages/api-seo/src/routes/index.ts b/packages/api-seo/src/routes/index.ts
index cd3b71951..281a80c55 100644
--- a/packages/api-seo/src/routes/index.ts
+++ b/packages/api-seo/src/routes/index.ts
@@ -7,6 +7,7 @@ export const router = {
   content: lazy(() => import("./content")),
   strategy: lazy(() => import("./strategy")),
   integrations: lazy(() => import("./integration")),
+  admin: lazy(() => import("./admin")),
   auth: {
     session: lazy(() => import("./auth/session")),
     organization: lazy(() => import("./auth/organization")),
diff --git a/packages/api-seo/src/workflows/onboarding-workflow.ts b/packages/api-seo/src/workflows/onboarding-workflow.ts
index 01d9045fe..35ebb474a 100644
--- a/packages/api-seo/src/workflows/onboarding-workflow.ts
+++ b/packages/api-seo/src/workflows/onboarding-workflow.ts
@@ -16,6 +16,7 @@ import { createDb } from "@rectangular-labs/db";
 import { updateSeoProject } from "@rectangular-labs/db/operations";
 import { generateText, Output, stepCountIs } from "ai";
 import { type } from "arktype";
+import { arktypeToAiJsonSchema } from "../lib/ai/arktype-json-schema";
 import { createWebToolsWithMetadata } from "../lib/ai/tools/web-tools";
 import { logAgentStep } from "../lib/ai/utils/log-agent-step";
 import { createTask } from "../lib/task";
@@ -104,9 +105,11 @@ Homepage Title: ${homepageTitle}
 Extract the name from the above context.`,
 
             output: Output.object({
-              schema: type({
-                name: "string",
-              }),
+              schema: arktypeToAiJsonSchema(
+                type({
+                  name: "string",
+                }),
+              ),
             }),
           });
 
@@ -149,8 +152,9 @@ Extract the name from the above context.`,
               logAgentStep(logInfo, "[backgroundResearch] step finished", step);
             },
             output: Output.object({
-              schema:
+              schema: arktypeToAiJsonSchema(
                 seoUnderstandSiteTaskOutputSchema.get("businessBackground"),
+              ),
             }),
           });
 
@@ -259,9 +263,11 @@ Extract the name from the above context.`,
             logAgentStep(logInfo, "step to extract brand voice finished", step);
           },
           output: Output.object({
-            schema: type({
-              brandVoice: "string",
-            }),
+            schema: arktypeToAiJsonSchema(
+              type({
+                brandVoice: "string",
+              }),
+            ),
           }),
         });
 
diff --git a/packages/api-seo/src/workflows/planner-workflow.ts b/packages/api-seo/src/workflows/planner-workflow.ts
index 1069821a3..7b0bff455 100644
--- a/packages/api-seo/src/workflows/planner-workflow.ts
+++ b/packages/api-seo/src/workflows/planner-workflow.ts
@@ -19,6 +19,7 @@ import {
 import { err, ok, type Result, safe } from "@rectangular-labs/result";
 import { generateText, Output, stepCountIs } from "ai";
 import { type } from "arktype";
+import { arktypeToAiJsonSchema } from "../lib/ai/arktype-json-schema";
 import {
   createTodoToolWithMetadata,
   formatTodoFocusReminder,
@@ -84,7 +85,7 @@ ${serpValue}
       prompt,
       stopWhen: [stepCountIs(40)],
       output: Output.object({
-        schema,
+        schema: arktypeToAiJsonSchema(schema),
       }),
     }),
   );
@@ -337,7 +338,7 @@ ${JSON.stringify(serp)}
       },
       stopWhen: [stepCountIs(25)],
       output: Output.object({
-        schema: outputSchema,
+        schema: arktypeToAiJsonSchema(outputSchema),
       }),
     }),
   );
diff --git a/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts b/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
index 354239bab..b486f31b0 100644
--- a/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
+++ b/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
@@ -27,6 +27,7 @@ import {
 } from "@rectangular-labs/db/operations";
 import { generateText, Output, stepCountIs } from "ai";
 import { apiEnv } from "../env";
+import { arktypeToAiJsonSchema } from "../lib/ai/arktype-json-schema";
 import { createDataforseoToolWithMetadata } from "../lib/ai/tools/dataforseo-tool";
 import { createGscToolWithMetadata } from "../lib/ai/tools/google-search-console-tool";
 import { createStrategyToolsWithMetadata } from "../lib/ai/tools/strategy-tools";
@@ -316,7 +317,7 @@ Generate the next strategy phase now.`,
             );
           },
           output: Output.object({
-            schema: strategyPhaseSuggestionScheme,
+            schema: arktypeToAiJsonSchema(strategyPhaseSuggestionScheme),
           }),
         }).catch((error) => {
           console.error("error generating phase suggestion", error);
diff --git a/packages/api-seo/src/workflows/strategy-suggestions-workflow.ts b/packages/api-seo/src/workflows/strategy-suggestions-workflow.ts
index c583971e0..90817b296 100644
--- a/packages/api-seo/src/workflows/strategy-suggestions-workflow.ts
+++ b/packages/api-seo/src/workflows/strategy-suggestions-workflow.ts
@@ -21,6 +21,7 @@ import {
 import { generateText, Output, stepCountIs } from "ai";
 import { type } from "arktype";
 import { apiEnv } from "../env";
+import { arktypeToAiJsonSchema } from "../lib/ai/arktype-json-schema";
 import { createDataforseoToolWithMetadata } from "../lib/ai/tools/dataforseo-tool";
 import { createGscToolWithMetadata } from "../lib/ai/tools/google-search-console-tool";
 import { createStrategyToolsWithMetadata } from "../lib/ai/tools/strategy-tools";
@@ -78,97 +79,99 @@ export class SeoStrategySuggestionsWorkflow extends WorkflowEntrypoint<
         timeout: "10 minutes",
       },
       async () => {
-        logInfo("creating strategy suggestion tools", {
-          instanceId: event.instanceId,
-          projectId: input.projectId,
-        });
-        const { tools: webTools } = createWebToolsWithMetadata(
-          project,
-          this.env.CACHE,
-        );
-        const dataforseoTools = createDataforseoToolWithMetadata(
-          project,
-          this.env.CACHE,
-        );
-        const db = createDb();
-        const strategyTools = createStrategyToolsWithMetadata({
-          db,
-          projectId: project.id,
-          organizationId: project.organizationId,
-        });
-        const env = apiEnv();
-        const auth = initAuthHandler({
-          baseURL: env.SEO_URL,
-          db,
-          encryptionKey: env.AUTH_SEO_ENCRYPTION_KEY,
-          fromEmail: env.AUTH_SEO_FROM_EMAIL,
-          inboundApiKey: env.SEO_INBOUND_API_KEY,
-          credentialVerificationType: env.AUTH_SEO_CREDENTIAL_VERIFICATION_TYPE,
-          discordClientId: env.AUTH_SEO_DISCORD_ID,
-          discordClientSecret: env.AUTH_SEO_DISCORD_SECRET,
-          githubClientId: env.AUTH_SEO_GITHUB_ID,
-          githubClientSecret: env.AUTH_SEO_GITHUB_SECRET,
-          googleClientId: env.AUTH_SEO_GOOGLE_CLIENT_ID,
-          googleClientSecret: env.AUTH_SEO_GOOGLE_CLIENT_SECRET,
-        });
-        const gscIntegrationResult = await getGscIntegrationForProject({
-          db,
-          projectId: project.id,
-          organizationId: project.organizationId,
-          authOverride: auth,
-        });
-        if (!gscIntegrationResult.ok) {
-          throw new Error(
-            `Something went wrong getting gsc integration ${gscIntegrationResult.error}`,
-            {
-              cause: gscIntegrationResult.error,
-            },
+        try {
+          logInfo("creating strategy suggestion tools", {
+            instanceId: event.instanceId,
+            projectId: input.projectId,
+          });
+          const { tools: webTools } = createWebToolsWithMetadata(
+            project,
+            this.env.CACHE,
           );
-        }
+          const dataforseoTools = createDataforseoToolWithMetadata(
+            project,
+            this.env.CACHE,
+          );
+          const db = createDb();
+          const strategyTools = createStrategyToolsWithMetadata({
+            db,
+            projectId: project.id,
+            organizationId: project.organizationId,
+          });
+          const env = apiEnv();
+          const auth = initAuthHandler({
+            baseURL: env.SEO_URL,
+            db,
+            encryptionKey: env.AUTH_SEO_ENCRYPTION_KEY,
+            fromEmail: env.AUTH_SEO_FROM_EMAIL,
+            inboundApiKey: env.SEO_INBOUND_API_KEY,
+            credentialVerificationType:
+              env.AUTH_SEO_CREDENTIAL_VERIFICATION_TYPE,
+            discordClientId: env.AUTH_SEO_DISCORD_ID,
+            discordClientSecret: env.AUTH_SEO_DISCORD_SECRET,
+            githubClientId: env.AUTH_SEO_GITHUB_ID,
+            githubClientSecret: env.AUTH_SEO_GITHUB_SECRET,
+            googleClientId: env.AUTH_SEO_GOOGLE_CLIENT_ID,
+            googleClientSecret: env.AUTH_SEO_GOOGLE_CLIENT_SECRET,
+          });
+          const gscIntegrationResult = await getGscIntegrationForProject({
+            db,
+            projectId: project.id,
+            organizationId: project.organizationId,
+            authOverride: auth,
+          });
+          if (!gscIntegrationResult.ok) {
+            throw new Error(
+              `Something went wrong getting gsc integration ${gscIntegrationResult.error}`,
+              {
+                cause: gscIntegrationResult.error,
+              },
+            );
+          }
 
-        const gscTools = createGscToolWithMetadata({
-          accessToken: gscIntegrationResult.value?.accessToken ?? null,
-          siteUrl: gscIntegrationResult.value?.config?.domain ?? null,
-          siteType: gscIntegrationResult.value?.config?.propertyType ?? null,
-        });
+          const gscTools = createGscToolWithMetadata({
+            accessToken: gscIntegrationResult.value?.accessToken ?? null,
+            siteUrl: gscIntegrationResult.value?.config?.domain ?? null,
+            siteType: gscIntegrationResult.value?.config?.propertyType ?? null,
+          });
 
-        const existingStrategiesResult = await listStrategiesByProjectId({
-          db,
-          projectId: project.id,
-          organizationId: project.organizationId,
-        });
-        if (!existingStrategiesResult.ok) {
-          throw existingStrategiesResult.error;
-        }
+          const existingStrategiesResult = await listStrategiesByProjectId({
+            db,
+            projectId: project.id,
+            organizationId: project.organizationId,
+          });
+          if (!existingStrategiesResult.ok) {
+            throw existingStrategiesResult.error;
+          }
 
-        const existingStrategies =
-          existingStrategiesResult.value.length > 0
-            ? existingStrategiesResult.value
-                .map((strategy) => {
-                  const goal = strategy.goal
-                    ? formatStrategyGoal(strategy.goal)
-                    : "none";
-                  const updatedAt = strategy.updatedAt
-                    ?.toISOString?.()
-                    ?.slice(0, 10);
-                  const dismissalReason = strategy.dismissalReason
-                    ? `dismissal reason: ${strategy.dismissalReason}`
-                    : "";
-                  return [
-                    `- [${strategy.status}] "${strategy.name}"`,
-                    `id: ${strategy.id}`,
-                    `goal: ${goal}`,
-                    `phases:${strategy.phases?.length ?? 0}`,
-                    `updated:${updatedAt ?? "unknown"}`,
-                    dismissalReason,
-                  ]
-                    .filter(Boolean)
-                    .join("|");
-                })
-                .join("\n")
-            : "- none";
+          const existingStrategies =
+            existingStrategiesResult.value.length > 0
+              ? existingStrategiesResult.value
+                  .map((strategy) => {
+                    const goal = strategy.goal
+                      ? formatStrategyGoal(strategy.goal)
+                      : "none";
+                    const updatedAt = strategy.updatedAt
+                      ?.toISOString?.()
+                      ?.slice(0, 10);
+                    const dismissalReason = strategy.dismissalReason
+                      ? `dismissal reason: ${strategy.dismissalReason}`
+                      : "";
+                    return [
+                      `- [${strategy.status}] "${strategy.name}"`,
+                      `id: ${strategy.id}`,
+                      `goal: ${goal}`,
+                      `phases:${strategy.phases?.length ?? 0}`,
+                      `updated:${updatedAt ?? "unknown"}`,
+                      dismissalReason,
+                    ]
+                      .filter(Boolean)
+                      .join("|");
+                  })
+                  .join("\n")
+              : "- none";
 
-        const system = `You are an SEO strategist generating strategy suggestions.
+          const system = `You are an SEO strategist generating strategy suggestions.
 
 ## Objective
 - Propose strategy suggestions that fit the project's context and current work.
@@ -190,35 +193,48 @@ ${existingStrategies}
 - Use realistic targets for goals and success criteria.
 - Strategies should be content-creation plays (new articles, pillar pages, content clusters), not technical SEO or on-page optimization tasks, unless the instructions explicitly ask for it.
 - Output MUST match the provided JSON schema.`;
-        logInfo("Starting strategy suggestion generation", {
-          instanceId: event.instanceId,
-          projectId: input.projectId,
-        });
-        const outputResult = await generateText({
-          model: openai("gpt-5.2"),
-          system,
-          tools: {
-            ...webTools,
-            ...dataforseoTools.tools,
-            ...strategyTools.tools,
-            ...(gscIntegrationResult.value ? gscTools.tools : {}),
-          },
-          prompt: `Project website: ${project.websiteUrl}
+          logInfo("Starting strategy suggestion generation", {
+            instanceId: event.instanceId,
+            projectId: input.projectId,
+          });
+          const outputResult = await generateText({
+            model: openai("gpt-5.2"),
+            system,
+            tools: {
+              ...webTools,
+              ...dataforseoTools.tools,
+              ...strategyTools.tools,
+              ...(gscIntegrationResult.value ? gscTools.tools : {}),
+            },
+            prompt: `Project website: ${project.websiteUrl}
 Business background:${formatBusinessBackground(project.businessBackground)}
 
 Generate strategy suggestions now.`,
-          stopWhen: [stepCountIs(40)],
-          onStepFinish: (step) => {
-            logAgentStep(logInfo, "step to generate suggestion finished", step);
-          },
-          output: Output.object({
-            schema: type({
-              suggestions: strategySuggestionSchema.array(),
+            stopWhen: [stepCountIs(40)],
+            onStepFinish: (step) => {
+              logAgentStep(
+                logInfo,
+                "step to generate suggestion finished",
+                step,
+              );
+            },
+            output: Output.object({
+              schema: arktypeToAiJsonSchema(
+                type({
+                  suggestions: strategySuggestionSchema.array(),
+                }),
+              ),
             }),
-          }),
-        });
+          });
 
-        return outputResult.output;
+          return outputResult.output;
+        } catch (e) {
+          console.error(
+            "[SeoStrategySuggestionsWorkflow] Error generating strategy suggestions",
+            e,
+          );
+          throw e;
+        }
       },
     );
 
diff --git a/packages/api-seo/src/workflows/writer-workflow.ts b/packages/api-seo/src/workflows/writer-workflow.ts
index 517b7b562..dbca0a52a 100644
--- a/packages/api-seo/src/workflows/writer-workflow.ts
+++ b/packages/api-seo/src/workflows/writer-workflow.ts
@@ -18,6 +18,7 @@ import {
 } from "@rectangular-labs/db/operations";
 import { generateText, Output, stepCountIs } from "ai";
 import { type } from "arktype";
+import { arktypeToAiJsonSchema } from "../lib/ai/arktype-json-schema";
 import { createImageToolsWithMetadata } from "../lib/ai/tools/image-tools";
 import {
   createTodoToolWithMetadata,
@@ -206,7 +207,7 @@ ${outlineText ?? ""}
     const result = await generateText({
       model: google("gemini-3-flash-preview"),
       output: Output.object({
-        schema: inferArticleTypeSchema,
+        schema: arktypeToAiJsonSchema(inferArticleTypeSchema),
       }),
       prompt,
     });
@@ -498,11 +499,13 @@ ${changes.join("\n")}
                 },
               ],
               output: Output.object({
-                schema: type({
-                  heroImage: "string",
-                  heroImageCaption: "string|null",
-                  markdown: "string",
-                }),
+                schema: arktypeToAiJsonSchema(
+                  type({
+                    heroImage: "string",
+                    heroImageCaption: "string|null",
+                    markdown: "string",
+                  }),
+                ),
               }),
               onStepFinish: (step) => {
                 logInfo(`[generateArticle] Step completed:`, {
@@ -637,7 +640,7 @@ ${text}
                 },
               ],
               output: Output.object({
-                schema: reviewArticleOutputSchema,
+                schema: arktypeToAiJsonSchema(reviewArticleOutputSchema),
               }),
               onStepFinish: (step) => {
                 logInfo("review step completed", {
diff --git a/packages/core/src/schema/arktype-json-schema-transformer.ts b/packages/core/src/schema/arktype-json-schema-transformer.ts
new file mode 100644
index 000000000..a1248d347
--- /dev/null
+++ b/packages/core/src/schema/arktype-json-schema-transformer.ts
@@ -0,0 +1,38 @@
+export type ArkTypeSchema = {
+  toJsonSchema: () => unknown;
+};
+
+function replaceStringEnumWithAnyOf(value: unknown): unknown {
+  if (Array.isArray(value)) {
+    return value.map((item) => replaceStringEnumWithAnyOf(item));
+  }
+
+  if (!value || typeof value !== "object") {
+    return value;
+  }
+
+  const record = value as Record<string, unknown>;
+  const normalized: Record<string, unknown> = {};
+
+  for (const [key, item] of Object.entries(record)) {
+    normalized[key] = replaceStringEnumWithAnyOf(item);
+  }
+
+  if (
+    Array.isArray(record.enum) &&
+    record.enum.every((item) => typeof item === "string")
+  ) {
+    normalized.anyOf = [...record.enum];
+    normalized.type = "string";
+    delete normalized.enum;
+  }
+  if (Array.isArray(record.anyOf)) {
+    normalized.type = "string";
+  }
+
+  return normalized;
+}
+
+export function arkTypeJsonSchemaTransformer(schema: ArkTypeSchema) {
+  return replaceStringEnumWithAnyOf(schema.toJsonSchema());
+}
diff --git a/packages/core/src/schemas/strategy-parsers.ts b/packages/core/src/schemas/strategy-parsers.ts
index 503194a5f..746db5bfd 100644
--- a/packages/core/src/schemas/strategy-parsers.ts
+++ b/packages/core/src/schemas/strategy-parsers.ts
@@ -28,7 +28,7 @@ export const strategySuggestionSchema = type({
   motivation: type("string").describe(
     "Why this strategy matters right now, grounded in research or data.",
   ),
-  "description?": type("string").describe(
+  description: type("string|null").describe(
     "Concise description of what will be executed and how it works.",
   ),
   goal: strategyGoalSchema.describe(

From 1b7c753bec2e8264e38bc69a92916fc8dfa4342b Mon Sep 17 00:00:00 2001
From: ElasticBottle <winstonyeo99@yahoo.com>
Date: Mon, 23 Feb 2026 20:08:56 +0800
Subject: [PATCH 2/3] fix: content phase generation

---
 apps/seo/src/routes/_authed/admin/route.tsx   |  99 +++++++++++++++++
 .../api-seo/src/lib/ai/arktype-json-schema.ts |   1 +
 packages/api-seo/src/routes/admin.ts          | 100 ++++++++++++++++++
 .../schema/arktype-json-schema-transformer.ts |   2 +-
 packages/core/src/schemas/strategy-parsers.ts |  39 ++++---
 5 files changed, 223 insertions(+), 18 deletions(-)

diff --git a/apps/seo/src/routes/_authed/admin/route.tsx b/apps/seo/src/routes/_authed/admin/route.tsx
index 01872c82b..54ae61190 100644
--- a/apps/seo/src/routes/_authed/admin/route.tsx
+++ b/apps/seo/src/routes/_authed/admin/route.tsx
@@ -34,6 +34,9 @@ function RouteComponent() {
   );
 
   const [instructions, setInstructions] = useState("");
+  const [phaseOrganizationSlug, setPhaseOrganizationSlug] = useState("");
+  const [phaseProjectSlug, setPhaseProjectSlug] = useState("");
+  const [phaseStrategyName, setPhaseStrategyName] = useState("");
 
   const { mutate: triggerStrategySuggestions, isPending: isPendingStrategy } =
     useMutation(
@@ -50,6 +53,22 @@ function RouteComponent() {
         },
       }),
     );
+  const { mutate: triggerStrategyPhase, isPending: isPendingStrategyPhase } =
+    useMutation(
+      api.admin.triggerStrategyPhaseGenerationTask.mutationOptions({
+        onSuccess: () => {
+          toast.success(
+            "Triggered strategy phase generation workflow successfully.",
+          );
+          setPhaseOrganizationSlug("");
+          setPhaseProjectSlug("");
+          setPhaseStrategyName("");
+        },
+        onError: (error) => {
+          toast.error(error.message);
+        },
+      }),
+    );
 
   const handleSubmit = (e: React.FormEvent) => {
     e.preventDefault();
@@ -72,6 +91,28 @@ function RouteComponent() {
     });
   };
 
+  const handleStrategyPhaseSubmit = (e: React.FormEvent) => {
+    e.preventDefault();
+    if (!phaseOrganizationSlug.trim()) {
+      toast.error("Please enter an organization slug");
+      return;
+    }
+    if (!phaseProjectSlug.trim()) {
+      toast.error("Please enter a project slug");
+      return;
+    }
+    if (!phaseStrategyName.trim()) {
+      toast.error("Please enter a strategy name");
+      return;
+    }
+
+    triggerStrategyPhase({
+      organizationSlug: phaseOrganizationSlug,
+      projectSlug: phaseProjectSlug,
+      strategyName: phaseStrategyName,
+    });
+  };
+
   return (
     <main className="mx-auto flex w-full max-w-3xl flex-col items-center space-y-6 p-6">
       <div className="flex w-full max-w-md flex-col gap-2">
@@ -156,6 +197,64 @@ function RouteComponent() {
           </form>
         </div>
       </div>
+
+      <div className="w-full max-w-md rounded-lg border bg-card text-card-foreground shadow-sm">
+        <div className="flex flex-col space-y-1.5 p-6">
+          <h3 className="font-semibold leading-none tracking-tight">
+            Trigger Strategy Phase Generation
+          </h3>
+          <p className="text-muted-foreground text-sm">
+            Trigger the strategy phase generation workflow in the api-seo
+            package for a specific strategy.
+          </p>
+        </div>
+        <div className="p-6 pt-0">
+          <form className="space-y-4" onSubmit={handleStrategyPhaseSubmit}>
+            <div className="space-y-2">
+              <Label htmlFor="phaseOrganizationSlug">Organization Slug</Label>
+              <Input
+                disabled={isPendingStrategyPhase}
+                id="phaseOrganizationSlug"
+                onChange={(e) => setPhaseOrganizationSlug(e.target.value)}
+                placeholder="e.g. rectangular-labs"
+                value={phaseOrganizationSlug}
+              />
+            </div>
+            <div className="space-y-2">
+              <Label htmlFor="phaseProjectSlug">Project Slug</Label>
+              <Input
+                disabled={isPendingStrategyPhase}
+                id="phaseProjectSlug"
+                onChange={(e) => setPhaseProjectSlug(e.target.value)}
+                placeholder="e.g. acme-corp"
+                value={phaseProjectSlug}
+              />
+            </div>
+            <div className="space-y-2">
+              <Label htmlFor="phaseStrategyName">Strategy Name</Label>
+              <Input
+                disabled={isPendingStrategyPhase}
+                id="phaseStrategyName"
+                onChange={(e) => setPhaseStrategyName(e.target.value)}
+                placeholder="e.g. Topic Cluster For CRM ROI"
+                value={phaseStrategyName}
+              />
+            </div>
+            <Button
+              disabled={
+                !phaseOrganizationSlug.trim() ||
+                !phaseProjectSlug.trim() ||
+                !phaseStrategyName.trim() ||
+                isPendingStrategyPhase
+              }
+              isLoading={isPendingStrategyPhase}
+              type="submit"
+            >
+              Trigger Strategy Phase Generation
+            </Button>
+          </form>
+        </div>
+      </div>
     </main>
   );
 }
diff --git a/packages/api-seo/src/lib/ai/arktype-json-schema.ts b/packages/api-seo/src/lib/ai/arktype-json-schema.ts
index 646fa8356..d0788b45c 100644
--- a/packages/api-seo/src/lib/ai/arktype-json-schema.ts
+++ b/packages/api-seo/src/lib/ai/arktype-json-schema.ts
@@ -53,6 +53,7 @@ export function arktypeToAiJsonSchema<TSchema extends ArkTypeWithInfer>(
   schema: TSchema,
 ) {
   const intermediate = arkTypeJsonSchemaTransformer(schema) as JSONSchema7;
+
   const result = jsonSchema<TSchema["infer"]>(
     addAdditionalPropertiesToJsonSchema(intermediate),
   );
diff --git a/packages/api-seo/src/routes/admin.ts b/packages/api-seo/src/routes/admin.ts
index a726651b4..4ba5e1ac6 100644
--- a/packages/api-seo/src/routes/admin.ts
+++ b/packages/api-seo/src/routes/admin.ts
@@ -104,7 +104,107 @@ const triggerStrategySuggestionsTask = protectedBase
     };
   });
 
+const triggerStrategyPhaseGenerationTask = protectedBase
+  .route({ method: "POST", path: "/trigger-strategy-phase-generation-task" })
+  .input(
+    type({
+      organizationSlug: "string",
+      projectSlug: "string",
+      strategyName: "string",
+    }),
+  )
+  .output(
+    type({
+      projectId: "string",
+      organizationId: "string",
+      strategyId: "string",
+      taskId: "string",
+    }),
+  )
+  .handler(async ({ context, input }) => {
+    if (!context.user.email?.endsWith("fluidposts.com")) {
+      throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
+    }
+
+    const db = context.db;
+
+    const organizationResult = await db.query.organization.findFirst({
+      where: eq(schema.organization.slug, input.organizationSlug),
+    });
+
+    if (!organizationResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Organization not found" });
+    }
+
+    const projectResult = await db.query.seoProject.findFirst({
+      where: (table, { and, eq }) =>
+        and(
+          eq(table.organizationId, organizationResult.id),
+          eq(table.slug, input.projectSlug),
+        ),
+    });
+
+    if (!projectResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Project not found" });
+    }
+
+    const strategyResults = await db.query.seoStrategy.findMany({
+      where: (table, { and, eq, isNull }) =>
+        and(
+          eq(table.organizationId, organizationResult.id),
+          eq(table.projectId, projectResult.id),
+          eq(table.name, input.strategyName),
+          isNull(table.deletedAt),
+        ),
+      limit: 2,
+      orderBy: (fields, { desc }) => [desc(fields.updatedAt)],
+    });
+
+    if (strategyResults.length === 0) {
+      throw new ORPCError("NOT_FOUND", { message: "Strategy not found" });
+    }
+
+    if (strategyResults.length > 1) {
+      throw new ORPCError("BAD_REQUEST", {
+        message:
+          "Multiple strategies found with that name. Please rename the strategy and try again.",
+      });
+    }
+
+    const strategy = strategyResults[0];
+    if (!strategy) {
+      throw new ORPCError("NOT_FOUND", { message: "Strategy not found" });
+    }
+
+    const createTaskResult = await createTask({
+      db,
+      userId: undefined,
+      input: {
+        type: "seo-generate-strategy-phase",
+        projectId: projectResult.id,
+        organizationId: organizationResult.id,
+        strategyId: strategy.id,
+        userId: undefined,
+      },
+      workflowInstanceId: `strategy_phase_generation_${strategy.id}_${crypto.randomUUID().slice(0, 6)}`,
+    });
+
+    if (!createTaskResult.ok) {
+      throw new ORPCError("INTERNAL_SERVER_ERROR", {
+        message: createTaskResult.error.message,
+      });
+    }
+
+    return {
+      projectId: projectResult.id,
+      organizationId: organizationResult.id,
+      strategyId: strategy.id,
+      taskId: createTaskResult.value.id,
+    };
+  });
+
 export default protectedBase.prefix("/admin").router({
   triggerOnboardingTask,
   triggerStrategySuggestionsTask,
+  triggerStrategyPhaseGenerationTask,
 });
diff --git a/packages/core/src/schema/arktype-json-schema-transformer.ts b/packages/core/src/schema/arktype-json-schema-transformer.ts
index a1248d347..134186901 100644
--- a/packages/core/src/schema/arktype-json-schema-transformer.ts
+++ b/packages/core/src/schema/arktype-json-schema-transformer.ts
@@ -26,7 +26,7 @@ function replaceStringEnumWithAnyOf(value: unknown): unknown {
     normalized.type = "string";
     delete normalized.enum;
   }
-  if (Array.isArray(record.anyOf)) {
+  if (Array.isArray(record.anyOf) || record.const) {
     normalized.type = "string";
   }
 
diff --git a/packages/core/src/schemas/strategy-parsers.ts b/packages/core/src/schemas/strategy-parsers.ts
index 746db5bfd..2f8910941 100644
--- a/packages/core/src/schemas/strategy-parsers.ts
+++ b/packages/core/src/schemas/strategy-parsers.ts
@@ -44,19 +44,22 @@ export const cadenceSchema = type({
   // "daily" => frequency is articles/day
   // "weekly" => frequency is articles/week
   // "monthly" => frequency is articles/month
-  period: cadencePeriodSchema
-    .describe("Publishing cadence unit.")
-    .default("weekly"),
-  frequency: type("number.integer >= 1")
-    .describe("Number of items published per period.")
-    .default(3),
+  period: cadencePeriodSchema.describe(
+    "Publishing cadence unit. Default to weekly",
+  ),
+  // .default("weekly"),
+  frequency: type("number.integer >= 1").describe(
+    "Number of items published per period. Default to 3",
+  ),
+  // .default(3),
   // Days that are eligible for publishing. Deselecting a day means we won't publish on that day.
   allowedDays: weekdaySchema
+    .describe("Eligible days for publishing.")
     .array()
     .describe(
-      "Eligible days for publishing. By default prefer mon through fri for publishing",
-    )
-    .default(() => ["mon", "tue", "wed", "thu", "fri"] as const),
+      "The set of days that content will be published on. By default prefer mon through fri for publishing.",
+    ),
+  // .default(() => ["mon", "tue", "wed", "thu", "fri"] as const),
 });
 
 export type PublishingCadence = typeof cadenceSchema.infer;
@@ -95,19 +98,21 @@ export const strategyPhaseSuggestionScheme = type({
     contentDraftId: type("string.uuid").describe(
       "Existing draft to improve/expand.",
     ),
-    "updatedRole?": contentRoleSchema.describe(
-      "Updated role for the content item based on the data. If not provided, the existing role will be used.",
-    ),
-    "updatedTitle?": type("string").describe(
+    updatedRole: contentRoleSchema
+      .or(type.null)
+      .describe(
+        "Updated role for the content item based on the data. If not provided, the existing role will be used.",
+      ),
+    updatedTitle: type("string|null").describe(
       "Updated SEO optimized title for the content item based on the data. If not provided, the existing title will be used.",
     ),
-    "updatedDescription?": type("string").describe(
+    updatedDescription: type("string|null").describe(
       "Updated SEO optimized description for the content item based on the data. If not provided, the existing description will be used.",
     ),
-    "updatedPrimaryKeyword?": type("string").describe(
+    updatedPrimaryKeyword: type("string|null").describe(
       "Updated primary keyword for the content item based on the data. If not provided, the existing primary keyword will be used.",
     ),
-    "updatedNotes?": type("string").describe(
+    updatedNotes: type("string|null").describe(
       "Notes on what we want to improve or expand on. This could be anything from adding new sections and subtopics, to improving the content based on the data, to adding new internal links. If we need to tweak anything in the content of the article, make sure to include notes here.",
     ),
   })
@@ -124,7 +129,7 @@ export const strategyPhaseSuggestionScheme = type({
     plannedPrimaryKeyword: type("string").describe(
       "Primary keyword targeted by the content item.",
     ),
-    "notes?": type("string").describe(
+    notes: type("string|null").describe(
       "Additional notes or constraints for the content item when we get to writing the content.",
     ),
   })

From a2bf7cb10147a1fa38c860c58d84d27457fd985a Mon Sep 17 00:00:00 2001
From: ElasticBottle <winstonyeo99@yahoo.com>
Date: Mon, 23 Feb 2026 20:15:25 +0800
Subject: [PATCH 3/3] fix: typecheck and lint

---
 .../-components/manage-strategy-dialog.tsx    |  1 +
 apps/seo/src/routes/_authed/admin/route.tsx   | 76 +++++++++++++------
 packages/api-seo/src/routes/admin.ts          | 44 +++++++++--
 .../strategy-phase-generation-workflow.ts     |  2 +-
 4 files changed, 93 insertions(+), 30 deletions(-)

diff --git a/apps/seo/src/routes/_authed/$organizationSlug/$projectSlug/strategies/-components/manage-strategy-dialog.tsx b/apps/seo/src/routes/_authed/$organizationSlug/$projectSlug/strategies/-components/manage-strategy-dialog.tsx
index 12f4bf4ed..13167458b 100644
--- a/apps/seo/src/routes/_authed/$organizationSlug/$projectSlug/strategies/-components/manage-strategy-dialog.tsx
+++ b/apps/seo/src/routes/_authed/$organizationSlug/$projectSlug/strategies/-components/manage-strategy-dialog.tsx
@@ -261,6 +261,7 @@ export function ManageStrategyDialog({
                   id={`${fieldPrefix}-description`}
                   placeholder="What will you do and how will it work?"
                   rows={8}
+                  value={field.value || ""}
                 />
                 {fieldState.invalid && (
                   <FieldError errors={[fieldState.error]} />
diff --git a/apps/seo/src/routes/_authed/admin/route.tsx b/apps/seo/src/routes/_authed/admin/route.tsx
index 54ae61190..154a128b7 100644
--- a/apps/seo/src/routes/_authed/admin/route.tsx
+++ b/apps/seo/src/routes/_authed/admin/route.tsx
@@ -19,13 +19,15 @@ export const Route = createFileRoute("/_authed/admin")({
 
 function RouteComponent() {
   const api = getApiClientRq();
+  const [organizationSlug, setOrganizationSlug] = useState("");
   const [projectSlug, setProjectSlug] = useState("");
+  const [instructions, setInstructions] = useState("");
+  const [phaseStrategyName, setPhaseStrategyName] = useState("");
 
   const { mutate: triggerOnboarding, isPending } = useMutation(
     api.admin.triggerOnboardingTask.mutationOptions({
       onSuccess: () => {
         toast.success("Triggered onboarding workflow successfully.");
-        setProjectSlug("");
       },
       onError: (error) => {
         toast.error(error.message);
@@ -33,11 +35,6 @@ function RouteComponent() {
     }),
   );
 
-  const [instructions, setInstructions] = useState("");
-  const [phaseOrganizationSlug, setPhaseOrganizationSlug] = useState("");
-  const [phaseProjectSlug, setPhaseProjectSlug] = useState("");
-  const [phaseStrategyName, setPhaseStrategyName] = useState("");
-
   const { mutate: triggerStrategySuggestions, isPending: isPendingStrategy } =
     useMutation(
       api.admin.triggerStrategySuggestionsTask.mutationOptions({
@@ -45,7 +42,6 @@ function RouteComponent() {
           toast.success(
             "Triggered strategy suggestions workflow successfully.",
           );
-          setProjectSlug("");
           setInstructions("");
         },
         onError: (error) => {
@@ -53,6 +49,7 @@ function RouteComponent() {
         },
       }),
     );
+
   const { mutate: triggerStrategyPhase, isPending: isPendingStrategyPhase } =
     useMutation(
       api.admin.triggerStrategyPhaseGenerationTask.mutationOptions({
@@ -60,8 +57,6 @@ function RouteComponent() {
           toast.success(
             "Triggered strategy phase generation workflow successfully.",
           );
-          setPhaseOrganizationSlug("");
-          setPhaseProjectSlug("");
           setPhaseStrategyName("");
         },
         onError: (error) => {
@@ -72,20 +67,29 @@ function RouteComponent() {
 
   const handleSubmit = (e: React.FormEvent) => {
     e.preventDefault();
+    if (!organizationSlug.trim()) {
+      toast.error("Please enter an organization slug");
+      return;
+    }
     if (!projectSlug.trim()) {
       toast.error("Please enter a project slug");
       return;
     }
-    triggerOnboarding({ projectSlug });
+    triggerOnboarding({ organizationSlug, projectSlug });
   };
 
   const handleStrategySubmit = (e: React.FormEvent) => {
     e.preventDefault();
+    if (!organizationSlug.trim()) {
+      toast.error("Please enter an organization slug");
+      return;
+    }
     if (!projectSlug.trim()) {
       toast.error("Please enter a project slug");
       return;
     }
     triggerStrategySuggestions({
+      organizationSlug,
       projectSlug,
       instructions,
     });
@@ -93,11 +97,11 @@ function RouteComponent() {
 
   const handleStrategyPhaseSubmit = (e: React.FormEvent) => {
     e.preventDefault();
-    if (!phaseOrganizationSlug.trim()) {
+    if (!organizationSlug.trim()) {
       toast.error("Please enter an organization slug");
       return;
     }
-    if (!phaseProjectSlug.trim()) {
+    if (!projectSlug.trim()) {
       toast.error("Please enter a project slug");
       return;
     }
@@ -107,8 +111,8 @@ function RouteComponent() {
     }
 
     triggerStrategyPhase({
-      organizationSlug: phaseOrganizationSlug,
-      projectSlug: phaseProjectSlug,
+      organizationSlug,
+      projectSlug,
       strategyName: phaseStrategyName,
     });
   };
@@ -134,6 +138,16 @@ function RouteComponent() {
         </div>
         <div className="p-6 pt-0">
           <form className="space-y-4" onSubmit={handleSubmit}>
+            <div className="space-y-2">
+              <Label htmlFor="organizationSlug">Organization Slug</Label>
+              <Input
+                disabled={isPending}
+                id="organizationSlug"
+                onChange={(e) => setOrganizationSlug(e.target.value)}
+                placeholder="e.g. acme"
+                value={organizationSlug}
+              />
+            </div>
             <div className="space-y-2">
               <Label htmlFor="projectSlug">Project Slug</Label>
               <Input
@@ -145,7 +159,9 @@ function RouteComponent() {
               />
             </div>
             <Button
-              disabled={!projectSlug.trim() || isPending}
+              disabled={
+                !organizationSlug.trim() || !projectSlug.trim() || isPending
+              }
               isLoading={isPending}
               type="submit"
             >
@@ -167,6 +183,18 @@ function RouteComponent() {
         </div>
         <div className="p-6 pt-0">
           <form className="space-y-4" onSubmit={handleStrategySubmit}>
+            <div className="space-y-2">
+              <Label htmlFor="strategyOrganizationSlug">
+                Organization Slug
+              </Label>
+              <Input
+                disabled={isPendingStrategy}
+                id="strategyOrganizationSlug"
+                onChange={(e) => setOrganizationSlug(e.target.value)}
+                placeholder="e.g. acme"
+                value={organizationSlug}
+              />
+            </div>
             <div className="space-y-2">
               <Label htmlFor="strategyProjectSlug">Project Slug</Label>
               <Input
@@ -188,7 +216,11 @@ function RouteComponent() {
               />
             </div>
             <Button
-              disabled={!projectSlug.trim() || isPendingStrategy}
+              disabled={
+                !organizationSlug.trim() ||
+                !projectSlug.trim() ||
+                isPendingStrategy
+              }
               isLoading={isPendingStrategy}
               type="submit"
             >
@@ -215,9 +247,9 @@ function RouteComponent() {
               <Input
                 disabled={isPendingStrategyPhase}
                 id="phaseOrganizationSlug"
-                onChange={(e) => setPhaseOrganizationSlug(e.target.value)}
+                onChange={(e) => setOrganizationSlug(e.target.value)}
                 placeholder="e.g. rectangular-labs"
-                value={phaseOrganizationSlug}
+                value={organizationSlug}
               />
             </div>
             <div className="space-y-2">
@@ -225,9 +257,9 @@ function RouteComponent() {
               <Input
                 disabled={isPendingStrategyPhase}
                 id="phaseProjectSlug"
-                onChange={(e) => setPhaseProjectSlug(e.target.value)}
+                onChange={(e) => setProjectSlug(e.target.value)}
                 placeholder="e.g. acme-corp"
-                value={phaseProjectSlug}
+                value={projectSlug}
               />
             </div>
             <div className="space-y-2">
@@ -242,8 +274,8 @@ function RouteComponent() {
             </div>
             <Button
               disabled={
-                !phaseOrganizationSlug.trim() ||
-                !phaseProjectSlug.trim() ||
+                !organizationSlug.trim() ||
+                !projectSlug.trim() ||
                 !phaseStrategyName.trim() ||
                 isPendingStrategyPhase
               }
diff --git a/packages/api-seo/src/routes/admin.ts b/packages/api-seo/src/routes/admin.ts
index 4ba5e1ac6..5e6e12253 100644
--- a/packages/api-seo/src/routes/admin.ts
+++ b/packages/api-seo/src/routes/admin.ts
@@ -7,7 +7,7 @@ import { createTask } from "../lib/task";
 
 const triggerOnboardingTask = protectedBase
   .route({ method: "POST", path: "/trigger-onboarding-task" })
-  .input(type({ projectSlug: "string" }))
+  .input(type({ organizationSlug: "string", projectSlug: "string" }))
   .output(
     type({
       projectId: "string",
@@ -16,13 +16,25 @@ const triggerOnboardingTask = protectedBase
     }),
   )
   .handler(async ({ context, input }) => {
-    if (!context.user.email?.endsWith("fluidposts.com")) {
+    if (!context.user.email?.endsWith("@fluidposts.com")) {
       throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
     }
 
     const db = context.db;
+    const organizationResult = await db.query.organization.findFirst({
+      where: eq(schema.organization.slug, input.organizationSlug),
+    });
+
+    if (!organizationResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Organization not found" });
+    }
+
     const projectResult = await db.query.seoProject.findFirst({
-      where: eq(schema.seoProject.slug, input.projectSlug),
+      where: (table, { and, eq }) =>
+        and(
+          eq(table.organizationId, organizationResult.id),
+          eq(table.slug, input.projectSlug),
+        ),
     });
 
     if (!projectResult) {
@@ -59,7 +71,13 @@ const triggerOnboardingTask = protectedBase
 
 const triggerStrategySuggestionsTask = protectedBase
   .route({ method: "POST", path: "/trigger-strategy-suggestions-task" })
-  .input(type({ projectSlug: "string", instructions: "string" }))
+  .input(
+    type({
+      organizationSlug: "string",
+      projectSlug: "string",
+      instructions: "string",
+    }),
+  )
   .output(
     type({
       projectId: "string",
@@ -68,13 +86,25 @@ const triggerStrategySuggestionsTask = protectedBase
     }),
   )
   .handler(async ({ context, input }) => {
-    if (!context.user.email?.endsWith("fluidposts.com")) {
+    if (!context.user.email?.endsWith("@fluidposts.com")) {
       throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
     }
 
     const db = context.db;
+    const organizationResult = await db.query.organization.findFirst({
+      where: eq(schema.organization.slug, input.organizationSlug),
+    });
+
+    if (!organizationResult) {
+      throw new ORPCError("NOT_FOUND", { message: "Organization not found" });
+    }
+
     const projectResult = await db.query.seoProject.findFirst({
-      where: eq(schema.seoProject.slug, input.projectSlug),
+      where: (table, { and, eq }) =>
+        and(
+          eq(table.organizationId, organizationResult.id),
+          eq(table.slug, input.projectSlug),
+        ),
     });
 
     if (!projectResult) {
@@ -122,7 +152,7 @@ const triggerStrategyPhaseGenerationTask = protectedBase
     }),
   )
   .handler(async ({ context, input }) => {
-    if (!context.user.email?.endsWith("fluidposts.com")) {
+    if (!context.user.email?.endsWith("@fluidposts.com")) {
       throw new ORPCError("FORBIDDEN", { message: "Not authorized" });
     }
 
diff --git a/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts b/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
index b486f31b0..d798667aa 100644
--- a/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
+++ b/packages/api-seo/src/workflows/strategy-phase-generation-workflow.ts
@@ -381,7 +381,7 @@ Generate the next strategy phase now.`,
           strategyId: strategy.id,
           title: contentUpdate.updatedTitle,
           description: contentUpdate.updatedDescription,
-          primaryKeyword: contentUpdate.updatedPrimaryKeyword,
+          primaryKeyword: contentUpdate.updatedPrimaryKeyword ?? undefined,
           role: contentUpdate.updatedRole,
           notes: contentUpdate.updatedNotes ?? null,
         });