go/wasm-http-server
1
0
Fork 0
mirror of https://github.com/nlepage/go-wasm-http-server.git synced 2026-01-12 10:09:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: go:v2.2.1
Branches Tags
go:master go:v1
go:v2.2.1 go:v2.2.0 go:v2.1.0 go:v2.0.5 go:v2.0.4 go:v2.0.3 go:v2.0.2 go:v2.0.1 go:v2.0.0 go:v1.1.0 go:v1.0.1 go:v1.0.0
..
compare: go:master
Branches Tags
go:master go:v1
go:v2.2.1 go:v2.2.0 go:v2.1.0 go:v2.0.5 go:v2.0.4 go:v2.0.3 go:v2.0.2 go:v2.0.1 go:v2.0.0 go:v1.1.0 go:v1.0.1 go:v1.0.0

3 Commits
v2.2.1 ... master

Author SHA1 Message Date
Nicolas Lepage
fb62588b31 feat: adds Referer, Host, RequestURI and User-Agent on request 2025-11-21 10:16:13 +01:00
Nicolas Lepage
9ae9f3c443 feat: allows registering multiple wasm instances 2025-11-21 01:04:46 +01:00
Nicolas Lepage
9ff6ec615a docs: updates build tags and adds warning for FOSDEM video 2025-02-13 10:41:03 +01:00
25 changed files with 327 additions and 148 deletions
Expand all files Collapse all files

5
.prettierrc Normal file
View File

@@ -0,0 +1,5 @@
{
"printWidth": 120,
"singleQuote": true,
"trailingComma": "all"
}

10
README.md
View File

@@ -22,7 +22,11 @@
## How? ## How?
Talk given at the Go devroom of FOSDEM 2021 explaining how `go-wasm-http-server` works: Below is a talk given at the Go devroom of FOSDEM 2021 explaining how `go-wasm-http-server` works.
> [!WARNING]
> `go-wasm-http-server` has suffered major changes since this talk, be aware that it is not accurate anymore on several aspects.
> Please refer to the documentation below for up to date usage of `go-wasm-http-server`.
[![Deploy a Go HTTP server in your browser Youtube link](https://raw.githubusercontent.com/nlepage/go-wasm-http-talk/main/youtube.png)](https://youtu.be/O2RB_8ircdE) [![Deploy a Go HTTP server in your browser Youtube link](https://raw.githubusercontent.com/nlepage/go-wasm-http-talk/main/youtube.png)](https://youtu.be/O2RB_8ircdE)
@@ -47,7 +51,7 @@ In your Go code, replace [`http.ListenAndServe()`](https://pkg.go.dev/net/http#L
📄 `server.go` 📄 `server.go`
```go ```go
// +build !js,!wasm //go:build !js && !wasm
package main package main
@@ -66,7 +70,7 @@ becomes:
📄 `server_js_wasm.go` 📄 `server_js_wasm.go`
```go ```go
// +build js,wasm //go:build js && wasm
package main package main

27
docs/hello-multiple/api.go Normal file
View File

@@ -0,0 +1,27 @@
package main
import (
"encoding/json"
"fmt"
"net/http"
"os"
wasmhttp "github.com/nlepage/go-wasm-http-server/v2"
)
var binaryName = ""
func main() {
http.HandleFunc("/hello", func(res http.ResponseWriter, req *http.Request) {
res.Header().Add("Content-Type", "application/json")
if err := json.NewEncoder(res).Encode(map[string]string{
"message": fmt.Sprintf("Hello from %s at path %s", binaryName, os.Getenv("WASM_HTTP_PATH")),
}); err != nil {
panic(err)
}
})
wasmhttp.Serve(nil)
select {}
}

BIN
docs/hello-multiple/api1.wasm Executable file
View File

Binary file not shown.

BIN
docs/hello-multiple/api2.wasm Executable file
View File

Binary file not shown.

3
docs/hello-multiple/build.sh Executable file
View File

@@ -0,0 +1,3 @@
#!/bin/sh
GOOS=js GOARCH=wasm go build -o api1.wasm --ldflags="-X 'main.binaryName=api1.wasm'" .
GOOS=js GOARCH=wasm go build -o api2.wasm --ldflags="-X 'main.binaryName=api2.wasm'" .

29
docs/hello-multiple/index.html Normal file
View File

@@ -0,0 +1,29 @@
<!DOCTYPE html>
<html>
<head>
<title>go-wasm-http-server hello demo</title>
<script>
navigator.serviceWorker.register('sw.js');
async function hello() {
const api = document.querySelector('#api').value;
const res = await fetch(`${api}/hello`);
const { message } = await res.json();
alert(message);
}
</script>
</head>
<body>
<label for="api">API: </label
><select id="api">
<option value="api1/1">api1.wasm first instance</option>
<option value="api1/2">api1.wasm second instance</option>
<option value="api2/1">api2.wasm first instance</option>
<option value="api2/2">api2.wasm second instance</option>
</select>
<button onclick="hello()">Hello</button>
</body>
</html>

15
docs/hello-multiple/sw.js Normal file
View File

@@ -0,0 +1,15 @@
importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.25.1/lib/wasm/wasm_exec.js');
importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@master/sw.js');
addEventListener('install', (event) => {
event.waitUntil(caches.open('examples').then((cache) => cache.addAll(['api1.wasm', 'api2.wasm'])));
});
addEventListener('activate', (event) => {
event.waitUntil(clients.claim());
});
registerWasmHTTPListener('api1.wasm', { base: 'api1/1/' });
registerWasmHTTPListener('api1.wasm', { base: 'api1/2/' });
registerWasmHTTPListener('api2.wasm', { base: 'api2/1/' });
registerWasmHTTPListener('api2.wasm', { base: 'api2/2/' });

BIN
docs/hello-sse/api.wasm
View File

Binary file not shown.

57
docs/hello-sse/index.html
View File

@@ -3,47 +3,46 @@
<head> <head>
<title>go-wasm-http-server hello sse demo</title> <title>go-wasm-http-server hello sse demo</title>
<script> <script>
navigator.serviceWorker.register('sw.js') navigator.serviceWorker.register('sw.js').then((registration) => {
.then(registration => { const serviceWorker = registration.installing ?? registration.waiting ?? registration.active;
const serviceWorker = registration.installing ?? registration.waiting ?? registration.active if (serviceWorker.state === 'activated') {
if (serviceWorker.state === 'activated') { document.querySelector('#open-button').disabled = false;
document.querySelector('#open-button').disabled = false } else {
} else { serviceWorker.addEventListener('statechange', (e) => {
serviceWorker.addEventListener('statechange', e => { if (e.target.state === 'activated') {
if (e.target.state === 'activated') { document.querySelector('#open-button').disabled = false;
document.querySelector('#open-button').disabled = false }
} });
}) }
} });
})
window.addEventListener('DOMContentLoaded', () => { window.addEventListener('DOMContentLoaded', () => {
let es; let es;
document.querySelector('#open-button').addEventListener('click', () => { document.querySelector('#open-button').addEventListener('click', () => {
if (es && es.readyState === es.OPEN) return if (es && es.readyState === es.OPEN) return;
es = new EventSource('api/events') es = new EventSource('api/events');
es.addEventListener('ping', (e) => { es.addEventListener('ping', (e) => {
const li = document.createElement('li') const li = document.createElement('li');
li.textContent = `ping: data=${e.data}` li.textContent = `ping: data=${e.data}`;
document.querySelector('ul').append(li) document.querySelector('ul').append(li);
}) });
}) });
document.querySelector('#close-button').addEventListener('click', () => { document.querySelector('#close-button').addEventListener('click', () => {
if (!es) return if (!es) return;
es.close() es.close();
}) });
document.querySelector('#clear-button').addEventListener('click', () => { document.querySelector('#clear-button').addEventListener('click', () => {
document.querySelector('ul').innerHTML = '' document.querySelector('ul').innerHTML = '';
}) });
window.addEventListener('unload', () => { window.addEventListener('unload', () => {
if (!es) return if (!es) return;
es.close() es.close();
}) });
}) });
</script> </script>
</head> </head>
<body> <body>

16
docs/hello-sse/sw.js
View File

@@ -1,14 +1,14 @@
importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.23.1/misc/wasm/wasm_exec.js') importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.25.1/lib/wasm/wasm_exec.js');
importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@v2.2.1/sw.js') importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@master/sw.js');
const wasm = 'api.wasm' const wasm = 'api.wasm';
addEventListener('install', (event) => { addEventListener('install', (event) => {
event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm))) event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm)));
}) });
addEventListener('activate', (event) => { addEventListener('activate', (event) => {
event.waitUntil(clients.claim()) event.waitUntil(clients.claim());
}) });
registerWasmHTTPListener(wasm, { base: 'api' }) registerWasmHTTPListener(wasm, { base: 'api' });

22
docs/hello-state-keepalive/index.html
View File

@@ -3,30 +3,30 @@
<head> <head>
<title>go-wasm-http-server hello with state and keepalive demo</title> <title>go-wasm-http-server hello with state and keepalive demo</title>
<script> <script>
navigator.serviceWorker.register('sw.js').then(registration => { navigator.serviceWorker.register('sw.js').then((registration) => {
const sw = registration.active ?? registration.installing ?? registration.waiting const sw = registration.active ?? registration.installing ?? registration.waiting;
setInterval(() => sw.postMessage(null), 15000) setInterval(() => sw.postMessage(null), 15000);
}) });
async function hello() { async function hello() {
const name = document.querySelector("#name").value const name = document.querySelector('#name').value;
const res = await fetch('api/hello', { const res = await fetch('api/hello', {
method: 'POST', method: 'POST',
headers: { headers: {
'Content-Type': 'application/json' 'Content-Type': 'application/json',
}, },
body: JSON.stringify({ name }) body: JSON.stringify({ name }),
}) });
const { message } = await res.json() const { message } = await res.json();
alert(message) alert(message);
} }
</script> </script>
</head> </head>
<body> <body>
<label for="name">Name: </label><input id="name" value="World"> <label for="name">Name: </label><input id="name" value="World" />
<button onclick="hello()">Hello</button> <button onclick="hello()">Hello</button>
</body> </body>
</html> </html>

22
docs/hello-state-keepalive/sw.js
View File

@@ -1,16 +1,16 @@
importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.23.1/misc/wasm/wasm_exec.js') importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.25.1/lib/wasm/wasm_exec.js');
importScripts('../sw.js') importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@master/sw.js');
const wasm = '../hello-state/api.wasm' const wasm = '../hello-state/api.wasm';
addEventListener('install', event => { addEventListener('install', (event) => {
event.waitUntil(caches.open('hello-state').then((cache) => cache.add(wasm))) event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm)));
}) });
addEventListener('activate', event => { addEventListener('activate', (event) => {
event.waitUntil(clients.claim()) event.waitUntil(clients.claim());
}) });
addEventListener('message', () => {}) addEventListener('message', () => {});
registerWasmHTTPListener(wasm, { base: 'api' }) registerWasmHTTPListener(wasm, { base: 'api' });

BIN
docs/hello-state/api.wasm
View File

Binary file not shown.

16
docs/hello-state/index.html
View File

@@ -3,27 +3,27 @@
<head> <head>
<title>go-wasm-http-server hello with state demo</title> <title>go-wasm-http-server hello with state demo</title>
<script> <script>
navigator.serviceWorker.register('sw.js') navigator.serviceWorker.register('sw.js');
async function hello() { async function hello() {
const name = document.querySelector("#name").value const name = document.querySelector('#name').value;
const res = await fetch('api/hello', { const res = await fetch('api/hello', {
method: 'POST', method: 'POST',
headers: { headers: {
'Content-Type': 'application/json' 'Content-Type': 'application/json',
}, },
body: JSON.stringify({ name }) body: JSON.stringify({ name }),
}) });
const { message } = await res.json() const { message } = await res.json();
alert(message) alert(message);
} }
</script> </script>
</head> </head>
<body> <body>
<label for="name">Name: </label><input id="name" value="World"> <label for="name">Name: </label><input id="name" value="World" />
<button onclick="hello()">Hello</button> <button onclick="hello()">Hello</button>
</body> </body>
</html> </html>

16
docs/hello-state/sw.js
View File

@@ -1,14 +1,14 @@
importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.23.1/misc/wasm/wasm_exec.js') importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.25.1/lib/wasm/wasm_exec.js');
importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@v2.2.1/sw.js') importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@master/sw.js');
const wasm = 'api.wasm' const wasm = 'api.wasm';
addEventListener('install', (event) => { addEventListener('install', (event) => {
event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm))) event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm)));
}) });
addEventListener('activate', (event) => { addEventListener('activate', (event) => {
event.waitUntil(clients.claim()) event.waitUntil(clients.claim());
}) });
registerWasmHTTPListener(wasm, { base: 'api' }) registerWasmHTTPListener(wasm, { base: 'api' });

BIN
docs/hello/api.wasm
View File

Binary file not shown.

16
docs/hello/index.html
View File

@@ -3,27 +3,27 @@
<head> <head>
<title>go-wasm-http-server hello demo</title> <title>go-wasm-http-server hello demo</title>
<script> <script>
navigator.serviceWorker.register('sw.js') navigator.serviceWorker.register('sw.js');
async function hello() { async function hello() {
const name = document.querySelector("#name").value const name = document.querySelector('#name').value;
const res = await fetch('api/hello', { const res = await fetch('api/hello', {
method: 'POST', method: 'POST',
headers: { headers: {
'Content-Type': 'application/json' 'Content-Type': 'application/json',
}, },
body: JSON.stringify({ name }) body: JSON.stringify({ name }),
}) });
const { message } = await res.json() const { message } = await res.json();
alert(message) alert(message);
} }
</script> </script>
</head> </head>
<body> <body>
<label for="name">Name: </label><input id="name" value="World"> <label for="name">Name: </label><input id="name" value="World" />
<button onclick="hello()">Hello</button> <button onclick="hello()">Hello</button>
</body> </body>
</html> </html>

16
docs/hello/sw.js
View File

@@ -1,14 +1,14 @@
importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.23.1/misc/wasm/wasm_exec.js') importScripts('https://cdn.jsdelivr.net/gh/golang/go@go1.25.1/lib/wasm/wasm_exec.js');
importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@v2.2.1/sw.js') importScripts('https://cdn.jsdelivr.net/gh/nlepage/go-wasm-http-server@master/sw.js');
const wasm = 'api.wasm' const wasm = 'api.wasm';
addEventListener('install', (event) => { addEventListener('install', (event) => {
event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm))) event.waitUntil(caches.open('examples').then((cache) => cache.add(wasm)));
}) });
addEventListener('activate', (event) => { addEventListener('activate', (event) => {
event.waitUntil(clients.claim()) event.waitUntil(clients.claim());
}) });
registerWasmHTTPListener(wasm, { base: 'api' }) registerWasmHTTPListener(wasm, { base: 'api' });

39
docs/index.html
View File

@@ -6,11 +6,40 @@
<body> <body>
<h1>go-wasm-http-server examples</h1> <h1>go-wasm-http-server examples</h1>
<ul> <ul>
<li><a href="hello/">Hello example</a> (<a href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello">Sources</a>)</li> <li>
<li><a href="hello-state/">Hello example with state</a> (<a href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-state">Sources</a>)</li> <a href="hello/">Hello example</a> (<a
<li><a href="hello-state-keepalive/">Hello example with state and keepalive</a> (<a href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-state-keepalive">Sources</a>)</li> href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello"
<li><a href="hello-sse/">Hello example with Server Sent Events</a> (<a href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-sse">Sources</a>)</li> >Sources</a
>)
</li>
<li>
<a href="hello-multiple/">Hello example with multiple wasm instances</a> (<a
href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-multiple"
>Sources</a
>)
</li>
<li>
<a href="hello-state/">Hello example with state</a> (<a
href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-state"
>Sources</a
>)
</li>
<li>
<a href="hello-state-keepalive/">Hello example with state and keepalive</a> (<a
href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-state-keepalive"
>Sources</a
>)
</li>
<li>
<a href="hello-sse/">Hello example with Server Sent Events</a> (<a
href="https://github.com/nlepage/go-wasm-http-server/tree/master/docs/hello-sse"
>Sources</a
>)
</li>
</ul> </ul>
<p>See <a href="https://github.com/nlepage/go-wasm-http-server?tab=readme-ov-file#readme">README</a> for more information.</p> <p>
See <a href="https://github.com/nlepage/go-wasm-http-server?tab=readme-ov-file#readme">README</a> for more
information.
</p>
</body> </body>
</html> </html>

6
go.mod
View File

@@ -1,9 +1,9 @@
module github.com/nlepage/go-wasm-http-server/v2 module github.com/nlepage/go-wasm-http-server/v2
go 1.18 go 1.22
require ( require (
github.com/hack-pad/safejs v0.1.1 github.com/hack-pad/safejs v0.1.1
github.com/nlepage/go-js-promise v1.0.0 github.com/nlepage/go-js-promise v1.1.0
github.com/tmaxmax/go-sse v0.8.0 github.com/tmaxmax/go-sse v0.11.0
) )

11
go.sum
View File

@@ -1,9 +1,6 @@
github.com/hack-pad/safejs v0.1.1 h1:d5qPO0iQ7h2oVtpzGnLExE+Wn9AtytxIfltcS2b9KD8= github.com/hack-pad/safejs v0.1.1 h1:d5qPO0iQ7h2oVtpzGnLExE+Wn9AtytxIfltcS2b9KD8=
github.com/hack-pad/safejs v0.1.1/go.mod h1:HdS+bKF1NrE72VoXZeWzxFOVQVUSqZJAG0xNCnb+Tio= github.com/hack-pad/safejs v0.1.1/go.mod h1:HdS+bKF1NrE72VoXZeWzxFOVQVUSqZJAG0xNCnb+Tio=
github.com/nlepage/go-js-promise v1.0.0 h1:K7OmJ3+0BgWJ2LfXchg2sI6RDr7AW/KWR8182epFwGQ= github.com/nlepage/go-js-promise v1.1.0 h1:BfvywsIMo4cpNOKyoReBWkxEW8f9HMwXqGc45wEKPRs=
github.com/nlepage/go-js-promise v1.0.0/go.mod h1:bdOP0wObXu34euibyK39K1hoBCtlgTKXGc56AGflaRo= github.com/nlepage/go-js-promise v1.1.0/go.mod h1:bdOP0wObXu34euibyK39K1hoBCtlgTKXGc56AGflaRo=
github.com/tmaxmax/go-sse v0.8.0 h1:pPpTgyyi1r7vG2o6icebnpGEh3ebcnBXqDWkb7aTofs= github.com/tmaxmax/go-sse v0.11.0 h1:nogmJM6rJUoOLoAwEKeQe5XlVpt9l7N82SS1jI7lWFg=
github.com/tmaxmax/go-sse v0.8.0/go.mod h1:HLoxqxdH+7oSUItjtnpxjzJedfr/+Rrm/dNWBcTxJFM= github.com/tmaxmax/go-sse v0.11.0/go.mod h1:u/2kZQR1tyngo1lKaNCj1mJmhXGZWS1Zs5yiSOD+Eg8=
golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/tools v0.5.0/go.mod h1:N+Kgy78s5I24c24dU8OfWNEotWjutIs8SnJvn5IDq+k=

20
request.go
View File

@@ -11,6 +11,10 @@ import (
"github.com/nlepage/go-wasm-http-server/v2/internal/safejs" "github.com/nlepage/go-wasm-http-server/v2/internal/safejs"
) )
var (
navigator = safejs.Safe(js.Global().Get("navigator"))
)
// Request builds and returns the equivalent http.Request // Request builds and returns the equivalent http.Request
func Request(uvalue js.Value) (*http.Request, error) { func Request(uvalue js.Value) (*http.Request, error) {
value := safejs.Safe(uvalue) value := safejs.Safe(uvalue)
@@ -66,13 +70,21 @@ func Request(uvalue js.Value) (*http.Request, error) {
req := &http.Request{ req := &http.Request{
Method: method, Method: method,
URL: u, URL: u,
Host: u.Host,
Body: bodyReader, Body: bodyReader,
Header: make(http.Header), Header: make(http.Header),
Proto: "HTTP/1.1", Proto: "HTTP/1.1",
ProtoMajor: 1, ProtoMajor: 1,
ProtoMinor: 1, ProtoMinor: 1,
RequestURI: rawURL,
} }
referer, err := value.GetString("referrer")
if err != nil {
return nil, err
}
req.Header.Set("Referer", referer)
headers, err := value.Get("headers") headers, err := value.Get("headers")
if err != nil { if err != nil {
return nil, err return nil, err
@@ -115,5 +127,13 @@ func Request(uvalue js.Value) (*http.Request, error) {
req.Header.Set(key, value) req.Header.Set(key, value)
} }
if req.UserAgent() == "" {
userAgent, err := navigator.GetString("userAgent")
if err != nil {
return nil, err
}
req.Header.Set("User-Agent", userAgent)
}
return req, nil return req, nil
} }

9
serve.go
View File

@@ -4,6 +4,7 @@ import (
"context" "context"
"fmt" "fmt"
"net/http" "net/http"
"os"
"strings" "strings"
"syscall/js" "syscall/js"
@@ -21,10 +22,8 @@ func Serve(handler http.Handler) (func(), error) {
h = http.DefaultServeMux h = http.DefaultServeMux
} }
prefix, err := wasmhttp.GetString("path") path := os.Getenv("WASM_HTTP_PATH")
if err != nil { prefix := path
return nil, err
}
for strings.HasSuffix(prefix, "/") { for strings.HasSuffix(prefix, "/") {
prefix = strings.TrimSuffix(prefix, "/") prefix = strings.TrimSuffix(prefix, "/")
@@ -78,7 +77,7 @@ func Serve(handler http.Handler) (func(), error) {
return nil, err return nil, err
} }
if _, err = wasmhttp.Call("setHandler", handlerValue); err != nil { if _, err = wasmhttp.Call("setHandler", path, handlerValue); err != nil {
return nil, err return nil, err
} }

112
sw.js
View File

@@ -1,42 +1,94 @@
function registerWasmHTTPListener(wasm, { base, cacheName, passthrough, args = [] } = {}) { class WasmHTTP {
let path = new URL(registration.scope).pathname #listeners = new Map();
if (base && base !== '') path = `${trimEnd(path, '/')}/${trimStart(base, '/')}`
const handlerPromise = new Promise(setHandler => { setHandler(path, handler) {
self.wasmhttp = { const listener = this.#listeners.get(path);
path, if (!listener) {
setHandler, throw new Error(`no listener for path "${path}"`);
} }
})
const go = new Go() listener.setHandler(handler);
go.argv = [wasm, ...args] }
const source = cacheName
? caches.open(cacheName).then((cache) => cache.match(wasm)).then((response) => response ?? fetch(wasm))
: caches.match(wasm).then(response => (response) ?? fetch(wasm))
WebAssembly.instantiateStreaming(source, go.importObject).then(({ instance }) => go.run(instance))
addEventListener('fetch', e => { handle(e) {
if (passthrough?.(e.request)) { const { pathname } = new URL(e.request.url);
e.respondWith(fetch(e.request))
for (const [path, listener] of this.#listeners) {
if (pathname.startsWith(path)) {
listener.handle(e);
return; return;
}
}
}
addListener({ wasm, base = '', cacheName, passthrough, args = [], env = {} }) {
const path = new URL(trimStart(base, '/'), registration.scope).pathname;
if (this.#listeners.has(path)) {
throw new Error(`a listener is already registered for path "${path}"`);
} }
const { pathname } = new URL(e.request.url) this.#listeners.set(path, new WasmHTTPListener({ wasm, path, cacheName, passthrough, args, env }));
if (!pathname.startsWith(path)) return }
}
e.respondWith(handlerPromise.then(handler => handler(e.request))) class WasmHTTPListener {
}) #handlerPromise;
#resolveHandler;
#passthrough;
constructor({ wasm, path, cacheName, passthrough, args, env }) {
this.#handlerPromise = new Promise((resolve) => {
this.#resolveHandler = resolve;
});
this.#passthrough = passthrough;
this.#run({ wasm, path, cacheName, passthrough, args, env });
}
async #run({ wasm, path, cacheName, args, env }) {
try {
const go = new Go();
go.argv = [wasm, ...args];
go.env = { ...env, WASM_HTTP_PATH: path };
const cache = cacheName ? await caches.open(cacheName) : caches;
const source = (await cache.match(wasm)) ?? (await fetch(wasm));
const { instance } = await WebAssembly.instantiateStreaming(source, go.importObject);
await go.run(instance);
} catch (err) {
console.error(`error while running ${wasm} for path "${path}"`, err);
}
}
setHandler(handler) {
this.#resolveHandler(handler);
}
handle(e) {
if (this.#passthrough?.(e.request)) return;
// FIXME return 500 if run has thrown
e.respondWith(this.#handlerPromise.then((handler) => handler(e.request)));
}
}
self.wasmhttp = new WasmHTTP();
addEventListener('fetch', (e) => {
self.wasmhttp.handle(e);
});
function registerWasmHTTPListener(wasm, { base, cacheName, passthrough, args, env } = {}) {
self.wasmhttp.addListener({ wasm, base, cacheName, passthrough, args, env });
} }
function trimStart(s, c) { function trimStart(s, c) {
let r = s let r = s;
while (r.startsWith(c)) r = r.slice(c.length) while (r.startsWith(c)) r = r.slice(c.length);
return r return r;
}
function trimEnd(s, c) {
let r = s
while (r.endsWith(c)) r = r.slice(0, -c.length)
return r
} }