Merge pull request #5 from rimrul/aggregate-deduplication

Prevent duplicate issues for aggregated feeds

Author: dscho

README.md

@@ -38,6 +38,8 @@ Log issue creation but do nothing
 
 Aggregate all items in a single issue
 
+Note: If you use this Action to create issues from multiple aggregated feeds in the same repository, give them different prefixes and/or labels.
+
 ### `character-limit`
 
 Limit the issue contents' size

dist/index.js

@@ -38259,7 +38259,8 @@ const parseDurationInMilliseconds = (text) => {
 
 const run = async () => {
   try {
-    const issueTitlePrefix = core.getInput('prefix')
+    let issueTitlePrefix = core.getInput('prefix')
+    issueTitlePrefix = issueTitlePrefix ? issueTitlePrefix + ' ' : ''
     let dryRun = core.getInput('dry-run')
     if (dryRun) dryRun = dryRun === 'true'
     let aggregate = core.getInput('aggregate')
@@ -38299,7 +38300,7 @@ const run = async () => {
 
     // Iterate
     for (const item of feed.items) {
-      let title = `${issueTitlePrefix ? issueTitlePrefix + ' ' : ''}${item.title}`
+      let title = `${issueTitlePrefix}${item.title}`
       if (titlePattern && !title.match(titlePattern)) {
         core.debug(`Feed item skipped because it does not match the title pattern (${title})`)
         continue
@@ -38312,6 +38313,11 @@ const run = async () => {
         continue
       }
 
+      if (aggregate && issues.find(x => x.title.startsWith(issueTitlePrefix) && Date.parse(x.created_at) > Date.parse(item.isoDate))) {
+        core.warning('Newer issue with same prefix already exists')
+        continue
+      }
+
       // Issue Content
       const content = item.content || item.description || ''
 
@@ -38336,7 +38342,7 @@ const run = async () => {
         // Create Issue
         createdIssues.push({ title, body, labels })
       } else {
-        title = `${issueTitlePrefix ? issueTitlePrefix + ' ' : ''}${new Date().toTimeString()}`
+        title = `${issueTitlePrefix}${new Date().toTimeString()}`
         createdIssues[0].title = title
 
         createdIssues[0].body += `\n\n${body}`

dist/index.js.map

@@ -22,7 +22,8 @@ const parseDurationInMilliseconds = (text) => {
 
 const run = async () => {
   try {
-    const issueTitlePrefix = core.getInput('prefix')
+    let issueTitlePrefix = core.getInput('prefix')
+    issueTitlePrefix = issueTitlePrefix ? issueTitlePrefix + ' ' : ''
     let dryRun = core.getInput('dry-run')
     if (dryRun) dryRun = dryRun === 'true'
     let aggregate = core.getInput('aggregate')
@@ -62,7 +63,7 @@ const run = async () => {
 
     // Iterate
     for (const item of feed.items) {
-      let title = `${issueTitlePrefix ? issueTitlePrefix + ' ' : ''}${item.title}`
+      let title = `${issueTitlePrefix}${item.title}`
       if (titlePattern && !title.match(titlePattern)) {
         core.debug(`Feed item skipped because it does not match the title pattern (${title})`)
         continue
@@ -75,6 +76,11 @@ const run = async () => {
         continue
       }
 
+      if (aggregate && issues.find(x => x.title.startsWith(issueTitlePrefix) && Date.parse(x.created_at) > Date.parse(item.isoDate))) {
+        core.warning('Newer issue with same prefix already exists')
+        continue
+      }
+
       // Issue Content
       const content = item.content || item.description || ''
 
@@ -99,7 +105,7 @@ const run = async () => {
         // Create Issue
         createdIssues.push({ title, body, labels })
       } else {
-        title = `${issueTitlePrefix ? issueTitlePrefix + ' ' : ''}${new Date().toTimeString()}`
+        title = `${issueTitlePrefix}${new Date().toTimeString()}`
         createdIssues[0].title = title
 
         createdIssues[0].body += `\n\n${body}`