seller onboard setup completed

Author: Srihari62

.env

@@ -10,4 +10,6 @@ SMTP_USER= "srihari6281@gmail.com"
 SMTP_PASS= "npva kjya qgig limk"
 
 JWT_ACCESS_SECRET = "86b9c4ad75ca4fdcd7f0802f02726b8d09d0a11cc0bc25aebca6ede3a03fe8e5"
-JWT_REFRESH_SECRET = "e8765102d2990ab6883d7637d70a14d4b39800b11ebf2896daee122e3376caf8"
+JWT_REFRESH_SECRET = "e8765102d2990ab6883d7637d70a14d4b39800b11ebf2896daee122e3376caf8"
+
+STRIPE_SECRET_KEY = "sk_test_51PXzbSSGnmKVDMGjgzYASGjq7ktUKr0moWbKGzm9cB1EzYl196t4LRvgU9jrI2IE5JhpLKQos2lEHPAIdQGJMGVq00VNk2qv95"

apps/auth-service/src/controller/auth.controller.ts

@@ -13,6 +13,11 @@ import { AuthenticationError, ValidationError } from "@packages/error-handler";
 import bcrypt from "bcryptjs";
 import jwt from "jsonwebtoken";
 import { setCookie } from "../utils/cookies/setCookie";
+import { Stripe } from "stripe";
+
+const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!, {
+  apiVersion: "2025-12-15.clover",
+});
 
 //new user registration
 export const userRegistration = async (
@@ -364,3 +369,126 @@ export const createShop = async (
     return next(error);
   }
 };
+
+//create a stripe connect link
+
+export const createStripeConnectLink = async (
+  req: Request,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+    const { sellerId } = req.body;
+    console.log(req.body, "req.body");
+    if (!sellerId) {
+      return next(new ValidationError("Seller ID is required"));
+    }
+    const seller = await prisma.sellers.findUnique({
+      where: { id: sellerId },
+    });
+    if (!seller) {
+      return next(new ValidationError("Seller not found"));
+    }
+
+    //create stripe connect account
+    const account = await stripe.accounts.create({
+      type: "express",
+      country: "IN",
+      email: seller.email,
+      business_type: "individual",
+      capabilities: {
+        card_payments: { requested: true },
+        transfers: { requested: true },
+      },
+    });
+    await prisma.sellers.update({
+      where: { id: sellerId },
+      data: { stripeId: account.id },
+    });
+
+    const accountLink = await stripe.accountLinks.create({
+      account: account.id,
+      refresh_url: `http://localhost:3000/success`,
+      return_url: `http://localhost:3000/success`,
+      type: "account_onboarding",
+    });
+
+    res.status(200).json({
+      success: true,
+      url: accountLink.url,
+    });
+  } catch (error) {
+    return next(error);
+  }
+};
+
+//Seller Login
+
+export const loginSeller = async (
+  req: Request,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+    const { email, password } = req.body;
+    if (!email || !password) {
+      return next(new ValidationError("Email and password are required"));
+    }
+    const seller = await prisma.sellers.findUnique({
+      where: { email },
+    });
+    if (!seller) {
+      return next(new AuthenticationError("Seller not found"));
+    }
+    //verify password
+    const isMatch = await bcrypt.compare(password, seller.password!);
+    if (!isMatch) {
+      return next(new AuthenticationError("Invalid credentials"));
+    }
+    //Generate Access Token and Refresh Token
+    const accessToken = jwt.sign(
+      { id: seller.id, role: "seller" },
+      process.env.JWT_ACCESS_SECRET! as string,
+      { expiresIn: "15m" }
+    );
+    const refreshToken = jwt.sign(
+      { id: seller.id, role: "seller" },
+      process.env.JWT_REFRESH_SECRET! as string,
+      { expiresIn: "7d" }
+    );
+
+    //store refresh token and access token in httpOnly cookies
+    setCookie(res, "sellerAccessToken", accessToken);
+    setCookie(res, "sellerRefreshToken", refreshToken);
+
+    res.status(200).json({
+      success: true,
+      message: "Login successful",
+
+      user: {
+        id: seller.id,
+        name: seller.name,
+        email: seller.email,
+      },
+    });
+  } catch (error) {
+    return next(error);
+  }
+};
+
+//get loggedin seller info
+export const getSeller = async (
+  req: any,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+    const seller = req.seller;
+    res.status(201).json({
+      success: true,
+      seller,
+    });
+  } catch (error) {
+    next(error);
+  }
+};

apps/auth-service/src/routes/auth.router.ts

@@ -1,7 +1,10 @@
 import express, { Router } from "express";
 import {
   createShop,
+  createStripeConnectLink,
+  getSeller,
   getUser,
+  loginSeller,
   loginUser,
   refreshToken,
   registerSeller,
@@ -13,6 +16,7 @@ import {
   verifyUserOtp,
 } from "../controller/auth.controller";
 import isAuthenticated from "@packages/middleware/isAuthenticated";
+import { isSeller } from "@packages/middleware/authorizeRoles";
 
 const router: Router = express.Router();
 
@@ -29,5 +33,8 @@ router.post("/verify-forgot-password-user", verifyUserForgotPassword);
 router.post("/seller-registration", registerSeller);
 router.post("/verify-seller", verifySellerOtp);
 router.post("/create-shop", createShop);
+router.post("/create-stripe-link", createStripeConnectLink);
+router.post("/login-seller", loginSeller);
+router.get("/logged-in-seller", isAuthenticated, isSeller, getSeller);
 
 export default router;

apps/seller-ui/src/app/(routes)/signup/page.tsx

@@ -7,6 +7,8 @@ import { Eye, EyeOff } from "lucide-react";
 import { useMutation } from "@tanstack/react-query";
 import axios, { AxiosError } from "axios";
 import countries from "apps/seller-ui/src/utils/countries";
+import CreateShop from "../../shared/modules/auth/create-shop";
+import StripeLogo from "apps/seller-ui/src/assets/svgs/stripe-logo";
 
 // type FormData = {
 //   name: string;
@@ -17,7 +19,7 @@ import countries from "apps/seller-ui/src/utils/countries";
 const Signup = () => {
   const [passwordVisible, setpasswordVisible] = useState(false);
   // const [serverError, setServerError] = useState<string | null>(null);
-  const [activeStep, setActiveStep] = useState(1);
+  const [activeStep, setActiveStep] = useState(3);
   const [timer, setTimer] = useState(60);
   const [showOtp, setShowOtp] = useState(false);
   const [canResend, setCanResend] = useState(true);
@@ -26,8 +28,6 @@ const Signup = () => {
   const [sellerId, setSellerId] = useState("");
   const inputRefs = useRef<(HTMLInputElement | null)[]>([]);
 
-  const router = useRouter();
-
   const {
     register,
     handleSubmit,
@@ -77,7 +77,7 @@ const Signup = () => {
       return response.data;
     },
     onSuccess: (data) => {
-      setSellerId(data?.sellerId);
+      setSellerId(data?.seller.id);
       setActiveStep(2);
     },
   });
@@ -115,6 +115,21 @@ const Signup = () => {
     }
   };
 
+  const connectStripe = async () => {
+    try {
+      console.log(sellerId, "SellerId");
+      const response = await axios.post(
+        `${process.env.NEXT_PUBLIC_SERVER_URI}/api/create-stripe-link`,
+        sellerId
+      );
+      if (response.data.url) {
+        window.location.href = response.data.url;
+      }
+    } catch (error) {
+      console.error("Error connecting to Stripe:", error);
+    }
+  };
+
   return (
     <div className="w-full flex flex-col items-center pt-10 min-h-screen">
       {/* {stepper} */}
@@ -324,6 +339,21 @@ const Signup = () => {
             )}
           </>
         )}
+        {activeStep === 2 && (
+          <CreateShop sellerId={sellerId} setActiveStep={setActiveStep} />
+        )}
+        {activeStep === 3 && (
+          <div className="text-center">
+            <h3 className="text-2xl font-semibold">Withdraw Method</h3>
+            <br />
+            <button
+              onClick={connectStripe}
+              className="w-full m-auto flex items-center justify-center gap-3 text-lg bg-[#334155] text-white py-2 rounded-lg"
+            >
+              Connect <StripeLogo />
+            </button>
+          </div>
+        )}
       </div>
     </div>
   );