added new processChatRoom function to reduce function nesting level d…

…own from 4
CMU-313 · Sep 12, 2024 · 9628970 · 9628970
1 parent 39e6ab3
commit 9628970
Showing 1 changed file with 27 additions and 19 deletions.
diff --git a/src/upgrades/1.0.0/chat_room_hashes.js b/src/upgrades/1.0.0/chat_room_hashes.js
@@ -12,28 +12,36 @@ module.exports = {
 			if (err) {
 				return callback(err);
 			}
-			let currentChatRoomId = 1;
-			async.whilst((next) => {
-				next(null, currentChatRoomId <= nextChatRoomId);
-			}, (next) => {
-				db.getSortedSetRange(`chat:room:${currentChatRoomId}:uids`, 0, 0, (err, uids) => {
+			const currentChatRoomId = 1;
+			async.whilst(
+				(next) => {
+					next(null, currentChatRoomId <= nextChatRoomId);
+				},
+				(next) => {
+					processChatRoom(currentChatRoomId, next);
+				},
+				callback
+			);
+		});
+
+		function processChatRoom(currentChatRoomId, next) {
+			db.getSortedSetRange(`chat:room:${currentChatRoomId}:uids`, 0, 0, (err, uids) => {
+				if (err) {
+					return next(err);
+				}
+				if (!Array.isArray(uids) || !uids.length || !uids[0]) {
+					currentChatRoomId += 1;
+					return next();
+				}
+
+				db.setObject(`chat:room:${currentChatRoomId}`, { owner: uids[0], roomId: currentChatRoomId }, (err) => {
 					if (err) {
 						return next(err);
 					}
-					if (!Array.isArray(uids) || !uids.length || !uids[0]) {
-						currentChatRoomId += 1;
-						return next();
-					}
-
-					db.setObject(`chat:room:${currentChatRoomId}`, { owner: uids[0], roomId: currentChatRoomId }, (err) => {
-						if (err) {
-							return next(err);
-						}
-						currentChatRoomId += 1;
-						next();
-					});
+					currentChatRoomId += 1;
+					next();
 				});
-			}, callback);
-		});
+			});
+		}
 	},
 };