Merge pull request #231 from whywaita/fix/230

Set installation object in rescue

Author: whywaita

pkg/gh/installation.go

@@ -102,6 +102,22 @@ func _listAppsInstalledRepo(ctx context.Context, installationID int64) ([]*githu
 	return repositories, nil
 }
 
+// GetInstallationByID returns installation from cache by ID
+func GetInstallationByID(ctx context.Context, installationID int64) (*github.Installation, error) {
+	installations, err := listInstallations(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get installations: %w", err)
+	}
+
+	for _, installation := range installations {
+		if installation.GetID() == installationID {
+			return installation, nil
+		}
+	}
+
+	return nil, fmt.Errorf("installation not found: %d", installationID)
+}
+
 // PurgeInstallationCache purges the cache of installations
 func PurgeInstallationCache(ctx context.Context) error {
 	installations, err := listInstallations(ctx)

pkg/starter/starter.go

@@ -435,13 +435,39 @@ func enqueueRescueRun(ctx context.Context, pendingRun datastore.PendingWorkflowR
 			continue
 		}
 
+		// Get installation ID from target scope
+		installationID, err := gh.IsInstalledGitHubApp(ctx, target.Scope)
+		if err != nil {
+			return fmt.Errorf("failed to get installation ID: %w", err)
+		}
+
+		// Get full installation data from cache
+		installation, err := gh.GetInstallationByID(ctx, installationID)
+		if err != nil {
+      logger.Logf(false, "failed to get installation from cache (installationID: %d), using minimal data: %+v", installationID, err)
+			// Fallback to minimal installation data
+			installation = &github.Installation{
+				ID: &installationID,
+			}
+		}
+
+		owner := pendingRun.WorkflowRun.GetRepository().GetOwner()
+		var org *github.Organization
+		if owner != nil {
+			org = &github.Organization{
+				ID:    owner.ID,
+				Login: owner.Login,
+				Name:  owner.Name,
+			}
+		}
+		
 		event := &github.WorkflowJobEvent{
 			WorkflowJob:  job,
 			Action:       github.String("queued"),
-			Org:          nil,
+			Org:          org,
 			Repo:         pendingRun.WorkflowRun.GetRepository(),
-			Sender:       nil,
-			Installation: nil,
+			Sender:       pendingRun.WorkflowRun.GetActor(),
+			Installation: installation,
 		}
 
 		if err := enqueueRescueJob(ctx, event, *target, ds); err != nil {