Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151import { Request } from './api.ts'import { createHtml } from './html.ts'import log from './log.ts'import { getContentType } from './mime.ts'import { injectHmr, Project } from './project.ts'import { path, serve, ws } from './std.ts'import util, { existsFileSync, hashShort } from './util.ts'
export async function start(appDir: string, port: number, isDev = false, reload = false) { const project = new Project(appDir, isDev ? 'development' : 'production', reload) await project.ready
while (true) { try { const s = serve({ port }) log.info(`Server ready on http://localhost:${port}`) for await (const req of s) { const url = new URL('http://localhost/' + req.url) const pathname = util.cleanPath(url.pathname) const resp = new Request(req, pathname, {}, url.searchParams)
try { // serve hmr ws if (pathname === '/_hmr') { const { conn, r: bufReader, w: bufWriter, headers } = req ws.acceptWebSocket({ conn, bufReader, bufWriter, headers }).then(async socket => { const watcher = project.createFSWatcher() watcher.on('add', (moduleId: string, hash: string) => socket.send(JSON.stringify({ type: 'add', moduleId, hash }))) watcher.on('remove', (moduleId: string) => { watcher.removeAllListeners('modify-' + moduleId) socket.send(JSON.stringify({ type: 'remove', moduleId })) }) for await (const e of socket) { if (util.isNEString(e)) { try { const data = JSON.parse(e) if (data.type === 'hotAccept' && util.isNEString(data.id)) { const mod = project.getModule(data.id) if (mod) { watcher.on('modify-' + mod.id, (hash: string) => socket.send(JSON.stringify({ type: 'update', moduleId: mod.id, hash, updateUrl: path.join('/', project.config.baseUrl, '/_aleph/', mod.id.replace(/\.js$/, '') + `.${hash!.slice(0, hashShort)}.js`) }))) } } } catch (e) { } } else if (ws.isWebSocketCloseEvent(e)) { break } } project.removeFSWatcher(watcher) }) continue }
// serve APIs if (pathname.startsWith('/api/')) { project.callAPI(req, { pathname, search: url.search }) continue }
// serve dist files if (pathname.startsWith('/_aleph/')) { if (pathname.startsWith('/_aleph/data/') && pathname.endsWith('/data.js')) { const [p, s] = util.splitBy(util.trimSuffix(util.trimPrefix(pathname, '/_aleph/data'), '/data.js'), '@') const [status, data] = await project.getSSRData({ pathname: p, search: s }) if (status === 200) { resp.send(`export default ` + JSON.stringify(data), 'application/javascript; charset=utf-8') } else { resp.status(status).send('') } continue } else if (pathname.endsWith('.css')) { const filePath = path.join(project.buildDir, util.trimPrefix(pathname, '/_aleph/')) if (existsFileSync(filePath)) { const body = await Deno.readFile(filePath) resp.send(body, 'text/css; charset=utf-8') continue } } else { const reqSourceMap = pathname.endsWith('.js.map') const mod = project.getModuleByPath(reqSourceMap ? pathname.slice(0, -4) : pathname) if (mod) { const etag = req.headers.get('If-None-Match') if (etag && etag === mod.hash) { resp.status(304).send('') continue }
let body = '' if (reqSourceMap) { body = mod.jsSourceMap } else { body = mod.jsContent if (project.isHMRable(mod.id)) { body = injectHmr({ ...mod, jsContent: body }) } } resp.setHeader('ETag', mod.hash) resp.send(body, `application/${reqSourceMap ? 'json' : 'javascript'}; charset=utf-8`) continue } } }
// serve public files const filePath = path.join(project.appRoot, 'public', pathname) if (existsFileSync(filePath)) { const info = await Deno.lstat(filePath) if (info.mtime?.toUTCString() === req.headers.get('If-Modified-Since')) { resp.status(304).send('') continue }
const body = await Deno.readFile(filePath) resp.setHeader('Last-Modified', info.mtime!.toUTCString()) resp.send(body, getContentType(filePath)) continue }
// ssr const [status, html] = await project.getPageHtml({ pathname, search: url.search }) resp.status(status).send(html, 'text/html; charset=utf-8') } catch (err) { resp.status(500).send(createHtml({ lang: 'en', head: ['<title>500 - internal server error</title>'], body: `<p><strong><code>500</code></strong><small> - </small><span>${err.message}</span></p>` }), 'text/html; charset=utf-8') } } } catch (err) { if (err instanceof Deno.errors.AddrInUse) { log.warn(`port ${port} already in use, try ${port + 1}`) port++ } else { log.fatal(err.message) } } }}