Update app.py

app.py

@@ -1,3 +1,145 @@
+# Final with gratitude email
+
+
+
+import streamlit as st
+import firebase_admin
+from firebase_admin import credentials, db
+import base64
+from io import BytesIO
+from PIL import Image
+import requests
+
+# Firebase
+if not firebase_admin._apps:
+    cred = credentials.Certificate("firebase_credentials.json")
+    firebase_admin.initialize_app(cred, {
+        'databaseURL': 'https://binsight-beda0-default-rtdb.asia-southeast1.firebasedatabase.app/'
+    })
+
+# Firebase Auth REST API
+FIREBASE_AUTH_URL = "https://identitytoolkit.googleapis.com/v1/accounts:signInWithPassword?key=AIzaSyCwYZcPI5pltxxHiMUxjmQUNIaObNXWydw"
+
+# Mailgun Settings
+MAILGUN_API_KEY = "9530f415a53e78317892af32cf3c4b93-79295dd0-b3f02e29"  # Replace with your Mailgun API key
+MAILGUN_DOMAIN = "sandboxb2e22240ec8a4b468825577fcb967a85.mailgun.org"  # Replace with your Mailgun domain
+Email_Domain = "Binsight.com"
+
+def send_gratitude_email(to_email, location):
+    try:
+        return requests.post(
+            f"https://api.mailgun.net/v3/{MAILGUN_DOMAIN}/messages",
+            auth=("api", MAILGUN_API_KEY),
+            data={
+                "from": f"Binsight <noreply@{Email_Domain}>",
+                "to": [to_email],
+                "subject": "🎉 Thank You for Your Contribution!",
+                "text": f"Thank you for reporting the dustbin at {location}. Your help is invaluable in keeping our surroundings clean. 🌱"
+            }
+        )
+    except Exception as e:
+        return None
+
+# Streamlit UI
+st.title("Binsight Admin Dashboard")
+
+if "authenticated" not in st.session_state:
+    st.session_state.authenticated = False
+if "user" not in st.session_state:
+    st.session_state.user = None
+
+def login():
+    st.subheader("Login")
+    email = st.text_input("Email")
+    password = st.text_input("Password", type="password")
+    if st.button("Login"):
+        payload = {"email": email, "password": password, "returnSecureToken": True}
+        response = requests.post(FIREBASE_AUTH_URL, json=payload)
+        if response.status_code == 200:
+            st.session_state.authenticated = True
+            st.session_state.user = email
+            st.rerun()
+        else:
+            st.error("Invalid credentials or user does not exist.")
+
+def logout():
+    st.session_state.authenticated = False
+    st.session_state.user = None
+    st.rerun()
+
+if st.session_state.authenticated:
+    st.sidebar.button("Logout", on_click=logout)
+    st.sidebar.header("Filters")
+    filter_status = st.sidebar.selectbox("Filter by Status", ["All", "Pending", "Allocated", "Completed"], index=0)
+    
+    dustbins_ref = db.reference("dustbins")
+    dustbins = dustbins_ref.get() or {}
+    
+    filtered_dustbins = {
+        key: value for key, value in dustbins.items()
+        if filter_status == "All" or value["status"] == filter_status
+    }
+
+    st.subheader(f"Showing {filter_status.lower()} dustbins ({len(filtered_dustbins)})")
+
+    for key, value in filtered_dustbins.items():
+        with st.expander(f"📍 {value['address']}"):
+            st.write(f"**Latitude**: {value['latitude']}")
+            st.write(f"**Longitude**: {value['longitude']}")
+            st.write(f"**Status**: {value['status']}")
+
+            if "image" in value:
+                image_data = base64.b64decode(value["image"])
+                st.image(Image.open(BytesIO(image_data)), caption="Dustbin Image", use_column_width=True)
+
+            if value["status"] == "Pending":
+                truck_email = st.text_input(f"Allocate Truck Email for {key}", key=f"truck_{key}")
+                if st.button(f"Allocate Truck", key=f"allocate_{key}"):
+                    if truck_email:
+                        dustbins_ref.child(key).update({
+                            "allocated_truck": truck_email,
+                            "status": "Allocated"
+                        })
+                        st.success("Truck allocated successfully!")
+                    else:
+                        st.error("Please enter a valid truck email.")
+
+            if value["status"] == "Allocated":
+                if st.button("Mark as Completed", key=f"complete_{key}"):
+                    dustbins_ref.child(key).update({"status": "Completed"})
+                    st.success("Status marked as Completed!")
+
+            if value["status"] == "Completed":
+                if st.button("Send Gratitude Email", key=f"gratitude_{key}"):
+                    email = value.get("email")
+                    location = value.get("address", "Unknown Location")
+                    if email:
+                        response = send_gratitude_email(email, location)
+                        if response and response.status_code == 200:
+                            st.success("✅ Gratitude email sent successfully!")
+                        else:
+                            st.error("❌ Failed to send email.")
+                    else:
+                        st.warning("⚠️ Email not available.")
+else:
+    login()
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+# Best version without back button
+
 # import streamlit as st
 # import firebase_admin
 # from firebase_admin import credentials, db
@@ -85,10 +227,6 @@
 #                         st.success("Truck allocated successfully!")
 #                     else:
 #                         st.error("Please enter a valid truck email.")
-
-# # Back button to redirect to dashboard
-# st.markdown("<br>", unsafe_allow_html=True)
-# st.markdown("<a href='https://binsight.onrender.com/dashboard.html' target='_self' style='text-decoration:none;'><button style='padding: 10px 20px; font-size: 16px;'>⬅ Back to Dashboard</button></a>", unsafe_allow_html=True)
 # else:
 #     login()
 
@@ -104,97 +242,114 @@
 
 
 
-# Best version without back button
 
-import streamlit as st
-import firebase_admin
-from firebase_admin import credentials, db
-import base64
-from io import BytesIO
-from PIL import Image
-import requests
 
-# Initialize Firebase Realtime Database
-if not firebase_admin._apps:
-    cred = credentials.Certificate("firebase_credentials.json")  
-    firebase_admin.initialize_app(cred, {
-        'databaseURL': 'https://binsight-beda0-default-rtdb.asia-southeast1.firebasedatabase.app/'
-    })
 
-# Firebase Authentication REST API
-FIREBASE_AUTH_URL = "https://identitytoolkit.googleapis.com/v1/accounts:signInWithPassword?key=AIzaSyCwYZcPI5pltxxHiMUxjmQUNIaObNXWydw"
 
-# Streamlit UI
-st.title("Binsight Admin Dashboard")
 
-# Session state for authentication
-if "authenticated" not in st.session_state:
-    st.session_state.authenticated = False
-if "user" not in st.session_state:
-    st.session_state.user = None
 
-# Authentication UI
-def login():
-    st.subheader("Login")
-    email = st.text_input("Email")
-    password = st.text_input("Password", type="password")
-    if st.button("Login"):
-        payload = {"email": email, "password": password, "returnSecureToken": True}
-        response = requests.post(FIREBASE_AUTH_URL, json=payload)
-        if response.status_code == 200:
-            st.session_state.authenticated = True
-            st.session_state.user = email
-            st.rerun()
-        else:
-            st.error("Invalid credentials or user does not exist.")
 
-# Logout functionality
-def logout():
-    st.session_state.authenticated = False
-    st.session_state.user = None
-    st.rerun()
 
-# Main Dashboard
-if st.session_state.authenticated:
-    st.sidebar.button("Logout", on_click=logout)
-    st.sidebar.header("Filters")
-    filter_status = st.sidebar.selectbox("Filter by Status", ["All", "Pending", "Allocated", "Completed"], index=0)
+
+
+# import streamlit as st
+# import firebase_admin
+# from firebase_admin import credentials, db
+# import base64
+# from io import BytesIO
+# from PIL import Image
+# import requests
+
+# # Initialize Firebase Realtime Database
+# if not firebase_admin._apps:
+#     cred = credentials.Certificate("firebase_credentials.json")  
+#     firebase_admin.initialize_app(cred, {
+#         'databaseURL': 'https://binsight-beda0-default-rtdb.asia-southeast1.firebasedatabase.app/'
+#     })
+
+# # Firebase Authentication REST API
+# FIREBASE_AUTH_URL = "https://identitytoolkit.googleapis.com/v1/accounts:signInWithPassword?key=AIzaSyCwYZcPI5pltxxHiMUxjmQUNIaObNXWydw"
+
+# # Streamlit UI
+# st.title("Binsight Admin Dashboard")
+
+# # Session state for authentication
+# if "authenticated" not in st.session_state:
+#     st.session_state.authenticated = False
+# if "user" not in st.session_state:
+#     st.session_state.user = None
+
+# # Authentication UI
+# def login():
+#     st.subheader("Login")
+#     email = st.text_input("Email")
+#     password = st.text_input("Password", type="password")
+#     if st.button("Login"):
+#         payload = {"email": email, "password": password, "returnSecureToken": True}
+#         response = requests.post(FIREBASE_AUTH_URL, json=payload)
+#         if response.status_code == 200:
+#             st.session_state.authenticated = True
+#             st.session_state.user = email
+#             st.rerun()
+#         else:
+#             st.error("Invalid credentials or user does not exist.")
+
+# # Logout functionality
+# def logout():
+#     st.session_state.authenticated = False
+#     st.session_state.user = None
+#     st.rerun()
+
+# # Main Dashboard
+# if st.session_state.authenticated:
+#     st.sidebar.button("Logout", on_click=logout)
+#     st.sidebar.header("Filters")
+#     filter_status = st.sidebar.selectbox("Filter by Status", ["All", "Pending", "Allocated", "Completed"], index=0)
     
-    dustbins_ref = db.reference("dustbins")
-    dustbins = dustbins_ref.get() or {}
+#     dustbins_ref = db.reference("dustbins")
+#     dustbins = dustbins_ref.get() or {}
     
-    filtered_dustbins = {
-        key: value for key, value in dustbins.items()
-        if filter_status == "All" or value["status"] == filter_status
-    }
+#     filtered_dustbins = {
+#         key: value for key, value in dustbins.items()
+#         if filter_status == "All" or value["status"] == filter_status
+#     }
     
-    st.subheader(f"Showing {filter_status.lower()} dustbins ({len(filtered_dustbins)})")
+#     st.subheader(f"Showing {filter_status.lower()} dustbins ({len(filtered_dustbins)})")
     
-    for key, value in filtered_dustbins.items():
-        with st.expander(f"📍 {value['address']}"):
-            st.write(f"**Latitude**: {value['latitude']}")
-            st.write(f"**Longitude**: {value['longitude']}")
-            st.write(f"**Status**: {value['status']}")
-            # st.write(f"**User**: {value['user_email']}")
+#     for key, value in filtered_dustbins.items():
+#         with st.expander(f"📍 {value['address']}"):
+#             st.write(f"**Latitude**: {value['latitude']}")
+#             st.write(f"**Longitude**: {value['longitude']}")
+#             st.write(f"**Status**: {value['status']}")
+#             # st.write(f"**User**: {value['user_email']}")
+
+#             # Display Image
+#             if "image" in value:
+#                 image_data = base64.b64decode(value["image"])
+#                 st.image(Image.open(BytesIO(image_data)), caption="Dustbin Image", use_column_width=True)
+
+#             if value["status"] == "Pending":
+#                 truck_email = st.text_input(f"Allocate Truck Email for {key}", key=f"truck_{key}")
+#                 if st.button(f"Allocate Truck", key=f"allocate_{key}"):
+#                     if truck_email:
+#                         dustbins_ref.child(key).update({
+#                             "allocated_truck": truck_email,
+#                             "status": "Allocated"
+#                         })
+#                         st.success("Truck allocated successfully!")
+#                     else:
+#                         st.error("Please enter a valid truck email.")
+
+# # Back button to redirect to dashboard
+# st.markdown("<br>", unsafe_allow_html=True)
+# st.markdown("<a href='https://binsight.onrender.com/dashboard.html' target='_self' style='text-decoration:none;'><button style='padding: 10px 20px; font-size: 16px;'>⬅ Back to Dashboard</button></a>", unsafe_allow_html=True)
+# else:
+#     login()
+
+
+
 
-            # Display Image
-            if "image" in value:
-                image_data = base64.b64decode(value["image"])
-                st.image(Image.open(BytesIO(image_data)), caption="Dustbin Image", use_column_width=True)
 
-            if value["status"] == "Pending":
-                truck_email = st.text_input(f"Allocate Truck Email for {key}", key=f"truck_{key}")
-                if st.button(f"Allocate Truck", key=f"allocate_{key}"):
-                    if truck_email:
-                        dustbins_ref.child(key).update({
-                            "allocated_truck": truck_email,
-                            "status": "Allocated"
-                        })
-                        st.success("Truck allocated successfully!")
-                    else:
-                        st.error("Please enter a valid truck email.")
-else:
-    login()