New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
intuit-oauth
Advanced tools
intuit-oauth - npm Package Compare versions
Comparing version 1.3.0 to 1.4.0
| { | ||
| "name": "intuit-oauth", | ||
| "version": "1.3.0", | ||
| "version": "1.4.0", | ||
| "description": "Intuit Node.js client for OAuth2.0 and OpenID", | ||
@@ -5,0 +5,0 @@ "main": "./src/OAuthClient.js", |
@@ -24,3 +24,2 @@ [][ss1] | ||
| - [Refresh Access_Token by passing the refresh_token explicitly](#refresh-access_token_explicitly) | ||
| - [Auto Refresh](#auto-refresh) | ||
| - [Revoke Access Token](#revoke-access_token) | ||
@@ -497,5 +496,2 @@ - [Getter / Setter for Token](#getter-/-setter-for-token ) | ||
| [ss1]: https://help.developer.intuit.com/s/SDKFeedback?cid=1120 | ||
| [ss1]: https://help.developer.intuit.com/s/SDKFeedback?cid=1120 |
@@ -33,13 +33,13 @@ /** | ||
| params = params || {}; | ||
| params = params || {}; | ||
| this.realmId = params.realmId || ''; | ||
| this.token_type = params.token_type || ''; | ||
| this.access_token = params.access_token || ''; | ||
| this.refresh_token = params.refresh_token || ''; | ||
| this.expires_in = params.expires_in || 0; | ||
| this.x_refresh_token_expires_in = params.x_refresh_token_expires_in || 0; | ||
| this.id_token = params.id_token || ''; | ||
| this.latency = params.latency || 60 * 1000; | ||
| this.createdAt = params.createdAt || Date.now(); | ||
| this.realmId = params.realmId || ''; | ||
| this.token_type = params.token_type || ''; | ||
| this.access_token = params.access_token || ''; | ||
| this.refresh_token = params.refresh_token || ''; | ||
| this.expires_in = params.expires_in || 0; | ||
| this.x_refresh_token_expires_in = params.x_refresh_token_expires_in || 0; | ||
| this.id_token = params.id_token || ''; | ||
| this.latency = params.latency || 60 * 1000; | ||
| this.createdAt = params.createdAt || Date.now(); | ||
| } | ||
@@ -52,3 +52,3 @@ | ||
| Token.prototype.accessToken = function() { | ||
| return this.getToken().access_token; | ||
| return this.getToken().access_token; | ||
| }; | ||
@@ -61,3 +61,3 @@ | ||
| Token.prototype.refreshToken = function() { | ||
| return this.getToken().refresh_token; | ||
| return this.getToken().refresh_token; | ||
| }; | ||
@@ -70,3 +70,3 @@ | ||
| Token.prototype.tokenType = function() { | ||
| return this.getToken().token_type; | ||
| return this.getToken().token_type; | ||
| }; | ||
@@ -81,12 +81,12 @@ | ||
| return { | ||
| token_type: this.token_type, | ||
| access_token: this.access_token, | ||
| expires_in: this.expires_in, | ||
| refresh_token: this.refresh_token, | ||
| x_refresh_token_expires_in: this.x_refresh_token_expires_in, | ||
| realmId: this.realmId, | ||
| id_token: this.id_token, | ||
| createdAt: this.createdAt | ||
| }; | ||
| return { | ||
| token_type: this.token_type, | ||
| access_token: this.access_token, | ||
| expires_in: this.expires_in, | ||
| refresh_token: this.refresh_token, | ||
| x_refresh_token_expires_in: this.x_refresh_token_expires_in, | ||
| realmId: this.realmId, | ||
| id_token: this.id_token, | ||
| createdAt: this.createdAt | ||
| }; | ||
@@ -102,10 +102,10 @@ }; | ||
| this.access_token = tokenData.access_token; | ||
| this.refresh_token = tokenData.refresh_token; | ||
| this.token_type = tokenData.token_type ; | ||
| this.expires_in = tokenData.expires_in; | ||
| this.x_refresh_token_expires_in = tokenData.x_refresh_token_expires_in; | ||
| this.id_token = tokenData.id_token || ''; | ||
| this.createdAt = tokenData.createdAt || Date.now(); | ||
| return this; | ||
| this.access_token = tokenData.access_token; | ||
| this.refresh_token = tokenData.refresh_token; | ||
| this.token_type = tokenData.token_type ; | ||
| this.expires_in = tokenData.expires_in; | ||
| this.x_refresh_token_expires_in = tokenData.x_refresh_token_expires_in; | ||
| this.id_token = tokenData.id_token || ''; | ||
| this.createdAt = tokenData.createdAt || Date.now(); | ||
| return this; | ||
@@ -115,2 +115,18 @@ }; | ||
| /** | ||
| * Helper Method to clear accessToken { clear Token Object } | ||
| * @param | ||
| * @returns {Token} | ||
| */ | ||
| Token.prototype.clearToken = function() { | ||
| this.access_token = ''; | ||
| this.refresh_token = ''; | ||
| this.token_type = ''; | ||
| this.expires_in = 0; | ||
| this.x_refresh_token_expires_in = 0; | ||
| this.id_token = ''; | ||
| this.createdAt = 0; | ||
| return this; | ||
| } | ||
| /** | ||
| * Helper Method to check token expiry { set Token Object } | ||
@@ -121,4 +137,4 @@ * @param seconds | ||
| Token.prototype._checkExpiry = function(seconds) { | ||
| var expiry = this.createdAt + (seconds * 1000); | ||
| return (expiry - this.latency > Date.now()); | ||
| var expiry = this.createdAt + (seconds * 1000); | ||
| return (expiry - this.latency > Date.now()); | ||
| } | ||
@@ -131,3 +147,3 @@ | ||
| Token.prototype.isAccessTokenValid = function() { | ||
| return this._checkExpiry(this.expires_in); | ||
| return this._checkExpiry(this.expires_in); | ||
| }; | ||
@@ -140,5 +156,5 @@ | ||
| Token.prototype.isRefreshTokenValid = function() { | ||
| return this._checkExpiry(this.x_refresh_token_expires_in); | ||
| return this._checkExpiry(this.x_refresh_token_expires_in); | ||
| }; | ||
| module.exports = Token; |
@@ -49,27 +49,27 @@ /** | ||
| this.environment = config.environment; | ||
| this.clientId = config.clientId; | ||
| this.clientSecret = config.clientSecret; | ||
| this.redirectUri = config.redirectUri; | ||
| this.token = new Token(config.token); | ||
| this.logging = config.hasOwnProperty('logging') && config.logging == true ? true : false; | ||
| this.logger = null; | ||
| this.environment = config.environment; | ||
| this.clientId = config.clientId; | ||
| this.clientSecret = config.clientSecret; | ||
| this.redirectUri = config.redirectUri; | ||
| this.token = new Token(config.token); | ||
| this.logging = config.hasOwnProperty('logging') && config.logging == true ? true : false; | ||
| this.logger = null; | ||
| if(this.logging) { | ||
| if(this.logging) { | ||
| var dir = './logs'; | ||
| if (!fs.existsSync(dir)){ | ||
| fs.mkdirSync(dir); | ||
| } | ||
| this.logger = winston.createLogger({ | ||
| level: 'info', | ||
| format: winston.format.combine( | ||
| winston.format.timestamp(), | ||
| winston.format.printf(info => { | ||
| return `${info.timestamp} ${info.level}: ${info.message}`; | ||
| }) | ||
| ), | ||
| transports: [new winston.transports.File({filename: path.join(dir , 'oAuthClient-log.log')})] | ||
| }); | ||
| var dir = './logs'; | ||
| if (!fs.existsSync(dir)){ | ||
| fs.mkdirSync(dir); | ||
| } | ||
| this.logger = winston.createLogger({ | ||
| level: 'info', | ||
| format: winston.format.combine( | ||
| winston.format.timestamp(), | ||
| winston.format.printf(info => { | ||
| return `${info.timestamp} ${info.level}: ${info.message}`; | ||
| }) | ||
| ), | ||
| transports: [new winston.transports.File({filename: path.join(dir , 'oAuthClient-log.log')})] | ||
| }); | ||
| } | ||
| } | ||
@@ -111,17 +111,17 @@ | ||
| params = params || {}; | ||
| params = params || {}; | ||
| // check if the scopes is provided | ||
| if(!params.scope) throw new Error('Provide the scopes'); | ||
| // check if the scopes is provided | ||
| if(!params.scope) throw new Error('Provide the scopes'); | ||
| var authorizeUri = OAuthClient.authorizeEndpoint + '?' + queryString.stringify({ | ||
| 'response_type': 'code', | ||
| 'redirect_uri': this.redirectUri , | ||
| 'client_id': this.clientId, | ||
| 'scope': (Array.isArray(params.scope)) ? params.scope.join(' ') : params.scope, | ||
| 'state': params.state || csrf.create(csrf.secretSync()) | ||
| }); | ||
| var authorizeUri = OAuthClient.authorizeEndpoint + '?' + queryString.stringify({ | ||
| 'response_type': 'code', | ||
| 'redirect_uri': this.redirectUri , | ||
| 'client_id': this.clientId, | ||
| 'scope': (Array.isArray(params.scope)) ? params.scope.join(' ') : params.scope, | ||
| 'state': params.state || csrf.create(csrf.secretSync()) | ||
| }); | ||
| this.log('info','The Authorize Uri is :',authorizeUri); | ||
| return authorizeUri; | ||
| this.log('info','The Authorize Uri is :',authorizeUri); | ||
| return authorizeUri; | ||
@@ -138,44 +138,44 @@ }; | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| if(!uri) throw new Error('Provide the Uri'); | ||
| var params = queryString.parse(uri.split('?').reverse()[0]); | ||
| this.getToken().realmId = (params['realmId'] ? params['realmId'] : ''); | ||
| if(!uri) throw new Error('Provide the Uri'); | ||
| var params = queryString.parse(uri.split('?').reverse()[0]); | ||
| this.getToken().realmId = (params['realmId'] ? params['realmId'] : ''); | ||
| var body = {}; | ||
| if (params.code) { | ||
| var body = {}; | ||
| if (params.code) { | ||
| body.grant_type = 'authorization_code'; | ||
| body.code = params.code; | ||
| body.redirect_uri = params.redirectUri || this.redirectUri; | ||
| } | ||
| body.grant_type = 'authorization_code'; | ||
| body.code = params.code; | ||
| body.redirect_uri = params.redirectUri || this.redirectUri; | ||
| } | ||
| var request = { | ||
| url: OAuthClient.tokenEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Content-Type': AuthResponse._urlencodedContentType, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: OAuthClient.tokenEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Content-Type': AuthResponse._urlencodedContentType, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(res) { | ||
| }.bind(this))).then(function(res) { | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','Create Token response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','Create Token response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','Create Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','Create Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -192,42 +192,42 @@ }; | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| /** | ||
| * Check if the tokens exist and are valid | ||
| */ | ||
| this.validateToken(); | ||
| /** | ||
| * Check if the tokens exist and are valid | ||
| */ | ||
| this.validateToken(); | ||
| var body = {}; | ||
| var body = {}; | ||
| body.grant_type = 'refresh_token'; | ||
| body.refresh_token = this.getToken().refresh_token; | ||
| body.grant_type = 'refresh_token'; | ||
| body.refresh_token = this.getToken().refresh_token; | ||
| var request = { | ||
| url: OAuthClient.tokenEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Content-Type': AuthResponse._urlencodedContentType, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: OAuthClient.tokenEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Content-Type': AuthResponse._urlencodedContentType, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(res) { | ||
| }.bind(this))).then(function(res) { | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','Refresh Token () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','Refresh Token () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','Refresh Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','Refresh Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -239,3 +239,3 @@ }; | ||
| * Refresh Tokens by passing refresh_token parameter explicitly { Refresh access_token by passing refresh_token } | ||
| * @param {Object} params.refresh_token (optional) | ||
| * @param {Object} params.refresh_token (refresh_token) | ||
| * @returns {Promise<AuthResponse>} | ||
@@ -299,37 +299,37 @@ */ | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| params = params || {}; | ||
| params = params || {}; | ||
| var body = {}; | ||
| var body = {}; | ||
| body.token = params.access_token || params.refresh_token || (this.getToken().isAccessTokenValid() ? this.getToken().access_token : this.getToken().refresh_token); | ||
| body.token = params.access_token || params.refresh_token || (this.getToken().isAccessTokenValid() ? this.getToken().access_token : this.getToken().refresh_token); | ||
| var request = { | ||
| url: OAuthClient.revokeEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'Content-Type': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: OAuthClient.revokeEndpoint, | ||
| body: body, | ||
| method: 'POST', | ||
| headers: { | ||
| 'Authorization': 'Basic ' + this.authHeader(), | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'Content-Type': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(authResponse) { | ||
| }.bind(this))).then(function(authResponse) { | ||
| this.token.clearToken(); | ||
| this.log('info','Revoke Token () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| this.log('info','Revoke Token () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','Revoke Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','Revoke Token () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
| }; | ||
@@ -344,30 +344,30 @@ | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| params = params || {}; | ||
| params = params || {}; | ||
| var request = { | ||
| url: this.environment == 'sandbox' ? OAuthClient.userinfo_endpoint_sandbox : OAuthClient.userinfo_endpoint_production, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Authorization': 'Bearer ' + this.token.access_token, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: this.environment == 'sandbox' ? OAuthClient.userinfo_endpoint_sandbox : OAuthClient.userinfo_endpoint_production, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Authorization': 'Bearer ' + this.token.access_token, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(res) { | ||
| }.bind(this))).then(function(res) { | ||
| var authResponse = res.json ? res : null; | ||
| this.log('info','The Get User Info () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| var authResponse = res.json ? res : null; | ||
| this.log('info','The Get User Info () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','Get User Info () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','Get User Info () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -383,29 +383,29 @@ }; | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| params = params || {}; | ||
| params = params || {}; | ||
| var request = { | ||
| url: params.url, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Authorization': 'Bearer ' + this.getToken().access_token, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: params.url, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Authorization': 'Bearer ' + this.getToken().access_token, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(authResponse) { | ||
| }.bind(this))).then(function(authResponse) { | ||
| this.log('info','The makeAPICall () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| this.log('info','The makeAPICall () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','Get makeAPICall () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','Get makeAPICall () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -421,44 +421,44 @@ }; | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| params = params || {}; | ||
| params = params || {}; | ||
| var uri = this.environment.toLowerCase() == 'sandbox' ? OAuthClient.migrate_sandbox : OAuthClient.migrate_production; | ||
| var uri = this.environment.toLowerCase() == 'sandbox' ? OAuthClient.migrate_sandbox : OAuthClient.migrate_production; | ||
| var authHeader = this.generateOauth1Sign(objectAssign({}, {method: 'POST', uri: uri}, params)); | ||
| var authHeader = this.generateOauth1Sign(objectAssign({}, {method: 'POST', uri: uri}, params)); | ||
| var body = { | ||
| 'scope':(Array.isArray(params.scope)) ? params.scope.join(' ') : params.scope, | ||
| 'redirect_uri':this.redirectUri, | ||
| 'client_id': this.clientId, | ||
| 'client_secret': this.clientSecret | ||
| }; | ||
| var body = { | ||
| 'scope':(Array.isArray(params.scope)) ? params.scope.join(' ') : params.scope, | ||
| 'redirect_uri':this.redirectUri, | ||
| 'client_id': this.clientId, | ||
| 'client_secret': this.clientSecret | ||
| }; | ||
| var request = { | ||
| url: uri, | ||
| method: 'POST', | ||
| body: body, | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| 'Authorization': 'OAuth ' + authHeader, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: uri, | ||
| method: 'POST', | ||
| body: body, | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| 'Authorization': 'OAuth ' + authHeader, | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getTokenRequest(request)); | ||
| resolve(this.getTokenRequest(request)); | ||
| }.bind(this))).then(function(res) { | ||
| }.bind(this))).then(function(res) { | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','The migrate () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| var authResponse = res.json ? res : null; | ||
| var json = authResponse && authResponse.getJson() || res; | ||
| this.token.setToken(json); | ||
| this.log('info','The migrate () response is : ',JSON.stringify(authResponse, null, 2)); | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','The migrate () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','The migrate () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -476,34 +476,34 @@ | ||
| var timestamp = Math.round(new Date().getTime()/1000); | ||
| var timestamp = Math.round(new Date().getTime()/1000); | ||
| var parameters = { | ||
| oauth_consumer_key : params.oauth_consumer_key, | ||
| oauth_token : params.access_token, | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : timestamp, | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0' | ||
| }; | ||
| var parameters = { | ||
| oauth_consumer_key : params.oauth_consumer_key, | ||
| oauth_token : params.access_token, | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : timestamp, | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0' | ||
| }; | ||
| var encodedSignature = oauthSignature.generate (params.method, params.uri, parameters, params.oauth_consumer_secret, params.access_secret); | ||
| var encodedSignature = oauthSignature.generate (params.method, params.uri, parameters, params.oauth_consumer_secret, params.access_secret); | ||
| parameters ['oauth_signature'] = encodedSignature; | ||
| var keys = Object.keys(parameters); | ||
| var authHeader = ''; | ||
| parameters ['oauth_signature'] = encodedSignature; | ||
| var keys = Object.keys(parameters); | ||
| var authHeader = ''; | ||
| for (key in parameters) { | ||
| for (key in parameters) { | ||
| // Add this for Accounting API minorversion url query parameter | ||
| if (key === 'minorversion') { | ||
| continue; | ||
| } | ||
| if (key === keys[keys.length-1]) { | ||
| authHeader += key + '=' + '"'+parameters[key]+'"'; | ||
| } | ||
| else { | ||
| authHeader += key + '=' + '"'+parameters[key]+'",'; | ||
| } | ||
| // Add this for Accounting API minorversion url query parameter | ||
| if (key === 'minorversion') { | ||
| continue; | ||
| } | ||
| if (key === keys[keys.length-1]) { | ||
| authHeader += key + '=' + '"'+parameters[key]+'"'; | ||
| } | ||
| else { | ||
| authHeader += key + '=' + '"'+parameters[key]+'",'; | ||
| } | ||
| } | ||
| return authHeader; | ||
| return authHeader; | ||
@@ -519,49 +519,49 @@ }; | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| if(!this.getToken().id_token) throw new Error('The bearer token does not have id_token'); | ||
| if(!this.getToken().id_token) throw new Error('The bearer token does not have id_token'); | ||
| var id_token = this.getToken().id_token || params.id_token; | ||
| var id_token = this.getToken().id_token || params.id_token; | ||
| params = params || {}; | ||
| params = params || {}; | ||
| // Decode ID Token | ||
| var token_parts = id_token.split('.') | ||
| var id_token_header = JSON.parse(atob(token_parts[0])); | ||
| var id_token_payload = JSON.parse(atob(token_parts[1])); | ||
| // Decode ID Token | ||
| var token_parts = id_token.split('.') | ||
| var id_token_header = JSON.parse(atob(token_parts[0])); | ||
| var id_token_payload = JSON.parse(atob(token_parts[1])); | ||
| var id_token_signature = atob(token_parts[2]); | ||
| // | ||
| // Step 1 : First check if the issuer is as mentioned in "issuer" | ||
| if(id_token_payload.iss != 'https://oauth.platform.intuit.com/op/v1') return false; | ||
| var id_token_signature = atob(token_parts[2]); | ||
| // | ||
| // Step 1 : First check if the issuer is as mentioned in "issuer" | ||
| if(id_token_payload.iss != 'https://oauth.platform.intuit.com/op/v1') return false; | ||
| // Step 2 : check if the aud field in idToken is same as application's clientId | ||
| if(id_token_payload.aud != this.clientId) return false; | ||
| // Step 2 : check if the aud field in idToken is same as application's clientId | ||
| if(id_token_payload.aud != this.clientId) return false; | ||
| // Step 3 : ensure the timestamp has not elapsed | ||
| if(id_token_payload.exp < Date.now() / 1000) return false; | ||
| // Step 3 : ensure the timestamp has not elapsed | ||
| if(id_token_payload.exp < Date.now() / 1000) return false; | ||
| var request = { | ||
| url: OAuthClient.jwks_uri, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| var request = { | ||
| url: OAuthClient.jwks_uri, | ||
| method: 'GET', | ||
| headers: { | ||
| 'Accept': AuthResponse._jsonContentType, | ||
| 'User-Agent': OAuthClient.user_agent | ||
| } | ||
| }; | ||
| resolve(this.getKeyFromJWKsURI(id_token, id_token_header.kid, request)); | ||
| resolve(this.getKeyFromJWKsURI(id_token, id_token_header.kid, request)); | ||
| }.bind(this))).then(function(res) { | ||
| }.bind(this))).then(function(res) { | ||
| this.log('info','The validateIdToken () response is : ',JSON.stringify(res, null, 2)); | ||
| if(res) return true; | ||
| this.log('info','The validateIdToken () response is : ',JSON.stringify(res, null, 2)); | ||
| if(res) return true; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| this.log('error','The validateIdToken () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| this.log('error','The validateIdToken () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
| } | ||
@@ -578,24 +578,24 @@ | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| resolve(this.loadResponse(request)); | ||
| resolve(this.loadResponse(request)); | ||
| }.bind(this))).then(function(response) { | ||
| }.bind(this))).then(function(response) { | ||
| if(response.status != "200") throw new Error('Could not reach JWK endpoint'); | ||
| if(response.status != "200") throw new Error('Could not reach JWK endpoint'); | ||
| // Find the key by KID | ||
| var responseBody = JSON.parse(response.body); | ||
| var key = responseBody.keys.find(el => (el.kid == kid)) | ||
| var cert = this.getPublicKey(key.n, key.e) | ||
| // Find the key by KID | ||
| var responseBody = JSON.parse(response.body); | ||
| var key = responseBody.keys.find(el => (el.kid == kid)) | ||
| var cert = this.getPublicKey(key.n, key.e) | ||
| return jwt.verify(id_token, cert); | ||
| return jwt.verify(id_token, cert); | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| e = this.createError(e); | ||
| this.log('error','The getKeyFromJWKsURI () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| e = this.createError(e); | ||
| this.log('error','The getKeyFromJWKsURI () threw an exception : ',JSON.stringify(e, null, 2)); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -610,5 +610,5 @@ } | ||
| OAuthClient.prototype.getPublicKey = function(modulus, exponent) { | ||
| var getPem = require('rsa-pem-from-mod-exp'); | ||
| var pem = getPem(modulus, exponent); | ||
| return pem | ||
| var getPem = require('rsa-pem-from-mod-exp'); | ||
| var pem = getPem(modulus, exponent); | ||
| return pem | ||
| }; | ||
@@ -623,22 +623,22 @@ | ||
| var authResponse = new AuthResponse({token:this.token}); | ||
| var authResponse = new AuthResponse({token:this.token}); | ||
| return (new Promise(function(resolve) { | ||
| return (new Promise(function(resolve) { | ||
| resolve(this.loadResponse(request)); | ||
| resolve(this.loadResponse(request)); | ||
| }.bind(this))).then(function(response) { | ||
| }.bind(this))).then(function(response) { | ||
| authResponse.processResponse(response); | ||
| authResponse.processResponse(response); | ||
| if (!authResponse.valid()) throw new Error('Response has an Error'); | ||
| if (!authResponse.valid()) throw new Error('Response has an Error'); | ||
| return authResponse; | ||
| return authResponse; | ||
| }.bind(this)).catch(function(e) { | ||
| }.bind(this)).catch(function(e) { | ||
| if (!e.authResponse) e = this.createError(e, authResponse); | ||
| throw e; | ||
| if (!e.authResponse) e = this.createError(e, authResponse); | ||
| throw e; | ||
| }.bind(this)); | ||
| }.bind(this)); | ||
@@ -652,4 +652,4 @@ }; | ||
| if(!this.token.refreshToken()) throw new Error('The Refresh token is missing'); | ||
| if(!this.token.isRefreshTokenValid()) throw new Error('The Refresh token is invalid, please Authorize again.'); | ||
| if(!this.token.refreshToken()) throw new Error('The Refresh token is missing'); | ||
| if(!this.token.isRefreshTokenValid()) throw new Error('The Refresh token is invalid, please Authorize again.'); | ||
| }; | ||
@@ -665,5 +665,5 @@ | ||
| return popsicle.get(request).then(function (response) { | ||
| return response; | ||
| }); | ||
| return popsicle.get(request).then(function (response) { | ||
| return response; | ||
| }); | ||
| }; | ||
@@ -678,5 +678,5 @@ | ||
| return popsicle.get(request).then(function (response) { | ||
| return response; | ||
| }); | ||
| return popsicle.get(request).then(function (response) { | ||
| return response; | ||
| }); | ||
| }; | ||
@@ -692,20 +692,20 @@ | ||
| if(!authResponse || authResponse.body == ""){ | ||
| if(!authResponse || authResponse.body == ""){ | ||
| e.error = e.originalMessage || ''; | ||
| e.authResponse = authResponse || '' | ||
| e.intuit_tid = authResponse.headers()['intuit_tid'] || ''; | ||
| e.originalMessage = authResponse.response.statusText || ''; | ||
| e.error = authResponse.response.statusText || ''; | ||
| e.error_description = authResponse.response.statusText || ''; | ||
| return e; | ||
| } | ||
| e.error = e.originalMessage || ''; | ||
| e.authResponse = authResponse || '' | ||
| e.intuit_tid = authResponse.headers()['intuit_tid'] || ''; | ||
| e.originalMessage = authResponse.response.statusText || ''; | ||
| e.error = authResponse.response.statusText || ''; | ||
| e.error_description = authResponse.response.statusText || ''; | ||
| return e; | ||
| } | ||
| e.authResponse = authResponse ? authResponse : null; | ||
| e.originalMessage = e.message; | ||
| e.error = ('error' in authResponse.getJson() ? authResponse.getJson().error : ''); | ||
| e.error_description = ('error_description' in authResponse.getJson() ? authResponse.getJson().error_description : ''); | ||
| e.intuit_tid = authResponse.headers()['intuit_tid']; | ||
| e.authResponse = authResponse ? authResponse : null; | ||
| e.originalMessage = e.message; | ||
| e.error = ('error' in authResponse.getJson() ? authResponse.getJson().error : ''); | ||
| e.error_description = ('error_description' in authResponse.getJson() ? authResponse.getJson().error_description : ''); | ||
| e.intuit_tid = authResponse.headers()['intuit_tid']; | ||
| return e; | ||
| return e; | ||
@@ -720,3 +720,3 @@ }; | ||
| OAuthClient.prototype.isAccessTokenValid = function() { | ||
| return this.token.isAccessTokenValid(); | ||
| return this.token.isAccessTokenValid(); | ||
| }; | ||
@@ -729,3 +729,3 @@ | ||
| OAuthClient.prototype.getToken = function() { | ||
| return this.token; | ||
| return this.token; | ||
| }; | ||
@@ -751,12 +751,12 @@ | ||
| OAuthClient.prototype.authHeader = function() { | ||
| var apiKey = this.clientId + ':' + this.clientSecret; | ||
| return (typeof btoa == 'function') ? btoa(apiKey) : new Buffer(apiKey).toString('base64'); | ||
| var apiKey = this.clientId + ':' + this.clientSecret; | ||
| return (typeof btoa == 'function') ? btoa(apiKey) : new Buffer(apiKey).toString('base64'); | ||
| }; | ||
| OAuthClient.prototype.log = function(level,message,messageData) { | ||
| if (this.logging) { | ||
| this.logger.log(level,message + messageData); | ||
| } | ||
| if (this.logging) { | ||
| this.logger.log(level,message + messageData); | ||
| } | ||
| }; | ||
| module.exports = OAuthClient; | ||
| module.exports = OAuthClient; |
@@ -21,6 +21,6 @@ 'use strict'; | ||
| var oauthClient = new OAuthClientTest({ | ||
| clientId: 'clientID', | ||
| clientSecret: 'clientSecret', | ||
| environment: 'sandbox', | ||
| redirectUri: 'http://localhost:8000/callback' | ||
| clientId: 'clientID', | ||
| clientSecret: 'clientSecret', | ||
| environment: 'sandbox', | ||
| redirectUri: 'http://localhost:8000/callback' | ||
| }); | ||
@@ -30,394 +30,394 @@ | ||
| describe('Tests for OAuthClient', function() { | ||
| var scope; | ||
| var scope; | ||
| it('Creates a new access token instance', function() { | ||
| var accessToken = oauthClient.getToken(); | ||
| expect(accessToken).to.have.property('realmId'); | ||
| expect(accessToken).to.have.property('token_type'); | ||
| expect(accessToken).to.have.property('refresh_token'); | ||
| expect(accessToken).to.have.property('expires_in'); | ||
| expect(accessToken).to.have.property('x_refresh_token_expires_in'); | ||
| expect(accessToken).to.have.property('id_token'); | ||
| expect(accessToken).to.have.property('latency'); | ||
| }); | ||
| it('Creates a new access token instance', function() { | ||
| var accessToken = oauthClient.getToken(); | ||
| expect(accessToken).to.have.property('realmId'); | ||
| expect(accessToken).to.have.property('token_type'); | ||
| expect(accessToken).to.have.property('refresh_token'); | ||
| expect(accessToken).to.have.property('expires_in'); | ||
| expect(accessToken).to.have.property('x_refresh_token_expires_in'); | ||
| expect(accessToken).to.have.property('id_token'); | ||
| expect(accessToken).to.have.property('latency'); | ||
| }); | ||
| describe('Get the authorizationURI', function() { | ||
| it('When Scope is passed', function() { | ||
| var actualAuthUri = oauthClient.authorizeUri({scope:'testScope',state:'testState'}); | ||
| var expectedAuthUri = 'https://appcenter.intuit.com/connect/oauth2?client_id=clientID&redirect_uri=http%3A%2F%2Flocalhost%3A8000%2Fcallback&response_type=code&scope=testScope&state=testState'; | ||
| expect(actualAuthUri).to.be.equal(expectedAuthUri); | ||
| }); | ||
| describe('Get the authorizationURI', function() { | ||
| it('When Scope is passed', function() { | ||
| var actualAuthUri = oauthClient.authorizeUri({scope:'testScope',state:'testState'}); | ||
| var expectedAuthUri = 'https://appcenter.intuit.com/connect/oauth2?client_id=clientID&redirect_uri=http%3A%2F%2Flocalhost%3A8000%2Fcallback&response_type=code&scope=testScope&state=testState'; | ||
| expect(actualAuthUri).to.be.equal(expectedAuthUri); | ||
| }); | ||
| it('When NO Scope is passed', function() { | ||
| try { | ||
| oauthClient.authorizeUri(); | ||
| it('When NO Scope is passed', function() { | ||
| try { | ||
| oauthClient.authorizeUri(); | ||
| } catch (e) { | ||
| expect(e.message).to.equal('Provide the scopes'); | ||
| } | ||
| }); | ||
| it('When Scope is passed as an array', function() { | ||
| var actualAuthUri = oauthClient.authorizeUri({scope:[OAuthClientTest.scopes.Accounting,OAuthClientTest.scopes.Payment,OAuthClientTest.scopes.OpenId],state:'testState'}); | ||
| var expectedAuthUri = 'https://appcenter.intuit.com/connect/oauth2?client_id=clientID&redirect_uri=http%3A%2F%2Flocalhost%3A8000%2Fcallback&response_type=code&scope=com.intuit.quickbooks.accounting%20com.intuit.quickbooks.payment%20openid&state=testState'; | ||
| expect(actualAuthUri).to.be.equal(expectedAuthUri); | ||
| }); | ||
| } catch (e) { | ||
| expect(e.message).to.equal('Provide the scopes'); | ||
| } | ||
| }); | ||
| it('When Scope is passed as an array', function() { | ||
| var actualAuthUri = oauthClient.authorizeUri({scope:[OAuthClientTest.scopes.Accounting,OAuthClientTest.scopes.Payment,OAuthClientTest.scopes.OpenId],state:'testState'}); | ||
| var expectedAuthUri = 'https://appcenter.intuit.com/connect/oauth2?client_id=clientID&redirect_uri=http%3A%2F%2Flocalhost%3A8000%2Fcallback&response_type=code&scope=com.intuit.quickbooks.accounting%20com.intuit.quickbooks.payment%20openid&state=testState'; | ||
| expect(actualAuthUri).to.be.equal(expectedAuthUri); | ||
| }); | ||
| }); | ||
| // Create bearer tokens | ||
| describe('Create Bearer Token', function() { | ||
| // Create bearer tokens | ||
| describe('Create Bearer Token', function() { | ||
| before(function() { | ||
| before(function() { | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .post('/oauth2/v1/tokens/bearer') | ||
| .reply(200, expectedTokenResponse, { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .post('/oauth2/v1/tokens/bearer') | ||
| .reply(200, expectedTokenResponse, { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Provide the uri to get the tokens', function() { | ||
| var parseRedirect = 'http://localhost:8000/callback?state=testState&code=Q011535008931rqveFweqmueq0GlOHhLPAFMp3NI2KJm5gbMMx'; | ||
| return oauthClient.createToken(parseRedirect) | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().access_token).to.be.equal(expectedAccessToken.access_token); | ||
| }); | ||
| it('Provide the uri to get the tokens', function() { | ||
| var parseRedirect = 'http://localhost:8000/callback?state=testState&code=Q011535008931rqveFweqmueq0GlOHhLPAFMp3NI2KJm5gbMMx'; | ||
| return oauthClient.createToken(parseRedirect) | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().access_token).to.be.equal(expectedAccessToken.access_token); | ||
| }); | ||
| }); | ||
| it('When NO uri is provided', function() { | ||
| return oauthClient.createToken() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().access_token).to.be.equal(expectedAccessToken.access_token); | ||
| }) | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('Provide the Uri'); | ||
| }); | ||
| it('When NO uri is provided', function() { | ||
| return oauthClient.createToken() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().access_token).to.be.equal(expectedAccessToken.access_token); | ||
| }) | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('Provide the Uri'); | ||
| }); | ||
| }); | ||
| }); | ||
| // Refresh bearer tokens | ||
| describe('Refresh Bearer Token', function() { | ||
| before(function() { | ||
| var refreshAccessToken = require("./mocks/refreshResponse.json"); | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .post('/oauth2/v1/tokens/bearer') | ||
| .reply(200,refreshAccessToken , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| // Refresh bearer tokens | ||
| describe('Refresh Bearer Token', function() { | ||
| before(function() { | ||
| var refreshAccessToken = require("./mocks/refreshResponse.json"); | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .post('/oauth2/v1/tokens/bearer') | ||
| .reply(200,refreshAccessToken , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Refresh the existing tokens', function() { | ||
| return oauthClient.refresh() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().refresh_token).to.be.equal(expectedAccessToken.refresh_token); | ||
| }); | ||
| it('Refresh the existing tokens', function() { | ||
| return oauthClient.refresh() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().refresh_token).to.be.equal(expectedAccessToken.refresh_token); | ||
| }); | ||
| }); | ||
| it('Refresh : refresh token is missing', function(){ | ||
| oauthClient.getToken().refresh_token = null; | ||
| return oauthClient.refresh() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is missing'); | ||
| }); | ||
| it('Refresh : refresh token is missing', function(){ | ||
| oauthClient.getToken().refresh_token = null; | ||
| return oauthClient.refresh() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is missing'); | ||
| }); | ||
| }); | ||
| it('Refresh : refresh token is invalid', function(){ | ||
| oauthClient.getToken().refresh_token = 'sample_refresh_token'; | ||
| oauthClient.getToken().x_refresh_token_expires_in = '300'; | ||
| return oauthClient.refresh() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is invalid, please Authorize again.'); | ||
| }); | ||
| it('Refresh : refresh token is invalid', function(){ | ||
| oauthClient.getToken().refresh_token = 'sample_refresh_token'; | ||
| oauthClient.getToken().x_refresh_token_expires_in = '300'; | ||
| return oauthClient.refresh() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is invalid, please Authorize again.'); | ||
| }); | ||
| }); | ||
| }); | ||
| // Revoke bearer tokens | ||
| describe('Revoke Bearer Token', function(){ | ||
| before(function() { | ||
| scope = nock('https://developer.api.intuit.com').persist() | ||
| .post('/v2/oauth2/tokens/revoke') | ||
| .reply(200, '' , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| // Revoke bearer tokens | ||
| describe('Revoke Bearer Token', function(){ | ||
| before(function() { | ||
| scope = nock('https://developer.api.intuit.com').persist() | ||
| .post('/v2/oauth2/tokens/revoke') | ||
| .reply(200, '' , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Revoke the existing tokens', function() { | ||
| oauthClient.getToken().x_refresh_token_expires_in = '4535995551112'; | ||
| return oauthClient.revoke() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().refresh_token).to.be.equal(expectedAccessToken.refresh_token); | ||
| }); | ||
| it('Revoke the existing tokens', function() { | ||
| oauthClient.getToken().x_refresh_token_expires_in = '4535995551112'; | ||
| return oauthClient.revoke() | ||
| .then(function(authResponse) { | ||
| expect(authResponse.getToken().refresh_token).to.be.equal(''); | ||
| }); | ||
| }); | ||
| it('Revoke : refresh token is missing', function() { | ||
| oauthClient.getToken().refresh_token = null; | ||
| return oauthClient.revoke() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is missing'); | ||
| }); | ||
| it('Revoke : refresh token is missing', function() { | ||
| oauthClient.getToken().refresh_token = null; | ||
| return oauthClient.revoke() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is missing'); | ||
| }); | ||
| }); | ||
| it('Revoke : refresh token is invalid', function() { | ||
| oauthClient.getToken().refresh_token = 'sample_refresh_token'; | ||
| oauthClient.getToken().x_refresh_token_expires_in = '300'; | ||
| return oauthClient.revoke() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is invalid, please Authorize again.'); | ||
| }); | ||
| it('Revoke : refresh token is invalid', function() { | ||
| oauthClient.getToken().refresh_token = 'sample_refresh_token'; | ||
| oauthClient.getToken().x_refresh_token_expires_in = '300'; | ||
| return oauthClient.revoke() | ||
| .catch(function(e) { | ||
| expect(e.message).to.equal('The Refresh token is invalid, please Authorize again.'); | ||
| }); | ||
| }); | ||
| }); | ||
| // Get User Info ( OpenID ) | ||
| describe('Get User Info ( OpenID )', function() { | ||
| describe('', function () { | ||
| before(function () { | ||
| scope = nock('https://sandbox-accounts.platform.intuit.com').persist() | ||
| .get('/v1/openid_connect/userinfo') | ||
| .reply(200, expectedUserInfo, { | ||
| "content-type": "application/json", | ||
| "content-length": "1636", | ||
| "connection": "close", | ||
| "server": "nginx", | ||
| "intuit_tid": "12345-123-1234-12345", | ||
| "cache-control": "no-cache, no-store", | ||
| "pragma": "no-cache" | ||
| }); | ||
| }); | ||
| // Get User Info ( OpenID ) | ||
| describe('Get User Info ( OpenID )', function() { | ||
| describe('', function () { | ||
| before(function () { | ||
| scope = nock('https://sandbox-accounts.platform.intuit.com').persist() | ||
| .get('/v1/openid_connect/userinfo') | ||
| .reply(200, expectedUserInfo, { | ||
| "content-type": "application/json", | ||
| "content-length": "1636", | ||
| "connection": "close", | ||
| "server": "nginx", | ||
| "intuit_tid": "12345-123-1234-12345", | ||
| "cache-control": "no-cache, no-store", | ||
| "pragma": "no-cache" | ||
| }); | ||
| }); | ||
| it('Get User Info in Sandbox', function () { | ||
| return oauthClient.getUserInfo() | ||
| .then(function (authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedUserInfo)); | ||
| }); | ||
| }); | ||
| it('Get User Info in Sandbox', function () { | ||
| return oauthClient.getUserInfo() | ||
| .then(function (authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedUserInfo)); | ||
| }); | ||
| }); | ||
| }); | ||
| describe('', function () { | ||
| before(function () { | ||
| scope = nock('https://accounts.platform.intuit.com').persist() | ||
| .get('/v1/openid_connect/userinfo') | ||
| .reply(200, expectedUserInfo, { | ||
| "content-type": "application/json", | ||
| "content-length": "1636", | ||
| "connection": "close", | ||
| "server": "nginx", | ||
| "intuit_tid": "12345-123-1234-12345", | ||
| "cache-control": "no-cache, no-store", | ||
| "pragma": "no-cache" | ||
| }); | ||
| }); | ||
| describe('', function () { | ||
| before(function () { | ||
| scope = nock('https://accounts.platform.intuit.com').persist() | ||
| .get('/v1/openid_connect/userinfo') | ||
| .reply(200, expectedUserInfo, { | ||
| "content-type": "application/json", | ||
| "content-length": "1636", | ||
| "connection": "close", | ||
| "server": "nginx", | ||
| "intuit_tid": "12345-123-1234-12345", | ||
| "cache-control": "no-cache, no-store", | ||
| "pragma": "no-cache" | ||
| }); | ||
| }); | ||
| it('Get User Info in Production', function () { | ||
| oauthClient.environment = 'production'; | ||
| return oauthClient.getUserInfo() | ||
| .then(function (authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedUserInfo)); | ||
| }); | ||
| }); | ||
| it('Get User Info in Production', function () { | ||
| oauthClient.environment = 'production'; | ||
| return oauthClient.getUserInfo() | ||
| .then(function (authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedUserInfo)); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| // make API Call | ||
| describe('Make API Call ', function() { | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://sandbox-quickbooks.api.intuit.com').persist() | ||
| .get('/v3/company/12345/companyinfo/12345') | ||
| .reply(200, expectedMakeAPICall , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Make API Call in Sandbox Environment', function() { | ||
| oauthClient.getToken().realmId = '12345'; | ||
| return oauthClient.makeApiCall({url:'https://sandbox-quickbooks.api.intuit.com/v3/company/'+'12345'+'/companyinfo/'+'12345'}) | ||
| .then(function(authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedMakeAPICall)); | ||
| }); | ||
| }); | ||
| }); | ||
| // make API Call | ||
| describe('Make API Call ', function() { | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://sandbox-quickbooks.api.intuit.com').persist() | ||
| .get('/v3/company/12345/companyinfo/12345') | ||
| .reply(200, expectedMakeAPICall , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Make API Call in Sandbox Environment', function() { | ||
| oauthClient.getToken().realmId = '12345'; | ||
| return oauthClient.makeApiCall({url:'https://sandbox-quickbooks.api.intuit.com/v3/company/'+'12345'+'/companyinfo/'+'12345'}) | ||
| .then(function(authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedMakeAPICall)); | ||
| }); | ||
| }); | ||
| }); | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://quickbooks.api.intuit.com').persist() | ||
| .get('/v3/company/12345/companyinfo/12345') | ||
| .reply(200, expectedMakeAPICall , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Make API Call in Production Environment', function() { | ||
| oauthClient.environment = 'production'; | ||
| oauthClient.getToken().realmId = '12345'; | ||
| return oauthClient.makeApiCall({url:'https://quickbooks.api.intuit.com/v3/company/'+'12345'+'/companyinfo/'+'12345'}) | ||
| .then(function(authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedMakeAPICall)); | ||
| }); | ||
| }); | ||
| }); | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://quickbooks.api.intuit.com').persist() | ||
| .get('/v3/company/12345/companyinfo/12345') | ||
| .reply(200, expectedMakeAPICall , { | ||
| "content-type":"application/json", | ||
| "content-length":"1636", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "intuit_tid":"12345-123-1234-12345", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Make API Call in Production Environment', function() { | ||
| oauthClient.environment = 'production'; | ||
| oauthClient.getToken().realmId = '12345'; | ||
| return oauthClient.makeApiCall({url:'https://quickbooks.api.intuit.com/v3/company/'+'12345'+'/companyinfo/'+'12345'}) | ||
| .then(function(authResponse) { | ||
| expect(JSON.stringify(authResponse.getJson())).to.be.equal(JSON.stringify(expectedMakeAPICall)); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| // make API Call | ||
| describe('Validate Id Token ', function() { | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .get('/op/v1/jwks') | ||
| .reply(200, expectedjwkResponseCall , { | ||
| "content-type":"application/json;charset=UTF-8", | ||
| "content-length":"264", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "strict-transport-security":"max-age=15552000", | ||
| "intuit_tid":"1234-1234-1234-123", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| // make API Call | ||
| describe('Validate Id Token ', function() { | ||
| describe('', function() { | ||
| before(function() { | ||
| scope = nock('https://oauth.platform.intuit.com').persist() | ||
| .get('/op/v1/jwks') | ||
| .reply(200, expectedjwkResponseCall , { | ||
| "content-type":"application/json;charset=UTF-8", | ||
| "content-length":"264", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "strict-transport-security":"max-age=15552000", | ||
| "intuit_tid":"1234-1234-1234-123", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Validate Id Token', function() { | ||
| oauthClient.getToken().setToken(expectedOpenIDToken); | ||
| oauthClient.validateIdToken() | ||
| .then(function(response) { | ||
| expect(response).to.be.equal(expectedvalidateIdToken); | ||
| }); | ||
| }); | ||
| it('Validate Id Token', function() { | ||
| oauthClient.getToken().setToken(expectedOpenIDToken); | ||
| oauthClient.validateIdToken() | ||
| .then(function(response) { | ||
| expect(response).to.be.equal(expectedvalidateIdToken); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| // Check Access Token Validity | ||
| describe('Check Access-Token Validity', function() { | ||
| it('access-token is valid', function() { | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.true; | ||
| }); | ||
| it('access-token is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| // Check Access Token Validity | ||
| describe('Check Access-Token Validity', function() { | ||
| it('access-token is valid', function() { | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.true; | ||
| }); | ||
| it('access-token is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| }); | ||
| // Get Token | ||
| describe('Get Token', function() { | ||
| it('get token instance', function() { | ||
| var token = oauthClient.getToken(); | ||
| expect(token).to.be.a('Object'); | ||
| }); | ||
| it('accesstoken is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| // Get Token | ||
| describe('Get Token', function() { | ||
| it('get token instance', function() { | ||
| var token = oauthClient.getToken(); | ||
| expect(token).to.be.a('Object'); | ||
| }); | ||
| it('accesstoken is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| }); | ||
| // Get Auth Header | ||
| describe('Get Auth Header', function() { | ||
| it('Auth Header is valid', function() { | ||
| var authHeader = oauthClient.authHeader(); | ||
| expect(authHeader).to.be.equal('Y2xpZW50SUQ6Y2xpZW50U2VjcmV0'); | ||
| }); | ||
| it('accesstoken is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| // Get Auth Header | ||
| describe('Get Auth Header', function() { | ||
| it('Auth Header is valid', function() { | ||
| var authHeader = oauthClient.authHeader(); | ||
| expect(authHeader).to.be.equal('Y2xpZW50SUQ6Y2xpZW50U2VjcmV0'); | ||
| }); | ||
| it('accesstoken is not valid', function() { | ||
| oauthClient.getToken().expires_in = null; | ||
| var validity = oauthClient.isAccessTokenValid(); | ||
| expect(validity).to.be.false; | ||
| }); | ||
| }); | ||
| // Generate OAuth1Sign | ||
| // Generate OAuth1Sign | ||
| describe('Generate OAuth1Sign', function() { | ||
| it('Generate OAuth1Sign String', function() { | ||
| var params = { | ||
| method: 'POST', | ||
| uri: 'uri', | ||
| oauth_consumer_key : 'qyprdFsHNQtdRupMKmYnDt6MOjWBW9', | ||
| oauth_consumer_secret : 'TOI5I5dK94dkqDy9SlRD7s08uQUvtow6CK53SpJ1', | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : 'timestamp', | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0', | ||
| access_token : 'qyprdlGm45UFPPhwAM59Awaq4BAd6hNFwp1SSkZDn54Zrgv9', | ||
| access_secret : 'xPZ44ZvT17H56pkAAqhfyjuZlF5zZb2k9ej3ohko' | ||
| } | ||
| describe('Generate OAuth1Sign', function() { | ||
| it('Generate OAuth1Sign String', function() { | ||
| var params = { | ||
| method: 'POST', | ||
| uri: 'uri', | ||
| oauth_consumer_key : 'qyprdFsHNQtdRupMKmYnDt6MOjWBW9', | ||
| oauth_consumer_secret : 'TOI5I5dK94dkqDy9SlRD7s08uQUvtow6CK53SpJ1', | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : 'timestamp', | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0', | ||
| access_token : 'qyprdlGm45UFPPhwAM59Awaq4BAd6hNFwp1SSkZDn54Zrgv9', | ||
| access_secret : 'xPZ44ZvT17H56pkAAqhfyjuZlF5zZb2k9ej3ohko' | ||
| } | ||
| var oauth1Sign = oauthClient.generateOauth1Sign(params); | ||
| expect(oauth1Sign).to.be.a('String'); | ||
| }); | ||
| var oauth1Sign = oauthClient.generateOauth1Sign(params); | ||
| expect(oauth1Sign).to.be.a('String'); | ||
| }); | ||
| }); | ||
| // Migrate Tokens | ||
| describe('Migrate OAuth Tokens', function() { | ||
| describe('Sandbox', function() { | ||
| before(function() { | ||
| scope = nock('https://developer.api.intuit.com').persist() | ||
| .post('/v2/oauth2/tokens/migrate') | ||
| .reply(200, expectedMigrationResponse , { | ||
| "content-type":"application/json;charset=UTF-8", | ||
| "content-length":"264", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "strict-transport-security":"max-age=15552000", | ||
| "intuit_tid":"1234-1234-1234-123", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| // Migrate Tokens | ||
| describe('Migrate OAuth Tokens', function() { | ||
| describe('Sandbox', function() { | ||
| before(function() { | ||
| scope = nock('https://developer.api.intuit.com').persist() | ||
| .post('/v2/oauth2/tokens/migrate') | ||
| .reply(200, expectedMigrationResponse , { | ||
| "content-type":"application/json;charset=UTF-8", | ||
| "content-length":"264", | ||
| "connection":"close", | ||
| "server":"nginx", | ||
| "strict-transport-security":"max-age=15552000", | ||
| "intuit_tid":"1234-1234-1234-123", | ||
| "cache-control":"no-cache, no-store", | ||
| "pragma":"no-cache" | ||
| }); | ||
| }); | ||
| it('Migrate OAuth Tokens - Sandbox', function() { | ||
| it('Migrate OAuth Tokens - Sandbox', function() { | ||
| var timestamp = Math.round(new Date().getTime()/1000); | ||
| var timestamp = Math.round(new Date().getTime()/1000); | ||
| var params = { | ||
| oauth_consumer_key : 'oauth_consumer_key', | ||
| oauth_consumer_secret : 'oauth_consumer_secret', | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : timestamp, | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0', | ||
| access_token : 'sample_access_token', | ||
| access_secret : 'sample_access_secret', | ||
| scope : ['com.intuit.quickbooks.accounting'] | ||
| } | ||
| oauthClient.migrate(params) | ||
| .then(function(response){ | ||
| expect(response).to.be.equal(expectedMigrationResponse); | ||
| }); | ||
| }); | ||
| var params = { | ||
| oauth_consumer_key : 'oauth_consumer_key', | ||
| oauth_consumer_secret : 'oauth_consumer_secret', | ||
| oauth_signature_method : 'HMAC-SHA1', | ||
| oauth_timestamp : timestamp, | ||
| oauth_nonce : 'nonce', | ||
| oauth_version : '1.0', | ||
| access_token : 'sample_access_token', | ||
| access_secret : 'sample_access_secret', | ||
| scope : ['com.intuit.quickbooks.accounting'] | ||
| } | ||
| oauthClient.migrate(params) | ||
| .then(function(response){ | ||
| expect(response).to.be.equal(expectedMigrationResponse); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| }); | ||
| }); |
No alert changes
Improved metrics
- Lines of code
- increased by0.86%
1643
Worsened metrics
- Total package byte prevSize
- decreased by-1.72%
186738
- Number of lines in readme file
- decreased by-1%
495
No dependency changes