Initial commit

.gitignore

@@ -1 +1,3 @@
-.pt
+.pt
+.env
+

.gradio/certificate.pem

@@ -0,0 +1,31 @@
+-----BEGIN CERTIFICATE-----
+MIIFazCCA1OgAwIBAgIRAIIQz7DSQONZRGPgu2OCiwAwDQYJKoZIhvcNAQELBQAw
+TzELMAkGA1UEBhMCVVMxKTAnBgNVBAoTIEludGVybmV0IFNlY3VyaXR5IFJlc2Vh
+cmNoIEdyb3VwMRUwEwYDVQQDEwxJU1JHIFJvb3QgWDEwHhcNMTUwNjA0MTEwNDM4
+WhcNMzUwNjA0MTEwNDM4WjBPMQswCQYDVQQGEwJVUzEpMCcGA1UEChMgSW50ZXJu
+ZXQgU2VjdXJpdHkgUmVzZWFyY2ggR3JvdXAxFTATBgNVBAMTDElTUkcgUm9vdCBY
+MTCCAiIwDQYJKoZIhvcNAQEBBQADggIPADCCAgoCggIBAK3oJHP0FDfzm54rVygc
+h77ct984kIxuPOZXoHj3dcKi/vVqbvYATyjb3miGbESTtrFj/RQSa78f0uoxmyF+
+0TM8ukj13Xnfs7j/EvEhmkvBioZxaUpmZmyPfjxwv60pIgbz5MDmgK7iS4+3mX6U
+A5/TR5d8mUgjU+g4rk8Kb4Mu0UlXjIB0ttov0DiNewNwIRt18jA8+o+u3dpjq+sW
+T8KOEUt+zwvo/7V3LvSye0rgTBIlDHCNAymg4VMk7BPZ7hm/ELNKjD+Jo2FR3qyH
+B5T0Y3HsLuJvW5iB4YlcNHlsdu87kGJ55tukmi8mxdAQ4Q7e2RCOFvu396j3x+UC
+B5iPNgiV5+I3lg02dZ77DnKxHZu8A/lJBdiB3QW0KtZB6awBdpUKD9jf1b0SHzUv
+KBds0pjBqAlkd25HN7rOrFleaJ1/ctaJxQZBKT5ZPt0m9STJEadao0xAH0ahmbWn
+OlFuhjuefXKnEgV4We0+UXgVCwOPjdAvBbI+e0ocS3MFEvzG6uBQE3xDk3SzynTn
+jh8BCNAw1FtxNrQHusEwMFxIt4I7mKZ9YIqioymCzLq9gwQbooMDQaHWBfEbwrbw
+qHyGO0aoSCqI3Haadr8faqU9GY/rOPNk3sgrDQoo//fb4hVC1CLQJ13hef4Y53CI
+rU7m2Ys6xt0nUW7/vGT1M0NPAgMBAAGjQjBAMA4GA1UdDwEB/wQEAwIBBjAPBgNV
+HRMBAf8EBTADAQH/MB0GA1UdDgQWBBR5tFnme7bl5AFzgAiIyBpY9umbbjANBgkq
+hkiG9w0BAQsFAAOCAgEAVR9YqbyyqFDQDLHYGmkgJykIrGF1XIpu+ILlaS/V9lZL
+ubhzEFnTIZd+50xx+7LSYK05qAvqFyFWhfFQDlnrzuBZ6brJFe+GnY+EgPbk6ZGQ
+3BebYhtF8GaV0nxvwuo77x/Py9auJ/GpsMiu/X1+mvoiBOv/2X/qkSsisRcOj/KK
+NFtY2PwByVS5uCbMiogziUwthDyC3+6WVwW6LLv3xLfHTjuCvjHIInNzktHCgKQ5
+ORAzI4JMPJ+GslWYHb4phowim57iaztXOoJwTdwJx4nLCgdNbOhdjsnvzqvHu7Ur
+TkXWStAmzOVyyghqpZXjFaH3pO3JLF+l+/+sKAIuvtd7u+Nxe5AW0wdeRlN8NwdC
+jNPElpzVmbUq4JUagEiuTDkHzsxHpFKVK7q4+63SM1N95R1NbdWhscdCb+ZAJzVc
+oyi3B43njTOQ5yOf+1CceWxG1bQVs5ZufpsMljq4Ui0/1lvh+wjChP4kqKOJ2qxq
+4RgqsahDYVvTH9w7jXbyLeiNdd8XM2w9U/t7y0Ff/9yi0GE44Za4rF2LN9d11TPA
+mRGunUHBcnWEvgJBQl9nJEiU0Zsnvgc/ubhPgXRR4Xq37Z0j4r7g1SgEEzwxA57d
+emyPxgcYxn/eR44/KJ4EBs+lVDR3veyJm+kXQ99b21/+jh5Xos1AnX5iItreGCc=
+-----END CERTIFICATE-----

app.py

@@ -0,0 +1,177 @@
+import gradio as gr
+from huggingface_hub import list_bucket_tree, download_bucket_files
+from datetime import datetime
+import pandas as pd
+import json
+import os
+from dotenv import load_dotenv
+
+# ---------- LOAD ENV ----------
+load_dotenv()
+BUCKET_NAME = os.getenv("BUCKET_NAME")
+
+PAGE_SIZE = 5
+
+
+# ---------- LOAD DATA FROM BUCKET ----------
+def extract_customer_data():
+    try:
+        tree = list_bucket_tree(BUCKET_NAME, recursive=True)
+
+        json_files = [
+            item.path for item in tree
+            if item.path.endswith("cameras.json")
+        ]
+
+        if not json_files:
+            return pd.DataFrame(columns=["customer_id", "customer_name", "customer_email"])
+
+        files_map = [(f, f"C:/tmp/{f.replace('/', '_')}") for f in json_files]
+
+        download_bucket_files(BUCKET_NAME, files=files_map)
+
+        rows = []
+
+        for remote_path, local_path in files_map:
+            parts = remote_path.split("/")
+            customer_id = parts[1] if len(parts) > 1 else "unknown"
+
+            try:
+                with open(local_path, "r", encoding="utf-8") as f:
+                    data = json.load(f)
+
+                for item in data:
+                    rows.append({
+                        "customer_id": customer_id,
+                        "customer_name": item.get("customer_name"),
+                        "customer_email": item.get("customer_email")
+                    })
+
+            except Exception as e:
+                print(f"File error {remote_path}: {e}")
+
+        df = pd.DataFrame(rows)
+
+        # ---------- REMOVE DUPLICATES ----------
+        if not df.empty:
+            df = df.drop_duplicates(
+                subset=["customer_id", "customer_name", "customer_email"]
+            )
+
+        return df
+
+    except Exception as e:
+        print("ERROR:", e)
+        return pd.DataFrame(columns=["customer_id", "customer_name", "customer_email"])
+
+
+# ---------- FILTER ----------
+def apply_search(df, email_query):
+    if df is None or not isinstance(df, pd.DataFrame):
+        return pd.DataFrame(columns=["customer_id", "customer_name", "customer_email"])
+
+    if email_query:
+        df = df[df["customer_email"].astype(str).str.contains(email_query, case=False, na=False)]
+
+    return df
+
+
+# ---------- PAGINATION ----------
+def build_view(df, page, email_query):
+    filtered = apply_search(df, email_query)
+
+    total_pages = max(1, (len(filtered) - 1) // PAGE_SIZE + 1)
+    page = max(0, min(page, total_pages - 1))
+
+    start = page * PAGE_SIZE
+    end = start + PAGE_SIZE
+
+    paged = filtered.iloc[start:end]
+
+    status = f"Page {page+1} / {total_pages} | Total Results: {len(filtered)}"
+
+    return paged, page, status
+
+
+# ---------- ACTIONS ----------
+def search(df, email_query):
+    page = 0
+    table, page, status = build_view(df, page, email_query)
+    return table, page, status, df
+
+
+def next_page(df, page, email_query):
+    page = page + 1
+    table, page, status = build_view(df, page, email_query)
+    return table, page, status, df
+
+
+def prev_page(df, page, email_query):
+    page = page - 1
+    table, page, status = build_view(df, page, email_query)
+    return table, page, status, df
+
+
+def refresh_data(email_query):
+    df = extract_customer_data()
+    page = 0
+    table, page, status = build_view(df, page, email_query)
+    return table, page, status, df
+
+
+# ---------- INITIAL DATA ----------
+df_global = extract_customer_data()
+
+
+# ---------- UI ----------
+with gr.Blocks() as app:
+    gr.Markdown("# 🛰 Buck Tracker Customer Dashboard")
+
+    state_df = gr.State(df_global)
+    state_page = gr.State(0)
+
+    search_box = gr.Textbox(
+        label="🔍 Search Customer Email",
+        placeholder="Enter email to search..."
+    )
+
+    table = gr.Dataframe(
+        value=build_view(df_global, 0, "")[0],
+        interactive=False,
+        label="Customer Data"
+    )
+
+    status = gr.Textbox(interactive=False)
+
+    with gr.Row():
+        refresh_btn = gr.Button("🔄 Refresh Bucket Data", variant="primary")
+        prev_btn = gr.Button("⬅️ Previous")
+        next_btn = gr.Button("Next ➡️")
+
+    # ---------- EVENTS ----------
+
+    search_box.change(
+        fn=search,
+        inputs=[state_df, search_box],
+        outputs=[table, state_page, status, state_df]
+    )
+
+    refresh_btn.click(
+        fn=refresh_data,
+        inputs=[search_box],
+        outputs=[table, state_page, status, state_df]
+    )
+
+    next_btn.click(
+        fn=next_page,
+        inputs=[state_df, state_page, search_box],
+        outputs=[table, state_page, status, state_df]
+    )
+
+    prev_btn.click(
+        fn=prev_page,
+        inputs=[state_df, state_page, search_box],
+        outputs=[table, state_page, status, state_df]
+    )
+
+app.launch()

requirements.txt

@@ -0,0 +1 @@
+gradio