Set up Background sync using Trigger.dev

.env.example

@@ -0,0 +1,43 @@
+# Required environment variables
+# for both development and production
+NEXT_PUBLIC_SUPABASE_URL=YOUR_SUPABASE_URL
+NEXT_PUBLIC_SUPABASE_ANON_KEY=YOUR_SUPABASE_ANON_KEY
+SUPABASE_SERVICE_KEY=YOUR_SUPABASE_SERVICE_KEY
+
+# Optional API keys
+OPENAI_API_KEY=YOUR_OPENAI_API_KEY 
+ANTHROPIC_API_KEY=YOUR_ANTHROPIC_API_KEY
+GOOGLE_GENERATIVE_AI_API_KEY=YOUR_GOOGLE_GENERATIVE_AI_API_KEY
+
+# Google Vertex AI credentials
+GOOGLE_VERTEX_PROJECT=YOUR_GOOGLE_VERTEX_PROJECT
+GOOGLE_VERTEX_LOCATION=YOUR_GOOGLE_VERTEX_LOCATION
+GOOGLE_APPLICATION_CREDENTIALS=YOUR_GOOGLE_APPLICATION_CREDENTIALS
+
+# Google Calendar API credentials
+GOOGLE_CLIENT_ID=YOUR_GOOGLE_CLIENT_ID
+GOOGLE_CLIENT_SECRET=YOUR_GOOGLE_CLIENT_SECRET
+GOOGLE_REDIRECT_URI=YOUR_GOOGLE_REDIRECT_URI
+
+# AWS Credentials
+AWS_REGION=YOUR_AWS_REGION
+AWS_ACCESS_KEY_ID=YOUR_AWS_ACCESS_KEY_ID
+AWS_SECRET_ACCESS_KEY=YOUR_AWS_SECRET
+SOURCE_NAME=YOUR_SOURCE_NAME
+SOURCE_EMAIL=YOUR_SOURCE_EMAIL
+
+DEEPGRAM_ENV=YOUR_DEEPGRAM_ENV
+DEEPGRAM_API_KEY=YOUR_DEEPGRAM_API_KEY
+
+MODAL_TOKEN_ID=YOUR_MODAL_TOKEN_ID
+MODAL_TOKEN_SECRET=YOUR_MODAL_TOKEN_SECRET
+
+CF_ACCOUNT_ID=YOUR_CF_ACCOUNT_ID
+CF_API_TOKEN=YOUR_CF_API_TOKEN
+
+# Infrastructure Credentials
+SCRAPER_URL=YOUR_SCRAPER_URL
+AURORA_EXTERNAL_URL=YOUR_AURORA_EXTERNAL_URL
+AURORA_EXTERNAL_WSID=YOUR_AURORA_EXTERNAL_WSID
+PROXY_API_KEY=YOUR_PROXY_API_KEY
+NEXT_PUBLIC_PROXY_API_KEY=YOUR_NEXT_PUBLIC_PROXY_API_KEY

.gitignore

@@ -25,9 +25,9 @@ dist
 # debug
 npm-debug.log*
 yarn-debug.log*
-yarn-error.log*
 
 # local env files
+.env
 .env.local
 .env.development.local
 .env.test.local
@@ -38,4 +38,10 @@ yarn-error.log*
 
 # Typescript
 *.tsbuildinfo
-next-env.d.ts
+next-env.d.ts
+.trigger.env
+.env.local
+.env.*.local
+
+# Trigger.dev
+.trigger/

apps/db/supabase/migrations/20250101000000_add_calendar_sync_coordination.sql

@@ -0,0 +1,53 @@
+-- Create table to coordinate calendar sync operations
+create table "public"."workspace_calendar_sync_coordination" (
+    "ws_id" uuid not null,
+    "last_upsert" timestamp with time zone not null default now(),
+    "created_at" timestamp with time zone default now(),
+    "updated_at" timestamp with time zone default now()
+);
+
+-- Add primary key
+alter table "public"."workspace_calendar_sync_coordination" 
+add constraint "workspace_calendar_sync_coordination_pkey" PRIMARY KEY (ws_id);
+
+-- Add foreign key to workspaces
+alter table "public"."workspace_calendar_sync_coordination" 
+add constraint "workspace_calendar_sync_coordination_ws_id_fkey" 
+FOREIGN KEY (ws_id) REFERENCES workspaces(id) ON DELETE CASCADE;
+
+-- Enable RLS
+alter table "public"."workspace_calendar_sync_coordination" enable row level security;
+
+-- Create policy for workspace members
+create policy "Enable access for workspace members" on "public"."workspace_calendar_sync_coordination" 
+as permissive for all to authenticated using (
+    EXISTS (
+        SELECT 1 FROM workspace_members 
+        WHERE workspace_members.ws_id = workspace_calendar_sync_coordination.ws_id
+        AND workspace_members.user_id = auth.uid()
+    )
+) with check (
+    EXISTS (
+        SELECT 1 FROM workspace_members 
+        WHERE workspace_members.ws_id = workspace_calendar_sync_coordination.ws_id
+        AND workspace_members.user_id = auth.uid()
+    )
+);
+
+-- Create function to update the updated_at timestamp
+CREATE OR REPLACE FUNCTION update_workspace_calendar_sync_coordination_updated_at()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.updated_at = now();
+    RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+-- Create trigger to automatically update updated_at
+CREATE TRIGGER update_workspace_calendar_sync_coordination_updated_at
+    BEFORE UPDATE ON workspace_calendar_sync_coordination
+    FOR EACH ROW
+    EXECUTE FUNCTION update_workspace_calendar_sync_coordination_updated_at();
+
+-- Enable audit tracking
+select audit.enable_tracking('public.workspace_calendar_sync_coordination'::regclass);

apps/web/src/app/[locale]/(dashboard)/[wsId]/calendar/active-sync.tsx

@@ -54,6 +54,12 @@
     }
   };
 
+  const triggerHelloWorld = async () => {
+    const res = await fetch('/api/hello-world');
+    const data = await res.json();
+    console.log(data);
+  };
+
   return (
     <div>
       <div className="mb-4 flex gap-2">
@@ -85,6 +91,7 @@
         >
           Switch to month
         </Button>
+        <Button onClick={() => triggerHelloWorld()}>Trigger Hello World</Button>
       </div>
 
       {/* Add sync progress bar when syncing */}

apps/web/src/app/api/hello-world/route.ts

@@ -0,0 +1,16 @@
+// Next.js API route support: https://nextjs.org/docs/api-routes/introduction
+import { tasks } from '@trigger.dev/sdk/v3';
+import type { helloWorldTask } from '@tuturuuu/trigger/example';
+import { NextResponse } from 'next/server';
+
+//tasks.trigger also works with the edge runtime
+//export const runtime = "edge";
+
+export async function GET() {
+  const handle = await tasks.trigger<typeof helloWorldTask>(
+    'hello-world',
+    'James'
+  );
+
+  return NextResponse.json(handle);
+}