feat: bump xp-runtime to get step name

Signed-off-by: Philippe Scorsolini <p.scorsolini@gmail.com>

Author: phisco

go.mod

@@ -4,8 +4,9 @@ go 1.24.9
 
 require (
 	github.com/alecthomas/kong v1.10.0
-	github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260127103424-627736f1b9f1
+	github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260130110818-b375c81880a3
 	github.com/go-logr/zapr v1.3.0
+	github.com/google/go-cmp v0.7.0
 	go.uber.org/zap v1.27.1
 	google.golang.org/grpc v1.75.1
 	google.golang.org/protobuf v1.36.11

go.sum

@@ -4,8 +4,8 @@ github.com/alecthomas/kong v1.10.0 h1:8K4rGDpT7Iu+jEXCIJUeKqvpwZHbsFRoebLbnzlmrp
 github.com/alecthomas/kong v1.10.0/go.mod h1:p2vqieVMeTAnaC83txKtXe8FLke2X07aruPWXyMPQrU=
 github.com/alecthomas/repr v0.4.0 h1:GhI2A8MACjfegCPVq9f1FLvIBS+DrQ2KQBFZP1iFzXc=
 github.com/alecthomas/repr v0.4.0/go.mod h1:Fr0507jx4eOXV7AlPV6AVZLYrLIuIeSOWtW57eE/O/4=
-github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260127103424-627736f1b9f1 h1:y5C/HJq9SXLYynEh4ZK6Tf7tDrsJNS+a5Ysjg9Eyc2I=
-github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260127103424-627736f1b9f1/go.mod h1:WVVus9FBbAVjAmFxrOGDdZBFuUv9TqR916JmVl3PVRk=
+github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260130110818-b375c81880a3 h1:MJuAjQSIhOhqFB//iEOqeQtFRA85QHQjJODKWRkFbCg=
+github.com/crossplane/crossplane-runtime/v2 v2.2.0-rc.0.0.20260130110818-b375c81880a3/go.mod h1:WVVus9FBbAVjAmFxrOGDdZBFuUv9TqR916JmVl3PVRk=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=

server/server.go

@@ -148,7 +148,8 @@ func (i *Inspector) logText(eventType string, meta *pipelinev1alpha1.StepMeta, p
 		_, _ = fmt.Fprintf(i.out, "  XR NS:       %s\n", ns)
 	}
 	_, _ = fmt.Fprintf(i.out, "  Composition: %s\n", meta.GetCompositionName())
-	_, _ = fmt.Fprintf(i.out, "  Function:    %s (step %d, iteration %d)\n", meta.GetFunctionName(), meta.GetStepIndex(), meta.GetIteration())
+	_, _ = fmt.Fprintf(i.out, "  Step:        %s (index %d, iteration %d)\n", meta.GetStepName(), meta.GetStepIndex(), meta.GetIteration())
+	_, _ = fmt.Fprintf(i.out, "  Function:    %s\n", meta.GetFunctionName())
 	_, _ = fmt.Fprintf(i.out, "  Trace ID:    %s\n", meta.GetTraceId())
 	_, _ = fmt.Fprintf(i.out, "  Span ID:     %s\n", meta.GetSpanId())
 	_, _ = fmt.Fprintf(i.out, "  Timestamp:   %s\n", meta.GetTimestamp().AsTime().Format("2006-01-02T15:04:05.000Z07:00"))

server/server_test.go

@@ -23,6 +23,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/google/go-cmp/cmp"
 	"google.golang.org/protobuf/types/known/timestamppb"
 
 	pipelinev1alpha1 "github.com/crossplane/crossplane-runtime/v2/apis/pipelineinspector/proto/v1alpha1"
@@ -144,6 +145,7 @@ func TestEmitRequest_Text(t *testing.T) {
 		CompositeResourceUid:        "uid-123",
 		CompositeResourceNamespace:  "my-namespace",
 		CompositionName:             "my-composition",
+		StepName:                    "my-step",
 		FunctionName:                "my-function",
 		TraceId:                     "trace-abc",
 		SpanId:                      "span-def",
@@ -159,44 +161,23 @@ func TestEmitRequest_Text(t *testing.T) {
 
 	_, _ = inspector.EmitRequest(context.Background(), req)
 
-	output := buf.String()
-
-	// Verify header.
-	if !strings.Contains(output, "=== REQUEST ===") {
-		t.Errorf("expected REQUEST header, got: %s", output)
-	}
-
-	// Verify XR info.
-	if !strings.Contains(output, "XR:          example.org/v1/XDatabase (my-xr)") {
-		t.Errorf("expected XR info in output, got: %s", output)
-	}
-
-	// Verify UID is included.
-	if !strings.Contains(output, "XR UID:      uid-123") {
-		t.Errorf("expected XR UID in output, got: %s", output)
-	}
-
-	// Verify namespace is included.
-	if !strings.Contains(output, "XR NS:       my-namespace") {
-		t.Errorf("expected XR namespace in output, got: %s", output)
-	}
+	want := `=== REQUEST ===
+  XR:          example.org/v1/XDatabase (my-xr)
+  XR UID:      uid-123
+  XR NS:       my-namespace
+  Composition: my-composition
+  Step:        my-step (index 1, iteration 2)
+  Function:    my-function
+  Trace ID:    trace-abc
+  Span ID:     span-def
+  Timestamp:   2026-01-15T10:30:00.000Z
+  Payload:
+    apiVersion: apiextensions.crossplane.io/v1
 
-	// Verify composition name.
-	if !strings.Contains(output, "Composition: my-composition") {
-		t.Errorf("expected composition name in output, got: %s", output)
-	}
-
-	// Verify function info.
-	if !strings.Contains(output, "Function:    my-function (step 1, iteration 2)") {
-		t.Errorf("expected function info in output, got: %s", output)
-	}
 
-	// Verify trace and span IDs.
-	if !strings.Contains(output, "Trace ID:    trace-abc") {
-		t.Errorf("expected trace ID in output, got: %s", output)
-	}
-	if !strings.Contains(output, "Span ID:     span-def") {
-		t.Errorf("expected span ID in output, got: %s", output)
+`
+	if diff := cmp.Diff(want, buf.String()); diff != "" {
+		t.Errorf("EmitRequest text output mismatch (-want +got):\n%s", diff)
 	}
 }
 
@@ -212,8 +193,9 @@ func TestEmitRequest_Text_NoNamespace(t *testing.T) {
 		CompositeResourceUid:        "uid-456",
 		CompositeResourceNamespace:  "", // Empty for cluster-scoped.
 		CompositionName:             "cluster-composition",
+		StepName:                    "my-step",
 		FunctionName:                "my-function",
-		Timestamp:                   timestamppb.New(time.Now()),
+		Timestamp:                   timestamppb.New(time.Date(2026, 1, 15, 10, 30, 0, 0, time.UTC)),
 	}
 
 	req := &pipelinev1alpha1.EmitRequestRequest{
@@ -223,11 +205,20 @@ func TestEmitRequest_Text_NoNamespace(t *testing.T) {
 
 	_, _ = inspector.EmitRequest(context.Background(), req)
 
-	output := buf.String()
-
-	// Verify namespace line is NOT included for cluster-scoped resources.
-	if strings.Contains(output, "XR NS:") {
-		t.Errorf("expected no XR NS line for cluster-scoped resource, got: %s", output)
+	want := "=== REQUEST ===\n" +
+		"  XR:          example.org/v1/XClusterDatabase (my-cluster-xr)\n" +
+		"  XR UID:      uid-456\n" +
+		"  Composition: cluster-composition\n" +
+		"  Step:        my-step (index 0, iteration 0)\n" +
+		"  Function:    my-function\n" +
+		"  Trace ID:    \n" +
+		"  Span ID:     \n" +
+		"  Timestamp:   2026-01-15T10:30:00.000Z\n" +
+		"  Payload:\n" +
+		"    {}\n" +
+		"\n\n"
+	if diff := cmp.Diff(want, buf.String()); diff != "" {
+		t.Errorf("EmitRequest text output mismatch (-want +got):\n%s", diff)
 	}
 }
 
@@ -236,8 +227,12 @@ func TestEmitResponse_Text_WithError(t *testing.T) {
 	inspector := NewInspector("text", WithOutput(&buf))
 
 	meta := &pipelinev1alpha1.StepMeta{
-		FunctionName: "failing-function",
-		Timestamp:    timestamppb.New(time.Now()),
+		CompositeResourceApiVersion: "example.org/v1",
+		CompositeResourceKind:       "XDatabase",
+		CompositeResourceName:       "my-xr",
+		StepName:                    "failing-step",
+		FunctionName:                "failing-function",
+		Timestamp:                   timestamppb.New(time.Date(2026, 1, 15, 10, 30, 0, 0, time.UTC)),
 	}
 
 	req := &pipelinev1alpha1.EmitResponseRequest{
@@ -248,9 +243,19 @@ func TestEmitResponse_Text_WithError(t *testing.T) {
 
 	_, _ = inspector.EmitResponse(context.Background(), req)
 
-	output := buf.String()
-	if !strings.Contains(output, "Error:       something went wrong") {
-		t.Errorf("expected error in output, got: %s", output)
+	want := "=== RESPONSE ===\n" +
+		"  XR:          example.org/v1/XDatabase (my-xr)\n" +
+		"  XR UID:      \n" +
+		"  Composition: \n" +
+		"  Step:        failing-step (index 0, iteration 0)\n" +
+		"  Function:    failing-function\n" +
+		"  Trace ID:    \n" +
+		"  Span ID:     \n" +
+		"  Timestamp:   2026-01-15T10:30:00.000Z\n" +
+		"  Error:       something went wrong\n" +
+		"\n"
+	if diff := cmp.Diff(want, buf.String()); diff != "" {
+		t.Errorf("EmitResponse text output mismatch (-want +got):\n%s", diff)
 	}
 }
 
@@ -351,9 +356,9 @@ func TestIndentLines(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			result := indentLines(tt.input, tt.prefix)
-			if result != tt.expected {
-				t.Errorf("indentLines(%q, %q) = %q, want %q", tt.input, tt.prefix, result, tt.expected)
+			got := indentLines(tt.input, tt.prefix)
+			if diff := cmp.Diff(tt.expected, got); diff != "" {
+				t.Errorf("indentLines(%q, %q) mismatch (-want +got):\n%s", tt.input, tt.prefix, diff)
 			}
 		})
 	}