【发布时间】:2017-10-24 02:59:25
【问题描述】:
有人可以解释一下服务创建是如何工作的吗?经过数小时碰壁后接收 JSON 对象超出了我的预期;我为 before 钩子提供了这段代码,它至少给了我一个 JSON 对象,而不是前一个的 404 错误。然而,正如我之前所描述的,无论在操作数据之前或之后是什么钩子,我在服务创建函数中放入的任何内容都会返回。
服务代码现在是这个:
module.exports = function () {
const app = this;
// Initialize our service with any options it requires
app.use('/v1/login',{
create(data, params){
console.log("creating service");
return Promise.resolve(data); // data or params or whatever is returned to the REST ignoring any modification done via hooks
}
});
// Get our initialized service so that we can register hooks and filters
const service = app.service('/v1/login');
service.hooks(hooks);
if (service.filter) {
service.filter(filters);
}
};
钩子文件是一样的,之后钩子(登录)现在是这样的:
const errors = require('feathers-errors');
const jwt = require('feathers-authentication-jwt');
const ExtractJwt = require('passport-jwt').ExtractJwt;
const moment = require('moment');
module.exports = function () {
return function (hook) {
if (hook.type !== 'before') {
throw new errors.Unprocessable('This hook should only be used as before hook.');
}
const sequelizeClient = hook.app.get('sequelizeClient');
sequelizeClient.query('SELECT to_jsonb(login_user($app::varchar, $usr::varchar, $pwd::varchar)) resultcode',
{ bind: { app: hook.data.app, usr: hook.data.usr, pwd: hook.data.pwd },
type: sequelizeClient.QueryTypes.SELECT }
).then(login => {
if (login[0].resultcode.loginStatus !== 0){
throw new errors.NotAuthenticated(login[0].resultcode.message);
}else if(login[0].resultcode.sessionId !== null){
delete hook.data.usr;
delete hook.data.pwd;
hook.data.resultcode = login[0].resultcode;
var payload = { 'iss': 'feathers',
'sub': hook.data.resultcode.sessionId,
'aud': 'localhost',
'rol': hook.data.resultcode.rol,
'nbf': moment(),
'iet': moment(),
'jti': hook.data.resultcode.nonce
};
var opts = {
name: 'jwt',
entity: 'sessions',
service: 'sessions',
passReqToCallback: true,
session: false
};
opts.jwtFromRequest = [ExtractJwt.fromAuthHeader(),
ExtractJwt.fromAuthHeaderWithScheme('Bearer'),
ExtractJwt.fromBodyField('body')
];
opts.secret = hook.data.resultcode.message;
hook.app.passport.createJWT(payload, opts)
.then( jwtResult => {
hook.result = { "token": jwtResult };
return hook;
})
.catch(error => {
console.log("JWT-ERROR: "+error);
throw new errors.GeneralError('Error generating jwt. Login failed');
});
}else{
console.log("ERROR: No session created");
throw new errors.GeneralError('Session cannot be created');
}
}).catch(error => {
console.log("ERROR: "+error);
throw new errors.GeneralError('Database error');
});
};
};
正如我所说,返回的是服务创建方法中接收到的参数。有没有办法摆脱服务创建的第二个参数?,我试过了,但是随后出现了一个错误,期望中间件函数出现。我做错了什么或者我误解了钩子(我认为它们在返回到 REST 客户端之前会操纵数据和参数,但似乎不是这样。请解释一下。我是使用羽毛的新手. 我希望实现第 161 页“专业提示:hook.result 也可以设置在之前的钩子中,这将 跳过服务方法调用(但运行所有其他钩子)”中所写的内容。 ,但直到现在还没有运气。我错过了其他任何方式或条件吗?
更新,还没有运气
我看到了身份验证服务代码,我尝试做类似的事情,它们实际上返回创建令牌的 JWT 承诺,并在内部返回 JSON 中的令牌,所以我将所有过程都放在服务创建中(有或没有挂钩相同的结果没有返回任何东西
const errors = require('feathers-errors');
const jwt = require('feathers-authentication-jwt');
const ExtractJwt = require('passport-jwt').ExtractJwt;
const moment = require('moment');
const hooks = require('./login.hooks'); //optional the only hook on create is to validate that params user and password are present
const filters = require('./login.filters');
module.exports = function () {
const app = this;
// Initialize our service with any options it requires
app.use('/v1/login',{
create(data, params){
console.log("creating service");
const sequelizeClient = app.get('sequelizeClient');
var modelSession = sequelizeClient.query('SELECT to_jsonb(login_user($app::varchar, $usr::varchar, $pwd::varchar)) resultcode',
{ bind: { app: data.app, usr: data.usr, pwd: data.pwd, cte: params.headers },
type: sequelizeClient.QueryTypes.SELECT }
).then(login => {
if (login[0].resultcode.login_status !== 0){
throw new errors.NotAuthenticated(login[0].resultcode.pmessage);
}else if(login[0].resultcode.sessionId !== null){
delete data.usr;
delete data.pwd;
data.resultcode = login[0].resultcode;
var payload = { 'iss': 'feathers',
'sub': data.resultcode.sessionId,
'aud': 'localhost',
'rol': data.resultcode.rol,
'nbf': moment(),
'iet': moment(),
'jti': data.resultcode.nonce
};
var opts = {
name: 'jwt',
entity: 'sessions',
service: 'sessions',
passReqToCallback: false, // to avoid verification
session: false
};
opts.jwtFromRequest = [ExtractJwt.fromAuthHeader(),
ExtractJwt.fromAuthHeaderWithScheme('Bearer'),
ExtractJwt.fromBodyField('body')
];
opts.secret = 'secret';
return app.passport.createJWT(pload, opts)
.then( function(jwtResult) { // mimic of authentication service, but less sophisticated
delete data.resultcode;
return { token: jwtResult }; // expected result, but nothing is received
})
.catch(error => {
console.log("JWT-ERROR: "+error);
throw new errors.GeneralError('Error generating jwt. Login failed');
});
}
}).catch(error => {
console.log("ERROR: "+error);
throw new errors.GeneralError('Database error');
});
}
});
// Get our initialized service so that we can register hooks and filters
const service = app.service('/v1/login');
service.hooks(hooks); //This line can be commented out
if (service.filter) {
service.filter(filters);
}
};
钩子是这样的
module.exports = {
before: {
all: [],
find: [ disallow() ],
get: [ disallow() ],
create: [ validateLoginParams() ], // just to see if the params are truthy
update: [ disallow(), disableMultiItemChange() ],
patch: [ disallow(), disableMultiItemChange() ],
remove: [ disallow(), disableMultiItemChange() ]
},
... //All is as in default, so empty brackets ;-)
}
项目是使用feathers-cli和feathers Auk创建的,这是相关的json包
"dependencies": {
"body-parser": "^1.17.2",
"compression": "^1.6.2",
"cors": "^2.8.3",
"feathers": "^2.1.2",
"feathers-authentication": "^1.2.3",
"feathers-authentication-hooks": "^0.1.3",
"feathers-authentication-jwt": "^0.3.1",
"feathers-authentication-local": "^0.3.4",
"feathers-authentication-oauth2": "^0.2.4",
"feathers-configuration": "^0.4.1",
"feathers-errors": "^2.8.0",
"feathers-hooks": "^2.0.1",
"feathers-hooks-common": "^3.3.2",
"feathers-rest": "^1.7.2",
"feathers-sequelize": "^2.0.0",
"feathers-socketio": "^1.6.0",
"helmet": "^3.6.0", ...
我正在使用 feathersjs 两到三周,开始一个新项目,并且似乎是一个很好的 REST JavaScript 框架,我希望在未来的版本中使用 TypeScript,就像在 angular2 中一样(对我来说更清晰的代码)。我希望很快能看到解决这个问题的方法,或者有人指出我在哪里犯了错误,或者如果我明确不了解如何使用羽毛或用于其目的。
【问题讨论】:
-
我认为没有人会阅读所有
:-)。你能去掉最后的答案,把它移到一个答案块,然后删除问题开头的评论,指的是里面的答案吗?这看起来像是一个隐藏在其中的问题的答案,并且相当混乱,这反过来又面临关闭的风险。我们也不会在这里使用 [已解决的] 设备,因为我们有一个完整的验收系统。谢谢。 -
@halfer,是的,我想提供尽可能多的信息,但你有理由。最后我删掉了第一部分和所有不相关的代码。希望现在更好并且仍然有用。感谢您的评论。
-
请不要在您的问题中回答问题或在您的标题中添加“已解决”。下一次,创建您自己的答案。我已在此处将您的答案添加为社区 wiki;感到被鼓励接受它。
标签: json rest angular feathersjs