在项目的当前状态下,你想要做什么并不容易,而且有点混乱。我指的是 v0.10 版本。你需要做的是
SimplePlugin.SimpleModel
将在sails.models中找到的模型定义注入
- 为模型注入一个虚拟控制器
_config: { rest: true }
请注意,我发布的代码示例取自我正在处理的自定义 Sails 挂钩,并假设在Sails 初始化阶段/该阶段之前sails
可以访问和执行代码示例(比较:lib/app/load.js)。loadHooks
MiddlewareRegistry
1.注入模型定义
按照 Sails v0.10 中的提示,orm
您必须:
- 获取中定义的模型和适配器
api
,将新模型合并到字典中
- 通过规范化模型定义
sails.hooks.orm.normalizeModelDef
- 将规范化的模型定义加载到 Waterline
- 通过卸载现有的适配器连接
teardown
- 重新初始化水线
sails.hooks.orm.prepareModels
通过(以前:sails.hooks.orm.exposeModels
,更改为:8d96895662)将初始化的 Waterline 集合公开给帆和全局范围
因为您必须重新初始化 Waterline 并重新加载所有模型定义,所以我建议收集所有模型定义以注入并将它们传递给注入函数一次。下面的示例代码反映了这一点。
...
function injectPluginModels(pluginModels, cb) {
// copy sails/lib/hooks/orm/loadUserModules to make it accessible here
var loadUserModelsAndAdapters = require('./loadUserModules')(sails);
async.auto({
// 1. load api/models, api/adapters
_loadModules: loadUserModelsAndAdapters,
// 2. Merge additional models, 3. normalize model definitions
modelDefs: ['_loadModules', function(next){
_.each(additionModels, function(aditionModel) {
_.merge(sails.models, additionalModel);
});
_.each(sails.models, sails.hooks.orm.normalizeModelDef);
next(null, sails.models);
}],
// 4. Load models into waterline, 5. tear down connections, 6. reinitialize waterline
instantiatedCollections: ['modelDefs', function(next, stack){
var modelDefs = stack.modelDefs;
var waterline = new Waterline();
_.each(modelDefs, function(modelDef, modelID){
waterline.loadCollection(Waterline.Collection.extend(modelDef));
});
var connections = {};
_.each(sails.adapters, function(adapter, adapterKey) {
_.each(sails.config.connections, function(connection, connectionKey) {
if (adapterKey !== connection.adapter) return;
connections[connectionKey] = connection;
});
});
var toTearDown = [];
_.each(connections, function(connection, connectionKey) {
toTearDown.push({ adapter: connection.adapter, connection: connectionKey });
});
async.each(toTearDown, function(tear, callback) {
sails.adapters[tear.adapter].teardown(tear.connection, callback);
}, function(){
waterline.initialize({
adapters: sails.adapters,
connections: connections
}, next)
});
}],
// 7. Expose initialized models to global scope and sails
_prepareModels: ['instantiatedCollections', sails.hooks.orm.prepareModels]
}, cb);
};
...
将允许您:
// Read your plugins
...
var pluginModels = // Get all the plugin models
injectPluginModels(pluginModels, function(){
// Plugin models now available via global[pluginModel.globalId] and sails.models[pluginModel.identity]
});
2.注入控制器
对于应该通过蓝图方法公开的每个模型,您必须:
- 创建具有匹配标识和启用蓝图的控制器定义
- 将控制器保存到
sails.controllers[controllerId]
- 将控制器保存到
sails.hooks.controllers.middleware[controllerId]
SailsMiddlewareRegistry
将自动拾取在这些对象中找到的控制器。
function mountBlueprintsForModels(pluginModels) {
_.each(pluginModels, function(pluginModel){
var controller = _.cloneDeep(pluginModel);
controller._config = { rest: true };
var controllerId = pluginModel.identity;
if (!_.isObject(sails.controllers[controllerId])) {
sails.controllers[controllerId] = controller;
}
if (!_.isObject(sails.hooks.controllers.middleware[controllerId])) {
sails.hooks.controllers.middleware[controllerId] = controller;
}
});
}
3. 在行动
// E.g. in /api/hooks/plugins/index.js
/*
* Module dependencies
*/
var async = require('async'),
_ = require('lodash'),
waterline = require('waterline');
module.exports = function(sails) {
// injectPluginModels and mountBlueprintsForModels defined here
...
return {
initialize: function(cb) {
sails.after('hook:orm:loaded', function() {
yourNiftyPluginLoader(function(err, plugins) {
// assuming plugin.models holds array of models for this plugin
// customize for your use case
var pluginModels = _.pluck(plugins, 'models');
injectPluginModels(pluginModels, cb);
mountBlueprintsForModels(pluginModels);
});
});
}
}
}