Merge pull request #327 from apsinghdev/feat/pro-sessions

[feat] add pro session

Author: apsinghdev

.gitignore

@@ -36,3 +36,7 @@ yarn-error.log*
 # Misc
 .DS_Store
 *.pem
+
+# specific file
+seed-sessions.js
+howtos.md

apps/api/prisma/migrations/20260117093501_add_pro_sessions/migration.sql

@@ -0,0 +1,35 @@
+-- CreateTable
+CREATE TABLE "WeeklySession" (
+    "id" TEXT NOT NULL,
+    "title" TEXT NOT NULL,
+    "description" TEXT,
+    "youtubeUrl" TEXT NOT NULL,
+    "sessionDate" TIMESTAMP(3) NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "WeeklySession_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "SessionTopic" (
+    "id" TEXT NOT NULL,
+    "sessionId" TEXT NOT NULL,
+    "timestamp" TEXT NOT NULL,
+    "topic" TEXT NOT NULL,
+    "order" INTEGER NOT NULL,
+
+    CONSTRAINT "SessionTopic_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE INDEX "WeeklySession_sessionDate_idx" ON "WeeklySession"("sessionDate");
+
+-- CreateIndex
+CREATE INDEX "WeeklySession_createdAt_idx" ON "WeeklySession"("createdAt");
+
+-- CreateIndex
+CREATE INDEX "SessionTopic_sessionId_order_idx" ON "SessionTopic"("sessionId", "order");
+
+-- AddForeignKey
+ALTER TABLE "SessionTopic" ADD CONSTRAINT "SessionTopic_sessionId_fkey" FOREIGN KEY ("sessionId") REFERENCES "WeeklySession"("id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/api/prisma/schema.prisma

@@ -115,3 +115,28 @@ model Plan {
   updatedAt     DateTime       @updatedAt
   subscriptions Subscription[]
 }
+
+model WeeklySession {
+  id          String        @id @default(cuid())
+  title       String
+  description String?
+  youtubeUrl  String
+  sessionDate DateTime
+  createdAt   DateTime      @default(now())
+  updatedAt   DateTime      @updatedAt
+  topics      SessionTopic[]
+
+  @@index([sessionDate])
+  @@index([createdAt])
+}
+
+model SessionTopic {
+  id        String         @id @default(cuid())
+  sessionId String
+  timestamp String
+  topic     String
+  order     Int
+  session   WeeklySession  @relation(fields: [sessionId], references: [id], onDelete: Cascade)
+
+  @@index([sessionId, order])
+}

apps/api/src/routers/_app.ts

@@ -4,6 +4,7 @@ import { userRouter } from "./user.js";
 import { projectRouter } from "./projects.js";
 import { authRouter } from "./auth.js";
 import { paymentRouter } from "./payment.js";
+import { sessionsRouter } from "./sessions.js";
 import { testimonialRouter } from "./testimonial.js";
 import { z } from "zod";
 
@@ -22,6 +23,7 @@ export const appRouter = router({
   project: projectRouter,
   auth: authRouter,
   payment: paymentRouter,
+  sessions: sessionsRouter,
   testimonial: testimonialRouter,
 });
 

apps/api/src/routers/sessions.ts

@@ -0,0 +1,24 @@
+import { TRPCError } from "@trpc/server";
+import { router, protectedProcedure, type ProtectedContext } from "../trpc.js";
+import {
+  sessionService,
+  AuthorizationError,
+} from "../services/session.service.js";
+
+export const sessionsRouter = router({
+  getAll: protectedProcedure.query(async ({ ctx }) => {
+    const userId = (ctx as ProtectedContext).user.id;
+
+    try {
+      return await sessionService.getSessions(ctx.db.prisma, userId);
+    } catch (error) {
+      if (error instanceof AuthorizationError) {
+        throw new TRPCError({
+          code: "FORBIDDEN",
+          message: error.message,
+        });
+      }
+      throw error;
+    }
+  }),
+});

apps/api/src/services/session.service.ts

@@ -0,0 +1,159 @@
+import type { Prisma, PrismaClient } from "@prisma/client";
+import { PrismaClientKnownRequestError } from "@prisma/client/runtime/library";
+import type { ExtendedPrismaClient } from "../prisma.js";
+import { SUBSCRIPTION_STATUS } from "../constants/subscription.js";
+
+export type SessionWithTopics = Prisma.WeeklySessionGetPayload<{
+  select: {
+    id: true;
+    title: true;
+    description: true;
+    youtubeUrl: true;
+    sessionDate: true;
+    topics: {
+      select: {
+        id: true;
+        timestamp: true;
+        topic: true;
+        order: true;
+      };
+    };
+  };
+}>;
+
+export class AuthorizationError extends Error {
+  constructor(message: string) {
+    super(message);
+    this.name = "AuthorizationError";
+  }
+}
+
+/**
+ * retry helper with exponential backoff for transient db failures
+ */
+async function withRetry<T>(
+  operation: () => Promise<T>,
+  options: {
+    maxRetries?: number;
+    baseDelay?: number;
+    multiplier?: number;
+    operationName?: string;
+  } = {}
+): Promise<T> {
+  const {
+    maxRetries = 3,
+    baseDelay = 100,
+    multiplier = 2,
+    operationName = "database operation",
+  } = options;
+
+  let lastError: Error | undefined;
+
+  for (let attempt = 0; attempt <= maxRetries; attempt++) {
+    try {
+      return await operation();
+    } catch (error) {
+      lastError = error as Error;
+      const isTransient =
+        error instanceof PrismaClientKnownRequestError &&
+        (error.code === "P1001" || // connection error
+          error.code === "P1002" || // connection timeout
+          error.code === "P1008" || // operations timed out
+          error.code === "P1017"); // server closed connection
+
+      const isNetworkError =
+        error instanceof Error &&
+        (error.message.includes("ECONNREFUSED") ||
+          error.message.includes("ETIMEDOUT") ||
+          error.message.includes("ENOTFOUND"));
+
+      if (!isTransient && !isNetworkError) {
+        throw error;
+      }
+
+      if (attempt < maxRetries) {
+        const delay = baseDelay * Math.pow(multiplier, attempt);
+        console.warn(
+          `[${new Date().toISOString()}] ${operationName} failed (attempt ${attempt + 1}/${maxRetries + 1}), retrying in ${delay}ms...`,
+          error
+        );
+        await new Promise((resolve) => setTimeout(resolve, delay));
+      }
+    }
+  }
+
+  throw lastError;
+}
+
+export const sessionService = {
+  /**
+   * Get all sessions for authenticated paid users
+   * Sessions are ordered by sessionDate descending (newest first)
+   */
+  async getSessions(
+    prisma: ExtendedPrismaClient | PrismaClient,
+    userId: string
+  ): Promise<SessionWithTopics[]> {
+    const subscription = await withRetry(
+      () =>
+        prisma.subscription.findFirst({
+          where: {
+            userId,
+            status: SUBSCRIPTION_STATUS.ACTIVE,
+            endDate: {
+              gte: new Date(),
+            },
+          },
+        }),
+      { operationName: "subscription check" }
+    );
+
+    if (!subscription) {
+      throw new AuthorizationError(
+        "Active subscription required to access sessions"
+      );
+    }
+
+    try {
+      const sessions = await withRetry(
+        () =>
+          prisma.weeklySession.findMany({
+            select: {
+              id: true,
+              title: true,
+              description: true,
+              youtubeUrl: true,
+              sessionDate: true,
+              topics: {
+                select: {
+                  id: true,
+                  timestamp: true,
+                  topic: true,
+                  order: true,
+                },
+                orderBy: {
+                  order: "asc",
+                },
+              },
+            },
+            orderBy: {
+              sessionDate: "desc",
+            },
+          }),
+        { operationName: "session fetch" }
+      );
+
+      return sessions;
+    } catch (error) {
+      const timestamp = new Date().toISOString();
+      const functionName = "getSessions";
+
+      console.error(
+        `[${timestamp}] Error in sessionService.${functionName} - userId: ${userId}`,
+        error
+      );
+
+      throw error;
+    }
+  },
+};

apps/api/src/trpc.ts

@@ -1,7 +1,8 @@
-import { initTRPC, TRPCError } from "@trpc/server";
+import { initTRPC, TRPCError, type AnyProcedure } from "@trpc/server";
 import superjson from "superjson";
 import type { Context } from "./context.js";
 import { verifyToken } from "./utils/auth.js";
+import type { User } from "@prisma/client";
 
 const t = initTRPC.context<Context>().create({
   transformer: superjson,
@@ -35,6 +36,10 @@ const isAuthed = t.middleware(async ({ ctx, next }) => {
   }
 });
 
+export type ProtectedContext = Context & { user: User };
+
 export const router = t.router;
 export const publicProcedure = t.procedure;
-export const protectedProcedure:any = t.procedure.use(isAuthed);
+export const protectedProcedure: typeof t.procedure = t.procedure.use(
+  isAuthed
+) as any;

apps/web/src/app/(main)/dashboard/pro/dashboard/page.tsx

@@ -4,7 +4,8 @@ import { useSubscription } from "@/hooks/useSubscription";
 import { useRouter } from "next/navigation";
 import { useEffect, useState } from "react";
 import { useSession } from "next-auth/react";
-import { trpc } from "@/lib/trpc";
+import Link from "next/link";
+import { Play } from "lucide-react";
 
 export default function ProDashboardPage() {
   const { isPaidUser, isLoading } = useSubscription();
@@ -13,19 +14,6 @@ export default function ProDashboardPage() {
   const [error, setError] = useState<string | null>(null);
   const [isJoining, setIsJoining] = useState(false);
 
-  // Check if user has already submitted a testimonial
-  const { data: testimonialData } = (
-    trpc as any
-  ).testimonial.getMyTestimonial.useQuery(undefined, {
-    enabled: !!isPaidUser,
-    retry: false,
-    refetchOnWindowFocus: true,
-    refetchOnMount: true,
-    staleTime: 0, // Always fetch fresh data
-  });
-
-  const hasSubmittedTestimonial = !!testimonialData?.testimonial;
-
   useEffect(() => {
     if (!isLoading && !isPaidUser) {
       router.push("/pricing");
@@ -94,7 +82,7 @@ export default function ProDashboardPage() {
         return;
       }
 
-      window.open(slackInviteUrl, "_blank", "noopener,noreferrer");
+      window.location.href = slackInviteUrl;
     } catch (err) {
       console.error("Failed to join community:", err);
       setError("Failed to connect to server");
@@ -123,27 +111,26 @@ export default function ProDashboardPage() {
           soon you&apos;ll see all the pro perks here. thanks for investin!
         </h1>
         {isPaidUser && (
-          <div className="mt-6">
-            <div className="flex flex-wrap gap-4 justify-center">
-              <button
-                onClick={handleJoinSlack}
-                disabled={isJoining}
-                className="px-4 py-2 bg-brand-purple hover:bg-brand-purple-light text-text-primary font-medium rounded-lg transition-colors duration-200 disabled:opacity-50 disabled:cursor-not-allowed text-sm"
-              >
-                {isJoining ? "Joining..." : "Join Slack"}
-              </button>
-              {!hasSubmittedTestimonial && (
-                <button
-                  onClick={() => router.push("/testimonials/submit")}
-                  className="px-4 py-2 bg-brand-purple hover:bg-brand-purple-light text-text-primary font-medium rounded-lg transition-colors duration-200 text-sm"
-                >
-                  Submit Testimonial
-                </button>
-              )}
-            </div>
-            {error && <p className="text-error-text text-sm mt-2">{error}</p>}
+          <div className="mt-6 flex flex-col sm:flex-row items-center justify-center gap-3">
+            <Link
+              href="/dashboard/pro/sessions"
+              className="inline-flex items-center gap-2 px-4 py-2 bg-brand-purple hover:bg-brand-purple-light text-text-primary font-medium rounded-lg transition-colors duration-200 text-sm"
+            >
+              <Play className="w-4 h-4" />
+              Pro Sessions
+            </Link>
+            <button
+              onClick={handleJoinSlack}
+              disabled={isJoining}
+              className="px-4 py-2 bg-dash-surface border border-dash-border hover:border-brand-purple/50 text-text-primary font-medium rounded-lg transition-colors duration-200 disabled:opacity-50 disabled:cursor-not-allowed text-sm"
+            >
+              {isJoining ? "Joining..." : "Join Slack"}
+            </button>
           </div>
         )}
+        {error && (
+          <p className="text-error-text text-sm mt-2 text-center">{error}</p>
+        )}
       </div>
     </div>
   );