Кеширование запроса при вызове функции NodeJS

Question

[Stricker]

Приветствую, такой вопрос по NodeJS -
Есть функция -

function getUserData (id, callback) {
        vk.api('users.get',{
            'user_ids'  : id,
            'fields'    : 'photo_100'
        }, function(err, result) {
            if (err) callback(err);
            else {
                callback(null, result.response[0]);
            }
        });
}

И вот как бы запрос -
getUserData(id, function(err, result) {
fn(result[some_data]);
});

Но как-бы организовать чтобы запрос к АПИ слался лишь один раз и все вызывающие функции ожидали пока придет ответ от неё?

Answer 1

[Александр Кит]

Deferred/Promise, реализаций данного шаблона очень много, но вот пример использования

var cache_ = {},
    Class = require('atma-class');

function getUserData(id, callback) {
    
    var dfr = cache_[id];
    if (dfr == null) {
        // делеаем запрос только с первым вызовом функции с этим id
        dfr = cache_[id] = new Class.Deferred();
        
        vk.api('users.get', {
            'user_ids': id,
            'fields': 'photo_100'
        }, function(err, result) {
            if (err)
                return dfr.fail(err);
    
            dfr.resolve(result.response[0]);
        });
    }
    
    // подписываемся на окончание загрузки, если же
    // загрузка уже завершилась(успешно или нет),
    // то callback вызывается сраюу
    dfr
        .done(function(response) {
            callback(null, response)
        })
        .fail(callback);

}

Comments

[Stricker]

Не совсем понял. Получается мы же не один раз обращаемся к функции и при каждом обращение получается будет при конструкции функции будет отсылаться запрос, так?

[Александр Кит]

Почитайте что такое `Promise`. Каждый раз когда когда вызываем функцию с одним и тем же id, то при первом вызове создается в данном случае `Deferred Object` и посылается запрос. Если же `Deferred Object` уже есть в кэше, тогда просто пидписываемся на результат. Извините вчера на скорую руку пример набросал, он был не правельным, сейчас кажется ничего не упустил)

[Stricker]

Огромное спасибо. Не могли бы вы показать пример на другой promise библиотеке? Я бы вашу с радостью использовал ваш модуль, но слишком уж много в ней функционала для меня помимо deferred, а вот что-то на другой библиотеках "deferred" и "Q" не получается такое сделать.

[Александр Кит]

Вот вытянул только `Deferred` класс:
gist:Deferred

A вот парочка библиотек со схожим функционалом:
jquery-deferred
node-promise

Будут вопросы - задавайте.

[Stricker]

Еще раз спасибо, вынес как модуль. Но вот все равно не пойму почему такое не выходит с Q и deferred либами, ибо по логике делаю тоже самое - Создаю deferred объект и выполняю resolve после получения ответа, ну и навешиваю так же через done слушателя. В случае с "Q" - слушатель никак не реагирует, а в случае с "deffered" -
так там вообще видимо можно работать с ней только извне, после возвращения promise.

Может быть знакомы с этими либами и подскажите чего -
https://github.com/medikoo/deferred
https://github.com/kriskowal/q

[Александр Кит]

Нет, к сожалению с данными либами сам не работал (