feat: event bus support for devtools

dev/index.html

@@ -113,7 +113,7 @@
   <div id="view"></div>
 <script type="module">
   import yaml from '../node_modules/yaml/browser/index.js';
-  import { astToDOM, astToESM, clear, parseSpec, setDatabaseConnector, vg } from './setup.ts';
+  import { astToDOM, astToESM, clear, observeLogger, parseSpec, setDatabaseConnector, vg } from './setup.ts';
 
   const view = document.querySelector('#view');
   const connectorMenu = document.querySelector('#connectors');
@@ -124,6 +124,7 @@
   const consolidateToggle = document.querySelector('#consolidate');
   const preaggToggle = document.querySelector('#preagg');
   const preaggState = document.querySelector('#preagg-state');
+  let unobserveQueryLog;
 
   connectorMenu.addEventListener('change', setConnector);
   exampleMenu.addEventListener('change', reload);
@@ -156,7 +157,10 @@
   }
 
   function setQueryLog() {
-    vg.coordinator().manager.logQueries(qlogToggle.checked);
+    unobserveQueryLog?.();
+    unobserveQueryLog = qlogToggle.checked
+      ? observeLogger(vg.coordinator(), console)
+      : undefined;
   }
 
   function setCache() {

dev/query/index.html

@@ -29,7 +29,7 @@
     <br/>
     <div id="output"></div>
 <script type="module">
-  import { setDatabaseConnector, vg } from '../setup.js';
+  import { observeLogger, setDatabaseConnector, vg } from '../setup.js';
   const tableName = 'query_result';
 
   const input = document.querySelector('#input');
@@ -73,6 +73,8 @@
     }
     enable();
   });
+
+  observeLogger(vg.coordinator(), console);
 </script>
   </body>
 </html>

dev/setup.ts

@@ -1,7 +1,8 @@
-import { DuckDBWASMConnector, RestConnector, SocketConnector } from '@uwdata/mosaic-core';
+import { DuckDBWASMConnector, observeLogger, RestConnector, SocketConnector } from '@uwdata/mosaic-core';
 import { createAPIContext } from '@uwdata/vgplot';
 
 export { parseSpec, astToDOM, astToESM } from '@uwdata/mosaic-spec';
+export { observeLogger };
 export const vg = createAPIContext();
 
 // make API accessible for console debugging