salix/back/methods/vn-user/renew-token.js

63 lines
2.0 KiB
JavaScript
Raw Normal View History

const {models} = require('vn-loopback/server/server');
module.exports = Self => {
Self.remoteMethodCtx('renewToken', {
description: 'Checks if the token has more than renewPeriod seconds to live and if so, renews it',
2023-06-21 12:12:42 +00:00
accessType: 'WRITE',
accepts: [],
returns: {
type: 'Object',
root: true
},
http: {
path: `/renewToken`,
verb: 'POST'
},
accessScopes: ['DEFAULT', 'read:multimedia']});
Self.renewToken = async function(ctx) {
let createTokenOptions = {};
let token; let isNotExceeded;
2024-06-20 11:49:25 +00:00
try {
token = ctx.req.accessToken;
2024-06-20 11:49:25 +00:00
const {courtesyTime} = await models.AccessTokenConfig.findOne({
fields: ['courtesyTime']
});
isNotExceeded = await Self.validateToken(ctx);
2024-06-20 11:49:25 +00:00
if (isNotExceeded)
return token;
2024-06-20 11:49:25 +00:00
// Schedule to remove current token
2024-08-26 10:04:03 +00:00
setTimeout(() => {
Self.logout(token.id);
2024-06-20 11:49:25 +00:00
}, courtesyTime * 1000);
2024-06-20 11:49:25 +00:00
// Get scopes
const {scopes} = token;
if (scopes)
createTokenOptions = {scopes: [scopes[0]]};
// Create new accessToken
const user = await Self.findById(token.userId);
const accessToken = await user.accessTokens.create(createTokenOptions);
2024-06-20 11:49:25 +00:00
return {id: accessToken.id, ttl: accessToken.ttl};
} catch (error) {
2024-08-26 10:04:03 +00:00
const body = {
error: error.message,
userId: token?.userId ?? null,
token: token?.id,
scopes: token?.scopes,
createTokenOptions,
isNotExceeded
};
await handleError(JSON.stringify(body));
2024-06-20 11:49:25 +00:00
throw new Error(error);
}
};
};
2024-06-20 11:49:25 +00:00
2024-08-26 10:04:03 +00:00
async function handleError(body) {
await models.Application.rawSql('CALL util.debugAdd(?,?);', ['renewToken', body]);
2024-06-20 11:49:25 +00:00
}