From fcebc0979459f8bcaec68e411349ac01b625f229 Mon Sep 17 00:00:00 2001
From: Kabir Shah <iamkbrsh@gmail.com>
Date: Thu, 18 Apr 2019 00:33:46 -0700
Subject: [PATCH] async execution of next set of phases

---
 packages/moon/dist/moon.js             | 17 +++++++++++++----
 packages/moon/dist/moon.min.js         |  2 +-
 packages/moon/src/executor/executor.js | 19 +++++++++++++++----
 3 files changed, 29 insertions(+), 9 deletions(-)

diff --git a/packages/moon/dist/moon.js b/packages/moon/dist/moon.js
index 4d58328d..aa595d21 100644
--- a/packages/moon/dist/moon.js
+++ b/packages/moon/dist/moon.js
@@ -934,7 +934,17 @@
 		executeQueue.shift(); // If there is new data in the execution queue, continue to it.
 
 		if (executeQueue.length !== 0) {
-			executeNext();
+			if (performance.now() - executeStart >= 16) {
+				// If the current frame doesn't have sufficient time left to keep
+				// running then start the next execution in the next frame.
+				requestAnimationFrame(function () {
+					executeStart = performance.now();
+					executeNext();
+				});
+			} else {
+				executeStart = performance.now();
+				executeNext();
+			}
 		}
 	}
 	/**
@@ -944,9 +954,7 @@
 
 	function executeNext() {
 		// Get the next data update.
-		var dataNew = executeQueue[0]; // Record the current time to reference when running different functions.
-
-		executeStart = performance.now(); // Merge new data into current data.
+		var dataNew = executeQueue[0]; // Merge new data into current data.
 
 		for (var key in dataNew) {
 			data[key] = dataNew[key];
@@ -988,6 +996,7 @@
 		executeQueue.push(dataNew); // Execute the next function in the queue if none are scheduled yet.
 
 		if (executeQueue.length === 1) {
+			executeStart = performance.now();
 			executeNext();
 		}
 	}
diff --git a/packages/moon/dist/moon.min.js b/packages/moon/dist/moon.min.js
index efa09d01..e7b38c31 100644
--- a/packages/moon/dist/moon.min.js
+++ b/packages/moon/dist/moon.min.js
@@ -4,4 +4,4 @@
  * Released under the MIT License
  * https://kbrsh.github.io/moon
  */
-!function(e,n){"undefined"==typeof module?e.Moon=n():module.exports=n()}(this,function(){"use strict";var v={element:0,text:1,component:2};var N=/<([\w\d-_]+)([^>]*?)(\/?)>/g,A=/\s*([\w\d-_:@]*)(?:=(?:("[^"]*"|'[^']*')|{([^{}]*)}))?/g,k=/"[^"]*"|'[^']*'|\d+[a-zA-Z$_]\w*|\.[a-zA-Z$_]\w*|[a-zA-Z$_]\w*:|([a-zA-Z$_]\w*)/g,E=["NaN","false","in","null","this","true","typeof","undefined","window"];function n(e){e=e.trim();for(var n=[],t=0;t<e.length;){var r=e[t];if("<"===r){var a=e[t+1];if("/"===a){var o=e.indexOf(">",t+2),d=e.slice(t+2,o);0,n.push({type:"tagClose",value:d}),t=o+1;continue}if("!"===a&&"-"===e[t+2]&&"-"===e[t+3]){var i=e.indexOf("--\x3e",t+4);0,t=i+3;continue}N.lastIndex=t;var l=N.exec(e);0;for(var u=l[0],p=l[1],f=l[2],s=l[3],c={},v=void 0;null!==(v=A.exec(f));){var h=v[0],m=v[1],w=v[2],g=v[3];0===h.length?A.lastIndex+=1:c[m]=void 0===g?w:g}n.push({type:"tagOpen",value:p,attributes:c,closed:"/"===s}),t+=u.length}else if("{"===r){var y="";for(t+=1;t<e.length;t++){var b=e[t];if("}"===b)break;y+=b}n.push({type:"tagOpen",value:"text",attributes:{"":y.replace(k,function(e,n){return void 0===n||-1!==E.indexOf(n)?e:"data."+n})},closed:!0}),t+=1}else{for(var x="";t<e.length;t++){var O=e[t];if("<"===O||"{"===O)break;x+=O}n.push({type:"tagOpen",value:"text",attributes:{"":'"'+x+'"'},closed:!0})}}return n}function p(e,n,t,r){this.message=e,this.start=n,this.end=t,this.next=r}function f(e,n,t){var r=t[e],a=t[n-1],o=n-e;if(0==o)return new p("",e,n);if(1==o)return"tagOpen"===r.type&&!0===r.closed?{type:r.value,attributes:r.attributes,children:[]}:new p("",e,n);if("tagOpen"!==r.type||"tagClose"!==a.type||r.value!==a.value)return new p("",e,n);var d=function e(n,t,r){var a;if(0==t-n)return[];for(var o=n+1;o<=t;o++){var d=f(n,o,r);if(d instanceof p)a=d;else{var i=e(o,t,r);if(!(i instanceof p)){for(var l=[d],u=0;u<i.length;u++)l.push(i[u]);return l}}}return new p("",n,t,a)}(e+1,n-1,t);return d instanceof p?new p("",e,n,d):{type:r.value,attributes:r.attributes,children:d}}function t(e){var n=f(0,e.length,e);return n}function i(e){var n,t=e.type;n="text"===t?v.text:t[0]===t[0].toLowerCase()?v.element:v.component;var r="{";for(var a in e.attributes)r+='"'+a+'":'+e.attributes[a]+",";r+="children:[";for(var o="",d=0;d<e.children.length;d++)r+=o+i(e.children[d]),o=",";return"{type:"+n+',name:"'+t+'",data:'+r+"]}}"}function a(e){return i(t(n(e)))}var u,s,o,h,r={},c={};function m(e){s=e}var g=[],y={updateText:0,setAttributes:1,appendElement:2,removeElement:3,replaceElement:4};function b(e){var n,t=e.type,r=e.name,a={},o=[];if(t===v.element){n=document.createElement(e.name);var d=e.data;for(var i in d){var l=d[i];"children"!==i&&(a[i]=l,n.setAttribute(i,l))}for(var u=d.children,p=0;p<u.length;p++){var f=b(u[p]);o.push(f),n.appendChild(f.node)}}else{var s=e.data[""];n=document.createTextNode(s),a[""]=s}return a.children=o,{type:t,name:r,data:a,node:n}}function w(e,n,t){for(;;){var r=e.pop(),a=n.pop();if(r!==a){if(r.name!==a.name)t.push({type:y.replaceElement,nodeOld:r,nodeNew:a,nodeParent:null});else if(r.type===v.text)t.push({type:y.updateText,nodeOld:r,nodeNew:a,parent:null});else{t.push({type:y.setAttributes,nodeOld:r,nodeNew:a,nodeParent:null});var o=r.data.children,d=a.data.children,i=o.length,l=d.length;if(i===l)for(var u=0;u<i;u++)e.push(o[u]),n.push(d[u]);else if(l<i){for(var p=0;p<l;p++)e.push(o[p]),n.push(d[p]);for(var f=l;f<i;f++)t.push({type:y.removeElement,nodeOld:o[f],nodeNew:null,nodeParent:r})}else{for(var s=0;s<i;s++)e.push(o[s]),n.push(d[s]);for(var c=i;c<l;c++)t.push({type:y.appendElement,nodeOld:null,nodeNew:d[c],nodeParent:r})}}if(0===e.length){x(t);break}if(16<=performance.now()-h){requestAnimationFrame(function(){h=performance.now(),w(e,n,t)});break}}}}function x(e){for(var n=0;n<e.length;n++){var t=e[n];switch(t.type){case y.updateText:var r=t.nodeOld,a=t.nodeNew.data[""];r.data[""]=a,r.node.textContent=a;break;case y.setAttributes:var o=t.nodeOld,d=o.data,i=o.node,l=t.nodeNew.data;for(var u in l){var p=l[u];"children"!==u&&(d[u]=p,i.setAttribute(u,p))}break;case y.appendElement:var f=t.nodeNew,s=t.nodeParent,c=b(f);s.data.children.push(c),s.node.appendChild(c.node);break;case y.removeElement:var v=t.nodeParent;v.data.children.pop(),v.node.removeChild(t.nodeOld.node);break;case y.replaceElement:var h=t.nodeOld,m=b(t.nodeNew),w=h.node;h.type=m.type,h.name=m.name,h.data=m.data,h.node=m.node,w.parentNode.replaceChild(h.node,w)}}g.shift(),0!==g.length&&O()}function O(){var e=g[0];for(var n in h=performance.now(),e)r[n]=e[n];!function e(n,t,r){for(;;){var a=n.pop(),o=t.pop(),d=r.pop();a.type===v.component?(a=c[a.name](a.data),null===o?m(a):o.data.children[d]=a):null===o&&m(a);for(var i=a.data.children,l=0;l<i.length;l++)n.push(i[l]),t.push(a),r.push(l);if(0===n.length){w([u],[s],[]);break}if(16<=performance.now()-h){requestAnimationFrame(function(){h=performance.now(),e(n,t,r)});break}}}([o(r)],[null],[0])}function d(e){g.push(e),1===g.length&&O()}function e(n){var e=function(e,n){return void 0===e?n:e}(n.name,"Root");delete n.name;var t=n.view;delete n.view,"string"==typeof t&&(t=new Function("data","return "+a(t)));var r="string"==typeof n.root?document.querySelector(n.root):n.root;delete n.root,void 0===r?c[e]=function(e){return t(function(e,n){var t={};for(var r in n)t[r]=n[r];for(var a in e)t[a]=e[a];return t}(e,n))}:(function(e){u=e}({type:v.element,name:r.tagName.toLowerCase(),data:{children:[]},node:r}),function(e){o=e}(t),d(n))}return e.lex=n,e.parse=t,e.generate=i,e.compile=a,e.components=c,e.set=d,e});
\ No newline at end of file
+!function(e,n){"undefined"==typeof module?e.Moon=n():module.exports=n()}(this,function(){"use strict";var v={element:0,text:1,component:2};var N=/<([\w\d-_]+)([^>]*?)(\/?)>/g,A=/\s*([\w\d-_:@]*)(?:=(?:("[^"]*"|'[^']*')|{([^{}]*)}))?/g,k=/"[^"]*"|'[^']*'|\d+[a-zA-Z$_]\w*|\.[a-zA-Z$_]\w*|[a-zA-Z$_]\w*:|([a-zA-Z$_]\w*)/g,E=["NaN","false","in","null","this","true","typeof","undefined","window"];function n(e){e=e.trim();for(var n=[],t=0;t<e.length;){var r=e[t];if("<"===r){var a=e[t+1];if("/"===a){var o=e.indexOf(">",t+2),i=e.slice(t+2,o);0,n.push({type:"tagClose",value:i}),t=o+1;continue}if("!"===a&&"-"===e[t+2]&&"-"===e[t+3]){var d=e.indexOf("--\x3e",t+4);0,t=d+3;continue}N.lastIndex=t;var l=N.exec(e);0;for(var u=l[0],p=l[1],f=l[2],s=l[3],c={},v=void 0;null!==(v=A.exec(f));){var h=v[0],m=v[1],w=v[2],g=v[3];0===h.length?A.lastIndex+=1:c[m]=void 0===g?w:g}n.push({type:"tagOpen",value:p,attributes:c,closed:"/"===s}),t+=u.length}else if("{"===r){var y="";for(t+=1;t<e.length;t++){var b=e[t];if("}"===b)break;y+=b}n.push({type:"tagOpen",value:"text",attributes:{"":y.replace(k,function(e,n){return void 0===n||-1!==E.indexOf(n)?e:"data."+n})},closed:!0}),t+=1}else{for(var x="";t<e.length;t++){var O=e[t];if("<"===O||"{"===O)break;x+=O}n.push({type:"tagOpen",value:"text",attributes:{"":'"'+x+'"'},closed:!0})}}return n}function p(e,n,t,r){this.message=e,this.start=n,this.end=t,this.next=r}function f(e,n,t){var r=t[e],a=t[n-1],o=n-e;if(0==o)return new p("",e,n);if(1==o)return"tagOpen"===r.type&&!0===r.closed?{type:r.value,attributes:r.attributes,children:[]}:new p("",e,n);if("tagOpen"!==r.type||"tagClose"!==a.type||r.value!==a.value)return new p("",e,n);var i=function e(n,t,r){var a;if(0==t-n)return[];for(var o=n+1;o<=t;o++){var i=f(n,o,r);if(i instanceof p)a=i;else{var d=e(o,t,r);if(!(d instanceof p)){for(var l=[i],u=0;u<d.length;u++)l.push(d[u]);return l}}}return new p("",n,t,a)}(e+1,n-1,t);return i instanceof p?new p("",e,n,i):{type:r.value,attributes:r.attributes,children:i}}function t(e){var n=f(0,e.length,e);return n}function d(e){var n,t=e.type;n="text"===t?v.text:t[0]===t[0].toLowerCase()?v.element:v.component;var r="{";for(var a in e.attributes)r+='"'+a+'":'+e.attributes[a]+",";r+="children:[";for(var o="",i=0;i<e.children.length;i++)r+=o+d(e.children[i]),o=",";return"{type:"+n+',name:"'+t+'",data:'+r+"]}}"}function a(e){return d(t(n(e)))}var u,s,o,g,r={},c={};function h(e){s=e}var y=[],b={updateText:0,setAttributes:1,appendElement:2,removeElement:3,replaceElement:4};function x(e){var n,t=e.type,r=e.name,a={},o=[];if(t===v.element){n=document.createElement(e.name);var i=e.data;for(var d in i){var l=i[d];"children"!==d&&(a[d]=l,n.setAttribute(d,l))}for(var u=i.children,p=0;p<u.length;p++){var f=x(u[p]);o.push(f),n.appendChild(f.node)}}else{var s=e.data[""];n=document.createTextNode(s),a[""]=s}return a.children=o,{type:t,name:r,data:a,node:n}}function m(e,n,t){for(;;){var r=e.pop(),a=n.pop();if(r!==a){if(r.name!==a.name)t.push({type:b.replaceElement,nodeOld:r,nodeNew:a,nodeParent:null});else if(r.type===v.text)t.push({type:b.updateText,nodeOld:r,nodeNew:a,parent:null});else{t.push({type:b.setAttributes,nodeOld:r,nodeNew:a,nodeParent:null});var o=r.data.children,i=a.data.children,d=o.length,l=i.length;if(d===l)for(var u=0;u<d;u++)e.push(o[u]),n.push(i[u]);else if(l<d){for(var p=0;p<l;p++)e.push(o[p]),n.push(i[p]);for(var f=l;f<d;f++)t.push({type:b.removeElement,nodeOld:o[f],nodeNew:null,nodeParent:r})}else{for(var s=0;s<d;s++)e.push(o[s]),n.push(i[s]);for(var c=d;c<l;c++)t.push({type:b.appendElement,nodeOld:null,nodeNew:i[c],nodeParent:r})}}if(0===e.length){w(t);break}if(16<=performance.now()-g){requestAnimationFrame(function(){g=performance.now(),m(e,n,t)});break}}}}function w(e){for(var n=0;n<e.length;n++){var t=e[n];switch(t.type){case b.updateText:var r=t.nodeOld,a=t.nodeNew.data[""];r.data[""]=a,r.node.textContent=a;break;case b.setAttributes:var o=t.nodeOld,i=o.data,d=o.node,l=t.nodeNew.data;for(var u in l){var p=l[u];"children"!==u&&(i[u]=p,d.setAttribute(u,p))}break;case b.appendElement:var f=t.nodeNew,s=t.nodeParent,c=x(f);s.data.children.push(c),s.node.appendChild(c.node);break;case b.removeElement:var v=t.nodeParent;v.data.children.pop(),v.node.removeChild(t.nodeOld.node);break;case b.replaceElement:var h=t.nodeOld,m=x(t.nodeNew),w=h.node;h.type=m.type,h.name=m.name,h.data=m.data,h.node=m.node,w.parentNode.replaceChild(h.node,w)}}y.shift(),0!==y.length&&(16<=performance.now()-g?requestAnimationFrame(function(){g=performance.now(),O()}):(g=performance.now(),O()))}function O(){var e=y[0];for(var n in e)r[n]=e[n];!function e(n,t,r){for(;;){var a=n.pop(),o=t.pop(),i=r.pop();a.type===v.component?(a=c[a.name](a.data),null===o?h(a):o.data.children[i]=a):null===o&&h(a);for(var d=a.data.children,l=0;l<d.length;l++)n.push(d[l]),t.push(a),r.push(l);if(0===n.length){m([u],[s],[]);break}if(16<=performance.now()-g){requestAnimationFrame(function(){g=performance.now(),e(n,t,r)});break}}}([o(r)],[null],[0])}function i(e){y.push(e),1===y.length&&(g=performance.now(),O())}function e(n){var e=function(e,n){return void 0===e?n:e}(n.name,"Root");delete n.name;var t=n.view;delete n.view,"string"==typeof t&&(t=new Function("data","return "+a(t)));var r="string"==typeof n.root?document.querySelector(n.root):n.root;delete n.root,void 0===r?c[e]=function(e){return t(function(e,n){var t={};for(var r in n)t[r]=n[r];for(var a in e)t[a]=e[a];return t}(e,n))}:(function(e){u=e}({type:v.element,name:r.tagName.toLowerCase(),data:{children:[]},node:r}),function(e){o=e}(t),i(n))}return e.lex=n,e.parse=t,e.generate=d,e.compile=a,e.components=c,e.set=i,e});
\ No newline at end of file
diff --git a/packages/moon/src/executor/executor.js b/packages/moon/src/executor/executor.js
index d9055931..d79b1b92 100644
--- a/packages/moon/src/executor/executor.js
+++ b/packages/moon/src/executor/executor.js
@@ -347,7 +347,19 @@ function executePatch(patches) {
 
 	// If there is new data in the execution queue, continue to it.
 	if (executeQueue.length !== 0) {
-		executeNext();
+		if (performance.now() - executeStart >= 16) {
+			// If the current frame doesn't have sufficient time left to keep
+			// running then start the next execution in the next frame.
+			requestAnimationFrame(() => {
+				executeStart = performance.now();
+
+				executeNext();
+			});
+		} else {
+			executeStart = performance.now();
+
+			executeNext();
+		}
 	}
 }
 
@@ -358,9 +370,6 @@ function executeNext() {
 	// Get the next data update.
 	const dataNew = executeQueue[0];
 
-	// Record the current time to reference when running different functions.
-	executeStart = performance.now();
-
 	// Merge new data into current data.
 	for (let key in dataNew) {
 		data[key] = dataNew[key];
@@ -402,6 +411,8 @@ export function execute(dataNew) {
 
 	// Execute the next function in the queue if none are scheduled yet.
 	if (executeQueue.length === 1) {
+		executeStart = performance.now();
+
 		executeNext();
 	}
 }