Ваш код может вернуть пустой результат, потому что вы вызываете ответ в то время, когда пользовательские статусы еще не могут быть получены из БД. Другая проблема заключается в том, что если я получил несколько сообщений от одного и того же пользователя, то вызов его статуса может быть дублированным. Ниже приведена функция, которая сначала извлекает сообщения из БД, избегая двойственности пользователей, а затем получает их статусы.
function getMessages(username, callback) {
// this would be "buffer" for senders of the messages
var users = {};
// variable for a number of total users I have - it would be used to determine
// the callback call because this function is doing async jobs
var usersCount = 0;
// helpers vars
var i = 0, user, item;
// get all the messages which recipient is "username"
db.view('privatemessages/all', {"key":username}, function (errA, resA) {
// for each of the message
resA.forEach(function (rowA) {
user = users[rowA.username];
// if user doesn't exists - add him to users list with current message
// else - add current message to existing user
if(!user) {
users[rowA.username] = {
// I guess this is the name of the sender
name: rowA.username,
// here will come his current status later
status: "",
// in this case I may only need content, so there is probably
// no need to insert whole message to array
messages: [rowA]
};
usersCount++;
} else {
user.messages.push(rowA);
}
});
// I should have all the senders with their messages
// and now I need to get their statuses
for(item in users) {
// assuming that user documents have keys based on their names
db.get(item, function(err, doc) {
i++;
// assign user status
users[item].status = doc.onlineStatus;
// when I finally fetched status of the last user, it's time to
// execute callback and rerutn my results
if(i === usersCount) {
callback(users);
}
});
}
});
}
...
getMessages(username, function(result) {
response.end(JSON.stringify(result));
});
Хотя CouchDB - отличная база данных документов, вы должны быть осторожны с частыми обновлениями существующих документов, потому что она создает совершенно новую версию документа после каждого обновления (это из-за модели MVCC , которая используется для достижения высокой доступность и долговечность данных). Следствием этого поведения является более высокое потребление дискового пространства (больше данных / обновлений, больше необходимого дискового пространства - пример ), поэтому вы должны наблюдать за ним и соответственно использовать потребление базы данных.