feat(apis, script): set restore & purge db ✨

modules/apis/repositories/apis.repository.js

@@ -57,6 +57,27 @@ exports.update = (api) => new Api(api).save().then((a) => a.populate(defaultPopu
  */
 exports.delete = (api) => Api.deleteOne({ _id: api.id }).exec();
 
+/**
+ * @desc Function to import list of apis in db
+ * @param {[Object]} apis
+ * @param {[String]} filters
+ * @return {Object} apis
+ */
+exports.import = (apis, filters) => Api.bulkWrite(apis.map((api) => {
+ const filter = {};
+ filters.forEach((value) => {
+ filter[value] = api[value];
+ });
+ return {
+ updateOne: {
+ filter,
+ update: api,
+ upsert: true,
+ },
+ };
+}));
+
+
 /**
  * @desc Function to update scrap history in db
  * @param {Object} scrap
@@ -72,11 +93,12 @@ exports.historize = (api, history) => Api.updateOne(
 );
 
 /**
- * @desc Function to import list of locations in db
- * @param {Object} locations
- * @return {Object} locations
+ * @desc Function to insert list of data in db
+ * @param {Object} collection
+ * @param {Object} items
+ * @return {Object} updateOne result
  */
-exports.import = (collection, items) => {
+exports.insert = (collection, items) => {
  const _schema = new mongoose.Schema({}, { collection, strict: false });
  let model;
  try {

modules/apis/services/apis.data.service.js

@@ -0,0 +1,15 @@
+/**
+ * Module dependencies
+ */
+const ApisRepository = require('../repositories/apis.repository');
+
+/**
+ * @desc Function to ask repository to import a list of apis
+ * @param {[Object]} apis
+ * @param {[String]} filters
+ * @return {Promise} apis
+ */
+exports.import = (apis, filters) => {
+ const result = ApisRepository.import(apis, filters);
+ return result;
+};

modules/apis/services/apis.service.js

@@ -137,7 +137,7 @@ exports.load = async (api, user) => {
  result.prepare = result.temp;
  result.temp = montaineSave.save(result.temp, start);
  result.mongo = result.temp;
- if (api.savedb) result.result = await ApisRepository.import(api.slug, _.cloneDeep(result.temp));
+ if (api.savedb) result.result = await ApisRepository.insert(api.slug, _.cloneDeep(result.temp));
  delete result.temp;
  }
 
@@ -203,7 +203,7 @@ exports.workerAuto = async (api, body) => {
  if (result.temp) {
  result.temp = montaineSave.prepare(result.temp, start);
  result.temp = montaineSave.save(result.temp, start);
- if (api.savedb) result.result = await ApisRepository.import(api.slug, _.cloneDeep(result.temp));
+ if (api.savedb) result.result = await ApisRepository.insert(api.slug, _.cloneDeep(result.temp));
  }
 
  // historize