Struct RileyCms 

pub struct RileyCms { /* private fields */ }

Main entry point for riley_cms functionality.

RileyCms provides access to all CMS operations: listing posts and series, retrieving individual content, managing assets, and cache control.

Example

use riley_cms_core::{RileyCms, RileyCmsConfig, ListOptions};

let config: RileyCmsConfig = toml::from_str(r#"
[content]
repo_path = "/data/content"
[storage]
bucket = "my-assets"
public_url_base = "https://assets.example.com"
"#)?;

let riley_cms = RileyCms::from_config(config).await?;
let posts = riley_cms.list_posts(&ListOptions::default()).await?;

Implementations

impl RileyCms

pub async fn from_config(config: RileyCmsConfig) -> Result<Self>

Create a new RileyCms instance from configuration.

This loads content from disk into an in-memory cache and initializes the S3 storage client.

Errors

Returns an error if content cannot be loaded or S3 configuration is invalid.

pub async fn list_posts( &self, opts: &ListOptions, ) -> Result<ListResult<PostSummary>>

List posts with filtering and pagination.

By default, only live posts (with goes_live_at in the past) are returned. Use ListOptions to include drafts or scheduled posts.

Posts are sorted by goes_live_at descending (newest first).

pub async fn get_post(&self, slug: &str) -> Result<Option<Post>>

Get a single post by its slug.

Returns None if no post with the given slug exists. Note: This returns the post regardless of visibility status.

pub async fn list_series( &self, opts: &ListOptions, ) -> Result<ListResult<SeriesSummary>>

List series with filtering and pagination.

By default, only live series are returned. Series are sorted by goes_live_at descending.

pub async fn get_series(&self, slug: &str) -> Result<Option<Series>>

Get a single series by its slug, including all posts.

Posts within the series are sorted by their order field, with alphabetical fallback for ties or missing values.

pub async fn validate_content(&self) -> Result<Vec<ValidationError>>

Validate content structure and return any errors.

Checks for common issues like empty titles, missing content, etc.

pub async fn list_assets( &self, opts: &AssetListOptions, ) -> Result<AssetListResult>

List assets in the S3/R2 storage bucket with pagination.

Uses cursor-based pagination via S3 continuation tokens. Defaults to 100 assets per page, capped at 1000.

pub async fn upload_asset( &self, path: &Path, dest: Option<&str>, ) -> Result<Asset>

Upload a file to the storage bucket.

Arguments

• path - Local file path to upload
• dest - Optional destination path in bucket (defaults to filename)

pub async fn refresh(&self) -> Result<()>

Refresh the content cache from disk.

Call this after content has been updated (e.g., after a git push) to reload the in-memory cache.

pub async fn content_etag(&self) -> String

Get an ETag representing the current content state.

This is a hash of all content, suitable for HTTP caching headers. The ETag changes when any content is modified.

pub async fn fire_webhooks(&self)

Fire webhooks after content update.

Each webhook is validated and sent atomically: DNS is resolved once, checked against private/internal IP ranges, and the connection is pinned to the validated IP (preventing DNS rebinding/TOCTOU attacks).

If a secret is configured in [webhooks], signs each request body with HMAC-SHA256 and includes the hex signature in the X-Riley-Cms-Signature header. Retries up to 3 times with exponential backoff on network errors or 5xx responses.

pub fn config(&self) -> &RileyCmsConfig

Get a reference to the config.