diff --git a/.env.example b/.env.example
index 08ac10b6a..a81b670a0 100644
--- a/.env.example
+++ b/.env.example
@@ -6,4 +6,9 @@ DATABASE_URL=postgresql://postgres:postgres@localhost:5432/gumboard
GOOGLE_CLIENT_ID=your_google-client_id
GOOGLE_CLIENT_SECRET=your_google-client_secret
GITHUB_CLIENT_ID=your_github_client_id
-GITHUB_CLIENT_SECRET=your_github_client_secret
\ No newline at end of file
+GITHUB_CLIENT_SECRET=your_github_client_secret
+QSTASH_URL=https://qstash.upstash.io
+QSTASH_TOKEN=your-qstash-token
+QSTASH_CURRENT_SIGNING_KEY=your-current-signing-key
+QSTASH_NEXT_SIGNING_KEY=your-next-signing-key
+BASE_URL=http://localhost:3000
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index 89db765f3..d309a92fb 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -38,7 +38,7 @@ jobs:
DATABASE_URL: postgresql://postgres:postgres@localhost:5432/gumboard_test
EMAIL_FROM: noreply@example.com
AUTH_RESEND_KEY: dummy-resend-key
-
+ BASE_URL: https://gumboard.com
steps:
- uses: actions/checkout@v4
diff --git a/app/api/organization/invites/worker/route.ts b/app/api/organization/invites/worker/route.ts
new file mode 100644
index 000000000..4c1f89ffe
--- /dev/null
+++ b/app/api/organization/invites/worker/route.ts
@@ -0,0 +1,104 @@
+import "server-only";
+
+import { db } from "@/lib/db";
+import { NextResponse } from "next/server";
+import { verifySignatureAppRouter } from "@upstash/qstash/nextjs";
+import { env } from "@/lib/env";
+import { Resend } from "resend";
+
+const resend = new Resend(env.AUTH_RESEND_KEY);
+
+/**
+ * Actual business logic (NO QStash verification here)
+ * This function is SAFE to import at build time
+ */
+async function handler(request: Request) {
+ try {
+ const { organization, user, emails } = await request.json();
+
+ if (!Array.isArray(emails) || emails.length === 0) {
+ return NextResponse.json(
+ {
+ message: "please send emails in array",
+ success: false,
+ },
+ { status: 400 }
+ );
+ }
+
+ const invites = await db.organizationInvite.createManyAndReturn({
+ data: emails.map((email: string) => ({
+ email,
+ organizationId: organization.id,
+ invitedBy: user.id,
+ })),
+ skipDuplicates: true,
+ });
+
+ if (invites.length === 0) {
+ return NextResponse.json(
+ { success: true, message: "no new invites created" },
+ { status: 200 }
+ );
+ }
+
+ const batch = invites.map((invite) => ({
+ from: env.EMAIL_FROM,
+ to: invite.email,
+ subject: `${user.name} invited you to join ${organization.name}`,
+ html: `
+
+
You're invited to join ${organization.name}!
+
${user.name} (${user.email}) has invited you to join their organization on Gumboard.
+
Click the link below to accept the invitation:
+
+ Accept Invitation
+
+
+ If you don't want to receive these emails, please ignore this message.
+
+
-
You're invited to join ${orgName}!
-
${session.user.name} (${session.user.email}) has invited you to join their organization on Gumboard.
-
Click the link below to accept the invitation:
-
- Accept Invitation
-
-
- If you don't want to receive these emails, please ignore this message.
-
-