@push.rocks/smartagent

Documentation for @push.rocks/smartagent

readme.md for @push.rocks/smartagent

A lightweight agentic loop built on Vercel AI SDK v6 via @push.rocks/smartai. Register tools, get a model, call runAgent() β€” done. πŸš€

Install

pnpm install @push.rocks/smartagent

Issue Reporting and Security

For reporting bugs, issues, or security vulnerabilities, please visit community.foss.global/. This is the central community hub for all issue reporting. Developers who sign and comply with our contribution agreement and go through identification can also get a code.foss.global/ account to submit Pull Requests directly.

Overview

@push.rocks/smartagent wraps the AI SDK's streamText with stopWhen: stepCountIs(n) for parallel multi-step tool execution. No classes to instantiate, no lifecycle to manage β€” just one async function:

import { runAgent, tool, z } from '@push.rocks/smartagent';
import { getModel } from '@push.rocks/smartai';

const model = getModel({
  provider: 'anthropic',
  model: 'claude-sonnet-4-5-20250929',
  apiKey: process.env.ANTHROPIC_TOKEN,
});

const result = await runAgent({
  model,
  prompt: 'What is 7 + 35?',
  system: 'You are a helpful assistant. Use tools when asked.',
  tools: {
    calculator: tool({
      description: 'Perform arithmetic',
      inputSchema: z.object({
        operation: z.enum(['add', 'subtract', 'multiply', 'divide']),
        a: z.number(),
        b: z.number(),
      }),
      execute: async ({ operation, a, b }) => {
        const ops = { add: a + b, subtract: a - b, multiply: a * b, divide: a / b };
        return String(ops[operation]);
      },
    }),
  },
  maxSteps: 10,
});

console.log(result.text);    // "7 + 35 = 42"
console.log(result.steps);   // number of agentic steps taken
console.log(result.usage);   // { promptTokens, completionTokens, totalTokens }

Architecture

β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
β”‚  runAgent({ model, prompt, tools, maxSteps })   β”‚
β”‚                                                 β”‚
β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”   β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”   β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β” β”‚
β”‚  β”‚ Messages   │──▢│ streamText│──▢│  Tools    β”‚ β”‚
β”‚  β”‚ (history)  │◀──│ (AI SDK)  │◀──│ (ToolSet) β”‚ β”‚
β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜   β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜   β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜ β”‚
β”‚                                                 β”‚
β”‚  stopWhen: stepCountIs(maxSteps)                β”‚
β”‚  + retry with backoff on 429/529/503            β”‚
β”‚  + context overflow detection & recovery        β”‚
β”‚  + tool call repair (case-insensitive matching) β”‚
β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜

Key features:

Core API

runAgent(options): Promise<IAgentRunResult>

The single entry point. Options:

Option Type Default Description
model LanguageModelV3 required Model from @push.rocks/smartai's getModel()
prompt string required The user's task/question
system string undefined System prompt
tools ToolSet {} Tools the agent can call
maxSteps number 20 Max agentic steps before stopping
messages ModelMessage[] [] Conversation history (for multi-turn)
maxRetries number 5 Max retries on rate-limit/server errors
onToken (delta: string) => void β€” Streaming token callback
onToolCall (name: string) => void β€” Called when a tool is invoked
onContextOverflow (messages) => messages β€” Handle context overflow (e.g., compact messages)

IAgentRunResult

interface IAgentRunResult {
  text: string;              // Final response text
  finishReason: string;      // 'stop', 'tool-calls', 'length', etc.
  steps: number;             // Number of agentic steps taken
  messages: ModelMessage[];  // Full conversation for multi-turn
  usage: {
    promptTokens: number;
    completionTokens: number;
    totalTokens: number;
  };
}

Defining Tools πŸ› οΈ

Tools use Vercel AI SDK's tool() helper with Zod schemas:

import { tool, z } from '@push.rocks/smartagent';

const myTool = tool({
  description: 'Describe what this tool does',
  inputSchema: z.object({
    param1: z.string().describe('What this parameter is for'),
    param2: z.number().optional(),
  }),
  execute: async ({ param1, param2 }) => {
    // Do work, return a string
    return `Result: ${param1}`;
  },
});

Pass tools as a flat object to runAgent():

await runAgent({
  model,
  prompt: 'Do the thing',
  tools: { myTool, anotherTool },
  maxSteps: 10,
});

ToolRegistry

A lightweight helper for collecting tools:

import { ToolRegistry, tool, z } from '@push.rocks/smartagent';

const registry = new ToolRegistry();

registry.register('random_number', tool({
  description: 'Generate a random integer between min and max',
  inputSchema: z.object({
    min: z.number(),
    max: z.number(),
  }),
  execute: async ({ min, max }) => {
    return String(Math.floor(Math.random() * (max - min + 1)) + min);
  },
}));

registry.register('is_even', tool({
  description: 'Check if a number is even',
  inputSchema: z.object({ number: z.number() }),
  execute: async ({ number: n }) => n % 2 === 0 ? 'Yes' : 'No',
}));

const result = await runAgent({
  model,
  prompt: 'Generate a random number and tell me if it is even',
  tools: registry.getTools(),
  maxSteps: 10,
});

Built-in Tool Factories 🧰

Import from the @push.rocks/smartagent/tools subpath:

import { filesystemTool, shellTool, httpTool, jsonTool } from '@push.rocks/smartagent/tools';

filesystemTool(options?)

Returns: read_file, write_file, list_directory, delete_file

const tools = filesystemTool({ rootDir: '/home/user/workspace' });

await runAgent({
  model,
  prompt: 'Create a file called hello.txt with "Hello World"',
  tools,
  maxSteps: 5,
});

Options:

shellTool(options?)

Returns: run_command

const tools = shellTool({ cwd: '/tmp', allowedCommands: ['ls', 'echo', 'cat'] });

await runAgent({
  model,
  prompt: 'List all files in /tmp',
  tools,
  maxSteps: 5,
});

Options:

httpTool()

Returns: http_get, http_post

const tools = httpTool();

await runAgent({
  model,
  prompt: 'Fetch the data from https://api.example.com/status',
  tools,
  maxSteps: 5,
});

jsonTool()

Returns: json_validate, json_transform

const tools = jsonTool();

// Direct usage:
const result = await tools.json_validate.execute({
  jsonString: '{"name":"test","value":42}',
  requiredFields: ['name', 'value'],
});
// β†’ "Valid JSON: object with 2 keys"

Streaming & Callbacks πŸŽ₯

Monitor the agent in real-time:

const result = await runAgent({
  model,
  prompt: 'Analyze this data...',
  tools,
  maxSteps: 10,

  // Token-by-token streaming
  onToken: (delta) => process.stdout.write(delta),

  // Tool call notifications
  onToolCall: (toolName) => console.log(`\nπŸ”§ Calling: ${toolName}`),
});

Context Overflow Handling πŸ’₯

For long-running agents that might exceed the model's context window, use the compaction subpath:

import { runAgent } from '@push.rocks/smartagent';
import { compactMessages } from '@push.rocks/smartagent/compaction';

const result = await runAgent({
  model,
  prompt: 'Process all 500 files...',
  tools,
  maxSteps: 100,

  onContextOverflow: async (messages) => {
    // Summarize the conversation to free up context space
    return await compactMessages(model, messages);
  },
});

Output Truncation βœ‚οΈ

Prevent large tool outputs from consuming too much context:

import { truncateOutput } from '@push.rocks/smartagent';

const { content, truncated, notice } = truncateOutput(hugeOutput, {
  maxLines: 2000,   // default
  maxBytes: 50_000, // default
});

The built-in tool factories use truncateOutput internally.

Multi-Turn Conversations πŸ’¬

Pass the returned messages back for multi-turn interactions:

// First turn
const turn1 = await runAgent({
  model,
  prompt: 'Create a project structure',
  tools,
  maxSteps: 10,
});

// Second turn β€” continues the conversation
const turn2 = await runAgent({
  model,
  prompt: 'Now add a README to the project',
  tools,
  maxSteps: 10,
  messages: turn1.messages, // pass history
});

Exports

Main (@push.rocks/smartagent)

Export Type Description
runAgent function Core agentic loop
ToolRegistry class Tool collection helper
truncateOutput function Output truncation utility
ContextOverflowError class Error type for context overflow
tool function Re-exported from @push.rocks/smartai
z object Re-exported Zod for schema definitions
stepCountIs function Re-exported from AI SDK
jsonSchema function Re-exported from @push.rocks/smartai

Tools (@push.rocks/smartagent/tools)

Export Type Description
filesystemTool factory File operations (read, write, list, delete)
shellTool factory Shell command execution
httpTool factory HTTP GET/POST requests
jsonTool factory JSON validation and transformation

Compaction (@push.rocks/smartagent/compaction)

Export Type Description
compactMessages function Summarize message history to free context

Dependencies

This repository contains open-source code licensed under the MIT License. A copy of the license can be found in the LICENSE file.

Please note: The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.

Trademarks

This project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH or third parties, and are not included within the scope of the MIT license granted herein.

Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines or the guidelines of the respective third-party owners, and any usage must be approved in writing. Third-party trademarks used herein are the property of their respective owners and used only in a descriptive manner, e.g. for an implementation of an API or similar.

Company Information

Task Venture Capital GmbH Registered at District Court Bremen HRB 35230 HB, Germany

By using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.

changelog.md for @push.rocks/smartagent

2026-03-06 - 3.0.2 - fix(agent)

use output parameter when invoking onToolResult instead of toolCall.result

2026-03-06 - 3.0.1 - fix(readme)

adjust ASCII art in README to fix box widths and spacing in agent diagram

2026-03-06 - 3.0.0 - BREAKING CHANGE(api)

Migrate public API to ai-sdk v6 and refactor core agent architecture: replace class-based DualAgent/Driver/Guardian with a single runAgent function; introduce ts_tools factories for tools, a compactMessages compaction subpath, and truncateOutput utility; simplify ToolRegistry to return ToolSet and remove legacy BaseToolWrapper/tool classes; update package exports and dependencies and bump major version.

2026-01-20 - 1.8.0 - feat(tools)

add ToolRegistry, ToolSearchTool and ExpertTool to support on-demand tool visibility, discovery, activation, and expert/subagent tooling; extend DualAgentOrchestrator API and interfaces to manage tool lifecycle

2026-01-20 - 1.7.0 - feat(docs)

document native tool calling support and update README to clarify standard and additional tools

2026-01-20 - 1.6.2 - fix(release)

bump version to 1.6.2

2026-01-20 - 1.6.1 - fix(driveragent)

include full message history for tool results and use a continuation prompt when invoking provider.collectStreamResponse

2026-01-20 - 1.6.0 - feat(smartagent)

record native tool results in message history by adding optional toolName to continueWithNativeTools and passing tool identifier from DualAgent

2026-01-20 - 1.5.4 - fix(driveragent)

prevent duplicate thinking/output markers during token streaming and mark transitions

2026-01-20 - 1.5.3 - fix(driveragent)

prefix thinking tokens with [THINKING] when forwarding streaming chunks to onToken

2026-01-20 - 1.5.2 - fix()

no changes in this diff; nothing to release

2026-01-20 - 1.5.1 - fix(smartagent)

bump patch version to 1.5.1 (no changes in diff)

2026-01-20 - 1.5.0 - feat(driveragent)

preserve assistant reasoning in message history and update @push.rocks/smartai dependency to ^0.13.0

2026-01-20 - 1.4.2 - fix(repo)

no changes detected in diff

2026-01-20 - 1.4.1 - fix()

no changes detected (empty diff)

2026-01-20 - 1.4.0 - feat(docs)

document Dual-Agent Driver/Guardian architecture, new standard tools, streaming/vision support, progress events, and updated API/export docs

2026-01-20 - 1.3.0 - feat(smartagent)

add JsonValidatorTool and support passing base64-encoded images with task runs (vision-capable models); bump @push.rocks/smartai to ^0.12.0

2026-01-20 - 1.2.7 - fix(deps(smartai))

bump @push.rocks/smartai to ^0.11.0

2026-01-20 - 1.2.6 - fix(deps)

bump @push.rocks/smartai to ^0.10.1

2025-12-15 - 1.1.1 - fix(ci)

Update CI/release config and bump devDependencies; enable verbose tests

2025-12-02 - 1.1.0 - feat(deno)

Add Deno tool and smartdeno integration; export and register DenoTool; update docs and tests

2025-12-02 - 1.0.2 - fix(core)

Bump version to 1.0.2 (patch release)

2025-12-02 - 1.0.1 - initial release

Initial commit: project scaffold and first release.