podcast manager
3
fork

Configure Feed

Select the types of activity you want to include in your feed.

test commit to verify pre-commit hook

+16 -18
+4
deno.json
··· 50 50 ], 51 51 "jsx": "react-jsx", 52 52 "jsxImportSource": "react" 53 + }, 54 + 55 + "fmt": { 56 + "lineWidth": 110 53 57 } 54 58 }
+3 -8
src/server/routes-socket/handler.ts
··· 1 1 import { takeSocket } from "@repo/common/socket.ts"; 2 2 import { combineSignals, timeoutSignal } from "@repo/common/aborts.ts"; 3 - import { 4 - AuthError, 5 - BaseError, 6 - CancellationError, 7 - ValidationError, 8 - } from "@repo/common/errors.ts"; 3 + import { BaseError, CancellationError, ValidationError } from "@repo/common/errors.ts"; 9 4 import { z } from "zod/v4"; 10 5 11 6 import { StrictMap } from "@repo/common/strict-map.ts"; ··· 56 51 const combinedSignal = combineSignals(signal, timeout.signal); 57 52 58 53 try { 59 - const data = await takeSocket(ws, combinedSignal); 60 - const schema = jwtDecodedSchema.pipe(preauthMessageSchema) 54 + const data = await takeSocket(ws, combinedSignal); 55 + const schema = jwtDecodedSchema.pipe(preauthMessageSchema); 61 56 62 57 return await schema.parseAsync(data); 63 58 } finally {
+9 -10
src/server/routes-socket/middleware.ts
··· 1 1 import { Middleware } from "@oak/oak/middleware"; 2 2 import { socketHandler } from "./handler.ts"; 3 3 4 - export const socketMiddleware: (path: string) => Middleware = 5 - (pathname) => (ctx, next) => { 6 - // must be an upgradable websocket connection to api root 7 - if (ctx.request.url.pathname !== pathname || !ctx.isUpgradable) { 8 - return next(); 9 - } 4 + export const socketMiddleware: (path: string) => Middleware = (pathname) => (ctx, next) => { 5 + // must be an upgradable websocket connection to api root 6 + if (ctx.request.url.pathname !== pathname || !ctx.isUpgradable) { 7 + return next(); 8 + } 10 9 11 - // then we'll upgrade and connect a handler 12 - const ws = ctx.upgrade(); 13 - ws.onopen = socketHandler; 14 - }; 10 + // then we'll upgrade and connect a handler 11 + const ws = ctx.upgrade(); 12 + ws.onopen = socketHandler; 13 + };