database and upload feat

Author: ank-it07

actions/upload-actions.ts

@@ -0,0 +1,181 @@
+"use server";
+import getDbConnection from "@/lib/db";
+import { revalidatePath } from "next/cache";
+import { redirect } from "next/navigation";
+import OpenAI from "openai";
+
+const openai = new OpenAI({
+  apiKey: process.env.OPENAI_API_KEY,
+});
+
+export async function transcribeUploadedFile(
+  resp: {
+    serverData: { userId: string; file: any };
+  }[]
+) {
+  if (!resp) {
+    return {
+      success: false,
+      message: "File upload failed",
+      data: null,
+    };
+  }
+
+  const {
+    serverData: {
+      userId,
+      file: { url: fileUrl, name: fileName },
+    },
+  } = resp[0];
+
+  if (!fileUrl || !fileName) {
+    return {
+      success: false,
+      message: "File upload failed",
+      data: null,
+    };
+  }
+
+  const response = await fetch(fileUrl);
+
+  try {
+    const transcriptions = await openai.audio.transcriptions.create({
+      model: "whisper-1",
+      file: response,
+    });
+
+    console.log({ transcriptions });
+    return {
+      success: true,
+      message: "File uploaded successfully!",
+      data: { transcriptions, userId },
+    };
+  } catch (error) {
+    console.error("Error processing file", error);
+
+    if (error instanceof OpenAI.APIError && error.status === 413) {
+      return {
+        success: false,
+        message: "File size exceeds the max limit of 20MB",
+        data: null,
+      };
+    }
+
+    return {
+      success: false,
+      message: error instanceof Error ? error.message : "Error processing file",
+      data: null,
+    };
+  }
+}
+
+async function saveBlogPost(userId: string, title: string, content: string) {
+  try {
+    const sql = await getDbConnection();
+    const [insertedPost] = await sql`
+    INSERT INTO posts (user_id, title, content)
+    VALUES (${userId}, ${title}, ${content})
+    RETURNING id
+    `;
+    return insertedPost.id;
+  } catch (error) {
+    console.error("Error saving blog post", error);
+    throw error;
+  }
+}
+
+async function getUserBlogPosts(userId: string) {
+  try {
+    const sql = await getDbConnection();
+    const posts = await sql`
+    SELECT content FROM posts 
+    WHERE user_id = ${userId} 
+    ORDER BY created_at DESC 
+    LIMIT 3
+  `;
+    return posts.map((post) => post.content).join("\n\n");
+  } catch (error) {
+    console.error("Error getting user blog posts", error);
+    throw error;
+  }
+}
+
+async function generateBlogPost({
+  transcriptions,
+  userPosts,
+}: {
+  transcriptions: string;
+  userPosts: string;
+}) {
+  const completion = await openai.chat.completions.create({
+    messages: [
+      {
+        role: "system",
+        content:
+          "You are a skilled content writer that converts audio transcriptions into well-structured, engaging blog posts in Markdown format. Create a comprehensive blog post with a catchy title, introduction, main body with multiple sections, and a conclusion. Analyze the user's writing style from their previous posts and emulate their tone and style in the new post. Keep the tone casual and professional.",
+      },
+      {
+        role: "user",
+        content: `Here are some of my previous blog posts for reference:
+
+${userPosts}
+
+Please convert the following transcription into a well-structured blog post using Markdown formatting. Follow this structure:
+
+1. Start with a SEO friendly catchy title on the first line.
+2. Add two newlines after the title.
+3. Write an engaging introduction paragraph.
+4. Create multiple sections for the main content, using appropriate headings (##, ###).
+5. Include relevant subheadings within sections if needed.
+6. Use bullet points or numbered lists where appropriate.
+7. Add a conclusion paragraph at the end.
+8. Ensure the content is informative, well-organized, and easy to read.
+9. Emulate my writing style, tone, and any recurring patterns you notice from my previous posts.
+
+Here's the transcription to convert: ${transcriptions}`,
+      },
+    ],
+    model: "gpt-4o-mini",
+    temperature: 0.7,
+    max_tokens: 1000,
+  });
+
+  return completion.choices[0].message.content;
+}
+export async function generateBlogPostAction({
+  transcriptions,
+  userId,
+}: {
+  transcriptions: { text: string };
+  userId: string;
+}) {
+  const userPosts = await getUserBlogPosts(userId);
+
+  let postId = null;
+
+  if (transcriptions) {
+    const blogPost = await generateBlogPost({
+      transcriptions: transcriptions.text,
+      userPosts,
+    });
+
+    if (!blogPost) {
+      return {
+        success: false,
+        message: "Blog post generation failed, please try again...",
+      };
+    }
+
+    const [title, ...contentParts] = blogPost?.split("\n\n") || [];
+
+    //database connection
+
+    if (blogPost) {
+      postId = await saveBlogPost(userId, title, blogPost);
+    }
+  }
+
+  //navigate
+  revalidatePath(`/posts/${postId}`);
+  redirect(`/posts/${postId}`);
+}

app/(logged-in)/dashboard/page.tsx

@@ -0,0 +1,92 @@
+import BgGradient from "@/components/common/bg-gradient";
+import { Badge } from "@/components/ui/badge";
+import UpgradeYourPlan from "@/components/upload/upgrade-your-plan";
+// import UploadForm from "@/components/upload/upload-form";
+import getDbConnection from "@/lib/db";
+import {
+  doesUserExist,
+  getPlanType,
+  hasCancelledSubscription,
+  updateUser,
+} from "@/lib/user-helpers";
+import { currentUser } from "@clerk/nextjs/server";
+import { redirect } from "next/navigation";
+
+export default async function Dashboard() {
+  const clerkUser = await currentUser();
+
+  if (!clerkUser) {
+    return redirect("/sign-in");
+  }
+
+  const email = clerkUser?.emailAddresses?.[0].emailAddress ?? "";
+
+  const sql = await getDbConnection();
+
+  //updatethe user id
+  let userId = null;
+  let priceId = null;
+
+  const hasUserCancelled = await hasCancelledSubscription(sql, email);
+  const user = await doesUserExist(sql, email);
+
+  if (user) {
+    //update the user_id in users table
+    userId = clerkUser?.id;
+    if (userId) {
+      await updateUser(sql, userId, email);
+    }
+
+    priceId = user[0].price_id;
+  }
+
+  const { id: planTypeId = "starter", name: planTypeName } =
+    getPlanType(priceId);
+
+  const isBasicPlan = planTypeId === "basic";
+  const isProPlan = planTypeId === "pro";
+
+  // check number of posts per plan
+  const posts = await sql`SELECT * FROM posts WHERE user_id = ${userId}`;
+
+  const isValidBasicPlan = isBasicPlan && posts.length < 3;
+
+  return (
+    <BgGradient>
+      <div className="mx-auto max-w-7xl px-6 py-24 sm:py-32 lg:px-8">
+        <div className="flex flex-col items-center justify-center gap-6 text-center">
+          <Badge className="bg-gradient-to-r from-purple-700 to-pink-800 text-white px-4 py-1 text-lg font-semibold capitalize">
+            {planTypeName} Plan
+          </Badge>
+
+          <h2 className="capitalize text-3xl font-bold tracking-tight text-gray-900 sm:text-4xl">
+            Start creating amazing content
+          </h2>
+
+          <p className="mt-2 text-lg leading-8 text-gray-600 max-w-2xl text-center">
+            Upload your audio or video file and let our AI do the magic!
+          </p>
+
+          {(isBasicPlan || isProPlan) && (
+            <p className="mt-2 text-lg leading-8 text-gray-600 max-w-2xl text-center">
+              You get{" "}
+              <span className="font-bold text-amber-600 bg-amber-100 px-2 py-1 rounded-md">
+                {isBasicPlan ? "3" : "Unlimited"} blog posts
+              </span>{" "}
+              as part of the{" "}
+              <span className="font-bold capitalize">{planTypeName}</span> Plan.
+            </p>
+          )}
+
+          {isValidBasicPlan || isProPlan ? (
+            <BgGradient>
+              {/* <UploadForm /> */}
+            </BgGradient>
+          ) : (
+            <UpgradeYourPlan />
+          )}
+        </div>
+      </div>
+    </BgGradient>
+  );
+}

app/sign-in/[[...sign-in]]/page.tsx app/(logged-in)/sign-in/[[...sign-in]]/page.tsx

@@ -0,0 +1,58 @@
+import {
+    handleCheckoutSessionCompleted,
+    handleSubscriptionDeleted,
+  } from "@/lib/payment-helpers";
+  import { NextRequest, NextResponse } from "next/server";
+  import Stripe from "stripe";
+  
+  const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);
+  
+  export async function POST(req: NextRequest) {
+    //webhook functionality
+    const payload = await req.text();
+  
+    const sig = req.headers.get("stripe-signature");
+  
+    let event;
+  
+    try {
+      event = stripe.webhooks.constructEvent(
+        payload,
+        sig!,
+        process.env.STRIPE_WEBHOOK_SECRET!
+      );
+  
+      // Handle the event
+      switch (event.type) {
+        // case "payment_intent.succeeded"
+
+        case "checkout.session.completed": {
+          const session = await stripe.checkout.sessions.retrieve(
+            event.data.object.id,
+            {
+              expand: ["line_items"],
+            }
+          );
+          console.log({ session });
+  
+          //connect to the db create or update user
+          await handleCheckoutSessionCompleted({ session, stripe });
+          break;
+        }
+        case "customer.subscription.deleted": {
+          // connect to db
+          const subscriptionId = event.data.object.id;
+  
+          await handleSubscriptionDeleted({ subscriptionId, stripe });
+          break;
+        }
+        default:
+          console.log(`Unhandled event type ${event.type}`);
+      }
+      return NextResponse.json({
+        status: "success",
+      });
+    } catch (err) {
+      return NextResponse.json({ status: "Failed", err });
+    }
+  }

app/sign-up/[[...sign-up]]/page.tsx app/(logged-in)/sign-up/[[...sign-up]]/page.tsx

@@ -0,0 +1,29 @@
+import { currentUser } from "@clerk/nextjs/server";
+import { createUploadthing, type FileRouter } from "uploadthing/next";
+import { UploadThingError } from "uploadthing/server";
+
+const f = createUploadthing();
+
+export const ourFileRouter = {
+  videoOrAudioUploader: f({ video: { maxFileSize: "32MB" } })
+    .middleware(async ({ req }) => {
+      const user = await currentUser();
+
+      console.log({ user });
+
+      if (!user) throw new UploadThingError("Unauthorized");
+
+      return { userId: user.id };
+    })
+    .onUploadComplete(async ({ metadata, file }) => {
+      // This code RUNS ON YOUR SERVER after upload
+      console.log("Upload complete for userId:", metadata.userId);
+
+      console.log("file url", file.url);
+
+      // !!! Whatever is returned here is sent to the clientside `onClientUploadComplete` callback
+      return { userId: metadata.userId, file };
+    }),
+} satisfies FileRouter;
+
+export type OurFileRouter = typeof ourFileRouter;

app/api/payments/routes.ts

@@ -0,0 +1,11 @@
+import { createRouteHandler } from "uploadthing/next";
+
+import { ourFileRouter } from "./core";
+
+// Export routes for Next App Router
+export const { GET, POST } = createRouteHandler({
+  router: ourFileRouter,
+
+  // Apply an (optional) custom config:
+  // config: { ... },
+});