poet 0.7.0

Static site generator with optional MCP server and LLM SEO optimizations
Documentation 
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

use std::sync::Arc;

use actix_web::rt;
use anyhow::Result;
use anyhow::anyhow;
use async_trait::async_trait;
use log::error;
use log::warn;
use tokio::sync::Notify;
use tokio::sync::mpsc;
use tokio::sync::mpsc::Receiver;
use tokio_util::sync::CancellationToken;

use crate::mcp::resource::Resource;
use crate::mcp::resource_content_parts::ResourceContentParts;
use crate::mcp::resource_provider_list_params::ResourceProviderListParams;
use crate::mcp::resource_reference::ResourceReference;
use crate::mcp::resource_template_provider::ResourceTemplateProvider;

#[async_trait]
pub trait ResourceProvider: ResourceTemplateProvider + Send + Sync + 'static {
    async fn list_resources(&self, params: ResourceProviderListParams) -> Result<Vec<Resource>>;

    async fn read_resource_contents(
        &self,
        resource_reference: ResourceReference,
    ) -> Result<Option<ResourceContentParts>>;

    async fn resource_update_notifier(
        self: Arc<Self>,
        cancellation_token: CancellationToken,
        resource_reference: ResourceReference,
    ) -> Result<Option<Arc<Notify>>>;

    fn total(&self) -> usize;

    fn resource_uri(&self, resource_path: &str) -> String {
        format!("{}/{resource_path}", self.resource_uri_prefix())
    }

    async fn subscribe(
        self: Arc<Self>,
        cancellation_token: CancellationToken,
        resource_reference: ResourceReference,
    ) -> Result<Option<Receiver<ResourceContentParts>>> {
        let (resource_content_parts_tx, resource_content_parts_rx) = mpsc::channel(3);
        let resource_update_notifier: Arc<Notify> = self
            .clone()
            .resource_update_notifier(cancellation_token.clone(), resource_reference.clone())
            .await?
            .ok_or_else(|| {
                anyhow!(
                    "Unable to obtain resource update notifier for resource: '{}'",
                    resource_reference.path
                )
            })?;
        let this = self.clone();

        rt::spawn(async move {
            loop {
                tokio::select! {
                    _ = cancellation_token.cancelled() => {
                        break;
                    }
                    _ = resource_update_notifier.notified() => {
                        let notification = match this.read_resource_contents(resource_reference.clone()).await {
                            Ok(Some(resource_content_parts)) => resource_content_parts,
                            Ok(None) => {
                                warn!("Resource has been removed while being subscribed to: '{}'", resource_reference.path);
                                break;
                            }
                            Err(err) => {
                                error!("Unable to get resource content parts for '{}': {err:#?}", resource_reference.path);
                                break;
                            }
                        };

                        if let Err(err) = resource_content_parts_tx.send(notification).await {
                            error!("Unable to forward resource update: {err:#?}");
                            break;
                        }
                    }
                }
            }

            cancellation_token.cancel();
        });

        Ok(Some(resource_content_parts_rx))
    }
}