Spaces:
Running
Running
| # -*- coding: utf-8 -*- | |
| import gradio as gr | |
| import json | |
| import os | |
| from Data_Fetching_and_Rendering import fetch_and_render_dashboard | |
| from analytics_fetch_and_rendering import fetch_and_render_analytics | |
| from mentions_dashboard import generate_mentions_dashboard | |
| from gradio_utils import get_url_user_token | |
| from Bubble_API_Calls import fetch_linkedin_token_from_bubble | |
| def check_token_status(token_state): | |
| return "✅ Token available" if token_state and token_state.get("token") else "❌ Token not available" | |
| def process_and_store_bubble_token(url_user_token, org_urn, token_state): | |
| new_state = token_state.copy() if token_state else {"token": None, "client_id": None, "org_urn": None} | |
| new_state.update({"token": None, "org_urn": org_urn}) | |
| client_id = os.environ.get("Linkedin_client_id") | |
| if not client_id: | |
| print("❌ CRITICAL ERROR: 'Linkedin_client_id' environment variable not set.") | |
| new_state["client_id"] = "ENV VAR MISSING" | |
| return check_token_status(new_state), new_state | |
| new_state["client_id"] = client_id | |
| if not url_user_token or "not found" in url_user_token or "Could not access" in url_user_token: | |
| return check_token_status(new_state), new_state | |
| print(f"Attempting to fetch token from Bubble with user token: {url_user_token}") | |
| parsed = fetch_linkedin_token_from_bubble(url_user_token) | |
| if isinstance(parsed, dict) and "access_token" in parsed: | |
| new_state["token"] = parsed | |
| print("✅ Token successfully fetched from Bubble.") | |
| else: | |
| print("❌ Failed to fetch a valid token from Bubble.") | |
| return check_token_status(new_state), new_state | |
| def guarded_fetch_dashboard(token_state): | |
| if not token_state or not token_state.get("token"): | |
| return "<p style='color:red; text-align:center;'>❌ Access denied. No token available.</p>" | |
| return fetch_and_render_dashboard(token_state.get("client_id"), token_state.get("token")) | |
| def guarded_fetch_analytics(token_state): | |
| if not token_state or not token_state.get("token"): | |
| return ("<p style='color:red; text-align:center;'>❌ Access denied. No token available.</p>", | |
| None, None, None, None, None, None, None) | |
| return fetch_and_render_analytics(token_state.get("client_id"), token_state.get("token")) | |
| def run_mentions_and_load(token_state): | |
| if not token_state or not token_state.get("token"): | |
| return ("<p style='color:red; text-align:center;'>❌ Access denied. No token available.</p>", None) | |
| return generate_mentions_dashboard(token_state.get("client_id"), token_state.get("token")) | |
| with gr.Blocks(theme=gr.themes.Soft(primary_hue="blue", secondary_hue="sky"), | |
| title="LinkedIn Post Viewer & Analytics") as app: | |
| token_state = gr.State(value={"token": None, "client_id": None, "org_urn": None}) | |
| gr.Markdown("# 🚀 LinkedIn Organization Post Viewer & Analytics") | |
| gr.Markdown("Token is supplied via URL parameter for Bubble.io lookup. Then explore dashboard and analytics.") | |
| url_user_token_display = gr.Textbox(label="User Token (from URL - Hidden)", interactive=False, visible=False) | |
| status_box = gr.Textbox(label="Overall Token Status", interactive=False) | |
| org_urn = gr.Textbox(visible=False) # Needed for input, was missing from initial script | |
| app.load(fn=get_url_user_token, inputs=None, outputs=[url_user_token_display, org_urn]) | |
| url_user_token_display.change( | |
| fn=process_and_store_bubble_token, | |
| inputs=[url_user_token_display, org_urn, token_state], | |
| outputs=[status_box, token_state] | |
| ) | |
| app.load(fn=check_token_status, inputs=[token_state], outputs=status_box) | |
| gr.Timer(5.0).tick(fn=check_token_status, inputs=[token_state], outputs=status_box) | |
| with gr.Tabs(): | |
| with gr.TabItem("1️⃣ Dashboard"): | |
| gr.Markdown("View your organization's recent posts and their engagement statistics.") | |
| fetch_dashboard_btn = gr.Button("📊 Fetch Posts & Stats", variant="primary") | |
| dashboard_html = gr.HTML("<p style='text-align: center; color: #555;'>Waiting for token...</p>") | |
| fetch_dashboard_btn.click(fn=guarded_fetch_dashboard, inputs=[token_state], outputs=[dashboard_html]) | |
| with gr.TabItem("2️⃣ Analytics"): | |
| gr.Markdown("View follower count and monthly gains for your organization.") | |
| fetch_analytics_btn = gr.Button("📈 Fetch Follower Analytics", variant="primary") | |
| follower_count = gr.Markdown("<p style='text-align: center; color: #555;'>Waiting for token...</p>") | |
| with gr.Row(): | |
| follower_plot, growth_plot = gr.Plot(), gr.Plot() | |
| with gr.Row(): | |
| eng_rate_plot = gr.Plot() | |
| with gr.Row(): | |
| interaction_plot = gr.Plot() | |
| with gr.Row(): | |
| eb_plot = gr.Plot() | |
| with gr.Row(): | |
| mentions_vol_plot, mentions_sentiment_plot = gr.Plot(), gr.Plot() | |
| fetch_analytics_btn.click( | |
| fn=guarded_fetch_analytics, | |
| inputs=[token_state], | |
| outputs=[follower_count, follower_plot, growth_plot, eng_rate_plot, | |
| interaction_plot, eb_plot, mentions_vol_plot, mentions_sentiment_plot] | |
| ) | |
| with gr.TabItem("3️⃣ Mentions"): | |
| gr.Markdown("Analyze sentiment of recent posts that mention your organization.") | |
| fetch_mentions_btn = gr.Button("🧠 Fetch Mentions & Sentiment", variant="primary") | |
| mentions_html = gr.HTML("<p style='text-align: center; color: #555;'>Waiting for token...</p>") | |
| mentions_plot = gr.Plot() | |
| fetch_mentions_btn.click( | |
| fn=run_mentions_and_load, | |
| inputs=[token_state], | |
| outputs=[mentions_html, mentions_plot] | |
| ) | |
| if __name__ == "__main__": | |
| if not os.environ.get("Linkedin_client_id"): | |
| print("WARNING: The 'Linkedin_client_id' environment variable is not set. The application may not function correctly.") | |
| app.launch(server_name="0.0.0.0", server_port=7860, share=True) | |