Merge branch 'hongpo/sorting-pagination' of https://github.com/yangshun/tech-interview-handbook into hongpo/sorting-pagination
hpkoh
3 years ago
commit
06840d10da
@ -1,275 +0,0 @@
|
|||||||
import { z } from 'zod';
|
|
||||||
import { TRPCError } from '@trpc/server';
|
|
||||||
|
|
||||||
import { createQuestionWithAggregateData } from '~/utils/questions/server/aggregate-encounters';
|
|
||||||
|
|
||||||
import { createProtectedRouter } from './context';
|
|
||||||
|
|
||||||
export const questionsListRouter = createProtectedRouter()
|
|
||||||
.query('getListsByUser', {
|
|
||||||
async resolve({ ctx }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
|
|
||||||
// TODO: Optimize by not returning question entries
|
|
||||||
const questionsLists = await ctx.prisma.questionsList.findMany({
|
|
||||||
include: {
|
|
||||||
questionEntries: {
|
|
||||||
include: {
|
|
||||||
question: {
|
|
||||||
include: {
|
|
||||||
_count: {
|
|
||||||
select: {
|
|
||||||
answers: true,
|
|
||||||
comments: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
encounters: {
|
|
||||||
select: {
|
|
||||||
company: true,
|
|
||||||
location: true,
|
|
||||||
role: true,
|
|
||||||
seenAt: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
user: {
|
|
||||||
select: {
|
|
||||||
name: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
votes: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
orderBy: {
|
|
||||||
createdAt: 'asc',
|
|
||||||
},
|
|
||||||
where: {
|
|
||||||
userId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
const lists = questionsLists.map((list) => ({
|
|
||||||
...list,
|
|
||||||
questionEntries: list.questionEntries.map((entry) => ({
|
|
||||||
...entry,
|
|
||||||
question: createQuestionWithAggregateData(entry.question),
|
|
||||||
})),
|
|
||||||
}));
|
|
||||||
|
|
||||||
return lists;
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.query('getListById', {
|
|
||||||
input: z.object({
|
|
||||||
listId: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
const { listId } = input;
|
|
||||||
|
|
||||||
const questionList = await ctx.prisma.questionsList.findFirst({
|
|
||||||
include: {
|
|
||||||
questionEntries: {
|
|
||||||
include: {
|
|
||||||
question: {
|
|
||||||
include: {
|
|
||||||
_count: {
|
|
||||||
select: {
|
|
||||||
answers: true,
|
|
||||||
comments: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
encounters: {
|
|
||||||
select: {
|
|
||||||
company: true,
|
|
||||||
location: true,
|
|
||||||
role: true,
|
|
||||||
seenAt: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
user: {
|
|
||||||
select: {
|
|
||||||
name: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
votes: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
orderBy: {
|
|
||||||
createdAt: 'asc',
|
|
||||||
},
|
|
||||||
where: {
|
|
||||||
id: listId,
|
|
||||||
userId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!questionList) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'NOT_FOUND',
|
|
||||||
message: 'Question list not found',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
...questionList,
|
|
||||||
questionEntries: questionList.questionEntries.map((questionEntry) => ({
|
|
||||||
...questionEntry,
|
|
||||||
question: createQuestionWithAggregateData(questionEntry.question),
|
|
||||||
})),
|
|
||||||
};
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.mutation('create', {
|
|
||||||
input: z.object({
|
|
||||||
name: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
|
|
||||||
const { name } = input;
|
|
||||||
|
|
||||||
return await ctx.prisma.questionsList.create({
|
|
||||||
data: {
|
|
||||||
name,
|
|
||||||
userId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.mutation('update', {
|
|
||||||
input: z.object({
|
|
||||||
id: z.string(),
|
|
||||||
name: z.string().optional(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
const { name, id } = input;
|
|
||||||
|
|
||||||
const listToUpdate = await ctx.prisma.questionsList.findUnique({
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (listToUpdate?.id !== userId) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'UNAUTHORIZED',
|
|
||||||
message: 'User have no authorization to record.',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return await ctx.prisma.questionsList.update({
|
|
||||||
data: {
|
|
||||||
name,
|
|
||||||
},
|
|
||||||
where: {
|
|
||||||
id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.mutation('delete', {
|
|
||||||
input: z.object({
|
|
||||||
id: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
|
|
||||||
const listToDelete = await ctx.prisma.questionsList.findUnique({
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (listToDelete?.userId !== userId) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'UNAUTHORIZED',
|
|
||||||
message: 'User have no authorization to record.',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return await ctx.prisma.questionsList.delete({
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.mutation('createQuestionEntry', {
|
|
||||||
input: z.object({
|
|
||||||
listId: z.string(),
|
|
||||||
questionId: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
|
|
||||||
const listToAugment = await ctx.prisma.questionsList.findUnique({
|
|
||||||
where: {
|
|
||||||
id: input.listId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (listToAugment?.userId !== userId) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'UNAUTHORIZED',
|
|
||||||
message: 'User have no authorization to record.',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
const { questionId, listId } = input;
|
|
||||||
|
|
||||||
return await ctx.prisma.questionsListQuestionEntry.create({
|
|
||||||
data: {
|
|
||||||
listId,
|
|
||||||
questionId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.mutation('deleteQuestionEntry', {
|
|
||||||
input: z.object({
|
|
||||||
id: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const userId = ctx.session?.user?.id;
|
|
||||||
|
|
||||||
const entryToDelete =
|
|
||||||
await ctx.prisma.questionsListQuestionEntry.findUnique({
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (entryToDelete === null) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'NOT_FOUND',
|
|
||||||
message: 'Entry not found.',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
const listToAugment = await ctx.prisma.questionsList.findUnique({
|
|
||||||
where: {
|
|
||||||
id: entryToDelete.listId,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
if (listToAugment?.userId !== userId) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'UNAUTHORIZED',
|
|
||||||
message: 'User have no authorization to record.',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return await ctx.prisma.questionsListQuestionEntry.delete({
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
||||||
@ -1,437 +0,0 @@
|
|||||||
import { z } from 'zod';
|
|
||||||
import { QuestionsQuestionType, Vote } from '@prisma/client';
|
|
||||||
import { TRPCError } from '@trpc/server';
|
|
||||||
|
|
||||||
import { createQuestionWithAggregateData } from '~/utils/questions/server/aggregate-encounters';
|
|
||||||
|
|
||||||
import { createProtectedRouter } from './context';
|
|
||||||
|
|
||||||
import { SortOrder, SortType } from '~/types/questions.d';
|
|
||||||
|
|
||||||
export const questionsQuestionRouter = createProtectedRouter()
|
|
||||||
.query('getQuestionsByFilter', {
|
|
||||||
input: z.object({
|
|
||||||
companyNames: z.string().array(),
|
|
||||||
cursor: z
|
|
||||||
.object({
|
|
||||||
idCursor: z.string().optional(),
|
|
||||||
lastSeenCursor: z.date().nullish().optional(),
|
|
||||||
upvoteCursor: z.number().optional(),
|
|
||||||
})
|
|
||||||
.nullish(),
|
|
||||||
endDate: z.date().default(new Date()),
|
|
||||||
limit: z.number().min(1).default(50),
|
|
||||||
locations: z.string().array(),
|
|
||||||
questionTypes: z.nativeEnum(QuestionsQuestionType).array(),
|
|
||||||
roles: z.string().array(),
|
|
||||||
sortOrder: z.nativeEnum(SortOrder),
|
|
||||||
sortType: z.nativeEnum(SortType),
|
|
||||||
startDate: z.date().optional(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const { cursor } = input;
|
|
||||||
|
|
||||||
const sortCondition =
|
|
||||||
input.sortType === SortType.TOP
|
|
||||||
? [
|
|
||||||
{
|
|
||||||
upvotes: input.sortOrder,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
id: input.sortOrder,
|
|
||||||
},
|
|
||||||
]
|
|
||||||
: [
|
|
||||||
{
|
|
||||||
lastSeenAt: input.sortOrder,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
id: input.sortOrder,
|
|
||||||
},
|
|
||||||
];
|
|
||||||
|
|
||||||
const questionsData = await ctx.prisma.questionsQuestion.findMany({
|
|
||||||
cursor:
|
|
||||||
cursor !== undefined
|
|
||||||
? {
|
|
||||||
id: cursor ? cursor!.idCursor : undefined,
|
|
||||||
}
|
|
||||||
: undefined,
|
|
||||||
include: {
|
|
||||||
_count: {
|
|
||||||
select: {
|
|
||||||
answers: true,
|
|
||||||
comments: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
encounters: {
|
|
||||||
select: {
|
|
||||||
company: true,
|
|
||||||
location: true,
|
|
||||||
role: true,
|
|
||||||
seenAt: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
user: {
|
|
||||||
select: {
|
|
||||||
name: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
votes: true,
|
|
||||||
},
|
|
||||||
orderBy: sortCondition,
|
|
||||||
take: input.limit + 1,
|
|
||||||
where: {
|
|
||||||
...(input.questionTypes.length > 0
|
|
||||||
? {
|
|
||||||
questionType: {
|
|
||||||
in: input.questionTypes,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
: {}),
|
|
||||||
encounters: {
|
|
||||||
some: {
|
|
||||||
seenAt: {
|
|
||||||
gte: input.startDate,
|
|
||||||
lte: input.endDate,
|
|
||||||
},
|
|
||||||
...(input.companyNames.length > 0
|
|
||||||
? {
|
|
||||||
company: {
|
|
||||||
name: {
|
|
||||||
in: input.companyNames,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
: {}),
|
|
||||||
...(input.locations.length > 0
|
|
||||||
? {
|
|
||||||
location: {
|
|
||||||
in: input.locations,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
: {}),
|
|
||||||
...(input.roles.length > 0
|
|
||||||
? {
|
|
||||||
role: {
|
|
||||||
in: input.roles,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
: {}),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
const processedQuestionsData = questionsData.map(
|
|
||||||
createQuestionWithAggregateData,
|
|
||||||
);
|
|
||||||
|
|
||||||
let nextCursor: typeof cursor | undefined = undefined;
|
|
||||||
|
|
||||||
if (questionsData.length > input.limit) {
|
|
||||||
const nextItem = questionsData.pop()!;
|
|
||||||
processedQuestionsData.pop();
|
|
||||||
|
|
||||||
const nextIdCursor: string | undefined = nextItem.id;
|
|
||||||
const nextLastSeenCursor =
|
|
||||||
input.sortType === SortType.NEW ? nextItem.lastSeenAt : undefined;
|
|
||||||
const nextUpvoteCursor =
|
|
||||||
input.sortType === SortType.TOP ? nextItem.upvotes : undefined;
|
|
||||||
|
|
||||||
nextCursor = {
|
|
||||||
idCursor: nextIdCursor,
|
|
||||||
lastSeenCursor: nextLastSeenCursor,
|
|
||||||
upvoteCursor: nextUpvoteCursor,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
data: processedQuestionsData,
|
|
||||||
nextCursor,
|
|
||||||
};
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.query('getQuestionById', {
|
|
||||||
input: z.object({
|
|
||||||
id: z.string(),
|
|
||||||
}),
|
|
||||||
async resolve({ ctx, input }) {
|
|
||||||
const questionData = await ctx.prisma.questionsQuestion.findUnique({
|
|
||||||
include: {
|
|
||||||
_count: {
|
|
||||||
select: {
|
|
||||||
answers: true,
|
|
||||||
comments: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
encounters: {
|
|
||||||
select: {
|
|
||||||
company: true,
|
|
||||||
location: true,
|
|
||||||
role: true,
|
|
||||||
seenAt: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
user: {
|
|
||||||
select: {
|
|
||||||
name: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
votes: true,
|
|
||||||
},
|
|
||||||
where: {
|
|
||||||
id: input.id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
if (!questionData) {
|
|
||||||
throw new TRPCError({
|
|
||||||
code: 'NOT_FOUND',
|
|
||||||
message: 'Question not found',
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return createQuestionWithAggregateData(questionData);
|
|
||||||
},
|
|
||||||
})
|
|
||||||
.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;
|
|
||||||
},
|
|
||||||
});
|
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
import { JobTitleLabels } from '~/components/shared/JobTitles';
|
||||||
|
|
||||||
|
import type { AggregatedQuestionEncounter } from '~/types/questions';
|
||||||
|
|
||||||
|
export default function relabelQuestionAggregates({
|
||||||
|
locationCounts,
|
||||||
|
companyCounts,
|
||||||
|
roleCounts,
|
||||||
|
latestSeenAt,
|
||||||
|
}: AggregatedQuestionEncounter) {
|
||||||
|
const newRoleCounts = Object.fromEntries(
|
||||||
|
Object.entries(roleCounts).map(([roleId, count]) => [
|
||||||
|
JobTitleLabels[roleId as keyof typeof JobTitleLabels],
|
||||||
|
count,
|
||||||
|
]),
|
||||||
|
);
|
||||||
|
|
||||||
|
const relabeledAggregate: AggregatedQuestionEncounter = {
|
||||||
|
companyCounts,
|
||||||
|
latestSeenAt,
|
||||||
|
locationCounts,
|
||||||
|
roleCounts: newRoleCounts,
|
||||||
|
};
|
||||||
|
|
||||||
|
return relabeledAggregate;
|
||||||
|
}
|
||||||
Loading…
Reference in new issue