feat(ipns): revise refreshIPNSFeed mutation

thematters · Nov 6, 2024 · 84386e9 · 84386e9
1 parent ec8dfde
commit 84386e9
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/mutations/user/refreshIPNSFeed.ts b/src/mutations/user/refreshIPNSFeed.ts
@@ -1,19 +1,20 @@
 import type { GQLMutationResolvers } from 'definitions'
 
+import { QUEUE_URL } from 'common/enums'
+import { aws } from 'connectors'
+
 const resolver: GQLMutationResolvers['refreshIPNSFeed'] = async (
   _,
   { input: { userName, numArticles = 50 } },
-  {
-    dataSources: {
-      userService,
-      queues: { publicationQueue },
-    },
-  }
+  { dataSources: { userService } }
 ) => {
   const ipnsKeyRec = await userService.findOrCreateIPNSKey(userName)
 
   if (ipnsKeyRec) {
-    // TODO
+    aws.sqsSendMessage({
+      messageBody: { userName, useMattersIPNS: true },
+      queueUrl: QUEUE_URL.ipnsUserPublication,
+    })
   }
 
   return userService.findByUserName(userName)