Add integration workflow

Author: bhf

.github/workflows/test.yml

@@ -0,0 +1,57 @@
+name: Rust CI
+
+on:
+  push:
+    branches: [ "main", "master" ]
+  pull_request:
+    branches: [ "main", "master" ]
+
+env:
+  CARGO_TERM_COLOR: always
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v4
+
+    - name: Set up Homebrew
+      run: |
+        echo "/home/linuxbrew/.linuxbrew/bin" >> $GITHUB_PATH
+        eval "$(/home/linuxbrew/.linuxbrew/bin/brew shellenv)"
+
+    - name: Install Toolchain
+      uses: dtolnay/rust-toolchain@stable
+
+    - name: Install Aeron Cache Backend
+      run: |
+        brew tap bhf/aeron-cache
+        brew install aeron-cache
+
+    - name: Start Aeron Cache Backend
+      run: |
+        aeron-cache &
+        # Wait for the environment file to be generated in ~/.aeron-cache/
+        ENV_FILE="$HOME/.aeron-cache/aeron-cache-ui.env"
+
+          if [ -f "$ENV_FILE" ]; then
+            echo "Environment file found"
+            break
+          fi
+          echo "Waiting for $ENV_FILE..."
+          sleep 1
+        done
+        
+        # Extract the API URL
+        if [ -f "$ENV_FILE" ]; then
+          API_URL=$(grep AERON_CACHE_API "$ENV_FILE" | cut -d'=' -f2)
+          echo "Found API URL: $API_URL"
+          echo "AERON_CACHE_API_URL=$API_URL" >> $GITHUB_ENV
+        else
+          echo "Error: $ENV_FILE not found after timeout"
+          exit 1
+        fi
+
+    - name: Run Tests
+      run: cargo test
+

Cargo.lock

@@ -10,3 +10,6 @@ reqwest = { version = "0.11", features = ["blocking", "json"] }
 serde = { version = "1.0.228", features = ["derive"] }
 serde_json = "1.0.148"
 
+[dev-dependencies]
+assert_cmd = "2.0"
+predicates = "3.1"

Cargo.toml

@@ -65,6 +65,8 @@ enum Commands {
     Delete {
         #[arg(help = "Name of the cache to delete")]
         name: String,
+        #[arg(short, long, help = "Automatically confirm deletion")]
+        yes: bool,
     },
 }
 
@@ -94,8 +96,8 @@ fn main() -> Result<(), Box<dyn Error>> {
         Commands::Remove { name: cache_name, key } => {
             process_remove_item(rest_client, &aeron_cache_api_url, &cache_name, &key)?;
         }
-        Commands::Delete { name } => {
-            if Confirm::new()
+        Commands::Delete { name, yes } => {
+            if yes || Confirm::new()
                 .with_prompt(format!(
                     "Are you sure you want to delete cache '{}'? This action cannot be undone.",
                     name
@@ -110,4 +112,3 @@ fn main() -> Result<(), Box<dyn Error>> {
     }
     Ok(())
 }
-

src/main.rs

@@ -0,0 +1,61 @@
+use assert_cmd::Command;
+use predicates::prelude::*;
+use std::env;
+
+fn get_api_url() -> String {
+    env::var("AERON_CACHE_API_URL").unwrap_or_else(|_| "http://localhost:7070/api/v1/cache".to_string())
+}
+
+#[test]
+fn test_help() -> Result<(), Box<dyn std::error::Error>> {
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.arg("--help");
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains("A CLI for interacting with Aeron Cache"));
+    Ok(())
+}
+
+#[test]
+fn test_cache_lifecycle() -> Result<(), Box<dyn std::error::Error>> {
+    let api_url = get_api_url();
+    let cache_name = "test-cache-lifecycle";
+
+    // 1. Create Cache
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.args(&["--api-url", &api_url, "create", cache_name]);
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains(format!("Created cache with id: {}", cache_name)));
+
+    // 2. Insert Item
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.args(&["--api-url", &api_url, "insert", cache_name, "mykey", "myvalue"]);
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains(format!("Put item into cache with id: {}", cache_name)));
+
+    // 3. Get Item
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.args(&["--api-url", &api_url, "get", cache_name, "mykey"]);
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains(format!("Got item from cache {} on key mykey with value myvalue", cache_name)));
+
+    // 4. Remove Item
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.args(&["--api-url", &api_url, "remove", cache_name, "mykey"]);
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains(format!("Removed item from cache {} on key mykey", cache_name)));
+
+    // 5. Delete Cache (using the --yes flag)
+    let mut cmd = Command::cargo_bin("CacheCLI")?;
+    cmd.args(&["--api-url", &api_url, "delete", cache_name, "--yes"]);
+    cmd.assert()
+        .success()
+        .stdout(predicate::str::contains(format!("Deleted cache: {}", cache_name)));
+
+    Ok(())
+}
+