test

.gitignore

@@ -4,4 +4,6 @@ node_modules
 # Nix
 /.direnv/
 
-.env.local
+.env.local
+.vercel
+.env*.local

.npmrc

@@ -0,0 +1 @@
+ignore-scripts=true

.pnpmrc.yaml

@@ -0,0 +1 @@
+ignore-scripts: true

examples/nextjs-blog-cms/.npmrc

@@ -0,0 +1 @@
+ignore-scripts=true

examples/nextjs-blog-cms/app/actions.ts

@@ -1,12 +1,14 @@
 "use server";
+
 import { inngest } from "@/lib/inngest/client";
 import { Json } from "@/lib/supabase/database.types";
 import { createClient } from "@/lib/supabase/server";
 import { type Workflow } from "@/lib/supabase/types";
 
 export const sendBlogPostToReview = async (id: string) => {
-  const supabase = createClient();
-  await supabase
+  const supabase = await createClient();
+
+  await (supabase as any)
     .from("blog_posts")
     .update({
       status: "under review",
@@ -32,8 +34,9 @@ export const approveBlogPostAiSuggestions = async (id: string) => {
 };
 
 export const publishBlogPost = async (id: string) => {
-  const supabase = createClient();
-  await supabase
+  const supabase = await createClient();
+
+  await (supabase as any)
     .from("blog_posts")
     .update({
       status: "published",
@@ -48,23 +51,29 @@ export const publishBlogPost = async (id: string) => {
     },
   });
 };
+
 export const updateWorkflow = async (workflow: Workflow) => {
-  const supabase = createClient();
-  await supabase
+  const supabase = await createClient();
+
+  await (supabase as any)
     .from("workflows")
     .update({
       workflow: workflow.workflow as unknown as Json,
     })
     .eq("id", workflow.id);
 };
 
-export const toggleWorkflow = async (workflowId: number, enabled: boolean) => {
-  const supabase = createClient();
-  await supabase
+export const toggleWorkflow = async (
+  workflowId: number,
+  enabled: boolean
+) => {
+  const supabase = await createClient();
+
+  await (supabase as any)
     .from("workflows")
     .update({
       enabled,
     })
     .eq("id", workflowId)
     .select("*");
-};
+};

examples/nextjs-blog-cms/app/api/blog-posts/route.ts

@@ -2,13 +2,17 @@ import { createClient } from "@/lib/supabase/server";
 import { NextResponse } from "next/server";
 
 export async function GET() {
-  const supabase = createClient();
-  const { data: blogPosts } = await supabase
+  const supabase = await createClient();
+  const { data: blogPosts, error } = await supabase
     .from("blog_posts")
     .select(
       "id, title, subtitle, markdown_ai_revision, created_at, status, markdown, ai_publishing_recommendations"
     )
     .order("created_at", { ascending: false });
 
+  if (error) {
+    return NextResponse.json({ error: error.message }, { status: 500 });
+  }
+
   return NextResponse.json({ blogPosts });
 }

examples/nextjs-blog-cms/app/api/workflows/route.ts

@@ -2,7 +2,7 @@ import { createClient } from "@/lib/supabase/server";
 import { NextResponse } from "next/server";
 
 export async function GET() {
-  const supabase = createClient();
+  const supabase = await createClient();
   const { data: workflows } = await supabase
     .from("workflows")
     .select("*")

examples/nextjs-blog-cms/app/automation/[id]/page.tsx

@@ -2,14 +2,13 @@ import { AutomationEditor } from "@/components/automation-editor";
 import { createClient } from "@/lib/supabase/server";
 import { notFound } from "next/navigation";
 
-export const runtime = "edge";
 
 export default async function Automation({
   params,
 }: {
   params: { id: string };
 }) {
-  const supabase = createClient();
+  const supabase = await createClient();
   const { data: workflow } = await supabase
     .from("workflows")
     .select("*")

examples/nextjs-blog-cms/components/automation-editor.tsx

@@ -19,8 +19,8 @@ import {
 import { updateWorkflow } from "@/app/actions";
 import { actions } from "@/lib/inngest/workflowActions";
 
-import "@inngest/workflow-kit/ui/ui.css";
-import "@xyflow/react/dist/style.css";
+// import "@inngest/workflow-kit/ui/ui.css";
+// import "@xyflow/react/dist/style.css";
 
 export const AutomationEditor = ({ workflow }: { workflow: Workflow }) => {
   const router = useRouter();

examples/nextjs-blog-cms/lib/inngest/workflowActionHandlers.ts

@@ -4,7 +4,7 @@ import OpenAI from "openai";
 import { type BlogPost } from "../supabase/types";
 
 import { loadBlogPost } from "../loaders/blog-post";
-import { createClient } from "../supabase/server";
+import { createClient } from "../supabase/service";
 import { actions } from "./workflowActions";
 import { inngest } from "./client";
 
@@ -28,7 +28,7 @@ function addAiPublishingSuggestion(
     : blogPost.ai_publishing_recommendations + `<br/ >` + additionalSuggestion; // otherwise add one
 }
 
-export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
+export const actionsWithHandlers: EngineAction<any>[] = [
   {
     // Add a Table of Contents
     ...actions[0],
@@ -71,8 +71,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       });
 
       await step.run("save-ai-revision", async () => {
-        await supabase
-          .from("blog_posts")
+          await (supabase as any)
+            .from("blog_posts")
           .update({
             markdown_ai_revision: aiRevision,
             status: "under review",
@@ -124,8 +124,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       });
 
       await step.run("save-ai-revision", async () => {
-        await supabase
-          .from("blog_posts")
+  await (supabase as any)
+  .from("blog_posts")
           .update({
             markdown_ai_revision: aiRevision,
             status: "under review",
@@ -146,8 +146,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       );
 
       await step.run("update-blog-post-status", async () => {
-        await supabase
-          .from("blog_posts")
+   await (supabase as any)
+  .from("blog_posts")
           .update({
             status: "needs approval",
           })
@@ -168,8 +168,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       // without action from the user within 1 day, the AI suggestions are discarded
       if (!approval) {
         await step.run("discard-ai-revision", async () => {
-          await supabase
-            .from("blog_posts")
+       await (supabase as any)
+  .from("blog_posts")
             .update({
               markdown_ai_revision: null,
               status: "draft",
@@ -179,8 +179,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
         });
       } else {
         await step.run("apply-ai-revision", async () => {
-          await supabase
-            .from("blog_posts")
+ await (supabase as any)
+  .from("blog_posts")
             .update({
               markdown: blogPost.markdown_ai_revision,
               markdown_ai_revision: null,
@@ -203,8 +203,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       );
 
       await step.run("apply-ai-revision", async () => {
-        await supabase
-          .from("blog_posts")
+        await (supabase as any)
+  .from("blog_posts")
           .update({
             markdown: blogPost.markdown_ai_revision,
             markdown_ai_revision: null,
@@ -261,8 +261,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       );
 
       await step.run("save-ai-recommendations", async () => {
-        await supabase
-          .from("blog_posts")
+       await (supabase as any)
+  .from("blog_posts")
           .update({
             ai_publishing_recommendations: addAiPublishingSuggestion(
               workflowAction,
@@ -320,8 +320,8 @@ export const actionsWithHandlers: EngineAction<typeof inngest>[] = [
       });
 
       await step.run("save-ai-recommendations", async () => {
-        await supabase
-          .from("blog_posts")
+      await (supabase as any)
+  .from("blog_posts")
           .update({
             ai_publishing_recommendations: addAiPublishingSuggestion(
               workflowAction,

examples/nextjs-blog-cms/lib/loaders/blog-post.ts

@@ -1,4 +1,4 @@
-import { createClient } from "../supabase/server";
+import { createClient } from "../supabase/service";
 import { BlogPost } from "../supabase/types";
 
 export async function loadBlogPost(id: string): Promise<BlogPost> {

examples/nextjs-blog-cms/lib/loaders/workflow.ts

@@ -1,6 +1,6 @@
 import { Workflow } from "@inngest/workflow-kit";
 
-import { createClient } from "../supabase/server";
+import { createClient } from "../supabase/service";
 
 export async function loadWorkflow(event: { name: string }) {
   const supabase = createClient();
@@ -10,5 +10,5 @@ export async function loadWorkflow(event: { name: string }) {
     .eq("trigger", event.name)
     .eq("enabled", true)
     .single();
-  return (data && data.workflow) as unknown as Workflow;
+return (data as any)?.workflow as Workflow;
 }