@live-change/framework
Advanced tools
Comparing version 0.2.3 to 0.2.4
@@ -163,3 +163,4 @@ const ReactiveDao = require("@live-change/dao") | ||
const routes = await this.dao.get(['database', 'tableRange', this.databaseName, 'triggerRoutes', | ||
{ gte: data.type+'_', lte: data.type+'_\xFF\xFF\xFF\xFF' }]) | ||
{ gte: data.type+'=', lte: data.type+'=\xFF\xFF\xFF\xFF' }]) | ||
console.log("TRIGGER ROUTES", routes) | ||
let promises = [] | ||
@@ -166,0 +167,0 @@ for(const route of routes) { |
@@ -136,3 +136,3 @@ const Model = require("./Model.js") | ||
await this.dao.request(['database', 'createTable'], this.databaseName, 'triggersRoutes').catch(e => 'ok') | ||
await this.dao.request(['database', 'createTable'], this.databaseName, 'triggerRoutes').catch(e => 'ok') | ||
@@ -145,3 +145,3 @@ this.triggerQueue = new eventSourcing.CommandQueue(this.dao, this.databaseName, | ||
const trigger = this.triggers[triggerName] | ||
await this.dao.request(['database', 'put'], this.databaseName, 'triggersRoutes', | ||
await this.dao.request(['database', 'put'], this.databaseName, 'triggerRoutes', | ||
{ id: triggerName+'=>'+this.name, trigger: triggerName, service: this.name }) | ||
@@ -148,0 +148,0 @@ if(trigger.queuedBy) { |
{ | ||
"name": "@live-change/framework", | ||
"version": "0.2.3", | ||
"version": "0.2.4", | ||
"description": "Live Change Framework - ultimate solution for real time mobile/web apps", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
100390
2803