Create app.py

app.py

@@ -0,0 +1,140 @@
+import streamlit as st
+from deepface import DeepFace
+import easyocr
+from PIL import Image
+import io
+import pandas as pd
+import sqlite3
+import requests
+import random  # for simulate QTE
+
+conn = sqlite3.connect('kyc_logs.db')
+c = conn.cursor()
+c.execute('''CREATE TABLE IF NOT EXISTS verifications 
+             (id INTEGER PRIMARY KEY, name TEXT, phone TEXT, address TEXT, trs REAL, status TEXT, qte_details TEXT, timestamp DATETIME DEFAULT CURRENT_TIMESTAMP)''')
+conn.commit()
+
+reader = easyocr.Reader(['en'], gpu=False)
+
+st.set_page_config(page_title="Bright KYC AI", layout="wide")
+st.title("🔒 Bright KYC AI – Strict Enforcer with Quantum Trust Echo 🚀")
+st.write("Ghana-Focused | No Shortcuts | Founder: Gov")
+
+tab1, tab2 = st.tabs(["Customer Onboarding", "Admin Dashboard"])
+
+with tab1:
+    st.header("Strict Verification Flow")
+    full_name = st.text_input("Full Name")
+    phone = st.text_input("Phone Number (+233...)")
+    gps_address = st.text_input("GhanaPost Digital Address (e.g., GA-123-4567)")
+    
+    col1, col2 = st.columns(2)
+    with col1: id_file = st.file_uploader("Upload ID (Ghana Card/Passport/Voter’s ID)", type=['jpg', 'jpeg', 'png'])
+    with col2: selfie_file = st.file_uploader("Upload Live Selfie", type=['jpg', 'jpeg', 'png'])
+    
+    if st.button("Run Strict Verification") and all([full_name, phone, gps_address, id_file, selfie_file]):
+        with st.spinner("Enforcing + Quantum Trust Echo... 🔍"):
+            id_bytes = id_file.read()
+            selfie_bytes = selfie_file.read()
+            
+            id_img = Image.open(io.BytesIO(id_bytes))
+            selfie_img = Image.open(io.BytesIO(selfie_bytes))
+            
+            col1, col2 = st.columns(2)
+            with col1: st.image(id_img, caption="ID")
+            with col2: st.image(selfie_img, caption="Selfie")
+            
+            # Step 2: ID Verification (OCR) - Simple extract for name match
+            extracted = reader.readtext(id_bytes)
+            full_text = " ".join([text for _, text, _ in extracted]).lower()
+            if full_name.lower() not in full_text:
+                st.warning("Name no match ID text! Flag ⚠️")
+            
+            # Step 3: Address Confirmation
+            try:
+                resp = requests.get(f"https://ghanapostgps.sperixlabs.org/get-address/{gps_address}")
+                address_valid = resp.status_code == 200 and resp.json().get("status")
+                address_score = 20 if address_valid else 0
+                st.success("Address Valid ✅") if address_valid else st.warning("Invalid Address ⚠️")
+            except:
+                address_score = 10
+                st.info("Address check skipped")
+            
+            # Step 4: Biometric Capture
+            try:
+                live_result = DeepFace.extract_faces(img_path=selfie_bytes, anti_spoofing=True)
+                is_live = live_result[0]['is_real']
+                live_score = live_result[0]['antispoof_score']
+                if not is_live:
+                    st.error("SPOOF DETECTED → BLOCKED 🚫")
+                    status = "BLOCKED"
+                    trs = 0
+                else:
+                    verify = DeepFace.verify(img1_path=id_bytes, img2_path=selfie_bytes)
+                    confidence = (1 - verify["distance"]) * 100
+            except Exception as e:
+                confidence = 0
+                live_score = 0
+                status = "ERROR"
+                st.error(f"Biometric error: {e}")
+            
+            # Step 5: Quantum Trust Echo (QTE) Simulation - Your Brilliant Feature!
+            # Temporal Consistency: Check duplicate in DB (identity exist before?)
+            c.execute("SELECT COUNT(*) FROM verifications WHERE name=? OR phone=?", (full_name, phone))
+            duplicate_count = c.fetchone()[0]
+            temporal_score = 30 if duplicate_count == 0 else -20  # New good, duplicate bad
+            
+            # Digital Gravity: How many systems know am? (Simulate with phone check + random)
+            gravity_score = 25 if phone.startswith("+233") and len(phone) == 13 else -10
+            gravity_score += random.randint(-5, 5)  # Simulate other systems
+            
+            # Echo Stability: Consistency across devices/locations (Simulate with address + name)
+            stability_score = 20 if len(gps_address) > 5 and address_score > 0 else -15
+            
+            qte_details = f"Temporal: {temporal_score} | Gravity: {gravity_score} | Stability: {stability_score}"
+            
+            # Final TRS with QTE + Biometric
+            biometric_base = confidence * 0.5 if 'confidence' in locals() else 0
+            trs = biometric_base + address_score + (live_score * 100 * 0.2) + temporal_score + gravity_score + stability_score
+            
+            if trs >= 70:
+                status = "AUTO-APPROVED ✅"
+            elif trs >= 40:
+                status = "MANUAL REVIEW ⚠️"
+            else:
+                status = "BLOCKED 🚫"
+            
+            # Step 6: Risk Scoring (Simple, add more later)
+            risk_flag = duplicate_count > 0 or confidence < 50
+            if risk_flag:
+                status = "FLAGGED FOR REVIEW ⚠️" if "APPROVED" in status else status
+                trs -= 10
+            
+            st.write(f"**Trust Resonance Score (TRS): {trs:.2f}/100**")
+            st.write(f"QTE Breakdown: {qte_details}")
+            st.write(f"Final Decision: {status}")
+            
+            # Save to DB
+            c.execute("INSERT INTO verifications (name, phone, address, trs, status, qte_details) VALUES (?, ?, ?, ?, ?, ?)",
+                      (full_name, phone, gps_address, trs, status, qte_details))
+            conn.commit()
+
+with tab2:
+    st.header("Admin & Compliance Dashboard")
+    df = pd.read_sql_query("SELECT * FROM verifications ORDER BY timestamp DESC", conn)
+    st.dataframe(df, use_container_width=True)
+    
+    st.subheader("Manual Override")
+    selected_id = st.number_input("Enter Verification ID to Override", min_value=1, step=1)
+    new_status = st.selectbox("New Status", ["APPROVED ✅", "MANUAL REVIEW ⚠️", "BLOCKED 🚫"])
+    
+    if st.button("Apply Override"):
+        if selected_id:
+            c.execute("UPDATE verifications SET status=? WHERE id=?", (new_status, selected_id))
+            conn.commit()
+            st.success(f"ID {selected_id} updated to {new_status}")
+            st.experimental_rerun()  # Refresh table
+        else:
+            st.warning("Enter valid ID")
+    
+    st.write(f"Total Verifications: {len(df)} | Flagged/Blocked: {len(df[df['status'].str.contains('REVIEW|BLOCKED|ERROR')])}")