| | |
| | | import chokidar from "chokidar" |
| | | import prettyBytes from "pretty-bytes" |
| | | import { execSync, spawnSync } from "child_process" |
| | | import { transform as cssTransform } from "lightningcss" |
| | | import http from "http" |
| | | import serveHandler from "serve-handler" |
| | | import { WebSocketServer } from "ws" |
| | | import { randomUUID } from "crypto" |
| | | |
| | | const ORIGIN_NAME = "origin" |
| | | const UPSTREAM_NAME = "upstream" |
| | |
| | | default: false, |
| | | describe: "run a local server to live-preview your Quartz", |
| | | }, |
| | | baseDir: { |
| | | string: true, |
| | | describe: "base path to serve your local server on", |
| | | }, |
| | | port: { |
| | | number: true, |
| | | default: 8080, |
| | |
| | | default: false, |
| | | describe: "show detailed bundle information", |
| | | }, |
| | | concurrency: { |
| | | number: true, |
| | | describe: "how many threads to use to parse notes", |
| | | }, |
| | | } |
| | | |
| | | function escapePath(fp) { |
| | |
| | | } |
| | | |
| | | function gitPull(origin, branch) { |
| | | const flags = ["-s", "recursive", "-X", "ours", "--no-edit"] |
| | | const flags = ["--no-rebase", "--autostash", "-s", "recursive", "-X", "ours", "--no-edit"] |
| | | spawnSync("git", ["pull", ...flags, origin, branch], { stdio: "inherit" }) |
| | | } |
| | | |
| | |
| | | outfile: path.join("quartz", cacheFile), |
| | | bundle: true, |
| | | keepNames: true, |
| | | minify: true, |
| | | minifyWhitespace: true, |
| | | minifySyntax: true, |
| | | platform: "node", |
| | | format: "esm", |
| | | jsx: "automatic", |
| | |
| | | packages: "external", |
| | | metafile: true, |
| | | sourcemap: true, |
| | | sourcesContent: false, |
| | | plugins: [ |
| | | sassPlugin({ |
| | | type: "css-text", |
| | | cssImports: true, |
| | | async transform(css) { |
| | | const { code } = cssTransform({ |
| | | filename: "style.css", |
| | | code: Buffer.from(css), |
| | | minify: true, |
| | | }) |
| | | return code.toString() |
| | | }, |
| | | }), |
| | | { |
| | | name: "inline-script-loader", |
| | |
| | | ], |
| | | }) |
| | | |
| | | let clientRefresh = () => {} |
| | | let closeHandler = null |
| | | const build = async () => { |
| | | const build = async (clientRefresh) => { |
| | | const result = await ctx.rebuild().catch((err) => { |
| | | console.error(`${chalk.red("Couldn't parse Quartz configuration:")} ${fp}`) |
| | | console.log(`Reason: ${chalk.grey(err)}`) |
| | |
| | | } |
| | | |
| | | // bypass module cache |
| | | const { default: buildQuartz } = await import(cacheFile + `?update=${new Date()}`) |
| | | if (closeHandler) { |
| | | await closeHandler() |
| | | } |
| | | |
| | | closeHandler = await buildQuartz(argv, clientRefresh) |
| | | // https://github.com/nodejs/modules/issues/307 |
| | | const { default: buildQuartz } = await import(cacheFile + `?update=${randomUUID()}`) |
| | | await buildQuartz(argv, clientRefresh) |
| | | clientRefresh() |
| | | } |
| | | |
| | | await build() |
| | | if (argv.serve) { |
| | | const wss = new WebSocketServer({ port: 3001 }) |
| | | const connections = [] |
| | | wss.on("connection", (ws) => connections.push(ws)) |
| | | clientRefresh = () => connections.forEach((conn) => conn.send("rebuild")) |
| | | const clientRefresh = () => connections.forEach((conn) => conn.send("rebuild")) |
| | | |
| | | await build(clientRefresh) |
| | | const server = http.createServer(async (req, res) => { |
| | | await serveHandler(req, res, { |
| | | public: argv.output, |
| | | directoryListing: false, |
| | | }) |
| | | const status = res.statusCode |
| | | const statusString = |
| | | status >= 200 && status < 300 |
| | | ? chalk.green(`[${status}]`) |
| | | : status >= 300 && status < 400 |
| | | ? chalk.yellow(`[${status}]`) |
| | | : chalk.red(`[${status}]`) |
| | | console.log(statusString + chalk.grey(` ${req.url}`)) |
| | | const serve = async () => { |
| | | await serveHandler(req, res, { |
| | | public: argv.output, |
| | | directoryListing: false, |
| | | }) |
| | | const status = res.statusCode |
| | | const statusString = |
| | | status >= 200 && status < 300 ? chalk.green(`[${status}]`) : chalk.red(`[${status}]`) |
| | | console.log(statusString + chalk.grey(` ${req.url}`)) |
| | | } |
| | | |
| | | const redirect = (newFp) => { |
| | | res.writeHead(302, { |
| | | Location: newFp, |
| | | }) |
| | | console.log(chalk.yellow("[302]") + chalk.grey(` ${req.url} -> ${newFp}`)) |
| | | res.end() |
| | | } |
| | | |
| | | let fp = req.url?.split("?")[0] ?? "/" |
| | | |
| | | // handle redirects |
| | | if (fp.endsWith("/")) { |
| | | // /trailing/ |
| | | // does /trailing/index.html exist? if so, serve it |
| | | const indexFp = path.posix.join(fp, "index.html") |
| | | if (fs.existsSync(path.posix.join(argv.output, indexFp))) { |
| | | req.url = fp |
| | | return serve() |
| | | } |
| | | |
| | | // does /trailing.html exist? if so, redirect to /trailing |
| | | let base = fp.slice(0, -1) |
| | | if (path.extname(base) === "") { |
| | | base += ".html" |
| | | } |
| | | if (fs.existsSync(path.posix.join(argv.output, base))) { |
| | | return redirect(fp.slice(0, -1)) |
| | | } |
| | | } else { |
| | | // /regular |
| | | // does /regular.html exist? if so, serve it |
| | | let base = fp |
| | | if (path.extname(base) === "") { |
| | | base += ".html" |
| | | } |
| | | if (fs.existsSync(path.posix.join(argv.output, base))) { |
| | | req.url = fp |
| | | return serve() |
| | | } |
| | | |
| | | // does /regular/index.html exist? if so, redirect to /regular/ |
| | | let indexFp = path.posix.join(fp, "index.html") |
| | | if (fs.existsSync(path.posix.join(argv.output, indexFp))) { |
| | | return redirect(fp + "/") |
| | | } |
| | | } |
| | | |
| | | return serve() |
| | | }) |
| | | server.listen(argv.port) |
| | | console.log(chalk.cyan(`Started a Quartz server listening at http://localhost:${argv.port}`)) |
| | |
| | | }) |
| | | .on("all", async () => { |
| | | console.log(chalk.yellow("Detected a source code change, doing a hard rebuild...")) |
| | | await build() |
| | | await build(clientRefresh) |
| | | }) |
| | | } else { |
| | | await build(() => { }) |
| | | ctx.dispose() |
| | | } |
| | | }) |