refactor: extract organization footprinting into dedicated component

- Moved organization footprinting logic from BugBountyEngine into new OrganizationFootprinting component
- Added organizationFootprinting field to BugBountyEngine struct
- Created buildOrganizationFootprinting factory method to initialize the new component
- Simplified Execute() method by delegating footprinting logic to the new component
- Maintained existing functionality while improving code organization and reducing complexity

Author: CodeMonkeyCybersecurity

internal/orchestrator/bounty_engine.go

@@ -77,9 +77,10 @@ type BugBountyEngine struct {
 	checkpointManager  CheckpointManager
 
 	// Output and Persistence (REFACTORED: extracted from bounty_engine.go)
-	outputFormatter      *OutputFormatter
-	persistenceManager   *PersistenceManager
-	platformIntegration  *PlatformIntegration
+	outputFormatter           *OutputFormatter
+	persistenceManager        *PersistenceManager
+	platformIntegration       *PlatformIntegration
+	organizationFootprinting  *OrganizationFootprinting
 
 	// Configuration
 	config BugBountyConfig
@@ -506,116 +507,21 @@ func (e *BugBountyEngine) Execute(ctx context.Context, target string) (*BugBount
 
 	// Phase 0: Organization Footprinting (if enabled)
 	var orgDomains []string
-	if e.orgCorrelator != nil && !e.config.SkipDiscovery {
-		footprintStart := time.Now()
-
-		// IMMEDIATE CLI FEEDBACK - Show user what's happening
-		fmt.Println()
-		fmt.Println("═══════════════════════════════════════════════════════════════")
-		fmt.Println(" Phase 0: Organization Footprinting")
-		fmt.Println("═══════════════════════════════════════════════════════════════")
-		fmt.Printf("   Analyzing: %s\n", target)
-		fmt.Printf("   • WHOIS lookup for organization details...\n")
-		fmt.Printf("   • Certificate transparency logs for related domains...\n")
-		fmt.Printf("   • ASN discovery for IP ranges...\n")
-		fmt.Println()
-
-		dbLogger.Infow(" Phase 0: Organization Footprinting",
-			"target", target,
-			"enable_whois", e.config.EnableWHOISAnalysis,
-			"enable_cert_transparency", e.config.EnableCertTransparency,
-			"enable_related_domains", e.config.EnableRelatedDomainDisc,
-			"component", "orchestrator",
-		)
-
-		// Correlate organization from target
-		org, err := e.orgCorrelator.FindOrganizationAssets(ctx, target)
-		if err != nil {
-			// ENHANCED ERROR LOGGING: Provide detailed diagnostics
-			dbLogger.Errorw("CRITICAL: Organization footprinting failed",
-				"error", err,
-				"error_type", fmt.Sprintf("%T", err),
-				"target", target,
-				"whois_enabled", e.config.EnableWHOISAnalysis,
-				"cert_enabled", e.config.EnableCertTransparency,
-				"asn_enabled", true,
-				"elapsed_time", time.Since(footprintStart).String(),
-				"component", "orchestrator",
-			)
-
-			// Store failed phase result
-			result.PhaseResults["footprinting"] = PhaseResult{
-				Phase:     "footprinting",
-				Status:    "failed",
-				StartTime: footprintStart,
-				EndTime:   time.Now(),
-				Duration:  time.Since(footprintStart),
-				Error:     err.Error(),
+	if e.organizationFootprinting != nil && e.organizationFootprinting.IsEnabled() {
+		footprintResult := e.organizationFootprinting.CorrelateOrganization(ctx, target, updateProgress, saveCheckpoint)
+		if footprintResult != nil {
+			// Store organization info and domains
+			if footprintResult.Organization != nil {
+				result.OrganizationInfo = footprintResult.Organization
 			}
-		} else if org == nil {
-			// NULL RESULT: Correlation returned nil without error
-			dbLogger.Warnw(" Organization footprinting returned nil (no error)",
-				"target", target,
-				"elapsed_time", time.Since(footprintStart).String(),
-				"component", "orchestrator",
-			)
-
-			result.PhaseResults["footprinting"] = PhaseResult{
-				Phase:     "footprinting",
-				Status:    "completed",
-				StartTime: footprintStart,
-				EndTime:   time.Now(),
-				Duration:  time.Since(footprintStart),
-				Findings:  0,
-			}
-		} else {
-			// Store org info for later display
-			result.OrganizationInfo = org // Add to result for display
-
-			dbLogger.Infow(" Organization footprinting completed",
-				"organization_name", org.Name,
-				"domains_found", len(org.Domains),
-				"asns_found", len(org.ASNs),
-				"ip_ranges_found", len(org.IPRanges),
-				"certificates_found", len(org.Certificates),
-				"confidence", org.Confidence,
-				"sources", org.Sources,
-				"duration", time.Since(footprintStart).String(),
-				"component", "orchestrator",
-			)
-
-			// USER-FRIENDLY CLI DISPLAY
-			e.outputFormatter.DisplayOrganizationFootprinting(org, time.Since(footprintStart))
+			orgDomains = footprintResult.Domains
 
-			// Store discovered domains for parallel scanning
-			orgDomains = org.Domains
-
-			// Log each discovered domain
-			for i, domain := range org.Domains {
-				dbLogger.Infow(" Discovered related domain",
-					"index", i+1,
-					"domain", domain,
-					"organization", org.Name,
-					"component", "orchestrator",
-				)
-			}
-
-			// Store organization metadata in result
+			// Store phase result
 			if result.PhaseResults == nil {
 				result.PhaseResults = make(map[string]PhaseResult)
 			}
-			result.PhaseResults["footprinting"] = PhaseResult{
-				Phase:     "footprinting",
-				Status:    "completed",
-				StartTime: footprintStart,
-				EndTime:   time.Now(),
-				Duration:  time.Since(footprintStart),
-				Findings:  len(org.Domains), // Count domains as findings
-			}
+			result.PhaseResults["footprinting"] = footprintResult.PhaseResult
 		}
-
-		updateProgress("footprinting", 5.0, []string{"footprinting"})
-		saveCheckpoint("footprinting", 5.0, []string{"footprinting"}, []types.Finding{})
 	}
 
 	// Phase 1: Asset Discovery (or skip if configured)

internal/orchestrator/factory.go

@@ -89,27 +89,29 @@ func (f *EngineFactory) Build() (*BugBountyEngine, error) {
 	outputFormatter := f.buildOutputFormatter()
 	persistenceMgr := f.buildPersistenceManager(enricher, checkpointMgr)
 	platformIntegration := f.buildPlatformIntegration(scopeManager)
+	orgFootprinting := f.buildOrganizationFootprinting(orgCorrelator, outputFormatter)
 
 	engine := &BugBountyEngine{
-		store:               f.store,
-		telemetry:           f.telemetry,
-		logger:              f.logger,
-		rateLimiter:         rateLimiter,
-		discoveryEngine:     discoveryEngine,
-		orgCorrelator:       orgCorrelator,
-		certIntel:           certIntel,
-		scopeManager:        scopeManager,
-		authDiscovery:       authDiscovery,
-		scannerManager:      scannerMgr,
-		pythonWorkers:       pythonWorkers,
-		enricher:            enricher,
-		checkpointEnabled:   f.config.EnableCheckpointing,
-		checkpointInterval:  f.config.CheckpointInterval,
-		checkpointManager:   checkpointMgr,
-		outputFormatter:     outputFormatter,
-		persistenceManager:  persistenceMgr,
-		platformIntegration: platformIntegration,
-		config:              f.config,
+		store:                    f.store,
+		telemetry:                f.telemetry,
+		logger:                   f.logger,
+		rateLimiter:              rateLimiter,
+		discoveryEngine:          discoveryEngine,
+		orgCorrelator:            orgCorrelator,
+		certIntel:                certIntel,
+		scopeManager:             scopeManager,
+		authDiscovery:            authDiscovery,
+		scannerManager:           scannerMgr,
+		pythonWorkers:            pythonWorkers,
+		enricher:                 enricher,
+		checkpointEnabled:        f.config.EnableCheckpointing,
+		checkpointInterval:       f.config.CheckpointInterval,
+		checkpointManager:        checkpointMgr,
+		outputFormatter:          outputFormatter,
+		persistenceManager:       persistenceMgr,
+		platformIntegration:      platformIntegration,
+		organizationFootprinting: orgFootprinting,
+		config:                   f.config,
 	}
 
 	f.logger.Infow("BugBountyEngine built successfully",
@@ -509,3 +511,11 @@ func (f *EngineFactory) buildPlatformIntegration(scopeManager *scope.Manager) *P
 	return NewPlatformIntegration(scopeManager, f.logger, f.config)
 }
 
+// buildOrganizationFootprinting creates organization footprinting manager
+func (f *EngineFactory) buildOrganizationFootprinting(
+	orgCorrelator *correlation.OrganizationCorrelator,
+	outputFormatter *OutputFormatter,
+) *OrganizationFootprinting {
+	return NewOrganizationFootprinting(orgCorrelator, outputFormatter, f.logger, f.config)
+}
+