+
+ );
+}
+
+function WarningBanner() {
+ return (
+
+ 
+
+
+ toggleSkill(skill)}
+ />
+
+
+
+ {icon &&
+ React.createElement(icon, {
+ size: 24,
+ color: "var(--theme-text-primary)",
+ weight: "bold",
+ })}
+
+
+
+
+
+ {enabled && (
+ <>
+
+ + {t("agent.skill.filesystem.description")} +
+ + {t("agent.skill.filesystem.learnMore")} → + +
+
+
+ )}
+
+
+ {loading ? (
+ + {t("agent.skill.filesystem.configuration")} +
+
+
+ ) : (
+ <>
+
+
+
+ + {t("agent.skill.filesystem.readActions")} +
+
+ {readSkills.map((subSkill) => (
+ toggleSubSkill(subSkill.name)}
+ />
+ ))}
+
+
+
+
+ )}
+
+
+ {writeSkills.map((subSkill) => (
+ toggleSubSkill(subSkill.name)}
+ isWriteOperation
+ />
+ ))}
+
+
+
+ );
+}
+
+function SubSkillRow({ subSkill, disabled, onToggle, isWriteOperation }) {
+ const Icon = subSkill.icon;
+ return (
+
+
+
+ );
+}
diff --git a/frontend/src/pages/Admin/Agents/index.jsx b/frontend/src/pages/Admin/Agents/index.jsx
index 4cb6f29e..2bb8617d 100644
--- a/frontend/src/pages/Admin/Agents/index.jsx
+++ b/frontend/src/pages/Admin/Agents/index.jsx
@@ -58,8 +58,13 @@ export default function AdminAgents() {
const [mcpServers, setMcpServers] = useState([]);
const [selectedMcpServer, setSelectedMcpServer] = useState(null);
+ const [fileSystemAgentAvailable, setFileSystemAgentAvailable] =
+ useState(false);
+
const defaultSkills = getDefaultSkills(t);
- const configurableSkills = getConfigurableSkills(t);
+ const configurableSkills = getConfigurableSkills(t, {
+ fileSystemAgentAvailable,
+ });
// Alert user if they try to leave the page with unsaved changes
useEffect(() => {
@@ -77,15 +82,20 @@ export default function AdminAgents() {
useEffect(() => {
async function fetchSettings() {
- const _settings = await System.keys();
- const _preferences = await Admin.systemPreferencesByFields([
- "disabled_agent_skills",
- "default_agent_skills",
- "imported_agent_skills",
- "active_agent_flows",
- ]);
- const { flows = [] } = await AgentFlows.listFlows();
+ const [_settings, _preferences, flowsRes, fsAgentAvailable] =
+ await Promise.all([
+ System.keys(),
+ Admin.systemPreferencesByFields([
+ "disabled_agent_skills",
+ "default_agent_skills",
+ "imported_agent_skills",
+ "active_agent_flows",
+ ]),
+ AgentFlows.listFlows(),
+ System.isFileSystemAgentAvailable(),
+ ]);
+ const { flows = [] } = flowsRes;
setSettings({ ..._settings, preferences: _preferences.settings } ?? {});
setAgentSkills(_preferences.settings?.default_agent_skills ?? []);
setDisabledAgentSkills(
@@ -94,6 +104,7 @@ export default function AdminAgents() {
setImportedSkills(_preferences.settings?.imported_agent_skills ?? []);
setActiveFlowIds(_preferences.settings?.active_agent_flows ?? []);
setAgentFlows(flows);
+ setFileSystemAgentAvailable(fsAgentAvailable);
setLoading(false);
}
fetchSettings();
diff --git a/frontend/src/pages/Admin/Agents/skills.js b/frontend/src/pages/Admin/Agents/skills.js
index 0b8fbb77..555c51dc 100644
--- a/frontend/src/pages/Admin/Agents/skills.js
+++ b/frontend/src/pages/Admin/Agents/skills.js
@@ -2,18 +2,21 @@ import AgentWebSearchSelection from "./WebSearchSelection";
import AgentSQLConnectorSelection from "./SQLConnectorSelection";
import GenericSkillPanel from "./GenericSkillPanel";
import DefaultSkillPanel from "./DefaultSkillPanel";
+import FileSystemSkillPanel from "./FileSystemSkillPanel";
import {
Brain,
File,
Browser,
ChartBar,
FileMagnifyingGlass,
+ FolderOpen,
} from "@phosphor-icons/react";
import RAGImage from "@/media/agents/rag-memory.png";
import SummarizeImage from "@/media/agents/view-summarize.png";
import ScrapeWebsitesImage from "@/media/agents/scrape-websites.png";
import GenerateChartsImage from "@/media/agents/generate-charts.png";
import GenerateSaveImages from "@/media/agents/generate-save-files.png";
+import FileSystemImage from "@/media/agents/file-system.png";
export const getDefaultSkills = (t) => ({
"rag-memory": {
@@ -42,7 +45,20 @@ export const getDefaultSkills = (t) => ({
},
});
-export const getConfigurableSkills = (t) => ({
+export const getConfigurableSkills = (
+ t,
+ { fileSystemAgentAvailable = true } = {}
+) => ({
+ ...(fileSystemAgentAvailable && {
+ "filesystem-agent": {
+ title: t("agent.skill.filesystem.title"),
+ description: t("agent.skill.filesystem.description"),
+ component: FileSystemSkillPanel,
+ skill: "filesystem-agent",
+ icon: FolderOpen,
+ image: FileSystemImage,
+ },
+ }),
"save-file-to-browser": {
title: t("agent.skill.save.title"),
description: t("agent.skill.save.description"),
diff --git a/server/.gitignore b/server/.gitignore
index d264868e..c4147a0a 100644
--- a/server/.gitignore
+++ b/server/.gitignore
@@ -10,6 +10,7 @@ storage/tmp/*
storage/vector-cache/*.json
storage/exports
storage/imports
+storage/anythingllm-fs/*
storage/plugins/agent-skills/*
storage/plugins/agent-flows/*
storage/plugins/office-extensions/*
diff --git a/server/endpoints/admin.js b/server/endpoints/admin.js
index 3756831c..4315d03e 100644
--- a/server/endpoints/admin.js
+++ b/server/endpoints/admin.js
@@ -403,6 +403,9 @@ function adminEndpoints(app) {
case "disabled_agent_skills":
requestedSettings[label] = safeJsonParse(setting?.value, []);
break;
+ case "disabled_filesystem_skills":
+ requestedSettings[label] = safeJsonParse(setting?.value, []);
+ break;
case "imported_agent_skills":
requestedSettings[label] = ImportedPlugin.listImportedPlugins();
break;
diff --git a/server/endpoints/agentSkillWhitelist.js b/server/endpoints/agentSkillWhitelist.js
index 12a414d6..116fb9ec 100644
--- a/server/endpoints/agentSkillWhitelist.js
+++ b/server/endpoints/agentSkillWhitelist.js
@@ -9,6 +9,24 @@ const {
function agentSkillWhitelistEndpoints(app) {
if (!app) return;
+ app.get(
+ "/agent-skills/filesystem-agent/is-available",
+ [validatedRequest],
+ async (_request, response) => {
+ try {
+ const filesystemTool = require("../utils/agents/aibitat/plugins/filesystem/lib");
+ return response
+ .status(200)
+ .json({ available: filesystemTool.isToolAvailable() });
+ } catch (e) {
+ console.error(e);
+ return response
+ .status(500)
+ .json({ available: false, error: e.message });
+ }
+ }
+ );
+
app.post(
"/agent-skills/whitelist/add",
[validatedRequest, flexUserRoleValid(ROLES.all)],
diff --git a/server/models/systemSettings.js b/server/models/systemSettings.js
index 4859dfbc..332fab23 100644
--- a/server/models/systemSettings.js
+++ b/server/models/systemSettings.js
@@ -33,6 +33,7 @@ const SystemSettings = {
"agent_sql_connections",
"default_agent_skills",
"disabled_agent_skills",
+ "disabled_filesystem_skills",
"imported_agent_skills",
"custom_app_name",
"feature_flags",
@@ -50,6 +51,7 @@ const SystemSettings = {
"agent_search_provider",
"default_agent_skills",
"disabled_agent_skills",
+ "disabled_filesystem_skills",
"agent_sql_connections",
"custom_app_name",
"default_system_prompt",
@@ -152,6 +154,15 @@ const SystemSettings = {
return JSON.stringify([]);
}
},
+ disabled_filesystem_skills: (updates) => {
+ try {
+ const skills = updates.split(",").filter((skill) => !!skill);
+ return JSON.stringify(skills);
+ } catch {
+ console.error(`Could not validate disabled filesystem skills.`);
+ return JSON.stringify([]);
+ }
+ },
agent_sql_connections: async (updates) => {
const existingConnections = safeJsonParse(
(await SystemSettings.get({ label: "agent_sql_connections" }))?.value,
diff --git a/server/package.json b/server/package.json
index 611e9829..4c9a07bf 100644
--- a/server/package.json
+++ b/server/package.json
@@ -38,6 +38,7 @@
"@pinecone-database/pinecone": "^2.0.1",
"@prisma/client": "5.3.1",
"@qdrant/js-client-rest": "^1.9.0",
+ "@vscode/ripgrep": "1.17.1",
"@xenova/transformers": "^2.14.0",
"@zilliz/milvus2-sdk-node": "^2.3.5",
"adm-zip": "^0.5.16",
@@ -52,6 +53,7 @@
"chromadb": "^2.0.1",
"cohere-ai": "^7.19.0",
"cors": "^2.8.5",
+ "diff": "7.0.0",
"dotenv": "^16.0.3",
"elevenlabs": "^0.5.0",
"express": "^4.21.2",
diff --git a/server/utils/agents/aibitat/index.js b/server/utils/agents/aibitat/index.js
index aab75872..37a285b3 100644
--- a/server/utils/agents/aibitat/index.js
+++ b/server/utils/agents/aibitat/index.js
@@ -45,6 +45,14 @@ class AIbitat {
*/
_pendingCitations = [];
+ /**
+ * Buffer for attachments (images) collected during tool execution.
+ * Tools can call addToolAttachment() to queue images for injection into the conversation.
+ * These are injected as a user message so all providers' existing attachment handling works.
+ * @type {Array<{name: string, mime: string, contentString: string}>}
+ */
+ _toolAttachments = [];
+
/**
* Get the default maximum number of tools an agent can chain for a single response.
* @returns {number}
@@ -141,6 +149,28 @@ class AIbitat {
this._pendingCitations = [];
}
+ /**
+ * Add an attachment (image) from a tool to be injected into the conversation.
+ * The attachment will be added as a user message so the model can "see" it.
+ * This leverages existing provider attachment handling for user messages.
+ * @param {{name: string, mime: string, contentString: string}} attachment - The attachment object with name, mime type, and base64 data URL
+ */
+ addToolAttachment(attachment) {
+ if (!attachment || !attachment.contentString) return;
+ this._toolAttachments.push(attachment);
+ }
+
+ /**
+ * Collect and clear any pending tool attachments.
+ * @returns {Array<{name: string, mime: string, contentString: string}>} The collected attachments
+ */
+ collectToolAttachments() {
+ if (this._toolAttachments.length === 0) return [];
+ const attachments = [...this._toolAttachments];
+ this._toolAttachments = [];
+ return attachments;
+ }
+
/**
* Add a new agent to the AIbitat.
*
@@ -896,17 +926,31 @@ https://docs.anythingllm.com/agent/intelligent-tool-selection
return result;
}
+ const toolAttachments = this.collectToolAttachments();
+ const newMessages = [
+ ...messages,
+ {
+ name,
+ role: "function",
+ content: result,
+ originalFunctionCall: completionStream.functionCall,
+ },
+ ];
+
+ if (toolAttachments.length > 0) {
+ this.handlerProps?.log?.(
+ `[debug]: Injecting ${toolAttachments.length} image attachment(s) from tool result`
+ );
+ newMessages.push({
+ role: "user",
+ content: "[Attached image(s) from tool result]",
+ attachments: toolAttachments,
+ });
+ }
+
return await this.handleAsyncExecution(
provider,
- [
- ...messages,
- {
- name,
- role: "function",
- content: result,
- originalFunctionCall: completionStream.functionCall,
- },
- ],
+ newMessages,
functions,
byAgent,
depth + 1
@@ -1034,17 +1078,31 @@ https://docs.anythingllm.com/agent/intelligent-tool-selection
return result;
}
+ const toolAttachments = this.collectToolAttachments();
+ const newMessages = [
+ ...messages,
+ {
+ name,
+ role: "function",
+ content: result,
+ originalFunctionCall: completion.functionCall,
+ },
+ ];
+
+ if (toolAttachments.length > 0) {
+ this.handlerProps?.log?.(
+ `[debug]: Injecting ${toolAttachments.length} image attachment(s) from tool result`
+ );
+ newMessages.push({
+ role: "user",
+ content: "[Attached image(s) from tool result]",
+ attachments: toolAttachments,
+ });
+ }
+
return await this.handleExecution(
provider,
- [
- ...messages,
- {
- name,
- role: "function",
- content: result,
- originalFunctionCall: completion.functionCall,
- },
- ],
+ newMessages,
functions,
byAgent,
depth + 1,
diff --git a/server/utils/agents/aibitat/plugins/filesystem/copy-file.js b/server/utils/agents/aibitat/plugins/filesystem/copy-file.js
new file mode 100644
index 00000000..fd22cb27
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/copy-file.js
@@ -0,0 +1,121 @@
+const fs = require("fs/promises");
+const path = require("path");
+const filesystem = require("./lib.js");
+
+async function copyRecursive(source, destination) {
+ const stats = await fs.stat(source);
+
+ if (stats.isDirectory()) {
+ await fs.mkdir(destination, { recursive: true });
+ const entries = await fs.readdir(source);
+ for (const entry of entries) {
+ await copyRecursive(
+ path.join(source, entry),
+ path.join(destination, entry)
+ );
+ }
+ } else {
+ await fs.copyFile(source, destination);
+ }
+}
+
+module.exports.FilesystemCopyFile = {
+ name: "filesystem-copy-file",
+ plugin: function () {
+ return {
+ name: "filesystem-copy-file",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Copy files and directories. Creates a duplicate of the source at the destination path. " +
+ "For directories, performs a recursive copy of all contents. If the destination exists, " +
+ "the operation will fail. Both source and destination must be within allowed directories.",
+ examples: [
+ {
+ prompt: "Make a backup copy of config.json",
+ call: JSON.stringify({
+ source: "config.json",
+ destination: "config.backup.json",
+ }),
+ },
+ {
+ prompt: "Copy the templates folder to a new location",
+ call: JSON.stringify({
+ source: "templates",
+ destination: "templates-backup",
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ source: {
+ type: "string",
+ description: "The path of the file or directory to copy.",
+ },
+ destination: {
+ type: "string",
+ description:
+ "The destination path where the copy should be created.",
+ },
+ },
+ required: ["source", "destination"],
+ additionalProperties: false,
+ },
+ handler: async function ({ source = "", destination = "" }) {
+ try {
+ this.super.handlerProps.log(
+ `Using the filesystem-copy-file tool.`
+ );
+
+ const validSourcePath = await filesystem.validatePath(source);
+ const validDestPath = await filesystem.validatePath(destination);
+
+ this.super.introspect(
+ `${this.caller}: Copying ${source} to ${destination}`
+ );
+
+ if (this.super.requestToolApproval) {
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: { source, destination },
+ description: "Copy a file or directory to a new location",
+ });
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ const destExists = await fs
+ .access(validDestPath)
+ .then(() => true)
+ .catch(() => false);
+
+ if (destExists) {
+ return `Error: Destination "${destination}" already exists. Please choose a different destination.`;
+ }
+
+ await copyRecursive(validSourcePath, validDestPath);
+ this.super.introspect(
+ `Successfully copied ${source} to ${destination}`
+ );
+ return `Successfully copied ${source} to ${destination}`;
+ } catch (e) {
+ this.super.handlerProps.log(
+ `filesystem-copy-file error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error copying file: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/filesystem/create-directory.js b/server/utils/agents/aibitat/plugins/filesystem/create-directory.js
new file mode 100644
index 00000000..f843085b
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/create-directory.js
@@ -0,0 +1,84 @@
+const fs = require("fs/promises");
+const filesystem = require("./lib.js");
+
+module.exports.FilesystemCreateDirectory = {
+ name: "filesystem-create-directory",
+ plugin: function () {
+ return {
+ name: "filesystem-create-directory",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Create a new directory or ensure a directory exists. Can create multiple " +
+ "nested directories in one operation. If the directory already exists, " +
+ "this operation will succeed silently. Perfect for setting up directory " +
+ "structures for projects or ensuring required paths exist. Only works within allowed directories.",
+ examples: [
+ {
+ prompt: "Create a new folder called 'reports'",
+ call: JSON.stringify({ path: "reports" }),
+ },
+ {
+ prompt: "Create nested directories for the new module",
+ call: JSON.stringify({ path: "src/modules/auth/utils" }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ path: {
+ type: "string",
+ description:
+ "The path of the directory to create. Can include nested paths.",
+ },
+ },
+ required: ["path"],
+ additionalProperties: false,
+ },
+ handler: async function ({ path: dirPath = "" }) {
+ try {
+ this.super.handlerProps.log(
+ `Using the filesystem-create-directory tool.`
+ );
+
+ const validPath = await filesystem.validatePath(dirPath);
+ this.super.introspect(
+ `${this.caller}: Creating directory ${dirPath}`
+ );
+
+ if (this.super.requestToolApproval) {
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: { path: dirPath },
+ description: "Create a new directory",
+ });
+
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ await fs.mkdir(validPath, { recursive: true });
+ this.super.introspect(
+ `Successfully created directory ${dirPath}`
+ );
+ return `Successfully created directory ${dirPath}`;
+ } catch (e) {
+ this.super.handlerProps.log(
+ `filesystem-create-directory error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error creating directory: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/filesystem/edit-file.js b/server/utils/agents/aibitat/plugins/filesystem/edit-file.js
new file mode 100644
index 00000000..a1965e7c
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/edit-file.js
@@ -0,0 +1,133 @@
+const filesystem = require("./lib.js");
+
+module.exports.FilesystemEditFile = {
+ name: "filesystem-edit-file",
+ plugin: function () {
+ return {
+ name: "filesystem-edit-file",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Make line-based edits to a text file. Each edit replaces exact line sequences " +
+ "with new content. Returns a git-style diff showing the changes made. " +
+ "Use dryRun=true to preview changes without applying them. " +
+ "Only works within allowed directories.",
+ examples: [
+ {
+ prompt: "Change the port number from 3000 to 8080 in config.js",
+ call: JSON.stringify({
+ path: "config.js",
+ edits: [{ oldText: "port: 3000", newText: "port: 8080" }],
+ }),
+ },
+ {
+ prompt: "Preview what would happen if I renamed the function",
+ call: JSON.stringify({
+ path: "utils.js",
+ edits: [
+ {
+ oldText: "function oldName()",
+ newText: "function newName()",
+ },
+ ],
+ dryRun: true,
+ }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ path: {
+ type: "string",
+ description: "The path to the file to edit.",
+ },
+ edits: {
+ type: "array",
+ items: {
+ type: "object",
+ properties: {
+ oldText: {
+ type: "string",
+ description: "Text to search for - must match exactly.",
+ },
+ newText: {
+ type: "string",
+ description: "Text to replace with.",
+ },
+ },
+ required: ["oldText", "newText"],
+ },
+ description: "Array of edit operations to apply.",
+ },
+ dryRun: {
+ type: "boolean",
+ default: false,
+ description:
+ "If true, preview changes using git-style diff format without applying them.",
+ },
+ },
+ required: ["path", "edits"],
+ additionalProperties: false,
+ },
+ handler: async function ({
+ path: filePath = "",
+ edits = [],
+ dryRun = false,
+ }) {
+ try {
+ this.super.handlerProps.log(
+ `Using the filesystem-edit-file tool.`
+ );
+
+ if (!Array.isArray(edits) || edits.length === 0) {
+ return "Error: At least one edit operation must be provided.";
+ }
+
+ const validPath = await filesystem.validatePath(filePath);
+
+ this.super.introspect(
+ `${this.caller}: ${dryRun ? "Previewing" : "Applying"} ${edits.length} edit(s) to ${filePath}`
+ );
+
+ if (this.super.requestToolApproval && !dryRun) {
+ const approval = await this.super.requestToolApproval({
+ skillName: this.name,
+ payload: { path: filePath, edits, dryRun },
+ description: "Edit a file",
+ });
+
+ if (!approval.approved) {
+ this.super.introspect(
+ `${this.caller}: User rejected the ${this.name} request.`
+ );
+ return approval.message;
+ }
+ }
+
+ const result = await filesystem.applyFileEdits(
+ validPath,
+ edits,
+ dryRun
+ );
+
+ if (dryRun)
+ this.super.introspect(`Preview of changes to ${filePath}:`);
+ else this.super.introspect(`Successfully edited ${filePath}`);
+
+ return result;
+ } catch (e) {
+ this.super.handlerProps.log(
+ `filesystem-edit-file error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error editing file: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/filesystem/get-file-info.js b/server/utils/agents/aibitat/plugins/filesystem/get-file-info.js
new file mode 100644
index 00000000..085cd685
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/get-file-info.js
@@ -0,0 +1,75 @@
+const filesystem = require("./lib.js");
+
+module.exports.FilesystemGetFileInfo = {
+ name: "filesystem-get-file-info",
+ plugin: function () {
+ return {
+ name: "filesystem-get-file-info",
+ setup(aibitat) {
+ aibitat.function({
+ super: aibitat,
+ name: this.name,
+ description:
+ "Retrieve detailed metadata about a file or directory. Returns comprehensive " +
+ "information including size, creation time, last modified time, permissions, " +
+ "and type. This tool is perfect for understanding file characteristics " +
+ "without reading the actual content. Only works within allowed directories.",
+ examples: [
+ {
+ prompt: "What's the size of the database file?",
+ call: JSON.stringify({ path: "data/app.db" }),
+ },
+ {
+ prompt: "When was the config file last modified?",
+ call: JSON.stringify({ path: "config.json" }),
+ },
+ ],
+ parameters: {
+ $schema: "http://json-schema.org/draft-07/schema#",
+ type: "object",
+ properties: {
+ path: {
+ type: "string",
+ description:
+ "The path to the file or directory to get information about.",
+ },
+ },
+ required: ["path"],
+ additionalProperties: false,
+ },
+ handler: async function ({ path: filePath = "" }) {
+ try {
+ this.super.handlerProps.log(
+ `Using the filesystem-get-file-info tool.`
+ );
+
+ const validPath = await filesystem.validatePath(filePath);
+
+ this.super.introspect(
+ `${this.caller}: Getting info for ${filePath}`
+ );
+
+ const info = await filesystem.getFileStats(validPath);
+
+ const formatted = Object.entries(info)
+ .map(([key, value]) => `${key}: ${value}`)
+ .join("\n");
+
+ this.super.introspect(
+ `Successfully retrieved info for ${filePath}`
+ );
+
+ return formatted;
+ } catch (e) {
+ this.super.handlerProps.log(
+ `filesystem-get-file-info error: ${e.message}`
+ );
+ this.super.introspect(`Error: ${e.message}`);
+ return `Error getting file info: ${e.message}`;
+ }
+ },
+ });
+ },
+ };
+ },
+};
diff --git a/server/utils/agents/aibitat/plugins/filesystem/index.js b/server/utils/agents/aibitat/plugins/filesystem/index.js
new file mode 100644
index 00000000..86b8304f
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/index.js
@@ -0,0 +1,33 @@
+const { FilesystemReadTextFile } = require("./read-text-file.js");
+const { FilesystemReadMultipleFiles } = require("./read-multiple-files.js");
+const { FilesystemWriteFile } = require("./write-file.js");
+const { FilesystemEditFile } = require("./edit-file.js");
+const { FilesystemCreateDirectory } = require("./create-directory.js");
+const { FilesystemListDirectory } = require("./list-directory.js");
+const { FilesystemMoveFile } = require("./move-file.js");
+const { FilesystemCopyFile } = require("./copy-file.js");
+const { FilesystemSearchFiles } = require("./search-files.js");
+const { FilesystemGetFileInfo } = require("./get-file-info.js");
+
+const filesystemAgent = {
+ name: "filesystem-agent",
+ startupConfig: {
+ params: {},
+ },
+ plugin: [
+ FilesystemReadTextFile,
+ FilesystemReadMultipleFiles,
+ FilesystemWriteFile,
+ FilesystemEditFile,
+ FilesystemCreateDirectory,
+ FilesystemListDirectory,
+ FilesystemMoveFile,
+ FilesystemCopyFile,
+ FilesystemSearchFiles,
+ FilesystemGetFileInfo,
+ ],
+};
+
+module.exports = {
+ filesystemAgent,
+};
diff --git a/server/utils/agents/aibitat/plugins/filesystem/lib.js b/server/utils/agents/aibitat/plugins/filesystem/lib.js
new file mode 100644
index 00000000..faf1e5d0
--- /dev/null
+++ b/server/utils/agents/aibitat/plugins/filesystem/lib.js
@@ -0,0 +1,787 @@
+const fs = require("fs/promises");
+const path = require("path");
+const os = require("os");
+const { randomBytes } = require("crypto");
+const { createTwoFilesPatch } = require("diff");
+const { humanFileSize } = require("../../../../helpers");
+
+/**
+ * Manages filesystem operations with security constraints.
+ * Ensures all file operations stay within allowed directories.
+ */
+class FilesystemManager {
+ static FILE_READ_CHUNK_SIZE = 1024;
+ static CONTEXT_RESERVE_RATIO = 0.25;
+ static IMAGE_EXTENSIONS = [
+ ".png",
+ ".jpg",
+ ".jpeg",
+ ".gif",
+ ".webp",
+ ".svg",
+ ".bmp",
+ ];
+ static IMAGE_MIME_TYPES = {
+ ".png": "image/png",
+ ".jpg": "image/jpeg",
+ ".jpeg": "image/jpeg",
+ ".gif": "image/gif",
+ ".webp": "image/webp",
+ ".svg": "image/svg+xml",
+ ".bmp": "image/bmp",
+ };
+
+ /**
+ * Checks if the filesystem tool is available.
+ * The filesystem tool is only available when running in a docker container
+ * or in development mode.
+ * @returns {boolean} True if the tool is available
+ */
+ isToolAvailable() {
+ if (process.env.NODE_ENV === "development") return true;
+ return process.env.ANYTHING_LLM_RUNTIME === "docker";
+ }
+
+ #allowedDirectories = [];
+ #isInitialized = false;
+
+ /**
+ * Gets the default filesystem root path.
+ * @returns {string} The default filesystem root path
+ */
+ #getDefaultFilesystemRoot() {
+ const storageRoot =
+ process.env.STORAGE_DIR ||
+ path.resolve(__dirname, "../../../../../storage");
+ return path.join(storageRoot, "anythingllm-fs");
+ }
+
+ /**
+ * Initializes the filesystem with default or configured directories.
+ * @param {string[]} [directories] - Optional array of directories to allow
+ * @returns {Promise
+
+
+
+ {subSkill.title}
+
+
+ {subSkill.description}
+
+
+