feat(apps/gql): add post upvote mutations

apps/gql/features/pano/index.ts

@@ -1,10 +1,12 @@
 import { createPanoCommentActions } from "~/features/pano/comment";
 import { createPanoPostActions } from "~/features/pano/post";
 import { type Clients } from "~/clients";
+import { createPostUpvoteActions } from "./postUpvote";
 
 export function createPanoActions(clients: Clients) {
   return {
     post: createPanoPostActions(clients),
     comment: createPanoCommentActions(clients),
+    postUpvote: createPostUpvoteActions(clients),
   };
 }

apps/gql/features/pano/postUpvote.ts

@@ -0,0 +1,35 @@
+import { type Clients } from "~/clients";
+
+interface CreatePostUpvoteArgs {
+  postID: string;
+  userID: string;
+}
+
+interface RemovePostUpvoteArgs {
+  postID: string;
+  userID: string;
+}
+
+export function createPostUpvoteActions({ prisma }: Clients) {
+  const create = (args: CreatePostUpvoteArgs) => {
+    return prisma.upvote.create({
+      data: {
+        post: { connect: { id: args.postID } },
+        owner: { connect: { id: args.userID } },
+      },
+    });
+  };
+
+  const remove = (args: RemovePostUpvoteArgs) => {
+    return prisma.upvote.delete({
+      where: {
+        postID_userID: {
+          postID: args.postID,
+          userID: args.userID,
+        },
+      },
+    });
+  };
+
+  return { create, remove };
+}

apps/gql/loaders/pano.ts

@@ -4,14 +4,15 @@ import {
   createPrismaLoader,
 } from "@kampus/gql-utils";
 import { type Connection } from "@kampus/gql-utils/connection";
-import { type Comment, type Post } from "@kampus/prisma";
+import { type Comment, type Post, type Upvote } from "@kampus/prisma";
 
 import { type Clients } from "~/clients";
 import {
   type PanoComment,
   type PanoCommentConnection,
   type PanoPost,
   type PanoPostConnection,
+  type PostUpvote,
 } from "~/schema/types.generated";
 
 export type PanoLoaders = ReturnType<typeof createPanoLoaders>;
@@ -142,3 +143,10 @@ export const transformPanoCommentConnection = (connection: Connection<Comment>)
     totalCount: connection.totalCount,
   } satisfies PanoCommentConnection;
 };
+
+export const transformPostUpvote = (upvote: Upvote) => {
+  return {
+    ...upvote,
+    __typename: "PostUpvote",
+  } satisfies PostUpvote;
+};

apps/gql/schema/resolvers/index.ts

@@ -13,6 +13,7 @@ import {
   transformPanoCommentConnection,
   transformPanoPost,
   transformPanoPostConnection,
+  transformPostUpvote,
 } from "~/loaders/pano";
 import { transformSozlukTerm, transformSozlukTermsConnection } from "~/loaders/sozluk";
 import { transformUser } from "~/loaders/user";
@@ -244,6 +245,9 @@ export const resolvers = {
   CreatePanoCommentPayload: {}, // union
   UpdatePanoCommentPayload: {}, // union
   RemovePanoCommentPayload: {}, // union
+  CreatePostUpvotePayload: {}, // union
+  RemovePostUpvotePayload: {}, // union
+
   UserError: {}, // interface
 
   InvalidInput: errorFieldsResolver,
@@ -347,5 +351,37 @@ export const resolvers = {
 
       return transformPanoComment(await actions.pano.comment.remove(id.value));
     },
+    createPostUpvote: async (_, { input }, { actions, pasaport: { session } }) => {
+      if (!session?.user?.id) {
+        return NotAuthorized();
+      }
+
+      if (!input.postID) {
+        return InvalidInput("post is required");
+      }
+
+      return transformPostUpvote(
+        await actions.pano.postUpvote.create({
+          postID: input.postID,
+          userID: session.user.id,
+        })
+      );
+    },
+    removePostUpvote: async (_, { input }, { actions, pasaport: { session } }) => {
+      if (!session?.user?.id) {
+        return NotAuthorized();
+      }
+
+      if (!input.postID) {
+        return InvalidInput("post is required");
+      }
+
+      return transformPostUpvote(
+        await actions.pano.postUpvote.remove({
+          postID: input.postID,
+          userID: session.user.id,
+        })
+      );
+    },
   },
 } satisfies Resolvers;

apps/gql/schema/schema.graphql

@@ -158,6 +158,12 @@ type PanoCommentEdge {
   node: PanoComment
 }
 
+type PostUpvote {
+  id: ID!
+  postID: String!
+  userID: String!
+}
+
 type Mutation {
   createPanoPost(input: CreatePanoPostInput!): CreatePanoPostPayload
   updatePanoPost(input: UpdatePanoPostInput!): UpdatePanoPostPayload
@@ -166,6 +172,9 @@ type Mutation {
   createPanoComment(input: CreatePanoCommentInput!): CreatePanoCommentPayload
   updatePanoComment(input: UpdatePanoCommentInput!): UpdatePanoCommentPayload
   removePanoComment(input: RemovePanoCommentInput!): RemovePanoCommentPayload
+
+  createPostUpvote(input: CreatePostUpvoteInput!): CreatePostUpvotePayload
+  removePostUpvote(input: RemovePostUpvoteInput!): RemovePostUpvotePayload
 }
 
 input CreatePanoPostInput {
@@ -211,3 +220,15 @@ union RemovePanoCommentPayload = PanoComment | NotAuthorized | InvalidInput
 input RemovePanoCommentInput {
   id: ID!
 }
+
+input CreatePostUpvoteInput {
+  postID: String!
+}
+
+union CreatePostUpvotePayload = PostUpvote | NotAuthorized | InvalidInput
+
+input RemovePostUpvoteInput {
+  postID: String!
+}
+
+union RemovePostUpvotePayload = PostUpvote | NotAuthorized | InvalidInput