Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226import * as path from 'https://deno.land/std@0.90.0/path/mod.ts'import { serve as stdServe, serveTLS } from 'https://deno.land/std@0.90.0/http/server.ts'import { acceptWebSocket, isWebSocketCloseEvent } from 'https://deno.land/std@0.90.0/ws/mod.ts'import { trimModuleExt } from '../framework/core/module.ts'import { rewriteURL, RouteModule } from '../framework/core/routing.ts'import { existsFileSync } from '../shared/fs.ts'import log from '../shared/log.ts'import util from '../shared/util.ts'import type { ServerRequest } from '../types.ts'import { Request } from './api.ts'import { Application } from './app.ts'import { getContentType } from './mime.ts'
/** The Aleph server class. */export class Server { #app: Application #ready: boolean
constructor(app: Application) { this.#app = app this.#ready = false }
async handle(r: ServerRequest) { if (!this.#ready) { await this.#app.ready this.#ready = true }
const app = this.#app const { baseUrl, rewrites } = app.config const url = rewriteURL(r.url, baseUrl, rewrites) const pathname = decodeURI(url.pathname) const req = new Request(r, {}, url.searchParams)
// set custom headers for (const key in app.config.headers) { req.setHeader(key, app.config.headers[key]) } if (app.isDev) { req.setHeader('Cache-Control', 'max-age=0') }
try { // serve hmr ws if (pathname === '/_hmr') { const { conn, r: bufReader, w: bufWriter, headers } = r const socket = await acceptWebSocket({ conn, bufReader, bufWriter, headers }) const watcher = app.createFSWatcher() watcher.on('add', (mod: RouteModule) => socket.send(JSON.stringify({ ...mod, type: 'add' }))) watcher.on('remove', (url: string) => { watcher.removeAllListeners('modify-' + url) socket.send(JSON.stringify({ type: 'remove', url })) }) for await (const e of socket) { if (util.isNEString(e)) { try { const data = JSON.parse(e) if (data.type === 'hotAccept' && util.isNEString(data.url)) { const mod = app.getModule(data.url) if (mod) { watcher.on('modify-' + mod.url, (hash: string) => { socket.send(JSON.stringify({ type: 'update', url: mod.url, updateUrl: util.cleanPath(`${baseUrl}/_aleph/${trimModuleExt(mod.url)}.js`), hash, })) }) } } } catch (e) { } } else if (isWebSocketCloseEvent(e)) { break } } app.removeFSWatcher(watcher) return }
// serve dist files if (pathname.startsWith('/_aleph/')) { if (pathname.startsWith('/_aleph/data/') && pathname.endsWith('.json')) { let p = util.trimSuffix(util.trimPrefix(pathname, '/_aleph/data'), '.json') if (p === '/index') { p = '/' } const [status, data] = await app.getSSRData({ pathname: p }) if (status === 200) { req.send(JSON.stringify(data), 'application/json; charset=utf-8') } else { req.status(status).send('') } return }
if (pathname == '/_aleph/main.js') { req.send(app.getMainJS(false), 'application/javascript; charset=utf-8') return }
const filePath = path.join(app.buildDir, util.trimPrefix(pathname, '/_aleph/')) if (existsFileSync(filePath)) { const info = Deno.lstatSync(filePath) const lastModified = info.mtime?.toUTCString() ?? (new Date).toUTCString() if (lastModified === r.headers.get('If-Modified-Since')) { req.status(304).send('') return }
let content = await Deno.readTextFile(filePath) if (app.isDev && filePath.endsWith('.js')) { const metaFile = util.trimSuffix(filePath, '.js') + '.meta.json' if (existsFileSync(metaFile)) { try { const { url } = JSON.parse(await Deno.readTextFile(metaFile)) const mod = app.getModule(url) if (mod && app.isHMRable(mod.url)) { content = app.injectHMRCode(mod, content) } } catch (e) { } } }
req.setHeader('Last-Modified', lastModified) req.send(content, getContentType(filePath)) return }
req.status(404).send('not found') return }
// serve public files const filePath = path.join(app.workingDir, 'public', pathname) if (existsFileSync(filePath)) { const info = Deno.lstatSync(filePath) const lastModified = info.mtime?.toUTCString() ?? (new Date).toUTCString() if (lastModified === r.headers.get('If-Modified-Since')) { req.status(304).send('') return }
const body = Deno.readFileSync(filePath) req.setHeader('Last-Modified', lastModified) req.send(body, getContentType(filePath)) return }
// serve APIs if (pathname.startsWith('/api/')) { const route = app.getAPIRoute({ pathname, search: url.searchParams.toString() }) if (route !== null) { try { const [{ params, query }, { jsFile, hash }] = route const { default: handle } = await import(`file://${jsFile}#${hash.slice(0, 6)}`) if (util.isFunction(handle)) { await handle(new Request(req, params, query)) } else { req.status(500).json({ status: 500, message: 'bad api handler' }) } } catch (err) { req.status(500).json({ status: 500, message: err.message }) log.error('invoke API:', err) } } else { req.status(404).json({ status: 404, message: 'not found' }) } return }
// ssr const [status, html] = await app.getPageHTML({ pathname, search: url.searchParams.toString() }) req.status(status).send(html, 'text/html; charset=utf-8') } catch (err) { req.status(500).send( `<!DOCTYPE html><title>500 - internal server error</title><p><strong><code>500</code></strong><small> - </small><span>${err.message}</span></p>`, 'text/html; charset=utf-8' ) } }}
/** Options for creating a standard Aleph server. */export type ServeOptions = { /** The Aleph Server Application to serve. */ app: Application /** The port to listen on. */ port: number /** A literal IP address or host name that can be resolved to an IP address. * If not specified, defaults to `0.0.0.0`. */ hostname?: string /** Server certificate file. */ certFile?: string /** Server public key file. */ keyFile?: string}
/** Create a standard Aleph server. */export async function serve({ app, port, hostname, certFile, keyFile }: ServeOptions) { const server = new Server(app) await app.ready
while (true) { try { let s: AsyncIterable<ServerRequest> if (certFile && keyFile) { s = serveTLS({ port, hostname, certFile, keyFile }) } else { s = stdServe({ port, hostname }) } log.info(`Server ready on http://${hostname || 'localhost'}:${port}${app.config.baseUrl}`) for await (const r of s) { server.handle(r) } } catch (err) { if (err instanceof Deno.errors.AddrInUse && app.isDev) { log.warn(`port ${port} already in use, try ${port + 1}...`) port++ } else { log.fatal(err.message) } } }}