Extremely Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131/* * This is an example of a server that utilizes the router. */
// Importing some console colorsimport { bold, cyan, green, yellow,} from "https://deno.land/std@0.152.0/fmt/colors.ts";
import { Application, Context, isHttpError, Router, ServerSentEvent, Status,} from "../mod.ts";
interface Book { id: string; title: string; author: string;}
function notFound(ctx: Context) { ctx.response.status = Status.NotFound; ctx.response.body = `<html><body><h1>404 - Not Found</h1><p>Path <code>${ctx.request.url}</code> not found.`;}
const router = new Router();router .get("/", async (ctx) => { await ctx.send( { root: `${Deno.cwd()}/examples/resources`, path: "sseServer_index.html", }, ); }) // for any clients that request the `/sse` endpoint, we will send a message // every 2 seconds. .get("/sse", (ctx: Context) => { ctx.assert( ctx.request.accepts("text/event-stream"), Status.UnsupportedMediaType, ); const connection = ctx.request.ip; const target = ctx.sendEvents(); console.log(`${green("SSE connect")} ${cyan(connection)}`); let counter = 0; const id = setInterval(() => { const evt = new ServerSentEvent( "message", { hello: "world" }, { id: counter++ }, ); target.dispatchEvent(evt); console.log("dispatched"); }, 2000); target.addEventListener("close", () => { console.log(`${green("SSE disconnect")} ${cyan(connection)}`); clearInterval(id); }); });
const app = new Application();
// Loggerapp.use(async (context, next) => { await next(); const rt = context.response.headers.get("X-Response-Time"); console.log( `${green(context.request.method)} ${cyan(context.request.url.pathname)} - ${ bold( String(rt), ) }`, );});
// Response Timeapp.use(async (context, next) => { const start = Date.now(); await next(); const ms = Date.now() - start; context.response.headers.set("X-Response-Time", `${ms}ms`);});
// Error handlerapp.use(async (context, next) => { try { await next(); } catch (err) { if (isHttpError(err)) { context.response.status = err.status; const { message, status, stack } = err; if (context.request.accepts("json")) { context.response.body = { message, status, stack }; context.response.type = "json"; } else { context.response.body = `${status} ${message}\n\n${stack ?? ""}`; context.response.type = "text/plain"; } } else { console.log(err); throw err; } }});
// Use the routerapp.use(router.routes());app.use(router.allowedMethods());
// A basic 404 pageapp.use(notFound);
app.addEventListener("listen", ({ hostname, port, serverType }) => { console.log( bold("Start listening on ") + yellow(`${hostname}:${port}`), ); console.log(bold(" using HTTP server: " + yellow(serverType)));});
await app.listen({ hostname: "127.0.0.1", port: 8000 });console.log(bold("Finished."));