Function updateUsersWithNewUsernames

models/users.js:1029–1112

()

    }
    return users;
  } catch (err) {
    logger.error("Firebase fetch operation failed!");
    return [];
  }
};

const getNonNickNameSyncedUsers = async () => {
  try {
    const usersRef = await userModel
      .where("roles.archived", "==", false)
      .where("nickname_synced", "==", false)
      .where("discordId", "!=", null)
      .get();
    const users = [];
    usersRef.forEach((user) => {
      const userData = user.data();
      if (userData?.discordId)
        users.push({
          ...userData,
          id: user.id,
        });
    });
    return users;
  } catch (err) {
    logger.error(`Error while fetching all users: ${err}`);
    throw err;
  }
};

const updateUsernamesInBatch = async (usersData) => {
  const batch = firestore.batch();
  const usersBatch = [];
  const summary = {
    totalUpdatedUsernames: 0,
    totalOperationsFailed: 0,
    failedUserDetails: [],
  };

  usersData.forEach((user) => {
    const updateUserData = { ...user, username: user.username };
    batch.update(userModel.doc(user.id), updateUserData);
    usersBatch.push(user.id);
  });

  try {
    await batch.commit();
    summary.totalUpdatedUsernames += usersData.length;
    usersBatch.forEach((id) => {
      userCache.invalidateUser(id);
    });
    return { ...summary };
  } catch (err) {
    logger.error("Firebase batch Operation Failed!");
    summary.totalOperationsFailed += usersData.length;
    summary.failedUserDetails = [...usersBatch];
    return { ...summary };
  }
};