STEVE

flowchart TD
    A([LaunchAgent fires\nevery 30 minutes]) --> B[Load config.json\n+ ~/.jira-token\n+ state.json]
    B --> C{Network ready?\nwait_for_network}
    C -- No --> Z1([Exit — launchd will retry])
    C -- Yes --> D[Scan Google Drive\nMeet Recordings via Drive API]
    D --> E{New .gdoc files\nsince lastRun?}
    E -- No --> Z2([Exit — nothing to process])
    E -- Yes --> F[For each new transcript]
    F --> G[Export doc as plain text\nDrive API /export]
    G --> H{Profile selection\nkeyword match on title}
    H --> I[agent_discover_meetings\nVertex AI Agent Engine]
    I -- Success --> J[Agent Engine: Gemini\nsummarizes transcript\nwith profile instructions]
    I -- Failure --> K[direct_discover_meetings\nCalendar API fallback]
    K --> J
    J --> L[Parse json_meetings block\nextract attendees + actions]
    L --> M{Dedup check:\nticket exists today?}
    M -- Duplicate --> N[Update existing ticket\nor skip]
    M -- New --> O[Create Jira call-log ticket\nADF description + labels]
    O --> P[Resolve attendees\n→ Jira account IDs]
    P --> Q[Set Relevant Party field\n+ Security Level]
    Q --> R{1:1 detected?}
    R -- Yes --> S[Set Jira security to\nRelevant Party Only]
    R -- No --> T[Create subtasks\nfor each action item]
    S --> T
    T --> U[Post Slack notification\nwith ticket link]
    U --> V[Update state.json\nmark file processed]
    V --> F
      

flowchart TD
    A([LaunchAgent fires\n8:00 AM weekdays]) --> B[Load config.json\nteam.json\nSlack tokens]
    B --> C[Fetch today's calendar\nGoogle Calendar API]
    C --> D[Filter: recurring + has attendees\nskip solo/cancelled/all-day]
    D --> E[For each meeting]
    E --> F{1:1 meeting?\n2 attendees}
    F -- Yes --> G[Search for 1:1 canvas\nSlack search.files]
    G --> H{Canvas found?}
    H -- Yes --> I[Use canvas content\nskip channel scan]
    H -- No --> J[Fetch DM history\nwith team member]
    J --> K[Scan team channels\nfor person context]
    K --> I
    F -- No --> L[Scan team channels\nfor all attendees]
    L --> I
    I --> M[Fetch Steve Notes\nDM-to-self scan]
    M --> N[Fetch open Jira items\nassigned to user]
    N --> O[Fetch past meeting summaries]
    O --> P{Pipeline data?\nSQLite steve.db}
    P -- Yes --> Q[Include pipeline KPIs]
    P -- No --> R[Skip pipeline section]
    Q --> S[Claude API synthesis\ngenerate prep note]
    R --> S
    S --> T[Collect all meetings]
    T --> U[Render full digest]
    U --> V{Slack configured?}
    V -- Yes --> W[Post digest to\nuser self-DM]
    V -- No --> X[Write to log file]
      

flowchart TD
    A([Triggered: UI button\nor LaunchAgent]) --> B[Load team.json\nfilter: direct_reports + self]
    B --> C[Phase A: Formal requests\nScan #ask-solutions channel]
    C --> D[For each message:\nparse SF opportunity URL]
    D --> E{SF URL found?}
    E -- Yes --> F[Resolve opportunity ID]
    F --> G[Query BigQuery\nsfdc_opportunityteammember]
    G --> H{Team member\non SF Opportunity Team?}
    H -- Yes --> I[Mark COMPLIANT]
    H -- No --> J[Mark CLAIMED_NOT_LOGGED]
    E -- No --> K[Check emoji reactions\nmatch_emoji_to_member]
    K --> L{Team member emoji?}
    L -- Yes --> M[Mark INFORMAL_NOT_LOGGED]
    L -- No --> N[Mark UNCLAIMED]
    C --> O[Phase B: Channel activity scan]
    O --> P[search_member_channels\nSlack search.messages API]
    P --> Q[Find win-, int-, ext- channels]
    Q --> R[Audit each customer channel]
    R --> S[Cross-reference SF opportunity team]
    I --> T[Consolidate → AuditLog]
    J --> T
    M --> T
    N --> T
    S --> T
    T --> U[Persist to SQLite\naudit_runs table]
    U --> V[Stream results to UI\nSSE progress events]
    V --> W{Auto-attach enabled?}
    W -- Yes --> X[sfdc_attachment.py:\nadd member to SF Opportunity Team]
    W -- No --> Y[Show in UI for\nmanual review]
      

flowchart TD
    A([LaunchAgent fires\n5:00 PM weekdays]) --> B[Compute next business day]
    B --> C[Fetch calendar\nGoogle Calendar API]
    C --> D[Detect 1:1 meetings:\nrecurring + 2 attendees\n+ team member match]
    D --> E[For each 1:1]
    E --> F[Read Team Context Canvas\nvia canvas_manager]
    F --> G[canvas_manager.read_person\nget person section]
    G --> H[Fetch last 60 DMs\nbetween user and person]
    H --> I[Scan team channels\nfor person context]
    I --> J[Fetch Steve Notes\n@person forwards]
    J --> K{Canvas already exists\nfor this date?}
    K -- Yes --> L[Skip — no duplicate]
    K -- No --> M[Claude API synthesis\nState of Mind, What's Live\nOpen Items, Agenda Hooks]
    M --> N[canvases.create API\npost canvas to Slack]
    N --> O[DM link to user\nself-DM channel]
    O --> E
      

flowchart LR
    Browser["Browser\nReact/Vite\nlocalhost:5173"] <-->|HTTP + SSE| Server["serve.js\nNode.js HTTP server\nlocalhost:5173"]
    Server <-->|Basic Auth| Jira["Jira REST API v3\nfullstory.atlassian.net"]
    Server <-->|Bearer token| Slack["Slack Web API\nslack.com/api/*"]
    Server <-->|Bearer token| Anthropic["Anthropic Claude API\napi.anthropic.com"]
    Server <-->|execFile python3| Python["Python scripts\nrun.py, morning-digest.py\nopportunity_assist/*"]
    Server <-->|SQL| DB1["projects.db\nSQLite PM data"]
    Server <-->|SQL| DB2["steve.db\nSQLite pipeline data"]
    Python <-->|REST| GCP["Google APIs\nCalendar, Drive\nVertex AI Agent Engine"]
    Python <-->|bq CLI| BQ["BigQuery\nfs-biz-intel\nSalesforce mirror tables"]
    Python <-->|OAuth| SF["Salesforce REST\nfullstory.my.salesforce.com"]
      

flowchart TD
    A([LaunchAgent fires\nevery 15 minutes]) --> B[Load bot + user tokens\nscan pending proposals from SQLite]
    B --> C[Phase 1: Detect new\ninbound DMs to STEVE bot]
    C --> D{New message?\nnot from Lane}
    D -- Yes --> E[Claude API: generate\nproposed reply]
    E --> F[Post proposal to Lane\nbot-DM with approve/reject prompt]
    F --> G[Store proposal in SQLite]
    D -- No --> H[Phase 2: Check\npending proposals]
    G --> H
    H --> I{Lane replied\nto proposal thread?}
    I -- ok --> J[Send proposed reply\nto original sender]
    I -- custom text --> K[Send Lane's text\nto original sender]
    I -- no/dismiss --> L[Drop proposal\ndelete from SQLite]
    I -- No reply yet --> M([Wait for next run])
      

flowchart TD
    A([LaunchAgent fires\nevery 30 seconds]) --> B[Load tunnel_state.json\nthread_ts + last_lane_ts]
    B --> C{Active tunnel session?\nthread_ts set?}
    C -- No --> Z([Exit])
    C -- Yes --> D[Fetch thread replies\nuser token im:history]
    D --> E{New Lane message\nsince last_lane_ts?}
    E -- No --> Z2([Exit])
    E -- Yes --> F[Build multi-turn context\nfrom thread history]
    F --> G[Claude API call\nno approval gate]
    G --> H[Post reply to thread\nbot token chat.postMessage]
    H --> I[Update last_lane_ts\nin tunnel_state.json]