Java 类javax.ws.rs.core.MediaType 实例源码

/**
 * Create a broker Instance
 *
 * @param brokerName
 * @return
 * @throws CloudKarafkaServiceException
 */
public CloudKarafkaCreateInstanceResponse createInstance(final String brokerName,
                                                         final String plan) throws CloudKarafkaServiceException {
    // build input form
    final MultivaluedMap<String, String> form = new MultivaluedHashMap<>();
    form.add("name", brokerName);
    form.add("plan", plan);
    form.add("region", brokerConfig.getCloudKarafkaRegion());

    //build post request
    final String target = String.format("%s/%s", brokerConfig.getCloudkarafkaApiUrl(), "instances");
    final WebTarget webTarget = client.target(target);

    // call create broker instances API
    return webTarget.request(MediaType.APPLICATION_JSON)
            .post(Entity.form(form), CloudKarafkaCreateInstanceResponse.class);
}

/**
 * NP経由でExtCellを作成するユーティリティ.
 * @param cellName セル名
 * @param token トークン
 * @param extCellUrl ExtCellのUrl
 * @param srcEntitySet ソース側エンティティセット名
 * @param srcEntitySetKey ソース側エンティティのキー
 * @param code レスポンスコード
 * @return レスポンス
 */
@SuppressWarnings("unchecked")
public static TResponse createViaNP(
        final String token,
        final String cellName,
        final String extCellUrl,
        final String srcEntitySet,
        final String srcEntitySetKey,
        final int code) {
    JSONObject body = new JSONObject();
    body.put("Url", extCellUrl);

    return Http.request("createNP.txt")
            .with("token", token)
            .with("accept", MediaType.APPLICATION_JSON)
            .with("contentType", MediaType.APPLICATION_JSON)
            .with("cell", cellName)
            .with("entityType", srcEntitySet)
            .with("id", srcEntitySetKey)
            .with("navPropName", "_ExtCell")
            .with("body", body.toString())
            .returns()
            .statusCode(code);
}

@Test
public void testJobCounters() throws JSONException, Exception {
  WebResource r = resource();
  Map<JobId, Job> jobsMap = appContext.getAllJobs();
  for (JobId id : jobsMap.keySet()) {
    String jobId = MRApps.toString(id);

    ClientResponse response = r.path("ws").path("v1").path("mapreduce")
        .path("jobs").path(jobId).path("counters")
        .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);
    assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
    JSONObject json = response.getEntity(JSONObject.class);
    assertEquals("incorrect number of elements", 1, json.length());
    JSONObject info = json.getJSONObject("jobCounters");
    verifyAMJobCounters(info, jobsMap.get(id));
  }
}

/**
 * Keyあり取得時にexpandに存在しないリースを指定した場合に400が返却されること.
 */
@Test
public final void Keyあり取得時にexpandに存在しないリースを指定した場合に400が返却されること() {

    try {
        // データ作成
        createData();

        // $expandを指定してデータを取得
        Http.request("box/odatacol/list.txt")
                .with("cell", Setup.TEST_CELL1)
                .with("box", Setup.TEST_BOX1)
                .with("collection", Setup.TEST_ODATA)
                .with("entityType", navPropName + "('" + fromUserDataId + "')")
                .with("query", "?\\$expand=_test")
                .with("accept", MediaType.APPLICATION_JSON)
                .with("token", PersoniumUnitConfig.getMasterToken())
                .returns()
                .statusCode(HttpStatus.SC_BAD_REQUEST)
                .debug();

    } finally {
        // データ削除
        deleteData();
    }
}

@POST
@Path("validate")
@Consumes({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
@Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
public Response addNamespacedList(final SnapshotList snapshotList) {
    NamespacedList namespace = (NamespacedList)snapshotList.getEntityToSave();

    if (!namespacedListsService.getNamespaceDuplicates(namespace, snapshotList.getNamespaces()).isEmpty()) {
        throw new WebApplicationException(Response.status(Response.Status.BAD_REQUEST)
                .entity(new ErrorMessage("There are duplicates in the namespaced list.")).build());
    }

    try {
        ModelValidationFacade.validateNamespacedList(namespace);
        namespace.updateVersion();
        namespace.setValueCount(namespace.getValueSet().size());
    } catch (ExpressionValidationException ex) {
        String error = String.format("Failed to save namespace '%s' due to validation error(s). %s",  namespace.getName(), ex.getMessage());
        throw new WebApplicationException(error, ex, Response.Status.BAD_REQUEST);
    }

    return Response.ok(namespace).build();
}

public static void reply(
        final RoutingContext context,
        final Envelop envelop) {
    // 1. Get response reference
    final HttpServerResponse response
            = context.response();
    // 2. Set response status
    final HttpStatusCode code = envelop.status();
    response.setStatusCode(code.code());
    response.setStatusMessage(code.message());
    response.putHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON);
    // 3. Response process
    if (!response.ended()) {
        response.end(envelop.response());
    }
    response.close();
}

@GET
@Path(KMSRESTConstants.KEY_PAIR_VERSION_RESOURCE + "/{versionName:.*}")
@Produces(MediaType.APPLICATION_JSON)
public Response getKeyVersionPair(
    @PathParam("versionName") final String versionName) throws Exception {
  UserGroupInformation user = HttpUserGroupInformation.get();
  KMSClientProvider.checkNotEmpty(versionName, "versionName");
  KMSWebApp.getKeyCallsMeter().mark();
  assertAccess(KMSACLs.Type.GET, user, KMSOp.GET_KEY_VERSION);

  KeyPairVersion keyVersion = user.doAs(
      new PrivilegedExceptionAction<KeyPairVersion>() {
        @Override
        public KeyPairVersion run() throws Exception {
          return provider.getKeyPairVersion(versionName);
        }
      }
  );

  if (keyVersion != null) {
    kmsAudit.ok(user, KMSOp.GET_KEY_VERSION, keyVersion.getName(), "");
  }
  Object json = KMSServerJSONUtils.toJSON(keyVersion);
  return Response.ok().type(MediaType.APPLICATION_JSON).entity(json).build();
}

/**
 * UserDataに前方一致検索クエリに真偽値trueを指定した場合ステータスコード400が返却されること.
 */
@Test
public final void UserDataに前方一致検索クエリに真偽値trueを指定した場合ステータスコード400が返却されること() {
    // ユーザデータの一覧取得
    String sdEntityTypeName = "SalesDetail";

    Http.request("box/odatacol/list.txt")
            .with("cell", cellName)
            .with("box", boxName)
            .with("collection", colName)
            .with("entityType", sdEntityTypeName)
            .with("query", "?\\$filter=startswith%28truth%2ctrue%29")
            .with("accept", MediaType.APPLICATION_JSON)
            .with("token", PersoniumUnitConfig.getMasterToken())
            .returns()
            .statusCode(HttpStatus.SC_BAD_REQUEST)
            .debug();
}

@Test
public void testInvalidRuleName() throws InstantiationException, IllegalAccessException {


    IfExpressionBuilder builder = new IfExpressionBuilder();
    IfExpression expression = builder.
            withRuleName(invalidRuleName).
            withExpression(newSingleParamExpression(Equals.class, "param1", "value1")).
            withExpression(newSingleParamExpression(Matches.class, "param2", "value2")).
            withExpression(newSingleParamExpression(NotEqual.class, "param3", "value3")).
            withExpression(newSingleParamExpression(LessThan.class, "param4", "4")).
            withReturnStatement(newSimpleServerForFlavor("1.1")).build();


    // now trying to post rule with invalid name
    WebTarget webTarget = HttpTestServerHelper.target().path(RULES_SERVICE_PATH).path(SERVICE_NAME).path(expression.getId());
    ValidationState error = ServiceHelper.post(webTarget, expression, MediaType.APPLICATION_JSON, ValidationState.class, true);

    // should get error ValidationState.ErrorType.InvalidRuleName
    Assert.assertEquals(1, error.getErrors().size());
    Assert.assertEquals(ValidationState.ErrorType.InvalidRuleName, error.getErrors().keySet().iterator().next());
}

@Test
public void testJobsQueryFinishTimeBeginNegative() throws JSONException,
    Exception {
  WebResource r = resource();
  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs")
      .queryParam("finishedTimeBegin", String.valueOf(-1000))
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);
  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils.checkStringMatch("exception message",
      "java.lang.Exception: finishedTimeBegin must be greater than 0",
      message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "BadRequestException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
}

/**
 * Creates a virtual network from the JSON input stream.
 *
 * @param stream tenant identifier JSON stream
 * @return status of the request - CREATED if the JSON is correct,
 * BAD_REQUEST if the JSON is invalid
 * @onos.rsModel TenantId
 */
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public Response createVirtualNetwork(InputStream stream) {
    try {
        final TenantId tid = TenantId.tenantId(getFromJsonStream(stream, "id").asText());
        VirtualNetwork newVnet = vnetAdminService.createVirtualNetwork(tid);
        UriBuilder locationBuilder = uriInfo.getBaseUriBuilder()
                .path("vnets")
                .path(newVnet.id().toString());
        return Response
                .created(locationBuilder.build())
                .build();
    } catch (IOException e) {
        throw new IllegalArgumentException(e);
    }
}

@POST
@Consumes(MediaType.MULTIPART_FORM_DATA)
@Produces({ MediaType.APPLICATION_JSON })
public FileOutVO addFile(@FormDataParam("json") FormDataBodyPart json,
        @FormDataParam("data") FormDataBodyPart content,
        @FormDataParam("data") FormDataContentDisposition contentDisposition,
        @FormDataParam("data") final InputStream input) throws AuthenticationException, AuthorisationException, ServiceException {
    // in.setTrialId(trialId);
    // in.setModule(FileModule.TRIAL_DOCUMENT);
    // https://stackoverflow.com/questions/27609569/file-upload-along-with-other-object-in-jersey-restful-web-service
    json.setMediaType(MediaType.APPLICATION_JSON_TYPE);
    FileInVO in = json.getValueAs(FileInVO.class);
    FileStreamInVO stream = new FileStreamInVO();
    stream.setStream(input);
    stream.setMimeType(content.getMediaType().toString()); // .getType());
    stream.setSize(contentDisposition.getSize());
    stream.setFileName(contentDisposition.getFileName());
    return WebUtil.getServiceLocator().getFileService().addFile(auth, in, stream);
}

@GET
@Path("/apps/{appid}/state")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AppState getAppState(@Context HttpServletRequest hsr,
    @PathParam("appid") String appId) throws AuthorizationException {
  init();
  UserGroupInformation callerUGI = getCallerUserGroupInformation(hsr, true);
  String userName = "";
  if (callerUGI != null) {
    userName = callerUGI.getUserName();
  }
  RMApp app = null;
  try {
    app = getRMAppForAppId(appId);
  } catch (NotFoundException e) {
    RMAuditLogger.logFailure(userName, AuditConstants.KILL_APP_REQUEST,
      "UNKNOWN", "RMWebService",
      "Trying to get state of an absent application " + appId);
    throw e;
  }

  AppState ret = new AppState();
  ret.setState(app.getState().toString());

  return ret;
}

@Pact(consumer = "AuthenticationService")
public PactFragment createFragment(PactDslWithProvider pactDslWithProvider) throws JsonProcessingException {
    Map<String, String> headers = new HashMap<>();
    headers.put("Content-Type", MediaType.APPLICATION_FORM_URLENCODED);

    return pactDslWithProvider
            .given("Customer Sean is registered")
            .uponReceiving("a request to validate Sean")
            .path("/rest/api/login/validate")
            .method("POST")
            .query("sessionId=" + customerSessionInfo.getId())
            .headers(headers)
            .willRespondWith()
            .status(200)
            .body(objectMapper.writeValueAsString(customerSessionInfo), MediaType.APPLICATION_JSON)
            .toFragment();
}

@POST
@Path("register")
@Consumes(MediaType.APPLICATION_FORM_URLENCODED)
public String register(@FormParam("userName") String userName,
        @FormParam("password") String password,
        @FormParam("phone") Long phone, @FormParam("email") String email,
        @FormParam("nick") String nick, @FormParam("addr") String addr,
        @FormParam("gender") String gender) {
    // check not null
    User u = new User();// dao 应该查询
    u.setAddr(addr);
    u.setEmail(email);
    u.setGender(gender);
    u.setNick(nick);
    u.setPassword(password);
    u.setPhone(phone);
    u.setUsername(userName);
    return JsonUtil.bean2Json(u);
}

/**
 * Cellの取得で認証トークンにBasic形式でトークン値空文字を指定した場合に認証エラーが返却されること.
 */
@Test
public final void Cellの取得で認証トークンにBasic形式でトークン値空文字を指定した場合に認証エラーが返却されること() {
    HashMap<String, String> headers = new HashMap<String, String>();
    headers.put(HttpHeaders.AUTHORIZATION, "Basic ");
    this.setHeaders(headers);

    PersoniumResponse res = this.restGet(getUrl(this.cellId));

    // ステータスコード:401
    // コンテンツタイプ:application/json
    // Etagヘッダが存在しない
    // ボディのエラーコードチェック
    assertEquals(HttpStatus.SC_UNAUTHORIZED, res.getStatusCode());
    assertEquals(MediaType.APPLICATION_JSON, res.getResponseHeaders(HttpHeaders.CONTENT_TYPE)[0].getValue());
}

@POST
@Path("/cli/run")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public Response runCliCommand(CommandRequest commandRequest) {
  if (StringUtils.isEmpty(commandRequest.getCommand())) {
    return Responses.badRequest();
  }

  MutableString command = new MutableString(commandRequest.getCommand());
  command.prependIfMissing("/");
  ConsoleInputEvent event = new ConsoleInputEvent(command.toString(), false);
  cliCommandRouter.onConsoleInputEvent(event);

  return Responses.ok();
}

@GET // 修改类使用PUT
@Path("{id}") // htpp://127.0.0.1/api/user/{id}
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public ResponseModel<UserCard> getUser(@PathParam("id") String id) {
    if (Strings.isNullOrEmpty(id)) {
        return ResponseModel.buildParameterError(); // 参数异常
    }

    User self = getSelf();
    if (self.getId().equalsIgnoreCase(id)) {
        // 返回自己不需要查询
        return ResponseModel.buildOk(new UserCard(self, true));
    }
    User user = UserFactory.findById(id);
    if (user == null) {
        // 没找到返回没找到
        return ResponseModel.buildNotFoundUserError(null);
    }
    // 如果我们直接有关注的记录，则我已经关注需要查询信息的用户
    boolean isFollow = UserFactory.getUserFollow(self, user) != null;
    return ResponseModel.buildOk(new UserCard(user, isFollow));

}

@Override
public Object getValue(HttpServletRequest request) throws Exception {
  Object body = request.getAttribute(RestConst.BODY_PARAMETER);
  if (body != null) {
    return convertValue(body, targetType);
  }

  // for standard HttpServletRequest, getInputStream will never return null
  // but for mocked HttpServletRequest, maybe get a null
  //  like org.apache.servicecomb.provider.springmvc.reference.ClientToHttpServletRequest
  InputStream inputStream = request.getInputStream();
  if (inputStream == null) {
    return null;
  }

  String contentType = request.getContentType();
  if (contentType != null && !contentType.toLowerCase(Locale.US).startsWith(MediaType.APPLICATION_JSON)) {
    // TODO: we should consider body encoding
    return IOUtils.toString(inputStream, "UTF-8");
  }
  return RestObjectMapper.INSTANCE.readValue(inputStream, targetType);
}

@Override
public void writeTo(final Message m,
    final Class<?> type,
    final Type genericType,
    final Annotation[] annotations,
    final MediaType mediaType,
    final MultivaluedMap<String, Object> httpHeaders,
    final OutputStream entityStream
) throws IOException {

  if (mediaType.getSubtype().contains("protobuf+text")) {
    entityStream.write(m.toString().getBytes(StandardCharsets.UTF_8));
  } else if (mediaType.getSubtype().contains("json")) {
    try {
      entityStream.write(Protobuf3Support.toJsonString(m).getBytes(StandardCharsets.UTF_8));
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  } else {
    entityStream.write(m.toByteArray());
  }
}

@GET
@Path("/verifyIssuedAt")
@Produces(MediaType.APPLICATION_JSON)
public JsonObject verifyIssuedAt(@QueryParam("iat") Long iat) {
    boolean pass = false;
    String msg;
    // iat
    Long iatValue = rawTokenJson.getIssuedAtTime();
    if (iatValue == null || iatValue.intValue() == 0) {
        msg = Claims.iat.name() + "value is null or empty, FAIL";
    }
    else if (iatValue.equals(iat)) {
        msg = Claims.iat.name() + " PASS";
        pass = true;
    }
    else {
        msg = String.format("%s: %s != %s", Claims.iat.name(), iatValue, iat);
    }
    JsonObject result = Json.createObjectBuilder()
            .add("pass", pass)
            .add("msg", msg)
            .build();
    return result;
}

/**
 * Keyなし取得時にexpandにアンダースコアのみを指定した場合に400が返却されること.
 */
@Test
public final void Keyなし取得時にexpandにアンダースコアのみを指定した場合に400が返却されること() {

    try {
        // データ作成
        createData();

        // $expandを指定してデータを取得
        Http.request("box/odatacol/list.txt")
                .with("cell", Setup.TEST_CELL1)
                .with("box", Setup.TEST_BOX1)
                .with("collection", Setup.TEST_ODATA)
                .with("entityType", navPropName)
                .with("query", "?\\$expand=_")
                .with("accept", MediaType.APPLICATION_JSON)
                .with("token", PersoniumUnitConfig.getMasterToken())
                .returns()
                .statusCode(HttpStatus.SC_BAD_REQUEST)
                .debug();

    } finally {
        // データ削除
        deleteData();
    }
}

@POST
@Path("auth")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public Response login(@Valid Login value) {
    try {
        String auth = authenticationService.auth(value.getUserName(), value.getPassword());
        //TODO Do not hardcode roles, query from database
        if (auth == null) {
            return Response.ok().entity("false").build();
        } else if ("Doctor".equals(auth)) {
            return Response.ok().entity("Doctor").build();
        } else if ("AdminClinic".equals(auth)) {
            return Response.ok().entity("AdminClinic").build();
        } else if ("Nurse".equals(auth)) {
            return Response.ok().entity("Nurse").build();
        } else if ("HRManager".equals(auth)) {
            return Response.ok().entity("HRManager").build();
        }
    } catch (Exception ex) {
        return Response.ok().header("Exception", ex.getMessage()).build();
    }
    return Response.ok().entity("Unknown").build();
}

@GET
@Path("/{id}/preferences/{key}")
@Consumes({ MediaType.APPLICATION_FORM_URLENCODED })
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })
public Response getOfficeSitePreferencesByKey(@Context HttpServletRequest request, @Context HttpHeaders header,
        @Context Company company, @Context Locale locale, @Context User user,
        @Context ServiceContext serviceContext, @PathParam("id") long id, @PathParam("key") String key);

@POST
@Consumes({MediaType.APPLICATION_JSON})
public Response postPerson(@Valid @NotNull ValidatedPerson person) {
    POSTED_PEOPLE.add(person);

    return Response.ok()
            .build();
}

@DELETE
@Path("/{id}/roles/{roleid}")
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })
@ApiOperation(value = "Remove a ServiceProcessRole of a ServiceProcess", response = RoleInputModel.class)
@ApiResponses(value = {
        @ApiResponse(code = HttpURLConnection.HTTP_OK, message = "Returns a ServiceProcessRole was deleted", response = RoleInputModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_UNAUTHORIZED, message = "Unauthorized", response = ExceptionModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_NOT_FOUND, message = "Not found", response = ExceptionModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_FORBIDDEN, message = "Access denied", response = ExceptionModel.class) })

public Response removeServiceProcessRole(@Context HttpServletRequest request, @Context HttpHeaders header,
        @Context Company company, @Context Locale locale, @Context User user,
        @Context ServiceContext serviceContext, @PathParam("id") long id, @PathParam("roleid") long roleid);

/**
 * Cellの一覧取得の不正なQueryを無視するのテスト.
 */
@Test
public final void Cellの一覧取得の不正なQueryを無視するのテスト() {
    cellCreate(DEF_CELL_NUM);
    PersoniumRequest req = PersoniumRequest.get(UrlUtils.unitCtl(Cell.EDM_TYPE_NAME));
    req.header("Accept", MediaType.APPLICATION_JSON);
    // 不正なQueryを指定しても無視される事
    req.query("query=test");
    this.cellListNormal(req);
}

@Override
public Response generateInstallation(KeycloakSession session, RealmModel realm, ClientModel client, URI baseUri) {
    UriBuilder bindingUrlBuilder = UriBuilder.fromUri(baseUri);
    String bindingUrl = RealmsResource.protocolUrl(bindingUrlBuilder)
            .build(realm.getName(), CASLoginProtocol.LOGIN_PROTOCOL).toString();
    String description = "CAS Server URL: " + bindingUrl + "\n" +
            "CAS Protocol: CAS 2.0/3.0 (SAML 1.1 is not supported)\n" +
            "Use CAS REST API: false (unsupported)";
    return Response.ok(description, MediaType.TEXT_PLAIN_TYPE).build();
}

@GET
@Path(URL_RULES_CONTROLLER_PATH + "/{serviceName}")
@Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
public Response getAllUrlRules(@PathParam("serviceName") final String serviceName) {
    if (commonBeans.connector().isConnected()) {
        return Response.ok(extractAllUrlRules(serviceName)).build();
    }
    return Response.status(Response.Status.SERVICE_UNAVAILABLE).build();
}

@Override
public Response toResponse(RedirectorDataSourceException exception) {
    log.error("Exception happened in RedirectorWebService", exception);

    return Response.status(Response.Status.SERVICE_UNAVAILABLE)
        .entity(new ErrorMessage(getHumanReadableMessage(exception)))
        .type(MediaType.APPLICATION_JSON)
        .build();
}

@POST
@Secured
@Path("SecureLogout")
@Produces(MediaType.APPLICATION_XML)
public String secureLogout() {
    return "";
}

/**
 * Creates a Multipart which will be needed for the SE-Repo API call to commit SE-Items.
 *
 * @param commit
 * @param seItemsWithContent
 * @return
 */
protected static MultipartFormDataOutput createMultipart(CreateCommit commit, List<SeItemWithContent> seItemsWithContent) {
    MultipartFormDataOutput multipart = new MultipartFormDataOutput();

    multipart.addFormData("commit", commit, MediaType.APPLICATION_JSON_TYPE);
    int partCounter = 0;
    // We create for each SE-Item a "multipart-pair" with JSON data (metadata_) and "binary" data (content_)
    for (SeItemWithContent seItem : seItemsWithContent) {
        multipart.addFormData("metadata_" + partCounter, seItem, MediaType.APPLICATION_JSON_TYPE);
        multipart.addFormData("content_" + partCounter, seItem.getContent(), MediaType.valueOf(seItem.getMimeType()), seItem.getName());
        partCounter++;
    }

    return multipart;
}

@GET
@Path("filter/group/query")
@Produces(MediaType.APPLICATION_JSON + ";charset=utf-8")
public void groupFilterQuery(@Suspended AsyncResponse response) {

    Map<String, String> resultMap = cm.getHashAll(godeyeFilterGroupCacheRegion, godeyeFilterGroupCacheRegionKey);
    response.resume(JSONHelper.toString(resultMap));
}

public ClusterInfoDTO getCluster(String clusterId) throws HttpException {
    //TODO should be DEBUG logging statement
    System.out.println("getCluster HTTP request for id "+clusterId);
    Response response = _target.path("get")
            .register(Session.Authentication)
            .queryParam("cluster_id", clusterId)
            .request()
            .accept(MediaType.APPLICATION_JSON)
            .get();

    checkResponse(response);
    return response.readEntity(ClusterInfoDTO.class);
}

@GET
@Path("/deliverables/{id}/preview")
@Consumes({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
@ApiOperation(value = "Get info preview for deliverable id")
@ApiResponses(value = {
        @ApiResponse(code = HttpURLConnection.HTTP_OK, message = "Returns"),
        @ApiResponse(code = HttpURLConnection.HTTP_UNAUTHORIZED, message = "Unauthorized", response = ExceptionModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_NOT_FOUND, message = "Not Found", response = ExceptionModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_FORBIDDEN, message = "Access defined", response = ExceptionModel.class) })
public Response getPreview(@Context HttpServletRequest request, @Context HttpHeaders header,
        @Context Company company, @Context Locale locale, @Context User user, @Context ServiceContext serviceContext,
        @ApiParam(value = "id of Deliverable", required = true) @PathParam("id") Long id);

public RpcClientResult put(String path, String content) {
    if (null == serverUri) {
        throw new RuntimeException("service url is null");
    }
    WebTarget target = client.target(serverUri).path(path);
    return target.request().buildPut(Entity.entity(content, MediaType.APPLICATION_JSON)).invoke(RpcClientResult.class);
}

@GET
@Path("/deliverables/{id}/formdata")
@Consumes({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
public Response getFormData(@Context HttpServletRequest request, @Context HttpHeaders header,
        @Context Company company, @Context Locale locale, @Context User user, @Context ServiceContext serviceContext,
        @ApiParam(value = "id of Deliverable", required = true) @PathParam("id") Long id);

@GET
@Path(NAMESPACE_CONTROLLER_PATH + "getOne/{name}")
@Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
public Response getNamespace(@PathParam("name") final String name) {
    if (!commonBeans.connector().isConnected()) {
        return Response.status(Response.Status.SERVICE_UNAVAILABLE).build();
    }

    NamespacedList namespacedList = extractNamespacedListByName(name);
    if (namespacedList == null) {
        return Response.status(Response.Status.NOT_FOUND).build();
    } else {
        return Response.ok(namespacedList).build();
    }
}

@GET
@Produces(MediaType.APPLICATION_XML)
public Response getZNodeList(
        @PathParam("path") String path,
        @QueryParam("callback") String callback,
        @DefaultValue("data") @QueryParam("view") String view,
        @DefaultValue("base64") @QueryParam("dataformat") String dataformat,
        @Context UriInfo ui) throws InterruptedException, KeeperException {
    return getZNodeList(false, path, callback, view, dataformat, ui);
}

@GET
@Path("/{id}/files/{referenceUid}")
@Consumes({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON, MediaType.APPLICATION_FORM_URLENCODED })
@ApiOperation(value = "getDossierFilesByDossierReferenceUid", response = DossierFileResultsModel.class)
@ApiResponses(value = {
        @ApiResponse(code = HttpURLConnection.HTTP_OK, message = "downloadByDossierId_ReferenceUid"),
        @ApiResponse(code = HttpURLConnection.HTTP_NOT_FOUND, message = "Not found", response = ExceptionModel.class),
        @ApiResponse(code = HttpURLConnection.HTTP_FORBIDDEN, message = "Access denied", response = ExceptionModel.class) })
public Response downloadByDossierId_ReferenceUid(@Context HttpServletRequest request, @Context HttpHeaders header,
        @Context Company company, @Context Locale locale, @Context User user,
        @Context ServiceContext serviceContext,
        @ApiParam(value = "id of dossier", required = true) @PathParam("id") long id,
        @ApiParam(value = "referenceUid of dossierfile", required = true) @PathParam("referenceUid") String referenceUid,
        @ApiParam(value = "password for access dossier file", required = false) @PathParam("password") String password);