wip on tla

packages/webapp/webapp_server.js

@@ -1494,11 +1494,6 @@ WebAppInternals.getBoilerplate = getBoilerplate;
 WebAppInternals.additionalStaticJs = additionalStaticJs;
 
 // TODO[fibers]: change this when we have TLA
-runWebAppServer()
-  .then(_ => _)
-  .catch(e => {
-    
-  console.error(e.stack);
-  process.exit(1);
-})
+await runWebAppServer()
+
 

tools/runners/run-all.js

@@ -213,7 +213,7 @@ class Runner {
     if (! self.stopped) {
       console.log("before start");
       await buildmessage.enterJob({ title: "starting your app" }, async function () {
-        await self.appRunner.start();
+         await self.appRunner.start();
       });
       if (! self.quiet && ! self.stopped) {
         runLog.log("Started your app.",  { arrow: true });

tools/runners/run-app.js

@@ -13,7 +13,7 @@ import { pluginVersionsFromStarManifest } from '../cordova/index.js';
 import { closeAllWatchers } from "../fs/safe-watcher";
 import { eachline } from "../utils/eachline";
 import { loadIsopackage } from '../tool-env/isopackets.js';
-import { once , EventEmitter}  from "events"
+import { once , EventEmitter, on }  from "events"
 // Parse out s as if it were a bash command line.
 var bashParse = function (s) {
   if (s.search("\"") !== -1 || s.search("'") !== -1) {
@@ -415,6 +415,19 @@ Object.assign(AppRunner.prototype, {
     self.startPromise = null;
   },
 
+  _findCachedEE: function (name) {
+    if (!this._promiseResolvers[name]) {
+      this._promiseResolvers[name] = new EventEmitter();
+    }
+    return this._promiseResolvers[name];
+  },
+
+  _makeIterable : function (name) {
+    var self = this;
+    const ee = self._findCachedEE(name);
+    return on(ee, name);
+  },
+
   /**
    * @param name
    * @return {Promise<[any]>}
@@ -422,14 +435,8 @@ Object.assign(AppRunner.prototype, {
    */
   _makePromise: function (name) {
     var self = this;
-    const ee = new EventEmitter();
-    self._promiseResolvers[name] = ee;
-
+    const ee = self._findCachedEE(name);
     return once(ee, name);
-    // var self = this;
-    // return new Promise(function (resolve) {
-    //   self._promiseResolvers[name] = resolve;
-    // });
   },
 
   _resolvePromise: function (name, value) {
@@ -728,7 +735,6 @@ Object.assign(AppRunner.prototype, {
     self.runPromise = self._makePromise("run");
     var runPromise = self.runPromise;
     var listenPromise = self._makePromise("listen");
-    debugger;
 
     // Run the program
     options.beforeRun && options.beforeRun();