+/*
+ * Copyright (C) 2007-2012 Mathieu Baudier
+ *
+ * Licensed 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.argeo.slc.cli;
+import java.io.File;
import java.io.FileInputStream;
+import java.util.List;
import java.util.Properties;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.Options;
import org.apache.commons.cli.ParseException;
import org.apache.commons.io.IOUtils;
+import org.argeo.osgi.boot.OsgiBoot;
import org.argeo.slc.SlcException;
-import org.argeo.slc.server.client.SlcServerHttpClient;
-import org.argeo.slc.server.client.impl.SlcServerHttpClientImpl;
+import org.argeo.slc.execution.ExecutionModulesManager;
+import org.eclipse.core.runtime.adaptor.EclipseStarter;
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceReference;
+@SuppressWarnings("static-access")
public class SlcMain {
public enum Type {
standalone, agent, server
private static Boolean debug = true;
- private final static String BOOTSTRAP_LOG4J_CONFIG = "org/argeo/slc/cli/bootstrapLog4j.properties";
- private final static String DEFAULT_AGENT_CONTEXT = "classpath:org/argeo/slc/cli/spring-agent-default.xml";
+ // private final static String BOOTSTRAP_LOG4J_CONFIG =
+ // "org/argeo/slc/cli/bootstrapLog4j.properties";
+ // private final static String DEFAULT_AGENT_CONTEXT =
+ // "classpath:org/argeo/slc/cli/spring-agent-default.xml";
private final static Option typeOpt = OptionBuilder.withLongOpt("mode")
- .withArgName("mode").hasArg().withDescription(
- "Execution type, one of: " + listTypeValues()).create('t');
+ .withArgName("mode").hasArg()
+ .withDescription("Execution type, one of: " + listTypeValues())
+ .create('t');
- private final static Option propertyOpt = OptionBuilder.withLongOpt(
- "property").withArgName("prop1=val1,prop2=val2").hasArgs()
- .withValueSeparator(',').withDescription(
- "use value for given property").create('p');
+ private final static Option propertyOpt = OptionBuilder
+ .withLongOpt("property").withArgName("prop1=val1,prop2=val2")
+ .hasArgs().withValueSeparator(',')
+ .withDescription("use value for given property").create('p');
- private final static Option propertiesOpt = OptionBuilder.withLongOpt(
- "properties").withArgName("properties file").hasArgs()
- .withValueSeparator(',').withDescription(
- "load properties from file (-p has priority)").create('P');
+ private final static Option propertiesOpt = OptionBuilder
+ .withLongOpt("properties").withArgName("properties file").hasArgs()
+ .withValueSeparator(',')
+ .withDescription("load properties from file (-p has priority)")
+ .create('P');
private final static Option moduleOpt = OptionBuilder.withLongOpt("module")
.withArgName("module").hasArg().withDescription("Execution module")
.withArgName("flows").hasArg().withDescription("Flows to execute")
.create('f');
- private final static Option runtimeOpt = OptionBuilder.withLongOpt(
- "runtime").withArgName("runtime").hasArg().withDescription(
- "Runtime URL").create('r');
+ private final static Option runtimeOpt = OptionBuilder
+ .withLongOpt("runtime").withArgName("runtime").hasArg()
+ .withDescription("Runtime URL").create('r');
private final static Options options;
private final static String commandName = "slc";
+ private static String bundlesToInstall = "/usr/share/osgi;in=*.jar";
+
+ private static String bundlesToStart = "org.springframework.osgi.extender,"
+ + "org.argeo.node.repofactory.jackrabbit,"
+ + "org.argeo.node.repo.jackrabbit," + "org.argeo.security.dao.os,"
+ + "org.argeo.slc.node.jackrabbit," + "org.argeo.slc.agent,"
+ + "org.argeo.slc.agent.jcr";
+
static {
options = new Options();
- options.addOption(typeOpt);
- options.addOption(moduleOpt);
- options.addOption(flowsOpt);
- options.addOption(propertyOpt);
- options.addOption(propertiesOpt);
- options.addOption(runtimeOpt);
+ // options.addOption(typeOpt);
+ // options.addOption(moduleOpt);
+ // options.addOption(flowsOpt);
+ // options.addOption(propertyOpt);
+ // options.addOption(propertiesOpt);
+ // options.addOption(runtimeOpt);
}
public static void main(String[] args) {
- Type type = null;
- Properties properties = new Properties();
+ // Type type = null;
+ // Properties properties = new Properties();
+ // String flows = null;
+ // String urlStr = null;
+
String module = null;
- String flows = null;
- String urlStr = null;
+ String moduleUrl = null;
+ String flow = null;
try {
CommandLineParser clParser = new GnuParser();
CommandLine cl = clParser.parse(options, args);
- // Mode
- String typeStr = cl.getOptionValue(typeOpt.getOpt());
- if (typeStr == null) {
- type = Type.standalone;
+ List<String> arguments = cl.getArgList();
+ if (arguments.size() == 0) {
+ // TODO default behaviour
} else {
- try {
- type = Type.valueOf(typeStr);
- } catch (IllegalArgumentException e) {
- throw new SlcException("Unrecognized mode '" + typeStr
- + "'", e);
+ module = arguments.get(0);
+ File moduleFile = new File(module);
+ if (moduleFile.exists()) {
+ if (moduleFile.isDirectory()) {
+ moduleUrl = "reference:file:"
+ + moduleFile.getCanonicalPath();
+ } else {
+ moduleUrl = "file:" + moduleFile.getCanonicalPath();
+ }
}
- }
- // Script
- if (type.equals(Type.standalone)) {
- if (!cl.hasOption(moduleOpt.getOpt()))
- throw new SlcException("Type " + Type.standalone
- + " requires option '" + moduleOpt.getLongOpt()
- + "'");
- module = cl.getOptionValue(moduleOpt.getOpt());
-
- // Targets
- if (cl.hasOption(flowsOpt.getOpt()))
- flows = cl.getOptionValue(flowsOpt.getOpt());
- }
-
- // Properties
- if (cl.hasOption(propertiesOpt.getOpt())) {
- for (String propertyFile : cl.getOptionValues(propertiesOpt
- .getOpt())) {
- loadPropertyFile(properties, propertyFile);
+ if (arguments.size() == 1) {
+ // TODO module info
+ } else {
+ flow = arguments.get(1);
}
}
- if (cl.hasOption(propertyOpt.getOpt())) {
- for (String property : cl.getOptionValues(propertyOpt.getOpt())) {
- addProperty(properties, property);
- }
+
+ // System.setProperty(
+ // ExecutionModulesManager.UNIQUE_LAUNCH_MODULE_PROPERTY,
+ // module);
+ // System.setProperty(
+ // ExecutionModulesManager.UNIQUE_LAUNCH_FLOW_PROPERTY, flow);
+
+ String executionDir = System.getProperty("user.dir");
+ File slcDir = new File(executionDir, ".slc");
+ File dataDir = new File(slcDir, "data");
+ if (!dataDir.exists())
+ dataDir.mkdirs();
+ File confDir = new File(slcDir, "conf");
+ if (!confDir.exists())
+ confDir.mkdirs();
+
+ BundleContext bundleContext = null;
+ try {
+ String[] osgiRuntimeArgs = { "-configuration",
+ confDir.getCanonicalPath(), "-data",
+ dataDir.getCanonicalPath(), "-console", "-clean" };
+ bundleContext = EclipseStarter.startup(osgiRuntimeArgs, null);
+ } catch (Exception e) {
+ throw new RuntimeException("Cannot start Equinox.", e);
}
- // Runtime
- if (cl.hasOption(runtimeOpt.getOpt())) {
- urlStr = cl.getOptionValue(runtimeOpt.getOpt());
+ // OSGi bootstrap
+ OsgiBoot osgiBoot = new OsgiBoot(bundleContext);
+ osgiBoot.installUrls(osgiBoot.getBundlesUrls(bundlesToInstall));
+ osgiBoot.startBundles(bundlesToStart);
+
+ if (moduleUrl != null) {
+ Bundle bundle = osgiBoot.installUrl(moduleUrl);
+ module = bundle.getSymbolicName();
+ // TODO deal with version
}
+
+ // retrieve modulesManager
+ ServiceReference sr = bundleContext
+ .getServiceReference(ExecutionModulesManager.class
+ .getName());
+ ExecutionModulesManager modulesManager = (ExecutionModulesManager) bundleContext
+ .getService(sr);
+
+
+ modulesManager.execute(null);
+
+ // osgiBoot.bootstrap();
+ // osgiBoot.bootstrap();
+
+ // Mode
+ // String typeStr = cl.getOptionValue(typeOpt.getOpt());
+ // if (typeStr == null) {
+ // type = Type.standalone;
+ // } else {
+ // try {
+ // type = Type.valueOf(typeStr);
+ // } catch (IllegalArgumentException e) {
+ // throw new SlcException("Unrecognized mode '" + typeStr
+ // + "'", e);
+ // }
+ // }
+ //
+ // // Script
+ // if (type.equals(Type.standalone)) {
+ // if (!cl.hasOption(moduleOpt.getOpt()))
+ // throw new SlcException("Type " + Type.standalone
+ // + " requires option '" + moduleOpt.getLongOpt()
+ // + "'");
+ // module = cl.getOptionValue(moduleOpt.getOpt());
+ //
+ // // Targets
+ // if (cl.hasOption(flowsOpt.getOpt()))
+ // flows = cl.getOptionValue(flowsOpt.getOpt());
+ // }
+ //
+ // // Properties
+ // if (cl.hasOption(propertiesOpt.getOpt())) {
+ // for (String propertyFile : cl.getOptionValues(propertiesOpt
+ // .getOpt())) {
+ // loadPropertyFile(properties, propertyFile);
+ // }
+ // }
+ // if (cl.hasOption(propertyOpt.getOpt())) {
+ // for (String property : cl.getOptionValues(propertyOpt.getOpt()))
+ // {
+ // addProperty(properties, property);
+ // }
+ // }
+ //
+ // // Runtime
+ // if (cl.hasOption(runtimeOpt.getOpt())) {
+ // urlStr = cl.getOptionValue(runtimeOpt.getOpt());
+ // }
} catch (ParseException e) {
System.err.println("Problem with command line arguments. "
+ e.getMessage());
badExit();
}
- if (debug) {
- debug("Mode: " + type);
- if (urlStr != null)
- debug("Runtime: " + urlStr);
- debug("User properties: " + properties);
- if (module != null)
- debug("Module: " + module);
- if (flows != null)
- debug("Flows: " + flows);
- }
-
- // Standalone
- if (type.equals(Type.standalone)) {
- }
- // Agent
- else if (type.equals(Type.agent)) {
- }
- // Server
- else if (type.equals(Type.server)) {
- SlcServerHttpClientImpl slcServerHttpClient = new SlcServerHttpClientImpl();
- slcServerHttpClient.setBaseUrl(urlStr);
- }
+ // if (debug) {
+ // debug("Mode: " + type);
+ // if (urlStr != null)
+ // debug("Runtime: " + urlStr);
+ // debug("User properties: " + properties);
+ // if (module != null)
+ // debug("Module: " + module);
+ // if (flows != null)
+ // debug("Flows: " + flows);
+ // }
+ //
+ // // Standalone
+ // if (type.equals(Type.standalone)) {
+ // }
+ // // Agent
+ // else if (type.equals(Type.agent)) {
+ // }
}
public static void printUsage() {
projects / gpl / argeo-slc.git / blobdiff