archive-gh-me/serverless
1
0
Fork 0
mirror of https://github.com/serverless/serverless.git synced 2026-01-25 15:07:39 +00:00
Code Issues Projects Releases Wiki Activity

More handling for 429

Browse Source
This commit is contained in:
Kamil Burzynski 2015-12-22 13:18:05 +01:00
parent d644a6e79b
commit 4f154e4fb9
1 changed files with 28 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
lib/actions/EndpointBuildApiGateway.js
View File

@ -18,6 +18,25 @@ module.exports = function(SPlugin, serverlessPath) {
// Promisify fs module.
BbPromise.promisifyAll(fs);
//Consider moving this to utils/
let slowdownRequests = function( f ){
return new BbPromise( function( resolve, reject ){
let doCall = function(){
f()
.then(resolve)
.catch(function(error) {
if( error.statusCode == 429 ) {
SUtils.sDebug("'Too many requests' received, sleeping 5 seconds");
setTimeout( doCall, 5000 );
} else
reject( error );
});
};
doCall();
});
};
class EndpointBuildApiGateway extends SPlugin {
/**
@ -222,7 +241,7 @@ module.exports = function(SPlugin, serverlessPath) {
};
// List all Resources for this REST API
return _this.ApiGateway.getResourcesPromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.getResourcesPromised(params); } )
.then(function(response) {
_this.apiResources = response.items;
@ -352,7 +371,7 @@ module.exports = function(SPlugin, serverlessPath) {
};
// Create Resource
return _this.ApiGateway.createResourcePromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.createResourcePromised(params); } )
.then(function(response) {
// Save resource
@ -403,7 +422,7 @@ module.exports = function(SPlugin, serverlessPath) {
restApiId: evt.region.restApiId /* required */
};
return _this.ApiGateway.getMethodPromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.getMethodPromised(params); } )
.then(function(response) {
// Method exists. Delete and recreate it.
@ -419,7 +438,7 @@ module.exports = function(SPlugin, serverlessPath) {
restApiId: evt.region.restApiId /* required */
};
return _this.ApiGateway.deleteMethodPromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.deleteMethodPromised(params); } )
.then(function(response) {
let params = {
@ -431,7 +450,7 @@ module.exports = function(SPlugin, serverlessPath) {
requestModels: evt.endpoint.requestModels,
requestParameters: requestParameters
};
return _this.ApiGateway.putMethodPromised(params);
return slowdownRequests( function(){ return _this.ApiGateway.putMethodPromised(params); } )
});
}, function(error) {
@ -448,7 +467,7 @@ module.exports = function(SPlugin, serverlessPath) {
requestParameters: requestParameters
};
return _this.ApiGateway.putMethodPromised(params);
return slowdownRequests( function(){ return _this.ApiGateway.putMethodPromised(params); } );
})
.then(function(response) {
@ -525,7 +544,7 @@ module.exports = function(SPlugin, serverlessPath) {
};
// Create Integration
return _this.ApiGateway.putIntegrationPromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.putIntegrationPromised(params); } )
.then(function(response) {
// Save integration
@ -597,7 +616,7 @@ module.exports = function(SPlugin, serverlessPath) {
};
// Create Method Response
return _this.ApiGateway.putMethodResponsePromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.putMethodResponsePromised(params); } )
.then(function() {
SUtils.sDebug(
@ -655,7 +674,7 @@ module.exports = function(SPlugin, serverlessPath) {
};
// Create Integration Response
return _this.ApiGateway.putIntegrationResponsePromised(params)
return slowdownRequests( function(){ return _this.ApiGateway.putIntegrationResponsePromised(params); } )
.then(function() {
SUtils.sDebug(