river-container-core/src/main/java/org/apache/river/container/deployer/ClasspathFilterBuilder.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.river.container.deployer;

import java.io.Reader;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Logger;
import org.apache.river.container.LocalizedRuntimeException;
import org.apache.river.container.MessageNames;
import org.apache.river.container.classloading.Acceptor;
import org.apache.river.container.classloading.AllAcceptor;
import org.apache.river.container.classloading.ClasspathFilter;
import org.apache.river.container.classloading.ResourceAcceptor;
import org.apache.river.container.classloading.VirtualFileSystemClassLoader;

/**
 *
 * @author trasukg
 */
public class ClasspathFilterBuilder {

    private static final Logger log = Logger.getLogger(ClasspathFilterBuilder.class.getName());

    public static List<ClasspathFilter> parseToFilters(String input) {
        try {
            ASTclasspath expression = classpathExpressionFromString(input);
            List<ClasspathFilter> filters = filtersFromClasspathExpression(expression);
            return filters;
        } catch (ParseException ex) {
            throw new LocalizedRuntimeException(MessageNames.BUNDLE_NAME,
                    MessageNames.BAD_CLASSPATH_EXPR,
                    new Object[]{input, ex.getMessage()});
        }
    }

    private static ASTclasspath classpathExpressionFromString(String input) throws ParseException {
        Reader r = new StringReader(input);
        DeployerConfigParser parser = new DeployerConfigParser(r);
        parser.classpath();
        ASTclasspath expression = (ASTclasspath) parser.jjtree.popNode();
        return expression;
    }

    public static List<ClasspathFilter> filtersFromClasspathExpression(ASTclasspath expression) {
        List<ClasspathFilter> filters = new ArrayList<ClasspathFilter>();
        for (int i = 0; i < expression.jjtGetNumChildren(); i++) {
            ASTcpEntry clause = (ASTcpEntry) expression.jjtGetChild(i);
            ClasspathFilter cpf = makeFilter(clause);
            filters.add(cpf);
        }
        return filters;
    }

    public static ClasspathFilter makeFilter(ASTcpEntry expression) {
        /* First node is the jar name.  Subsequent nodes are the filter
        conditions.
         */
        ClasspathFilter cpf = new ClasspathFilter();
        cpf.setJarName(expression.jjtGetChild(0).toString());
        for (int i = 1; i < expression.jjtGetNumChildren(); i++) {
            Node node = expression.jjtGetChild(i);
            if (node instanceof ASTsymbol) {
                String resourceName = VirtualFileSystemClassLoader.classToResourceName(node.toString());
                log.fine("Building ResourceAcceptor with string '" + resourceName + "'");
                Acceptor acc = new ResourceAcceptor(resourceName);
                cpf.getAcceptors().add(acc);
            }
            if (node instanceof ASTliteral) {
                log.fine("Building ResourceAcceptor with string '" + node.toString() + "'");
                ASTliteral lNode=(ASTliteral) node;
                Acceptor acc = new ResourceAcceptor((String)lNode.getValue());
                cpf.getAcceptors().add(acc);
            }
        }
        /* If there were no filter clauses, hence no acceptors, allow all
        patterns.
         */
        if (cpf.getAcceptors().isEmpty()) {
            cpf.getAcceptors().add(new AllAcceptor());
        }
        return cpf;
    }
}