org.wso2.msf4j.Request类的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(13.4k)|赞(0)|评价(0)|浏览(186)

本文整理了Java中org.wso2.msf4j.Request类的一些代码示例，展示了Request类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request类的具体详情如下：
包路径：org.wso2.msf4j.Request
类名称：Request

Request介绍

[英]Class that represents an HTTP request in MSF4J level.
[中]类，该类表示MSF4J级别的HTTP请求。

代码示例

代码示例来源：origin: wso2/msf4j

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     log.info("Logging HTTP request { HTTPMethod: {}, URI: {} }", request.getHttpMethod(), request.getUri());
  4.     return true;
  5.   }
  6. }

代码示例来源：origin: wso2/msf4j

  1. /**
  2.  * Returns the value of the named attribute as an Object, or null if no attribute of the given name exists.
  3.  *
  4.  * @param name a {@link String} specifying the name of the attribute
  5.  * @return an {@link Object} containing the value of the attribute, or null if the attribute does not exist
  6.  */
  7. public Object getAttribute(String name) {
  8.   return request.getProperty(name);
  9. }

代码示例来源：origin: wso2/msf4j

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     request.getHeaders().getRequestHeaders().entrySet()
  4.         .forEach(header -> log.info("Header - " + header.getKey() + " : " + header.getValue()));
  5.     return true;
  6.   }
  7. }

代码示例来源：origin: wso2/msf4j

  1. @Override
  2. default boolean interceptRequest(Request request, Response response) throws Exception {
  3.   Method method = (Method) request.getProperty(MSF4JConstants.METHOD_PROPERTY_NAME);
  4.   ServiceMethodInfo serviceMethodInfo = new ServiceMethodInfo(method.getName(), method, request);
  5.   request.getProperties().forEach(serviceMethodInfo::setAttribute);
  6.   return preCall(request, response, serviceMethodInfo);
  7. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. private void setBaseUri(Request request) {
  2.   StringBuilder builder = new StringBuilder();
  3.   builder.append(request.getProperty(Constants.PROTOCOL).toString().toLowerCase(Locale.US)).append("://")
  4.       .append(request.getHeader(HttpHeaderNames.HOST.toString()));
  5.   if (builder.charAt(builder.length() - 1) != '/') {
  6.     builder.append("/");
  7.   }
  8.   try {
  9.     MSF4JResponse.setBaseUri(new URI(builder.toString()));
  10.   } catch (URISyntaxException e) {
  11.     log.error("Error while setting the Base URI. " + e.getMessage(), e);
  12.   }
  13. }

代码示例来源：origin: org.wso2.carbon.uis/org.wso2.carbon.uis

  1. this.method = request.getHttpMethod();
  2. String rawUri = request.getUri();
  3. int uriPathEndIndex = rawUri.indexOf('?');
  4. String rawUriPath, rawQueryString;
  5. Map<String, String> httpHeaders = request.getHeaders().getRequestHeaders().entrySet().stream()
  6.     .collect(Collectors.toMap(Map.Entry::getKey, entry -> entry.getValue().get(0)));
  7. this.headers = Collections.unmodifiableMap(httpHeaders);

代码示例来源：origin: org.wso2.carbon.identity.gateway/org.wso2.carbon.identity.gateway.api

  1. /**
  2.  * Update GatewayRequestBuilder.
  3.  *
  4.  * @param builder Builder.
  5.  * @param request MS4J request
  6.  * @throws GatewayClientException GatewayClientException
  7.  */
  8. protected void create(T builder, Request request)
  9.     throws GatewayClientException {
  10.   request.getHeaders().getAll().forEach(header -> {
  11.     builder.addHeader(header.getName(), header.getValue());
  12.   });
  13.   builder.setMethod(request.getHttpMethod());
  14.   builder.setContentType(request.getContentType());
  15.   builder.setRequestURI(request.getUri());
  16.   builder.setMethod(request.getHttpMethod());
  17.   builder.setAttributes((Map) request.getProperties());
  18.   builder.addParameter(Constants.QUERY_PARAMETERS,
  19.       (Serializable) request.getProperty(Constants.QUERY_PARAMETERS));
  20.   builder.addParameter(Constants.BODY_PARAMETERS, (Serializable) request.getProperty(Constants.BODY_PARAMETERS));
  21.   String[] queryStringParams = request.getUri().split("\\?");
  22.   if (queryStringParams.length > 1) {
  23.     builder.setQueryString(queryStringParams[1]);
  24.   } else {
  25.     builder.setQueryString(queryStringParams[0]);
  26.   }
  27.   if (logger.isDebugEnabled()) {
  28.     logger.debug("Successfully Updated the request builder in GatewayRequestBuilderFactory.");
  29.   }
  30. }

代码示例来源：origin: org.wso2.carbon.analytics-common/org.wso2.carbon.analytics.msf4j.interceptor.common

  1. } else {
  2.   for (String url : DataHolder.getInstance().getExcludeURLList()) {
  3.     if (request.getUri().matches(url)) {
  4.       return true;
  5.   Headers headers = request.getHeaders();
  6.   String authorizationHeader = request.getHeader(IdPClientConstants.AUTHORIZATION_HEADER);
  7.   if (authorizationHeader != null) {
  8.     String headerPrefix = authorizationHeader.split(" ")[0];
  9.         String username = idPClient.authenticate(accessToken);
  10.         if (username != null) {
  11.           request.setProperty(InterceptorConstants.PROPERTY_USERNAME, username);
  12.           return true;
  13.         String userName = authHeader.split(":")[0];
  14.         String password = authHeader.split(":")[1];
  15.         String appName = request.getUri().split("/\\|?")[1];
  16.             .equals(IdPClientConstants.LoginStatus.LOGIN_FAILURE)) {
  17.           LOGGER.debug("Authentication failed for the request to '{}' due to Error: '{}', " +
  18.                   "Error Description: '{}'.", request.getUri(),
  19.               loginValues.get(IdPClientConstants.ERROR),
  20.               loginValues.get(IdPClientConstants.ERROR_DESCRIPTION));
  21.           response.setEntity("Authentication failed for the request to : '" + request.getUri() +
  22.               "' due to Error :'" + loginValues.get(IdPClientConstants.ERROR) + "'," +
  23.               " Error Description : '" + loginValues.get(IdPClientConstants.ERROR_DESCRIPTION))
  24.         request.setProperty(InterceptorConstants.PROPERTY_USERNAME, userName);

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. String requestPath = request.getUri();
  2. if (requestPath.endsWith("/")) {
  3.   requestPath = requestPath.substring(0, requestPath.length() - 1);
  4.           .filter(e -> e.getValue().getHttpMethod().contains(request.getHttpMethod()) &&
  5.                 finalRequestPath.matches(e.getKey().getPath().replaceAll(GROUP_PATTERN,
  6.                                           GROUP_PATTERN_REGEX)) &&
  7.           .collect(Collectors.toList());
  8. Optional<Map.Entry<SubresourceKey, HttpResourceModel>> entry = entries.stream().filter(
  9.     entryPair -> entryPair.getValue().matchConsumeMediaType(request.getContentType()) &&
  10.            entryPair.getValue().matchProduceMediaType(request.getAcceptTypes()))
  11.                                    .findFirst();
  12.                       .getValue()
  13.                       .matchConsumeMediaType(
  14.                           request.getContentType()) &&
  15.                   entryPair
  16.                       .getValue()
  17.                       .matchProduceMediaType(
  18.                           request.getAcceptTypes()))
  19.       .findFirst();
  20.   if (entry.isPresent()) {
  21. httpSubResourceModelProcessor.setFormParameters(formParameters);
  22. responder.setMediaType(
  23.     Util.getResponseType(request.getAcceptTypes(), resourceModel.getProducesMediaTypes()));
  24. HttpMethodInfo httpMethodInfo = httpSubResourceModelProcessor
  25.     .buildHttpMethodInfo(request, responder, groupNameValues);

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   SecurityErrorCode errorCode;
  4.   try {
  5.     HttpHeaders headers = request.getHeaders();
  6.     String authHeader = headers.getHeaderString(AUTHORIZATION_HTTP_HEADER);
  7.     if (authHeader != null && !authHeader.isEmpty()) {
  8.       return validateToken(authHeader);
  9.     } else {
  10.       throw new MSF4JSecurityException(SecurityErrorCode.AUTHENTICATION_FAILURE,
  11.           "Missing Authorization header is the request.`");
  12.     }
  13.   } catch (MSF4JSecurityException e) {
  14.     errorCode = e.getErrorCode();
  15.     log.error(e.getMessage() + " Requested Path: " + request.getUri());
  16.   }
  17.   handleSecurityError(errorCode, response);
  18.   return false;
  19. }

代码示例来源：origin: wso2/msf4j

  1. Request request, MicroservicesRegistryImpl microservicesRegistry, boolean isSubResource) throws Exception {
  2. Class<?> clazz = httpMethodInfo.method.getDeclaringClass();
  3. request.setProperty(MSF4JConstants.METHOD_PROPERTY_NAME, httpMethodInfo.method); // Required for analytics
  4.   ((ArrayList<Class<?>>) request.getProperty(DECLARING_CLASS_LIST_CONSTANT)).add(0, clazz);
  5.   ((ArrayList<Method>) request.getProperty(RESOURCE_METHOD_LIST_CONSTANT)).add(0, httpMethodInfo.method);
  6.   return httpMethodInfo
  7.       .invokeSubResource(request, destination, returnedValue, microservicesRegistry);

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. /**
  2.  * Get the request's content type.
  3.  *
  4.  * @return String request's content type
  5.  */
  6. public String getContentType() {
  7.   return this.request.getHeader("Content-Type");
  8. }

代码示例来源：origin: org.wso2.carbon.auth/org.wso2.carbon.auth.rest.api.authenticators

  1. /**
  2.  * Get defined HTTP methods in the swagger definition as a comma separated string
  3.  *
  4.  * @param request Request
  5.  * @return Http Methods as a comma separated string
  6.  */
  7. public static RestAPIInfo getElectedRestApiInfo(Request request) {
  8.   if (request.getProperty(RestAPIConstants.ELECTED_BASE_PATH) != null) {
  9.     return ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().get(request.getProperty
  10.         (RestAPIConstants.ELECTED_BASE_PATH));
  11.   }
  12.   String requestURI = request.getUri().toLowerCase(Locale.ENGLISH);
  13.   RestAPIInfo electedSwagger = null;
  14.   for (String basePath : ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().keySet()) {
  15.     if (requestURI.contains(basePath)) {
  16.       electedSwagger = ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().get(basePath);
  17.       break;
  18.     }
  19.   }
  20.   if (electedSwagger != null) {
  21.     request.setProperty(RestAPIConstants.ELECTED_BASE_PATH, electedSwagger.getBasePath());
  22.   }
  23.   return electedSwagger;
  24. }

代码示例来源：origin: wso2/msf4j

  1. @Override
  2. public URI getUri() {
  3.   return URI.create(req.getUri());
  4. }

代码示例来源：origin: wso2/msf4j

  1. long time = new Date().getTime();
  2. serviceMethodInfo.setAttribute(RESPONDER_ATTRIBUTE, responder);
  3. String traceOriginId = request.getHeader(TracingConstants.TRACE_ORIGIN_ID_HEADER);
  4. String serverTraceId;
  5. if (traceOriginId == null) {
  6.   serverTraceId = TracingUtil.generateUniqueId();
  7. String traceParentId = request.getHeader(TracingConstants.TRACE_ID_HEADER);
  8. TraceEvent serverTraceEvent = new TraceEvent(
  9.     TracingConstants.SERVER_TRACE_START,
  10. serverTraceEvent.setInstanceName(instanceName);
  11. serverTraceEvent.setParentId(traceParentId);
  12. serverTraceEvent.setHttpMethod(request.getHttpMethod());
  13. serverTraceEvent.setUrl(request.getUri());
  14. TracingEventTracker.setTraceEvent(serverTraceEvent);
  15. serviceMethodInfo.setAttribute(TRACE_EVENT_ATTRIBUTE, serverTraceEvent);

代码示例来源：origin: org.wso2.carbon.auth/org.wso2.carbon.auth.rest.api.authenticators

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) {
  3.   Method method = (Method) request.getProperty(MSF4JConstants.METHOD_PROPERTY_NAME);
  4.   String origin = request.getHeader(RestAPIConstants.ORIGIN_HEADER);
  5.   String allowedOrigin = RestApiUtil.getAllowedOrigin(origin);
  6.   if (allowedOrigin != null) {
  7.   if (request.getHttpMethod().equalsIgnoreCase(RestAPIConstants.HTTP_OPTIONS)) {
  8.     try {
  9.       String definedHttpMethods = RestApiUtil.getDefinedMethodHeadersInSwaggerContent(request, method);

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.msf4j.interceptor.common

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   String authorizationHeader = request.getHeader(HEADER_AUTHORIZATION);
  4.   if (authorizationHeader != null) {
  5.     byte[] decodedAuthHeader = Base64.getDecoder().decode(authorizationHeader.split(" ")[1]);
  6.     String authHeader = new String(decodedAuthHeader);
  7.     String userName = authHeader.split(":")[0];
  8.     String password = authHeader.split(":")[1];
  9.     CarbonMessage carbonMessage = new DefaultCarbonMessage();
  10.     carbonMessage.setHeader(HEADER_AUTHORIZATION, "Basic " + Base64.getEncoder()
  11.         .encodeToString((userName + ":" + password).getBytes())
  12.     );
  13.     /*
  14.     ProxyCallbackHandler callbackHandler = new ProxyCallbackHandler(carbonMessage);
  15.     LoginContext loginContext;
  16.     loginContext = new LoginContext("CarbonSecurityConfig", callbackHandler);
  17.     loginContext.login();
  18.     */
  19.     return true;
  20.   }
  21.   LOG.error("Authorization header not found for request : '" + request.getUri() + "'");
  22.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode())
  23.       .setEntity("Authorization is required to access uri '" + request.getUri() + "'. Please set " +
  24.           "the authentication header and try again.")
  25.       .setMediaType(MediaType.TEXT_PLAIN);
  26.   return false;
  27. }

代码示例来源：origin: org.wso2.carbon.apimgt/org.wso2.carbon.apimgt.authenticator

  1. if (AuthenticatorConstants.REFRESH_GRANT.equals(grantType)) {
  2.   refToken = AuthUtil
  3.       .extractTokenFromHeaders(request.getHeaders(), AuthenticatorConstants.REFRESH_TOKEN_2);
  4.   if (refToken == null) {
  5.     ErrorDTO errorDTO = new ErrorDTO();
  6.           refreshTokenCookie, refreshTokenHttpOnlyCookie).header(AuthenticatorConstants.
  7.               REFERER_HEADER,
  8.           (request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) != null && request
  9.               .getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER)
  10.               .equals(request.getHeader(AuthenticatorConstants.REFERER_HEADER))) ?
  11.               "" :
  12.               request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) != null ?
  13.                   request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) :
  14.                   "").build();
  15. } else {
  16.       .header(AuthenticatorConstants.
  17.               REFERER_HEADER,
  18.           (request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) != null && request
  19.               .getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER)
  20.               .equals(request.getHeader(AuthenticatorConstants.REFERER_HEADER))) ?
  21.               "" :
  22.               request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) != null ?
  23.                   request.getHeader(AuthenticatorConstants.X_ALT_REFERER_HEADER) :
  24.                   "").build();

代码示例来源：origin: org.wso2.carbon.auth/org.wso2.carbon.auth.rest.api.commons

  1. RestAPIAuthSecurityException {
  2. String authHeader = request.getHeader(RestApiConstants.AUTHORIZATION_HTTP_HEADER);
  3. if (authHeader != null) {
  4.   String authEncoded = authHeader.substring(RestApiConstants.AUTH_TYPE_BASIC.length()).trim();
  5.       boolean authenticated = userStoreManager.doAuthenticate(username, password);
  6.       if (authenticated) {
  7.         request.setProperty(RestAPIConstants.LOGGED_IN_USER, username);
  8.         request.setProperty(RestAPIConstants.LOGGED_IN_PSEUDO_USER, userNameMapper
  9.             .getLoggedInPseudoNameFromUserID(username));
  10.         return true;

代码示例来源：origin: org.wso2.carbon.apimgt/org.wso2.carbon.apimgt.rest.api.webserver

  1. @Override public Response publisherGet(String accept, String ifNoneMatch, String ifModifiedSince, Request request)
  2.     throws NotFoundException {
  3.   String rawUri = request.getUri();
  4.   String hostName = String.valueOf(request.getProperties().get("HOST"));
  5.   String port = String.valueOf(request.getProperties().get("LISTENER_PORT"));
  6.   String protocol = String.valueOf(request.getProperties().get("PROTOCOL"));
  7.   String absURL = protocol + "://" + hostName + ":" + port + rawUri;
  8.   String path;

内容来源于网络，如有侵权，请联系作者删除！

request

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com