update refres and access token added
This commit is contained in:
parent
036b47235a
commit
1dae751ce4
@ -56,7 +56,7 @@ async function exchangeZohoToken(req, res) {
|
||||
const { access_token, refresh_token, expires_in } = data;
|
||||
|
||||
const expiresAt = expires_in ? new Date(Date.now() + expires_in * 1000) : null;
|
||||
await userAuthTokenRepo.createToken({
|
||||
await userAuthTokenRepo.upsertToken({
|
||||
userId: id,
|
||||
serviceName: service_name,
|
||||
accessToken: encrypt(access_token),
|
||||
|
||||
@ -8,6 +8,18 @@ async function findByUserAndService(userId, serviceName) {
|
||||
return UserAuthToken.findOne({ where: { userId, serviceName } });
|
||||
}
|
||||
|
||||
module.exports = { createToken, findByUserAndService };
|
||||
async function upsertToken(payload) {
|
||||
const { userId, serviceName } = payload;
|
||||
const [token, created] = await UserAuthToken.findOrCreate({
|
||||
where: { userId, serviceName },
|
||||
defaults: payload
|
||||
});
|
||||
if (!created) {
|
||||
await token.update(payload);
|
||||
}
|
||||
return token;
|
||||
}
|
||||
|
||||
module.exports = { createToken, findByUserAndService, upsertToken };
|
||||
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user