node.js - NodeJS/Express MVC 模式中的 REST 数据源

Question

在 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 controller/userTweets.js，在其中为 View 准备数据。

我们应该如何在我们的应用程序中包含 Twitter REST API 来处理这个用例？ (假设我们正在使用 Nodejs 客户端来实现 twitter api)

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

Answer 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 '使用严格'； 让 _ = 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

现在在路由方面，在你的 main 中，无论你的 server.js 是什么，将模块注入(inject)到 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.
});