threads up

app.py

@@ -7,6 +7,7 @@ from ui import (
     blog,
     #general_blog,
     meta,
+    threads,
     twitter,
     price_matching,
     inventory,
@@ -17,6 +18,7 @@ from server import (
     blog as blog_srv,
     #general_blog as general_blog_srv,
     meta as meta_srv,
+    threads as threads_srv,
     twitter as twitter_srv,
     price_matching as price_matching_srv,
     inventory as inventory_srv,
@@ -29,6 +31,7 @@ ui = ui.page_fluid(
         blog.ui,
         #general_blog.ui,
         meta.ui,
+        threads.ui,
         twitter.ui,
         price_matching.ui,
         inventory.ui,
@@ -44,6 +47,7 @@ def server(input, output, session):
     blog_srv.server(input, output, session)
     #general_blog_srv.server(input, output, session)
     meta_srv.server(input, output, session)
+    threads_srv.server(input, output, session)
     twitter_srv.server(input, output, session)
     price_matching_srv.server(input, output, session)
     inventory_srv.server(input, output, session)

server/meta.py

@@ -19,7 +19,7 @@ def scrape_shopify_blog(url: str) -> str:
         soup = BeautifulSoup(resp.content, 'html.parser')
         section = soup.find(
             'div',
-            class_='article-template__content page-width page-width--narrow rte scroll-trigger animate--slide-in'
+            class_='w940 align-center size-content'
         )
         return section.get_text(strip=True, separator=' ') if section else ""
     except Exception as e:
@@ -95,12 +95,22 @@ def post_to_facebook(message: str) -> str:
         res.raise_for_status()
         data = res.json()
 
-        if data["status"] == "success":
-            return f"✅ Post successful! Facebook Post ID: {data['post_id']}"
-        else:
-            return f"❌ Proxy error: {data.get('error', 'Unknown error')}"
+        # Safely handle both proxy success and raw Facebook responses
+        if isinstance(data, dict):
+            if "status" in data and data["status"] == "success":
+                return f"✅ Post successful! Facebook Post ID: {data.get('post_id', 'unknown')}"
+            elif "id" in data or "post_id" in data:
+                post_id = data.get("post_id") or data.get("id")
+                return f"✅ Post successful! Facebook Post ID: {post_id}"
+            elif "error" in data:
+                return f"❌ Facebook error: {data['error']}"
+        
+        return f"⚠️ Unexpected response: {data}"
+
+    except requests.RequestException as e:
+        return f"❌ Network or proxy error: {e}"
     except Exception as e:
-        return f"❌ Failed to reach proxy: {e}"
+        return f"❌ Unexpected error: {e}"
 
 
 

server/threads.py

@@ -0,0 +1,167 @@
+from shiny import reactive, render, ui
+import os
+import requests
+from dotenv import load_dotenv
+from bs4 import BeautifulSoup
+from llm_connect import get_response
+
+# Load env
+load_dotenv()
+
+# ===== Threads config =====
+THREADS_TOKEN = os.getenv("THREADS_ACCESS_TOKEN")  # <-- set this in your env
+
+# Store latest generated post text
+generated_threads_post = reactive.Value("")  # keeping the same name so your UI doesn't change
+
+
+# ---- Helpers ----
+def scrape_shopify_blog(url: str) -> str:
+    try:
+        resp = requests.get(url, timeout=10)
+        resp.raise_for_status()
+        soup = BeautifulSoup(resp.content, 'html.parser')
+        # Adjust this selector to match your Shopify theme if needed
+        section = soup.find('div', class_='w940 align-center size-content')
+        return section.get_text(strip=True, separator=' ') if section else ""
+    except Exception as e:
+        return f"❌ Error scraping blog: {e}"
+
+
+def generate_threads_post(  # keeping the function name to avoid UI refactor
+    topic: str = "",
+    url: str = "",
+    min_len: int = 100,
+    max_len: int = 450
+) -> str:
+    """
+    Generates post text using your existing LLM helper.
+    (Text is suitable for Threads now; you can tweak tone if you want.)
+    """
+    if url:
+        scraped = scrape_shopify_blog(url)
+        if scraped.startswith("❌") or not scraped.strip():
+            return f"⚠️ Failed to extract blog content from URL: {url}"
+        prompt = (
+            "You are a social media manager for a hobby e-commerce company called 'Ultima Supply'.\n"
+            f"Write a detailed, engaging Threads post (min {min_len} chars, max {max_len} chars) summarizing the Shopify blog:\n\n"
+            f"{scraped}\n\n"
+            f"The post MUST include this exact URL: {url}\n"
+            "Use a casual, friendly tone with emojis.\n"
+            "VERY IMPORTANT: Include exactly 5 to 10 SEO-relevant hashtags grouped at the end (not inline).\n"
+            f"Keep everything under {max_len} characters total."
+        )
+    elif topic:
+        prompt = (
+            "You are a social media manager for a hobby e-commerce company called 'Ultima Supply'.\n"
+            f"Write a short, engaging Threads post (min {min_len} chars, max {max_len} chars) about: '{topic}'.\n"
+            "Use a casual, friendly tone with fun emojis.\n"
+            "VERY IMPORTANT: Include exactly 5 to 10 SEO-relevant hashtags grouped at the end (not inline).\n"
+            f"The entire post must be under {max_len} characters total."
+        )
+    else:
+        return "⚠️ Provide either a topic or a Shopify blog URL."
+
+    # Step 1: Generate
+    post = get_response(
+        input=prompt,
+        template=lambda x: x.strip(),
+        llm="gemini",
+        md=False,
+        temperature=0.9,
+        max_tokens=250
+    ).strip()
+
+    if len(post) <= max_len:
+        return post
+
+    # Step 2: Shorten if needed
+    shorten_prompt = (
+        f"Shorten this post to {max_len} characters or fewer. Keep the Shopify link ({url}) and all original hashtags:\n\n{post}"
+        if url else
+        f"Shorten this post to {max_len} characters or fewer, keeping the tone, emojis, and all original hashtags:\n\n{post}"
+    )
+
+    shortened = get_response(
+        input=shorten_prompt,
+        template=lambda x: x.strip(),
+        llm="gemini",
+        md=False,
+        temperature=0.7,
+        max_tokens=200
+    ).strip()
+
+    return shortened[:max_len]
+
+
+# ---- Threads poster (replaces the proxy) ----
+def post_to_threads(message: str) -> str:
+    """
+    One-shot TEXT post to Threads using your long-lived token.
+    Uses: POST https://graph.threads.net/me/threads with text params
+    """
+    if not THREADS_TOKEN:
+        return "❌ Missing THREADS_USER_ACCESS_TOKEN environment variable."
+
+    try:
+        r = requests.post(
+            "https://graph.threads.net/me/threads",
+            headers={"Authorization": f"Bearer {THREADS_TOKEN}"},
+            params={
+                "text": message,
+                "media_type": "TEXT",
+                "auto_publish_text": "true",  # one-call publish for text
+            },
+            timeout=30,
+        )
+        # Prefer JSON, fall back to raw text for debugging
+        data = {}
+        try:
+            data = r.json()
+        except Exception:
+            data = {"raw": r.text}
+
+        if r.ok and isinstance(data, dict) and data.get("id"):
+            return f"✅ Post successful! Threads Post ID: {data['id']}"
+        return f"❌ Threads error ({r.status_code}): {data}"
+
+    except requests.RequestException as e:
+        return f"❌ Network error posting to Threads: {e}"
+    except Exception as e:
+        return f"❌ Unexpected error: {e}"
+
+
+# ---- Shiny server wiring (IDs unchanged) ----
+def server(input, output, session):
+    post_status = reactive.Value("")
+
+    @output
+    @render.ui
+    @reactive.event(input.gen_btn_threads)
+    def threads_post_draft():
+        topic = input.threads_topic().strip()
+        url = input.threads_url().strip()
+
+        if not topic and not url:
+            return ui.HTML("<p><strong>⚠️ Enter a topic or a blog URL.</strong></p>")
+
+        post = generate_threads_post(topic=topic, url=url)
+        if post.startswith(("⚠️", "❌")):
+            return ui.HTML(f"<p><strong>{post}</strong></p>")
+
+        generated_threads_post.set(post)
+        return ui.HTML(f"<p><strong>Generated Threads Post:</strong><br>{post}</p>")
+
+    @output
+    @render.text
+    def threads_post_status():
+        return post_status()
+
+    @reactive.effect
+    @reactive.event(input.post_btn_threads)
+    def _():
+        post = generated_threads_post()
+        if not post:
+            post_status.set("⚠️ No post generated yet.")
+        else:
+            post_status.set(post_to_threads(post))

server/twitter.py

@@ -23,7 +23,7 @@ def scrape_shopify_blog(url: str) -> str:
         soup = BeautifulSoup(resp.content, 'html.parser')
         section = soup.find(
             'div',
-            class_='article-template__content page-width page-width--narrow rte scroll-trigger animate--slide-in'
+            class_='w940 align-center size-content'
         )
         return section.get_text(strip=True, separator=' ') if section else ""
     except Exception as e:

ui/threads.py

@@ -0,0 +1,27 @@
+from shiny import ui
+
+ui = ui.nav_panel(
+    "Threads Poster",
+
+    # Topic input
+    ui.input_text("threads_topic", "Enter Topic", placeholder="e.g. New Anime Drop This Friday"),
+
+    # Optional blog link
+    ui.input_text("threads_url", "Optional Blog Link", placeholder="https://yourshop.com/blogs/xyz"),
+
+    # Generate button
+    ui.div(
+        ui.input_action_button("gen_btn_threads", "Generate Threads Post", class_="btn-primary"),
+        class_="mt-3 mb-2"
+    ),
+
+    # Post output and button
+    ui.output_ui("threads_post_draft"),
+    ui.div(
+        ui.input_action_button("post_btn_threads", "Post to Threads", class_="btn-success"),
+        class_="my-3"
+    ),
+
+    # Status output
+    ui.output_text("threads_post_status")
+)