Jobs

apps/dashboard/package.json

@@ -20,11 +20,9 @@
     "@midday/notification": "workspace:*",
     "@midday/supabase": "workspace:*",
     "@midday/ui": "workspace:*",
-    "@novu/headless": "^0.21.0",
+    "@midday/jobs": "workspace:*",
     "@trigger.dev/nextjs": "^2.2.7",
-    "@trigger.dev/react": "^2.2.7",
-    "@trigger.dev/sdk": "^2.2.7",
-    "@trigger.dev/supabase": "^2.2.7",
+    "@novu/headless": "^0.21.0",
     "@vercel/edge-config": "^0.4.1",
     "@vercel/toolbar": "^0.1.5",
     "change-case": "^5.2.0",

apps/dashboard/src/actions/export-transactions-action.ts

@@ -1,6 +1,6 @@
 "use server";
 
-import { client } from "@/trigger";
+import { Events, client } from "@midday/jobs";
 import { getUser } from "@midday/supabase/cached-queries";
 import { action } from "./safe-action";
 import { exportTransactionsSchema } from "./schema";
@@ -11,7 +11,7 @@ export const exportTransactionsAction = action(
     const user = await getUser();
 
     const event = await client.sendEvent({
-      name: "transactions.export",
+      name: Events.TRANSACTIONS_EXPORT,
       payload: {
         from,
         to,

apps/dashboard/src/app/api/trigger/route.ts

@@ -1,9 +1,9 @@
-import { client } from "@/trigger";
+import { client } from "@midday/jobs";
 import { createAppRoute } from "@trigger.dev/nextjs";
 
 export const runtime = "nodejs";
 export const maxDuration = 60;
 
-import "@/jobs/transactions";
+import "@midday/jobs";
 
 export const { POST, dynamic } = createAppRoute(client);

packages/jobs/package.json

@@ -0,0 +1,18 @@
+{
+    "name": "@midday/jobs",
+    "version": "1.0.0",
+    "private": true,
+    "main": "src/index.ts",
+    "scripts": {
+        "clean": "rm -rf .turbo node_modules",
+        "lint": "biome check .",
+        "format": "biome format --write .",
+        "check:types": "tsc --noEmit"
+    },
+    "dependencies": {
+        "@trigger.dev/react": "^2.2.7",
+        "@trigger.dev/sdk": "^2.2.7",
+        "@trigger.dev/supabase": "^2.2.7"
+    }
+}
+

apps/dashboard/src/jobs/client.ts → packages/jobs/src/client.ts

@@ -1,6 +1,13 @@
 import { Database } from "@midday/supabase/src/types";
+import { TriggerClient } from "@trigger.dev/sdk";
 import { Supabase, SupabaseManagement } from "@trigger.dev/supabase";
 
+export const client = new TriggerClient({
+  id: "midday-CpkS",
+  apiKey: process.env.TRIGGER_API_KEY,
+  apiUrl: process.env.TRIGGER_API_URL,
+});
+
 export const supabase = new Supabase<Database>({
   id: "supabase",
   projectId: process.env.SUPABASE_ID!,

packages/jobs/src/index.ts

@@ -0,0 +1,3 @@
+export * from "./transactions";
+export * from "./client";
+export * from "./constants";

apps/dashboard/src/jobs/transactions/created.ts → packages/jobs/src/transactions/created.ts

@@ -1,5 +1,4 @@
-import { client } from "@/trigger";
-import { supabaseTriggers } from "../client";
+import { client, supabaseTriggers } from "@/client";
 import { Events, Jobs } from "../constants";
 import { scheduler } from "./scheduler";
 

apps/dashboard/src/jobs/transactions/encrichment.ts → packages/jobs/src/transactions/encrichment.ts

@@ -1,10 +1,9 @@
-import { client } from "@/trigger";
+import { client, supabase } from "@/client";
+import { Events, Jobs } from "@/constants";
+import { processPromisesBatch } from "@/utils";
 import { eventTrigger } from "@trigger.dev/sdk";
 import { revalidateTag } from "next/cache";
 import { z } from "zod";
-import { supabase } from "../client";
-import { Events, Jobs } from "../constants";
-import { processPromisesBatch } from "./utils";
 
 client.defineJob({
   id: Jobs.TRANSACTIONS_ENCRICHMENT,

apps/dashboard/src/jobs/transactions/export.ts → packages/jobs/src/transactions/export.ts

@@ -1,9 +1,8 @@
-import { client } from "@/trigger";
+import { client, supabase } from "@/client";
+import { Events, Jobs } from "@/constants";
 import { getTransactionsQuery } from "@midday/supabase/queries";
 import { eventTrigger } from "@trigger.dev/sdk";
 import { z } from "zod";
-import { supabase } from "../client";
-import { Events, Jobs } from "../constants";
 
 client.defineJob({
   id: Jobs.TRANSACTIONS_EXPORT,

apps/dashboard/src/jobs/transactions/initial.ts → packages/jobs/src/transactions/initial.ts

@@ -1,11 +1,10 @@
-import { client } from "@/trigger";
+import { client, supabase } from "@/client";
+import { Events, Jobs } from "@/constants";
+import { transformTransactions } from "@/utils";
 import { getTransactions } from "@midday/gocardless";
 import { eventTrigger } from "@trigger.dev/sdk";
 import { revalidateTag } from "next/cache";
 import { z } from "zod";
-import { supabase } from "../client";
-import { Events, Jobs } from "../constants";
-import { transformTransactions } from "./utils";
 
 client.defineJob({
   id: Jobs.TRANSACTIONS_INITIAL_SYNC,

apps/dashboard/src/jobs/transactions/notification.ts → packages/jobs/src/transactions/notification.ts

@@ -1,12 +1,12 @@
-import { client } from "@/trigger";
+import { client, supabase } from "@/client";
+import { Events, Jobs } from "@/constants";
 import TransactionsEmail from "@midday/email/emails/transactions";
 import { getI18n } from "@midday/email/locales";
 import { TriggerEvents, triggerBulk } from "@midday/notification";
+import { renderAsync } from "@react-email/components";
 import { eventTrigger } from "@trigger.dev/sdk";
 import { revalidateTag } from "next/cache";
 import { z } from "zod";
-import { supabase } from "../client";
-import { Events, Jobs } from "../constants";
 
 client.defineJob({
   id: Jobs.TRANSACTIONS_NOTIFICATION,

apps/dashboard/src/jobs/transactions/scheduler.ts → packages/jobs/src/transactions/scheduler.ts

@@ -1,5 +1,5 @@
-import { client } from "@/trigger";
-import { Jobs } from "../constants";
+import { client } from "@/client";
+import { Jobs } from "@/constants";
 
 export const scheduler = client.defineDynamicSchedule({
   id: Jobs.TRANSACTION_SCHEDULER,

apps/dashboard/src/jobs/transactions/sync.ts → packages/jobs/src/transactions/sync.ts

@@ -1,10 +1,9 @@
-import { client } from "@/trigger";
+import { client, supabase } from "@/client";
+import { Events, Jobs } from "@/constants";
+import { transformTransactions } from "@/utils";
 import { getTransactions } from "@midday/gocardless";
 import { revalidateTag } from "next/cache";
-import { supabase } from "../client";
-import { Events, Jobs } from "../constants";
 import { scheduler } from "./scheduler";
-import { transformTransactions } from "./utils";
 
 client.defineJob({
   id: Jobs.TRANSACTIONS_SYNC,

packages/jobs/tsconfig.json

@@ -0,0 +1,11 @@
+{
+    "extends": "../../tsconfig.json",
+    "compilerOptions": {
+        "baseUrl": ".",
+        "paths": {
+          "@/*": ["./src/*"]
+        },
+    },
+    "include": ["src", "*.ts"]
+  }
+