diff --git a/lib/schedule_events.js b/lib/schedule_events.js index 51bee5d3..520f3a7d 100644 --- a/lib/schedule_events.js +++ b/lib/schedule_events.js @@ -33,10 +33,10 @@ class ScheduleEvents { _putRule (params) { // return RuleArn if created - return new Promise((resolve) => { + return new Promise((resolve, reject) => { const _params = this._putRulePrams(params) this.cloudwatchevents.putRule(_params, (err, rule) => { - if (err) throw err + if (err) reject(err) resolve(rule) }) }) @@ -53,11 +53,11 @@ class ScheduleEvents { } _addPermission (params) { - return new Promise((resolve) => { + return new Promise((resolve, reject) => { const _params = this._addPermissionParams(params) this.lambda.addPermission(_params, (err, data) => { if (err) { - if (err.code !== 'ResourceConflictException') throw err + if (err.code !== 'ResourceConflictException') reject(err) // If it exists it will result in an error but there is no problem. resolve('Permission already set') } @@ -78,11 +78,11 @@ class ScheduleEvents { } _putTargets (params) { - return new Promise((resolve) => { + return new Promise((resolve, reject) => { const _params = this._putTargetsParams(params) this.cloudwatchevents.putTargets(_params, (err, data) => { // even if it is already registered, it will not be an error. - if (err) throw (err) + if (err) reject(err) resolve(data) }) }) @@ -91,9 +91,9 @@ class ScheduleEvents { add (params) { return Promise.resolve().then(() => { return this._putRule(params) - }).then((rule) => { + }).then(rule => { return this._addPermission(Object.assign(params, rule)) - }).then((data) => { + }).then(data => { return this._putTargets(params) }) }