Supabase

1
import { SupabaseManagement, Supabase } from "@trigger.dev/supabase";
2
import { OpenAI } from "@trigger.dev/openai";
3
import { TriggerClient } from "@trigger.dev/sdk";
4
const supabaseManagement = new SupabaseManagement({
5
  id: "supabase-management",
6
});
7

8
const openai = new OpenAI({
9
  id: "open-ai",
10
  apiKey: process.env.OPENAI_API_KEY!,
11
});
12

13
// Use Supabase integration to run authenticated tasks using the service_role key
14
const supabase = new Supabase({
15
  id: "supabase",
16
  supabaseKey: process.env.SUPABASE_SERVICE_ROLE_KEY!,
17
  supabaseUrl: "https://<project id>.supabase.co",
18
});
19

20
// Pass the generated types to the db instance
21
const db = supabase.db<Database>("https://<project id>.supabase.co");
22

23
client.defineJob({
24
  id: "auto-generate-blog-title",
25
  name: "Auto generate blog title",
26
  version: "1.0.0",
27
  // Subscribe to new blog posts being created
28
  trigger: db.onInserted({
29
    table: "blog_posts",
30
  }),
31
  // Define the integrations that this Job will use
32
  integrations: {
33
    supabase,
34
    openai,
35
  },
36
  run: async (payload, io, ctx) => {
37
    const result = await io.openai.backgroundCreateChatCompletion(
38
      "create-blog-title",
39
      {
40
        model: "gpt-3.5-turbo",
41
        messages: [
42
          {
43
            role: "user",
44
            content: `Suggest some great titles for this blog post: \n ${payload.record.content}`,
45
          },
46
        ],
47
      }
48
    );
49

50
    const blogTitle = result.choices[0].message.content;
51

52
    if (blogTitle) {
53
      // Set the title for the blog post
54
      const { data, error } = await io.supabase.runTask(
55
        "update-blog-post",
56
        async (db) => {
57
          return db
58
            .from("blog_posts")
59
            .update({ title: blogTitle })
60
            .eq("id", payload.record.id)
61
            .select("*");
62
        }
63
      );
64
    }
65
  },
66
});