Comparing version 0.0.17 to 0.0.18
@@ -30,5 +30,5 @@ 'use strict' | ||
this.onRollbackHook = () => {} | ||
this.onTaskEndHook = () => {} | ||
this.onTaskStartHook = () => {} | ||
this.onRollbackHooks = [] | ||
this.onTaskEndHooks = [] | ||
this.onTaskStartHooks = [] | ||
} | ||
@@ -94,3 +94,5 @@ /** | ||
try { | ||
await this.onRollbackHook(task) | ||
for (let hook of this.onRollbackHooks) { | ||
await hook(task) | ||
} | ||
await task.rollback(err) | ||
@@ -114,3 +116,3 @@ } catch (err) { | ||
onTaskStart(fn) { | ||
this.onTaskStartHook = fn | ||
this.onTaskStartHooks.push(fn) | ||
} | ||
@@ -124,3 +126,3 @@ /** | ||
onTaskEnd(fn) { | ||
this.onTaskEndHook = fn | ||
this.onTaskEndHooks.push(fn) | ||
} | ||
@@ -134,3 +136,3 @@ /** | ||
onRollback(fn) { | ||
this.onRollbackHook = fn | ||
this.onRollbackHooks.push(fn) | ||
} | ||
@@ -301,3 +303,6 @@ /** | ||
try { | ||
await this.onTaskStartHook(state) | ||
for (let hook of this.onTaskStartHooks) { | ||
await hook(state) | ||
} | ||
await this.onInit(state) | ||
@@ -307,3 +312,6 @@ await this.onBefore(state) | ||
await this.onAfter(state) | ||
await this.onTaskEndHook(state) | ||
for (let hook of this.onTaskEndHooks) { | ||
await hook(state) | ||
} | ||
} catch (err) { | ||
@@ -313,3 +321,6 @@ error('Task error %O', err) | ||
await this.rollback(err) | ||
await this.onTaskEndHook(state) | ||
for (let hook of this.onTaskEndHooks) { | ||
await hook(state) | ||
} | ||
} | ||
@@ -316,0 +327,0 @@ }) |
@@ -58,5 +58,12 @@ 'use strict' | ||
this.pipeline.registry.addTask(task) | ||
await this.pipeline.onTaskStartHook(state) | ||
for (let hook of this.pipeline.onTaskStartHooks) { | ||
await hook(state) | ||
} | ||
await this.pipeline.executeTask(task, state) | ||
await this.pipeline.onTaskEndHook(state) | ||
for (let hook of this.pipeline.onTaskEndHooks) { | ||
await hook(state) | ||
} | ||
} | ||
@@ -63,0 +70,0 @@ /** |
{ | ||
"name": "bootme", | ||
"version": "0.0.17", | ||
"version": "0.0.18", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
14856
672