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

@@ -16,29 +16,34 @@ module.exports = Self => {
         accessScopes: ['DEFAULT', 'read:multimedia']});
 
     Self.renewToken = async function(ctx) {
-        const {accessToken: token} = ctx.req;
+        let createTokenOptions = {};
+        let token; let isNotExceeded;
+        try {
+            token = ctx.req.accessToken;
 
             const {courtesyTime} = await models.AccessTokenConfig.findOne({
                 fields: ['courtesyTime']
             });
-        const isNotExceeded = await Self.validateToken(ctx);
+            isNotExceeded = await Self.validateToken(ctx);
             if (isNotExceeded)
                 return token;
 
             // Schedule to remove current token
             setTimeout(async() => {
+                let exists;
                 try {
-                const exists = await models.AccessToken.findById(token.id);
+                    exists = await models.AccessToken.findById(token.id);
                     exists && await Self.logout(token.id);
-            } catch (err) {
+                } catch (error) {
                 // eslint-disable-next-line no-console
-                console.error(err);
+                    console.error(error);
+                    const body = {error: error.message, now: Date.now(), userId: token?.userId ?? null, exists};
+                    await handleError(body);
+                    throw new Error(error);
                 }
             }, courtesyTime * 1000);
 
             // Get scopes
-
-        let createTokenOptions = {};
             const {scopes} = token;
             if (scopes)
                 createTokenOptions = {scopes: [scopes[0]]};
@@ -47,5 +52,15 @@ module.exports = Self => {
             const accessToken = await user.accessTokens.create(createTokenOptions);
 
             return {id: accessToken.id, ttl: accessToken.ttl};
+        } catch (error) {
+            const body = {error: error.message, now: Date.now(), userId: token?.userId ?? null, createTokenOptions, isNotExceeded};
+            await handleError(body);
+            throw new Error(error);
+        }
     };
 };
+
+async function handleError(body, tag = 'renewToken') {
+    body = JSON.stringify(body);
+    await models.Application.rawSql('CALL util.debugAdd(?,?);', [tag, body]);
+}

back/methods/vn-user/specs/renew-token.spec.js

@@ -61,4 +61,21 @@ describe('Renew Token', () => {
         expect(error).toBeUndefined();
         expect(response.id).toEqual(ctx.req.accessToken.id);
     });
+
+    it('throw error', async() => {
+        let error;
+
+        try {
+            await models.VnUser.renewToken({req: {token: null}});
+        } catch (e) {
+            error = e;
+        }
+
+        expect(error).toBeDefined();
+        const query = 'SELECT * FROM util.debug';
+
+        const debugLog = await models.Application.rawSql(query, null);
+
+        expect(debugLog.length).toEqual(1);
+    });
 });