Function handleManagementRequest

apps/yalt/src/index.ts:89–120

(request: Request, env: Env, ctx: ExecutionContext)

}

async function handleManagementRequest(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
	const authHeader = request.headers.get('authorization');
	if (!authHeader) {
		return new Response('Authorization header is required', { status: 401 });
	}

	const authHeaderParts = authHeader.split(' ');
	if (authHeaderParts.length !== 2) {
		return new Response('Authorization header is invalid', { status: 401 });
	}

	const [authType, authKey] = authHeaderParts;

	if (authType !== 'Bearer') {
		return new Response('Authorization header is invalid', { status: 401 });
	}

	if (authKey !== env.SECRET_KEY) {
		return new Response('Authorization header is invalid', { status: 401 });
	}

	// Okay now we can actually handle the request
	// We need to look at the path and see what we are doing
	// POST /api/tunnels -> create a new tunnel
	const url = new URL(request.url);

	if (url.pathname === '/api/tunnels' && request.method === 'POST') {
		return handleCreateTunnel(request, env, ctx);
	}

	return new Response('Not Found', { status: 404 });
}

async function handleCreateTunnel(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
	const tunnelId = env.connections.newUniqueId();