Create iristrack_seed.py

iristrack_seed.py

@@ -0,0 +1,786 @@
+#!/usr/bin/env python3
+"""
+iristrack_seed.py — IrisTrack Demo Environment Seeder
+======================================================
+Creates a complete IrisPlus Technologies test organization with:
+  - Kalpesh Morar (Org Admin)
+  - 8 employees across Tech, Sales, and Support departments
+  - KPI models per department
+  - 2 projects
+  - Tasks with subtasks (in various states)
+  - Weekly submissions (8 weeks of history) per employee
+  - Leave requests (mix of approved / pending / declined)
+  - Expenses (mix of approved / pending)
+  - Client meetings with intelligence
+
+USAGE:
+  pip install firebase-admin python-dotenv
+  export FIREBASE='<your-service-account-json>'
+  export Firebase_DB='https://your-project.firebaseio.com'
+  python iristrack_seed.py
+
+  --reset flag: wipes the IrisPlus test org before re-seeding
+  python iristrack_seed.py --reset
+
+All credentials printed to stdout at end of run.
+"""
+
+import os
+import sys
+import json
+import uuid
+import argparse
+from datetime import datetime, timezone, date, timedelta
+
+import firebase_admin
+from firebase_admin import credentials, db, auth
+
+try:
+    from dotenv import load_dotenv
+    load_dotenv()
+except ImportError:
+    pass
+
+# ── Init ──────────────────────────────────────────────────────────────────────
+_fb_json = os.environ.get("FIREBASE")
+_fb_url  = os.environ.get("Firebase_DB")
+if not _fb_json or not _fb_url:
+    print("ERROR: FIREBASE and Firebase_DB env vars required.")
+    sys.exit(1)
+
+firebase_admin.initialize_app(
+    credentials.Certificate(json.loads(_fb_json)),
+    {"databaseURL": _fb_url},
+)
+db_ref = db.reference()
+
+# ── Helpers ───────────────────────────────────────────────────────────────────
+def now_iso():
+    return datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%S.%f") + "Z"
+
+def past_iso(days_ago=0, hours_ago=0):
+    dt = datetime.now(timezone.utc) - timedelta(days=days_ago, hours=hours_ago)
+    return dt.strftime("%Y-%m-%dT%H:%M:%S.%f") + "Z"
+
+def week_id(weeks_ago=0):
+    d = date.today() - timedelta(weeks=weeks_ago)
+    return d.strftime("%G-W%V")
+
+def next_weekday(d: date, weekday: int) -> date:
+    days_ahead = weekday - d.weekday()
+    if days_ahead <= 0:
+        days_ahead += 7
+    return d + timedelta(days=days_ahead)
+
+def create_fb_user(email, password, display_name):
+    try:
+        user = auth.create_user(email=email, password=password, display_name=display_name)
+        print(f"  ✓ Created Auth user: {email}")
+        return user.uid
+    except Exception as e:
+        if "EMAIL_EXISTS" in str(e) or "email-already-exists" in str(e).lower():
+            user = auth.get_user_by_email(email)
+            print(f"  ~ Existing Auth user: {email} → {user.uid}")
+            return user.uid
+        raise
+
+ORG_ID = "irisplus-test-org-001"
+PRINT_DIVIDER = "─" * 60
+
+# ── Departments ───────────────────────────────────────────────────────────────
+DEPARTMENTS = {
+    "dept-tech":    {"deptId": "dept-tech",    "name": "Technology",    "description": "Engineering, infrastructure, product"},
+    "dept-sales":   {"deptId": "dept-sales",   "name": "Sales",         "description": "Business development and client acquisition"},
+    "dept-support": {"deptId": "dept-support", "name": "Client Support","description": "Customer success and post-sale support"},
+}
+
+# ── Team ──────────────────────────────────────────────────────────────────────
+TEAM = [
+    # (display_name, email, password, phone, position, dept_id, platform_role)
+    ("Kalpesh Morar",    "kalpesh@irisplus.co.zw",   "IrisAdmin2026!",  "+263771000001", "Chief Executive Officer",       None,           "org_admin"),
+    ("Tendai Moyo",      "tendai@irisplus.co.zw",    "IrisTech2026!",   "+263771000002", "Lead Software Engineer",        "dept-tech",    "dept_admin"),
+    ("Rudo Chikwanda",   "rudo@irisplus.co.zw",      "IrisTech2026!",   "+263771000003", "Frontend Developer",            "dept-tech",    "employee"),
+    ("Farai Ncube",      "farai@irisplus.co.zw",     "IrisTech2026!",   "+263771000004", "Backend Developer",             "dept-tech",    "employee"),
+    ("Simba Dube",       "simba@irisplus.co.zw",     "IrisSales2026!",  "+263771000005", "Sales Manager",                 "dept-sales",   "dept_admin"),
+    ("Nyasha Mutasa",    "nyasha@irisplus.co.zw",    "IrisSales2026!",  "+263771000006", "Business Development Executive","dept-sales",   "employee"),
+    ("Chiedza Mhaka",    "chiedza@irisplus.co.zw",   "IrisSales2026!",  "+263771000007", "Sales Executive",               "dept-sales",   "employee"),
+    ("Tatenda Zvobgo",   "tatenda@irisplus.co.zw",   "IrisSupport2026!","+263771000008", "Support Lead",                  "dept-support", "dept_admin"),
+    ("Mazvita Chirinda", "mazvita@irisplus.co.zw",   "IrisSupport2026!","+263771000009", "Client Success Executive",      "dept-support", "employee"),
+]
+
+# ── KPI Models ────────────────────────────────────────────────────────────────
+KPI_MODELS = {
+    "kpi-tech": {
+        "modelId":  "kpi-tech",
+        "role":     "Software Engineer",
+        "kpi_categories": [
+            {"name": "Feature Development",    "weight": 45, "description": "Building and shipping product features"},
+            {"name": "Bug Fixes & Maintenance", "weight": 25, "description": "Resolving defects and technical debt"},
+            {"name": "Code Review & Mentoring", "weight": 15, "description": "Supporting team quality and growth"},
+            {"name": "Documentation",           "weight": 10, "description": "Technical writing and knowledge base"},
+            {"name": "Internal Admin",          "weight":  5, "description": "Meetings, reporting, overhead"},
+        ],
+        "synthesized_from": "seed",
+    },
+    "kpi-sales": {
+        "modelId":  "kpi-sales",
+        "role":     "Sales Executive",
+        "kpi_categories": [
+            {"name": "Revenue-Generating Activities", "weight": 40, "description": "Prospecting, pitching, closing"},
+            {"name": "Client Relationship Management","weight": 30, "description": "Nurturing existing accounts"},
+            {"name": "Product & Market Knowledge",    "weight": 20, "description": "Staying sharp on offering and competitors"},
+            {"name": "Internal Administration",       "weight": 10, "description": "CRM updates, reporting, internal meetings"},
+        ],
+        "synthesized_from": "seed",
+    },
+    "kpi-support": {
+        "modelId":  "kpi-support",
+        "role":     "Client Support",
+        "kpi_categories": [
+            {"name": "Ticket Resolution",      "weight": 50, "description": "Resolving client issues end-to-end"},
+            {"name": "Proactive Client Check-in","weight": 25, "description": "Reaching out before problems escalate"},
+            {"name": "Knowledge Base Updates", "weight": 15, "description": "Documenting solutions for future use"},
+            {"name": "Internal Escalations",   "weight": 10, "description": "Coordinating with tech and sales on complex issues"},
+        ],
+        "synthesized_from": "seed",
+    },
+}
+
+# ── Projects ──────────────────────────────────────────────────────────────────
+PROJECTS = {
+    "proj-iristrack": {
+        "projectId":   "proj-iristrack",
+        "orgId":       ORG_ID,
+        "name":        "IrisTrack v1 Launch",
+        "description": "Internal rollout and external go-to-market for IrisTrack",
+        "color":       "#00B4D8",
+        "active":      True,
+    },
+    "proj-client-harare": {
+        "projectId":   "proj-client-harare",
+        "orgId":       ORG_ID,
+        "name":        "Harare Enterprise Pilot",
+        "description": "Acquiring first 3 paying enterprise clients in Harare CBD",
+        "color":       "#F59E0B",
+        "active":      True,
+    },
+}
+
+# ── Submissions data ──────────────────────────────────────────────────────────
+SUBMISSION_TEMPLATES = {
+    "dept-tech": [
+        ("Spent most of the week finalising the IrisTrack WhatsApp submission pipeline. The Twilio webhook is fully wired and we're now transcribing voice notes via AssemblyAI. Also reviewed two PRs from Rudo on the expense upload feature and fixed a bug where the week ID was using %W instead of the ISO %G-W%V format. Short on documentation time this week — pushed it to next.",
+         88, False),
+        ("Heavy week on feature development. Shipped the subtask endpoint and the project grouping feature. Code review took a bit longer than expected because Farai's PR had some edge cases around the Firebase update logic. Spent about 15% of time on internal meetings and sprint planning — higher than usual.",
+         72, True),
+        ("Mostly maintenance this week. Tracked down a memory leak in the HuggingFace deployment — turned out to be an unclosed AssemblyAI polling loop. Also updated the README and deployment docs. Feature development was lighter than target.",
+         61, False),
+        ("Strong week. Shipped the KPI model preview endpoint and the mark-all-read notifications endpoint. Pair-programmed with Farai on the receipt image upload to Firebase Storage. Documentation is still behind — need to carve out time.",
+         84, False),
+        ("Delivered the full admin dashboard analytics endpoint. Spent time reviewing Rudo's Lovable frontend work and giving feedback on the alignment gauge component. Some scope creep into support — helped Tatenda debug a WhatsApp delivery issue for about 3 hours which wasn't planned.",
+         69, True),
+        ("Sprint focused on performance. Optimised the org analytics query — was doing N+1 reads on submissions. Reduced to two reads. Also mentored Rudo on TypeScript generics. Admin overhead was high this week due to board prep.",
+         78, False),
+        ("Closed out 4 features this week: task preview workload assessment, project endpoints, subtask notifications, and the Resend invite email. All shipped clean. Code review cadence was good. Zero documentation work though.",
+         82, False),
+        ("Week was split between a production incident (Gemini rate limit hit during bulk submission processing) and new feature work on the meeting recording pipeline. Incident resolution took half a day. Back on track by Wednesday.",
+         75, False),
+    ],
+    "dept-sales": [
+        ("Had three prospect meetings this week — two with HR managers at logistics firms in Avondale and one with a professional services firm in Borrowdale. One of the Avondale leads is warm, requesting a demo next week. Also spent time updating the CRM and preparing the IrisTrack pitch deck.",
+         91, False),
+        ("Focused on account management this week. Three check-in calls with existing contacts. The Borrowdale firm came back with questions about data residency — escalated to Tendai for a technical response. Prospecting was lighter than target.",
+         68, True),
+        ("Two client demos delivered. One converted to a trial agreement — Harare Enterprise Pilot first client confirmed. Proposal sent to second prospect. Market research on competitor pricing took more time than budgeted.",
+         87, False),
+        ("CRM cleanup week. Updated 40+ contact records and rebuilt the pipeline view. Also attended a networking event at the Harare Chamber of Commerce — 6 new contacts. No direct revenue activities but important pipeline work.",
+         55, True),
+        ("Strong prospecting week. Made 18 outbound calls, booked 4 discovery calls for next week. Spent time studying the new IrisTrack meeting intelligence feature to incorporate into the pitch. Client relationship work was minimal.",
+         73, False),
+        ("Closed second Harare Enterprise Pilot client. Contract signed for 3-month pilot at $199/month. Celebration aside — need to focus on third client. Relationship management took significant time post-close.",
+         95, False),
+        ("Pipeline review and forecast update with Kalpesh. Two follow-up proposals sent. One prospect went cold — needs re-engagement strategy. Market knowledge session with Tendai on product roadmap.",
+         71, False),
+        ("Attended the Zimbabwe ICT conference. Three warm leads generated. Demo pipeline is healthy. Spent significant time on admin and conference logistics which pushed revenue activities below target.",
+         62, True),
+    ],
+    "dept-support": [
+        ("Resolved 12 client tickets this week. Two were escalated to tech — both were bugs in the WhatsApp submission flow (now fixed). Proactively called three clients nearing their monthly submission window. Updated the FAQ with three new entries.",
+         82, False),
+        ("High ticket volume — 18 resolved. Most were onboarding questions from the new Harare Enterprise client. Spent less time on proactive check-ins than planned. Knowledge base updates done for 2 articles.",
+         71, False),
+        ("Lighter ticket week — 8 resolved. Used the bandwidth for proactive outreach: called all 9 active clients to check satisfaction. Two flagged confusion about the leave request WhatsApp flow — documented and sent to Tendai for UX review.",
+         88, False),
+        ("Processed all pending expense approvals for the week. Followed up on 3 flagged expenses. Ticket resolution was below target — a public holiday mid-week affected throughput. Knowledge base work was good.",
+         65, False),
+        ("Resolved 15 tickets. One critical issue — client's WhatsApp number changed and submissions were being missed. Fixed with Farai's help. Proactive check-in rate was good. Escalations were minimal.",
+         84, False),
+        ("Knowledge base sprint. Wrote 5 new articles covering the meeting recording flow, expense submission via WhatsApp, and the leave approval decision process. Ticket resolution was lighter as a result.",
+         76, False),
+        ("Onboarded the third Harare Enterprise Pilot client. Ran a 2-hour onboarding session covering all features. Ticket volume low. Proactive outreach focused on the new client this week.",
+         79, False),
+        ("End of pilot review for client 1. Prepared usage report and sat in on the renewal meeting with Simba. Ticket resolution normal. Internal escalation about API timeout errors — routed to tech.",
+         74, False),
+    ],
+}
+
+# ── Leave requests ────────────────────────────────────────────────────────────
+LEAVE_REQUESTS = [
+    ("nyasha@irisplus.co.zw",  "annual",      5,  "approved",  "Family wedding in Bulawayo"),
+    ("rudo@irisplus.co.zw",    "sick",         2,  "approved",  "Flu — doctor's note attached"),
+    ("chiedza@irisplus.co.zw", "annual",       3,  "pending",   "Short holiday next month"),
+    ("farai@irisplus.co.zw",   "study",        2,  "approved",  "AWS certification exam prep"),
+    ("mazvita@irisplus.co.zw", "compassionate",3,  "approved",  "Bereavement — grandfather passed"),
+    ("tatenda@irisplus.co.zw", "annual",       5,  "declined",  "Leave during peak support period — please reschedule"),
+    ("simba@irisplus.co.zw",   "annual",       5,  "pending",   "Annual leave — December"),
+]
+
+# ── Expenses ──────────────────────────────────────────────────────────────────
+EXPENSES = [
+    ("nyasha@irisplus.co.zw",  "Client lunch at Amanzi Restaurant with CFO of Harare Logistics Ltd",        35.00,  "USD", "client_entertainment", "approved"),
+    ("simba@irisplus.co.zw",   "Fuel for client visits — Borrowdale and Avondale in one day",               18.00,  "USD", "transport",            "approved"),
+    ("chiedza@irisplus.co.zw", "Zimbabwe ICT Conference registration fee",                                  50.00,  "USD", "other",                "approved"),
+    ("rudo@irisplus.co.zw",    "USB-C hub for home office setup — needed for dual monitor work",             42.00,  "USD", "office_supplies",      "pending"),
+    ("farai@irisplus.co.zw",   "AWS certification exam fee",                                               150.00,  "USD", "other",                "approved"),
+    ("tatenda@irisplus.co.zw", "Client team dinner at Bronte Hotel — 5 people, post-onboarding",            95.00,  "USD", "client_entertainment", "flagged"),
+    ("mazvita@irisplus.co.zw", "Grab taxi to client site — Westgate",                                        8.00,  "USD", "transport",            "approved"),
+    ("nyasha@irisplus.co.zw",  "Team lunch during pipeline review session",                                  28.00,  "USD", "meals",                "pending"),
+]
+
+# ── Tasks ─────────────────────────────────────────────────────────────────────
+TASKS = [
+    # (title, description, assignee_email, priority, kpi_cat, project_id, status, due_days_from_now, est_hours, subtasks)
+    (
+        "Finalise IrisTrack meeting recording endpoint",
+        "Complete the WhatsApp audio → AssemblyAI → Gemini meeting intelligence pipeline. Include dual summaries and action item extraction.",
+        "farai@irisplus.co.zw", "high", "Feature Development", "proj-iristrack", "in_progress", 3, 8.0,
+        ["Write AssemblyAI polling logic", "Integrate Gemini meeting prompt", "Add WhatsApp distribution logic", "Write endpoint tests"],
+    ),
+    (
+        "Build KPI alignment dashboard chart",
+        "React recharts component showing actual vs target KPI allocation for the employee dashboard. Use the alignment gauge design spec.",
+        "rudo@irisplus.co.zw", "high", "Feature Development", "proj-iristrack", "in_progress", 4, 6.0,
+        ["Design alignment bar chart component", "Wire to GET /submissions endpoint", "Mobile responsive layout"],
+    ),
+    (
+        "Deliver IrisTrack demo to Harare Logistics Ltd",
+        "Prepare and deliver a full product demo covering weekly reporting, leave management, and expense tracking. Use the IrisPlus internal deployment as the live demo environment.",
+        "simba@irisplus.co.zw", "high", "Revenue-Generating Activities", "proj-client-harare", "open", 7, 4.0,
+        ["Prepare demo script", "Set up demo org in IrisTrack", "Rehearse with Nyasha", "Send follow-up proposal"],
+    ),
+    (
+        "Write onboarding guide for new IrisTrack clients",
+        "Create a step-by-step WhatsApp and web onboarding guide for org admins. Cover: org setup, adding users, KPI model creation, and first submission walkthrough.",
+        "tatenda@irisplus.co.zw", "medium", "Knowledge Base Updates", "proj-iristrack", "open", 10, 5.0,
+        ["Draft WhatsApp interaction guide", "Draft web dashboard guide", "Review with Kalpesh", "Publish to help centre"],
+    ),
+    (
+        "Resolve CRM data gaps from conference leads",
+        "Clean up and enrich the 6 Harare Chamber of Commerce contacts added last week. Add company info, LinkedIn, and assign follow-up dates.",
+        "nyasha@irisplus.co.zw", "medium", "Client Relationship Management", "proj-client-harare", "open", 5, 3.0,
+        ["Research company profiles", "Update CRM records", "Schedule follow-up calls"],
+    ),
+    (
+        "Deploy IrisTrack to production HuggingFace Space",
+        "Final production deployment. Verify all env secrets, run health check, test WhatsApp webhook with Twilio sandbox, confirm Resend invite email flow.",
+        "tendai@irisplus.co.zw", "high", "Feature Development", "proj-iristrack", "completed", -2, 6.0,
+        ["Set all HF secrets", "Deploy and run /api/health", "Test Twilio webhook", "Test Resend invite"],
+    ),
+    (
+        "Close third Harare Enterprise Pilot client",
+        "Follow up with Nyaradzo Insurance — they've had a demo and requested a proposal. Negotiate terms and close before end of month.",
+        "simba@irisplus.co.zw", "high", "Revenue-Generating Activities", "proj-client-harare", "in_progress", 12, 5.0,
+        ["Send revised proposal", "Schedule negotiation call", "Prepare contract draft"],
+    ),
+    (
+        "Support ticket SLA review",
+        "Analyse the last 30 days of support tickets. Identify the top 3 recurring issue categories and propose process improvements.",
+        "mazvita@irisplus.co.zw", "low", "Knowledge Base Updates", "proj-iristrack", "open", 14, 4.0,
+        ["Pull ticket data from Firebase", "Categorise and count issues", "Draft recommendations"],
+    ),
+]
+
+# ── Client meetings ────────────────────────────────────────────────────────────
+MEETINGS = [
+    {
+        "title":      "IrisTrack Demo — Harare Logistics Ltd",
+        "clientName": "Harare Logistics Ltd",
+        "attendee_emails": ["simba@irisplus.co.zw", "nyasha@irisplus.co.zw"],
+        "status":     "completed",
+        "intelligence": {
+            "executive_summary": "A 45-minute product demo covering weekly reporting, leave management, and expense tracking. The CFO and HR Director were engaged throughout. Key concern raised was data residency — they want confirmation that data stays in-country or within Africa.",
+            "key_decisions":     ["Request for pilot proposal to be sent within 48 hours", "Technical data residency question to be answered by engineering"],
+            "action_items": [
+                {"action": "Send pilot proposal with pricing", "owner": "Simba Dube", "due_date": (date.today() - timedelta(days=5)).isoformat(), "priority": "high"},
+                {"action": "Technical response on data residency", "owner": "Tendai Moyo", "due_date": (date.today() - timedelta(days=3)).isoformat(), "priority": "high"},
+            ],
+            "client_sentiment":    "positive",
+            "follow_up_required":  True,
+            "risks_identified":    ["Data residency compliance may require Firebase region configuration"],
+            "opportunities_identified": ["CFO mentioned interest in expense reconciliation feature for their 40-person field team"],
+            "employee_summary":    "Strong demo. The client was particularly interested in the WhatsApp-native reporting flow — exactly the pain point they have with their field drivers. Next step is the proposal. Make sure the data residency answer is watertight before sending.",
+            "manager_summary":     "Warm lead. CFO is the economic buyer. The data residency question is a real gating issue — needs engineering input within 48 hours or we risk losing momentum. The field team expense use case is a significant upsell opportunity if the pilot lands.",
+        }
+    },
+    {
+        "title":      "Pilot Review — Client 1",
+        "clientName": "Harare Logistics Ltd",
+        "attendee_emails": ["simba@irisplus.co.zw", "mazvita@irisplus.co.zw"],
+        "status":     "completed",
+        "intelligence": {
+            "executive_summary": "30-day pilot review meeting. Client reported 85% weekly submission compliance, up from near-zero with their previous spreadsheet process. Two feature requests raised: bulk expense upload and department-level reporting. Renewal discussed.",
+            "key_decisions":     ["Client proceeding to paid subscription — Growth tier", "Feature requests logged for Q3 roadmap"],
+            "action_items": [
+                {"action": "Send Growth tier subscription agreement", "owner": "Simba Dube", "due_date": (date.today() + timedelta(days=2)).isoformat(), "priority": "high"},
+                {"action": "Log bulk expense upload in product backlog", "owner": "Tendai Moyo", "due_date": (date.today() + timedelta(days=7)).isoformat(), "priority": "medium"},
+            ],
+            "client_sentiment":    "positive",
+            "follow_up_required":  True,
+            "risks_identified":    ["Two team members still not submitting — may need WhatsApp number re-registration"],
+            "opportunities_identified": ["Client has 3 sister companies — warm referral opportunity"],
+            "employee_summary":    "Great meeting. Client is happy and converting. Mention the sister company referral angle to Kalpesh — that's three potential logos from one relationship.",
+            "manager_summary":     "First conversion secured. The 85% compliance stat is a strong case study data point. Referral opportunity to sister companies should be actioned immediately while sentiment is high.",
+        }
+    },
+]
+
+
+# ═══════════════════════════════════════════════════════════════════════════════
+# SEEDING FUNCTIONS
+# ═══════════════════════════════════════════════════════════════════════════════
+
+def reset_org():
+    print(f"\n🗑  Resetting org {ORG_ID}...")
+    for node in ["organizations", "departments", "users", "kpi_models", "projects",
+                 "tasks", "subtasks", "submissions", "leave_requests", "expenses",
+                 "budgets", "notifications", "audit_log", "client_meetings"]:
+        db_ref.child(f"{node}/{ORG_ID}").delete()
+    db_ref.child(f"platform_orgs/{ORG_ID}").delete()
+    print("  ✓ Org data wiped")
+
+
+def seed_org(admin_uid):
+    print(f"\n🏢 Seeding organization...")
+    org_data = {
+        "orgId":          ORG_ID,
+        "name":           "IrisPlus Technologies",
+        "industry":       "Technology",
+        "country":        "Zimbabwe",
+        "createdAt":      past_iso(90),
+        "reporting_day":  "friday",
+        "reporting_time": "08:00",
+        "org_goals":      "Build and ship IrisTrack to 10 paying customers in Harare by Q3 2026. Maintain team alignment scores above 75%. Grow revenue to $2,000 MRR.",
+        "active":         True,
+    }
+    db_ref.child(f"organizations/{ORG_ID}").set(org_data)
+    db_ref.child(f"platform_orgs/{ORG_ID}").set({
+        "orgId":     ORG_ID,
+        "name":      "IrisPlus Technologies",
+        "adminUid":  admin_uid,
+        "createdAt": past_iso(90),
+    })
+    print("  ✓ Organization: IrisPlus Technologies")
+
+
+def seed_departments():
+    print(f"\n🏗  Seeding departments...")
+    for dept_id, dept_data in DEPARTMENTS.items():
+        db_ref.child(f"departments/{ORG_ID}/{dept_id}").set({
+            **dept_data,
+            "createdAt": past_iso(89),
+        })
+        print(f"  ✓ {dept_data['name']}")
+
+
+def seed_kpi_models(admin_uid):
+    print(f"\n📊 Seeding KPI models...")
+    for model_id, model_data in KPI_MODELS.items():
+        db_ref.child(f"kpi_models/{ORG_ID}/{model_id}").set({
+            **model_data,
+            "orgId":     ORG_ID,
+            "createdBy": admin_uid,
+            "createdAt": past_iso(88),
+        })
+        print(f"  ✓ {model_data['role']}")
+
+
+def seed_projects(admin_uid):
+    print(f"\n📁 Seeding projects...")
+    for proj_id, proj_data in PROJECTS.items():
+        db_ref.child(f"projects/{ORG_ID}/{proj_id}").set({
+            **proj_data,
+            "createdBy": admin_uid,
+            "createdAt": past_iso(60),
+        })
+        print(f"  ✓ {proj_data['name']}")
+
+
+def seed_budgets():
+    print(f"\n💰 Seeding budgets...")
+    budgets = {
+        "dept-sales": {
+            "client_entertainment": {"allocated": 400, "spent": 130.00},
+            "transport":            {"allocated": 200, "spent":  26.00},
+            "meals":                {"allocated": 150, "spent":  28.00},
+            "other":                {"allocated": 300, "spent": 200.00},
+        },
+        "dept-tech": {
+            "office_supplies": {"allocated": 200, "spent":  42.00},
+            "other":           {"allocated": 500, "spent": 150.00},
+        },
+        "dept-support": {
+            "client_entertainment": {"allocated": 200, "spent": 103.00},
+            "transport":            {"allocated": 100, "spent":   8.00},
+        },
+    }
+    for dept_id, budget in budgets.items():
+        db_ref.child(f"budgets/{ORG_ID}/{dept_id}").set(budget)
+    print("  ✓ Budgets set for all departments")
+
+
+def seed_users():
+    print(f"\n👥 Seeding users...")
+    uid_map = {}
+    for (display_name, email, password, phone, position, dept_id, platform_role) in TEAM:
+        uid = create_fb_user(email, password, display_name)
+        uid_map[email] = uid
+        leave_balance = {"annual": 20, "sick": 10, "study": 5}
+
+        # Simulate some used leave
+        if email == "nyasha@irisplus.co.zw":
+            leave_balance["annual"] = 15
+        elif email == "rudo@irisplus.co.zw":
+            leave_balance["sick"] = 8
+        elif email == "farai@irisplus.co.zw":
+            leave_balance["study"] = 3
+        elif email == "mazvita@irisplus.co.zw":
+            leave_balance["annual"] = 17
+
+        db_ref.child(f"users/{ORG_ID}/{uid}").set({
+            "uid":               uid,
+            "email":             email,
+            "displayName":       display_name,
+            "phone":             phone,
+            "platform_role":     platform_role,
+            "department_id":     dept_id,
+            "position":          position,
+            "createdAt":         past_iso(85),
+            "addedBy":           "seed",
+            "active":            True,
+            "leave_balance":     leave_balance,
+            "whatsapp_state":    "idle",
+            "last_alignment_score": None,
+        })
+    print(f"  ✓ {len(TEAM)} users seeded")
+    return uid_map
+
+
+def seed_submissions(uid_map):
+    print(f"\n📝 Seeding submissions (8 weeks × 8 employees)...")
+    dept_templates = {
+        "dept-tech":    (SUBMISSION_TEMPLATES["dept-tech"],    "kpi-tech",    ["tendai@irisplus.co.zw", "rudo@irisplus.co.zw", "farai@irisplus.co.zw"]),
+        "dept-sales":   (SUBMISSION_TEMPLATES["dept-sales"],   "kpi-sales",   ["simba@irisplus.co.zw",  "nyasha@irisplus.co.zw", "chiedza@irisplus.co.zw"]),
+        "dept-support": (SUBMISSION_TEMPLATES["dept-support"], "kpi-support", ["tatenda@irisplus.co.zw","mazvita@irisplus.co.zw"]),
+    }
+
+    kpi_weights_map = {
+        "kpi-tech":    {c["name"]: c["weight"] for c in KPI_MODELS["kpi-tech"]["kpi_categories"]},
+        "kpi-sales":   {c["name"]: c["weight"] for c in KPI_MODELS["kpi-sales"]["kpi_categories"]},
+        "kpi-support": {c["name"]: c["weight"] for c in KPI_MODELS["kpi-support"]["kpi_categories"]},
+    }
+
+    for dept_id, (templates, model_id, emails) in dept_templates.items():
+        cats    = [c["name"] for c in KPI_MODELS[model_id]["kpi_categories"]]
+        weights = kpi_weights_map[model_id]
+        for email in emails:
+            uid = uid_map.get(email)
+            if not uid:
+                continue
+            for week_offset in range(8):
+                # Skip current week for a couple of employees to simulate missing submissions
+                if week_offset == 0 and email in ("chiedza@irisplus.co.zw", "mazvita@irisplus.co.zw"):
+                    continue
+                tmpl_idx                   = week_offset % len(templates)
+                raw_text, alignment_score, drift = templates[tmpl_idx]
+                wid                        = week_id(week_offset)
+                submitted_at               = past_iso(days_ago=week_offset * 7, hours_ago=2)
+
+                # Simulate actual KPI allocation based on alignment score
+                if model_id == "kpi-tech":
+                    actual = {"Feature Development": 40 if not drift else 20, "Bug Fixes & Maintenance": 25,
+                              "Code Review & Mentoring": 15, "Documentation": 5 if drift else 10,
+                              "Internal Admin": 15 if drift else 5}
+                elif model_id == "kpi-sales":
+                    actual = {"Revenue-Generating Activities": 35 if drift else 42,
+                              "Client Relationship Management": 28 if drift else 31,
+                              "Product & Market Knowledge": 22, "Internal Administration": 15 if drift else 5}
+                else:
+                    actual = {"Ticket Resolution": 48, "Proactive Client Check-in": 22,
+                              "Knowledge Base Updates": 18, "Internal Escalations": 12}
+
+                sub_data = {
+                    "submissionId":       str(uuid.uuid4()),
+                    "orgId":              ORG_ID,
+                    "uid":                uid,
+                    "weekId":             wid,
+                    "rawText":            raw_text,
+                    "kpiModelId":         model_id,
+                    "submittedAt":        submitted_at,
+                    "source":             "seed",
+                    "alignment_score":    alignment_score,
+                    "alignment_notes":    f"Employee's time allocation {'shows significant drift from' if drift else 'broadly aligns with'} target KPI weights. Alignment score: {alignment_score}/100.",
+                    "actual_allocation":  actual,
+                    "role_drift_detected": drift,
+                    "role_drift_detail":  "Significant time on out-of-role administrative tasks" if drift else None,
+                    "success_events":     ["Shipped feature on time", "Closed client follow-up"] if alignment_score > 80 else [],
+                    "structured_activities": [{"activity": "Work activities", "kpi_category": cats[0], "estimated_percent": 45}],
+                    "summary":            raw_text[:200] + "...",
+                }
+                db_ref.child(f"submissions/{ORG_ID}/{uid}/{wid}").set(sub_data)
+                # Update last alignment score on user record
+                db_ref.child(f"users/{ORG_ID}/{uid}").update({
+                    "last_submission_at":    submitted_at,
+                    "last_alignment_score":  alignment_score,
+                })
+    print("  ✓ Submissions seeded")
+
+
+def seed_leave_requests(uid_map, admin_uid):
+    print(f"\n🏖  Seeding leave requests...")
+    for (email, ltype, days, status, reason) in LEAVE_REQUESTS:
+        uid      = uid_map.get(email)
+        if not uid:
+            continue
+        start    = date.today() + timedelta(days=14) if status == "pending" else date.today() - timedelta(days=30)
+        end      = start + timedelta(days=days - 1)
+        req_id   = str(uuid.uuid4())
+        req_data = {
+            "requestId":      req_id,
+            "orgId":          ORG_ID,
+            "uid":            uid,
+            "employeeName":   next(t[0] for t in TEAM if t[1] == email),
+            "leave_type":     ltype,
+            "start_date":     start.isoformat(),
+            "end_date":       end.isoformat(),
+            "days_requested": days,
+            "reason":         reason,
+            "is_urgent":      False,
+            "status":         status,
+            "submittedAt":    past_iso(20),
+        }
+        if status in ("approved", "declined"):
+            req_data.update({
+                "decidedBy":      admin_uid,
+                "decidedAt":      past_iso(18),
+                "decision_note":  reason if status == "declined" else "",
+            })
+        db_ref.child(f"leave_requests/{ORG_ID}/{req_id}").set(req_data)
+    print(f"  ✓ {len(LEAVE_REQUESTS)} leave requests seeded")
+
+
+def seed_expenses(uid_map, admin_uid):
+    print(f"\n🧾 Seeding expenses...")
+    for (email, description, amount, currency, category, status) in EXPENSES:
+        uid        = uid_map.get(email)
+        if not uid:
+            continue
+        user_team  = next(t for t in TEAM if t[1] == email)
+        dept_id    = user_team[5]
+        exp_id     = str(uuid.uuid4())
+        exp_data   = {
+            "expenseId":     exp_id,
+            "orgId":         ORG_ID,
+            "uid":           uid,
+            "employeeName":  user_team[0],
+            "department_id": dept_id,
+            "receiptUrl":    None,
+            "rawText":       description,
+            "vendor":        description.split(" at ")[-1].split(" — ")[0][:40],
+            "amount":        amount,
+            "currency":      currency,
+            "category":      category,
+            "description":   description,
+            "is_client_related": "client" in description.lower() or "conference" in description.lower(),
+            "status":        status,
+            "submittedAt":   past_iso(14),
+        }
+        if status in ("approved", "flagged"):
+            exp_data.update({
+                "decidedBy":     admin_uid,
+                "decidedAt":     past_iso(12),
+                "decision_note": "Flagged — amount exceeds entertainment guideline. Please provide itemised receipt." if status == "flagged" else "",
+            })
+        db_ref.child(f"expenses/{ORG_ID}/{exp_id}").set(exp_data)
+    print(f"  ✓ {len(EXPENSES)} expenses seeded")
+
+
+def seed_tasks(uid_map, admin_uid):
+    print(f"\n✅ Seeding tasks and subtasks...")
+    for (title, description, assignee_email, priority, kpi_cat, project_id, status, due_days, est_hours, subtask_titles) in TASKS:
+        assignee_uid = uid_map.get(assignee_email)
+        if not assignee_uid:
+            continue
+        task_id  = str(uuid.uuid4())
+        due_dt   = date.today() + timedelta(days=due_days)
+        if due_dt.weekday() == 5: due_dt += timedelta(days=2)
+        if due_dt.weekday() == 6: due_dt += timedelta(days=1)
+
+        task_data = {
+            "taskId":           task_id,
+            "orgId":            ORG_ID,
+            "projectId":        project_id,
+            "title":            title,
+            "description":      description,
+            "kpi_category":     kpi_cat,
+            "priority":         priority,
+            "assignedTo":       assignee_uid,
+            "assigned_to_uid":  assignee_uid,
+            "assignedBy":       admin_uid,
+            "dueDateTime":      due_dt.strftime("%Y-%m-%dT17:00:00Z"),
+            "estimated_hours":  est_hours,
+            "status":           status,
+            "createdAt":        past_iso(days_ago=max(0, -due_days + 7)),
+            "synthesized_from": "seed",
+            "workload_assessment":     "ok",
+            "workload_recommendation": "Reasonable workload based on current open tasks.",
+        }
+        if status == "completed":
+            task_data["completedAt"] = past_iso(abs(due_days))
+
+        db_ref.child(f"tasks/{ORG_ID}/{task_id}").set(task_data)
+
+        # Seed subtasks
+        for i, st_title in enumerate(subtask_titles):
+            st_id = str(uuid.uuid4())
+            st_status = "completed" if status == "completed" else ("completed" if i == 0 and status == "in_progress" else "open")
+            st_data = {
+                "subtaskId":  st_id,
+                "taskId":     task_id,
+                "orgId":      ORG_ID,
+                "title":      st_title,
+                "status":     st_status,
+                "createdBy":  assignee_uid,
+                "order":      i,
+                "createdAt":  past_iso(days_ago=max(0, -due_days + 6)),
+            }
+            if st_status == "completed":
+                st_data["completedAt"] = past_iso(abs(due_days) + 1)
+            db_ref.child(f"subtasks/{ORG_ID}/{task_id}/{st_id}").set(st_data)
+
+    print(f"  ✓ {len(TASKS)} tasks with subtasks seeded")
+
+
+def seed_meetings(uid_map, admin_uid):
+    print(f"\n🤝 Seeding client meetings...")
+    for meeting in MEETINGS:
+        attendee_uids = [uid_map[e] for e in meeting["attendee_emails"] if e in uid_map]
+        meeting_id    = str(uuid.uuid4())
+        meeting_data  = {
+            "meetingId":    meeting_id,
+            "orgId":        ORG_ID,
+            "title":        meeting["title"],
+            "clientName":   meeting["clientName"],
+            "scheduledAt":  past_iso(days_ago=21 if "Demo" in meeting["title"] else 7),
+            "attendeeUids": attendee_uids,
+            "status":       meeting["status"],
+            "createdBy":    uid_map.get("simba@irisplus.co.zw", admin_uid),
+            "createdAt":    past_iso(days_ago=25 if "Demo" in meeting["title"] else 10),
+            "completedAt":  past_iso(days_ago=21 if "Demo" in meeting["title"] else 7),
+            "transcript":   f"[Seeded transcript for: {meeting['title']}]",
+            "intelligence": meeting["intelligence"],
+        }
+        db_ref.child(f"client_meetings/{ORG_ID}/{meeting_id}").set(meeting_data)
+    print(f"  ✓ {len(MEETINGS)} client meetings seeded")
+
+
+def seed_notifications(uid_map, admin_uid):
+    print(f"\n🔔 Seeding sample notifications...")
+    samples = [
+        (uid_map.get("rudo@irisplus.co.zw"),    "New Task Assigned",        "Build KPI alignment dashboard chart",             "info"),
+        (uid_map.get("farai@irisplus.co.zw"),   "New Task Assigned",        "Finalise IrisTrack meeting recording endpoint",   "info"),
+        (uid_map.get("nyasha@irisplus.co.zw"),  "✅ Leave Approved",        "Your annual leave (5 days) has been approved.",   "success"),
+        (uid_map.get("tatenda@irisplus.co.zw"), "❌ Leave Declined",        "Leave request declined — peak support period.",   "warning"),
+        (uid_map.get("chiedza@irisplus.co.zw"), "⚠️ Role Drift Detected",  "Your latest submission shows role drift. Check your KPI alignment.", "warning"),
+        (uid_map.get("simba@irisplus.co.zw"),   "Meeting Summary Ready",    "IrisTrack Demo — Harare Logistics Ltd",           "success"),
+        (admin_uid,                             "New Leave Request",        "Simba Dube has submitted a leave request.",       "info"),
+        (admin_uid,                             "⚠️ Budget Alert: client_entertainment", "dept-sales has used 82% of client entertainment budget.", "warning"),
+    ]
+    for (uid, title, message, ntype) in samples:
+        if not uid:
+            continue
+        ref = db_ref.child(f"notifications/{ORG_ID}/{uid}").push()
+        ref.set({
+            "notificationId": ref.key,
+            "title":          title,
+            "message":        message,
+            "type":           ntype,
+            "read":           False,
+            "createdAt":      past_iso(days_ago=1),
+        })
+    print(f"  ✓ {len(samples)} notifications seeded")
+
+
+def print_credentials(uid_map):
+    print(f"\n{PRINT_DIVIDER}")
+    print("IRISTRACK TEST ENVIRONMENT — CREDENTIALS")
+    print(PRINT_DIVIDER)
+    print(f"Organization ID: {ORG_ID}")
+    print(f"Login URL:       https://iristrack.app/login\n")
+    print(f"{'Name':<22} {'Email':<35} {'Password':<20} {'Role'}")
+    print("─" * 100)
+    for (display_name, email, password, phone, position, dept_id, platform_role) in TEAM:
+        role_label = {"org_admin": "Org Admin", "dept_admin": "Dept Admin", "employee": "Employee"}.get(platform_role, platform_role)
+        dept_label = DEPARTMENTS.get(dept_id, {}).get("name", "—") if dept_id else "—"
+        print(f"{display_name:<22} {email:<35} {password:<20} {role_label} / {dept_label}")
+    print(PRINT_DIVIDER)
+    print("\nData seeded:")
+    print(f"  • 8 weeks of weekly submissions per employee")
+    print(f"  • {len(TASKS)} tasks with subtasks across both projects")
+    print(f"  • {len(LEAVE_REQUESTS)} leave requests (mix of approved/pending/declined)")
+    print(f"  • {len(EXPENSES)} expense claims (mix of approved/pending/flagged)")
+    print(f"  • {len(MEETINGS)} completed client meetings with full intelligence")
+    print(f"  • KPI models for Tech, Sales, Support")
+    print(f"  • 2 projects: IrisTrack v1 Launch, Harare Enterprise Pilot")
+    print(f"  • Budget allocations for all departments")
+    print(f"\nRole drift flags:  Chiedza Mhaka (Sales), Tendai Moyo (Tech — week 2)")
+    print(f"Missing this week: Chiedza Mhaka, Mazvita Chirinda (simulate missing submissions)")
+    print(f"Overdue task:      Deliver demo to Harare Logistics (Simba — check dueDateTime)")
+    print(PRINT_DIVIDER)
+
+
+# ═══════════════════════════════════════════════════════════════════════════════
+# MAIN
+# ══════════════════════════���════════════════════════════════════════════════════
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(description="IrisTrack seed script")
+    parser.add_argument("--reset", action="store_true", help="Wipe org data before seeding")
+    args = parser.parse_args()
+
+    if args.reset:
+        reset_org()
+
+    print(f"\n{'═' * 60}")
+    print("IRISTRACK SEED — IrisPlus Technologies")
+    print(f"{'═' * 60}")
+
+    # Admin user first
+    admin = next(t for t in TEAM if t[6] == "org_admin")
+    admin_uid = create_fb_user(admin[1], admin[2], admin[0])
+
+    seed_org(admin_uid)
+    seed_departments()
+    seed_kpi_models(admin_uid)
+    seed_projects(admin_uid)
+    seed_budgets()
+    uid_map = seed_users()
+    uid_map[admin[1]] = admin_uid
+
+    seed_submissions(uid_map)
+    seed_leave_requests(uid_map, admin_uid)
+    seed_expenses(uid_map, admin_uid)
+    seed_tasks(uid_map, admin_uid)
+    seed_meetings(uid_map, admin_uid)
+    seed_notifications(uid_map, admin_uid)
+
+    print(f"\n✅ Seed complete.")
+    print_credentials(uid_map)