Update modules/analysis.py

modules/analysis.py

@@ -710,3 +710,88 @@ def analyze_github(readme_text=None):
     return clean_text("\\n".join(tips))
 
 
+
+import requests
+import time
+import json
+
+# Make sure this is defined globally
+memo_data = []
+
+def fetch_and_analyze_linkedin(linkedin_url):
+    if not linkedin_url.strip():
+        return "⚠️ Please enter a valid LinkedIn profile URL."
+
+    apify_token = os.getenv("APIFY_TOKEN")
+    if not apify_token:
+        return "⚠️ APIFY_TOKEN not found in environment variables."
+
+    actor_id = "rivapereira268~linkedin-profile-full-sections-scraper---no-cookies-task"
+    start_url = f"https://api.apify.com/v2/actor-tasks/{actor_id}/runs?token={apify_token}"
+    input_payload = {"profileUrls": [linkedin_url]}
+
+    try:
+        # Step 1: Start Apify run
+        run_response = requests.post(start_url, json=input_payload)
+        run_data = run_response.json()
+        if "data" not in run_data or "id" not in run_data["data"]:
+            return "❌ Failed to start Apify task."
+
+        run_id = run_data["data"]["id"]
+        print(f"[DEBUG] Apify task started. Run ID: {run_id}")
+
+        # Step 2: Poll for status
+        status_url = f"https://api.apify.com/v2/actor-runs/{run_id}?token={apify_token}"
+        for _ in range(30):
+            time.sleep(2)
+            run_status = requests.get(status_url).json()
+            status = run_status["data"]["status"]
+            print(f"[DEBUG] Apify task status: {status}")
+            if status == "SUCCEEDED":
+                break
+            elif status in ["FAILED", "ABORTED"]:
+                return f"❌ Apify task failed: {status}"
+
+        # Step 3: Fetch dataset
+        dataset_id = run_status["data"]["defaultDatasetId"]
+        items_url = f"https://api.apify.com/v2/datasets/{dataset_id}/items?format=json"
+        items = requests.get(items_url).json()
+        print(f"[DEBUG] Items fetched: {len(items)}")
+
+        if not items or not isinstance(items, list):
+            return "❌ No data returned from Apify. LinkedIn profile may be private or blocked."
+
+        # Step 4: Unwrap nested list if needed
+        while isinstance(items[0], list):
+            items = items[0]
+        profile_data = items[0]
+
+        if not isinstance(profile_data, dict):
+            return "❌ Apify returned unexpected data format."
+
+        # Step 5: Analyze profile and extract actions
+        result = analyze_scraped_linkedin_profile(profile_data)
+        print(f"[DEBUG] Analysis Result: {result[:100]}...")
+
+        actions = extract_actions_from_feedback(result, source="Linky")
+        print(f"[DEBUG] Actions Extracted: {len(actions)}")
+        memo_data.extend(actions)
+
+        # Step 6: Add generic Linky nudges if missing
+        existing_texts = [entry["text"] for entry in memo_data]
+        linky_nudges = [
+            {"type": "Action", "text": "🧩 Create a free Linktree to unify your portfolio links", "source": "Linky"},
+            {"type": "Action", "text": "🤝 Reach out for 1–2 professional recommendations on LinkedIn", "source": "Linky"},
+            {"type": "Action", "text": "🌿 Add a volunteering experience — even academic or event-based", "source": "Linky"},
+            {"type": "Action", "text": "📊 Review your LinkedIn Analytics this month", "source": "Linky"},
+        ]
+        for nudge in linky_nudges:
+            if nudge["text"] not in existing_texts:
+                memo_data.append(nudge)
+
+        return result
+
+    except Exception as e:
+        print(f"[ERROR] Exception during LinkedIn analysis: {e}")
+        return f"❌ Internal error: {e}"
+