| 6dd74de | | | 1 | /* eslint-disable no-console */ |
| 6dd74de | | | 2 | import chokidar from 'chokidar'; |
| 6dd74de | | | 3 | import cors from 'cors'; |
| 6dd74de | | | 4 | import { context } from 'esbuild'; |
| 6dd74de | | | 5 | import type { Request, Response } from 'express'; |
| 6dd74de | | | 6 | import express from 'express'; |
| 6dd74de | | | 7 | import { packageOptions } from '../.build/common.js'; |
| 6dd74de | | | 8 | import { generateLangium } from '../.build/generateLangium.js'; |
| 6dd74de | | | 9 | import { defaultOptions, getBuildConfig } from './util.js'; |
| 6dd74de | | | 10 | import 'dotenv/config'; |
| 6dd74de | | | 11 | |
| 6dd74de | | | 12 | const configs = Object.values(packageOptions).map(({ packageName }) => |
| 6dd74de | | | 13 | getBuildConfig({ |
| 6dd74de | | | 14 | ...defaultOptions, |
| 6dd74de | | | 15 | minify: false, |
| 6dd74de | | | 16 | core: false, |
| 6dd74de | | | 17 | options: packageOptions[packageName], |
| 6dd74de | | | 18 | }) |
| 6dd74de | | | 19 | ); |
| 6dd74de | | | 20 | const mermaidIIFEConfig = getBuildConfig({ |
| 6dd74de | | | 21 | ...defaultOptions, |
| 6dd74de | | | 22 | minify: false, |
| 6dd74de | | | 23 | core: false, |
| 6dd74de | | | 24 | options: packageOptions.mermaid, |
| 6dd74de | | | 25 | format: 'iife', |
| 6dd74de | | | 26 | }); |
| 6dd74de | | | 27 | configs.push(mermaidIIFEConfig); |
| 6dd74de | | | 28 | |
| 6dd74de | | | 29 | const contexts = await Promise.all( |
| 6dd74de | | | 30 | configs.map(async (config) => ({ config, context: await context(config) })) |
| 6dd74de | | | 31 | ); |
| 6dd74de | | | 32 | |
| 6dd74de | | | 33 | let rebuildCounter = 1; |
| 6dd74de | | | 34 | const rebuildAll = async () => { |
| 6dd74de | | | 35 | const buildNumber = rebuildCounter++; |
| 6dd74de | | | 36 | const timeLabel = `Rebuild ${buildNumber} Time (total)`; |
| 6dd74de | | | 37 | console.time(timeLabel); |
| 6dd74de | | | 38 | await Promise.all( |
| 6dd74de | | | 39 | contexts.map(async ({ config, context }) => { |
| 6dd74de | | | 40 | const buildVariant = `Rebuild ${buildNumber} Time (${Object.keys(config.entryPoints!)[0]} ${config.format})`; |
| 6dd74de | | | 41 | console.time(buildVariant); |
| 6dd74de | | | 42 | await context.rebuild(); |
| 6dd74de | | | 43 | console.timeEnd(buildVariant); |
| 6dd74de | | | 44 | }) |
| 6dd74de | | | 45 | ).catch((e) => console.error(e)); |
| 6dd74de | | | 46 | console.timeEnd(timeLabel); |
| 6dd74de | | | 47 | }; |
| 6dd74de | | | 48 | |
| 6dd74de | | | 49 | let clients: { id: number; response: Response }[] = []; |
| 6dd74de | | | 50 | function eventsHandler(request: Request, response: Response) { |
| 6dd74de | | | 51 | const headers = { |
| 6dd74de | | | 52 | 'Content-Type': 'text/event-stream', |
| 6dd74de | | | 53 | Connection: 'keep-alive', |
| 6dd74de | | | 54 | 'Cache-Control': 'no-cache', |
| 6dd74de | | | 55 | }; |
| 6dd74de | | | 56 | response.writeHead(200, headers); |
| 6dd74de | | | 57 | const clientId = Date.now(); |
| 6dd74de | | | 58 | clients.push({ |
| 6dd74de | | | 59 | id: clientId, |
| 6dd74de | | | 60 | response, |
| 6dd74de | | | 61 | }); |
| 6dd74de | | | 62 | request.on('close', () => { |
| 6dd74de | | | 63 | clients = clients.filter((client) => client.id !== clientId); |
| 6dd74de | | | 64 | }); |
| 6dd74de | | | 65 | } |
| 6dd74de | | | 66 | |
| 6dd74de | | | 67 | let timeoutID: NodeJS.Timeout | undefined = undefined; |
| 6dd74de | | | 68 | |
| 6dd74de | | | 69 | /** |
| 6dd74de | | | 70 | * Debounce file change events to avoid rebuilding multiple times. |
| 6dd74de | | | 71 | */ |
| 6dd74de | | | 72 | function handleFileChange() { |
| 6dd74de | | | 73 | if (timeoutID !== undefined) { |
| 6dd74de | | | 74 | clearTimeout(timeoutID); |
| 6dd74de | | | 75 | } |
| 6dd74de | | | 76 | // eslint-disable-next-line @typescript-eslint/no-misused-promises |
| 6dd74de | | | 77 | timeoutID = setTimeout(async () => { |
| 6dd74de | | | 78 | await rebuildAll(); |
| 6dd74de | | | 79 | sendEventsToAll(); |
| 6dd74de | | | 80 | timeoutID = undefined; |
| 6dd74de | | | 81 | }, 100); |
| 6dd74de | | | 82 | } |
| 6dd74de | | | 83 | |
| 6dd74de | | | 84 | function sendEventsToAll() { |
| 6dd74de | | | 85 | clients.forEach(({ response }) => response.write(`data: ${Date.now()}\n\n`)); |
| 6dd74de | | | 86 | } |
| 6dd74de | | | 87 | |
| 6dd74de | | | 88 | async function createServer() { |
| 6dd74de | | | 89 | await generateLangium(); |
| 6dd74de | | | 90 | handleFileChange(); |
| 6dd74de | | | 91 | const app = express(); |
| 6dd74de | | | 92 | const port = process.env.MERMAID_PORT ?? 9000; |
| 6dd74de | | | 93 | chokidar |
| 6dd74de | | | 94 | .watch('**/src/**/*.{js,ts,langium,yaml,json}', { |
| 6dd74de | | | 95 | ignoreInitial: true, |
| 6dd74de | | | 96 | ignored: [/node_modules/, /dist/, /docs/, /coverage/], |
| 6dd74de | | | 97 | }) |
| 6dd74de | | | 98 | // eslint-disable-next-line @typescript-eslint/no-misused-promises |
| 6dd74de | | | 99 | .on('all', async (event, path) => { |
| 6dd74de | | | 100 | // Ignore other events. |
| 6dd74de | | | 101 | if (!['add', 'change'].includes(event)) { |
| 6dd74de | | | 102 | return; |
| 6dd74de | | | 103 | } |
| 6dd74de | | | 104 | console.log(`${path} changed. Rebuilding...`); |
| 6dd74de | | | 105 | if (path.endsWith('.langium')) { |
| 6dd74de | | | 106 | await generateLangium(); |
| 6dd74de | | | 107 | } |
| 6dd74de | | | 108 | handleFileChange(); |
| 6dd74de | | | 109 | }); |
| 6dd74de | | | 110 | |
| 6dd74de | | | 111 | app.use(cors()); |
| 6dd74de | | | 112 | app.get('/events', eventsHandler); |
| 6dd74de | | | 113 | for (const { packageName } of Object.values(packageOptions)) { |
| 6dd74de | | | 114 | app.use(express.static(`./packages/${packageName}/dist`)); |
| 6dd74de | | | 115 | } |
| 6dd74de | | | 116 | app.use(express.static('demos')); |
| 6dd74de | | | 117 | app.use(express.static('cypress/platform')); |
| 6dd74de | | | 118 | |
| 6dd74de | | | 119 | app.listen(port, () => { |
| 6dd74de | | | 120 | console.log(`Listening on http://localhost:${port}`); |
| 6dd74de | | | 121 | }); |
| 6dd74de | | | 122 | } |
| 6dd74de | | | 123 | |
| 6dd74de | | | 124 | void createServer(); |