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

项目:crnk-framework    文件:CookieParamProvider.java   
@Override
public Object provideValue(Parameter parameter, ContainerRequestContext requestContext, ObjectMapper objectMapper) {
    Object returnValue;
    String cookieName = parameter.getAnnotation(CookieParam.class).value();
    Cookie cookie = requestContext.getCookies().get(cookieName);
    if (cookie == null) {
        return null;
    } else {
        if (Cookie.class.isAssignableFrom(parameter.getType())) {
            returnValue = cookie;
        } else if (String.class.isAssignableFrom(parameter.getType())) {
            returnValue = cookie.getValue();
        } else {
            try {
                returnValue = objectMapper.readValue(cookie.getValue(), parameter.getType());
            } catch (IOException e) {
                throw new IllegalStateException(e);
            }
        }
    }

    return returnValue;
}
项目:osc-core    文件:RestBaseClient.java   
public <I> void putResource(String resourcePath, final I input, Cookie cookie) throws Exception {
    Response response = null;
    try {
        final Invocation.Builder requestBuilder = getRequestBuilder(resourcePath);
        response = requestBuilder.async().put(Entity.entity(input, this.mediaType), new InvocationLogCallback())
                .get(REQUEST_THREAD_TIMEOUT, TimeUnit.MILLISECONDS);
        Response.Status status = Response.Status.fromStatusCode(response.getStatus());

        if (status == Response.Status.OK || status == Response.Status.NO_CONTENT) {
            this.lastRequestHeaders = response.getHeaders();
        } else {
            throw new ClientResponseNotOkException();
        }
    } catch (Exception ex) {
        RestClientException restClientException = createRestClientException("PUT", this.webTarget.getUri() + "/"
                + resourcePath, input, response, ex);
        log.debug("Error invoking putResource", restClientException);

        throw restClientException;
    }
}
项目:minijax    文件:MinijaxRuntimeDelegate.java   
@Override
@SuppressWarnings("unchecked")
public <T> HeaderDelegate<T> createHeaderDelegate(final Class<T> type) {
    if (type == MediaType.class) {
        return (HeaderDelegate<T>) MEDIA_TYPE_DELEGATE;
    }
    if (type == Cookie.class) {
        return (HeaderDelegate<T>) COOKIE_DELEGATE;
    }
    if (type == NewCookie.class) {
        return (HeaderDelegate<T>) NEW_COOKIE_DELEGATE;
    }
    if (type == CacheControl.class) {
        return (HeaderDelegate<T>) CACHE_CONTROL_DELEGATE;
    }
    throw new IllegalArgumentException("Unrecognized header delegate: " + type);
}
项目:lyre    文件:SwaggerInflector.java   
@Override
public Response apply(ContainerRequestContext arg0) {
    SwaggerSpecFilter filter = FilterFactory.getFilter();
    if (filter != null) {

        Map<String, Cookie> cookiesvalue = arg0.getCookies();
        Map<String, String> cookies = new HashMap<>();
        if (cookiesvalue != null) {
            for (String key : cookiesvalue.keySet()) {
                cookies.put(key, cookiesvalue.get(key).getValue());
            }
        }

        MultivaluedMap<String, String> headers = arg0.getHeaders();
        return Response.ok().entity(new VendorSpecFilter().filter(getSwagger(), filter, null, cookies, headers)).build();
    }
    return Response.ok().entity(getSwagger()).build();
}
项目:turism-201620-2    文件:ClientTest.java   
/**
 * Prueba para consultar un Client
 *
 * @generated
 */
@Test
public void getClientByIdTest() {
    Cookie cookieSessionId = login(username, password);

    ClientDTO clientTest = target
        .path(oraculo.get(0).getId().toString())
        .request().cookie(cookieSessionId).get(ClientDTO.class);

    Assert.assertEquals(clientTest.getId(), oraculo.get(0).getId());
    Assert.assertEquals(clientTest.getName(), oraculo.get(0).getName());
    Assert.assertEquals(clientTest.getMiddleName(), oraculo.get(0).getMiddleName());
    Assert.assertEquals(clientTest.getLastName(), oraculo.get(0).getLastName());
    Assert.assertEquals(clientTest.getEmail(), oraculo.get(0).getEmail());
    Assert.assertEquals(clientTest.getPhoneNumber(), oraculo.get(0).getPhoneNumber());
    Assert.assertEquals(clientTest.getAddress(), oraculo.get(0).getAddress());
    Assert.assertEquals(clientTest.getPhoto(), oraculo.get(0).getPhoto());
}
项目:turism-201620-2    文件:PaymentMethodTest.java   
/**
 * Prueba para consultar un PaymentMethod
 *
 * @generated
 */
@Test
public void getPaymentMethodByIdTest() {
    Cookie cookieSessionId = login(username, password);

    PaymentMethodDTO paymentMethodTest = target
            .path(ORACULO.get(0).getId().toString())
            .request().cookie(cookieSessionId).get(PaymentMethodDTO.class);

    Assert.assertEquals(paymentMethodTest.getId(), ORACULO.get(0).getId());
    Assert.assertEquals(paymentMethodTest.getName(), ORACULO.get(0).getName());
    Assert.assertEquals(paymentMethodTest.getCardType(), ORACULO.get(0).getCardType());
    Assert.assertEquals(paymentMethodTest.getCardNumber(), ORACULO.get(0).getCardNumber());
    Assert.assertEquals(paymentMethodTest.getSecurityCode(), ORACULO.get(0).getSecurityCode());
    Assert.assertEquals(paymentMethodTest.getExpirationMonth(), ORACULO.get(0).getExpirationMonth());
    Assert.assertEquals(paymentMethodTest.getExpirationYear(), ORACULO.get(0).getExpirationYear());
}
项目:turism-201620-2    文件:ProductTest.java   
/**
 * Prueba para actualizar un Product
 *
 * @generated
 */
@Test
public void updateProductTest() throws IOException {
    Cookie cookieSessionId = login(username, password);
    ProductDTO product = new ProductDTO(oraculo.get(0));

    ProductDTO productChanged = factory.manufacturePojo(ProductDTO.class);

    product.setName(productChanged.getName());
    product.setPrice(productChanged.getPrice());

    Response response = target
        .path(product.getId().toString())
        .request().cookie(cookieSessionId)
        .put(Entity.entity(product, MediaType.APPLICATION_JSON));

    ProductDTO productTest = (ProductDTO) response.readEntity(ProductDTO.class);

    Assert.assertEquals(Ok, response.getStatus());
    Assert.assertEquals(product.getName(), productTest.getName());
    Assert.assertEquals(product.getPrice(), productTest.getPrice());
}
项目:turism-201620-2    文件:ItemTest.java   
/**
 * Prueba para actualizar un Item
 *
 * @generated
 */
@Test
public void updateItemTest() throws IOException {
    Cookie cookieSessionId = login(username, password);
    ItemDTO item = new ItemDTO(oraculo.get(0));

    ItemDTO itemChanged = factory.manufacturePojo(ItemDTO.class);

    item.setName(itemChanged.getName());
    item.setQty(itemChanged.getQty());

    Response response = target
        .path(item.getId().toString())
        .request().cookie(cookieSessionId)
        .put(Entity.entity(item, MediaType.APPLICATION_JSON));

    ItemDTO itemTest = (ItemDTO) response.readEntity(ItemDTO.class);

    Assert.assertEquals(Ok, response.getStatus());
    Assert.assertEquals(item.getName(), itemTest.getName());
    Assert.assertEquals(item.getQty(), itemTest.getQty());
}
项目:turism-201620-2    文件:CategoryTest.java   
/**
 * Prueba para actualizar un Category
 *
 * @generated
 */
@Test
public void updateCategoryTest() throws IOException {
    Cookie cookieSessionId = login(username, password);
    CategoryDTO category = new CategoryDTO(oraculo.get(0));

    CategoryDTO categoryChanged = factory.manufacturePojo(CategoryDTO.class);

    category.setName(categoryChanged.getName());

    Response response = target
        .path(category.getId().toString())
        .request().cookie(cookieSessionId)
        .put(Entity.entity(category, MediaType.APPLICATION_JSON));

    CategoryDTO categoryTest = (CategoryDTO) response.readEntity(CategoryDTO.class);

    Assert.assertEquals(Ok, response.getStatus());
    Assert.assertEquals(category.getName(), categoryTest.getName());
}
项目:turism-201620-2    文件:TripTest.java   
/**
 * Prueba para actualizar un Trip
 *
 * @generated
 */
@Test
public void updateTripTest() throws IOException {
    Cookie cookieSessionId = login(username, password);
    TripDTO trip = new TripDTO(oraculo.get(0));

    TripDTO tripChanged = factory.manufacturePojo(TripDTO.class);

    trip.setName(tripChanged.getName());
    trip.setImage(tripChanged.getImage());
    trip.setPrice(tripChanged.getPrice());

    Response response = target
        .path(trip.getId().toString())
        .request().cookie(cookieSessionId)
        .put(Entity.entity(trip, MediaType.APPLICATION_JSON));

    TripDTO tripTest = (TripDTO) response.readEntity(TripDTO.class);

    Assert.assertEquals(Ok, response.getStatus());
    Assert.assertEquals(trip.getName(), tripTest.getName());
    Assert.assertEquals(trip.getImage(), tripTest.getImage());
    Assert.assertEquals(trip.getPrice(), tripTest.getPrice());
}
项目:turism-201620-2    文件:AgencyTest.java   
/**
 * Prueba para actualizar un Agency
 *
 * @generated
 */
@Test
public void updateAgencyTest() throws IOException {
    Cookie cookieSessionId = login(username, password);
    AgencyDTO agency = new AgencyDTO(oraculo.get(0));

    AgencyDTO agencyChanged = factory.manufacturePojo(AgencyDTO.class);

    agency.setName(agencyChanged.getName());

    Response response = target
        .path(agency.getId().toString())
        .request().cookie(cookieSessionId)
        .put(Entity.entity(agency, MediaType.APPLICATION_JSON));

    AgencyDTO agencyTest = (AgencyDTO) response.readEntity(AgencyDTO.class);

    Assert.assertEquals(Ok, response.getStatus());
    Assert.assertEquals(agency.getName(), agencyTest.getName());
}
项目:turism-201620-2    文件:TripCategoryTest.java   
/**
 * Login para poder consultar los diferentes servicios
 *
 * @param username Nombre de usuario
 * @param password Clave del usuario
 * @return Cookie con información de la sesión del usuario
 * @generated
 */
public Cookie login(String username, String password) {
    UserDTO user = new UserDTO();
    user.setUserName(username);
    user.setPassword(password);
    user.setRememberMe(true);
    Response response = createWebTarget()
            .path("users")
            .path("login")
            .request()
            .post(Entity.entity(user, MediaType.APPLICATION_JSON));
    if (response.getStatus() == Ok) {
        return response.getCookies().get(JWT.cookieName);
    } else {
        return null;
    }
}
项目:katharsis-framework    文件:CookieParamProvider.java   
@Override
public Object provideValue(Parameter parameter, ContainerRequestContext requestContext, ObjectMapper objectMapper) {
    Object returnValue;
    String cookieName = parameter.getAnnotation(CookieParam.class).value();
    Cookie cookie = requestContext.getCookies().get(cookieName);
    if (cookie == null) {
        return null;
    } else {
        if (Cookie.class.isAssignableFrom(parameter.getType())) {
            returnValue = cookie;
        } else if (String.class.isAssignableFrom(parameter.getType())) {
            returnValue = cookie.getValue();
        } else {
            try {
                returnValue = objectMapper.readValue(cookie.getValue(), parameter.getType());
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    }

    return returnValue;
}
项目:codenvy    文件:AuthenticationDaoImpl.java   
/**
 * Perform logout for the given token.
 *
 * @param token - authentication token
 * @param tokenAccessCookie - old session-based cookie with token.
 */
public Response logout(String token, Cookie tokenAccessCookie, UriInfo uriInfo) {
  Response.ResponseBuilder response;
  String accessToken = token;
  if (accessToken == null && tokenAccessCookie != null) {
    accessToken = tokenAccessCookie.getValue();
  }

  boolean secure = uriInfo.getRequestUri().getScheme().equals("https");
  if (accessToken != null) {
    response = Response.ok();
    AccessTicket accessTicket = ticketManager.removeTicket(accessToken);
    if (accessTicket != null) {
      LOG.info("EVENT#user-sso-logged-out# USER#{}#", accessTicket.getUserId());
    } else {
      LOG.warn("AccessTicket not found. Nothing to do.");
    }
  } else {
    response = Response.status(Response.Status.BAD_REQUEST);
    LOG.warn("Token not found in request.");
  }
  if (cookieBuilder != null) {
    cookieBuilder.clearCookies(response, accessToken, secure);
  }
  return response.build();
}
项目:keywhiz    文件:SessionLogoutResource.java   
/**
 * Logout and remove any session cookies
 *
 * @description Log out and remove any session cookies
 * @responseMessage 200 Logged out successfully
 */
@Timed @ExceptionMetered
@POST
@Produces(APPLICATION_JSON)
public Response logout(@Nullable @CookieParam(value = "session") Cookie sessionCookie) {
  if (sessionCookie != null) {
    Optional<User> user = cookieAuthenticator.authenticate(sessionCookie);

    if (user.isPresent()) {
      logger.info("User logged out: {}", user.get().getName());
    } else {
      logger.warn("Invalid user cookie on logout.");
    }
  }

  NewCookie expiredCookie = cookieFactory.getExpiredSessionCookie();

  return Response.ok()
      .header(HttpHeaders.SET_COOKIE, expiredCookie.toString())
      .build();
}
项目:keywhiz    文件:CookieRenewingFilter.java   
/**
 * If the user has a valid session token, set a new session token. The new one should have a later
 * expiration time.
 */
@Override public void filter(ContainerRequestContext request, ContainerResponseContext response)
    throws IOException {
  String sessionCookieName = sessionCookieConfig.getName();
  // If the response will be setting a session cookie, don't overwrite it; just let it go.
  if (response.getCookies().containsKey(sessionCookieName)) {
    return;
  }

  // If the request doesn't have a session cookie, we're not going to renew one.
  if (!request.getCookies().containsKey(sessionCookieName)) {
    return;
  }

  Cookie requestCookie = request.getCookies().get(sessionCookieName);
  Optional<User> optionalUser = authenticator.authenticate(requestCookie);
  if (optionalUser.isPresent()) {
    sessionLoginResource.cookiesForUser(optionalUser.get())
        .forEach(c -> response.getHeaders().add(HttpHeaders.SET_COOKIE, c));
  }
}
项目:alex    文件:WebServiceConnector.java   
/**
 * Creates a request object that is passed to further REST actions.
 *
 * @param path           The URI that is called.
 * @param requestHeaders The HTTP headers of the request.
 * @param requestCookies The cookies of the request.
 *
 * @return The request object.
 */
private Invocation.Builder getRequestObject(String path, Map<String, String> requestHeaders,
                                            Set<Cookie> requestCookies) {
    final String[] splitPath = path.split("\\?");
    WebTarget tmpTarget = target.path(splitPath[0]);

    if (splitPath.length > 1) {
        for (final String queryParam : splitPath[1].split("&")) {
            final String[] queryParamPair = queryParam.split("\\=");

            if (queryParamPair.length == 2) {
                tmpTarget = tmpTarget.queryParam(queryParamPair[0], queryParamPair[1]);
            }
        }
    }
    final Invocation.Builder builder = tmpTarget.request();
    requestHeaders.forEach(builder::header);
    requestCookies.forEach(builder::cookie);

    return builder;
}
项目:routing-bird    文件:AuthRoutingBirdSessionFilter.java   
@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    MultivaluedMap<String, Object> headers = responseContext.getHeaders();
    for (String name : requestContext.getPropertyNames()) {
        if (name.startsWith("rb_session")) {
            Object rbSession = requestContext.getProperty(name);
            headers.add("Set-Cookie",
                new NewCookie(name,
                    rbSession.toString(),
                    "/",
                    null,
                    Cookie.DEFAULT_VERSION,
                    null,
                    NewCookie.DEFAULT_MAX_AGE,
                    null,
                    false,
                    false));
        }
    }
}
项目:msf4j    文件:CookieHeaderProviderTest.java   
@Test
public void testFromStringWithExtendedParameters() {
    String cookieString = "Version=1; Application=msf4j; Path=/carbon; Domain=wso2; Expires=Sun, 06 Nov 1994 " +
            "08:49:37 GMT; Secure; HttpOnly; MaxAge=50; Comment=TestOnly";
    String name = "Application";
    String value = "msf4j";
    String path = "/carbon";
    String domain = "wso2";
    long dateTime = 784111777000L;

    NewCookie cookie = (NewCookie) Cookie.valueOf(cookieString);
    assertEquals(cookie.getName(), name);
    assertEquals(cookie.getValue(), value);
    assertEquals(cookie.getPath(), path);
    assertEquals(cookie.getVersion(), 1);
    assertEquals(cookie.getDomain(), domain);
    assertEquals(cookie.getComment(), "TestOnly");
    assertEquals(cookie.getExpiry().getTime(), dateTime);
    assertEquals(cookie.getMaxAge(), 50);
    assertEquals(cookie.isSecure(), true);
    assertEquals(cookie.isHttpOnly(), true);
}
项目:msf4j    文件:HttpHeadersImpl.java   
@Override
public Map<String, Cookie> getCookies() {
    List<String> values = nettyHttpHeaders.getAll(HttpHeaders.COOKIE);
    if (values == null || values.isEmpty()) {
        return Collections.emptyMap();
    }

    Map<String, Cookie> cookieMap = new HashMap<>();
    for (String value : values) {
        if (value == null) {
            continue;
        }
        Cookie cookie = Cookie.valueOf(value);
        cookieMap.put(cookie.getName(), cookie);
    }
    return cookieMap;
}
项目:gigasetelements    文件:GigasetElementsBase.java   
@Override
   public void setMode(String baseId, Mode mode) {
// connect
final Client client = newClient();
final Cookie authorization = getAuthorization(client);
// ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
// urlBase
// ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
WebTarget targetSetMode = client.target(url02).path(urlBase.concat("/").concat(baseId));
decorate(targetSetMode);
String json = "{ 'intrusion_settings' : { 'active_mode' : '" + mode.name().toLowerCase() + "' }}";
json = json.replace("'", "\"");
Response responseSetMode = targetSetMode.request(MediaType.TEXT_PLAIN_TYPE).cookie(authorization).post(Entity.entity(json, MediaType.TEXT_PLAIN_TYPE));
report(responseSetMode);
String entitySetMode = responseSetMode.readEntity(String.class);
System.out.println("--> " + entitySetMode);
   }
项目:gigasetelements    文件:GigasetElementsBase.java   
@Override
   public void setMode(String baseId, Mode mode) {
// connect
final Client client = newClient();
final Cookie authorization = getAuthorization(client);
// ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
// urlBase
// ------------------------------------------------------------------------------------------------------------------------------------------------------------------------
WebTarget targetSetMode = client.target(url02).path(urlBase.concat("/").concat(baseId));
decorate(targetSetMode);
String json = "{ 'intrusion_settings' : { 'active_mode' : '" + mode.name().toLowerCase() + "' }}";
json = json.replace("'", "\"");
Response responseSetMode = targetSetMode.request(MediaType.TEXT_PLAIN_TYPE).cookie(authorization).post(Entity.entity(json, MediaType.TEXT_PLAIN_TYPE));
report(responseSetMode);
String entitySetMode = responseSetMode.readEntity(String.class);
System.out.println("--> " + entitySetMode);
   }
项目:verigreen    文件:Request.java   
public Request(
        String uri,
        Object entity,
        String mediaType,
        List<Cookie> cookies,
        Map<String, Object> headers) {

    _uri = uri;
    _entity = entity;
    _mediaType = mediaType;
    if (cookies != null) {
        _cookies = cookies;
    }
    if (headers != null) {
        _headers = headers;
    }
}
项目:verigreen    文件:RestClientImpl.java   
private Builder prepareRequest(Request request) {

    WebTarget webTarget = _client.target(request.getUri());
    Map<String, String> queryParams = request.getQueryParams();
    if (queryParams != null) {
        for (Entry<String, String> param : queryParams.entrySet()) {
            webTarget = webTarget.queryParam(param.getKey(), param.getValue());
        }
    }
    Map<String, Object> pathTemplateParams = request.getPathTemplateParams();
    if (pathTemplateParams != null) {
        webTarget = webTarget.resolveTemplates(pathTemplateParams);
    }
    Builder builder = webTarget.request();
    for (Cookie currCookie : request.getCookies()) {
        builder = builder.cookie(currCookie);
    }
    for (Entry<String, Object> currEntry : request.getHeaders().entrySet()) {
        builder = builder.header(currEntry.getKey(), currEntry.getValue());
    }

    return builder;
}
项目:bagri    文件:RestServiceTest.java   
public static void startServices() throws Exception {
    //System.setProperty("bdb.log.level", "trace");
       startAdminServer();
    ctx = startCacheServer("0");

    //URI baseURI = new URI("https://localhost:3443");
    URI baseURI = new URI("http://localhost:3030");
    ClientConfig clientConfig = new ClientConfig();
    Client client = ClientBuilder.newClient(clientConfig);
    target = client.target(baseURI);

    LoginParams params = new LoginParams("default", "guest", "password");
       Response response = target.path("access/login").request()
            .header("Content-Type", "application/json")
            .post(Entity.json(params), Response.class);
       assertEquals(Status.OK.getStatusCode(), response.getStatus());

       Cookie cc = response.getCookies().get(bg_cookie);
       assertNotNull(cc);
       assertEquals(bg_cookie, cc.getName());
       cuid = cc.getValue();
}
项目:bagri    文件:AuthFilter.java   
@Override
public void filter(ContainerRequestContext requestContext) throws IOException {
    final SecurityContext securityContext = requestContext.getSecurityContext();
    if (securityContext != null) {
        logger.debug("filter; auth scheme: {}; secure: {}", securityContext.getAuthenticationScheme(), securityContext.isSecure());
        String path = requestContext.getUriInfo().getPath();
        if ("access/login".equals(path)) {
            // just check https
            if (!securityContext.isSecure()) {
                requestContext.abortWith(Response.status(Status.NOT_ACCEPTABLE)
                        .entity("Wrong protocol used.").build());
            }
        } else if ("application.wadl".equals(path) || "swagger.json".equals(path) || "swagger.yaml".equals(path)) {
            return; 
        } else {
            Cookie cc = requestContext.getCookies().get(bg_cookie);
            if (cc == null || !checkAuth(cc.getValue())) {
                requestContext.abortWith(Response.status(Status.UNAUTHORIZED)
                        .entity("No authorization token provided.").build());
            }
        }
    } else {
           requestContext.abortWith(Response.status(Status.UNAUTHORIZED)
                   .entity("No security context provided.").build());
    }
}
项目:bagri    文件:AccessServiceTest.java   
@Test
public void testLogout() throws Exception {
    //
    Response response = target("access/logout").request()
            .post(null, Response.class);
    assertEquals(401, response.getStatus());

    response = target("access/logout").request()
            .cookie(bg_cookie, "client-id")
            .post(null, Response.class);
    assertEquals(200, response.getStatus());
    //assertNull(response.getCookies().get(bg_cookie));
    Cookie cc = response.getCookies().get(bg_cookie);
    assertNotNull(cc);
    assertEquals(bg_cookie, cc.getName());
    assertTrue(cc.toString().endsWith("Max-Age=0"));
}
项目:ameba-utils    文件:Cookies.java   
/**
 * <p>newDeletedCookie.</p>
 *
 * @param name a {@link java.lang.String} object.
 * @return a {@link javax.ws.rs.core.NewCookie} object.
 */
public static NewCookie newDeletedCookie(String name) {
    /**
     * Create a new instance.
     *
     * @param name     the name of the cookie
     * @param value    the value of the cookie
     * @param path     the URI path for which the cookie is valid
     * @param domain   the host domain for which the cookie is valid
     * @param version  the version of the specification to which the cookie complies
     * @param comment  the comment
     * @param maxAge   the maximum age of the cookie in seconds
     * @param expiry   the cookie expiry date.
     * @param secure   specifies whether the cookie will only be sent over a secure connection
     * @param httpOnly if {@code true} make the cookie HTTP only, i.e. only visible as part of an HTTP request.
     * @throws IllegalArgumentException if name is {@code null}.
     * @since 2.0
     */
    return new NewCookie(name, DELETED_COOKIE_VALUE, "/", null, Cookie.DEFAULT_VERSION, null, 0, null, false, true);
}
项目:ameba-utils    文件:Cookies.java   
/**
 * <p>newHttpOnlyCookie.</p>
 *
 * @param name  a {@link java.lang.String} object.
 * @param value a {@link java.lang.String} object.
 * @return a {@link javax.ws.rs.core.NewCookie} object.
 */
public static NewCookie newHttpOnlyCookie(String name, String value) {
    /**
     * Create a new instance.
     *
     * @param name     the name of the cookie
     * @param value    the value of the cookie
     * @param path     the URI path for which the cookie is valid
     * @param domain   the host domain for which the cookie is valid
     * @param version  the version of the specification to which the cookie complies
     * @param comment  the comment
     * @param maxAge   the maximum age of the cookie in seconds
     * @param expiry   the cookie expiry date.
     * @param secure   specifies whether the cookie will only be sent over a secure connection
     * @param httpOnly if {@code true} make the cookie HTTP only, i.e. only visible as part of an HTTP request.
     * @throws IllegalArgumentException if name is {@code null}.
     * @since 2.0
     */
    return new NewCookie(name, value, null, null, Cookie.DEFAULT_VERSION, null, -1, null, false, true);
}
项目:ameba-utils    文件:Cookies.java   
/**
 * <p>newHttpOnlyCookie.</p>
 *
 * @param name a {@link java.lang.String} object.
 * @param value a {@link java.lang.String} object.
 * @param maxAge a int.
 * @return a {@link javax.ws.rs.core.NewCookie} object.
 */
public static NewCookie newHttpOnlyCookie(String name, String value, int maxAge) {
    /**
     * Create a new instance.
     *
     * @param name     the name of the cookie
     * @param value    the value of the cookie
     * @param path     the URI path for which the cookie is valid
     * @param domain   the host domain for which the cookie is valid
     * @param version  the version of the specification to which the cookie complies
     * @param comment  the comment
     * @param maxAge   the maximum age of the cookie in seconds
     * @param expiry   the cookie expiry date.
     * @param secure   specifies whether the cookie will only be sent over a secure connection
     * @param httpOnly if {@code true} make the cookie HTTP only, i.e. only visible as part of an HTTP request.
     * @throws IllegalArgumentException if name is {@code null}.
     * @since 2.0
     */
    return new NewCookie(name, value, null, null, Cookie.DEFAULT_VERSION, null, maxAge, null, false, true);
}
项目:dropwizard-cookie-authprovider    文件:CookieAuthProvider.java   
@Override
public T getValue(HttpContext httpContext) {
    final Cookie cookie = httpContext.getRequest().getCookies().get(this.cookie);

    if (cookie != null) {
        final String value = cookie.getValue();
        try {
            final Optional<T> result = authenticator.authenticate(value);
            if (result.isPresent()) {
                return result.get();
            }
        } catch (AuthenticationException e) {
            e.printStackTrace();
        }
    }

    if (required) {
        throw new WebApplicationException(
                Response.status(Response.Status.UNAUTHORIZED)
                        .entity("Credentials are required to access this resource")
                        .type(MediaType.TEXT_PLAIN_TYPE)
                        .build());
    }

    return null;
}
项目:module.jaxrs-filter-security    文件:HttpCookieAuthenticationFilter.java   
@Override
public void filter(ContainerRequestContext request) throws IOException {
    Collection<String> expired = SessionCookieFilter.getExpiredSystems(request);
    sessionConfigurations.forEach((system, config) -> {
        Subject subject = SubjectContext.getSubject(system);
        if (config.getCookieName() != null && subject.getPrincipal() == null) {
            Cookie cookie = request.getCookies().get(config.getCookieName());
            if (cookie != null) {
                LOGGER.trace("enter() {} - {}", subject, request.getUriInfo().getRequestUri());
                HttpCookieToken token = new HttpCookieToken(system, cookie);
                try {
                    SubjectContext.login(token);
                } catch (LoginException e) {
                    LOGGER.trace("login failed: {}: {}", e.getClass().getSimpleName(), e.getMessage());
                    expired.add(system);
                }
            }
        }
    });
}
项目:redhat-support-lib-java    文件:API.java   
public API(String url, String proxyUser, String proxyPassword,
        URL proxyUrl, int proxyPort, String userAgent,
        Map<String, Cookie> cookies, boolean isDevel) {
    config = new ConfigHelper(url, proxyUser, proxyPassword, proxyUrl,
            proxyPort, userAgent, cookies, isDevel);
    connectionManager = new ConnectionManager(config);

    search = new Search(connectionManager);
    solutions = new Solutions(connectionManager);
    articles = new Articles(connectionManager);
    cases = new Cases(connectionManager);
    products = new Products(connectionManager);
    comments = new Comments(connectionManager);
    entitlements = new Entitlements(connectionManager);
    problems = new Problems(connectionManager);
    attachments = new Attachments(connectionManager);
    ping = new Ping(connectionManager);
    groups = new Groups(connectionManager);
    symptoms = new Symptoms(connectionManager);
    insights = new Insights(connectionManager);
}
项目:ameba-shiro    文件:CookieRememberMeManager.java   
@Override
protected byte[] getRememberedSerializedIdentity(SubjectContext subjectContext) {
    if (isIdentityRemoved()) {
        return null;
    }

    Cookie cookie = Requests.getCookies().get(getCookie().getName());
    //no cookie set - new site visitor?
    if (cookie == null) return null;
    String base64 = cookie.getValue();
    if (Cookies.DELETED_COOKIE_VALUE.equals(base64)) return null;

    if (base64 != null) {
        base64 = ensurePadding(base64);
        logger.trace("Acquired Base64 encoded identity [" + base64 + "]");
        byte[] decoded = Base64.decode(base64);
        logger.trace("Base64 decoded byte array length: " + (decoded != null ? decoded.length : 0) + " bytes.");
        return decoded;
    } else {
        //no cookie set - new site visitor?
        return null;
    }
}
项目:pinot    文件:ThirdEyeAuthFilter.java   
private Credentials getCredentials(ContainerRequestContext requestContext) throws Exception {
  Credentials credentials = new Credentials();

  Map<String, Cookie> cookies = requestContext.getCookies();
  if (cookies != null && cookies.containsKey(AuthResource.AUTH_TOKEN_NAME)) {
    String rawCookie = cookies.get(AuthResource.AUTH_TOKEN_NAME).getValue();
    if (rawCookie.isEmpty()) {
      LOG.error("Empty cookie. Skipping.");
      return credentials;
    }

    AuthCookie cookie = this.serializer.deserializeCookie(rawCookie);
    credentials.setPrincipal(cookie.getPrincipal());
    credentials.setPassword(cookie.getPassword()); // TODO replace with token in DB
  }

  return credentials;
}
项目:minnal    文件:AbstractSecurityFilter.java   
/**
 * @param request
 * @param create
 * @return
 */
protected Session getSession(ContainerRequestContext request, boolean create) {
    Session session = (Session) request.getProperty(SESSION);
    if (session != null) {
        return session;
    }
    Cookie sessionCookie = request.getCookies().get(AUTH_COOKIE);

    if (sessionCookie != null) {
        session = configuration.getSessionStore().getSession(sessionCookie.getValue());
    }

    if (session != null && session.hasExpired(configuration.getSessionExpiryTimeInSecs())) {
        session = null;
    }
    if (session == null && create) {
        String sessionId = null;
        if (Strings.isNullOrEmpty(sessionId)) {
            sessionId = UUID.randomUUID().toString();
        }
        session = configuration.getSessionStore().createSession(sessionId);
    }
    return session;
}