Artifact [558e28d5c7]

Artifact 558e28d5c71f29e5a13f820f46644a6268e6a86ac628deed7c7520f1488becd4:

• File leaf/cmd/wasm/main.go — part of check-in [38efed7a12] at 2026-08-12 20:50:57 on branch main — chore(deps): migrate to go-libfossil v0.9.0 (#195)

  * chore(deps): migrate to go-libfossil v0.9.0 (renamed module path)

  - import path danmestas/libfossil → danmestas/go-libfossil everywhere - CloneOpts.ProjectCode removed upstream; assert via CloneResult instead - Timeline now takes TimelineOpts (cursor pagination, newest-first) - testutil.HasFossil removed; check FossilBinary() != ""

  * ci: retrigger checks

  ---------

  Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> (user: [email protected], size: 2448) [annotate] [blame] [check-ins using]

//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/go-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 {}
}