n8n streamlit

				
					# https://apify.com/apify/instagram-post-scraper/input-schema
# python -m streamlit run test.py

import os
import json
from datetime import datetime, timezone, timedelta
import streamlit as st
import requests

#os/json – read environment variables & build JSON.
#datetime/timezone/timedelta – handle current time, time zones, and “1 month earlier” default.
#streamlit – build the web UI.
#requests – send HTTP POST to n8n.


st.set_page_config(
    page_title="IG → n8n (Cost per Post)",
    page_icon="📮",
    layout="centered"
)

#Configures the Streamlit page: a title for the browser tab, an icon, and a centered layout.

st.title("Streamlit n8n Demo")
st.caption(
    "Minimal demo: enter an IG profile + promised posts + budget → "
    "compute cost/post → send to n8n webhook for scraping."
)

#Visible heading and short description shown at the top of the app.

def _get_default_webhook_url() -> str:
    if "WEBHOOK_URL" in st.secrets:
        return st.secrets["WEBHOOK_URL"]
    return os.getenv("WEBHOOK_URL", "")

#Looks for a WEBHOOK_URL in Streamlit secrets first (best for production).
#If missing, falls back to the operating system environment variable.

def _coerce_url(url: str) -> str:
    return (url or "").strip()

webhook_url = _get_default_webhook_url()

# Ensure session keys exist
#payload – the JSON that will be sent to n8n.
#calc – numbers used to display metrics (posts, budget, cost per post).

if "payload" not in st.session_state:
    st.session_state.payload = None
if "calc" not in st.session_state:
    st.session_state.calc = None

# --------------------------------------------------------------------
# Main form
# --------------------------------------------------------------------
with st.form("ig_form", clear_on_submit=False):
    ig_profile = st.text_input(
        "Instagram profile (username or full URL)",
        placeholder="creator_handle or https://www.instagram.com/creator_handle/",
        help="No scraping here—just collecting what you enter and sending it to n8n.",
    )


    #Splits the form into two columns
    col1, col2 = st.columns(2)
    with col1:
        promised_posts = st.number_input(
            "Promised posts (count)",
            min_value=1,
            step=1,
            value=3,
            help="How many posts/reels are promised in the collaboration.",
        )
    with col2:
        budget = st.number_input(
            "Total campaign budget ($)",
            min_value=0.01,
            step=50.0,
            value=1200.0,
            help="Used only to compute cost per post on the client side.",
        )

    #Set default time to 1 month earlier
    st.markdown("### Time frame")
    default_cutoff = datetime.now().date() - timedelta(days=30)  # ~1 month earlier
    newer_than = st.date_input(
        "Extract posts newer than",
        value=default_cutoff,
        help="Matches Apify's parameter. Posts strictly newer than this date will be considered.",
    )
    
    submitted = st.form_submit_button("Compute & Prepare Payload")

# --------------------------------------------------------------------
# Handle form submit: validate + compute + persist
# --------------------------------------------------------------------
if submitted:
    errors = []
    if not ig_profile.strip():
        errors.append("Provide an Instagram profile.")
    if promised_posts <= 0:
        errors.append("Promised posts must be at least 1.")
    if budget <= 0:
        errors.append("Budget must be greater than 0.")

    if errors:
        st.error("\n".join(errors))
        st.session_state.payload = None
        st.session_state.calc = None
    elif newer_than and newer_than > datetime.now().date():
        st.error("'Extract posts newer than' cannot be in the future.")
        st.session_state.payload = None
        st.session_state.calc = None
    else:
        # Use the input exactly as provided (username or full URL)
        ig_value = ig_profile.strip()

        cost_per_post = round(float(budget) / float(promised_posts), 2)

        payload = {
            "source": "streamlit-ig-basic",
            "submitted_at": datetime.now(timezone.utc).isoformat(),
            "inputs": {
                "ig_profile": ig_value,
                "promised_posts": int(promised_posts),
                "budget": float(budget),
                "cost_per_post": cost_per_post,
            },
            "scrape_filters": {
                "newer_than": newer_than.isoformat() if newer_than else None,
            },
        }
        st.session_state.payload = payload
        st.session_state.calc = {
            "promised_posts": promised_posts,
            "budget": budget,
            "cost_per_post": cost_per_post,
        }

# --------------------------------------------------------------------
# Always render the “Calculated / Send” section if we have a payload
# --------------------------------------------------------------------
if st.session_state.payload:
    st.subheader("Calculated")
    c1, c2, c3 = st.columns(3)
    c1.metric("Promised posts", st.session_state.calc["promised_posts"])
    c2.metric("Budget ($)", f"${st.session_state.calc['budget']:,.2f}")
    c3.metric("Cost per post ($)", f"${st.session_state.calc['cost_per_post']:,.2f}")

    st.subheader("Payload")
    st.code(json.dumps(st.session_state.payload, indent=2), language="json")

    colA, colB = st.columns([1, 1])
    send_clicked = colA.button("🚀 Send to n8n", type="primary")
    copy_clicked = colB.button("📋 Copy JSON")

    if copy_clicked:
        st.toast(
            "Copy the payload manually from the JSON block above "
            "(automatic copy not supported here)."
        )

    if send_clicked:
        if not webhook_url:
            st.error(
                "Webhook URL not found. Add `WEBHOOK_URL` to Streamlit secrets or set the `WEBHOOK_URL` environment variable."
            )
        else:
            try:
                st.info("Sending payload to n8n…")
                resp = requests.post(
                    _coerce_url(webhook_url),
                    json=st.session_state.payload,
                    timeout=15
                )
                st.write("**Response status:**", resp.status_code)
                try:
                    st.json(resp.json())
                except Exception:
                    st.code(resp.text[:2000])

                if 200 <= resp.status_code < 300:
                    st.success("Sent to n8n successfully ✨")
                else:
                    st.warning("Request sent but got a non-2xx response.")
            except requests.RequestException as e:
                st.error(f"Request failed: {e.__class__.__name__}: {e}")

# --------------------------------------------------------------------
# Footer
# --------------------------------------------------------------------
st.divider()
st.caption(
    "This app computes cost per post locally and forwards IG profile, "
    "promised posts, and date filters to n8n. "
    "Your n8n workflow should handle the Instagram scraping."
)