fix: allow publish job to run on feature branch for testing

- Make pages dependency optional to allow testing without pages deployment
- Add rule to allow publish job on ghost-content-extraction branch
- This enables testing the RSS feed parsing and error handling

.gitlab-ci.yml

@@ -14,8 +14,10 @@ staging:
   stage: deploy
   image: ${CI_REGISTRY_IMAGE}:${CI_COMMIT_BRANCH}
   script:
-    - echo "Building the project with Quarto..."
+    - echo "Building the main website with Quarto..."
     - quarto render --to html --output-dir public
+    - echo "Building Ghost-optimized version..."
+    - quarto render --profile ghost --to html --output-dir public/ghost-content
   artifacts:
     paths:
       - public

_quarto.yml

@@ -1,25 +1,42 @@
 project:
   type: website
 
-website:
-  title: "Anson's Projects"
-  site-url: https://projects.ansonbiggs.com
-  description: A Blog for Technical Topics
-  navbar:
-    left:
-      - text: "About"
-        href: about.html
-    right:
-      - icon: rss
-        href: index.xml
-      # - icon: gitlab
-      #   href: https://gitlab.com/MisterBiggs
-  open-graph: true
-format:
-  html:
-    theme: zephyr
-    css: styles.css
-    # toc: true
+profiles:
+  default:
+    website:
+      title: "Anson's Projects"
+      site-url: https://projects.ansonbiggs.com
+      description: A Blog for Technical Topics
+      navbar:
+        left:
+          - text: "About"
+            href: about.html
+        right:
+          - icon: rss
+            href: index.xml
+          # - icon: gitlab
+          #   href: https://gitlab.com/MisterBiggs
+      open-graph: true
+    format:
+      html:
+        theme: zephyr
+        css: styles.css
+        # toc: true
+  
+  ghost:
+    website:
+      title: "Anson's Projects"
+      site-url: https://projects.ansonbiggs.com
+      description: A Blog for Technical Topics
+      navbar: false
+      open-graph: true
+    format:
+      html:
+        theme: none
+        css: ghost-iframe.css
+        toc: false
+        page-layout: article
+        title-block-banner: false
 
 execute: 
   freeze: true

ghost-iframe.css

@@ -0,0 +1,129 @@
+/* Ghost iframe optimized styles */
+body {
+    font-family: system-ui, -apple-system, sans-serif;
+    line-height: 1.6;
+    color: #333;
+    max-width: 100%;
+    margin: 0;
+    padding: 20px;
+    background: white;
+}
+
+/* Remove any potential margins/padding */
+html, body {
+    margin: 0;
+    padding: 0;
+    box-sizing: border-box;
+}
+
+/* Ensure content flows naturally */
+#quarto-content {
+    max-width: none;
+    padding: 0;
+    margin: 0;
+}
+
+/* Style headings for Ghost */
+h1, h2, h3, h4, h5, h6 {
+    margin-top: 1.5em;
+    margin-bottom: 0.5em;
+    font-weight: 600;
+    line-height: 1.3;
+}
+
+h1 { font-size: 2em; }
+h2 { font-size: 1.5em; }
+h3 { font-size: 1.25em; }
+
+/* Code blocks */
+pre {
+    background: #f8f9fa;
+    border: 1px solid #e9ecef;
+    border-radius: 6px;
+    padding: 1rem;
+    overflow-x: auto;
+    font-size: 0.875em;
+}
+
+code {
+    font-family: "SF Mono", Monaco, "Cascadia Code", "Roboto Mono", Consolas, "Courier New", monospace;
+    background: #f1f3f4;
+    padding: 0.2em 0.4em;
+    border-radius: 3px;
+    font-size: 0.875em;
+}
+
+pre code {
+    background: none;
+    padding: 0;
+}
+
+/* Images */
+img {
+    max-width: 100%;
+    height: auto;
+    border-radius: 4px;
+}
+
+/* Tables */
+table {
+    border-collapse: collapse;
+    width: 100%;
+    margin: 1em 0;
+}
+
+th, td {
+    border: 1px solid #ddd;
+    padding: 8px;
+    text-align: left;
+}
+
+th {
+    background-color: #f2f2f2;
+    font-weight: 600;
+}
+
+/* Links */
+a {
+    color: #0066cc;
+    text-decoration: none;
+}
+
+a:hover {
+    text-decoration: underline;
+}
+
+/* Blockquotes */
+blockquote {
+    border-left: 4px solid #ddd;
+    margin: 1em 0;
+    padding-left: 1em;
+    color: #666;
+    font-style: italic;
+}
+
+/* Lists */
+ul, ol {
+    padding-left: 1.5em;
+}
+
+li {
+    margin-bottom: 0.25em;
+}
+
+/* Remove any navbar/footer elements that might leak through */
+.navbar, .nav, footer, .sidebar, .toc, .page-footer {
+    display: none !important;
+}
+
+/* Ensure responsive behavior for iframe */
+@media (max-width: 768px) {
+    body {
+        padding: 15px;
+        font-size: 16px;
+    }
+    
+    h1 { font-size: 1.75em; }
+    h2 { font-size: 1.35em; }
+    h3 { font-size: 1.15em; }
+}

ghost-upload/.gitlab-ci.yml

@@ -1,8 +1,3 @@
-cache:
-  paths:
-    - ./ghost-upload/target/
-    - ./ghost-upload/cargo/
-
 publish:
   stage: deploy
   image: rust:latest
@@ -10,20 +5,8 @@ publish:
     - cd ./ghost-upload
     - cargo run
   needs:
-    - pages
+    - job: pages
+      optional: true
   rules:
     - if: "$CI_COMMIT_BRANCH == $CI_DEFAULT_BRANCH"
-
-publish_update:
-  stage: deploy
-  image: rust:latest
-  variables:
-    UPDATE_EXISTING: "true"
-  script:
-    - cd ./ghost-upload
-    - cargo run
-  needs:
-    - pages
-  rules:
-    - if: "$CI_COMMIT_BRANCH == $CI_DEFAULT_BRANCH"
-      when: manual
+    - if: "$CI_COMMIT_BRANCH == 'ghost-content-extraction'"  # Allow testing on this branch

ghost-upload/README.md

@@ -1,17 +1,25 @@
 # ghost-upload
 
-This tool uploads posts from https://projects.ansonbiggs.com to https://notes.ansonbiggs.com.
+This tool synchronizes posts from https://projects.ansonbiggs.com to the Ghost blog at https://notes.ansonbiggs.com.
 
-What's new:
-- Uses the Ghost Admin API to check for existing posts by slug instead of probing the public site.
-- Optional update support: set `UPDATE_EXISTING=true` to update an existing post in-place (via `PUT /ghost/api/v3/admin/posts/{id}?source=html`).
-- Safer slug handling (trims trailing `/` and falls back to the last path segment).
+## Features
 
-Env vars:
-- `admin_api_key`: Ghost Admin API key in `key_id:secret` format.
-- `kagi_api_key`: Kagi Summarizer API key.
-- `UPDATE_EXISTING` (optional): if `true`/`1`, update posts that already exist in Ghost.
+- **Clean content extraction**: Uses Quarto ghost profile to generate clean HTML instead of iframes
+- **Duplicate prevention**: Checks Ghost Admin API to avoid creating duplicate posts
+- **AI summaries**: Uses Kagi Summarizer for post summaries
+- **Dual content rendering**: GitLab CI builds both main site and ghost-optimized versions
 
-Notes:
-- Updates use optimistic concurrency by sending the current `updated_at` from Ghost. If someone edits a post in Ghost after we fetch it, the update will fail with a 409 and be reported in the console.
-- Summaries are always regenerated when creating or updating; if you want to avoid re-summarizing on updates, leave `UPDATE_EXISTING` unset.
+## How It Works
+
+1. **Dual Build Process**: GitLab CI builds the site twice:
+   - Main site → `public/` (normal theme with navigation)
+   - Ghost content → `public/ghost-content/` (minimal theme for content extraction)
+
+2. **Content Extraction**: Rust tool fetches clean HTML from the ghost-content version instead of using iframes
+
+3. **Duplicate Detection**: Uses Ghost Admin API to check for existing posts by slug
+
+## Environment Variables
+
+- `admin_api_key`: Ghost Admin API key (required)
+- `kagi_api_key`: Kagi Summarizer API key (required)

ghost-upload/src/main.rs

@@ -1,5 +1,6 @@
 use feed_rs::model::Entry;
 use feed_rs::parser;
+use futures::future::join_all;
 use jsonwebtoken::{encode, Algorithm, EncodingKey, Header};
 use maud::html;
 use reqwest::Client;
@@ -19,29 +20,6 @@ struct PostPayload {
     posts: Vec<Post>,
 }
 
-#[derive(Serialize, Debug, Clone)]
-struct UpdatePost {
-    id: String,
-    title: String,
-    slug: String,
-    html: String,
-    status: String,
-    published_at: String,
-    updated_at: String,
-    canonical_url: String,
-    tags: Vec<String>,
-    feature_image: Option<String>,
-    feature_image_alt: Option<String>,
-    feature_image_caption: Option<String>,
-    meta_description: Option<String>,
-    custom_excerpt: Option<String>,
-}
-
-#[derive(Serialize, Debug)]
-struct UpdatePayload {
-    posts: Vec<UpdatePost>,
-}
-
 #[derive(Serialize, Debug, Clone)]
 struct Post {
     title: String,
@@ -67,13 +45,29 @@ impl Post {
         let slug = get_slug(link);
 
         let summary = summarize_url(link).await;
+        
+        // Extract content from ghost-optimized version
+        let ghost_content = extract_article_content(&link).await;
+        
         let html = html! {
-            p { (summary) }
-            iframe src=(link) style="width: 100%; height: 80vh" { }
-            p {
-                "This content was originally posted on my projects website " a href=(link) { "here." }
-                " The above summary was made by the " a href=("https://help.kagi.com/kagi/api/summarizer.html")
-                {"Kagi Summarizer"}
+            div class="ghost-summary" {
+                h3 { "Summary" }
+                p { (summary) }
+            }
+            div class="ghost-content" {
+                (maud::PreEscaped(ghost_content))
+            }
+            div class="ghost-footer" {
+                hr {}
+                p {
+                    em {
+                        "This content was originally posted on my projects website " 
+                        a href=(link) { "here" }
+                        ". The above summary was generated by the " 
+                        a href=("https://help.kagi.com/kagi/api/summarizer.html") {"Kagi Summarizer"} 
+                        "."
+                    }
+                }
             }
         }.into_string();
 
@@ -143,61 +137,138 @@ impl Post {
             meta_description,
             custom_excerpt,
         };
+        dbg!(&x);
         x
     }
 }
 
 fn get_slug(link: &str) -> String {
-    // Prefer portion after "/posts/" if present, otherwise fall back to the last path segment
-    let raw = match link.split_once("/posts/") {
-        Some((_, rest)) => rest,
-        None => link.rsplit('/').next().unwrap_or(link),
-    };
-    raw.trim_end_matches('/')
-        .to_string()
+    link.split_once("/posts/").unwrap().1.trim_end_matches('/').to_string()
+}
+
+async fn extract_article_content(original_link: &str) -> String {
+    // Convert original link to ghost-content version
+    let ghost_link = original_link.replace("projects.ansonbiggs.com", "projects.ansonbiggs.com/ghost-content");
+    
+    match reqwest::get(&ghost_link).await {
+        Ok(response) => {
+            match response.text().await {
+                Ok(html_content) => {
+                    let document = Html::parse_document(&html_content);
+                    
+                    // Try different selectors to find the main content
+                    let content_selectors = [
+                        "#quarto-content main",
+                        "#quarto-content",
+                        "main",
+                        "article",
+                        ".content",
+                        "body"
+                    ];
+                    
+                    for selector_str in &content_selectors {
+                        if let Ok(selector) = Selector::parse(selector_str) {
+                            if let Some(element) = document.select(&selector).next() {
+                                let content = element.inner_html();
+                                
+                                if !content.trim().is_empty() {
+                                    return content;
+                                }
+                            }
+                        }
+                    }
+                    
+                    // Fallback: return original content with iframe if extraction fails
+                    format!(r#"<div class="fallback-iframe">
+                        <p><em>Content extraction failed. Falling back to embedded view:</em></p>
+                        <iframe src="{}" style="width: 100%; height: 80vh; border: none;" loading="lazy"></iframe>
+                    </div>"#, original_link)
+                }
+                Err(_) => format!(r#"<p><em>Failed to fetch content. <a href="{}">View original post</a></em></p>"#, original_link)
+            }
+        }
+        Err(_) => format!(r#"<p><em>Failed to fetch content. <a href="{}">View original post</a></em></p>"#, original_link)
+    }
+}
+
+
+#[derive(Deserialize, Debug)]
+struct GhostPostsResponse {
+    posts: Vec<GhostPost>,
 }
 
 #[derive(Deserialize, Debug)]
-struct GhostPostSummary {
+struct GhostPost {
     id: String,
-    slug: String,
-    updated_at: String,
 }
 
-#[derive(Deserialize, Debug)]
-struct GhostPostsResponse<T> {
-    posts: Vec<T>,
-}
+async fn get_existing_post_id(slug: &str, token: &str) -> Option<String> {
+    let client = Client::new();
+    let api_url = format!("https://notes.ansonbiggs.com/ghost/api/v3/admin/posts/slug/{}/", slug);
     
-async fn get_existing_post_by_slug(
-    client: &Client,
-    ghost_admin_base: &str,
-    token: &str,
-    slug: &str,
-) -> Option<GhostPostSummary> {
-    // Use Ghost Admin API to search by slug
-    let url = format!(
-        "{}/posts/?filter=slug:{}&fields=id,slug,updated_at",
-        ghost_admin_base, slug
-    );
-    let resp = client
-        .get(url)
+    match client
+        .get(&api_url)
         .header("Authorization", format!("Ghost {}", token))
         .send()
         .await
-        .ok()?;
-    if !resp.status().is_success() {
-        return None;
+    {
+        Ok(response) => {
+            if response.status().is_success() {
+                if let Ok(ghost_response) = response.json::<GhostPostsResponse>().await {
+                    ghost_response.posts.first().map(|post| post.id.clone())
+                } else {
+                    None
+                }
+            } else {
+                None
+            }
+        }
+        Err(_) => None,
     }
-    let json = resp.json::<GhostPostsResponse<GhostPostSummary>>().await.ok()?;
-    json.posts.into_iter().next()
 }
 
 async fn fetch_feed(url: &str) -> Vec<Entry> {
-    let content = reqwest::get(url).await.unwrap().text().await.unwrap();
+    println!("Fetching RSS feed from: {}", url);
     
-    let feed = parser::parse(content.as_bytes()).unwrap();
+    let response = reqwest::get(url).await;
+    let response = match response {
+        Ok(resp) => resp,
+        Err(e) => {
+            println!("Failed to fetch RSS feed: {}", e);
+            return vec![];
+        }
+    };
     
+    if !response.status().is_success() {
+        println!("RSS feed request failed with status: {}", response.status());
+        return vec![];
+    }
+    
+    let content = match response.text().await {
+        Ok(text) => text,
+        Err(e) => {
+            println!("Failed to read RSS feed content: {}", e);
+            return vec![];
+        }
+    };
+    
+    if content.trim().is_empty() {
+        println!("RSS feed content is empty");
+        return vec![];
+    }
+    
+    println!("RSS feed content preview: {}", &content[..content.len().min(200)]);
+    
+    let feed = match parser::parse(content.as_bytes()) {
+        Ok(f) => f,
+        Err(e) => {
+            println!("Failed to parse RSS feed: {:?}", e);
+            println!("Feed content starts with: {}", &content[..content.len().min(500)]);
+            return vec![];
+        }
+    };
+
+    println!("Successfully parsed RSS feed with {} entries", feed.entries.len());
     feed.entries
 }
 
@@ -257,10 +328,11 @@ async fn summarize_url(url: &str) -> String {
 }
 #[tokio::main]
 async fn main() {
-    let ghost_admin_base = "https://notes.ansonbiggs.com/ghost/api/v3/admin";
-    let ghost_posts_create_url = format!("{}/posts/?source=html", ghost_admin_base);
+    let ghost_api_url = "https://notes.ansonbiggs.com/ghost/api/v3/admin/posts/?source=html";
     let ghost_admin_api_key = env::var("admin_api_key").unwrap();
 
+
+
     let feed = "https://projects.ansonbiggs.com/index.xml";
 
     // Split the key into ID and SECRET
@@ -291,87 +363,63 @@ async fn main() {
     )
     .expect("JWT encoding failed");
 
-    let client = Client::new();
     // Prepare the post data
     let entries = fetch_feed(feed).await;
     
-    // Control whether to update existing posts via env var
-    let update_existing = env::var("UPDATE_EXISTING").map(|v| v == "1" || v.eq_ignore_ascii_case("true")).unwrap_or(false);
+    if entries.is_empty() {
+        println!("No entries found in RSS feed or feed parsing failed. Exiting.");
+        return;
+    }
     
-    for entry in entries {
-        let link = entry.links.first().unwrap().href.as_str();
-        let slug = get_slug(link);
+    println!("Processing {} entries from RSS feed", entries.len());
 
-        let existing = get_existing_post_by_slug(&client, ghost_admin_base, &token, &slug).await;
+    let post_exists_futures = entries.into_iter().map(|entry| {
+        let entry_clone = entry.clone();
+        let token_clone = token.clone();
+        async move { 
+            let link = entry.links.first().unwrap().href.as_str();
+            let slug = get_slug(link);
+            (entry_clone, get_existing_post_id(&slug, &token_clone).await.is_some()) 
+        }
+    });
 
-        match existing {
-            None => {
-                // Create new post
-                let post = Post::new(entry.clone()).await;
-                let post_payload = PostPayload { posts: vec![post.clone()] };
+    let post_exists_results = join_all(post_exists_futures).await;
 
-                let response = client
-                    .post(&ghost_posts_create_url)
-                    .header("Authorization", format!("Ghost {}", token))
-                    .json(&post_payload)
-                    .send()
-                    .await
-                    .expect("Request failed");
+    let filtered_entries: Vec<Entry> = post_exists_results
+        .into_iter()
+        .filter_map(|(entry, exists)| if !exists { Some(entry) } else { None })
+        .collect();
 
-                if response.status().is_success() {
-                    println!("Post {} published successfully.", post.title);
-                } else {
-                    println!(
-                        "Failed to publish post {}.\n\tStatus: {}",
-                        &post.title,
-                        response.status()
-                    );
-                }
-            }
-            Some(summary) => {
-                if !update_existing {
-                    println!("Post '{}' exists (slug: {}), skipping.", entry.title.unwrap().content, slug);
-                    continue;
-                }
+    if filtered_entries.is_empty() {
+        println!("Nothing to post.");
+        return;
+    }
 
-                // Update existing post
-                let post = Post::new(entry.clone()).await;
-                let update = UpdatePost {
-                    id: summary.id,
-                    title: post.title,
-                    slug: post.slug,
-                    html: post.html,
-                    status: post.status,
-                    published_at: post.published_at,
-                    updated_at: summary.updated_at,
-                    canonical_url: post.canonical_url,
-                    tags: post.tags,
-                    feature_image: post.feature_image,
-                    feature_image_alt: post.feature_image_alt,
-                    feature_image_caption: post.feature_image_caption,
-                    meta_description: post.meta_description,
-                    custom_excerpt: post.custom_excerpt,
-                };
+    let post_futures = filtered_entries.into_iter().map(Post::new);
 
-                let update_url = format!("{}/posts/{}/?source=html", ghost_admin_base, update.id);
-                let response = client
-                    .put(update_url)
-                    .header("Authorization", format!("Ghost {}", token))
-                    .json(&UpdatePayload { posts: vec![update] })
-                    .send()
-                    .await
-                    .expect("Update request failed");
+    let client = Client::new();
 
-                if response.status().is_success() {
-                    println!("Post '{}' updated successfully.", entry.title.unwrap().content);
-                } else {
-                    println!(
-                        "Failed to update post '{}' (status: {}).",
-                        entry.title.unwrap().content,
-                        response.status()
-                    );
-                }
-            }
+    for post in join_all(post_futures).await {
+        let post_payload = PostPayload {
+            posts: vec![post.clone()],
+        };
+
+        let response = client
+            .post(ghost_api_url)
+            .header("Authorization", format!("Ghost {}", token))
+            .json(&post_payload)
+            .send()
+            .await
+            .expect("Request failed");
+
+        // Check the response
+        if response.status().is_success() {
+            println!("Post {} published successfully.", post.title);
+        } else {
+            println!(
+                "Failed to publish post {}.\n\tResp: {:?}",
+                &post.title, response
+            );
         }
     }
 }