+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationsService.ts | +
+
+ |
+ 100% | +33/33 | +100% | +6/6 | +100% | +9/9 | +100% | +32/32 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 | +1x +1x + + + + +2x + + +2x +1x + +1x + + + +2x + +1x + + + +3x + +2x + + + + +2x +1x + + + + +7x +7x + +4x + + + +1x + + + +1x + + + +2x + +2x + +2x +2x +1x + + +1x +1x + + + +2x + + + + +2x +1x + + +1x + + + +2x +1x + + +1x + + +1x + + + + + + + + + + | import { Recommendation } from "@prisma/client";
+import { recommendationRepository } from "../repositories/recommendationRepository";
+import { conflictError, notFoundError } from "../utils/errorUtils";
+
+export type CreateRecommendationData = Omit<Recommendation, "id" | "score">;
+
+async function insert(createRecommendationData: CreateRecommendationData) {
+ const existingRecommendation = await recommendationRepository.findByName(
+ createRecommendationData.name
+ );
+ if (existingRecommendation)
+ throw conflictError("Recommendations names must be unique");
+
+ await recommendationRepository.create(createRecommendationData);
+}
+
+async function upvote(id: number) {
+ await getByIdOrFail(id);
+
+ await recommendationRepository.updateScore(id, "increment");
+}
+
+async function downvote(id: number) {
+ await getByIdOrFail(id);
+
+ const updatedRecommendation = await recommendationRepository.updateScore(
+ id,
+ "decrement"
+ );
+
+ if (updatedRecommendation.score < -5) {
+ await recommendationRepository.remove(id);
+ }
+}
+
+async function getByIdOrFail(id: number) {
+ const recommendation = await recommendationRepository.find(id);
+ if (!recommendation) throw notFoundError("Recommendation not found");
+
+ return recommendation;
+}
+
+async function get() {
+ return recommendationRepository.findAll();
+}
+
+async function getTop(amount: number) {
+ return recommendationRepository.getAmountByScore(amount);
+}
+
+async function getRandom() {
+ const random = Math.random();
+
+ const scoreFilter = getScoreFilter(random);
+
+ const recommendations = await getByScore(scoreFilter);
+ if (recommendations.length === 0) {
+ throw notFoundError("Recommendation not found");
+ }
+
+ const randomIndex = Math.floor(Math.random() * recommendations.length);
+ return recommendations[randomIndex];
+}
+
+async function getByScore(scoreFilter: "gt" | "lte") {
+ const recommendations = await recommendationRepository.findAll({
+ score: 10,
+ scoreFilter,
+ });
+
+ if (recommendations.length > 0) {
+ return recommendations;
+ }
+
+ return [];
+}
+
+ function getScoreFilter(random: number) {
+ if (random < 0.7) {
+ return "gt";
+ }
+
+ return "lte";
+}
+
+export const recommendationService = {
+ insert,
+ upvote,
+ downvote,
+ getRandom,
+ get,
+ getById: getByIdOrFail,
+ getTop,
+ getScoreFilter
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | 1x +1x +1x +1x +1x +1x + +1x +1x +1x + +1x +1x + + +1x +1x + +1x + | import cors from "cors";
+import express from "express";
+import "express-async-errors";
+import { errorHandlerMiddleware } from "./middlewares/errorHandlerMiddleware";
+import recommendationRouter from "./routers/recommendationRouter";
+import testsRouter from "./routers/testsRouter"
+
+const app = express();
+app.use(cors());
+app.use(express.json());
+
+if(process.env.NODE_ENV === "test"){
+ app.use(testsRouter)
+}
+
+app.use("/recommendations", recommendationRouter);
+app.use(errorHandlerMiddleware);
+
+export default app;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationController.ts | +
+
+ |
+ 100% | +25/25 | +100% | +1/1 | +100% | +7/7 | +100% | +25/25 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 | +1x +1x +1x + + +10x +10x +1x + + +9x + +8x + + + +2x + +2x + +1x + + + +3x + +3x + +2x + + + +2x + +1x + + + +4x +4x + + + +1x + +1x +1x + + + +2x + +2x +1x + + +1x + + + + + + + + + | import { Request, Response } from "express";
+import { recommendationSchema } from "../schemas/recommendationsSchemas";
+import { recommendationService } from "../services/recommendationsService";
+import { wrongSchemaError } from "../utils/errorUtils";
+
+async function insert(req: Request, res: Response) {
+ const validation = recommendationSchema.validate(req.body);
+ if (validation.error) {
+ throw wrongSchemaError();
+ }
+
+ await recommendationService.insert(req.body);
+
+ res.sendStatus(201);
+}
+
+async function upvote(req: Request, res: Response) {
+ const { id } = req.params;
+
+ await recommendationService.upvote(+id);
+
+ res.sendStatus(200);
+}
+
+async function downvote(req: Request, res: Response) {
+ const { id } = req.params;
+
+ await recommendationService.downvote(+id);
+
+ res.sendStatus(200);
+}
+
+async function random(req: Request, res: Response) {
+ const randomRecommendation = await recommendationService.getRandom();
+
+ res.send(randomRecommendation);
+}
+
+async function get(req: Request, res: Response) {
+ const recommendations = await recommendationService.get();
+ res.send(recommendations);
+}
+
+async function getTop(req: Request, res: Response) {
+ const { amount } = req.params;
+
+ const recommendations = await recommendationService.getTop(+amount);
+ res.send(recommendations);
+}
+
+async function getById(req: Request, res: Response) {
+ const { id } = req.params;
+
+ const recommendation = await recommendationService.getById(+id);
+ res.send(recommendation);
+}
+
+export const recommendationController = {
+ insert,
+ upvote,
+ downvote,
+ random,
+ getTop,
+ get,
+ getById,
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 | 1x + +1x +1x + | import { PrismaClient } from "@prisma/client";
+
+const prisma = new PrismaClient();
+export {prisma}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| database.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| app.ts | +
+
+ |
+ 100% | +14/14 | +100% | +1/1 | +100% | +0/0 | +100% | +14/14 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | +1x + + + + + +1x + + + + + + + +6x +6x + + + + + | import { NextFunction, Request, Response } from "express";
+import {
+ AppError,
+ errorTypeToStatusCode,
+ isAppError,
+} from "../utils/errorUtils";
+
+export function errorHandlerMiddleware(
+ err: Error | AppError,
+ req: Request,
+ res: Response,
+ next: NextFunction
+) {
+
+
+ if (isAppError(err)) {
+ return res.status(errorTypeToStatusCode(err.type)).send(err.message);
+ }
+
+ return res.sendStatus(500);
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| errorHandlerMiddleware.ts | +
+
+ |
+ 80% | +4/5 | +100% | +1/1 | +100% | +1/1 | +80% | +4/5 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationRepository.ts | +
+
+ |
+ 100% | +14/14 | +100% | +1/1 | +100% | +8/8 | +100% | +13/13 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 | +2x + + + +8x + + + + + + + + + + +8x + +8x + + + + + + + +1x + + + + + + + + +8x + +2x + +2x + + + + + +7x + + + + + +9x + + + + + +3x + + + + + + + + +1x + + + + +2x + + + + + + + + + | import { Prisma } from "@prisma/client";
+import { prisma } from "../database/database";
+import { CreateRecommendationData } from "../services/recommendationsService";
+
+async function create(createRecommendationData: CreateRecommendationData) {
+ await prisma.recommendation.create({
+ data: createRecommendationData,
+ });
+}
+
+interface FindAllWhere {
+ score: number;
+ scoreFilter: "lte" | "gt";
+}
+
+function findAll(findAllWhere?: FindAllWhere) {
+ const filter = getFindAllFilter(findAllWhere);
+
+ return prisma.recommendation.findMany({
+ where: filter,
+ orderBy: { id: "desc" },
+ take: 10
+ });
+}
+
+function getAmountByScore(take: number) {
+ return prisma.recommendation.findMany({
+ orderBy: { score: "desc" },
+ take,
+ });
+}
+
+function getFindAllFilter(
+ findAllWhere?: FindAllWhere
+): Prisma.RecommendationWhereInput {
+ if (!findAllWhere) return {};
+
+ const { score, scoreFilter } = findAllWhere;
+
+ return {
+ score: { [scoreFilter]: score },
+ };
+}
+
+function find(id: number) {
+ return prisma.recommendation.findUnique({
+ where: { id },
+ });
+}
+
+function findByName(name: string) {
+ return prisma.recommendation.findUnique({
+ where: { name },
+ });
+}
+
+async function updateScore(id: number, operation: "increment" | "decrement") {
+ return prisma.recommendation.update({
+ where: { id },
+ data: {
+ score: { [operation]: 1 },
+ },
+ });
+}
+
+async function remove(id: number) {
+ await prisma.recommendation.delete({
+ where: { id },
+ });
+}
+
+export const recommendationRepository = {
+ create,
+ findAll,
+ find,
+ findByName,
+ updateScore,
+ getAmountByScore,
+ remove,
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationRouter.ts | +
+
+ |
+ 100% | +11/11 | +100% | +0/0 | +100% | +0/0 | +100% | +11/11 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 | 1x +1x + +1x + +1x +1x +1x +1x +1x +1x +1x + +1x + | import { Router } from "express";
+import { recommendationController } from "../controllers/recommendationController";
+
+const recommendationRouter = Router();
+
+recommendationRouter.post("/", recommendationController.insert);
+recommendationRouter.get("/", recommendationController.get);
+recommendationRouter.get("/random", recommendationController.random);
+recommendationRouter.get("/top/:amount", recommendationController.getTop);
+recommendationRouter.get("/:id", recommendationController.getById);
+recommendationRouter.post("/:id/upvote", recommendationController.upvote);
+recommendationRouter.post("/:id/downvote", recommendationController.downvote);
+
+export default recommendationRouter;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationsSchemas.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 | 1x + + +1x + +1x + + + + | import joi from "joi";
+import { CreateRecommendationData } from "../services/recommendationsService";
+
+const youtubeLinkRegex = /^(https?\:\/\/)?(www\.youtube\.com|youtu\.?be)\/.+$/;
+
+export const recommendationSchema = joi.object<CreateRecommendationData>({
+ name: joi.string().required(),
+ youtubeLink: joi.string().required().pattern(youtubeLinkRegex),
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationsService.ts | +
+
+ |
+ 100% | +33/33 | +100% | +6/6 | +100% | +9/9 | +100% | +32/32 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 | +1x +1x + + + + +8x + + +8x +1x + +7x + + + +2x + +1x + + + +3x + +2x + + + + +2x +1x + + + + +7x +7x + +4x + + + +4x + + + +1x + + + +3x + +3x + +3x +3x +1x + + +2x +2x + + + +3x + + + + +3x +2x + + +1x + + + +3x +1x + + +2x + + +1x + + + + + + + + + + | import { Recommendation } from "@prisma/client";
+import { recommendationRepository } from "../repositories/recommendationRepository";
+import { conflictError, notFoundError } from "../utils/errorUtils";
+
+export type CreateRecommendationData = Omit<Recommendation, "id" | "score">;
+
+async function insert(createRecommendationData: CreateRecommendationData) {
+ const existingRecommendation = await recommendationRepository.findByName(
+ createRecommendationData.name
+ );
+ if (existingRecommendation)
+ throw conflictError("Recommendations names must be unique");
+
+ await recommendationRepository.create(createRecommendationData);
+}
+
+async function upvote(id: number) {
+ await getByIdOrFail(id);
+
+ await recommendationRepository.updateScore(id, "increment");
+}
+
+async function downvote(id: number) {
+ await getByIdOrFail(id);
+
+ const updatedRecommendation = await recommendationRepository.updateScore(
+ id,
+ "decrement"
+ );
+
+ if (updatedRecommendation.score < -5) {
+ await recommendationRepository.remove(id);
+ }
+}
+
+async function getByIdOrFail(id: number) {
+ const recommendation = await recommendationRepository.find(id);
+ if (!recommendation) throw notFoundError("Recommendation not found");
+
+ return recommendation;
+}
+
+async function get() {
+ return recommendationRepository.findAll();
+}
+
+async function getTop(amount: number) {
+ return recommendationRepository.getAmountByScore(amount);
+}
+
+async function getRandom() {
+ const random = Math.random();
+
+ const scoreFilter = getScoreFilter(random);
+
+ const recommendations = await getByScore(scoreFilter);
+ if (recommendations.length === 0) {
+ throw notFoundError("Recommendation not found");
+ }
+
+ const randomIndex = Math.floor(Math.random() * recommendations.length);
+ return recommendations[randomIndex];
+}
+
+async function getByScore(scoreFilter: "gt" | "lte") {
+ const recommendations = await recommendationRepository.findAll({
+ score: 10,
+ scoreFilter,
+ });
+
+ if (recommendations.length > 0) {
+ return recommendations;
+ }
+
+ return [];
+}
+
+ function getScoreFilter(random: number) {
+ if (random < 0.7) {
+ return "gt";
+ }
+
+ return "lte";
+}
+
+export const recommendationService = {
+ insert,
+ upvote,
+ downvote,
+ getRandom,
+ get,
+ getById: getByIdOrFail,
+ getTop,
+ getScoreFilter
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 | 1x + +1x + + + +1x + + | import * as testsRepository from '../repositories/testsRepository'; + +export async function truncate() { + await testsRepository.truncate(); +} + +export async function populateDatabase(){ + await testsRepository.populateDatabase() +} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | + + + + + +2x +6x + + +2x +6x +5x +1x +1x + + + +2x +1x + + +2x +4x + + +2x + + + +2x +1x + + | type AppErrorTypes = "conflict" | "not_found" | "unauthorized" | "wrong_schema";
+export interface AppError {
+ type: AppErrorTypes;
+ message: string;
+}
+
+export function isAppError(error: object): error is AppError {
+ return (error as AppError).type !== undefined;
+}
+
+export function errorTypeToStatusCode(type: AppErrorTypes) {
+ if (type === "conflict") return 409;
+ if (type === "not_found") return 404;
+ Iif (type === "unauthorized") return 401;
+ if (type === "wrong_schema") return 422;
+ return 400;
+}
+
+export function conflictError(message?: string): AppError {
+ return { type: "conflict", message: message ?? "" };
+}
+
+export function notFoundError(message?: string): AppError {
+ return { type: "not_found", message: message ?? "" };
+}
+
+export function unauthorizedError(message?: string): AppError {
+ return { type: "unauthorized", message: message ?? "" };
+}
+
+export function wrongSchemaError(message?: string): AppError {
+ return { type: "wrong_schema", message: message ?? "" };
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| errorUtils.ts | +
+
+ |
+ 85% | +17/20 | +60% | +12/20 | +83.33% | +5/6 | +87.5% | +14/16 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommendationFactory.ts | +
+
+ |
+ 100% | +11/11 | +100% | +0/0 | +100% | +2/2 | +100% | +10/10 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | 2x +2x + + + + + + + +2x +9x + + + + +9x + + +2x + +1x +5x + +5x + + + + + +5x + + + + | import {faker} from "@faker-js/faker"
+import {prisma} from "../../src/database/database"
+
+interface IRecommendation {
+ name:string;
+ youtubeLink:string;
+}
+
+
+export async function recommendationFactory(){
+ const recommendation: IRecommendation = {
+ name:faker.music.songName(),
+ youtubeLink: "https://www.youtube.com/watch?v=h_D3VFfhvs4"
+ }
+
+ return recommendation
+}
+
+export async function populateRecommendationsWithRandomScores(amount: number){
+
+ for(let i =0; i < amount; i++){
+ const randomScore = Math.floor(Math.random()*10)
+
+ const recommendation = {
+ name:faker.music.songName(),
+ youtubeLink: "https://www.youtube.com/watch?v=h_D3VFfhvs4",
+ score: randomScore
+ }
+
+ await prisma.recommendation.create({data:recommendation})
+
+
+ }
+} |