sparkles: Add reset event for sdk (#143)

internal/agent/install.go

@@ -31,9 +31,11 @@ func optsToArgs(options map[string]string) (res []string) {
 	for k, v := range options {
 		if k != "device" && k != "cc" && k != "reboot" && k != "poweroff" {
 			res = append(res, fmt.Sprintf("--%s", k))
+			if v != "" {
 				res = append(res, v)
 			}
 		}
+	}
 	return
 }
 

internal/agent/reset.go

@@ -1,19 +1,34 @@
 package agent
 
 import (
+	"encoding/json"
 	"fmt"
 	"os"
 	"os/exec"
 	"sync"
 	"time"
 
+	"github.com/kairos-io/kairos/internal/bus"
 	"github.com/kairos-io/kairos/internal/cmd"
 	"github.com/kairos-io/kairos/pkg/machine"
 	"github.com/kairos-io/kairos/pkg/utils"
+	sdk "github.com/kairos-io/kairos/sdk/bus"
+
+	"github.com/mudler/go-pluggable"
 	"github.com/pterm/pterm"
 )
 
 func Reset() error {
+	bus.Manager.Initialize()
+
+	options := map[string]string{}
+
+	bus.Manager.Response(sdk.EventBeforeReset, func(p *pluggable.Plugin, r *pluggable.EventResponse) {
+		err := json.Unmarshal([]byte(r.Data), &options)
+		if err != nil {
+			fmt.Println(err)
+		}
+	})
 
 	cmd.PrintBranding(DefaultBanner)
 
@@ -43,7 +58,15 @@ func Reset() error {
 	time.Sleep(60 * time.Second)
 	lock.Lock()
 	args := []string{"reset"}
+
+	bus.Manager.Publish(sdk.EventBeforeReset, sdk.EventPayload{}) //nolint:errcheck
+
+	optsArgs := optsToArgs(options)
+	if len(optsArgs) > 0 {
+		args = append(args, optsArgs...)
+	} else {
 		args = append(args, "--reset-persistent")
+	}
 
 	cmd := exec.Command("elemental", args...)
 	cmd.Env = os.Environ()
@@ -55,6 +78,8 @@ func Reset() error {
 		os.Exit(1)
 	}
 
+	bus.Manager.Publish(sdk.EventAfterReset, sdk.EventPayload{}) //nolint:errcheck
+
 	pterm.Info.Println("Rebooting in 60 seconds, press Enter to abort...")
 
 	// We don't close the lock, as none of the following actions are expected to return