@@ -77,16 +77,16 @@ export function ConcurrencyQueue ({ axios, config }) {
77
77
request . data = transformFormData ( request )
78
78
}
79
79
if ( axios ?. oauth ?. accessToken ) {
80
- const isTokenExpired = axios . oauth . tokenExpiryTime && Date . now ( ) > axios . oauth . tokenExpiryTime ;
80
+ const isTokenExpired = axios . oauth . tokenExpiryTime && Date . now ( ) > axios . oauth . tokenExpiryTime
81
81
if ( isTokenExpired ) {
82
82
return refreshAccessToken ( ) . catch ( ( error ) => {
83
- throw new Error ( 'Failed to refresh access token: ' + error . message ) ;
84
- } ) ;
83
+ throw new Error ( 'Failed to refresh access token: ' + error . message )
84
+ } )
85
85
}
86
- }
87
-
86
+ }
87
+
88
88
request . retryCount = request ?. retryCount || 0
89
- setAuthorizationHeaders ( request ) ;
89
+ setAuthorizationHeaders ( request )
90
90
if ( request . cancelToken === undefined ) {
91
91
const source = Axios . CancelToken . source ( )
92
92
request . cancelToken = source . token
@@ -121,32 +121,31 @@ export function ConcurrencyQueue ({ axios, config }) {
121
121
request . authtoken = this . config . authtoken
122
122
} else if ( axios ?. oauth ?. accessToken ) {
123
123
// If OAuth access token is available in axios instance
124
- request . headers . authorization = `Bearer ${ axios . oauth . accessToken } ` ;
125
- request . authorization = `Bearer ${ axios . oauth . accessToken } ` ;
124
+ request . headers . authorization = `Bearer ${ axios . oauth . accessToken } `
125
+ request . authorization = `Bearer ${ axios . oauth . accessToken } `
126
126
delete request . headers . authtoken
127
127
}
128
128
}
129
129
130
- // Refresh Access Token
130
+ // Refresh Access Token
131
131
const refreshAccessToken = async ( ) => {
132
132
try {
133
133
// Try to refresh the token
134
- await new OAuthHandler ( axios ) . refreshAccessToken ( ) ;
135
- this . paused = false ; // Resume the request queue once the token is refreshed
134
+ await new OAuthHandler ( axios ) . refreshAccessToken ( )
135
+ this . paused = false // Resume the request queue once the token is refreshed
136
136
137
137
// Retry the requests that were pending due to token expiration
138
138
this . running . forEach ( ( { request, resolve, reject } ) => {
139
139
// Retry the request
140
- axios ( request ) . then ( resolve ) . catch ( reject ) ;
141
- } ) ;
142
- this . running = [ ] ; // Clear the running queue after retrying requests
140
+ axios ( request ) . then ( resolve ) . catch ( reject )
141
+ } )
142
+ this . running = [ ] // Clear the running queue after retrying requests
143
143
} catch ( error ) {
144
- this . paused = false ; // stop queueing requests on failure
145
- this . running . forEach ( ( { reject } ) => reject ( error ) ) ; // Reject all queued requests
146
- this . running = [ ] ; // Clear the running queue
144
+ this . paused = false // stop queueing requests on failure
145
+ this . running . forEach ( ( { reject } ) => reject ( error ) ) // Reject all queued requests
146
+ this . running = [ ] // Clear the running queue
147
147
}
148
148
}
149
-
150
149
151
150
const delay = ( time , isRefreshToken = false ) => {
152
151
if ( ! this . paused ) {
0 commit comments