parent
352f8a03ad
commit
c20c0e0eca
@ -0,0 +1,64 @@
|
|||||||
|
import { z } from 'zod';
|
||||||
|
import { Vote } from '@prisma/client';
|
||||||
|
|
||||||
|
import { createRouter } from '../context';
|
||||||
|
|
||||||
|
import type { AnswerComment } from '~/types/questions';
|
||||||
|
|
||||||
|
export const questionsAnswerCommentRouter = createRouter().query(
|
||||||
|
'getAnswerComments',
|
||||||
|
{
|
||||||
|
input: z.object({
|
||||||
|
answerId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const questionAnswerCommentsData =
|
||||||
|
await ctx.prisma.questionsAnswerComment.findMany({
|
||||||
|
include: {
|
||||||
|
user: {
|
||||||
|
select: {
|
||||||
|
image: true,
|
||||||
|
name: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
votes: true,
|
||||||
|
},
|
||||||
|
orderBy: {
|
||||||
|
createdAt: 'desc',
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
answerId: input.answerId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
return questionAnswerCommentsData.map((data) => {
|
||||||
|
const votes: number = data.votes.reduce(
|
||||||
|
(previousValue: number, currentValue) => {
|
||||||
|
let result: number = previousValue;
|
||||||
|
|
||||||
|
switch (currentValue.vote) {
|
||||||
|
case Vote.UPVOTE:
|
||||||
|
result += 1;
|
||||||
|
break;
|
||||||
|
case Vote.DOWNVOTE:
|
||||||
|
result -= 1;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
},
|
||||||
|
0,
|
||||||
|
);
|
||||||
|
|
||||||
|
const answerComment: AnswerComment = {
|
||||||
|
content: data.content,
|
||||||
|
createdAt: data.createdAt,
|
||||||
|
id: data.id,
|
||||||
|
numVotes: votes,
|
||||||
|
updatedAt: data.updatedAt,
|
||||||
|
user: data.user?.name ?? '',
|
||||||
|
userImage: data.user?.image ?? '',
|
||||||
|
};
|
||||||
|
return answerComment;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
},
|
||||||
|
);
|
@ -0,0 +1,128 @@
|
|||||||
|
import { z } from 'zod';
|
||||||
|
import { Vote } from '@prisma/client';
|
||||||
|
import { TRPCError } from '@trpc/server';
|
||||||
|
|
||||||
|
import { createRouter } from '../context';
|
||||||
|
|
||||||
|
import type { Answer } from '~/types/questions';
|
||||||
|
|
||||||
|
export const questionsAnswerRouter = createRouter()
|
||||||
|
.query('getAnswers', {
|
||||||
|
input: z.object({
|
||||||
|
questionId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const { questionId } = input;
|
||||||
|
|
||||||
|
const answersData = await ctx.prisma.questionsAnswer.findMany({
|
||||||
|
include: {
|
||||||
|
_count: {
|
||||||
|
select: {
|
||||||
|
comments: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
user: {
|
||||||
|
select: {
|
||||||
|
image: true,
|
||||||
|
name: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
votes: true,
|
||||||
|
},
|
||||||
|
orderBy: {
|
||||||
|
createdAt: 'desc',
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
questionId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
return answersData.map((data) => {
|
||||||
|
const votes: number = data.votes.reduce(
|
||||||
|
(previousValue: number, currentValue) => {
|
||||||
|
let result: number = previousValue;
|
||||||
|
|
||||||
|
switch (currentValue.vote) {
|
||||||
|
case Vote.UPVOTE:
|
||||||
|
result += 1;
|
||||||
|
break;
|
||||||
|
case Vote.DOWNVOTE:
|
||||||
|
result -= 1;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
},
|
||||||
|
0,
|
||||||
|
);
|
||||||
|
|
||||||
|
const answer: Answer = {
|
||||||
|
content: data.content,
|
||||||
|
createdAt: data.createdAt,
|
||||||
|
id: data.id,
|
||||||
|
numComments: data._count.comments,
|
||||||
|
numVotes: votes,
|
||||||
|
user: data.user?.name ?? '',
|
||||||
|
userImage: data.user?.image ?? '',
|
||||||
|
};
|
||||||
|
return answer;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.query('getAnswerById', {
|
||||||
|
input: z.object({
|
||||||
|
answerId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const answerData = await ctx.prisma.questionsAnswer.findUnique({
|
||||||
|
include: {
|
||||||
|
_count: {
|
||||||
|
select: {
|
||||||
|
comments: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
user: {
|
||||||
|
select: {
|
||||||
|
image: true,
|
||||||
|
name: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
votes: true,
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id: input.answerId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
if (!answerData) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: 'NOT_FOUND',
|
||||||
|
message: 'Answer not found',
|
||||||
|
});
|
||||||
|
}
|
||||||
|
const votes: number = answerData.votes.reduce(
|
||||||
|
(previousValue: number, currentValue) => {
|
||||||
|
let result: number = previousValue;
|
||||||
|
|
||||||
|
switch (currentValue.vote) {
|
||||||
|
case Vote.UPVOTE:
|
||||||
|
result += 1;
|
||||||
|
break;
|
||||||
|
case Vote.DOWNVOTE:
|
||||||
|
result -= 1;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
},
|
||||||
|
0,
|
||||||
|
);
|
||||||
|
|
||||||
|
const answer: Answer = {
|
||||||
|
content: answerData.content,
|
||||||
|
createdAt: answerData.createdAt,
|
||||||
|
id: answerData.id,
|
||||||
|
numComments: answerData._count.comments,
|
||||||
|
numVotes: votes,
|
||||||
|
user: answerData.user?.name ?? '',
|
||||||
|
userImage: answerData.user?.image ?? '',
|
||||||
|
};
|
||||||
|
return answer;
|
||||||
|
},
|
||||||
|
});
|
@ -0,0 +1,64 @@
|
|||||||
|
import { z } from 'zod';
|
||||||
|
import { Vote } from '@prisma/client';
|
||||||
|
|
||||||
|
import { createRouter } from '../context';
|
||||||
|
|
||||||
|
import type { QuestionComment } from '~/types/questions';
|
||||||
|
|
||||||
|
export const questionsQuestionCommentRouter = createRouter().query(
|
||||||
|
'getQuestionComments',
|
||||||
|
{
|
||||||
|
input: z.object({
|
||||||
|
questionId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const { questionId } = input;
|
||||||
|
const questionCommentsData =
|
||||||
|
await ctx.prisma.questionsQuestionComment.findMany({
|
||||||
|
include: {
|
||||||
|
user: {
|
||||||
|
select: {
|
||||||
|
image: true,
|
||||||
|
name: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
votes: true,
|
||||||
|
},
|
||||||
|
orderBy: {
|
||||||
|
createdAt: 'desc',
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
questionId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
return questionCommentsData.map((data) => {
|
||||||
|
const votes: number = data.votes.reduce(
|
||||||
|
(previousValue: number, currentValue) => {
|
||||||
|
let result: number = previousValue;
|
||||||
|
|
||||||
|
switch (currentValue.vote) {
|
||||||
|
case Vote.UPVOTE:
|
||||||
|
result += 1;
|
||||||
|
break;
|
||||||
|
case Vote.DOWNVOTE:
|
||||||
|
result -= 1;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
},
|
||||||
|
0,
|
||||||
|
);
|
||||||
|
|
||||||
|
const questionComment: QuestionComment = {
|
||||||
|
content: data.content,
|
||||||
|
createdAt: data.createdAt,
|
||||||
|
id: data.id,
|
||||||
|
numVotes: votes,
|
||||||
|
user: data.user?.name ?? '',
|
||||||
|
userImage: data.user?.image ?? '',
|
||||||
|
};
|
||||||
|
return questionComment;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
},
|
||||||
|
);
|
@ -0,0 +1,61 @@
|
|||||||
|
import { z } from 'zod';
|
||||||
|
|
||||||
|
import { createRouter } from '../context';
|
||||||
|
|
||||||
|
import type { AggregatedQuestionEncounter } from '~/types/questions';
|
||||||
|
|
||||||
|
export const questionsQuestionEncounterRouter = createRouter().query(
|
||||||
|
'getAggregatedEncounters',
|
||||||
|
{
|
||||||
|
input: z.object({
|
||||||
|
questionId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const questionEncountersData =
|
||||||
|
await ctx.prisma.questionsQuestionEncounter.findMany({
|
||||||
|
include: {
|
||||||
|
company: true,
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
...input,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
const companyCounts: Record<string, number> = {};
|
||||||
|
const locationCounts: Record<string, number> = {};
|
||||||
|
const roleCounts: Record<string, number> = {};
|
||||||
|
|
||||||
|
let latestSeenAt = questionEncountersData[0].seenAt;
|
||||||
|
|
||||||
|
for (let i = 0; i < questionEncountersData.length; i++) {
|
||||||
|
const encounter = questionEncountersData[i];
|
||||||
|
|
||||||
|
latestSeenAt =
|
||||||
|
latestSeenAt < encounter.seenAt ? encounter.seenAt : latestSeenAt;
|
||||||
|
|
||||||
|
if (!(encounter.company!.name in companyCounts)) {
|
||||||
|
companyCounts[encounter.company!.name] = 1;
|
||||||
|
}
|
||||||
|
companyCounts[encounter.company!.name] += 1;
|
||||||
|
|
||||||
|
if (!(encounter.location in locationCounts)) {
|
||||||
|
locationCounts[encounter.location] = 1;
|
||||||
|
}
|
||||||
|
locationCounts[encounter.location] += 1;
|
||||||
|
|
||||||
|
if (!(encounter.role in roleCounts)) {
|
||||||
|
roleCounts[encounter.role] = 1;
|
||||||
|
}
|
||||||
|
roleCounts[encounter.role] += 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
const questionEncounter: AggregatedQuestionEncounter = {
|
||||||
|
companyCounts,
|
||||||
|
latestSeenAt,
|
||||||
|
locationCounts,
|
||||||
|
roleCounts,
|
||||||
|
};
|
||||||
|
return questionEncounter;
|
||||||
|
},
|
||||||
|
},
|
||||||
|
);
|
@ -0,0 +1,248 @@
|
|||||||
|
import { z } from 'zod';
|
||||||
|
import { QuestionsQuestionType, Vote } from '@prisma/client';
|
||||||
|
import { TRPCError } from '@trpc/server';
|
||||||
|
|
||||||
|
import { createProtectedRouter } from '../context';
|
||||||
|
|
||||||
|
export const questionsQuestionUserRouter = createProtectedRouter()
|
||||||
|
.mutation('create', {
|
||||||
|
input: z.object({
|
||||||
|
companyId: z.string(),
|
||||||
|
content: z.string(),
|
||||||
|
location: z.string(),
|
||||||
|
questionType: z.nativeEnum(QuestionsQuestionType),
|
||||||
|
role: z.string(),
|
||||||
|
seenAt: z.date(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
|
||||||
|
return await ctx.prisma.questionsQuestion.create({
|
||||||
|
data: {
|
||||||
|
content: input.content,
|
||||||
|
encounters: {
|
||||||
|
create: {
|
||||||
|
company: {
|
||||||
|
connect: {
|
||||||
|
id: input.companyId,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
location: input.location,
|
||||||
|
role: input.role,
|
||||||
|
seenAt: input.seenAt,
|
||||||
|
user: {
|
||||||
|
connect: {
|
||||||
|
id: userId,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
lastSeenAt: input.seenAt,
|
||||||
|
questionType: input.questionType,
|
||||||
|
userId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.mutation('update', {
|
||||||
|
input: z.object({
|
||||||
|
content: z.string().optional(),
|
||||||
|
id: z.string(),
|
||||||
|
questionType: z.nativeEnum(QuestionsQuestionType).optional(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
|
||||||
|
const questionToUpdate = await ctx.prisma.questionsQuestion.findUnique({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (questionToUpdate?.id !== userId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: 'UNAUTHORIZED',
|
||||||
|
message: 'User have no authorization to record.',
|
||||||
|
// Optional: pass the original error to retain stack trace
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const { content, questionType } = input;
|
||||||
|
|
||||||
|
return await ctx.prisma.questionsQuestion.update({
|
||||||
|
data: {
|
||||||
|
content,
|
||||||
|
questionType,
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.mutation('delete', {
|
||||||
|
input: z.object({
|
||||||
|
id: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
|
||||||
|
const questionToDelete = await ctx.prisma.questionsQuestion.findUnique({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (questionToDelete?.id !== userId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: 'UNAUTHORIZED',
|
||||||
|
message: 'User have no authorization to record.',
|
||||||
|
// Optional: pass the original error to retain stack trace
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return await ctx.prisma.questionsQuestion.delete({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.query('getVote', {
|
||||||
|
input: z.object({
|
||||||
|
questionId: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
const { questionId } = input;
|
||||||
|
|
||||||
|
return await ctx.prisma.questionsQuestionVote.findUnique({
|
||||||
|
where: {
|
||||||
|
questionId_userId: { questionId, userId },
|
||||||
|
},
|
||||||
|
});
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.mutation('createVote', {
|
||||||
|
input: z.object({
|
||||||
|
questionId: z.string(),
|
||||||
|
vote: z.nativeEnum(Vote),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
const { questionId, vote } = input;
|
||||||
|
|
||||||
|
const incrementValue = vote === Vote.UPVOTE ? 1 : -1;
|
||||||
|
|
||||||
|
const [questionVote] = await ctx.prisma.$transaction([
|
||||||
|
ctx.prisma.questionsQuestionVote.create({
|
||||||
|
data: {
|
||||||
|
questionId,
|
||||||
|
userId,
|
||||||
|
vote,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
ctx.prisma.questionsQuestion.update({
|
||||||
|
data: {
|
||||||
|
upvotes: {
|
||||||
|
increment: incrementValue,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id: questionId,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
return questionVote;
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.mutation('updateVote', {
|
||||||
|
input: z.object({
|
||||||
|
id: z.string(),
|
||||||
|
vote: z.nativeEnum(Vote),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
const { id, vote } = input;
|
||||||
|
|
||||||
|
const voteToUpdate = await ctx.prisma.questionsQuestionVote.findUnique({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (voteToUpdate?.userId !== userId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: 'UNAUTHORIZED',
|
||||||
|
message: 'User have no authorization to record.',
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const incrementValue = vote === Vote.UPVOTE ? 2 : -2;
|
||||||
|
|
||||||
|
const [questionVote] = await ctx.prisma.$transaction([
|
||||||
|
ctx.prisma.questionsQuestionVote.update({
|
||||||
|
data: {
|
||||||
|
vote,
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
ctx.prisma.questionsQuestion.update({
|
||||||
|
data: {
|
||||||
|
upvotes: {
|
||||||
|
increment: incrementValue,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id: voteToUpdate.questionId,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
|
||||||
|
return questionVote;
|
||||||
|
},
|
||||||
|
})
|
||||||
|
.mutation('deleteVote', {
|
||||||
|
input: z.object({
|
||||||
|
id: z.string(),
|
||||||
|
}),
|
||||||
|
async resolve({ ctx, input }) {
|
||||||
|
const userId = ctx.session?.user?.id;
|
||||||
|
|
||||||
|
const voteToDelete = await ctx.prisma.questionsQuestionVote.findUnique({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (voteToDelete?.userId !== userId) {
|
||||||
|
throw new TRPCError({
|
||||||
|
code: 'UNAUTHORIZED',
|
||||||
|
message: 'User have no authorization to record.',
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
const incrementValue = voteToDelete.vote === Vote.UPVOTE ? -1 : 1;
|
||||||
|
|
||||||
|
const [questionVote] = await ctx.prisma.$transaction([
|
||||||
|
ctx.prisma.questionsQuestionVote.delete({
|
||||||
|
where: {
|
||||||
|
id: input.id,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
ctx.prisma.questionsQuestion.update({
|
||||||
|
data: {
|
||||||
|
upvotes: {
|
||||||
|
increment: incrementValue,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
where: {
|
||||||
|
id: voteToDelete.questionId,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
return questionVote;
|
||||||
|
},
|
||||||
|
});
|
Loading…
Reference in new issue