Merge pull request #131 from apsinghdev/feat/auto-onboarding

auto onboarding

Author: apsinghdev

apps/api/package.json

@@ -34,6 +34,9 @@
     "express-rate-limit": "^7.5.0",
     "helmet": "^7.2.0",
     "jsonwebtoken": "^9.0.2",
+    "razorpay": "^2.9.6",
+    "superjson": "^2.2.5",
+    "zeptomail": "^6.2.1",
     "zod": "^4.1.9"
   }
 }

apps/api/prisma/migrations/20241216100538_init/migration.sql

@@ -0,0 +1,7 @@
+-- CreateTable
+CREATE TABLE "QueryCount" (
+    "id" INTEGER NOT NULL DEFAULT 1,
+    "total_queries" INTEGER NOT NULL,
+
+    CONSTRAINT "QueryCount_pkey" PRIMARY KEY ("id")
+);

apps/api/prisma/migrations/20250113181752_bigint_qc/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "QueryCount" ALTER COLUMN "total_queries" SET DATA TYPE BIGINT;

apps/api/prisma/migrations/20250113182224_add_user_and_ac/migration.sql

@@ -0,0 +1,38 @@
+-- CreateTable
+CREATE TABLE "User" (
+    "id" TEXT NOT NULL,
+    "email" TEXT NOT NULL,
+    "firstName" TEXT NOT NULL,
+    "authMethod" TEXT NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastLogin" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "User_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Account" (
+    "id" TEXT NOT NULL,
+    "userId" TEXT NOT NULL,
+    "type" TEXT NOT NULL,
+    "provider" TEXT NOT NULL,
+    "providerAccountId" TEXT NOT NULL,
+    "refresh_token" TEXT,
+    "access_token" TEXT,
+    "expires_at" INTEGER,
+    "token_type" TEXT,
+    "scope" TEXT,
+    "id_token" TEXT,
+    "session_state" TEXT,
+
+    CONSTRAINT "Account_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "User_email_key" ON "User"("email");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Account_provider_providerAccountId_key" ON "Account"("provider", "providerAccountId");
+
+-- AddForeignKey
+ALTER TABLE "Account" ADD CONSTRAINT "Account_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/api/prisma/migrations/20251021101502_add_ox_premium/migration.sql

@@ -0,0 +1,59 @@
+-- CreateTable
+CREATE TABLE "Payment" (
+    "id" TEXT NOT NULL,
+    "userId" TEXT NOT NULL,
+    "subscriptionId" TEXT,
+    "razorpayPaymentId" TEXT NOT NULL,
+    "razorpayOrderId" TEXT NOT NULL,
+    "amount" INTEGER NOT NULL,
+    "currency" TEXT NOT NULL DEFAULT 'INR',
+    "status" TEXT NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "Payment_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Subscription" (
+    "id" TEXT NOT NULL,
+    "userId" TEXT NOT NULL,
+    "planId" TEXT NOT NULL,
+    "status" TEXT NOT NULL,
+    "startDate" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "endDate" TIMESTAMP(3) NOT NULL,
+    "autoRenew" BOOLEAN NOT NULL DEFAULT true,
+
+    CONSTRAINT "Subscription_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Plan" (
+    "id" TEXT NOT NULL,
+    "name" TEXT NOT NULL,
+    "interval" TEXT NOT NULL,
+    "price" INTEGER NOT NULL,
+    "currency" TEXT NOT NULL DEFAULT 'INR',
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "Plan_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Payment_razorpayPaymentId_key" ON "Payment"("razorpayPaymentId");
+
+-- CreateIndex
+CREATE INDEX "Subscription_userId_idx" ON "Subscription"("userId");
+
+-- AddForeignKey
+ALTER TABLE "Payment" ADD CONSTRAINT "Payment_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Payment" ADD CONSTRAINT "Payment_subscriptionId_fkey" FOREIGN KEY ("subscriptionId") REFERENCES "Subscription"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Subscription" ADD CONSTRAINT "Subscription_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Subscription" ADD CONSTRAINT "Subscription_planId_fkey" FOREIGN KEY ("planId") REFERENCES "Plan"("id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/api/prisma/migrations/20251030121123_add_payment_constraints/migration.sql

@@ -0,0 +1,41 @@
+/*
+  Warnings:
+
+  - Changed the type of `status` on the `Payment` table. No cast exists, the column would be dropped and recreated, which cannot be done if there is data, since the column is required.
+  - Changed the type of `status` on the `Subscription` table. No cast exists, the column would be dropped and recreated, which cannot be done if there is data, since the column is required.
+
+*/
+-- CreateEnum
+CREATE TYPE "PaymentStatus" AS ENUM ('created', 'authorized', 'captured', 'refunded', 'failed');
+
+-- CreateEnum
+CREATE TYPE "SubscriptionStatus" AS ENUM ('created', 'authenticated', 'active', 'pending', 'halted', 'cancelled', 'completed', 'expired');
+
+-- AlterTable: Migrate Payment.status from TEXT to PaymentStatus enum
+-- First, temporarily drop NOT NULL constraint to allow safe conversion
+ALTER TABLE "Payment" ALTER COLUMN "status" DROP NOT NULL;
+
+-- Convert the column type preserving existing data
+ALTER TABLE "Payment" ALTER COLUMN "status" TYPE "PaymentStatus" USING status::"PaymentStatus";
+
+-- Backfill any NULLs with a default value if needed (shouldn't be necessary but being safe)
+-- If there are NULLs, we'd set a default here, but since original was NOT NULL, this shouldn't be needed
+
+-- Re-add NOT NULL constraint after successful conversion
+ALTER TABLE "Payment" ALTER COLUMN "status" SET NOT NULL;
+
+-- AlterTable: Migrate Subscription.status from TEXT to SubscriptionStatus enum
+-- First, temporarily drop NOT NULL constraint to allow safe conversion
+ALTER TABLE "Subscription" ALTER COLUMN "status" DROP NOT NULL;
+
+-- Convert the column type preserving existing data
+ALTER TABLE "Subscription" ALTER COLUMN "status" TYPE "SubscriptionStatus" USING status::"SubscriptionStatus";
+
+-- Backfill any NULLs with a default value if needed (shouldn't be necessary but being safe)
+-- If there are NULLs, we'd set a default here, but since original was NOT NULL, this shouldn't be needed
+
+-- Re-add NOT NULL constraint after successful conversion
+ALTER TABLE "Subscription" ALTER COLUMN "status" SET NOT NULL;
+
+-- AlterTable: Make Subscription.endDate nullable
+ALTER TABLE "Subscription" ALTER COLUMN "endDate" DROP NOT NULL;

apps/api/prisma/migrations/20251031113043_add_payment_status_enum/migration.sql

@@ -0,0 +1,3 @@
+# Please do not edit this file manually
+# It should be added in your version-control system (i.e. Git)
+provider = "postgresql"

apps/api/prisma/migrations/migration_lock.toml

@@ -12,48 +12,92 @@ model QueryCount {
   total_queries BigInt
 }
 
-model User {
-  id String @id @default(cuid())
-
-  email String @unique
-
-  firstName String
-
-  authMethod String
-
-  createdAt DateTime @default(now())
+enum PaymentStatus {
+  created
+  authorized
+  captured
+  refunded
+  failed
+}
 
-  lastLogin DateTime @updatedAt
+enum SubscriptionStatus {
+  created
+  authenticated
+  active
+  pending
+  halted
+  cancelled
+  completed
+  expired
+}
 
-  accounts Account[]
+model User {
+  id            String         @id @default(cuid())
+  email         String         @unique
+  firstName     String
+  authMethod    String
+  createdAt     DateTime       @default(now())
+  lastLogin     DateTime       @updatedAt
+  accounts      Account[]
+  payments      Payment[]
+  subscriptions Subscription[]
 }
 
 model Account {
-  id String @id @default(cuid())
-
-  userId String // Foreign key to User
-
-  type String // "oauth", "email", etc.
-
-  provider String // "google", "github", etc.
+  id                String  @id @default(cuid())
+  userId            String
+  type              String
+  provider          String
+  providerAccountId String
+  refresh_token     String?
+  access_token      String?
+  expires_at        Int?
+  token_type        String?
+  scope             String?
+  id_token          String?
+  session_state     String?
+  user              User    @relation(fields: [userId], references: [id], onDelete: Cascade)
 
-  providerAccountId String // ID from the provider
-
-  refresh_token String?
-
-  access_token String?
-
-  expires_at Int?
-
-  token_type String?
-
-  scope String?
-
-  id_token String?
+  @@unique([provider, providerAccountId])
+}
 
-  session_state String?
+model Payment {
+  id                String        @id @default(cuid())
+  userId            String
+  subscriptionId    String?
+  razorpayPaymentId String        @unique
+  razorpayOrderId   String
+  amount            Int           // Amount in paise (smallest currency unit)
+  currency          String        @default("INR")
+  status            PaymentStatus
+  createdAt         DateTime      @default(now())
+  updatedAt         DateTime      @updatedAt
+  subscription      Subscription? @relation(fields: [subscriptionId], references: [id])
+  user              User          @relation(fields: [userId], references: [id], onDelete: Cascade)
+}
 
-  user User @relation(fields: [userId], references: [id], onDelete: Cascade)
+model Subscription {
+  id        String    @id @default(cuid())
+  userId    String
+  planId    String
+  status    SubscriptionStatus
+  startDate DateTime  @default(now())
+  endDate   DateTime?
+  autoRenew Boolean   @default(true)
+  payments  Payment[]
+  plan      Plan      @relation(fields: [planId], references: [id], onDelete: Cascade)
+  user      User      @relation(fields: [userId], references: [id], onDelete: Cascade)
+
+  @@index([userId])
+}
 
-  @@unique([provider, providerAccountId])
+model Plan {
+  id            String         @id @default(cuid())
+  name          String
+  interval      String
+  price         Int
+  currency      String         @default("INR")
+  createdAt     DateTime       @default(now())
+  updatedAt     DateTime       @updatedAt
+  subscriptions Subscription[]
 }

apps/api/prisma/schema.prisma

@@ -0,0 +1,21 @@
+import Razorpay from "razorpay";
+
+const RAZORPAY_KEY_ID = process.env.RAZORPAY_KEY_ID;
+const RAZORPAY_KEY_SECRET = process.env.RAZORPAY_KEY_SECRET;
+
+if (!RAZORPAY_KEY_ID) {
+  throw new Error(
+    "RAZORPAY_KEY_ID is required but not set in environment variables. Please configure it in your .env file."
+  );
+}
+
+if (!RAZORPAY_KEY_SECRET) {
+  throw new Error(
+    "RAZORPAY_KEY_SECRET is required but not set in environment variables. Please configure it in your .env file."
+  );
+}
+
+export const rz_instance = new Razorpay({
+  key_id: RAZORPAY_KEY_ID,
+  key_secret: RAZORPAY_KEY_SECRET,
+});