portail 2.1.0

Unified proxy/gateway: AI Gateway + MCP Gateway + CDN cache
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::cdn::CacheManager;
use futures::StreamExt;
use std::sync::Arc;
use tracing::info;

pub async fn purge_loop(mut subscription: async_nats::Subscriber, cache: Arc<CacheManager>) {
    info!("CDN invalidator: listening for index.invalidated.>");

    while let Some(msg) = subscription.next().await {
        let subject = msg.subject.clone();
        info!(%subject, "CDN invalidation received");

        if let Some(path) = subject.strip_prefix("index.invalidated.") {
            let prefix = path.replace('.', "/");
            cache.purge_prefix(&prefix).await;
            info!(prefix, "CDN cache invalidated");
        }
    }
}