changed fetch publickeys to a queue

src/backgroundFunctions/encryption.ts

@@ -1,6 +1,7 @@
 import { getBaseApi, getKeyPair } from "../background";
 import { createSymmetricKeyAndNonce, decryptGroupData, encryptDataGroup, objectToBase64 } from "../qdn/encryption/group-encryption";
 import { publishData } from "../qdn/publish/pubish";
+import { RequestQueueWithPromise } from "../utils/queue/queue";
 
 const apiEndpoints = [
     "https://api.qortal.org",
@@ -13,6 +14,8 @@ const apiEndpoints = [
     "https://apinode4.qortalnodes.live",
 ];
 
+export const requestQueueGetPublicKeys = new RequestQueueWithPromise(10);
+
 async function findUsableApi() {
     for (const endpoint of apiEndpoints) {
       try {
@@ -64,43 +67,50 @@ export async function getNameInfo() {
 //     }
 //   }
 const getPublicKeys = async (groupNumber: number) => {
-    const validApi = await getBaseApi()
+  const validApi = await getBaseApi();
   const response = await fetch(`${validApi}/groups/members/${groupNumber}?limit=0`);
   const groupData = await response.json();
 
-      let members: any = [];
+  if (groupData && Array.isArray(groupData.members)) {
-      if (groupData && Array.isArray(groupData?.members)) {
+    // Use the request queue for fetching public keys
-        for (const member of groupData.members) {
+    const memberPromises = groupData.members
-          if (member.member) {
+      .filter((member) => member.member)
+      .map((member) =>
+        requestQueueGetPublicKeys.enqueue(async () => {
           const resAddress = await fetch(`${validApi}/addresses/${member.member}`);
           const resData = await resAddress.json();
-            const publicKey = resData.publicKey;
+          return resData.publicKey;
-            members.push(publicKey)
+        })
-          }
+      );
-        }
+
+    const members = await Promise.all(memberPromises);
+    return members;
   }
 
-      return members
+  return [];
-  }
+};
 
-  export const getPublicKeysByAddress = async (admins) => {
+export const getPublicKeysByAddress = async (admins: string[]) => {
-    const validApi = await getBaseApi()
+  const validApi = await getBaseApi();
 
-
-      let members: any = [];
   if (Array.isArray(admins)) {
-        for (const address of admins) {
+    // Use the request queue to limit concurrent fetches
-          if (address) {
+    const memberPromises = admins
+      .filter((address) => address) // Ensure the address is valid
+      .map((address) =>
+        requestQueueGetPublicKeys.enqueue(async () => {
           const resAddress = await fetch(`${validApi}/addresses/${address}`);
           const resData = await resAddress.json();
-            const publicKey = resData.publicKey;
+          return resData.publicKey;
-            members.push(publicKey)
+        })
-          }
+      );
-        }
+
+    const members = await Promise.all(memberPromises);
+    return members;
   }
 
-      return members
+  return []; // Return empty array if admins is not an array
-  }
+};
 export const encryptAndPublishSymmetricKeyGroupChatForAdmins = async ({groupId, previousData, admins}: {
   groupId: number,
   previousData: Object,