Make it work end-to-end

internal/cmd/beta/beta_cmd.go

@@ -1,6 +1,8 @@
 package beta
 
 import (
+	"fmt"
+
 	"github.com/spf13/cobra"
 	"github.com/spf13/pflag"
 
@@ -10,8 +12,10 @@ import (
 )
 
 type commonFlags struct {
+	silent     bool
 	categories []string
 	filename   string
+	subtle     bool
 }
 
 func BetaCmd() *cobra.Command {
@@ -27,7 +31,7 @@ All commands are experimental and not yet ready for production use.
 All commands use the runme.yaml configuration file.`,
 		Hidden: true,
 		PersistentPreRunE: func(cmd *cobra.Command, args []string) error {
-			return autoconfig.InvokeForCommand(func(cfg *config.Config) error {
+			err := autoconfig.InvokeForCommand(func(cfg *config.Config) error {
 				// Override the filename if provided.
 				if cFlags.filename != "" {
 					cfg.ProjectFilename = cFlags.filename
@@ -44,6 +48,10 @@ All commands use the runme.yaml configuration file.`,
 
 				return nil
 			})
+			if !cFlags.silent && err != nil {
+				fmt.Fprintf(cmd.ErrOrStderr(), "%s\n", err)
+			}
+			return nil
 		},
 	}
 
@@ -54,6 +62,8 @@ All commands use the runme.yaml configuration file.`,
 	pFlags := cmd.PersistentFlags()
 	pFlags.StringVar(&cFlags.filename, "filename", "", "Name of the Markdown file to run blocks from.")
 	pFlags.StringSliceVar(&cFlags.categories, "category", nil, "Run blocks only from listed categories.")
+	pFlags.BoolVar(&cFlags.silent, "silent", false, "Silent mode. Do not error messages.")
+	pFlags.BoolVar(&cFlags.subtle, "subtle", false, "Explicitly allow delicate operations to prevent misuse")
 
 	// Hide all persistent flags from the root command.
 	// "beta" is a completely different set of commands and
@@ -73,6 +83,7 @@ All commands use the runme.yaml configuration file.`,
 	cmd.AddCommand(printCmd(cFlags))
 	cmd.AddCommand(server.Cmd())
 	cmd.AddCommand(runCmd(cFlags))
+	cmd.AddCommand(envCmd(cFlags))
 
 	return &cmd
 }

internal/cmd/environment.go

@@ -204,7 +204,7 @@ func environmentDumpCmd() *cobra.Command {
 		Long:  "Dumps all environment variables to stdout as a list of K=V separated by null terminators",
 		RunE: func(cmd *cobra.Command, args []string) error {
 			if !fInsecure {
-				return errors.New("must be run in insecure mode; enable by running with --insecure flag")
+				return errors.New("must be run in insecure mode to prevent misuse; enable by adding --insecure flag")
 			}
 
 			producer, err := newOSEnvironReader()

internal/cmd/root.go

@@ -24,6 +24,7 @@ var (
 	fRespectGitignore      bool
 	fSkipRunnerFallback    bool
 	fInsecure              bool
+	fSubtle                bool
 	fLogEnabled            bool
 	fLogFilePath           string
 	fExtensionHandle       string
@@ -84,7 +85,8 @@ func Root() *cobra.Command {
 
 	pflags.StringVar(&fChdir, "chdir", getCwd(), "Switch to a different working directory before executing the command")
 	pflags.StringVar(&fFileName, "filename", "README.md", "Name of the README file")
-	pflags.BoolVar(&fInsecure, "insecure", false, "Run command in insecure-mode")
+	pflags.BoolVar(&fInsecure, "insecure", false, "Explicitly allow insecure operations to prevent misuse")
+	pflags.BoolVar(&fSubtle, "subtle", false, "Explicitly allow delicate operations to prevent misuse")
 
 	pflags.StringVar(&fProject, "project", "", "Root project to find runnable tasks")
 	pflags.BoolVar(&fRespectGitignore, "git-ignore", true, "Whether to respect .gitignore file(s) in project")

internal/command/command_terminal.go

@@ -48,8 +48,12 @@ func (c *terminalCommand) Start(ctx context.Context) (err error) {
 		}
 	}
 
+	if _, err := c.stdinWriter.Write([]byte(" eval $(runme beta env source --silent --subtle --export)\n clear\n")); err != nil {
+		return err
+	}
+
 	// todo(sebastian): good enough for prototype; it makes more sense to write this message at the TTY-level
-	initMsg := []byte(" clear\n # Runme: This terminal forked your session. " +
+	initMsg := []byte(" # Runme: This terminal forked your session. " +
 		"Upon exit exported environment variables will be rolled up into the session.\n\n")
 	_, err = c.stdinWriter.Write(initMsg)
 

internal/runnerv2service/service_sessions.go

@@ -3,6 +3,7 @@ package runnerv2service
 import (
 	"context"
 
+	"go.uber.org/zap"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
 
@@ -45,6 +46,8 @@ func (r *runnerService) CreateSession(ctx context.Context, req *runnerv2alpha1.C
 
 	r.sessions.Add(sess)
 
+	r.logger.Debug("created session", zap.String("id", sess.ID))
+
 	return &runnerv2alpha1.CreateSessionResponse{
 		Session: convertSessionToRunnerv2alpha1Session(sess),
 	}, nil