feat(ngrok): onConnect

Use the shiny new array lifting to support `tunnel.onConnect()`.

ngrok/README.md

@@ -42,6 +42,11 @@ let t = new ngrok.Tunnel(api.url,
   },
 );
 
+// you can add listeners
+t.onConnect(inflight (url) => {
+  log("url: {url}");
+});
+
 new cloud.Function(inflight () => {
   log("tunnel connected to {t.url}");
 });

ngrok/ngrok.test.w

@@ -26,8 +26,21 @@ api.get("/uri", inflight () => {
 
 let w = new cloud.Website(path: "./public");
 
-let external = new ngrok.Tunnel(api.url, domain: "eladbgithub.ngrok.dev");
+let external = new ngrok.Tunnel(api.url, 
+  domain: "eladbgithub.ngrok.dev",
+  onConnect: inflight (url) => {
+    log("onConnect called: {url}");
+  }
+);
+
+external.onConnect(inflight (url) => {
+  log("another onConnect callback: {url}");
+});
 
 new cloud.Function(inflight () => {
   log("ready {external.url}");
-});
+});
+
+test "url" {
+  log(external.url);
+}

ngrok/ngrok.w

@@ -14,16 +14,19 @@ pub interface OnConnectHandler {
 
 pub struct NgrokProps {
   domain: str?;
-  onConnect: OnConnectHandler?;
+  onConnect: (inflight (str): void)?;
 }
 
 pub class Tunnel {
   pub url: str;
   state: sim.State;
 
+  var onConnectHandlers: MutArray<inflight (str): void>;
+
   new(url: str, props: NgrokProps?) {
     this.state = new sim.State();
     this.url = this.state.token("url");
+    this.onConnectHandlers = MutArray<inflight (str): void>[];
 
     if !nodeof(this).app.isTestEnvironment {
       if !util.tryEnv("NGROK_AUTHTOKEN")? {
@@ -37,7 +40,9 @@ pub class Tunnel {
           log("ngrok: {child.url()} => {url}");
           let url = child.url();
           this.state.set("url", url);
-          props?.onConnect?.handle(url);
+          for handler in this.onConnectHandlers {
+            handler(url);
+          }
           return () => {
             child.kill();
           };
@@ -60,6 +65,14 @@ pub class Tunnel {
         this.state.set("url", "<test>");
       });
     }
+
+    if let h = props?.onConnect {
+      this.onConnect(h);
+    }
+  }
+
+  pub onConnect(handler: inflight (str): void) {
+    this.onConnectHandlers.push(handler);
   }
 
   extern "./util.js"