feat(gnodev): txs manipulation ability

contribs/gnodev/cmd/gnodev/main.go

@@ -49,6 +49,7 @@
 	root            string
 	premineAccounts varPremineAccounts
 	balancesFile    string
+	genesisFile     string
 
 	// Node Configuration
 	minimal    bool
@@ -171,6 +172,13 @@
 		"set node ChainID",
 	)
 
+	fs.StringVar(
+		&c.genesisFile,
+		"genesis-file",
+		defaultDevOptions.genesisFile,
+		"load the given genesis file",
+	)
+
 	fs.BoolVar(
 		&c.noWatch,
 		"no-watch",
@@ -236,7 +244,8 @@
 	// Setup Dev Node
 	// XXX: find a good way to export or display node logs
 	nodeLogger := logger.WithGroup(NodeLogName)
-	devNode, err := setupDevNode(ctx, nodeLogger, cfg, emitterServer, balances, pkgpaths)
+	nodeCfg := setupDevNodeConfig(cfg, logger, emitterServer, balances, pkgpaths)
+	devNode, err := gnodev.NewDevNode(ctx, nodeCfg)
 	if err != nil {
 		return err
 	}
@@ -292,11 +301,15 @@
 }
 
 var helper string = `
-A           Accounts - Display known accounts and balances
-H           Help - Display this message
-R           Reload - Reload all packages to take change into account.
-Ctrl+R      Reset - Reset application state.
-Ctrl+C      Exit - Exit the application
+P           Previous TX	 - Go to the previous tx
+N           Next TX	 - Go to the next tx
+E           Export	 - Export the current state as genesis doc
+A           Accounts	 - Display known accounts and balances
+H           Help	 - Display this message
+R           Reload	 - Reload all packages to take change into account.
+Ctrl+S      Save State	 - Save the current state
+Ctrl+R      Reset	 - Reset application to it's initial/save state.
+Ctrl+C      Exit	 - Exit the application
 `
 
 func runEventLoop(
@@ -307,6 +320,20 @@
 	dnode *gnodev.Node,
 	watch *watcher.PackageWatcher,
 ) error {
+	// XXX: move this in above, but we need to have a proper struct first
+	// XXX: make this configurable
+	exported := 0
+	path, err := os.MkdirTemp("", "gnodev-export")
+	if err != nil {
+		return fmt.Errorf("unable to create `export` directory: %w", err)
+	}
+
+	defer func() {
+		if exported == 0 {
+			_ = os.RemoveAll(path)
+		}
+	}()
+
 	keyPressCh := listenForKeyPress(logger.WithGroup(KeyPressLogName), rt)
 	for {
 		var err error
@@ -358,6 +385,44 @@
 						Error("unable to reset node state", "err", err)
 				}
 
+			case rawterm.KeyCtrlS: // Save
+				logger.WithGroup(NodeLogName).Info("saving state...")
+				if err := dnode.SaveCurrentState(ctx); err != nil {
+					logger.WithGroup(NodeLogName).
+						Error("unable to save node state", "err", err)
+				}
+
+			case rawterm.KeyE:
+				logger.WithGroup(NodeLogName).Info("exporting state...")
+				doc, err := dnode.ExportStateAsGenesis(ctx)
+				if err != nil {
+					logger.WithGroup(NodeLogName).
+						Error("unable to export node state", "err", err)
+					continue
+				}
+
+				docfile := filepath.Join(path, fmt.Sprintf("export_%d.jsonl", exported))
+				if err := doc.SaveAs(docfile); err != nil {
+					logger.WithGroup(NodeLogName).
+						Error("unable to save genesis", "err", err)
+				}
+				exported++
+
+				logger.WithGroup(NodeLogName).Info("node state exported", "file", docfile)
+			case rawterm.KeyN: // Next tx
+				logger.Info("moving forward...")
+				if err := dnode.MoveToNextTX(ctx); err != nil {
+					logger.WithGroup(NodeLogName).
+						Error("unable to move forward", "err", err)
+				}
+
+			case rawterm.KeyP: // Next tx
+				logger.Info("moving backward...")
+				if err := dnode.MoveToPreviousTX(ctx); err != nil {
+					logger.WithGroup(NodeLogName).
+						Error("unable to move backward", "err", err)
+				}
+
 			case rawterm.KeyCtrlC: // Exit
 				return nil
 			default:

contribs/gnodev/cmd/gnodev/setup_node.go

@@ -1,33 +1,38 @@
 package main
 
 import (
-	"context"
 	"fmt"
 	"log/slog"
 	"net"
 	"strings"
 
 	gnodev "github.com/gnolang/gno/contribs/gnodev/pkg/dev"
-	"github.com/gnolang/gno/contribs/gnodev/pkg/emitter"
+	emitter "github.com/gnolang/gno/contribs/gnodev/pkg/emitter"
 	"github.com/gnolang/gno/gno.land/pkg/gnoland"
+	"github.com/gnolang/gno/tm2/pkg/bft/types"
+	"github.com/gnolang/gno/tm2/pkg/std"
 )
 
-// setupDevNode initializes and returns a new DevNode.
-func setupDevNode(
-	ctx context.Context,
-	logger *slog.Logger,
+// setupDevNodeConfig creates and returns a new dev.NodeConfig.
+func setupDevNodeConfig(
 	cfg *devCfg,
-	remitter emitter.Emitter,
+	logger *slog.Logger,
+	emitter emitter.Emitter,
 	balances gnoland.Balances,
 	pkgspath []gnodev.PackagePath,
-) (*gnodev.Node, error) {
-	config := setupDevNodeConfig(cfg, balances, pkgspath)
-	return gnodev.NewDevNode(ctx, logger, remitter, config)
-}
-
-// setupDevNodeConfig creates and returns a new dev.NodeConfig.
-func setupDevNodeConfig(cfg *devCfg, balances gnoland.Balances, pkgspath []gnodev.PackagePath) *gnodev.NodeConfig {
+) *gnodev.NodeConfig {
 	config := gnodev.DefaultNodeConfig(cfg.root)
+	if cfg.genesisFile != "" {
+		var err error
+		if config.InitialTxs, err = extractTxsFromGenesisFile(cfg.genesisFile); err != nil {
+			logger.Error("unable to load genesis file", "path", cfg.genesisFile, "err", err)
+		} else {
+			logger.Info("genesis file loaded", "path", cfg.genesisFile, "txs", len(config.InitialTxs))
+		}
+	}
+
+	config.Logger = logger
+	config.Emitter = emitter
 	config.BalancesList = balances.List()
 	config.PackagesPathList = pkgspath
 	config.TMConfig.RPC.ListenAddress = resolveUnixOrTCPAddr(cfg.nodeRPCListenerAddr)
@@ -42,6 +47,20 @@
 	return config
 }
 
+func extractTxsFromGenesisFile(path string) (txs []std.Tx, err error) {
+	doc, err := types.GenesisDocFromFile(path)
+	if err != nil {
+		return []std.Tx{}, fmt.Errorf("unable to parse doc file: %w", err)
+	}
+
+	state, ok := doc.AppState.(gnoland.GnoGenesisState)
+	if !ok {
+		return []std.Tx{}, fmt.Errorf("invalid `GnoGenesisState` app state")
+	}
+
+	return state.Txs, nil
+}
+
 func resolveUnixOrTCPAddr(in string) (out string) {
 	var err error
 	var addr net.Addr

contribs/gnodev/go.mod

@@ -46,7 +46,7 @@ require (
 	github.com/peterbourgon/ff/v3 v3.4.0 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
-	github.com/rivo/uniseg v0.4.3 // indirect
+	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/rogpeppe/go-internal v1.12.0 // indirect
 	github.com/rs/cors v1.10.1 // indirect
 	github.com/rs/xid v1.5.0 // indirect
@@ -67,7 +67,8 @@ require (
 	golang.org/x/exp v0.0.0-20240222234643-814bf88cf225 // indirect
 	golang.org/x/mod v0.16.0 // indirect
 	golang.org/x/net v0.23.0 // indirect
-	golang.org/x/sys v0.18.0 // indirect
+	golang.org/x/sync v0.7.0 // indirect
+	golang.org/x/sys v0.20.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
 	golang.org/x/tools v0.19.0 // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de // indirect

contribs/gnodev/internal/mock/server_emitter.go

@@ -7,6 +7,12 @@ import (
 	"github.com/gnolang/gno/contribs/gnodev/pkg/events"
 )
 
+// Define empty event for NextEvent empty queue
+var (
+	eventNull = events.Custom("NULL")
+	EvtNull   = eventNull.Type()
+)
+
 // ServerEmitter is an `emitter.Emitter`
 var _ emitter.Emitter = (*ServerEmitter)(nil)
 
@@ -23,6 +29,8 @@ func (m *ServerEmitter) Emit(evt events.Event) {
 }
 
 func (m *ServerEmitter) NextEvent() (evt events.Event) {
+	evt = eventNull
+
 	m.muEvents.Lock()
 	defer m.muEvents.Unlock()