sql >> Databáze >  >> NoSQL >> Redis

Express Node.JS - Příjem zpětného volání Redis, plnění slibů

Přišel jsem na to. K provedení všech funkcí jsem použil knihovnu Q namísto client.multi().exec(). To umožnilo čisté provedení všech příkazů redis post a pak mi umožnilo získat informace.

V souboru routes.js jsem měl jen krátký kousek kódu. Vše se provádí v souboru doctorDB.js.

routes.js

app.post('/addDoctorInfo', ensureLoggedIn('/login'), function(req, res, next){
        return doctorDB.addDoctor(req.body.id, req.body.doc, req, res, next);
});

doctorDB.js

var addDoctor = function addDoctor(id, doc, req, res, next){
    var fields = Object.keys(doc.fields);

    function middleName(id, doc){
        if (doc.middleName){ return client.hset(id, "middleName", doc.middleName); }
        else { return; }
    }

    return Q.all([Q.ninvoke(client, 'sadd', 'Doctors', id),
                    Q.ninvoke(client, 'hmset', id, "lastName", doc.lastName, "firstName", doc.firstName, "email", doc.email, "university", doc.university, "work", doc.work),
                    Q.ninvoke(client, 'sadd', id + ':fields', fields),
                    middleName(id, doc)]).then(function(x){
                        return getInfo(id, req, res, next);;
                    }, function (err) { res.status(404); });
};

To se předá funkci getInfo(), která odešle odpověď na stranu klienta:

var redisHGetAll = Q.nbind(client.hgetall, client);

var getInfo = function getInfo(id, req, res, next){
    return redisHGetAll(id).then(function(x){
        return findByMatchingProperties(x);
    }, function (err) { res.status(404); }).then(function(){
        return client.smembers(id + ':fields', function(err, reply){
            data['fields'] = reply;
            res.setHeader('Content-Type', 'application/json');
            res.end(JSON.stringify(data));
        });
    }, function (err) { res.status(404); })
};

function findByMatchingProperties(x) {
    for (var y in x){
        checkData(y, x[y]);
    }       

    function checkData(y, z){
        for (var d in data){
            if (d === y){
                data[d] = z;
            }
        }
    }
}

var data = {
    lastName: null,
    firstName: null,
    middleName: null,
    email: null,
    university: null,
    work: null,
    fields: null
};



  1. Nelze se připojit k serveru Redis pomocí poskytovatele stavu relace ASP.NET

  2. Limit hloubky pole vnořeného objektu MongoDB

  3. Jak zkontrolovat, zda je pole pole součástí jiného pole v MongoDB?

  4. Průměrné agregační dotazy v Meteoru