EntertainMe

Apis/.gitignore

@@ -0,0 +1 @@
+node_modules

Apis/api/entertainme.js

@@ -0,0 +1,50 @@
+const express = require('express');
+const axios = require('axios');
+const redis = require('redis');
+const client = redis.createClient();
+
+const router = express.Router();
+
+router.get('/', async (req, res) => {
+  // res.send((Math.floor(Date.now() / 1000)).toString());
+  const lastDataUpdate = await new Promise(function(resolve, reject) {
+    client.get("lastDataUpdate", (err, reply) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(reply);
+      }
+    });
+  });
+
+  let returnedValue = null;
+  const cachedItem = await new Promise(function(resolve, reject) {
+    client.get("returnedValue", (err, reply) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(reply);
+      }
+    });
+  });
+
+  if (!cachedItem) {
+    const movie = await axios.get('http://localhost:3001/movie/');
+    const tvseries = await axios.get('http://localhost:3002/tvseries');
+
+    returnedValue = {
+      movie: movie.data,
+      tvSeries: tvseries.data,
+    }
+
+    client.set("returnValue", JSON.stringify(returnedValue), 'EX', 100)
+  } else {
+    console.log(cachedItem);
+    returnedValue = JSON.parse(cachedItem);
+  }
+
+  res.status(200).send(returnedValue);
+  // res.send('asd')
+})
+
+module.exports = router;

Apis/api/graphql.js

@@ -0,0 +1,136 @@
+const {
+  graphql,
+  GraphQLSchema,
+  GraphQLObjectType,
+  GraphQLString,
+  GraphQLList,
+  buildSchema
+} =  require('graphql');
+const axios = require('axios');
+
+// module.exports =  schema = new GraphQLSchema({
+//   query: new GraphQLObjectType({
+//     name: 'RootQueryType',
+//     fields: {
+//       hello: {
+//         type: GraphQLString,
+//         resolve() {
+//           return 'world'
+//         }
+//       },
+//       world: {
+//         type: GraphQLString,
+//         resolve() {
+//           return 'tuturu'
+//         }
+//       },
+//       movies: {
+//         type: GraphQLString,
+//         resolve: async() => {
+//           const { data } = await axios.get('http://localhost:3001/movie')
+//           return JSON.stringify(data);
+//         }
+//       },
+//       tvSeries: {
+//         type:
+//           new GraphQLObjectType({
+//             name: 'asd',
+//             fields: {
+//               id: {
+//                 type: GraphQLString,
+//                 resolve() {
+//                   return 'asd'
+//                 }
+//               }
+//             }
+//           })
+//
+//       }
+//     }
+//   })
+// })
+
+module.exports = {
+  schema: buildSchema(`
+    type Query {
+      movies: [Movie]
+      tvSeries: [TvSerie]
+    }
+
+    type Mutation {
+      updateMovie(movie: MovieInput): Movie
+    }
+
+    input MovieInput {
+      id: String
+      title: String
+      overview: String
+      poster_path: String
+      popularity: Float
+      tag: [String]
+      status: String
+    }
+
+    type Movie {
+      id: String
+      title: String
+      overview: String
+      poster_path: String
+      popularity: Float
+      tag: [String]
+      status: String
+    }
+
+    type TvSerie {
+      id: String
+      title: String
+      overview: String
+      poster_path: String
+      popularity: Float
+      tag: [String]
+      status: String
+    }
+  `),
+  root: {
+    updateMovie: async({ movie }) => {
+      const params = {};
+      movie.title && (params.title = movie.title);
+      movie.overview && (params.overview = movie.overview);
+      movie.poster_path && (params.poster_pamovie.body.poster_path);
+      movie.popularity && (params.popularity = movie.popularity);
+      movie.tag && (params.tag = movie.tag);
+      movie.status && (params.status = movie.status);
+      // console.log(movie.id);
+      // console.log(params);
+      const { data } = await axios.put(`http://localhost:3001/movie/${movie.id}`, params)
+      // console.log(data);
+      return data;
+    },
+    movies: async() => {
+      const { data } = await axios.get('http://localhost:3001/movie');
+      // console.log(data);
+      return data.map((item) => ({
+        id: item._id,
+        title: item.title,
+        overview: item.overview,
+        poster_path: item.poster_path,
+        popularity: item.popularity,
+        tag: item.tag,
+        status: item.status,
+      }));
+    },
+    tvSeries: async() => {
+      const { data } = await axios.get('http://localhost:3002/tvseries');
+      // console.log(data);
+      return data.map((item) => ({
+        id: item._id,
+        title: item.title,
+        overview: item.overview,
+        poster_path: item.poster_path,
+        popularity: item.popularity,
+        tag: item.tag,
+        status: item.status,
+      }));
+    },
+  }
+}

Apis/api/movie.js

@@ -0,0 +1,42 @@
+const express = require('express');
+const axios = require('axios');
+const router = express.Router();
+
+axios.defaults.baseURL = 'http://localhost:3001/movie';
+
+router.get('/', async (req, res) => {
+  const request = await axios.get('/');
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.post('/', async (req, res) => {
+  const params = {};
+  req.body.title && (params.title = req.body.title);
+  req.body.overview && (params.overview = req.body.overview);
+  req.body.poster_path && (params.poster_path = req.body.poster_path);
+  req.body.popularity && (params.popularity = req.body.popularity);
+  req.body.tag && (params.tag = req.body.tag);
+  req.body.status && (params.status = req.body.status);
+
+  const request =  await axios.post('/', params);
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.put('/:id', async (req, res) => {
+  const params = {};
+  req.body.title && (params.title = req.body.title);
+  req.body.overview && (params.overview = req.body.overview);
+  req.body.poster_path && (params.poster_path = req.body.poster_path);
+  req.body.popularity && (params.popularity = req.body.popularity);
+  req.body.tag && (params.tag = req.body.tag);
+  req.body.status && (params.status = req.body.status);''
+
+  const request = await axios.put(`/${req.params.id}`, params);
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.delete('/:id', async (req, res) => {
+  const request = await axios.delete(`/`)
+})
+
+module.exports = router;

Apis/api/tvSeries.js

@@ -0,0 +1,42 @@
+const express = require('express');
+const axios = require('axios');
+const router = express.Router();
+
+axios.defaults.baseURL = 'http://localhost:3002/tvseries';
+
+router.get('/', async (req, res) => {
+  const request = await axios.get('/');
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.post('/', async (req, res) => {
+  const params = {};
+  req.body.title && (params.title = req.body.title);
+  req.body.overview && (params.overview = req.body.overview);
+  req.body.poster_path && (params.poster_path = req.body.poster_path);
+  req.body.popularity && (params.popularity = req.body.popularity);
+  req.body.tag && (params.tag = req.body.tag);
+  req.body.status && (params.status = req.body.status);
+
+  const request =  await axios.post('/', params);
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.put('/:id', async (req, res) => {
+  const params = {};
+  req.body.title && (params.title = req.body.title);
+  req.body.overview && (params.overview = req.body.overview);
+  req.body.poster_path && (params.poster_path = req.body.poster_path);
+  req.body.popularity && (params.popularity = req.body.popularity);
+  req.body.tag && (params.tag = req.body.tag);
+  req.body.status && (params.status = req.body.status);
+
+  const request = await axios.put(`/${req.params.id}`, params);
+  res.send(JSON.stringify(request.data)).status(200);
+})
+
+router.delete('/:id', async (req, res) => {
+  const request = await axios.delete(`/`)
+})
+
+module.exports = router;

Apis/index.js

@@ -0,0 +1,32 @@
+const express = require('express');
+const bodyParser = require('body-parser');
+const responseTime = require('response-time');
+const graphqlHTTP = require('express-graphql');
+const cors = require('cors');
+
+const movie = require('./api/movie');
+const tvSeries = require('./api/tvSeries');
+const entertainme = require('./api/entertainme');
+const graphQLobj =  require('./api/graphql');
+
+const app = express();
+
+app.use(cors());
+
+
+const jsonParser = bodyParser.json();
+const urlencodedParser = bodyParser.urlencoded({ extended: false });
+app.use(urlencodedParser);
+app.use(jsonParser)
+app.use('/graphql', graphqlHTTP({
+  schema: graphQLobj.schema,
+  rootValue: graphQLobj.root,
+  graphiql: true,
+}))
+app.use(responseTime());
+
+app.use('/movie', movie);
+app.use('/tvseries', tvSeries);
+app.use('/entertainme', entertainme);
+
+app.listen(3000);

Apis/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "Apis",
+  "version": "1.0.0",
+  "main": "index.js",
+  "license": "MIT",
+  "dependencies": {
+    "axios": "^0.17.1",
+    "body-parser": "^1.18.2",
+    "cors": "^2.8.4",
+    "express": "^4.16.2",
+    "express-graphql": "^0.6.11",
+    "graphql": "^0.11.7",
+    "redis": "^2.8.0",
+    "response-time": "^2.3.2"
+  },
+  "scripts": {
+    "dev": "nodemon index.js"
+  }
+}