Skip to content

Commit

Permalink
fixed metafacture#16
Browse files Browse the repository at this point in the history 
implemented metafacture#3
some warnings removed
  • Loading branch information
mgeipel committed Mar 12, 2013
1 parent 07628b0 commit cec781c
Show file tree
Hide file tree
Showing 10 changed files with 973 additions and 945 deletions.
1 change: 1 addition & 0 deletions .gitignore
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,3 +6,4 @@
*.ear

/target
/myflux
214 changes: 105 additions & 109 deletions src/main/java/org/culturegraph/mf/Flux.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,113 +13,109 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.culturegraph.mf;

import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.antlr.runtime.ANTLRInputStream;
import org.antlr.runtime.CommonTokenStream;
import org.antlr.runtime.RecognitionException;
import org.antlr.runtime.tree.CommonTreeNodeStream;
import org.culturegraph.mf.flux.Flow;
import org.culturegraph.mf.flux.parser.FlowBuilder;
import org.culturegraph.mf.flux.parser.FluxLexer;
import org.culturegraph.mf.flux.parser.FluxParser;
import org.culturegraph.mf.util.ResourceUtil;


/**
* @author Markus Michael Geipel
*
*/
public final class Flux {
public static final String MODULES_DIR = "modules";
private static final Pattern VAR_PATTERN = Pattern.compile("([^=]*)=(.*)");
private static final String SCRIPT_HOME = "FLUX_DIR";

private Flux() {
// no instances
}

/**
* @param args
* @throws IOException
* @throws RecognitionException
*/
public static void main(final String[] args) throws IOException, RecognitionException {

final File modulesDir = new File(MODULES_DIR);
if (modulesDir.exists()) {
final FilenameFilter filter = new FilenameFilter() {
@Override
public boolean accept(final File dir, final String name) {
return name.endsWith(".jar") || name.endsWith(".class");
}
};
final List<URL> moduleURLs = new LinkedList<URL>();
for (File file : modulesDir.listFiles(filter)) {
moduleURLs.add(file.getAbsoluteFile().toURI().toURL());
}
final URLClassLoader moduleLoader = new URLClassLoader(moduleURLs.toArray(new URL[0]), Thread
.currentThread().getContextClassLoader());
Thread.currentThread().setContextClassLoader(moduleLoader);
}

if (args.length < 1) {
Flow.printHelp();
System.exit(2);
return;
}

final File fluxFile = new File(args[0]);
if(!fluxFile.exists()){
System.err.println("File not found: " + args[0]);
System.exit(1);
return;
}


// get variable assignments
final Map<String, String> vars = new HashMap<String, String>();
vars.put(SCRIPT_HOME, fluxFile.getAbsoluteFile().getParent() + System.getProperty("file.separator"));


for (int i = 1; i < args.length; ++i) {
final Matcher matcher = VAR_PATTERN.matcher(args[i]);
if (!matcher.find()) {
Flow.printHelp();
return;
}
vars.put(matcher.group(1), matcher.group(2));
}

// run parser and builder
final Flow flow = compileFlow(compileAst(ResourceUtil.getStream(fluxFile)), vars);
flow.start();
}

public static CommonTreeNodeStream compileAst(final InputStream flowDef) throws IOException, RecognitionException {
final FluxParser parser = new FluxParser(new CommonTokenStream(new FluxLexer(new ANTLRInputStream(
flowDef))));
return new CommonTreeNodeStream(parser.flux().getTree());
}

public static Flow compileFlow(final CommonTreeNodeStream treeNodes, final Map<String, String> vars)
throws RecognitionException {
final FlowBuilder flowBuilder = new FlowBuilder(treeNodes);
flowBuilder.addVaribleAssignements(vars);
final Flow flow = flowBuilder.flux();
return flow;
}
package org.culturegraph.mf;

import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.antlr.runtime.ANTLRInputStream;
import org.antlr.runtime.CommonTokenStream;
import org.antlr.runtime.RecognitionException;
import org.antlr.runtime.tree.CommonTreeNodeStream;
import org.culturegraph.mf.flux.Flow;
import org.culturegraph.mf.flux.parser.FlowBuilder;
import org.culturegraph.mf.flux.parser.FluxLexer;
import org.culturegraph.mf.flux.parser.FluxParser;
import org.culturegraph.mf.util.ResourceUtil;

/**
* @author Markus Michael Geipel
*
*/
public final class Flux {
public static final String MODULES_DIR = "modules";
private static final Pattern VAR_PATTERN = Pattern.compile("([^=]*)=(.*)");
private static final String SCRIPT_HOME = "FLUX_DIR";

private Flux() {
// no instances
}

/**
* @param args
* @throws IOException
* @throws RecognitionException
*/
public static void main(final String[] args) throws IOException, RecognitionException {

final File modulesDir = new File(MODULES_DIR);
if (modulesDir.exists()) {
final FilenameFilter filter = new FilenameFilter() {
@Override
public boolean accept(final File dir, final String name) {
return name.endsWith(".jar") || name.endsWith(".class");
}
};
final List<URL> moduleURLs = new LinkedList<URL>();
for (File file : modulesDir.listFiles(filter)) {
moduleURLs.add(file.getAbsoluteFile().toURI().toURL());
}
final URLClassLoader moduleLoader = new URLClassLoader(moduleURLs.toArray(new URL[0]), Thread
.currentThread().getContextClassLoader());
Thread.currentThread().setContextClassLoader(moduleLoader);
}

if (args.length < 1) {
Flow.printHelp(System.out);
System.exit(2);
} else {

final File fluxFile = new File(args[0]);
if (!fluxFile.exists()) {
System.err.println("File not found: " + args[0]);
System.exit(1);
return;
}

// get variable assignments
final Map<String, String> vars = new HashMap<String, String>();
vars.put(SCRIPT_HOME, fluxFile.getAbsoluteFile().getParent() + System.getProperty("file.separator"));

for (int i = 1; i < args.length; ++i) {
final Matcher matcher = VAR_PATTERN.matcher(args[i]);
if (!matcher.find()) {
Flow.printHelp(System.err);
return;
}
vars.put(matcher.group(1), matcher.group(2));
}

// run parser and builder
final Flow flow = compileFlow(compileAst(ResourceUtil.getStream(fluxFile)), vars);
flow.start();
}
}

public static CommonTreeNodeStream compileAst(final InputStream flowDef) throws IOException, RecognitionException {
final FluxParser parser = new FluxParser(new CommonTokenStream(new FluxLexer(new ANTLRInputStream(flowDef))));
return new CommonTreeNodeStream(parser.flux().getTree());
}

public static Flow compileFlow(final CommonTreeNodeStream treeNodes, final Map<String, String> vars)
throws RecognitionException {
final FlowBuilder flowBuilder = new FlowBuilder(treeNodes);
flowBuilder.addVaribleAssignements(vars);
final Flow flow = flowBuilder.flux();
return flow;
}
}
Loading

0 comments on commit cec781c

Please sign in to comment.