feat: implement review submission and update functionality with TRPC integration

Author: Starefossen

src/app/(admin)/admin/api/proposals/[id]/review/route.ts

@@ -3,9 +3,9 @@
 import { useState } from 'react'
 import { StarIcon } from '@heroicons/react/24/solid'
 import { PaperAirplaneIcon, ArrowRightIcon } from '@heroicons/react/24/outline'
-import { Review, ReviewBase } from '@/lib/review/types'
-import { adminPostReview } from '@/lib/review/client'
+import { Review } from '@/lib/review/types'
 import { adminFetchNextUnreviewedProposal } from '@/lib/proposal'
+import { api } from '@/lib/trpc/client'
 import { useNotification } from './NotificationProvider'
 import { Textarea } from '@/components/Form'
 import { AdminButton } from '@/components/admin/AdminButton'
@@ -26,6 +26,7 @@ export function ProposalReviewForm({
 }: ProposalReviewFormProps) {
   const router = useRouter()
   const { showNotification } = useNotification()
+  const utils = api.useUtils()
   const [ratings, setRatings] = useState<{
     content: number
     relevance: number
@@ -44,24 +45,24 @@ export function ProposalReviewForm({
   const [isSubmitting, setIsSubmitting] = useState<boolean>(false)
   const [isLoadingNext, setIsLoadingNext] = useState<boolean>(false)
 
+  const submitReviewMutation = api.proposal.admin.submitReview.useMutation({
+    onSuccess: (review) => {
+      utils.proposal.admin.getById.invalidate({ id: proposalId })
+      utils.proposal.admin.list.invalidate()
+      onReviewSubmit(review as Review)
+    },
+  })
+
   const submitHandler = async (e: React.FormEvent) => {
     e.preventDefault()
     setIsSubmitting(true)
 
-    const reviewData: ReviewBase = {
-      comment,
-      score: ratings,
-    }
-
     try {
-      const res = await adminPostReview(proposalId, reviewData)
-
-      if (res.reviewError || !res.review) {
-        console.error('Error submitting review:', res.reviewError)
-        return
-      }
-
-      onReviewSubmit(res.review)
+      await submitReviewMutation.mutateAsync({
+        id: proposalId,
+        comment,
+        score: ratings,
+      })
     } catch (error) {
       console.error('Error submitting review:', error)
     } finally {

src/components/admin/ProposalReviewForm.tsx

@@ -20,6 +20,7 @@ import {
   IdParamSchema,
   ProposalActionSchema,
   AudienceFeedbackSchema,
+  SubmitReviewSchema,
 } from '@/server/schemas/proposal'
 import { AttachmentSchema } from '@/server/schemas/attachment'
 import {
@@ -47,6 +48,7 @@ import { Speaker } from '@/lib/speaker/types'
 import { eventBus } from '@/lib/events/bus'
 import { ProposalStatusChangeEvent } from '@/lib/events/types'
 import { updateProposalStatus, getProposalSanity } from '@/lib/proposal/server'
+import { createReview, updateReview } from '@/lib/review/sanity'
 import '@/lib/events/registry'
 
 /**
@@ -332,7 +334,7 @@ export const proposalRouter = router({
         if (!ctx.speaker.isOrganizer && existing.conference) {
           const conferenceId =
             typeof existing.conference === 'object' &&
-            '_id' in existing.conference
+              '_id' in existing.conference
               ? existing.conference._id
               : typeof existing.conference === 'string'
                 ? existing.conference
@@ -863,6 +865,72 @@ export const proposalRouter = router({
           })
         }
       }),
+
+    // Submit or update a review (admin)
+    submitReview: adminProcedure
+      .input(SubmitReviewSchema)
+      .mutation(async ({ input, ctx }) => {
+        try {
+          const { proposal, proposalError } = await getProposal({
+            id: input.id,
+            speakerId: ctx.speaker._id,
+            isOrganizer: true,
+            includeReviews: true,
+          })
+
+          if (proposalError || !proposal || !proposal._id) {
+            throw new TRPCError({
+              code: proposalError ? 'INTERNAL_SERVER_ERROR' : 'NOT_FOUND',
+              message: proposalError
+                ? 'Failed to fetch proposal'
+                : 'Proposal not found',
+              cause: proposalError,
+            })
+          }
+
+          const existingReview = proposal.reviews?.find(
+            (r) => 'email' in r.reviewer && r.reviewer._id === ctx.speaker._id,
+          )
+
+          const conferenceId =
+            '_id' in proposal.conference
+              ? proposal.conference._id
+              : (proposal.conference as { _ref: string })._ref
+
+          const reviewData = { comment: input.comment, score: input.score }
+
+          const { review, reviewError } = existingReview
+            ? await updateReview(
+              existingReview._id,
+              ctx.speaker._id,
+              reviewData,
+            )
+            : await createReview(
+              proposal._id,
+              ctx.speaker._id,
+              conferenceId,
+              reviewData,
+            )
+
+          if (reviewError || !review) {
+            throw new TRPCError({
+              code: 'INTERNAL_SERVER_ERROR',
+              message: `Failed to ${existingReview ? 'update' : 'create'} review`,
+              cause: reviewError,
+            })
+          }
+
+          return review
+        } catch (error) {
+          if (error instanceof TRPCError) throw error
+
+          throw new TRPCError({
+            code: 'INTERNAL_SERVER_ERROR',
+            message: 'Failed to submit review',
+            cause: error,
+          })
+        }
+      }),
   }),
 
   // Speaker attachment operations

src/lib/review/client.ts

@@ -170,4 +170,15 @@ export const AudienceFeedbackSchema = z.object({
   redCount: z.number().int().min(0),
 })
 
-export const IdParamSchema = CommonIdParamSchema
+export const ReviewScoreSchema = z.object({
+  content: z.number().int().min(1).max(5),
+  relevance: z.number().int().min(1).max(5),
+  speaker: z.number().int().min(1).max(5),
+})
+
+export const SubmitReviewSchema = CommonIdParamSchema.extend({
+  comment: z.string(),
+  score: ReviewScoreSchema,
+})
+
+export { CommonIdParamSchema as IdParamSchema }