Fetch issue with queryone.

Author: afrisalyp

src/common/db-helper.js

@@ -1,3 +1,4 @@
+const _ = require('lodash');
 const logger = require('./logger');
 
 /*
@@ -47,6 +48,36 @@ async function scan(model, scanParams) {
   });
 }
 
+/**
+ * Get single data by query parameters
+ * @param {Object} model The dynamoose model to query
+ * @param {Object} params The parameters object
+ * @returns {Promise<void>}
+ */
+async function queryOne(model, params) {
+  logger.debug('Enter queryOne.');
+
+  return await new Promise((resolve, reject) => {
+    const queryParams = {};
+
+    _.forOwn(params, (value, key) => {
+      queryParams[key] = {eq: value};
+    });
+
+    logger.debug(`${JSON.stringify(queryParams)}`);
+    model.queryOne(queryParams).exec((err, result) => {
+      if (err) {
+        logger.debug(`queryOne. Error. ${err}`);
+        return reject(err);
+      }
+      logger.debug('queryOne. Result.');
+      logger.debug(result);
+
+      return resolve(result);
+    });
+  });
+}
+
 /**
  * Get single data by scan parameters
  * @param {Object} model The dynamoose model to scan
@@ -136,4 +167,5 @@ module.exports = {
   create,
   update,
   remove,
+  queryOne
 };

src/services/IssueService.js

@@ -238,22 +238,6 @@ async function recreate(issue, currentUser) {
     },
   };
 
-  const dbIssue = await dbHelper.scanOne(models.Issue, {
-    number: issueNumber,
-    projectId: issue.projectId
-  });
-
-  if (!issue.recreate) {
-    if (dbIssue) dbIssue.delete();
-    return {
-      success: true
-    };
-  }
-
-  if (!dbIssue) {
-    createEvent.event = 'issue.created';
-  }
-
   const labels = [];
 
   if (provider === 'github') {
@@ -315,6 +299,23 @@ async function recreate(issue, currentUser) {
     }
   }
 
+  const dbIssue = await dbHelper.scanOne(models.Issue, {
+    number: issueNumber,
+    provider,
+    repositoryId: createEvent.data.repository.id
+  });
+
+  if (!issue.recreate) {
+    if (dbIssue) dbIssue.delete();
+    return {
+      success: true
+    };
+  }
+
+  if (!dbIssue) {
+    createEvent.event = 'issue.created';
+  }
+
   if (labels.length > 0) {
     createEvent.data.issue.labels = labels;
   }