feat: add slack invite

apsinghdev · apsinghdev · commit 37752e3c56c2 · 2025-10-25T23:25:30.000+05:30
diff --git a/apps/api/src/index.ts b/apps/api/src/index.ts
@@ -13,6 +13,7 @@ import ipBlocker from "./middleware/ipBlock.js";
 import Razorpay from "razorpay";
 import crypto from "crypto";
 import { paymentService } from "./services/payment.service.js";
+import { verifyToken } from "./utils/auth.js";
 
 dotenv.config();
 
@@ -98,6 +99,63 @@ app.get("/test", apiLimiter, (req: Request, res: Response) => {
   res.status(200).json({ status: "ok", message: "Test endpoint is working" });
 });
 
+// Slack Community Invite Endpoint (Protected)
+app.get("/join-community", apiLimiter, async (req: Request, res: Response) => {
+  try {
+    // Get token from Authorization header or query parameter
+    let token: string | undefined;
+    const authHeader = req.headers.authorization;
+
+    if (authHeader && authHeader.startsWith("Bearer ")) {
+      token = authHeader.substring(7); // Remove "Bearer " prefix
+    } else if (req.query.token && typeof req.query.token === "string") {
+      token = req.query.token;
+    }
+
+    if (!token) {
+      return res.status(401).json({ error: "Unauthorized - Missing token" });
+    }
+
+    // Verify token and get user
+    let user;
+    try {
+      user = await verifyToken(token);
+    } catch (error) {
+      return res.status(401).json({ error: "Unauthorized - Invalid token" });
+    }
+
+    // Check if user has an active subscription
+    const subscription = await prismaModule.prisma.subscription.findFirst({
+      where: {
+        userId: user.id,
+        status: "active",
+        endDate: {
+          gte: new Date(),
+        },
+      },
+    });
+
+    if (!subscription) {
+      return res.status(403).json({
+        error: "Forbidden - Active subscription required to join community",
+      });
+    }
+
+    // Get Slack invite URL from environment
+    const slackInviteUrl = process.env.SLACK_INVITE_URL;
+    if (!slackInviteUrl) {
+      console.error("SLACK_INVITE_URL not configured");
+      return res.status(500).json({ error: "Community invite not configured" });
+    }
+
+    // Redirect to Slack community
+    return res.redirect(slackInviteUrl);
+  } catch (error: any) {
+    console.error("Community invite error:", error);
+    return res.status(500).json({ error: "Internal server error" });
+  }
+});
+
 // Razorpay Webhook Handler (Backup Flow)
 app.post("/webhook/razorpay", async (req: Request, res: Response) => {
   try {
diff --git a/apps/api/src/routers/user.ts b/apps/api/src/routers/user.ts
@@ -1,9 +1,15 @@
-import { router, publicProcedure } from "../trpc.js";
+import { router, publicProcedure, protectedProcedure } from "../trpc.js";
 import { userService } from "../services/user.service.js";
 
 export const userRouter = router({
   // get the total count of users
   count: publicProcedure.query(async ({ ctx }) => {
     return await userService.getUserCount(ctx.db.prisma);
   }),
+
+  // check if current user has an active subscription
+  subscriptionStatus: protectedProcedure.query(async ({ ctx }: any) => {
+    const userId = ctx.user.id;
+    return await userService.checkSubscriptionStatus(ctx.db.prisma, userId);
+  }),
 });
diff --git a/apps/api/src/services/user.service.ts b/apps/api/src/services/user.service.ts
@@ -11,4 +11,35 @@ export const userService = {
       total_users: userCount,
     };
   },
+
+  /**
+   * Check if user has an active subscription
+   */
+  async checkSubscriptionStatus(prisma: PrismaClient, userId: string) {
+    const subscription = await prisma.subscription.findFirst({
+      where: {
+        userId,
+        status: "active",
+        endDate: {
+          gte: new Date(),
+        },
+      },
+      include: {
+        plan: true,
+      },
+    });
+
+    return {
+      isPaidUser: !!subscription,
+      subscription: subscription
+        ? {
+            id: subscription.id,
+            planName: subscription.plan?.name,
+            startDate: subscription.startDate,
+            endDate: subscription.endDate,
+            status: subscription.status,
+          }
+        : null,
+    };
+  },
 };
diff --git a/apps/api/src/utils/auth.ts b/apps/api/src/utils/auth.ts
@@ -8,7 +8,7 @@ if (!process.env.JWT_SECRET) {
 }
 
 export const generateToken = (email: string): string => {
-  return jwt.sign({ email }, JWT_SECRET, { expiresIn: "48h" });
+  return jwt.sign({ email }, JWT_SECRET, { expiresIn: "7d" });
 };
 
 export const verifyToken = async (token: string) => {
diff --git a/apps/web/src/app/checkout/page.tsx b/apps/web/src/app/checkout/page.tsx
@@ -1,4 +1,4 @@
-import CheckoutConfirmation from "@/components/checkout/checkout-confirmation";
+import CheckoutWrapper from "@/components/checkout/CheckoutWrapper";
 import Image from "next/image";
 
 export default function Checkout() {
@@ -12,7 +12,7 @@ export default function Checkout() {
         priority
       />
       <div className=" z-10">
-        <CheckoutConfirmation></CheckoutConfirmation>
+        <CheckoutWrapper />
       </div>
     </div>
   );
diff --git a/apps/web/src/components/checkout/CheckoutWrapper.tsx b/apps/web/src/components/checkout/CheckoutWrapper.tsx
@@ -0,0 +1,33 @@
+"use client";
+
+import React from "react";
+import { useSubscription } from "@/hooks/useSubscription";
+import { useRouter } from "next/navigation";
+import CheckoutConfirmation from "./checkout-confirmation";
+
+export default function CheckoutWrapper() {
+  const { isPaidUser, isLoading } = useSubscription();
+  const router = useRouter();
+
+  // Show loading state while checking subscription
+  if (isLoading) {
+    return (
+      <div className="flex flex-col h-screen w-full justify-center items-center">
+        <div className="text-white text-xl">Loading...</div>
+      </div>
+    );
+  }
+
+  // Redirect to pricing if not a paid user
+  if (!isPaidUser) {
+    router.push("/pricing");
+    return (
+      <div className="flex flex-col h-screen w-full justify-center items-center">
+        <div className="text-white text-xl">Redirecting...</div>
+      </div>
+    );
+  }
+
+  // Show checkout confirmation for paid users
+  return <CheckoutConfirmation />;
+}
diff --git a/apps/web/src/components/checkout/checkout-confirmation.tsx b/apps/web/src/components/checkout/checkout-confirmation.tsx
@@ -1,6 +1,9 @@
-import React from "react";
+"use client";
+
+import React, { useState } from "react";
 import { Check } from "lucide-react";
 import { cn } from "@/lib/utils";
+import { useSession } from "next-auth/react";
 
 interface CheckoutConfirmationProps {
   className?: string;
@@ -9,6 +12,27 @@ interface CheckoutConfirmationProps {
 const CheckoutConfirmation: React.FC<CheckoutConfirmationProps> = ({
   className,
 }) => {
+  const { data: session } = useSession();
+  const [error, setError] = useState<string | null>(null);
+
+  const handleJoinCommunity = () => {
+    if (!session?.user) {
+      setError("Please sign in to join the community");
+      return;
+    }
+
+    const accessToken = (session as any)?.accessToken;
+
+    if (!accessToken) {
+      setError("Authentication token not found");
+      return;
+    }
+
+    // Redirect to backend endpoint which will validate subscription and redirect to Slack
+    const apiUrl = process.env.NEXT_PUBLIC_API_URL || "http://localhost:4000";
+    window.location.href = `${apiUrl}/join-community?token=${encodeURIComponent(accessToken)}`;
+  };
+
   return (
     <div className={cn("max-w-4xl mx-auto p-8 lg:p-16", className)}>
       <div className="relative bg-transparent border-2 border-white/20 rounded-[2rem] p-8 lg:p-16 backdrop-blur-sm">
@@ -27,10 +51,27 @@ const CheckoutConfirmation: React.FC<CheckoutConfirmationProps> = ({
             with the next steps from our side.
           </p>
 
+          <p className="text-lg lg:text-xl text-white/90 leading-relaxed font-light max-w-3xl mx-auto">
+            Click on "Join" button below to join the Opensox premium community.
+          </p>
+
           <p className="text-lg lg:text-xl text-white/90 leading-relaxed font-light max-w-3xl mx-auto">
             If you have any doubts, feel free to ping us here:{" "}
             <span className="text-[#A970FF]">hi@opensox.ai</span>
           </p>
+
+          {/* Join Community Button - Only shown when logged in */}
+          {session?.user && (
+            <div className="pt-4">
+              <button
+                onClick={handleJoinCommunity}
+                className="px-8 py-3 bg-[#A970FF] hover:bg-[#9255E8] text-white font-semibold rounded-lg transition-colors duration-200"
+              >
+                Join
+              </button>
+              {error && <p className="text-red-400 text-sm mt-2">{error}</p>}
+            </div>
+          )}
         </div>
       </div>
     </div>
diff --git a/apps/web/src/hooks/useSubscription.ts b/apps/web/src/hooks/useSubscription.ts
@@ -0,0 +1,52 @@
+import { useEffect } from "react";
+import { useSession } from "next-auth/react";
+import { trpc } from "@/lib/trpc";
+import { useSubscriptionStore } from "@/store/useSubscriptionStore";
+
+/**
+ * Custom hook to fetch and manage user subscription status
+ * This hook automatically fetches subscription status when user is logged in
+ * and updates the global subscription store
+ */
+export function useSubscription() {
+  const { data: session, status } = useSession();
+  const {
+    setSubscriptionStatus,
+    setLoading,
+    reset,
+    isPaidUser,
+    subscription,
+    isLoading,
+  } = useSubscriptionStore();
+
+  // Fetch subscription status using tRPC
+  const { data, isLoading: isFetching } = (
+    trpc.user as any
+  ).subscriptionStatus.useQuery(undefined, {
+    enabled: !!session?.user && status === "authenticated",
+    refetchOnWindowFocus: false,
+    refetchOnMount: true,
+  });
+
+  useEffect(() => {
+    if (status === "loading" || isFetching) {
+      setLoading(true);
+      return;
+    }
+
+    if (status === "unauthenticated") {
+      reset();
+      return;
+    }
+
+    if (data) {
+      setSubscriptionStatus(data.isPaidUser, data.subscription);
+    }
+  }, [data, status, isFetching, setSubscriptionStatus, setLoading, reset]);
+
+  return {
+    isPaidUser,
+    subscription,
+    isLoading,
+  };
+}
diff --git a/apps/web/src/store/useSubscriptionStore.ts b/apps/web/src/store/useSubscriptionStore.ts
@@ -0,0 +1,31 @@
+import { create } from "zustand";
+
+interface Subscription {
+  id: string;
+  planName: string | null;
+  startDate: Date;
+  endDate: Date;
+  status: string;
+}
+
+interface SubscriptionState {
+  isPaidUser: boolean;
+  subscription: Subscription | null;
+  isLoading: boolean;
+  setSubscriptionStatus: (
+    isPaidUser: boolean,
+    subscription: Subscription | null
+  ) => void;
+  setLoading: (isLoading: boolean) => void;
+  reset: () => void;
+}
+
+export const useSubscriptionStore = create<SubscriptionState>((set) => ({
+  isPaidUser: false,
+  subscription: null,
+  isLoading: true,
+  setSubscriptionStatus: (isPaidUser, subscription) =>
+    set({ isPaidUser, subscription, isLoading: false }),
+  setLoading: (isLoading) => set({ isLoading }),
+  reset: () => set({ isPaidUser: false, subscription: null, isLoading: true }),
+}));

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@ if (!process.env.JWT_SECRET) {`
`8`	`8`	`}`
`9`	`9`
`10`	`10`	`export const generateToken = (email: string): string => {`
`11`		`- return jwt.sign({ email }, JWT_SECRET, { expiresIn: "48h" });`
	`11`	`+ return jwt.sign({ email }, JWT_SECRET, { expiresIn: "7d" });`
`12`	`12`	`};`
`13`	`13`
`14`	`14`	`export const verifyToken = async (token: string) => {`