Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
flowx - npm Package Compare versions
Comparing version 1.3.3 to 1.4.0
217
index.js
@@ -9,6 +9,3 @@ 'use strict' | ||
| let externals = {} | ||
| let internals = {} | ||
| internals.client = new Catbox.Client(CatboxMemory) | ||
| class flowEmitter extends EventEmitter { } | ||
@@ -18,52 +15,69 @@ | ||
| const client = new Catbox.Client(CatboxMemory) | ||
| externals.Instance = (function () { | ||
| function Instance(model, emitter, middlewares) { | ||
| /*this.flow = flow | ||
| this.id = id*/ | ||
| this.model = model | ||
| this.actualState = this.model.states[INITIAL_STATE] | ||
| this.middlewares = [] | ||
| this.internalEmitter = emitter | ||
| this.middlewares = middlewares | ||
| client.start((err) => { | ||
| if (err) { | ||
| throw err | ||
| } | ||
| Instance.prototype.searchNextState = function (stateName) { | ||
| return new Promise((resolve, reject) => { | ||
| this.model.states.forEach((state) => { | ||
| if (state.name === stateName) { | ||
| return resolve(state) | ||
| } | ||
| }) | ||
| return reject(new Error('No default state found')) | ||
| }) | ||
| } | ||
| externals.Instance = (function () { | ||
| Instance.prototype.validateTransition = function (transitionName) { | ||
| return new Promise((resolve, reject) => { | ||
| if (this.actualState.transitions) { | ||
| this.actualState.transitions.forEach((transition) => { | ||
| if (Utils.matchRule(transition.name, transitionName) || Utils.matchRegExp(transition.name, transitionName)) { | ||
| return resolve(transition) | ||
| function Instance(model, emitter, middlewares) { | ||
| /*this.flow = flow | ||
| this.id = id*/ | ||
| this.model = model | ||
| this.actualState = this.model.states[INITIAL_STATE] | ||
| this.middlewares = [] | ||
| this.internalEmitter = emitter | ||
| this.middlewares = middlewares | ||
| } | ||
| Instance.prototype.searchNextState = function (stateName) { | ||
| return new Promise((resolve, reject) => { | ||
| this.model.states.forEach((state) => { | ||
| if (state.name === stateName) { | ||
| return resolve(state) | ||
| } | ||
| }) | ||
| return reject(new Error('No se pudo encontrar el estado en las transiciones')) | ||
| } else { | ||
| return reject(new Error('No se pudo encontrar el estado en las transiciones')) | ||
| } | ||
| }) | ||
| } | ||
| return reject(new Error('No default state found')) | ||
| }) | ||
| } | ||
| Instance.prototype.getState = function (data) { | ||
| return new Promise((resolve, reject) => { | ||
| if (data && data.action) { | ||
| this.validateTransition(data.action).then((transition) => { | ||
| this.searchNextState(transition.to).then((nextState) => { | ||
| if (transition.use) { | ||
| this.middlewares[transition.use](this.actualState, (data) => { | ||
| Instance.prototype.validateTransition = function (transitionName) { | ||
| return new Promise((resolve, reject) => { | ||
| if (this.actualState.transitions) { | ||
| this.actualState.transitions.forEach((transition) => { | ||
| if (Utils.matchRule(transition.name, transitionName) || Utils.matchRegExp(transition.name, transitionName)) { | ||
| return resolve(transition) | ||
| } | ||
| }) | ||
| return reject(new Error('No se pudo encontrar el estado en las transiciones')) | ||
| } else { | ||
| return reject(new Error('No se pudo encontrar el estado en las transiciones')) | ||
| } | ||
| }) | ||
| } | ||
| Instance.prototype.getState = function (data) { | ||
| return new Promise((resolve, reject) => { | ||
| if (data && data.action) { | ||
| this.validateTransition(data.action).then((transition) => { | ||
| this.searchNextState(transition.to).then((nextState) => { | ||
| if (transition.use) { | ||
| this.middlewares[transition.use](this.actualState, (data) => { | ||
| this.actualState = nextState | ||
| return resolve(this.actualState) | ||
| }) | ||
| } else { | ||
| this.actualState = nextState | ||
| if (this.actualState.onEnter) { | ||
| if (this.actualState.onEnter.emit) { | ||
| this.internalEmitter.emit(this.actualState.onEnter.emit, this.actualState.onEnter.data) | ||
| } | ||
| } | ||
| return resolve(this.actualState) | ||
| }) | ||
| } else { | ||
| } | ||
| }) | ||
| }).catch((err) => { | ||
| this.searchNextState('default').then((nextState) => { | ||
| this.actualState = nextState | ||
@@ -76,63 +90,80 @@ if (this.actualState.onEnter) { | ||
| return resolve(this.actualState) | ||
| } | ||
| }).catch((err) => { | ||
| return resolve({ template: err }) | ||
| }) | ||
| }) | ||
| }).catch((err) => { | ||
| this.searchNextState('default').then((nextState) => { | ||
| this.actualState = nextState | ||
| if (this.actualState.onEnter) { | ||
| if (this.actualState.onEnter.emit) { | ||
| this.internalEmitter.emit(this.actualState.onEnter.emit, this.actualState.onEnter.data) | ||
| } | ||
| } | ||
| return resolve(this.actualState) | ||
| }).catch((err) => { | ||
| return resolve({ template: err }) | ||
| }) | ||
| }) | ||
| } else { | ||
| return resolve(this.actualState) | ||
| } | ||
| }) | ||
| } | ||
| } else { | ||
| return resolve(this.actualState) | ||
| } | ||
| }) | ||
| } | ||
| return Instance | ||
| })() | ||
| return Instance | ||
| })() | ||
| externals.Flow = (function () { | ||
| externals.Flow = (function () { | ||
| function Flow(name, model) { | ||
| this.name = name | ||
| this.model = model | ||
| this.instances = [] | ||
| this.middlewares = [] | ||
| this.internalEmitter = new flowEmitter(); | ||
| } | ||
| function Flow(name, model) { | ||
| this.name = name | ||
| this.model = model | ||
| this.instances = [] | ||
| this.middlewares = [] | ||
| this.internalEmitter = new flowEmitter(); | ||
| } | ||
| Flow.prototype.newInstance = function (id) { | ||
| //this.instances[id] = new externals.Instance(this.model, this.internalEmitter, this.middlewares) | ||
| //return this.instances[id] | ||
| return new Promise((resolve, reject) => { | ||
| var newInstance = new externals.Instance(this.model, this.internalEmitter, this.middlewares) | ||
| client.set(id, newInstance, this.model.ttl, (err) => { | ||
| if (err){ | ||
| reject(err) | ||
| } | ||
| resolve(newInstance) | ||
| }) | ||
| }) | ||
| } | ||
| Flow.prototype.newInstance = function (id) { | ||
| this.instances[id] = new externals.Instance(this.model, this.internalEmitter, this.middlewares) | ||
| return this.instances[id] | ||
| } | ||
| Flow.prototype.addInstance = function (instance) { | ||
| //this.instance[instance.id] = instance | ||
| //return this.instances[instance.id] | ||
| return new Promise((resolve, reject) => { | ||
| client.set(instance.id, instance, this.model.ttl, (err) => { | ||
| if (err){ | ||
| reject(err) | ||
| } | ||
| resolve(instance) | ||
| }) | ||
| }) | ||
| } | ||
| Flow.prototype.addInstance = function (instance) { | ||
| this.instance[instance.id] = instance | ||
| return this.instances[instance.id] | ||
| } | ||
| Flow.prototype.getInstance = function (id) { | ||
| //return this.instances[id] | ||
| return new Promise((resolve, reject) => { | ||
| client.get(id, (err, cached) => { | ||
| if (err){ | ||
| reject(err) | ||
| }else if (!cached){ | ||
| reject(new Error('Data not found')) | ||
| } | ||
| resolve(cached.item) | ||
| }) | ||
| }) | ||
| } | ||
| Flow.prototype.getInstance = function (id) { | ||
| return this.instances[id] | ||
| } | ||
| Flow.prototype.on = function (eventName, eventFunction) { | ||
| this.internalEmitter.on(eventName, eventFunction) | ||
| } | ||
| Flow.prototype.on = function (eventName, eventFunction) { | ||
| this.internalEmitter.on(eventName, eventFunction) | ||
| } | ||
| Flow.prototype.register = function (name, fn) { | ||
| this.middlewares[name] = fn | ||
| } | ||
| Flow.prototype.register = function (name, fn) { | ||
| this.middlewares[name] = fn | ||
| } | ||
| return Flow | ||
| return Flow | ||
| })() | ||
| })() | ||
| module.exports = externals | ||
| module.exports = externals | ||
| }) |
| { | ||
| "name": "flowx", | ||
| "version": "1.3.3", | ||
| "version": "1.4.0", | ||
| "description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
New alerts
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
Fixed alerts
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
Improved metrics
- Total package byte prevSize
- increased by13.55%
8926
- Lines of code
- increased by22.63%
168
Worsened metrics
- Number of downloads
- decreased by-100%
0
No dependency changes