go
/
applets
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
Browse Source

Initial SDL2 Ripple applet

master
Noah Petherbridge 3 years ago
commit
9cf3a96bfb
12 changed files with 1114 additions and 0 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 1
      .gitignore
  2. 1
      README.md
  3. 11
      examples/ripple/Makefile
  4. 41
      examples/ripple/index.html
  5. 114
      examples/ripple/main.go
  6. 136
      examples/ripple/main_wasm.go
  7. BIN
      examples/ripple/photo.jpg
  8. 123
      examples/ripple/ripple.go
  9. 127
      examples/ripple/server.go
  10. 533
      examples/ripple/wasm_exec.js
  11. 14
      go.mod
  12. 13
      go.sum

1
.gitignore
View File

@ -0,0 +1 @@
*.wasm

1
README.md
View File

@ -0,0 +1 @@
# WebAssembly Applets

11
examples/ripple/Makefile
View File

@ -0,0 +1,11 @@
.PHONY: run
run:
go run main.go ripple.go
.PHONY: wasm
wasm:
GOOS=js GOARCH=wasm go build -v -o ripple.wasm main_wasm.go ripple.go
.PHONY: serve
serve: wasm
go run server.go

41
examples/ripple/index.html
View File

@ -0,0 +1,41 @@
<!DOCTYPE html>
<html>
<head>
<title>go/render: hello wasm!</title>
<style>
#canvas {
position: fixed;
width: 100%;
height: 100%;
top: 0;
right: 0;
left: 0;
bottom: 0;
}
</style>
</head>
<body>
<script src="wasm_exec.js"></script>
<script>
if (!WebAssembly.instantiateStreaming) { // polyfill
WebAssembly.instantiateStreaming = async (resp, importObject) => {
const source = await (await resp).arrayBuffer();
return await WebAssembly.instantiate(source, importObject);
};
}
(function() {
const go = new Go();
WebAssembly.instantiateStreaming(fetch("ripple.wasm"), go.importObject).then(result => {
console.clear();
go.run(result.instance);
WebAssembly.instantiate(result.module, go.importObject); // reset instance
})
})();
</script>
<canvas id="canvas"></canvas>
</body>
</html>

114
examples/ripple/main.go
View File

@ -0,0 +1,114 @@
package main
import (
"math"
"math/rand"
"time"
"git.kirsle.net/go/render"
"git.kirsle.net/go/render/sdl"
)
// Config variables.
var (
Filename = "photo.jpg"
Width = 640
Height = 480
Quality = 4
// computed.
Size = Width * Height
)
// Runtime variables.
var (
app *App
mw render.Engine
TargetFPS = 1000 / 60 // run at 60fps
)
func main() {
setup()
mainloop()
}
// setup the applet
func setup() {
// Seed the random number generator.
rand.Seed(time.Now().UnixNano())
// Create SDL2 window.
mw = sdl.New("Ripple effect", Width, Height)
if err := mw.Setup(); err != nil {
panic(err)
}
// Load the jpeg image.
var err error
photo, err := render.OpenImage(Filename)
if err != nil {
panic(err)
}
app = New(mw, photo)
}
// loop runs the applet logic for each loop.
func loop() bool {
app.Ripple()
mw.Clear(render.White)
// Poll events.
ev, err := mw.Poll()
if err != nil {
panic(err)
}
// Escape key closes the program.
if ev.Escape {
mw.Teardown()
return false
}
// Is mouse over the drawing?
if ev.CursorX >= 0 && ev.CursorX < Width && ev.CursorY >= 0 && ev.CursorY < Width {
app.Disturb(ev.CursorX, ev.CursorY, 15000)
}
// rain
app.Disturb(
int(math.Floor(rand.Float64()*float64(Width))),
int(math.Floor(rand.Float64()*float64(Height))),
int(rand.Float64()*10000),
)
app.Present()
return true
}
// mainloop runs a loop of loop() while maintaing the frame rate.
func mainloop() {
var (
start time.Time
elapsed time.Duration
ok bool
)
for {
// Record how long the frame takes.
start = time.Now()
ok = loop()
// Delay to maintain target frames per second.
var delay uint32
elapsed = time.Now().Sub(start) / time.Millisecond
if TargetFPS-int(elapsed) > 0 {
delay = uint32(TargetFPS - int(elapsed))
}
mw.Delay(delay)
if !ok {
break
}
}
}

136
examples/ripple/main_wasm.go
View File

@ -0,0 +1,136 @@
// +build js,wasm
package main
import (
"fmt"
"image/jpeg"
"math/rand"
"net/http"
"time"
"git.kirsle.net/go/render"
"git.kirsle.net/go/render/canvas"
)
// Config variables.
var (
Filename = "photo.jpg"
Width = 640
Height = 480
Quality = 4
// computed.
Size = Width * Height
)
// Runtime variables.
var (
app *App
mw *canvas.Engine
TargetFPS = 1000 / 60 // run at 60fps
)
func main() {
setup()
go mainloop()
for {
time.Sleep(10 * time.Second)
}
}
// setup the applet
func setup() {
var err error
// Seed the random number generator.
rand.Seed(time.Now().UnixNano())
// Get the HTML Canvas.
mw, err = canvas.New("canvas")
if err != nil {
panic(err)
}
// Configure the engine.
err = mw.Setup()
if err != nil {
panic(err)
}
mw.AddEventListeners()
// Fetch the image via HTTP.
r, err := http.Get(Filename)
if err != nil {
panic(err)
}
// Parse it as a jpeg.
photo, err := jpeg.Decode(r.Body)
if err != nil {
panic(err)
}
app = New(mw, photo)
}
// loop runs the applet logic for each loop.
func loop() bool {
app.Ripple()
fmt.Println("loop")
mw.Clear(render.White)
// Poll events.
ev, err := mw.Poll()
if err != nil {
panic(err)
}
// Is mouse over the drawing?
if ev.CursorX >= 0 && ev.CursorX < Width && ev.CursorY >= 0 && ev.CursorY < Width {
app.Disturb(ev.CursorX, ev.CursorY, 15000)
}
// rain
// app.Disturb(
// int(math.Floor(rand.Float64()*float64(Width))),
// int(math.Floor(rand.Float64()*float64(Height))),
// int(rand.Float64()*10000),
// )
app.Present()
// test
for pt := range render.IterLine(render.Origin, render.NewPoint(128, 128)) {
mw.DrawPoint(render.Black, pt)
}
return true
}
// mainloop runs a loop of loop() while maintaing the frame rate.
func mainloop() {
var (
start time.Time
elapsed time.Duration
ok bool
)
for {
// Record how long the frame takes.
start = time.Now()
ok = loop()
// Delay to maintain target frames per second.
var delay uint32
elapsed = time.Now().Sub(start) / time.Millisecond
if TargetFPS-int(elapsed) > 0 {
delay = uint32(TargetFPS - int(elapsed))
}
mw.Delay(delay)
if !ok {
break
}
}
}

BIN
examples/ripple/photo.jpg
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 97 KiB

123
examples/ripple/ripple.go
View File

@ -0,0 +1,123 @@
package main
import (
"image"
"git.kirsle.net/go/render"
)
// App holds the ripple applet state.
type App struct {
e render.Engine
image image.Image
source *image.RGBA
data *image.RGBA
tex render.Texturer
// computed
width int
height int
size int
// frame buffers
buffer0 []int
buffer1 []int
}
// New creates the ripple applet.
func New(e render.Engine, i image.Image) *App {
var (
bounds = i.Bounds()
width = bounds.Max.X
height = bounds.Max.Y
size = width * height
)
a := &App{
e: e,
image: i,
source: render.ImageToRGBA(i),
data: render.ImageToRGBA(i),
width: width,
height: height,
size: size,
buffer0: make([]int, size),
buffer1: make([]int, size),
}
tex, err := a.e.StoreTexture("pic", a.data)
if err != nil {
panic(err)
}
a.tex = tex
return a
}
// Disturb creates a disturbance in the water.
func (a *App) Disturb(x, y, z int) {
if x < 2 || x > Width-2 || y < 1 || y > Height-2 {
return
}
var i = x + y*Width
a.buffer0[i] += z
a.buffer0[i-1] -= z
}
// Ripple runs the ripple algorithm.
func (a *App) Ripple() {
var (
width = a.width
size = a.size
)
// average cells to make the surface more even
for i := width + 1; i < size-width-1; i += 2 {
for x := 1; x < width-1; x++ {
avg := (a.buffer0[i] + a.buffer0[i+1] + a.buffer0[i-1] + a.buffer0[i-width] + a.buffer0[i+width]) / 5
a.buffer0[i] = avg
i++
}
}
// Loop for every non-edge element.
y := 0
for i := width + 1; i < size-width-1; i += 2 {
y++
for x := 1; x < width-1; x++ {
// Wave propagation
waveHeight := (a.buffer0[i-1]+
a.buffer0[i+1]+
a.buffer0[i+Width]+
a.buffer0[i-Width])/2 - a.buffer1[i]
a.buffer1[i] = waveHeight
// Some very fake lighting
var light = int(float64(waveHeight)*2.0 - float64(a.buffer1[i-2])*0.6)
if light < -10 {
light = -10
} else if light > 100 {
light = 100
}
color := a.source.At(x, y)
a.data.Set(x, y, render.FromColor(color).Lighten(light).ToColor())
i++
}
}
aux := a.buffer0
a.buffer0 = a.buffer1
a.buffer1 = aux
a.tex, _ = a.e.StoreTexture("pic", a.data)
}
// Present the visual state.
func (a *App) Present() {
rect := render.Rect{
W: a.width,
H: a.height,
}
a.e.Copy(a.tex, rect, rect)
a.e.Present()
}

127
examples/ripple/server.go
View File

@ -0,0 +1,127 @@
// +build disabled
package main
import (
"fmt"
"io/ioutil"
"log"
"net/http"
"os/exec"
"path/filepath"
"github.com/fsnotify/fsnotify"
)
func main() {
const wasm = "/ripple.wasm"
// Watch the dev directory for changes.
go watchChanges()
http.Handle("/", http.FileServer(http.Dir(".")))
http.HandleFunc(wasm, func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/wasm")
http.ServeFile(w, r, "."+wasm)
})
fmt.Println("Listening at http://localhost:8080/")
log.Fatal(http.ListenAndServe(":8080", nil))
}
// onChange handler to rebuild the wasm file automatically.
func onChange() {
out, err := exec.Command("make", "wasm").Output()
if err != nil {
log.Printf("error: %s", err)
}
log.Printf("%s", out)
log.Printf("Doodle WASM file rebuilt")
}
// Watch the Doodle source tree for changes to Go files and rebuild
// the wasm binary automatically.
func watchChanges() {
watcher, err := fsnotify.NewWatcher()
if err != nil {
log.Printf("error: %s", err)
return
}
defer watcher.Close()
done := make(chan bool)
go func() {
log.Println("Starting watch files loop")
for {
select {
case event, ok := <-watcher.Events:
if !ok {
return
}
log.Printf("event: %s", event)
if event.Op&fsnotify.Write == fsnotify.Write {
log.Printf("modified file: %s", event.Name)
onChange()
}
case err, ok := <-watcher.Errors:
if !ok {
return
}
log.Printf("error: %s", err)
}
}
}()
log.Println("Adding source directory to watcher")
dirs := crawlDirectory("../")
// Watch all these folders.
for _, dir := range dirs {
err = watcher.Add(dir)
if err != nil {
log.Printf("error: %s", err)
}
}
<-done
}
// Crawl the filesystem and return paths with Go files.
func crawlDirectory(root string) []string {
var (
ext = ".go"
result []string
has bool
)
files, err := ioutil.ReadDir(root)
if err != nil {
log.Fatalln(err)
}
for _, file := range files {
if file.Name() == ".git" {
continue
}
// Recursively scan subdirectories.
if file.IsDir() {
result = append(result,
crawlDirectory(filepath.Join(root, file.Name()))...,
)
continue
}
// This root has a file we want?
if filepath.Ext(file.Name()) == ext {
has = true
}
}
if has {
result = append(result, root)
}
return result
}

533
examples/ripple/wasm_exec.js
View File

@ -0,0 +1,533 @@
// Copyright 2018 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
(() => {
// Map multiple JavaScript environments to a single common API,
// preferring web standards over Node.js API.
//
// Environments considered:
// - Browsers
// - Node.js
// - Electron
// - Parcel
if (typeof global !== "undefined") {
// global already exists
} else if (typeof window !== "undefined") {
window.global = window;
} else if (typeof self !== "undefined") {
self.global = self;
} else {
throw new Error("cannot export Go (neither global, window nor self is defined)");
}
if (!global.require && typeof require !== "undefined") {
global.require = require;
}
if (!global.fs && global.require) {
global.fs = require("fs");
}
if (!global.fs) {
let outputBuf = "";
global.fs = {
constants: { O_WRONLY: -1, O_RDWR: -1, O_CREAT: -1, O_TRUNC: -1, O_APPEND: -1, O_EXCL: -1 }, // unused
writeSync(fd, buf) {
outputBuf += decoder.decode(buf);
const nl = outputBuf.lastIndexOf("\n");
if (nl != -1) {
console.log(outputBuf.substr(0, nl));
outputBuf = outputBuf.substr(nl + 1);
}
return buf.length;
},
write(fd, buf, offset, length, position, callback) {
if (offset !== 0 || length !== buf.length || position !== null) {
throw new Error("not implemented");
}
const n = this.writeSync(fd, buf);
callback(null, n);
},
open(path, flags, mode, callback) {
const err = new Error("not implemented");
err.code = "ENOSYS";
callback(err);
},
read(fd, buffer, offset, length, position, callback) {
const err = new Error("not implemented");
err.code = "ENOSYS";
callback(err);
},
fsync(fd, callback) {
callback(null);
},
};
}
if (!global.crypto) {
const nodeCrypto = require("crypto");
global.crypto = {
getRandomValues(b) {
nodeCrypto.randomFillSync(b);
},
};
}
if (!global.performance) {
global.performance = {
now() {
const [sec, nsec] = process.hrtime();
return sec * 1000 + nsec / 1000000;
},
};
}
if (!global.TextEncoder) {
global.TextEncoder = require("util").TextEncoder;
}
if (!global.TextDecoder) {
global.TextDecoder = require("util").TextDecoder;
}
// End of polyfills for common API.
const encoder = new TextEncoder("utf-8");
const decoder = new TextDecoder("utf-8");
global.Go = class {
constructor() {
this.argv = ["js"];
this.env = {};
this.exit = (code) => {
if (code !== 0) {
console.warn("exit code:", code);
}
};
this._exitPromise = new Promise((resolve) => {
this._resolveExitPromise = resolve;
});
this._pendingEvent = null;
this._scheduledTimeouts = new Map();
this._nextCallbackTimeoutID = 1;
const mem = () => {
// The buffer may change when requesting more memory.
return new DataView(this._inst.exports.mem.buffer);
}
const setInt64 = (addr, v) => {
mem().setUint32(addr + 0, v, true);
mem().setUint32(addr + 4, Math.floor(v / 4294967296), true);
}
const getInt64 = (addr) => {
const low = mem().getUint32(addr + 0, true);
const high = mem().getInt32(addr + 4, true);
return low + high * 4294967296;
}
const loadValue = (addr) => {
const f = mem().getFloat64(addr, true);
if (f === 0) {
return undefined;
}
if (!isNaN(f)) {
return f;
}
const id = mem().getUint32(addr, true);
return this._values[id];
}
const storeValue = (addr, v) => {
const nanHead = 0x7FF80000;
if (typeof v === "number") {
if (isNaN(v)) {
mem().setUint32(addr + 4, nanHead, true);
mem().setUint32(addr, 0, true);
return;
}
if (v === 0) {
mem().setUint32(addr + 4, nanHead, true);
mem().setUint32(addr, 1, true);
return;
}
mem().setFloat64(addr, v, true);
return;
}
switch (v) {
case undefined:
mem().setFloat64(addr, 0, true);
return;
case null:
mem().setUint32(addr + 4, nanHead, true);
mem().setUint32(addr, 2, true);
return;
case true:
mem().setUint32(addr + 4, nanHead, true);
mem().setUint32(addr, 3, true);
return;
case false:
mem().setUint32(addr + 4, nanHead, true);
mem().setUint32(addr, 4, true);
return;
}
let ref = this._refs.get(v);
if (ref === undefined) {
ref = this._values.length;
this._values.push(v);
this._refs.set(v, ref);
}
let typeFlag = 0;
switch (typeof v) {
case "string":
typeFlag = 1;
break;
case "symbol":
typeFlag = 2;
break;
case "function":
typeFlag = 3;
break;
}
mem().setUint32(addr + 4, nanHead | typeFlag, true);
mem().setUint32(addr, ref, true);
}
const loadSlice = (addr) => {
const array = getInt64(addr + 0);
const len = getInt64(addr + 8);
return new Uint8Array(this._inst.exports.mem.buffer, array, len);
}
const loadSliceOfValues = (addr) => {
const array = getInt64(addr + 0);
const len = getInt64(addr + 8);
const a = new Array(len);
for (let i = 0; i < len; i++) {
a[i] = loadValue(array + i * 8);
}
return a;
}
const loadString = (addr) => {
const saddr = getInt64(addr + 0);
const len = getInt64(addr + 8);
return decoder.decode(new DataView(this._inst.exports.mem.buffer, saddr, len));
}
const timeOrigin = Date.now() - performance.now();
this.importObject = {
go: {
// Go's SP does not change as long as no Go code is running. Some operations (e.g. calls, getters and setters)
// may synchronously trigger a Go event handler. This makes Go code get executed in the middle of the imported
// function. A goroutine can switch to a new stack if the current stack is too small (see morestack function).
// This changes the SP, thus we have to update the SP used by the imported function.
// func wasmExit(code int32)
"runtime.wasmExit": (sp) => {
const code = mem().getInt32(sp + 8, true);
this.exited = true;
delete this._inst;
delete this._values;
delete this._refs;
this.exit(code);
},
// func wasmWrite(fd uintptr, p unsafe.Pointer, n int32)
"runtime.wasmWrite": (sp) => {
const fd = getInt64(sp + 8);
const p = getInt64(sp + 16);
const n = mem().getInt32(sp + 24, true);
fs.writeSync(fd, new Uint8Array(this._inst.exports.mem.buffer, p, n));
},
// func nanotime() int64
"runtime.nanotime": (sp) => {
setInt64(sp + 8, (timeOrigin + performance.now()) * 1000000);
},
// func walltime() (sec int64, nsec int32)
"runtime.walltime": (sp) => {
const msec = (new Date).getTime();
setInt64(sp + 8, msec / 1000);
mem().setInt32(sp + 16, (msec % 1000) * 1000000, true);
},
// func scheduleTimeoutEvent(delay int64) int32
"runtime.scheduleTimeoutEvent": (sp) => {
const id = this._nextCallbackTimeoutID;
this._nextCallbackTimeoutID++;
this._scheduledTimeouts.set(id, setTimeout(
() => {
this._resume();
while (this._scheduledTimeouts.has(id)) {
// for some reason Go failed to register the timeout event, log and try again
// (temporary workaround for https://github.com/golang/go/issues/28975)
console.warn("scheduleTimeoutEvent: missed timeout event");
this._resume();
}
},
getInt64(sp + 8) + 1, // setTimeout has been seen to fire up to 1 millisecond early
));
mem().setInt32(sp + 16, id, true);
},
// func clearTimeoutEvent(id int32)
"runtime.clearTimeoutEvent": (sp) => {
const id = mem().getInt32(sp + 8, true);
clearTimeout(this._scheduledTimeouts.get(id));
this._scheduledTimeouts.delete(id);
},
// func getRandomData(r []byte)
"runtime.getRandomData": (sp) => {
crypto.getRandomValues(loadSlice(sp + 8));
},
// func stringVal(value string) ref
"syscall/js.stringVal": (sp) => {
storeValue(sp + 24, loadString(sp + 8));
},
// func valueGet(v ref, p string) ref
"syscall/js.valueGet": (sp) => {
const result = Reflect.get(loadValue(sp + 8), loadString(sp + 16));
sp = this._inst.exports.getsp(); // see comment above
storeValue(sp + 32, result);
},
// func valueSet(v ref, p string, x ref)
"syscall/js.valueSet": (sp) => {
Reflect.set(loadValue(sp + 8), loadString(sp + 16), loadValue(sp + 32));
},
// func valueIndex(v ref, i int) ref
"syscall/js.valueIndex": (sp) => {
storeValue(sp + 24, Reflect.get(loadValue(sp + 8), getInt64(sp + 16)));
},
// valueSetIndex(v ref, i int, x ref)
"syscall/js.valueSetIndex": (sp) => {
Reflect.set(loadValue(sp + 8), getInt64(sp + 16), loadValue(sp + 24));
},
// func valueCall(v ref, m string, args []ref) (ref, bool)
"syscall/js.valueCall": (sp) => {
try {
const v = loadValue(sp + 8);
const m = Reflect.get(v, loadString(sp + 16));
const args = loadSliceOfValues(sp + 32);
const result = Reflect.apply(m, v, args);
sp = this._inst.exports.getsp(); // see comment above
storeValue(sp + 56, result);
mem().setUint8(sp + 64, 1);
} catch (err) {
storeValue(sp + 56, err);
mem().setUint8(sp + 64, 0);
}
},
// func valueInvoke(v ref, args []ref) (ref, bool)
"syscall/js.valueInvoke": (sp) => {
try {
const v = loadValue(sp + 8);
const args = loadSliceOfValues(sp + 16);
const result = Reflect.apply(v, undefined, args);
sp = this._inst.exports.getsp(); // see comment above
storeValue(sp + 40, result);
mem().setUint8(sp + 48, 1);
} catch (err) {
storeValue(sp + 40, err);
mem().setUint8(sp + 48, 0);
}
},
// func valueNew(v ref, args []ref) (ref, bool)
"syscall/js.valueNew": (sp) => {
try {
const v = loadValue(sp + 8);
const args = loadSliceOfValues(sp + 16);
const result = Reflect.construct(v, args);
sp = this._inst.exports.getsp(); // see comment above
storeValue(sp + 40, result);
mem().setUint8(sp + 48, 1);
} catch (err) {
storeValue(sp + 40, err);
mem().setUint8(sp + 48, 0);
}
},
// func valueLength(v ref) int
"syscall/js.valueLength": (sp) => {
setInt64(sp + 16, parseInt(loadValue(sp + 8).length));
},
// valuePrepareString(v ref) (ref, int)
"syscall/js.valuePrepareString": (sp) => {
const str = encoder.encode(String(loadValue(sp + 8)));
storeValue(sp + 16, str);
setInt64(sp + 24, str.length);
},
// valueLoadString(v ref, b []byte)
"syscall/js.valueLoadString": (sp) => {
const str = loadValue(sp + 8);
loadSlice(sp + 16).set(str);
},
// func valueInstanceOf(v ref, t ref) bool
"syscall/js.valueInstanceOf": (sp) => {
mem().setUint8(sp + 24, loadValue(sp + 8) instanceof loadValue(sp + 16));
},
// func copyBytesToGo(dst []byte, src ref) (int, bool)
"syscall/js.copyBytesToGo": (sp) => {
const dst = loadSlice(sp + 8);
const src = loadValue(sp + 32);
if (!(src instanceof Uint8Array)) {
mem().setUint8(sp + 48, 0);
return;
}
const toCopy = src.subarray(0, dst.length);
dst.set(toCopy);
setInt64(sp + 40, toCopy.length);
mem().setUint8(sp + 48, 1);
},
// func copyBytesToJS(dst ref, src []byte) (int, bool)
"syscall/js.copyBytesToJS": (sp) => {
const dst = loadValue(sp + 8);
const src = loadSlice(sp + 16);
if (!(dst instanceof Uint8Array)) {
mem().setUint8(sp + 48, 0);
return;
}
const toCopy = src.subarray(0, dst.length);
dst.set(toCopy);
setInt64(sp + 40, toCopy.length);
mem().setUint8(sp + 48, 1);
},
"debug": (value) => {
console.log(value);
},
}
};
}
async run(instance) {
this._inst = instance;
this._values = [ // TODO: garbage collection
NaN,
0,
null,
true,
false,
global,
this,
];
this._refs = new Map();
this.exited = false;
const mem = new DataView(this._inst.exports.mem.buffer)
// Pass command line arguments and environment variables to WebAssembly by writing them to the linear memory.
let offset = 4096;
const strPtr = (str) => {
const ptr = offset;
const bytes = encoder.encode(str + "\0");
new Uint8Array(mem.buffer, offset, bytes.length).set(bytes);
offset += bytes.length;
if (offset % 8 !== 0) {
offset += 8 - (offset % 8);
}
return ptr;
};
const argc = this.argv.length;
const argvPtrs = [];
this.argv.forEach((arg) => {
argvPtrs.push(strPtr(arg));
});
const keys = Object.keys(this.env).sort();
argvPtrs.push(keys.length);
keys.forEach((key) => {
argvPtrs.push(strPtr(`${key}=${this.env[key]}`));
});
const argv = offset;
argvPtrs.forEach((ptr) => {
mem.setUint32(offset, ptr, true);
mem.setUint32(offset + 4, 0, true);
offset += 8;
});
this._inst.exports.run(argc, argv);
if (this.exited) {
this._resolveExitPromise();
}
await this._exitPromise;
}
_resume() {
if (this.exited) {
throw new Error("Go program has already exited");
}
this._inst.exports.resume();
if (this.exited) {
this._resolveExitPromise();
}
}
_makeFuncWrapper(id) {
const go = this;
return function () {
const event = { id: id, this: this, args: arguments };
go._pendingEvent = event;
go._resume();
return event.result;
};
}
}
if (
global.require &&
global.require.main === module &&
global.process &&
global.process.versions &&
!global.process.versions.electron
) {
if (process.argv.length < 3) {
console.error("usage: go_js_wasm_exec [wasm binary] [arguments]");
process.exit(1);
}
const go = new Go();
go.argv = process.argv.slice(2);
go.env = Object.assign({ TMPDIR: require("os").tmpdir() }, process.env);
go.exit = process.exit;
WebAssembly.instantiate(fs.readFileSync(process.argv[2]), go.importObject).then((result) => {
process.on("exit", (code) => { // Node.js exits if no event handler is pending
if (code === 0 && !go.exited) {
// deadlock, make Go print error and stack traces
go._pendingEvent = { id: 0 };
go._resume();
}
});
return go.run(result.instance);
}).catch((err) => {
console.error(err);
process.exit(1);
});
}
})();

14
go.mod
View File

@ -0,0 +1,14 @@
module git.kirsle.net/go/applets
go 1.13
replace git.kirsle.net/go/ui => /home/kirsle/go/src/git.kirsle.net/go/ui
replace git.kirsle.net/go/render => /home/kirsle/go/src/git.kirsle.net/go/render
require (
git.kirsle.net/go/render v0.0.0-20200102014411-4d008b5c468d
git.kirsle.net/go/ui v0.0.0-20191229080003-4ba563d48d6f
github.com/fsnotify/fsnotify v1.4.7 // indirect
golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae // indirect
)

13
go.sum
View File

@ -0,0 +1,13 @@
git.kirsle.net/go/render v0.0.0-20200102014411-4d008b5c468d h1:vErak6oVRT2dosyQzcwkjXyWQ2NRIVL8q9R8NOUTtsg=
git.kirsle.net/go/render v0.0.0-20200102014411-4d008b5c468d/go.mod h1:ywZtC+zE2SpeObfkw0OvG01pWHQadsVQ4WDKOYzaejc=
git.kirsle.net/go/ui v0.0.0-20191229080003-4ba563d48d6f h1:upiac1ipv6cx0Um9uPSHTtwqVpmY1nctJi6mMxFdHTM=
git.kirsle.net/go/ui v0.0.0-20191229080003-4ba563d48d6f/go.mod h1:MWMEQKnc2LOKK9yXO49FxkAdt9uiTvVQPZH7N5tIXhY=
github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
github.com/veandco/go-sdl2 v0.4.1 h1:HmSBvVmKWI8LAOeCfTTM8R33rMyPcs6U3o8n325c9Qg=
github.com/veandco/go-sdl2 v0.4.1/go.mod h1:FB+kTpX9YTE+urhYiClnRzpOXbiWgaU3+5F2AB78DPg=
golang.org/x/image v0.0.0-20200119044424-58c23975cae1 h1:5h3ngYt7+vXCDZCup/HkCQgW5XwmSvR/nA2JmJ0RErg=
golang.org/x/image v0.0.0-20200119044424-58c23975cae1/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0=
golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae h1:/WDfKMnPU+m5M4xB+6x4kaepxRw6jWvR5iDRdvjHgy8=
golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
Write Preview
Loading…
Cancel
Save