authenticate.js
2.8 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
/*
* @Descripttion:
* @version: 0.0.0
* @Author: genglw
* @Date: 2022-01-21 15:31:14
* @LastEditors: genglw
* @LastEditTime: 2022-02-12 16:57:36
*/
var async = require('async');
exports = module.exports = function (logger, rest) {
function strategy(req, username, password, done) {
var user = {
refreshToken: "",
token: "",
yxly_token: "",
service_catalog: {},
user_info: {},
err: null
};
async.waterfall([
function (callback) {//get temp token
logger.debug("get temp token");
var tempParams = {
"grant_type": req.body.grant_type,
"username": req.body.username,
"scope": req.body.scope,
"password": req.body.password,
"img_code": req.body.img_code,
};
if (req.body.smscode)
tempParams['sms_code'] = req.body.smscode;
logger.debug("url:" + rest.getBaseUrl('auth/tokens', 'uaa'));
logger.debug("params", tempParams);
var url = rest.getBaseUrl('auth/tokens', 'uaa');
var headers = rest.addHeaders({ 'Content-Type': 'application/json', "Accept": "application/json" },req);
rest.restful.postJson(url, tempParams, {
headers: headers
})
.on('success', function (data, response) {
logger.debug("tokens-success", data);
if (data.access_token) {
user.token = data.access_token;
user.refreshToken = data.refresh_token;
user.user_info = {
'user': data.user,
'tenant': data.tenant,
'perms': [],
'scope': data.scope,
'oss': {}
};
user.service_catalog = data.service_catalog
callback(null, data)
} else {
var err = new Error('name or pass err');
user.err = data.message;
callback(err, data);
}
rest.proxyLog(data,response,req,{headers,'data':tempParams,url})
}).on('error', function (err, response) {
// logger.debug("tokens-error",data);
var err = new Error('name or pass err');
rest.proxyLog(err,response,req,{headers,'data':tempParams,url})
callback(err, response);
}).on('fail', function (data, response) {
logger.debug("tokens-fail", data);
var err = new Error('name or pass err');
rest.proxyLog(data,response,req,{headers,'data':tempParams,url})
callback(data, response);
});
}], function (err, result) {
if (err) {
return done(null, false, err);
} else {
return done(null, user);
}
});
}
function serializeUser(user, done) {
logger.debug("passport.serializeUser");
done(null, user);
}
function deserializeUser(user, done) {
var user = {
refreshToken: "",
token: "",
info: {},
err: null
};
logger.debug("passport.deserializeUser");
done(null, user);
}
return {
strategy: strategy,
serializeUser: serializeUser,
deserializeUser: deserializeUser
};
};
exports['@singleton'] = true;
exports['@require'] = ['igloo/logger', 'utils/rest'];