1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
package python
import (
"bytes"
"context"
_ "embed"
"os"
"github.com/tetratelabs/wazero"
"github.com/tetratelabs/wazero/imports/wasi_snapshot_preview1"
)
var (
//go:embed python.wasm
Binary []byte
r wazero.Runtime
code wazero.CompiledModule
)
func init() {
ctx := context.Background()
r = wazero.NewRuntime(ctx)
wasi_snapshot_preview1.MustInstantiate(ctx, r)
var err error
code, err = r.CompileModule(ctx, Binary)
if err != nil {
panic(err)
}
}
type Result struct {
Stdout string
Stderr string
PlatformError string
}
func Run(ctx context.Context, tmpDir, userCode string) (*Result, error) {
fout := &bytes.Buffer{}
ferr := &bytes.Buffer{}
fin := &bytes.Buffer{}
os.WriteFile(tmpDir+"/main.py", []byte(userCode), 0644)
fsConfig := wazero.NewFSConfig().
WithFSMount(os.DirFS(tmpDir), "/")
config := wazero.NewModuleConfig().
// stdio
WithStdout(fout).
WithStderr(ferr).
WithStdin(fin).
// argv
WithArgs("python", "/main.py").
WithName("python").
// fs / system
WithFSConfig(fsConfig).
WithSysNanosleep().
WithSysNanotime().
WithSysWalltime()
mod, err := r.InstantiateModule(ctx, code, config)
if err != nil {
result := &Result{
Stdout: fout.String(),
Stderr: ferr.String(),
PlatformError: err.Error(),
}
return result, err
}
defer mod.Close(ctx)
return &Result{
Stdout: fout.String(),
Stderr: ferr.String(),
}, nil
}
|
