Upload 3 files

main.py

@@ -0,0 +1,303 @@
+import os
+import warnings
+import logging
+from market_analysis_crew import get_market_analysis_crew, get_report_generator, create_reports
+
+# Disable all warnings and telemetry
+warnings.filterwarnings('ignore')
+os.environ["ANONYMIZED_TELEMETRY"] = "False"
+os.environ["OPENTELEMETRY_ENABLED"] = "False"
+os.environ["DISABLE_TELEMETRY"] = "True"
+
+# Configure logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
+)
+logger = logging.getLogger(__name__)
+
+def get_user_input():
+    print("\n=== Report Generation Configuration ===\n")
+    
+    # Show available report types
+    print("Available Report Types:")
+    print("1. Market Analysis")
+    print("2. Competitor Tracking")
+    print("3. ICP Report")
+    print("4. Gap Analysis")
+    print("5. Market Assessment")
+    print("6. Impact Assessment")
+    
+    # Get report type
+    while True:
+        try:
+            report_choice = int(input("\nSelect report type (1-6): "))
+            if 1 <= report_choice <= 6:
+                report_types = {
+                    1: "market_analysis",
+                    2: "competitor_tracking",
+                    3: "icp_report",
+                    4: "gap_analysis",
+                    5: "market_assessment",
+                    6: "impact_assessment"
+                }
+                report_type = report_types[report_choice]
+                break
+            print("Please select a number between 1 and 6.")
+        except ValueError:
+            print("Please enter a valid number.")
+
+    # Common inputs for all report types
+    inputs = {}
+    inputs["company_name"] = input("\nEnter company name: ").strip()
+    inputs["industry"] = input("Enter industry sector (optional): ").strip()
+    inputs["time_period"] = input("Enter time period (e.g., 2024, press Enter for current): ").strip() or "2024"
+
+    # Report-specific inputs
+    if report_type == "icp_report":
+        # Business Model
+        print("\nSelect business model:")
+        print("1. B2B")
+        print("2. B2C")
+        print("3. B2B2C")
+        while True:
+            try:
+                model_choice = int(input("Select model (1-3) [1]: ") or "1")
+                if 1 <= model_choice <= 3:
+                    model_map = {1: "b2b", 2: "b2c", 3: "b2b2c"}
+                    inputs["business_model"] = model_map[model_choice]
+                    break
+                print("Please select a valid number between 1 and 3")
+            except ValueError:
+                print("Please enter a valid number")
+
+        # Company Size
+        print("\nSelect target company size:")
+        print("1. Small (1-50 employees)")
+        print("2. Medium (51-500 employees)")
+        print("3. Large (501+ employees)")
+        print("4. All sizes")
+        while True:
+            try:
+                size_choice = int(input("Select size (1-4) [4]: ") or "4")
+                if 1 <= size_choice <= 4:
+                    size_map = {1: "small", 2: "medium", 3: "large", 4: "all"}
+                    inputs["company_size"] = size_map[size_choice]
+                    break
+                print("Please select a valid number between 1 and 4")
+            except ValueError:
+                print("Please enter a valid number")
+
+        # Target Market
+        print("\nSelect target market:")
+        markets = ["Global", "North America", "Europe", "Asia Pacific", "Latin America"]
+        for i, market in enumerate(markets, 1):
+            print(f"{i}. {market}")
+        while True:
+            try:
+                market_choice = int(input(f"Select market (1-{len(markets)}) [1]: ") or "1")
+                if 1 <= market_choice <= len(markets):
+                    inputs["target_market"] = markets[market_choice-1].lower().replace(" ", "_")
+                    break
+                print(f"Please select a valid number between 1 and {len(markets)}")
+            except ValueError:
+                print("Please enter a valid number")
+
+        # Annual Revenue Range
+        print("\nSelect annual revenue range:")
+        revenue_ranges = [
+            "Under $1M",
+            "$1M - $10M",
+            "$10M - $50M",
+            "Over $50M"
+        ]
+        for i, range_ in enumerate(revenue_ranges, 1):
+            print(f"{i}. {range_}")
+        while True:
+            try:
+                revenue_choice = int(input(f"Select range (1-{len(revenue_ranges)}) [2]: ") or "2")
+                if 1 <= revenue_choice <= len(revenue_ranges):
+                    revenue_map = {1: "under_1m", 2: "1m_10m", 3: "10m_50m", 4: "over_50m"}
+                    inputs["annual_revenue"] = revenue_map[revenue_choice]
+                    break
+                print(f"Please select a valid number between 1 and {len(revenue_ranges)}")
+            except ValueError:
+                print("Please enter a valid number")
+
+    elif report_type == "competitor_tracking":
+        # Competitor inputs
+        print("\nEnter competitors (one per line, press Enter twice to finish):")
+        competitors = []
+        while True:
+            competitor = input().strip()
+            if not competitor:
+                if competitors:
+                    break
+                print("Please enter at least one competitor.")
+                continue
+            competitors.append(competitor)
+        inputs["competitors"] = competitors
+
+        # Metrics selection
+        print("\nSelect metrics to track (enter numbers separated by commas):")
+        metrics = [
+            "Market Share",
+            "Product Features",
+            "Pricing Strategy",
+            "Marketing Channels",
+            "Customer Satisfaction"
+        ]
+        for i, metric in enumerate(metrics, 1):
+            print(f"{i}. {metric}")
+        
+        while True:
+            try:
+                selected = input("\nEnter metric numbers (e.g. 1,2,3): ").strip()
+                if selected:
+                    selected_indices = [int(x.strip()) for x in selected.split(",")]
+                    if all(1 <= i <= len(metrics) for i in selected_indices):
+                        inputs["metrics"] = [metrics[i-1] for i in selected_indices]
+                        break
+                print("Please enter valid numbers separated by commas")
+            except ValueError:
+                print("Please enter valid numbers")
+
+        # Add additional competitor-specific inputs
+        inputs["analysis_depth"] = input("\nSelect analysis depth (basic/detailed/comprehensive) [detailed]: ").strip().lower() or "detailed"
+        inputs["market_region"] = input("Enter target market region [global]: ").strip() or "global"
+        
+        print("\nAdditional analysis parameters:")
+        print("1. Historical Data")
+        print("2. Current Market Position")
+        print("3. Future Projections")
+        print("4. All of the above")
+        
+        while True:
+            try:
+                analysis_scope = int(input("Select analysis scope (1-4) [4]: ") or "4")
+                if 1 <= analysis_scope <= 4:
+                    inputs["analysis_scope"] = analysis_scope
+                    break
+                print("Please select a valid number between 1 and 4.")
+            except ValueError:
+                print("Please enter a valid number.")
+
+    elif report_type == "gap_analysis":
+        # Ensure all required fields are present
+        inputs.update({
+            "focus_areas": inputs.get("focus_areas", []),
+            "timeframe": inputs.get("time_period", "2024"),
+            "analysis_depth": inputs.get("analysis_depth", "detailed"),
+            "market_region": inputs.get("market_region", "global")
+        })
+
+        if not inputs.get("focus_areas"):
+            print("\nSelect focus areas (enter numbers separated by commas):")
+            focus_areas = [
+                "Market Size and Growth",
+                "Industry Trends",
+                "Market Segments",
+                "Geographic Distribution",
+                "Competitive Landscape"
+            ]
+            for i, area in enumerate(focus_areas, 1):
+                print(f"{i}. {area}")
+            
+            while True:
+                try:
+                    selected = input("\nEnter focus area numbers (e.g. 1,2,3): ").strip()
+                    if selected:
+                        selected_indices = [int(x.strip()) for x in selected.split(",")]
+                        if all(1 <= i <= len(focus_areas) for i in selected_indices):
+                            inputs["focus_areas"] = [focus_areas[i-1] for i in selected_indices]
+                            break
+                    print("Please enter valid numbers separated by commas")
+                except ValueError:
+                    print("Please enter valid numbers")
+
+            # Add analysis depth selection
+            print("\nSelect analysis depth:")
+            print("1. Basic")
+            print("2. Detailed")
+            print("3. Comprehensive")
+            
+            while True:
+                try:
+                    depth_choice = int(input("Select depth (1-3) [2]: ") or "2")
+                    if 1 <= depth_choice <= 3:
+                        depth_map = {1: "basic", 2: "detailed", 3: "comprehensive"}
+                        inputs["analysis_depth"] = depth_map[depth_choice]
+                        break
+                    print("Please select a valid number between 1 and 3")
+                except ValueError:
+                    print("Please enter a valid number")
+
+            # Add market region selection
+            print("\nSelect target market region:")
+            regions = [
+                "Global",
+                "North America",
+                "Europe",
+                "Asia Pacific"
+            ]
+            for i, region in enumerate(regions, 1):
+                print(f"{i}. {region}")
+            
+            while True:
+                try:
+                    region_choice = int(input("\nSelect region (1-4) [1]: ") or "1")
+                    if 1 <= region_choice <= len(regions):
+                        inputs["market_region"] = regions[region_choice-1].lower().replace(" ", "_")
+                        break
+                    print(f"Please select a valid number between 1 and {len(regions)}")
+                except ValueError:
+                    print("Please enter a valid number")
+
+            # Add timeframe input
+            inputs["timeframe"] = inputs["time_period"]  # Use the common time_period as timeframe
+
+    return inputs, report_type.lower().replace(' ', '_')
+
+def main():
+    try:
+        # Get user inputs
+        user_inputs, report_type = get_user_input()
+        
+        print("\nInitializing analysis...")
+        print(f"Company: {user_inputs['company_name']}")
+        print(f"Report Type: {report_type}")
+        print(f"Industry: {user_inputs['industry'] or 'Not specified'}")
+        
+        # Confirmation
+        confirm = input("\nProceed with analysis? (y/n): ").lower().strip()
+        if confirm != 'y':
+            print("Analysis cancelled.")
+            return
+        
+        print("\nStarting analysis...")
+        print("=" * 50)
+        
+        # Use the new generator
+        generator = get_report_generator()
+        result = generator.generate_report(report_type, user_inputs)
+        
+        # Create reports
+        validation_file, report_file = create_reports(result, user_inputs, report_type)
+        
+        print("\n" + "="*50)
+        print("ANALYSIS COMPLETE")
+        print("="*50)
+        print(f"\nReports generated:")
+        print(f"1. Validation Report: {validation_file}")
+        print(f"2. Analysis Report: {report_file}")
+        
+    except KeyboardInterrupt:
+        print("\nAnalysis cancelled by user.")
+    except Exception as e:
+        print(f"\nError during analysis: {str(e)}")
+        logger.exception("Analysis failed")
+    finally:
+        print("\nThank you for using the Market Analysis Tool!")
+
+if __name__ == "__main__":
+    main() 

market_analysis_crew.py

@@ -0,0 +1,525 @@
+from crewai import Agent, Task, Crew, Process
+from langchain_openai import ChatOpenAI
+from langchain.tools import Tool
+from langchain_community.tools import WriteFileTool
+from langchain_community.utilities.serpapi import SerpAPIWrapper
+import os
+import time
+from pathlib import Path
+
+# Initialize tools and models
+openai_model = ChatOpenAI(
+    model_name="gpt-4o-mini",
+    temperature=0.7
+)
+search = SerpAPIWrapper()
+
+class ReportGenerator:
+    def __init__(self):
+        self.search_tool = Tool(
+            name="Search the internet",
+            description="Search the web for comprehensive analysis",
+            func=self.enhanced_search
+        )
+        
+        self.write_file_tool = Tool(
+            name="Write File",
+            description="Write content to a file. Input should be a dictionary with 'file_path' and 'text' keys.",
+            func=self.write_file_tool_wrapper
+        )
+
+    def enhanced_search(self, query):
+        try:
+            formatted_query = f"{query} analysis OR {query} insights 2024"
+            search_results = search.run(query=formatted_query, kwargs={
+                "num": 10,
+                "time": "y",
+            })
+            return {
+                "query": formatted_query,
+                "results": search_results,
+                "timestamp": time.strftime('%Y-%m-%d %H:%M:%S')
+            }
+        except Exception as e:
+            return {
+                "error": f"Search failed: {str(e)}",
+                "timestamp": time.strftime('%Y-%m-%d %H:%M:%S')
+            }
+
+    def write_file_tool_wrapper(self, file_input):
+        try:
+            if isinstance(file_input, str):
+                file_input = {"file_path": "report.md", "text": file_input}
+            return WriteFileTool().run(file_input)
+        except Exception as e:
+            return {
+                "error": f"File write failed: {str(e)}",
+                "timestamp": time.strftime('%Y-%m-%d %H:%M:%S')
+            }
+
+    def create_market_analysis_crew(self, inputs):
+        analyst = Agent(
+            role='Market Research Analyst',
+            goal=f'Analyze {inputs["company_name"]} market position and trends',
+            backstory="""Expert in market research and analysis. Skilled at identifying trends 
+            and opportunities in various markets.""",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='Business Report Writer',
+            goal='Create comprehensive market analysis reports',
+            backstory="""Professional business writer specializing in creating clear, 
+            actionable market analysis reports.""",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Analyze market trends and position for {inputs["company_name"]}
+                Focus on: {', '.join(inputs['focus_areas'])}
+                Industry: {inputs['industry']}
+                Time Period: {inputs['time_period']}""",
+                expected_output="""A comprehensive market analysis containing:
+                - Market size and growth trends
+                - Industry analysis
+                - Key market drivers
+                - Competitive landscape
+                - Market opportunities and challenges""",
+                agent=analyst
+            ),
+            Task(
+                description="Create a detailed market analysis report with findings",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Market overview
+                - Detailed analysis
+                - Key findings
+                - Strategic recommendations""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def create_competitor_tracking_crew(self, inputs):
+        analyst = Agent(
+            role='Competitive Intelligence Analyst',
+            goal=f'Track and analyze competitors of {inputs["company_name"]}',
+            backstory="Expert in competitive analysis and market intelligence.",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='Competition Report Writer',
+            goal='Create detailed competitor analysis reports',
+            backstory="Specialist in competitive intelligence reporting.",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Analyze competitors for {inputs['company_name']} in {inputs['industry']}
+                Competitors to analyze: {', '.join(inputs['competitors'])}
+                Metrics to track: {', '.join(inputs['metrics'])}
+                Time Period: {inputs['timeframe']}
+                Analysis Depth: {inputs['analysis_depth']}
+                Market Region: {inputs['market_region']}
+                Analysis Scope: {inputs['analysis_scope']}
+                
+                Provide detailed analysis including:
+                1. Competitor Overview
+                2. Market Position
+                3. Strengths and Weaknesses
+                4. Competitive Advantages
+                5. Market Strategy
+                6. Future Outlook
+                
+                Focus on the selected metrics and provide actionable insights.""",
+                expected_output="""A comprehensive competitor analysis document containing:
+                - Detailed analysis of each competitor
+                - Market positioning comparison
+                - Strengths and weaknesses analysis
+                - Strategic recommendations
+                The analysis should be data-driven and actionable.""",
+                agent=analyst
+            ),
+            Task(
+                description=f"""Create a comprehensive competitor analysis report including:
+                1. Executive Summary
+                2. Detailed Analysis of Each Competitor
+                3. Comparative Analysis
+                4. Strategic Recommendations
+                5. Future Considerations
+                
+                Use data and insights from the analysis to create a clear, actionable report.""",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Competitor profiles and analysis
+                - Market positioning
+                - Strategic insights
+                - Actionable recommendations
+                The report should be clear, professional, and ready for executive review.""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def create_icp_report_crew(self, inputs):
+        analyst = Agent(
+            role='ICP Research Analyst',
+            goal=f'Create detailed Ideal Customer Profile for {inputs["company_name"]}',
+            backstory="""Expert in customer profiling, market segmentation, and buyer persona development. 
+            Skilled at identifying and analyzing ideal customer characteristics and behaviors.""",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='ICP Report Writer',
+            goal='Create comprehensive ICP analysis reports',
+            backstory="""Professional report writer specializing in customer profile documentation 
+            and actionable insights for business strategy.""",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Analyze and create Ideal Customer Profile for {inputs["company_name"]}
+                Industry: {inputs['industry']}
+                Business Model: {inputs.get('business_model', 'B2B')}
+                Target Market: {inputs.get('target_market', 'Global')}
+                Company Size: {inputs.get('company_size', 'All')}
+                
+                Provide detailed analysis including:
+                1. Customer Demographics
+                2. Firmographics (for B2B)
+                3. Behavioral Patterns
+                4. Pain Points
+                5. Decision Making Process
+                6. Value Propositions
+                7. Buying Criteria
+                
+                Focus on creating actionable customer insights.""",
+                expected_output="""A comprehensive ICP analysis containing:
+                - Detailed customer characteristics
+                - Market segment analysis
+                - Behavioral insights
+                - Purchase patterns
+                - Decision factors
+                The analysis should be data-driven and actionable.""",
+                agent=analyst
+            ),
+            Task(
+                description=f"""Create a detailed ICP report including:
+                1. Executive Summary
+                2. Ideal Customer Profile Overview
+                3. Detailed Customer Characteristics
+                4. Market Segment Analysis
+                5. Customer Journey Mapping
+                6. Engagement Strategies
+                7. Implementation Recommendations
+                
+                Use insights from the analysis to create a clear, actionable report.""",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Detailed ICP analysis
+                - Market insights
+                - Strategic recommendations
+                The report should be clear, professional, and ready for executive review.""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def create_gap_analysis_crew(self, inputs):
+        analyst = Agent(
+            role='Gap Analysis Specialist',
+            goal=f'Analyze gaps and opportunities for {inputs["company_name"]}',
+            backstory="""Expert in identifying and analyzing organizational gaps, market gaps, 
+            and strategic opportunities. Skilled at providing actionable recommendations.""",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='Gap Analysis Report Writer',
+            goal='Create comprehensive gap analysis reports',
+            backstory="""Professional report writer specializing in gap analysis documentation 
+            and strategic recommendations.""",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Conduct gap analysis for {inputs["company_name"]} in {inputs["industry"]}
+                Focus Areas: {', '.join(inputs['focus_areas'])}
+                Time Period: {inputs['timeframe']}
+                Analysis Depth: {inputs['analysis_depth']}
+                Market Region: {inputs['market_region']}
+                
+                Provide detailed analysis including:
+                1. Current State Assessment
+                2. Desired Future State
+                3. Gap Identification
+                4. Root Cause Analysis
+                5. Impact Assessment
+                6. Recommendations
+                
+                Focus on the selected areas and provide actionable insights.""",
+                expected_output="""A comprehensive gap analysis containing:
+                - Current state evaluation
+                - Future state definition
+                - Gap identification and analysis
+                - Strategic recommendations
+                The analysis should be data-driven and actionable.""",
+                agent=analyst
+            ),
+            Task(
+                description=f"""Create a detailed gap analysis report including:
+                1. Executive Summary
+                2. Current State Analysis
+                3. Future State Vision
+                4. Gap Identification
+                5. Impact Analysis
+                6. Strategic Recommendations
+                7. Implementation Roadmap
+                
+                Use insights from the analysis to create a clear, actionable report.""",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Detailed gap analysis
+                - Strategic recommendations
+                - Implementation plan
+                The report should be clear, professional, and ready for executive review.""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def create_market_assessment_crew(self, inputs):
+        """Create crew for market assessment reports"""
+        analyst = Agent(
+            role='Market Assessment Analyst',
+            goal=f'Analyze market position and opportunities for {inputs["company_name"]}',
+            backstory="""Expert in market assessment and analysis. Skilled at evaluating 
+            market conditions, competitive landscapes, and growth opportunities.""",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='Market Assessment Writer',
+            goal='Create comprehensive market assessment reports',
+            backstory="""Professional report writer specializing in market assessment documentation 
+            and strategic insights.""",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Conduct market assessment for {inputs["company_name"]} in {inputs["industry"]}
+                Assessment Type: {inputs["market_type"]}
+                Focus Areas: {', '.join(inputs['focus_areas'])}
+                Market Region: {inputs['market_region']}
+                Timeframe: {inputs['timeframe']}
+                Key Metrics: {', '.join(inputs['metrics'])}
+                
+                Provide detailed analysis including:
+                1. Market Overview
+                2. Competitive Position
+                3. Growth Opportunities
+                4. Market Trends
+                5. Risk Assessment
+                6. Strategic Recommendations
+                
+                Focus on the selected areas and metrics to provide actionable insights.""",
+                expected_output="""A comprehensive market assessment containing:
+                - Market overview and size
+                - Competitive analysis
+                - Growth opportunities
+                - Strategic recommendations
+                The analysis should be data-driven and actionable.""",
+                agent=analyst
+            ),
+            Task(
+                description=f"""Create a detailed market assessment report including:
+                1. Executive Summary
+                2. Market Analysis
+                3. Competitive Position
+                4. Growth Opportunities
+                5. Risk Assessment
+                6. Strategic Recommendations
+                7. Implementation Guidelines
+                
+                Use insights from the analysis to create a clear, actionable report.""",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Detailed market assessment
+                - Strategic recommendations
+                - Implementation guidelines
+                The report should be clear, professional, and ready for executive review.""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def create_impact_assessment_crew(self, inputs):
+        """Create crew for impact assessment reports"""
+        analyst = Agent(
+            role='Impact Assessment Analyst',
+            goal=f'Analyze business impact for {inputs["company_name"]}',
+            backstory="""Expert in impact analysis and assessment. Skilled at evaluating 
+            social, economic, and environmental impacts of business operations.""",
+            tools=[self.search_tool],
+            verbose=True
+        )
+
+        writer = Agent(
+            role='Impact Assessment Writer',
+            goal='Create comprehensive impact assessment reports',
+            backstory="""Professional report writer specializing in impact assessment documentation 
+            and strategic recommendations.""",
+            tools=[self.write_file_tool],
+            verbose=True
+        )
+
+        tasks = [
+            Task(
+                description=f"""Analyze impact for {inputs["company_name"]} in {inputs["industry"]}
+                Impact Areas: {', '.join(inputs['impact_areas'])}
+                Timeframe: {inputs['timeframe']}
+                Region: {inputs['market_region']}
+                
+                Provide detailed analysis including:
+                1. Social Impact Analysis
+                2. Economic Impact Assessment
+                3. Environmental Impact
+                4. Stakeholder Impact
+                5. Long-term Sustainability
+                6. Risk Assessment
+                7. Recommendations
+                
+                Focus on quantifiable metrics and actionable insights.""",
+                expected_output="""A comprehensive impact assessment containing:
+                - Social impact metrics
+                - Economic impact analysis
+                - Environmental sustainability measures
+                - Stakeholder analysis
+                - Strategic recommendations
+                The analysis should be data-driven and actionable.""",
+                agent=analyst
+            ),
+            Task(
+                description=f"""Create a detailed impact assessment report including:
+                1. Executive Summary
+                2. Impact Analysis Overview
+                3. Social Impact Assessment
+                4. Economic Impact Analysis
+                5. Environmental Impact Evaluation
+                6. Stakeholder Analysis
+                7. Risk Assessment
+                8. Strategic Recommendations
+                9. Implementation Guidelines
+                
+                Use insights from the analysis to create a clear, actionable report.""",
+                expected_output="""A well-structured markdown report containing:
+                - Executive summary
+                - Detailed impact assessment
+                - Key metrics and findings
+                - Strategic recommendations
+                The report should be clear, professional, and ready for executive review.""",
+                agent=writer
+            )
+        ]
+
+        return Crew(
+            agents=[analyst, writer],
+            tasks=tasks,
+            verbose=True
+        )
+
+    def generate_report(self, report_type, inputs):
+        # Convert report type to match the crew creator function names
+        report_type = report_type.lower().replace(' ', '_')
+        
+        crew_creators = {
+            'market_analysis': self.create_market_analysis_crew,
+            'competitor_tracking': self.create_competitor_tracking_crew,
+            'icp_report': self.create_icp_report_crew,
+            'gap_analysis': self.create_gap_analysis_crew,
+            'market_assessment': self.create_market_assessment_crew,
+            'impact_assessment': self.create_impact_assessment_crew
+        }
+
+        if report_type not in crew_creators:
+            raise ValueError(f"Invalid report type: {report_type}")
+
+        crew = crew_creators[report_type](inputs)
+        if crew is None:
+            raise ValueError(f"Failed to create crew for report type: {report_type}")
+        
+        return crew.kickoff()
+
+def create_reports(result, inputs, report_type):
+    timestamp = time.strftime('%Y%m%d_%H%M%S')
+    base_name = f"{inputs['company_name']}_{report_type}_{timestamp}"
+    
+    validation_file = f"{base_name}_validation.txt"
+    report_file = f"{base_name}_report.md"
+
+    # Create validation report
+    with open(validation_file, 'w') as f:
+        f.write(f"Validation Report for {inputs['company_name']}\n")
+        f.write(f"Report Type: {report_type}\n")
+        f.write(f"Generated on: {time.strftime('%Y-%m-%d %H:%M:%S')}\n\n")
+        f.write(str(result))
+
+    # Create main report
+    with open(report_file, 'w') as f:
+        f.write(f"# {report_type.replace('_', ' ').title()} Report\n\n")
+        f.write(f"## Overview\n")
+        f.write(f"Company: {inputs['company_name']}\n")
+        # Add report-specific content
+        f.write(str(result))
+
+    return validation_file, report_file
+
+def get_report_generator():
+    return ReportGenerator()
+
+def get_market_analysis_crew(user_inputs):
+    """Backward compatibility function for existing code"""
+    generator = ReportGenerator()
+    return generator.create_market_analysis_crew(user_inputs)

requirements.txt

@@ -1,7 +1,11 @@
-huggingface_hub==0.22.2
-minijinja
-torch
-diffusers
-transformers
-fastapi
-uvicorn[standard]
+flask
+flask-cors
+python-dotenv
+crewai
+langchain
+google-generativeai
+serpapi
+requests
+beautifulsoup4
+markdown
+python-dotenv