feat: ftl call -v prints out more info (just request key for now) (#4830)

- It can be helpful to know the request key to then understand what
happened as part of the call (via the timeline)
    - Goose will make use of this
- We will probably want more info in the future so i made the flag not
request key specific
- Verb router now includes the request key in the call response it
creates

Author: matt2e

cmd/ftl/cmd_call.go

@@ -18,6 +18,7 @@ import (
 	"github.com/block/ftl/common/reflection"
 	"github.com/block/ftl/internal/log"
 	"github.com/block/ftl/internal/rpc"
+	"github.com/block/ftl/internal/rpc/headers"
 	"github.com/block/ftl/internal/schema/schemaeventsource"
 	status "github.com/block/ftl/internal/terminal"
 )
@@ -26,6 +27,7 @@ type callCmd struct {
 	Wait    time.Duration  `short:"w" help:"Wait up to this elapsed time for the FTL cluster to become available." default:"1m"`
 	Verb    reflection.Ref `arg:"" required:"" help:"Full path of Verb to call." predictor:"verbs"`
 	Request string         `arg:"" optional:"" help:"JSON5 request payload." default:"{}"`
+	Verbose bool           `flag:"" short:"v" help:"Print verbose information."`
 }
 
 func (c *callCmd) Run(
@@ -50,7 +52,7 @@ func (c *callCmd) Run(
 
 	logger.Debugf("Calling %s", c.Verb)
 
-	return callVerb(ctx, verbClient, schemaClient, c.Verb, requestJSON)
+	return callVerb(ctx, verbClient, schemaClient, c.Verb, requestJSON, c.Verbose)
 }
 
 func callVerb(
@@ -59,6 +61,7 @@ func callVerb(
 	schemaClient *schemaeventsource.EventSource,
 	verb reflection.Ref,
 	requestJSON []byte,
+	verbose bool,
 ) error {
 	logger := log.FromContext(ctx)
 	// otherwise, we have a match so call the verb
@@ -78,6 +81,17 @@ func callVerb(
 	if err != nil {
 		return err
 	}
+
+	if verbose {
+		requestKey, ok, err := headers.GetRequestKey(resp.Header())
+		if err != nil {
+			return fmt.Errorf("could not get request key: %w", err)
+		}
+		if ok {
+			fmt.Printf("RequestKey: %s\n", requestKey)
+		}
+	}
+
 	switch resp := resp.Msg.Response.(type) {
 	case *ftlv1.CallResponse_Error_:
 		if resp.Error.Stack != nil && logger.GetLevel() <= log.Debug {

cmd/ftl/cmd_replay.go

@@ -20,8 +20,9 @@ import (
 )
 
 type replayCmd struct {
-	Wait time.Duration  `short:"w" help:"Wait up to this elapsed time for the FTL cluster to become available." default:"1m"`
-	Verb reflection.Ref `arg:"" required:"" help:"Full path of Verb to call." predictor:"verbs"`
+	Wait    time.Duration  `short:"w" help:"Wait up to this elapsed time for the FTL cluster to become available." default:"1m"`
+	Verb    reflection.Ref `arg:"" required:"" help:"Full path of Verb to call." predictor:"verbs"`
+	Verbose bool           `flag:"" short:"v" help:"Print verbose information."`
 }
 
 func (c *replayCmd) Run(
@@ -98,5 +99,5 @@ func (c *replayCmd) Run(
 	logger.Infof("Calling %s with body:", c.Verb)
 	status.PrintJSON(ctx, []byte(requestJSON))
 	logger.Infof("Response:")
-	return callVerb(ctx, verbClient, eventSource, c.Verb, []byte(requestJSON))
+	return callVerb(ctx, verbClient, eventSource, c.Verb, []byte(requestJSON), c.Verbose)
 }

internal/routing/verb_routing.go

@@ -85,6 +85,7 @@ func (s *VerbCallRouter) Call(ctx context.Context, req *connect.Request[ftlv1.Ca
 	callEvent.Response = result.Ok(resp.Msg)
 	s.timelineClient.Publish(ctx, callEvent)
 	observability.Calls.Request(ctx, req.Msg.Verb, start, optional.None[string]())
+	headers.SetRequestKey(resp.Header(), requestKey)
 	return resp, nil
 }