library_usage/
library_usage.rs

1use axum::Router;
2use phantom_frame::{cache::RefreshTrigger, create_proxy, CreateProxyConfig};
3
4#[tokio::main]
5async fn main() {
6    // Initialize tracing (optional but recommended)
7    // tracing_subscriber::fmt::init();
8
9    // Create proxy configuration
10    // You can specify method prefixes to filter by HTTP method
11    let proxy_config = CreateProxyConfig::new("http://localhost:8080".to_string())
12        .with_include_paths(vec![
13            "/api/*".to_string(),
14            "/public/*".to_string(),
15            "GET /admin/stats".to_string(), // Only cache GET requests to this endpoint
16        ])
17        .with_exclude_paths(vec![
18            "/api/admin/*".to_string(),
19            "POST *".to_string(),  // Don't cache any POST requests
20            "PUT *".to_string(),   // Don't cache any PUT requests
21            "DELETE *".to_string(), // Don't cache any DELETE requests
22        ])
23        .with_websocket_enabled(true); // Enable WebSocket support (default: true)
24
25    // Create proxy - proxy_url is the backend server to proxy requests to
26    let (proxy_app, refresh_trigger): (Router, RefreshTrigger) = create_proxy(proxy_config);
27
28    // You can clone and use the refresh_trigger in your code
29    let trigger_clone = refresh_trigger.clone();
30
31    // Example: Trigger cache refresh from another part of your application
32    tokio::spawn(async move {
33        tokio::time::sleep(tokio::time::Duration::from_secs(60)).await;
34        
35        // Clear all cache entries
36        trigger_clone.trigger();
37        println!("All cache cleared!");
38        
39        tokio::time::sleep(tokio::time::Duration::from_secs(30)).await;
40        
41        // Clear only cache entries matching a pattern (supports wildcards)
42        trigger_clone.trigger_by_key_match("GET:/api/*");
43        println!("Cache cleared for GET:/api/* pattern!");
44    });
45
46    // Start the proxy server
47    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
48
49    println!("Proxy server listening on http://0.0.0.0:3000");
50    println!("Caching paths: /api/*, /public/*, GET /admin/stats");
51    println!("Excluding: /api/admin/*, POST *, PUT *, DELETE *");
52    println!("Note: Only GET requests will be cached (POST/PUT/DELETE are excluded)");
53    println!("WebSocket support: enabled");
54
55    axum::serve(listener, proxy_app).await.unwrap();
56}
library_usage/library_usage.rs

library_usage/
library_usage.rs
