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 openai = new OpenAI({
5
  id: "open-ai",
6
  apiKey: process.env.OPENAI_API_KEY!,
7
});
8

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

16
const supabaseManagement = new SupabaseManagement({
17
  id: "supabase-management",
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: "ai-all-the-things",
25
  name: "AI all the images",
26
  version: "1.0.0",
27
  // Subscribe to objects being inserted
28
  trigger: db.onInserted({
29
    schema: "storage",
30
    table: "objects",
31
    filter: {
32
      record: {
33
        bucket_id: ["uploads"],
34
        name: [
35
          {
36
            $endsWith: ".png",
37
          },
38
        ],
39
      },
40
    },
41
  }),
42
  // Define the integrations that this Job will use
43
  integrations: {
44
    supabase,
45
    openai,
46
  },
47
  run: async (payload, io, ctx) => {
48
    // Assuming the bucket is private, we create a signed url for temporary access
49
    // Use the native supabase client to get a signed url
50
    const { error, data } = await io.supabase.client.storage
51
      .from("example_bucket")
52
      .createSignedUrl(payload.record.name, 60);
53

54
    if (error) {
55
      throw error;
56
    }
57

58
    const imageVariation = await io.openai.createImageVariation(
59
      "variation-image",
60
      {
61
        image: data.signedUrl,
62
        n: 2,
63
        response_format: "url",
64
        size: "512x512",
65
      }
66
    );
67

68
    // do something with the imageVariation response
69
  },
70
});