Inferno patch v2

src/app/api/drafts/fetch/route.js

@@ -0,0 +1,108 @@
+import { google } from 'googleapis';
+import { getSession } from '@auth0/nextjs-auth0';
+import getUserTokens from '@/lib/getUserTokens';
+
+export async function GET(req) {
+  const { searchParams } = new URL(req.url);
+  const email = searchParams.get('email');
+
+  if (!email) {
+    return new Response(JSON.stringify({ message: 'Email is required' }), {
+      status: 400,
+      headers: { 'Content-Type': 'application/json' },
+    });
+  }
+
+  try {
+    const session = await getSession(req);
+    const user = session?.user;
+
+    if (!user) {
+      return new Response(JSON.stringify({ message: 'User not authenticated' }), {
+        status: 401,
+        headers: { 'Content-Type': 'application/json' },
+      });
+    }
+
+    const userTokens = await getUserTokens(email);
+    if (!userTokens || !userTokens.access_token || !userTokens.refresh_token) {
+      return new Response(JSON.stringify({ message: 'User tokens not found or incomplete' }), {
+        status: 401,
+        headers: { 'Content-Type': 'application/json' },
+      });
+    }
+
+    const oauth2Client = new google.auth.OAuth2(
+      process.env.GOOGLE_CLIENT_ID,
+      process.env.GOOGLE_CLIENT_SECRET
+    );
+    oauth2Client.setCredentials({
+      access_token: userTokens.access_token,
+      refresh_token: userTokens.refresh_token,
+    });
+
+    const gmail = google.gmail({ version: 'v1', auth: oauth2Client });
+
+    const draftsResponse = await gmail.users.drafts.list({
+      userId: 'me',
+      maxResults: 10,
+    });
+
+    if (!draftsResponse.data.drafts) {
+      return new Response(JSON.stringify({ drafts: [] }), {
+        status: 200,
+        headers: { 'Content-Type': 'application/json' },
+      });
+    }
+
+    const drafts = await Promise.all(
+      draftsResponse.data.drafts.map(async (draft) => {
+        const draftData = await gmail.users.drafts.get({
+          userId: 'me',
+          id: draft.id,
+        });
+
+        const decodeBase64 = (data) => Buffer.from(data || '', 'base64').toString('utf-8');
+
+        const getDraftBody = (msg) => {
+          let body = '';
+          const parts = msg.payload.parts || [msg.payload];
+          for (const part of parts) {
+            if (part.mimeType === 'text/html' && part.body?.data) {
+              body = decodeBase64(part.body.data);
+              break;
+            } else if (part.mimeType === 'text/plain' && part.body?.data) {
+              body = decodeBase64(part.body.data);
+            }
+          }
+          return body || 'No content available';
+        };
+
+        const body = getDraftBody(draftData.data.message);
+
+        return {
+          id: draftData.data.id,
+          subject: draftData.data.message.payload.headers.find((h) => h.name === 'Subject')?.value || '(No Subject)',
+          to: draftData.data.message.payload.headers.find((h) => h.name === 'To')?.value || '',
+          body,
+          snippet: draftData.data.message.snippet,
+          timestamp: new Date(parseInt(draftData.data.message.internalDate || Date.now())),
+        };
+      })
+    );
+
+    return new Response(JSON.stringify({ drafts }), {
+      status: 200,
+      headers: { 'Content-Type': 'application/json' },
+    });
+  } catch (error) {
+    console.error('Error fetching drafts:', error);
+    return new Response(
+      JSON.stringify({
+        message: 'Internal server error',
+        details: error.message,
+      }),
+      { status: 500, headers: { 'Content-Type': 'application/json' } }
+    );
+  }
+}

src/app/api/drafts/save/route.js

@@ -0,0 +1,107 @@
+import { google } from 'googleapis';
+import { getSession } from '@auth0/nextjs-auth0';
+import getUserTokens from '@/lib/getUserTokens';
+
+export async function POST(req) {
+  try {
+    const body = await req.json(); // Parse the request body
+    const { to, subject, body: emailBody, userEmail, draftId } = body;
+
+    if (!userEmail || !to || !subject || !emailBody) {
+      return new Response(
+        JSON.stringify({ message: 'Missing required fields' }),
+        { status: 400, headers: { 'Content-Type': 'application/json' } }
+      );
+    }
+
+    // Get user session
+    const session = await getSession(req);
+    if (!session || !session.user) {
+      return new Response(
+        JSON.stringify({ message: 'User not authenticated' }),
+        { status: 401, headers: { 'Content-Type': 'application/json' } }
+      );
+    }
+
+    // Fetch user's tokens from the database
+    const userTokens = await getUserTokens(userEmail);
+    if (!userTokens || !userTokens.access_token || !userTokens.refresh_token) {
+      return new Response(
+        JSON.stringify({ message: 'User tokens not found or incomplete' }),
+        { status: 401, headers: { 'Content-Type': 'application/json' } }
+      );
+    }
+
+    // Initialize OAuth2 client
+    const oauth2Client = new google.auth.OAuth2(
+      process.env.GOOGLE_CLIENT_ID,
+      process.env.GOOGLE_CLIENT_SECRET
+    );
+    oauth2Client.setCredentials({
+      access_token: userTokens.access_token,
+      refresh_token: userTokens.refresh_token,
+    });
+
+    const gmail = google.gmail({ version: 'v1', auth: oauth2Client });
+
+    // Format email for draft
+    const rawEmail = [
+      `To: ${to}`,
+      `Subject: ${subject}`,
+      'Content-Type: text/html; charset=UTF-8',
+      '',
+      emailBody,
+    ].join('\n');
+
+    const encodedEmail = Buffer.from(rawEmail)
+      .toString('base64')
+      .replace(/\+/g, '-')
+      .replace(/\//g, '_')
+      .replace(/=+$/, '');
+
+    if (draftId) {
+      // Update existing draft
+      const response = await gmail.users.drafts.update({
+        userId: 'me',
+        id: draftId,
+        requestBody: {
+          message: {
+            raw: encodedEmail,
+          },
+        },
+      });
+
+      return new Response(
+        JSON.stringify({
+          message: 'Draft updated successfully',
+          draftId: response.data.id,
+        }),
+        { status: 200, headers: { 'Content-Type': 'application/json' } }
+      );
+    } else {
+      // Create new draft
+      const response = await gmail.users.drafts.create({
+        userId: 'me',
+        requestBody: {
+          message: {
+            raw: encodedEmail,
+          },
+        },
+      });
+
+      return new Response(
+        JSON.stringify({
+          message: 'Draft saved successfully',
+          draftId: response.data.id,
+        }),
+        { status: 200, headers: { 'Content-Type': 'application/json' } }
+      );
+    }
+  } catch (error) {
+    console.error('Error saving draft to Gmail:', error);
+    return new Response(
+      JSON.stringify({ message: 'Internal server error', error: error.message }),
+      { status: 500, headers: { 'Content-Type': 'application/json' } }
+    );
+  }
+}

src/app/dashboard/[slug]/components/Drafts.js

@@ -0,0 +1,104 @@
+// 'use client';
+
+// import { useEffect, useState } from 'react';
+
+// const Drafts = ({ email }) => {
+//   const [drafts, setDrafts] = useState([]);
+//   const [loading, setLoading] = useState(true);
+
+//   const fetchDrafts = async () => {
+//     try {
+//       const response = await fetch(`/api/drafts/fetch?email=${encodeURIComponent(email)}`);
+//       const data = await response.json();
+//       setDrafts(data.drafts || []);
+//     } catch (error) {
+//       console.error('Error fetching drafts:', error.message);
+//     } finally {
+//       setLoading(false);
+//     }
+//   };
+
+//   useEffect(() => {
+//     if (email) {
+//       fetchDrafts();
+//     }
+//   }, [email]);
+
+//   if (loading) return <p>Loading drafts...</p>;
+//   if (drafts.length === 0) return <p>No drafts found.</p>;
+
+//   return (
+//     <div className="drafts-container">
+//       <h2 className="text-xl font-semibold">Drafts</h2>
+//       <ul className="space-y-4">
+//         {drafts.map((draft) => (
+//           <li key={draft.id} className="bg-white p-4 rounded shadow">
+//             <h3 className="font-bold">{draft.subject || '(No Subject)'}</h3>
+//             <p className="text-gray-600">To: {draft.to || '(Not specified)'}</p>
+//             <p className="text-gray-800 truncate">{draft.snippet}</p>
+//           </li>
+//         ))}
+//       </ul>
+//     </div>
+//   );
+// };
+
+// export default Drafts;
+
+
+
+
+
+
+
+
+
+'use client';
+
+import { useEffect, useState } from 'react';
+
+const Drafts = ({ email, onDraftClick }) => {
+  const [drafts, setDrafts] = useState([]);
+  const [loading, setLoading] = useState(true);
+
+  const fetchDrafts = async () => {
+    try {
+      const response = await fetch(`/api/drafts/fetch?email=${encodeURIComponent(email)}`);
+      const data = await response.json();
+      setDrafts(data.drafts || []);
+    } catch (error) {
+      console.error('Error fetching drafts:', error.message);
+    } finally {
+      setLoading(false);
+    }
+  };
+
+  useEffect(() => {
+    if (email) {
+      fetchDrafts();
+    }
+  }, [email]);
+
+  if (loading) return <p>Loading drafts...</p>;
+  if (drafts.length === 0) return <p>No drafts found.</p>;
+
+  return (
+    <div className="drafts-container">
+      <ul className="space-y-4">
+        {drafts.map((draft) => (
+          <li
+            key={draft.id}
+            className="bg-white p-4 rounded shadow cursor-pointer hover:bg-gray-100"
+            onClick={() => onDraftClick(draft)} // Pass the draft data on click
+          >
+            <h3 className="font-bold">{draft.subject || '(No Subject)'}</h3>
+            <p className="text-gray-600">To: {draft.to || '(Not specified)'}</p>
+            <p className="text-gray-800 truncate">{draft.snippet}</p>
+          </li>
+        ))}
+      </ul>
+    </div>
+  );
+};
+
+export default Drafts;