Artifact [6a6e81c03d]

Artifact 6a6e81c03dce6258f2b70c0b992e2701cae60ac99f5489953733e2e2fac668dd:

• File leaf/cmd/wasm/main.go — part of check-in [eda7960b81] at 2026-04-23 19:23:42 on branch trunk — rename module to github.com/danmestas/EdgeSync

  Fix the case-sensitive module path to match the actual GitHub repo URL (danmestas/EdgeSync). Remove tracked leaf/leaf binary and ignore .claude/skills/ scratchpad dirs. (user: [email protected], size: 2445) [annotate] [blame] [check-ins using] [more...]

//go:build js

package main

import (
	"context"
	"log/slog"
	"syscall/js"
	"time"

	"github.com/danmestas/EdgeSync/leaf/agent"
	"github.com/danmestas/EdgeSync/leaf/telemetry"

	_ "github.com/danmestas/libfossil/db/driver/ncruces"
)

var (
	currentAgent *agent.Agent
	agentCancel  context.CancelFunc
)

func jsNewAgent(_ js.Value, args []js.Value) any {
	if len(args) < 1 {
		return js.ValueOf("error: config object required")
	}
	cfg := args[0]

	repoPath := cfg.Get("repoPath").String()
	if repoPath == "" {
		return js.ValueOf("error: repoPath is required")
	}
	natsUrl := cfg.Get("natsUrl").String()
	if natsUrl == "" {
		return js.ValueOf("error: natsUrl is required")
	}

	// Optional fields with defaults.
	const defaultPollSeconds = 5
	pollSec := defaultPollSeconds
	if p := cfg.Get("pollSeconds"); !p.IsUndefined() && !p.IsNull() {
		pollSec = p.Int()
	}

	// Setup no-op telemetry for browser.
	ctx := context.Background()
	if _, err := telemetry.Setup(ctx, telemetry.TelemetryConfig{ServiceName: "edgesync-browser"}); err != nil {
		slog.Error("telemetry setup failed", "error", err)
	}
	obs := telemetry.NewOTelObserver(nil, nil)

	config := agent.Config{
		RepoPath:     repoPath,
		NATSUpstream:      natsUrl,
		Push:         true,
		Pull:         true,
		PollInterval: time.Duration(pollSec) * time.Second,
		Observer:     obs,
	}

	var err error
	currentAgent, err = agent.New(config)
	if err != nil {
		return js.ValueOf("error: " + err.Error())
	}
	return js.ValueOf("ok")
}

func jsStart(_ js.Value, _ []js.Value) any {
	if currentAgent == nil {
		return js.ValueOf("error: no agent — call newAgent first")
	}
	if err := currentAgent.Start(); err != nil {
		return js.ValueOf("error: " + err.Error())
	}
	slog.Info("edgesync agent started in browser")
	return js.ValueOf("ok")
}

func jsStop(_ js.Value, _ []js.Value) any {
	if currentAgent != nil {
		if err := currentAgent.Stop(); err != nil {
			return js.ValueOf("error: " + err.Error())
		}
	}
	return js.ValueOf("ok")
}

func jsSyncNow(_ js.Value, _ []js.Value) any {
	if currentAgent != nil {
		currentAgent.SyncNow()
	}
	return js.ValueOf("ok")
}

func main() {
	js.Global().Set("edgesync", js.ValueOf(map[string]any{
		"newAgent": js.FuncOf(jsNewAgent),
		"start":    js.FuncOf(jsStart),
		"stop":     js.FuncOf(jsStop),
		"syncNow":  js.FuncOf(jsSyncNow),
	}))

	slog.Info("edgesync WASM module loaded")

	// Block forever — WASM module stays alive
	select {}
}