NodeJS/ Express MVC 模式中的 REST 数据源答案

【问题标题】：REST data source in NodeJS/ Express MVC PatternNodeJS/ Express MVC 模式中的 REST 数据源
【发布时间】：2015-09-18 13:49:11
【问题描述】：

在 Express MVC 应用程序中包含外部 REST 数据源的最佳做法是什么？我们应该为从外部 REST 源检索的实体创建模型吗？

让我们以这个实际的例子为例：

我们的出发点是使用 mongoose 进行 ODM 的 user.js 模型。

var mongoose = require('mongoose');

var userModel = function () {

    //Define a simple schema for our user.
    var userSchema = mongoose.Schema({
        name: String,
        twitterId: Number
    });


    return mongoose.model('User', userSchema);

};

module.exports = new userModel();

我们的目标是显示特定用户的所有推文，因此我们创建了一个控制器 controller/userTweets.js，在其中为我们的视图准备数据。

我们应该如何在我们的应用程序中包含 Twitter REST API 来处理这个用例？（假设我们正在为 twitter api 使用 nodejs 客户端）

我更愿意为推文实体使用特定模型，然后使用我们的模型从控制器中检索用户推文，但是我们的 tweet.js 模型应该是什么样子？或者我们应该以不同的方式设计我们的 REST API 集成？

【问题讨论】：

标签： node.js rest model-view-controller express kraken.js

【解决方案1】：

我会创建一个名为 Tweet 的类和一个相应的存储库。

假设你使用的是 es6，因为为什么不呢。

我们称之为tweets.js

'use strict';
module.exports = function (cfg) {
    class Tweet {
        constructor() {
            this.userid = null;
            this.text = null;
        }
    }

    class Repo {
        static getTweetsForUser(usedId) {
            // make a call to twitter api, use https://www.npmjs.com/package/request
            // psuedo code
            let _ = require('lodash');
            getTweets(userid, function (err, tweets) {
                return new Promise(function (resolve, reject) {
                    if (err) {
                        return reject(err);
                    }

                    let data = [],
                        tweet = new Tweet;

                    if (! tweets.length) {
                        return resolve(data);
                    }


                    resolve(_.collect(tweets, function (t) {
                        tweet.userId = userId;
                        tweet.text = t.getTheTweet;

                        return tweet;
                    }));
                });
            });
        }
    }

    return {
        'tweet': Tweet,
        'repo' : Repo
    }
}

// 导出任何模块，就像上面一样，我们称之为index.js '使用严格'; let _ = require('lodash');

let modules = [
    'tweets',
];

// cfg = any app configs that you might need in modules
function init(cfg) {
    let core = {};

    return _.collect(modules, function (m) {
        core[m] = require('./' + m)(cfg);
    });
}

module.exports = init;

示例 - https://github.com/swarajgiri/express-bootstrap/blob/master/core/index.js

现在在路由方面，无论您的 server.js 是什么，将模块注入到 express() 的实例中

app.set('core', require('path/to/core/index')(whateverConfigYouMightNeed))

完成后，您的路线可能看起来像

'use strict'
let wrap = require('co-wrap');
route.get(':userId/tweets'), wrap(function* (req, res, next) {
    let tweets = [];

    try {
        tweets = yield req.app.get('core').tweets.Repo.getTweetsForUser(req.params.userId)
    } catch(e) {
        // let the common error handler do its job.
        return next(e);
    }

    // render whatever view you want.
});

【讨论】：