feat: wasm build (#3024)

Co-authored-by: Rémy Léone <[email protected]>

Author: Codelax

.github/workflows/wasm.yml

@@ -0,0 +1,30 @@
+name: WebAssembly
+
+on:
+  pull_request:
+  merge_group:
+
+jobs:
+  build-and-test:
+    strategy:
+      matrix:
+        go-version: [1.19.x]
+        platform: [ubuntu-latest]
+    runs-on: ${{ matrix.platform }}
+    steps:
+      - name: Install Go
+        uses: actions/setup-go@v3
+        with:
+          go-version: ${{ matrix.go-version }}
+      - name: Install pnpm
+        uses: pnpm/action-setup@v2
+        with:
+          version: 6.0.2
+      - name: Checkout
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 1
+      - name: Build
+        run: ./scripts/build-wasm.sh
+      - name: Run npm package tests
+        run: ./scripts/run-tests-wasm.sh

cmd/scw-wasm/args.go

@@ -0,0 +1,22 @@
+//go:build wasm && js
+
+package main
+
+import "os"
+
+type Args struct {
+	callback     string
+	targetObject string
+}
+
+func getArgs() Args {
+	args := Args{}
+	if len(os.Args) > 0 {
+		args.callback = os.Args[0]
+	}
+	if len(os.Args) > 1 {
+		args.targetObject = os.Args[1]
+	}
+
+	return args
+}

cmd/scw-wasm/async.go

@@ -0,0 +1,45 @@
+//go:build wasm && js
+
+package main
+
+import (
+	"fmt"
+	"syscall/js"
+)
+
+type fn func(this js.Value, args []js.Value) (any, error)
+
+var (
+	jsErr     js.Value = js.Global().Get("Error")
+	jsObject  js.Value = js.Global().Get("Object")
+	jsPromise js.Value = js.Global().Get("Promise")
+)
+
+func asyncFunc(innerFunc fn) js.Func {
+	return js.FuncOf(func(this js.Value, args []js.Value) any {
+		handler := js.FuncOf(func(_ js.Value, promFn []js.Value) any {
+			resolve, reject := promFn[0], promFn[1]
+
+			go func() {
+				defer func() {
+					if r := recover(); r != nil {
+						reject.Invoke(jsErr.New(fmt.Sprint("panic:", r)))
+					}
+				}()
+
+				res, err := innerFunc(this, args)
+				if err != nil {
+					errContent := jsObject.New()
+					errContent.Set("cause", err.Error())
+					reject.Invoke(jsErr.New(res, errContent))
+				} else {
+					resolve.Invoke(res)
+				}
+			}()
+
+			return nil
+		})
+
+		return jsPromise.New(handler)
+	})
+}

cmd/scw-wasm/main.go

@@ -0,0 +1,81 @@
+//go:build wasm && js
+
+package main
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+	"syscall/js"
+
+	"github.com/scaleway/scaleway-cli/v2/internal/core"
+	"github.com/scaleway/scaleway-cli/v2/internal/namespaces"
+)
+
+var commands *core.Commands
+
+func getCommands() *core.Commands {
+	if commands == nil {
+		commands = namespaces.GetCommands()
+	}
+	return commands
+}
+
+func runCommand(args []string, stdout io.Writer, stderr io.Writer) chan int {
+	ret := make(chan int, 1)
+	go func() {
+		exitCode, _, _ := core.Bootstrap(&core.BootstrapConfig{
+			Args:      args,
+			Commands:  getCommands(),
+			BuildInfo: &core.BuildInfo{},
+			Stdout:    stdout,
+			Stderr:    stderr,
+			Stdin:     nil,
+		})
+		ret <- exitCode
+	}()
+
+	return ret
+}
+
+func wasmRun(this js.Value, args []js.Value) (any, error) {
+	cliArgs := []string{"scw"}
+	stdout := bytes.NewBuffer(nil)
+	stderr := bytes.NewBuffer(nil)
+
+	for argIndex, arg := range args {
+		if arg.Type() != js.TypeString {
+			return nil, fmt.Errorf("invalid argument at index %d", argIndex)
+		}
+		cliArgs = append(cliArgs, arg.String())
+	}
+
+	exitCodeChan := runCommand(cliArgs, stdout, stderr)
+	exitCode := <-exitCodeChan
+	if exitCode != 0 {
+		errBody := stderr.String()
+		return js.ValueOf(errBody), fmt.Errorf("exit code: %d", exitCode)
+	}
+
+	outBody := stdout.String()
+
+	return js.ValueOf(outBody), nil
+}
+
+func main() {
+	args := getArgs()
+
+	if args.targetObject != "" {
+		cliPackage := js.ValueOf(map[string]any{})
+		cliPackage.Set("run", asyncFunc(wasmRun))
+		js.Global().Set(args.targetObject, cliPackage)
+	}
+
+	if args.callback != "" {
+		givenCallback := js.Global().Get(args.callback)
+		if !givenCallback.IsUndefined() {
+			givenCallback.Invoke()
+		}
+	}
+	<-make(chan struct{}, 0)
+}

internal/config/config.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"os"
 	"path/filepath"
+	"runtime"
 	"text/template"
 
 	"gopkg.in/yaml.v3"
@@ -57,6 +58,14 @@ type Config struct {
 // returns a new empty config if file doesn't exist
 // return error if fail to load config file
 func LoadConfig(configPath string) (*Config, error) {
+	if runtime.GOARCH == "wasm" {
+		return &Config{
+			Alias:  alias.EmptyConfig(),
+			Output: DefaultOutput,
+			path:   configPath,
+		}, nil
+	}
+
 	file, err := os.ReadFile(configPath)
 	if err != nil {
 		if os.IsNotExist(err) {
@@ -83,6 +92,10 @@ func LoadConfig(configPath string) (*Config, error) {
 
 // Save marshal config to config file
 func (c *Config) Save() error {
+	if runtime.GOARCH == "wasm" {
+		return nil
+	}
+
 	file, err := c.HumanConfig()
 	if err != nil {
 		return err

internal/core/client.go

@@ -5,15 +5,32 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"runtime"
 	"strings"
 
 	"github.com/scaleway/scaleway-sdk-go/logger"
 	"github.com/scaleway/scaleway-sdk-go/scw"
 	"github.com/scaleway/scaleway-sdk-go/validation"
 )
 
+func createWasmClient(httpClient *http.Client, buildInfo *BuildInfo) (*scw.Client, error) {
+	opts := []scw.ClientOption{
+		scw.WithDefaultRegion(scw.RegionFrPar),
+		scw.WithDefaultZone(scw.ZoneFrPar1),
+		scw.WithUserAgent(buildInfo.GetUserAgent()),
+		scw.WithProfile(scw.LoadEnvProfile()),
+		scw.WithHTTPClient(httpClient),
+	}
+
+	return scw.NewClient(opts...)
+}
+
 // createClient creates a Scaleway SDK client.
 func createClient(ctx context.Context, httpClient *http.Client, buildInfo *BuildInfo, profileName string) (*scw.Client, error) {
+	if runtime.GOARCH == "wasm" {
+		return createWasmClient(httpClient, buildInfo)
+	}
+
 	profile := scw.LoadEnvProfile()
 
 	// Default path is based on the following priority order:

internal/core/cobra_utils.go

@@ -23,12 +23,12 @@ func cobraRun(ctx context.Context, cmd *Command) func(*cobra.Command, []string)
 		if !cmd.AllowAnonymousClient && !meta.isClientFromBootstrapConfig {
 			client, err := createClient(ctx, meta.httpClient, meta.BuildInfo, ExtractProfileName(ctx))
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to create client: %w", err)
 			}
 			meta.Client = client
 			err = validateClient(meta.Client)
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to validate client: %w", err)
 			}
 		}
 

internal/core/shell.go

@@ -1,5 +1,4 @@
-//go:build !freebsd
-// +build !freebsd
+//go:build !freebsd && !wasm
 
 // shell is disabled on freebsd as current version of github.com/pkg/[email protected] is not compiling
 package core

internal/core/shell_disabled.go

@@ -1,5 +1,4 @@
-//go:build freebsd
-// +build freebsd
+//go:build freebsd || wasm
 
 package core
 

internal/gotty/client.go

@@ -1,3 +1,5 @@
+//go:build !wasm
+
 package gotty
 
 import (