Merge pull request #802 from stakwork/update/only_pubkey

Update/only pubkey
stakwork · Feb 8, 2024 · 4e99a46 · 4e99a46
2 parents c8818b8 + ca66dbe
commit 4e99a46
Show file tree

Hide file tree

Showing 4 changed files with 111 additions and 35 deletions.
diff --git a/dist/src/controllers/botapi/broadcast.js b/dist/src/controllers/botapi/broadcast.js
diff --git a/dist/src/controllers/botapi/broadcast.js.map b/dist/src/controllers/botapi/broadcast.js.map
diff --git a/src/controllers/botapi/broadcast.ts b/src/controllers/botapi/broadcast.ts
@@ -30,18 +30,34 @@ export default async function broadcast(a: Action): Promise<void> {
   const tenant: number = owner.id
 
   if (only_user || only_pubkey) {
-    if (only_user) {
-      chat.contactIds = `[${only_user}]`
-    } else {
-      try {
-        const user = (await models.Contact.findOne({
-          where: { tenant, publicKey: only_pubkey! },
-        })) as ContactRecord
-        if (user) chat.contactIds = `[${user.id}]`
-      } catch (error) {
-        sphinxLogger.error(`=> ONLY_PUBKEY ERROR ${error}`, logging.Bots)
+    if (only_pubkey) {
+      const pubkeysArray = only_pubkey.split(',')
+      const userIds: number[] = []
+
+      for (let i = 0; i < pubkeysArray.length; i++) {
+        const publicKey = pubkeysArray[i]
+        try {
+          const user = (await models.Contact.findOne({
+            where: { tenant, publicKey },
+          })) as ContactRecord
+          if (user) userIds.push(user.id)
+        } catch (error) {
+          sphinxLogger.error(
+            `=> ERROR GETTING USER WITH THIS PUBKEY ${publicKey} ${error}`,
+            logging.Bots
+          )
+        }
+      }
+      if (userIds.length === 0) {
+        sphinxLogger.error(
+          `=> USERS WITH PUBKEYS PROVIDED DO NOT EXIST`,
+          logging.Bots
+        )
         return
       }
+      chat.contactIds = JSON.stringify([...userIds])
+    } else {
+      chat.contactIds = `[${only_user}]`
     }
   }