add more logs

CloudEcosystemDev · Aug 22, 2023 · 230e002 · 230e002
1 parent 83ffa31
commit 230e002
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/services/secret-service/src/auth-flow-manager/index.js b/services/secret-service/src/auth-flow-manager/index.js
@@ -9,7 +9,7 @@ const { OA2_AUTHORIZATION_CODE, OA1_THREE_LEGGED, SESSION_AUTH } = require('../c
 const { HEADER_AUTH, BODY_AUTH, PARAMS_AUTH } = require('../constant').AUTH_REQUEST_TYPE;
 const defaultAdapter = require('../adapter/preprocessor/default');
 
-const log = logger.getLogger(`${conf.log.namespace}/auth-flow-manager`);
+const log = logger.getLogger(`${conf.log.namespace}/auth-flow-manager`, { json: true });
 
 class HTTPResponseError extends Error {
     constructor(response, ...args) {
@@ -240,7 +240,10 @@ module.exports = {
         }
     },
     async refresh(authClient, secret) {
-        log.debug(`Refreshing auth ${secret && secret._id ? secret._id : ''} client id: ${authClient && authClient._id ? authClient._id : ''}`);
+        log.debug(`Refreshing secret ${secret && secret._id ? secret._id : ''} via auth client id: ${authClient && authClient._id ? authClient._id : ''}`, {
+            secretId: secret._id,
+            authClientId: authClient._id
+        });
         switch (authClient.type) {
         case OA2_AUTHORIZATION_CODE: {
             const { clientId, clientSecret, refreshWithScope } = authClient;

diff --git a/services/secret-service/src/dao/secret.js b/services/secret-service/src/dao/secret.js
@@ -16,6 +16,8 @@ const CONSTANTS = require('../constant');
 
 const auditLog = Logger.getAuditLogger(`${conf.log.namespace}/secretDao`);
 
+const log = Logger.getLogger(`${conf.log.namespace}/secretDao`, { json: true });
+
 // retry refresh procedure after ms
 const waitBeforeRetry = 1000;
 const MAX_RETRY = 3;
@@ -72,11 +74,13 @@ function refreshToken(secret) {
         try {
             const authClient = await AuthClientDAO.findById(secret.value.authClientId);
 
+            log.debug('About to refresh secret', { secretId: secret._id, authClientId: authClient._id });
             resolve(await authFlowManager.refresh(
                 authClient,
                 secret,
             ));
         } catch (err) {
+            log.error('Failed to refresh secret', { secretId: secret._id, authClientId: authClient._id, err });
             reject(err);
         }
     });