Feat: structured logging with source repo context (#2165)

* Fix: structured logging with resource repo context

Signed-off-by: Shubham Bhardwaj <[email protected]>

Author: infernus01

pkg/adapter/sinker.go

@@ -33,8 +33,23 @@ func (s *sinker) processEventPayload(ctx context.Context, request *http.Request)
 		return err
 	}
 
-	// set logger with sha and event type
-	s.logger = s.logger.With("event-sha", s.event.SHA, "event-type", s.event.EventType)
+	// Enhanced structured logging with source repository context for operators
+	logFields := []interface{}{
+		"event-sha", s.event.SHA,
+		"event-type", s.event.EventType,
+		"source-repo-url", s.event.URL,
+	}
+
+	// Add branch information if available
+	if s.event.BaseBranch != "" {
+		logFields = append(logFields, "target-branch", s.event.BaseBranch)
+	}
+	// For PRs, also include source branch if different
+	if s.event.HeadBranch != "" && s.event.HeadBranch != s.event.BaseBranch {
+		logFields = append(logFields, "source-branch", s.event.HeadBranch)
+	}
+
+	s.logger = s.logger.With(logFields...)
 	s.vcx.SetLogger(s.logger)
 
 	s.event.Request = &info.Request{

pkg/reconciler/reconciler.go

@@ -125,10 +125,30 @@ func (r *Reconciler) ReconcileKind(ctx context.Context, pr *tektonv1.PipelineRun
 
 	ctx = info.StoreCurrentControllerName(ctx, r.run.Info.Controller.Name)
 
-	logger = logger.With(
+	logFields := []interface{}{
 		"pipeline-run", pr.GetName(),
 		"event-sha", pr.GetAnnotations()[keys.SHA],
-	)
+	}
+
+	// Add source repository URL if available
+	if repoURL := pr.GetAnnotations()[keys.RepoURL]; repoURL != "" {
+		logFields = append(logFields, "source-repo-url", repoURL)
+	}
+
+	// Add branch information if available
+	if targetBranch := pr.GetAnnotations()[keys.Branch]; targetBranch != "" {
+		logFields = append(logFields, "target-branch", targetBranch)
+		if sourceBranch := pr.GetAnnotations()[keys.SourceBranch]; sourceBranch != "" && sourceBranch != targetBranch {
+			logFields = append(logFields, "source-branch", sourceBranch)
+		}
+	}
+
+	// Add event type information if available
+	if eventType := pr.GetAnnotations()[keys.EventType]; eventType != "" {
+		logFields = append(logFields, "event-type", eventType)
+	}
+
+	logger = logger.With(logFields...)
 	logger.Infof("pipelineRun %v/%v is done, reconciling to report status!  ", pr.GetNamespace(), pr.GetName())
 	r.eventEmitter.SetLogger(logger)