+
+ );
+}
+
+function ConfigurationSection({
+ deploymentId,
+ setDeploymentId,
+ apiKey,
+ setApiKey,
+ setHasChanges,
+ isConfigured,
+ defaultExpanded = true,
+}) {
+ const { t } = useTranslation();
+ const [expanded, setExpanded] = useState(defaultExpanded);
+
+ return (
+
+
+
+ toggleSkill(skill)}
+ />
+
+
+ {isMultiUserMode && (
+
+ 
+
+
+
+
+ )}
+
+ + {t("agent.skill.gmail.multiUserWarning")} +
+
+
+
+ ) : (
+ <>
+
+
+
+ {expanded && (
+
+ );
+}
+
+function SkillSearchInput({ onSearch }) {
+ const { t } = useTranslation();
+ const inputRef = useRef(null);
+
+ const debouncedSearch = useMemo(
+ () =>
+ debounce((value) => {
+ onSearch(value);
+ }, 300),
+ [onSearch]
+ );
+
+ useEffect(() => {
+ return () => {
+ debouncedSearch.cancel();
+ };
+ }, [debouncedSearch]);
+
+ const handleChange = (e) => {
+ debouncedSearch(e.target.value);
+ };
+
+ return (
+
+
+ )}
+
+
+
+
+
+
+ {t("agent.skill.gmail.deploymentIdHelp")}
+
+
+ {
+ setDeploymentId(e.target.value);
+ setHasChanges(true);
+ }}
+ placeholder="AKfycb..."
+ className="w-full px-3 py-2 bg-theme-bg-primary border border-theme-sidebar-border rounded-lg text-theme-text-primary text-sm placeholder:text-theme-text-secondary/50"
+ />
+
+
+ {!isConfigured && (
+
+
+
+ {t("agent.skill.gmail.apiKeyHelp")}
+
+
+ {
+ setApiKey(e.target.value);
+ setHasChanges(true);
+ }}
+ placeholder="Your API key..."
+ className="w-full px-3 py-2 bg-theme-bg-primary border border-theme-sidebar-border rounded-lg text-theme-text-primary text-sm placeholder:text-theme-text-secondary/50"
+ />
+
+
+ )}
+ + {t("agent.skill.gmail.configurationRequired")} +
+
+
+
+ );
+}
+
+function SkillsSection({ skillCategories, disabledSkills, onToggle }) {
+ const { t } = useTranslation();
+ const [searchTerm, setSearchTerm] = useState("");
+
+ const handleSearch = useCallback((value) => {
+ setSearchTerm(value);
+ }, []);
+
+ const filteredCategories = useMemo(
+ () => filterSkillCategories(skillCategories, searchTerm),
+ [skillCategories, searchTerm]
+ );
+
+ const hasResults = Object.keys(filteredCategories).length > 0;
+
+ return (
+
+
+ );
+}
+
+function CategorySection({ category, disabledSkills, onToggle }) {
+ const Icon = category.icon;
+
+ return (
+
+ {Object.entries(filteredCategories).map(([categoryKey, category]) => (
+
+ ) : (
+ + {t("agent.skill.gmail.noSkillsFound")} +
+ )} +
+
+ );
+}
+
+function SkillRow({ skill, disabled, onToggle }) {
+ return (
+
+
+
+ {category.skills.map((skill) => (
+ onToggle(skill.name)}
+ />
+ ))}
+
+
+
+ );
+}
+
+function HiddenFormInputs({ disabledSkills, deploymentId, apiKey }) {
+ return (
+ <>
+
+
+
+
+ );
+}
diff --git a/frontend/src/pages/Admin/Agents/GMailSkillPanel/utils.js b/frontend/src/pages/Admin/Agents/GMailSkillPanel/utils.js
new file mode 100644
index 00000000..ea683adc
--- /dev/null
+++ b/frontend/src/pages/Admin/Agents/GMailSkillPanel/utils.js
@@ -0,0 +1,168 @@
+import {
+ MagnifyingGlass,
+ EnvelopeOpen,
+ PaperPlaneTilt,
+ ChartBar,
+ PencilSimple,
+} from "@phosphor-icons/react";
+import strDistance from "js-levenshtein";
+
+const LEVENSHTEIN_THRESHOLD = 3;
+
+export const getGmailSkills = (t) => ({
+ search: {
+ title: t("agent.skill.gmail.categories.search.title"),
+ description: t("agent.skill.gmail.categories.search.description"),
+ icon: MagnifyingGlass,
+ skills: [
+ {
+ name: "gmail-get-inbox",
+ title: t("agent.skill.gmail.skills.getInbox.title"),
+ description: t("agent.skill.gmail.skills.getInbox.description"),
+ },
+ {
+ name: "gmail-search",
+ title: t("agent.skill.gmail.skills.search.title"),
+ description: t("agent.skill.gmail.skills.search.description"),
+ },
+ {
+ name: "gmail-read-thread",
+ title: t("agent.skill.gmail.skills.readThread.title"),
+ description: t("agent.skill.gmail.skills.readThread.description"),
+ },
+ ],
+ },
+ drafts: {
+ title: t("agent.skill.gmail.categories.drafts.title"),
+ description: t("agent.skill.gmail.categories.drafts.description"),
+ icon: PencilSimple,
+ skills: [
+ {
+ name: "gmail-create-draft",
+ title: t("agent.skill.gmail.skills.createDraft.title"),
+ description: t("agent.skill.gmail.skills.createDraft.description"),
+ },
+ {
+ name: "gmail-create-draft-reply",
+ title: t("agent.skill.gmail.skills.createDraftReply.title"),
+ description: t("agent.skill.gmail.skills.createDraftReply.description"),
+ },
+ {
+ name: "gmail-update-draft",
+ title: t("agent.skill.gmail.skills.updateDraft.title"),
+ description: t("agent.skill.gmail.skills.updateDraft.description"),
+ },
+ {
+ name: "gmail-get-draft",
+ title: t("agent.skill.gmail.skills.getDraft.title"),
+ description: t("agent.skill.gmail.skills.getDraft.description"),
+ },
+ {
+ name: "gmail-list-drafts",
+ title: t("agent.skill.gmail.skills.listDrafts.title"),
+ description: t("agent.skill.gmail.skills.listDrafts.description"),
+ },
+ {
+ name: "gmail-delete-draft",
+ title: t("agent.skill.gmail.skills.deleteDraft.title"),
+ description: t("agent.skill.gmail.skills.deleteDraft.description"),
+ },
+ {
+ name: "gmail-send-draft",
+ title: t("agent.skill.gmail.skills.sendDraft.title"),
+ description: t("agent.skill.gmail.skills.sendDraft.description"),
+ },
+ ],
+ },
+ send: {
+ title: t("agent.skill.gmail.categories.send.title"),
+ description: t("agent.skill.gmail.categories.send.description"),
+ icon: PaperPlaneTilt,
+ skills: [
+ {
+ name: "gmail-send-email",
+ title: t("agent.skill.gmail.skills.sendEmail.title"),
+ description: t("agent.skill.gmail.skills.sendEmail.description"),
+ },
+ {
+ name: "gmail-reply-to-thread",
+ title: t("agent.skill.gmail.skills.replyToThread.title"),
+ description: t("agent.skill.gmail.skills.replyToThread.description"),
+ },
+ ],
+ },
+ threads: {
+ title: t("agent.skill.gmail.categories.threads.title"),
+ description: t("agent.skill.gmail.categories.threads.description"),
+ icon: EnvelopeOpen,
+ skills: [
+ {
+ name: "gmail-mark-read",
+ title: t("agent.skill.gmail.skills.markRead.title"),
+ description: t("agent.skill.gmail.skills.markRead.description"),
+ },
+ {
+ name: "gmail-mark-unread",
+ title: t("agent.skill.gmail.skills.markUnread.title"),
+ description: t("agent.skill.gmail.skills.markUnread.description"),
+ },
+ {
+ name: "gmail-move-to-trash",
+ title: t("agent.skill.gmail.skills.moveToTrash.title"),
+ description: t("agent.skill.gmail.skills.moveToTrash.description"),
+ },
+ {
+ name: "gmail-move-to-archive",
+ title: t("agent.skill.gmail.skills.moveToArchive.title"),
+ description: t("agent.skill.gmail.skills.moveToArchive.description"),
+ },
+ {
+ name: "gmail-move-to-inbox",
+ title: t("agent.skill.gmail.skills.moveToInbox.title"),
+ description: t("agent.skill.gmail.skills.moveToInbox.description"),
+ },
+ ],
+ },
+ account: {
+ title: t("agent.skill.gmail.categories.account.title"),
+ description: t("agent.skill.gmail.categories.account.description"),
+ icon: ChartBar,
+ skills: [
+ {
+ name: "gmail-get-mailbox-stats",
+ title: t("agent.skill.gmail.skills.getMailboxStats.title"),
+ description: t("agent.skill.gmail.skills.getMailboxStats.description"),
+ },
+ ],
+ },
+});
+
+function skillMatchesSearch(skill, searchTerm) {
+ if (!searchTerm) return true;
+
+ const normalizedSearch = searchTerm.toLowerCase().trim();
+ const titleLower = skill.title.toLowerCase();
+ const descLower = skill.description.toLowerCase();
+
+ if (titleLower.includes(normalizedSearch)) return true;
+ if (descLower.includes(normalizedSearch)) return true;
+ if (strDistance(titleLower, normalizedSearch) <= LEVENSHTEIN_THRESHOLD)
+ return true;
+
+ return false;
+}
+
+export function filterSkillCategories(skillCategories, searchTerm) {
+ if (!searchTerm) return skillCategories;
+
+ const filtered = {};
+ for (const [key, category] of Object.entries(skillCategories)) {
+ const matchingSkills = category.skills.filter((skill) =>
+ skillMatchesSearch(skill, searchTerm)
+ );
+ if (matchingSkills.length > 0) {
+ filtered[key] = { ...category, skills: matchingSkills };
+ }
+ }
+ return filtered;
+}
diff --git a/frontend/src/pages/Admin/Agents/index.jsx b/frontend/src/pages/Admin/Agents/index.jsx
index 26564cdc..0e106e5a 100644
--- a/frontend/src/pages/Admin/Agents/index.jsx
+++ b/frontend/src/pages/Admin/Agents/index.jsx
@@ -64,11 +64,26 @@ export default function AdminAgents() {
useState(false);
const defaultSkills = getDefaultSkills(t);
- const configurableSkills = getConfigurableSkills(t, {
+ const allConfigurableSkills = getConfigurableSkills(t, {
fileSystemAgentAvailable,
createFilesAgentAvailable,
});
+ // Filter skills based on mode restrictions
+ // singleUserOnly -> hidden in multi-user mode
+ // multiUserOnly -> hidden when NOT in multi-user mode
+ const isMultiUserMode = settings?.MultiUserMode ?? false;
+ const configurableSkills = Object.fromEntries(
+ Object.entries(allConfigurableSkills).filter(([_, skillConfig]) => {
+ if (!skillConfig.mode) return true;
+ if (skillConfig.mode.includes("singleUserOnly") && isMultiUserMode)
+ return false;
+ if (skillConfig.mode.includes("multiUserOnly") && !isMultiUserMode)
+ return false;
+ return true;
+ })
+ );
+
// Alert user if they try to leave the page with unsaved changes
useEffect(() => {
const handleBeforeUnload = (event) => {
diff --git a/frontend/src/pages/Admin/Agents/skills.js b/frontend/src/pages/Admin/Agents/skills.js
index 8c0aabed..37be377c 100644
--- a/frontend/src/pages/Admin/Agents/skills.js
+++ b/frontend/src/pages/Admin/Agents/skills.js
@@ -4,6 +4,7 @@ import GenericSkillPanel from "./GenericSkillPanel";
import DefaultSkillPanel from "./DefaultSkillPanel";
import FileSystemSkillPanel from "./FileSystemSkillPanel";
import CreateFileSkillPanel from "./CreateFileSkillPanel";
+import GMailSkillPanel from "./GMailSkillPanel";
import {
Brain,
File,
@@ -11,6 +12,7 @@ import {
ChartBar,
FolderOpen,
FilePlus,
+ EnvelopeSimple,
} from "@phosphor-icons/react";
import RAGImage from "@/media/agents/rag-memory.png";
import SummarizeImage from "@/media/agents/view-summarize.png";
@@ -90,4 +92,12 @@ export const getConfigurableSkills = (
component: AgentSQLConnectorSelection,
skill: "sql-agent",
},
+ "gmail-agent": {
+ title: t("agent.skill.gmail.title"),
+ description: t("agent.skill.gmail.description"),
+ component: GMailSkillPanel,
+ skill: "gmail-agent",
+ icon: EnvelopeSimple,
+ mode: ["singleUserOnly"],
+ },
});
diff --git a/server/endpoints/admin.js b/server/endpoints/admin.js
index a9b32df0..b0cb7dc8 100644
--- a/server/endpoints/admin.js
+++ b/server/endpoints/admin.js
@@ -409,6 +409,15 @@ function adminEndpoints(app) {
case "disabled_create_files_skills":
requestedSettings[label] = safeJsonParse(setting?.value, []);
break;
+ case "disabled_gmail_skills":
+ requestedSettings[label] = safeJsonParse(setting?.value, []);
+ break;
+ case "gmail_deployment_id":
+ requestedSettings[label] = setting?.value || null;
+ break;
+ case "gmail_api_key":
+ requestedSettings[label] = setting?.value || null;
+ break;
case "imported_agent_skills":
requestedSettings[label] = ImportedPlugin.listImportedPlugins();
break;
diff --git a/server/models/systemSettings.js b/server/models/systemSettings.js
index 13ccb5cd..36ca930a 100644
--- a/server/models/systemSettings.js
+++ b/server/models/systemSettings.js
@@ -35,6 +35,9 @@ const SystemSettings = {
"disabled_agent_skills",
"disabled_filesystem_skills",
"disabled_create_files_skills",
+ "disabled_gmail_skills",
+ "gmail_deployment_id",
+ "gmail_api_key",
"imported_agent_skills",
"custom_app_name",
"feature_flags",
@@ -54,6 +57,9 @@ const SystemSettings = {
"disabled_agent_skills",
"disabled_filesystem_skills",
"disabled_create_files_skills",
+ "disabled_gmail_skills",
+ "gmail_deployment_id",
+ "gmail_api_key",
"agent_sql_connections",
"custom_app_name",
"default_system_prompt",
@@ -174,6 +180,33 @@ const SystemSettings = {
return JSON.stringify([]);
}
},
+ disabled_gmail_skills: (updates) => {
+ try {
+ const skills = updates.split(",").filter((skill) => !!skill);
+ return JSON.stringify(skills);
+ } catch {
+ console.error(`Could not validate disabled gmail skills.`);
+ return JSON.stringify([]);
+ }
+ },
+ gmail_deployment_id: (update) => {
+ try {
+ if (!update || typeof update !== "string") return null;
+ return String(update).trim();
+ } finally {
+ const GmailBridge = require("../utils/agents/aibitat/plugins/gmail/lib");
+ GmailBridge.reset();
+ }
+ },
+ gmail_api_key: (update) => {
+ try {
+ if (!update || typeof update !== "string") return null;
+ return String(update).trim();
+ } finally {
+ const GmailBridge = require("../utils/agents/aibitat/plugins/gmail/lib");
+ GmailBridge.reset();
+ }
+ },
agent_sql_connections: async (updates) => {
const existingConnections = safeJsonParse(
(await SystemSettings.get({ label: "agent_sql_connections" }))?.value,
diff --git a/server/utils/agents/aibitat/plugins/gmail/account/gmail-get-mailbox-stats.js b/server/utils/agents/aibitat/plugins/gmail/account/gmail-get-mailbox-stats.js
new file mode 100644
index 00000000..c63b6262
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/account/gmail-get-mailbox-stats.js
@@ -0,0 +1,75 @@
+const gmailLib = require("../lib.js");
+
+module.exports.GmailGetMailboxStats = {
+ name: "gmail-get-mailbox-stats",
+ plugin: function () {
+ return {
+ name: "gmail-get-mailbox-stats",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Used for general account information. Reports Gmail mailbox statistics including unread counts for inbox, " +
+ "priority inbox, starred messages, and spam folder.",
+ examples: [
+ {
+ prompt: "How much of my mailbox quota is remaining?",
+ call: JSON.stringify({}),
+ },
+ {
+ prompt: "Show me my mailbox statistics",
+ call: JSON.stringify({}),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {},
+ additionalProperties: false,
+ },
+ handler: async function () {
+ try {
+ this.super.handlerProps.log(
+ `Using the gmail-get-mailbox-stats tool.`
+ );
+
+ this.super.introspect(
+ `${this.caller}: Getting Gmail mailbox statistics`
+ );
+
+ const result = await gmailLib.getMailboxStats();
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to get mailbox stats - ${result.error}`
+ );
+ return `Error getting mailbox statistics: ${result.error}`;
+ }
+
+ const stats = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully retrieved mailbox statistics`
+ );
+
+ return (
+ `Gmail Mailbox Statistics:\n\n` +
+ `Inbox Unread: ${stats.inboxUnreadCount}\n` +
+ `Priority Inbox Unread: ${stats.priorityInboxUnreadCount}\n` +
+ `Starred Unread: ${stats.starredUnreadCount}\n` +
+ `Spam Unread: ${stats.spamUnreadCount}\n\n` +
+ `Use gmail-search to find and read specific emails.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-get-mailbox-stats error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error getting mailbox statistics: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft-reply.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft-reply.js
new file mode 100644
index 00000000..1809d515
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft-reply.js
@@ -0,0 +1,220 @@
+const gmailLib = require("../lib.js");
+const { prepareAttachment, MAX_TOTAL_ATTACHMENT_SIZE } = require("../lib.js");
+const { humanFileSize } = require("../../../../../helpers");
+
+module.exports.GmailCreateDraftReply = {
+ name: "gmail-create-draft-reply",
+ plugin: function () {
+ return {
+ name: "gmail-create-draft-reply",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Create a draft reply to an existing email thread in Gmail. " +
+ "The draft will be saved but not sent. You can choose to reply to all recipients or just the sender. " +
+ "Supports file attachments.",
+ examples: [
+ {
+ prompt: "Create a draft reply to thread 18abc123def",
+ call: JSON.stringify({
+ threadId: "18abc123def",
+ body: "Thank you for your email. I will review this and get back to you shortly.",
+ replyAll: false,
+ }),
+ },
+ {
+ prompt: "Draft a reply-all response to the thread",
+ call: JSON.stringify({
+ threadId: "18abc123def",
+ body: "Thanks everyone for your input. Here are my thoughts...",
+ replyAll: true,
+ }),
+ },
+ {
+ prompt: "Create a draft reply with an attachment",
+ call: JSON.stringify({
+ threadId: "18abc123def",
+ body: "Please find the requested document attached.",
+ attachments: ["/Users/me/Documents/document.pdf"],
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ threadId: {
+ type: "string",
+ description: "The Gmail thread ID to reply to.",
+ },
+ body: {
+ type: "string",
+ description: "Plain text reply body content.",
+ },
+ replyAll: {
+ type: "boolean",
+ description:
+ "Whether to reply to all recipients. Defaults to false (reply to sender only).",
+ default: false,
+ },
+ cc: {
+ type: "string",
+ description:
+ "Additional CC recipient email address(es). Optional.",
+ },
+ bcc: {
+ type: "string",
+ description: "BCC recipient email address(es). Optional.",
+ },
+ htmlBody: {
+ type: "string",
+ description: "HTML version of the reply body. Optional.",
+ },
+ attachments: {
+ type: "array",
+ items: { type: "string" },
+ description:
+ "Array of absolute file paths to attach to the draft reply.",
+ },
+ },
+ required: ["threadId", "body"],
+ additionalProperties: false,
+ },
+ handler: async function ({
+ threadId,
+ body,
+ replyAll = false,
+ cc,
+ bcc,
+ htmlBody,
+ attachments,
+ }) {
+ try {
+ this.super.handlerProps.log(
+ `Using the gmail-create-draft-reply tool.`
+ );
+
+ if (!threadId || !body) {
+ return "Error: 'threadId' and 'body' are required.";
+ }
+
+ const preparedAttachments = [];
+ const attachmentSummaries = [];
+ let totalAttachmentSize = 0;
+
+ if (Array.isArray(attachments) && attachments.length > 0) {
+ this.super.introspect(
+ `${this.caller}: Validating ${attachments.length} attachment(s)...`
+ );
+
+ for (const filePath of attachments) {
+ const result = prepareAttachment(filePath);
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Attachment validation failed - ${result.error}`
+ );
+ return `Error with attachment: ${result.error}`;
+ }
+
+ totalAttachmentSize += result.fileInfo.size;
+ if (totalAttachmentSize > MAX_TOTAL_ATTACHMENT_SIZE) {
+ const totalFormatted = humanFileSize(
+ totalAttachmentSize,
+ true
+ );
+ this.super.introspect(
+ `${this.caller}: Total attachment size (${totalFormatted}) exceeds 20MB limit`
+ );
+ return `Error: Total attachment size (${totalFormatted}) exceeds the 20MB limit. Please reduce the number or size of attachments.`;
+ }
+
+ preparedAttachments.push(result.attachment);
+ attachmentSummaries.push(
+ `${result.fileInfo.name} (${result.fileInfo.sizeFormatted})`
+ );
+ this.super.introspect(
+ `${this.caller}: Prepared attachment "${result.fileInfo.name}"`
+ );
+ }
+ }
+
+ if (this.super.requestToolApproval) {
+ const attachmentNote =
+ preparedAttachments.length > 0
+ ? ` with ${preparedAttachments.length} attachment(s): ${attachmentSummaries.join(", ")}`
+ : "";
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: {
+ threadId,
+ replyAll,
+ attachmentCount: preparedAttachments.length,
+ },
+ description: `Create Gmail draft reply to thread "${threadId}"${replyAll ? " (reply all)" : ""}${attachmentNote}`,
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ this.super.introspect(
+ `${this.caller}: Creating draft reply to thread ${threadId}${replyAll ? " (reply all)" : ""}${preparedAttachments.length > 0 ? ` with ${preparedAttachments.length} attachment(s)` : ""}`
+ );
+
+ const options = {};
+ if (cc) options.cc = cc;
+ if (bcc) options.bcc = bcc;
+ if (htmlBody) options.htmlBody = htmlBody;
+ if (preparedAttachments.length > 0) {
+ options.attachments = preparedAttachments;
+ }
+
+ const result = await gmailLib.createDraftReply(
+ threadId,
+ body,
+ replyAll,
+ options
+ );
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to create draft reply - ${result.error}`
+ );
+ return `Error creating Gmail draft reply: ${result.error}`;
+ }
+
+ const draft = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully created draft reply (ID: ${draft.draftId})`
+ );
+
+ return (
+ `Successfully created Gmail draft reply:\n` +
+ `Draft ID: ${draft.draftId}\n` +
+ `Message ID: ${draft.messageId}\n` +
+ `To: ${draft.to}\n` +
+ `Subject: ${draft.subject}\n` +
+ `Reply Type: ${replyAll ? "Reply All" : "Reply"}\n` +
+ (preparedAttachments.length > 0
+ ? `Attachments: ${attachmentSummaries.join(", ")}\n`
+ : "") +
+ `\nThe draft reply has been saved and can be edited or sent later.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-create-draft-reply error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error creating Gmail draft reply: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft.js
new file mode 100644
index 00000000..9b2b0ee2
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-create-draft.js
@@ -0,0 +1,217 @@
+const gmailLib = require("../lib.js");
+const { prepareAttachment, MAX_TOTAL_ATTACHMENT_SIZE } = require("../lib.js");
+const { humanFileSize } = require("../../../../../helpers");
+
+module.exports.GmailCreateDraft = {
+ name: "gmail-create-draft",
+ plugin: function () {
+ return {
+ name: "gmail-create-draft",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Create a new draft email in Gmail. The draft will be saved but not sent. " +
+ "You can optionally include CC, BCC recipients, HTML body content, and file attachments.",
+ examples: [
+ {
+ prompt:
+ "Create a draft email to john@example.com about the meeting",
+ call: JSON.stringify({
+ to: "john@example.com",
+ subject: "Meeting Tomorrow",
+ body: "Hi John,\n\nJust wanted to confirm our meeting tomorrow at 2pm.\n\nBest regards",
+ }),
+ },
+ {
+ prompt: "Draft an email with CC recipients",
+ call: JSON.stringify({
+ to: "john@example.com",
+ subject: "Project Update",
+ body: "Please see the attached project update.",
+ cc: "manager@example.com",
+ }),
+ },
+ {
+ prompt: "Create a draft with an attachment",
+ call: JSON.stringify({
+ to: "john@example.com",
+ subject: "Report",
+ body: "Please find the report attached.",
+ attachments: ["/Users/me/Documents/report.pdf"],
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ to: {
+ type: "string",
+ description:
+ "Recipient email address(es). Multiple addresses can be comma-separated.",
+ },
+ subject: {
+ type: "string",
+ description: "Email subject line.",
+ },
+ body: {
+ type: "string",
+ description: "Plain text email body content.",
+ },
+ cc: {
+ type: "string",
+ description: "CC recipient email address(es). Optional.",
+ },
+ bcc: {
+ type: "string",
+ description: "BCC recipient email address(es). Optional.",
+ },
+ htmlBody: {
+ type: "string",
+ description: "HTML version of the email body. Optional.",
+ },
+ attachments: {
+ type: "array",
+ items: { type: "string" },
+ description:
+ "Array of absolute file paths to attach to the draft.",
+ },
+ },
+ required: ["to", "subject", "body"],
+ additionalProperties: false,
+ },
+ handler: async function ({
+ to,
+ subject,
+ body,
+ cc,
+ bcc,
+ htmlBody,
+ attachments,
+ }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-create-draft tool.`);
+
+ if (!to || !subject || !body) {
+ return "Error: 'to', 'subject', and 'body' are required.";
+ }
+
+ const preparedAttachments = [];
+ const attachmentSummaries = [];
+ let totalAttachmentSize = 0;
+
+ if (Array.isArray(attachments) && attachments.length > 0) {
+ this.super.introspect(
+ `${this.caller}: Validating ${attachments.length} attachment(s)...`
+ );
+
+ for (const filePath of attachments) {
+ const result = prepareAttachment(filePath);
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Attachment validation failed - ${result.error}`
+ );
+ return `Error with attachment: ${result.error}`;
+ }
+
+ totalAttachmentSize += result.fileInfo.size;
+ if (totalAttachmentSize > MAX_TOTAL_ATTACHMENT_SIZE) {
+ const totalFormatted = humanFileSize(
+ totalAttachmentSize,
+ true
+ );
+ this.super.introspect(
+ `${this.caller}: Total attachment size (${totalFormatted}) exceeds 20MB limit`
+ );
+ return `Error: Total attachment size (${totalFormatted}) exceeds the 20MB limit. Please reduce the number or size of attachments.`;
+ }
+
+ preparedAttachments.push(result.attachment);
+ attachmentSummaries.push(
+ `${result.fileInfo.name} (${result.fileInfo.sizeFormatted})`
+ );
+ this.super.introspect(
+ `${this.caller}: Prepared attachment "${result.fileInfo.name}"`
+ );
+ }
+ }
+
+ if (this.super.requestToolApproval) {
+ const attachmentNote =
+ preparedAttachments.length > 0
+ ? ` with ${preparedAttachments.length} attachment(s): ${attachmentSummaries.join(", ")}`
+ : "";
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: {
+ to,
+ subject,
+ attachmentCount: preparedAttachments.length,
+ },
+ description: `Create Gmail draft to "${to}" with subject "${subject}"${attachmentNote}`,
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ this.super.introspect(
+ `${this.caller}: Creating Gmail draft to ${to}${preparedAttachments.length > 0 ? ` with ${preparedAttachments.length} attachment(s)` : ""}`
+ );
+
+ const options = {};
+ if (cc) options.cc = cc;
+ if (bcc) options.bcc = bcc;
+ if (htmlBody) options.htmlBody = htmlBody;
+ if (preparedAttachments.length > 0) {
+ options.attachments = preparedAttachments;
+ }
+
+ const result = await gmailLib.createDraft(
+ to,
+ subject,
+ body,
+ options
+ );
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to create draft - ${result.error}`
+ );
+ return `Error creating Gmail draft: ${result.error}`;
+ }
+
+ const draft = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully created draft (ID: ${draft.draftId})`
+ );
+
+ return (
+ `Successfully created Gmail draft:\n` +
+ `Draft ID: ${draft.draftId}\n` +
+ `Message ID: ${draft.messageId}\n` +
+ `To: ${draft.to}\n` +
+ `Subject: ${draft.subject}\n` +
+ (preparedAttachments.length > 0
+ ? `Attachments: ${attachmentSummaries.join(", ")}\n`
+ : "") +
+ `\nThe draft has been saved and can be edited or sent later.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-create-draft error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error creating Gmail draft: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-delete-draft.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-delete-draft.js
new file mode 100644
index 00000000..ce569e8e
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-delete-draft.js
@@ -0,0 +1,87 @@
+const gmailLib = require("../lib.js");
+
+module.exports.GmailDeleteDraft = {
+ name: "gmail-delete-draft",
+ plugin: function () {
+ return {
+ name: "gmail-delete-draft",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Delete a draft email from Gmail. " +
+ "This action is permanent and cannot be undone.",
+ examples: [
+ {
+ prompt: "Delete the draft with ID r123456",
+ call: JSON.stringify({
+ draftId: "r123456",
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ draftId: {
+ type: "string",
+ description: "The Gmail draft ID to delete.",
+ },
+ },
+ required: ["draftId"],
+ additionalProperties: false,
+ },
+ handler: async function ({ draftId }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-delete-draft tool.`);
+
+ if (!draftId) {
+ return "Error: 'draftId' is required.";
+ }
+
+ if (this.super.requestToolApproval) {
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: { draftId },
+ description: `Delete Gmail draft "${draftId}"`,
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ this.super.introspect(
+ `${this.caller}: Deleting Gmail draft ${draftId}`
+ );
+
+ const result = await gmailLib.deleteDraft(draftId);
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to delete draft - ${result.error}`
+ );
+ return `Error deleting Gmail draft: ${result.error}`;
+ }
+
+ this.super.introspect(
+ `${this.caller}: Successfully deleted draft ${draftId}`
+ );
+
+ return `Successfully deleted Gmail draft (ID: ${draftId}).`;
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-delete-draft error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error deleting Gmail draft: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-get-draft.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-get-draft.js
new file mode 100644
index 00000000..66c3829c
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-get-draft.js
@@ -0,0 +1,84 @@
+const gmailLib = require("../lib.js");
+
+module.exports.GmailGetDraft = {
+ name: "gmail-get-draft",
+ plugin: function () {
+ return {
+ name: "gmail-get-draft",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Retrieve a specific draft email by its ID. " +
+ "Returns the draft details including recipient, subject, and body content.",
+ examples: [
+ {
+ prompt: "Get the draft with ID r123456",
+ call: JSON.stringify({
+ draftId: "r123456",
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ draftId: {
+ type: "string",
+ description: "The Gmail draft ID to retrieve.",
+ },
+ },
+ required: ["draftId"],
+ additionalProperties: false,
+ },
+ handler: async function ({ draftId }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-get-draft tool.`);
+
+ if (!draftId) {
+ return "Error: 'draftId' is required.";
+ }
+
+ this.super.introspect(
+ `${this.caller}: Retrieving Gmail draft ${draftId}`
+ );
+
+ const result = await gmailLib.getDraft(draftId);
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to get draft - ${result.error}`
+ );
+ return `Error retrieving Gmail draft: ${result.error}`;
+ }
+
+ const draft = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully retrieved draft (ID: ${draft.draftId})`
+ );
+
+ return (
+ `Gmail Draft:\n` +
+ `Draft ID: ${draft.draftId}\n` +
+ `Message ID: ${draft.messageId}\n` +
+ `To: ${draft.to}\n` +
+ (draft.cc ? `CC: ${draft.cc}\n` : "") +
+ (draft.bcc ? `BCC: ${draft.bcc}\n` : "") +
+ `Subject: ${draft.subject}\n` +
+ `Date: ${new Date(draft.date).toLocaleString()}\n` +
+ `\n--- Body ---\n${draft.body}`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-get-draft error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error retrieving Gmail draft: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-list-drafts.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-list-drafts.js
new file mode 100644
index 00000000..e41241d7
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-list-drafts.js
@@ -0,0 +1,96 @@
+const gmailLib = require("../lib.js");
+
+module.exports.GmailListDrafts = {
+ name: "gmail-list-drafts",
+ plugin: function () {
+ return {
+ name: "gmail-list-drafts",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "List all draft emails in Gmail. " +
+ "Returns a summary of each draft including ID, recipient, subject, and date.",
+ examples: [
+ {
+ prompt: "List my email drafts",
+ call: JSON.stringify({
+ limit: 25,
+ }),
+ },
+ {
+ prompt: "Show me the first 10 drafts",
+ call: JSON.stringify({
+ limit: 10,
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ limit: {
+ type: "number",
+ description:
+ "Maximum number of drafts to return (1-100). Defaults to 25.",
+ default: 25,
+ },
+ },
+ additionalProperties: false,
+ },
+ handler: async function ({ limit = 25 }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-list-drafts tool.`);
+
+ this.super.introspect(
+ `${this.caller}: Listing Gmail drafts (limit: ${limit})`
+ );
+
+ const result = await gmailLib.listDrafts(limit);
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to list drafts - ${result.error}`
+ );
+ return `Error listing Gmail drafts: ${result.error}`;
+ }
+
+ const { totalDrafts, returned, drafts } = result.data;
+ this.super.introspect(
+ `${this.caller}: Found ${totalDrafts} total drafts, returning ${returned}`
+ );
+
+ if (totalDrafts === 0) {
+ return "No drafts found in Gmail.";
+ }
+
+ const summary = drafts
+ .map(
+ (d, i) =>
+ `${i + 1}. Draft ID: ${d.draftId}\n` +
+ ` To: ${d.to || "(no recipient)"}\n` +
+ ` Subject: ${d.subject || "(no subject)"}\n` +
+ ` Date: ${new Date(d.date).toLocaleString()}`
+ )
+ .join("\n\n");
+
+ return (
+ `Gmail Drafts (${returned} of ${totalDrafts} total):\n\n${summary}\n\n` +
+ `Use the draft ID with gmail-get-draft to view full content, ` +
+ `gmail-update-draft to edit, gmail-delete-draft to remove, ` +
+ `or gmail-send-draft to send.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-list-drafts error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error listing Gmail drafts: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-send-draft.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-send-draft.js
new file mode 100644
index 00000000..e06bc6ba
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-send-draft.js
@@ -0,0 +1,94 @@
+const gmailLib = require("../lib.js");
+
+module.exports.GmailSendDraft = {
+ name: "gmail-send-draft",
+ plugin: function () {
+ return {
+ name: "gmail-send-draft",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Send an existing draft email from Gmail. " +
+ "This will send the draft immediately and remove it from drafts. " +
+ "This action cannot be undone.",
+ examples: [
+ {
+ prompt: "Send the draft with ID r123456",
+ call: JSON.stringify({
+ draftId: "r123456",
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ draftId: {
+ type: "string",
+ description: "The Gmail draft ID to send.",
+ },
+ },
+ required: ["draftId"],
+ additionalProperties: false,
+ },
+ handler: async function ({ draftId }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-send-draft tool.`);
+
+ if (!draftId) {
+ return "Error: 'draftId' is required.";
+ }
+
+ if (this.super.requestToolApproval) {
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: { draftId },
+ description: `Send Gmail draft "${draftId}" - This will send the email immediately`,
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ this.super.introspect(
+ `${this.caller}: Sending Gmail draft ${draftId}`
+ );
+
+ const result = await gmailLib.sendDraft(draftId);
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to send draft - ${result.error}`
+ );
+ return `Error sending Gmail draft: ${result.error}`;
+ }
+
+ const { messageId, threadId } = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully sent draft as message ${messageId}`
+ );
+
+ return (
+ `Successfully sent Gmail draft:\n` +
+ `Message ID: ${messageId}\n` +
+ `Thread ID: ${threadId}\n\n` +
+ `The email has been sent and removed from drafts.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-send-draft error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error sending Gmail draft: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-update-draft.js b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-update-draft.js
new file mode 100644
index 00000000..8f7ae006
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/drafts/gmail-update-draft.js
@@ -0,0 +1,217 @@
+const gmailLib = require("../lib.js");
+const { prepareAttachment, MAX_TOTAL_ATTACHMENT_SIZE } = require("../lib.js");
+const { humanFileSize } = require("../../../../../helpers");
+
+module.exports.GmailUpdateDraft = {
+ name: "gmail-update-draft",
+ plugin: function () {
+ return {
+ name: "gmail-update-draft",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Update an existing draft email in Gmail. " +
+ "You must provide the draft ID and the new content for the draft. " +
+ "Supports file attachments.",
+ examples: [
+ {
+ prompt: "Update draft r123456 with new content",
+ call: JSON.stringify({
+ draftId: "r123456",
+ to: "john@example.com",
+ subject: "Updated: Meeting Tomorrow",
+ body: "Hi John,\n\nThe meeting has been rescheduled to 3pm.\n\nBest regards",
+ }),
+ },
+ {
+ prompt: "Update draft with an attachment",
+ call: JSON.stringify({
+ draftId: "r123456",
+ to: "john@example.com",
+ subject: "Report",
+ body: "Please find the updated report attached.",
+ attachments: ["/Users/me/Documents/report.pdf"],
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ draftId: {
+ type: "string",
+ description: "The Gmail draft ID to update.",
+ },
+ to: {
+ type: "string",
+ description:
+ "Recipient email address(es). Multiple addresses can be comma-separated.",
+ },
+ subject: {
+ type: "string",
+ description: "Email subject line.",
+ },
+ body: {
+ type: "string",
+ description: "Plain text email body content.",
+ },
+ cc: {
+ type: "string",
+ description: "CC recipient email address(es). Optional.",
+ },
+ bcc: {
+ type: "string",
+ description: "BCC recipient email address(es). Optional.",
+ },
+ htmlBody: {
+ type: "string",
+ description: "HTML version of the email body. Optional.",
+ },
+ attachments: {
+ type: "array",
+ items: { type: "string" },
+ description:
+ "Array of absolute file paths to attach to the draft.",
+ },
+ },
+ required: ["draftId", "to", "subject", "body"],
+ additionalProperties: false,
+ },
+ handler: async function ({
+ draftId,
+ to,
+ subject,
+ body,
+ cc,
+ bcc,
+ htmlBody,
+ attachments,
+ }) {
+ try {
+ this.super.handlerProps.log(`Using the gmail-update-draft tool.`);
+
+ if (!draftId || !to || !subject) {
+ return "Error: 'draftId', 'to', and 'subject' are required.";
+ }
+
+ const preparedAttachments = [];
+ const attachmentSummaries = [];
+ let totalAttachmentSize = 0;
+
+ if (Array.isArray(attachments) && attachments.length > 0) {
+ this.super.introspect(
+ `${this.caller}: Validating ${attachments.length} attachment(s)...`
+ );
+
+ for (const filePath of attachments) {
+ const result = prepareAttachment(filePath);
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Attachment validation failed - ${result.error}`
+ );
+ return `Error with attachment: ${result.error}`;
+ }
+
+ totalAttachmentSize += result.fileInfo.size;
+ if (totalAttachmentSize > MAX_TOTAL_ATTACHMENT_SIZE) {
+ const totalFormatted = humanFileSize(
+ totalAttachmentSize,
+ true
+ );
+ this.super.introspect(
+ `${this.caller}: Total attachment size (${totalFormatted}) exceeds 20MB limit`
+ );
+ return `Error: Total attachment size (${totalFormatted}) exceeds the 20MB limit. Please reduce the number or size of attachments.`;
+ }
+
+ preparedAttachments.push(result.attachment);
+ attachmentSummaries.push(
+ `${result.fileInfo.name} (${result.fileInfo.sizeFormatted})`
+ );
+ this.super.introspect(
+ `${this.caller}: Prepared attachment "${result.fileInfo.name}"`
+ );
+ }
+ }
+
+ if (this.super.requestToolApproval) {
+ const attachmentNote =
+ preparedAttachments.length > 0
+ ? ` with ${preparedAttachments.length} attachment(s): ${attachmentSummaries.join(", ")}`
+ : "";
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: {
+ draftId,
+ to,
+ subject,
+ attachmentCount: preparedAttachments.length,
+ },
+ description: `Update Gmail draft "${draftId}"${attachmentNote}`,
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ this.super.introspect(
+ `${this.caller}: Updating Gmail draft ${draftId}${preparedAttachments.length > 0 ? ` with ${preparedAttachments.length} attachment(s)` : ""}`
+ );
+
+ const options = {};
+ if (cc) options.cc = cc;
+ if (bcc) options.bcc = bcc;
+ if (htmlBody) options.htmlBody = htmlBody;
+ if (preparedAttachments.length > 0) {
+ options.attachments = preparedAttachments;
+ }
+
+ const result = await gmailLib.updateDraft(
+ draftId,
+ to,
+ subject,
+ body,
+ options
+ );
+
+ if (!result.success) {
+ this.super.introspect(
+ `${this.caller}: Failed to update draft - ${result.error}`
+ );
+ return `Error updating Gmail draft: ${result.error}`;
+ }
+
+ const draft = result.data;
+ this.super.introspect(
+ `${this.caller}: Successfully updated draft (ID: ${draft.draftId})`
+ );
+
+ return (
+ `Successfully updated Gmail draft:\n` +
+ `Draft ID: ${draft.draftId}\n` +
+ `Message ID: ${draft.messageId}\n` +
+ `To: ${draft.to}\n` +
+ `Subject: ${draft.subject}\n` +
+ (preparedAttachments.length > 0
+ ? `Attachments: ${attachmentSummaries.join(", ")}\n`
+ : "") +
+ `\nThe draft has been updated.`
+ );
+ } catch (e) {
+ this.super.handlerProps.log(
+ `gmail-update-draft error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error updating Gmail draft: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/index.js b/server/utils/agents/aibitat/plugins/gmail/index.js
new file mode 100644
index 00000000..506a9ed7
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/index.js
@@ -0,0 +1,73 @@
+// Get Inbox & Search
+const { GmailGetInbox } = require("./search/gmail-get-inbox.js");
+const { GmailSearch } = require("./search/gmail-search.js");
+const { GmailReadThread } = require("./search/gmail-read-thread.js");
+
+// Drafts
+const { GmailCreateDraft } = require("./drafts/gmail-create-draft.js");
+const {
+ GmailCreateDraftReply,
+} = require("./drafts/gmail-create-draft-reply.js");
+const { GmailUpdateDraft } = require("./drafts/gmail-update-draft.js");
+const { GmailGetDraft } = require("./drafts/gmail-get-draft.js");
+const { GmailListDrafts } = require("./drafts/gmail-list-drafts.js");
+const { GmailDeleteDraft } = require("./drafts/gmail-delete-draft.js");
+const { GmailSendDraft } = require("./drafts/gmail-send-draft.js");
+
+// Send & Reply
+const { GmailSendEmail } = require("./send/gmail-send-email.js");
+const { GmailReplyToThread } = require("./send/gmail-reply-to-thread.js");
+
+// Thread Management
+const { GmailMarkRead } = require("./threads/gmail-mark-read.js");
+const { GmailMarkUnread } = require("./threads/gmail-mark-unread.js");
+const { GmailMoveToTrash } = require("./threads/gmail-move-to-trash.js");
+const { GmailMoveToArchive } = require("./threads/gmail-move-to-archive.js");
+const { GmailMoveToInbox } = require("./threads/gmail-move-to-inbox.js");
+
+// Account
+const {
+ GmailGetMailboxStats,
+} = require("./account/gmail-get-mailbox-stats.js");
+
+const gmailAgent = {
+ name: "gmail-agent",
+ startupConfig: {
+ params: {},
+ },
+ plugin: [
+ // Alias for easy access to the inbox
+ GmailGetInbox,
+
+ // Search & Read (read-only)
+ GmailSearch,
+ GmailReadThread,
+
+ // Drafts (modifying)
+ GmailCreateDraft,
+ GmailCreateDraftReply,
+ GmailUpdateDraft,
+ GmailGetDraft,
+ GmailListDrafts,
+ GmailDeleteDraft,
+ GmailSendDraft,
+
+ // Send & Reply (modifying)
+ GmailSendEmail,
+ GmailReplyToThread,
+
+ // Thread Management (modifying)
+ GmailMarkRead,
+ GmailMarkUnread,
+ GmailMoveToTrash,
+ GmailMoveToArchive,
+ GmailMoveToInbox,
+
+ // Account (read-only)
+ GmailGetMailboxStats,
+ ],
+};
+
+module.exports = {
+ gmailAgent,
+};
diff --git a/server/utils/agents/aibitat/plugins/gmail/lib.js b/server/utils/agents/aibitat/plugins/gmail/lib.js
new file mode 100644
index 00000000..711e450e
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/gmail/lib.js
@@ -0,0 +1,555 @@
+const fs = require("fs");
+const path = require("path");
+const os = require("os");
+const mime = require("mime");
+const { SystemSettings } = require("../../../../../models/systemSettings");
+const { CollectorApi } = require("../../../../collectorApi");
+const { humanFileSize } = require("../../../../helpers");
+
+const MAX_TOTAL_ATTACHMENT_SIZE = 20 * 1024 * 1024; // 20MB limit for all attachments combined
+
+/**
+ * Validates and prepares a file attachment for email.
+ * Note: Does not check total size limit - caller should track cumulative size.
+ * @param {string} filePath - Absolute path to the file
+ * @returns {{success: boolean, attachment?: object, error?: string, fileInfo?: object}}
+ */
+function prepareAttachment(filePath) {
+ if (process.env.ANYTHING_LLM_RUNTIME === "docker") {
+ return {
+ success: false,
+ error: "File attachments are not supported in Docker environments.",
+ };
+ }
+
+ if (!path.isAbsolute(filePath)) {
+ return { success: false, error: `Path must be absolute: ${filePath}` };
+ }
+
+ if (!fs.existsSync(filePath)) {
+ return { success: false, error: `File does not exist: ${filePath}` };
+ }
+
+ const stats = fs.statSync(filePath);
+ if (!stats.isFile()) {
+ return { success: false, error: `Path is not a file: ${filePath}` };
+ }
+
+ if (stats.size === 0) {
+ return { success: false, error: `File is empty: ${filePath}` };
+ }
+
+ try {
+ const fileBuffer = fs.readFileSync(filePath);
+ const base64Data = fileBuffer.toString("base64");
+ const fileName = path.basename(filePath);
+ const contentType = mime.getType(filePath) || "application/octet-stream";
+
+ return {
+ success: true,
+ attachment: {
+ name: fileName,
+ contentType,
+ data: base64Data,
+ },
+ fileInfo: {
+ path: filePath,
+ name: fileName,
+ size: stats.size,
+ sizeFormatted: humanFileSize(stats.size, true),
+ contentType,
+ },
+ };
+ } catch (e) {
+ return { success: false, error: `Failed to read file: ${e.message}` };
+ }
+}
+
+/**
+ * Parse an attachment using the CollectorApi for secure content extraction.
+ * Writes the base64 data to a temp file, parses it, then cleans up.
+ * @param {Object} attachment - The attachment object with name, contentType, size, data (base64)
+ * @returns {Promise<{success: boolean, content: string|null, error: string|null}>}
+ */
+async function parseAttachment(attachment) {
+ const tempDir = os.tmpdir();
+ const safeFilename = attachment.name.replace(/[^a-zA-Z0-9._-]/g, "_");
+ const tempFilePath = path.join(
+ tempDir,
+ `gmail-attachment-${Date.now()}-${safeFilename}`
+ );
+
+ try {
+ const buffer = Buffer.from(attachment.data, "base64");
+ fs.writeFileSync(tempFilePath, buffer);
+
+ const collector = new CollectorApi();
+ const result = await collector.parseDocument(safeFilename, {
+ absolutePath: tempFilePath,
+ });
+
+ if (fs.existsSync(tempFilePath)) {
+ fs.unlinkSync(tempFilePath);
+ }
+
+ if (!result.success) {
+ return {
+ success: false,
+ content: null,
+ error: result.reason || "Failed to parse attachment",
+ };
+ }
+
+ const textContent = result.documents
+ ?.map((doc) => doc.pageContent || doc.content || "")
+ .filter(Boolean)
+ .join("\n\n");
+
+ return {
+ success: true,
+ content: textContent || "(No text content extracted)",
+ error: null,
+ };
+ } catch (e) {
+ if (fs.existsSync(tempFilePath)) {
+ try {
+ fs.unlinkSync(tempFilePath);
+ } catch {}
+ }
+ return { success: false, content: null, error: e.message };
+ }
+}
+
+/**
+ * Collect attachments from messages and optionally parse them with user approval.
+ * @param {Object} context - The handler context (this) from the aibitat function
+ * @param {Array} messages - Array of message objects (single message should be wrapped in array)
+ * @returns {Promise<{allAttachments: Array, parsedContent: string}>}
+ */
+async function handleAttachments(context, messages) {
+ const allAttachments = [];
+ messages.forEach((msg, msgIndex) => {
+ if (msg.attachments?.length > 0) {
+ msg.attachments.forEach((att) => {
+ allAttachments.push({
+ ...att,
+ messageIndex: msgIndex + 1,
+ messageId: msg.id,
+ });
+ });
+ }
+ });
+
+ let parsedContent = "";
+ const citations = [];
+ if (allAttachments.length > 0 && context.super.requestToolApproval) {
+ const attachmentNames = allAttachments.map((a) => a.name).join(", ");
+
+ const approval = await context.super.requestToolApproval({
+ skillName: context.name,
+ payload: { attachments: attachmentNames },
+ description: `Parse attachments (${attachmentNames}) to extract text content?`,
+ });
+
+ if (approval.approved) {
+ context.super.introspect(
+ `${context.caller}: Parsing ${allAttachments.length} attachment(s)...`
+ );
+
+ const parsedResults = [];
+ for (const attachment of allAttachments) {
+ if (!attachment.data) continue;
+ context.super.introspect(
+ `${context.caller}: Parsing "${attachment.name}"...`
+ );
+ const parseResult = await parseAttachment(attachment);
+ if (!parseResult.success) continue;
+
+ citations.push({
+ id: `gmail-attachment-${attachment.messageId}-${attachment.name}`,
+ title: attachment.name,
+ text: parseResult.content,
+ chunkSource: "gmail-attachment://" + attachment.name,
+ score: null,
+ });
+ parsedResults.push({
+ name: attachment.name,
+ messageIndex: attachment.messageIndex,
+ ...parseResult,
+ });
+ }
+
+ parsedContent =
+ "\n\n--- Parsed Attachment Content ---\n" +
+ parsedResults
+ .map((r) => `\n[Message ${r.messageIndex}: ${r.name}]\n${r.content}`)
+ .join("\n");
+
+ context.super.introspect(
+ `${context.caller}: Finished parsing attachments`
+ );
+ } else {
+ context.super.introspect(
+ `${context.caller}: User declined to parse attachments`
+ );
+ }
+ }
+
+ citations.forEach((c) => context.super.addCitation?.(c));
+ return { allAttachments, parsedContent };
+}
+
+/**
+ * Gmail Bridge Library
+ * Handles communication with the AnythingLLM Gmail Google Apps Script deployment.
+ */
+class GmailBridge {
+ #deploymentId = null;
+ #apiKey = null;
+ #isInitialized = false;
+
+ #log(text, ...args) {
+ console.log(`\x1b[36m[GmailBridge]\x1b[0m ${text}`, ...args);
+ }
+
+ /**
+ * Resets the bridge state, forcing re-initialization on next use.
+ * Call this when configuration changes (e.g., deployment ID updated).
+ */
+ reset() {
+ this.#deploymentId = null;
+ this.#apiKey = null;
+ this.#isInitialized = false;
+ }
+
+ /**
+ * Initializes the Gmail bridge by fetching configuration from system settings.
+ * @returns {Promise<{success: boolean, error?: string}>}
+ */
+ async initialize() {
+ if (this.#isInitialized) return { success: true };
+
+ try {
+ const isMultiUser = await SystemSettings.isMultiUserMode();
+ if (isMultiUser) {
+ return {
+ success: false,
+ error:
+ "Gmail integration is not available in multi-user mode for security reasons.",
+ };
+ }
+
+ const deploymentId = await SystemSettings.getValueOrFallback(
+ { label: "gmail_deployment_id" },
+ null
+ );
+ const apiKey = await SystemSettings.getValueOrFallback(
+ { label: "gmail_api_key" },
+ null
+ );
+
+ if (!deploymentId || !apiKey) {
+ return {
+ success: false,
+ error:
+ "Gmail integration is not configured. Please set the Deployment ID and API Key in the agent settings.",
+ };
+ }
+
+ this.#deploymentId = deploymentId;
+ this.#apiKey = apiKey;
+ this.#isInitialized = true;
+ return { success: true };
+ } catch (error) {
+ return { success: false, error: error.message };
+ }
+ }
+
+ /**
+ * Checks if the Gmail bridge is properly configured and available.
+ * @returns {Promise
+
+ {skill.title}
+
+
+ {skill.description}
+
+
+