Merge branch 'develop' into BETTERZON-120

BETTERZON-139: Fixing Codacy Error Prone Issues

Backend/src/models/contact_persons/contact_persons.router.ts

@@ -89,7 +89,7 @@ contactpersonsRouter.post('/', async (req: Request, res: Response) => {
         const success = await ContactPersonService.createContactEntry(user.user_id, vendor_id, first_name, last_name, gender, email, phone);
 
         if (success) {
-            res.sendStatus(200);
+            res.sendStatus(201);
         } else {
             res.sendStatus(500);
         }

Backend/src/models/pricealarms/pricealarms.router.ts

@@ -85,11 +85,11 @@ pricealarmsRouter.put('/', async (req: Request, res: Response) => {
             return;
         }
 
-        // Create price alarm
+        // Update price alarm
         const success = await PriceAlarmsService.updatePriceAlarm(alarm_id, user.user_id, defined_price);
 
         if (success) {
-            res.status(201).send(JSON.stringify({success: true}));
+            res.status(200).send(JSON.stringify({success: true}));
             return;
         } else {
             res.status(500).send(JSON.stringify({success: false}));

Backend/src/models/prices/prices.router.ts

@@ -117,7 +117,7 @@ pricesRouter.post('/', async (req: Request, res: Response) => {
         const success = await PriceService.createPriceEntry(user.user_id, vendor_id, product_id, price_in_cents);
 
         if (success) {
-            res.sendStatus(200);
+            res.sendStatus(201);
         } else {
             res.sendStatus(500);
         }

Backend/src/models/users/users.router.ts

@@ -105,7 +105,7 @@ usersRouter.post('/checkSessionValid', async (req: Request, res: Response) => {
         }
 
         // Send the session details back to the user
-        res.status(201).send(user);
+        res.status(200).send(user);
     } catch (e) {
         console.log('Error handling a request: ' + e.message);
         res.status(500).send(JSON.stringify({'message': 'Internal Server Error. Try again later.'}));

Crawler/Dockerfile

@@ -1,10 +1,10 @@
 # Base image
-FROM python
+FROM python:3.9.5-buster
 
 # Create directories and copy files
 RUN echo 'Creating directory and copying files'
 RUN mkdir /crawler
-ADD . /crawler
+COPY . /crawler
 WORKDIR /crawler
 
 # Install dependencies

Frontend/src/app/models/category.ts

@@ -0,0 +1,4 @@
+export interface Category {
+    category_id: number;
+    name: string;
+}

Frontend/src/app/models/contactperson.ts

@@ -0,0 +1,9 @@
+export interface ContactPerson {
+    contact_person_id: number;
+    first_name: string;
+    last_name: string;
+    gender: string;
+    email: string;
+    phone: string;
+    vendor_id: number;
+}

Frontend/src/app/models/crawlingstatus.ts

@@ -0,0 +1,7 @@
+export interface CrawlingStatus {
+    process_id: number;
+    started_timestamp: Date;
+    combinations_to_crawl: number;
+    successful_crawls: number;
+    failed_crawls: number;
+}

Frontend/src/app/models/manufacturer.ts

@@ -0,0 +1,4 @@
+export interface Manufacturer {
+    manufacturer_id: number;
+    name: string;
+}

Frontend/src/app/services/api.service.ts

@@ -7,6 +7,10 @@ import {Observable, of} from 'rxjs';
 import {Vendor} from '../models/vendor';
 import {PriceAlarm} from '../models/pricealarm';
 import {FavoriteShop} from '../models/favoriteshop';
+import {ContactPerson} from '../models/contactperson';
+import {Category} from '../models/category';
+import {Manufacturer} from '../models/manufacturer';
+import {CrawlingStatus} from '../models/crawlingstatus';
 
 @Injectable({
     providedIn: 'root'
@@ -381,4 +385,216 @@ export class ApiService {
             process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
         }
     }
+
+
+    /*     ______            __             __     ____
+          / ____/___  ____  / /_____ ______/ /_   / __ \___  ______________  ____  _____
+         / /   / __ \/ __ \/ __/ __ `/ ___/ __/  / /_/ / _ \/ ___/ ___/ __ \/ __ \/ ___/
+        / /___/ /_/ / / / / /_/ /_/ / /__/ /_   / ____/  __/ /  (__  ) /_/ / / / (__  )
+        \____/\____/_/ /_/\__/\__,_/\___/\__/  /_/    \___/_/  /____/\____/_/ /_/____/
+     */
+
+    /**
+     * Gets a list of all contact persons
+     * @return Observable<ContactPerson[]> An observable list of contact persons
+     */
+    getContactPersons(): Observable<ContactPerson[]> {
+        try {
+            return this.http.get<ContactPerson[]>((this.apiUrl + '/contactpersons'));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Gets the specified contact person by id
+     * @param id the id of the contact person to get info about
+     * @return Observable<ContactPerson> An observable containing a single contact person
+     */
+    getContactPersonById(id: number): Observable<ContactPerson> {
+        try {
+            return this.http.get<ContactPerson>((this.apiUrl + '/contactpersons/' + id));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Gets the contact persons for the specified vendor
+     * @param vendorId the id of the vendor to get the contact persons for
+     * @return Observable<ContactPerson[]> An observable list of contact persons
+     */
+    getContactPersonsByVendor(vendorId: number): Observable<ContactPerson[]> {
+        try {
+            return this.http.get<ContactPerson[]>((this.apiUrl + '/contactpersons/byvendor/' + vendorId));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Adds a contact person for the specified vendor
+     * @param vendorId The id of the vendor to mark as favorite
+     * @param firstName The given name of the contact person
+     * @param lastName The family name of the contact person
+     * @param gender The gender of the contact person
+     * @param email The email address of the contact person
+     * @param phone The phone number of the contact person
+     * @return Observable<any> The observable response of the api
+     */
+    addContactPerson(vendorId: number, firstName: string, lastName: string, gender: string, email: string, phone: string): Observable<any> {
+        try {
+            return this.http.post((this.apiUrl + '/contactpersons'), JSON.stringify({
+                vendor_id: vendorId,
+                first_name: firstName,
+                last_name: lastName,
+                gender,
+                email,
+                phone
+            }));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Updates the specified contact person record
+     * @param contactId The id of the contact person record
+     * @param vendorId The id of the vendor to mark as favorite
+     * @param firstName The given name of the contact person
+     * @param lastName The family name of the contact person
+     * @param gender The gender of the contact person
+     * @param email The email address of the contact person
+     * @param phone The phone number of the contact person
+     * @return Observable<any> The observable response of the api
+     */
+    updateContactPerson(contactId: number, vendorId: number, firstName: string, lastName: string, gender: string, email: string, phone: string): Observable<any> {
+        try {
+            return this.http.put((this.apiUrl + '/contactpersons/' + contactId), JSON.stringify({
+                vendor_id: vendorId,
+                first_name: firstName,
+                last_name: lastName,
+                gender,
+                email,
+                phone
+            }));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+
+    /*     ______      __                        _
+          / ____/___ _/ /____  ____ _____  _____(_)__  _____
+         / /   / __ `/ __/ _ \/ __ `/ __ \/ ___/ / _ \/ ___/
+        / /___/ /_/ / /_/  __/ /_/ / /_/ / /  / /  __(__  )
+        \____/\__,_/\__/\___/\__, /\____/_/  /_/\___/____/
+                            /____/
+     */
+
+    /**
+     * Gets the specified category from the API
+     * @param id The id of the category to get
+     * @return Observable<Category> An observable containing a single category
+     */
+    getCategoryById(id: number): Observable<Category> {
+        try {
+            return this.http.get<Category>((this.apiUrl + '/categories/' + id));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+
+    /**
+     * Gets a list of categories that match the given search term
+     * @param query The search term to match
+     * @return Observable<Category[]> An observable list of categories
+     */
+    getCategoriesByQuery(query: string): Observable<Category[]> {
+        try {
+            return this.http.get<Category[]>((this.apiUrl + '/categories/search/' + query));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Gets a list of all categories
+     * @return Observable<Category[]> An observable list of categories
+     */
+    getCategories(): Observable<Category[]> {
+        try {
+            return this.http.get<Category[]>((this.apiUrl + '/categories'));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /*     __  ___                  ____           __
+          /  |/  /___ _____  __  __/ __/___ ______/ /___  __________  __________
+         / /|_/ / __ `/ __ \/ / / / /_/ __ `/ ___/ __/ / / / ___/ _ \/ ___/ ___/
+        / /  / / /_/ / / / / /_/ / __/ /_/ / /__/ /_/ /_/ / /  /  __/ /  (__  )
+       /_/  /_/\__,_/_/ /_/\__,_/_/  \__,_/\___/\__/\__,_/_/   \___/_/  /____/
+     */
+
+    /**
+     * Gets the specified manufacturer from the API
+     * @param id The id of the manufacturer to get
+     * @return Observable<Manufacturer> An observable containing a single manufacturer
+     */
+    getManufacturerById(id: number): Observable<Manufacturer> {
+        try {
+            return this.http.get<Manufacturer>((this.apiUrl + '/manufacturers/' + id));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+
+    /**
+     * Gets a list of manufacturers that match the given search term
+     * @param query The search term to match
+     * @return Observable<Manufacturer[]> An observable list of manufacturers
+     */
+    getManufacturersByQuery(query: string): Observable<Manufacturer[]> {
+        try {
+            return this.http.get<Manufacturer[]>((this.apiUrl + '/manufacturers/search/' + query));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+    /**
+     * Gets a list of all manufacturers
+     * @return Observable<Manufacturer[]> An observable list of manufacturer
+     */
+    getManufacturers(): Observable<Manufacturer[]> {
+        try {
+            return this.http.get<Manufacturer[]>((this.apiUrl + '/manufacturers'));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
+
+
+    /*     ______                    ___                _____ __        __
+          / ____/________ __      __/ (_)___  ____ _   / ___// /_____ _/ /___  _______
+         / /   / ___/ __ `/ | /| / / / / __ \/ __ `/   \__ \/ __/ __ `/ __/ / / / ___/
+        / /___/ /  / /_/ /| |/ |/ / / / / / / /_/ /   ___/ / /_/ /_/ / /_/ /_/ (__  )
+        \____/_/   \__,_/ |__/|__/_/_/_/ /_/\__, /   /____/\__/\__,_/\__/\__,_/____/
+                                           /____/
+     */
+
+    /**
+     * Gets the current crawling status
+     * @return Observable<CrawlingStatus> An observable containing a single crawling status object
+     */
+    getCurrentCrawlingStatus(): Observable<CrawlingStatus> {
+        try {
+            return this.http.get<CrawlingStatus>((this.apiUrl + '/crawlingstatus'));
+        } catch (exception) {
+            process.stderr.write(`ERROR received from ${this.apiUrl}: ${exception}\n`);
+        }
+    }
 }

README.md

@@ -5,6 +5,7 @@ Wiki: https://github.com/Mueller-Patrick/Betterzon/wiki
 
 # Code Quality
 [![Codacy Badge](https://app.codacy.com/project/badge/Grade/88e47ebf837b43af9d12147c22f77f7f)](https://www.codacy.com/gh/Mueller-Patrick/Betterzon/dashboard?utm_source=github.com&utm_medium=referral&utm_content=Mueller-Patrick/Betterzon&utm_campaign=Badge_Grade)
+[![Code Coverage](https://img.shields.io/badge/coverage-82%25-green)](https://ci.betterzon.xyz)
 
 # Project Status
 [![Website Status](https://img.shields.io/website?label=www.betterzon.xyz&style=for-the-badge&url=https%3A%2F%2Fwww.betterzon.xyz)](https://www.betterzon.xyz)