feat: complete email service

Author: apsinghdev

apps/api/src/routers/payment.ts

@@ -2,6 +2,10 @@ import { router, protectedProcedure } from "../trpc.js";
 import { z } from "zod";
 import { TRPCError } from "@trpc/server";
 import { paymentService } from "../services/payment.service.js";
+import { emailService } from "../services/email.service.js";
+import prismaModule from "../prisma.js";
+
+const { prisma } = prismaModule;
 
 const createOrderSchema = z.object({
   planId: z.string().min(1, "Plan ID is required"),
@@ -162,6 +166,34 @@ export const paymentRouter = router({
             payment.id
           );
 
+          // Step 4: Fetch user details and send premium subscription email
+          try {
+            const user = await prisma.user.findUnique({
+              where: { id: userId },
+              select: { email: true, firstName: true },
+            });
+
+            if (user && user.email && user.firstName) {
+              // Send premium subscription confirmation email
+              await emailService.sendPremiumSubscriptionEmail(
+                user.email,
+                user.firstName
+              );
+            } else {
+              // Log warning but don't fail the payment verification
+              console.warn(
+                `Unable to send premium subscription email: User ${userId} not found or missing email/firstName`
+              );
+            }
+          } catch (emailError) {
+            // Log error but don't fail the payment verification
+            // Payment and subscription are already successful
+            console.error(
+              "Error sending premium subscription email:",
+              emailError
+            );
+          }
+
           return {
             success: true,
             message: "Payment verified and subscription activated",

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

@@ -103,10 +103,6 @@ export const emailService = {
           Let's have a chat over a meeting so that I can understand where you are currently and how I can help you move ahead.
         </p>
         
-        <p style="color: #333; line-height: 1.8; font-size: 16px;">
-          Soon, I'll add you to the private Slack so that we can talk regularly.
-        </p>
-        
         <p style="color: #333; line-height: 1.8; font-size: 16px;">
           Again, thank you :)
         </p>
@@ -143,8 +139,6 @@ To get started, please book your slot in the cal meet.
 
 Let's have a chat over a meeting so that I can understand where you are currently and how I can help you move ahead.
 
-Soon, I'll add you to the private Slack so that we can talk regularly.
-
 Again, thank you :)
 
 Cal: https://cal.com/ajeetunc/secret

apps/api/types/zeptomail.d.ts

@@ -0,0 +1,13 @@
+declare module "zeptomail" {
+  export class SendMailClient {
+    constructor(config: { url: string; token: string });
+    sendMail(options: {
+      from: { address: string; name: string };
+      to: Array<{ email_address: { address: string; name: string } }>;
+      subject: string;
+      htmlbody: string;
+      textbody?: string;
+    }): Promise<any>;
+  }
+}
+

apps/web/src/components/payment/PaymentFlow.tsx

@@ -147,8 +147,8 @@ const PaymentFlow: React.FC<PaymentFlowProps> = ({
 
       await initiatePayment(options);
     } catch (error) {
-      console.error("Failed to create order:", error);
-      alert("Failed to initiate payment. Please try again.");
+      console.warn("Failed to create order:", error);
+      router.push("/login?callbackUrl=/pricing");
       setIsProcessing(false);
     }
   };

apps/web/src/providers/trpc-provider.tsx

@@ -2,12 +2,12 @@
 
 import { QueryClient, QueryClientProvider } from "@tanstack/react-query";
 import { httpBatchLink } from "@trpc/client";
-import { useState } from "react";
+import { useState, useMemo } from "react";
 import { useSession } from "next-auth/react";
 import { trpc } from "@/lib/trpc";
 
 export function TRPCProvider({ children }: { children: React.ReactNode }) {
-  const session = useSession();
+  const { data: session, status } = useSession();
   const [queryClient] = useState(
     () =>
       new QueryClient({
@@ -19,7 +19,8 @@ export function TRPCProvider({ children }: { children: React.ReactNode }) {
       })
   );
 
-  const [trpcClient] = useState(() => {
+  // Recreate client when session status changes to ensure we get the latest token
+  const trpcClient = useMemo(() => {
     const baseUrl = process.env.NEXT_PUBLIC_API_URL || "http://localhost:4000";
     const trpcUrl = baseUrl.endsWith("/trpc") ? baseUrl : `${baseUrl}/trpc`;
 
@@ -28,7 +29,7 @@ export function TRPCProvider({ children }: { children: React.ReactNode }) {
         httpBatchLink({
           url: trpcUrl,
           async headers() {
-            const token = (session.data as any)?.accessToken;
+            const token = (session as any)?.accessToken;
             if (token) {
               return {
                 authorization: `Bearer ${token}`,
@@ -39,7 +40,7 @@ export function TRPCProvider({ children }: { children: React.ReactNode }) {
         }),
       ],
     });
-  });
+  }, [status, session]);
 
   return (
     <trpc.Provider client={trpcClient} queryClient={queryClient}>