Compare commits

..

No commits in common. "ee25b79fb5b5c24c1ec122b8cb73f13b98a0a540" and "ab53f86ed0a6d2306c642bda61c9fba14d34d266" have entirely different histories.

2 changed files with 62 additions and 69 deletions

View File

@ -647,6 +647,7 @@ module.BaseParser = {
&& (body = this.expand(page, body, state, nested_handlers))
// call macro...
//* XXX LOCAL_STATE
// NOTE: here we separate local macro state and global/parent
// state via the prototpype...
// This is mainly needed to sparate promises, since the
@ -654,8 +655,7 @@ module.BaseParser = {
// each macro can wait async for an arbitrary amount of
// time it only should care about what was promised
// before it neglecting what came after.
var res =
that.callMacro(page, name, args, body, {
var res = that.callMacro(page, name, args, body, {
// global/parent state...
__proto__: state,
root: state.root ?? state,
@ -664,6 +664,9 @@ module.BaseParser = {
waitAll: state.waitAll,
waitNested: state.waitNested,
})
/*/
var res = that.callMacro(page, name, args, body, state)
//*/
// async...
if(res instanceof Promise){
@ -790,6 +793,8 @@ module.BaseParser = {
ast
: ast.iter()
// XXX LOCAL_STATE
//state.unresolved = []
var unresolved = []
// merge resolved elements into the last item of elems...
@ -833,6 +838,9 @@ module.BaseParser = {
// nested macro with no value set -- skip...
if(that.macros[elem.name] instanceof Array){
continue }
// XXX LOCAL_STATE...
// ...use the same mechanism here as in .expand(..)
//state.unresolved
unresolved
.push(elem.resolving instanceof Promise ?
elem.resolving
@ -842,14 +850,13 @@ module.BaseParser = {
// are the responsibility of the respective macros...
elems.push(elem) }
if(unresolved.length > 0){
var resolving =
state.wait =
Promise.all([state.wait, ...unresolved])
// cleanup...
.then(function(){
if(state.wait === resolving){
delete state.wait } }) }
var resolving =
state.wait =
Promise.all([state.wait, ...unresolved])
// cleanup...
.then(function(){
if(state.wait === resolving){
delete state.wait } })
return elems },
@ -872,12 +879,10 @@ module.BaseParser = {
// - apply stage III post handlers
//
//
// XXX BUG: this seems to always return a promise...
// XXX RECURSION might be a good idea to limit recursion/nesting depth
// of inner resolve(..)...
// XXX RENAME...
finalize: function(page, ast, state={}, nested_handlers={}, wait='wait'){
//finalize: function(page, ast, state={}, nested_handlers={}, wait='waitNested'){
var that = this
var stage3 = function(ast){
@ -890,6 +895,7 @@ module.BaseParser = {
var resolve = function(ast){
return Promise.awaitOrRun(
// XXX LOCAL_STATE
//...(state.unresolved ?? []),
state.hasOwnProperty('wait') ?
state.wait
// XXX
@ -915,7 +921,7 @@ module.BaseParser = {
// XXX do we actually need to wait here???
// ...each macro should already be waiting...
//...[state[wait]].flat(),
(wait && state.hasOwnProperty(wait)) ?
state.hasOwnProperty(wait) ?
state[wait]
: null,
function(){
@ -925,9 +931,12 @@ module.BaseParser = {
return Promise.awaitOrRun(
// XXX LOCAL_STATE if we are nested we should not wait
// for anything after the caller...
that.isResolved(ast) ?
ast
: resolve(ast),
//(state.unresolved
// || !that.isResolved(ast)) ?
//state.hasOwnProperty('wait') ?
!that.isResolved(ast) ?
resolve(ast)
: ast,
function(ast){
return (
// stage III post...
@ -944,8 +953,16 @@ module.BaseParser = {
function(res){
return res.join('') }) },
// XXX
execNested: function(page, ast, state={}, nested_handlers={}){
//return ast
/* XXX LOCAL_STATE waitNested here deadlocks the parser -- not sure why...
//return this.exec(page, ast, state, nested_handlers, 'unresolved') },
return this.exec(page, ast, state, nested_handlers, 'waitNested') },
/*/
return this.exec(page, ast, state, nested_handlers, '') },
//*/
// XXX render api...
@ -1030,7 +1047,20 @@ module.parser = {
echo: function(page, args, body, state){
console.log(['----', ...Object.keys(args), body ?? ''].join(' ').gray)
return Promise.awaitOrRun(
// XXX this works and sequences correctly...
state.waitNested,
// XXX this deadlocks...
// calling .execNested(..) from any macro (@include(..)
// in the example code) will deadlock the execution
// if .execNested(..) is waiting for .waitNested...
// to reproduce:
// - uncomment the LOCAL_STATE track
// - run:
// @echo(A)@source(/async/echo)@echo(B)@include(/async/echo)@echo(C)
// -> need a way to call .exex(..) while evaluating...
//this.execNested(page, '', state),
// XXX this also does not work...
//this.resolve(page, '', state),
function(){
console.log(' --', ...Object.keys(args), body ?? '') }) },
//*/
@ -1080,16 +1110,18 @@ module.parser = {
// stage III
return function(state){
return Promise.awaitOrRun(
// apply the filters...
that.finalize(
page,
body,
{
__proto__: state,
...state,
filters: clear ?
filters
: [...filters, ...state.filters ?? []],
}),
function(body){
// stage III post...
// NOTE: we are protecting the result from
@ -1168,9 +1200,12 @@ module.parser = {
if(!name){
return '' }
// XXX LOCAL_STATE
//* XXX LOCAL_STATE
var vars = state.parent.vars ??= {}
//var vars = state.root.vars ??= {}
/*/
var vars = state.vars ??= {}
//*/
return Promise.awaitOrRun(
this.execNested(page, name, state),
@ -1315,9 +1350,12 @@ module.parser = {
var that = this
var name = args.name
// XXX LOCAL_STATE
//* XXX LOCAL_STATE
var slots = state.parent.slots ??= {}
//var slots = state.root.slots ??= {}
/*/
var slots = state.slots ??= {}
//*/
return Promise.awaitOrRun(
this.execNested(page, name, state),
@ -1676,9 +1714,12 @@ module.parser = {
function(page, args, body, state){
var that = this
// XXX LOCAL_STATE
//* XXX LOCAL_STATE
var macros = state.parent.macros ??= {}
//var macros = state.root.macros ??= {}
/*/
var macros = state.macros ??= {}
//*/
return Promise.awaitOrRun(
this.execNested(page, args.name, state),

View File

@ -399,55 +399,7 @@ test.Setups({
// XXX
// XXX filter...
filter_local: function(assert){
return {
page: P,
code: [
'<filter upper>moo</filter>',
'MOO' ]} },
filter_local_sync: function(assert){
return {
page: P,
code: [
'<filter upper>@include(/page)</filter>',
'PAGE' ]} },
filter_local_async: function(assert){
return {
page: P,
code: [
'<filter upper>@include(/async/page)</filter>',
'PAGE' ]} },
filter_global: function(assert){
return {
page: P,
code: [
'<filter upper/>moo',
'MOO' ]} },
filter_global_sync: function(assert){
return {
page: P,
code: [
'<filter upper/>@include(/page)',
'PAGE' ]} },
filter_global_async: function(assert){
return {
page: P,
code: [
'<filter upper/>@include(/async/page)',
'PAGE' ]} },
filter_mixed_isolated_sync: function(assert){
return {
page: P,
code: [
'<filter upper/>local <filter -upper>@include(/page)</filter>',
'LOCAL Page' ]} },
// XXX BUG
filter_mixed_isolated_async: function(assert){
return {
page: P,
code: [
'<filter upper/>local <filter -upper>@include(/async/page)</filter>',
'LOCAL Page' ]} },
// XXX
})