Merge branch 'main' of https://github.com/Tuntii/RustAPI

Author: Tuntii

crates/rustapi-extras/src/oauth2/tokens.rs

@@ -362,7 +362,7 @@ mod property_tests {
             // Remaining time should be close to expires_in (within a few seconds)
             let remaining_secs = remaining.unwrap().as_secs();
             prop_assert!(remaining_secs <= expires_in_secs);
-            prop_assert!(remaining_secs >= expires_in_secs - 2); // Allow 2 sec tolerance
+            prop_assert!(remaining_secs >= expires_in_secs.saturating_sub(2)); // Allow 2 sec tolerance
         }
 
         /// Property 16: Token response builder pattern works correctly

docs/GETTING_STARTED.md

@@ -22,14 +22,14 @@ Add RustAPI to your `Cargo.toml`:
 
 ```toml
 [dependencies]
-rustapi-rs = "0.1.9"
+rustapi-rs = "0.1.233"
 ```
 
 Or with specific features:
 
 ```toml
 [dependencies]
-rustapi-rs = { version = "0.1.9", features = ["jwt", "cors", "toon", "ws", "view"] }
+rustapi-rs = { version = "0.1.233", features = ["jwt", "cors", "toon", "ws", "view"] }
 ```
 
 ### Available Features
@@ -358,7 +358,7 @@ ApiError::internal("message")         // 500
 ### CORS
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["cors"] }
+rustapi-rs = { version = "0.1.233", features = ["cors"] }
 ```
 
 ```rust
@@ -379,7 +379,7 @@ RustApi::new()
 ### JWT Authentication
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["jwt"] }
+rustapi-rs = { version = "0.1.233", features = ["jwt"] }
 ```
 
 ```rust
@@ -409,7 +409,7 @@ async fn protected(user: AuthUser<Claims>) -> Json<Response> {
 ### Rate Limiting
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["rate-limit"] }
+rustapi-rs = { version = "0.1.233", features = ["rate-limit"] }
 ```
 
 ```rust
@@ -427,7 +427,7 @@ RustApi::new()
 ## TOON Format (LLM Optimization)
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["toon"] }
+rustapi-rs = { version = "0.1.233", features = ["toon"] }
 ```
 
 ```rust
@@ -458,7 +458,7 @@ Response includes token counting headers:
 Real-time bidirectional communication:
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["ws"] }
+rustapi-rs = { version = "0.1.233", features = ["ws"] }
 ```
 
 ```rust
@@ -495,7 +495,7 @@ websocat ws://localhost:8080/ws
 Server-side HTML rendering with Tera:
 
 ```toml
-rustapi-rs = { version = "0.1.4", features = ["view"] }
+rustapi-rs = { version = "0.1.233", features = ["view"] }
 ```
 
 Create a template file `templates/index.html`:
@@ -697,7 +697,7 @@ struct AnyBody { ... }
 Check that the `swagger-ui` feature is enabled (it's on by default):
 
 ```toml
-rustapi-rs = { version = "0.1.9", features = ["swagger-ui"] }
+rustapi-rs = { version = "0.1.233", features = ["swagger-ui"] }
 ```
 
 ### CLI Commands Not Working

docs/cookbook/src/crates/rustapi_extras.md

@@ -13,6 +13,7 @@ This crate is a collection of production-ready middleware. Everything is behind
 | `cors` | `CorsLayer` |
 | `csrf` | `CsrfLayer`, `CsrfToken` extractor |
 | `audit` | `AuditStore`, `AuditLogger` |
+| `insight` | `InsightLayer`, `InsightStore` |
 | `rate-limit` | `RateLimitLayer` |
 
 ## Middleware Usage
@@ -82,3 +83,38 @@ async fn delete_user(
 }
 ```
 
+## Traffic Insight
+
+The `insight` feature provides powerful real-time traffic analysis and debugging capabilities without external dependencies. It is designed to be low-overhead and privacy-conscious.
+
+```toml
+[dependencies]
+rustapi-extras = { version = "0.1", features = ["insight"] }
+```
+
+### Setup
+
+```rust
+use rustapi_extras::insight::{InsightLayer, InMemoryInsightStore, InsightConfig};
+use std::sync::Arc;
+
+let store = Arc::new(InMemoryInsightStore::new());
+let config = InsightConfig::default();
+
+let app = RustApi::new()
+    .layer(InsightLayer::new(config, store.clone()));
+```
+
+### Accessing Data
+
+You can inspect the collected data (e.g., via an admin dashboard):
+
+```rust
+#[rustapi_rs::get("/admin/insights")]
+async fn get_insights(State(store): State<Arc<InMemoryInsightStore>>) -> Json<InsightStats> {
+    // Returns aggregated stats like req/sec, error rates, p99 latency
+    Json(store.get_stats().await)
+}
+```
+
+The `InsightStore` trait allows you to implement custom backends (e.g., ClickHouse or Elasticsearch) if you need long-term retention.

docs/cookbook/src/crates/rustapi_jobs.md

@@ -5,25 +5,87 @@
 
 ## Background Processing
 
-Long-running tasks shouldn't block HTTP requests. `rustapi-jobs` provides a robust queue system.
+Long-running tasks shouldn't block HTTP requests. `rustapi-jobs` provides a robust queue system that can run in-memory or be backed by Redis/Postgres.
+
+## Usage Example
+
+Here is how to set up a simple background job queue using the in-memory backend.
+
+### 1. Define the Job
+
+Jobs are simple structs that implement `Serialize` and `Deserialize`.
+
+```rust
+use serde::{Deserialize, Serialize};
+use rustapi_jobs::{Job, JobContext, Result};
+use std::sync::Arc;
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+struct EmailJob {
+    to: String,
+    subject: String,
+    body: String,
+}
+
+// Implement the Job trait to define how to process it
+#[async_trait::async_trait]
+impl Job for EmailJob {
+    const NAME: &'static str = "email_job";
+
+    async fn run(&self, _ctx: JobContext) -> Result<()> {
+        println!("Sending email to {} with subject: {}", self.to, self.subject);
+        // Simulate work
+        tokio::time::sleep(std::time::Duration::from_millis(100)).await;
+        Ok(())
+    }
+}
+```
+
+### 2. Configure the Queue
+
+In your `main` function, initialize the queue and start the worker.
 
 ```rust
-// Define a job
-#[derive(Serialize, Deserialize)]
-struct EmailJob { to: String }
+use rustapi_jobs::{JobQueue, InMemoryBackend, EnqueueOptions};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // 1. Create the backend
+    let backend = InMemoryBackend::new();
+
+    // 2. Create the queue
+    let queue = JobQueue::new(backend);
 
-// Enqueue it
-queue.push(EmailJob { to: "alice@example.com" }).await;
+    // 3. Register the job type
+    queue.register_job::<EmailJob>();
+
+    // 4. Start the worker in the background
+    let worker_queue = queue.clone();
+    tokio::spawn(async move {
+        worker_queue.start_workers().await;
+    });
+
+    // 5. Enqueue a job
+    queue.enqueue(EmailJob {
+        to: "user@example.com".into(),
+        subject: "Welcome!".into(),
+        body: "Thanks for joining.".into(),
+    }).await?;
+
+    Ok(())
+}
 ```
 
 ## Backends
 
-- **Memory**: Great for development and testing.
-- **Redis**: High throughput persistence.
-- **Postgres**: Transactional reliability (acid).
+- **Memory**: Great for development and testing. Zero infrastructure required.
+- **Redis**: High throughput persistence. Recommended for production.
+- **Postgres**: Transactional reliability (ACID). Best if you cannot lose jobs.
+
+## Reliability Features
 
-## Reliability
+The worker system includes built-in reliability features:
 
-The worker system features:
-- **Exponential Backoff**: Automatic retries for failing jobs.
-- **Dead Letter Queue**: Poison jobs are isolated for manual inspection.
+- **Exponential Backoff**: Automatically retries failing jobs with increasing delays.
+- **Dead Letter Queue (DLQ)**: "Poison" jobs that fail repeatedly are isolated for manual inspection.
+- **Concurrency Control**: Limit the number of concurrent workers to prevent overloading your system.

docs/cookbook/src/getting_started/installation.md

@@ -25,6 +25,21 @@ Verify your installation:
 cargo-rustapi --version
 ```
 
+## Adding to an Existing Project
+
+If you prefer not to use the CLI, you can add RustAPI to your `Cargo.toml` manually:
+
+```bash
+cargo add rustapi-rs@0.1.233
+```
+
+Or add this to your `Cargo.toml`:
+
+```toml
+[dependencies]
+rustapi-rs = "0.1.233"
+```
+
 ## Editor Setup
 
 For the best experience, we recommend **VS Code** with the **rust-analyzer** extension. This provides:

docs/cookbook/src/learning/README.md

@@ -10,6 +10,16 @@ We maintain a comprehensive examples repository with **18 real-world projects**
 
 🔗 **[rustapi-rs-examples](https://github.com/Tuntii/rustapi-rs-examples)** - Complete examples from hello-world to production microservices
 
+### Cookbook Internal Path
+
+If you prefer reading through documentation first, follow this path through the cookbook:
+
+1. **Foundations**: Start with [Handlers & Extractors](../concepts/handlers.md) and [System Overview](../architecture/system_overview.md).
+2. **Core Crates**: Read about [rustapi-core](../crates/rustapi_core.md) and [rustapi-macros](../crates/rustapi_macros.md).
+3. **Building Blocks**: Try the [Creating Resources](../recipes/crud_resource.md) recipe.
+4. **Security**: Implement [JWT Authentication](../recipes/jwt_auth.md) and [CSRF Protection](../recipes/csrf_protection.md).
+5. **Advanced**: Explore [Performance Tuning](../recipes/high_performance.md) and [HTTP/3](../recipes/http3_quic.md).
+
 ### Why Use the Examples Repository?
 
 | Benefit | Description |