roxid 0.1.2

A Terminal User Interface (TUI) for managing and executing YAML-based pipelines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
# Roxid

A Terminal User Interface (TUI) application built with [Ratatui](https://ratatui.rs/) for managing and executing YAML-based pipelines.

## Table of Contents

- [Features]#features
- [Quick Start]#quick-start
- [Installation]#installation
- [Usage]#usage
- [Architecture]#architecture
- [Pipeline System]#pipeline-system
- [TUI Guide]#tui-guide
- [Extending the Application]#extending-the-application
- [Project Structure]#project-structure
- [Resources]#resources

## Features

### TUI Features
- **Pipeline Discovery**: Automatically discovers pipeline YAML files in the current directory
- **Interactive Selection**: Navigate through available pipelines with keyboard controls
- **Real-time Execution**: Execute pipelines with live progress tracking
- **Progress Visualization**: Visual progress bar showing current step
- **Live Output**: Real-time output display during pipeline execution
- **Error Handling**: Uses color-eyre for better error reporting
- **Cross-platform**: Works on Linux, macOS, and Windows

### Pipeline Features
- **YAML-based pipeline definitions**: Simple, declarative syntax
- **Command and shell script execution**: Run single commands or multi-line scripts
- **Environment variable support**: Pipeline-level and step-level env vars
- **Real-time progress reporting**: Live updates via async channels
- **Error handling**: Continue on error support for non-critical steps

## Quick Start

### 1. Build the Project
```bash
cd /path/to/roxid
cargo build
```

### 2. Run the TUI
```bash
cargo run --bin roxid-tui
```

### 3. Navigate and Execute
- Use **** and **** arrow keys (or **k**/**j**) to select a pipeline
- Press **Enter** to execute the selected pipeline
- Watch the progress bar and live output
- Press **q** or **Esc** to return to the list after completion

## Installation

### Option 1: From crates.io (Recommended)

```bash
cargo install roxid
roxid
```

### Option 2: Pre-built Binary

Download from [Releases](https://github.com/yourusername/roxid/releases/latest):
- **Linux x86_64**: `roxid-linux-x86_64.tar.gz`
- **macOS Intel**: `roxid-macos-x86_64.tar.gz`
- **macOS Apple Silicon**: `roxid-macos-aarch64.tar.gz`
- **Windows**: `roxid-windows-x86_64.exe.zip`

**Linux/macOS:**
```bash
tar xzf roxid-*.tar.gz
sudo mv roxid-* /usr/local/bin/roxid
chmod +x /usr/local/bin/roxid
```

**Windows:** Extract ZIP and add to PATH.

### Option 3: From Git

```bash
cargo install --git https://github.com/yourusername/roxid
```

### Option 4: Build from Source

```bash
git clone https://github.com/yourusername/roxid
cd roxid
cargo build --release
sudo cp target/release/roxid /usr/local/bin/
```

### Verify

```bash
roxid --help
```

### Uninstall

```bash
# If installed via cargo:
cargo uninstall roxid

# If installed manually:
sudo rm /usr/local/bin/roxid
```

## Usage

### Interactive TUI

Run the TUI application to browse and execute pipelines:

```bash
cd /path/to/your/pipelines
cargo run --bin roxid-tui
```

The TUI will discover all `.yaml` and `.yml` files in the current directory and display them as available pipelines.

### Keyboard Controls

**Pipeline List Screen:**
- `` or `k` - Move selection up
- `` or `j` - Move selection down
- `Enter` - Execute selected pipeline
- `q` or `Esc` - Quit application

**Pipeline Execution Screen:**
- `q` or `Esc` - Return to pipeline list (only after completion)

### Pipeline Execution

You can also execute pipelines directly via CLI:

```bash
# Run example pipeline
cargo run --bin roxid-cli run example-pipeline.yaml

# Run Rust build pipeline
cargo run --bin roxid-cli run rust-build-pipeline.yaml
```

## Architecture

### Workspace Structure

This workspace follows a typical Rust project structure with separation of concerns:

```
roxid/
├── Cargo.toml              # Workspace manifest
├── roxid-tui/              # Terminal UI application (binary)
│   ├── Cargo.toml
│   └── src/
│       ├── main.rs         # Entry point
│       ├── app.rs          # Application state and logic
│       ├── events.rs       # Event handling (keyboard, mouse)
│       └── ui/             # UI rendering modules
│           ├── mod.rs
│           ├── components.rs  # Reusable UI components
│           └── layout.rs      # Layout definitions
├── pipeline-service/       # Business logic layer (library)
│   ├── Cargo.toml
│   └── src/
│       ├── lib.rs          # Library entry point
│       ├── error.rs        # Error types
│       ├── models/         # Data models
│       ├── pipeline/       # Pipeline execution system
│       └── services/       # Business logic
├── pipeline-rpc/           # RPC API layer (library)
│   ├── Cargo.toml
│   └── src/
│       ├── lib.rs          # Library entry point
│       ├── api.rs          # RPC server setup
│       └── handlers/       # RPC request handlers
└── roxid-cli/              # CLI application (binary)
    ├── Cargo.toml
    └── src/
        └── main.rs         # CLI entry point
```

### Architecture Layers

#### 1. **Service Package** (`pipeline-service/`)
- **Purpose**: Core business logic
- **Type**: Library crate
- **Dependencies**: None (pure business logic)
- **Structure**:
  - `models/`: Data structures and domain models
  - `pipeline/`: Pipeline execution system
  - `services/`: Business logic implementations
  - `error.rs`: Domain-specific error types

#### 2. **RPC Package** (`pipeline-rpc/`)
- **Purpose**: Remote procedure call API layer
- **Type**: Library crate
- **Dependencies**: Depends on `pipeline-service`
- **Structure**:
  - `api.rs`: RPC server setup
  - `handlers/`: Request handlers that call service layer (PipelineHandler, UserHandler)
  - `error.rs`: RPC-specific error handling
- **Responsibilities**: Provides the API interface that clients use to interact with the service layer

#### 3. **TUI Package** (`roxid-tui/`)
- **Purpose**: Terminal user interface
- **Type**: Binary crate (executable)
- **Dependencies**: Depends only on `pipeline-rpc`
- **Structure**:
  - `main.rs`: Application entry point
  - `app.rs`: Application state management
  - `events.rs`: User input handling
  - `ui/`: All rendering logic separated by concern

#### 4. **CLI Package** (`roxid-cli/`)
- **Purpose**: Command-line interface
- **Type**: Binary crate (executable)
- **Dependencies**: Depends only on `pipeline-rpc`
- **Structure**:
  - `main.rs`: CLI entry point with command parsing

### Dependency Direction
```
roxid-tui → pipeline-rpc → pipeline-service
roxid-cli → pipeline-rpc → pipeline-service
```

**Key Architectural Principle**: Both client applications (TUI and CLI) communicate with the service layer exclusively through the RPC API. This ensures:
- Clean separation between presentation and business logic
- Consistent API interface for all clients
- Easy addition of new clients (web, mobile, etc.) without modifying service code
- Centralized API logic in the RPC layer

### TUI Application Flow

1. **Pipeline List State**: 
   - Discovers and displays available pipeline YAML files
   - User navigates with arrow keys and selects with Enter
   
2. **Pipeline Execution State**:
   - Executes selected pipeline asynchronously via RPC handler
   - Displays real-time progress bar (current step / total steps)
   - Streams output to the terminal as it's generated
   - Shows completion status (success/failure)

3. **Event Loop**: The main loop continuously:
   - Draws the UI based on current state
   - Handles keyboard events with non-blocking polling
   - Updates state based on execution events
   
4. **RPC Communication**: 
   - TUI uses `PipelineHandler` from pipeline-rpc to interact with pipelines
   - All service operations go through the RPC layer
   - Uses async channels for progress updates and output streaming
   - No direct dependency on pipeline-service

### State Machine
```
┌─────────────────┐
│ PipelineList    │
│ - Discover YAML │
│ - Navigate      │
│ - Select        │
└────────┬────────┘
         │ Enter
┌─────────────────┐
│ ExecutingPipe   │
│ - Run pipeline  │
│ - Show progress │
│ - Stream output │
└────────┬────────┘
         │ Complete
┌─────────────────┐
│ PipelineList    │
│ (return)        │
└─────────────────┘
```

### Components

- **App State Machine**: Manages transitions between PipelineList and ExecutingPipeline states
- **Event Handler**: Non-blocking event processing with state-aware key bindings
- **UI Rendering**: Modular components for pipeline list, progress bar, and output display
- **Pipeline Executor**: Async execution with progress events streamed via channels

## Pipeline System

### Pipeline YAML Format

```yaml
name: my-pipeline
description: Optional description
env:
  GLOBAL_VAR: value

steps:
  - name: Step name
    command: echo "Hello World"
    
  - name: Multi-line script
    shell:
      script: |
        echo "Line 1"
        echo "Line 2"
    env:
      STEP_VAR: value
    continue_on_error: true
```

### Creating a Pipeline

Create a file ending in `.yaml` or `.yml`:

```yaml
name: my-first-pipeline
description: My first custom pipeline
steps:
  - name: Hello World
    command: echo "Hello from my pipeline!"
  
  - name: Show Date
    command: date
  
  - name: List Files
    command: ls -la
```

### Basic Usage Example

```rust
use pipeline_rpc::{PipelineHandler, ExecutionEvent};
use color_eyre::Result;

#[tokio::main]
async fn main() -> Result<()> {
    // Create RPC handler
    let handler = PipelineHandler::new();
    
    // Parse pipeline from file
    let pipeline = handler.parse_from_file("pipeline.yaml")?;
    
    // Get working directory
    let working_dir = std::env::current_dir()?.to_string_lossy().to_string();
    
    // Execute pipeline through RPC layer
    handler.execute_pipeline(pipeline, working_dir, None).await?;
    
    Ok(())
}
```

### With Progress Reporting

```rust
use pipeline_rpc::{PipelineHandler, ExecutionEvent};

// Create event channel
let (tx, mut rx) = PipelineHandler::create_event_channel();

// Create handler and parse pipeline
let handler = PipelineHandler::new();
let pipeline = handler.parse_from_file("pipeline.yaml")?;
let working_dir = std::env::current_dir()?.to_string_lossy().to_string();

// Spawn executor
let handle = tokio::spawn(async move {
    handler.execute_pipeline(pipeline, working_dir, Some(tx)).await
});

// Monitor progress
while let Some(event) = rx.recv().await {
    match event {
        ExecutionEvent::StepStarted { step_name, .. } => {
            println!("Running: {}", step_name);
        }
        ExecutionEvent::StepOutput { output, .. } => {
            println!("  {}", output);
        }
        ExecutionEvent::StepCompleted { result, .. } => {
            println!("Completed: {:?}", result.status);
        }
        _ => {}
    }
}

let result = handle.await?;
```

### Example Pipelines

#### Simple Test Pipeline
```yaml
name: quick-test
steps:
  - name: Check version
    command: rustc --version
  - name: Run tests
    command: cargo test
```

#### Build Pipeline
```yaml
name: build-pipeline
env:
  RUST_BACKTRACE: "1"

steps:
  - name: Format check
    command: cargo fmt --check
    continue_on_error: true
    
  - name: Build
    command: cargo build --all
    
  - name: Test
    command: cargo test --all
```

### Pipeline Architecture

The pipeline system consists of:

- **Parser** (`pipeline/parser.rs`) - Parses YAML into Rust structs
- **Executor** (`pipeline/executor.rs`) - Orchestrates step execution
- **Runners** (`pipeline/runners/`) - Execute different step types
  - `shell.rs` - Runs shell commands and scripts
- **Models** (`pipeline/models.rs`) - Data structures for pipelines, steps, results

## TUI Guide

### Interface Overview

#### Pipeline List Screen
```
┌─────────────────────────────────────────────┐
│  Pipeline Runner                            │
└─────────────────────────────────────────────┘
┌─ Available Pipelines ──────────────────────┐
│  → example-pipeline - A simple example     │
│    rust-build-pipeline - Build Rust project│
│    advanced-pipeline - Complex workflow    │
└─────────────────────────────────────────────┘
┌─ Help ──────────────────────────────────────┐
│ ↑/↓: Navigate | Enter: Execute | q: Quit   │
└─────────────────────────────────────────────┘
```

#### Pipeline Execution Screen
```
┌─────────────────────────────────────────────┐
│  Executing: example-pipeline                │
└─────────────────────────────────────────────┘
┌─ Progress ──────────────────────────────────┐
│ ████████████░░░░░░░░  Step 3/5             │
└─────────────────────────────────────────────┘
┌─ Output ────────────────────────────────────┐
│ [Step 1/5] Check Rust version              │
│   rustc 1.70.0 (90c541806 2023-05-31)      │
│   ✓ Completed in 0.05s                     │
│                                             │
│ [Step 2/5] List files                      │
│   ✓ Completed in 0.02s                     │
│                                             │
│ [Step 3/5] Multi-line script               │
│   Starting multi-line script                │
└─────────────────────────────────────────────┘
```

**Features:**
- Real-time progress bar showing current step
- Live output streaming as commands execute
- Color-coded status indicators:
  - ✓ Green for successful steps
  - ✗ Red for failed steps
  - Yellow for step headers
- Auto-scrolling output (shows most recent lines)
- Execution time per step

### Execution Flow

1. **Select Pipeline**: Use arrow keys to highlight a pipeline
2. **Start Execution**: Press Enter to begin execution
3. **Watch Progress**: View real-time progress and output
4. **Completion**: Pipeline shows success or failure status
5. **Return to List**: Press q or Esc to select another pipeline

### Troubleshooting

**No Pipelines Found**
- Ensure you're in a directory with `.yaml` or `.yml` files
- Check that files are valid pipeline YAML format
- Verify files have the required `name` and `steps` fields

**Pipeline Fails to Execute**
- Check the output panel for error messages
- Verify commands are available on your system
- Check file permissions and working directory
- Review pipeline YAML syntax

**TUI Doesn't Respond**
- Ensure terminal supports TUI applications
- Check terminal size is adequate (minimum 80x24)
- Try resizing terminal window

## Extending the Application

### Adding a New Tab System

```rust
#[derive(Debug, Default, Clone, Copy, PartialEq, Eq)]
enum Tab {
    #[default]
    Counter,
    Items,
    Settings,
}

// Add to App struct:
struct App {
    counter: i32,
    items: Vec<String>,
    current_tab: Tab,
    should_quit: bool,
}

// Handle tab switching:
KeyCode::Char('1') => self.current_tab = Tab::Counter,
KeyCode::Char('2') => self.current_tab = Tab::Items,
KeyCode::Char('3') => self.current_tab = Tab::Settings,
```

### Adding Scrolling to Lists

```rust
use ratatui::widgets::ListState;

struct App {
    // ... existing fields
    list_state: ListState,
}

// Handle scrolling:
KeyCode::Up => {
    let i = self.list_state.selected().unwrap_or(0);
    if i > 0 {
        self.list_state.select(Some(i - 1));
    }
}
KeyCode::Down => {
    let i = self.list_state.selected().unwrap_or(0);
    if i < self.items.len() - 1 {
        self.list_state.select(Some(i + 1));
    }
}

// Render with state:
frame.render_stateful_widget(list, main_chunks[1], &mut self.list_state);
```

### Adding Input Fields

```rust
struct App {
    // ... existing fields
    input: String,
    input_mode: bool,
}

// Handle input mode:
KeyCode::Char('i') if !self.input_mode => {
    self.input_mode = true;
}
KeyCode::Esc if self.input_mode => {
    self.input_mode = false;
}
KeyCode::Char(c) if self.input_mode => {
    self.input.push(c);
}
KeyCode::Backspace if self.input_mode => {
    self.input.pop();
}
KeyCode::Enter if self.input_mode => {
    self.items.push(self.input.clone());
    self.input.clear();
    self.input_mode = false;
}
```

### Adding Mouse Support

```rust
use crossterm::event::{MouseEvent, MouseEventKind};

// In handle_events:
Event::Mouse(mouse_event) => self.handle_mouse_event(mouse_event),

// Handler:
fn handle_mouse_event(&mut self, mouse_event: MouseEvent) {
    match mouse_event.kind {
        MouseEventKind::Down(_) => {
            // Handle click at position (mouse_event.column, mouse_event.row)
        }
        MouseEventKind::ScrollUp => {
            // Handle scroll up
        }
        MouseEventKind::ScrollDown => {
            // Handle scroll down
        }
        _ => {}
    }
}
```

### Adding Async Operations

```rust
// Add to Cargo.toml:
// tokio = { version = "1", features = ["full"] }

use tokio::sync::mpsc;
use std::time::Duration;

enum AppEvent {
    Input(Event),
    DataUpdate(String),
}

#[tokio::main]
async fn main() -> Result<()> {
    let (tx, mut rx) = mpsc::channel(100);
    
    // Spawn background task
    let tx_clone = tx.clone();
    tokio::spawn(async move {
        loop {
            tokio::time::sleep(Duration::from_secs(1)).await;
            let _ = tx_clone.send(AppEvent::DataUpdate("Updated".to_string())).await;
        }
    });
    
    // Main event loop
    loop {
        if event::poll(Duration::from_millis(100))? {
            tx.send(AppEvent::Input(event::read()?)).await?;
        }
        
        while let Ok(event) = rx.try_recv() {
            match event {
                AppEvent::Input(e) => { /* handle input */ }
                AppEvent::DataUpdate(data) => { /* update state */ }
            }
        }
    }
}
```

### Custom Pipeline Steps

To extend the pipeline system:

1. **Add new pipeline steps**: Update pipeline YAML files with new commands or shell scripts
2. **Custom step runners**: Implement new runners in `pipeline-service/src/pipeline/runners/`
3. **RPC handlers**: Add new RPC handlers in `pipeline-rpc/src/handlers/` to expose new functionality
4. **Update RPC API**: Export new handlers and types in `pipeline-rpc/src/lib.rs`
5. **Client updates**: Use new RPC handlers in CLI/TUI applications
6. **UI screens**: Create new app states and corresponding UI components in TUI
7. **Pipeline filters**: Add filtering/searching capabilities to the pipeline list

**Remember**: All client functionality must go through the RPC layer. Never import `pipeline-service` directly in CLI or TUI.

### Best Practices

1. **Keep render functions pure** - Don't modify state during rendering
2. **Handle errors gracefully** - Use Result types and proper error handling
3. **Test rendering logic** - Ratatui supports testing with Buffer
4. **Profile performance** - TUI apps should render at 60fps
5. **Use proper terminal cleanup** - Always restore terminal state on exit

## Project Structure

### Building and Running

```bash
# Build entire workspace
cargo build

# Build specific package
cargo build -p roxid-tui
cargo build -p pipeline-service
cargo build -p pipeline-rpc
cargo build -p roxid-cli

# Run the TUI application
cargo run --bin roxid-tui

# Run the CLI application
cargo run --bin roxid-cli run example-pipeline.yaml

# Run tests for all packages
cargo test

# Run tests for specific package
cargo test -p pipeline-rpc

# Check code without building
cargo check
```

### Benefits of This Structure

1. **Separation of Concerns**: Each package has a single responsibility
2. **Reusability**: Service logic can be used by multiple clients through RPC layer
3. **Testability**: Each layer can be tested independently
4. **Maintainability**: Clear boundaries make code easier to understand
5. **Scalability**: Easy to add new interfaces (web, mobile, desktop) without touching core logic
6. **API Consistency**: All clients use the same RPC interface, ensuring consistent behavior
7. **Security**: RPC layer can add authentication, rate limiting, and validation before reaching service
8. **Flexibility**: RPC layer can be made into a network service without changing clients

## Resources

- [Ratatui Documentation]https://docs.rs/ratatui
- [Ratatui Website]https://ratatui.rs/
- [Ratatui Examples]https://github.com/ratatui/ratatui/tree/main/examples
- [Ratatui Book]https://ratatui.rs/concepts/
- [Crossterm Documentation]https://docs.rs/crossterm
- [Example Projects]https://github.com/ratatui/awesome-ratatui

## License

This skeleton application is provided as-is for educational and development purposes.