feat(apis): save in db for the first time :) ✨

modules/apis/models/apis.model.mongoose.js

@@ -9,7 +9,10 @@ const Schema = mongoose.Schema;
  * Data Model Mongoose
  */
 const ApiMongoose = new Schema({
-  title: String,
+  title: {
+    type: String,
+    unique: 'Title already exists',
+  },
   url: String,
   auth: String,
   serviceId: String,

modules/apis/repositories/apis.repository.js

@@ -41,3 +41,36 @@ exports.update = (api) => new Api(api).save().then((a) => a.populate('history').
  * @return {Object} confirmation of delete
  */
 exports.delete = (api) => Api.deleteOne({ _id: api.id }).exec();
+
+/**
+ * @desc Function to import list of locations in db
+ * @param {Object} locations
+ * @return {Object} locations
+ */
+exports.import = (collection, items, filters) => {
+  const _schema = new mongoose.Schema({}, {
+    collection,
+    strict: false,
+  });
+
+  let model;
+  try {
+    model = mongoose.model(collection);
+  } catch (error) {
+    model = mongoose.model(collection, _schema);
+  }
+
+  return model.bulkWrite(items.map((item) => {
+    const filter = {};
+    filters.forEach((value) => {
+      filter[value] = item[value];
+    });
+    return {
+      updateOne: {
+        filter,
+        update: item,
+        upsert: true,
+      },
+    };
+  }));
+};

modules/apis/services/apis.service.js

@@ -2,6 +2,7 @@
  * Module dependencies
  */
 const path = require('path');
+const _ = require('lodash');
 
 const UserService = require(path.resolve('./modules/users/services/user.service.js'));
 const montaineMapping = require(path.resolve('./lib/helpers/montaineMapping'));
@@ -113,10 +114,9 @@ exports.load = async (api) => {
   // prepare for save
   if (result.result) {
     result.result = montaineSaving.saving(result.result, start);
+    await ApisRepository.import(_.camelCase(api.title), result.result, ['@id', '@date']);
   }
 
-  // Mapping
-
   const history = await HistoryRepository.create(montaineRequest.setScrapHistory(result.request, api, start));
   api.status = result.request.type === 'success';
   api.history.push(history._id);