org.gluu.credmanager.core.RSRegistryHandler クラス

org.gluu.credmanager.core.RSRegistryHandler 連携図

公開メンバ関数
void	scan (String id, Path path, ClassLoader classLoader)
void	remove (String id)

静的公開変数類
static final String	ENDPOINTS_PREFIX = "pl"

非公開メンバ関数
void	inited ()
boolean	processClassEntry (String id, String binaryName, ClassLoader clsLoader, List< Class<?>> list)
int	scanJarForRSResources (String id, JarInputStream inStream, ClassLoader clsLoader) throws IOException
int	scanFolderForRSResources (String id, Path start, ClassLoader clsLoader) throws IOException

非公開変数類
Logger	logger
ServletContext	servletContext
Registry	rsRegistry
boolean	enabled
List< String >	skipFolders
Map< String, List< Class<?> > >	registeredResources

詳解

著者

jgomer

関数詳解

inited()

void org.gluu.credmanager.core.RSRegistryHandler.inited ( )

inlineprivate

                          {
        try {
            skipFolders = Arrays.asList(ZKService.EXTERNAL_LABELS_DIR, ExtensionsManager.ASSETS_DIR, "META-INF");
            registeredResources = new HashMap<>();

            //Try to find a ResteasyDeployment
            Object obj = servletContext.getAttribute(Registry.class.getName());
            //sc.getAttribute(ResteasyDeployment.class.getName())

            if (obj == null) {
                obj = servletContext.getAttribute(ResteasyContextParameters.RESTEASY_DEPLOYMENTS);
                Map<String, ResteasyDeployment> deployments = (Map<String, ResteasyDeployment>) obj;
                rsRegistry = deployments.get(RSInitializer.ROOT_PATH).getRegistry();
            } else {
                rsRegistry = ((ResteasyDeployment) obj).getRegistry();
            }

        } catch (Exception e) {
            logger.error(e.getMessage(), e);
        } finally {
            if (rsRegistry == null) {
                logger.warn("Could not access RestEasy registry. Addition of REST services at runtime may not be available");
            } else {
                logger.info("RestEasy registry is accessible. Addition of REST services at runtime will be available");
                enabled = true;
            }
        }
        //registry.removeRegistrations(RestService2.class);

    }

processClassEntry()

boolean org.gluu.credmanager.core.RSRegistryHandler.processClassEntry ( String  id, String  binaryName, ClassLoader  clsLoader, List< Class<?>>  list  )

inlineprivate

                                                                                                                {

        boolean added = false;
        try {
            Class<?> cls = clsLoader.loadClass(binaryName);
            javax.ws.rs.Path pathAnnotation = cls.getAnnotation(javax.ws.rs.Path.class);

            if (pathAnnotation != null) {
                logger.info("Found class '{}' annotated with @Path", binaryName);
                String basePath = ENDPOINTS_PREFIX + "/" + id;
                String absolutePath = RSInitializer.ROOT_PATH + "/" + basePath + pathAnnotation.value();

                RSResourceScope scopeAnnotation = cls.getAnnotation(RSResourceScope.class);
                boolean isSingleton =  scopeAnnotation == null || scopeAnnotation.singleton();

                if (isSingleton) {
                    try {
                        rsRegistry.addSingletonResource(cls.newInstance(), basePath);
                        logger.info("Singleton resource has been bound to '{}' endpoint", absolutePath);
                        list.add(cls);
                        added = true;
                    } catch (Exception e) {
                        logger.error("Class could not be instantiated. Check it has no args constructor");
                    }
                } else {
                    rsRegistry.addPerRequestResource(cls, basePath);
                    logger.info("Per-request resource has been bound to '{}' endpoint", absolutePath);
                    list.add(cls);
                    added = true;
                }
            }

        } catch (ClassNotFoundException e) {
            //Intentionally left empty
        }
        return added;

    }

remove()

void org.gluu.credmanager.core.RSRegistryHandler.remove ( String  id )

inline

                                  {

        if (enabled) {
            List<Class<?>> classes = registeredResources.get(id);
            if (classes != null) {
                for (Class<?> cls : classes) {
                    logger.debug("Removing RestEasy registration {}", cls.getName());
                    rsRegistry.removeRegistrations(cls, ENDPOINTS_PREFIX + "/" + id);
                }
                registeredResources.remove(id);
            }
        }

    }

scan()

void org.gluu.credmanager.core.RSRegistryHandler.scan ( String  id, Path  path, ClassLoader  classLoader  )

inline

                                                                    {

        int scannedResources = 0;

        if (enabled) {
            try {
                registeredResources.put(id, new ArrayList<>());
                //Recursively scan for @Path annotation in directory (or jar file)
                if (Files.isDirectory(path)) {
                    scannedResources = scanFolderForRSResources(id, path, classLoader);
                } else if (Utils.isJarFile(path)) {
                    try (JarInputStream jis = new JarInputStream(new BufferedInputStream(new FileInputStream(path.toString())), false)) {
                        scannedResources = scanJarForRSResources(id, jis, classLoader);
                    }
                }
            } catch (IOException e) {
                logger.error("Error scanning RestEasy resources: {}", e.getMessage());
            }
            logger.info("{} RestEasy resource class(es) registered", scannedResources);

        } else {
            logger.info("Path '{}' will not be scanned: no RestEasy registry was found", path.toString());
        }
    }

scanFolderForRSResources()

int org.gluu.credmanager.core.RSRegistryHandler.scanFolderForRSResources ( String  id, Path  start, ClassLoader  clsLoader  ) throws IOException

inlineprivate

                                                                                                          {

        final class MyCounterFileVisitor extends SimpleFileVisitor<Path> {

            private int count = 0;
            private int offset;

            private MyCounterFileVisitor(String basePath) {
                this.offset = basePath.length() + 1;    //Add one because trailing (back)slash is not in basePath
            }

            @Override
            public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {

                String path = file.toString().substring(offset);
                if (Utils.isClassFile(file) && skipFolders.stream().noneMatch(skip -> path.startsWith(skip + File.separator))) {
                    String binaryName = path.startsWith("classes" + File.separator) ? path.substring("classes".length() + 1) : path;
                    binaryName = binaryName.replace(File.separator, ".");
                    binaryName = binaryName.substring(0, binaryName.length() - ".class".length());
                    count += processClassEntry(id, binaryName, clsLoader, registeredResources.get(id)) ? 1 : 0;
                }
                return FileVisitResult.CONTINUE;
            }

        }

        MyCounterFileVisitor visitor = new MyCounterFileVisitor(start.toString());
        Files.walkFileTree(start, visitor);
        return visitor.count;

    }

scanJarForRSResources()

int org.gluu.credmanager.core.RSRegistryHandler.scanJarForRSResources ( String  id, JarInputStream  inStream, ClassLoader  clsLoader  ) throws IOException

inlineprivate

                                                                                                                    {

        int count = 0;
        JarEntry entry = inStream.getNextJarEntry();

        for (; entry != null; entry = inStream.getNextJarEntry()) {
            final String entryName = entry.getName();

            if (!entry.isDirectory() && entryName.endsWith(".class")
                    && skipFolders.stream().noneMatch(skip -> entryName.startsWith(skip + "/"))) {

                String binaryName = entryName.replace("/", ".");
                binaryName = binaryName.substring(0, binaryName.length() - ".class".length());
                count += processClassEntry(id, binaryName, clsLoader, registeredResources.get(id)) ? 1 : 0;
            }
        }
        return count;

    }

メンバ詳解

enabled

boolean org.gluu.credmanager.core.RSRegistryHandler.enabled

private

ENDPOINTS_PREFIX

final String org.gluu.credmanager.core.RSRegistryHandler.ENDPOINTS_PREFIX = "pl"

static

logger

Logger org.gluu.credmanager.core.RSRegistryHandler.logger

private

registeredResources

Map<String, List<Class<?> > > org.gluu.credmanager.core.RSRegistryHandler.registeredResources

private

rsRegistry

Registry org.gluu.credmanager.core.RSRegistryHandler.rsRegistry

private

servletContext

ServletContext org.gluu.credmanager.core.RSRegistryHandler.servletContext

private

skipFolders

List<String> org.gluu.credmanager.core.RSRegistryHandler.skipFolders

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/cred-manager/app/src/main/java/org/gluu/credmanager/core/RSRegistryHandler.java