+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| now.js | +
+
+ |
+ 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 | +1x +1x +1x + | "use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const now = new Intl.DateTimeFormat('en-US', { dateStyle: 'medium', timeStyle: 'long' }).format(Date.now());
+exports.default = now;
+//# sourceMappingURL=now.js.map |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 | 1x +1x | const now = new Intl.DateTimeFormat('en-US', { dateStyle: 'medium', timeStyle: 'long' }).format(Date.now())
+export default now; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 | 1x +1x | import path from 'path'; +export const appRoot = path.resolve(__dirname); |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from "http-errors";
+import { ICollection } from "../schemas";
+import { Collection } from "../models/collection";
+const CollectionInstance = new Collection();
+
+export default class CollectionCtl {
+ async getOne(id: number | string) {
+ const result = await CollectionInstance.getOne(id);
+ Iif (!result) throw createError('404', 'Collection not found');
+ return result;
+ }
+
+ async getAll() {
+ const result = await CollectionInstance.getAll();
+ Iif (!result) throw createError('404', 'No collections found');
+ return result;
+ }
+
+ async getUserDefault(id: number | string) {
+ const result = await CollectionInstance.getUserDefault(id);
+ Iif (!result) throw createError('404', "No default collection found. Contact an admin, this isn't supposed to happen");
+ return result;
+ }
+
+ async post(data: ICollection) {
+ const result = await CollectionInstance.post(data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ }
+
+ async getSubscriptions(userid: number | string) {
+ const result = await CollectionInstance.getSubscriptions(userid);
+ Iif (!result) throw createError('404', 'No subscriptions found');
+ return result;
+ }
+
+ async postSubscription(collectionid: number | string, userid: number | string) {
+ const { ok, code, data } = await CollectionInstance.postSubscription(collectionid, userid);
+
+ if (ok) {
+ return data;
+ } else {
+ throw createError(code, data as string);
+ }
+ }
+} |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from 'http-errors';
+import { ICourse } from '../schemas';
+import Course from '../models/course';
+const CourseInstance = new Course();
+
+export default class CourseCtl {
+ async getAll() {
+ try {
+ const result = await CourseInstance.getAll();
+ Iif (!result) throw createError('404', 'No cuisines found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const result = await CourseInstance.getOne(id);
+ Iif (!result) throw createError('404', 'No cuisine found with id ' + id);
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: ICourse) {
+ try {
+ const result = await CourseInstance.post(data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from "http-errors";
+import { ICuisine } from "../schemas";
+import Cuisine from "../models/cuisine";
+const CuisineInstance = new Cuisine();
+
+export default class CuisineCtl {
+ async getAll() {
+ try {
+ const result = await CuisineInstance.getAll();
+ Iif (!result) throw createError('404', 'No cuisines found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const result = await CuisineInstance.getOne(id);
+ Iif (!result) throw createError('404', 'No cuisine found with id ' + id);
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: ICuisine) {
+ try {
+ const result = await CuisineInstance.post(data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from "http-errors";
+import { IGroceryList } from "../schemas";
+import { GroceryList } from "../models/groceryList";
+const GroceryInstance = new GroceryList();
+
+export default class GroceryListCtl {
+ async getAll() {
+ try {
+ const result = await GroceryInstance.getAll();
+ Iif (!result) throw createError('404', 'No results found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const result = await GroceryInstance.getOne(id);
+ Iif (!result) throw createError('404', 'No results found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getByUserID(userid: string) {
+ try {
+ const result = await GroceryInstance.getByUserID(userid);
+ Iif (!result) throw createError('404', 'No results found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: IGroceryList) {
+ try {
+ const result = await GroceryInstance.post(data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async put(id: string, data: IGroceryList) {
+ try {
+ const result = await GroceryInstance.put(id, data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from "http-errors";
+import { IIngredient } from "../schemas";
+import { Ingredient } from "../models/ingredient";
+const IngredientInstance = new Ingredient();
+
+export default class IngredientCtl {
+ async getAll() {
+ try {
+ const result = await IngredientInstance.getAll();
+ Iif (!result) throw createError('404', 'No ingredients found');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const result = await IngredientInstance.getOne(id);
+ Iif (!result) throw createError('404', 'No ingredient found with id ' + id);
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: IIngredient) {
+ try {
+ const result = await IngredientInstance.post(data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async put(id: string, data: IIngredient) {
+ try {
+ const result = await IngredientInstance.put(id, data);
+ Iif (!result) throw createError('400', 'Bad request');
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x + +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from "http-errors";
+import { IRecipe } from "../schemas";
+import { Recipe } from "../models/recipe";
+const RecipeInstance = new Recipe();
+
+export default class RecipeCtl {
+ async getOne(id: string) {
+ try {
+ const result = await RecipeInstance.getOneByID(id);
+ Iif (!result) throw createError('404', "Recipe not found");
+ return result;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getAllAuthored(id: string) {
+ try {
+ const result = await RecipeInstance.getAllAuthored(id);
+ Iif (!result) throw createError('404', "No recipes found");
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getAllAccessible(id: string) {
+ try {
+
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async updateOne(id: string, data: IRecipe) {
+ try {
+ const result = await RecipeInstance.updateOneByID(id, data);
+ Iif (!result) throw createError('400', "Bad request");
+ return result;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async post(userid: string, data: IRecipe) {
+ try {
+ const result = await RecipeInstance.post(userid, data);
+ Iif (!result) throw createError('400', "Bad request");
+ return result;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+} |
+ 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 +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import createError from 'http-errors';
+import { IUser } from '../schemas';
+import { User } from "../models/user";
+const UserInstance = new User();
+
+export default class UserCtl {
+ async getAll() {
+ try {
+ const users = await UserInstance.getAllUsers();
+ Iif (!users) throw createError(404, "No users found");
+ return users;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async post(data: IUser) {
+ try {
+ const response = await UserInstance.post(data);
+ // if (!response) throw createError(400, "Bad request");
+ return response;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getOne(id: number | string) {
+ try {
+ const user = await UserInstance.getOneByID(id);
+ Iif (!user) throw createError(404, "User not found");
+ return user;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async updateOne(id: number | string, data: IUser) {
+ try {
+ const result = await UserInstance.updateOneByID(id, data);
+ Iif (!result) throw createError(400, "Bad request");
+ return result;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getFriends(id: number | string) {
+ try {
+ const result = await UserInstance.getFriends(id);
+ Iif (!result) return createError(404, "You have no friends");
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getFriendshipByID(id: number | string, userid: number | string) {
+ try {
+ const { ok, code, result } = await UserInstance.getFriendshipByID(id, userid);
+ Iif (ok) return result;
+ throw createError(code, result);
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getPendingFriendRequests(senderid: string | number) {
+ try {
+ const { ok, code, result } = await UserInstance.getPendingFriendRequests(senderid);
+ Iif (ok) return result;
+ throw createError(code, result);
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async addFriendship(userid: number | string, targetid: number | string) {
+ try {
+ const result = await UserInstance.addFriendship(userid, targetid);
+ Iif (!result) throw createError(400, "something went wrong");
+ return result;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async updateFriendship(id: number | string, userid: number | string, data: { active: boolean, pending: boolean, dateterminated?: string }) {
+ try {
+ const { ok, code, result } = await UserInstance.updateFriendship(id, userid, data);
+ Iif (ok) return result;
+ throw createError(code, result);
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| CollectionCtl.ts | +
+
+ |
+ 14.28% | +4/28 | +0% | +0/7 | +0% | +0/6 | +17.39% | +4/23 | +
| CourseCtl.ts | +
+
+ |
+ 18.18% | +4/22 | +0% | +0/3 | +0% | +0/3 | +21.05% | +4/19 | +
| CuisineCtl.ts | +
+
+ |
+ 18.18% | +4/22 | +0% | +0/3 | +0% | +0/3 | +21.05% | +4/19 | +
| GroceryListCtl.ts | +
+
+ |
+ 11.76% | +4/34 | +0% | +0/5 | +0% | +0/5 | +13.79% | +4/29 | +
| IngredientCtl.ts | +
+
+ |
+ 14.28% | +4/28 | +0% | +0/4 | +0% | +0/4 | +16.66% | +4/24 | +
| RecipeCtl.ts | +
+
+ |
+ 13.33% | +4/30 | +0% | +0/4 | +0% | +0/5 | +15.38% | +4/26 | +
| UserCtl.ts | +
+
+ |
+ 7.14% | +4/56 | +0% | +0/8 | +0% | +0/9 | +8.33% | +4/48 | +
| index.ts | +
+
+ |
+ 100% | +14/14 | +100% | +0/0 | +100% | +0/0 | +100% | +8/8 | +
+ 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 | 1x +1x +1x +1x +1x +1x +1x + + +1x + | import CollectionCtl from "./CollectionCtl";
+import CuisineCtl from "./CuisineCtl";
+import GroceryListCtl from "./GroceryListCtl";
+import IngredientCtl from "./IngredientCtl";
+import RecipeCtl from "./RecipeCtl";
+import UserCtl from "./UserCtl";
+import CourseCtl from "./CourseCtl";
+
+export {
+ CollectionCtl, CuisineCtl, CourseCtl, GroceryListCtl, IngredientCtl, RecipeCtl, UserCtl
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| index.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +
+ 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 | 1x +1x +1x + +1x +1x | import { Pool } from 'pg';
+import dotenv from 'dotenv';
+dotenv.config();
+
+const pool = new Pool({ connectionString: process.env.CONSTRING });
+export default pool; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| appRoot.ts | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +
+ 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 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 | +1x +1x +1x +1x +1x +1x +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { ICollection, IUser } from "../schemas";
+import { User } from "./user";
+import { appRoot } from "../appRoot";
+import now from "../util/now";
+import pool from "../db";
+import fs from 'fs';
+const UserInstance = new User();
+export class Collection {
+ async getOne(id: number | string) {
+ try {
+ const statement = `SELECT * FROM recipin.collection WHERE id = $1`;
+ const values = [id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getUserDefault(id: number | string) {
+ try {
+ const statement = `
+ SELECT * FROM recipin.collection
+ WHERE ownerid = $1
+ AND ismaincollection = true;
+ `
+ const result = await pool.query(statement, [id]);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getAll() {
+ // requires clearance
+ try {
+ const statement = `SELECT * FROM recipin.collection`;
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: ICollection) {
+ console.log('new default collection');
+ const { name, active, ismaincollection, ownerid } = data;
+ try {
+ const statement = `
+ INSERT INTO recipin.collection
+ (name, active, ismaincollection, ownerid, datecreated, datemodified)
+ VALUES ($1, $2, $3, $4, $5, $6)
+ RETURNING *;
+ `
+ const values = [name, (active || true), (ismaincollection || false), ownerid, now, now];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getSubscriptions(userid: number | string) {
+ try {
+ const sql = fs.readFileSync(appRoot + '/db/sql/get/getsubscriptions.sql').toString();
+ console.log(sql);
+ const result = await pool.query(sql, [userid]);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async postSubscription(collectionid: number | string, userid: number | string): Promise<{ ok: boolean, code: number, data: number | string | any[] }> {
+ try {
+ // ensure user exists
+ const user: IUser | null = await UserInstance.getOneByID(userid);
+ Iif (!user) {
+ return {
+ ok: false,
+ code: 404,
+ data: "User not found"
+ }
+ }
+
+ // ensure collection exists
+ const target: ICollection | null = await this.getOne(collectionid);
+ Iif (!target) {
+ return {
+ ok: false,
+ code: 404,
+ data: "Collection not found"
+ }
+ }
+
+ // ensure a user cannot subscribe to their own collection
+ let typedUserID: number = (userid == typeof 'string') ? parseInt(userid) : userid as number;
+ Iif (target.ownerid == typedUserID) {
+ return {
+ ok: false,
+ code: 403,
+ data: "User cannot subscribe to their own collection"
+ }
+ }
+
+ // ensure a duplicate subscription does not exist
+ const allSubscriptions = `
+ SELECT * FROM recipin.cmp_usersubscriptions
+ WHERE collectionid = $1;
+ `
+ const subscriptionResult = await pool.query(allSubscriptions, [collectionid]);
+ Iif (subscriptionResult.rows?.length) {
+ for (let row of subscriptionResult.rows) {
+ Iif (row.usermemberid == typedUserID) {
+ return {
+ ok: false,
+ code: 403,
+ data: "This user is already subscribed"
+ }
+ }
+ }
+ }
+
+ // finally, execute insertion
+ const statement = `
+ INSERT INTO recipin.cmp_usersubscriptions
+ (collectionid, usermemberid, active)
+ VALUES ($1, $2, true)
+ RETURNING *;
+ `
+
+ const result = await pool.query(statement, [collectionid, userid]);
+ Iif (result.rows.length) {
+ return {
+ ok: true,
+ code: 201,
+ data: result.rows
+ }
+ }
+
+ return {
+ ok: false,
+ code: 400,
+ data: "Bad request. No data returned."
+ }
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x +1x + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import now from "../util/now";
+import pool from "../db";
+import { ICourse } from "../schemas";
+
+export default class Course {
+ async getOne(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.course WHERE id = $1`;
+ const values = [id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getAll() {
+ try {
+ const statement = `SELECT * FROM recipin.course`;
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: ICourse) {
+ try {
+ const { name } = data;
+ const statement = `
+ INSERT INTO recipin.course
+ (name, datecreated, datemodified, active)
+ VALUES ($1, $2, $3, $4) RETURNING *`;
+ const values = [name, now, now, true];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x +1x + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import pool from "../db";
+import now from "../util/now";
+import { ICuisine } from "../schemas";
+
+export default class Cuisine {
+ async getOne(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.cuisine WHERE id = $1`;
+ const values = [id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getAll() {
+ try {
+ const statement = `SELECT * FROM recipin.cuisine`;
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: ICuisine) {
+ try {
+ const { name } = data;
+ const statement = `
+ INSERT INTO recipin.cuisine
+ (name, datecreated, datemodified, active)
+ VALUES ($1, $2, $3, $4) RETURNING *`;
+ const values = [name, now, now, true];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { IGroceryList } from "../schemas";
+import pool from "../db";
+
+export class GroceryList {
+ async getAll() {
+ try {
+ const statement = 'SELECT * FROM recipin.grocerylist';
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.grocerylist WHERE id = $1`
+ const result = await pool.query(statement, [id]);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getByUserID(userid: string) {
+ try {
+ const statement = `SELECT * FROM recipin.grocerylist WHERE ownerid = $1`
+ const result = await pool.query(statement, [userid]);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: IGroceryList) {
+ try {
+ // assumes that any new list will be active on creation
+ const statement = `
+ INSERT INTO recipin.grocerylist
+ (name, active, ownerid)
+ VALUES ($1, true, $2)
+ RETURNING *;
+ `
+ const values = [data.name, data.ownerid];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async put(id: string, data: IGroceryList) {
+ try {
+ const statement = `
+ UPDATE recipin.grocerylist
+ SET name = $1,
+ active = $2,
+ ownerid = $3
+ WHERE id = $4
+ RETURNING *
+ `
+ const values = [data.name, data.active, data.ownerid, id];
+
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| collection.ts | +
+
+ |
+ 10.14% | +7/69 | +0% | +0/21 | +0% | +0/6 | +10.93% | +7/64 | +
| course.ts | +
+
+ |
+ 11.11% | +3/27 | +0% | +0/3 | +0% | +0/3 | +12.5% | +3/24 | +
| cuisine.ts | +
+
+ |
+ 11.11% | +3/27 | +0% | +0/3 | +0% | +0/3 | +12.5% | +3/24 | +
| groceryList.ts | +
+
+ |
+ 5.12% | +2/39 | +0% | +0/5 | +0% | +0/5 | +5.88% | +2/34 | +
| ingredient.ts | +
+
+ |
+ 9.09% | +3/33 | +0% | +0/6 | +0% | +0/4 | +10.34% | +3/29 | +
| recipe.ts | +
+
+ |
+ 11.36% | +5/44 | +0% | +0/5 | +0% | +0/6 | +12.82% | +5/39 | +
| user.ts | +
+
+ |
+ 5.31% | +5/94 | +0% | +0/20 | +0% | +0/10 | +5.95% | +5/84 | +
+ 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 | +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { IIngredient } from "../schemas";
+import pool from "../db";
+import now from "../util/now";
+
+export class Ingredient {
+ async getAll() {
+ try {
+ const statement = `SELECT * FROM recipin.ingredient`;
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getOne(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.ingredient WHERE id = $1`;
+ const result = await pool.query(statement, [id]);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async post(data: IIngredient) {
+ try {
+ const statement = `
+ INSERT INTO recipin.ingredient
+ (name, description, datecreated)
+ VALUES ($1, $2, $3) RETURNING *`;
+ const values = [data.name, data.description, data.datecreated || now];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async put(id: string, data: IIngredient) {
+ try {
+ const statement = `
+ UPDATE recipin.ingredient
+ SET name = $1,
+ description = $2
+ WHERE id = $3
+ RETURNING *
+ `
+
+ const values = [data.name, data.description, id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | +1x +1x +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { IRecipe } from "../schemas";
+import pool from "../db";
+import { CollectionCtl } from "../controllers";
+import now from "../util/now";
+const CollectionInstance = new CollectionCtl();
+
+export class Recipe {
+ async getOneByID(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.recipe WHERE id = $1`;
+ const values = [id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getAllAuthored(id: string) {
+ try {
+ const statement = `SELECT * FROM recipin.recipe WHERE authoruserid = $1`;
+ const result = await pool.query(statement, [id]);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getAllAccessible(id: string) {
+
+ }
+
+ async fetchRecipesByCollection(collectionid: string) {
+ try {
+
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async updateOneByID(id: string, data: IRecipe) {
+ const { name, description, preptime } = data;
+ try {
+ const statement = `
+ UPDATE recipin.recipe
+ SET name = $1,
+ description = $2,
+ preptime = $3
+ WHERE id = $4
+ RETURNING *;
+ `
+
+ const result = await pool.query(statement, [name, description, preptime, id]);
+ Iif (result.rows) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async post(userid: string, data: IRecipe) {
+ const { name, description, preptime } = data;
+
+ try {
+ // create recipe itself
+ const statement = `
+ INSERT INTO recipin.recipe
+ (name, description, preptime, authoruserid, datecreated, datemodified)
+ VALUES ($1, $2, $3, $4, $5, $6)
+ RETURNING *;
+ `
+ const values = [name, description, preptime, userid, now, now];
+ const result = await pool.query(statement, values);
+ Iif (!result.rows.length) return null;
+
+ // associate recipe with default collection once created
+ const collection = await CollectionInstance.getUserDefault(userid);
+ const associateToCollection = `
+ INSERT INTO recipin.cmp_recipecollection
+ (recipeid, collectionid)
+ VALUES ($1, $2) RETURNING *
+ `
+ const associateResult = await pool.query(associateToCollection, [result.rows[0].id, collection.id]);
+ Iif (!associateResult.rows.length) return null;
+
+ return { recipe: result.rows[0], collection: associateResult.rows[0] }
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+} |
+ 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 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 | +1x +1x +1x +1x + +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { IUser } from "../schemas";
+import fs from "fs";
+import pool from '../db';
+import now from "../util/now";
+import { appRoot } from "../appRoot";
+
+export class User {
+ async getAllUsers() {
+ // behind auth
+ try {
+ const statement = `SELECT * FROM recipin.appusers`;
+ const result = await pool.query(statement);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getOneByID(id: number | string) {
+ try {
+ const statement = `SELECT * FROM recipin.appusers WHERE id = $1`;
+ const values = [id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getOneByEmail(email: number | string) {
+ try {
+ const statement = `SELECT * FROM recipin.appusers WHERE email = $1`;
+ const result = await pool.query(statement, [email]);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+
+ }
+ }
+
+ async updateOneByID(id: number | string, data: IUser) {
+ try {
+ const statement = `
+ UPDATE recipin.appusers
+ SET firstname = $1,
+ lastname = $2,
+ handle = $3,
+ email = $4,
+ password = $5,
+ active = $6,
+ datemodified = $7
+ WHERE id = $8
+ RETURNING *;
+ `
+ const values = [
+ data.firstname, data.lastname, data.handle,
+ data.email, data.password, data.active,
+ data.datemodified, id
+ ]
+
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return result.rows[0];
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+
+ async post(data: IUser) {
+ const { firstname, lastname, handle, email, password, active, isadmin } = data;
+
+ try {
+ const statement = `
+ INSERT INTO recipin.appusers (
+ firstname, lastname, handle, email, password,
+ active, isadmin, datecreated, datemodified)
+ VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
+ RETURNING *;
+ `;
+ const params = [firstname, lastname, handle, email, password, active, isadmin, now, now];
+ const result = await pool.query(statement, params);
+ Iif (result.rows.length) return result.rows[0] as IUser;
+ return null;
+ } catch (error: any) {
+ throw new Error(error);
+ }
+ }
+
+ async getFriends(id: number | string) {
+ try {
+ // const sql = fs.readFileSync(appRoot + '/db/sql/derived/friendships.sql').toString();
+ const sql = `
+ SELECT * FROM recipin.cmp_userfriendships
+ WHERE senderid = $1;
+ `
+ const result = await pool.query(sql, [id]);
+ Iif (result.rows.length) return result.rows;
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getFriendshipByID(id: number | string, userid: number | string) {
+ try {
+ const statement = `SELECT * FROM recipin.cmp_userfriendships WHERE id = $1`;
+ const result = await pool.query(statement, [id]);
+
+ Iif (result.rows.length) {
+ const row = result.rows[0];
+ Iif (row.senderid == userid || row.targetid == userid) {
+ const sql = fs.readFileSync(appRoot + '/db/sql/get/friendshipbyid.sql').toString();
+ const formattedResult = await pool.query(sql, [id]);
+ Iif (formattedResult.rows.length) return { ok: true, code: 200, result: formattedResult.rows }
+ return { ok: false, code: 400, result: "Something went wrong" }
+ }
+ return { ok: true, code: 403, result: "Not authorized to access this resource" }
+ }
+
+ return { ok: false, code: 404, result: "No friendship found with that ID" }
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async getPendingFriendRequests(senderid: number | string) {
+ try {
+ const statement = `SELECT * FROM recipin.cmp_userfriendships WHERE pending = true AND senderid = $1`
+ const result = await pool.query(statement, [senderid]);
+
+ Iif (result.rows.length) return { ok: true, code: 200, result: result.rows }
+ return { ok: true, code: 200, result: "No pending friend requests found" }
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async addFriendship(userid: number | string, targetid: number | string) {
+ try {
+ const statement = `
+ INSERT INTO recipin.cmp_userfriendships
+ (datecreated, active, pending, senderid, targetid)
+ VALUES ($1, false, true, $2, $3)
+ RETURNING *;
+ `
+ const values = [now, userid, targetid];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) {
+ return result.rows[0];
+ }
+ return null;
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+
+ async updateFriendship(id: number | string, userid: number | string, data: { active: boolean, pending: boolean, dateterminated?: string }) {
+ try {
+ const query = `SELECT * FROM recipin.cmp_userfriendships WHERE id = $1`;
+ const friendship = await pool.query(query, [id]);
+ Iif (!friendship.rows.length) return { ok: false, code: 404, result: "Friendship with this code not found" };
+ Iif (!(friendship.rows[0].active) && friendship.rows[0].senderid == userid) {
+ return { ok: false, code: 403, result: "Please wait for friend request to be accepted" }
+ }
+
+ const statement = `
+ UPDATE recipin.cmp_userfriendships
+ SET active = $1,
+ pending = $2,
+ dateterminated = $3
+ WHERE id = $4
+ RETURNING *;
+ `
+ const values = [data.active, data.pending, (data.dateterminated || null), id];
+ const result = await pool.query(statement, values);
+ Iif (result.rows.length) return { ok: true, code: 200, result: result.rows[0] }
+ return { ok: false, code: 400, result: "Bad request" }
+ } catch (e: any) {
+ throw new Error(e);
+ }
+ }
+} |
+ 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 | 1x +1x +1x + +1x + +1x +1x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { Express, Router } from 'express';
+import { CuisineCtl } from '../controllers';
+const CuisineInstance = new CuisineCtl();
+
+const router = Router();
+
+export const cuisineRouter = (app: Express) => {
+ app.use('/cuisine', router);
+
+ router.get('/', async (req, res, next) => {
+ try {
+ const result = await CuisineInstance.getAll();
+ res.status(200).send(result);
+ } catch(e) {
+ next(e);
+ }
+ })
+
+ router.get('/:id', async (req, res, next) => {
+ const { id } = req.params;
+
+ try {
+ const result = await CuisineInstance.getOne(id);
+ res.status(200).send(result);
+ } catch(e) {
+ next(e);
+ }
+ })
+
+ router.post('/', async (req, res, next) => {
+ const data = req.body;
+
+ try {
+ const result = await CuisineInstance.post(data);
+ res.status(201).send(result);
+ } catch(e) {
+ next(e);
+ }
+ })
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| cuisine.ts | +
+
+ |
+ 29.16% | +7/24 | +100% | +0/0 | +25% | +1/4 | +26.08% | +6/23 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| now.ts | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 | 2x +2x | const now = new Intl.DateTimeFormat('en-US', { dateStyle: 'medium', timeStyle: 'long' }).format(Date.now())
+export default now; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| now.ts | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 | 1x +1x | const now = new Intl.DateTimeFormat('en-US', { dateStyle: 'medium', timeStyle: 'long' }).format(Date.now())
+export default now; |