fix(edit-article): uniq tags & collection

src/connectors/queue/publication.ts

@@ -241,7 +241,9 @@ class PublicationQueue extends BaseQueue {
     if (tags && tags.length > 0) {
       // get tag editor
       const mattyUser = await this.userService.findByEmail('[email protected]')
-      const tagEditors = [mattyUser.id, article.authorId]
+      const tagEditors = mattyUser
+        ? [mattyUser.id, article.authorId]
+        : [article.authorId]
 
       // create tag records, return tag record if already exists
       const dbTags = ((await Promise.all(

src/mutations/article/editArticle.ts

@@ -1,4 +1,4 @@
-import { difference } from 'lodash'
+import { difference, uniq } from 'lodash'
 
 import { ARTICLE_STATE, CACHE_KEYWORD, NODE_TYPES } from 'common/enums'
 import {
@@ -94,16 +94,20 @@ const resolver: MutationToEditArticleResolver = async (
   if (tags) {
     // get tag editor
     const mattyUser = await userService.findByEmail('[email protected]')
-    const tagEditors = [mattyUser.id, article.authorId]
+    const tagEditors = mattyUser
+      ? [mattyUser.id, article.authorId]
+      : [article.authorId]
 
     // create tag records
     const dbTags = ((await Promise.all(
-      tags.map((tag: string) =>
-        tagService.create({
-          content: tag,
-          creator: article.authorId,
-          editors: tagEditors,
-        })
+      uniq(
+        tags.map((tag: string) =>
+          tagService.create({
+            content: tag,
+            creator: article.authorId,
+            editors: tagEditors,
+          })
+        )
       )
     )) as unknown) as [{ id: string; content: string }]
 
@@ -137,7 +141,9 @@ const resolver: MutationToEditArticleResolver = async (
         limit: null,
       })
     ).map(({ articleId }: { articleId: string }) => articleId)
-    const newIds = collection.map((articleId) => fromGlobalId(articleId).id)
+    const newIds = uniq(
+      collection.map((articleId) => fromGlobalId(articleId).id)
+    )
     const addItems: any[] = []
     const updateItems: any[] = []
     const diff = difference(newIds, oldIds)

src/queries/article/tag/editors.ts

@@ -4,6 +4,6 @@ const resolver: TagToEditorsResolver = (
   { editors },
   _,
   { dataSources: { userService } }
-) => userService.dataloader.loadMany(editors)
+) => userService.dataloader.loadMany(editors || [])
 
 export default resolver

src/types/directives/purgeCache.ts

@@ -34,7 +34,6 @@ export class PurgeCacheDirective extends SchemaDirectiveVisitor {
       const [root, _, { redis }, { returnType }] = args
 
       const result = await resolve.apply(this, args)
-
       if (result && result.id && redis && returnType) {
         try {
           const cache = _get(result, CACHE_KEYWORD, [])