mirror of
https://github.com/cdr/code-server.git
synced 2025-12-07 08:52:16 +01:00
77 lines
2.1 KiB
TypeScript
77 lines
2.1 KiB
TypeScript
import { Request, Response } from "express"
|
|
import * as path from "path"
|
|
import { HttpCode, HttpError } from "../../common/http"
|
|
import { ensureProxyEnabled, authenticated, ensureAuthenticated, ensureOrigin, redirect, self } from "../http"
|
|
import { proxy as _proxy } from "../proxy"
|
|
import type { WebsocketRequest } from "../wsRouter"
|
|
|
|
const getProxyTarget = (
|
|
req: Request,
|
|
opts?: {
|
|
proxyBasePath?: string
|
|
},
|
|
): string => {
|
|
// If there is a base path, strip it out.
|
|
const base = (req as any).base || ""
|
|
const port = parseInt(req.params.port, 10)
|
|
if (isNaN(port)) {
|
|
throw new HttpError("Invalid port", HttpCode.BadRequest)
|
|
}
|
|
return `http://0.0.0.0:${port}${opts?.proxyBasePath || ""}/${req.originalUrl.slice(base.length)}`
|
|
}
|
|
|
|
export async function proxy(
|
|
req: Request,
|
|
res: Response,
|
|
opts?: {
|
|
passthroughPath?: boolean
|
|
proxyBasePath?: string
|
|
},
|
|
): Promise<void> {
|
|
ensureProxyEnabled(req)
|
|
|
|
if (req.method === "OPTIONS" && req.args["skip-auth-preflight"]) {
|
|
// Allow preflight requests with `skip-auth-preflight` flag
|
|
} else if (!(await authenticated(req))) {
|
|
// If visiting the root (/:port only) redirect to the login page.
|
|
if (!req.params.path || req.params.path === "/") {
|
|
const to = self(req)
|
|
return redirect(req, res, "login", {
|
|
to: to !== "/" ? to : undefined,
|
|
})
|
|
}
|
|
throw new HttpError("Unauthorized", HttpCode.Unauthorized)
|
|
}
|
|
|
|
// The base is used for rewriting (redirects, target).
|
|
if (!opts?.passthroughPath) {
|
|
;(req as any).base = req.path.split(path.sep).slice(0, 3).join(path.sep)
|
|
}
|
|
|
|
_proxy.web(req, res, {
|
|
ignorePath: true,
|
|
target: getProxyTarget(req, opts),
|
|
})
|
|
}
|
|
|
|
export async function wsProxy(
|
|
req: WebsocketRequest,
|
|
opts?: {
|
|
passthroughPath?: boolean
|
|
proxyBasePath?: string
|
|
},
|
|
): Promise<void> {
|
|
ensureProxyEnabled(req)
|
|
ensureOrigin(req)
|
|
await ensureAuthenticated(req)
|
|
|
|
// The base is used for rewriting (redirects, target).
|
|
if (!opts?.passthroughPath) {
|
|
;(req as any).base = req.path.split(path.sep).slice(0, 3).join(path.sep)
|
|
}
|
|
|
|
_proxy.ws(req, req.ws, req.head, {
|
|
ignorePath: true,
|
|
target: getProxyTarget(req, opts),
|
|
})
|
|
}
|