chore: allow dry-run for non-prod envs

Signed-off-by: Mouad BANI <mouad-mb@outlook.com>

Author: mbani01

services/apps/git_integration/src/crowdgit/services/software_value/main.go

@@ -51,17 +51,25 @@ func processRepository() StandardResponse {
 	// Process single repository (the target path argument)
 	repoDir := config.TargetPath
 
-	insightsDb, err := NewInsightsDB(ctx, config.InsightsDatabase)
-	if err != nil {
-		errorCode := ErrorCodeDatabaseConnection
-		errorMessage := fmt.Sprintf("Error connecting to insights database: %v", err)
-		return StandardResponse{
-			Status:       StatusFailure,
-			ErrorCode:    &errorCode,
-			ErrorMessage: &errorMessage,
+	dryRun := os.Getenv("IS_PROD_ENV") != "true"
+
+	var insightsDb *InsightsDB
+	if !dryRun {
+		var dbErr error
+		insightsDb, dbErr = NewInsightsDB(ctx, config.InsightsDatabase)
+		if dbErr != nil {
+			errorCode := ErrorCodeDatabaseConnection
+			errorMessage := fmt.Sprintf("Error connecting to insights database: %v", dbErr)
+			return StandardResponse{
+				Status:       StatusFailure,
+				ErrorCode:    &errorCode,
+				ErrorMessage: &errorMessage,
+			}
 		}
+		defer insightsDb.Close()
+	} else {
+		fmt.Println("[DRY RUN] Skipping database connection")
 	}
-	defer insightsDb.Close()
 
 	// Get git URL for the repository
 	gitUrl, err := getGitRepositoryURL(repoDir)
@@ -88,24 +96,32 @@ func processRepository() StandardResponse {
 	}
 	report.Repository.URL = gitUrl
 
-	// Save to database
-	if err := insightsDb.saveProjectCost(ctx, report.Repository, report.Cocomo.CostInDollars); err != nil {
-		errorCode := ErrorCodeDatabaseOperation
-		errorMessage := fmt.Sprintf("Error saving project cost: %v", err)
-		return StandardResponse{
-			Status:       StatusFailure,
-			ErrorCode:    &errorCode,
-			ErrorMessage: &errorMessage,
+	if dryRun {
+		fmt.Printf("[DRY RUN] Would save project cost: repo=%s cost=$%.2f\n", report.Repository.URL, report.Cocomo.CostInDollars)
+		fmt.Printf("[DRY RUN] Would save %d language stats entries\n", len(report.LanguageStats))
+		for _, ls := range report.LanguageStats {
+			fmt.Printf("[DRY RUN]   language=%s lines=%d code=%d\n", ls.LanguageName, ls.Lines, ls.Code)
+		}
+	} else {
+		// Save to database
+		if err := insightsDb.saveProjectCost(ctx, report.Repository, report.Cocomo.CostInDollars); err != nil {
+			errorCode := ErrorCodeDatabaseOperation
+			errorMessage := fmt.Sprintf("Error saving project cost: %v", err)
+			return StandardResponse{
+				Status:       StatusFailure,
+				ErrorCode:    &errorCode,
+				ErrorMessage: &errorMessage,
+			}
 		}
-	}
 
-	if err := insightsDb.saveLanguageStats(ctx, report.Repository, report.LanguageStats); err != nil {
-		errorCode := ErrorCodeDatabaseOperation
-		errorMessage := fmt.Sprintf("Error saving language stats: %v", err)
-		return StandardResponse{
-			Status:       StatusFailure,
-			ErrorCode:    &errorCode,
-			ErrorMessage: &errorMessage,
+		if err := insightsDb.saveLanguageStats(ctx, report.Repository, report.LanguageStats); err != nil {
+			errorCode := ErrorCodeDatabaseOperation
+			errorMessage := fmt.Sprintf("Error saving language stats: %v", err)
+			return StandardResponse{
+				Status:       StatusFailure,
+				ErrorCode:    &errorCode,
+				ErrorMessage: &errorMessage,
+			}
 		}
 	}
 
@@ -123,7 +139,7 @@ func processRepository() StandardResponse {
 func getSCCReport(sccPath, dirPath string) (SCCReport, error) {
 	cost, err := getCost(sccPath, dirPath)
 	if err != nil {
-		return SCCReport{}, fmt.Errorf("error getting SCC report for '%s': %v\"", err)
+		return SCCReport{}, fmt.Errorf("error getting SCC report for '%s': %v", dirPath, err)
 	}
 
 	// Skip saving to database if cost is 0 - do we want to do this?

services/apps/git_integration/src/crowdgit/settings.py

@@ -44,3 +44,4 @@ def load_env_var(key: str, required=True, default=None):
 STUCK_RECURRENT_REPO_TIMEOUT_HOURS = int(
     load_env_var("STUCK_RECURRENT_REPO_TIMEOUT_HOURS", default="4")
 )
+IS_PROD_ENV = bool(load_env_var("IS_PROD_ENV"))