jokull/src/jobs/examples.ts

22 lines
524 B
TypeScript

import { client } from "@/trigger";
import { Database } from "@/supabase-types";
import { SupabaseManagement } from "@trigger.dev/supabase";
const supabase = new SupabaseManagement({
id: "jokullbase-sanity-check",
});
const db = supabase.db<Database>(process.env.NEXT_PUBLIC_SUPABASE_URL || "");
client.defineJob({
id: "on-new-todos",
name: "On New Todos",
version: "0.1.1",
trigger: db.onInserted({
table: 'potential_arrivals',
}),
run: async (payload, io, ctx) => {
console.log(payload);
},
});