PluralFlux-infra/src/helpers/importHelper.js

const {enums} = require("../enums.js");
const {memberHelper} = require("memberHelper.js");

const importHelper = {

    /**
     * Tries to import from Pluralkit.
     *
     * @async
     * @param {string} authorId - The author of the message
     * @param {string} attachmentUrl - The attached JSON url.
     * @returns {string} A successful addition of all members.
     * @throws {Error}  When the member exists, or creating a member doesn't work.
     */
    async pluralKitImport(authorId, attachmentUrl) {
        if (!attachmentUrl) {
            throw new Error(enums.err.NOT_JSON_FILE);
        }
        return fetch(attachmentUrl).then((res) => res.json()).then(async (pkData) => {
            const pkMembers = pkData.members;
            const errors = [];
            const addedMembers = [];
            for (let pkMember of pkMembers) {
                const proxy = pkMember.proxy_tags[0] ? `${pkMember.proxy_tags[0].prefix ?? ''}text${pkMember.proxy_tags[0].suffix ?? ''}` : null;
                await memberHelper.addFullMember(authorId, pkMember.name, pkMember.display_name, proxy, pkMember.avatar_url, true).then((member) => {
                    addedMembers.push(member.name);
                }).catch(e => {
                    errors.push(`${pkMember.name}: ${e.message}`);
                });
                await memberHelper.checkImageFormatValidity(pkMember.avatar_url).catch(e => {
                    errors.push(`${pkMember.name}: ${e.message}`)
                });
            }
            const aggregatedText = addedMembers.length > 0 ? `Successfully added members: ${addedMembers.join(', ')}` : enums.err.NO_MEMBERS_IMPORTED;
            if (errors.length > 0) {
                throw new AggregateError(errors, aggregatedText);
            }
            return aggregatedText;
        });
    }
};

module.exports = importHelper;