manas_server 0.1.0

This crate provides default recipes of solid server.
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

//! I define items to help in integrating solidos into recipe
//! as databrowser.
//!

use std::sync::Arc;

use manas_http::{
    header::common::qvalue::QValue,
    representation::impl_::{binary::BinaryRepresentation, common::data::bytes_inmem::BytesInmem},
    uri::invariant::AbsoluteHttpUri,
};
use manas_repo_layers::dconneging::conneg_layer::{
    impl_::{
        constant_overriding::{
            ConstantOverrideNegotiationConfig, ConstantOverrideNegotiationLayer,
            ConstantOverridingPreferences,
        },
        stack::StackConfig,
    },
    DerivedContentNegotiationLayer,
};
use manas_repo_opendal::service::resource_operator::reader::ODRResourceReader;
use once_cell::sync::Lazy;
use tower::layer::util::Stack;
use upon::Engine;

use crate::repo::{RcpBaseRepo, RcpBaseRepoSetup, RcpRdfSourceCNL};

static DATABROWSER_TEMPLATE_ENGINE: Lazy<Engine> = Lazy::new(|| {
    let mut engine = Engine::new();
    engine
        .add_template(
            "databrowser",
            include_str!("../templates/databrowser.html.template"),
        )
        .expect("Template must be valid.");
    engine
});

/// A struct for representing databrowser context.
#[derive(serde::Serialize)]
pub struct DatabrowserContext {
    /// Mashlib js uri.
    pub mashlib_js_uri: AbsoluteHttpUri,

    /// Mashlib css uri.
    pub mashlib_css_uri: AbsoluteHttpUri,
}

impl DatabrowserContext {
    /// Get a new [`DatabrowserContext`] with mashlib served from unpkg cdn.
    pub fn new_from_unpkg() -> Self {
        Self {
            mashlib_js_uri: "https://www.unpkg.com/mashlib/dist/mashlib.min.js"
                .parse()
                .unwrap(),
            mashlib_css_uri: "https://www.unpkg.com/mashlib/dist/mash.css"
                .parse()
                .unwrap(),
        }
    }
}

/// Resolve databrowser content for given context.
pub fn resolve_databrowser_content(context: DatabrowserContext) -> BytesInmem {
    DATABROWSER_TEMPLATE_ENGINE
        .get_template("databrowser")
        .expect("Template must exist")
        .render(&context)
        .to_string()
        .expect("Must be valid")
        .into()
}

/// Type of databrowser adapted conneg layer.
pub type DatabrowserAdaptedCNL<Backend, Inner> = Stack<
    Inner,
    ConstantOverrideNegotiationLayer<
        RcpBaseRepo<Backend>,
        <Inner as DerivedContentNegotiationLayer<
            RcpBaseRepo<Backend>,
            BinaryRepresentation,
            ODRResourceReader<RcpBaseRepoSetup<Backend>>,
        >>::WService,
    >,
>;

/// Type of databrowser adapted rdf source conneg layer.
pub type RcpDatabrowserAdaptedRdfSourceCNL<Backend> =
    DatabrowserAdaptedCNL<Backend, RcpRdfSourceCNL<Backend>>;

/// Adapt conneg layer config.
pub fn adapt_dconneg_layer_config<InnerConfig>(
    inner_config: Arc<InnerConfig>,
    opt_databrowser_context: Option<DatabrowserContext>,
) -> Arc<StackConfig<InnerConfig, Option<ConstantOverrideNegotiationConfig>>> {
    let overrider_config = opt_databrowser_context.map(|databrowser_context| {
        ConstantOverrideNegotiationConfig {
            constant_rep_content_type: mime::TEXT_HTML.try_into().expect("Must be valid"),
            constant_rep_complete_data: resolve_databrowser_content(databrowser_context),
            overriding_preferences: Arc::new(ConstantOverridingPreferences {
                min_quality: QValue::ZERO,
                enabled_src_media_ranges: vec![mime::STAR_STAR],
                // TODO disable for images, videos etc.
                disabled_src_media_ranges: vec![],
            }),
        }
    });
    Arc::new(StackConfig {
        inner_config,
        outer_config: Arc::new(overrider_config),
    })
}