From f5c91359cf7dd1da94af9b5811d973ff2ba31ec6 Mon Sep 17 00:00:00 2001
From: Jarvis <jarvis@moltbot.ai>
Date: Fri, 30 Jan 2026 11:00:44 +0000
Subject: [PATCH] Initial MVP Commit: Ingest, Enrich, Dashboard

---
 Dockerfile                     |   9 ++++
 __pycache__/db.cpython-311.pyc | Bin 0 -> 4050 bytes
 app.py                         |  55 ++++++++++++++++++++++++
 data/leads.db                  | Bin 0 -> 16384 bytes
 db.py                          |  70 ++++++++++++++++++++++++++++++
 enrich.py                      |  43 +++++++++++++++++++
 ingest.py                      |  75 +++++++++++++++++++++++++++++++++
 7 files changed, 252 insertions(+)
 create mode 100644 Dockerfile
 create mode 100644 __pycache__/db.cpython-311.pyc
 create mode 100644 app.py
 create mode 100644 data/leads.db
 create mode 100644 db.py
 create mode 100644 enrich.py
 create mode 100644 ingest.py

diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..540ffee
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,9 @@
+FROM python:3.9-slim
+
+WORKDIR /app
+
+COPY . .
+
+RUN pip install streamlit pandas
+
+CMD ["streamlit", "run", "app.py", "--server.port=8501", "--server.address=0.0.0.0"]
diff --git a/__pycache__/db.cpython-311.pyc b/__pycache__/db.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..8ed2237fb1fc2092c777e1d245cc3709b1ba9cc6
GIT binary patch
literal 4050
zcmbVP-ESMm5#Rfu?ns`b=)-Ojz{y!3wrMa{iXsRQD@thd+%Og?g*>&9ih`i;PWHLv
zow9cdBZUTNLx3Yei4&lJ^HM-hZUaB`wT}goKY#>?f;hl{f%c_u43q*vo;te}k33p5
z1TT5R-PxJh+2#Ib=KeZ796`|j^;O0EkATp>$)MBNqt4;`(0Pb-q%%dd*8XMI7#Oof
zw#2Tn4AQwZPUm;f8n1_dhV&tzL%OI7JItD(GdUCs|CgA{#28Q13$EdsC1d-QqEXP_
zFsz%VWy}G$Fh>~9CH;m*ggcFc4tWkeAP<qtbS4nG?e|^2%Y6jg$NtP6R6z$s|C#m(
zIFEhq9j3w@^jPsHVB<lH46zvM&Ubr3i&So?JKOE`%jpP?h|Ltf2d^XYQM;N|5~?Dr
zi7ShWoVq4wmQ-2!IF(a#GCe2xf-g!mOkGZ8ROPoyR$k7g(uwS<d|g?U6D#UcDg(CC
zN=A(bG#q;qYepUvRpnz<Udg0BT2X=`*w75~Q$x=eTv<(}m7JPLF9$_5yR=cTw(?e?
zWKcu>)0SJ%+(FYusbCh5QQNp>TgREhg>wFet#2KpVp!PJZj}tn&6CS?jD+JB+)am0
z$Vuf|Vr5a4&s#?Me9&cVI2*R*7<nBR)?wdpI6(o2tkHWS{;|er?>oU0oKK3TYy8F&
zG~2Qa&Gm%jmHcu-{lFX2HnC%4PcS|+v`yClhFvO|t{2jZwqwLtk0&}Fqd5eFvi!@`
z+%3Cg%vrW>%xT3!S*Jkpk#pnH#+E0TmI)ibfnNe0z%p`HfmG3x==lD7e|fteoo+;@
ztI4J)J&5i_cZc_ftBEEbx}Un2YN63l@kcZo3jah141vff6uy7`-u1ibopd$b<i-0R
z-uv+G;?81~eh$Gn(tMD?K!S(Dv;tng089z|P6AUlj4JFPpbi42&ITdu4io>|?KU|r
z+JdkgXp0Nl8Yst~P%d;rxuFxv2|+nsTo)g~fAY8!(GdhD=0NQ1y7xDD0t|w)W)8x=
z5}kg(q#n+pY2<dM;rBMpErc<H@XHKZJ-Mw&4wcbo+$t(F(<j#IXvCtK?Z5emB%v{t
z$thWtgvX^$==5V>T<(c+ak)2|kx@5z#bp|+;xY|Qpmr3A;&MBzw4qOyBkgyI#T6wd
zUwAJrAM@?XdaS9F7(rtw4HhI?dLg=&7oux<VrMOngJ`8*i$(De94jUl7nA=HlfMX)
z^Y*x#hKmV~K-MnfD48J8^hQ#aYuv=9yQN@k;~3|KNgAQC5)(M!5g-mx1^@9V(TSQ6
z2C<tbg7`JyoFO8w0PLS1SX%5v=u}e-KM3zZIN>IwmWYN=KS=MTzn!T|uQ#OEpGcGY
zi@TZqOj9~V`LVh*(~xEc4A0l4sfIMwne7{1tV^>EX|^eiwZ_6Dksk#q9Q_FaX;Jbj
z3J-UJ-WS8o(FyPdIFY@`uCy<GK|eqLPe9T{BYL)ln9!*%X^u`lg^(GLZ3!UqGql!F
zpB>;iGjK$Izw*}A%jo;dqsb}mhX|9LML(QnNPmhW{n^vW%bW&sej}$&p2L^mY+oRF
z27yN`(N;luzoHowrh-7GRS>yc&$MHzAm+dioxS3H7Fk&NM8QU9cObMUQBWT$BQCT3
zMow8&uB!4y`C4`<eT3qrY!a%SE33T_hQyw`8c0l}Qk#J1Fb?D)x(U_WAII)6y>(=z
zufqF=-5<}P?+}!$yl!eP<Ye~Jn;wVl@=;Ev`1mC<Uo;(;pm$;W3;>S;#kn+Jw6#Lf
zS%6MwdLGtx2!g7p7CqPgemnhT^6QD+)PBlm;V}@2h5O*`aap_UMPc>)Iz$H>Z}k9P
zTsK_pR-ss=FpqIvEPFihH;Cx4?<KwnOT9(hGO1gAg~F3xz4qtNtH}mGd0fd*8+o_R
zFEsdt8o$ttN)O)IduMlke;(?K-a?^CcX}`h+p9;<HDJV_qdV068wyL4+eYs`<cJr!
z`&@-P=(Pvt+AVmG?(h{Bzgpo3mJUn>Zt6PMpDL}F2kNjD1~k}y4e;k=ZwK4~+50ms
z=r_Dxk+%cD!2HT`lDrYLtN)y$9%UZ+U6Nz^s#f61zyCnVD&)lg2HO{&qaBdM#Q9jr
z6KHyX^fc5?aNbC8iS9*nhz2B$PTCmX+#oM`6b<>dGM)pG1$dmhK%SpHngRr1F7y#|
zltF6a%eCBU?GI+{Pq>zK>Z02a-5UKqZReQU`20UU{b#whuv8b98{%?JTqYNBaQWKC
z8Iy^L6lxxS+p#U0Hrx4>6wx%{QIt^U@mazn_-tceoG;n>X3<!{zXl#$UF2*5X>kn0
zG|@<vewrv+rJp7`Qwx5dMrNx*i=Sl1TF58y(+uq0CvOVO`4;lYxJZNt5bE0h0mG&$
AF#rGn

literal 0
HcmV?d00001

diff --git a/app.py b/app.py
new file mode 100644
index 0000000..cce4dd5
--- /dev/null
+++ b/app.py
@@ -0,0 +1,55 @@
+import streamlit as st
+import pandas as pd
+from db import get_leads, init_db
+import json
+
+st.set_page_config(page_title="TradingTwins Lead Engine", layout="wide")
+
+st.title("🚀 Lead Engine: TradingTwins")
+
+# Metrics
+leads = get_leads()
+df = pd.DataFrame(leads)
+
+if not df.empty:
+    col1, col2, col3 = st.columns(3)
+    col1.metric("Total Leads", len(df))
+    col2.metric("New Today", len(df[df['status'] == 'new']))
+    col3.metric("Action Required", len(df[df['status'] == 'enriched']))
+
+    st.subheader("Latest Inquiries")
+    
+    for index, row in df.iterrows():
+        with st.expander(f"{row['company_name']} - {row['status']}"):
+            c1, c2 = st.columns(2)
+            c1.write(f"**Contact:** {row['contact_name']}")
+            c1.write(f"**Email:** {row['email']}")
+            
+            enrichment = json.loads(row['enrichment_data']) if row['enrichment_data'] else {}
+            
+            if enrichment:
+                c2.success(f"Score: {enrichment.get('score')}")
+                c2.write(f"**Vertical:** {enrichment.get('vertical')}")
+                c2.info(f"💡 {enrichment.get('recommendation')}")
+            
+            if st.button(f"Generate Response for {row['id']}"):
+                st.write("Generating draft... (Simulated)")
+                # Here we would call the LLM
+                draft = f"Hallo {row['contact_name']},\n\ndanke für Ihre Anfrage..."
+                st.text_area("Draft", draft, height=200)
+
+else:
+    st.info("No leads found. Waiting for ingest...")
+
+if st.sidebar.button("Run Ingest (Mock)"):
+    from ingest import ingest_mock_leads
+    init_db()
+    count = ingest_mock_leads()
+    st.sidebar.success(f"Ingested {count} leads.")
+    st.rerun()
+
+if st.sidebar.button("Run Enrichment"):
+    from enrich import run_enrichment
+    run_enrichment()
+    st.sidebar.success("Enrichment complete.")
+    st.rerun()
diff --git a/data/leads.db b/data/leads.db
new file mode 100644
index 0000000000000000000000000000000000000000..15fffc11cc9fa27bde02ec4bab5a61903fab06ab
GIT binary patch
literal 16384
zcmeI3Pj4Dm5WsgKP8%AB-Z)s5rW~4B7_zYZF-Wb9?R7$HD8{&{RaNM*`(QWhzK8dZ
zsZ&)|<f_LW`!RCtp~}tYevp2ENImu~CfG}`)JV-C(mZK*-(zO>&HQGBm|byruy6Sk
z2HbUs532OBB+JqkfFwyP;<zP_*FzSQ#r131P1hAEr^~C!f28>8pVGa%$-l$}2NFO6
zNB{{S0VIF~kN^@u0!RP}ycL0V{B|mnk&k`Sx2bnxi#D$3(UX8OeQ|kfr=!)o8g%R1
z`x-3hK48S58^Ut^{0sSmR4OI^`rY)NHYJ8PJ;fsS(~sam0<I0qfJUpUJ<>YR?lhY9
z&M|zY9Yg)7`*ouwteaY^yAiSQc;M=^Ck(sVw_P}DH4cunsESK<YMoM}Cpyz^qp2Ns
z>&<plMd!|#u(Mtm!}LarV&)Uwze!9TV%bZ~#wKUWZs(Foug{IMB_@=)mTo$f`8|X9
zWQm676F=~#0@&5|>PP!sxX<Y1e$-``dSlK!+A~}-5OE7QQ3WsD<2sQ!*7fz+?bPQf
zS+bZxf0(721U{dxd(*u2^3zLPl-h@3xvk#&U5X`MNQoDBe|xL)LuDj@1dsp{Kmter
z2_OL^@XiUGe=jGcwR-*2O6Gj{-1$V33Tm}dD3uFJp`2CnSyh3&QY&rN)KadHFPGKg
z*yT*T+yc#FeG-f=Ug{=g@W|;u{*sJ%ANB$^dK%7h12Nm0spkxuDORCWQB|l`s`*N3
z{wq7|diF(Ylx^(RV77fkxMzuXX*IZc<B0Y*+zp$T8cf}Zh+0H9FJ+;V5mAR)%o+x4
z=w<h85m62DIYr4sR)jAm3Y<6*eG$D!{AbT5R3Ft~ZVjiL!S=-;24xZTAJeDQ^(~#)
z=^CV)garf9Mg^|LhVT%caBfVvI})q(2BbZmyHx0Hmc&BzY}^rTkZ6J|&O+<Q*3g8u
zYjM}|&xC_*%hyfV4Ll!qIP+a@r+>Qao~ZH5N-WIpll5li{O9K<VSbDGqFOF4%WqlP
z%&W>lKn(Z{I^4FY>zRBEhq^f-edppOo2ObtFmR~>+m<P`u5@!V-LPpEWwAA({aNNW
z3u*zXN~usRN61`d{?f6CaF+T1<Wj_NUIa5oBf_gPxO6`voTqYL2<l}S{O?uJp?=sc
zKZLsIC>`#L&is1z%gWO1H>qI-&YSr^H2K8k+<_g@k22e0)bp<DK$7IA@BGUIHxL98
z;)o^xmXfc;2?r8D0!RP}AOR$R1dsp{Kmter2_OL^@O~5cD844o9;U?-@wGd%Czq=t
xDmnQ|^#AX7c<4P6Kmter2_OL^fCP{L5<mh-00|%gB(Ol>jvP<P)Bgd){smzt*G2#U

literal 0
HcmV?d00001

diff --git a/db.py b/db.py
new file mode 100644
index 0000000..aa6afda
--- /dev/null
+++ b/db.py
@@ -0,0 +1,70 @@
+import sqlite3
+import json
+from datetime import datetime
+
+DB_PATH = 'lead-engine/data/leads.db'
+
+def init_db():
+    conn = sqlite3.connect(DB_PATH)
+    c = conn.cursor()
+    c.execute('''
+        CREATE TABLE IF NOT EXISTS leads (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            source_id TEXT UNIQUE,
+            received_at TIMESTAMP,
+            company_name TEXT,
+            contact_name TEXT,
+            email TEXT,
+            phone TEXT,
+            raw_body TEXT,
+            enrichment_data TEXT,
+            status TEXT DEFAULT 'new',
+            response_draft TEXT,
+            sent_at TIMESTAMP
+        )
+    ''')
+    conn.commit()
+    conn.close()
+
+def insert_lead(lead_data):
+    conn = sqlite3.connect(DB_PATH)
+    c = conn.cursor()
+    try:
+        c.execute('''
+            INSERT INTO leads (source_id, received_at, company_name, contact_name, email, phone, raw_body, status)
+            VALUES (?, ?, ?, ?, ?, ?, ?, ?)
+        ''', (
+            lead_data.get('id'),
+            datetime.now(),
+            lead_data.get('company'),
+            lead_data.get('contact'),
+            lead_data.get('email'),
+            lead_data.get('phone'),
+            lead_data.get('raw_body'),
+            'new'
+        ))
+        conn.commit()
+        return True
+    except sqlite3.IntegrityError:
+        return False
+    finally:
+        conn.close()
+
+def get_leads():
+    conn = sqlite3.connect(DB_PATH)
+    conn.row_factory = sqlite3.Row
+    c = conn.cursor()
+    c.execute('SELECT * FROM leads ORDER BY received_at DESC')
+    rows = c.fetchall()
+    conn.close()
+    return [dict(row) for row in rows]
+
+def update_lead_status(lead_id, status, response_draft=None):
+    conn = sqlite3.connect(DB_PATH)
+    c = conn.cursor()
+    if response_draft:
+        c.execute('UPDATE leads SET status = ?, response_draft = ? WHERE id = ?', (status, response_draft, lead_id))
+    else:
+        c.execute('UPDATE leads SET status = ? WHERE id = ?', (status, lead_id))
+    conn.commit()
+    conn.close()
diff --git a/enrich.py b/enrich.py
new file mode 100644
index 0000000..9bcf8ad
--- /dev/null
+++ b/enrich.py
@@ -0,0 +1,43 @@
+import json
+from db import update_lead_status, get_leads
+import sqlite3
+
+def enrich_lead(lead):
+    # Mock Enrichment Logic
+    # In production, this would call the Company Explorer API
+    
+    enrichment = {
+        'vertical': 'Unknown',
+        'score': 0,
+        'recommendation': 'Manual Review'
+    }
+    
+    company = lead['company_name'].lower()
+    raw = lead['raw_body']
+    
+    if 'küche' in company or 'einbau' in company:
+        enrichment['vertical'] = 'Manufacturing / Woodworking'
+        enrichment['score'] = 85
+        enrichment['recommendation'] = 'High Priority - Pitch Dust Control'
+        
+    if 'shop' in company or 'roller' in company:
+        enrichment['vertical'] = 'Retail / Automotive'
+        enrichment['score'] = 60
+        enrichment['recommendation'] = 'Medium Priority - Pitch Showroom Cleanliness'
+
+    # Update DB
+    conn = sqlite3.connect('lead-engine/data/leads.db')
+    c = conn.cursor()
+    c.execute('UPDATE leads SET enrichment_data = ?, status = ? WHERE id = ?', 
+              (json.dumps(enrichment), 'enriched', lead['id']))
+    conn.commit()
+    conn.close()
+    
+def run_enrichment():
+    leads = get_leads()
+    for lead in leads:
+        if lead['status'] == 'new':
+            enrich_lead(lead)
+
+if __name__ == "__main__":
+    run_enrichment()
diff --git a/ingest.py b/ingest.py
new file mode 100644
index 0000000..49f09a1
--- /dev/null
+++ b/ingest.py
@@ -0,0 +1,75 @@
+import re
+from db import insert_lead
+
+def parse_tradingtwins_email(body):
+    data = {}
+    
+    # Simple regex extraction based on the email format
+    patterns = {
+        'id': r'Lead-ID:\s*(\d+)',
+        'company': r'Firma:\s*(.+)',
+        'contact_first': r'Vorname:\s*(.+)',
+        'contact_last': r'Nachname:\s*(.+)',
+        'email': r'E-Mail:\s*([^\s<]+)',
+        'phone': r'Rufnummer:\s*([^\n]+)',
+        'area': r'Reinigungs-Flche:\s*([^\n]+)',
+        'purpose': r'Einsatzzweck:\s*([^\n]+)'
+    }
+    
+    for key, pattern in patterns.items():
+        match = re.search(pattern, body)
+        if match:
+            data[key] = match.group(1).strip()
+            
+    # Combine names
+    if 'contact_first' in data and 'contact_last' in data:
+        data['contact'] = f"{data['contact_first']} {data['contact_last']}"
+    
+    data['raw_body'] = body
+    return data
+
+def ingest_mock_leads():
+    # Mock data from the session context
+    leads = [
+        {
+            'id': '2397256',
+            'company': 'pronorm Einbauküchen GmbH',
+            'contact': 'Jakob Funk',
+            'email': 'jakob.funk@pronorm.de',
+            'phone': '+49 5733 979175',
+            'raw_body': """
+            Lead-ID: 2397256
+            Firma: pronorm Einbauküchen GmbH
+            Vorname: Jakob
+            Nachname: Funk
+            Reinigungs-Flche: 1.001 - 10.000 qm
+            Einsatzzweck: Reinigung von Böden
+            """
+        },
+        {
+            'id': '2414364',
+            'company': 'Quad & Rollershop Schwabmünchen GmbH',
+            'contact': 'Manfred Bihler',
+            'email': 'Rollershop.Schwabmuenchen@web.de',
+            'phone': '+49 8232 905246',
+            'raw_body': """
+            Lead-ID: 2414364
+            Firma: Quad & Rollershop Schwabmünchen GmbH
+            Vorname: Manfred
+            Nachname: Bihler
+            Reinigungs-Flche: 301 - 1.000 qm
+            Einsatzzweck: Reinigung von Böden
+            """
+        }
+    ]
+    
+    count = 0
+    for lead in leads:
+        if insert_lead(lead):
+            count += 1
+    return count
+
+if __name__ == "__main__":
+    from db import init_db
+    init_db()
+    print(f"Ingested {ingest_mock_leads()} new leads.")