hottie

m
2026-02-22 19:19:46 -05:00 · 2026-02-20 15:36:29 -05:00 · 2026-02-20 14:12:41 -05:00 · 2026-02-20 14:01:07 -05:00 · 2026-02-20 13:58:58 -05:00 · 2026-02-20 13:52:27 -05:00
25 changed files with 3244 additions and 847 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -1,12 +1,11 @@
 node_modules/
 build/

-# OAuth secrets
-credentials.json
-credentials.*
-token*.json
-accounts.json
+# OAuth secrets (inside accountsAndCredentials/, example files are NOT ignored)
+accountsAndCredentials/credentials.json
+accountsAndCredentials/accounts.json
+accountsAndCredentials/token*.json
+!accountsAndCredentials/*.example.json

 # Runtime output
-summary.json
-summary-secondary.json
+mailSummaries/
--- a/README.md
+++ b/README.md
@@ -1,272 +1,378 @@
-# Declawed: A Configurable, Promptable AI Mail Assisty Kitty
+<p align="center">
+<img src="assets/logo.png" alt="Declawed" width="120" />
+</p>

-A local Model Context Protocol (MCP) server and LLM integration platform. Built to connect to LLM APIs - be itClaude Desktop, *others*... or locally hosted models. Executes your prompts to manage your mail, while you... watch Fellini films, solve climate change, sip Mai Tais, or.... whatever. 
+# Declawed: your kuddly assisty-kitty

-Ssssimple. Siamsese, if you please.... Eats the blue-plate-crustacean for breakfast.
+Inbox brimming with stank, algorithmically-generated logs?  Wanna cut the crap and get the stuff that matters into your calendars, Atlassian, Jira, Asana, G sheets (etc., etc.) ... in two clicks?

-Infinitely mod-able.  Dead simple. Privacy centric.  
+### (Cat) nip it in the bud!!
+
+# The "why":
+
+###  Declawed is a configurable, prompt purrr-fectable LLM mail and task automation assisty-kitty.
+###  More private than other options (not purrfect *yet* - but privacy is our number one goal with every release).
+###  More accurate actions/results (read on).
+###  Eliminates the frustrating feeling you'll never get the dangling, catnip-stuffed mouse you've been chasing all week
+
+# Privacy: more than the blue-plate crustacean
+
+Your own local Model Context Protocol (MCP) server integrates with your preferred LLM API.
+Each step offers greater control, configurability and transparency over permissions.
+
+Avoid the flakey (molty?) black-box installs that are loaded with more Trojans than an Olympic Village. Silent/dark processes, data harvesting phone-homes, behavioral analytics, telemetry backdoors - the nasties lurking in the dark detritus.
+
+💩 You know lobsters eat poop, right? 💩
+
+# Simplicity
+### NLP prompts are **actually** easy and  **demonstrably**  more effective
+
+Stop drilling down byzantine menus in mail, scheduling and workflow platforms to configure filters and actions  that 1. only ever work 20% of the time 2. change in functionality and scope every two months.
+
+Write short, declarative prompts instead. It's like wrapping busywork's paws in tinfoil and tossing it in a bathtub.
+
+Prompts
+
+1. Use semantic grouping, organizing by message intent, purpose, and context.
+2. The prompt templates in our "built in" library are evaluated using, for example, cosine similarity, ROUGE scoring and real human feedback.
+3. For example: you'll consistently keep the treasure and trash the junk when you task deClawed with reviewing forums/feeds where actionable insights are gold, but only 10% of the signal.
+
+### Prompting: easily configured to cron: cleaning the litter(in)box before the stank wafts into the whole house.
+### Imagine your morning inbox or summaries brimming with a fresh, spring-meadow aroma of opportunity and insight -- not last night's litter.
+
+# -- You just might feel like it' s freakin' 1998 again.
+
+# Wiring up your kitty
+
+Assisty-kitty easily interfaces with mail and calendar and other app APIs (about any other service you want to plug in) ... it keeps things moving so you can go chase laser pointers or enjoy a 19-hour nap in a sunbeam.

 ---

-# Scope 
+# Scope and Architecture

-## Current implementation contemplates: Claude Desktop + Custom, Local Model Context Protocol Server + Commercial SMTP Server (MX'config’d properly) + your DNS-config’d XXX.YYY
+## Current implementation requires building/using:
+-- Claude Desktop (as UI - proprietary UI coming soonish)
+-- Building/Connecting a Local Model Context Protocol Server
+-- A DNS-config’d domain, with MX records pointing to:
+-- A commercial or self-hosted SMTP Server

---
+## Coming soonish:
+-- Proprietary custom UI.
+-- Support for Hugging Face models galore.
+- Support for wiring to local LLMs.

-### 1. Install: Node.js
+# Setup

- Node.js v16 or higher must be installed.
+### 1. Install Node.js (v16+ required).

 ```bash
 node --version
 npm --version
 ```

-If not installed, download from [nodejs.org](https://nodejs.org/).
+If not installed, grab it from [nodejs.org](https://nodejs.org/).

-### 2. Initialize the Project
+### 2. Clone and Install

 ```bash
-mkdir assistant
-cd assistant
-npm init -y
+git clone https://github.com/kjannette/deClawed-Assisty-Kitty.git
+cd deClawed-Assity-Kitty
+npm install
 ```

-### 3. Install Dependencies
+### 3. Set Up Google Cloud Credentials

-```bash
-npm install @modelcontextprotocol/sdk zod@3 googleapis
-npm install -D @types/node typescript
-```
-
-Create the source directory and entry file:
-
-```bash
-mkdir src
-touch src/index.ts
-```
-
-### 4. Configure the Project
-
-#### 4a. Update `package.json`
-
-Set the module type, binary entry, and build scripts:
-
-```json
-{
-  "type": "module",
-  "bin": {
-    "assistant": "./build/index.js"
-  },
-  "scripts": {
-    "build": "tsc && chmod 755 build/index.js",
-    "auth": "npm run build && node build/auth.js"
-  },
-  "files": ["build"]
-}
-```
-
-#### 4b. Create `tsconfig.json` in the project root
-
-```json
-{
-  "compilerOptions": {
-    "target": "ES2022",
-    "module": "Node16",
-    "moduleResolution": "Node16",
-    "outDir": "./build",
-    "rootDir": "./src",
-    "strict": true,
-    "esModuleInterop": true,
-    "skipLibCheck": true,
-    "forceConsistentCasingInFileNames": true
-  },
-  "include": ["src/**/*"],
-  "exclude": ["node_modules"]
-}
-```
-
-### 5. Write the Server Code
-
-The server source lives in `src/index.ts`. It registers three tools and one prompt with the MCP server:
-
- **`fetch_new_emails`** -- fetches unread Gmail messages
- **`delete_emails`** -- trashes messages by ID
- **`append_to_summary`** -- logs classified emails to `summary.json`
- **`review_emails`** (prompt) -- feeds Claude the classification instructions
-
-The auth helper lives in `src/auth.ts`, used only for the one-time OAuth setup.
-
-### 6. Set Up Google Cloud Credentials
-
-#### 6a. Create a Google Cloud Project
+#### 3a. Create a Google Cloud Project

 1. Go to [Google Cloud Console](https://console.cloud.google.com/)
 2. Sign in with the Google account that owns the target Gmail
-3. Click the project dropdown (top-left) and select **New Project**
+3. Click the project dropdown (top-left) > **New Project**
 4. Name it (e.g., `assistant-mcp`) and click **Create**
 5. Select the new project from the dropdown

-#### 6b. Enable the Gmail API
+#### 3b. Enable APIs

-1. Go to **APIs & Services > Library** ([direct link](https://console.cloud.google.com/apis/library))
-2. Search for **Gmail API**
-3. Click it, then click **Enable**
+In **APIs & Services > Library**, enable:
+- **Gmail API**
+- **Google Sheets API** (if mapping mail to sheets)
+- **Google Calendar API** (if using calendar event creation, etc.s)

-#### 6c. Configure the OAuth Consent Screen
+#### 3c. Configure the OAuth Consent Screen

 1. Go to **Google Auth Platform > Branding** (or **APIs & Services > OAuth consent screen**)
 2. Set user type to **External**, click **Create**
 3. Fill in app name, support email, and developer contact email
 4. Save and continue

-#### 6d. Add the Gmail Scope
+#### 3d. Add OAuth Scopes

-1. Go to **Google Auth Platform > Data Access** (or the Scopes page)
-2. Click **Add or remove scopes**
-3. Add: `https://www.googleapis.com/auth/gmail.modify`
-4. Save
+In **Google Auth Platform > Data Access**, add:
+- `https://www.googleapis.com/auth/gmail.modify`
+- `https://www.googleapis.com/auth/spreadsheets` (for Sheets integration)
+- `https://www.googleapis.com/auth/calendar.events` (for Calendar integration)

-#### 6e. Add Yourself as a Test User
+#### 3e. Add Yourself as a Test User

-1. Go to **Google Auth Platform > Audience**
-2. Add your Gmail address as a test user
+Go to **Google Auth Platform > Audience** and add each Gmail address you'll use.

-#### 6f. Create OAuth Client Credentials
+#### 3f. Create OAuth Client Credentials

 1. Go to **Google Auth Platform > Clients** (or **APIs & Services > Credentials**)
-2. Click **Create Client** (or **+ Create Credentials > OAuth client ID**)
-3. Application type: **Desktop app**
-4. Name it anything (e.g., `Assistant MCP Desktop`)
-5. Click **Create**
-6. **Download the JSON** file
-7. Rename it to `credentials.json`
-8. Move it to the project root: `/Users/kjannette/assistant/credentials.json`
+2. Click **Create Client** > Application type: **Desktop app**
+3. **Download the JSON**, rename it to `credentials.json`
+4. Place it in the project root

-### 7. Authorize Your Gmail Account
+### 4. Configure Accounts

-Build the project and run the auth script:
+Create file `accounts.json` in the project root. Each key is an account alias with its own token file and optional Sheets/Calendar config:

-```bash
-npm run auth
+```json
+{
+"work": {
+"label": "you@yourdomain.com",
+"tokenFile": "token.json",
+"spreadsheetId": "YOUR_GOOGLE_SHEET_ID",
+"calendarId": "primary"
+},
+"secondary": {
+"label": "you@gmail.com",
+"tokenFile": "token-secondary.json"
+}
+}
 ```

-This will:
+- **`label`** -- display name (typically the email address)
+- **`tokenFile`** -- per-account OAuth token (auto-generated during auth)
+- **`spreadsheetId`** -- Google Sheets ID for recruiter contact logging (optional)
+- **`calendarId`** -- Google Calendar ID for event creation (optional, `"primary"` uses the default calendar)
+
+### 5. Authorize Gmail Accounts
+
+Build and run the auth script for each account:
+
+```bash
+npm run auth              # authorizes the "work" account
+npm run auth -- secondary # authorizes the "secondary" account
+```
+
+Each run will:
 1. Print a URL -- open it in your browser
-2. Sign in with your Google account and click **Allow**
-3. You'll land on a "localhost refused to connect" page (this is normal)
-4. Copy the **entire URL** from the browser address bar
-5. Paste it into the terminal prompt
-6. The script extracts the auth code and saves `token.json`
+2. Sign in and click **Allow**
+3. You'll land on a "localhost refused to connect" page (normal)
+4. Copy the **entire URL** from the address bar and paste it back into the terminal
+5. The script saves the token file (e.g., `token.json` or `token-secondary.json`)

-You only need to do this once. The token auto-refreshes.
+You only need to do this once per account. Tokens auto-refresh.

-### 8. Build the Server
+### 6. Write the Prompts
+
+Two plain-text prompt files in `src/prompts/` control the workflow:
+
+| File | Phase | Purpose |
+|------|-------|---------|
+| `src/prompts/classify-emails.txt` | 1 -- Classification | Defines categories A/B/C/D and how to sort emails |
+| `src/prompts/take-action-on-emails.txt` | 2 -- Action | Tells the LLM what to do with each category (delete, log, schedule, etc.) |
+
+**Tips:**
+- Use clear, explicit category definitions with example language
+- Handle ambiguous cases (e.g., "If an email both acknowledges receipt AND requests action, classify as B")
+- Prompt files are loaded at runtime -- edit them anytime, no rebuild required
+
+### 7. Build

 ```bash
 npm run build
 ```

-This compiles `src/*.ts` into `build/*.js`.
+Compiles `src/**/*.ts` into `build/`.

-### 9. Write the Classification Prompt
+## 8. Configure Claude Desktop

-Create a file called `classify-emails.txt` in the project root. This file contains the plain-text instructions that tell Claude how to classify your emails.
-
-**Tips for writing the prompt:**
- Use clear, explicit category definitions with example language for each
- Handle ambiguous cases (e.g., "If an email both acknowledges receipt AND requests action, classify it as B")
- Define the exact actions to take for each category (delete, summarize, etc.)
- Specify what fields to include in summaries
- Keep it in plain text -- no JSON or special formatting needed
- The file is loaded at runtime, so you can edit it without rebuilding the server
-
-**File location:** Must be at the project root as `classify-emails.txt`.
-
-### 10. Configure Claude Desktop
-
-Edit the Claude Desktop config file:
+Edit your Claude Desktop config:

 ```bash
 code ~/Library/Application\ Support/Claude/claude_desktop_config.json
 ```

-Add the `assistant` server to the `mcpServers` object:
+Add the server:

 ```json
 {
-  "mcpServers": {
-    "assistant": {
-      "command": "/ABSOLUTE/PATH/TO/node",
-      "args": [
-        "/Users/kjannette/assistant/build/index.js"
-      ]
-    }
-  }
+"mcpServers": {
+"assistant": {
+ "command": "/ABSOLUTE/PATH/TO/node",
+ "args": [
+   "/ABSOLUTE/PATH/TO/deClawed-Assity-Kitty/build/index.js"
+ ]
+}
+}
 }
 ```

-Replace `/ABSOLUTE/PATH/TO/node` with the output of `which node`.
+Replace paths with the output of `which node` and your actual project location.

-### 11. Restart Claude Desktop
+## 9. Add/Configure API Keys, Credentials, and Other Secrets

-Fully quit Claude Desktop (**Cmd+Q**, not just close the window) and reopen it. The `assistant` server should now appear under **Connectors** in the chat input.
+Secret files are **gitignored** -- they never leave your machine. Example templates are provided so you know what shape each file needs to be in.
+
+#### 9a. `credentials.json`
+
+This file holds your Google OAuth client credentials. **You do not write this by hand** -- it is downloaded from the Google Cloud Console (see Step 3f above). Copy the example and then replace it with the real download:
+
+```bash
+cp credentials.example.json credentials.json
+# Now replace credentials.json with the file downloaded from Google Cloud Console.
+```
+
+The structure looks like this (the example file ships with empty values):
+
+```json
+{
+"installed": {
+ "client_id": "",
+ "project_id": "",
+ "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+ "token_uri": "https://oauth2.googleapis.com/token",
+ "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+ "client_secret": "",
+ "redirect_uris": ["http://localhost"]
+}
+}
+```
+
+#### 9b. `accounts.json`
+
+Defines each Gmail account the server manages. Copy the example and fill in your values:
+
+```bash
+cp accounts.example.json accounts.json
+```
+
+| Field | What to put here |
+|-------|-----------------|
+| `label` | The email address for this account (display only) |
+| `tokenFile` | Filename for this account's OAuth token (e.g., `token.json`) |
+| `spreadsheetId` | The ID from your Google Sheet URL: `docs.google.com/spreadsheets/d/<THIS_PART>/edit` (optional) |
+| `calendarId` | `"primary"` for your default calendar, or a specific calendar ID (optional) |
+
+Add as many accounts as you need. Each key (e.g., `"work"`, `"secondary"`) becomes the account name used in tool calls and auth commands.
+
+#### 9c. `token*.json` (auto-generated)
+
+Token files are **created automatically** when you run `npm run auth` (Step 5). You do not need to create or edit them manually. A `token.example.json` is provided for reference only -- it shows the structure but the values are populated by the OAuth flow.
+
+#### Summary of secret files
+
+| Example template | Actual file (gitignored) | How to create |
+|-----------------|--------------------------|---------------|
+| `credentials.example.json` | `credentials.json` | Download from Google Cloud Console |
+| `accounts.example.json` | `accounts.json` | Copy example, fill in your email/sheet/calendar IDs |
+| `token.example.json` | `token.json`, `token-secondary.json`, etc. | Auto-generated by `npm run auth` |
+
+### 10. Restart Claude Desktop
+
+Fully quit (**Cmd+Q**, not just close the window) and reopen. The `assistant` server should appear under **Connectors**.

 ---

-## Usage Guide
+## MCP Tools

-### Prompt Loader
+| Tool | Description |
+|------|-------------|
+| `fetch_new_emails` | Fetches unread emails for a given account. Classification and action prompts are automatically appended to the response. |
+| `delete_emails` | Moves emails to trash by Gmail message ID. Used for categories A (acknowledgements/junk/”THANKS!”/offers) and C (rejections). |
+| `append_to_summary` | Logs classified emails to per-account summary files in `mailSummaries/`. Entries older than 30 days are auto-purged. |
+| `log_contact` | Logs or updates contact info in a Google Sheet. Merges rows by email + role. |
+| `create_calendar_event` | Creates a Google Calendar event for scheduled calls/meetings. Includes meeting links, attendees and their contact info. |

-The server reads `classify-emails.txt` from the project root at runtime. To change classification behavior, edit that file directly -- no rebuild required. The updated instructions take effect on the next tool call.
+## MCP Prompts (built in as of now-ish - add your own)
+### BETTER YET - DO A PR OR FORK

-### MCP Prompt: `review_emails`
+| Prompt | Account | Description |
+|--------|---------|-------------|
+| `review_emails` | work | Loads the classification + action prompts for the work inbox |
+| `review_secondary_emails` | secondary | Same workflow, but for a second email account inbox |

-A registered MCP prompt available in Claude Desktop's Connectors menu. When invoked, it feeds Claude the full contents of `classify-emails.txt` as a user message, giving Claude all the classification criteria before it calls any tools. This is the recommended way to trigger the workflow -- it ensures Claude has the complete instructions every time.
+Invoke these from Claude Desktop's Connectors menu, or just type "Review my inbox" / "Review my secondary inbox."

-### `fetch_new_emails` Enrichment
+---

-Every time `fetch_new_emails` is called, the classification instructions from `classify-emails.txt` are appended to the response alongside the email data. This means Claude always sees the rules with the data, even if the `review_emails` prompt was not explicitly invoked. Belt and suspenders.
+## Two-Phase Workflow

-### Running the Workflow
+**Phase 1 -- Classify**

-1. Open Claude Desktop
-2. Type: **"Review my inbox"** (or invoke the `review_emails` prompt from Connectors)
-3. Claude will:
-   - Call `fetch_new_emails` to retrieve unread messages
-   - Classify each email as A, B, C, or D using the prompt instructions
-   - Call `delete_emails` for categories A and C
-   - Call `append_to_summary` for categories B and D
-4. Results are displayed in the chat and saved to `summary.json`
+The LLM calls `fetch_new_emails`, which returns email data with the classification instructions from `classify-emails.txt` appended. Each email is sorted into:

-### Key Commands
+| Category | Meaning | Action |
+|----------|---------|--------|
+| **A** | Acknowledgement / auto-reply | Delete |
+| **B** | Advancement to next step | Summarize + log |
+| **C** | Rejection | Delete |
+| **D** | Other / uncategorized | Summarize + log |
+
+**Phase 2 -- Act**
+
+Using `take-action-on-emails.txt`, the LLM:
+- Calls `delete_emails` for A + C
+- Calls `append_to_summary` for B + D
+- Calls `log_recruiter_contact` to track contacts in Sheets (if configured)
+- Calls `create_calendar_event` for any scheduled interviews/calls (if configured)
+
+---
+
+## Key Commands

 | Command | Purpose |
 |---------|---------|
-| `npm run build` | Recompile after editing `src/index.ts` |
-| `npm run auth` | Re-authorize Gmail (only if `token.json` deleted/expired) |
-| Cmd+Q Claude Desktop, reopen | Pick up server changes after a rebuild |
+| `npm run build` | Recompile after editing source files |
+| `npm run auth` | Authorize the default (work) account |
+| `npm run auth -- secondary` | Authorize the secondary account |
+| `npm test` | Run the test suite |
+| `npm run test:watch` | Run tests in watch mode |

 ---

 ## Project Structure

 ```
-assistant/
+deClawed-Assity-Kitty/
 ├── src/
-│   ├── index.ts          # MCP server source (tools + prompt)
-│   └── auth.ts           # One-time OAuth setup script
-├── build/
-│   ├── index.js          # Compiled server (Claude Desktop runs this)
-│   └── auth.js           # Compiled auth script
-├── classify-emails.txt   # Classification prompt (plain text, edit anytime)
-├── credentials.json      # Google OAuth client credentials (from Cloud Console)
-├── token.json            # Gmail access/refresh token (auto-generated)
-├── summary.json          # Output file where B/D emails are logged
-├── package.json          # Project config and scripts
-├── tsconfig.json         # TypeScript compiler config
-└── README.md             # This file
+│   ├── index.ts                         # Entry point -- imports modules, starts server
+│   ├── McpServer.ts                     # MCP server instance
+│   ├── auth.ts                          # Multi-account OAuth setup script
+│   ├── loaders/
+│   │   └── prompt-config-loaders.ts     # Account, prompt, and OAuth client loaders
+│   ├── prompt-controller-service/
+│   │   └── prompt-controller-service.ts # MCP prompt registration
+│   ├── prompts/
+│   │   ├── classify-emails.txt          # Phase 1: classification instructions
+│   │   └── take-action-on-emails.txt    # Phase 2: action instructions
+│   └── tools/
+│       ├── tools-email.ts               # fetch, delete, append_to_summary
+│       ├── tools-calendar.ts            # create_calendar_event
+│       └── tools-spreadsheet.ts         # log_recruiter_contact
+├── accountsAndCredentials/
+│   ├── accounts.json                    # Multi-account configuration (gitignored)
+│   ├── accounts.example.json            # Template for accounts.json
+│   ├── credentials.json                 # Google OAuth client credentials (gitignored)
+│   ├── credentials.example.json         # Template for credentials.json
+│   ├── token.json                       # OAuth token -- work account (gitignored, auto-generated)
+│   ├── token-secondary.json             # OAuth token -- secondary account (gitignored, auto-generated)
+│   └── token.example.json              # Template showing token structure
+├── test/
+│   ├── fixtures/
+│   │   └── mock-emails.ts              # Mock Gmail API responses
+│   ├── integration/
+│   │   └── email-workflow.test.ts       # Integration tests
+│   └── unit/
+│       └── email-parsing.test.ts        # Unit tests for parsing helpers
+├── mailSummaries/                       # Per-account summary output (gitignored, auto-generated)
+├── build/                               # Compiled JS (auto-generated)
+├── assets/
+│   └── logo.png                         # Project logo
+├── package.json
+├── tsconfig.json
+├── vitest.config.ts
+├── .gitignore
+└── README.md
 ```
-
-
--- a/accountsAndCredentials/accounts.example.json
+++ b/accountsAndCredentials/accounts.example.json
@@ -0,0 +1,12 @@
+{
+  "work": {
+    "label": "",
+    "tokenFile": "token.json",
+    "spreadsheetId": "",
+    "calendarId": "primary"
+  },
+  "secondary": {
+    "label": "",
+    "tokenFile": "token-secondary.json"
+  }
+}
--- a/accountsAndCredentials/credentials.example.json
+++ b/accountsAndCredentials/credentials.example.json
@@ -0,0 +1,11 @@
+{
+  "installed": {
+    "client_id": "",
+    "project_id": "",
+    "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+    "token_uri": "https://oauth2.googleapis.com/token",
+    "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+    "client_secret": "",
+    "redirect_uris": ["http://localhost"]
+  }
+}
--- a/accountsAndCredentials/token.example.json
+++ b/accountsAndCredentials/token.example.json
@@ -0,0 +1,7 @@
+{
+  "access_token": "",
+  "refresh_token": "",
+  "scope": "https://www.googleapis.com/auth/spreadsheets https://www.googleapis.com/auth/gmail.modify https://www.googleapis.com/auth/calendar.events",
+  "token_type": "Bearer",
+  "expiry_date": 0
+}
--- a/assets/logo.png
+++ b/assets/logo.png
--- a/classify-emails.txt
+++ b/classify-emails.txt
@@ -1,30 +0,0 @@
-You are an expert Executive Assistant AI specialized in email management and productivity. Your goal is to organize, prioritize, and summarize incoming emails to maximize user efficiency.
-
-I have been applying for jobs, which generates a large volume of responses. Review my inbox and apply the following instructions to all new emails.
-
-STEP 1: Constraints
- Do not make up information.
-
-STEP 2: CLASSIFY each email into exactly one category.
-
-Category A - Acknowledgement Only
-The employer confirms receipt of my application but requires no action from me. Typical language: "We received your application," "Your application is under review," "We will contact you if selected." No next steps are requested.
-
-Category B - Advancement to Next Step
-The employer wants to move forward. This includes: invitations to schedule a phone screen or interview, requests to complete an assessment or assignment, requests for additional information or documents, or any communication that requires a response or action from me. If an email both acknowledges receipt AND requests action, classify it as B.
-
-Category C - Rejection
-The employer declines to move forward. Typical language: "We have decided to pursue other candidates," "Unfortunately, you were not selected," "We will not be moving forward with your application."
-
-Category D - Other
-The email does not fit into categories A, B, or C. This includes non-job-application emails, newsletters, promotional content, or ambiguous messages that do not clearly match another category.
-
-STEP 3: DELETE emails classified as Category A and Category C.
-
-STEP 4: SUMMARIZE emails classified as Category B and Category D. For each, include:
-1. Sender name and email address
-2. Email subject line
-3. Date and time received
-4. Category (B or D)
-5. Suggested action I should take
-
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@@ -8,7 +8,9 @@
  },
  "scripts": {
    "build": "tsc && chmod 755 build/index.js",
-    "auth": "npm run build && node build/auth.js"
+    "auth": "npm run build && node build/auth.js",
+    "test": "vitest run",
+    "test:watch": "vitest"
  },
  "files": [
    "build"
@@ -23,6 +25,7 @@
  },
  "devDependencies": {
    "@types/node": "^25.2.3",
-    "typescript": "^5.9.3"
+    "typescript": "^5.9.3",
+    "vitest": "^4.0.18"
  }
 }
--- a/src/McpServer.ts
+++ b/src/McpServer.ts
@@ -0,0 +1,6 @@
+import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+
+export const server = new McpServer({
+  name: "assistant",
+  version: "1.0.0",
+});
--- a/src/auth.ts
+++ b/src/auth.ts
@@ -5,21 +5,47 @@ import readline from "readline";

 const __dirname = path.dirname(new URL(import.meta.url).pathname);
 const PROJECT_ROOT = path.resolve(__dirname, "..");
-const CREDENTIALS_PATH = path.join(PROJECT_ROOT, "credentials.json");
-const TOKEN_PATH = path.join(PROJECT_ROOT, "token.json");
+const SECRETS_DIR = path.join(PROJECT_ROOT, "accountsAndCredentials");
+const CREDENTIALS_PATH = path.join(SECRETS_DIR, "credentials.json");
+const ACCOUNTS_PATH = path.join(SECRETS_DIR, "accounts.json");

-// Gmail modify scope: read, send, delete, and manage labels
-const SCOPES = ["https://www.googleapis.com/auth/gmail.modify"];
+const SCOPES = [
+  "https://www.googleapis.com/auth/gmail.modify",
+  "https://www.googleapis.com/auth/spreadsheets",
+  "https://www.googleapis.com/auth/calendar.events",
+];
+
+function resolveTokenPath(accountKey: string): string {
+  if (!fs.existsSync(ACCOUNTS_PATH)) {
+    throw new Error(`Missing ${ACCOUNTS_PATH}. Create accounts.json first.`);
+  }
+  const accounts = JSON.parse(fs.readFileSync(ACCOUNTS_PATH, "utf-8"));
+  const acct = accounts[accountKey];
+  if (!acct) {
+    const available = Object.keys(accounts).join(", ");
+    throw new Error(
+      `Unknown account "${accountKey}". Available: ${available}`
+    );
+  }
+  return path.join(SECRETS_DIR, acct.tokenFile);
+}

 async function authorize(): Promise<void> {
+  const accountKey = process.argv[2] || "work";
+  const tokenPath = resolveTokenPath(accountKey);
+
+  console.log(`Authorizing account: "${accountKey}"`);
+  console.log(`Token file: ${tokenPath}`);
+  console.log(`Scopes: ${SCOPES.join(", ")}\n`);
+
  if (!fs.existsSync(CREDENTIALS_PATH)) {
    console.error(
      `Missing ${CREDENTIALS_PATH}\n\n` +
        "To create this file:\n" +
        "1. Go to https://console.cloud.google.com/\n" +
-        "2. Create a project and enable the Gmail API\n" +
+        "2. Create a project and enable the Gmail, Sheets, and Calendar APIs\n" +
        "3. Create OAuth 2.0 credentials (Desktop app type)\n" +
-        "4. Download the JSON and save it as credentials.json in the project root\n"
+        "4. Download the JSON and save it as credentials.json in the accountsAndCredentials/ folder\n"
    );
    process.exit(1);
  }
@@ -34,16 +60,18 @@ async function authorize(): Promise<void> {
    redirect_uris[0]
  );

-  // Check if we already have a valid token
-  if (fs.existsSync(TOKEN_PATH)) {
-    const token = JSON.parse(fs.readFileSync(TOKEN_PATH, "utf-8"));
+  if (fs.existsSync(tokenPath)) {
+    const token = JSON.parse(fs.readFileSync(tokenPath, "utf-8"));
    oAuth2Client.setCredentials(token);
-    console.log("Token already exists at:", TOKEN_PATH);
-    console.log("To re-authorize, delete token.json and run this script again.");
+    console.log("Token already exists at:", tokenPath);
+    console.log(
+      "To re-authorize with new scopes, delete the token file and run again:\n" +
+        `  rm ${tokenPath}\n` +
+        `  npm run auth -- ${accountKey}`
+    );
    return;
  }

-  // Generate auth URL and prompt user
  const authUrl = oAuth2Client.generateAuthUrl({
    access_type: "offline",
    scope: SCOPES,
@@ -69,7 +97,6 @@ async function authorize(): Promise<void> {
    );
  });

-  // Extract the code whether they pasted the full URL or just the code
  let code = rawInput;
  if (rawInput.includes("code=")) {
    const url = new URL(rawInput);
@@ -81,8 +108,8 @@ async function authorize(): Promise<void> {
  const { tokens } = await oAuth2Client.getToken(code);
  oAuth2Client.setCredentials(tokens);

-  fs.writeFileSync(TOKEN_PATH, JSON.stringify(tokens, null, 2));
-  console.log("\nToken saved to:", TOKEN_PATH);
+  fs.writeFileSync(tokenPath, JSON.stringify(tokens, null, 2));
+  console.log("\nToken saved to:", tokenPath);
  console.log("You can now start the MCP server.");
 }

--- a/src/index.ts
+++ b/src/index.ts
@@ -1,488 +1,18 @@
-import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+#!/usr/bin/env node
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
-import { z } from "zod";
-import { google, gmail_v1 } from "googleapis";
-import fs from "fs";
-import path from "path";
+import { server } from "./McpServer.js";

-// ---------------------------------------------------------------------------
-// Paths — resolved relative to the compiled build/ directory, up one level
-// to the project root where credentials.json, token.json, and summary.json live.
-// ---------------------------------------------------------------------------
-const __dirname = path.dirname(new URL(import.meta.url).pathname);
-const PROJECT_ROOT = path.resolve(__dirname, "..");
-const CREDENTIALS_PATH = path.join(PROJECT_ROOT, "credentials.json");
-const ACCOUNTS_PATH = path.join(PROJECT_ROOT, "accounts.json");
-const PROMPT_PATH = path.join(PROJECT_ROOT, "classify-emails.txt");
+// Side-effect imports: each module registers its prompts/tools on the server
+import "./prompt-controller-service/prompt-controller-service.js";
+import "./tools/tools-email.js";
+import "./tools/tools-spreadsheet.js";
+import "./tools/tools-calendar.js";

-// ---------------------------------------------------------------------------
-// Account configuration
-// ---------------------------------------------------------------------------
-interface AccountConfig {
-  label: string;
-  tokenFile: string;
-}
-
-interface AccountsMap {
-  [key: string]: AccountConfig;
-}
-
-function loadAccounts(): AccountsMap {
-  if (!fs.existsSync(ACCOUNTS_PATH)) {
-    throw new Error(`Missing accounts.json at ${ACCOUNTS_PATH}.`);
-  }
-  return JSON.parse(fs.readFileSync(ACCOUNTS_PATH, "utf-8"));
-}
-
-function getTokenPath(account: string): string {
-  const accounts = loadAccounts();
-  const acct = accounts[account];
-  if (!acct) {
-    const available = Object.keys(accounts).join(", ");
-    throw new Error(
-      `Unknown account "${account}". Available accounts: ${available}`
-    );
-  }
-  return path.join(PROJECT_ROOT, acct.tokenFile);
-}
-
-function getSummaryPath(account: string): string {
-  if (account === "work") {
-    return path.join(PROJECT_ROOT, "summary.json");
-  }
-  return path.join(PROJECT_ROOT, `summary-${account}.json`);
-}
-
-const VALID_ACCOUNTS = ["work", "secondary"] as const;
-const accounts = loadAccounts();
-const accountDescription = VALID_ACCOUNTS
-  .map((key) => `"${key}" (${accounts[key]?.label ?? key})`)
-  .join(" or ");
-const accountSchema = z
-  .enum(VALID_ACCOUNTS)
-  .describe(`Which email account to use: ${accountDescription}`);
-
-// ---------------------------------------------------------------------------
-// Load classification prompt
-// ---------------------------------------------------------------------------
-function loadClassificationPrompt(): string {
-  if (!fs.existsSync(PROMPT_PATH)) {
-    console.error(`Warning: ${PROMPT_PATH} not found. Classification instructions will be missing.`);
-    return "";
-  }
-  return fs.readFileSync(PROMPT_PATH, "utf-8");
-}
-
-// ---------------------------------------------------------------------------
-// Gmail auth helper — parameterized by account key
-// ---------------------------------------------------------------------------
-function getGmailClient(account: string): gmail_v1.Gmail {
-  const tokenPath = getTokenPath(account);
-
-  if (!fs.existsSync(CREDENTIALS_PATH)) {
-    throw new Error(
-      `Missing credentials.json at ${CREDENTIALS_PATH}. Run "npm run auth" first.`
-    );
-  }
-  if (!fs.existsSync(tokenPath)) {
-    throw new Error(
-      `Missing token file at ${tokenPath} for account "${account}". Run "npm run auth" first.`
-    );
-  }
-
-  const credentials = JSON.parse(fs.readFileSync(CREDENTIALS_PATH, "utf-8"));
-  const { client_id, client_secret, redirect_uris } =
-    credentials.installed || credentials.web;
-
-  const oAuth2Client = new google.auth.OAuth2(
-    client_id,
-    client_secret,
-    redirect_uris[0]
-  );
-
-  const token = JSON.parse(fs.readFileSync(tokenPath, "utf-8"));
-  oAuth2Client.setCredentials(token);
-
-  // Persist refreshed tokens automatically
-  oAuth2Client.on("tokens", (newTokens) => {
-    const current = JSON.parse(fs.readFileSync(tokenPath, "utf-8"));
-    fs.writeFileSync(
-      tokenPath,
-      JSON.stringify({ ...current, ...newTokens }, null, 2)
-    );
-    console.error(`Token refreshed and saved for account "${account}".`);
-  });
-
-  return google.gmail({ version: "v1", auth: oAuth2Client });
-}
-
-// ---------------------------------------------------------------------------
-// Email parsing helpers
-// ---------------------------------------------------------------------------
-function getHeader(
-  headers: gmail_v1.Schema$MessagePartHeader[] | undefined,
-  name: string
-): string {
-  if (!headers) return "";
-  const header = headers.find(
-    (h) => h.name?.toLowerCase() === name.toLowerCase()
-  );
-  return header?.value ?? "";
-}
-
-function decodeBody(message: gmail_v1.Schema$Message): string {
-  const parts = message.payload?.parts;
-  let encoded = "";
-
-  if (parts) {
-    // Multipart message — prefer text/plain
-    const textPart = parts.find((p) => p.mimeType === "text/plain");
-    encoded = textPart?.body?.data ?? "";
-
-    // Fallback to text/html if no plain text
-    if (!encoded) {
-      const htmlPart = parts.find((p) => p.mimeType === "text/html");
-      encoded = htmlPart?.body?.data ?? "";
-    }
-  } else {
-    // Single-part message
-    encoded = message.payload?.body?.data ?? "";
-  }
-
-  if (!encoded) {
-    return message.snippet ?? "";
-  }
-
-  return Buffer.from(encoded, "base64url").toString("utf-8");
-}
-
-// ---------------------------------------------------------------------------
-// MCP Server
-// ---------------------------------------------------------------------------
-const server = new McpServer({
-  name: "assistant",
-  version: "1.0.0",
-});
-
-// ---------------------------------------------------------------------------
-// Prompt: review_emails (work account)
-// ---------------------------------------------------------------------------
-server.registerPrompt(
-  "review_emails",
-  {
-    description:
-      `Review WORK inbox (${accounts.work?.label ?? "work"}): classify job application emails (A/B/C/D), delete A+C, summarize B+D.`,
-  },
-  () => {
-    const instructions = loadClassificationPrompt();
-    return {
-      messages: [
-        {
-          role: "user" as const,
-          content: {
-            type: "text" as const,
-            text:
-              `ACCOUNT: Use account = "work" for ALL tool calls in this session.\n\n` +
-              (instructions ||
-                "Review my new emails and classify them by job application category."),
-          },
-        },
-      ],
-    };
-  }
-);
-
-// ---------------------------------------------------------------------------
-// Prompt: review_secondary_emails (secondary account)
-// ---------------------------------------------------------------------------
-server.registerPrompt(
-  "review_secondary_emails",
-  {
-    description:
-      `Review SECONDARY inbox (${accounts.secondary?.label ?? "secondary"}): classify job application emails (A/B/C/D), delete A+C, summarize B+D.`,
-  },
-  () => {
-    const instructions = loadClassificationPrompt();
-    return {
-      messages: [
-        {
-          role: "user" as const,
-          content: {
-            type: "text" as const,
-            text:
-              `ACCOUNT: Use account = "secondary" for ALL tool calls in this session.\n\n` +
-              (instructions ||
-                "Review my new emails and classify them by job application category."),
-          },
-        },
-      ],
-    };
-  }
-);
-
-// ---------------------------------------------------------------------------
-// Tool: fetch_new_emails
-// ---------------------------------------------------------------------------
-server.registerTool(
-  "fetch_new_emails",
-  {
-    description:
-      "Fetch unread emails from a Gmail inbox. Returns sender, date, " +
-      "subject, message ID, and body text for each message. The message IDs " +
-      "can be passed to delete_emails later. Specify which account to fetch from.",
-    inputSchema: {
-      account: accountSchema,
-      maxResults: z
-        .number()
-        .min(1)
-        .max(100)
-        .describe("Maximum number of unread emails to fetch (1-100)"),
-    },
-  },
-  async ({ account, maxResults }) => {
-    try {
-      const gmail = getGmailClient(account);
-
-      const listResponse = await gmail.users.messages.list({
-        userId: "me",
-        q: "is:unread",
-        maxResults,
-      });
-
-      const messageIds = listResponse.data.messages ?? [];
-
-      if (messageIds.length === 0) {
-        return {
-          content: [{ type: "text" as const, text: "No unread emails found." }],
-        };
-      }
-
-      const emails: string[] = [];
-
-      for (const msg of messageIds) {
-        const detail = await gmail.users.messages.get({
-          userId: "me",
-          id: msg.id!,
-          format: "full",
-        });
-
-        const headers = detail.data.payload?.headers;
-        const from = getHeader(headers, "From");
-        const subject = getHeader(headers, "Subject");
-        const date = getHeader(headers, "Date");
-        const body = decodeBody(detail.data);
-
-        // Truncate body to avoid overwhelming the context window
-        const truncatedBody =
-          body.length > 2000 ? body.substring(0, 2000) + "\n[...truncated]" : body;
-
-        emails.push(
-          [
-            `MESSAGE_ID: ${msg.id}`,
-            `FROM: ${from}`,
-            `DATE: ${date}`,
-            `SUBJECT: ${subject}`,
-            `BODY:\n${truncatedBody}`,
-          ].join("\n")
-        );
-      }
-
-      const classificationInstructions = loadClassificationPrompt();
-      const instructionsBlock = classificationInstructions
-        ? `\n\n${"=".repeat(60)}\nCLASSIFICATION INSTRUCTIONS:\n${"=".repeat(60)}\n${classificationInstructions}`
-        : "";
-
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text:
-              `Found ${emails.length} unread email(s):\n\n` +
-              `${"=".repeat(60)}\n${emails.join(`\n${"=".repeat(60)}\n`)}` +
-              instructionsBlock,
-          },
-        ],
-      };
-    } catch (error) {
-      const errMsg = error instanceof Error ? error.message : String(error);
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text: `Error fetching emails: ${errMsg}`,
-          },
-        ],
-      };
-    }
-  }
-);
-
-// ---------------------------------------------------------------------------
-// Tool: delete_emails
-// ---------------------------------------------------------------------------
-server.registerTool(
-  "delete_emails",
-  {
-    description:
-      "Move emails to trash by their Gmail message IDs. Use this for " +
-      "category A (acknowledgements) and category C (rejections) emails. " +
-      "Specify which account the emails belong to.",
-    inputSchema: {
-      account: accountSchema,
-      messageIds: z
-        .array(z.string())
-        .describe("Array of Gmail message IDs to move to trash"),
-    },
-  },
-  async ({ account, messageIds }) => {
-    try {
-      const gmail = getGmailClient(account);
-      const results: string[] = [];
-
-      for (const id of messageIds) {
-        try {
-          await gmail.users.messages.trash({
-            userId: "me",
-            id,
-          });
-          results.push(`Trashed: ${id}`);
-        } catch (err) {
-          const errMsg = err instanceof Error ? err.message : String(err);
-          results.push(`Failed to trash ${id}: ${errMsg}`);
-        }
-      }
-
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text: `Delete results:\n${results.join("\n")}`,
-          },
-        ],
-      };
-    } catch (error) {
-      const errMsg = error instanceof Error ? error.message : String(error);
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text: `Error deleting emails: ${errMsg}`,
-          },
-        ],
-      };
-    }
-  }
-);
-
-// ---------------------------------------------------------------------------
-// Tool: append_to_summary
-// ---------------------------------------------------------------------------
-interface SummaryEntry {
-  senderName: string;
-  senderEmail: string;
-  dateReceived: string;
-  subject: string;
-  category: "B" | "D";
-  addedAt: string;
-}
-
-server.registerTool(
-  "append_to_summary",
-  {
-    description:
-      "Append classified email entries to the local summary file. Use this " +
-      "for category B (advancement to next step) and category D (other) emails. " +
-      "Each entry records the sender, date, subject, and category. " +
-      "Specify which account the emails belong to.",
-    inputSchema: {
-      account: accountSchema,
-      entries: z
-        .array(
-          z.object({
-            senderName: z.string().describe("Name of the sender"),
-            senderEmail: z.string().describe("Email address of the sender"),
-            dateReceived: z
-              .string()
-              .describe("Date and time the email was received"),
-            subject: z.string().describe("Email subject line"),
-            category: z
-              .enum(["B", "D"])
-              .describe(
-                "Category: B = advancement to next step, D = other/uncategorized"
-              ),
-          })
-        )
-        .describe("Array of email summary entries to append"),
-    },
-  },
-  async ({ account, entries }) => {
-    try {
-      const summaryPath = getSummaryPath(account);
-
-      // Load existing summary or start fresh
-      let summary: SummaryEntry[] = [];
-      if (fs.existsSync(summaryPath)) {
-        summary = JSON.parse(fs.readFileSync(summaryPath, "utf-8"));
-      }
-
-      const now = new Date();
-      const nowIso = now.toISOString();
-      const newEntries: SummaryEntry[] = entries.map((e) => ({
-        ...e,
-        addedAt: nowIso,
-      }));
-
-      summary.push(...newEntries);
-
-      // Purge entries older than 30 days
-      const RETENTION_MS = 30 * 24 * 60 * 60 * 1000;
-      const cutoff = now.getTime() - RETENTION_MS;
-      const beforePurge = summary.length;
-      summary = summary.filter(
-        (entry) => new Date(entry.addedAt).getTime() >= cutoff
-      );
-      const purged = beforePurge - summary.length;
-
-      fs.writeFileSync(summaryPath, JSON.stringify(summary, null, 2));
-
-      const purgeNote = purged > 0
-        ? `\nPurged ${purged} entry/entries older than 30 days.`
-        : "";
-
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text:
-              `Appended ${newEntries.length} entry/entries to summary.\n` +
-              `Total entries in summary: ${summary.length}\n` +
-              `Summary file: ${summaryPath}` +
-              purgeNote,
-          },
-        ],
-      };
-    } catch (error) {
-      const errMsg = error instanceof Error ? error.message : String(error);
-      return {
-        content: [
-          {
-            type: "text" as const,
-            text: `Error appending to summary: ${errMsg}`,
-          },
-        ],
-      };
-    }
-  }
-);
-
-// ---------------------------------------------------------------------------
-// Start server
-// ---------------------------------------------------------------------------
-async function main(): Promise<void> {
+const main = async (): Promise<void> => {
  const transport = new StdioServerTransport();
  await server.connect(transport);
  console.error("Assistant MCP Server running on stdio");
-}
+};

 main().catch((error) => {
  console.error("Fatal error in main():", error);
--- a/src/loaders/prompt-config-loaders.ts
+++ b/src/loaders/prompt-config-loaders.ts
@@ -0,0 +1,149 @@
+import { z } from "zod";
+import { google, gmail_v1, sheets_v4, calendar_v3 } from "googleapis";
+import { OAuth2Client } from "google-auth-library";
+import fs from "fs";
+import path from "path";
+
+// ---------------------------------------------------------------------------
+// Paths
+// ---------------------------------------------------------------------------
+const __dirname = path.dirname(new URL(import.meta.url).pathname);
+export const PROJECT_ROOT = path.resolve(__dirname, "..", "..");
+const SECRETS_DIR = path.join(PROJECT_ROOT, "accountsAndCredentials");
+const CREDENTIALS_PATH = path.join(SECRETS_DIR, "credentials.json");
+const ACCOUNTS_PATH = path.join(SECRETS_DIR, "accounts.json");
+const PROMPTS_DIR = path.join(PROJECT_ROOT, "src", "prompts");
+const CLASSIFY_PROMPT_PATH = path.join(PROMPTS_DIR, "classify-emails.txt");
+const ACTION_PROMPT_PATH = path.join(PROMPTS_DIR, "take-action-on-emails.txt");
+
+// ---------------------------------------------------------------------------
+// Account configuration
+// ---------------------------------------------------------------------------
+export interface AccountConfig {
+  label: string;
+  tokenFile: string;
+  spreadsheetId?: string;
+  calendarId?: string;
+}
+
+export interface AccountsMap {
+  [key: string]: AccountConfig;
+}
+
+export const loadAccounts = (): AccountsMap => {
+  if (!fs.existsSync(ACCOUNTS_PATH)) {
+    throw new Error(`Missing accounts.json at ${ACCOUNTS_PATH}.`);
+  }
+  return JSON.parse(fs.readFileSync(ACCOUNTS_PATH, "utf-8"));
+};
+
+export const getTokenPath = (account: string): string => {
+  const accts = loadAccounts();
+  const acct = accts[account];
+  if (!acct) {
+    const available = Object.keys(accts).join(", ");
+    throw new Error(
+      `Unknown account "${account}". Available accounts: ${available}`
+    );
+  }
+  return path.join(SECRETS_DIR, acct.tokenFile);
+};
+
+export const getSummaryPath = (account: string): string => {
+  if (account === "work") {
+    return path.join(PROJECT_ROOT, "mailSummaries", "summary.json");
+  }
+  return path.join(PROJECT_ROOT, "mailSummaries", `summary-${account}.json`);
+};
+
+export const VALID_ACCOUNTS = ["work", "secondary"] as const;
+export const accounts = loadAccounts();
+
+const accountDescription = VALID_ACCOUNTS
+  .map((key) => `"${key}" (${accounts[key]?.label ?? key})`)
+  .join(" or ");
+
+export const accountSchema = z
+  .enum(VALID_ACCOUNTS)
+  .describe(`Which email account to use: ${accountDescription}`);
+
+// ---------------------------------------------------------------------------
+// Prompt loaders
+// ---------------------------------------------------------------------------
+const loadPromptFile = (filePath: string, label: string): string => {
+  if (!fs.existsSync(filePath)) {
+    console.error(`Warning: ${filePath} not found. ${label} will be missing.`);
+    return "";
+  }
+  return fs.readFileSync(filePath, "utf-8");
+};
+
+export const loadClassificationPrompt = (): string =>
+  loadPromptFile(CLASSIFY_PROMPT_PATH, "Classification instructions");
+
+export const loadActionPrompt = (): string =>
+  loadPromptFile(ACTION_PROMPT_PATH, "Action instructions");
+
+// ---------------------------------------------------------------------------
+// Auth helpers — generic OAuth2 client, then service-specific factories
+// ---------------------------------------------------------------------------
+export const getOAuth2Client = (account: string): OAuth2Client => {
+  const tokenPath = getTokenPath(account);
+
+  if (!fs.existsSync(CREDENTIALS_PATH)) {
+    throw new Error(
+      `Missing credentials.json at ${CREDENTIALS_PATH}. Run "npm run auth" first.`
+    );
+  }
+  if (!fs.existsSync(tokenPath)) {
+    throw new Error(
+      `Missing token file at ${tokenPath} for account "${account}". Run "npm run auth" first.`
+    );
+  }
+
+  const credentials = JSON.parse(fs.readFileSync(CREDENTIALS_PATH, "utf-8"));
+  const { client_id, client_secret, redirect_uris } =
+    credentials.installed || credentials.web;
+
+  const oAuth2Client = new google.auth.OAuth2(
+    client_id,
+    client_secret,
+    redirect_uris[0]
+  );
+
+  const token = JSON.parse(fs.readFileSync(tokenPath, "utf-8"));
+  oAuth2Client.setCredentials(token);
+
+  oAuth2Client.on("tokens", (newTokens) => {
+    const current = JSON.parse(fs.readFileSync(tokenPath, "utf-8"));
+    fs.writeFileSync(
+      tokenPath,
+      JSON.stringify({ ...current, ...newTokens }, null, 2)
+    );
+    console.error(`Token refreshed and saved for account "${account}".`);
+  });
+
+  return oAuth2Client;
+};
+
+export const getGmailClient = (account: string): gmail_v1.Gmail =>
+  google.gmail({ version: "v1", auth: getOAuth2Client(account) });
+
+export const getSheetsClient = (account: string): sheets_v4.Sheets =>
+  google.sheets({ version: "v4", auth: getOAuth2Client(account) });
+
+export const getCalendarClient = (account: string): calendar_v3.Calendar =>
+  google.calendar({ version: "v3", auth: getOAuth2Client(account) });
+
+export const getSpreadsheetId = (account: string): string => {
+  const acct = accounts[account];
+  if (!acct?.spreadsheetId || acct.spreadsheetId === "PASTE_YOUR_SHEET_ID_HERE") {
+    throw new Error(
+      `No spreadsheetId configured for account "${account}" in accounts.json.`
+    );
+  }
+  return acct.spreadsheetId;
+};
+
+export const getCalendarId = (account: string): string =>
+  accounts[account]?.calendarId ?? "primary";
--- a/src/prompt-controller-service/prompt-controller-service.ts
+++ b/src/prompt-controller-service/prompt-controller-service.ts
@@ -0,0 +1,64 @@
+import { server } from "../McpServer.js";
+import {
+  accounts,
+  loadClassificationPrompt,
+  loadActionPrompt,
+} from "../loaders/prompt-config-loaders.js";
+
+// ---------------------------------------------------------------------------
+// Prompt: review_emails (work account)
+// ---------------------------------------------------------------------------
+server.registerPrompt(
+  "review_emails",
+  {
+    description:
+      `Review WORK inbox (${accounts.work?.label ?? "work"}): classify emails, delete A+C, summarize B+D, log B to spreadsheet, create calendar events.`,
+  },
+  () => {
+    const phase1 = loadClassificationPrompt();
+    const phase2 = loadActionPrompt();
+    return {
+      messages: [
+        {
+          role: "user" as const,
+          content: {
+            type: "text" as const,
+            text:
+              `ACCOUNT: Use account = "work" for ALL tool calls in this session.\n\n` +
+              (phase1 || "Review my new emails and classify them by job application category.") +
+              (phase2 ? `\n\n${phase2}` : ""),
+          },
+        },
+      ],
+    };
+  }
+);
+
+// ---------------------------------------------------------------------------
+// Prompt: review_secondary_emails (secondary account)
+// ---------------------------------------------------------------------------
+server.registerPrompt(
+  "review_secondary_emails",
+  {
+    description:
+      `Review SECONDARY inbox (${accounts.secondary?.label ?? "secondary"}): classify emails, delete A+C, summarize B+D, log B to spreadsheet, create calendar events.`,
+  },
+  () => {
+    const phase1 = loadClassificationPrompt();
+    const phase2 = loadActionPrompt();
+    return {
+      messages: [
+        {
+          role: "user" as const,
+          content: {
+            type: "text" as const,
+            text:
+              `ACCOUNT: Use account = "secondary" for ALL tool calls in this session.\n\n` +
+              (phase1 || "Review my new emails and classify them by job application category.") +
+              (phase2 ? `\n\n${phase2}` : ""),
+          },
+        },
+      ],
+    };
+  }
+);
--- a/src/prompts/classify-emails.txt
+++ b/src/prompts/classify-emails.txt
@@ -21,10 +21,11 @@ The email does not fit into categories A, B, or C. This includes non-job-applica

 STEP 3: DELETE emails classified as Category A and Category C.

-STEP 4: SUMMARIZE emails classified as Category B and Category D. For each, include:
+STEP 4: ("Anti step") -  NEVER DELETE Category B emails.
+
+STEP 5: SUMMARIZE emails classified as Category B and Category D. For each, include:
 1. Sender name and email address
 2. Email subject line
 3. Date and time received
 4. Category (B or D)
 5. Suggested action I should take
-
--- a/src/prompts/take-action-on-emails.txt
+++ b/src/prompts/take-action-on-emails.txt
@@ -0,0 +1,45 @@
+PHASE 2: TAKE ACTION ON CATEGORY B EMAILS
+
+After completing classification (Phase 1), perform the following actions for each email classified as Category B (Advancement to Next Step).
+
+STEP 1: LOG TO SPREADSHEET
+For each Category B email, extract as much of the following information as possible from the email contents and log it using the log_recruiter_contact tool:
+
+A column exists for:
+
+- Recruiter Name
+- Recruiter Email
+- Recruiter Phone/Tel
+- Company/Role the recruiter seeks to fill
+- First Contact: the date and time the email was received
+- Subsequent Contacts: any follow-up communication with this recruiter about this role
+- Recruiter Call Scheduled: if the email contains scheduling information, extract ALL details — date, time, platform (Zoom, MS Teams, Google Meet, etc.), meeting link, phone number to call — and note whether they confirm having your cell number or might not have it
+
+A row should already exists for the same recruiter email + company/role combination (from a previous email), the tool will UPDATE the existing row. Provide all available fields and the tool handles merging.
+
+STEP 2: CREATE CALENDAR EVENTS
+Immediately after logging to the spreadsheet, check whether ANY of these fields were populated or updated:
+- Recruiter Call Scheduled
+- Company First Interview
+- Company Second Interview
+
+For EACH of the above fields that contains a date/time, create a Google Calendar event using the create_calendar_event tool:
+- Title format: "[<Recruiter NaME> Call] Company - Role" or "[First Interview] Company - Role" or "[Second Interview] Company - Role"
+- Start date/time: extracted from the email (convert to ISO 8601)
+- Duration: 30 minutes unless otherwise specified in the email
+- Location: the video meeting link, phone number, or platform name
+- Description: include recruiter or company contact name/email/phone, and note whether they have your cell number
+
+STEP 3: COMPANY INTERVIEW TRACKING
+When an email indicates advancement beyond the recruiter screen to a company interview:
+- Populate the Company First Interview or Company Second Interview field with details
+- Those details should include company contact info (interviewer name, email, phone)
+- Then immeidately create a calendar event for the new interview date/time including interviewer name, email, phone
+
+STRICT CONSTRAINTS:
+- Do not make up phone numbers, links, dates, or anything at all.  If it does not exist in text wihtin a verifiable email, IT DOES NOT EXIST.
+- PAST-DATE CHECK: Before creating a calendar event, compare the proposed meeting date/time against today's date. If the meeting date has already passed, do NOT create a calendar event for it. Still log it to the spreadsheet, but skip the calendar step. The tool will also enforce this server-side.
+- As described in more detail below, each new date/time value in a scheduling column = one new calendar event. Never skip this.
+- Always use the same account for calendar events as was used for email fetching.
+- Do not create duplicate calendar events for the same meeting.
+- If information is not present in the email, leave that field empty do ot guess.
--- a/src/tools/tools-calendar.ts
+++ b/src/tools/tools-calendar.ts
@@ -0,0 +1,111 @@
+import { z } from "zod";
+import { server } from "../McpServer.js";
+import {
+  accountSchema,
+  getCalendarClient,
+  getCalendarId,
+} from "../loaders/prompt-config-loaders.js";
+
+// ---------------------------------------------------------------------------
+// Tool: create_calendar_event
+// ---------------------------------------------------------------------------
+server.registerTool(
+  "create_calendar_event",
+  {
+    description:
+      "Create a Google Calendar event. Use immediately after logging a " +
+      "recruiter call, company first interview, or company second interview " +
+      "to the spreadsheet. One calendar event per scheduling column populated.",
+    inputSchema: {
+      account: accountSchema,
+      title: z
+        .string()
+        .describe(
+          "Event title, e.g. '[Recruiter Call] Acme Corp - Sr Engineer' " +
+          "or '[Interview] Acme Corp - Sr Engineer'"
+        ),
+      startDateTime: z
+        .string()
+        .describe("Event start in ISO 8601 format, e.g. 2026-02-20T14:00:00-06:00"),
+      durationMinutes: z
+        .number()
+        .min(5)
+        .max(480)
+        .optional()
+        .describe("Duration in minutes (default 60)"),
+      description: z
+        .string()
+        .optional()
+        .describe(
+          "Event description: recruiter/company contact info, notes, " +
+          "whether they have your cell number, etc."
+        ),
+      location: z
+        .string()
+        .optional()
+        .describe("Video meeting link (Zoom/Teams URL) or phone number"),
+    },
+  },
+  async ({ account, title, startDateTime, durationMinutes, description, location }) => {
+    try {
+      const start = new Date(startDateTime);
+
+      if (start.getTime() < Date.now()) {
+        return {
+          content: [
+            {
+              type: "text" as const,
+              text:
+                `Skipped calendar event "${title}" — the proposed date ` +
+                `(${start.toISOString()}) is in the past.`,
+            },
+          ],
+        };
+      }
+
+      const calendar = getCalendarClient(account);
+      const calendarId = getCalendarId(account);
+
+      const end = new Date(start.getTime() + (durationMinutes ?? 60) * 60_000);
+
+      const event = await calendar.events.insert({
+        calendarId,
+        requestBody: {
+          summary: title,
+          start: {
+            dateTime: start.toISOString(),
+          },
+          end: {
+            dateTime: end.toISOString(),
+          },
+          description: description ?? "",
+          location: location ?? "",
+        },
+      });
+
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text:
+              `Created calendar event: "${title}"\n` +
+              `Start: ${start.toISOString()}\n` +
+              `End: ${end.toISOString()}\n` +
+              `Event ID: ${event.data.id}\n` +
+              `Link: ${event.data.htmlLink}`,
+          },
+        ],
+      };
+    } catch (error) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Error creating calendar event: ${errMsg}`,
+          },
+        ],
+      };
+    }
+  }
+);
--- a/src/tools/tools-email.ts
+++ b/src/tools/tools-email.ts
@@ -0,0 +1,305 @@
+import { z } from "zod";
+import { gmail_v1 } from "googleapis";
+import fs from "fs";
+import { server } from "../McpServer.js";
+import {
+  accountSchema,
+  getGmailClient,
+  getSummaryPath,
+  loadClassificationPrompt,
+  loadActionPrompt,
+} from "../loaders/prompt-config-loaders.js";
+
+// ---------------------------------------------------------------------------
+// Email parsing helpers
+// ---------------------------------------------------------------------------
+export const getHeader = (
+  headers: gmail_v1.Schema$MessagePartHeader[] | undefined,
+  name: string
+): string => {
+  if (!headers) return "";
+  const header = headers.find(
+    (h) => h.name?.toLowerCase() === name.toLowerCase()
+  );
+  return header?.value ?? "";
+};
+
+export const decodeBody = (message: gmail_v1.Schema$Message): string => {
+  const parts = message.payload?.parts;
+  let encoded = "";
+
+  if (parts) {
+    const textPart = parts.find((p) => p.mimeType === "text/plain");
+    encoded = textPart?.body?.data ?? "";
+
+    if (!encoded) {
+      const htmlPart = parts.find((p) => p.mimeType === "text/html");
+      encoded = htmlPart?.body?.data ?? "";
+    }
+  } else {
+    encoded = message.payload?.body?.data ?? "";
+  }
+
+  if (!encoded) {
+    return message.snippet ?? "";
+  }
+
+  return Buffer.from(encoded, "base64url").toString("utf-8");
+};
+
+// ---------------------------------------------------------------------------
+// Tool: fetch_new_emails
+// ---------------------------------------------------------------------------
+server.registerTool(
+  "fetch_new_emails",
+  {
+    description:
+      "Fetch unread emails from a Gmail inbox. Returns sender, date, " +
+      "subject, message ID, and body text for each message. The message IDs " +
+      "can be passed to delete_emails later. Specify which account to fetch from.",
+    inputSchema: {
+      account: accountSchema,
+      maxResults: z
+        .number()
+        .min(1)
+        .max(100)
+        .describe("Maximum number of unread emails to fetch (1-100)"),
+    },
+  },
+  async ({ account, maxResults }) => {
+    try {
+      const gmail = getGmailClient(account);
+
+      const listResponse = await gmail.users.messages.list({
+        userId: "me",
+        q: "is:unread",
+        maxResults,
+      });
+
+      const messageIds = listResponse.data.messages ?? [];
+
+      if (messageIds.length === 0) {
+        return {
+          content: [{ type: "text" as const, text: "No unread emails found." }],
+        };
+      }
+
+      const emails: string[] = [];
+
+      for (const msg of messageIds) {
+        const detail = await gmail.users.messages.get({
+          userId: "me",
+          id: msg.id!,
+          format: "full",
+        });
+
+        const headers = detail.data.payload?.headers;
+        const from = getHeader(headers, "From");
+        const subject = getHeader(headers, "Subject");
+        const date = getHeader(headers, "Date");
+        const body = decodeBody(detail.data);
+
+        const truncatedBody =
+          body.length > 2000 ? body.substring(0, 2000) + "\n[...truncated]" : body;
+
+        emails.push(
+          [
+            `MESSAGE_ID: ${msg.id}`,
+            `FROM: ${from}`,
+            `DATE: ${date}`,
+            `SUBJECT: ${subject}`,
+            `BODY:\n${truncatedBody}`,
+          ].join("\n")
+        );
+      }
+
+      const classificationInstructions = loadClassificationPrompt();
+      const actionInstructions = loadActionPrompt();
+      const instructionsBlock =
+        (classificationInstructions
+          ? `\n\n${"=".repeat(60)}\nCLASSIFICATION INSTRUCTIONS (PHASE 1):\n${"=".repeat(60)}\n${classificationInstructions}`
+          : "") +
+        (actionInstructions
+          ? `\n\n${"=".repeat(60)}\nACTION INSTRUCTIONS (PHASE 2):\n${"=".repeat(60)}\n${actionInstructions}`
+          : "");
+
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text:
+              `Found ${emails.length} unread email(s):\n\n` +
+              `${"=".repeat(60)}\n${emails.join(`\n${"=".repeat(60)}\n`)}` +
+              instructionsBlock,
+          },
+        ],
+      };
+    } catch (error) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Error fetching emails: ${errMsg}`,
+          },
+        ],
+      };
+    }
+  }
+);
+
+// ---------------------------------------------------------------------------
+// Tool: delete_emails
+// ---------------------------------------------------------------------------
+server.registerTool(
+  "delete_emails",
+  {
+    description:
+      "Move emails to trash by their Gmail message IDs. Use this for " +
+      "category A (acknowledgements) and category C (rejections) emails. " +
+      "Specify which account the emails belong to.",
+    inputSchema: {
+      account: accountSchema,
+      messageIds: z
+        .array(z.string())
+        .describe("Array of Gmail message IDs to move to trash"),
+    },
+  },
+  async ({ account, messageIds }) => {
+    try {
+      const gmail = getGmailClient(account);
+      const results: string[] = [];
+
+      for (const id of messageIds) {
+        try {
+          await gmail.users.messages.trash({
+            userId: "me",
+            id,
+          });
+          results.push(`Trashed: ${id}`);
+        } catch (err) {
+          const errMsg = err instanceof Error ? err.message : String(err);
+          results.push(`Failed to trash ${id}: ${errMsg}`);
+        }
+      }
+
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Delete results:\n${results.join("\n")}`,
+          },
+        ],
+      };
+    } catch (error) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Error deleting emails: ${errMsg}`,
+          },
+        ],
+      };
+    }
+  }
+);
+
+// ---------------------------------------------------------------------------
+// Tool: append_to_summary
+// ---------------------------------------------------------------------------
+interface SummaryEntry {
+  senderName: string;
+  senderEmail: string;
+  dateReceived: string;
+  subject: string;
+  category: "B" | "D";
+  addedAt: string;
+}
+
+server.registerTool(
+  "append_to_summary",
+  {
+    description:
+      "Append classified email entries to the local summary file. Use this " +
+      "for category B (advancement to next step) and category D (other) emails. " +
+      "Each entry records the sender, date, subject, and category. " +
+      "Specify which account the emails belong to.",
+    inputSchema: {
+      account: accountSchema,
+      entries: z
+        .array(
+          z.object({
+            senderName: z.string().describe("Name of the sender"),
+            senderEmail: z.string().describe("Email address of the sender"),
+            dateReceived: z
+              .string()
+              .describe("Date and time the email was received"),
+            subject: z.string().describe("Email subject line"),
+            category: z
+              .enum(["B", "D"])
+              .describe(
+                "Category: B = advancement to next step, D = other/uncategorized"
+              ),
+          })
+        )
+        .describe("Array of email summary entries to append"),
+    },
+  },
+  async ({ account, entries }) => {
+    try {
+      const summaryPath = getSummaryPath(account);
+
+      let summary: SummaryEntry[] = [];
+      if (fs.existsSync(summaryPath)) {
+        summary = JSON.parse(fs.readFileSync(summaryPath, "utf-8"));
+      }
+
+      const now = new Date();
+      const nowIso = now.toISOString();
+      const newEntries: SummaryEntry[] = entries.map((e) => ({
+        ...e,
+        addedAt: nowIso,
+      }));
+
+      summary.push(...newEntries);
+
+      const RETENTION_MS = 30 * 24 * 60 * 60 * 1000;
+      const cutoff = now.getTime() - RETENTION_MS;
+      const beforePurge = summary.length;
+      summary = summary.filter(
+        (entry) => new Date(entry.addedAt).getTime() >= cutoff
+      );
+      const purged = beforePurge - summary.length;
+
+      fs.writeFileSync(summaryPath, JSON.stringify(summary, null, 2));
+
+      const purgeNote = purged > 0
+        ? `\nPurged ${purged} entry/entries older than 30 days.`
+        : "";
+
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text:
+              `Appended ${newEntries.length} entry/entries to summary.\n` +
+              `Total entries in summary: ${summary.length}\n` +
+              `Summary file: ${summaryPath}` +
+              purgeNote,
+          },
+        ],
+      };
+    } catch (error) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Error appending to summary: ${errMsg}`,
+          },
+        ],
+      };
+    }
+  }
+);
--- a/src/tools/tools-spreadsheet.ts
+++ b/src/tools/tools-spreadsheet.ts
@@ -0,0 +1,179 @@
+import { z } from "zod";
+import { server } from "../McpServer.js";
+import {
+  accountSchema,
+  getSheetsClient,
+  getSpreadsheetId,
+} from "../loaders/prompt-config-loaders.js";
+
+// ---------------------------------------------------------------------------
+// Sheet column layout for "Recruiter Communication Log and Call Schedule"
+// ---------------------------------------------------------------------------
+const SHEET_COLUMNS = [
+  "Recruiter Name",            // A
+  "Recruiter Email",           // B
+  "Recruiter Tel",             // C
+  "Company/Role",              // D
+  "First Contact",             // E
+  "Subsequent Contact(s)",     // F
+  "Recruiter Call Scheduled",  // G
+  "Company Contact Info",      // H
+  "Company First Interview",   // I
+  "Company Second Interview",  // J
+];
+
+const SHEET_RANGE = "Sheet1";
+
+// ---------------------------------------------------------------------------
+// Tool: log_recruiter_contact
+// ---------------------------------------------------------------------------
+server.registerTool(
+  "log_recruiter_contact",
+  {
+    description:
+      "Log or update recruiter contact info in the tracking spreadsheet. " +
+      "If a row already exists for the same recruiterEmail + companyRole, it " +
+      "updates the existing row (merging non-empty fields). Otherwise appends " +
+      "a new row. Use for Category B emails after classification.",
+    inputSchema: {
+      account: accountSchema,
+      recruiterName: z.string().describe("Recruiter's full name"),
+      recruiterEmail: z.string().describe("Recruiter's email address"),
+      recruiterTel: z
+        .string()
+        .optional()
+        .describe("Recruiter's phone number, if mentioned in the email"),
+      companyRole: z
+        .string()
+        .describe("Company name and role the recruiter seeks to fill"),
+      firstContact: z
+        .string()
+        .describe("Date/time of first contact (from the email's Date header)"),
+      subsequentContacts: z
+        .string()
+        .optional()
+        .describe("Any follow-up contact context mentioned in the email"),
+      recruiterCallScheduled: z
+        .string()
+        .optional()
+        .describe(
+          "Scheduled call details: date, time, platform (Zoom/Teams), " +
+          "meeting link or phone, and whether they have your cell number"
+        ),
+      companyContactInfo: z
+        .string()
+        .optional()
+        .describe("Company interviewer name/email/tel if advancing to company interview"),
+      companyFirstInterview: z
+        .string()
+        .optional()
+        .describe("Company first interview: date, time, platform, link/phone, cell number note"),
+      companySecondInterview: z
+        .string()
+        .optional()
+        .describe("Company second interview: date, time, platform, link/phone, cell number note"),
+    },
+  },
+  async ({
+    account,
+    recruiterName,
+    recruiterEmail,
+    recruiterTel,
+    companyRole,
+    firstContact,
+    subsequentContacts,
+    recruiterCallScheduled,
+    companyContactInfo,
+    companyFirstInterview,
+    companySecondInterview,
+  }) => {
+    try {
+      const sheets = getSheetsClient(account);
+      const spreadsheetId = getSpreadsheetId(account);
+
+      const incomingRow = [
+        recruiterName,
+        recruiterEmail,
+        recruiterTel ?? "",
+        companyRole,
+        firstContact,
+        subsequentContacts ?? "",
+        recruiterCallScheduled ?? "",
+        companyContactInfo ?? "",
+        companyFirstInterview ?? "",
+        companySecondInterview ?? "",
+      ];
+
+      const existing = await sheets.spreadsheets.values.get({
+        spreadsheetId,
+        range: SHEET_RANGE,
+      });
+      const rows = existing.data.values ?? [];
+
+      const emailNorm = recruiterEmail.toLowerCase().trim();
+      const roleNorm = companyRole.toLowerCase().trim();
+      let matchIdx = -1;
+      for (let i = 0; i < rows.length; i++) {
+        const rowEmail = (rows[i][1] ?? "").toString().toLowerCase().trim();
+        const rowRole = (rows[i][3] ?? "").toString().toLowerCase().trim();
+        if (rowEmail === emailNorm && rowRole === roleNorm) {
+          matchIdx = i;
+          break;
+        }
+      }
+
+      if (matchIdx >= 0) {
+        const existingRow = rows[matchIdx];
+        const merged = incomingRow.map((val, col) => {
+          if (col === 5 && val && existingRow[col]) {
+            return `${existingRow[col]}; ${val}`;
+          }
+          return val || existingRow[col] || "";
+        });
+
+        const rowNum = matchIdx + 1;
+        await sheets.spreadsheets.values.update({
+          spreadsheetId,
+          range: `${SHEET_RANGE}!A${rowNum}:J${rowNum}`,
+          valueInputOption: "USER_ENTERED",
+          requestBody: { values: [merged] },
+        });
+
+        return {
+          content: [
+            {
+              type: "text" as const,
+              text: `Updated existing row ${rowNum} for ${recruiterName} / ${companyRole}.`,
+            },
+          ],
+        };
+      }
+
+      await sheets.spreadsheets.values.append({
+        spreadsheetId,
+        range: SHEET_RANGE,
+        valueInputOption: "USER_ENTERED",
+        requestBody: { values: [incomingRow] },
+      });
+
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Appended new row for ${recruiterName} / ${companyRole}.`,
+          },
+        ],
+      };
+    } catch (error) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      return {
+        content: [
+          {
+            type: "text" as const,
+            text: `Error logging recruiter contact: ${errMsg}`,
+          },
+        ],
+      };
+    }
+  }
+);
--- a/summary-secondary.json
+++ b/summary-secondary.json
@@ -1,130 +0,0 @@
-[
-  {
-    "senderName": "Yelena Nikolov",
-    "senderEmail": "Yelena.Nikolov@meridianlink.com",
-    "dateReceived": "Tue, 17 Feb 2026 13:57:42 +0000",
-    "subject": "Interview next steps with MeridianLink",
-    "category": "B",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "LDEAskHR",
-    "senderEmail": "LDEAskHR@epiqglobal.com",
-    "dateReceived": "Fri, 13 Feb 2026 17:12:26 +0000",
-    "subject": "Immediate Action Requested - Background check",
-    "category": "B",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Talent Experience Team",
-    "senderEmail": "talentsupport@mbopartners.com",
-    "dateReceived": "Fri, 13 Feb 2026 17:03:27 +0000",
-    "subject": "[URGENT ACTION NEEDED!] FINAL NOTICE - Security Training - OVERDUE",
-    "category": "B",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Talent Experience Team",
-    "senderEmail": "talentsupport@mbopartners.com",
-    "dateReceived": "Fri, 13 Feb 2026 17:01:12 +0000",
-    "subject": "[ACTION NEEDED!] KPMG Ethics & Integrity Training for KPMG's Contingent Worker Training - OVERDUE",
-    "category": "B",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Penny from Rocket Money",
-    "senderEmail": "support@rocketmoney.com",
-    "dateReceived": "Tue, 17 Feb 2026 14:00:20 +0000",
-    "subject": "Re: [External] New Cell Number -m Cannot 2FA to My Account",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Mondaq Newsletters",
-    "senderEmail": "newsletters@webiis01.mondaq.com",
-    "dateReceived": "Tue, 17 Feb 2026 13:37:53 +0000",
-    "subject": "Mondaq Personalized News Alert",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "MoneyLion Partner",
-    "senderEmail": "partners@iemail.moneylion.com",
-    "dateReceived": "Tue, 17 Feb 2026 04:00:40 +0000",
-    "subject": "3 days left to view your personalized offers.",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "JobCopilot",
-    "senderEmail": "noreply@jobcopilot.com",
-    "dateReceived": "Mon, 16 Feb 2026 23:33:56 +0000",
-    "subject": "JobCopilot has applied to 50 jobs",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "no-reply@equifax.com",
-    "senderEmail": "no-reply@equifax.com",
-    "dateReceived": "Mon, 16 Feb 2026 21:01:48 +0000",
-    "subject": "New Equifax Credit Report Available",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Call-On-Doc",
-    "senderEmail": "no-reply@callondoc.com",
-    "dateReceived": "Mon, 16 Feb 2026 20:46:24 +0000",
-    "subject": "CallonDoc - Your Login Email has Been Changed.",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Bank of America",
-    "senderEmail": "customerservice@ealerts.bankofamerica.com",
-    "dateReceived": "Mon, 16 Feb 2026 09:55:20 -0600",
-    "subject": "Kenneth S Jannette sent you $150.00",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Concora Credit",
-    "senderEmail": "donotreply_concoracredit@mail.concoracredit.com",
-    "dateReceived": "Sat, 14 Feb 2026 16:01:10 -0600",
-    "subject": "Your Statement Is Ready To View",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "MBO Talent Experience & Support Team",
-    "senderEmail": "talentsupport@mbopartners.com",
-    "dateReceived": "Fri, 13 Feb 2026 10:44:08 -0600",
-    "subject": "KPMG Standard Work Hours and Overtime Policy",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Noun Project",
-    "senderEmail": "yourfriends@thenounproject.com",
-    "dateReceived": "Fri, 13 Feb 2026 01:00:53 +0000",
-    "subject": "Your Noun Project Invoice",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "The Termly Team",
-    "senderEmail": "termlyservices@email.termly.io",
-    "dateReceived": "Thu, 12 Feb 2026 20:16:59 +0000",
-    "subject": "Upcoming IAB TCF v2.3 update: disclosedVendors support",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  },
-  {
-    "senderName": "Brave Search API",
-    "senderEmail": "search-api@brave.com",
-    "dateReceived": "Thu, 12 Feb 2026 19:57:43 +0000",
-    "subject": "New ToS & plans for the Brave Search API",
-    "category": "D",
-    "addedAt": "2026-02-17T14:10:30.911Z"
-  }
-]
--- a/test/fixtures/mock-emails.ts
+++ b/test/fixtures/mock-emails.ts
@@ -0,0 +1,167 @@
+/**
+ * Canned Gmail API responses representing one email from each category.
+ * Body text is base64url-encoded to match the real Gmail API format.
+ */
+
+const toBase64Url = (text: string): string =>
+  Buffer.from(text, "utf-8").toString("base64url");
+
+// Category A — Acknowledgement only
+const catABody = [
+  "Dear Steven,",
+  "",
+  "Thank you for your interest in the Senior Software Engineer position at Acme Corp.",
+  "We have received your application and it is currently under review.",
+  "We will contact you if your qualifications match our needs.",
+  "",
+  "Best regards,",
+  "Acme Talent Acquisition",
+].join("\n");
+
+// Category B — Advancement to next step
+const catBBody = [
+  "Hi Steven,",
+  "",
+  "Thanks for applying to the Full Stack Engineer role at Globex Corp.",
+  "We'd love to schedule a phone screen to discuss your background.",
+  "Are you available this Thursday at 2:00 PM CST?",
+  "Please join via Zoom: https://zoom.us/j/123456789",
+  "",
+  "Looking forward to connecting,",
+  "Jane Smith",
+  "Senior Recruiter, Globex Corp",
+  "jane.smith@globexcorp.com",
+  "(555) 867-5309",
+].join("\n");
+
+// Category C — Rejection
+const catCBody = [
+  "Dear Steven,",
+  "",
+  "Thank you for taking the time to interview for the Platform Engineer position at Initech.",
+  "After careful consideration, we have decided to pursue other candidates",
+  "whose experience more closely aligns with our current needs.",
+  "",
+  "We wish you the best in your job search.",
+  "",
+  "Regards,",
+  "Initech Recruiting Team",
+].join("\n");
+
+// Category D — Other / non-job
+const catDBody = [
+  "Your Tailscale subscription payment of $6.00 was unsuccessful.",
+  "Please update your payment method at https://login.tailscale.com/billing.",
+  "",
+  "— Tailscale Billing",
+].join("\n");
+
+const makeHeaders = (from: string, subject: string, date: string) => [
+  { name: "From", value: from },
+  { name: "Subject", value: subject },
+  { name: "Date", value: date },
+  { name: "To", value: "steven@sjdev.co" },
+];
+
+export const MOCK_MESSAGE_LIST = {
+  data: {
+    messages: [
+      { id: "msg-cat-a-001" },
+      { id: "msg-cat-b-001" },
+      { id: "msg-cat-c-001" },
+      { id: "msg-cat-d-001" },
+    ],
+  },
+};
+
+export const MOCK_MESSAGES: Record<string, { data: any }> = {
+  "msg-cat-a-001": {
+    data: {
+      id: "msg-cat-a-001",
+      snippet: "Thank you for your interest in the Senior Software Engineer position...",
+      payload: {
+        headers: makeHeaders(
+          "Acme Talent <talent@acmecorp.com>",
+          "Application Received — Senior Software Engineer",
+          "Mon, 17 Feb 2026 10:00:00 +0000"
+        ),
+        mimeType: "multipart/alternative",
+        parts: [
+          {
+            mimeType: "text/plain",
+            body: { data: toBase64Url(catABody) },
+          },
+          {
+            mimeType: "text/html",
+            body: { data: toBase64Url(`<p>${catABody}</p>`) },
+          },
+        ],
+      },
+    },
+  },
+
+  "msg-cat-b-001": {
+    data: {
+      id: "msg-cat-b-001",
+      snippet: "We'd love to schedule a phone screen...",
+      payload: {
+        headers: makeHeaders(
+          "Jane Smith <jane.smith@globexcorp.com>",
+          "Phone Screen — Full Stack Engineer at Globex Corp",
+          "Tue, 18 Feb 2026 14:30:00 +0000"
+        ),
+        mimeType: "multipart/alternative",
+        parts: [
+          {
+            mimeType: "text/plain",
+            body: { data: toBase64Url(catBBody) },
+          },
+        ],
+      },
+    },
+  },
+
+  "msg-cat-c-001": {
+    data: {
+      id: "msg-cat-c-001",
+      snippet: "We have decided to pursue other candidates...",
+      payload: {
+        headers: makeHeaders(
+          "Initech Recruiting <recruiting@initech.com>",
+          "Update on Your Application — Platform Engineer",
+          "Wed, 19 Feb 2026 09:15:00 +0000"
+        ),
+        mimeType: "text/plain",
+        body: { data: toBase64Url(catCBody) },
+      },
+    },
+  },
+
+  "msg-cat-d-001": {
+    data: {
+      id: "msg-cat-d-001",
+      snippet: "Your Tailscale subscription payment of $6.00 was unsuccessful.",
+      payload: {
+        headers: makeHeaders(
+          "Tailscale Billing <billing@tailscale.com>",
+          "$6.00 payment to Tailscale US Inc. was unsuccessful",
+          "Thu, 20 Feb 2026 17:00:00 +0000"
+        ),
+        mimeType: "text/plain",
+        body: { data: toBase64Url(catDBody) },
+      },
+    },
+  },
+};
+
+export const MOCK_EMPTY_LIST = {
+  data: { messages: undefined },
+};
+
+// Raw body text for assertion comparisons
+export const RAW_BODIES = {
+  "msg-cat-a-001": catABody,
+  "msg-cat-b-001": catBBody,
+  "msg-cat-c-001": catCBody,
+  "msg-cat-d-001": catDBody,
+};
--- a/test/integration/email-workflow.test.ts
+++ b/test/integration/email-workflow.test.ts
@@ -0,0 +1,287 @@
+import { describe, it, expect, vi, beforeAll, afterAll, beforeEach } from "vitest";
+import { z } from "zod";
+import fs from "fs";
+import os from "os";
+import path from "path";
+import { Client } from "@modelcontextprotocol/sdk/client/index.js";
+import { InMemoryTransport } from "@modelcontextprotocol/sdk/inMemory.js";
+import { MOCK_MESSAGE_LIST, MOCK_MESSAGES, MOCK_EMPTY_LIST } from "../fixtures/mock-emails.js";
+
+// -----------------------------------------------------------------------
+// Mock the loaders module so no real credentials/tokens/APIs are needed.
+// vi.mock is hoisted — runs before any module imports.
+// -----------------------------------------------------------------------
+const mockGmailList = vi.fn();
+const mockGmailGet = vi.fn();
+const mockGmailTrash = vi.fn();
+let tmpDir: string;
+
+vi.mock("../../src/loaders/prompt-config-loaders.js", () => {
+  const testAccounts = {
+    work: { label: "test@test.com", tokenFile: "token.json" },
+    secondary: { label: "test2@test.com", tokenFile: "token-secondary.json" },
+  };
+
+  return {
+    PROJECT_ROOT: "/tmp/test-project",
+    VALID_ACCOUNTS: ["work", "secondary"] as const,
+    accounts: testAccounts,
+    accountSchema: z
+      .enum(["work", "secondary"])
+      .describe("test account"),
+    loadAccounts: () => testAccounts,
+    getTokenPath: () => "/tmp/fake-token.json",
+    getSummaryPath: (account: string) => {
+      const base = tmpDir || os.tmpdir();
+      return account === "work"
+        ? path.join(base, "mailSummaries", "summary.json")
+        : path.join(base, "mailSummaries", `summary-${account}.json`);
+    },
+    loadClassificationPrompt: () => "CLASSIFY EACH EMAIL AS A, B, C, OR D.",
+    loadActionPrompt: () => "PHASE 2 INSTRUCTIONS HERE.",
+    getGmailClient: () => ({
+      users: {
+        messages: {
+          list: mockGmailList,
+          get: mockGmailGet,
+          trash: mockGmailTrash,
+        },
+      },
+    }),
+    getSheetsClient: vi.fn(),
+    getCalendarClient: vi.fn(),
+    getSpreadsheetId: vi.fn(),
+    getCalendarId: () => "primary",
+    getOAuth2Client: vi.fn(),
+  };
+});
+
+// Now import the server and tool modules (they'll use the mocked loaders)
+const { server } = await import("../../src/McpServer.js");
+await import("../../src/tools/tools-email.js");
+
+// -----------------------------------------------------------------------
+// Helpers
+// -----------------------------------------------------------------------
+let client: Client;
+
+async function connectClient(): Promise<void> {
+  client = new Client({ name: "test-client", version: "1.0.0" });
+  const [clientTransport, serverTransport] = InMemoryTransport.createLinkedPair();
+  await Promise.all([
+    client.connect(clientTransport),
+    server.connect(serverTransport),
+  ]);
+}
+
+async function callTool(name: string, args: Record<string, unknown>) {
+  const result = await client.callTool({ name, arguments: args });
+  const text = (result.content as Array<{ type: string; text: string }>)[0]?.text ?? "";
+  return text;
+}
+
+// -----------------------------------------------------------------------
+// Test suite
+// -----------------------------------------------------------------------
+describe("Phase 1: Email Review Workflow", () => {
+  beforeAll(async () => {
+    tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), "mcp-test-"));
+    fs.mkdirSync(path.join(tmpDir, "mailSummaries"), { recursive: true });
+    await connectClient();
+  });
+
+  afterAll(async () => {
+    await client?.close();
+    fs.rmSync(tmpDir, { recursive: true, force: true });
+  });
+
+  beforeEach(() => {
+    vi.clearAllMocks();
+  });
+
+  // ----- Step 1: Fetch new emails -----
+  describe("fetch_new_emails", () => {
+    it("returns formatted emails with classification instructions", async () => {
+      mockGmailList.mockResolvedValue(MOCK_MESSAGE_LIST);
+      mockGmailGet.mockImplementation(({ id }: { id: string }) =>
+        Promise.resolve(MOCK_MESSAGES[id])
+      );
+
+      const text = await callTool("fetch_new_emails", {
+        account: "work",
+        maxResults: 10,
+      });
+
+      expect(text).toContain("Found 4 unread email(s)");
+
+      // All 4 messages present
+      expect(text).toContain("msg-cat-a-001");
+      expect(text).toContain("msg-cat-b-001");
+      expect(text).toContain("msg-cat-c-001");
+      expect(text).toContain("msg-cat-d-001");
+
+      // Headers extracted correctly
+      expect(text).toContain("FROM: Acme Talent <talent@acmecorp.com>");
+      expect(text).toContain("SUBJECT: Phone Screen — Full Stack Engineer at Globex Corp");
+      expect(text).toContain("FROM: Initech Recruiting <recruiting@initech.com>");
+
+      // Body content decoded
+      expect(text).toContain("We have received your application");
+      expect(text).toContain("schedule a phone screen");
+      expect(text).toContain("decided to pursue other candidates");
+      expect(text).toContain("payment of $6.00 was unsuccessful");
+
+      // Classification instructions appended
+      expect(text).toContain("CLASSIFICATION INSTRUCTIONS (PHASE 1)");
+      expect(text).toContain("CLASSIFY EACH EMAIL AS A, B, C, OR D.");
+
+      // Phase 2 instructions also appended
+      expect(text).toContain("ACTION INSTRUCTIONS (PHASE 2)");
+    });
+
+    it("handles an empty inbox", async () => {
+      mockGmailList.mockResolvedValue(MOCK_EMPTY_LIST);
+
+      const text = await callTool("fetch_new_emails", {
+        account: "work",
+        maxResults: 10,
+      });
+
+      expect(text).toBe("No unread emails found.");
+    });
+
+    it("handles Gmail API errors gracefully", async () => {
+      mockGmailList.mockRejectedValue(new Error("Token expired"));
+
+      const text = await callTool("fetch_new_emails", {
+        account: "work",
+        maxResults: 10,
+      });
+
+      expect(text).toContain("Error fetching emails");
+      expect(text).toContain("Token expired");
+    });
+  });
+
+  // ----- Step 2: Delete A and C emails -----
+  describe("delete_emails", () => {
+    it("trashes the specified message IDs", async () => {
+      mockGmailTrash.mockResolvedValue({});
+
+      const text = await callTool("delete_emails", {
+        account: "work",
+        messageIds: ["msg-cat-a-001", "msg-cat-c-001"],
+      });
+
+      expect(mockGmailTrash).toHaveBeenCalledTimes(2);
+      expect(mockGmailTrash).toHaveBeenCalledWith({ userId: "me", id: "msg-cat-a-001" });
+      expect(mockGmailTrash).toHaveBeenCalledWith({ userId: "me", id: "msg-cat-c-001" });
+      expect(text).toContain("Trashed: msg-cat-a-001");
+      expect(text).toContain("Trashed: msg-cat-c-001");
+    });
+
+    it("reports partial failures without aborting", async () => {
+      mockGmailTrash
+        .mockResolvedValueOnce({})
+        .mockRejectedValueOnce(new Error("Not Found"));
+
+      const text = await callTool("delete_emails", {
+        account: "work",
+        messageIds: ["msg-cat-a-001", "msg-bad-id"],
+      });
+
+      expect(text).toContain("Trashed: msg-cat-a-001");
+      expect(text).toContain("Failed to trash msg-bad-id: Not Found");
+    });
+
+    it("handles auth/client errors", async () => {
+      // Make getGmailClient itself throw by having list throw before any trash
+      mockGmailTrash.mockRejectedValue(new Error("Auth failed"));
+
+      const text = await callTool("delete_emails", {
+        account: "work",
+        messageIds: ["msg-cat-a-001"],
+      });
+
+      expect(text).toContain("Failed to trash msg-cat-a-001: Auth failed");
+    });
+  });
+
+  // ----- Step 3: Summarize B and D -----
+  describe("append_to_summary", () => {
+    it("creates a summary file and appends entries", async () => {
+      const entries = [
+        {
+          senderName: "Jane Smith",
+          senderEmail: "jane.smith@globexcorp.com",
+          dateReceived: "Tue, 18 Feb 2026 14:30:00 +0000",
+          subject: "Phone Screen — Full Stack Engineer at Globex Corp",
+          category: "B",
+        },
+        {
+          senderName: "Tailscale Billing",
+          senderEmail: "billing@tailscale.com",
+          dateReceived: "Thu, 20 Feb 2026 17:00:00 +0000",
+          subject: "$6.00 payment to Tailscale US Inc. was unsuccessful",
+          category: "D",
+        },
+      ];
+
+      const text = await callTool("append_to_summary", {
+        account: "work",
+        entries,
+      });
+
+      expect(text).toContain("Appended 2 entry/entries to summary.");
+      expect(text).toContain("Total entries in summary: 2");
+
+      const summaryPath = path.join(tmpDir, "mailSummaries", "summary.json");
+      const written = JSON.parse(fs.readFileSync(summaryPath, "utf-8"));
+      expect(written).toHaveLength(2);
+      expect(written[0].senderName).toBe("Jane Smith");
+      expect(written[0].category).toBe("B");
+      expect(written[1].category).toBe("D");
+      expect(written[0].addedAt).toBeDefined();
+    });
+
+    it("purges entries older than 30 days", async () => {
+      const summaryPath = path.join(tmpDir, "mailSummaries", "summary.json");
+      const oldDate = new Date(Date.now() - 31 * 24 * 60 * 60 * 1000).toISOString();
+
+      // Seed with an old entry
+      fs.writeFileSync(
+        summaryPath,
+        JSON.stringify([
+          {
+            senderName: "Old Entry",
+            senderEmail: "old@example.com",
+            dateReceived: "2025-01-01",
+            subject: "Ancient email",
+            category: "D",
+            addedAt: oldDate,
+          },
+        ])
+      );
+
+      const text = await callTool("append_to_summary", {
+        account: "work",
+        entries: [
+          {
+            senderName: "New Entry",
+            senderEmail: "new@example.com",
+            dateReceived: "2026-02-18",
+            subject: "Fresh email",
+            category: "B",
+          },
+        ],
+      });
+
+      expect(text).toContain("Purged 1 entry/entries older than 30 days.");
+      expect(text).toContain("Total entries in summary: 1");
+
+      const written = JSON.parse(fs.readFileSync(summaryPath, "utf-8"));
+      expect(written).toHaveLength(1);
+      expect(written[0].senderName).toBe("New Entry");
+    });
+  });
+});
--- a/test/unit/email-parsing.test.ts
+++ b/test/unit/email-parsing.test.ts
@@ -0,0 +1,86 @@
+import { describe, it, expect } from "vitest";
+import { getHeader, decodeBody } from "../../src/tools/tools-email.js";
+import { MOCK_MESSAGES, RAW_BODIES } from "../fixtures/mock-emails.js";
+
+describe("getHeader", () => {
+  const headers = [
+    { name: "From", value: "Jane <jane@example.com>" },
+    { name: "Subject", value: "Hello World" },
+    { name: "Date", value: "Mon, 17 Feb 2026 10:00:00 +0000" },
+  ];
+
+  it("extracts a header by name (case-insensitive)", () => {
+    expect(getHeader(headers, "from")).toBe("Jane <jane@example.com>");
+    expect(getHeader(headers, "FROM")).toBe("Jane <jane@example.com>");
+    expect(getHeader(headers, "From")).toBe("Jane <jane@example.com>");
+  });
+
+  it("returns empty string for missing header", () => {
+    expect(getHeader(headers, "Cc")).toBe("");
+  });
+
+  it("returns empty string for undefined headers array", () => {
+    expect(getHeader(undefined, "From")).toBe("");
+  });
+
+  it("returns empty string for empty headers array", () => {
+    expect(getHeader([], "From")).toBe("");
+  });
+});
+
+describe("decodeBody", () => {
+  it("decodes a multipart message (text/plain preferred)", () => {
+    const msg = MOCK_MESSAGES["msg-cat-a-001"].data;
+    const body = decodeBody(msg);
+    expect(body).toBe(RAW_BODIES["msg-cat-a-001"]);
+    expect(body).toContain("We have received your application");
+  });
+
+  it("decodes a multipart message with only text/plain part", () => {
+    const msg = MOCK_MESSAGES["msg-cat-b-001"].data;
+    const body = decodeBody(msg);
+    expect(body).toBe(RAW_BODIES["msg-cat-b-001"]);
+    expect(body).toContain("schedule a phone screen");
+  });
+
+  it("decodes a single-part message (no parts array)", () => {
+    const msg = MOCK_MESSAGES["msg-cat-c-001"].data;
+    const body = decodeBody(msg);
+    expect(body).toBe(RAW_BODIES["msg-cat-c-001"]);
+    expect(body).toContain("decided to pursue other candidates");
+  });
+
+  it("falls back to snippet when body data is empty", () => {
+    const msg = {
+      snippet: "This is a snippet fallback",
+      payload: { body: { data: "" } },
+    };
+    expect(decodeBody(msg)).toBe("This is a snippet fallback");
+  });
+
+  it("falls back to snippet when payload has no body data at all", () => {
+    const msg = {
+      snippet: "Snippet only",
+      payload: {},
+    };
+    expect(decodeBody(msg)).toBe("Snippet only");
+  });
+
+  it("returns empty string when no body and no snippet", () => {
+    const msg = { payload: {} };
+    expect(decodeBody(msg)).toBe("");
+  });
+
+  it("falls back to text/html when text/plain is missing in multipart", () => {
+    const htmlContent = "<p>Hello from HTML</p>";
+    const encoded = Buffer.from(htmlContent).toString("base64url");
+    const msg = {
+      payload: {
+        parts: [
+          { mimeType: "text/html", body: { data: encoded } },
+        ],
+      },
+    };
+    expect(decodeBody(msg)).toBe(htmlContent);
+  });
+});
--- a/tsconfig.json
+++ b/tsconfig.json
@@ -11,5 +11,5 @@
    "forceConsistentCasingInFileNames": true
  },
  "include": ["src/**/*"],
-  "exclude": ["node_modules"]
+  "exclude": ["node_modules", "test", "vitest.config.ts"]
 }
--- a/vitest.config.ts
+++ b/vitest.config.ts
@@ -0,0 +1,8 @@
+import { defineConfig } from "vitest/config";
+
+export default defineConfig({
+  test: {
+    include: ["test/**/*.test.ts"],
+    globals: true,
+  },
+});
Author	SHA1	Message	Date
KS Jannette	a91c8c0009	hottie	2026-02-22 19:19:46 -05:00
KS Jannette	8874b32334	m	2026-02-20 15:36:29 -05:00
KS Jannette	f3cf4a51bd	m	2026-02-20 14:12:41 -05:00
KS Jannette	065645983a	more	2026-02-20 14:01:07 -05:00
KS Jannette	98585b52ad	more	2026-02-20 13:58:58 -05:00
KS Jannette	ea62edbc21	Tweaker	2026-02-20 13:52:27 -05:00
KS Jannette	21b4e656f6	hotfix	2026-02-20 12:36:46 -05:00
KS Jannette	fc3223a119	more	2026-02-20 12:29:53 -05:00
KS Jannette	9adc9cc3e0	more	2026-02-20 11:55:11 -05:00
S Jannette	7a02c49bd2	Merge pull request #6 from kjannette/refine-mail-processing-prompts Refine mail processing prompts	2026-02-20 11:53:53 -05:00
KS Jannette	1cff926c15	mo	2026-02-20 11:53:31 -05:00
KS Jannette	809da541dc	more	2026-02-20 10:59:01 -05:00
KS Jannette	b44118bd2f	more readme stuff	2026-02-18 09:17:11 -05:00
KS Jannette	1d86280e8c	more	2026-02-18 08:59:14 -05:00
KS Jannette	a22a43a5ab	More	2026-02-18 08:50:24 -05:00
KS Jannette	9d465d5fca	more	2026-02-18 08:44:37 -05:00
KS Jannette	5ca368f15e	m	2026-02-18 08:32:13 -05:00
KS Jannette	dc8624592d	more	2026-02-18 08:23:58 -05:00
KS Jannette	3a3a971feb	tune up README	2026-02-18 08:14:10 -05:00
KS Jannette	8fb4fe7ce5	More updates for mail configs	2026-02-18 07:31:02 -05:00
KS Jannette	a0e1b43360	basic unit tests	2026-02-18 07:26:13 -05:00
S Jannette	410ee0656f	Merge pull request #5 from kjannette/restructure Restructure	2026-02-18 07:06:07 -05:00
KS Jannette	94b07531d0	restruct and refact	2026-02-18 07:04:41 -05:00
KS Jannette	1094f9c972	more	2026-02-18 06:58:44 -05:00
S Jannette	68e48b2345	Merge pull request #4 from kjannette/finetune more	2026-02-18 06:21:31 -05:00
KS Jannette	28a368326d	more	2026-02-18 06:21:04 -05:00
S Jannette	50214fb4e5	Merge pull request #3 from kjannette/processEmails Ingest and process emails, take calendar actions, build rich spreadsheets.	2026-02-18 06:12:25 -05:00
KS Jannette	dc1fdecfcd	More	2026-02-18 06:06:17 -05:00
KS Jannette	e66eea75dc	more	2026-02-18 05:48:50 -05:00
S Jannette	54d944b9fb	Merge pull request #2 from kjannette/sec Sec	2026-02-17 14:00:22 -05:00