feat(ipuaro): add error handling matrix and ErrorHandler service

Implemented comprehensive error handling system according to v0.16.0 roadmap:

- ERROR_MATRIX with 9 error types (redis, parse, llm, file, command, conflict, validation, timeout, unknown)
- Enhanced IpuaroError with options, defaultOption, context properties
- New methods: getMeta(), hasOption(), toDisplayString()
- ErrorHandler service with handle(), wrap(), withRetry() methods
- Utility functions: getErrorOptions(), isRecoverableError(), toIpuaroError()
- 59 new tests (27 for IpuaroError, 32 for ErrorHandler)
- Coverage maintained at 97.59%

Breaking changes:
- IpuaroError constructor signature changed to (type, message, options?)
- ErrorChoice deprecated in favor of ErrorOption

packages/ipuaro/CHANGELOG.md

@@ -5,6 +5,123 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.16.0] - 2025-12-01 - Error Handling
+
+### Added
+
+- **Error Handling Matrix (0.16.2)**
+  - `ERROR_MATRIX`: Defines behavior for each error type
+  - Per-type options: retry, skip, abort, confirm, regenerate
+  - Per-type defaults and recoverability settings
+  - Comprehensive error type support: redis, parse, llm, file, command, conflict, validation, timeout, unknown
+
+- **IpuaroError Enhancements (0.16.1)**
+  - `ErrorOption` type: New type for available recovery options
+  - `ErrorMeta` interface: Error metadata with type, recoverable flag, options, and default
+  - `options` property: Available recovery options from matrix
+  - `defaultOption` property: Default option for the error type
+  - `context` property: Optional context data for debugging
+  - `getMeta()`: Returns full error metadata
+  - `hasOption()`: Checks if an option is available
+  - `toDisplayString()`: Formatted error message with suggestion
+  - New factory methods: `llmTimeout()`, `fileNotFound()`, `commandBlacklisted()`, `unknown()`
+
+- **ErrorHandler Service**
+  - `handle()`: Async error handling with user callback
+  - `handleSync()`: Sync error handling with defaults
+  - `wrap()`: Wraps async functions with error handling
+  - `withRetry()`: Wraps functions with automatic retry logic
+  - `resetRetries()`: Resets retry counters
+  - `getRetryCount()`: Gets current retry count
+  - `isMaxRetriesExceeded()`: Checks if max retries reached
+  - Configurable options: maxRetries, autoSkipParseErrors, autoRetryLLMErrors
+
+- **Utility Functions**
+  - `getErrorOptions()`: Get available options for error type
+  - `getDefaultErrorOption()`: Get default option for error type
+  - `isRecoverableError()`: Check if error type is recoverable
+  - `toIpuaroError()`: Convert any error to IpuaroError
+  - `createErrorHandler()`: Factory function for ErrorHandler
+
+### Changed
+
+- **IpuaroError Constructor**
+  - New signature: `(type, message, options?)` with options object
+  - Options include: recoverable, suggestion, context
+  - Matrix-based defaults for all properties
+
+- **ErrorChoice → ErrorOption**
+  - `ErrorChoice` type deprecated in shared/types
+  - Use `ErrorOption` from shared/errors instead
+  - Updated HandleMessage and useSession to use ErrorOption
+
+### Technical Details
+
+- Total tests: 1420 (59 new tests)
+- Coverage: 97.59% maintained
+- New test files: ErrorHandler.test.ts
+- Updated test file: IpuaroError.test.ts
+
+---
+
+## [0.15.0] - 2025-12-01 - CLI Entry Point
+
+### Added
+
+- **Onboarding Module (0.15.3)**
+  - `checkRedis()`: Validates Redis connection with helpful error messages
+  - `checkOllama()`: Validates Ollama availability with install instructions
+  - `checkModel()`: Checks if LLM model is available, offers to pull if missing
+  - `checkProjectSize()`: Warns if project has >10K files
+  - `runOnboarding()`: Runs all pre-flight checks before starting
+
+- **Start Command (0.15.1)**
+  - Full TUI startup with dependency injection
+  - Integrates onboarding checks before launch
+  - Interactive model pull prompt if model missing
+  - Redis, storage, LLM, and tools initialization
+  - Clean shutdown with disconnect on exit
+
+- **Init Command (0.15.1)**
+  - Creates `.ipuaro.json` configuration file
+  - Default template with Redis, LLM, and edit settings
+  - `--force` option to overwrite existing config
+  - Helpful output showing available options
+
+- **Index Command (0.15.1)**
+  - Standalone project indexing without TUI
+  - File scanning with progress output
+  - AST parsing with error handling
+  - Metadata analysis and storage
+  - Symbol index and dependency graph building
+  - Duration and statistics reporting
+
+- **CLI Options (0.15.2)**
+  - `--auto-apply`: Enable auto-apply mode for edits
+  - `--model <name>`: Override LLM model
+  - `--help`: Show help
+  - `--version`: Show version
+
+- **Tools Setup Helper**
+  - `registerAllTools()`: Registers all 18 tools with the registry
+  - Clean separation from CLI logic
+
+### Changed
+
+- **CLI Architecture**
+  - Refactored from placeholder to full implementation
+  - Commands in separate modules under `src/cli/commands/`
+  - Dynamic version from package.json
+  - `start` command is now default (runs with `ipuaro` or `ipuaro start`)
+
+### Technical Details
+
+- Total tests: 1372 (29 new CLI tests)
+- Coverage: ~98% maintained (CLI excluded from coverage thresholds)
+- New test files: onboarding.test.ts, init.test.ts, tools-setup.test.ts
+
+---
+
 ## [0.14.0] - 2025-12-01 - Commands
 
 ### Added

packages/ipuaro/ROADMAP.md

@@ -1182,10 +1182,10 @@ Tab     // Path autocomplete
 
 ---
 
-## Version 0.15.0 - CLI Entry Point 🚪 ⬜
+## Version 0.15.0 - CLI Entry Point 🚪 ✅
 
 **Priority:** HIGH
-**Status:** NEXT MILESTONE
+**Status:** Complete (v0.15.0 released)
 
 ### 0.15.1 - CLI Commands
 
@@ -1219,41 +1219,75 @@ ipuaro index            // Index only (no TUI)
 ```
 
 **Tests:**
-- [ ] E2E tests for CLI
+- [x] Unit tests for CLI commands (29 tests)
 
 ---
 
-## Version 0.16.0 - Error Handling ⚠️ ⬜
+## Version 0.16.0 - Error Handling ⚠️ ✅
 
 **Priority:** HIGH
-**Status:** Partial — IpuaroError exists (v0.1.0), need full error matrix implementation
+**Status:** Complete (v0.16.0 released)
 
-### 0.16.1 - Error Types
+### 0.16.1 - Error Types ✅
 
 ```typescript
 // src/shared/errors/IpuaroError.ts
-type ErrorType = "redis" | "parse" | "llm" | "file" | "command" | "conflict"
+type ErrorType = "redis" | "parse" | "llm" | "file" | "command" | "conflict" | "validation" | "timeout" | "unknown"
+type ErrorOption = "retry" | "skip" | "abort" | "confirm" | "regenerate"
+
+interface ErrorMeta {
+    type: ErrorType
+    recoverable: boolean
+    options: ErrorOption[]
+    defaultOption: ErrorOption
+}
 
 class IpuaroError extends Error {
     type: ErrorType
     recoverable: boolean
     suggestion?: string
+    options: ErrorOption[]
+    defaultOption: ErrorOption
+    context?: Record<string, unknown>
+
+    getMeta(): ErrorMeta
+    hasOption(option: ErrorOption): boolean
+    toDisplayString(): string
 }
 ```
 
-### 0.16.2 - Error Handling Matrix
+### 0.16.2 - Error Handling Matrix ✅
 
-| Error | Recoverable | Options |
-|-------|-------------|---------|
-| Redis unavailable | No | Retry / Abort |
-| AST parse failed | Yes | Skip file / Abort |
-| LLM timeout | Yes | Retry / Skip / Abort |
-| File not found | Yes | Skip / Abort |
-| Command not in whitelist | Yes | Confirm / Skip / Abort |
-| Edit conflict | Yes | Apply / Skip / Regenerate |
+| Error | Recoverable | Options | Default |
+|-------|-------------|---------|---------|
+| Redis unavailable | No | Retry / Abort | Abort |
+| AST parse failed | Yes | Skip / Abort | Skip |
+| LLM timeout | Yes | Retry / Skip / Abort | Retry |
+| File not found | Yes | Skip / Abort | Skip |
+| Command not in whitelist | Yes | Confirm / Skip / Abort | Confirm |
+| Edit conflict | Yes | Skip / Regenerate / Abort | Skip |
+| Validation error | Yes | Skip / Abort | Skip |
+| Timeout | Yes | Retry / Skip / Abort | Retry |
+| Unknown | No | Abort | Abort |
+
+### 0.16.3 - ErrorHandler Service ✅
+
+```typescript
+// src/shared/errors/ErrorHandler.ts
+class ErrorHandler {
+    handle(error: IpuaroError, contextKey?: string): Promise<ErrorHandlingResult>
+    handleSync(error: IpuaroError, contextKey?: string): ErrorHandlingResult
+    wrap<T>(fn: () => Promise<T>, errorType: ErrorType, contextKey?: string): Promise<Result>
+    withRetry<T>(fn: () => Promise<T>, errorType: ErrorType, contextKey: string): Promise<T>
+    resetRetries(contextKey?: string): void
+    getRetryCount(contextKey: string): number
+    isMaxRetriesExceeded(contextKey: string): boolean
+}
+```
 
 **Tests:**
-- [ ] Unit tests for error handling
+- [x] Unit tests for IpuaroError (27 tests)
+- [x] Unit tests for ErrorHandler (32 tests)
 
 ---
 
@@ -1265,7 +1299,7 @@ class IpuaroError extends Error {
 - [x] All 18 tools implemented and tested ✅ (v0.9.0)
 - [x] TUI fully functional ✅ (v0.11.0, v0.12.0)
 - [x] Session persistence working ✅ (v0.10.0)
-- [ ] Error handling complete (partial)
+- [x] Error handling complete ✅ (v0.16.0)
 - [ ] Performance optimized
 - [ ] Documentation complete
 - [x] 80%+ test coverage ✅ (~98%)
@@ -1347,4 +1381,4 @@ sessions:list             # List<session_id>
 
 **Last Updated:** 2025-12-01
 **Target Version:** 1.0.0
-**Current Version:** 0.14.0
+**Current Version:** 0.16.0

packages/ipuaro/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@samiyev/ipuaro",
-    "version": "0.14.0",
+    "version": "0.15.0",
     "description": "Local AI agent for codebase operations with infinite context feeling",
     "author": "Fozilbek Samiyev <fozilbek.samiyev@gmail.com>",
     "license": "MIT",

packages/ipuaro/src/application/use-cases/HandleMessage.ts

@@ -14,8 +14,7 @@ import {
 import type { ToolCall } from "../../domain/value-objects/ToolCall.js"
 import { createErrorResult, type ToolResult } from "../../domain/value-objects/ToolResult.js"
 import { createUndoEntry, type UndoEntry } from "../../domain/value-objects/UndoEntry.js"
-import { IpuaroError } from "../../shared/errors/IpuaroError.js"
-import type { ErrorChoice } from "../../shared/types/index.js"
+import { type ErrorOption, IpuaroError } from "../../shared/errors/IpuaroError.js"
 import {
     buildInitialContext,
     type ProjectStructure,
@@ -58,7 +57,7 @@ export interface HandleMessageEvents {
     onToolCall?: (call: ToolCall) => void
     onToolResult?: (result: ToolResult) => void
     onConfirmation?: (message: string, diff?: DiffInfo) => Promise<boolean>
-    onError?: (error: IpuaroError) => Promise<ErrorChoice>
+    onError?: (error: IpuaroError) => Promise<ErrorOption>
     onStatusChange?: (status: HandleMessageStatus) => void
     onUndoEntry?: (entry: UndoEntry) => void
 }

packages/ipuaro/src/cli/commands/index-cmd.ts

@@ -0,0 +1,250 @@
+/**
+ * Index command implementation.
+ * Indexes project without starting TUI.
+ */
+
+import * as fs from "node:fs/promises"
+import * as path from "node:path"
+import { RedisClient } from "../../infrastructure/storage/RedisClient.js"
+import { RedisStorage } from "../../infrastructure/storage/RedisStorage.js"
+import { generateProjectName } from "../../infrastructure/storage/schema.js"
+import { FileScanner } from "../../infrastructure/indexer/FileScanner.js"
+import { ASTParser } from "../../infrastructure/indexer/ASTParser.js"
+import { MetaAnalyzer } from "../../infrastructure/indexer/MetaAnalyzer.js"
+import { IndexBuilder } from "../../infrastructure/indexer/IndexBuilder.js"
+import { createFileData } from "../../domain/value-objects/FileData.js"
+import type { FileAST } from "../../domain/value-objects/FileAST.js"
+import { type Config, DEFAULT_CONFIG } from "../../shared/constants/config.js"
+import { md5 } from "../../shared/utils/hash.js"
+import { checkRedis } from "./onboarding.js"
+
+type Language = "ts" | "tsx" | "js" | "jsx"
+
+/**
+ * Result of index command.
+ */
+export interface IndexResult {
+    success: boolean
+    filesIndexed: number
+    filesSkipped: number
+    errors: string[]
+    duration: number
+}
+
+/**
+ * Progress callback for indexing.
+ */
+export type IndexProgressCallback = (
+    phase: "scanning" | "parsing" | "analyzing" | "storing",
+    current: number,
+    total: number,
+    currentFile?: string,
+) => void
+
+/**
+ * Execute the index command.
+ */
+export async function executeIndex(
+    projectPath: string,
+    config: Config = DEFAULT_CONFIG,
+    onProgress?: IndexProgressCallback,
+): Promise<IndexResult> {
+    const startTime = Date.now()
+    const resolvedPath = path.resolve(projectPath)
+    const projectName = generateProjectName(resolvedPath)
+    const errors: string[] = []
+
+    console.warn(`📁 Indexing project: ${resolvedPath}`)
+    console.warn(`   Project name: ${projectName}\n`)
+
+    const redisResult = await checkRedis(config.redis)
+    if (!redisResult.ok) {
+        console.error(`❌ ${redisResult.error ?? "Redis unavailable"}`)
+        return {
+            success: false,
+            filesIndexed: 0,
+            filesSkipped: 0,
+            errors: [redisResult.error ?? "Redis unavailable"],
+            duration: Date.now() - startTime,
+        }
+    }
+
+    let redisClient: RedisClient | null = null
+
+    try {
+        redisClient = new RedisClient(config.redis)
+        await redisClient.connect()
+
+        const storage = new RedisStorage(redisClient, projectName)
+        const scanner = new FileScanner({
+            onProgress: (progress): void => {
+                onProgress?.("scanning", progress.current, progress.total, progress.currentFile)
+            },
+        })
+        const astParser = new ASTParser()
+        const metaAnalyzer = new MetaAnalyzer(resolvedPath)
+        const indexBuilder = new IndexBuilder(resolvedPath)
+
+        console.warn("🔍 Scanning files...")
+        const files = await scanner.scanAll(resolvedPath)
+        console.warn(`   Found ${String(files.length)} files\n`)
+
+        if (files.length === 0) {
+            console.warn("⚠️  No files found to index.")
+            return {
+                success: true,
+                filesIndexed: 0,
+                filesSkipped: 0,
+                errors: [],
+                duration: Date.now() - startTime,
+            }
+        }
+
+        console.warn("📝 Parsing files...")
+        const allASTs = new Map<string, FileAST>()
+        const fileContents = new Map<string, string>()
+        let parsed = 0
+        let skipped = 0
+
+        for (const file of files) {
+            const fullPath = path.join(resolvedPath, file.path)
+            const language = getLanguage(file.path)
+
+            if (!language) {
+                skipped++
+                continue
+            }
+
+            try {
+                const content = await fs.readFile(fullPath, "utf-8")
+                const ast = astParser.parse(content, language)
+
+                if (ast.parseError) {
+                    errors.push(
+                        `Parse error in ${file.path}: ${ast.parseErrorMessage ?? "unknown"}`,
+                    )
+                    skipped++
+                    continue
+                }
+
+                allASTs.set(file.path, ast)
+                fileContents.set(file.path, content)
+                parsed++
+
+                onProgress?.("parsing", parsed + skipped, files.length, file.path)
+
+                if ((parsed + skipped) % 50 === 0) {
+                    process.stdout.write(
+                        `\r   Parsed ${String(parsed)} files (${String(skipped)} skipped)...`,
+                    )
+                }
+            } catch (error) {
+                const message = error instanceof Error ? error.message : String(error)
+                errors.push(`Error reading ${file.path}: ${message}`)
+                skipped++
+            }
+        }
+        console.warn(`\r   Parsed ${String(parsed)} files (${String(skipped)} skipped)     \n`)
+
+        console.warn("📊 Analyzing metadata...")
+        let analyzed = 0
+        for (const [filePath, ast] of allASTs) {
+            const content = fileContents.get(filePath) ?? ""
+            const meta = metaAnalyzer.analyze(
+                path.join(resolvedPath, filePath),
+                ast,
+                content,
+                allASTs,
+            )
+
+            const fileData = createFileData({
+                lines: content.split("\n"),
+                hash: md5(content),
+                size: content.length,
+                lastModified: Date.now(),
+            })
+
+            await storage.setFile(filePath, fileData)
+            await storage.setAST(filePath, ast)
+            await storage.setMeta(filePath, meta)
+
+            analyzed++
+            onProgress?.("analyzing", analyzed, allASTs.size, filePath)
+
+            if (analyzed % 50 === 0) {
+                process.stdout.write(
+                    `\r   Analyzed ${String(analyzed)}/${String(allASTs.size)} files...`,
+                )
+            }
+        }
+        console.warn(`\r   Analyzed ${String(analyzed)} files                    \n`)
+
+        console.warn("🏗️  Building indexes...")
+        onProgress?.("storing", 0, 2)
+        const symbolIndex = indexBuilder.buildSymbolIndex(allASTs)
+        const depsGraph = indexBuilder.buildDepsGraph(allASTs)
+
+        await storage.setSymbolIndex(symbolIndex)
+        await storage.setDepsGraph(depsGraph)
+        onProgress?.("storing", 2, 2)
+
+        const duration = Date.now() - startTime
+        const durationSec = (duration / 1000).toFixed(2)
+
+        console.warn(`✅ Indexing complete in ${durationSec}s`)
+        console.warn(`   Files indexed: ${String(parsed)}`)
+        console.warn(`   Files skipped: ${String(skipped)}`)
+        console.warn(`   Symbols: ${String(symbolIndex.size)}`)
+
+        if (errors.length > 0) {
+            console.warn(`\n⚠️  ${String(errors.length)} errors occurred:`)
+            for (const error of errors.slice(0, 5)) {
+                console.warn(`   - ${error}`)
+            }
+            if (errors.length > 5) {
+                console.warn(`   ... and ${String(errors.length - 5)} more`)
+            }
+        }
+
+        return {
+            success: true,
+            filesIndexed: parsed,
+            filesSkipped: skipped,
+            errors,
+            duration,
+        }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        console.error(`❌ Indexing failed: ${message}`)
+        return {
+            success: false,
+            filesIndexed: 0,
+            filesSkipped: 0,
+            errors: [message],
+            duration: Date.now() - startTime,
+        }
+    } finally {
+        if (redisClient) {
+            await redisClient.disconnect()
+        }
+    }
+}
+
+/**
+ * Get language from file extension.
+ */
+function getLanguage(filePath: string): Language | null {
+    const ext = path.extname(filePath).toLowerCase()
+    switch (ext) {
+        case ".ts":
+            return "ts"
+        case ".tsx":
+            return "tsx"
+        case ".js":
+            return "js"
+        case ".jsx":
+            return "jsx"
+        default:
+            return null
+    }
+}

packages/ipuaro/src/cli/commands/index.ts

@@ -0,0 +1,18 @@
+/**
+ * CLI commands module.
+ */
+
+export { executeStart, type StartOptions, type StartResult } from "./start.js"
+export { executeInit, type InitOptions, type InitResult } from "./init.js"
+export { executeIndex, type IndexResult, type IndexProgressCallback } from "./index-cmd.js"
+export {
+    runOnboarding,
+    checkRedis,
+    checkOllama,
+    checkModel,
+    checkProjectSize,
+    pullModel,
+    type OnboardingResult,
+    type OnboardingOptions,
+} from "./onboarding.js"
+export { registerAllTools } from "./tools-setup.js"

packages/ipuaro/src/cli/commands/init.ts

@@ -0,0 +1,114 @@
+/**
+ * Init command implementation.
+ * Creates .ipuaro.json configuration file.
+ */
+
+import * as fs from "node:fs/promises"
+import * as path from "node:path"
+
+/**
+ * Default configuration template for .ipuaro.json
+ */
+const CONFIG_TEMPLATE = {
+    $schema: "https://raw.githubusercontent.com/samiyev/puaros/main/packages/ipuaro/schema.json",
+    redis: {
+        host: "localhost",
+        port: 6379,
+        db: 0,
+    },
+    llm: {
+        model: "qwen2.5-coder:7b-instruct",
+        temperature: 0.1,
+        host: "http://localhost:11434",
+    },
+    project: {
+        ignorePatterns: [],
+    },
+    edit: {
+        autoApply: false,
+    },
+}
+
+/**
+ * Options for init command.
+ */
+export interface InitOptions {
+    force?: boolean
+}
+
+/**
+ * Result of init command.
+ */
+export interface InitResult {
+    success: boolean
+    filePath?: string
+    error?: string
+    skipped?: boolean
+}
+
+/**
+ * Execute the init command.
+ * Creates a .ipuaro.json file in the specified directory.
+ */
+export async function executeInit(
+    projectPath = ".",
+    options: InitOptions = {},
+): Promise<InitResult> {
+    const resolvedPath = path.resolve(projectPath)
+    const configPath = path.join(resolvedPath, ".ipuaro.json")
+
+    try {
+        const exists = await fileExists(configPath)
+
+        if (exists && !options.force) {
+            console.warn(`⚠️  Configuration file already exists: ${configPath}`)
+            console.warn("   Use --force to overwrite.")
+            return {
+                success: true,
+                skipped: true,
+                filePath: configPath,
+            }
+        }
+
+        const dirExists = await fileExists(resolvedPath)
+        if (!dirExists) {
+            await fs.mkdir(resolvedPath, { recursive: true })
+        }
+
+        const content = JSON.stringify(CONFIG_TEMPLATE, null, 4)
+        await fs.writeFile(configPath, content, "utf-8")
+
+        console.warn(`✅ Created ${configPath}`)
+        console.warn("\nConfiguration options:")
+        console.warn("  redis.host     - Redis server host (default: localhost)")
+        console.warn("  redis.port     - Redis server port (default: 6379)")
+        console.warn("  llm.model      - Ollama model name (default: qwen2.5-coder:7b-instruct)")
+        console.warn("  llm.temperature - LLM temperature (default: 0.1)")
+        console.warn("  edit.autoApply - Auto-apply edits without confirmation (default: false)")
+        console.warn("\nRun `ipuaro` to start the AI agent.")
+
+        return {
+            success: true,
+            filePath: configPath,
+        }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        console.error(`❌ Failed to create configuration: ${message}`)
+        return {
+            success: false,
+            error: message,
+        }
+    }
+}
+
+/**
+ * Check if a file or directory exists.
+ */
+async function fileExists(filePath: string): Promise<boolean> {
+    try {
+        await fs.access(filePath)
+        return true
+    } catch {
+        return false
+    }
+}

packages/ipuaro/src/cli/commands/onboarding.ts

@@ -0,0 +1,290 @@
+/**
+ * Onboarding checks for CLI.
+ * Validates environment before starting ipuaro.
+ */
+
+import { RedisClient } from "../../infrastructure/storage/RedisClient.js"
+import { OllamaClient } from "../../infrastructure/llm/OllamaClient.js"
+import { FileScanner } from "../../infrastructure/indexer/FileScanner.js"
+import type { LLMConfig, RedisConfig } from "../../shared/constants/config.js"
+
+/**
+ * Result of onboarding checks.
+ */
+export interface OnboardingResult {
+    success: boolean
+    redisOk: boolean
+    ollamaOk: boolean
+    modelOk: boolean
+    projectOk: boolean
+    fileCount: number
+    errors: string[]
+    warnings: string[]
+}
+
+/**
+ * Options for onboarding checks.
+ */
+export interface OnboardingOptions {
+    redisConfig: RedisConfig
+    llmConfig: LLMConfig
+    projectPath: string
+    maxFiles?: number
+    skipRedis?: boolean
+    skipOllama?: boolean
+    skipModel?: boolean
+    skipProject?: boolean
+}
+
+const DEFAULT_MAX_FILES = 10_000
+
+/**
+ * Check Redis availability.
+ */
+export async function checkRedis(config: RedisConfig): Promise<{
+    ok: boolean
+    error?: string
+}> {
+    const client = new RedisClient(config)
+
+    try {
+        await client.connect()
+        const pingOk = await client.ping()
+        await client.disconnect()
+
+        if (!pingOk) {
+            return {
+                ok: false,
+                error: "Redis ping failed. Server may be overloaded.",
+            }
+        }
+
+        return { ok: true }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        return {
+            ok: false,
+            error: `Cannot connect to Redis: ${message}
+
+Redis is required for ipuaro to store project indexes and session data.
+
+Install Redis:
+  macOS:   brew install redis && brew services start redis
+  Ubuntu:  sudo apt install redis-server && sudo systemctl start redis
+  Docker:  docker run -d -p 6379:6379 redis`,
+        }
+    }
+}
+
+/**
+ * Check Ollama availability.
+ */
+export async function checkOllama(config: LLMConfig): Promise<{
+    ok: boolean
+    error?: string
+}> {
+    const client = new OllamaClient(config)
+
+    try {
+        const available = await client.isAvailable()
+
+        if (!available) {
+            return {
+                ok: false,
+                error: `Cannot connect to Ollama at ${config.host}
+
+Ollama is required for ipuaro to process your requests using local LLMs.
+
+Install Ollama:
+  macOS:   brew install ollama && ollama serve
+  Linux:   curl -fsSL https://ollama.com/install.sh | sh && ollama serve
+  Manual:  https://ollama.com/download
+
+After installing, ensure Ollama is running with: ollama serve`,
+            }
+        }
+
+        return { ok: true }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        return {
+            ok: false,
+            error: `Ollama check failed: ${message}`,
+        }
+    }
+}
+
+/**
+ * Check model availability.
+ */
+export async function checkModel(config: LLMConfig): Promise<{
+    ok: boolean
+    needsPull: boolean
+    error?: string
+}> {
+    const client = new OllamaClient(config)
+
+    try {
+        const hasModel = await client.hasModel(config.model)
+
+        if (!hasModel) {
+            return {
+                ok: false,
+                needsPull: true,
+                error: `Model "${config.model}" is not installed.
+
+Would you like to pull it? This may take a few minutes.
+Run: ollama pull ${config.model}`,
+            }
+        }
+
+        return { ok: true, needsPull: false }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        return {
+            ok: false,
+            needsPull: false,
+            error: `Model check failed: ${message}`,
+        }
+    }
+}
+
+/**
+ * Pull model from Ollama.
+ */
+export async function pullModel(
+    config: LLMConfig,
+    onProgress?: (status: string) => void,
+): Promise<{ ok: boolean; error?: string }> {
+    const client = new OllamaClient(config)
+
+    try {
+        onProgress?.(`Pulling model "${config.model}"...`)
+        await client.pullModel(config.model)
+        onProgress?.(`Model "${config.model}" pulled successfully.`)
+        return { ok: true }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        return {
+            ok: false,
+            error: `Failed to pull model: ${message}`,
+        }
+    }
+}
+
+/**
+ * Check project size.
+ */
+export async function checkProjectSize(
+    projectPath: string,
+    maxFiles: number = DEFAULT_MAX_FILES,
+): Promise<{
+    ok: boolean
+    fileCount: number
+    warning?: string
+}> {
+    const scanner = new FileScanner()
+
+    try {
+        const files = await scanner.scanAll(projectPath)
+        const fileCount = files.length
+
+        if (fileCount > maxFiles) {
+            return {
+                ok: true,
+                fileCount,
+                warning: `Project has ${fileCount.toLocaleString()} files (>${maxFiles.toLocaleString()}).
+This may take a while to index and use more memory.
+
+Consider:
+  1. Running ipuaro in a subdirectory: ipuaro ./src
+  2. Adding patterns to .gitignore to exclude unnecessary files
+  3. Using a smaller project for better performance`,
+            }
+        }
+
+        if (fileCount === 0) {
+            return {
+                ok: false,
+                fileCount: 0,
+                warning: `No supported files found in "${projectPath}".
+
+ipuaro supports: .ts, .tsx, .js, .jsx, .json, .yaml, .yml
+
+Ensure you're running ipuaro in a project directory with source files.`,
+            }
+        }
+
+        return { ok: true, fileCount }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        return {
+            ok: false,
+            fileCount: 0,
+            warning: `Failed to scan project: ${message}`,
+        }
+    }
+}
+
+/**
+ * Run all onboarding checks.
+ */
+export async function runOnboarding(options: OnboardingOptions): Promise<OnboardingResult> {
+    const errors: string[] = []
+    const warnings: string[] = []
+    const maxFiles = options.maxFiles ?? DEFAULT_MAX_FILES
+
+    let redisOk = true
+    let ollamaOk = true
+    let modelOk = true
+    let projectOk = true
+    let fileCount = 0
+
+    if (!options.skipRedis) {
+        const redisResult = await checkRedis(options.redisConfig)
+        redisOk = redisResult.ok
+        if (!redisOk && redisResult.error) {
+            errors.push(redisResult.error)
+        }
+    }
+
+    if (!options.skipOllama) {
+        const ollamaResult = await checkOllama(options.llmConfig)
+        ollamaOk = ollamaResult.ok
+        if (!ollamaOk && ollamaResult.error) {
+            errors.push(ollamaResult.error)
+        }
+    }
+
+    if (!options.skipModel && ollamaOk) {
+        const modelResult = await checkModel(options.llmConfig)
+        modelOk = modelResult.ok
+        if (!modelOk && modelResult.error) {
+            errors.push(modelResult.error)
+        }
+    }
+
+    if (!options.skipProject) {
+        const projectResult = await checkProjectSize(options.projectPath, maxFiles)
+        projectOk = projectResult.ok
+        fileCount = projectResult.fileCount
+        if (projectResult.warning) {
+            if (projectResult.ok) {
+                warnings.push(projectResult.warning)
+            } else {
+                errors.push(projectResult.warning)
+            }
+        }
+    }
+
+    return {
+        success: redisOk && ollamaOk && modelOk && projectOk && errors.length === 0,
+        redisOk,
+        ollamaOk,
+        modelOk,
+        projectOk,
+        fileCount,
+        errors,
+        warnings,
+    }
+}

packages/ipuaro/src/cli/commands/start.ts

@@ -0,0 +1,162 @@
+/**
+ * Start command implementation.
+ * Launches the ipuaro TUI.
+ */
+
+import * as path from "node:path"
+import * as readline from "node:readline"
+import { render } from "ink"
+import React from "react"
+import { App, type AppDependencies } from "../../tui/App.js"
+import { RedisClient } from "../../infrastructure/storage/RedisClient.js"
+import { RedisStorage } from "../../infrastructure/storage/RedisStorage.js"
+import { RedisSessionStorage } from "../../infrastructure/storage/RedisSessionStorage.js"
+import { OllamaClient } from "../../infrastructure/llm/OllamaClient.js"
+import { ToolRegistry } from "../../infrastructure/tools/registry.js"
+import { generateProjectName } from "../../infrastructure/storage/schema.js"
+import { type Config, DEFAULT_CONFIG } from "../../shared/constants/config.js"
+import { checkModel, pullModel, runOnboarding } from "./onboarding.js"
+import { registerAllTools } from "./tools-setup.js"
+
+/**
+ * Options for start command.
+ */
+export interface StartOptions {
+    autoApply?: boolean
+    model?: string
+}
+
+/**
+ * Result of start command.
+ */
+export interface StartResult {
+    success: boolean
+    error?: string
+}
+
+/**
+ * Execute the start command.
+ */
+export async function executeStart(
+    projectPath: string,
+    options: StartOptions,
+    config: Config = DEFAULT_CONFIG,
+): Promise<StartResult> {
+    const resolvedPath = path.resolve(projectPath)
+    const projectName = generateProjectName(resolvedPath)
+
+    const llmConfig = {
+        ...config.llm,
+        model: options.model ?? config.llm.model,
+    }
+
+    console.warn("🔍 Running pre-flight checks...\n")
+
+    const onboardingResult = await runOnboarding({
+        redisConfig: config.redis,
+        llmConfig,
+        projectPath: resolvedPath,
+    })
+
+    for (const warning of onboardingResult.warnings) {
+        console.warn(`⚠️  ${warning}\n`)
+    }
+
+    if (!onboardingResult.success) {
+        for (const error of onboardingResult.errors) {
+            console.error(`❌ ${error}\n`)
+        }
+
+        if (!onboardingResult.modelOk && onboardingResult.ollamaOk) {
+            const shouldPull = await promptYesNo(
+                `Would you like to pull "${llmConfig.model}"? (y/n): `,
+            )
+
+            if (shouldPull) {
+                const pullResult = await pullModel(llmConfig, console.warn)
+                if (!pullResult.ok) {
+                    console.error(`❌ ${pullResult.error ?? "Unknown error"}`)
+                    return { success: false, error: pullResult.error }
+                }
+
+                const recheckModel = await checkModel(llmConfig)
+                if (!recheckModel.ok) {
+                    console.error("❌ Model still not available after pull.")
+                    return { success: false, error: "Model pull failed" }
+                }
+            } else {
+                return { success: false, error: "Model not available" }
+            }
+        } else {
+            return {
+                success: false,
+                error: onboardingResult.errors.join("\n"),
+            }
+        }
+    }
+
+    console.warn(`✅ All checks passed. Found ${String(onboardingResult.fileCount)} files.\n`)
+    console.warn("🚀 Starting ipuaro...\n")
+
+    const redisClient = new RedisClient(config.redis)
+
+    try {
+        await redisClient.connect()
+
+        const storage = new RedisStorage(redisClient, projectName)
+        const sessionStorage = new RedisSessionStorage(redisClient)
+        const llm = new OllamaClient(llmConfig)
+        const tools = new ToolRegistry()
+
+        registerAllTools(tools)
+
+        const deps: AppDependencies = {
+            storage,
+            sessionStorage,
+            llm,
+            tools,
+        }
+
+        const handleExit = (): void => {
+            void redisClient.disconnect()
+        }
+
+        const { waitUntilExit } = render(
+            React.createElement(App, {
+                projectPath: resolvedPath,
+                autoApply: options.autoApply ?? config.edit.autoApply,
+                deps,
+                onExit: handleExit,
+            }),
+        )
+
+        await waitUntilExit()
+        await redisClient.disconnect()
+
+        return { success: true }
+    } catch (error) {
+        const message = error instanceof Error ? error.message : String(error)
+        console.error(`❌ Failed to start ipuaro: ${message}`)
+        await redisClient.disconnect()
+        return { success: false, error: message }
+    }
+}
+
+/**
+ * Simple yes/no prompt for CLI.
+ */
+async function promptYesNo(question: string): Promise<boolean> {
+    return new Promise((resolve) => {
+        process.stdout.write(question)
+
+        const rl = readline.createInterface({
+            input: process.stdin,
+            output: process.stdout,
+        })
+
+        rl.once("line", (answer: string) => {
+            rl.close()
+            resolve(answer.toLowerCase() === "y" || answer.toLowerCase() === "yes")
+        })
+    })
+}

packages/ipuaro/src/cli/commands/tools-setup.ts

@@ -0,0 +1,59 @@
+/**
+ * Tool registration helper for CLI.
+ * Registers all 18 tools with the tool registry.
+ */
+
+import type { IToolRegistry } from "../../application/interfaces/IToolRegistry.js"
+
+import { GetLinesTool } from "../../infrastructure/tools/read/GetLinesTool.js"
+import { GetFunctionTool } from "../../infrastructure/tools/read/GetFunctionTool.js"
+import { GetClassTool } from "../../infrastructure/tools/read/GetClassTool.js"
+import { GetStructureTool } from "../../infrastructure/tools/read/GetStructureTool.js"
+
+import { EditLinesTool } from "../../infrastructure/tools/edit/EditLinesTool.js"
+import { CreateFileTool } from "../../infrastructure/tools/edit/CreateFileTool.js"
+import { DeleteFileTool } from "../../infrastructure/tools/edit/DeleteFileTool.js"
+
+import { FindReferencesTool } from "../../infrastructure/tools/search/FindReferencesTool.js"
+import { FindDefinitionTool } from "../../infrastructure/tools/search/FindDefinitionTool.js"
+
+import { GetDependenciesTool } from "../../infrastructure/tools/analysis/GetDependenciesTool.js"
+import { GetDependentsTool } from "../../infrastructure/tools/analysis/GetDependentsTool.js"
+import { GetComplexityTool } from "../../infrastructure/tools/analysis/GetComplexityTool.js"
+import { GetTodosTool } from "../../infrastructure/tools/analysis/GetTodosTool.js"
+
+import { GitStatusTool } from "../../infrastructure/tools/git/GitStatusTool.js"
+import { GitDiffTool } from "../../infrastructure/tools/git/GitDiffTool.js"
+import { GitCommitTool } from "../../infrastructure/tools/git/GitCommitTool.js"
+
+import { RunCommandTool } from "../../infrastructure/tools/run/RunCommandTool.js"
+import { RunTestsTool } from "../../infrastructure/tools/run/RunTestsTool.js"
+
+/**
+ * Register all 18 tools with the tool registry.
+ */
+export function registerAllTools(registry: IToolRegistry): void {
+    registry.register(new GetLinesTool())
+    registry.register(new GetFunctionTool())
+    registry.register(new GetClassTool())
+    registry.register(new GetStructureTool())
+
+    registry.register(new EditLinesTool())
+    registry.register(new CreateFileTool())
+    registry.register(new DeleteFileTool())
+
+    registry.register(new FindReferencesTool())
+    registry.register(new FindDefinitionTool())
+
+    registry.register(new GetDependenciesTool())
+    registry.register(new GetDependentsTool())
+    registry.register(new GetComplexityTool())
+    registry.register(new GetTodosTool())
+
+    registry.register(new GitStatusTool())
+    registry.register(new GitDiffTool())
+    registry.register(new GitCommitTool())
+
+    registry.register(new RunCommandTool())
+    registry.register(new RunTestsTool())
+}

packages/ipuaro/src/cli/index.ts

@@ -1,44 +1,63 @@
 #!/usr/bin/env node
 
+/**
+ * ipuaro CLI entry point.
+ * Local AI agent for codebase operations with infinite context feeling.
+ */
+
+import { createRequire } from "node:module"
 import { Command } from "commander"
+import { executeStart } from "./commands/start.js"
+import { executeInit } from "./commands/init.js"
+import { executeIndex } from "./commands/index-cmd.js"
+import { loadConfig } from "../shared/config/loader.js"
+
+const require = createRequire(import.meta.url)
+const pkg = require("../../package.json") as { version: string }
 
 const program = new Command()
 
 program
     .name("ipuaro")
     .description("Local AI agent for codebase operations with infinite context feeling")
-    .version("0.1.0")
+    .version(pkg.version)
 
 program
-    .command("start")
+    .command("start", { isDefault: true })
     .description("Start ipuaro TUI in the current directory")
     .argument("[path]", "Project path", ".")
     .option("--auto-apply", "Enable auto-apply mode for edits")
-    .option("--model <name>", "Override LLM model", "qwen2.5-coder:7b-instruct")
-    .action((path: string, options: { autoApply?: boolean; model?: string }) => {
-        const model = options.model ?? "default"
-        const autoApply = options.autoApply ?? false
-        console.warn(`Starting ipuaro in ${path}...`)
-        console.warn(`Model: ${model}`)
-        console.warn(`Auto-apply: ${autoApply ? "enabled" : "disabled"}`)
-        console.warn("\nNot implemented yet. Coming in version 0.11.0!")
+    .option("--model <name>", "Override LLM model")
+    .action(async (projectPath: string, options: { autoApply?: boolean; model?: string }) => {
+        const config = loadConfig(projectPath)
+        const result = await executeStart(projectPath, options, config)
+        if (!result.success) {
+            process.exit(1)
+        }
     })
 
 program
     .command("init")
     .description("Create .ipuaro.json config file")
-    .action(() => {
-        console.warn("Creating .ipuaro.json...")
-        console.warn("\nNot implemented yet. Coming in version 0.17.0!")
+    .argument("[path]", "Project path", ".")
+    .option("--force", "Overwrite existing config file")
+    .action(async (projectPath: string, options: { force?: boolean }) => {
+        const result = await executeInit(projectPath, options)
+        if (!result.success) {
+            process.exit(1)
+        }
     })
 
 program
     .command("index")
     .description("Index project without starting TUI")
     .argument("[path]", "Project path", ".")
-    .action((path: string) => {
-        console.warn(`Indexing ${path}...`)
-        console.warn("\nNot implemented yet. Coming in version 0.3.0!")
+    .action(async (projectPath: string) => {
+        const config = loadConfig(projectPath)
+        const result = await executeIndex(projectPath, config)
+        if (!result.success) {
+            process.exit(1)
+        }
     })
 
 program.parse()

packages/ipuaro/src/infrastructure/tools/registry.ts

@@ -16,12 +16,7 @@ export class ToolRegistry implements IToolRegistry {
      */
     register(tool: ITool): void {
         if (this.tools.has(tool.name)) {
-            throw new IpuaroError(
-                "validation",
-                `Tool "${tool.name}" is already registered`,
-                true,
-                "Use a different tool name or unregister the existing tool first",
-            )
+            throw IpuaroError.validation(`Tool "${tool.name}" is already registered`)
         }
         this.tools.set(tool.name, tool)
     }

packages/ipuaro/src/shared/errors/ErrorHandler.ts

@@ -0,0 +1,295 @@
+/**
+ * ErrorHandler service for handling errors with user interaction.
+ * Implements the error handling matrix from ROADMAP.md.
+ */
+
+import { ERROR_MATRIX, type ErrorOption, type ErrorType, IpuaroError } from "./IpuaroError.js"
+
+/**
+ * Result of error handling.
+ */
+export interface ErrorHandlingResult {
+    action: ErrorOption
+    shouldContinue: boolean
+    retryCount?: number
+}
+
+/**
+ * Callback for requesting user choice on error.
+ */
+export type ErrorChoiceCallback = (
+    error: IpuaroError,
+    availableOptions: ErrorOption[],
+    defaultOption: ErrorOption,
+) => Promise<ErrorOption>
+
+/**
+ * Options for ErrorHandler.
+ */
+export interface ErrorHandlerOptions {
+    maxRetries?: number
+    autoSkipParseErrors?: boolean
+    autoRetryLLMErrors?: boolean
+    onError?: ErrorChoiceCallback
+}
+
+const DEFAULT_MAX_RETRIES = 3
+
+/**
+ * Error handler service with matrix-based logic.
+ */
+export class ErrorHandler {
+    private readonly maxRetries: number
+    private readonly autoSkipParseErrors: boolean
+    private readonly autoRetryLLMErrors: boolean
+    private readonly onError?: ErrorChoiceCallback
+
+    private readonly retryCounters = new Map<string, number>()
+
+    constructor(options: ErrorHandlerOptions = {}) {
+        this.maxRetries = options.maxRetries ?? DEFAULT_MAX_RETRIES
+        this.autoSkipParseErrors = options.autoSkipParseErrors ?? true
+        this.autoRetryLLMErrors = options.autoRetryLLMErrors ?? false
+        this.onError = options.onError
+    }
+
+    /**
+     * Handle an error and determine the action to take.
+     */
+    async handle(error: IpuaroError, contextKey?: string): Promise<ErrorHandlingResult> {
+        const key = contextKey ?? error.message
+        const currentRetries = this.retryCounters.get(key) ?? 0
+
+        if (this.shouldAutoHandle(error)) {
+            const autoAction = this.getAutoAction(error, currentRetries)
+            if (autoAction) {
+                return this.createResult(autoAction, key, currentRetries)
+            }
+        }
+
+        if (!error.recoverable) {
+            return {
+                action: "abort",
+                shouldContinue: false,
+            }
+        }
+
+        if (this.onError) {
+            const choice = await this.onError(error, error.options, error.defaultOption)
+            return this.createResult(choice, key, currentRetries)
+        }
+
+        return this.createResult(error.defaultOption, key, currentRetries)
+    }
+
+    /**
+     * Handle an error synchronously with default behavior.
+     */
+    handleSync(error: IpuaroError, contextKey?: string): ErrorHandlingResult {
+        const key = contextKey ?? error.message
+        const currentRetries = this.retryCounters.get(key) ?? 0
+
+        if (this.shouldAutoHandle(error)) {
+            const autoAction = this.getAutoAction(error, currentRetries)
+            if (autoAction) {
+                return this.createResult(autoAction, key, currentRetries)
+            }
+        }
+
+        if (!error.recoverable) {
+            return {
+                action: "abort",
+                shouldContinue: false,
+            }
+        }
+
+        return this.createResult(error.defaultOption, key, currentRetries)
+    }
+
+    /**
+     * Reset retry counters.
+     */
+    resetRetries(contextKey?: string): void {
+        if (contextKey) {
+            this.retryCounters.delete(contextKey)
+        } else {
+            this.retryCounters.clear()
+        }
+    }
+
+    /**
+     * Get retry count for a context.
+     */
+    getRetryCount(contextKey: string): number {
+        return this.retryCounters.get(contextKey) ?? 0
+    }
+
+    /**
+     * Check if max retries exceeded for a context.
+     */
+    isMaxRetriesExceeded(contextKey: string): boolean {
+        return this.getRetryCount(contextKey) >= this.maxRetries
+    }
+
+    /**
+     * Wrap a function with error handling.
+     */
+    async wrap<T>(
+        fn: () => Promise<T>,
+        errorType: ErrorType,
+        contextKey?: string,
+    ): Promise<{ success: true; data: T } | { success: false; result: ErrorHandlingResult }> {
+        try {
+            const data = await fn()
+            if (contextKey) {
+                this.resetRetries(contextKey)
+            }
+            return { success: true, data }
+        } catch (err) {
+            const error =
+                err instanceof IpuaroError
+                    ? err
+                    : new IpuaroError(errorType, err instanceof Error ? err.message : String(err))
+
+            const result = await this.handle(error, contextKey)
+            return { success: false, result }
+        }
+    }
+
+    /**
+     * Wrap a function with retry logic.
+     */
+    async withRetry<T>(fn: () => Promise<T>, errorType: ErrorType, contextKey: string): Promise<T> {
+        const key = contextKey
+
+        while (!this.isMaxRetriesExceeded(key)) {
+            try {
+                const result = await fn()
+                this.resetRetries(key)
+                return result
+            } catch (err) {
+                const error =
+                    err instanceof IpuaroError
+                        ? err
+                        : new IpuaroError(
+                              errorType,
+                              err instanceof Error ? err.message : String(err),
+                          )
+
+                const handlingResult = await this.handle(error, key)
+
+                if (handlingResult.action !== "retry" || !handlingResult.shouldContinue) {
+                    throw error
+                }
+            }
+        }
+
+        throw new IpuaroError(
+            errorType,
+            `Max retries (${String(this.maxRetries)}) exceeded for: ${key}`,
+        )
+    }
+
+    private shouldAutoHandle(error: IpuaroError): boolean {
+        if (error.type === "parse" && this.autoSkipParseErrors) {
+            return true
+        }
+        if ((error.type === "llm" || error.type === "timeout") && this.autoRetryLLMErrors) {
+            return true
+        }
+        return false
+    }
+
+    private getAutoAction(error: IpuaroError, currentRetries: number): ErrorOption | null {
+        if (error.type === "parse" && this.autoSkipParseErrors) {
+            return "skip"
+        }
+
+        if ((error.type === "llm" || error.type === "timeout") && this.autoRetryLLMErrors) {
+            if (currentRetries < this.maxRetries) {
+                return "retry"
+            }
+            return "abort"
+        }
+
+        return null
+    }
+
+    private createResult(
+        action: ErrorOption,
+        key: string,
+        currentRetries: number,
+    ): ErrorHandlingResult {
+        if (action === "retry") {
+            this.retryCounters.set(key, currentRetries + 1)
+            const newRetryCount = currentRetries + 1
+
+            if (newRetryCount > this.maxRetries) {
+                return {
+                    action: "abort",
+                    shouldContinue: false,
+                    retryCount: newRetryCount,
+                }
+            }
+
+            return {
+                action: "retry",
+                shouldContinue: true,
+                retryCount: newRetryCount,
+            }
+        }
+
+        this.retryCounters.delete(key)
+
+        return {
+            action,
+            shouldContinue: action === "skip" || action === "confirm" || action === "regenerate",
+            retryCount: currentRetries,
+        }
+    }
+}
+
+/**
+ * Get available options for an error type.
+ */
+export function getErrorOptions(errorType: ErrorType): ErrorOption[] {
+    return ERROR_MATRIX[errorType].options
+}
+
+/**
+ * Get default option for an error type.
+ */
+export function getDefaultErrorOption(errorType: ErrorType): ErrorOption {
+    return ERROR_MATRIX[errorType].defaultOption
+}
+
+/**
+ * Check if an error type is recoverable by default.
+ */
+export function isRecoverableError(errorType: ErrorType): boolean {
+    return ERROR_MATRIX[errorType].recoverable
+}
+
+/**
+ * Convert any error to IpuaroError.
+ */
+export function toIpuaroError(error: unknown, defaultType: ErrorType = "unknown"): IpuaroError {
+    if (error instanceof IpuaroError) {
+        return error
+    }
+
+    if (error instanceof Error) {
+        return new IpuaroError(defaultType, error.message, {
+            context: { originalError: error.name },
+        })
+    }
+
+    return new IpuaroError(defaultType, String(error))
+}
+
+/**
+ * Create a default ErrorHandler instance.
+ */
+export function createErrorHandler(options?: ErrorHandlerOptions): ErrorHandler {
+    return new ErrorHandler(options)
+}

packages/ipuaro/src/shared/errors/IpuaroError.ts

@@ -12,6 +12,72 @@ export type ErrorType =
     | "timeout"
     | "unknown"
 
+/**
+ * Available options for error recovery.
+ */
+export type ErrorOption = "retry" | "skip" | "abort" | "confirm" | "regenerate"
+
+/**
+ * Error metadata with available options.
+ */
+export interface ErrorMeta {
+    type: ErrorType
+    recoverable: boolean
+    options: ErrorOption[]
+    defaultOption: ErrorOption
+}
+
+/**
+ * Error handling matrix - defines behavior for each error type.
+ */
+export const ERROR_MATRIX: Record<ErrorType, Omit<ErrorMeta, "type">> = {
+    redis: {
+        recoverable: false,
+        options: ["retry", "abort"],
+        defaultOption: "abort",
+    },
+    parse: {
+        recoverable: true,
+        options: ["skip", "abort"],
+        defaultOption: "skip",
+    },
+    llm: {
+        recoverable: true,
+        options: ["retry", "skip", "abort"],
+        defaultOption: "retry",
+    },
+    file: {
+        recoverable: true,
+        options: ["skip", "abort"],
+        defaultOption: "skip",
+    },
+    command: {
+        recoverable: true,
+        options: ["confirm", "skip", "abort"],
+        defaultOption: "confirm",
+    },
+    conflict: {
+        recoverable: true,
+        options: ["skip", "regenerate", "abort"],
+        defaultOption: "skip",
+    },
+    validation: {
+        recoverable: true,
+        options: ["skip", "abort"],
+        defaultOption: "skip",
+    },
+    timeout: {
+        recoverable: true,
+        options: ["retry", "skip", "abort"],
+        defaultOption: "retry",
+    },
+    unknown: {
+        recoverable: false,
+        options: ["abort"],
+        defaultOption: "abort",
+    },
+}
+
 /**
  * Base error class for ipuaro.
  */
@@ -19,60 +85,142 @@ export class IpuaroError extends Error {
     readonly type: ErrorType
     readonly recoverable: boolean
     readonly suggestion?: string
+    readonly options: ErrorOption[]
+    readonly defaultOption: ErrorOption
+    readonly context?: Record<string, unknown>
 
-    constructor(type: ErrorType, message: string, recoverable = true, suggestion?: string) {
+    constructor(
+        type: ErrorType,
+        message: string,
+        options?: {
+            recoverable?: boolean
+            suggestion?: string
+            context?: Record<string, unknown>
+        },
+    ) {
         super(message)
         this.name = "IpuaroError"
         this.type = type
-        this.recoverable = recoverable
-        this.suggestion = suggestion
+
+        const meta = ERROR_MATRIX[type]
+        this.recoverable = options?.recoverable ?? meta.recoverable
+        this.options = meta.options
+        this.defaultOption = meta.defaultOption
+        this.suggestion = options?.suggestion
+        this.context = options?.context
     }
 
-    static redis(message: string): IpuaroError {
-        return new IpuaroError(
-            "redis",
-            message,
-            false,
-            "Please ensure Redis is running: redis-server",
-        )
+    /**
+     * Get error metadata.
+     */
+    getMeta(): ErrorMeta {
+        return {
+            type: this.type,
+            recoverable: this.recoverable,
+            options: this.options,
+            defaultOption: this.defaultOption,
+        }
+    }
+
+    /**
+     * Check if an option is available for this error.
+     */
+    hasOption(option: ErrorOption): boolean {
+        return this.options.includes(option)
+    }
+
+    /**
+     * Create a formatted error message with suggestion.
+     */
+    toDisplayString(): string {
+        let result = `[${this.type}] ${this.message}`
+        if (this.suggestion) {
+            result += `\n  Suggestion: ${this.suggestion}`
+        }
+        return result
+    }
+
+    static redis(message: string, context?: Record<string, unknown>): IpuaroError {
+        return new IpuaroError("redis", message, {
+            suggestion: "Please ensure Redis is running: redis-server",
+            context,
+        })
     }
 
     static parse(message: string, filePath?: string): IpuaroError {
         const msg = filePath ? `${message} in ${filePath}` : message
-        return new IpuaroError("parse", msg, true, "File will be skipped")
+        return new IpuaroError("parse", msg, {
+            suggestion: "File will be skipped during indexing",
+            context: filePath ? { filePath } : undefined,
+        })
     }
 
-    static llm(message: string): IpuaroError {
-        return new IpuaroError(
-            "llm",
-            message,
-            true,
-            "Please ensure Ollama is running and model is available",
-        )
+    static llm(message: string, context?: Record<string, unknown>): IpuaroError {
+        return new IpuaroError("llm", message, {
+            suggestion: "Please ensure Ollama is running and model is available",
+            context,
+        })
     }
 
-    static file(message: string): IpuaroError {
-        return new IpuaroError("file", message, true)
+    static llmTimeout(message: string): IpuaroError {
+        return new IpuaroError("timeout", message, {
+            suggestion: "The LLM request timed out. Try again or check Ollama status.",
+        })
     }
 
-    static command(message: string): IpuaroError {
-        return new IpuaroError("command", message, true)
+    static file(message: string, filePath?: string): IpuaroError {
+        return new IpuaroError("file", message, {
+            suggestion: "Check if the file exists and you have permission to access it",
+            context: filePath ? { filePath } : undefined,
+        })
     }
 
-    static conflict(message: string): IpuaroError {
-        return new IpuaroError(
-            "conflict",
-            message,
-            true,
-            "File was modified externally. Regenerate or skip.",
-        )
+    static fileNotFound(filePath: string): IpuaroError {
+        return new IpuaroError("file", `File not found: ${filePath}`, {
+            suggestion: "Check the file path and try again",
+            context: { filePath },
+        })
     }
 
-    static validation(message: string): IpuaroError {
-        return new IpuaroError("validation", message, true)
+    static command(message: string, command?: string): IpuaroError {
+        return new IpuaroError("command", message, {
+            suggestion: "Command requires confirmation or is not in whitelist",
+            context: command ? { command } : undefined,
+        })
     }
 
-    static timeout(message: string): IpuaroError {
-        return new IpuaroError("timeout", message, true, "Try again or increase timeout")
+    static commandBlacklisted(command: string): IpuaroError {
+        return new IpuaroError("command", `Command is blacklisted: ${command}`, {
+            recoverable: false,
+            suggestion: "This command is not allowed for security reasons",
+            context: { command },
+        })
+    }
+
+    static conflict(message: string, filePath?: string): IpuaroError {
+        return new IpuaroError("conflict", message, {
+            suggestion: "File was modified externally. Regenerate or skip the change.",
+            context: filePath ? { filePath } : undefined,
+        })
+    }
+
+    static validation(message: string, field?: string): IpuaroError {
+        return new IpuaroError("validation", message, {
+            suggestion: "Please check the input and try again",
+            context: field ? { field } : undefined,
+        })
+    }
+
+    static timeout(message: string, timeoutMs?: number): IpuaroError {
+        return new IpuaroError("timeout", message, {
+            suggestion: "Try again or increase the timeout value",
+            context: timeoutMs ? { timeoutMs } : undefined,
+        })
+    }
+
+    static unknown(message: string, originalError?: Error): IpuaroError {
+        return new IpuaroError("unknown", message, {
+            context: originalError ? { originalError: originalError.message } : undefined,
+        })
     }
 }

packages/ipuaro/src/shared/errors/index.ts

@@ -1,2 +1,3 @@
 // Shared errors
 export * from "./IpuaroError.js"
+export * from "./ErrorHandler.js"

packages/ipuaro/src/shared/types/index.ts

@@ -19,9 +19,13 @@ export type ConfirmChoice = "apply" | "cancel" | "edit"
 
 /**
  * User choice for errors.
+ * @deprecated Use ErrorOption from shared/errors instead
  */
 export type ErrorChoice = "retry" | "skip" | "abort"
 
+// Re-export ErrorOption for convenience
+export type { ErrorOption } from "../errors/IpuaroError.js"
+
 /**
  * Project structure node.
  */

packages/ipuaro/src/tui/hooks/useSession.ts

@@ -10,7 +10,7 @@ import type { ISessionStorage } from "../../domain/services/ISessionStorage.js"
 import type { IStorage } from "../../domain/services/IStorage.js"
 import type { DiffInfo } from "../../domain/services/ITool.js"
 import type { ChatMessage } from "../../domain/value-objects/ChatMessage.js"
-import type { ErrorChoice } from "../../shared/types/index.js"
+import type { ErrorOption } from "../../shared/errors/IpuaroError.js"
 import type { IToolRegistry } from "../../application/interfaces/IToolRegistry.js"
 import {
     HandleMessage,
@@ -34,7 +34,7 @@ export interface UseSessionDependencies {
 export interface UseSessionOptions {
     autoApply?: boolean
     onConfirmation?: (message: string, diff?: DiffInfo) => Promise<boolean>
-    onError?: (error: Error) => Promise<ErrorChoice>
+    onError?: (error: Error) => Promise<ErrorOption>
 }
 
 export interface UseSessionReturn {

packages/ipuaro/tests/unit/cli/commands/init.test.ts

@@ -0,0 +1,117 @@
+import { describe, it, expect, vi, beforeEach, afterEach } from "vitest"
+import * as fs from "node:fs/promises"
+import * as path from "node:path"
+import { executeInit } from "../../../../src/cli/commands/init.js"
+
+vi.mock("node:fs/promises")
+
+describe("executeInit", () => {
+    const testPath = "/test/project"
+    const configPath = path.join(testPath, ".ipuaro.json")
+
+    beforeEach(() => {
+        vi.clearAllMocks()
+        vi.spyOn(console, "warn").mockImplementation(() => {})
+        vi.spyOn(console, "error").mockImplementation(() => {})
+    })
+
+    afterEach(() => {
+        vi.restoreAllMocks()
+    })
+
+    it("should create .ipuaro.json file successfully", async () => {
+        vi.mocked(fs.access).mockRejectedValue(new Error("ENOENT"))
+        vi.mocked(fs.mkdir).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockResolvedValue(undefined)
+
+        const result = await executeInit(testPath)
+
+        expect(result.success).toBe(true)
+        expect(result.filePath).toBe(configPath)
+        expect(fs.writeFile).toHaveBeenCalledWith(
+            configPath,
+            expect.stringContaining('"redis"'),
+            "utf-8",
+        )
+    })
+
+    it("should skip existing file without force option", async () => {
+        vi.mocked(fs.access).mockResolvedValue(undefined)
+
+        const result = await executeInit(testPath)
+
+        expect(result.success).toBe(true)
+        expect(result.skipped).toBe(true)
+        expect(fs.writeFile).not.toHaveBeenCalled()
+    })
+
+    it("should overwrite existing file with force option", async () => {
+        vi.mocked(fs.access).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockResolvedValue(undefined)
+
+        const result = await executeInit(testPath, { force: true })
+
+        expect(result.success).toBe(true)
+        expect(result.skipped).toBeUndefined()
+        expect(fs.writeFile).toHaveBeenCalled()
+    })
+
+    it("should handle write errors", async () => {
+        vi.mocked(fs.access).mockRejectedValue(new Error("ENOENT"))
+        vi.mocked(fs.mkdir).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockRejectedValue(new Error("Permission denied"))
+
+        const result = await executeInit(testPath)
+
+        expect(result.success).toBe(false)
+        expect(result.error).toContain("Permission denied")
+    })
+
+    it("should create parent directories if needed", async () => {
+        vi.mocked(fs.access)
+            .mockRejectedValueOnce(new Error("ENOENT"))
+            .mockRejectedValueOnce(new Error("ENOENT"))
+        vi.mocked(fs.mkdir).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockResolvedValue(undefined)
+
+        const result = await executeInit(testPath)
+
+        expect(result.success).toBe(true)
+        expect(fs.mkdir).toHaveBeenCalledWith(expect.any(String), { recursive: true })
+    })
+
+    it("should use current directory as default", async () => {
+        vi.mocked(fs.access).mockRejectedValue(new Error("ENOENT"))
+        vi.mocked(fs.mkdir).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockResolvedValue(undefined)
+
+        const result = await executeInit()
+
+        expect(result.success).toBe(true)
+        expect(result.filePath).toContain(".ipuaro.json")
+    })
+
+    it("should include expected config sections", async () => {
+        vi.mocked(fs.access).mockRejectedValue(new Error("ENOENT"))
+        vi.mocked(fs.mkdir).mockResolvedValue(undefined)
+        vi.mocked(fs.writeFile).mockResolvedValue(undefined)
+
+        await executeInit(testPath)
+
+        const writeCall = vi.mocked(fs.writeFile).mock.calls[0]
+        const content = writeCall[1] as string
+        const config = JSON.parse(content) as {
+            redis: unknown
+            llm: unknown
+            edit: unknown
+        }
+
+        expect(config).toHaveProperty("redis")
+        expect(config).toHaveProperty("llm")
+        expect(config).toHaveProperty("edit")
+        expect(config.redis).toHaveProperty("host", "localhost")
+        expect(config.redis).toHaveProperty("port", 6379)
+        expect(config.llm).toHaveProperty("model", "qwen2.5-coder:7b-instruct")
+        expect(config.edit).toHaveProperty("autoApply", false)
+    })
+})

packages/ipuaro/tests/unit/cli/commands/onboarding.test.ts

@@ -0,0 +1,353 @@
+import { describe, it, expect, vi, beforeEach, afterEach } from "vitest"
+import {
+    checkRedis,
+    checkOllama,
+    checkModel,
+    checkProjectSize,
+    runOnboarding,
+} from "../../../../src/cli/commands/onboarding.js"
+import { RedisClient } from "../../../../src/infrastructure/storage/RedisClient.js"
+import { OllamaClient } from "../../../../src/infrastructure/llm/OllamaClient.js"
+import { FileScanner } from "../../../../src/infrastructure/indexer/FileScanner.js"
+
+vi.mock("../../../../src/infrastructure/storage/RedisClient.js")
+vi.mock("../../../../src/infrastructure/llm/OllamaClient.js")
+vi.mock("../../../../src/infrastructure/indexer/FileScanner.js")
+
+describe("onboarding", () => {
+    beforeEach(() => {
+        vi.clearAllMocks()
+    })
+
+    afterEach(() => {
+        vi.restoreAllMocks()
+    })
+
+    describe("checkRedis", () => {
+        it("should return ok when Redis connects and pings successfully", async () => {
+            const mockConnect = vi.fn().mockResolvedValue(undefined)
+            const mockPing = vi.fn().mockResolvedValue(true)
+            const mockDisconnect = vi.fn().mockResolvedValue(undefined)
+
+            vi.mocked(RedisClient).mockImplementation(
+                () =>
+                    ({
+                        connect: mockConnect,
+                        ping: mockPing,
+                        disconnect: mockDisconnect,
+                    }) as unknown as RedisClient,
+            )
+
+            const result = await checkRedis({
+                host: "localhost",
+                port: 6379,
+                db: 0,
+                keyPrefix: "ipuaro:",
+            })
+
+            expect(result.ok).toBe(true)
+            expect(result.error).toBeUndefined()
+            expect(mockConnect).toHaveBeenCalled()
+            expect(mockPing).toHaveBeenCalled()
+            expect(mockDisconnect).toHaveBeenCalled()
+        })
+
+        it("should return error when Redis connection fails", async () => {
+            vi.mocked(RedisClient).mockImplementation(
+                () =>
+                    ({
+                        connect: vi.fn().mockRejectedValue(new Error("Connection refused")),
+                    }) as unknown as RedisClient,
+            )
+
+            const result = await checkRedis({
+                host: "localhost",
+                port: 6379,
+                db: 0,
+                keyPrefix: "ipuaro:",
+            })
+
+            expect(result.ok).toBe(false)
+            expect(result.error).toContain("Cannot connect to Redis")
+        })
+
+        it("should return error when ping fails", async () => {
+            vi.mocked(RedisClient).mockImplementation(
+                () =>
+                    ({
+                        connect: vi.fn().mockResolvedValue(undefined),
+                        ping: vi.fn().mockResolvedValue(false),
+                        disconnect: vi.fn().mockResolvedValue(undefined),
+                    }) as unknown as RedisClient,
+            )
+
+            const result = await checkRedis({
+                host: "localhost",
+                port: 6379,
+                db: 0,
+                keyPrefix: "ipuaro:",
+            })
+
+            expect(result.ok).toBe(false)
+            expect(result.error).toContain("Redis ping failed")
+        })
+    })
+
+    describe("checkOllama", () => {
+        it("should return ok when Ollama is available", async () => {
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        isAvailable: vi.fn().mockResolvedValue(true),
+                    }) as unknown as OllamaClient,
+            )
+
+            const result = await checkOllama({
+                model: "qwen2.5-coder:7b-instruct",
+                contextWindow: 128_000,
+                temperature: 0.1,
+                host: "http://localhost:11434",
+                timeout: 120_000,
+            })
+
+            expect(result.ok).toBe(true)
+            expect(result.error).toBeUndefined()
+        })
+
+        it("should return error when Ollama is not available", async () => {
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        isAvailable: vi.fn().mockResolvedValue(false),
+                    }) as unknown as OllamaClient,
+            )
+
+            const result = await checkOllama({
+                model: "qwen2.5-coder:7b-instruct",
+                contextWindow: 128_000,
+                temperature: 0.1,
+                host: "http://localhost:11434",
+                timeout: 120_000,
+            })
+
+            expect(result.ok).toBe(false)
+            expect(result.error).toContain("Cannot connect to Ollama")
+        })
+    })
+
+    describe("checkModel", () => {
+        it("should return ok when model is available", async () => {
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        hasModel: vi.fn().mockResolvedValue(true),
+                    }) as unknown as OllamaClient,
+            )
+
+            const result = await checkModel({
+                model: "qwen2.5-coder:7b-instruct",
+                contextWindow: 128_000,
+                temperature: 0.1,
+                host: "http://localhost:11434",
+                timeout: 120_000,
+            })
+
+            expect(result.ok).toBe(true)
+            expect(result.needsPull).toBe(false)
+        })
+
+        it("should return needsPull when model is not available", async () => {
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        hasModel: vi.fn().mockResolvedValue(false),
+                    }) as unknown as OllamaClient,
+            )
+
+            const result = await checkModel({
+                model: "qwen2.5-coder:7b-instruct",
+                contextWindow: 128_000,
+                temperature: 0.1,
+                host: "http://localhost:11434",
+                timeout: 120_000,
+            })
+
+            expect(result.ok).toBe(false)
+            expect(result.needsPull).toBe(true)
+            expect(result.error).toContain("not installed")
+        })
+    })
+
+    describe("checkProjectSize", () => {
+        it("should return ok when file count is within limits", async () => {
+            vi.mocked(FileScanner).mockImplementation(
+                () =>
+                    ({
+                        scanAll: vi.fn().mockResolvedValue(
+                            Array.from({ length: 100 }, (_, i) => ({
+                                path: `file${String(i)}.ts`,
+                                type: "file" as const,
+                                size: 1000,
+                                lastModified: Date.now(),
+                            })),
+                        ),
+                    }) as unknown as FileScanner,
+            )
+
+            const result = await checkProjectSize("/test/path")
+
+            expect(result.ok).toBe(true)
+            expect(result.fileCount).toBe(100)
+            expect(result.warning).toBeUndefined()
+        })
+
+        it("should return warning when file count exceeds limit", async () => {
+            vi.mocked(FileScanner).mockImplementation(
+                () =>
+                    ({
+                        scanAll: vi.fn().mockResolvedValue(
+                            Array.from({ length: 15000 }, (_, i) => ({
+                                path: `file${String(i)}.ts`,
+                                type: "file" as const,
+                                size: 1000,
+                                lastModified: Date.now(),
+                            })),
+                        ),
+                    }) as unknown as FileScanner,
+            )
+
+            const result = await checkProjectSize("/test/path", 10_000)
+
+            expect(result.ok).toBe(true)
+            expect(result.fileCount).toBe(15000)
+            expect(result.warning).toContain("15")
+            expect(result.warning).toContain("000 files")
+        })
+
+        it("should return error when no files found", async () => {
+            vi.mocked(FileScanner).mockImplementation(
+                () =>
+                    ({
+                        scanAll: vi.fn().mockResolvedValue([]),
+                    }) as unknown as FileScanner,
+            )
+
+            const result = await checkProjectSize("/test/path")
+
+            expect(result.ok).toBe(false)
+            expect(result.fileCount).toBe(0)
+            expect(result.warning).toContain("No supported files found")
+        })
+    })
+
+    describe("runOnboarding", () => {
+        it("should return success when all checks pass", async () => {
+            vi.mocked(RedisClient).mockImplementation(
+                () =>
+                    ({
+                        connect: vi.fn().mockResolvedValue(undefined),
+                        ping: vi.fn().mockResolvedValue(true),
+                        disconnect: vi.fn().mockResolvedValue(undefined),
+                    }) as unknown as RedisClient,
+            )
+
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        isAvailable: vi.fn().mockResolvedValue(true),
+                        hasModel: vi.fn().mockResolvedValue(true),
+                    }) as unknown as OllamaClient,
+            )
+
+            vi.mocked(FileScanner).mockImplementation(
+                () =>
+                    ({
+                        scanAll: vi.fn().mockResolvedValue([{ path: "file.ts" }]),
+                    }) as unknown as FileScanner,
+            )
+
+            const result = await runOnboarding({
+                redisConfig: { host: "localhost", port: 6379, db: 0, keyPrefix: "ipuaro:" },
+                llmConfig: {
+                    model: "test",
+                    contextWindow: 128_000,
+                    temperature: 0.1,
+                    host: "http://localhost:11434",
+                    timeout: 120_000,
+                },
+                projectPath: "/test/path",
+            })
+
+            expect(result.success).toBe(true)
+            expect(result.redisOk).toBe(true)
+            expect(result.ollamaOk).toBe(true)
+            expect(result.modelOk).toBe(true)
+            expect(result.projectOk).toBe(true)
+            expect(result.errors).toHaveLength(0)
+        })
+
+        it("should return failure when Redis fails", async () => {
+            vi.mocked(RedisClient).mockImplementation(
+                () =>
+                    ({
+                        connect: vi.fn().mockRejectedValue(new Error("Connection refused")),
+                    }) as unknown as RedisClient,
+            )
+
+            vi.mocked(OllamaClient).mockImplementation(
+                () =>
+                    ({
+                        isAvailable: vi.fn().mockResolvedValue(true),
+                        hasModel: vi.fn().mockResolvedValue(true),
+                    }) as unknown as OllamaClient,
+            )
+
+            vi.mocked(FileScanner).mockImplementation(
+                () =>
+                    ({
+                        scanAll: vi.fn().mockResolvedValue([{ path: "file.ts" }]),
+                    }) as unknown as FileScanner,
+            )
+
+            const result = await runOnboarding({
+                redisConfig: { host: "localhost", port: 6379, db: 0, keyPrefix: "ipuaro:" },
+                llmConfig: {
+                    model: "test",
+                    contextWindow: 128_000,
+                    temperature: 0.1,
+                    host: "http://localhost:11434",
+                    timeout: 120_000,
+                },
+                projectPath: "/test/path",
+            })
+
+            expect(result.success).toBe(false)
+            expect(result.redisOk).toBe(false)
+            expect(result.errors.length).toBeGreaterThan(0)
+        })
+
+        it("should skip checks when skip options are set", async () => {
+            const result = await runOnboarding({
+                redisConfig: { host: "localhost", port: 6379, db: 0, keyPrefix: "ipuaro:" },
+                llmConfig: {
+                    model: "test",
+                    contextWindow: 128_000,
+                    temperature: 0.1,
+                    host: "http://localhost:11434",
+                    timeout: 120_000,
+                },
+                projectPath: "/test/path",
+                skipRedis: true,
+                skipOllama: true,
+                skipModel: true,
+                skipProject: true,
+            })
+
+            expect(result.success).toBe(true)
+            expect(result.redisOk).toBe(true)
+            expect(result.ollamaOk).toBe(true)
+            expect(result.modelOk).toBe(true)
+            expect(result.projectOk).toBe(true)
+        })
+    })
+})

packages/ipuaro/tests/unit/cli/commands/tools-setup.test.ts

@@ -0,0 +1,111 @@
+import { describe, it, expect } from "vitest"
+import { registerAllTools } from "../../../../src/cli/commands/tools-setup.js"
+import { ToolRegistry } from "../../../../src/infrastructure/tools/registry.js"
+
+describe("registerAllTools", () => {
+    it("should register all 18 tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.size).toBe(18)
+    })
+
+    it("should register all read tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("get_lines")).toBe(true)
+        expect(registry.has("get_function")).toBe(true)
+        expect(registry.has("get_class")).toBe(true)
+        expect(registry.has("get_structure")).toBe(true)
+    })
+
+    it("should register all edit tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("edit_lines")).toBe(true)
+        expect(registry.has("create_file")).toBe(true)
+        expect(registry.has("delete_file")).toBe(true)
+    })
+
+    it("should register all search tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("find_references")).toBe(true)
+        expect(registry.has("find_definition")).toBe(true)
+    })
+
+    it("should register all analysis tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("get_dependencies")).toBe(true)
+        expect(registry.has("get_dependents")).toBe(true)
+        expect(registry.has("get_complexity")).toBe(true)
+        expect(registry.has("get_todos")).toBe(true)
+    })
+
+    it("should register all git tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("git_status")).toBe(true)
+        expect(registry.has("git_diff")).toBe(true)
+        expect(registry.has("git_commit")).toBe(true)
+    })
+
+    it("should register all run tools", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        expect(registry.has("run_command")).toBe(true)
+        expect(registry.has("run_tests")).toBe(true)
+    })
+
+    it("should register tools with correct categories", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        const readTools = registry.getByCategory("read")
+        const editTools = registry.getByCategory("edit")
+        const searchTools = registry.getByCategory("search")
+        const analysisTools = registry.getByCategory("analysis")
+        const gitTools = registry.getByCategory("git")
+        const runTools = registry.getByCategory("run")
+
+        expect(readTools.length).toBe(4)
+        expect(editTools.length).toBe(3)
+        expect(searchTools.length).toBe(2)
+        expect(analysisTools.length).toBe(4)
+        expect(gitTools.length).toBe(3)
+        expect(runTools.length).toBe(2)
+    })
+
+    it("should register tools with requiresConfirmation flag", () => {
+        const registry = new ToolRegistry()
+
+        registerAllTools(registry)
+
+        const confirmationTools = registry.getConfirmationTools()
+        const safeTools = registry.getSafeTools()
+
+        expect(confirmationTools.length).toBeGreaterThan(0)
+        expect(safeTools.length).toBeGreaterThan(0)
+
+        const confirmNames = confirmationTools.map((t) => t.name)
+        expect(confirmNames).toContain("edit_lines")
+        expect(confirmNames).toContain("create_file")
+        expect(confirmNames).toContain("delete_file")
+        expect(confirmNames).toContain("git_commit")
+    })
+})

packages/ipuaro/tests/unit/shared/errors/ErrorHandler.test.ts

@@ -0,0 +1,327 @@
+import { describe, it, expect, vi, beforeEach } from "vitest"
+import {
+    createErrorHandler,
+    ErrorHandler,
+    getDefaultErrorOption,
+    getErrorOptions,
+    isRecoverableError,
+    toIpuaroError,
+} from "../../../../src/shared/errors/ErrorHandler.js"
+import { IpuaroError } from "../../../../src/shared/errors/IpuaroError.js"
+
+describe("ErrorHandler", () => {
+    let handler: ErrorHandler
+
+    beforeEach(() => {
+        handler = new ErrorHandler()
+    })
+
+    describe("handle", () => {
+        it("should abort non-recoverable errors", async () => {
+            const error = IpuaroError.redis("Connection failed")
+
+            const result = await handler.handle(error)
+
+            expect(result.action).toBe("abort")
+            expect(result.shouldContinue).toBe(false)
+        })
+
+        it("should use default option for recoverable errors without callback", async () => {
+            const error = IpuaroError.llm("Timeout")
+
+            const result = await handler.handle(error)
+
+            expect(result.action).toBe("retry")
+            expect(result.shouldContinue).toBe(true)
+        })
+
+        it("should call onError callback when provided", async () => {
+            const onError = vi.fn().mockResolvedValue("skip")
+            const handler = new ErrorHandler({ onError })
+            const error = IpuaroError.llm("Timeout")
+
+            const result = await handler.handle(error)
+
+            expect(onError).toHaveBeenCalledWith(error, error.options, error.defaultOption)
+            expect(result.action).toBe("skip")
+        })
+
+        it("should auto-skip parse errors when enabled", async () => {
+            const handler = new ErrorHandler({ autoSkipParseErrors: true })
+            const error = IpuaroError.parse("Syntax error")
+
+            const result = await handler.handle(error)
+
+            expect(result.action).toBe("skip")
+            expect(result.shouldContinue).toBe(true)
+        })
+
+        it("should auto-retry LLM errors when enabled", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true })
+            const error = IpuaroError.llm("Timeout")
+
+            const result = await handler.handle(error, "test-key")
+
+            expect(result.action).toBe("retry")
+            expect(result.shouldContinue).toBe(true)
+            expect(result.retryCount).toBe(1)
+        })
+
+        it("should track retry count", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "test-key")
+            await handler.handle(error, "test-key")
+            const result = await handler.handle(error, "test-key")
+
+            expect(result.retryCount).toBe(3)
+        })
+
+        it("should abort after max retries", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true, maxRetries: 2 })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "test-key")
+            await handler.handle(error, "test-key")
+            const result = await handler.handle(error, "test-key")
+
+            expect(result.action).toBe("abort")
+            expect(result.shouldContinue).toBe(false)
+        })
+    })
+
+    describe("handleSync", () => {
+        it("should abort non-recoverable errors", () => {
+            const error = IpuaroError.redis("Connection failed")
+
+            const result = handler.handleSync(error)
+
+            expect(result.action).toBe("abort")
+            expect(result.shouldContinue).toBe(false)
+        })
+
+        it("should use default option for recoverable errors", () => {
+            const error = IpuaroError.file("Not found")
+
+            const result = handler.handleSync(error)
+
+            expect(result.action).toBe("skip")
+            expect(result.shouldContinue).toBe(true)
+        })
+    })
+
+    describe("resetRetries", () => {
+        it("should reset specific context", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "key1")
+            await handler.handle(error, "key1")
+            handler.resetRetries("key1")
+
+            expect(handler.getRetryCount("key1")).toBe(0)
+        })
+
+        it("should reset all contexts when no key provided", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "key1")
+            await handler.handle(error, "key2")
+            handler.resetRetries()
+
+            expect(handler.getRetryCount("key1")).toBe(0)
+            expect(handler.getRetryCount("key2")).toBe(0)
+        })
+    })
+
+    describe("getRetryCount", () => {
+        it("should return 0 for unknown context", () => {
+            expect(handler.getRetryCount("unknown")).toBe(0)
+        })
+    })
+
+    describe("isMaxRetriesExceeded", () => {
+        it("should return false when retries not exceeded", () => {
+            expect(handler.isMaxRetriesExceeded("test")).toBe(false)
+        })
+
+        it("should return true when retries exceeded", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true, maxRetries: 1 })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "test")
+
+            expect(handler.isMaxRetriesExceeded("test")).toBe(true)
+        })
+    })
+
+    describe("wrap", () => {
+        it("should return success result on success", async () => {
+            const fn = vi.fn().mockResolvedValue("result")
+
+            const result = await handler.wrap(fn, "llm")
+
+            expect(result.success).toBe(true)
+            if (result.success) {
+                expect(result.data).toBe("result")
+            }
+        })
+
+        it("should return error result on failure", async () => {
+            const fn = vi.fn().mockRejectedValue(new Error("Failed"))
+
+            const result = await handler.wrap(fn, "llm")
+
+            expect(result.success).toBe(false)
+            if (!result.success) {
+                expect(result.result.action).toBe("retry")
+            }
+        })
+
+        it("should handle IpuaroError directly", async () => {
+            const fn = vi.fn().mockRejectedValue(IpuaroError.file("Not found"))
+
+            const result = await handler.wrap(fn, "llm")
+
+            expect(result.success).toBe(false)
+            if (!result.success) {
+                expect(result.result.action).toBe("skip")
+            }
+        })
+
+        it("should reset retries on success", async () => {
+            const handler = new ErrorHandler({ autoRetryLLMErrors: true })
+            const error = IpuaroError.llm("Timeout")
+
+            await handler.handle(error, "test-key")
+            await handler.wrap(() => Promise.resolve("ok"), "llm", "test-key")
+
+            expect(handler.getRetryCount("test-key")).toBe(0)
+        })
+    })
+
+    describe("withRetry", () => {
+        it("should return result on success", async () => {
+            const fn = vi.fn().mockResolvedValue("result")
+
+            const result = await handler.withRetry(fn, "llm", "test")
+
+            expect(result).toBe("result")
+        })
+
+        it("should retry on failure", async () => {
+            const fn = vi
+                .fn()
+                .mockRejectedValueOnce(new Error("Fail 1"))
+                .mockResolvedValueOnce("success")
+            const handler = new ErrorHandler({
+                onError: vi.fn().mockResolvedValue("retry"),
+            })
+
+            const result = await handler.withRetry(fn, "llm", "test")
+
+            expect(result).toBe("success")
+            expect(fn).toHaveBeenCalledTimes(2)
+        })
+
+        it("should throw after max retries", async () => {
+            const fn = vi.fn().mockRejectedValue(new Error("Always fails"))
+            const handler = new ErrorHandler({
+                maxRetries: 2,
+                onError: vi.fn().mockResolvedValue("retry"),
+            })
+
+            await expect(handler.withRetry(fn, "llm", "test")).rejects.toThrow("Max retries")
+        })
+
+        it("should throw immediately when skip is chosen", async () => {
+            const fn = vi.fn().mockRejectedValue(new Error("Fail"))
+            const handler = new ErrorHandler({
+                onError: vi.fn().mockResolvedValue("skip"),
+            })
+
+            await expect(handler.withRetry(fn, "llm", "test")).rejects.toThrow("Fail")
+        })
+    })
+})
+
+describe("utility functions", () => {
+    describe("getErrorOptions", () => {
+        it("should return options for error type", () => {
+            const options = getErrorOptions("llm")
+
+            expect(options).toEqual(["retry", "skip", "abort"])
+        })
+    })
+
+    describe("getDefaultErrorOption", () => {
+        it("should return default option for error type", () => {
+            expect(getDefaultErrorOption("llm")).toBe("retry")
+            expect(getDefaultErrorOption("parse")).toBe("skip")
+            expect(getDefaultErrorOption("redis")).toBe("abort")
+        })
+    })
+
+    describe("isRecoverableError", () => {
+        it("should return true for recoverable errors", () => {
+            expect(isRecoverableError("llm")).toBe(true)
+            expect(isRecoverableError("parse")).toBe(true)
+            expect(isRecoverableError("file")).toBe(true)
+        })
+
+        it("should return false for non-recoverable errors", () => {
+            expect(isRecoverableError("redis")).toBe(false)
+            expect(isRecoverableError("unknown")).toBe(false)
+        })
+    })
+
+    describe("toIpuaroError", () => {
+        it("should return IpuaroError as-is", () => {
+            const error = IpuaroError.llm("Timeout")
+
+            const result = toIpuaroError(error)
+
+            expect(result).toBe(error)
+        })
+
+        it("should convert Error to IpuaroError", () => {
+            const error = new Error("Something went wrong")
+
+            const result = toIpuaroError(error, "llm")
+
+            expect(result).toBeInstanceOf(IpuaroError)
+            expect(result.type).toBe("llm")
+            expect(result.message).toBe("Something went wrong")
+        })
+
+        it("should convert string to IpuaroError", () => {
+            const result = toIpuaroError("Error message", "file")
+
+            expect(result).toBeInstanceOf(IpuaroError)
+            expect(result.type).toBe("file")
+            expect(result.message).toBe("Error message")
+        })
+
+        it("should use unknown type by default", () => {
+            const result = toIpuaroError("Error")
+
+            expect(result.type).toBe("unknown")
+        })
+    })
+
+    describe("createErrorHandler", () => {
+        it("should create handler with default options", () => {
+            const handler = createErrorHandler()
+
+            expect(handler).toBeInstanceOf(ErrorHandler)
+        })
+
+        it("should create handler with custom options", () => {
+            const handler = createErrorHandler({ maxRetries: 5 })
+
+            expect(handler).toBeInstanceOf(ErrorHandler)
+        })
+    })
+})

packages/ipuaro/tests/unit/shared/errors/IpuaroError.test.ts

@@ -1,22 +1,93 @@
 import { describe, it, expect } from "vitest"
-import { IpuaroError } from "../../../../src/shared/errors/IpuaroError.js"
+import { ERROR_MATRIX, IpuaroError } from "../../../../src/shared/errors/IpuaroError.js"
 
 describe("IpuaroError", () => {
     describe("constructor", () => {
         it("should create error with all fields", () => {
-            const error = new IpuaroError("file", "Not found", true, "Check path")
+            const error = new IpuaroError("file", "Not found", {
+                suggestion: "Check path",
+                context: { filePath: "/test.ts" },
+            })
 
             expect(error.name).toBe("IpuaroError")
             expect(error.type).toBe("file")
             expect(error.message).toBe("Not found")
             expect(error.recoverable).toBe(true)
             expect(error.suggestion).toBe("Check path")
+            expect(error.context).toEqual({ filePath: "/test.ts" })
         })
 
-        it("should default recoverable to true", () => {
-            const error = new IpuaroError("parse", "Parse failed")
+        it("should use matrix defaults for recoverable", () => {
+            const redisError = new IpuaroError("redis", "Connection failed")
+            const parseError = new IpuaroError("parse", "Parse failed")
 
-            expect(error.recoverable).toBe(true)
+            expect(redisError.recoverable).toBe(false)
+            expect(parseError.recoverable).toBe(true)
+        })
+
+        it("should allow overriding recoverable", () => {
+            const error = new IpuaroError("command", "Blacklisted", {
+                recoverable: false,
+            })
+
+            expect(error.recoverable).toBe(false)
+        })
+
+        it("should have options from matrix", () => {
+            const error = new IpuaroError("llm", "Timeout")
+
+            expect(error.options).toEqual(["retry", "skip", "abort"])
+            expect(error.defaultOption).toBe("retry")
+        })
+    })
+
+    describe("getMeta", () => {
+        it("should return error metadata", () => {
+            const error = IpuaroError.conflict("File changed")
+
+            const meta = error.getMeta()
+
+            expect(meta.type).toBe("conflict")
+            expect(meta.recoverable).toBe(true)
+            expect(meta.options).toEqual(["skip", "regenerate", "abort"])
+            expect(meta.defaultOption).toBe("skip")
+        })
+    })
+
+    describe("hasOption", () => {
+        it("should return true for available option", () => {
+            const error = IpuaroError.llm("Timeout")
+
+            expect(error.hasOption("retry")).toBe(true)
+            expect(error.hasOption("skip")).toBe(true)
+            expect(error.hasOption("abort")).toBe(true)
+        })
+
+        it("should return false for unavailable option", () => {
+            const error = IpuaroError.parse("Syntax error")
+
+            expect(error.hasOption("retry")).toBe(false)
+            expect(error.hasOption("regenerate")).toBe(false)
+        })
+    })
+
+    describe("toDisplayString", () => {
+        it("should format error with suggestion", () => {
+            const error = IpuaroError.redis("Connection refused")
+
+            const display = error.toDisplayString()
+
+            expect(display).toContain("[redis]")
+            expect(display).toContain("Connection refused")
+            expect(display).toContain("Suggestion:")
+        })
+
+        it("should format error without suggestion", () => {
+            const error = new IpuaroError("unknown", "Something went wrong")
+
+            const display = error.toDisplayString()
+
+            expect(display).toBe("[unknown] Something went wrong")
         })
     })
 
@@ -27,6 +98,13 @@ describe("IpuaroError", () => {
             expect(error.type).toBe("redis")
             expect(error.recoverable).toBe(false)
             expect(error.suggestion).toContain("Redis")
+            expect(error.options).toEqual(["retry", "abort"])
+        })
+
+        it("should create redis error with context", () => {
+            const error = IpuaroError.redis("Connection failed", { host: "localhost" })
+
+            expect(error.context).toEqual({ host: "localhost" })
         })
 
         it("should create parse error", () => {
@@ -35,12 +113,14 @@ describe("IpuaroError", () => {
             expect(error.type).toBe("parse")
             expect(error.message).toContain("test.ts")
             expect(error.recoverable).toBe(true)
+            expect(error.context).toEqual({ filePath: "test.ts" })
         })
 
         it("should create parse error without file", () => {
             const error = IpuaroError.parse("Syntax error")
 
             expect(error.message).toBe("Syntax error")
+            expect(error.context).toBeUndefined()
         })
 
         it("should create llm error", () => {
@@ -51,36 +131,113 @@ describe("IpuaroError", () => {
             expect(error.suggestion).toContain("Ollama")
         })
 
+        it("should create llmTimeout error", () => {
+            const error = IpuaroError.llmTimeout("Request timed out")
+
+            expect(error.type).toBe("timeout")
+            expect(error.suggestion).toContain("timed out")
+        })
+
         it("should create file error", () => {
-            const error = IpuaroError.file("Not found")
+            const error = IpuaroError.file("Not found", "/path/to/file.ts")
 
             expect(error.type).toBe("file")
+            expect(error.context).toEqual({ filePath: "/path/to/file.ts" })
+        })
+
+        it("should create fileNotFound error", () => {
+            const error = IpuaroError.fileNotFound("/path/to/file.ts")
+
+            expect(error.type).toBe("file")
+            expect(error.message).toContain("/path/to/file.ts")
+            expect(error.context).toEqual({ filePath: "/path/to/file.ts" })
         })
 
         it("should create command error", () => {
-            const error = IpuaroError.command("Blacklisted")
+            const error = IpuaroError.command("Not in whitelist", "rm -rf /")
 
             expect(error.type).toBe("command")
+            expect(error.context).toEqual({ command: "rm -rf /" })
+        })
+
+        it("should create commandBlacklisted error", () => {
+            const error = IpuaroError.commandBlacklisted("rm -rf /")
+
+            expect(error.type).toBe("command")
+            expect(error.recoverable).toBe(false)
+            expect(error.message).toContain("blacklisted")
         })
 
         it("should create conflict error", () => {
-            const error = IpuaroError.conflict("File changed")
+            const error = IpuaroError.conflict("File changed", "test.ts")
 
             expect(error.type).toBe("conflict")
             expect(error.suggestion).toContain("Regenerate")
+            expect(error.context).toEqual({ filePath: "test.ts" })
         })
 
         it("should create validation error", () => {
-            const error = IpuaroError.validation("Invalid param")
+            const error = IpuaroError.validation("Invalid param", "name")
 
             expect(error.type).toBe("validation")
+            expect(error.context).toEqual({ field: "name" })
         })
 
         it("should create timeout error", () => {
-            const error = IpuaroError.timeout("Request timeout")
+            const error = IpuaroError.timeout("Request timeout", 5000)
 
             expect(error.type).toBe("timeout")
             expect(error.suggestion).toContain("timeout")
+            expect(error.context).toEqual({ timeoutMs: 5000 })
+        })
+
+        it("should create unknown error", () => {
+            const original = new Error("Something broke")
+            const error = IpuaroError.unknown("Unknown error", original)
+
+            expect(error.type).toBe("unknown")
+            expect(error.recoverable).toBe(false)
+            expect(error.context).toEqual({ originalError: "Something broke" })
+        })
+    })
+
+    describe("ERROR_MATRIX", () => {
+        it("should have all error types defined", () => {
+            const types = [
+                "redis",
+                "parse",
+                "llm",
+                "file",
+                "command",
+                "conflict",
+                "validation",
+                "timeout",
+                "unknown",
+            ]
+
+            for (const type of types) {
+                expect(ERROR_MATRIX[type as keyof typeof ERROR_MATRIX]).toBeDefined()
+            }
+        })
+
+        it("should have correct non-recoverable errors", () => {
+            expect(ERROR_MATRIX.redis.recoverable).toBe(false)
+            expect(ERROR_MATRIX.unknown.recoverable).toBe(false)
+        })
+
+        it("should have correct recoverable errors", () => {
+            expect(ERROR_MATRIX.parse.recoverable).toBe(true)
+            expect(ERROR_MATRIX.llm.recoverable).toBe(true)
+            expect(ERROR_MATRIX.file.recoverable).toBe(true)
+            expect(ERROR_MATRIX.command.recoverable).toBe(true)
+            expect(ERROR_MATRIX.conflict.recoverable).toBe(true)
+            expect(ERROR_MATRIX.timeout.recoverable).toBe(true)
+        })
+
+        it("should have abort option for all error types", () => {
+            for (const config of Object.values(ERROR_MATRIX)) {
+                expect(config.options).toContain("abort")
+            }
         })
     })
 })

packages/ipuaro/vitest.config.ts

@@ -15,6 +15,7 @@ export default defineConfig({
                 "src/**/*.test.ts",
                 "src/tui/**/*.ts",
                 "src/tui/**/*.tsx",
+                "src/cli/**/*.ts",
             ],
             thresholds: {
                 lines: 95,