| | |
| | | import path from "path" |
| | | import fs from "fs" |
| | | import { PerfTimer } from "../perf" |
| | | import { PerfTimer } from "../util/perf" |
| | | import { getStaticResourcesFromPlugins } from "../plugins" |
| | | import { EmitCallback } from "../plugins/types" |
| | | import { ProcessedContent } from "../plugins/vfile" |
| | | import { FilePath, joinSegments } from "../path" |
| | | import { QuartzLogger } from "../log" |
| | | import { trace } from "../trace" |
| | | import { BuildCtx } from "../ctx" |
| | | import { QuartzLogger } from "../util/log" |
| | | import { trace } from "../util/trace" |
| | | import { BuildCtx } from "../util/ctx" |
| | | import { styleText } from "util" |
| | | |
| | | export async function emitContent(ctx: BuildCtx, content: ProcessedContent[]) { |
| | | const { argv, cfg } = ctx |
| | | const perf = new PerfTimer() |
| | | const log = new QuartzLogger(ctx.argv.verbose) |
| | | |
| | | log.start(`Emitting output files`) |
| | | const emit: EmitCallback = async ({ slug, ext, content }) => { |
| | | const pathToPage = joinSegments(argv.output, slug + ext) as FilePath |
| | | const dir = path.dirname(pathToPage) |
| | | await fs.promises.mkdir(dir, { recursive: true }) |
| | | await fs.promises.writeFile(pathToPage, content) |
| | | return pathToPage |
| | | } |
| | | log.start(`Emitting files`) |
| | | |
| | | let emittedFiles = 0 |
| | | const staticResources = getStaticResourcesFromPlugins(ctx) |
| | | for (const emitter of cfg.plugins.emitters) { |
| | | try { |
| | | const emitted = await emitter.emit(ctx, content, staticResources, emit) |
| | | emittedFiles += emitted.length |
| | | |
| | | if (ctx.argv.verbose) { |
| | | for (const file of emitted) { |
| | | console.log(`[emit:${emitter.name}] ${file}`) |
| | | await Promise.all( |
| | | cfg.plugins.emitters.map(async (emitter) => { |
| | | try { |
| | | const emitted = await emitter.emit(ctx, content, staticResources) |
| | | if (Symbol.asyncIterator in emitted) { |
| | | // Async generator case |
| | | for await (const file of emitted) { |
| | | emittedFiles++ |
| | | if (ctx.argv.verbose) { |
| | | console.log(`[emit:${emitter.name}] ${file}`) |
| | | } else { |
| | | log.updateText(`${emitter.name} -> ${styleText("gray", file)}`) |
| | | } |
| | | } |
| | | } else { |
| | | // Array case |
| | | emittedFiles += emitted.length |
| | | for (const file of emitted) { |
| | | if (ctx.argv.verbose) { |
| | | console.log(`[emit:${emitter.name}] ${file}`) |
| | | } else { |
| | | log.updateText(`${emitter.name} -> ${styleText("gray", file)}`) |
| | | } |
| | | } |
| | | } |
| | | } catch (err) { |
| | | trace(`Failed to emit from plugin \`${emitter.name}\``, err as Error) |
| | | } |
| | | } catch (err) { |
| | | trace(`Failed to emit from plugin \`${emitter.name}\``, err as Error) |
| | | throw err |
| | | } |
| | | } |
| | | }), |
| | | ) |
| | | |
| | | log.end(`Emitted ${emittedFiles} files to \`${argv.output}\` in ${perf.timeSince()}`) |
| | | } |