From d342e01ef15945b694dc94a7dc902ff4dc0508f8 Mon Sep 17 00:00:00 2001
From: barisusakli <barisusakli@gmail.com>
Date: Tue, 10 Mar 2015 14:09:24 -0400
Subject: [PATCH] search group members

---
 src/groups.js           | 63 +++++++++++++++++++++++++++++++++++++++++
 src/socket.io/groups.js |  9 ++++++
 src/user/search.js      | 43 +++++++++++++++++-----------
 3 files changed, 98 insertions(+), 17 deletions(-)

diff --git a/src/groups.js b/src/groups.js
index 0645fc55ac..dddd0aafcf 100644
--- a/src/groups.js
+++ b/src/groups.js
@@ -1096,4 +1096,67 @@ var async = require('async'),
 		next(null, groups);
 	};
 
+	Groups.searchMembers = function(data, callback) {
+
+		function userInGroup(userGroups) {
+			for(var i=0; i<userGroups.length; ++i) {
+				if (userGroups[i].name === data.groupName) {
+					return true;
+				}
+			}
+			return false;
+		}
+		var searchResult;
+		var pagination;
+
+		if (!data.query) {
+			async.waterfall([
+				function(next) {
+					user.getUidsFromSet('group:' + data.groupName + ':members', 0, -1, next);
+				},
+				function(uids, next) {
+					pagination = user.paginate(1, uids);
+
+					uids = pagination.data;
+					user.getUsers(uids, data.uid, next);
+				},
+				function(users, next) {
+					next(null, {
+						users: users,
+						pagination: pagination.pagination
+					});
+				}
+			], callback);
+			return;
+		}
+
+		async.waterfall([
+			function(next) {
+				data.paginate = false;
+				user.search(data, next);
+			},
+			function(_searchResult, next) {
+				searchResult = _searchResult;
+				var uids = searchResult.users.map(function(user) {
+					return user && user.uid;
+				});
+
+				if (!uids.length) {
+					return callback(null, searchResult);
+				}
+				Groups.getUserGroups(uids, next);
+			},
+			function(groups, next) {
+				searchResult.users = searchResult.users.filter(function(user, index) {
+					return user && userInGroup(groups[index]);
+				});
+
+				pagination = user.paginate(data.page, searchResult.users);
+				searchResult.pagination = pagination.pagination;
+				searchResult.users = pagination.data;
+				next(null, searchResult);
+			}
+		], callback);
+	};
+
 }(module.exports));
diff --git a/src/socket.io/groups.js b/src/socket.io/groups.js
index bb814e6006..44f460d4ed 100644
--- a/src/socket.io/groups.js
+++ b/src/socket.io/groups.js
@@ -184,6 +184,15 @@ SocketGroups.search = function(socket, data, callback) {
 	groups.search(data.query || '', data.options || {}, callback);
 };
 
+SocketGroups.searchMembers = function(socket, data, callback) {
+	if (!data) {
+		return callback(null, []);
+	}
+
+	data.uid = socket.uid;
+	groups.searchMembers(data, callback);
+};
+
 SocketGroups.kick = function(socket, data, callback) {
 	if (!data) {
 		return callback(new Error('[[error:invalid-data]]'));
diff --git a/src/user/search.js b/src/user/search.js
index 4a26940416..bc5efa7f77 100644
--- a/src/user/search.js
+++ b/src/user/search.js
@@ -15,6 +15,7 @@ module.exports = function(User) {
 		var startsWith = data.hasOwnProperty('startsWith') ? data.startsWith : true;
 		var page = data.page || 1;
 		var uid = data.uid || 0;
+		var paginate = data.hasOwnProperty('paginate') ? data.paginate : true;
 
 		if (searchBy.indexOf('ip') !== -1) {
 			return searchByIP(query, uid, callback);
@@ -25,42 +26,50 @@ module.exports = function(User) {
 			return searchBy + ':uid';
 		});
 
-		var resultsPerPage = parseInt(meta.config.userSearchResultsPerPage, 10) || 20;
-		var start = Math.max(0, page - 1) * resultsPerPage;
-		var end = start + resultsPerPage;
-		var pageCount = 1;
-		var matchCount = 0;
 		var filterBy = Array.isArray(data.filterBy) ? data.filterBy : [];
 
+		var searchResult = {};
 		async.waterfall([
 			function(next) {
 				findUids(query, keys, startsWith, next);
 			},
 			function(uids, next) {
+
 				filterAndSortUids(uids, filterBy, data.sortBy, next);
 			},
 			function(uids, next) {
-				matchCount = uids.length;
-				uids = uids.slice(start, end);
+				searchResult.matchCount = uids.length;
+
+				if (paginate) {
+					var pagination = user.paginate(page, uids);
+					uids = pagination.data;
+					searchResult.pagination = pagination.pagination;
+				}
 
 				User.getUsers(uids, uid, next);
 			},
 			function(userData, next) {
-				var data = {
-					timing: (process.elapsedTimeSince(startTime) / 1000).toFixed(2),
-					users: userData,
-					matchCount: matchCount
-				};
-
-				var currentPage = Math.max(1, Math.ceil((start + 1) / resultsPerPage));
-				pageCount = Math.ceil(matchCount / resultsPerPage);
-				data.pagination = pagination.create(currentPage, pageCount);
+				searchResult.timing = (process.elapsedTimeSince(startTime) / 1000).toFixed(2);
+				searchResult.users = userData;
 
-				next(null, data);
+				next(null, searchResult);
 			}
 		], callback);
 	};
 
+	User.paginate = function(page, data) {
+		var resultsPerPage = parseInt(meta.config.userSearchResultsPerPage, 10) || 20;
+		var start = Math.max(0, page - 1) * resultsPerPage;
+		var end = start + resultsPerPage;
+		var pageCount = Math.ceil(data.length / resultsPerPage);
+		var currentPage = Math.max(1, Math.ceil((start + 1) / resultsPerPage));
+
+		return {
+			pagination: pagination.create(currentPage, pageCount),
+			data: data.slice(start, end)
+		};
+	};
+
 	function findUids(query, keys, startsWith, callback) {
 		db.getObjects(keys, function(err, hashes) {
 			if (err || !hashes) {