@@ -53,22 +53,20 @@ export class AzureServiceWorkflow extends ServiceWorkflow {
53
53
throw new MongoAzureError ( TOKEN_AUDIENCE_MISSING_ERROR ) ;
54
54
}
55
55
let token ;
56
- let response ;
57
56
const entry = this . cache . getEntry ( tokenAudience ) ;
58
57
if ( entry ?. isValid ( ) ) {
59
58
token = entry . token ;
60
59
} else {
61
60
this . cache . deleteEntry ( tokenAudience ) ;
62
- response = await getAzureTokenData ( tokenAudience ) ;
61
+ const response = await getAzureTokenData ( tokenAudience ) ;
62
+ if ( isEndpointResultInvalid ( response ) ) {
63
+ throw new MongoAzureError ( ENDPOINT_RESULT_ERROR ) ;
64
+ }
63
65
console . log ( 'response' , response ) ;
64
66
this . cache . addEntry ( tokenAudience , response ) ;
65
67
token = response . access_token ;
66
68
}
67
69
console . log ( 'token' , token ) ;
68
- if ( isEndpointResultInvalid ( response ) ) {
69
- this . cache . deleteEntry ( tokenAudience ) ;
70
- throw new MongoAzureError ( ENDPOINT_RESULT_ERROR ) ;
71
- }
72
70
return token ;
73
71
}
74
72
}
@@ -92,8 +90,6 @@ async function getAzureTokenData(tokenAudience: string): Promise<AzureAccessToke
92
90
* the expires_in required field.
93
91
*/
94
92
function isEndpointResultInvalid ( token : unknown ) : boolean {
95
- console . log ( 'token in validation' , token ) ;
96
93
if ( token == null || typeof token !== 'object' ) return true ;
97
- console . log ( 'test' , 'access_token' in token , 'expires_in' in token ) ;
98
94
return ! ( 'access_token' in token ) && ! ( 'expires_in' in token ) ;
99
95
}
0 commit comments