You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1204 lines
43KB

  1. extern crate glob;
  2. extern crate rayon;
  3. extern crate serde;
  4. extern crate tera;
  5. #[macro_use]
  6. extern crate serde_derive;
  7. extern crate sass_rs;
  8. #[macro_use]
  9. extern crate errors;
  10. extern crate config;
  11. extern crate front_matter;
  12. extern crate imageproc;
  13. extern crate library;
  14. extern crate link_checker;
  15. extern crate search;
  16. extern crate templates;
  17. extern crate utils;
  18. #[cfg(test)]
  19. extern crate tempfile;
  20. mod sitemap;
  21. use std::collections::HashMap;
  22. use std::fs::{copy, create_dir_all, remove_dir_all};
  23. use std::path::{Path, PathBuf};
  24. use std::sync::{Arc, Mutex, RwLock};
  25. use glob::glob;
  26. use rayon::prelude::*;
  27. use sass_rs::{compile_file, Options as SassOptions, OutputStyle};
  28. use tera::{Context, Tera};
  29. use config::{get_config, Config};
  30. use errors::{Error, ErrorKind, Result};
  31. use front_matter::InsertAnchor;
  32. use library::{
  33. find_taxonomies, sort_actual_pages_by_date, Library, Page, Paginator, Section, Taxonomy,
  34. };
  35. use link_checker::check_url;
  36. use templates::{global_fns, render_redirect_template, ZOLA_TERA};
  37. use utils::fs::{copy_directory, create_directory, create_file, ensure_directory_exists};
  38. use utils::net::get_available_port;
  39. use utils::templates::{render_template, rewrite_theme_paths};
  40. #[derive(Debug)]
  41. pub struct Site {
  42. /// The base path of the zola site
  43. pub base_path: PathBuf,
  44. /// The parsed config for the site
  45. pub config: Config,
  46. pub tera: Tera,
  47. imageproc: Arc<Mutex<imageproc::Processor>>,
  48. // the live reload port to be used if there is one
  49. pub live_reload: Option<u16>,
  50. pub output_path: PathBuf,
  51. content_path: PathBuf,
  52. pub static_path: PathBuf,
  53. pub taxonomies: Vec<Taxonomy>,
  54. /// A map of all .md files (section and pages) and their permalink
  55. /// We need that if there are relative links in the content that need to be resolved
  56. pub permalinks: HashMap<String, String>,
  57. /// Contains all pages and sections of the site
  58. pub library: Arc<RwLock<Library>>,
  59. }
  60. impl Site {
  61. /// Parse a site at the given path. Defaults to the current dir
  62. /// Passing in a path is only used in tests
  63. pub fn new<P: AsRef<Path>>(path: P, config_file: &str) -> Result<Site> {
  64. let path = path.as_ref();
  65. let mut config = get_config(path, config_file);
  66. config.load_extra_syntaxes(path)?;
  67. let tpl_glob =
  68. format!("{}/{}", path.to_string_lossy().replace("\\", "/"), "templates/**/*.*ml");
  69. // Only parsing as we might be extending templates from themes and that would error
  70. // as we haven't loaded them yet
  71. let mut tera =
  72. Tera::parse(&tpl_glob).map_err(|e| Error::chain("Error parsing templates", e))?;
  73. if let Some(theme) = config.theme.clone() {
  74. // Grab data from the extra section of the theme
  75. config.merge_with_theme(&path.join("themes").join(&theme).join("theme.toml"))?;
  76. // Test that the templates folder exist for that theme
  77. let theme_path = path.join("themes").join(&theme);
  78. if !theme_path.join("templates").exists() {
  79. bail!("Theme `{}` is missing a templates folder", theme);
  80. }
  81. let theme_tpl_glob = format!(
  82. "{}/{}",
  83. path.to_string_lossy().replace("\\", "/"),
  84. format!("themes/{}/templates/**/*.*ml", theme)
  85. );
  86. let mut tera_theme = Tera::parse(&theme_tpl_glob)
  87. .map_err(|e| Error::chain("Error parsing templates from themes", e))?;
  88. rewrite_theme_paths(&mut tera_theme, &theme);
  89. // TODO: we do that twice, make it dry?
  90. if theme_path.join("templates").join("robots.txt").exists() {
  91. tera_theme
  92. .add_template_file(theme_path.join("templates").join("robots.txt"), None)?;
  93. }
  94. tera_theme.build_inheritance_chains()?;
  95. tera.extend(&tera_theme)?;
  96. }
  97. tera.extend(&ZOLA_TERA)?;
  98. // the `extend` above already does it but hey
  99. tera.build_inheritance_chains()?;
  100. // TODO: Tera doesn't use globset right now so we can load the robots.txt as part
  101. // of the glob above, therefore we load it manually if it exists.
  102. if path.join("templates").join("robots.txt").exists() {
  103. tera.add_template_file(path.join("templates").join("robots.txt"), Some("robots.txt"))?;
  104. }
  105. let content_path = path.join("content");
  106. let static_path = path.join("static");
  107. let imageproc =
  108. imageproc::Processor::new(content_path.clone(), &static_path, &config.base_url);
  109. let site = Site {
  110. base_path: path.to_path_buf(),
  111. config,
  112. tera,
  113. imageproc: Arc::new(Mutex::new(imageproc)),
  114. live_reload: None,
  115. output_path: path.join("public"),
  116. content_path,
  117. static_path,
  118. taxonomies: Vec::new(),
  119. permalinks: HashMap::new(),
  120. // We will allocate it properly later on
  121. library: Arc::new(RwLock::new(Library::new(0, 0, false))),
  122. };
  123. Ok(site)
  124. }
  125. /// The index sections are ALWAYS at those paths
  126. /// There are one index section for the basic language + 1 per language
  127. fn index_section_paths(&self) -> Vec<(PathBuf, Option<String>)> {
  128. let mut res = vec![(self.content_path.join("_index.md"), None)];
  129. for language in &self.config.languages {
  130. res.push((
  131. self.content_path.join(format!("_index.{}.md", language.code)),
  132. Some(language.code.clone()),
  133. ));
  134. }
  135. res
  136. }
  137. /// We avoid the port the server is going to use as it's not bound yet
  138. /// when calling this function and we could end up having tried to bind
  139. /// both http and websocket server to the same port
  140. pub fn enable_live_reload(&mut self, port_to_avoid: u16) {
  141. self.live_reload = get_available_port(port_to_avoid);
  142. }
  143. /// Get the number of orphan (== without section) pages in the site
  144. pub fn get_number_orphan_pages(&self) -> usize {
  145. self.library.read().unwrap().get_all_orphan_pages().len()
  146. }
  147. pub fn set_base_url(&mut self, base_url: String) {
  148. let mut imageproc = self.imageproc.lock().expect("Couldn't lock imageproc (set_base_url)");
  149. imageproc.set_base_url(&base_url);
  150. self.config.base_url = base_url;
  151. }
  152. pub fn set_output_path<P: AsRef<Path>>(&mut self, path: P) {
  153. self.output_path = path.as_ref().to_path_buf();
  154. }
  155. /// Reads all .md files in the `content` directory and create pages/sections
  156. /// out of them
  157. pub fn load(&mut self) -> Result<()> {
  158. let base_path = self.base_path.to_string_lossy().replace("\\", "/");
  159. let content_glob = format!("{}/{}", base_path, "content/**/*.md");
  160. let (section_entries, page_entries): (Vec<_>, Vec<_>) = glob(&content_glob)
  161. .expect("Invalid glob")
  162. .filter_map(|e| e.ok())
  163. .filter(|e| !e.as_path().file_name().unwrap().to_str().unwrap().starts_with('.'))
  164. .partition(|entry| {
  165. entry.as_path().file_name().unwrap().to_str().unwrap().starts_with("_index.")
  166. });
  167. self.library = Arc::new(RwLock::new(Library::new(
  168. page_entries.len(),
  169. section_entries.len(),
  170. self.config.is_multilingual(),
  171. )));
  172. let sections = {
  173. let config = &self.config;
  174. section_entries
  175. .into_par_iter()
  176. .map(|entry| {
  177. let path = entry.as_path();
  178. Section::from_file(path, config, &self.base_path)
  179. })
  180. .collect::<Vec<_>>()
  181. };
  182. let pages = {
  183. let config = &self.config;
  184. page_entries
  185. .into_par_iter()
  186. .map(|entry| {
  187. let path = entry.as_path();
  188. Page::from_file(path, config, &self.base_path)
  189. })
  190. .collect::<Vec<_>>()
  191. };
  192. // Kinda duplicated code for add_section/add_page but necessary to do it that
  193. // way because of the borrow checker
  194. for section in sections {
  195. let s = section?;
  196. self.add_section(s, false)?;
  197. }
  198. self.create_default_index_sections()?;
  199. let mut pages_insert_anchors = HashMap::new();
  200. for page in pages {
  201. let p = page?;
  202. if p.meta.draft {
  203. continue;
  204. }
  205. pages_insert_anchors.insert(
  206. p.file.path.clone(),
  207. self.find_parent_section_insert_anchor(&p.file.parent.clone(), &p.lang),
  208. );
  209. self.add_page(p, false)?;
  210. }
  211. // taxonomy Tera fns are loaded in `register_early_global_fns`
  212. // so we do need to populate it first.
  213. self.populate_taxonomies()?;
  214. self.register_early_global_fns();
  215. self.populate_sections();
  216. self.render_markdown()?;
  217. self.register_tera_global_fns();
  218. // Needs to be done after rendering markdown as we only get the anchors at that point
  219. self.check_internal_links_with_anchors()?;
  220. if self.config.is_in_check_mode() {
  221. self.check_external_links()?;
  222. }
  223. Ok(())
  224. }
  225. /// Very similar to check_external_links but can't be merged as far as I can see since we always
  226. /// want to check the internal links but only the external in zola check :/
  227. pub fn check_internal_links_with_anchors(&self) -> Result<()> {
  228. let library = self.library.write().expect("Get lock for check_internal_links_with_anchors");
  229. let page_links = library
  230. .pages()
  231. .values()
  232. .map(|p| {
  233. let path = &p.file.path;
  234. p.internal_links_with_anchors.iter().map(move |l| (path.clone(), l))
  235. })
  236. .flatten();
  237. let section_links = library
  238. .sections()
  239. .values()
  240. .map(|p| {
  241. let path = &p.file.path;
  242. p.internal_links_with_anchors.iter().map(move |l| (path.clone(), l))
  243. })
  244. .flatten();
  245. let all_links = page_links.chain(section_links).collect::<Vec<_>>();
  246. if self.config.is_in_check_mode() {
  247. println!("Checking {} internal link(s) with an anchor.", all_links.len());
  248. }
  249. if all_links.is_empty() {
  250. return Ok(());
  251. }
  252. let mut full_path = self.base_path.clone();
  253. full_path.push("content");
  254. let errors: Vec<_> = all_links
  255. .iter()
  256. .filter_map(|(page_path, (md_path, anchor))| {
  257. // There are a few `expect` here since the presence of the .md file will
  258. // already have been checked in the markdown rendering
  259. let mut p = full_path.clone();
  260. for part in md_path.split('/') {
  261. p.push(part);
  262. }
  263. if md_path.contains("_index.md") {
  264. let section = library
  265. .get_section(&p)
  266. .expect("Couldn't find section in check_internal_links_with_anchors");
  267. if section.has_anchor(&anchor) {
  268. None
  269. } else {
  270. Some((page_path, md_path, anchor))
  271. }
  272. } else {
  273. let page = library
  274. .get_page(&p)
  275. .expect("Couldn't find section in check_internal_links_with_anchors");
  276. if page.has_anchor(&anchor) {
  277. None
  278. } else {
  279. Some((page_path, md_path, anchor))
  280. }
  281. }
  282. })
  283. .collect();
  284. if self.config.is_in_check_mode() {
  285. println!("> Checked {} internal link(s) with an anchor: {} error(s) found.", all_links.len(), errors.len());
  286. }
  287. if errors.is_empty() {
  288. return Ok(());
  289. }
  290. let msg = errors
  291. .into_iter()
  292. .map(|(page_path, md_path, anchor)| {
  293. format!(
  294. "The anchor in the link `@/{}#{}` in {} does not exist.",
  295. md_path,
  296. anchor,
  297. page_path.to_string_lossy(),
  298. )
  299. })
  300. .collect::<Vec<_>>()
  301. .join("\n");
  302. Err(Error { kind: ErrorKind::Msg(msg), source: None })
  303. }
  304. pub fn check_external_links(&self) -> Result<()> {
  305. let library = self.library.write().expect("Get lock for check_external_links");
  306. let page_links = library
  307. .pages()
  308. .values()
  309. .map(|p| {
  310. let path = &p.file.path;
  311. p.external_links.iter().map(move |l| (path.clone(), l))
  312. })
  313. .flatten();
  314. let section_links = library
  315. .sections()
  316. .values()
  317. .map(|p| {
  318. let path = &p.file.path;
  319. p.external_links.iter().map(move |l| (path.clone(), l))
  320. })
  321. .flatten();
  322. let all_links = page_links.chain(section_links).collect::<Vec<_>>();
  323. println!("Checking {} external link(s).", all_links.len());
  324. if all_links.is_empty() {
  325. return Ok(());
  326. }
  327. // create thread pool with lots of threads so we can fetch
  328. // (almost) all pages simultaneously
  329. let threads = std::cmp::min(all_links.len(), 32);
  330. let pool = rayon::ThreadPoolBuilder::new()
  331. .num_threads(threads)
  332. .build()
  333. .map_err(|e| Error { kind: ErrorKind::Msg(e.to_string()), source: None })?;
  334. let errors: Vec<_> = pool.install(|| {
  335. all_links
  336. .par_iter()
  337. .filter_map(|(page_path, link)| {
  338. let res = check_url(&link);
  339. if res.is_valid() {
  340. None
  341. } else {
  342. Some((page_path, link, res))
  343. }
  344. })
  345. .collect()
  346. });
  347. println!("> Checked {} external link(s): {} error(s) found.", all_links.len(), errors.len());
  348. if errors.is_empty() {
  349. return Ok(());
  350. }
  351. let msg = errors
  352. .into_iter()
  353. .map(|(page_path, link, check_res)| {
  354. format!(
  355. "Dead link in {} to {}: {}",
  356. page_path.to_string_lossy(),
  357. link,
  358. check_res.message()
  359. )
  360. })
  361. .collect::<Vec<_>>()
  362. .join("\n");
  363. Err(Error { kind: ErrorKind::Msg(msg), source: None })
  364. }
  365. /// Insert a default index section for each language if necessary so we don't need to create
  366. /// a _index.md to render the index page at the root of the site
  367. pub fn create_default_index_sections(&mut self) -> Result<()> {
  368. for (index_path, lang) in self.index_section_paths() {
  369. if let Some(ref index_section) = self.library.read().unwrap().get_section(&index_path) {
  370. if self.config.build_search_index && !index_section.meta.in_search_index {
  371. bail!(
  372. "You have enabled search in the config but disabled it in the index section: \
  373. either turn off the search in the config or remote `in_search_index = true` from the \
  374. section front-matter."
  375. )
  376. }
  377. }
  378. let mut library = self.library.write().expect("Get lock for load");
  379. // Not in else because of borrow checker
  380. if !library.contains_section(&index_path) {
  381. let mut index_section = Section::default();
  382. index_section.file.parent = self.content_path.clone();
  383. index_section.file.filename =
  384. index_path.file_name().unwrap().to_string_lossy().to_string();
  385. if let Some(ref l) = lang {
  386. index_section.file.name = format!("_index.{}", l);
  387. index_section.permalink = self.config.make_permalink(l);
  388. let filename = format!("_index.{}.md", l);
  389. index_section.file.path = self.content_path.join(&filename);
  390. index_section.file.relative = filename;
  391. index_section.lang = index_section.file.find_language(&self.config)?;
  392. } else {
  393. index_section.file.name = "_index".to_string();
  394. index_section.permalink = self.config.make_permalink("");
  395. index_section.file.path = self.content_path.join("_index.md");
  396. index_section.file.relative = "_index.md".to_string();
  397. }
  398. library.insert_section(index_section);
  399. }
  400. }
  401. Ok(())
  402. }
  403. /// Render the markdown of all pages/sections
  404. /// Used in a build and in `serve` if a shortcode has changed
  405. pub fn render_markdown(&mut self) -> Result<()> {
  406. // Another silly thing needed to not borrow &self in parallel and
  407. // make the borrow checker happy
  408. let permalinks = &self.permalinks;
  409. let tera = &self.tera;
  410. let config = &self.config;
  411. // This is needed in the first place because of silly borrow checker
  412. let mut pages_insert_anchors = HashMap::new();
  413. for (_, p) in self.library.read().unwrap().pages() {
  414. pages_insert_anchors.insert(
  415. p.file.path.clone(),
  416. self.find_parent_section_insert_anchor(&p.file.parent.clone(), &p.lang),
  417. );
  418. }
  419. let mut library = self.library.write().expect("Get lock for render_markdown");
  420. library
  421. .pages_mut()
  422. .values_mut()
  423. .collect::<Vec<_>>()
  424. .par_iter_mut()
  425. .map(|page| {
  426. let insert_anchor = pages_insert_anchors[&page.file.path];
  427. page.render_markdown(permalinks, tera, config, insert_anchor)
  428. })
  429. .collect::<Result<()>>()?;
  430. library
  431. .sections_mut()
  432. .values_mut()
  433. .collect::<Vec<_>>()
  434. .par_iter_mut()
  435. .map(|section| section.render_markdown(permalinks, tera, config))
  436. .collect::<Result<()>>()?;
  437. Ok(())
  438. }
  439. /// Adds global fns that are to be available to shortcodes while
  440. /// markdown
  441. pub fn register_early_global_fns(&mut self) {
  442. self.tera.register_function(
  443. "get_url",
  444. global_fns::GetUrl::new(self.config.clone(), self.permalinks.clone()),
  445. );
  446. self.tera.register_function(
  447. "resize_image",
  448. global_fns::ResizeImage::new(self.imageproc.clone()),
  449. );
  450. self.tera.register_function(
  451. "get_image_metadata",
  452. global_fns::GetImageMeta::new(self.content_path.clone()),
  453. );
  454. self.tera.register_function("load_data", global_fns::LoadData::new(self.base_path.clone()));
  455. self.tera.register_function("trans", global_fns::Trans::new(self.config.clone()));
  456. self.tera.register_function(
  457. "get_taxonomy_url",
  458. global_fns::GetTaxonomyUrl::new(&self.taxonomies),
  459. );
  460. }
  461. pub fn register_tera_global_fns(&mut self) {
  462. self.tera.register_function(
  463. "get_page",
  464. global_fns::GetPage::new(self.base_path.clone(), self.library.clone()),
  465. );
  466. self.tera.register_function(
  467. "get_section",
  468. global_fns::GetSection::new(self.base_path.clone(), self.library.clone()),
  469. );
  470. self.tera.register_function(
  471. "get_taxonomy",
  472. global_fns::GetTaxonomy::new(self.taxonomies.clone(), self.library.clone()),
  473. );
  474. }
  475. /// Add a page to the site
  476. /// The `render` parameter is used in the serve command, when rebuilding a page.
  477. /// If `true`, it will also render the markdown for that page
  478. /// Returns the previous page struct if there was one at the same path
  479. pub fn add_page(&mut self, mut page: Page, render: bool) -> Result<Option<Page>> {
  480. self.permalinks.insert(page.file.relative.clone(), page.permalink.clone());
  481. if render {
  482. let insert_anchor =
  483. self.find_parent_section_insert_anchor(&page.file.parent, &page.lang);
  484. page.render_markdown(&self.permalinks, &self.tera, &self.config, insert_anchor)?;
  485. }
  486. let mut library = self.library.write().expect("Get lock for add_page");
  487. let prev = library.remove_page(&page.file.path);
  488. library.insert_page(page);
  489. Ok(prev)
  490. }
  491. /// Add a section to the site
  492. /// The `render` parameter is used in the serve command, when rebuilding a page.
  493. /// If `true`, it will also render the markdown for that page
  494. /// Returns the previous section struct if there was one at the same path
  495. pub fn add_section(&mut self, mut section: Section, render: bool) -> Result<Option<Section>> {
  496. self.permalinks.insert(section.file.relative.clone(), section.permalink.clone());
  497. if render {
  498. section.render_markdown(&self.permalinks, &self.tera, &self.config)?;
  499. }
  500. let mut library = self.library.write().expect("Get lock for add_section");
  501. let prev = library.remove_section(&section.file.path);
  502. library.insert_section(section);
  503. Ok(prev)
  504. }
  505. /// Finds the insert_anchor for the parent section of the directory at `path`.
  506. /// Defaults to `AnchorInsert::None` if no parent section found
  507. pub fn find_parent_section_insert_anchor(
  508. &self,
  509. parent_path: &PathBuf,
  510. lang: &str,
  511. ) -> InsertAnchor {
  512. let parent = if lang != self.config.default_language {
  513. parent_path.join(format!("_index.{}.md", lang))
  514. } else {
  515. parent_path.join("_index.md")
  516. };
  517. match self.library.read().unwrap().get_section(&parent) {
  518. Some(s) => s.meta.insert_anchor_links,
  519. None => InsertAnchor::None,
  520. }
  521. }
  522. /// Find out the direct subsections of each subsection if there are some
  523. /// as well as the pages for each section
  524. pub fn populate_sections(&mut self) {
  525. let mut library = self.library.write().expect("Get lock for populate_sections");
  526. library.populate_sections(&self.config);
  527. }
  528. /// Find all the tags and categories if it's asked in the config
  529. pub fn populate_taxonomies(&mut self) -> Result<()> {
  530. if self.config.taxonomies.is_empty() {
  531. return Ok(());
  532. }
  533. self.taxonomies = find_taxonomies(&self.config, &self.library.read().unwrap())?;
  534. Ok(())
  535. }
  536. /// Inject live reload script tag if in live reload mode
  537. fn inject_livereload(&self, html: String) -> String {
  538. if let Some(port) = self.live_reload {
  539. return html.replace(
  540. "</body>",
  541. &format!(
  542. r#"<script src="/livereload.js?port={}&mindelay=10"></script></body>"#,
  543. port
  544. ),
  545. );
  546. }
  547. html
  548. }
  549. /// Copy the main `static` folder and the theme `static` folder if a theme is used
  550. pub fn copy_static_directories(&self) -> Result<()> {
  551. // The user files will overwrite the theme files
  552. if let Some(ref theme) = self.config.theme {
  553. copy_directory(
  554. &self.base_path.join("themes").join(theme).join("static"),
  555. &self.output_path,
  556. false
  557. )?;
  558. }
  559. // We're fine with missing static folders
  560. if self.static_path.exists() {
  561. copy_directory(&self.static_path, &self.output_path, self.config.hard_link_static)?;
  562. }
  563. Ok(())
  564. }
  565. pub fn num_img_ops(&self) -> usize {
  566. let imageproc = self.imageproc.lock().expect("Couldn't lock imageproc (num_img_ops)");
  567. imageproc.num_img_ops()
  568. }
  569. pub fn process_images(&self) -> Result<()> {
  570. let mut imageproc =
  571. self.imageproc.lock().expect("Couldn't lock imageproc (process_images)");
  572. imageproc.prune()?;
  573. imageproc.do_process()
  574. }
  575. /// Deletes the `public` directory if it exists
  576. pub fn clean(&self) -> Result<()> {
  577. if self.output_path.exists() {
  578. // Delete current `public` directory so we can start fresh
  579. remove_dir_all(&self.output_path)
  580. .map_err(|e| Error::chain("Couldn't delete output directory", e))?;
  581. }
  582. Ok(())
  583. }
  584. /// Renders a single content page
  585. pub fn render_page(&self, page: &Page) -> Result<()> {
  586. ensure_directory_exists(&self.output_path)?;
  587. // Copy the nesting of the content directory if we have sections for that page
  588. let mut current_path = self.output_path.to_path_buf();
  589. for component in page.path.split('/') {
  590. current_path.push(component);
  591. if !current_path.exists() {
  592. create_directory(&current_path)?;
  593. }
  594. }
  595. // Make sure the folder exists
  596. create_directory(&current_path)?;
  597. // Finally, create a index.html file there with the page rendered
  598. let output = page.render_html(&self.tera, &self.config, &self.library.read().unwrap())?;
  599. create_file(&current_path.join("index.html"), &self.inject_livereload(output))?;
  600. // Copy any asset we found previously into the same directory as the index.html
  601. for asset in &page.assets {
  602. let asset_path = asset.as_path();
  603. copy(
  604. &asset_path,
  605. &current_path
  606. .join(asset_path.file_name().expect("Couldn't get filename from page asset")),
  607. )?;
  608. }
  609. Ok(())
  610. }
  611. /// Deletes the `public` directory and builds the site
  612. pub fn build(&self) -> Result<()> {
  613. self.clean()?;
  614. // Generate/move all assets before rendering any content
  615. if let Some(ref theme) = self.config.theme {
  616. let theme_path = self.base_path.join("themes").join(theme);
  617. if theme_path.join("sass").exists() {
  618. self.compile_sass(&theme_path)?;
  619. }
  620. }
  621. if self.config.compile_sass {
  622. self.compile_sass(&self.base_path)?;
  623. }
  624. if self.config.build_search_index {
  625. self.build_search_index()?;
  626. }
  627. // Render aliases first to allow overwriting
  628. self.render_aliases()?;
  629. self.render_sections()?;
  630. self.render_orphan_pages()?;
  631. self.render_sitemap()?;
  632. let library = self.library.read().unwrap();
  633. if self.config.generate_rss {
  634. let pages = if self.config.is_multilingual() {
  635. library
  636. .pages_values()
  637. .iter()
  638. .filter(|p| p.lang == self.config.default_language)
  639. .cloned()
  640. .collect()
  641. } else {
  642. library.pages_values()
  643. };
  644. self.render_rss_feed(pages, None)?;
  645. }
  646. for lang in &self.config.languages {
  647. if !lang.rss {
  648. continue;
  649. }
  650. let pages =
  651. library.pages_values().iter().filter(|p| p.lang == lang.code).cloned().collect();
  652. self.render_rss_feed(pages, Some(&PathBuf::from(lang.code.clone())))?;
  653. }
  654. self.render_404()?;
  655. self.render_robots()?;
  656. self.render_taxonomies()?;
  657. // We process images at the end as we might have picked up images to process from markdown
  658. // or from templates
  659. self.process_images()?;
  660. // Processed images will be in static so the last step is to copy it
  661. self.copy_static_directories()?;
  662. Ok(())
  663. }
  664. pub fn build_search_index(&self) -> Result<()> {
  665. // index first
  666. create_file(
  667. &self.output_path.join(&format!("search_index.{}.js", self.config.default_language)),
  668. &format!(
  669. "window.searchIndex = {};",
  670. search::build_index(&self.config.default_language, &self.library.read().unwrap())?
  671. ),
  672. )?;
  673. // then elasticlunr.min.js
  674. create_file(&self.output_path.join("elasticlunr.min.js"), search::ELASTICLUNR_JS)?;
  675. Ok(())
  676. }
  677. pub fn compile_sass(&self, base_path: &Path) -> Result<()> {
  678. ensure_directory_exists(&self.output_path)?;
  679. let sass_path = {
  680. let mut sass_path = PathBuf::from(base_path);
  681. sass_path.push("sass");
  682. sass_path
  683. };
  684. let mut options = SassOptions::default();
  685. options.output_style = OutputStyle::Compressed;
  686. let mut compiled_paths = self.compile_sass_glob(&sass_path, "scss", &options.clone())?;
  687. options.indented_syntax = true;
  688. compiled_paths.extend(self.compile_sass_glob(&sass_path, "sass", &options)?);
  689. compiled_paths.sort();
  690. for window in compiled_paths.windows(2) {
  691. if window[0].1 == window[1].1 {
  692. bail!(
  693. "SASS path conflict: \"{}\" and \"{}\" both compile to \"{}\"",
  694. window[0].0.display(),
  695. window[1].0.display(),
  696. window[0].1.display(),
  697. );
  698. }
  699. }
  700. Ok(())
  701. }
  702. fn compile_sass_glob(
  703. &self,
  704. sass_path: &Path,
  705. extension: &str,
  706. options: &SassOptions,
  707. ) -> Result<Vec<(PathBuf, PathBuf)>> {
  708. let glob_string = format!("{}/**/*.{}", sass_path.display(), extension);
  709. let files = glob(&glob_string)
  710. .expect("Invalid glob for sass")
  711. .filter_map(|e| e.ok())
  712. .filter(|entry| {
  713. !entry.as_path().file_name().unwrap().to_string_lossy().starts_with('_')
  714. })
  715. .collect::<Vec<_>>();
  716. let mut compiled_paths = Vec::new();
  717. for file in files {
  718. let css = compile_file(&file, options.clone())?;
  719. let path_inside_sass = file.strip_prefix(&sass_path).unwrap();
  720. let parent_inside_sass = path_inside_sass.parent();
  721. let css_output_path = self.output_path.join(path_inside_sass).with_extension("css");
  722. if parent_inside_sass.is_some() {
  723. create_dir_all(&css_output_path.parent().unwrap())?;
  724. }
  725. create_file(&css_output_path, &css)?;
  726. compiled_paths.push((path_inside_sass.to_owned(), css_output_path));
  727. }
  728. Ok(compiled_paths)
  729. }
  730. fn render_alias(&self, alias: &str, permalink: &str) -> Result<()> {
  731. let mut output_path = self.output_path.to_path_buf();
  732. let mut split = alias.split('/').collect::<Vec<_>>();
  733. // If the alias ends with an html file name, use that instead of mapping
  734. // as a path containing an `index.html`
  735. let page_name = match split.pop() {
  736. Some(part) if part.ends_with(".html") => part,
  737. Some(part) => {
  738. split.push(part);
  739. "index.html"
  740. }
  741. None => "index.html",
  742. };
  743. for component in split {
  744. output_path.push(&component);
  745. if !output_path.exists() {
  746. create_directory(&output_path)?;
  747. }
  748. }
  749. create_file(
  750. &output_path.join(page_name),
  751. &render_redirect_template(&permalink, &self.tera)?,
  752. )
  753. }
  754. pub fn render_aliases(&self) -> Result<()> {
  755. ensure_directory_exists(&self.output_path)?;
  756. let library = self.library.read().unwrap();
  757. for (_, page) in library.pages() {
  758. for alias in &page.meta.aliases {
  759. self.render_alias(&alias, &page.permalink)?;
  760. }
  761. }
  762. for (_, section) in library.sections() {
  763. for alias in &section.meta.aliases {
  764. self.render_alias(&alias, &section.permalink)?;
  765. }
  766. }
  767. Ok(())
  768. }
  769. /// Renders 404.html
  770. pub fn render_404(&self) -> Result<()> {
  771. ensure_directory_exists(&self.output_path)?;
  772. let mut context = Context::new();
  773. context.insert("config", &self.config);
  774. let output = render_template("404.html", &self.tera, context, &self.config.theme)?;
  775. create_file(&self.output_path.join("404.html"), &self.inject_livereload(output))
  776. }
  777. /// Renders robots.txt
  778. pub fn render_robots(&self) -> Result<()> {
  779. ensure_directory_exists(&self.output_path)?;
  780. let mut context = Context::new();
  781. context.insert("config", &self.config);
  782. create_file(
  783. &self.output_path.join("robots.txt"),
  784. &render_template("robots.txt", &self.tera, context, &self.config.theme)?,
  785. )
  786. }
  787. /// Renders all taxonomies with at least one non-draft post
  788. pub fn render_taxonomies(&self) -> Result<()> {
  789. for taxonomy in &self.taxonomies {
  790. self.render_taxonomy(taxonomy)?;
  791. }
  792. Ok(())
  793. }
  794. fn render_taxonomy(&self, taxonomy: &Taxonomy) -> Result<()> {
  795. if taxonomy.items.is_empty() {
  796. return Ok(());
  797. }
  798. ensure_directory_exists(&self.output_path)?;
  799. let output_path = if taxonomy.kind.lang != self.config.default_language {
  800. let mid_path = self.output_path.join(&taxonomy.kind.lang);
  801. create_directory(&mid_path)?;
  802. mid_path.join(&taxonomy.kind.name)
  803. } else {
  804. self.output_path.join(&taxonomy.kind.name)
  805. };
  806. let list_output =
  807. taxonomy.render_all_terms(&self.tera, &self.config, &self.library.read().unwrap())?;
  808. create_directory(&output_path)?;
  809. create_file(&output_path.join("index.html"), &self.inject_livereload(list_output))?;
  810. let library = self.library.read().unwrap();
  811. taxonomy
  812. .items
  813. .par_iter()
  814. .map(|item| {
  815. let path = output_path.join(&item.slug);
  816. if taxonomy.kind.is_paginated() {
  817. self.render_paginated(
  818. &path,
  819. &Paginator::from_taxonomy(&taxonomy, item, &library),
  820. )?;
  821. } else {
  822. let single_output =
  823. taxonomy.render_term(item, &self.tera, &self.config, &library)?;
  824. create_directory(&path)?;
  825. create_file(&path.join("index.html"), &self.inject_livereload(single_output))?;
  826. }
  827. if taxonomy.kind.rss {
  828. self.render_rss_feed(
  829. item.pages.iter().map(|p| library.get_page_by_key(*p)).collect(),
  830. Some(&PathBuf::from(format!("{}/{}", taxonomy.kind.name, item.slug))),
  831. )
  832. } else {
  833. Ok(())
  834. }
  835. })
  836. .collect::<Result<()>>()
  837. }
  838. /// What it says on the tin
  839. pub fn render_sitemap(&self) -> Result<()> {
  840. ensure_directory_exists(&self.output_path)?;
  841. let library = self.library.read().unwrap();
  842. let all_sitemap_entries = {
  843. let mut all_sitemap_entries =
  844. sitemap::find_entries(&library, &self.taxonomies[..], &self.config);
  845. all_sitemap_entries.sort();
  846. all_sitemap_entries
  847. };
  848. let sitemap_limit = 30000;
  849. if all_sitemap_entries.len() < sitemap_limit {
  850. // Create single sitemap
  851. let mut context = Context::new();
  852. context.insert("entries", &all_sitemap_entries);
  853. let sitemap = &render_template("sitemap.xml", &self.tera, context, &self.config.theme)?;
  854. create_file(&self.output_path.join("sitemap.xml"), sitemap)?;
  855. return Ok(());
  856. }
  857. // Create multiple sitemaps (max 30000 urls each)
  858. let mut sitemap_index = Vec::new();
  859. for (i, chunk) in
  860. all_sitemap_entries.iter().collect::<Vec<_>>().chunks(sitemap_limit).enumerate()
  861. {
  862. let mut context = Context::new();
  863. context.insert("entries", &chunk);
  864. let sitemap = &render_template("sitemap.xml", &self.tera, context, &self.config.theme)?;
  865. let file_name = format!("sitemap{}.xml", i + 1);
  866. create_file(&self.output_path.join(&file_name), sitemap)?;
  867. let mut sitemap_url: String = self.config.make_permalink(&file_name);
  868. sitemap_url.pop(); // Remove trailing slash
  869. sitemap_index.push(sitemap_url);
  870. }
  871. // Create main sitemap that reference numbered sitemaps
  872. let mut main_context = Context::new();
  873. main_context.insert("sitemaps", &sitemap_index);
  874. let sitemap = &render_template(
  875. "split_sitemap_index.xml",
  876. &self.tera,
  877. main_context,
  878. &self.config.theme,
  879. )?;
  880. create_file(&self.output_path.join("sitemap.xml"), sitemap)?;
  881. Ok(())
  882. }
  883. /// Renders a RSS feed for the given path and at the given path
  884. /// If both arguments are `None`, it will render only the RSS feed for the whole
  885. /// site at the root folder.
  886. pub fn render_rss_feed(
  887. &self,
  888. all_pages: Vec<&Page>,
  889. base_path: Option<&PathBuf>,
  890. ) -> Result<()> {
  891. ensure_directory_exists(&self.output_path)?;
  892. let mut context = Context::new();
  893. let mut pages = all_pages
  894. .into_iter()
  895. .filter(|p| p.meta.date.is_some() && !p.is_draft())
  896. .collect::<Vec<_>>();
  897. // Don't generate a RSS feed if none of the pages has a date
  898. if pages.is_empty() {
  899. return Ok(());
  900. }
  901. pages.par_sort_unstable_by(sort_actual_pages_by_date);
  902. context.insert("last_build_date", &pages[0].meta.date.clone());
  903. let library = self.library.read().unwrap();
  904. // limit to the last n elements if the limit is set; otherwise use all.
  905. let num_entries = self.config.rss_limit.unwrap_or_else(|| pages.len());
  906. let p = pages
  907. .iter()
  908. .take(num_entries)
  909. .map(|x| x.to_serialized_basic(&library))
  910. .collect::<Vec<_>>();
  911. context.insert("pages", &p);
  912. context.insert("config", &self.config);
  913. let rss_feed_url = if let Some(ref base) = base_path {
  914. self.config.make_permalink(&base.join("rss.xml").to_string_lossy().replace('\\', "/"))
  915. } else {
  916. self.config.make_permalink("rss.xml")
  917. };
  918. context.insert("feed_url", &rss_feed_url);
  919. let feed = &render_template("rss.xml", &self.tera, context, &self.config.theme)?;
  920. if let Some(ref base) = base_path {
  921. let mut output_path = self.output_path.clone();
  922. for component in base.components() {
  923. output_path.push(component);
  924. if !output_path.exists() {
  925. create_directory(&output_path)?;
  926. }
  927. }
  928. create_file(&output_path.join("rss.xml"), feed)?;
  929. } else {
  930. create_file(&self.output_path.join("rss.xml"), feed)?;
  931. }
  932. Ok(())
  933. }
  934. /// Renders a single section
  935. pub fn render_section(&self, section: &Section, render_pages: bool) -> Result<()> {
  936. ensure_directory_exists(&self.output_path)?;
  937. let mut output_path = self.output_path.clone();
  938. if section.lang != self.config.default_language {
  939. output_path.push(&section.lang);
  940. if !output_path.exists() {
  941. create_directory(&output_path)?;
  942. }
  943. }
  944. for component in &section.file.components {
  945. output_path.push(component);
  946. if !output_path.exists() {
  947. create_directory(&output_path)?;
  948. }
  949. }
  950. // Copy any asset we found previously into the same directory as the index.html
  951. for asset in &section.assets {
  952. let asset_path = asset.as_path();
  953. copy(
  954. &asset_path,
  955. &output_path.join(
  956. asset_path.file_name().expect("Failed to get asset filename for section"),
  957. ),
  958. )?;
  959. }
  960. if render_pages {
  961. section
  962. .pages
  963. .par_iter()
  964. .map(|k| self.render_page(self.library.read().unwrap().get_page_by_key(*k)))
  965. .collect::<Result<()>>()?;
  966. }
  967. if !section.meta.render {
  968. return Ok(());
  969. }
  970. if let Some(ref redirect_to) = section.meta.redirect_to {
  971. let permalink = self.config.make_permalink(redirect_to);
  972. create_file(
  973. &output_path.join("index.html"),
  974. &render_redirect_template(&permalink, &self.tera)?,
  975. )?;
  976. return Ok(());
  977. }
  978. if section.meta.is_paginated() {
  979. self.render_paginated(
  980. &output_path,
  981. &Paginator::from_section(&section, &self.library.read().unwrap()),
  982. )?;
  983. } else {
  984. let output =
  985. section.render_html(&self.tera, &self.config, &self.library.read().unwrap())?;
  986. create_file(&output_path.join("index.html"), &self.inject_livereload(output))?;
  987. }
  988. Ok(())
  989. }
  990. /// Used only on reload
  991. pub fn render_index(&self) -> Result<()> {
  992. self.render_section(
  993. &self
  994. .library
  995. .read()
  996. .unwrap()
  997. .get_section(&self.content_path.join("_index.md"))
  998. .expect("Failed to get index section"),
  999. false,
  1000. )
  1001. }
  1002. /// Renders all sections
  1003. pub fn render_sections(&self) -> Result<()> {
  1004. self.library
  1005. .read()
  1006. .unwrap()
  1007. .sections_values()
  1008. .into_par_iter()
  1009. .map(|s| self.render_section(s, true))
  1010. .collect::<Result<()>>()
  1011. }
  1012. /// Renders all pages that do not belong to any sections
  1013. pub fn render_orphan_pages(&self) -> Result<()> {
  1014. ensure_directory_exists(&self.output_path)?;
  1015. let library = self.library.read().unwrap();
  1016. for page in library.get_all_orphan_pages() {
  1017. self.render_page(page)?;
  1018. }
  1019. Ok(())
  1020. }
  1021. /// Renders a list of pages when the section/index is wanting pagination.
  1022. pub fn render_paginated(&self, output_path: &Path, paginator: &Paginator) -> Result<()> {
  1023. ensure_directory_exists(&self.output_path)?;
  1024. let folder_path = output_path.join(&paginator.paginate_path);
  1025. create_directory(&folder_path)?;
  1026. paginator
  1027. .pagers
  1028. .par_iter()
  1029. .map(|pager| {
  1030. let page_path = folder_path.join(&format!("{}", pager.index));
  1031. create_directory(&page_path)?;
  1032. let output = paginator.render_pager(
  1033. pager,
  1034. &self.config,
  1035. &self.tera,
  1036. &self.library.read().unwrap(),
  1037. )?;
  1038. if pager.index > 1 {
  1039. create_file(&page_path.join("index.html"), &self.inject_livereload(output))?;
  1040. } else {
  1041. create_file(&output_path.join("index.html"), &self.inject_livereload(output))?;
  1042. create_file(
  1043. &page_path.join("index.html"),
  1044. &render_redirect_template(&paginator.permalink, &self.tera)?,
  1045. )?;
  1046. }
  1047. Ok(())
  1048. })
  1049. .collect::<Result<()>>()
  1050. }
  1051. }