headless_lms_server/controllers/cms/
gutenberg.rs

use std::time::Duration;

use headless_lms_utils::url_to_oembed_endpoint::{
    mentimeter_oembed_response_builder, thinglink_oembed_response_builder, url_to_oembed_endpoint,
    vimeo_oembed_response_builder, OEmbedRequest, OEmbedResponse,
};
use serde::{Deserialize, Serialize};

use crate::prelude::*;

#[derive(Deserialize, Serialize)]
#[serde(rename_all = "kebab-case")]
pub struct ThemeSupports {
    pub responsive_embeds: bool,
}

#[derive(Deserialize, Serialize)]
pub struct ThemeResponse {
    pub theme_supports: ThemeSupports,
}

// Needed for Spotify oembed, should be fetched from env?
static APP_USER_AGENT: &str = concat!("moocfi", "/", "0.1.0",);

/**
GET `/api/v0/cms/gutenberg/oembed/preview?url=https%3A%2F%2Fyoutube.com%2Fwatch%3Fv%3D123123123` - Fetch oembed response from correct provider.
Endpoint for proxying oembed requests to correct provider using url query param.

# Example

Request:
```http
GET /api/v0/cms/gutenberg/oembed/preview?url=https%3A%2F%2Fyoutube.com%2Fwatch%3Fv%3D123123123 HTTP/1.1
Content-Type: application/json

```

Response:
```json
{
    "title":"AUTHOR - Title (OFFICIAL)",
    "author_name":"Author Name",
    "author_url":"https://www.youtube.com/author",
    "type":"video",
    "height":439,
    "width":780,
    "version":"1.0",
    "provider_name":"YouTube",
    "provider_url":"https://www.youtube.com/",
    "thumbnail_height":360,"thumbnail_width":480,
    "thumbnail_url":"https://i.ytimg.com/vi/JWBo/hqdefault.jpg",
    "html":"<iframe width=\"780\" height=\"439\" src=\"https://www.youtube.com/embed/JYjVo?feature=oembed\" frameborder=\"0\" allow=\"accelerometer; autoplay; clipboard-write; encrypted-media; gyroscope; picture-in-picture\" allowfullscreen></iframe>"}
}

```
*/
#[instrument(skip(pool, app_conf))]
async fn get_oembed_data_from_provider(
    query_params: web::Query<OEmbedRequest>,
    pool: web::Data<PgPool>,
    user: AuthUser,
    app_conf: web::Data<ApplicationConfiguration>,
) -> ControllerResult<web::Json<serde_json::Value>> {
    let mut conn = pool.acquire().await?;
    let token = authorize(&mut conn, Act::Teach, Some(user.id), Res::AnyCourse).await?;
    let endpoint = url_to_oembed_endpoint(
        query_params.url.to_string(),
        Some(app_conf.base_url.to_string()),
    )?;
    let client = reqwest::Client::builder()
        .user_agent(APP_USER_AGENT)
        .build()
        .map_err(|oe| anyhow::anyhow!(oe.to_string()))?;
    let res = client
        .get(endpoint)
        .timeout(Duration::from_secs(120))
        .send()
        .await
        .map_err(|oe| {
            ControllerError::new(
                ControllerErrorType::BadRequest,
                oe.to_string(),
                Some(oe.into()),
            )
        })?;
    let status = res.status();
    if !status.is_success() {
        let response_url = res.url().to_string();
        let body = res.text().await.map_err(|oe| {
            ControllerError::new(
                ControllerErrorType::BadRequest,
                oe.to_string(),
                Some(oe.into()),
            )
        })?;
        warn!(url=?response_url, status=?status, body=?body, "Could not fetch oembed data from provider");
        return Err(ControllerError::new(
            ControllerErrorType::BadRequest,
            "Could not fetch oembed data from provider".to_string(),
            None,
        ));
    }
    let res = res.json::<serde_json::Value>().await.map_err(|oe| {
        ControllerError::new(
            ControllerErrorType::BadRequest,
            oe.to_string(),
            Some(oe.into()),
        )
    })?;
    token.authorized_ok(web::Json(res))
}

/**
GET `/api/v0/cms/gutenberg/themes?context=edit&status=active&_locale=user` - Mock themes response
Endpoint for proxying themes requests.
<https://github.com/WordPress/gutenberg/blob/trunk/packages/block-library/src/embed/test/index.native.js#L128>

# Example

Request:
```http
GET /api/v0/cms/gutenberg/themes?context=edit&status=active&_locale=user HTTP/1.1
Content-Type: application/json

```

Response:
```json
{
    {
        "theme_supports": {
                "responsive-embeds": true
            }
        }
}

```
*/
#[instrument(skip(pool))]
async fn get_theme_settings(
    pool: web::Data<PgPool>,
    user: AuthUser,
) -> ControllerResult<web::Json<ThemeResponse>> {
    let mut conn = pool.acquire().await?;
    let token = authorize(&mut conn, Act::Teach, Some(user.id), Res::AnyCourse).await?;
    let response = ThemeResponse {
        theme_supports: ThemeSupports {
            responsive_embeds: true,
        },
    };
    token.authorized_ok(web::Json(response))
}

#[instrument(skip(app_conf))]
async fn get_mentimeter_oembed_data(
    query_params: web::Query<OEmbedRequest>,
    app_conf: web::Data<ApplicationConfiguration>,
    pool: web::Data<PgPool>,
) -> ControllerResult<web::Json<OEmbedResponse>> {
    let token = skip_authorize();
    let url = query_params.url.to_string();
    let response = mentimeter_oembed_response_builder(url, app_conf.base_url.to_string())?;
    token.authorized_ok(web::Json(response))
}

#[instrument(skip(app_conf))]
async fn get_thinglink_oembed_data(
    query_params: web::Query<OEmbedRequest>,
    app_conf: web::Data<ApplicationConfiguration>,
    pool: web::Data<PgPool>,
) -> ControllerResult<web::Json<OEmbedResponse>> {
    let token = skip_authorize();
    let url = query_params.url.to_string();
    let response = thinglink_oembed_response_builder(url, app_conf.base_url.to_string())?;
    token.authorized_ok(web::Json(response))
}

#[instrument(skip(app_conf))]
async fn get_vimeo_oembed_data(
    query_params: web::Query<OEmbedRequest>,
    app_conf: web::Data<ApplicationConfiguration>,
    pool: web::Data<PgPool>,
) -> ControllerResult<web::Json<OEmbedResponse>> {
    let token = skip_authorize();
    let url = query_params.url.to_string();
    let response = vimeo_oembed_response_builder(url, app_conf.base_url.to_string())?;
    token.authorized_ok(web::Json(response))
}

/**
Add a route for each controller in this module.

The name starts with an underline in order to appear before other functions in the module documentation.

We add the routes by calling the route method instead of using the route annotations because this method preserves the function signatures for documentation.
*/
pub fn _add_routes(cfg: &mut ServiceConfig) {
    cfg.route(
        "/oembed/preview",
        web::get().to(get_oembed_data_from_provider),
    )
    .route("/themes", web::get().to(get_theme_settings))
    .route(
        "/oembed/mentimeter",
        web::get().to(get_mentimeter_oembed_data),
    )
    .route(
        "/oembed/thinglink",
        web::get().to(get_thinglink_oembed_data),
    )
    .route("/oembed/vimeo", web::get().to(get_vimeo_oembed_data));
}
headless_lms_server/controllers/cms/gutenberg.rs

headless_lms_server/controllers/cms/
gutenberg.rs
