diff --git a/.github/workflows/electron-build.yml b/.github/workflows/electron-build.yml index 4bd774c2..6566f105 100644 --- a/.github/workflows/electron-build.yml +++ b/.github/workflows/electron-build.yml @@ -13,7 +13,7 @@ jobs: steps: - name: Checkout code - uses: actions/checkout@v4 + uses: actions/checkout@v6 - name: Setup pnpm uses: pnpm/action-setup@v4 @@ -21,7 +21,7 @@ jobs: version: 9 - name: Setup Node.js - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: node-version: 24 cache: 'pnpm' @@ -107,7 +107,7 @@ jobs: fi - name: Upload workflow artifacts - uses: actions/upload-artifact@v4 + uses: actions/upload-artifact@v6 with: name: distributables path: apps/x/apps/main/out/make/* @@ -118,7 +118,7 @@ jobs: steps: - name: Checkout code - uses: actions/checkout@v4 + uses: actions/checkout@v6 - name: Setup pnpm uses: pnpm/action-setup@v4 @@ -126,7 +126,7 @@ jobs: version: 9 - name: Setup Node.js - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: node-version: 24 cache: 'pnpm' @@ -171,7 +171,7 @@ jobs: working-directory: apps/x/apps/main - name: Upload workflow artifacts - uses: actions/upload-artifact@v4 + uses: actions/upload-artifact@v6 with: name: distributables-linux path: apps/x/apps/main/out/make/* @@ -182,7 +182,7 @@ jobs: steps: - name: Checkout code - uses: actions/checkout@v4 + uses: actions/checkout@v6 - name: Setup pnpm uses: pnpm/action-setup@v4 @@ -190,7 +190,7 @@ jobs: version: 9 - name: Setup Node.js - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: node-version: 24 cache: 'pnpm' @@ -237,7 +237,7 @@ jobs: working-directory: apps/x/apps/main - name: Upload workflow artifacts - uses: actions/upload-artifact@v4 + uses: actions/upload-artifact@v6 with: name: distributables-windows path: apps/x/apps/main/out/make/* diff --git a/.github/workflows/rowboat-build.yml b/.github/workflows/rowboat-build.yml index ef2f93fa..270e6263 100644 --- a/.github/workflows/rowboat-build.yml +++ b/.github/workflows/rowboat-build.yml @@ -8,10 +8,10 @@ jobs: runs-on: ubuntu-latest steps: - - uses: actions/checkout@v4 + - uses: actions/checkout@v6 - name: Setup Node.js - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: cache-dependency-path: 'apps/rowboat/package-lock.json' node-version: '20' @@ -29,10 +29,10 @@ jobs: runs-on: ubuntu-latest steps: - - uses: actions/checkout@v4 + - uses: actions/checkout@v6 - name: Setup Node.js - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: cache-dependency-path: 'apps/rowboat/package-lock.json' node-version: '24' diff --git a/.github/workflows/x-publish.yml b/.github/workflows/x-publish.yml index 4f58b1df..c411ab68 100644 --- a/.github/workflows/x-publish.yml +++ b/.github/workflows/x-publish.yml @@ -12,10 +12,10 @@ jobs: steps: - name: Checkout repo - uses: actions/checkout@v4 + uses: actions/checkout@v6 - name: Set up Node - uses: actions/setup-node@v4 + uses: actions/setup-node@v6 with: node-version: 24 registry-url: https://registry.npmjs.org/ diff --git a/README.md b/README.md index 9ba7e099..640ee35c 100644 --- a/README.md +++ b/README.md @@ -141,11 +141,6 @@ Examples: Exa (web search), Twitter/X, ElevenLabs (voice), Slack, Linear/Jira, G - No proprietary formats or hosted lock-in - You can inspect, edit, back up, or delete everything at any time - -## Looking for Rowboat Web Studio? - -If you’re looking for Rowboat web Studio, start [here](https://docs.rowboatlabs.com/). - ---
diff --git a/apps/cli/src/application/assistant/instructions.ts b/apps/cli/src/application/assistant/instructions.ts index b6e49cf0..b22425c6 100644 --- a/apps/cli/src/application/assistant/instructions.ts +++ b/apps/cli/src/application/assistant/instructions.ts @@ -1,5 +1,8 @@ import { skillCatalog } from "./skills/index.js"; import { WorkDir as BASE_DIR } from "../../config/config.js"; +import { getRuntimeContext, getRuntimeContextPrompt } from "./runtime-context.js"; + +const runtimeContextPrompt = getRuntimeContextPrompt(getRuntimeContext()); export const CopilotInstructions = `You are an intelligent workflow assistant helping users manage their workflows in ${BASE_DIR}. You can also help the user with general tasks. @@ -39,6 +42,8 @@ When a user asks for ANY task that might require external capabilities (web sear - Use relative paths (no \${BASE_DIR} prefixes) when running commands or referencing files. - Keep user data safe—double-check before editing or deleting important resources. +${runtimeContextPrompt} + ## Workspace access & scope - You have full read/write access inside \`${BASE_DIR}\` (this resolves to the user's \`~/.rowboat\` directory). Create folders, files, and agents there using builtin tools or allowed shell commands—don't wait for the user to do it manually. - If a user mentions a different root (e.g., \`~/.rowboatx\` or another path), clarify whether they meant the Rowboat workspace and propose the equivalent path you can act on. Only refuse if they explicitly insist on an inaccessible location. diff --git a/apps/cli/src/application/assistant/runtime-context.ts b/apps/cli/src/application/assistant/runtime-context.ts new file mode 100644 index 00000000..f1011c2c --- /dev/null +++ b/apps/cli/src/application/assistant/runtime-context.ts @@ -0,0 +1,69 @@ +export type RuntimeShellDialect = 'windows-cmd' | 'posix-sh'; +export type RuntimeOsName = 'Windows' | 'macOS' | 'Linux' | 'Unknown'; + +export interface RuntimeContext { + platform: NodeJS.Platform; + osName: RuntimeOsName; + shellDialect: RuntimeShellDialect; + shellExecutable: string; +} + +export function getExecutionShell(platform: NodeJS.Platform = process.platform): string { + return platform === 'win32' ? (process.env.ComSpec || 'cmd.exe') : '/bin/sh'; +} + +export function getRuntimeContext(platform: NodeJS.Platform = process.platform): RuntimeContext { + if (platform === 'win32') { + return { + platform, + osName: 'Windows', + shellDialect: 'windows-cmd', + shellExecutable: getExecutionShell(platform), + }; + } + + if (platform === 'darwin') { + return { + platform, + osName: 'macOS', + shellDialect: 'posix-sh', + shellExecutable: getExecutionShell(platform), + }; + } + + if (platform === 'linux') { + return { + platform, + osName: 'Linux', + shellDialect: 'posix-sh', + shellExecutable: getExecutionShell(platform), + }; + } + + return { + platform, + osName: 'Unknown', + shellDialect: 'posix-sh', + shellExecutable: getExecutionShell(platform), + }; +} + +export function getRuntimeContextPrompt(runtime: RuntimeContext): string { + if (runtime.shellDialect === 'windows-cmd') { + return `## Runtime Platform (CRITICAL) +- Detected platform: **${runtime.platform}** +- Detected OS: **${runtime.osName}** +- Shell used by executeCommand: **${runtime.shellExecutable}** (Windows Command Prompt / cmd syntax) +- Use Windows command syntax for executeCommand (for example: \`dir\`, \`type\`, \`copy\`, \`move\`, \`del\`, \`rmdir\`). +- Use Windows-style absolute paths when outside workspace (for example: \`C:\\Users\\...\`). +- Do not assume macOS/Linux command syntax when the runtime is Windows.`; + } + + return `## Runtime Platform (CRITICAL) +- Detected platform: **${runtime.platform}** +- Detected OS: **${runtime.osName}** +- Shell used by executeCommand: **${runtime.shellExecutable}** (POSIX sh syntax) +- Use POSIX command syntax for executeCommand (for example: \`ls\`, \`cat\`, \`cp\`, \`mv\`, \`rm\`). +- Use POSIX paths when outside workspace (for example: \`~/Desktop\`, \`/Users/.../\` on macOS, \`/home/.../\` on Linux). +- Do not assume Windows command syntax when the runtime is POSIX.`; +} diff --git a/apps/cli/src/application/lib/command-executor.ts b/apps/cli/src/application/lib/command-executor.ts index 814d9801..cd16f05e 100644 --- a/apps/cli/src/application/lib/command-executor.ts +++ b/apps/cli/src/application/lib/command-executor.ts @@ -1,11 +1,13 @@ import { exec, execSync } from 'child_process'; import { promisify } from 'util'; import { getSecurityAllowList, SECURITY_CONFIG_PATH } from '../../config/security.js'; +import { getExecutionShell } from '../assistant/runtime-context.js'; const execPromise = promisify(exec); const COMMAND_SPLIT_REGEX = /(?:\|\||&&|;|\||\n)/; const ENV_ASSIGNMENT_REGEX = /^[A-Za-z_][A-Za-z0-9_]*=.*/; const WRAPPER_COMMANDS = new Set(['sudo', 'env', 'time', 'command']); +const EXECUTION_SHELL = getExecutionShell(); function sanitizeToken(token: string): string { return token.trim().replace(/^['"]+|['"]+$/g, ''); @@ -91,7 +93,7 @@ export async function executeCommand( cwd: options?.cwd, timeout: options?.timeout, maxBuffer: options?.maxBuffer || 1024 * 1024, // default 1MB - shell: '/bin/sh', // use sh for cross-platform compatibility + shell: EXECUTION_SHELL, }); return { @@ -125,7 +127,7 @@ export function executeCommandSync( cwd: options?.cwd, timeout: options?.timeout, encoding: 'utf-8', - shell: '/bin/sh', + shell: EXECUTION_SHELL, }); return { diff --git a/apps/docs/docs.json b/apps/docs/docs.json index 3c381b70..8442b158 100644 --- a/apps/docs/docs.json +++ b/apps/docs/docs.json @@ -18,36 +18,12 @@ "group": "Getting Started", "pages": [ "docs/getting-started/introduction", - "docs/getting-started/quickstart", - "docs/getting-started/license" + "docs/getting-started/quickstart" ] }, - { - "group": "Using Rowboat", - "pages": [ - "docs/using-rowboat/rowboat-studio", - "docs/using-rowboat/agents", - "docs/using-rowboat/tools", - "docs/using-rowboat/rag", - "docs/using-rowboat/triggers", - "docs/using-rowboat/jobs", - "docs/using-rowboat/conversations", - { - "group": "Customise", - "icon": "sliders", - "pages": [ - "docs/using-rowboat/customise/custom-llms" - ] - } - ] - }, - { - "group": "API & SDK", - "pages": ["docs/api-sdk/using_the_api", "docs/api-sdk/using_the_sdk"] - }, { "group": "Development", - "pages": ["docs/development/contribution-guide", "docs/development/roadmap"] + "pages": ["docs/development/contribution-guide", "docs/getting-started/license"] } ] }, diff --git a/apps/docs/docs/api-sdk/using_the_api.mdx b/apps/docs/docs/api-sdk/using_the_api.mdx deleted file mode 100644 index 60125b90..00000000 --- a/apps/docs/docs/api-sdk/using_the_api.mdx +++ /dev/null @@ -1,173 +0,0 @@ ---- -title: "Using the API" -description: "This is a guide on using the HTTP API to power conversations with the assistant created in Studio." -icon: "code" ---- - - -## Deploy your assistant to production on Studio - - Prod Deploy - - -## Obtain API key and Project ID - -Generate API keys via the developer configs in your project. Copy the Project ID from the same page. - - Developer Configs - - -## API Endpoint - -``` -POST /api/v1//chat -``` - -Where: - -- For self-hosted: `` is `http://localhost:3000` - -## Authentication - -Include your API key in the Authorization header: - -``` -Authorization: Bearer -``` - -## Examples - -### First Turn - -```bash -curl --location '/api/v1//chat' \ ---header 'Content-Type: application/json' \ ---header 'Authorization: Bearer ' \ ---data '{ - "messages": [ - { - "role": "user", - "content": "Hello, can you help me?" - } - ], - "state": null -}' -``` - -Response: -```json -{ - "messages": [ - { - "role": "assistant", - "content": "Hello! Yes, I'd be happy to help you. What can I assist you with today?", - "agenticResponseType": "external" - } - ], - "state": { - "last_agent_name": "MainAgent" - } -} -``` - -### Subsequent Turn - -Notice how we include both the previous messages and the state from the last response: - -```bash -curl --location '/api/v1//chat' \ ---header 'Content-Type: application/json' \ ---header 'Authorization: Bearer ' \ ---data '{ - "messages": [ - { - "role": "user", - "content": "Hello, can you help me?" - }, - { - "role": "assistant", - "content": "Hello! Yes, I'd be happy to help you. What can I assist you with today?", - "agenticResponseType": "external" - }, - { - "role": "user", - "content": "What services do you offer?" - } - ], - "state": { - "last_agent_name": "MainAgent" - } -}' -``` - -## API Specification - -### Request Schema - -```typescript -{ - // Required fields - messages: Message[]; // Array of message objects representing the conversation history - state: any; // State object from previous response, or null for first message - - // Optional fields - workflowId?: string; // Specific workflow ID to use (defaults to production workflow) - testProfileId?: string; // Test profile ID for simulation -} -``` - -### Message Types - -Messages can be one of the following types: - -1. System Message -```typescript -{ - role: "system"; - content: string; -} -``` - -2. User Message -```typescript -{ - role: "user"; - content: string; -} -``` - -3. Assistant Message -```typescript -{ - role: "assistant"; - content: string; - agenticResponseType: "internal" | "external"; - agenticSender?: string | null; -} -``` - -### Response Schema - -```typescript -{ - messages: Message[]; // Array of new messages from this turn - state: any; // State object to pass in the next request -} -``` - -## Important Notes - -1. Always pass the complete conversation history in the `messages` array -2. Always include the `state` from the previous response in your next request -3. The last message in the response's `messages` array will be a user-facing assistant message (`agenticResponseType: "external"`) - -## Rate Limiting - -The API has rate limits per project. If exceeded, you'll receive a 429 status code. - -## Error Responses - -- 400: Invalid request body or missing/invalid Authorization header -- 403: Invalid API key -- 404: Project or workflow not found -- 429: Rate limit exceeded \ No newline at end of file diff --git a/apps/docs/docs/api-sdk/using_the_sdk.mdx b/apps/docs/docs/api-sdk/using_the_sdk.mdx deleted file mode 100644 index 0909224f..00000000 --- a/apps/docs/docs/api-sdk/using_the_sdk.mdx +++ /dev/null @@ -1,91 +0,0 @@ ---- -title: "Using the SDK" -description: "This is a guide on using the RowBoat Python SDK as an alternative to the [RowBoat HTTP API](/using_the_api) to power conversations with the assistant created in Studio." -icon: "toolbox" ---- - -## Prerequisites -- ``` pip install rowboat ``` -- [Deploy your assistant to production](/using_the_api/#deploy-your-assistant-to-production-on-studio) -- [Obtain your `` and ``](/using_the_api/#obtain-api-key-and-project-id) - -### API Host -- For the open source installation, the `` is [http://localhost:3000](http://localhost:3000) -- When using the hosted app, the `` is [https://app.rowboatlabs.com](https://app.rowboatlabs.com) - -## Usage - -### Basic Usage - -The main way to interact with Rowboat is using the `Client` class, which provides a stateless chat API. You can manage conversation state using the `conversationId` returned in each response. - -```python -from rowboat.client import Client -from rowboat.schema import UserMessage - -# Initialize the client -client = Client( - host="", - projectId="", - apiKey="" -) - -# Start a new conversation -result = client.run_turn( - messages=[ - UserMessage(role='user', content="What is the capital of France?") - ] -) -print(result.turn.output[-1].content) -# The capital of France is Paris. - -print("Conversation ID:", result.conversationId) - -# Continue the conversation by passing the conversationId -result = client.run_turn( - messages=[ - UserMessage(role='user', content="What other major cities are in that country?") - ], - conversationId=result.conversationId -) -print(result.turn.output[-1].content) -# Other major cities in France include Lyon, Marseille, Toulouse, and Nice. - -result = client.run_turn( - messages=[ - UserMessage(role='user', content="What's the population of the first city you mentioned?") - ], - conversationId=result.conversationId -) -print(result.turn.output[-1].content) -# Lyon has a population of approximately 513,000 in the city proper. -``` - -### Using Tool Overrides (Mock Tools) - -You can provide tool override instructions to test a specific configuration using the `mockTools` argument: - -```python -result = client.run_turn( - messages=[ - UserMessage(role='user', content="What's the weather?") - ], - mockTools={ - "weather_lookup": "The weather in any city is sunny and 25°C.", - "calculator": "The result of any calculation is 42." - } -) -print(result.turn.output[-1].content) -``` - -### Message Types - -You can use different message types as defined in `rowboat.schema`, such as `UserMessage`, `SystemMessage`, `AssistantMessage`, etc. See `schema.py` for all available message types. - -### Error Handling - -If the API returns a non-200 status code, a `ValueError` will be raised with the error details. - ---- - -For more advanced usage, see the docstrings in `client.py` and the message schemas in `schema.py`. \ No newline at end of file diff --git a/apps/docs/docs/development/contribution-guide.mdx b/apps/docs/docs/development/contribution-guide.mdx index 94d0f46c..1089d7e0 100644 --- a/apps/docs/docs/development/contribution-guide.mdx +++ b/apps/docs/docs/development/contribution-guide.mdx @@ -1,59 +1,55 @@ --- title: "Contribution Guide" -description: "Learn how to contribute to the Rowboat project and help improve our platform." +description: "How to contribute to Rowboat — from bug reports to pull requests." icon: "github" --- -# Join the Rowboat Voyage +# Contributing to Rowboat -We're building Rowboat as an open-source, community-powered platform — and we'd love for you to hop aboard! Whether you're fixing typos, suggesting a new tool integration, or designing your dream multi-agent workflow, your contributions are valuable and welcome. +Rowboat is open-source and we welcome contributions of all kinds — bug reports, feature ideas, code, and docs improvements. - - Contribution guide hero image showing community collaboration - +**Quick links:** +- [GitHub Repository](https://github.com/rowboatlabs/rowboat) +- [Discord Community](https://discord.gg/wajrgmJQ6b) +- [Open Issues](https://github.com/rowboatlabs/rowboat/issues) --- -## How You Can Contribute +## Ways to Contribute +**Report bugs or suggest improvements** — If something feels off or could be better, [open an issue](https://github.com/rowboatlabs/rowboat/issues/new). Include steps to reproduce for bugs, or a clear description of the improvement you have in mind. -- **Tackle Open Issues** - Browse our [GitHub Issues](https://github.com/rowboatlabs/rowboat/issues) for tags like `good first issue`, `help wanted`, or `bug` to find a spot that fits your skillset. +**Fix an existing issue** — Browse [open issues](https://github.com/rowboatlabs/rowboat/issues) and comment on one to let us know you're working on it. -- **Join the Community** - Our [Discord](https://discord.gg/rxB8pzHxaS) is the go-to hub for brainstorming, feedback, and finding contributors for bigger efforts. - -- **Propose Something New** - Have a new tool integration idea or found a bug? Open an issue and let’s discuss it! +**Propose a new feature or integration** — Open an issue first so we can discuss the approach before you invest time building it. +**Improve documentation** — Typos, unclear explanations, missing examples — all fair game. --- -## Contribution Workflow & Best Practices - -Whether it's your first contribution or your fiftieth, here's what a great contribution looks like: - -| Step / Tip | Description | -|-------------------------------|-----------------------------------------------------------------------------------------------| -| **1. Fork the Repository** | Create a personal copy of [rowboatlabs/rowboat](https://github.com/rowboatlabs/rowboat) to start contributing. | -| **2. Create a New Branch** | Use a descriptive name like `fix-tool-crash` or `feature-new-mcp`. Avoid committing to `main`. | -| **3. Make Your Changes** | Focus your PR on a single issue or feature to keep things clean and reviewable. | -| **4. Write Tests if Needed** | If you change logic, add relevant tests so your contribution is future-proof. | -| **5. Run Tests & Lint Locally**| Make sure your branch passes all tests and code quality checks before pushing. | -| **6. Document or Demo It** | Add helpful context: screenshots, example scripts, or a short video/gif to demonstrate your changes. | -| **7. Submit a Pull Request** | Open a PR with a clear description of your changes and any context reviewers should know. | -| **8. Collaborate on Feedback** | Our maintainers may leave comments — it’s all part of the process. Let’s improve it together. | -| **9. Don’t Be Shy to Follow Up** | Feel free to ping the PR/issue if you're waiting on feedback. We appreciate polite nudges. | -| **10. Celebrate the Merge!** | You just made Rowboat better. Thanks for contributing 🚀 | - -If you're fixing typos, spacing, or small tweaks — try bundling those into a related PR instead of sending them standalone. It helps keep reviews focused. +## Contribution Workflow +1. **Fork** [rowboatlabs/rowboat](https://github.com/rowboatlabs/rowboat) and clone it locally. +2. **Create a branch from `dev`** with a descriptive name (`fix-tool-crash`, `feature-mcp-discovery`). +3. **Make your changes.** Keep PRs focused on a single issue or feature. +4. **Test your changes** locally before submitting. +5. **Open a pull request against `dev`** (not `main`) with a clear description of what you changed and why. Screenshots or short demos are appreciated for UI changes. +6. **Respond to feedback** — maintainers may request changes. This is normal and collaborative. +7. **Merge!** Once approved, we'll merge your PR. +For small fixes like typos or formatting, try bundling related changes into a single PR rather than submitting them individually. --- -## Come Build With Us +## Guidelines -We believe great ideas come from the community — and that means **you**. Whether you're an engineer, designer, AI tinkerer, or curious beginner, there’s room on this boat for everyone. +- **One PR, one concern.** Don't mix unrelated changes in the same pull request. +- **Write clear commit messages.** A reviewer should understand what changed from the message alone. +- **Follow existing code style.** Match the patterns you see in the codebase. +- **Be patient and respectful.** We review PRs as quickly as we can. A polite ping on Discord is always welcome if things go quiet. -Let’s build the future of AI workflows — together. 🫶 +--- + +## Getting Help + +If you're stuck or unsure about anything, drop a message in our [Discord](https://discord.gg/wajrgmJQ6b). We're happy to help you get unblocked. \ No newline at end of file diff --git a/apps/docs/docs/getting-started/introduction.mdx b/apps/docs/docs/getting-started/introduction.mdx index 8fde54db..fd76e87d 100644 --- a/apps/docs/docs/getting-started/introduction.mdx +++ b/apps/docs/docs/getting-started/introduction.mdx @@ -1,60 +1,96 @@ --- title: "Introduction" -description: "Welcome to the official Rowboat documentation! Rowboat is a low-code AI IDE to build tool connected multi-agent assistants. Rowboat copilot builds the agents for you based on your requirements with the option do everything manually as well." +description: "Welcome to the official Rowboat documentation! Rowboat is an open-source AI coworker that turns work into a knowledge graph and acts on it." icon: "book-open" --- - - - Intro Video - - -## What is RowBoat? -**RowBoat is a state-of-art platform to build multi-agent AI systems in a visual interface, with the help of a copilot.** - -RowBoat enables you to build, manage and deploy user-facing assistants. An assistant is made up of multiple agents, each having access to a set of tools and working together to interact with the user as a single assistant. You can connect any tool to the agents. - -For example, you can build a *meeting prep assistant* that helps you prepare for upcoming meetings. One agent can access your Google Calendar to see your scheduled meetings, another agent can research the meeting attendees (such as finding their LinkedIn profiles or recent news), and a third agent can compile this research and send it to your email before the meeting. This way, you get automated, personalized meeting prep without manual effort. +[![Demo](https://github.com/user-attachments/assets/3f560bcf-d93c-4064-81eb-75a9fae31742)](https://www.youtube.com/watch?v=5AWoGo-L16I) --- -## How RowBoat works +## What is Rowboat? +Rowboat is a local-first AI coworker, with work memory. Rowboat connects to your email and meeting notes, builds a long-lived knowledge graph, and uses that context to help you get work done - privately, on your machine. -### RowBoat Studio -RowBoat Studio lets you create AI agents in minutes, using a visual interface and plain language. -There are key components that you will work with: -- Agents -- Playground -- Copilot - - - - Learn about Rowboat Studio and key concepts used in building assistants - - - -### RowBoat Chat API & SDK -- [RowBoat Chat API](/docs/api-sdk/using_the_api) is a stateless HTTP API to interface with the assistant created on RowBoat Studio. You can use the API to drive end-user facing conversations in your app or website. -- [RowBoat Chat SDK](/docs/api-sdk/using_the_sdk) is a simple Python SDK which wraps the HTTP API under the hood. It provides a clean interface for managing conversations using conversation IDs for state management. +You can do things like: +- `Build me a deck about our next quarter roadmap` → generates a PDF using context from your knowledge graph +- `Prep me for my meeting with Alex` → pulls past decisions, open questions, and relevant threads into a crisp brief (or a voice note) +- Visualize, edit, and update your knowledge graph anytime (it’s just Markdown) +- Record voice memos that automatically capture and update key takeaways in the graph --- -## Why RowBoat? -Rowboat is the fastest way to build and deploy multi-agent assistants. +## What it does - - - Use plain language and a powerful visual interface to design and orchestrate multi-agent assistants with ease. - +Rowboat is a **local-first AI coworker** that can: +- **Remember** the important context you don’t want to re-explain (people, projects, decisions, commitments) +- **Understand** what’s relevant right now (before a meeting, while replying to an email, when writing a doc) +- **Help you act** by drafting, summarizing, planning, and producing real artifacts (briefs, emails, docs, PDF slides) - - Add tools and connect to MCP servers in just minutes — no complex setup required. - +Under the hood, Rowboat maintains an **Obsidian-compatible vault** of plain Markdown notes with backlinks — a transparent “working memory” you can inspect and edit. - - Accelerate development with battle-tested tooling tailored for building production-ready, multi-agent AI systems. - - +## Integrations +Rowboat builds memory from the work you already do, including: +- **Gmail** (email) +- **Granola** (meeting notes) +- **Fireflies** (meeting notes) + +## How it’s different + +Most AI tools reconstruct context on demand by searching transcripts or documents. + +Rowboat maintains **long-lived knowledge** instead: +- context accumulates over time +- relationships are explicit and inspectable +- notes are editable by you, not hidden inside a model +- everything lives on your machine as plain Markdown + +The result is memory that compounds, rather than retrieval that starts cold every time. + +## What you can do with it + +- **Meeting prep** from prior decisions, threads, and open questions +- **Email drafting** grounded in history and commitments +- **Docs & decks** generated from your ongoing context (including PDF slides) +- **Follow-ups**: capture decisions, action items, and owners so nothing gets dropped +- **On-your-machine help**: create files, summarize into notes, and run workflows using local tools (with explicit, reviewable actions) + +## Background agents + +Rowboat can spin up **background agents** to do repeatable work automatically - so routine tasks happen without you having to ask every time. + +Examples: +- Draft email replies in the background (grounded in your past context and commitments) +- Generate a daily voice note each morning (agenda, priorities, upcoming meetings) +- Create recurring project updates from the latest emails/notes +- Keep your knowledge graph up to date as new information comes in + +You control what runs, when it runs, and what gets written back into your local Markdown vault. + +## Bring your own model + +Rowboat works with the model setup you prefer: +- **Local models** via Ollama or LM Studio +- **Hosted models** (bring your own API key/provider) +- Swap models anytime — your data stays in your local Markdown vault + +## Extend Rowboat with tools (MCP) + +Rowboat can connect to external tools and services via **Model Context Protocol (MCP)**. +That means you can plug in (for example) search, databases, CRMs, support tools, and automations - or your own internal tools. + +Examples: Exa (web search), Twitter/X, ElevenLabs (voice), Slack, Linear/Jira, GitHub, and more. + +## Local-first by design + +- All data is stored locally as plain Markdown +- No proprietary formats or hosted lock-in +- You can inspect, edit, back up, or delete everything at any time + +--- +
+ +[Discord](https://discord.gg/wajrgmJQ6b) · [Twitter](https://x.com/intent/user?screen_name=rowboatlabshq) +
--- ## Contributing @@ -72,7 +108,7 @@ Need help using Rowboat? Join our community! Join our growing discord community and interact with hundreds of developer using Rowboat! diff --git a/apps/docs/docs/getting-started/quickstart.mdx b/apps/docs/docs/getting-started/quickstart.mdx index 04fc761b..1ab0bc05 100644 --- a/apps/docs/docs/getting-started/quickstart.mdx +++ b/apps/docs/docs/getting-started/quickstart.mdx @@ -3,92 +3,25 @@ title: "Quickstart" description: "guide to getting started with rowboat" icon: "rocket" --- ---- -# Cloud Setup +**Download latest for Mac/Windows/Linux:** [Download](https://www.rowboatlabs.com/downloads) -Using the open-source version of Rowboat requires more technical skill to set up and navigate. For the smoothest experience, we recommend using our [hosted version](https://dev.rowboatlabs.com/) +**All release files:** https://github.com/rowboatlabs/rowboat/releases/latest ---- +## Google setup (optional) +To connect Gmail, Calendar, and Drive, follow [Google setup](https://github.com/rowboatlabs/rowboat/blob/main/google-setup.md). -# Local Setup +## Voice notes (optional) +To enable voice notes, add a Deepgram API key in `~/.rowboat/config/deepgram.json`: -Pre-requisite: Ensure Docker is installed on your machine. You'll also need an OpenAI account and API key to use the Copilot and agents. +```json +{ + "apiKey": "" +} +``` +## Web search (optional) +To use Brave web search, add the Brave API key in `~/.rowboat/config/brave-search.json`. - - - Export your OpenAI API key in your terminal: +To use Exa research search, add the Exa API key in `~/.rowboat/config/exa-search.json`. - ```bash - export OPENAI_API_KEY=your-openai-api-key - ``` - - - - To use external tools and triggers, export your Composio API key: - - ```bash - export COMPOSIO_API_KEY=your-composio-api-key - export COMPOSIO_TRIGGERS_WEBHOOK_SECRET=your-webhook-secret - ``` - - For more detailed setup instructions, see the [Triggers](/docs/using-rowboat/triggers#local-setup) page. - - - - Clone the Rowboat repository and start the app using Docker: - - ```bash - git clone git@github.com:rowboatlabs/rowboat.git - cd rowboat - ./start.sh - ``` - - - - Once Docker is running, open your browser and go to: - - [http://localhost:3000](http://localhost:3000) - - - - -See the [Using custom LLM providers](#using-custom-llm-providers) section below for using custom providers like OpenRouter and LiteLLM. - ---- - -## Demo -{/* (would be better to change this to a Getiing Started Tutorial) */} - -#### Create a multi-agent assistant with MCP tools by chatting with Rowboat -[![Screenshot 2025-04-23 at 00 25 31](https://github.com/user-attachments/assets/c8a41622-8e0e-459f-becb-767503489866)](https://youtu.be/YRTCw9UHRbU) - ---- - -## Integrate with Rowboat agents - -There are 2 ways to integrate with the agents you create in Rowboat - - - - - Guide on using the HTTP API - - - - Guide on using the Python SDK - - - - ---- - -## Using custom LLM providers -By default, Rowboat uses OpenAI LLMs (gpt-4o, gpt-4.1, etc.) for both agents and copilot, when you export your OPENAI_API_KEY. - -However, you can also configure custom LLM providers (e.g. LiteLLM, OpenRouter) to use any of the hundreds of available LLMs beyond OpenAI, such as Claude, DeepSeek, Ollama LLMs and so on. - -Check out our page on customising - - Learn more about customising your Rowboat experience here - +(Use the same JSON format as above.) diff --git a/apps/docs/docs/using-rowboat/agents.mdx b/apps/docs/docs/using-rowboat/agents.mdx deleted file mode 100644 index ceaeccae..00000000 --- a/apps/docs/docs/using-rowboat/agents.mdx +++ /dev/null @@ -1,141 +0,0 @@ ---- -title: "Agents" -description: "Learn about creating and configuring individual agents within your multi-agent system" -icon: "robot" ---- - -## Overview - -Agents are the core building blocks of Rowboat's multi-agent system. Each agent carries out a specific part of a conversation, handles tasks via tools, and can collaborate with other agents to orchestrate complex workflows. - -They are powered by LLMs and can: -- Respond to user input -- Trigger tools or APIs -- Pass control to other agents using @mentions -- Fetch or process internal data -- Execute RAG (Retrieval-Augmented Generation) queries -- Participate in sequential pipeline workflows - ---- - -## Agent Types - -Rowboat supports several types of agents, each designed for specific use cases: - -| Name | Purpose | Characteristics | -|------|---------|-----------------| -| **Conversational Agents** (`conversation`) | Primary user-facing agents that interact directly with users and orchestrate workflows. | • Can respond to users and orchestrate workflows
• Typically serve as the start agent (Hub Agent)| -| **Task Agents** (`internal`) | Specialized agents that perform specific tasks without direct user interaction. | • Focused on specific functions
• Return results to parent agents| -| **Pipeline Agents** (`pipeline`) | Sequential workflow execution agents that process data in a chain. | • Execute in sequence within a pipeline
• Cannot transfer to other agents directly| - - ---- - -## Agent Configuration - -Agents are configured through two main tabs in the Rowboat Studio interface: - -### **Instructions Tab** - - -#### Description -A clear description of the agent's role and responsibilities - -#### Instructions -Instructions are the backbone of the agent's behavior. Use the Copilot's structured format for consistency: - -**Recommended Structure:** -``` -## 🧑‍💼 Role: -[Clear description of the agent's role] - -## ⚙️ Steps to Follow: -1. [Step 1] -2. [Step 2] -3. [Step 3] - -## 🎯 Scope: -✅ In Scope: -- [What the agent should handle] - -❌ Out of Scope: -- [What the agent should NOT handle] - -## 📋 Guidelines: -✔️ Dos: -- [Positive behaviors] - -🚫 Don'ts: -- [Negative behaviors] -``` - -#### Examples -These help agents behave correctly in specific situations. Each example can include: -- A sample user message -- The expected agent response -- Any tool calls (if applicable) - -### **Configurations Tab** - -#### Name -Name of the agent - - -#### Behaviour -- **Agent Type**: Choose from `conversation`, `internal`, or `pipeline` -- **Model**: Select the LLM model (GPT-4.1, GPT-4o, google/gemini-2.5-flash, etc.) - -#### RAG -- **Add Source**: Connect data sources to enable RAG capabilities for the agent - ---- - -## Creating Your Initial Set of Agents - -Let Copilot bootstrap your agent graph. - -### Instruct Copilot - -Start by telling Copilot what your assistant is meant to do — it'll generate an initial set of agents with best-practice instructions, role definitions, and connected agents. - - - Creating agents with Copilot - - -### Inspect the Output - -After applying the suggested agents, take a close look at each one's: -- **Instructions**: Define how the agent behaves -- **Examples**: Guide agent responses and tool use - - - Inspect agent instructions - - ---- - -## Updating Agent Behavior - -There are three ways to update an agent: - -### 1. With Copilot - -Copilot understands the current chat context and can help rewrite or improve an agent's behavior based on how it performed. - - - Update agent using Copilot - - - - -### 2. Manual Edits - -You can always manually edit the agent's instructions. - - - Manually edit agent - - ---- - - diff --git a/apps/docs/docs/using-rowboat/conversations.mdx b/apps/docs/docs/using-rowboat/conversations.mdx deleted file mode 100644 index c755f47d..00000000 --- a/apps/docs/docs/using-rowboat/conversations.mdx +++ /dev/null @@ -1,52 +0,0 @@ ---- -title: "Conversations" -description: "View and manage all conversations with your Rowboat agents" -icon: "list-check" ---- - -## Overview - -The Conversations page in Rowboat shows you all the interactions between users and your agents. Here you can monitor conversations, view detailed message exchanges, and understand how your agents are performing. - - - Conversations page UI showing list of conversations - - -## What You'll See - -The Conversations page displays a list of all conversations organized by time: - -- **Today**: Recent conversations from today -- **This week**: Conversations from the current week -- **This month**: Conversations from the current month -- **Older**: Conversations from previous months - -Each conversation shows: -- **Conversation ID**: Unique identifier for the conversation -- **Created time**: When the conversation started -- **Reason**: What triggered the conversation (chat or job) - -## Viewing Conversation Details -Click on any conversation to see the detailed view with all the message exchanges: - - - Conversation details showing expanded view of a conversation with turns and messages - - -**Conversation Metadata**: Shows the Conversation ID, creation time, and last update time. - -**Workflow**: Shows the workflow JSON - -**Turns**: Each conversation is made up of turns, where: -- **Turn #1, #2, etc.**: Numbered sequence of interactions -- **Reason badge**: Shows why each turn happened (chat, API, job, etc.) -- **Timestamp**: When each turn occurred -- **Input messages**: What was sent to your agents -- **Output messages**: What your agents responded with - -### Turn Details - -Each turn displays: -- **Input**: The messages sent to your agents (user messages, system messages) -- **Output**: The responses from your agents -- **Error information**: Any issues that occurred during processing diff --git a/apps/docs/docs/using-rowboat/customise/custom-llms.mdx b/apps/docs/docs/using-rowboat/customise/custom-llms.mdx deleted file mode 100644 index 64b27ca1..00000000 --- a/apps/docs/docs/using-rowboat/customise/custom-llms.mdx +++ /dev/null @@ -1,53 +0,0 @@ ---- -title: "Custom LLMs" -description: "How to use and configure custom LLMs in Rowboat." - ---- - - This is currently only possible in the self hosted version of Rowboat - -## Using custom LLM providers - -By default, Rowboat uses OpenAI LLMs (gpt-4o, gpt-4.1, etc.) for both agents and copilot, when you export your OPENAI_API_KEY. - -However, you can also configure custom LLM providers (e.g. LiteLLM, OpenRouter) to use any of the hundreds of available LLMs beyond OpenAI, such as Claude, DeepSeek, Ollama LLMs and so on. - - - - Configure your environment variables to point to your preferred LLM backend. Example using LiteLLM: - - ```bash - export PROVIDER_BASE_URL=http://host.docker.internal:4000/ - export PROVIDER_API_KEY=sk-1234 - ``` - - Rowboat uses gpt-4.1 as the default model for agents and copilot. You can override these: - - ```bash - export PROVIDER_DEFAULT_MODEL=claude-3-7-sonnet-latest - export PROVIDER_COPILOT_MODEL=gpt-4.1 - ``` - - **Notes:** - - Copilot is optimized for gpt-4o/gpt-4.1. We strongly recommend using these models for best results. - - You can use different models for the copilot and each agent, but all must be from the same provider (e.g., LiteLLM). - - Rowboat is provider-agnostic — any backend implementing the OpenAI messages format should work. - - OpenAI-specific tools (like web_search) will not function with non-OpenAI providers. Remove such tools to avoid errors. - - - - Clone the Rowboat repo and spin it up locally: - - ```bash - git clone git@github.com:rowboatlabs/rowboat.git - cd rowboat - docker-compose up --build - ``` - - - - Once Docker is running, navigate to: - - [http://localhost:3000](http://localhost:3000) - - diff --git a/apps/docs/docs/using-rowboat/jobs.mdx b/apps/docs/docs/using-rowboat/jobs.mdx deleted file mode 100644 index 5b3e14df..00000000 --- a/apps/docs/docs/using-rowboat/jobs.mdx +++ /dev/null @@ -1,45 +0,0 @@ ---- -title: "Jobs" -description: "Monitor and inspect all your trigger executions and job runs" -icon: "message" ---- - -## Overview - -The Jobs page in Rowboat provides a comprehensive view of all your automated job executions. Here you can monitor the status of your triggers, inspect what happened during each run, and troubleshoot any issues that may have occurred. - - - Jobs page showing list of all job runs with status indicators - - -## What You'll See - -The Jobs page displays a list of all job runs from your triggers, including: - -- **External trigger executions** from webhook events -- **One-time trigger runs** from scheduled jobs -- **Recurring trigger executions** from cron-based schedules - -Each job run displays the following key information: -- **Job ID**: Unique identifier for the job run -- **Status**: Indicates if the job succeeded, failed, or is in progress -- **Reason**: The trigger or cause for the job (e.g., external trigger, scheduled, cron) -- **Created Time**: When the job was executed - -## Viewing Job Details - -### Expand a Job Run - -Click on any job run to expand it and see detailed information about what happened during execution: - - - Job run details showing expanded information for a specific job - - -**Basic job details**: Job ID, Status, creation time, Updated time, Conversation ID and Turn ID. By clicking on the Conversation ID, you can view more in-depth details about the run. - -**Job Reason**: Why the job triggered - either external trigger, scheduled, or cron. - -**Job Input**: The input data sent to your assistant. - -**Job Output**: The final output produced by your agents. \ No newline at end of file diff --git a/apps/docs/docs/using-rowboat/rag.mdx b/apps/docs/docs/using-rowboat/rag.mdx deleted file mode 100644 index 772d034d..00000000 --- a/apps/docs/docs/using-rowboat/rag.mdx +++ /dev/null @@ -1,68 +0,0 @@ ---- -title: "RAG (Data)" -description: "How to use our inbuilt RAG" -icon: "database" ---- - -# Using RAG in Rowboat - -Rowboat provides multiple ways to enhance your agents' context with Retrieval-Augmented Generation (RAG). This guide will help you set up and use each RAG feature. - -RAG is called "Data" on the build view in the Rowboat UI. - ---- - -## Types of RAG - -| RAG Type | Description | Configuration Required | -|----------|-------------|------------------------| -| **Text RAG** | Process and reason over text content directly | No configuration needed | -| **File Uploads** | Upload PDF files directly from your device | No configuration needed | -| **URL Scraping** | Scrape content from web URLs using Firecrawl | Requires API key setup | - - URL Scraping does not require any setup in the managed version of Rowboat. - - - Adding data sources for RAG in Rowboat - - - -## RAG Features - -### 1. Text RAG - -Process and reason over text content directly - - -### 2. File Uploads - -- Upload PDF files directly from your device -- **Open Source Version**: Files are stored locally on your machine -- **Managed Version**: Files are stored in cloud S3 storage -- Files are parsed using OpenAI by default - - You can also use Google's Gemini model for parsing as it is better at parsing larger files. - -#### 2.1 Using Gemini for File Parsing - -To use Google's Gemini model for parsing uploaded PDFs, set the following variables: - -```bash -# Enable Gemini for file parsing -export USE_GEMINI_FILE_PARSING=true -export GOOGLE_API_KEY=your_google_api_key -``` - - -### 3. URL Scraping - -Rowboat uses Firecrawl for URL scraping. You can have a maximum of 100 URLs. - -**Open Source Version**: To enable URL scraping, set the following variables: - -```bash -export USE_RAG_SCRAPING=true -export FIRECRAWL_API_KEY=your_firecrawl_api_key -``` - -**Managed Version**: No configuration required - URL scraping is handled automatically. diff --git a/apps/docs/docs/using-rowboat/rowboat-studio.mdx b/apps/docs/docs/using-rowboat/rowboat-studio.mdx deleted file mode 100644 index edf74fb3..00000000 --- a/apps/docs/docs/using-rowboat/rowboat-studio.mdx +++ /dev/null @@ -1,60 +0,0 @@ ---- -title: "Rowboat Studio" -description: "Visual interface to build, test, and deploy multi-agent AI assistants using plain language" -icon: "puzzle-piece" ---- - - -## Overview - -**Rowboat Studio** is your visual interface for building AI assistants — powered by agents, tools, and workflows — using plain language and minimal setup. It brings the process of creating multi-agent systems down to just a few clicks. - -Workflows created within Rowboat are known as **assistants**, and each assistant is composed of: -- One or more **agents** -- Attached **tools** and **MCP servers** - -Once built, assistants can be tested live in the **playground** and deployed in real-world products using the [API](/docs/api-sdk/using_the_api) or [SDK](/docs/api-sdk//using_the_sdk). - ---- - -## Key Components - -Here’s what you’ll interact with in Studio: - -| Component | Description | Highlights | -|------------|-------------|------------| -| **Agent** | Core building blocks of your assistant.
Each agent handles a specific part of the conversation and performs tasks using tools and instructions. | • Define behavior in plain language
• Connect agents into a graph
• Attach tools and RAG sources | -| **Playground** | Interactive testbed for conversations.
Lets you simulate end-user chats with your assistant and inspect agent behavior in real time. | • Real-time feedback and debugging
• See tool calls and agent handoffs
• Test individual agents or the whole system | -| **Copilot** | Your AI assistant for building assistants.
Copilot creates and updates agents, tools, and instructions based on your plain-English prompts. | • Understands full system context
• Improves agents based on playground chat
• Builds workflows intelligently and fast | - -> **Agents are the heart of every assistant.** Learn more about how they work in the Agents page. - - - Learn about creating and configuring individual agents within your multi-agent system - ---- - -## Building in Rowboat - - - - Use plain language to tell Copilot what you want your assistant to do. Copilot will auto-generate the agents, instructions, and tools that form the base of your assistant. - - - - Inspect the created agents — especially their instructions and examples — and refine or approve them before moving forward. - - - - Integrate external services, tools, and backend logic into your agents using Rowboat's modular system. Tools are tied to agents and triggered through instructions. - - - - Use the chat playground to simulate real-world conversations. You’ll see which agent takes control, what tools are triggered, and how your assistant flows. - - - - Assistants can be deployed into production using the **Rowboat Chat API** or the **Rowboat Chat SDK**. Both support stateless and stateful conversation flows. - - - diff --git a/apps/docs/docs/using-rowboat/tools.mdx b/apps/docs/docs/using-rowboat/tools.mdx deleted file mode 100644 index 7a116d63..00000000 --- a/apps/docs/docs/using-rowboat/tools.mdx +++ /dev/null @@ -1,56 +0,0 @@ ---- -title: "Tools" -description: "Add and configure tools for your agents to interact with external services" -icon: "wrench" ---- - -## Overview - -The Tools page in Rowboat lets you add and configure tools that your agents can use to interact with external services, APIs, and systems. Tools enable your agents to perform real-world actions like sending emails, managing calendars, or processing payments. - - - Screenshot of the Tools UI in Rowboat - - -## Tool Types - -| Tool Type | Description | Use Case | Availability | -|-----------|-------------|----------|--------------| -| **Library Tools** | Pre-built integrations with popular services | Quick setup, no configuration needed | Managed and open source | -| **MCP Tools** | Custom tools from MCP servers | Custom functionality, specialized APIs | Managed and open source | -| **Webhook Tools** | HTTP endpoints for custom integrations | Your own systems, custom workflows | Open source only | - - -## Library (Composio Tools) - -- Browse a library of 500+ toolkits from popular services -- With 3000+ tools to choose from! -- Click on a service to see available tools and add them to your workflow -- Users must create a [Composio](https://composio.dev/) account and add their API key -- Tools require authorization to work properly - -### Setting up Composio API Key - -To use Composio tools, get a Composio key and export it as an environment variable: - -```bash -export COMPOSIO_API_KEY=your_api_key_here -``` - -Users can visit [Composio's toolkit documentation](https://docs.composio.dev/toolkits/introduction) for a deep dive into all the tools available. - -## Custom MCP Servers - -- Add your own MCP (Model Context Protocol) servers -- Connect to custom tools and APIs you've built -- Configure server URLs and authentication -- Import tools from your MCP servers - -## Webhook - -Webhook tools are only available in the open source (local) version of Rowboat. - -- Create custom webhook tools -- Configure HTTP endpoints for your agents to call -- Set up custom authentication and parameters -- Build integrations with your own systems diff --git a/apps/docs/docs/using-rowboat/triggers.mdx b/apps/docs/docs/using-rowboat/triggers.mdx deleted file mode 100644 index 32c81f66..00000000 --- a/apps/docs/docs/using-rowboat/triggers.mdx +++ /dev/null @@ -1,131 +0,0 @@ ---- -title: "Triggers" -description: "Learn about setting up automated triggers for your Rowboat agents" -icon: "bolt" ---- - -## Overview - -Triggers in Rowboat are automated mechanisms that activate your agents when specific events occur or conditions are met. They form the foundation of your automated workflow system, enabling your agents to respond to external events, scheduled times, and system conditions without manual intervention. - - - -## Trigger Types - -Rowboat supports three main categories of triggers, each designed for different automation scenarios: - -| Trigger Type | Purpose | Execution | Use Cases | -|--------------|---------|-----------|-----------| -| **External Triggers** | Connect to external services and events | Real-time via webhooks | Slack messages, GitHub events, email processing | -| **One-Time Triggers** | Execute at specific predetermined times | Single execution at set time | Delayed responses, time-sensitive actions | -| **Recurring Triggers** | Execute on repeating schedules | Continuous via cron expressions | Daily reports, periodic maintenance, regular syncs | - ---- - -## External Triggers (Composio Integration) - -External triggers are powered by **Composio** and allow users to use triggers from across 30+ services including Slack, GitHub, Gmail, Notion, Google Calendar, and more. - - - External Triggers UI showing available toolkits and services - - -### Creating External Triggers - -1. **Click New External Trigger**: Start the trigger creation process -2. **Select a Toolkit**: Browse available toolkits or search for specific services -3. **Choose Trigger Type**: Select the specific trigger from available options, click configure -4. **Authenticate**: Complete OAuth2 flow or enter API keys for the selected service (your preferred method) -5. **Configure**: Set up event filters and data mapping if required -6. **Deploy**: Activate the trigger to start listening for events - -### Local Setup - -If you're running the open source version of Rowboat, you'll need to set up external triggers manually. In the managed version, this is all handled automatically for you. - - - - Sign into [Composio](https://composio.dev/) and create a new project for your Rowboat instance. - - - - Go to your project settings and copy the project API key. Export it in your Rowboat environment: - - ```bash - export COMPOSIO_API_KEY=your-composio-api-key - ``` - - - - Use ngrok to expose your local Rowboat instance: - - ```bash - ngrok http 3000 - ``` - - Copy the generated ngrok URL (e.g., `https://a5fe8c0d45b8.ngrok-free.app`). - - - - In Composio, go to Events & Triggers section and set the Trigger Webhook URL to: - - ``` - {ngrok_url}/api/composio/webhook - ``` - - Example: `https://a5fe8c0d45b8.ngrok-free.app/api/composio/webhook` - - - - Copy the Webhook Secret from Composio and export it in Rowboat: - - ```bash - export COMPOSIO_TRIGGERS_WEBHOOK_SECRET=your-webhook-secret - ``` - - - - Restart your Rowboat instance to load the new environment variables. You're now ready to use external triggers! - - - -Make sure your Rowboat assistant is deployed before receiving trigger calls - ---- - -## One-Time Triggers (Scheduled Jobs) - -One-time triggers execute your agents at a specific, predetermined time. They're useful for delayed responses, batch processing, time-sensitive actions, or coordinating with external schedules. - - - One-Time Triggers UI showing scheduled job configuration - - -### Creating One-Time Triggers -1. Set the exact execution time (date and time) -2. Configure the input messages for your agents -3. Deploy to schedule the execution - ---- - -## Recurring Triggers (Cron-based Jobs) - -Recurring triggers execute your agents on a repeating schedule using cron expressions. They're ideal for daily reports, periodic maintenance, regular data syncs, and continuous monitoring tasks. - - - Recurring Triggers UI showing cron-based job configuration - - -### Creating Recurring Triggers -1. Define the cron expression (e.g., `0 9 * * *` for daily at 9 AM) -2. Configure the recurring message structure -3. Enable the trigger to start the recurring schedule - -### Common Cron Patterns -```cron -0 9 * * * # Daily at 9:00 AM -0 8 * * 1 # Every Monday at 8:00 AM -*/15 * * * * # Every 15 minutes -0 0 1 * * # First day of month at midnight -``` - diff --git a/apps/rowboat/package.json b/apps/rowboat/package.json index 5b0bd228..c6c5e2b5 100644 --- a/apps/rowboat/package.json +++ b/apps/rowboat/package.json @@ -4,7 +4,7 @@ "private": true, "type": "module", "scripts": { - "dev": "next dev --turbopack", + "dev": "npx next dev --turbopack", "build": "next build", "start": "next start", "lint": "next lint", diff --git a/apps/x/apps/main/src/ipc.ts b/apps/x/apps/main/src/ipc.ts index 72e1e589..4d272275 100644 --- a/apps/x/apps/main/src/ipc.ts +++ b/apps/x/apps/main/src/ipc.ts @@ -30,6 +30,8 @@ import * as composioHandler from './composio-handler.js'; import { IAgentScheduleRepo } from '@x/core/dist/agent-schedule/repo.js'; import { IAgentScheduleStateRepo } from '@x/core/dist/agent-schedule/state-repo.js'; import { triggerRun as triggerAgentScheduleRun } from '@x/core/dist/agent-schedule/runner.js'; +import { search } from '@x/core/dist/search/search.js'; +import { versionHistory } from '@x/core'; type InvokeChannels = ipc.InvokeChannels; type IPCChannels = ipc.IPCChannels; @@ -104,6 +106,18 @@ let watcher: FSWatcher | null = null; const changeQueue = new Set(); let debounceTimer: ReturnType | null = null; +/** + * Emit knowledge commit event to all renderer windows + */ +function emitKnowledgeCommitEvent(): void { + const windows = BrowserWindow.getAllWindows(); + for (const win of windows) { + if (!win.isDestroyed() && win.webContents) { + win.webContents.send('knowledge:didCommit', {}); + } + } +} + /** * Emit workspace change event to all renderer windows */ @@ -282,6 +296,9 @@ export function stopServicesWatcher(): void { * Add new handlers here as you add channels to IPCChannels */ export function setupIpcHandlers() { + // Forward knowledge commit events to renderer for panel refresh + versionHistory.onCommit(() => emitKnowledgeCommitEvent()); + registerIpcHandlers({ 'app:getVersions': async () => { // args is null for this channel (no request payload) @@ -497,5 +514,22 @@ export function setupIpcHandlers() { const mimeType = mimeMap[ext] || 'application/octet-stream'; return { data: buffer.toString('base64'), mimeType, size: stat.size }; }, + // Knowledge version history handlers + 'knowledge:history': async (_event, args) => { + const commits = await versionHistory.getFileHistory(args.path); + return { commits }; + }, + 'knowledge:fileAtCommit': async (_event, args) => { + const content = await versionHistory.getFileAtCommit(args.path, args.oid); + return { content }; + }, + 'knowledge:restore': async (_event, args) => { + await versionHistory.restoreFile(args.path, args.oid); + return { ok: true }; + }, + // Search handler + 'search:query': async (_event, args) => { + return search(args.query, args.limit, args.types); + }, }); } diff --git a/apps/x/apps/main/src/main.ts b/apps/x/apps/main/src/main.ts index 2a5330ab..34363b28 100644 --- a/apps/x/apps/main/src/main.ts +++ b/apps/x/apps/main/src/main.ts @@ -17,7 +17,6 @@ import { init as initCalendarSync } from "@x/core/dist/knowledge/sync_calendar.j import { init as initFirefliesSync } from "@x/core/dist/knowledge/sync_fireflies.js"; import { init as initGranolaSync } from "@x/core/dist/knowledge/granola/sync.js"; import { init as initGraphBuilder } from "@x/core/dist/knowledge/build_graph.js"; -import { init as initPreBuiltRunner } from "@x/core/dist/pre_built/runner.js"; import { init as initAgentRunner } from "@x/core/dist/agent-schedule/runner.js"; import { initConfigs } from "@x/core/dist/config/initConfigs.js"; import started from "electron-squirrel-startup"; @@ -171,9 +170,6 @@ app.whenReady().then(async () => { // start knowledge graph builder initGraphBuilder(); - // start pre-built agent runner - initPreBuiltRunner(); - // start background agent runner (scheduled agents) initAgentRunner(); diff --git a/apps/x/apps/main/src/oauth-handler.ts b/apps/x/apps/main/src/oauth-handler.ts index eba43956..2efc77c2 100644 --- a/apps/x/apps/main/src/oauth-handler.ts +++ b/apps/x/apps/main/src/oauth-handler.ts @@ -84,7 +84,7 @@ async function getProviderConfiguration(provider: string, clientIdOverride?: str return clientIdOverride; } const oauthRepo = getOAuthRepo(); - const clientId = await oauthRepo.getClientId(provider); + const { clientId } = await oauthRepo.read(provider); if (clientId) { return clientId; } @@ -179,9 +179,9 @@ export async function connectProvider(provider: string, clientId?: string): Prom // Build authorization URL const authUrl = oauthClient.buildAuthorizationUrl(config, { - redirectUri: REDIRECT_URI, + redirect_uri: REDIRECT_URI, scope: scopes.join(' '), - codeChallenge, + code_challenge: codeChallenge, state, }); @@ -212,11 +212,11 @@ export async function connectProvider(provider: string, clientId?: string): Prom // Save tokens console.log(`[OAuth] Token exchange successful for ${provider}`); - await oauthRepo.saveTokens(provider, tokens); + await oauthRepo.upsert(provider, { tokens }); if (provider === 'google' && clientId) { - await oauthRepo.setClientId(provider, clientId); + await oauthRepo.upsert(provider, { clientId }); } - await oauthRepo.clearError(provider); + await oauthRepo.upsert(provider, { error: null }); // Trigger immediate sync for relevant providers if (provider === 'google') { @@ -281,7 +281,7 @@ export async function connectProvider(provider: string, clientId?: string): Prom export async function disconnectProvider(provider: string): Promise<{ success: boolean }> { try { const oauthRepo = getOAuthRepo(); - await oauthRepo.clearTokens(provider); + await oauthRepo.delete(provider); return { success: true }; } catch (error) { console.error('OAuth disconnect failed:', error); @@ -297,7 +297,7 @@ export async function getAccessToken(provider: string): Promise { try { const oauthRepo = getOAuthRepo(); - let tokens = await oauthRepo.getTokens(provider); + const { tokens } = await oauthRepo.read(provider); if (!tokens) { return null; } @@ -306,7 +306,7 @@ export async function getAccessToken(provider: string): Promise { if (oauthClient.isTokenExpired(tokens)) { if (!tokens.refresh_token) { // No refresh token, need to reconnect - await oauthRepo.setError(provider, 'Missing refresh token. Please reconnect.'); + await oauthRepo.upsert(provider, { error: 'Missing refresh token. Please reconnect.' }); return null; } @@ -316,11 +316,11 @@ export async function getAccessToken(provider: string): Promise { // Refresh token, preserving existing scopes const existingScopes = tokens.scopes; - tokens = await oauthClient.refreshTokens(config, tokens.refresh_token, existingScopes); - await oauthRepo.saveTokens(provider, tokens); + const refreshedTokens = await oauthClient.refreshTokens(config, tokens.refresh_token, existingScopes); + await oauthRepo.upsert(provider, { tokens }); } catch (error) { const message = error instanceof Error ? error.message : 'Token refresh failed'; - await oauthRepo.setError(provider, message); + await oauthRepo.upsert(provider, { error: message }); console.error('Token refresh failed:', error); return null; } diff --git a/apps/x/apps/renderer/src/App.tsx b/apps/x/apps/renderer/src/App.tsx index 7658c4c8..af6a4740 100644 --- a/apps/x/apps/renderer/src/App.tsx +++ b/apps/x/apps/renderer/src/App.tsx @@ -5,16 +5,16 @@ import { RunEvent, ListRunsResponse } from '@x/shared/src/runs.js'; import type { LanguageModelUsage, ToolUIPart } from 'ai'; import './App.css' import z from 'zod'; -import { Button } from './components/ui/button'; -import { CheckIcon, LoaderIcon, ArrowUp, PanelLeftIcon, PanelRightIcon, Square, X, ChevronLeftIcon, ChevronRightIcon, SquarePen } from 'lucide-react'; +import { CheckIcon, LoaderIcon, PanelLeftIcon, Maximize2, Minimize2, ChevronLeftIcon, ChevronRightIcon, SquarePen, SearchIcon, HistoryIcon } from 'lucide-react'; import { cn } from '@/lib/utils'; import { MarkdownEditor } from './components/markdown-editor'; -import { ChatInputBar } from './components/chat-button'; import { ChatSidebar } from './components/chat-sidebar'; +import { ChatInputWithMentions, type StagedAttachment } from './components/chat-input-with-mentions'; +import { ChatMessageAttachments } from '@/components/chat-message-attachments' import { GraphView, type GraphEdge, type GraphNode } from '@/components/graph-view'; import { useDebounce } from './hooks/use-debounce'; import { SidebarContentPanel } from '@/components/sidebar-content'; -import { SidebarSectionProvider, type ActiveSection } from '@/contexts/sidebar-context'; +import { SidebarSectionProvider } from '@/contexts/sidebar-context'; import { Conversation, ConversationContent, @@ -28,9 +28,6 @@ import { } from '@/components/ai-elements/message'; import { type PromptInputMessage, - PromptInputProvider, - PromptInputTextarea, - usePromptInputController, type FileMention, } from '@/components/ai-elements/prompt-input'; @@ -46,13 +43,32 @@ import { SidebarProvider, useSidebar, } from "@/components/ui/sidebar" -import { TooltipProvider } from "@/components/ui/tooltip" +import { Tooltip, TooltipContent, TooltipProvider, TooltipTrigger } from "@/components/ui/tooltip" import { Toaster } from "@/components/ui/sonner" import { stripKnowledgePrefix, toKnowledgePath, wikiLabel } from '@/lib/wiki-links' import { OnboardingModal } from '@/components/onboarding-modal' +import { SearchDialog } from '@/components/search-dialog' import { BackgroundTaskDetail } from '@/components/background-task-detail' +import { VersionHistoryPanel } from '@/components/version-history-panel' import { FileCardProvider } from '@/contexts/file-card-context' import { MarkdownPreOverride } from '@/components/ai-elements/markdown-code-override' +import { TabBar, type ChatTab, type FileTab } from '@/components/tab-bar' +import { + type ChatMessage, + type ChatTabViewState, + type ConversationItem, + type ToolCall, + createEmptyChatTabViewState, + getWebSearchCardData, + inferRunTitleFromMessage, + isChatMessage, + isErrorMessage, + isToolCall, + normalizeToolInput, + normalizeToolOutput, + parseAttachedFiles, + toToolState, +} from '@/lib/chat-conversation' import { AgentScheduleConfig } from '@x/shared/dist/agent-schedule.js' import { AgentScheduleState } from '@x/shared/dist/agent-schedule-state.js' import { toast } from "sonner" @@ -66,52 +82,6 @@ interface TreeNode extends DirEntry { loaded?: boolean } -interface ChatMessage { - id: string; - role: 'user' | 'assistant'; - content: string; - timestamp: number; -} - -interface ToolCall { - id: string; - name: string; - input: ToolUIPart['input']; - result?: ToolUIPart['output']; - status: 'pending' | 'running' | 'completed' | 'error'; - timestamp: number; -} - -interface ErrorMessage { - id: string; - kind: 'error'; - message: string; - timestamp: number; -} - -type ConversationItem = ChatMessage | ToolCall | ErrorMessage; - -type ToolState = 'input-streaming' | 'input-available' | 'output-available' | 'output-error'; - -const isChatMessage = (item: ConversationItem): item is ChatMessage => 'role' in item -const isToolCall = (item: ConversationItem): item is ToolCall => 'name' in item -const isErrorMessage = (item: ConversationItem): item is ErrorMessage => 'kind' in item && item.kind === 'error' - -const toToolState = (status: ToolCall['status']): ToolState => { - switch (status) { - case 'pending': - return 'input-streaming' - case 'running': - return 'input-available' - case 'completed': - return 'output-available' - case 'error': - return 'output-error' - default: - return 'input-available' - } -} - const streamdownComponents = { pre: MarkdownPreOverride } const DEFAULT_SIDEBAR_WIDTH = 256 @@ -132,48 +102,18 @@ const TITLEBAR_BUTTON_PX = 32 const TITLEBAR_BUTTON_GAP_PX = 4 const TITLEBAR_HEADER_GAP_PX = 8 const TITLEBAR_TOGGLE_MARGIN_LEFT_PX = 12 -const TITLEBAR_BUTTONS_COLLAPSED = 4 -const TITLEBAR_BUTTON_GAPS_COLLAPSED = 3 +const TITLEBAR_BUTTONS_COLLAPSED = 5 +const TITLEBAR_BUTTON_GAPS_COLLAPSED = 4 +const GRAPH_TAB_PATH = '__rowboat_graph_view__' const clampNumber = (value: number, min: number, max: number) => Math.min(max, Math.max(min, value)) -// Parse attached files from message content and return clean message + file paths -const parseAttachedFiles = (content: string): { message: string; files: string[] } => { - const attachedFilesRegex = /\s*([\s\S]*?)\s*<\/attached-files>/ - const match = content.match(attachedFilesRegex) - - if (!match) { - return { message: content, files: [] } - } - - // Extract file paths from the XML - const filesXml = match[1] - const filePathRegex = //g - const files: string[] = [] - let fileMatch - while ((fileMatch = filePathRegex.exec(filesXml)) !== null) { - files.push(fileMatch[1]) - } - - // Remove the attached-files block - let cleanMessage = content.replace(attachedFilesRegex, '').trim() - - // Also remove @mentions for the attached files (they're shown as pills) - for (const filePath of files) { - // Get the display name (last part of path without extension) - const fileName = filePath.split('/').pop()?.replace(/\.md$/i, '') || '' - if (fileName) { - // Remove @filename pattern (with optional trailing space) - const mentionRegex = new RegExp(`@${fileName.replace(/[.*+?^${}()|[\]\\]/g, '\\$&')}\\s*`, 'gi') - cleanMessage = cleanMessage.replace(mentionRegex, '') - } - } - - return { message: cleanMessage.trim(), files } -} - const untitledBaseName = 'untitled' +const untitledIndexedNamePattern = /^untitled-\d+$/ + +const isUntitledPlaceholderName = (name: string) => + name === untitledBaseName || untitledIndexedNamePattern.test(name) const getHeadingTitle = (markdown: string) => { const lines = markdown.split('\n') @@ -201,6 +141,98 @@ const getBaseName = (path: string) => { return file.replace(/\.md$/i, '') } +const WIKI_LINK_TOKEN_REGEX = /\[\[([^[\]]+)\]\]/g +const KNOWLEDGE_PREFIX = 'knowledge/' + +const normalizeRelPathForWiki = (relPath: string) => + relPath.replace(/\\/g, '/').replace(/^\/+/, '') + +const stripKnowledgePrefixForWiki = (relPath: string) => { + const normalized = normalizeRelPathForWiki(relPath) + return normalized.toLowerCase().startsWith(KNOWLEDGE_PREFIX) + ? normalized.slice(KNOWLEDGE_PREFIX.length) + : normalized +} + +const stripMarkdownExtensionForWiki = (wikiPath: string) => + wikiPath.toLowerCase().endsWith('.md') ? wikiPath.slice(0, -3) : wikiPath + +const wikiPathCompareKey = (wikiPath: string) => + stripMarkdownExtensionForWiki(wikiPath).toLowerCase() + +const splitWikiPathPrefix = (rawPath: string) => { + let normalized = rawPath.trim().replace(/^\/+/, '').replace(/^\.\//, '') + const hadKnowledgePrefix = /^knowledge\//i.test(normalized) + if (hadKnowledgePrefix) { + normalized = normalized.slice(KNOWLEDGE_PREFIX.length) + } + return { pathWithoutPrefix: normalized, hadKnowledgePrefix } +} + +const rewriteWikiLinksForRenamedFileInMarkdown = ( + markdown: string, + fromRelPath: string, + toRelPath: string +) => { + const normalizedFrom = normalizeRelPathForWiki(fromRelPath) + const normalizedTo = normalizeRelPathForWiki(toRelPath) + const lowerFrom = normalizedFrom.toLowerCase() + const lowerTo = normalizedTo.toLowerCase() + if (!lowerFrom.startsWith(KNOWLEDGE_PREFIX) || !lowerFrom.endsWith('.md')) return markdown + if (!lowerTo.startsWith(KNOWLEDGE_PREFIX) || !lowerTo.endsWith('.md')) return markdown + + const fromWikiPath = stripKnowledgePrefixForWiki(normalizedFrom) + const toWikiPath = stripKnowledgePrefixForWiki(normalizedTo) + const fromCompareKey = wikiPathCompareKey(fromWikiPath) + const fromBaseName = stripMarkdownExtensionForWiki(fromWikiPath).split('/').pop()?.toLowerCase() ?? null + const toWikiPathWithoutExtension = stripMarkdownExtensionForWiki(toWikiPath) + const toBaseName = toWikiPathWithoutExtension.split('/').pop() ?? toWikiPathWithoutExtension + + return markdown.replace(WIKI_LINK_TOKEN_REGEX, (fullMatch, innerRaw: string) => { + const pipeIndex = innerRaw.indexOf('|') + const pathAndAnchor = pipeIndex >= 0 ? innerRaw.slice(0, pipeIndex) : innerRaw + const aliasSuffix = pipeIndex >= 0 ? innerRaw.slice(pipeIndex) : '' + + const hashIndex = pathAndAnchor.indexOf('#') + const pathPart = hashIndex >= 0 ? pathAndAnchor.slice(0, hashIndex) : pathAndAnchor + const anchorSuffix = hashIndex >= 0 ? pathAndAnchor.slice(hashIndex) : '' + + const leadingWhitespace = pathPart.match(/^\s*/)?.[0] ?? '' + const trailingWhitespace = pathPart.match(/\s*$/)?.[0] ?? '' + const rawPath = pathPart.trim() + if (!rawPath) return fullMatch + + const { pathWithoutPrefix, hadKnowledgePrefix } = splitWikiPathPrefix(rawPath) + if (!pathWithoutPrefix) return fullMatch + + const matchesFullPath = wikiPathCompareKey(pathWithoutPrefix) === fromCompareKey + const isBareTarget = !pathWithoutPrefix.includes('/') + const targetBaseName = stripMarkdownExtensionForWiki(pathWithoutPrefix).toLowerCase() + const matchesBareSelfName = Boolean(fromBaseName && isBareTarget && targetBaseName === fromBaseName) + if (!matchesFullPath && !matchesBareSelfName) return fullMatch + + const preserveMarkdownExtension = rawPath.toLowerCase().endsWith('.md') + const rewrittenTarget = matchesBareSelfName + ? (preserveMarkdownExtension ? `${toBaseName}.md` : toBaseName) + : (preserveMarkdownExtension ? toWikiPath : toWikiPathWithoutExtension) + const finalPath = hadKnowledgePrefix ? `${KNOWLEDGE_PREFIX}${rewrittenTarget}` : rewrittenTarget + + return `[[${leadingWhitespace}${finalPath}${trailingWhitespace}${anchorSuffix}${aliasSuffix}]]` + }) +} + +const getAncestorDirectoryPaths = (path: string): string[] => { + const parts = path.split('/').filter(Boolean) + if (parts.length <= 2) return [] + const ancestors: string[] = [] + for (let i = 1; i < parts.length - 1; i++) { + ancestors.push(parts.slice(0, i + 1).join('/')) + } + return ancestors +} + +const isGraphTabPath = (path: string) => path === GRAPH_TAB_PATH + const normalizeUsage = (usage?: Partial | null): LanguageModelUsage | null => { if (!usage) return null const hasNumbers = Object.values(usage).some((value) => typeof value === 'number') @@ -218,29 +250,6 @@ const normalizeUsage = (usage?: Partial | null): LanguageMod } } -const normalizeToolInput = (input: ToolCall['input'] | string | undefined): ToolCall['input'] => { - if (input === undefined || input === null) return {} - if (typeof input === 'string') { - const trimmed = input.trim() - if (!trimmed) return {} - try { - return JSON.parse(trimmed) - } catch { - return input - } - } - return input -} - -const normalizeToolOutput = (output: ToolCall['result'] | undefined, status: ToolCall['status']) => { - if (output === undefined || output === null) { - return status === 'completed' ? 'No output returned.' : null - } - if (output === '') return '(empty output)' - if (typeof output === 'boolean' || typeof output === 'number') return String(output) - return output -} - // Sort nodes (dirs first, then alphabetically) function sortNodes(nodes: TreeNode[]): TreeNode[] { return nodes.sort((a, b) => { @@ -292,170 +301,6 @@ const collectDirPaths = (nodes: TreeNode[]): string[] => const collectFilePaths = (nodes: TreeNode[]): string[] => nodes.flatMap(n => n.kind === 'file' ? [n.path] : (n.children ? collectFilePaths(n.children) : [])) -// Inner component that uses the controller to access mentions -interface ChatInputInnerProps { - onSubmit: (message: PromptInputMessage, mentions?: FileMention[]) => void - onStop?: () => void - isProcessing: boolean - isStopping?: boolean - presetMessage?: string - onPresetMessageConsumed?: () => void - runId?: string | null -} - -function ChatInputInner({ - onSubmit, - onStop, - isProcessing, - isStopping, - presetMessage, - onPresetMessageConsumed, - runId, -}: ChatInputInnerProps) { - const controller = usePromptInputController() - const message = controller.textInput.value - const canSubmit = Boolean(message.trim()) && !isProcessing - - // Handle preset message from suggestions - useEffect(() => { - if (presetMessage) { - controller.textInput.setInput(presetMessage) - onPresetMessageConsumed?.() - } - }, [presetMessage, controller.textInput, onPresetMessageConsumed]) - - const handleSubmit = useCallback(() => { - if (!canSubmit) return - onSubmit({ text: message.trim(), files: [] }, controller.mentions.mentions) - controller.textInput.clear() - controller.mentions.clearMentions() - }, [canSubmit, message, onSubmit, controller]) - - const handleKeyDown = useCallback((e: React.KeyboardEvent) => { - if (e.key === 'Enter' && !e.shiftKey) { - e.preventDefault() - handleSubmit() - } - }, [handleSubmit]) - - useEffect(() => { - const onDragOver = (e: DragEvent) => { - if (e.dataTransfer?.types?.includes("Files")) { - e.preventDefault() - } - } - const onDrop = (e: DragEvent) => { - if (e.dataTransfer?.types?.includes("Files")) { - e.preventDefault() - } - if (e.dataTransfer?.files && e.dataTransfer.files.length > 0) { - const paths = Array.from(e.dataTransfer.files) - .map((f) => window.electronUtils?.getPathForFile(f)) - .filter(Boolean) - if (paths.length > 0) { - const currentText = controller.textInput.value - const pathText = paths.join(' ') - controller.textInput.setInput( - currentText ? `${currentText} ${pathText}` : pathText - ) - } - } - } - document.addEventListener("dragover", onDragOver) - document.addEventListener("drop", onDrop) - return () => { - document.removeEventListener("dragover", onDragOver) - document.removeEventListener("drop", onDrop) - } - }, [controller]) - - return ( -
- - {isProcessing ? ( - - ) : ( - - )} -
- ) -} - -// Wrapper component with PromptInputProvider -interface ChatInputWithMentionsProps { - knowledgeFiles: string[] - recentFiles: string[] - visibleFiles: string[] - onSubmit: (message: PromptInputMessage, mentions?: FileMention[]) => void - onStop?: () => void - isProcessing: boolean - isStopping?: boolean - presetMessage?: string - onPresetMessageConsumed?: () => void - runId?: string | null -} - -function ChatInputWithMentions({ - knowledgeFiles, - recentFiles, - visibleFiles, - onSubmit, - onStop, - isProcessing, - isStopping, - presetMessage, - onPresetMessageConsumed, - runId, -}: ChatInputWithMentionsProps) { - return ( - - - - ) -} - /** A snapshot of which view the user is on */ type ViewState = | { type: 'chat'; runId: string | null } @@ -478,6 +323,7 @@ function FixedSidebarToggle({ canNavigateBack, canNavigateForward, onNewChat, + onOpenSearch, leftInsetPx, }: { onNavigateBack: () => void @@ -485,6 +331,7 @@ function FixedSidebarToggle({ canNavigateBack: boolean canNavigateForward: boolean onNewChat: () => void + onOpenSearch: () => void leftInsetPx: number }) { const { toggleSidebar, state } = useSidebar() @@ -511,6 +358,15 @@ function FixedSidebarToggle({ > + {/* Back / Forward navigation */} {isCollapsed && ( <> @@ -560,15 +416,15 @@ function ContentHeader({ return (
{!isCollapsed && onNavigateBack && onNavigateForward ? ( -
+
+ {selectedPath && selectedPath.startsWith('knowledge/') && selectedPath.endsWith('.md') && ( + + + + + Version history + + )} + {!selectedPath && !isGraphOpen && !selectedTask && ( + + + + + New chat tab + )} {!selectedPath && !isGraphOpen && expandedFrom && ( - + + + + + Restore two-pane view + )} {(selectedPath || isGraphOpen) && ( - + + + + + + {isChatSidebarOpen ? "Maximize knowledge view" : "Restore two-pane view"} + + )} @@ -2397,14 +3317,80 @@ function App() {
) : selectedPath ? ( selectedPath.endsWith('.md') ? ( -
- +
+
+ {openMarkdownTabs.map((tab) => { + const isActive = activeFileTabId + ? tab.id === activeFileTabId || tab.path === selectedPath + : tab.path === selectedPath + const isViewingHistory = viewingHistoricalVersion && isActive && versionHistoryPath === tab.path + const tabContent = isViewingHistory + ? viewingHistoricalVersion.content + : editorContentByPath[tab.path] + ?? (isActive && editorPathRef.current === tab.path ? editorContent : '') + return ( +
+ { if (!isViewingHistory) handleEditorChange(tab.path, markdown) }} + placeholder="Start writing..." + wikiLinks={wikiLinkConfig} + onImageUpload={handleImageUpload} + editorSessionKey={editorSessionByTabId[tab.id] ?? 0} + onHistoryHandlersChange={(handlers) => { + if (handlers) { + fileHistoryHandlersRef.current.set(tab.id, handlers) + } else { + fileHistoryHandlersRef.current.delete(tab.id) + } + }} + editable={!isViewingHistory} + /> +
+ ) + })} +
+ {versionHistoryPath && ( + { + setVersionHistoryPath(null) + setViewingHistoricalVersion(null) + }} + onSelectVersion={(oid, content) => { + if (oid === null) { + setViewingHistoricalVersion(null) + } else { + setViewingHistoricalVersion({ oid, content }) + } + }} + onRestore={async (oid) => { + try { + await window.ipc.invoke('knowledge:restore', { + path: versionHistoryPath.startsWith('knowledge/') + ? versionHistoryPath.slice('knowledge/'.length) + : versionHistoryPath, + oid, + }) + // Reload file content + const result = await window.ipc.invoke('workspace:readFile', { path: versionHistoryPath }) + handleEditorChange(versionHistoryPath, result.data) + setViewingHistoricalVersion(null) + setVersionHistoryPath(null) + } catch (err) { + console.error('Failed to restore version:', err) + } + }} + /> + )}
) : (
@@ -2431,70 +3417,94 @@ function App() { ) : ( { navigateToFile(path) }}>
- - - - {!hasConversation ? ( - -
- What are we working on? -
- - ) : ( - <> - {conversation.map(item => { - const rendered = renderConversationItem(item) - // If this is a tool call, check for permission request (pending or responded) - if (isToolCall(item)) { - const permRequest = allPermissionRequests.get(item.id) - if (permRequest) { - const response = permissionResponses.get(item.id) || null - return ( - - {rendered} - handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve')} - onDeny={() => handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'deny')} - isProcessing={isProcessing} - response={response} +
+ {chatTabs.map((tab) => { + const isActive = tab.id === activeChatTabId + const tabState = getChatTabStateForRender(tab.id) + const tabHasConversation = tabState.conversation.length > 0 || tabState.currentAssistantMessage + const tabConversationContentClassName = tabHasConversation + ? "mx-auto w-full max-w-4xl pb-28" + : "mx-auto w-full max-w-4xl min-h-full items-center justify-center pb-0" + return ( +
+ + + + {!tabHasConversation ? ( + +
+ What are we working on? +
+ + ) : ( + <> + {tabState.conversation.map(item => { + const rendered = renderConversationItem(item, tab.id) + if (isToolCall(item)) { + const permRequest = tabState.allPermissionRequests.get(item.id) + if (permRequest) { + const response = tabState.permissionResponses.get(item.id) || null + return ( + + {rendered} + handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve')} + onApproveSession={() => handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve', 'session')} + onApproveAlways={() => handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve', 'always')} + onDeny={() => handlePermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'deny')} + isProcessing={isActive && isProcessing} + response={response} + /> + + ) + } + } + return rendered + })} + + {Array.from(tabState.pendingAskHumanRequests.values()).map((request) => ( + handleAskHumanResponse(request.toolCallId, request.subflow, response)} + isProcessing={isActive && isProcessing} /> - - ) - } - } - return rendered - })} + ))} - {/* Render pending ask-human requests */} - {Array.from(pendingAskHumanRequests.values()).map((request) => ( - handleAskHumanResponse(request.toolCallId, request.subflow, response)} - isProcessing={isProcessing} - /> - ))} + {tabState.currentAssistantMessage && ( + + + {tabState.currentAssistantMessage} + + + )} - {currentAssistantMessage && ( - - - {currentAssistantMessage} - - - )} - - {isProcessing && !currentAssistantMessage && ( - - - Thinking... - - - )} - - )} - - + {isActive && isProcessing && !tabState.currentAssistantMessage && ( + + + Thinking... + + + )} + + )} + + +
+ ) + })} +
@@ -2502,18 +3512,34 @@ function App() { {!hasConversation && ( )} - setPresetMessage(undefined)} - runId={runId} - /> + {chatTabs.map((tab) => { + const isActive = tab.id === activeChatTabId + const tabState = getChatTabStateForRender(tab.id) + return ( +
+ setPresetMessage(undefined) : undefined} + runId={tabState.runId} + initialDraft={chatDraftsRef.current.get(tab.id)} + onDraftChange={(text) => setChatDraftForTab(tab.id, text)} + /> +
+ ) + })}
@@ -2522,31 +3548,43 @@ function App() { {/* Chat sidebar - shown when viewing files/graph */} - {(selectedPath || isGraphOpen) && ( + {isRightPaneContext && ( setPresetMessage(undefined)} + getInitialDraft={(tabId) => chatDraftsRef.current.get(tabId)} + onDraftChangeForTab={setChatDraftForTab} pendingAskHumanRequests={pendingAskHumanRequests} allPermissionRequests={allPermissionRequests} permissionResponses={permissionResponses} onPermissionResponse={handlePermissionResponse} onAskHumanResponse={handleAskHumanResponse} + isToolOpenForTab={isToolOpenForTab} + onToolOpenChangeForTab={setToolOpenForTab} onOpenKnowledgeFile={(path) => { navigateToFile(path) }} + onActivate={() => setActiveShortcutPane('right')} /> )} {/* Rendered last so its no-drag region paints over the sidebar drag region */} @@ -2555,19 +3593,18 @@ function App() { onNavigateForward={() => { void navigateForward() }} canNavigateBack={canNavigateBack} canNavigateForward={canNavigateForward} - onNewChat={handleNewChat} + onNewChat={handleNewChatTab} + onOpenSearch={() => setIsSearchOpen(true)} leftInsetPx={isMac ? MACOS_TRAFFIC_LIGHTS_RESERVED_PX : 0} /> - - {/* Floating chat input - shown when viewing files/graph and chat sidebar is closed */} - {(selectedPath || isGraphOpen) && !isChatSidebarOpen && ( - setIsChatSidebarOpen(true)} - /> - )}
+ { void navigateToView({ type: 'chat', runId: id }) }} + /> { - const { isAtBottom } = useStickToBottomContext(); + const { isAtBottom, scrollRef } = useStickToBottomContext(); const preservationContext = useContext(ScrollPreservationContext); const containerFoundRef = useRef(false); @@ -110,29 +110,13 @@ export const ScrollPositionPreserver = () => { useLayoutEffect(() => { if (containerFoundRef.current || !preservationContext) return; - // Find the scroll container (StickToBottom creates one) - // It's the first parent with overflow-y scroll/auto - const findScrollContainer = (): HTMLElement | null => { - const candidates = document.querySelectorAll('[role="log"]'); - for (const candidate of candidates) { - // The scroll container is a direct child of the role="log" element - const children = candidate.children; - for (const child of children) { - const style = window.getComputedStyle(child); - if (style.overflowY === 'auto' || style.overflowY === 'scroll') { - return child as HTMLElement; - } - } - } - return null; - }; - - const container = findScrollContainer(); + // Use the local StickToBottom scroll container for this conversation instance. + const container = scrollRef.current; if (container) { preservationContext.registerScrollContainer(container); containerFoundRef.current = true; } - }, [preservationContext]); + }, [preservationContext, scrollRef]); // Track engagement based on scroll position useEffect(() => { diff --git a/apps/x/apps/renderer/src/components/ai-elements/permission-request.tsx b/apps/x/apps/renderer/src/components/ai-elements/permission-request.tsx index 91b16287..e9cef6dc 100644 --- a/apps/x/apps/renderer/src/components/ai-elements/permission-request.tsx +++ b/apps/x/apps/renderer/src/components/ai-elements/permission-request.tsx @@ -2,8 +2,14 @@ import { Badge } from "@/components/ui/badge"; import { Button } from "@/components/ui/button"; +import { + DropdownMenu, + DropdownMenuTrigger, + DropdownMenuContent, + DropdownMenuItem, +} from "@/components/ui/dropdown-menu"; import { cn } from "@/lib/utils"; -import { AlertTriangleIcon, CheckCircleIcon, CheckIcon, XCircleIcon, XIcon } from "lucide-react"; +import { AlertTriangleIcon, CheckCircleIcon, CheckIcon, ChevronDownIcon, XCircleIcon, XIcon } from "lucide-react"; import type { ComponentProps } from "react"; import { ToolCallPart } from "@x/shared/dist/message.js"; import z from "zod"; @@ -11,6 +17,8 @@ import z from "zod"; export type PermissionRequestProps = ComponentProps<"div"> & { toolCall: z.infer; onApprove?: () => void; + onApproveSession?: () => void; + onApproveAlways?: () => void; onDeny?: () => void; isProcessing?: boolean; response?: 'approve' | 'deny' | null; @@ -20,6 +28,8 @@ export const PermissionRequest = ({ className, toolCall, onApprove, + onApproveSession, + onApproveAlways, onDeny, isProcessing = false, response = null, @@ -117,16 +127,40 @@ export const PermissionRequest = ({
{!isResponded && (
- +
+ + {command && ( + + + + + + + Allow for Session + + + Always Allow + + + + )} +
+ + ) + })} +
+ )} +
+ { + const files = e.target.files + if (!files || files.length === 0) return + const paths = Array.from(files) + .map((file) => window.electronUtils?.getPathForFile(file)) + .filter(Boolean) as string[] + if (paths.length > 0) { + void addFiles(paths) + } + e.target.value = '' + }} + /> + + + {isProcessing ? ( + + ) : ( + + )} +
+
+ ) +} + +export interface ChatInputWithMentionsProps { + knowledgeFiles: string[] + recentFiles: string[] + visibleFiles: string[] + onSubmit: (message: PromptInputMessage, mentions?: FileMention[], attachments?: StagedAttachment[]) => void + onStop?: () => void + isProcessing: boolean + isStopping?: boolean + isActive?: boolean + presetMessage?: string + onPresetMessageConsumed?: () => void + runId?: string | null + initialDraft?: string + onDraftChange?: (text: string) => void +} + +export function ChatInputWithMentions({ + knowledgeFiles, + recentFiles, + visibleFiles, + onSubmit, + onStop, + isProcessing, + isStopping, + isActive = true, + presetMessage, + onPresetMessageConsumed, + runId, + initialDraft, + onDraftChange, +}: ChatInputWithMentionsProps) { + return ( + + + + ) +} diff --git a/apps/x/apps/renderer/src/components/chat-message-attachments.tsx b/apps/x/apps/renderer/src/components/chat-message-attachments.tsx new file mode 100644 index 00000000..298e5f03 --- /dev/null +++ b/apps/x/apps/renderer/src/components/chat-message-attachments.tsx @@ -0,0 +1,137 @@ +import { + AudioLines, + FileArchive, + FileCode2, + FileIcon, + FileSpreadsheet, + FileText, + FileVideo, +} from 'lucide-react' +import { useEffect, useMemo, useState } from 'react' + +import type { MessageAttachment } from '@/lib/chat-conversation' +import { + type AttachmentIconKind, + getAttachmentDisplayName, + getAttachmentIconKind, + getAttachmentToneClass, + getAttachmentTypeLabel, +} from '@/lib/attachment-presentation' +import { isImageMime, toFileUrl } from '@/lib/file-utils' +import { cn } from '@/lib/utils' + +function getAttachmentIcon(kind: AttachmentIconKind) { + switch (kind) { + case 'audio': + return AudioLines + case 'video': + return FileVideo + case 'spreadsheet': + return FileSpreadsheet + case 'archive': + return FileArchive + case 'code': + return FileCode2 + case 'text': + return FileText + default: + return FileIcon + } +} + +function ImageAttachmentPreview({ attachment }: { attachment: MessageAttachment }) { + const fallbackFileUrl = useMemo(() => toFileUrl(attachment.path), [attachment.path]) + const [src, setSrc] = useState(attachment.thumbnailUrl || fallbackFileUrl) + const [triedBase64, setTriedBase64] = useState(Boolean(attachment.thumbnailUrl)) + + useEffect(() => { + const nextSrc = attachment.thumbnailUrl || fallbackFileUrl + setSrc(nextSrc) + setTriedBase64(Boolean(attachment.thumbnailUrl)) + }, [attachment.thumbnailUrl, fallbackFileUrl]) + + const loadBase64 = useMemo( + () => async () => { + try { + const result = await window.ipc.invoke('shell:readFileBase64', { path: attachment.path }) + const mimeType = result.mimeType || attachment.mimeType || 'image/*' + setSrc(`data:${mimeType};base64,${result.data}`) + } catch { + // Keep current src; fallback rendering (broken image icon) is better than crashing. + } + }, + [attachment.mimeType, attachment.path] + ) + + useEffect(() => { + if (attachment.thumbnailUrl || triedBase64) return + setTriedBase64(true) + void loadBase64() + }, [attachment.thumbnailUrl, loadBase64, triedBase64]) + + return ( + Image attachment { + if (triedBase64) return + setTriedBase64(true) + void loadBase64() + }} + /> + ) +} + +interface ChatMessageAttachmentsProps { + attachments: MessageAttachment[] + className?: string +} + +export function ChatMessageAttachments({ attachments, className }: ChatMessageAttachmentsProps) { + if (attachments.length === 0) return null + + const imageAttachments = attachments.filter((attachment) => isImageMime(attachment.mimeType)) + const fileAttachments = attachments.filter((attachment) => !isImageMime(attachment.mimeType)) + + return ( +
+ {imageAttachments.length > 0 && ( +
+ {imageAttachments.map((attachment, index) => ( + + ))} +
+ )} + {fileAttachments.length > 0 && ( +
+ {fileAttachments.map((attachment, index) => { + const Icon = getAttachmentIcon(getAttachmentIconKind(attachment)) + const attachmentName = getAttachmentDisplayName(attachment) + const attachmentType = getAttachmentTypeLabel(attachment) + return ( + + + + + + {attachmentName} + {attachmentType} + + + ) + })} +
+ )} +
+ ) +} diff --git a/apps/x/apps/renderer/src/components/chat-sidebar.tsx b/apps/x/apps/renderer/src/components/chat-sidebar.tsx index 8d2a005f..f020cdae 100644 --- a/apps/x/apps/renderer/src/components/chat-sidebar.tsx +++ b/apps/x/apps/renderer/src/components/chat-sidebar.tsx @@ -1,13 +1,9 @@ -import { useCallback, useEffect, useMemo, useRef, useState } from 'react' -import { ArrowUp, Expand, LoaderIcon, SquarePen, Square } from 'lucide-react' -import type { ToolUIPart } from 'ai' +import React, { useCallback, useEffect, useMemo, useRef, useState } from 'react' +import { Maximize2, Minimize2, SquarePen } from 'lucide-react' + import { Button } from '@/components/ui/button' import { cn } from '@/lib/utils' -import { - Tooltip, - TooltipContent, - TooltipTrigger, -} from '@/components/ui/tooltip' +import { Tooltip, TooltipContent, TooltipTrigger } from '@/components/ui/tooltip' import { Conversation, ConversationContent, @@ -19,233 +15,200 @@ import { MessageContent, MessageResponse, } from '@/components/ai-elements/message' - import { Shimmer } from '@/components/ai-elements/shimmer' import { Tool, ToolContent, ToolHeader, ToolInput, ToolOutput } from '@/components/ai-elements/tool' +import { WebSearchResult } from '@/components/ai-elements/web-search-result' import { PermissionRequest } from '@/components/ai-elements/permission-request' import { AskHumanRequest } from '@/components/ai-elements/ask-human-request' import { Suggestions } from '@/components/ai-elements/suggestions' import { type PromptInputMessage, type FileMention } from '@/components/ai-elements/prompt-input' -import { useMentionDetection } from '@/hooks/use-mention-detection' -import { MentionPopover } from '@/components/mention-popover' -import { toKnowledgePath, wikiLabel } from '@/lib/wiki-links' -import { getMentionHighlightSegments } from '@/lib/mention-highlights' -import { ToolPermissionRequestEvent, AskHumanRequestEvent } from '@x/shared/src/runs.js' -import z from 'zod' -import React from 'react' import { FileCardProvider } from '@/contexts/file-card-context' import { MarkdownPreOverride } from '@/components/ai-elements/markdown-code-override' - -interface ChatMessage { - id: string - role: 'user' | 'assistant' - content: string - timestamp: number -} - -interface ToolCall { - id: string - name: string - input: ToolUIPart['input'] - result?: ToolUIPart['output'] - status: 'pending' | 'running' | 'completed' | 'error' - timestamp: number -} - -interface ErrorMessage { - id: string - kind: 'error' - message: string - timestamp: number -} - -type ConversationItem = ChatMessage | ToolCall | ErrorMessage - -type ToolState = 'input-streaming' | 'input-available' | 'output-available' | 'output-error' - -const isChatMessage = (item: ConversationItem): item is ChatMessage => 'role' in item -const isToolCall = (item: ConversationItem): item is ToolCall => 'name' in item -const isErrorMessage = (item: ConversationItem): item is ErrorMessage => 'kind' in item && item.kind === 'error' - -const toToolState = (status: ToolCall['status']): ToolState => { - switch (status) { - case 'pending': - return 'input-streaming' - case 'running': - return 'input-available' - case 'completed': - return 'output-available' - case 'error': - return 'output-error' - default: - return 'input-available' - } -} - -const normalizeToolInput = (input: ToolCall['input'] | string | undefined): ToolCall['input'] => { - if (input === undefined || input === null) return {} - if (typeof input === 'string') { - const trimmed = input.trim() - if (!trimmed) return {} - try { - return JSON.parse(trimmed) - } catch { - return input - } - } - return input -} - -const normalizeToolOutput = (output: ToolCall['result'] | undefined, status: ToolCall['status']) => { - if (output === undefined || output === null) { - return status === 'completed' ? 'No output returned.' : null - } - if (output === '') return '(empty output)' - if (typeof output === 'boolean' || typeof output === 'number') return String(output) - return output -} +import { TabBar, type ChatTab } from '@/components/tab-bar' +import { ChatInputWithMentions, type StagedAttachment } from '@/components/chat-input-with-mentions' +import { ChatMessageAttachments } from '@/components/chat-message-attachments' +import { wikiLabel } from '@/lib/wiki-links' +import { + type ChatTabViewState, + type ConversationItem, + type PermissionResponse, + createEmptyChatTabViewState, + getWebSearchCardData, + isChatMessage, + isErrorMessage, + isToolCall, + normalizeToolInput, + normalizeToolOutput, + parseAttachedFiles, + toToolState, +} from '@/lib/chat-conversation' const streamdownComponents = { pre: MarkdownPreOverride } -const MIN_WIDTH = 300 -const MAX_WIDTH = 700 -const DEFAULT_WIDTH = 400 +const MIN_WIDTH = 360 +const MAX_WIDTH = 1600 +const MIN_MAIN_PANE_WIDTH = 420 +const MIN_MAIN_PANE_RATIO = 0.3 +const DEFAULT_WIDTH = 460 +const RIGHT_PANE_WIDTH_STORAGE_KEY = 'x:right-pane-width' + +function clampPaneWidth(width: number, maxWidth: number = MAX_WIDTH): number { + const boundedMax = Math.max(0, Math.min(MAX_WIDTH, maxWidth)) + const boundedMin = Math.min(MIN_WIDTH, boundedMax) + return Math.min(boundedMax, Math.max(boundedMin, width)) +} + +function getInitialPaneWidth(defaultWidth: number): number { + const fallback = clampPaneWidth(defaultWidth) + if (typeof window === 'undefined') return fallback + try { + const raw = window.localStorage.getItem(RIGHT_PANE_WIDTH_STORAGE_KEY) + if (!raw) return fallback + const parsed = Number(raw) + if (!Number.isFinite(parsed)) return fallback + return clampPaneWidth(parsed) + } catch { + return fallback + } +} interface ChatSidebarProps { defaultWidth?: number isOpen?: boolean - onNewChat: () => void + isMaximized?: boolean + chatTabs: ChatTab[] + activeChatTabId: string + getChatTabTitle: (tab: ChatTab) => string + isChatTabProcessing: (tab: ChatTab) => boolean + onSwitchChatTab: (tabId: string) => void + onCloseChatTab: (tabId: string) => void + onNewChatTab: () => void onOpenFullScreen?: () => void conversation: ConversationItem[] currentAssistantMessage: string + chatTabStates?: Record isProcessing: boolean isStopping?: boolean onStop?: () => void - message: string - onMessageChange: (message: string) => void - onSubmit: (message: PromptInputMessage, mentions?: FileMention[]) => void + onSubmit: (message: PromptInputMessage, mentions?: FileMention[], attachments?: StagedAttachment[]) => void knowledgeFiles?: string[] recentFiles?: string[] visibleFiles?: string[] - selectedPath?: string | null - pendingPermissionRequests?: Map> - pendingAskHumanRequests?: Map> - allPermissionRequests?: Map> - permissionResponses?: Map - onPermissionResponse?: (toolCallId: string, subflow: string[], response: 'approve' | 'deny') => void + runId?: string | null + presetMessage?: string + onPresetMessageConsumed?: () => void + getInitialDraft?: (tabId: string) => string | undefined + onDraftChangeForTab?: (tabId: string, text: string) => void + pendingAskHumanRequests?: ChatTabViewState['pendingAskHumanRequests'] + allPermissionRequests?: ChatTabViewState['allPermissionRequests'] + permissionResponses?: ChatTabViewState['permissionResponses'] + onPermissionResponse?: (toolCallId: string, subflow: string[], response: PermissionResponse, scope?: 'once' | 'session' | 'always') => void onAskHumanResponse?: (toolCallId: string, subflow: string[], response: string) => void + isToolOpenForTab?: (tabId: string, toolId: string) => boolean + onToolOpenChangeForTab?: (tabId: string, toolId: string, open: boolean) => void onOpenKnowledgeFile?: (path: string) => void + onActivate?: () => void } export function ChatSidebar({ defaultWidth = DEFAULT_WIDTH, isOpen = true, - onNewChat, + isMaximized = false, + chatTabs, + activeChatTabId, + getChatTabTitle, + isChatTabProcessing, + onSwitchChatTab, + onCloseChatTab, + onNewChatTab, onOpenFullScreen, conversation, currentAssistantMessage, + chatTabStates = {}, isProcessing, isStopping, onStop, - message, - onMessageChange, onSubmit, knowledgeFiles = [], recentFiles = [], visibleFiles = [], - selectedPath, + runId, + presetMessage, + onPresetMessageConsumed, + getInitialDraft, + onDraftChangeForTab, pendingAskHumanRequests = new Map(), allPermissionRequests = new Map(), permissionResponses = new Map(), onPermissionResponse, onAskHumanResponse, + isToolOpenForTab, + onToolOpenChangeForTab, onOpenKnowledgeFile, + onActivate, }: ChatSidebarProps) { - const [width, setWidth] = useState(defaultWidth) + const [width, setWidth] = useState(() => getInitialPaneWidth(defaultWidth)) const [isResizing, setIsResizing] = useState(false) const [showContent, setShowContent] = useState(isOpen) + const [localPresetMessage, setLocalPresetMessage] = useState(undefined) + + const paneRef = useRef(null) + const startXRef = useRef(0) + const startWidthRef = useRef(0) + const prevIsMaximizedRef = useRef(isMaximized) + const justToggledMaximize = prevIsMaximizedRef.current !== isMaximized + + const getMaxAllowedWidth = useCallback(() => { + if (typeof window === 'undefined') return MAX_WIDTH + const paneElement = paneRef.current + const splitContainer = paneElement?.parentElement + const mainPane = splitContainer?.querySelector('[data-slot="sidebar-inset"]') + const paneWidth = paneElement?.getBoundingClientRect().width ?? 0 + const mainPaneWidth = mainPane?.getBoundingClientRect().width ?? 0 + const splitWidth = paneWidth + mainPaneWidth + const fallbackWidth = splitContainer?.clientWidth ?? window.innerWidth + const availableSplitWidth = splitWidth > 0 ? splitWidth : fallbackWidth + const minMainPaneWidth = Math.min( + availableSplitWidth, + Math.max( + MIN_MAIN_PANE_WIDTH, + Math.floor(availableSplitWidth * MIN_MAIN_PANE_RATIO) + ) + ) + return Math.max(0, availableSplitWidth - minMainPaneWidth) + }, []) - // Delay showing content when opening, hide immediately when closing useEffect(() => { if (isOpen) { const timer = setTimeout(() => setShowContent(true), 150) return () => clearTimeout(timer) - } else { - setShowContent(false) } + setShowContent(false) }, [isOpen]) - const startXRef = useRef(0) - const startWidthRef = useRef(0) - const textareaRef = useRef(null) - const containerRef = useRef(null) - const highlightRef = useRef(null) - const [mentions, setMentions] = useState([]) - const autoMentionRef = useRef<{ path: string; displayName: string } | null>(null) - const lastSelectedPathRef = useRef(null) - - // Build mention labels for highlighting (handles multi-word names like "AI Agents") - const mentionLabels = useMemo(() => { - if (knowledgeFiles.length === 0) return [] - const labels = knowledgeFiles - .map((path) => wikiLabel(path)) - .map((label) => label.trim()) - .filter(Boolean) - return Array.from(new Set(labels)) - }, [knowledgeFiles]) - - const { activeMention, cursorCoords } = useMentionDetection( - textareaRef, - message, - knowledgeFiles.length > 0 - ) - - // Use proper regex-based highlight segmentation that handles multi-word names - const mentionHighlights = useMemo( - () => getMentionHighlightSegments(message, activeMention, mentionLabels), - [message, activeMention, mentionLabels] - ) - - // Sync highlight overlay scroll with textarea - const syncHighlightScroll = useCallback(() => { - const textarea = textareaRef.current - const highlight = highlightRef.current - if (!textarea || !highlight) return - highlight.scrollTop = textarea.scrollTop - highlight.scrollLeft = textarea.scrollLeft - }, []) useEffect(() => { - syncHighlightScroll() - }, [message, mentionHighlights.hasHighlights, syncHighlightScroll]) + prevIsMaximizedRef.current = isMaximized + }, [isMaximized]) - const handleMentionSelect = useCallback( - (path: string, displayName: string) => { - if (!activeMention) return + useEffect(() => { + if (typeof window === 'undefined') return + try { + window.localStorage.setItem(RIGHT_PANE_WIDTH_STORAGE_KEY, String(width)) + } catch { + // Ignore persistence failures and keep in-memory behavior. + } + }, [width]) - const beforeAt = message.substring(0, activeMention.triggerIndex) - const afterQuery = message.substring( - activeMention.triggerIndex + 1 + activeMention.query.length - ) + useEffect(() => { + const clampToAvailableWidth = () => { + const maxAllowedWidth = getMaxAllowedWidth() + setWidth((prev) => clampPaneWidth(prev, maxAllowedWidth)) + } - const newText = `${beforeAt}@${displayName} ${afterQuery}` - onMessageChange(newText) - - const fullPath = toKnowledgePath(path) - if (fullPath) { - setMentions(prev => { - if (prev.some(m => m.path === fullPath)) return prev - return [...prev, { id: `mention-${Date.now()}`, path: fullPath, displayName }] - }) - } - - textareaRef.current?.focus() - }, - [activeMention, message, onMessageChange] - ) - - const handleMentionClose = useCallback(() => { - // The popover handles its own closing - }, []) + clampToAvailableWidth() + window.addEventListener('resize', clampToAvailableWidth) + return () => window.removeEventListener('resize', clampToAvailableWidth) + }, [getMaxAllowedWidth]) const handleMouseDown = useCallback((e: React.MouseEvent) => { e.preventDefault() @@ -253,10 +216,10 @@ export function ChatSidebar({ startWidthRef.current = width setIsResizing(true) - const handleMouseMove = (e: MouseEvent) => { - const delta = startXRef.current - e.clientX - const newWidth = Math.min(MAX_WIDTH, Math.max(MIN_WIDTH, startWidthRef.current + delta)) - setWidth(newWidth) + const handleMouseMove = (event: MouseEvent) => { + const delta = startXRef.current - event.clientX + const maxAllowedWidth = getMaxAllowedWidth() + setWidth(clampPaneWidth(startWidthRef.current + delta, maxAllowedWidth)) } const handleMouseUp = () => { @@ -267,159 +230,101 @@ export function ChatSidebar({ document.addEventListener('mousemove', handleMouseMove) document.addEventListener('mouseup', handleMouseUp) - }, [width]) + }, [width, getMaxAllowedWidth]) - // Auto-focus textarea when sidebar opens or when conversation is cleared (new chat) - useEffect(() => { - // Focus when conversation is empty (new chat started) - if (conversation.length === 0) { - const timer = setTimeout(() => { - textareaRef.current?.focus() - }, 50) - return () => clearTimeout(timer) - } - }, [conversation.length]) + const activeTabState = useMemo(() => ({ + runId: runId ?? null, + conversation, + currentAssistantMessage, + pendingAskHumanRequests, + allPermissionRequests, + permissionResponses, + }), [ + runId, + conversation, + currentAssistantMessage, + pendingAskHumanRequests, + allPermissionRequests, + permissionResponses, + ]) + const emptyTabState = useMemo(() => createEmptyChatTabViewState(), []) + const getTabState = useCallback((tabId: string): ChatTabViewState => { + if (tabId === activeChatTabId) return activeTabState + return chatTabStates[tabId] ?? emptyTabState + }, [activeChatTabId, activeTabState, chatTabStates, emptyTabState]) + const hasConversation = activeTabState.conversation.length > 0 || Boolean(activeTabState.currentAssistantMessage) - // Auto-populate with @currentfile when switching knowledge files - useEffect(() => { - if (selectedPath === lastSelectedPathRef.current) return - lastSelectedPathRef.current = selectedPath ?? null - - if (!selectedPath || !selectedPath.startsWith('knowledge/') || !selectedPath.endsWith('.md')) { - return - } - - const displayName = wikiLabel(selectedPath) - const previousAuto = autoMentionRef.current - const trimmed = message.trim() - const previousToken = previousAuto ? `@${previousAuto.displayName}` : null - const shouldReplace = !trimmed || (previousToken && trimmed === previousToken) - - if (!shouldReplace) { - return - } - - const nextText = `@${displayName} ` - if (message !== nextText) { - onMessageChange(nextText) - } - - setMentions((prev) => { - const withoutPrevious = previousAuto - ? prev.filter((mention) => mention.path !== previousAuto.path) - : prev - if (withoutPrevious.some((mention) => mention.path === selectedPath)) { - return withoutPrevious - } - return [ - ...withoutPrevious, - { - id: `mention-auto-${Date.now()}`, - path: selectedPath, - displayName, - }, - ] - }) - - autoMentionRef.current = { path: selectedPath, displayName } - }, [selectedPath, message, onMessageChange]) - - const hasConversation = conversation.length > 0 || currentAssistantMessage - const canSubmit = Boolean(message.trim()) && !isProcessing - - const handleSubmit = () => { - const trimmed = message.trim() - if (trimmed && !isProcessing) { - onSubmit({ text: trimmed, files: [] }, mentions) - setMentions([]) - } - } - - const handleKeyDown = (e: React.KeyboardEvent) => { - // If mention popover is open, let it handle navigation keys - if (activeMention && ['ArrowDown', 'ArrowUp', 'Tab', 'Escape'].includes(e.key)) { - return - } - - if (e.key === 'Enter') { - // If mention popover is open, Enter should select the item - if (activeMention) { - return - } - - if (!e.shiftKey) { - e.preventDefault() - handleSubmit() - } - } - - // Handle backspace to delete entire mention at once - if (e.key === 'Backspace') { - const textarea = e.currentTarget - const cursorPos = textarea.selectionStart - const selectionEnd = textarea.selectionEnd - - // Only handle if no text is selected (cursor is at a single position) - if (cursorPos !== selectionEnd) return - - // Check if cursor is right after a mention - for (const label of mentionLabels) { - const mentionText = `@${label}` - const startPos = cursorPos - mentionText.length - if (startPos >= 0) { - const textBefore = message.substring(startPos, cursorPos) - if (textBefore === mentionText) { - // Check if it's at word boundary (start of string or preceded by whitespace) - if (startPos === 0 || /\s/.test(message[startPos - 1])) { - e.preventDefault() - const newText = message.substring(0, startPos) + message.substring(cursorPos) - onMessageChange(newText) - // Remove the mention from state - setMentions(prev => prev.filter(m => m.displayName !== label)) - // Set cursor position after React updates - setTimeout(() => { - textarea.selectionStart = startPos - textarea.selectionEnd = startPos - }, 0) - return - } - } - } - } - } - } - - const renderConversationItem = (item: ConversationItem) => { + const renderConversationItem = (item: ConversationItem, tabId: string) => { if (isChatMessage(item)) { + if (item.role === 'user') { + if (item.attachments && item.attachments.length > 0) { + return ( + + + + + {item.content && ( + {item.content} + )} + + ) + } + const { message, files } = parseAttachedFiles(item.content) + return ( + + + {files.length > 0 && ( +
+ {files.map((filePath, index) => ( + + @{wikiLabel(filePath)} + + ))} +
+ )} + {message} + + + ) + } return ( - {item.role === 'assistant' ? ( - {item.content} - ) : ( - item.content - )} + {item.content} ) } if (isToolCall(item)) { + const webSearchData = getWebSearchCardData(item) + if (webSearchData) { + return ( + + ) + } const errorText = item.status === 'error' ? 'Tool error' : '' const output = normalizeToolOutput(item.result, item.status) const input = normalizeToolInput(item.input) return ( - - + onToolOpenChangeForTab?.(tabId, item.id, open)} + > + - {output !== null ? ( - - ) : null} + {output !== null ? : null} ) @@ -438,218 +343,213 @@ export function ChatSidebar({ return null } - const displayWidth = isOpen ? width : 0 + const paneStyle = useMemo(() => { + if (!isOpen) { + return { width: 0, flex: '0 0 auto' } + } + if (isMaximized) { + // In maximize mode the pane should grow into the freed left space, + // not add extra width to the right and overflow the app viewport. + return { width: 0, flex: '1 1 auto' } + } + return { width, flex: '0 0 auto' } + }, [isOpen, isMaximized, width]) return (
- {/* Resize handle */} -
+ {!isMaximized && ( +
+ )} - {/* Content - delayed on open, hidden immediately on close to avoid layout issues during animation */} {showContent && ( <> - {/* Header - minimal, expand and new chat buttons */} -
+
+ tab.id} + isProcessing={isChatTabProcessing} + onSwitchTab={onSwitchChatTab} + onCloseTab={onCloseChatTab} + /> - - New chat + New chat tab {onOpenFullScreen && ( - - Full screen chat + + {isMaximized ? 'Restore two-pane view' : 'Maximize chat view'} + )}
- {/* Conversation area */} - {})}> -
- - - - {!hasConversation ? ( - -
-
- Ask anything... -
-
- - ) : ( - <> - {conversation.map(item => { - const rendered = renderConversationItem(item) - // If this is a tool call, check for permission request (pending or responded) - if (isToolCall(item) && onPermissionResponse) { - const permRequest = allPermissionRequests.get(item.id) - if (permRequest) { - const response = permissionResponses.get(item.id) || null - return ( - - {rendered} - onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve')} - onDeny={() => onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'deny')} - isProcessing={isProcessing} - response={response} - /> - - ) - } - } - return rendered + {})}> +
+
+ {chatTabs.map((tab) => { + const isActive = tab.id === activeChatTabId + const tabState = getTabState(tab.id) + const tabHasConversation = tabState.conversation.length > 0 || Boolean(tabState.currentAssistantMessage) + return ( +
+ + + + {!tabHasConversation ? ( + +
Ask anything...
+ + ) : ( + <> + {tabState.conversation.map((item) => { + const rendered = renderConversationItem(item, tab.id) + if (isToolCall(item) && onPermissionResponse) { + const permRequest = tabState.allPermissionRequests.get(item.id) + if (permRequest) { + const response = tabState.permissionResponses.get(item.id) || null + return ( + + {rendered} + onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve')} + onApproveSession={() => onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve', 'session')} + onApproveAlways={() => onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'approve', 'always')} + onDeny={() => onPermissionResponse(permRequest.toolCall.toolCallId, permRequest.subflow, 'deny')} + isProcessing={isActive && isProcessing} + response={response} + /> + + ) + } + } + return rendered + })} + + {onAskHumanResponse && Array.from(tabState.pendingAskHumanRequests.values()).map((request) => ( + onAskHumanResponse(request.toolCallId, request.subflow, response)} + isProcessing={isActive && isProcessing} + /> + ))} + + {tabState.currentAssistantMessage && ( + + + {tabState.currentAssistantMessage} + + + )} + + {isActive && isProcessing && !tabState.currentAssistantMessage && ( + + + Thinking... + + + )} + + )} + + +
+ ) })} +
- {/* Render pending ask-human requests */} - {onAskHumanResponse && Array.from(pendingAskHumanRequests.values()).map((request) => ( - onAskHumanResponse(request.toolCallId, request.subflow, response)} - isProcessing={isProcessing} - /> - ))} - - {currentAssistantMessage && ( - - - {currentAssistantMessage} - - - )} - - {isProcessing && !currentAssistantMessage && ( - - - Thinking... - - - )} - - )} - - - - {/* Input area - responsive to sidebar width, matches floating bar position exactly */} -
- {!hasConversation && ( - { - onMessageChange(prompt) - setTimeout(() => textareaRef.current?.focus(), 0) - }} - vertical - className="mb-3" - /> - )} -
-
- {mentionHighlights.hasHighlights && ( -