import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
/**
 * This method will be invoked when an connection has been received and not haven't yet be suspended. Note that
 * the connection will be suspended AFTER the method has been invoked when used with {@link org.atmosphere.interceptor.AtmosphereResourceLifecycleInterceptor}
 *
 * @param resource an {@link AtmosphereResource}
 * @throws IOException
 */
public void onOpen(AtmosphereResource resource) throws IOException {
    final SUser currentUser = SessionUser.getUser(resource.getRequest());
    if (currentUser == null) {
        LOG.error("Websocket Open request with unknown user. Request: " + WebUtil.getRequestDump(resource.getRequest()));
        return;
    }

    LOG.debug("WebSocket connection is opened by " + currentUser.getUsername() + ". Connection UUID: " + resource.uuid());

    // Store connection
    AtmosphereResourceSessionFactory.getDefault().getSession(resource).setAttribute(USER_ID, currentUser.getId());
    Queue<AtmosphereResource> resources = myResources.get(currentUser.getId());
    if (resources == null){
        resources = new ConcurrentLinkedQueue<AtmosphereResource>();
        myResources.put(currentUser.getId(), resources);
    }

    resources.add(resource);
    resource.suspend();
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
protected ModelAndView doHandle(@NotNull final HttpServletRequest request,
                                @NotNull final HttpServletResponse response) throws Exception {


  String requestedResource = WebUtil.getPathFromUrl(WebUtil.getOriginalPathWithoutContext(request))
          .replace(pagesContentUrlBase, "");

  try {
    String requestedResourceBasePath = getResourceBaseFolder();
    File file = getRequestedFile(requestedResource, requestedResourceBasePath);
    boolean legal = isLegalPath(file, new File(requestedResourceBasePath));
    if (!legal) {
      throw new IllegalArgumentException("Requested resource doesn't exist under the resource base folder.");
    }
    response.setContentType(WebUtil.getMimeType(request, file.getName()));
    writeResourceContent(request, response, file);
  } catch (Exception e) {
    LOG.warn("Failed to retrieve file. Error: " + e.getMessage(), e);
    response.setContentType("text/plain");
    response.getWriter().write("ERROR: Content for Widgets plugin was not found. " +
            "Requested resource: " + requestedResource + ", error: " + e.getMessage());
  }
  return null;
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
protected ModelAndView doHandle(@NotNull HttpServletRequest request, @NotNull HttpServletResponse response) throws Exception {
  String buildIdParam = request.getParameter("buildId");
  String path = request.getParameter("file");
  String torrentPath = path + TorrentUtil.TORRENT_FILE_SUFFIX;

  File torrentFile = null;
  long buildId = Long.parseLong(buildIdParam);
  SBuild build = myBuildsManager.findBuildInstanceById(buildId);
  if (build != null) {
    torrentFile = myTorrentsManager.getTorrentFile(build, torrentPath);
    if (!torrentFile.isFile()) {
      torrentFile = null;
    }
  }

  if (torrentFile == null) {
    response.sendError(HttpServletResponse.SC_NOT_FOUND);
  } else {
    response.setContentType(WebUtil.getMimeType(request, torrentFile.getName()));
    // force set content-disposition to attachment
    WebUtil.setContentDisposition(request, response, torrentFile.getName(), false);
    ServletOutputStream output = response.getOutputStream();
    FileInputStream fis = null;
    try {
      fis = new FileInputStream(torrentFile);
      StreamUtil.copyStreamContent(fis, output);
    } finally {
      FileUtil.close(fis);
      output.close();
    }
  }

  return null;
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
public boolean isAvailable(@NotNull HttpServletRequest request) {
  return "/profile.html".equals(WebUtil.getPathWithoutContext(request)) ||
      getPluginName().equals(request.getParameter("notificatorType"));
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
public void fillModel(@NotNull Map<String, Object> model, @NotNull HttpServletRequest request) {
  super.fillModel(model, request);
  model.put("actualServerUrl", WebUtil.getRootUrl(request));
  model.put("appUrl", SymbolsConstants.APP_SYMBOLS);
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
public boolean isAvailable(@NotNull final HttpServletRequest request) {
  return super.isAvailable(request) && WebUtil.getPathWithoutContext(request).startsWith("/viewLog.html");
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
public boolean isAvailable(@NotNull final HttpServletRequest request) {
  return super.isAvailable(request) && WebUtil.getPathWithoutContext(request).startsWith("/viewType.html");
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
public boolean isAvailable(@NotNull HttpServletRequest request) {
  return "/profile.html".equals(WebUtil.getPathWithoutContext(request)) || getPluginName().equals(request.getParameter("notificatorType"));
}
 

import jetbrains.buildServer.web.util.WebUtil; //导入依赖的package包/类
@Override
public boolean isAvailable(@NotNull final HttpServletRequest request) {
    return WebUtil.getPathWithoutAuthenticationType(request).startsWith("/overview.html");
}