feat(apis): set api data request v0 ✨

weareopensource · Mar 26, 2020 · b3c254a · b3c254a
1 parent 5468277
commit b3c254a
Show file tree

Hide file tree

Showing 4 changed files with 60 additions and 9 deletions.
diff --git a/modules/apis/controllers/apis.controller.js b/modules/apis/controllers/apis.controller.js
@@ -95,14 +95,30 @@ exports.load = async (req, res) => {
 };
 
 /**
- * @desc Endpoint to getData stocked from load
+ * @desc Endpoint to getData stocked from load on apis
  * @param {Object} req - Express request object
  * @param {Object} res - Express response object
  */
-exports.getApiData = async (req, res) => {
+exports.listApi = async (req, res) => {
   // TODO if (req.scrap && req.user && req.scrap.user && req.scrap.user.id === req.user.id) next();
   try {
-    const data = await ApisService.getApiData(req.api);
+    const data = await ApisService.listApi(req.api);
+    responses.success(res, 'api getData')(data);
+  } catch (err) {
+    responses.error(res, 422, 'Unprocessable Entity', errors.getMessage(err))(err);
+  }
+};
+
+
+/**
+ * @desc Endpoint to getData stocked from load on apis
+ * @param {Object} req - Express request object
+ * @param {Object} res - Express response object
+ */
+exports.getApi = async (req, res) => {
+  // TODO if (req.scrap && req.user && req.scrap.user && req.scrap.user.id === req.user.id) next();
+  try {
+    const data = await ApisService.getApi(req.api, req.body);
     responses.success(res, 'api getData')(data);
   } catch (err) {
     responses.error(res, 422, 'Unprocessable Entity', errors.getMessage(err))(err);

diff --git a/modules/apis/repositories/apis.repository.js b/modules/apis/repositories/apis.repository.js
@@ -71,11 +71,35 @@ exports.import = (collection, items) => {
 
 
 /**
- * @desc Function to import list of locations in db
+ * @desc Function to get api data from db
+ * @param {string} colletion name
+ * @return [{Object}] data
+ */
+exports.listApi = (collection) => {
+  const _schema = new mongoose.Schema({}, {
+    collection,
+    strict: false,
+    timestamps: true,
+  });
+
+  let model;
+  try {
+    model = mongoose.model(collection);
+  } catch (error) {
+    model = mongoose.model(collection, _schema);
+  }
+
+  return model.find().sort('-updatedAt').exec();
+};
+
+
+/**
+ * @desc Function to ask for  api data in db
  * @param {Object} locations
  * @return {Object} locations
  */
-exports.getApiData = (collection) => {
+exports.getApi = (collection, filters) => {
+  console.log(collection, filters);
   const _schema = new mongoose.Schema({}, {
     collection,
     strict: false,
@@ -89,5 +113,5 @@ exports.getApiData = (collection) => {
     model = mongoose.model(collection, _schema);
   }
 
-  return model.find().sort('-updatedAt').exec();
+  return model.findOne(filters).exec();
 };
diff --git a/modules/apis/routes/apis.routes.js b/modules/apis/routes/apis.routes.js
@@ -28,7 +28,8 @@ module.exports = (app) => {
     .get(apis.load);
 
   app.route('/api/apis/data/:apiId')
-    .get(apis.getApiData);
+    .get(apis.listApi)
+    .post(apis.getApi);
 
   // Finish by binding the api middleware
   app.param('apiId', apis.apiByID);

diff --git a/modules/apis/services/apis.service.js b/modules/apis/services/apis.service.js
@@ -141,7 +141,17 @@ exports.load = async (api, start) => {
  * @param {Object} scrap - original scrap
  * @return {Promise} scrap
  */
-exports.getApiData = async (api) => {
-  const result = await ApisRepository.getApiData(api.slug);
+exports.listApi = async (api) => {
+  const result = await ApisRepository.listApi(api.slug);
+  return Promise.resolve(result);
+};
+
+/**
+ * @desc Functio to ask repository to get data stocker from apis request
+ * @param {Object} scrap - original scrap
+ * @return {Promise} scrap
+ */
+exports.getApi = async (api, body) => {
+  const result = await ApisRepository.getApi(api.slug, body);
   return Promise.resolve(result);
 };