getMessagesCallback: refactor to async

5e354f22c5f9ac36d37b67c8caa7126ab5049273

Succubyss <87207237+Succubyss@users.noreply.github.com>

Parents: cfb40cae0b6e6c49c8e44281ecd9ee24e9cb5c30

public/scripts/slash-commands.js+25 -19 Viewed

     return String(value);
+}
 async function getMessagesCallback(args, value) {
     const includeNames = !isFalseBoolean(args?.names);
     const includeHidden = isTrueBoolean(args?.hidden);
     const role = args?.role;

         throw new Error(`Invalid role provided. Expected one of: system, assistant, user. Got: ${role}`);
     };
 -    const messages = [];
 +    const processMessage = async (mesId) => {
+-
 +        const msg = chat[mesId];
 -    for (let messageId = range.start; messageId <= range.end; messageId++) {
 +        if (!msg) {
 -        const message = chat[messageId];
 +            console.warn(`WARN: No message found with ID ${mesId}`);
 -        if (!message) {
 +            return null;
 -            console.warn(`WARN: No message found with ID ${messageId}`);
 -            continue;
+        }
         if (role && !filterByRole(messagemsg)) {
             console.debug(`/messages: Skipping message with ID ${messageIdmesId} due to role filter`);
             continuereturn null;
+        }
         if (!includeHidden && messagemsg.is_system) {
             console.debug(`/messages: Skipping hidden message with ID ${messageIdmesId}`);
             continuereturn null;
+        }
 -        if (includeNames) {
 +        return includeNames ? `${msg.name}: ${msg.mes}` : msg.mes;
 -            messages.push(`${message.name}: ${message.mes}`);
 +    };
 -        } else {
++
 -            messages.push(message.mes);
 +    const messagePromises = new Array(range.end - range.start + 1);
 -        }
++
 +    for (let rInd = range.start; rInd <= range.end; ++rInd)
 +        messagePromises[rInd - range.start] = processMessage(rInd);
++
 +    const messages = await Promise.all(messagePromises);
++
 +    for (let i = 0; i < messages.length; /**/ ) {
 +        if (messages[i] !== null) ++i;
 +        else messages.splice(i, 1);
+    }
     return messages.join('\n\n');