Function startDatasetServer

e2e/webgpu-bicycle.spec.ts:120–204

(rootPath: string)

}

async function startDatasetServer(rootPath: string): Promise<DatasetServer> {
  const root = resolve(rootPath);
  const rootPrefix = root.endsWith(sep) ? root : `${root}${sep}`;
  const rootStat = await stat(root);
  if (!rootStat.isDirectory()) {
    throw new Error(`Bicycle dataset path is not a directory: ${root}`);
  }

  const server = createServer(async (request, response) => {
    response.setHeader('access-control-allow-origin', '*');
    response.setHeader('access-control-allow-methods', 'GET,HEAD,OPTIONS');

    if (request.method === 'OPTIONS') {
      response.writeHead(204);
      response.end();
      return;
    }

    if (request.method !== 'GET' && request.method !== 'HEAD') {
      sendStatus(response, 405, 'Method not allowed');
      return;
    }

    try {
      const url = new URL(request.url ?? '/', 'http://127.0.0.1');
      const relativePath = decodeURIComponent(url.pathname)
        .replace(/^\/+/, '')
        .replace(/\//g, sep);
      if (!relativePath || relativePath.includes('\0')) {
        sendStatus(response, 404, 'Not found');
        return;
      }

      const filePath = resolve(root, relativePath);
      if (filePath !== root && !filePath.startsWith(rootPrefix)) {
        sendStatus(response, 403, 'Forbidden');
        return;
      }

      const fileStat = await stat(filePath);
      if (!fileStat.isFile()) {
        sendStatus(response, 404, 'Not found');
        return;
      }

      response.writeHead(200, {
        'access-control-allow-origin': '*',
        'accept-ranges': 'bytes',
        'content-length': String(fileStat.size),
        'content-type': getContentType(filePath),
      });
      if (request.method === 'HEAD') {
        response.end();
        return;
      }

      const stream = createReadStream(filePath);
      stream.on('error', () => {