Merge pull request #17 from syumai/wait-for-ready

wait for ready to setup Go program
syumai · Nov 19, 2022 · 0e499ad · 0e499ad
2 parents 8794617 + 1f6f230
commit 0e499ad
Show file tree

Hide file tree

Showing 8 changed files with 36 additions and 0 deletions.
diff --git a/examples/basic-auth-proxy/worker.mjs b/examples/basic-auth-proxy/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/env/worker.mjs b/examples/env/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/hello/worker.mjs b/examples/hello/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/kv-counter/worker.mjs b/examples/kv-counter/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/r2-image-server/worker.mjs b/examples/r2-image-server/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/r2-image-viewer/worker.mjs b/examples/r2-image-viewer/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/examples/simple-json-server/worker.mjs b/examples/simple-json-server/worker.mjs
@@ -9,9 +9,14 @@ const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
  return instance;
 });
 
+const readyPromise = new Promise((resolve) => {
+ globalThis.ready = resolve;
+});
+
 async function processRequest(event) {
  const req = event.request;
  await load;
+ await readyPromise;
  return handleRequest(req);
 }
 

diff --git a/handler.go b/handler.go
@@ -67,5 +67,6 @@ func Serve(handler http.Handler) {
  handler = http.DefaultServeMux
  }
  httpHandler = handler
+ jsutil.Global.Call("ready")
  select {}
 }