feat: Add LinkedIn API posting + enhanced analyzer + schema

main.py

@@ -15,6 +15,7 @@ from services.analyzer import analyze_seo_content
 from services.youtube_analyzer import analyze_youtube
 from services.instagram_analyzer import analyze_instagram
 from services.linkedin_analyzer import analyze_linkedin
+from services.linkedin_api import get_oauth_url, exchange_code, get_user_info, create_post
 from services.facebook_analyzer import analyze_facebook
 from services.twitter_analyzer import analyze_twitter
 from services.tiktok_analyzer import analyze_tiktok
@@ -98,6 +99,47 @@ def analyze_instagram_route(request: SEORequest):
 def analyze_linkedin_route(request: SEORequest):
     return safe_analyze(analyze_linkedin, request.content)
 
+
+@app.get("/api/linkedin/auth-url")
+def linkedin_auth_url(state: str = ""):
+    url = get_oauth_url(state)
+    return {"url": url}
+
+
+class TokenExchangeRequest(BaseModel):
+    code: str
+
+
+@app.post("/api/linkedin/exchange-token")
+def linkedin_exchange_token(req: TokenExchangeRequest):
+    token_data, err = exchange_code(req.code)
+    if err:
+        raise HTTPException(status_code=400, detail=err)
+    user_info, uerr = get_user_info(token_data["access_token"])
+    if uerr:
+        raise HTTPException(status_code=400, detail=uerr)
+    return {
+        "access_token": token_data["access_token"],
+        "expires_at": token_data["expires_at"],
+        "user": user_info,
+    }
+
+
+class PostToLinkedInRequest(BaseModel):
+    access_token: str
+    author_urn: str
+    text: str
+    hashtags: list[str] = []
+
+
+@app.post("/api/linkedin/post")
+def linkedin_post(req: PostToLinkedInRequest):
+    result, err = create_post(req.access_token, req.author_urn, req.text, req.hashtags)
+    if err:
+        raise HTTPException(status_code=400, detail=err)
+    return {"success": True, **result}
+
+
 # ---------------------------------------------------------------------------
 # Facebook
 # ---------------------------------------------------------------------------

models/schemas.py

@@ -79,16 +79,33 @@ class PostDraft(BaseModel):
     headline: str
     body: str
     hook: str
+    post_type: str = "text"
+    call_to_action: Optional[str] = None
+    media_suggestion: Optional[str] = None
 
 class LinkedInResponse(BaseModel):
     post_drafts: List[PostDraft]
     hashtags: List[str]
     article_topics: List[str]
     thought_leadership_angles: List[str]
+    engagement_prompts: List[str] = []
+    target_audience_tags: List[str] = []
     best_posting_time: str
     industry_insights: str
     error: Optional[str] = None
 
+class LinkedInPostRequest(BaseModel):
+    content: str
+    draft_index: int = 0
+    access_token: str = ""
+    linkedin_urn: str = ""
+
+class LinkedInPostResponse(BaseModel):
+    success: bool
+    post_url: Optional[str] = None
+    message: str
+    error: Optional[str] = None
+
 # ---------------------------------------------------------------------------
 # Facebook
 # ---------------------------------------------------------------------------

services/linkedin_analyzer.py

@@ -1,12 +1,16 @@
 from services.utils import run_analysis
 
-SYSTEM_PROMPT = """You are a LinkedIn content strategist. Return ONLY a valid JSON object (not an array)."""
+SYSTEM_PROMPT = """You are a LinkedIn content strategist. Return ONLY a valid JSON object (not an array). Create high-engagement LinkedIn posts with industry insights."""
 
 DEFAULTS = {
-    "post_drafts": [{"headline": "Key Insights on This Topic", "body": "Here are my thoughts on this important subject.", "hook": "Stop scrolling if you care about this"}],
+    "post_drafts": [
+        {"headline": "Key Insights on This Topic", "body": "Here are my thoughts on this important subject. It's changing how we approach problems in 2026.", "hook": "Stop scrolling if you care about this", "post_type": "text", "call_to_action": "Share your thoughts below", "media_suggestion": "Infographic with key stats"}
+    ],
     "hashtags": ["#industry", "#leadership"],
     "article_topics": ["The Future of This Industry"],
     "thought_leadership_angles": ["Unique perspective on current trends"],
+    "engagement_prompts": ["What has your experience been with this topic?"],
+    "target_audience_tags": ["#TechLeaders", "#IndustryPros"],
     "best_posting_time": "7-9 AM EST Tue-Thu",
     "industry_insights": "This is a growing space with significant potential."
 }
@@ -14,6 +18,6 @@ DEFAULTS = {
 def analyze_linkedin(content: str) -> dict:
     messages = [
         {"role": "system", "content": SYSTEM_PROMPT},
-        {"role": "user", "content": f'Topic: "{content[:1000]}"\nReturn a JSON object (not an array) with these keys:\n- post_drafts (2 items, each with "headline" + "body" + "hook")\n- hashtags (3 items)\n- article_topics (2 items)\n- thought_leadership_angles (2 items)\n- best_posting_time (string)\n- industry_insights (string)'}
+        {"role": "user", "content": f'Topic: "{content[:1000]}"\nReturn a JSON object (not an array) with these keys:\n- post_drafts (2 items, each with "headline" + "body" + "hook" + "post_type" ["text"|"article"|"poll"] + "call_to_action" + "media_suggestion")\n- hashtags (4 items)\n- article_topics (2 items)\n- thought_leadership_angles (2 items)\n- engagement_prompts (2 items, questions to spark discussion)\n- target_audience_tags (2 items, industry tags)\n- best_posting_time (string)\n- industry_insights (string)'}
     ]
-    return run_analysis(messages, defaults=DEFAULTS, temperature=0.3, max_new_tokens=800)
+    return run_analysis(messages, defaults=DEFAULTS, temperature=0.35, max_new_tokens=1000)

services/linkedin_api.py

@@ -0,0 +1,132 @@
+import os
+import json
+import requests
+import time
+from pathlib import Path
+from dotenv import load_dotenv
+
+env_path = Path(__file__).resolve().parent.parent / ".env"
+load_dotenv(dotenv_path=env_path)
+
+CLIENT_ID = os.getenv("LINKEDIN_CLIENT_ID", "")
+CLIENT_SECRET = os.getenv("LINKEDIN_CLIENT_SECRET", "")
+REDIRECT_URI = os.getenv("LINKEDIN_REDIRECT_URI", "http://localhost:8000/linkedin/callback/")
+SCOPE = "w_member_social profile email openid"
+API_BASE = "https://api.linkedin.com"
+AUTH_BASE = "https://www.linkedin.com/oauth/v2"
+
+
+def _log(msg):
+    print(f"[LinkedInAPI] {msg}")
+
+
+def get_oauth_url(state=""):
+    params = {
+        "response_type": "code",
+        "client_id": CLIENT_ID,
+        "redirect_uri": REDIRECT_URI,
+        "scope": SCOPE,
+    }
+    if state:
+        params["state"] = state
+    qs = "&".join(f"{k}={requests.utils.quote(str(v))}" for k, v in params.items())
+    return f"{AUTH_BASE}/authorization?{qs}"
+
+
+def exchange_code(code):
+    if not CLIENT_ID or not CLIENT_SECRET:
+        return None, "LinkedIn app not configured. Set LINKEDIN_CLIENT_ID and LINKEDIN_CLIENT_SECRET."
+
+    data = {
+        "grant_type": "authorization_code",
+        "code": code,
+        "client_id": CLIENT_ID,
+        "client_secret": CLIENT_SECRET,
+        "redirect_uri": REDIRECT_URI,
+    }
+    try:
+        resp = requests.post(f"{AUTH_BASE}/accessToken", data=data, timeout=30)
+        if resp.status_code != 200:
+            _log(f"Token exchange failed ({resp.status_code}): {resp.text[:200]}")
+            return None, f"Failed to get access token: {resp.text[:100]}"
+        body = resp.json()
+        token = body.get("access_token")
+        expires = body.get("expires_in", 86400)
+        if not token:
+            return None, "No access_token in response"
+        _log("Token exchange successful")
+        return {"access_token": token, "expires_at": time.time() + expires}, None
+    except requests.exceptions.RequestException as e:
+        _log(f"Token exchange error: {e}")
+        return None, str(e)
+
+
+def get_user_info(access_token):
+    headers = {"Authorization": f"Bearer {access_token}"}
+    try:
+        resp = requests.get(f"{API_BASE}/v2/userinfo", headers=headers, timeout=15)
+        if resp.status_code != 200:
+            _log(f"User info failed ({resp.status_code}): {resp.text[:200]}")
+            return None, "Failed to get user info"
+        body = resp.json()
+        sub = body.get("sub", "")
+        name = body.get("name", "")
+        picture = body.get("picture", "")
+        _log(f"User info: {name} ({sub})")
+        return {"urn": f"urn:li:person:{sub}", "name": name, "picture": picture, "sub": sub}, None
+    except requests.exceptions.RequestException as e:
+        _log(f"User info error: {e}")
+        return None, str(e)
+
+
+def create_post(access_token, author_urn, text, hashtags=None, visibility="PUBLIC"):
+    if not access_token or not author_urn:
+        return None, "Missing access_token or author_urn"
+
+    body = {"author": author_urn, "lifecycleState": "PUBLISHED", "visibility": visibility}
+
+    full_text = text
+    if hashtags:
+        tag_str = " ".join(f"#{h.lstrip('#')}" for h in hashtags[:5])
+        full_text = f"{text}\n\n{tag_str}"
+
+    body["specificContent"] = {
+        "com.linkedin.ugc.ShareContent": {
+            "shareCommentary": {"text": full_text},
+            "shareMediaCategory": "NONE",
+        }
+    }
+
+    headers = {
+        "Authorization": f"Bearer {access_token}",
+        "Content-Type": "application/json",
+        "X-Restli-Protocol-Version": "2.0.0",
+    }
+
+    try:
+        resp = requests.post(f"{API_BASE}/v2/ugcPosts", json=body, headers=headers, timeout=30)
+        if resp.status_code in (200, 201):
+            post_id = resp.headers.get("X-RestLi-Id", "")
+            post_url = f"https://www.linkedin.com/feed/update/{post_id}" if post_id else ""
+            _log(f"Post created: {post_id}")
+            return {"post_id": post_id, "post_url": post_url}, None
+
+        _log(f"Post failed ({resp.status_code}): {resp.text[:300]}")
+
+        if resp.status_code == 401:
+            return None, "Access token expired. Please reconnect LinkedIn."
+        if resp.status_code == 403:
+            return None, "Missing permissions. Re-authenticate with w_member_social scope."
+        if resp.status_code == 429:
+            return None, "Rate limited. Try again later."
+
+        detail = ""
+        try:
+            detail = resp.json().get("message", resp.text[:100])
+        except Exception:
+            detail = resp.text[:100]
+        return None, f"LinkedIn API error: {detail}"
+
+    except requests.exceptions.RequestException as e:
+        _log(f"Post request error: {e}")
+        return None, str(e)

services/utils.py

@@ -284,6 +284,16 @@ def cross_map_fields(data: dict) -> dict:
         if ideas:
             data["strategy_tips"] = ideas
 
+    # LinkedIn cross-maps
+    if "post_drafts" in data and "content_titles" not in data:
+        data["content_titles"] = [d.get("headline", str(d)) for d in data["post_drafts"] if isinstance(d, dict)]
+    if "post_drafts" in data and "related_phrases" not in data:
+        data["related_phrases"] = [d.get("body", str(d))[:100] for d in data["post_drafts"] if isinstance(d, dict)]
+    if "thought_leadership_angles" in data and "strategy_tips" not in data:
+        data["strategy_tips"] = data["thought_leadership_angles"]
+    if "engagement_prompts" in data and "related_phrases" not in data:
+        data["related_phrases"] = data["engagement_prompts"]
+
     return data