+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| recommend | +100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +|
| recommend/config | +100% | +9/9 | +50% | +1/2 | +100% | +0/0 | +100% | +9/9 | +|
| recommend/server | +80% | +16/20 | +0% | +0/2 | +50% | +3/6 | +80% | +16/20 | +|
| recommend/server/controllers/apis/plex | +100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +|
| recommend/server/models | +80.95% | +17/21 | +50% | +2/4 | +83.33% | +5/6 | +80.95% | +17/21 | +|
| recommend/server/routes | +75% | +6/8 | +0% | +0/2 | +66.67% | +2/3 | +75% | +6/8 | +|
| recommend/server/routes/apis | +100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +|
| recommend/server/routes/apis/v1 | +100% | +2/2 | +100% | +0/0 | +100% | +0/0 | +100% | +2/2 | +|
| recommend/server/services/plexApi | +67.72% | +86/127 | +72.22% | +13/18 | +57.89% | +22/38 | +67.46% | +85/126 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
++ 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 + + + + | /* eslint-disable no-undef */
+require('custom-env').env();
+require('dotenv').config();
+const _ = require('lodash');
+
+const env = process.env.NODE_ENV || 'local';
+
+const envConfig = require(`./${env}`).default;
+const plexConfig = require('./plex').default;
+
+const defaultConfig = {
+ env,
+};
+export default {server: _.merge(defaultConfig, envConfig), plex: plexConfig};
+ |
+ 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 | 1x + + + + + + + | const plexConfig = {
+ ip: 'http://192.168.0.44',
+ plexServerUrl: 'https://plex.mjrflix.com',
+ plexApiUrl: 'https://plex.tv/api',
+ token: process.env.PLEX_API_TOKEN,
+};
+export default plexConfig;
+ |
+ 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 | 1x + + + + + + | const testConfig = {
+ hostname: 'localhost',
+ port: 8080,
+};
+
+export default testConfig;
+ |
+ 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.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 +6 +7 +8 +9 +10 | + +1x + +1x + +1x + + + | import config from './config';
+
+const server = require('./server').default();
+
+server.create(config);
+
+server.start();
+
+export default server.create(config);
+ |
+ 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.js | +100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
+ 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 | + + +1x + +1x + + +1x + +1x +1x + +1x +1x + +1x +1x + + + | import {Router} from 'express';
+import plexService from '../../../services/plexApi';
+
+const router = Router();
+
+router.get('/auth', plexService.getAuthToken);
+
+// users
+router.get('/users', plexService.getUsers);
+
+router.get('/most-watched', plexService.getMostWatched);
+router.get('/import/most-watched', plexService.importMostWatched);
+
+router.get('/sections', plexService.getSections);
+router.get('/import/sections', plexService.importSections);
+
+router.get('/library/:id', plexService.getLibraryDataBySection);
+router.get('/import/libraries', plexService.importLibraries);
+
+export default router;
+ |
+ 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.js | +80% | +16/20 | +0% | +0/2 | +50% | +3/6 | +80% | +16/20 | +
+ 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 | + + + +1x + + +1x + +1x + +2x +2x +2x + + +2x +2x + + +2x +2x + + +1x +1x + +1x + +1x + + + + + + + + + + +1x + + + +1x + + | import express from 'express';
+import {json, urlencoded} from 'body-parser';
+import {sequelize} from './models';
+
+const routes = require('./routes').default;
+
+export default () => {
+ const server = express();
+
+ const create = config => {
+ // Server settings
+ server.set('env', config.env);
+ server.set('port', config.server.port);
+ server.set('hostname', config.server.hostname);
+
+ // Returns middleware that parses json
+ server.use(json());
+ server.use(urlencoded({extended: true}));
+
+ // Set up routes
+ routes.init(server);
+ return server;
+ };
+
+ const start = () => {
+ const hostname = server.get('hostname');
+
+ const port = server.get('port');
+
+ sequelize.sync().then(() => {
+ if (!module.parent) {
+ server.listen(port, () => {
+ console.log(
+ `Express server listening on - http://${hostname}:${port}`,
+ );
+ });
+ }
+ });
+ };
+
+ process.on('unhandledRejection', (reason, p) => {
+ console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
+ });
+
+ return {create, start};
+};
+ |
+ 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.js | +100% | +5/5 | +100% | +2/2 | +100% | +1/1 | +100% | +5/5 | +|
| plexLibrary.js | +100% | +3/3 | +100% | +0/0 | +100% | +1/1 | +100% | +3/3 | +|
| plexSection.js | +100% | +5/5 | +100% | +0/0 | +100% | +2/2 | +100% | +5/5 | +|
| user.js | +50% | +4/8 | +0% | +0/2 | +50% | +1/2 | +50% | +4/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 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | + +1x + + + + + + + + + + +1x + + + + + +1x +3x +1x + + + + + + + | import Sequelize from 'sequelize';
+
+const sequelize = new Sequelize(
+ process.env.DATABASE,
+ process.env.DATABASE_USER,
+ process.env.DATABASE_PASSWORD,
+ {
+ dialect: 'postgres',
+ host: 'localhost',
+ logging: false,
+ },
+);
+
+const models = {
+ User: sequelize.import('./user'),
+ PlexLibrary: sequelize.import('./plexLibrary'),
+ PlexSection: sequelize.import('./plexSection'),
+};
+
+Object.keys(models).forEach(key => {
+ if ('associate' in models[key]) {
+ models[key].associate(models);
+ }
+});
+
+export {sequelize};
+
+export default models;
+ |
+ 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 | 1x +1x + + + + + + + + + + + + + + +1x + + + + | const plexLibrary = (sequelize, DataTypes) => {
+ const plexLibrary = sequelize.define('plex_library', {
+ title: {
+ type: DataTypes.STRING,
+ unique: true,
+ },
+ type: DataTypes.STRING,
+ views: DataTypes.INTEGER,
+ rating_key: DataTypes.INTEGER,
+ metadata_path: DataTypes.STRING,
+ summary: DataTypes.TEXT,
+ rating: DataTypes.FLOAT,
+ year: DataTypes.INTEGER,
+ genre: DataTypes.STRING,
+ });
+
+ return plexLibrary;
+};
+
+export default plexLibrary;
+ |
+ 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 | 1x +1x + + + + + +1x +1x + + +1x + + + + | const plexSection = (sequelize, DataTypes) => {
+ const plexSection = sequelize.define('plex_section', {
+ title: DataTypes.STRING,
+ type: DataTypes.STRING,
+ key: DataTypes.INTEGER,
+ });
+
+ plexSection.associate = models => {
+ plexSection.belongsTo(models.User);
+ };
+
+ return plexSection;
+};
+
+export default plexSection;
+ |
+ 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 | 1x +1x + + + + + + + + + + +1x + + + + + + + + + + + + + +1x + + + + | const user = (sequelize, DataTypes) => {
+ const User = sequelize.define('user', {
+ username: {
+ type: DataTypes.STRING,
+ },
+ });
+
+ // User.associate = models => {
+ // User.hasMany(models.PlexLibrary, {onDelete: 'CASCADE'});
+ // User.hasMany(models.PlexSection, {onDelete: 'CASCADE'});
+ // };
+
+ User.findByLogin = async login => {
+ let user = await User.findOne({
+ where: {username: login},
+ });
+
+ if (!user) {
+ user = await User.findOne({
+ where: {email: login},
+ });
+ }
+
+ return user;
+ };
+
+ return User;
+};
+
+export default user;
+ |
+ 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.js | +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 | + + +1x + +1x + + + | import {Router} from 'express';
+import v1ApiController from './v1';
+
+const router = Router();
+
+router.use('/v1', v1ApiController);
+
+export default router;
+ |
+ 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.js | +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 | + + +1x + +1x + + + | import {Router} from 'express';
+import plexController from '../../../controllers/apis/plex';
+
+const router = Router();
+
+router.use('/plex', plexController);
+
+export default router;
+ |
+ 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.js | +75% | +6/8 | +0% | +0/2 | +66.67% | +2/3 | +75% | +6/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 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 | + +1x +2x +6x +6x + + +2x + +2x + + + + + + + + + + | import apiRoute from './apis';
+
+const init = server => {
+ server.get('*', (req, res, next) => {
+ console.log(`Request was made to: ${req.originalUrl}`);
+ return next();
+ });
+
+ server.use('/api', apiRoute);
+
+ server.use((err, req, res, next) => {
+ if (err) {
+ console.log('Error in routes/index', err);
+ }
+ });
+};
+
+export default {
+ init,
+};
+ |
+ 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 | + + + +1x + +1x + + + + + + + +1x +1x +1x + + +1x +1x +1x +1x + + + + | import uuid from 'uuid';
+import btoa from 'btoa';
+import request from 'request-promise';
+
+const rxAuthToken = /authenticationToken="([^"]+)"/;
+
+const urlParams = (username, password) => ({
+ url: 'https://plex.tv/users/sign_in.xml',
+ headers: {
+ 'X-Plex-Client-Identifier': uuid(),
+ Authorization: `Basic ${encryptUserCreds(username, password)}`,
+ },
+});
+
+const encryptUserCreds = (username, password) => {
+ const creds = `${username}:${password}`;
+ return btoa(creds);
+};
+
+const fetchToken = async (username, password) => {
+ const res = await request.post(urlParams(username, password));
+ const token = res.match(rxAuthToken)[1];
+ return token;
+};
+
+export default fetchToken;
+ |
+ 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 | + +1x +7x +7x +3x + +4x + + + + | import parser from 'xml2json';
+
+const formatResponse = response => {
+ const xmlResponse = response.headers['content-type'].includes('xml');
+ if (xmlResponse) {
+ return JSON.parse(parser.toJson(response.data));
+ }
+ return response.data;
+};
+
+export default formatResponse;
+ |
+ 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 + + + + + + + +1x + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + + +1x + + + + + + + + + + + + + + + + + + + + + + + + + | import plexApiClient from './plexApi'; +import models from '../../models'; + +const importSections = async () => { + const plexApi = plexApiClient(); + const sections = await plexApi.getSections(); + createSections(sections); + return sections; +}; + +const createSections = sections => { + sections.forEach(async section => { + await models.PlexSection.create({ + userId: 1, + title: section.title, + type: section.type, + key: section.key, + }); + }); +}; + +const importLibraries = async () => { + const plexApi = plexApiClient(); + const sections = await plexApi.getSections(); + sections.forEach(async section => { + await importLibrary(section.key); + }); +}; + +const importMostWatched = async req => { + const plexApi = plexApiClient(); + const mostWatched = await plexApi.getMostWatched(req); + mostWatched.forEach(async libraryData => { + await updateLibrary([libraryData]); + }); +}; + +const importLibrary = async sectionId => { + const plexApi = plexApiClient(); + const libraryData = await plexApi.getLibraryDataBySection({ + sectionId, + }); + createLibrary(libraryData); + return libraryData; +}; + +const updateLibrary = libraryData => { + libraryData.forEach(async data => { + await models.PlexLibrary.update( + { + userId: 1, + title: data.title, + type: data.type, + views: data.globalViewCount, + rating_key: data.ratingKey, + metadata_path: data.key, + summary: data.summary, + rating: data.rating, + year: data.year, + genre: JSON.stringify(data.Genre), + }, + { + where: { + title: data.title, + }, + }, + ); + }); +}; + +const createLibrary = libraryData => { + libraryData.forEach(async data => { + await models.PlexLibrary.upsert( + { + userId: 1, + title: data.title, + type: data.type, + views: data.views, + rating_key: data.ratingKey, + metadata_path: data.key, + summary: data.summary, + rating: data.rating, + year: data.year, + genre: JSON.stringify(data.Genre), + }, + { + where: { + title: data.title, + }, + }, + ); + }); +}; + +export default {importSections, importLibraries, importMostWatched}; + |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| auth.js | +100% | +10/10 | +100% | +0/0 | +100% | +3/3 | +100% | +9/9 | +|
| helpers.js | +100% | +5/5 | +100% | +2/2 | +100% | +1/1 | +100% | +5/5 | +|
| importData.js | +24.14% | +7/29 | +100% | +0/0 | +0% | +0/12 | +24.14% | +7/29 | +|
| index.js | +72.41% | +21/29 | +100% | +0/0 | +66.67% | +6/9 | +72.41% | +21/29 | +|
| plexApi.js | +79.63% | +43/54 | +68.75% | +11/16 | +92.31% | +12/13 | +79.63% | +43/54 | +
+ 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 | + + + + +1x +1x +1x + +1x +1x + + + +1x +1x +1x + + +1x +2x +2x + + +1x +1x +1x + + +1x +1x +1x +1x + + + + + +1x + + + + +1x + + + + +1x + + + + + + + + + + + + + + + + | import plexApi from './plexApi';
+import importData from './importData';
+import auth from './auth';
+import helpers from './helpers';
+
+const getAuthToken = async (req, res) => {
+ const {username} = req.query;
+ const {password} = req.query;
+
+ auth(username, password).then(data => {
+ return res.json(data);
+ });
+};
+
+const getUsers = async (req, res) => {
+ const users = await plexApi.getUsers();
+ res.json(users);
+};
+
+const getMostWatched = async (req, res) => {
+ const mostWatched = await plexApi.getMostWatched(req);
+ res.json(mostWatched);
+};
+
+const getSections = async (req, res) => {
+ const sections = await plexApi.getSections();
+ res.json(sections);
+};
+
+const getLibraryDataBySection = async (req, res) => {
+ try {
+ const sections = await plexApi.getLibraryDataBySection(req);
+ res.json(sections);
+ } catch (error) {
+ console.log(error);
+ }
+};
+
+const importSections = async (req, res) => {
+ const sections = await importData.importSections();
+ res.json(sections);
+};
+
+const importLibraries = async (req, res) => {
+ const libraries = await importData.importLibraries();
+ res.json(libraries);
+};
+
+const importMostWatched = async (req, res) => {
+ req.query.type = 2;
+ const libraries = await importData.importMostWatched(req);
+ res.json(libraries);
+};
+
+export default {
+ getUsers,
+ getMostWatched,
+ getSections,
+ getLibraryDataBySection,
+ importSections,
+ importLibraries,
+ importMostWatched,
+ getAuthToken,
+};
+ |
+ 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 | + + + + +1x +5x + + + + + + + + +1x +1x + + + + + + + + +1x +2x + + + + + + + + + + + + + +1x +1x +1x + + + + + + + + +1x +8x +8x +8x +8x +8x + +8x + + + + + + +1x +7x +7x +7x +7x + + +7x + + + + + + + + + + + + + + + + + +1x +2x +2x +2x +2x + + +1x +2x +2x +2x +2x + + +1x +1x +1x +1x +1x + + +1x +1x +1x +1x +1x +1x + + + + + + + + + + + + + + + + + | import axios from 'axios';
+import buildUrlPack from 'build-url';
+import config from '../../../config';
+import formatResponse from './helpers';
+
+const getUsersUrlParams = function() {
+ return {
+ host: config.plex.plexApiUrl,
+ path: '/users',
+ queryParams: {
+ 'X-Plex-Token': config.plex.token,
+ },
+ };
+};
+
+const getSectionsUrlParams = function() {
+ return {
+ host: config.plex.plexServerUrl,
+ path: '/library/sections',
+ queryParams: {
+ 'X-Plex-Token': config.plex.token,
+ },
+ };
+};
+
+const mostWatchedUrlParams = function(req) {
+ return {
+ host: config.plex.plexServerUrl,
+ path: '/library/all/top',
+ queryParams: {
+ ...(req && req.query.accountID && {accountID: req.query.accountID}),
+ ...(req && req.query.type && {type: req.query.type}),
+ ...((req && (req.query.limit && {limit: req.query.limit})) || {
+ limit: 10,
+ }),
+ 'X-Plex-Token': config.plex.token,
+ },
+ };
+};
+
+const getLibraryDataBySectionUrlParams = function(req) {
+ const sectionId = req.sectionId || req.params.id;
+ return {
+ host: config.plex.plexServerUrl,
+ path: `/library/sections/${sectionId}/all`,
+ queryParams: {
+ 'X-Plex-Token': config.plex.token,
+ },
+ };
+};
+
+const buildUrl = function(urlParams) {
+ try {
+ const params = urlParams;
+ const {host} = params;
+ delete params.host;
+ const urlHash = params;
+
+ return buildUrlPack(host, urlHash);
+ } catch (error) {
+ console.log(error);
+ return error;
+ }
+};
+
+const request = async function(url) {
+ console.log('Request URL', url);
+ return new Promise((resolve, reject) => {
+ const httpClient = axios;
+ httpClient
+ .get(url)
+ .then(response => {
+ return resolve(formatResponse(response));
+ })
+ .catch(error => {
+ if (error.response) {
+ console.log('status', error.response.status);
+ console.log('headers', error.response.headers);
+ return reject(error.response);
+ }
+ if (error.request) {
+ console.log('request', error.request);
+ } else {
+ console.log('Error', error.message);
+ }
+ return reject(error);
+ });
+ });
+};
+
+const getUsers = async function() {
+ const urlParams = getUsersUrlParams();
+ const getUsersUrl = buildUrl(urlParams);
+ const response = await request(getUsersUrl);
+ return response.MediaContainer.User;
+};
+
+const getMostWatched = async function(req) {
+ const urlParams = mostWatchedUrlParams(req);
+ const mostWatchedUrl = buildUrl(urlParams);
+ const response = await request(mostWatchedUrl);
+ return response.MediaContainer.Metadata;
+};
+
+const getSections = async function() {
+ const urlParams = getSectionsUrlParams();
+ const getSectionsUrl = buildUrl(urlParams);
+ const response = await request(getSectionsUrl);
+ return response.MediaContainer.Directory;
+};
+
+const getLibraryDataBySection = async function(req) {
+ try {
+ const urlParams = getLibraryDataBySectionUrlParams(req);
+ const getLibraryDataBySectionUrl = buildUrl(urlParams);
+ const response = await request(getLibraryDataBySectionUrl);
+ return response.MediaContainer.Metadata;
+ } catch (error) {
+ return error;
+ }
+};
+
+export default {
+ getUsers,
+ getMostWatched,
+ getSections,
+ getLibraryDataBySection,
+ getUsersUrlParams,
+ getLibraryDataBySectionUrlParams,
+ getSectionsUrlParams,
+ buildUrl,
+ request,
+};
+ |