Java 类javax.ws.rs.container.ResourceInfo 实例源码

项目：wechat-mall 文件：AppkeyServiceFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    List<Annotation> authzSpecs = new ArrayList<>();

    Annotation classAuthzSpec =
        resourceInfo.getResourceClass().getAnnotation(AppkeyAnnotation.class);
    Annotation methodAuthzSpec =
        resourceInfo.getResourceMethod().getAnnotation(AppkeyAnnotation.class);

    if (classAuthzSpec != null)
        authzSpecs.add(classAuthzSpec);
    if (methodAuthzSpec != null)
        authzSpecs.add(methodAuthzSpec);

    if (!authzSpecs.isEmpty()) {
        context.register(AppkeyFilter.class);
    }
}

项目：wechat-mall 文件：AuthServiceFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    List<Annotation> authzSpecs = new ArrayList<>();

    Annotation classAuthzSpec =
        resourceInfo.getResourceClass().getAnnotation(AuthAnnotation.class);
    Annotation methodAuthzSpec =
        resourceInfo.getResourceMethod().getAnnotation(AuthAnnotation.class);

    if (classAuthzSpec != null)
        authzSpecs.add(classAuthzSpec);
    if (methodAuthzSpec != null)
        authzSpecs.add(methodAuthzSpec);

    if (!authzSpecs.isEmpty()) {
        // 需要拦截的api
        context.register(AuthorizationFilter.class);
    }
}

项目：syndesis 文件：CacheForFilter.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    CacheFor cc = resourceInfo.getResourceClass().getAnnotation(CacheFor.class);
    CacheFor mcc = resourceInfo.getResourceMethod().getAnnotation(CacheFor.class);
    if( mcc!=null ) {
        cc = mcc;
    }
    if (cc!=null) {
        if( cc.value() == 0 ) {
            context.register(NoCacheFilter.class);
        } else if( cc.value() > 0 ) {
            context.register(new CacheFilter("max-age= " + cc.unit().toSeconds(cc.value())));
        }
    } else {
        context.register(NoCacheFilter.class);
    }
}

项目：oscm 文件：VersionFilterTest.java

@SuppressWarnings("boxing")
private MultivaluedMap<String, String> testVersionFilter(String version) throws WebApplicationException, NoSuchMethodException {

    ResourceInfo resourceInfo = mock(ResourceInfo.class);
    ContainerRequestContext request = mock(ContainerRequestContext.class);
    UriInfo uriInfo = mock(UriInfo.class);
    when(request.getUriInfo()).thenReturn(uriInfo);

    Method method = SinceClass.class.getMethod("dummy");

    MultivaluedMap<String, String> prop = new MultivaluedHashMap<>();
    prop.putSingle(CommonParams.PARAM_VERSION, version);
    when(uriInfo.getPathParameters()).thenReturn(prop);

    VersionFilter filter = spy(new VersionFilter());
    when(filter.getResourceInfo()).thenReturn(resourceInfo);
    when(resourceInfo.getResourceMethod()).thenReturn(method);
    filter.filter(request);

    return prop;
}

项目：azeroth 文件：DefaultFilterDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    // 获取资源方法
    Method resourceMethod = resourceInfo.getResourceMethod();

    if (resourceMethod != null) {

        // 获取FormatJson注解
        ResponseFormat formatJson = resourceMethod.getAnnotation(ResponseFormat.class);

        if (formatJson == null || formatJson.type().equals(FormatType.JSON)) {
            context.register(DefaultWebFilter.class);
        }

    }
}

项目：mycore 文件：MCRJerseyDefaultFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Class<?> resourceClass = resourceInfo.getResourceClass();
    Method resourceMethod = resourceInfo.getResourceMethod();
    if (isStaticContent(resourceClass, resourceMethod)) {
        // class or method is annotated with MCRStaticContent
        //   -> do not register any filter
        return;
    }
    String packageName = resourceClass.getPackage().getName();
    if (getPackages().contains(packageName)) {
        registerTransactionFilter(context);
        registerSessionHookFilter(context);
        registerAccessFilter(context, resourceClass, resourceMethod);
    }
}

项目：awplab-core 文件：BasicAuthKarafSecurityDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext featureContext) {

    AnnotatedMethod am = new AnnotatedMethod(resourceInfo.getResourceMethod());

    RequireBasicAuth requireBasicAuth = null;
    if (am.isAnnotationPresent(RequireBasicAuth.class)) {
        requireBasicAuth = am.getAnnotation(RequireBasicAuth.class);
    }
    else {
        requireBasicAuth = resourceInfo.getResourceClass().getAnnotation(RequireBasicAuth.class);
    }

    if (requireBasicAuth != null) {
        featureContext.register(new BasicAuthKarafSecurityRequestFilter(requireBasicAuth.limitToGroups(), requireBasicAuth.limitToRoles(), requireBasicAuth.karafRealm(), requireBasicAuth.requiresSecure(), requireBasicAuth.httpRealm()));
    }
}

项目：ozark 文件：ViewResponseFilter.java

private static MediaType selectVariant(Request request, ResourceInfo resourceInfo) {

        Produces produces = resourceInfo.getResourceMethod().getAnnotation(Produces.class);
        if (produces == null) {
            produces = getAnnotation(resourceInfo.getResourceClass(), Produces.class);
        }

        if (produces != null) {

            List<Variant> variants = Arrays.stream(produces.value())
                .map((String mt) -> Variant.mediaTypes(MediaType.valueOf(mt)).build().get(0))
                .collect(Collectors.toList());

            Variant variant = request.selectVariant(variants);
            if (variant != null) {
                return variant.getMediaType();
            }

        }

        return null;

    }

项目：openregister-java 文件：RegisterAuthDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    final AnnotatedMethod am = new AnnotatedMethod(resourceInfo.getResourceMethod());
    final Annotation[][] parameterAnnotations = am.getParameterAnnotations();
    //@DenyAll shouldn't be attached to classes
    final boolean annotationOnClass = (resourceInfo.getResourceClass().getAnnotation(RolesAllowed.class) != null) ||
            (resourceInfo.getResourceClass().getAnnotation(PermitAll.class) != null);
    final boolean annotationOnMethod = am.isAnnotationPresent(RolesAllowed.class) || am.isAnnotationPresent(DenyAll.class) ||
            am.isAnnotationPresent(PermitAll.class);

    if (annotationOnClass || annotationOnMethod) {
        context.register(filterClass);
    } else {
        for (Annotation[] annotations : parameterAnnotations) {
            for (Annotation annotation : annotations) {
                if (annotation instanceof Auth) {
                    context.register(filterClass);
                    return;
                }
            }
        }
    }
}

项目：jeesuite-libs 文件：ResponseWrapperHandler.java

@Override
public void processResponse(ContainerRequestContext requestContext, ContainerResponseContext responseContext,
        ResourceInfo resourceInfo) {
    MediaType mediaType = responseContext.getMediaType();
    if (mediaType != null && MediaType.APPLICATION_JSON_TYPE.equals(mediaType)) {
        Object responseData = responseContext.getEntity();
        WrapperResponseEntity jsonResponse;

        if (responseData instanceof WrapperResponseEntity) {
            jsonResponse = (WrapperResponseEntity) responseData;
        } else {
            jsonResponse = new WrapperResponseEntity(ResponseCode.OK);
            jsonResponse.setData(responseData);
        }
        responseContext.setStatus(ResponseCode.OK.getCode());

        responseContext.setEntity(jsonResponse);

    }
}

项目：jeesuite-libs 文件：DefaultFilterDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    // 获取资源方法
    Method resourceMethod = resourceInfo.getResourceMethod();

    if (resourceMethod != null) {

        // 获取FormatJson注解
        ResponseFormat formatJson = resourceMethod.getAnnotation(ResponseFormat.class);

        if(formatJson == null || formatJson.type().equals(FormatType.JSON)){
            context.register(DefaultWebFilter.class);
        }

    }
}

项目：java-jaxrs 文件：ServerTracingDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    // TODO why it is called twice for the same endpoint
    if (!tracingDisabled(resourceInfo) && builder.allTraced) {
        log(resourceInfo);
        context.register(new ServerTracingFilter(
            builder.tracer,
            operationName(resourceInfo),
            builder.spanDecorators,
            builder.operationNameBuilder.build(resourceInfo.getResourceClass(), resourceInfo.getResourceMethod()),
            builder.skipPattern != null ? Pattern.compile(builder.skipPattern) : null),
            builder.priority);

        if (builder.traceSerialization) {
            context.register(new ServerTracingInterceptor(builder.tracer,
                builder.serializationSpanDecorators), builder.serializationPriority);
        }
    }
}

项目：java-dropwizard 文件：ServerTracingFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Trace annotation = resourceInfo.getResourceMethod().getAnnotation(Trace.class);
    String operationName = this.operationName;
    if (annotation != null) {
        if (!annotation.operationName().equals("")) {
            operationName = annotation.operationName();
        }
        context.register(new ServerRequestTracingFilter(this.tracer, operationName,
            this.tracedAttributes, this.tracedProperties, this.decorator));
        context.register(new ServerResponseTracingFilter(this.tracer));  
    } else {
        if (traceAll) {
            context.register(new ServerRequestTracingFilter(this.tracer, operationName,
                this.tracedAttributes, this.tracedProperties, this.decorator));
            context.register(new ServerResponseTracingFilter(this.tracer));
        } 
    }
}

项目：syndesis-rest 文件：CacheForFilter.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    CacheFor cc = resourceInfo.getResourceClass().getAnnotation(CacheFor.class);
    CacheFor mcc = resourceInfo.getResourceMethod().getAnnotation(CacheFor.class);
    if( mcc!=null ) {
        cc = mcc;
    }
    if (cc!=null) {
        if( cc.value() == 0 ) {
            context.register(NoCacheFilter.class);
        } else if( cc.value() > 0 ) {
            context.register(new CacheFilter("max-age= " + cc.unit().toSeconds(cc.value())));
        }
    } else {
        context.register(NoCacheFilter.class);
    }
}

项目：drill 文件：AuthDynamicFeature.java

@Override
public void configure(final ResourceInfo resourceInfo, final FeatureContext configuration) {
  AnnotatedMethod am = new AnnotatedMethod(resourceInfo.getResourceMethod());

  // RolesAllowed on the method takes precedence over PermitAll
  RolesAllowed ra = am.getAnnotation(RolesAllowed.class);
  if (ra != null) {
    configuration.register(AuthCheckFilter.INSTANCE);
    return;
  }

  // PermitAll takes precedence over RolesAllowed on the class
  // This avoids putting AuthCheckFilter in the request flow for all path's which
  // are defined under PermitAll annotation. That is requests for "/", "/login", "/mainLogin" and "/spnegoLogin"
  // path's doesn't go through AuthCheckFilter.
  if (am.isAnnotationPresent(PermitAll.class)) {
    // Do nothing.
    return;
  }

  // RolesAllowed on the class takes precedence over PermitAll
  ra = resourceInfo.getResourceClass().getAnnotation(RolesAllowed.class);
  if (ra != null) {
    configuration.register(AuthCheckFilter.INSTANCE);
  }
}

项目：sealion 文件：PermissionProvider.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    if (resourceInfo.getResourceClass().getName()
            .startsWith(RootResource.class.getPackage().getName() + ".") == false) {
        return;
    }

    Permissions permissions = resourceInfo.getResourceMethod().getAnnotation(Permissions.class);
    if (permissions == null) {
        permissions = resourceInfo.getResourceClass().getAnnotation(Permissions.class);
    }
    if (permissions == null) {
        //TODO
        Logger.getLogger(PermissionProvider.class.getName())
                .warning(String.format("%s not annotated @Permissions",
                        resourceInfo.getResourceMethod().toGenericString()));
        return;
    }
    context.register(new PermissionTester(permissions));
}

项目：jee-user-auth 文件：AuthenticationFeatureTest.java

@Test
public void shouldRegisterFilterWhenIsPermitAllReturnsFalse() throws Exception {
    // given
    AuthenticationFeature feature = new AuthenticationFeature() {
        @Override
        boolean isPermitAll(ResourceInfo resourceInfo) {
            return false;
        }
    };

    // when
    FeatureContext context = mock(FeatureContext.class);
    feature.configure(mock(ResourceInfo.class), context);

    // then
    verify(context).register(any(AuthenticationFilter.class));
}

项目：jee-user-auth 文件：AuthenticationFeatureTest.java

@Test
public void shouldNotRegisterFilterWhenIsPermitAllReturnsTrue() throws Exception {
    // given
    AuthenticationFeature feature = new AuthenticationFeature() {
        @Override
        boolean isPermitAll(ResourceInfo resourceInfo) {
            return true;
        }
    };

    // when
    FeatureContext context = mock(FeatureContext.class);
    feature.configure(mock(ResourceInfo.class), context);

    // then
    verify(context, never()).register(any(AuthenticationFilter.class));
}

项目：hawkular-commons 文件：TenantFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Class<?> resourceClass = resourceInfo.getResourceClass();
    Method method = resourceInfo.getResourceMethod();

    boolean required = true;
    if (resourceClass.isAnnotationPresent(TenantRequired.class)) {
        required = resourceClass.getAnnotation(TenantRequired.class).value();
    }

    if (method.isAnnotationPresent(TenantRequired.class)) {
        required = method.getAnnotation(TenantRequired.class).value();
    }

    if (required) {
        context.register(TENANT_FILTER);
    }
}

项目：respiro 文件：TimerFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    Method resourceMethod = resourceInfo.getResourceMethod();
    Class<?> resourceClass = resourceInfo.getResourceClass();
    if(metricsDisabled(resourceClass)) {
        return;
    }
    Path methodPath = resourceMethod.getAnnotation(Path.class);
    Path classPath  = resourceClass.getAnnotation(Path.class);

    Path path = methodPath != null ? methodPath : classPath;
    if(path != null) {
        UriBuilder builder = methodPath != null
                ? UriBuilder.fromResource(resourceClass).path(resourceClass, resourceMethod.getName())
                : UriBuilder.fromResource(resourceClass);

        String template = builder.toTemplate();
        context.register(new TimerBeforeFilter(template));
        context.register(TimerAfterFilter.class);
    }
}

项目：shiro-jersey 文件：AuthorizationFilterFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    List<Annotation> authzSpecs = new ArrayList<>();

    for (Class<? extends Annotation> annotationClass : shiroAnnotations) {
        // XXX What is the performance of getAnnotation vs getAnnotations?
        Annotation classAuthzSpec = resourceInfo.getResourceClass().getAnnotation(annotationClass);
        Annotation methodAuthzSpec = resourceInfo.getResourceMethod().getAnnotation(annotationClass);

        if (classAuthzSpec != null) authzSpecs.add(classAuthzSpec);
        if (methodAuthzSpec != null) authzSpecs.add(methodAuthzSpec);
    }

    if (!authzSpecs.isEmpty()) {
        context.register(new AuthorizationFilter(authzSpecs), Priorities.AUTHORIZATION);
    }
}

项目：module.jaxrs-filter-jsend 文件：JSendFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Jsend jsend = resourceInfo.getResourceMethod().getAnnotation(Jsend.class);
    if (jsend == null) {
        jsend = resourceInfo.getResourceClass().getAnnotation(Jsend.class);
    }
    if (jsend != null) {
        Produces produces = resourceInfo.getResourceMethod().getAnnotation(Produces.class);
        if (produces == null) {
            produces = resourceInfo.getResourceClass().getAnnotation(Produces.class);
        }
        if (produces == null || produces.value().length == 0) {
            context.register(new JsendFilter(jsend));
        } else {
            final Jsend finalJsend = jsend;
            Arrays.asList(produces.value())
                .stream()
                .filter(ct -> MediaType.APPLICATION_JSON_TYPE.isCompatible(MediaType.valueOf(ct)))
                .findFirst()
                .ifPresent(s -> context.register(new JsendFilter(finalJsend)));
        }
    }
}

项目：dropwizard-guicey 文件：GuiceBindingsModule.java

@Override
protected void configure() {
    jerseyToGuice(MultivaluedParameterExtractorProvider.class);
    jerseyToGuice(Application.class);
    jerseyToGuice(Providers.class);

    // request scoped objects, but hk will control their scope
    // must be used in guice only with Provider
    jerseyToGuice(UriInfo.class);
    jerseyToGuice(ResourceInfo.class);
    jerseyToGuice(HttpHeaders.class);
    jerseyToGuice(SecurityContext.class);
    jerseyToGuice(Request.class);
    jerseyToGuice(ContainerRequest.class);
    jerseyToGuice(AsyncContext.class);

    if (!guiceServletSupport) {
        // bind request and response objects when guice servlet module not registered
        // but this will work only for resources
        jerseyToGuice(HttpServletRequest.class);
        jerseyToGuice(HttpServletResponse.class);
    }
}

项目：Shiro-Jersey2-annotations 文件：ShiroDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext featureContext) {
    // No need to check non-Jax-rs classes
    if (resourceInfo.getResourceClass().getAnnotation(Path.class) != null) {
        if (filterNeeded(RequiresAuthentication.class, RequiresNoAuthentication.class, resourceInfo)) {
            featureContext.register(new RequiresAuthenticationContainerRequestFilter());
        }

        if (filterNeeded(RequiresGuest.class, RequiresNoGuest.class, resourceInfo)) {
            featureContext.register(new RequiresGuestContainerRequestFilter());
        }

        if (filterNeeded(RequiresPermissions.class, RequiresNoPermission.class, resourceInfo)) {
            featureContext.register(new RequiresPermissionContainerRequestFilter(resourceInfo));
        }

        if (filterNeeded(RequiresRoles.class, RequiresNoRoles.class, resourceInfo)) {
            featureContext.register(new RequiresRolesContainerRequestFilter(resourceInfo));
        }

        if (filterNeeded(RequiresUser.class, RequiresNoUser.class, resourceInfo)) {
            featureContext.register(new RequiresUserContainerRequestFilter());
        }
    }
}

项目：Shiro-Jersey2-annotations 文件：RequiresPermissionContainerRequestFilter.java

public RequiresPermissionContainerRequestFilter(ResourceInfo resourceInfo) {
    RequiresPermissions permissions = resourceInfo.getResourceClass().getAnnotation(
            RequiresPermissions.class);
    RequiresPermissions methodPermissions = resourceInfo.getResourceMethod().getAnnotation(
            RequiresPermissions.class);

    if (methodPermissions != null) {
        permissions = methodPermissions;
    }

    Objects.requireNonNull(permissions);
    logical = permissions.logical();
    for (String permission : permissions.value()) {
        requiredPermissions.add(new WildcardPermission(permission));
    }
}

项目：dropwizard-java8 文件：AuthDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    final AnnotatedMethod am = new AnnotatedMethod(resourceInfo.getResourceMethod());
    final Annotation[][] parameterAnnotations = am.getParameterAnnotations();
    if (am.isAnnotationPresent(RolesAllowed.class) || am.isAnnotationPresent(DenyAll.class) ||
        am.isAnnotationPresent(PermitAll.class)) {
        context.register(authFilter);
    } else {
        for (Annotation[] annotations : parameterAnnotations) {
            for (Annotation annotation : annotations) {
                if (annotation instanceof Auth) {
                    context.register(authFilter);
                    return;
                }
            }
        }
    }
}

项目：module.jaxrs-filter-security 文件：PermissionsFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Method am = resourceInfo.getResourceMethod();
    if (am.isAnnotationPresent(Permissions.class)) {
        Authenticated authenticated = am.getAnnotation(Authenticated.class);
        if (authenticated == null) {
            authenticated = resourceInfo.getResourceClass().getAnnotation(Authenticated.class);
            if (authenticated == null) {
                throw new IllegalStateException("@Permissions found on " + am + " but no @Authenticated found");
            }
        }
        List<String> permissions = Arrays.asList(am.getAnnotation(Permissions.class).value());
        Collection<String> vars = new HashSet<>();
        for (String p : permissions) {
            int s = p.indexOf('{');
            while (s != -1) {
                int e = p.indexOf('}', s + 1);
                vars.add(p.substring(s + 1, e));
                s = p.indexOf('{', e + 1);
            }
        }
        context.register(new PermissionFilter(authenticated.value(), permissions, vars));
    }
}

项目：baguette 文件：Server.java

public Server() {
    register(FreemarkerMvcFeature.class);

    packages("ru.qatools.school.baguette.resources");

    register(new DynamicFeature() {
        @Override
        public void configure(ResourceInfo resourceInfo, FeatureContext context) {
            context.register(DatabaseProvider.class);

            if (resourceInfo.getResourceMethod().isAnnotationPresent(AuthenticationRequired.class)) {
                context.register(AuthenticationFilter.class);
            }
        }
    });
}

项目：shiro-jersey 文件：AuthorizationFilterFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    List<Annotation> authzSpecs = new ArrayList<>();

    for (Class<? extends Annotation> annotationClass : shiroAnnotations) {
        // XXX What is the performance of getAnnotation vs getAnnotations?
        Annotation classAuthzSpec = resourceInfo.getResourceClass().getAnnotation(annotationClass);
        Annotation methodAuthzSpec = resourceInfo.getResourceMethod().getAnnotation(annotationClass);

        if (classAuthzSpec != null) authzSpecs.add(classAuthzSpec);
        if (methodAuthzSpec != null) authzSpecs.add(methodAuthzSpec);
    }

    if (!authzSpecs.isEmpty()) {
        context.register(new AuthorizationFilter(authzSpecs), Priorities.AUTHORIZATION);
    }
}

项目：Mastering-Java-EE-Development-with-WildFly 文件：MyResourceSingleton.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Class<?> resourceClass = resourceInfo.getResourceClass();
    Method method = resourceInfo.getResourceMethod();
    logger.info("getResourceClass: " + resourceClass);
    logger.info("getResourceMethod: " + method);
    context.property("new_dynamic_feature", resourceClass + "|" + method);
}

项目：Alpine 文件：AuthorizationFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    if (ENFORCE_AUTHENTICATION && ENFORCE_AUTHORIZATION) {
        final Method method = resourceInfo.getResourceMethod();
        if (method.isAnnotationPresent(PermissionRequired.class)) {
            context.register(AuthorizationFilter.class);
        }
    }
}

项目：Alpine 文件：AuthenticationFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    if (ENFORCE_AUTHENTICATION) {
        final Method method = resourceInfo.getResourceMethod();
        if (!method.isAnnotationPresent(AuthenticationNotRequired.class)) {
            context.register(AuthenticationFilter.class);
        }
    }
}

项目：SAPNetworkMonitor 文件：AuthFilterDynamicBinding.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    Method method = resourceInfo.getResourceMethod();
    Annotation[][] parameterAnnotations = method.getParameterAnnotations();
    for (Annotation[] annotations : parameterAnnotations) {
        for (Annotation annotation : annotations) {
            if (annotation.annotationType().equals(Session.class) && !method.getName().startsWith("log")) {
                context.register(NiPingAuthFilter.class);
            }
        }
    }
}

项目：redpipe 文件：AuthorizationFilterFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {

    List<Annotation> authzSpecs = new ArrayList<>();
    boolean canRedirect = true;
    for (Class<? extends Annotation> annotationClass : filterAnnotations) {
        // XXX What is the performance of getAnnotation vs getAnnotations?
        Annotation classAuthzSpec = resourceInfo.getResourceClass().getAnnotation(annotationClass);
        Annotation methodAuthzSpec = resourceInfo.getResourceMethod().getAnnotation(annotationClass);

        if (classAuthzSpec != null) authzSpecs.add(classAuthzSpec);
        if (methodAuthzSpec != null) authzSpecs.add(methodAuthzSpec);

        if(resourceInfo.getResourceClass().isAnnotationPresent(NoAuthRedirect.class)
                || resourceInfo.getResourceMethod().isAnnotationPresent(NoAuthRedirect.class))
            canRedirect = false;
        if(resourceInfo.getResourceClass().isAnnotationPresent(NoAuthFilter.class)
                || resourceInfo.getResourceMethod().isAnnotationPresent(NoAuthFilter.class))
            return;
    }

    if (!authzSpecs.isEmpty()) {
        if(canRedirect)
            context.register(new LoginRedirectFilter(), Priorities.AUTHENTICATION + 1);
        context.register(new AuthorizationFilter(authzSpecs), Priorities.AUTHORIZATION);
    }
}

项目：haystack-client-java 文件：ServerFilter.java

/**
* Helper to determine if the filter applies in the current context or not.
*
* @param context Context provided on the request
* @param resourceInfo Resource Info injected via @Context
* @return <code>true</code> if this filter should apply to the current context
*/
 protected boolean shouldFilter(ContainerRequestContext context, ResourceInfo resourceInfo) {
     if (resourceInfo.getResourceMethod().getAnnotation(DisableTracing.class) != null
         || resourceInfo.getResourceClass().getAnnotation(DisableTracing.class) != null) {
         return false;
     }
     return true;
 }

项目：haystack-client-java 文件：ServerFilter.java

/**
 * Extension point used to supply the operation name for tracing.
 *
 * @param context Context provided on the request
 * @param resourceInfo Resource Info injected via @Context
 * @return the name used for this operation
 */
protected String getOperationName(ContainerRequestContext context, ResourceInfo resourceInfo) {
    final Traced methodAnnotation = resourceInfo.getResourceMethod().getAnnotation(Traced.class);
    if (methodAnnotation != null) {
        return methodAnnotation.name();
    }

    final Traced classAnnotation = resourceInfo.getResourceClass().getAnnotation(Traced.class);
    if (classAnnotation != null) {
        return classAnnotation.name();
    }

    return String.format("%s:%s", context.getMethod(), resourceInfo.getResourceClass().getCanonicalName());
}

项目：apm-client 文件：TraceContainerFilterTest.java

public Span test(String clientTraceId, String clientSpanId, int statusCode) throws Exception {

    TracerTestImpl tracer = new TracerTestImpl();

    ResourceInfo resourceInfo  = Mockito.mock(ResourceInfo.class);
    Method method = TraceContainerFilterTest.class.getMethod("testNoClientTrace");
    Mockito.when(resourceInfo.getResourceMethod()).thenReturn(method);
    Mockito.when(resourceInfo.getResourceClass()).thenReturn((Class)method.getDeclaringClass());

    TraceContainerFilter scf = new TraceContainerFilter();
    scf.setTracer(tracer);
    scf.resourceInfo = resourceInfo;

    UriInfo uriInfo  = Mockito.mock(UriInfo.class);
    Mockito.when(uriInfo.getRequestUri()).thenReturn(new URI("https://example.com:7110/some/path"));
    Mockito.when(uriInfo.getPath()).thenReturn("/path");

    ContainerRequestContext requestContext = Mockito.mock(ContainerRequestContext.class);
    Mockito.when(requestContext.getUriInfo()).thenReturn(uriInfo);
    Mockito.when(requestContext.getMethod()).thenReturn("GET");

    Mockito.when(requestContext.getHeaderString(Mockito.eq(TracerImpl.SPAN_ID))).thenReturn(clientSpanId);
    Mockito.when(requestContext.getHeaderString(Mockito.eq(TracerImpl.TRACE_ID))).thenReturn(clientTraceId);

    scf.filter(requestContext);
    Assert.assertNotNull(tracer.getCurrentSpan());

    ContainerResponseContext responseContext = Mockito.mock(ContainerResponseContext.class);
    Mockito.when(responseContext.getEntityAnnotations()).thenReturn(new Annotation[]{});
    Mockito.when(responseContext.getStatus()).thenReturn(statusCode);

    scf.filter(requestContext, responseContext);
    Assert.assertNull(tracer.getCurrentSpan());

    Span span = tracer.getCapturedSpan();
    Assert.assertEquals("service", span.getService());
    Assert.assertEquals("TraceContainerFilterTest", span.getResource());
    Assert.assertEquals("testNoClientTrace", span.getOperation());
    return span;
  }

项目：app-ms 文件：InterceptorTest.java

@SuppressWarnings({
    "unchecked",
    "rawtypes"
})
@Test
public void testInterceptor() throws Exception {

    jwtInterceptor.setClaimsProcessor(new ValidatingProcessor("typ", "https://example.com/register"));

    final JwtClaims jwtClaims = JwtClaims.parse("{\"typ\":\"https://example.com/register\", \"aud\":\"sample\", \"jti\": \"abc\", \"iss\":\"http://accounts.trajano.net\"}");
    final String jwt = cryptoOps.sign(jwtClaims);
    System.out.println(jwt);

    final ResourceInfo resourceInfo = Mockito.mock(ResourceInfo.class);
    Mockito.when(resourceInfo.getResourceMethod()).thenReturn(Hello.class.getMethod("hello2B"));
    Mockito.when(resourceInfo.getResourceClass()).thenReturn((Class) Hello.class);
    jwtInterceptor.setResourceInfo(resourceInfo);

    final ContainerRequestContext containerRequestContext = Mockito.mock(ContainerRequestContext.class);
    final UriInfo uriInfo = Mockito.mock(UriInfo.class);
    Mockito.when(uriInfo.getRequestUri()).thenReturn(URI.create("http://trajano.net/sample"));
    Mockito.when(containerRequestContext.getUriInfo()).thenReturn(uriInfo);
    Mockito.when(containerRequestContext.getHeaderString("X-JWT-Assertion")).thenReturn(jwt);
    Mockito.when(containerRequestContext.getHeaderString("X-JWT-Audience")).thenReturn("sample");
    mdcInterceptor.filter(containerRequestContext);
    jwtInterceptor.filter(containerRequestContext);
    //        final Request request = mock(Request.class);
    //        when(request.getHeader("X-JWT-Assertion")).thenReturn(jwt);
    //        final Response responder = mock(Response.class);
    //        final ServiceMethodInfo serviceMethodInfo = mock(ServiceMethodInfo.class);
    //        assertTrue(interceptor.preCall(request, responder, serviceMethodInfo));
}

项目：holon-jaxrs 文件：AuthenticationDynamicFeature.java

@Override
public void configure(ResourceInfo resourceInfo, FeatureContext context) {
    // check method
    if (!registerAuthenticationFilters(context, resourceInfo.getResourceMethod())) {
        // check class
        registerAuthenticationFilters(context, resourceInfo.getResourceClass());
    }
}

项目：azeroth 文件：ResponseWrapperHandler.java

@Override
public void processResponse(ContainerRequestContext requestContext,
                            ContainerResponseContext responseContext,
                            ResourceInfo resourceInfo) {
    MediaType mediaType = responseContext.getMediaType();
    if (mediaType != null && MediaType.APPLICATION_JSON_TYPE.equals(mediaType)) {
        Object responseData = responseContext.getEntity();
        WrapperResponseEntity jsonResponse;

        if (responseData instanceof WrapperResponseEntity) {
            jsonResponse = (WrapperResponseEntity) responseData;
        } else {
            jsonResponse = new WrapperResponseEntity(ResponseCode.OK);
            jsonResponse.setData(responseData);
        }
        responseContext.setStatus(ResponseCode.OK.getCode());

        responseContext.setEntity(jsonResponse);

    }
}