Implemented Interaction model and server-action

Author: ladunjexa

components/shared/Votes.tsx

@@ -1,10 +1,11 @@
 "use client";
 
+import { useEffect } from "react";
 import Image from "next/image";
-import { usePathname } from "next/navigation";
+import { usePathname, useRouter } from "next/navigation";
 
 import { upvoteAnswer, downvoteAnswer } from "@/lib/actions/answer.action";
-
+import { viewQuestion } from "@/lib/actions/interaction.action";
 import {
   downvoteQuestion,
   upvoteQuestion,
@@ -32,8 +33,16 @@ const Votes = ({
   hasdownVoted,
   hasSaved,
 }: Props) => {
+  const router = useRouter();
   const pathname = usePathname();
 
+  useEffect(() => {
+    viewQuestion({
+      questionId: JSON.parse(itemId),
+      userId: userId ? JSON.parse(userId) : undefined,
+    });
+  }, [itemId, userId, pathname, router]);
+
   const handleSave = async () => {
     await toggleSaveQuestion({
       userId: JSON.parse(userId),

database/interaction.model.ts

@@ -0,0 +1,24 @@
+import { Schema, models, model, Document } from "mongoose";
+
+export interface IInteraction extends Document {
+  user: Schema.Types.ObjectId;
+  action: string;
+  question: Schema.Types.ObjectId;
+  answer: Schema.Types.ObjectId;
+  tags: Schema.Types.ObjectId[];
+  createdAt: Date;
+}
+
+const InteractionSchema = new Schema({
+  user: { type: Schema.Types.ObjectId, ref: "User", required: true },
+  action: { type: String, required: true },
+  question: { type: Schema.Types.ObjectId, ref: "Question" },
+  answer: { type: Schema.Types.ObjectId, ref: "Answer" },
+  tags: [{ type: Schema.Types.ObjectId, ref: "Tag" }],
+  createdAt: { type: Date, default: Date.now },
+});
+
+const Interaction =
+  models.Interaction || model("Interaction", InteractionSchema);
+
+export default Interaction;

lib/actions/interaction.action.ts

@@ -0,0 +1,38 @@
+"use server";
+
+import Question from "@/database/question.model";
+import Interaction from "@/database/interaction.model";
+
+import { connectToDatabase } from "@/lib/mongoose";
+
+import type { ViewQuestionParams } from "./shared.types";
+
+export async function viewQuestion(params: ViewQuestionParams) {
+  try {
+    connectToDatabase();
+
+    const { questionId, userId } = params;
+
+    // update view count for the question
+    await Question.findByIdAndUpdate(questionId, { $inc: { views: 1 } });
+
+    if (userId) {
+      const existingInteraction = await Interaction.findOne({
+        user: userId,
+        action: "view",
+        question: questionId,
+      });
+
+      if (existingInteraction) return console.log("User has already viewed.");
+
+      await Interaction.create({
+        user: userId,
+        action: "view",
+        question: questionId,
+      });
+    }
+  } catch (error) {
+    console.log(error);
+    throw error;
+  }
+}