feat(cmd/rpc): Automatically detect running node for RPC requests

cmd/rpc.go

@@ -10,7 +10,9 @@ import (
 
 	rpc "github.com/celestiaorg/celestia-node/api/rpc/client"
 	"github.com/celestiaorg/celestia-node/api/rpc/perms"
+	"github.com/celestiaorg/celestia-node/nodebuilder"
 	nodemod "github.com/celestiaorg/celestia-node/nodebuilder/node"
+	"github.com/celestiaorg/celestia-node/nodebuilder/p2p"
 )
 
 const (
@@ -47,11 +49,11 @@ func RPCFlags() *flag.FlagSet {
 
 func InitClient(cmd *cobra.Command, _ []string) error {
 	if authTokenFlag == "" {
-		storePath := ""
-		if !cmd.Flag(nodeStoreFlag).Changed {
-			return errors.New("cant get the access to the auth token: token/node-store flag was not specified")
+		storePath, err := getStorePath(cmd)
+		if err != nil {
+			return err
 		}
-		storePath = cmd.Flag(nodeStoreFlag).Value.String()
+
 		token, err := getToken(storePath)
 		if err != nil {
 			return fmt.Errorf("cant get the access to the auth token: %v", err)
@@ -69,6 +71,31 @@ func InitClient(cmd *cobra.Command, _ []string) error {
 	return nil
 }
 
+func getStorePath(cmd *cobra.Command) (string, error) {
+	// if node store flag is set, use it
+	if cmd.Flag(nodeStoreFlag).Changed {
+		return cmd.Flag(nodeStoreFlag).Value.String(), nil
+	}
+
+	// try to detect a running node by checking for a lock file
+	nodeTypes := []nodemod.Type{nodemod.Bridge, nodemod.Full, nodemod.Light}
+	defaultNetwork := []p2p.Network{p2p.Mainnet, p2p.Mocha, p2p.Arabica, p2p.Private}
+	for _, t := range nodeTypes {
+		for _, n := range defaultNetwork {
+			path, err := DefaultNodeStorePath(t.String(), n.String())
+			if err != nil {
+				return "", err
+			}
+
+			if nodebuilder.IsOpened(path) {
+				return path, nil
+			}
+		}
+	}
+
+	return "", errors.New("cant get the access to the auth token: token/node-store flag was not specified")
+}
+
 func getToken(path string) (string, error) {
 	if path == "" {
 		return "", errors.New("root directory was not specified")

nodebuilder/store.go

@@ -3,6 +3,7 @@ package nodebuilder
 import (
 	"errors"
 	"fmt"
+	"os"
 	"path/filepath"
 	"runtime"
 	"sync"
@@ -150,6 +151,16 @@ type fsStore struct {
 	dirLock *flock.Flock // protects directory
 }
 
+// IsOpened checks if a directory is in use by checking if a lock file exists.
+func IsOpened(path string) bool {
+	lockPath := lockPath(path)
+	if _, err := os.Stat(lockPath); errors.Is(err, os.ErrNotExist) {
+		return false
+	}
+
+	return true
+}
+
 func storePath(path string) (string, error) {
 	return homedir.Expand(filepath.Clean(path))
 }