FeathersJS无模式服务不会返回预期的JSON对象



>有人可以解释一下服务创建的工作原理吗?经过几个小时的墙,接收 JSON 对象比我所期望的要多;我为之前的钩子提供了这段代码,它至少给了我一个 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 也可以在 beforehook 中设置的内容,这将跳过服务方法调用(但运行所有其他钩子)",但直到现在都没有运气。我错过了其他方式或条件吗?

更新,还没有运气

我看到了身份验证服务代码,我尝试做类似的事情,它们实际上返回了创建令牌的 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中一样(对我来说更清晰的代码)。我希望很快看到这个问题的解决方案,或者有人指出我在哪里犯了错误,或者如果我最终不明白如何使用羽毛或意图。

在仔细观察了羽毛中的身份验证代码以及如何使用 sequelize 创建其他服务后,我意识到问题从一开始就是尝试在不使用任何模型的情况下执行新服务。我阅读了这两个谷歌搜索的页面 https://github.com/feathersjs/feathers-hooks/issues/25 和 https://github.com/feathersjs/feathers/issues/351,但提到的解决方案都会导致一个不存在的页面。真正的问题是如何执行无模式服务,或者如何创建一个返回任何后端中不存在的资源的服务;换句话说,如何返回通过服务本身生成的资源。

答:不可能,除非你从头开始创建一个服务。话虽如此,我唯一的方法是使用内置的身份验证服务,但是如果您需要执行其他无模式的操作(不是身份验证,而是电子邮件注册,或者在服务中或直接从数据库中完成的过程的结果,但没有CRUD),您必须询问feathersjs的开发人员,(请帮助, 我很快就会需要其他非 CRUD 服务)。

最后我只是删除了默认钩子,更改的身份验证服务代码是这样的:

// to create a new valid JWT (e.g. local or oauth2)
app.service('/v1/authentication').hooks({
before: {
create: [
// authentication.hooks.authenticate(config.strategies),
validateLoginParams(),
login()
],
remove: [
authentication.hooks.authenticate('jwt')

登录钩子是整个代码,它返回带有结果的钩子,我得到了访问令牌 JSON 返回。现在我的问题是生成的令牌没有我设置的有效负载,而只有身份验证配置中不存在的那些部分。

感谢您花时间和耐心阅读此代码故事。希望这对其他新手有所帮助。