Compare commits
4 Commits
dbfa913e5e
...
FEAT-incre
| Author | SHA1 | Date | |
|---|---|---|---|
|
31618b1acf | ||
| 087839d2bf | |||
| b9337d1b0c | |||
|
|
ee12a44ec1 |
188
README.md
188
README.md
@@ -2,130 +2,182 @@
|
||||
<img src="assets/logo.png" alt="Declawed" width="120" />
|
||||
</p>
|
||||
|
||||
|
||||
# Declawed: your kuddly assisty-kitty
|
||||
|
||||
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?
|
||||
|
||||
### (Cat) nip it in the bud!!
|
||||
Inbox brimming with stank? Wanna cut the crap and get the messaging that matters into calendars, Atlassian, Jira, Asana, Google Calendar/Sheets (etc.) ... in two clicks? (Cat) nip slop in the bud with Assisty-Kitty!!
|
||||
|
||||
|
||||
# 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
|
||||
|
||||
### Eliminates that frustrating feeling you'll never get your paws around the dangling, catnip-stuffed mouse through haunch-high mail from list you're never signed up for or were re-sold to from ones you have, bot-generated marketing slop, and, of course, nigerians princes that need help claim their lottery jackpot.
|
||||
|
||||
|
||||
"deClawed" because: no one should be beholden to one LLM api or local model. Have you seen that baddie Kimi K3?
|
||||
|
||||
|
||||
The platform princes are rent extractors.
|
||||
|
||||
|
||||
Open weights are heavy weight champions.
|
||||
|
||||
|
||||
# The "how"
|
||||
|
||||
|
||||
Because It's soooo easy.
|
||||
deClawed is configurable, prompt purrr-fectable, LLM-driven mail and task automation for anyone that can cut n' paste a few CLI commands and can type in short declarative sentences.
|
||||
More private than other options (not purrfect *yet* - but privacy is our number one goal with every release).
|
||||
More accurate actions/results (read on).
|
||||
|
||||
|
||||
# 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.
|
||||
Your own local Model Context Protocol (MCP) server integrates with your preferred LLM API. Each step in the install, and setup offers greater control, and transparency. Permissions are 100% configurable.
|
||||
|
||||
|
||||
Escape black-box installs stocked with more Trojans than an Olympic Village - silent/dark processes, data harvesting phone-homes, behavioral analytics, telemetry backdoors, corporate surveillance - the nasties lurking in the dark discoverable only by secops edgelords that are masters of the the CLI.
|
||||
|
||||
💩 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.
|
||||
|
||||
Stop drilling down byzantine menus in mail, scheduling and workflow to configure filters and actions that 1. only ever work 20% of the time 2. change in functionality and scope every two months because a project manager needs to justify their salary.
|
||||
|
||||
|
||||
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.
|
||||
2. The prompt templates in Kitty's "built in" library are evaluated using, for example, cosine similarity, ROUGE scoring and real human eval in the SDLC dev loop.
|
||||
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.
|
||||
|
||||
### Prompting: easily configured to cron: cleaning the litter(in)box before the stank wafts through the whole work house.
|
||||
### Imagine your morning inbox or summaries brimming with a fresh, spring-meadow aroma of opportunity and insight -- not last night's Kitty kibble.
|
||||
|
||||
|
||||
# -- 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 and Architecture
|
||||
|
||||
|
||||
## Current implementation requires building/using:
|
||||
-- Claude Desktop (as UI - proprietary UI coming soonish)
|
||||
-- Building/Connecting a Local Model Context Protocol Server
|
||||
-- Claude Desktop (as UI only - proprietary UI coming soonish)
|
||||
-- Building/Connecting a Model API or 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.
|
||||
-- Proprietary, custom UI.
|
||||
-- Support for all stripes of models on HugginFFace.
|
||||
- Support for local LLMs.
|
||||
|
||||
|
||||
# Setup
|
||||
|
||||
|
||||
### 1. Install Node.js (v16+ required).
|
||||
|
||||
|
||||
```bash
|
||||
node --version
|
||||
npm --version
|
||||
```
|
||||
|
||||
|
||||
If not installed, grab it from [nodejs.org](https://nodejs.org/).
|
||||
|
||||
|
||||
### 2. Clone and Install
|
||||
|
||||
```bash
|
||||
git clone https://github.com/kjannette/deClawed-Assisty-Kitty.git
|
||||
cd deClawed-Assity-Kitty
|
||||
npm install
|
||||
```
|
||||
|
||||
```bash
|
||||
git clone https://git.sjdev.online/kjannette/deClawed-Assity-Kitty
|
||||
cd deClawed-Assity-Kitty
|
||||
npm i
|
||||
```
|
||||
### 3. Set Up Google Cloud Credentials
|
||||
|
||||
|
||||
#### 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) > **New Project**
|
||||
4. Name it (e.g., `assistant-mcp`) and click **Create**
|
||||
5. Select the new project from the dropdown
|
||||
|
||||
|
||||
#### 3b. Enable APIs
|
||||
|
||||
|
||||
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)
|
||||
|
||||
|
||||
#### 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
|
||||
|
||||
|
||||
#### 3d. Add OAuth Scopes
|
||||
|
||||
|
||||
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)
|
||||
|
||||
|
||||
#### 3e. Add Yourself as a Test User
|
||||
|
||||
|
||||
Go to **Google Auth Platform > Audience** and add each Gmail address you'll use.
|
||||
|
||||
|
||||
#### 3f. Create OAuth Client Credentials
|
||||
|
||||
|
||||
1. Go to **Google Auth Platform > Clients** (or **APIs & Services > Credentials**)
|
||||
2. Click **Create Client** > Application type: **Desktop app**
|
||||
3. **Download the JSON**, rename it to `credentials.json`
|
||||
4. Place it in the project root
|
||||
|
||||
|
||||
### 4. Configure Accounts
|
||||
|
||||
|
||||
Create file `accounts.json` in the project root. Each key is an account alias with its own token file and optional Sheets/Calendar config:
|
||||
|
||||
|
||||
```json
|
||||
{
|
||||
"work": {
|
||||
@@ -141,113 +193,147 @@ Create file `accounts.json` in the project root. Each key is an account alias wi
|
||||
}
|
||||
```
|
||||
|
||||
|
||||
- **`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:
|
||||
|
||||
Each run required steps:
|
||||
|
||||
|
||||
1. Print a URL -- open it in your browser
|
||||
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 per account. Tokens auto-refresh.
|
||||
|
||||
|
||||
### 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.) |
|
||||
| `src/prompts/take-action-on-emails.txt` | 2 -- Action | Tell 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
|
||||
```
|
||||
|
||||
|
||||
Compiles `src/**/*.ts` into `build/`.
|
||||
|
||||
|
||||
## 8. Configure Claude Desktop
|
||||
|
||||
|
||||
Edit your Claude Desktop config:
|
||||
|
||||
|
||||
```bash
|
||||
code ~/Library/Application\ Support/Claude/claude_desktop_config.json
|
||||
```
|
||||
|
||||
|
||||
Add the server:
|
||||
|
||||
|
||||
```json
|
||||
{
|
||||
"mcpServers": {
|
||||
"assistant": {
|
||||
"command": "/ABSOLUTE/PATH/TO/node",
|
||||
"args": [
|
||||
"/ABSOLUTE/PATH/TO/deClawed-Assity-Kitty/build/index.js"
|
||||
]
|
||||
"command": "/ABSOLUTE/PATH/TO/node",
|
||||
"args": [
|
||||
"/ABSOLUTE/PATH/TO/deClawed-Assity-Kitty/build/index.js"
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
|
||||
Replace paths with the output of `which node` and your actual project location.
|
||||
|
||||
|
||||
## 9. Add/Configure API Keys, Credentials, and Other Secrets
|
||||
|
||||
|
||||
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"]
|
||||
"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) |
|
||||
@@ -255,28 +341,38 @@ cp accounts.example.json accounts.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**.
|
||||
|
||||
|
||||
---
|
||||
|
||||
|
||||
## MCP Tools
|
||||
|
||||
|
||||
| Tool | Description |
|
||||
|------|-------------|
|
||||
| `fetch_new_emails` | Fetches unread emails for a given account. Classification and action prompts are automatically appended to the response. |
|
||||
@@ -285,24 +381,32 @@ Fully quit (**Cmd+Q**, not just close the window) and reopen. The `assistant` se
|
||||
| `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. |
|
||||
|
||||
|
||||
## MCP Prompts (built in as of now-ish - add your own)
|
||||
### BETTER YET - DO A PR OR FORK
|
||||
|
||||
|
||||
| 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 |
|
||||
|
||||
|
||||
Invoke these from Claude Desktop's Connectors menu, or just type "Review my inbox" / "Review my secondary inbox."
|
||||
|
||||
|
||||
---
|
||||
|
||||
|
||||
## Two-Phase Workflow
|
||||
|
||||
|
||||
**Phase 1 -- Classify**
|
||||
|
||||
|
||||
The LLM calls `fetch_new_emails`, which returns email data with the classification instructions from `classify-emails.txt` appended. Each email is sorted into:
|
||||
|
||||
|
||||
| Category | Meaning | Action |
|
||||
|----------|---------|--------|
|
||||
| **A** | Acknowledgement / auto-reply | Delete |
|
||||
@@ -310,18 +414,23 @@ The LLM calls `fetch_new_emails`, which returns email data with the classificati
|
||||
| **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 source files |
|
||||
@@ -330,10 +439,13 @@ Using `take-action-on-emails.txt`, the LLM:
|
||||
| `npm test` | Run the test suite |
|
||||
| `npm run test:watch` | Run tests in watch mode |
|
||||
|
||||
|
||||
---
|
||||
|
||||
|
||||
## Project Structure
|
||||
|
||||
|
||||
```
|
||||
deClawed-Assity-Kitty/
|
||||
├── src/
|
||||
@@ -375,4 +487,4 @@ deClawed-Assity-Kitty/
|
||||
├── vitest.config.ts
|
||||
├── .gitignore
|
||||
└── README.md
|
||||
```
|
||||
```
|
||||
7
accountsAndCredentials/token.json.bak
Normal file
7
accountsAndCredentials/token.json.bak
Normal file
@@ -0,0 +1,7 @@
|
||||
{
|
||||
"access_token": "ya29.a0AT3oNZ9Db5cbvOq43MccPAw3bB6dmyKxfHkvLlHvvAnMGd-fQqyHYa0raFy5Tx0G0iJysQz_Hb9A-POPTp3_KJ7-6KpovEJPsgoTxy_jKlt81aa2CKKFWZlAClrvldH4I5XTJt6hyrDwu8fFvfBrpoqbVe0FK9yJWIMua3GAfChFjEebPMIqGF7VCwGjhXNMdOikNp_5SQaCgYKAagSARMSFQHGX2Miikn-iDccI4e7x_vlkScaaw0209",
|
||||
"refresh_token": "1//0fD27YPvUVJODCgYIARAAGA8SNwF-L9IrSeT9ypacVvfAmW0K7J6M7PS4o4i4LBBLKwgm54lvNs1-VyIWnYav_88jWcP3Ugb_7Xw",
|
||||
"scope": "https://www.googleapis.com/auth/calendar.events https://www.googleapis.com/auth/spreadsheets https://www.googleapis.com/auth/gmail.modify",
|
||||
"token_type": "Bearer",
|
||||
"expiry_date": 1783036437865
|
||||
}
|
||||
@@ -2,7 +2,7 @@ You are an expert Executive Assistant AI specialized in email management and pro
|
||||
|
||||
I have been applying for jobs, which generates a large volume of responses.
|
||||
|
||||
Review, in reverse chronoloical order, the first 150 emails in my inbox. Apply the following instructions to those emails.
|
||||
Review the first 200 emails in my inbox. Apply the following instructions to those emails.
|
||||
|
||||
STEP 1: Constraints
|
||||
- Do not make up information.
|
||||
@@ -25,7 +25,9 @@ STEP 3: DELETE emails classified as Category A and Category C.
|
||||
|
||||
STEP 4: ("Anti step") - NEVER DELETE Category B emails.
|
||||
|
||||
STEP 5: SUMMARIZE emails classified as Category B and Category D. For each, include:
|
||||
STEP 5: Confirm via natrual lanugage output in the cat, the total number of emails fetched for review.
|
||||
|
||||
STEP 6: 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
|
||||
|
||||
@@ -3,303 +3,303 @@ import { gmail_v1 } from "googleapis";
|
||||
import fs from "fs";
|
||||
import { server } from "../McpServer.js";
|
||||
import {
|
||||
accountSchema,
|
||||
getGmailClient,
|
||||
getSummaryPath,
|
||||
loadClassificationPrompt,
|
||||
loadActionPrompt,
|
||||
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
|
||||
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 ?? "";
|
||||
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 = "";
|
||||
const parts = message.payload?.parts;
|
||||
let encoded = "";
|
||||
|
||||
if (parts) {
|
||||
const textPart = parts.find((p) => p.mimeType === "text/plain");
|
||||
encoded = textPart?.body?.data ?? "";
|
||||
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) {
|
||||
const htmlPart = parts.find((p) => p.mimeType === "text/html");
|
||||
encoded = htmlPart?.body?.data ?? "";
|
||||
return message.snippet ?? "";
|
||||
}
|
||||
} else {
|
||||
encoded = message.payload?.body?.data ?? "";
|
||||
}
|
||||
|
||||
if (!encoded) {
|
||||
return message.snippet ?? "";
|
||||
}
|
||||
|
||||
return Buffer.from(encoded, "base64url").toString("utf-8");
|
||||
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)"),
|
||||
"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(200)
|
||||
.describe("Maximum number of unread emails to fetch (1-200)"),
|
||||
},
|
||||
},
|
||||
},
|
||||
async ({ account, maxResults }) => {
|
||||
try {
|
||||
const gmail = getGmailClient(account);
|
||||
async ({ account, maxResults }) => {
|
||||
try {
|
||||
const gmail = getGmailClient(account);
|
||||
|
||||
const listResponse = await gmail.users.messages.list({
|
||||
userId: "me",
|
||||
q: "is:unread",
|
||||
maxResults,
|
||||
});
|
||||
const listResponse = await gmail.users.messages.list({
|
||||
userId: "me",
|
||||
q: "is:unread",
|
||||
maxResults,
|
||||
});
|
||||
|
||||
const messageIds = listResponse.data.messages ?? [];
|
||||
const messageIds = listResponse.data.messages ?? [];
|
||||
|
||||
if (messageIds.length === 0) {
|
||||
return {
|
||||
content: [{ type: "text" as const, text: "No unread emails found." }],
|
||||
};
|
||||
}
|
||||
if (messageIds.length === 0) {
|
||||
return {
|
||||
content: [{ type: "text" as const, text: "No unread emails found." }],
|
||||
};
|
||||
}
|
||||
|
||||
const emails: string[] = [];
|
||||
const emails: string[] = [];
|
||||
|
||||
for (const msg of messageIds) {
|
||||
const detail = await gmail.users.messages.get({
|
||||
userId: "me",
|
||||
id: msg.id!,
|
||||
format: "full",
|
||||
});
|
||||
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 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;
|
||||
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")
|
||||
);
|
||||
}
|
||||
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}`
|
||||
: "");
|
||||
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}`,
|
||||
},
|
||||
],
|
||||
};
|
||||
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"),
|
||||
"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) {
|
||||
async ({ account, 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}`);
|
||||
}
|
||||
}
|
||||
const gmail = getGmailClient(account);
|
||||
const results: string[] = [];
|
||||
|
||||
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}`,
|
||||
},
|
||||
],
|
||||
};
|
||||
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;
|
||||
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"),
|
||||
"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);
|
||||
async ({ account, entries }) => {
|
||||
try {
|
||||
const summaryPath = getSummaryPath(account);
|
||||
|
||||
let summary: SummaryEntry[] = [];
|
||||
if (fs.existsSync(summaryPath)) {
|
||||
summary = JSON.parse(fs.readFileSync(summaryPath, "utf-8"));
|
||||
}
|
||||
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,
|
||||
}));
|
||||
const now = new Date();
|
||||
const nowIso = now.toISOString();
|
||||
const newEntries: SummaryEntry[] = entries.map((e) => ({
|
||||
...e,
|
||||
addedAt: nowIso,
|
||||
}));
|
||||
|
||||
summary.push(...newEntries);
|
||||
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;
|
||||
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));
|
||||
fs.writeFileSync(summaryPath, JSON.stringify(summary, null, 2));
|
||||
|
||||
const purgeNote = purged > 0
|
||||
? `\nPurged ${purged} entry/entries older than 30 days.`
|
||||
: "";
|
||||
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}`,
|
||||
},
|
||||
],
|
||||
};
|
||||
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}`,
|
||||
},
|
||||
],
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user