};

}

function buildRequestUrl(

requestUrl: string | undefined,

requestHost: string | undefined,

fallbackHost = "localhost",

): URL {

return new URL(requestUrl ?? "/", `http://${requestHost ?? fallbackHost}`);

function buildRequestUrl(requestUrl: string | undefined): URL {

return new URL(requestUrl ?? "/", "http://localhost");

}

function normalizeProxyIp(value: string | undefined): string | undefined {

private getUpgradePathname(request: http.IncomingMessage): string | null {

try {

return buildRequestUrl(request.url, request.headers.host).pathname;

return buildRequestUrl(request.url).pathname;

} catch {

return null;

}

req: http.IncomingMessage,

webhookPath: string,

): Promise<WebhookResponsePayload> {

const url = buildRequestUrl(req.url, req.headers.host);

const url = buildRequestUrl(req.url);

if (url.pathname === "/voice/hold-music") {

return {

private isRealtimeWebSocketUpgrade(req: http.IncomingMessage): boolean {

try {

const pathname = buildRequestUrl(req.url, req.headers.host).pathname;

const pathname = buildRequestUrl(req.url).pathname;

const pattern = this.realtimeHandler?.getStreamPathPattern();

return Boolean(pattern && pathname.startsWith(pattern));

} catch {