You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@syncope.apache.org by il...@apache.org on 2015/02/12 18:32:01 UTC
syncope git commit: [SYNCOPE-620] cli
Repository: syncope
Updated Branches:
refs/heads/2_0_X 9cbd0d0e8 -> 689e8bbb3
[SYNCOPE-620] cli
Project: http://git-wip-us.apache.org/repos/asf/syncope/repo
Commit: http://git-wip-us.apache.org/repos/asf/syncope/commit/689e8bbb
Tree: http://git-wip-us.apache.org/repos/asf/syncope/tree/689e8bbb
Diff: http://git-wip-us.apache.org/repos/asf/syncope/diff/689e8bbb
Branch: refs/heads/2_0_X
Commit: 689e8bbb3803132309411c99bf1d18371623a810
Parents: 9cbd0d0
Author: Francesco Chicchiriccò <il...@apache.org>
Authored: Thu Feb 12 18:31:56 2015 +0100
Committer: Francesco Chicchiriccò <il...@apache.org>
Committed: Thu Feb 12 18:31:56 2015 +0100
----------------------------------------------------------------------
syncope620/client/cli/pom.xml | 178 ++++++++++++++++
.../apache/syncope/client/cli/SyncopeAdm.java | 123 +++++++++++
.../syncope/client/cli/SyncopeServices.java | 45 ++++
.../client/cli/commands/AbstractCommand.java | 32 +++
.../cli/commands/ConfigurationCommand.java | 209 +++++++++++++++++++
.../client/cli/commands/EntitlementCommand.java | 70 +++++++
.../client/cli/commands/LoggerCommand.java | 168 +++++++++++++++
.../cli/commands/NotificationCommand.java | 92 ++++++++
.../client/cli/commands/PolicyCommand.java | 105 ++++++++++
.../client/cli/commands/ReportCommand.java | 193 +++++++++++++++++
.../syncope/client/cli/util/XmlUtils.java | 47 +++++
.../cli/validators/DebugLevelValidator.java | 61 ++++++
.../client/cli/src/main/resources/log4j2.xml | 58 +++++
.../cli/src/main/resources/syncope.properties | 19 ++
syncope620/client/pom.xml | 1 +
syncope620/pom.xml | 6 +
16 files changed, 1407 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/pom.xml
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/pom.xml b/syncope620/client/cli/pom.xml
new file mode 100644
index 0000000..fa70a01
--- /dev/null
+++ b/syncope620/client/cli/pom.xml
@@ -0,0 +1,178 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+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.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.syncope</groupId>
+ <artifactId>syncope-client</artifactId>
+ <version>2.0.0-SNAPSHOT</version>
+ </parent>
+
+ <name>Apache Syncope Client CLI</name>
+ <description>Apache Syncope Client CLI</description>
+
+ <groupId>org.apache.syncope</groupId>
+ <artifactId>syncope-client-cli</artifactId>
+ <packaging>jar</packaging>
+
+ <properties>
+ <log.directory>/tmp</log.directory>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>com.beust</groupId>
+ <artifactId>jcommander</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.syncope.client</groupId>
+ <artifactId>syncope-client-lib</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.lmax</groupId>
+ <artifactId>disruptor</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-slf4j-impl</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>commons-logging</groupId>
+ <artifactId>commons-logging</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>jcl-over-slf4j</artifactId>
+ </dependency>
+
+ </dependencies>
+
+ <build>
+
+ <defaultGoal>package</defaultGoal>
+
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <version>2.3</version>
+ <executions>
+ <execution>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <createDependencyReducedPom>false</createDependencyReducedPom>
+ <transformers>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+ <manifestEntries>
+ <Main-Class>org.apache.syncope.cli.SyncopeAdm</Main-Class>
+ </manifestEntries>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.IncludeResourceTransformer">
+ <resource>messages.properties</resource>
+ <file>src/main/resources/messages.properties</file>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.IncludeResourceTransformer">
+ <resource>messages_it_IT.properties</resource>
+ <file>src/main/resources/messages_it_IT.properties</file>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
+ <resource>META-INF/spring.handlers</resource>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
+ <resource>META-INF/spring.schemas</resource>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
+ <resource>META-INF/cxf/bus-extensions.txt</resource>
+ </transformer>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.XmlAppendingTransformer">
+ <resource>META-INF/wsdl.plugin.xml</resource>
+ </transformer>
+ </transformers>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+
+ <resources>
+ <resource>
+ <directory>src/main/resources</directory>
+ <filtering>true</filtering>
+ <targetPath>${project.build.directory}/classes</targetPath>
+ <includes>
+ <include>log4j2.xml</include>
+ </includes>
+ </resource>
+ <resource>
+ <directory>src/main/resources</directory>
+ <filtering>true</filtering>
+ <targetPath>${project.build.directory}/classes</targetPath>
+ <includes>
+ <include>syncope.properties</include>
+ </includes>
+ </resource>
+ <resource>
+ <directory>..</directory>
+ <targetPath>META-INF</targetPath>
+ <includes>
+ <include>LICENSE</include>
+ <include>NOTICE</include>
+ </includes>
+ </resource>
+ </resources>
+
+ </build>
+
+ <profiles>
+ <profile>
+ <id>apache-release</id>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+
+</project>
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeAdm.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeAdm.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeAdm.java
new file mode 100644
index 0000000..2bb802f
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeAdm.java
@@ -0,0 +1,123 @@
+/*
+ * 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.syncope.client.cli;
+
+import com.beust.jcommander.JCommander;
+import com.beust.jcommander.ParameterException;
+import org.apache.syncope.client.cli.commands.ConfigurationCommand;
+import org.apache.syncope.client.cli.commands.EntitlementCommand;
+import org.apache.syncope.client.cli.commands.LoggerCommand;
+import org.apache.syncope.client.cli.commands.NotificationCommand;
+import org.apache.syncope.client.cli.commands.PolicyCommand;
+import org.apache.syncope.client.cli.commands.ReportCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SyncopeAdm {
+
+ private static final Logger LOG = LoggerFactory.getLogger(SyncopeAdm.class);
+
+ private static final String helpMessage = "Usage: Main [options]\n"
+ + " Options:\n"
+ + " logger --help \n"
+ + " config --help \n"
+ + " notification --help \n"
+ + " report --help \n"
+ + " policy --help \n"
+ + " entitlement --help \n";
+
+ private static final JCommander jcommander = new JCommander();
+
+ private static LoggerCommand loggerCommand;
+
+ private static ConfigurationCommand configurationCommand;
+
+ private static NotificationCommand notificationCommand;
+
+ private static ReportCommand reportCommand;
+
+ private static PolicyCommand policyCommand;
+
+ private static EntitlementCommand entitlementCommand;
+
+ public static void main(final String[] args) {
+ LOG.debug("Starting with args \n");
+
+ for (final String arg : args) {
+ LOG.debug("Arg: {}", arg);
+ }
+
+ instantiateCommands();
+
+ if (args.length == 0) {
+ System.out.println(helpMessage);
+ } else {
+ try {
+ jcommander.parse(args);
+ } catch (final ParameterException ioe) {
+ System.out.println(helpMessage);
+ LOG.error("Parameter exception", ioe);
+ }
+ executeCommand();
+ }
+
+ }
+
+ private static void instantiateCommands() {
+ LOG.debug("Init JCommander");
+ loggerCommand = new LoggerCommand();
+ jcommander.addCommand(loggerCommand);
+ LOG.debug("Added LoggerCommand");
+ configurationCommand = new ConfigurationCommand();
+ jcommander.addCommand(configurationCommand);
+ LOG.debug("Added ConfigurationCommand");
+ notificationCommand = new NotificationCommand();
+ jcommander.addCommand(notificationCommand);
+ LOG.debug("Added NotificationCommand");
+ reportCommand = new ReportCommand();
+ jcommander.addCommand(reportCommand);
+ LOG.debug("Added ReportCommand");
+ policyCommand = new PolicyCommand();
+ jcommander.addCommand(policyCommand);
+ LOG.debug("Added PolicyCommand");
+ entitlementCommand = new EntitlementCommand();
+ jcommander.addCommand(entitlementCommand);
+ LOG.debug("Added EntitlementCommand");
+ }
+
+ private static void executeCommand() {
+ final String command = jcommander.getParsedCommand();
+
+ LOG.debug("Called command {}", command);
+
+ if ("logger".equalsIgnoreCase(command)) {
+ loggerCommand.execute();
+ } else if ("config".equalsIgnoreCase(command)) {
+ configurationCommand.execute();
+ } else if ("notification".equalsIgnoreCase(command)) {
+ notificationCommand.execute();
+ } else if ("report".equalsIgnoreCase(command)) {
+ reportCommand.execute();
+ } else if ("policy".equalsIgnoreCase(command)) {
+ policyCommand.execute();
+ } else if ("entitlement".equalsIgnoreCase(command)) {
+ entitlementCommand.execute();
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeServices.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeServices.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeServices.java
new file mode 100644
index 0000000..26ce276
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/SyncopeServices.java
@@ -0,0 +1,45 @@
+/*
+ * 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.syncope.client.cli;
+
+import java.util.ResourceBundle;
+import org.apache.syncope.client.lib.SyncopeClient;
+import org.apache.syncope.client.lib.SyncopeClientFactoryBean;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public final class SyncopeServices {
+
+ private static final Logger LOG = LoggerFactory.getLogger(SyncopeServices.class);
+
+ private final static ResourceBundle SYNCOPE_PROPS = ResourceBundle.getBundle("syncope");
+
+ private static final SyncopeClient CLIENT = new SyncopeClientFactoryBean()
+ .setAddress(SYNCOPE_PROPS.getString("syncope.rest.services"))
+ .create(SYNCOPE_PROPS.getString("syncope.user"), SYNCOPE_PROPS.getString("syncope.password"));
+
+ public static <T> T get(final Class<T> claz) {
+ LOG.debug("Creting service for {}", claz.getName());
+ return CLIENT.getService(claz);
+ }
+
+ private SyncopeServices() {
+ // private constructor for static utility class
+ }
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/AbstractCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/AbstractCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/AbstractCommand.java
new file mode 100644
index 0000000..a6753bf
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/AbstractCommand.java
@@ -0,0 +1,32 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.Parameter;
+
+public abstract class AbstractCommand {
+
+ @Parameter(names = {"-h", "--help"})
+ protected boolean help = false;
+
+ @Parameter(names = {"-l", "--list"})
+ protected boolean list = false;
+
+ protected abstract void execute();
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ConfigurationCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ConfigurationCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ConfigurationCommand.java
new file mode 100644
index 0000000..4ca94d0
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ConfigurationCommand.java
@@ -0,0 +1,209 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.DynamicParameter;
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import java.io.IOException;
+import java.io.SequenceInputStream;
+import java.util.HashMap;
+import java.util.Map;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.transform.TransformerConfigurationException;
+import javax.xml.transform.TransformerException;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.client.cli.util.XmlUtils;
+import org.apache.syncope.common.lib.SyncopeClientException;
+import org.apache.syncope.common.lib.to.AttrTO;
+import org.apache.syncope.common.lib.to.ConfTO;
+import org.apache.syncope.common.rest.api.service.ConfigurationService;
+import org.apache.syncope.common.rest.api.service.SyncopeService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.xml.sax.SAXException;
+
+@Parameters(
+ commandNames = "config",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope configuration service")
+public class ConfigurationCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(ConfigurationCommand.class);
+
+ private static final String EXPORT_FILE_NAME = "/content.xml";
+
+ private final String helpMessage = "Usage: config [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -r, --read \n"
+ + " Syntax: -r={CONF-NAME} \n"
+ + " -u, --update \n"
+ + " Syntax: {CONF-NAME}={CONF-VALUE} \n"
+ + " -c, --create \n"
+ + " Syntax: {CONF-NAME}={CONF-VALUE} \n"
+ + " -d, --delete \n"
+ + " Syntax: -d={CONF-NAME}"
+ + " -v, --validators \n"
+ + " -mt, --mail-templates \n"
+ + " -e, --export \n"
+ + " Syntax: -e={WHERE-DIR} \n";
+
+ @Parameter(names = { "-r", "--read" })
+ public String confNameToRead;
+
+ @DynamicParameter(names = { "-u", "--update" })
+ private final Map<String, String> updateConf = new HashMap<String, String>();
+
+ @DynamicParameter(names = { "-c", "--create" })
+ private final Map<String, String> createConf = new HashMap<String, String>();
+
+ @Parameter(names = { "-d", "--delete" })
+ public String confNameToDelete;
+
+ @Parameter(names = { "-v", "--validators" })
+ public boolean validators = false;
+
+ @Parameter(names = { "-mt", "--mail-templates" })
+ public boolean mailTemplates = false;
+
+ @Parameter(names = { "-e", "--export" })
+ public String export;
+
+ @Override
+ public void execute() {
+ final SyncopeService syncopeService = SyncopeServices.get(SyncopeService.class);
+ final ConfigurationService configurationService = SyncopeServices.get(ConfigurationService.class);
+
+ LOG.debug("Logger service successfully created");
+
+ if (help) {
+ LOG.debug("- configuration help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+ LOG.debug("- configuration list command");
+ try {
+ final ConfTO confTO = configurationService.list();
+ for (final AttrTO attrTO : confTO.getPlainAttrMap().values()) {
+ System.out.println(" - Conf " + attrTO.getSchema() + " has value(s) " + attrTO.getValues()
+ + " - readonly: " + attrTO.isReadonly());
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (StringUtils.isNotBlank(confNameToRead)) {
+ LOG.debug("- configuration read {} command", confNameToRead);
+ try {
+ final AttrTO attrTO = configurationService.read(confNameToRead);
+ System.out.println(" - Conf " + attrTO.getSchema() + " has value(s) " + attrTO.getValues()
+ + " - readonly: " + attrTO.isReadonly());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (!updateConf.isEmpty()) {
+ LOG.debug("- configuration update command with params {}", updateConf);
+ try {
+ for (final Map.Entry<String, String> entrySet : updateConf.entrySet()) {
+ final AttrTO attrTO = configurationService.read(entrySet.getKey());
+ attrTO.getValues().clear();
+ attrTO.getValues().add(entrySet.getValue());
+ configurationService.set(entrySet.getKey(), attrTO);
+ System.out.println(" - Conf " + attrTO.getSchema() + " has value(s) " + attrTO.getValues()
+ + " - readonly: " + attrTO.isReadonly());
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (!createConf.isEmpty()) {
+ LOG.debug("- configuration create command with params {}", createConf);
+ try {
+ for (final Map.Entry<String, String> entrySet : createConf.entrySet()) {
+ final AttrTO attrTO = new AttrTO();
+ attrTO.setSchema(entrySet.getKey());
+ attrTO.getValues().add(entrySet.getValue());
+ configurationService.set(entrySet.getKey(), attrTO);
+ System.out.println(" - Conf " + attrTO.getSchema() + " created with value(s) " + attrTO.getValues()
+ + " - readonly: " + attrTO.isReadonly());
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (StringUtils.isNotBlank(confNameToDelete)) {
+ try {
+ LOG.debug("- configuration delete {} command", confNameToDelete);
+ configurationService.delete(confNameToDelete);
+ System.out.println(" - Conf " + confNameToDelete + " deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (validators) {
+ LOG.debug("- configuration validators command");
+ try {
+ System.out.println("Conf validator class: ");
+ for (final String validator : syncopeService.info().getValidators()) {
+ System.out.println(" *** " + validator);
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (mailTemplates) {
+ LOG.debug("- configuration mailTemplates command");
+ try {
+ System.out.println("Conf mail template for:");
+ for (final String mailTemplate : syncopeService.info().getMailTemplates()) {
+ System.out.println(" *** " + mailTemplate);
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (StringUtils.isNotBlank(export)) {
+ LOG.debug("- configuration export command, directory where xml will be export: {}", export);
+
+ try {
+ XmlUtils.createXMLFile((SequenceInputStream) configurationService.export().getEntity(), export
+ + EXPORT_FILE_NAME);
+ System.out.println(" - " + export + EXPORT_FILE_NAME + " successfully created");
+ } catch (final IOException ex) {
+ LOG.error("Error creating content.xml file in {} directory", export, ex);
+ System.out.println(" - Error creating " + export + EXPORT_FILE_NAME + " " + ex.getMessage());
+ } catch (final ParserConfigurationException ex) {
+ LOG.error("Error creating content.xml file in {} directory", export, ex);
+ System.out.println(" - Error creating " + export + EXPORT_FILE_NAME + " " + ex.getMessage());
+ } catch (final SAXException ex) {
+ LOG.error("Error creating content.xml file in {} directory", export, ex);
+ System.out.println(" - Error creating " + export + EXPORT_FILE_NAME + " " + ex.getMessage());
+ } catch (final TransformerConfigurationException ex) {
+ LOG.error("Error creating content.xml file in {} directory", export, ex);
+ System.out.println(" - Error creating " + export + EXPORT_FILE_NAME + " " + ex.getMessage());
+ } catch (final TransformerException ex) {
+ LOG.error("Error creating content.xml file in {} directory", export, ex);
+ System.out.println(" - Error creating " + export + EXPORT_FILE_NAME + " " + ex.getMessage());
+ } catch (final SyncopeClientException ex) {
+ LOG.error("Error calling configuration service", ex);
+ System.out.println(" - Error calling configuration service " + ex.getMessage());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/EntitlementCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/EntitlementCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/EntitlementCommand.java
new file mode 100644
index 0000000..e0058ab
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/EntitlementCommand.java
@@ -0,0 +1,70 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.common.lib.wrap.EntitlementTO;
+import org.apache.syncope.common.rest.api.service.EntitlementService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@Parameters(
+ commandNames = "entitlement",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope entitlement service")
+public class EntitlementCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(EntitlementCommand.class);
+
+ private final String helpMessage = "Usage: entitlement [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -lo, --list-own \n";
+
+ @Parameter(names = { "-lo", "--list-own" })
+ public boolean listOwn = false;
+
+ @Override
+ public void execute() {
+ final EntitlementService entitlementService = SyncopeServices.get(EntitlementService.class);
+ LOG.debug("Entitlement service successfully created");
+
+ if (help) {
+ LOG.debug("- entitlement help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+ System.out.println("All entitlement:");
+ for (final EntitlementTO entitlementTO : entitlementService.getAllEntitlements()) {
+ System.out.println(" *** " + entitlementTO.getElement());
+ }
+ } else if (listOwn) {
+ System.out.println("All own entitlement:");
+ for (final EntitlementTO entitlementTO : entitlementService.getOwnEntitlements()) {
+ System.out.println(" *** " + entitlementTO.getElement());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/LoggerCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/LoggerCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/LoggerCommand.java
new file mode 100644
index 0000000..e5115d9
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/LoggerCommand.java
@@ -0,0 +1,168 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.DynamicParameter;
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import java.util.HashMap;
+import java.util.Map;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.common.lib.SyncopeClientException;
+import org.apache.syncope.common.lib.to.LoggerTO;
+import org.apache.syncope.common.lib.types.LoggerLevel;
+import org.apache.syncope.common.lib.types.LoggerType;
+import org.apache.syncope.common.rest.api.service.LoggerService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@Parameters(
+ commandNames = "logger",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope logger service")
+public class LoggerCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(LoggerCommand.class);
+
+ private final String helpMessage = "Usage: logger [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -r, --read \n"
+ + " Syntax: -r={LOG-NAME} \n"
+ + " -u, --update \n"
+ + " Syntax: {LOG-NAME}={LOG-LEVEL} \n"
+ + " -ua, --update-all \n"
+ + " Syntax: -ua={LOG-LEVEL} \n"
+ + " -c, --create \n"
+ + " Syntax: {LOG-NAME}={LOG-LEVEL} \n"
+ + " -d, --delete \n"
+ + " Syntax: -d={LOG-NAME}";
+
+ @Parameter(names = { "-r", "--read" })
+ public String logNameToRead;
+
+ @DynamicParameter(names = { "-u", "--update" })
+ private final Map<String, String> updateLogs = new HashMap<String, String>();
+
+ @Parameter(names = { "-ua", "--update-all" })
+ public String logLevel;
+
+ @DynamicParameter(names = { "-c", "--create" })
+ private final Map<String, String> createLogs = new HashMap<String, String>();
+
+ @Parameter(names = { "-d", "--delete" })
+ public String logNameToDelete;
+
+ @Override
+ public void execute() {
+ final LoggerService loggerService = SyncopeServices.get(LoggerService.class);
+
+ LOG.debug("Logger service successfully created");
+
+ if (help) {
+ LOG.debug("- logger help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+ LOG.debug("- logger list command");
+ try {
+ for (final LoggerTO loggerTO : loggerService.list(LoggerType.LOG)) {
+ System.out.println(" - " + loggerTO.getKey() + " -> " + loggerTO.getLevel());
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (StringUtils.isNotBlank(logNameToRead)) {
+ LOG.debug("- logger read {} command", logNameToRead);
+ try {
+ final LoggerTO loggerTO = loggerService.read(LoggerType.LOG, logNameToRead);
+ System.out.println(" - Logger " + loggerTO.getKey() + " with level -> " + loggerTO.getLevel());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (!updateLogs.isEmpty()) {
+ LOG.debug("- logger update command with params {}", updateLogs);
+
+ for (final Map.Entry<String, String> log : updateLogs.entrySet()) {
+ final LoggerTO loggerTO = loggerService.read(LoggerType.LOG, log.getKey());
+ try {
+ loggerTO.setLevel(LoggerLevel.valueOf(log.getValue()));
+ loggerService.update(LoggerType.LOG, loggerTO.getKey(), loggerTO);
+ System.out.println(" - Logger " + loggerTO.getKey() + " new level -> " + loggerTO.getLevel());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ } catch (final IllegalArgumentException ex) {
+ System.out.println(" - Error: " + log.getValue() + " isn't a valid logger level, try with:");
+ for (final LoggerLevel level : LoggerLevel.values()) {
+ System.out.println(" *** " + level.name());
+ }
+ }
+ }
+ } else if (StringUtils.isNotBlank(logLevel)) {
+ LOG.debug("- logger update all command with level {}", logLevel);
+ for (final LoggerTO loggerTO : loggerService.list(LoggerType.LOG)) {
+ try {
+ loggerTO.setLevel(LoggerLevel.valueOf(logLevel));
+ loggerService.update(LoggerType.LOG, loggerTO.getKey(), loggerTO);
+ System.out.println(" - Logger " + loggerTO.getKey() + " new level -> " + loggerTO.getLevel());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ } catch (final IllegalArgumentException ex) {
+ System.out.println(" - Error: " + loggerTO.getLevel() + " isn't a valid logger level, try with:");
+ for (final LoggerLevel level : LoggerLevel.values()) {
+ System.out.println(" *** " + level.name());
+ }
+ }
+ }
+ } else if (!createLogs.isEmpty()) {
+ LOG.debug("- logger create command with params {}", createLogs);
+
+ for (final Map.Entry<String, String> entrySet : createLogs.entrySet()) {
+ final LoggerTO loggerTO = new LoggerTO();
+ try {
+ loggerTO.setKey(entrySet.getKey());
+ loggerTO.setLevel(LoggerLevel.valueOf(entrySet.getValue()));
+ loggerService.update(LoggerType.LOG, loggerTO.getKey(), loggerTO);
+ System.out.println(" - Logger " + loggerTO.getKey() + " created with level -> " + loggerTO.
+ getLevel());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ } catch (final IllegalArgumentException ex) {
+ System.out.println(" - Error: " + loggerTO.getLevel() + " isn't a valid logger level, try with:");
+ for (final LoggerLevel level : LoggerLevel.values()) {
+ System.out.println(" *** " + level.name());
+ }
+ }
+ }
+ } else if (StringUtils.isNotBlank(logNameToDelete)) {
+ try {
+ LOG.debug("- logger delete {} command", logNameToDelete);
+ loggerService.delete(LoggerType.LOG, logNameToDelete);
+ System.out.println(" - Logger " + logNameToDelete + " deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/NotificationCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/NotificationCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/NotificationCommand.java
new file mode 100644
index 0000000..4e18996
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/NotificationCommand.java
@@ -0,0 +1,92 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.common.lib.SyncopeClientException;
+import org.apache.syncope.common.lib.to.NotificationTO;
+import org.apache.syncope.common.rest.api.service.NotificationService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@Parameters(
+ commandNames = "notification",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope notification service")
+public class NotificationCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(NotificationCommand.class);
+
+ private final String helpMessage = "Usage: notification [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -r, --read \n"
+ + " Syntax: -r={NOTIFICATION-ID} \n"
+ + " -d, --delete \n"
+ + " Syntax: -d={NOTIFICATION-ID}";
+
+ @Parameter(names = { "-r", "--read" })
+ public Long notificationIdToRead = -1L;
+
+ @Parameter(names = { "-d", "--delete" })
+ public Long notificationIdToDelete = -1L;
+
+ @Override
+ public void execute() {
+ final NotificationService notificationService = SyncopeServices.get(NotificationService.class);
+
+ LOG.debug("Notification service successfully created");
+
+ if (help) {
+ LOG.debug("- notification help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+ LOG.debug("- notification list command");
+ try {
+ for (final NotificationTO notificationTO : notificationService.list()) {
+ System.out.println(notificationTO);
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (notificationIdToRead > -1L) {
+ LOG.debug("- notification read {} command", notificationIdToRead);
+ try {
+ System.out.println(notificationService.read(notificationIdToRead));
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (notificationIdToDelete > -1L) {
+ try {
+ LOG.debug("- notification delete {} command", notificationIdToDelete);
+ notificationService.delete(notificationIdToDelete);
+ System.out.println(" - Notification " + notificationIdToDelete + " deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/PolicyCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/PolicyCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/PolicyCommand.java
new file mode 100644
index 0000000..c2bcb5f
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/PolicyCommand.java
@@ -0,0 +1,105 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.common.lib.SyncopeClientException;
+import org.apache.syncope.common.lib.to.AbstractPolicyTO;
+import org.apache.syncope.common.lib.types.PolicyType;
+import org.apache.syncope.common.rest.api.service.PolicyService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@Parameters(
+ commandNames = "policy",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope policy service")
+public class PolicyCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(PolicyCommand.class);
+
+ private final String helpMessage = "Usage: policy [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -ll, --list-policy \n"
+ + " Syntax: -ll={POLICY-TYPE} \n"
+ + " -r, --read \n"
+ + " Syntax: -r={POLICY-ID} \n"
+ + " -d, --delete \n"
+ + " Syntax: -d={POLICY-ID}";
+
+ @Parameter(names = { "-ll", "--list-policy" })
+ public String policyType;
+
+ @Parameter(names = { "-r", "--read" })
+ public Long policyIdToRead = -1L;
+
+ @Parameter(names = { "-d", "--delete" })
+ public Long policyIdToDelete = -1L;
+
+ @Override
+ public void execute() {
+ final PolicyService policyService = SyncopeServices.get(PolicyService.class);
+ LOG.debug("Policy service successfully created");
+
+ if (help) {
+ LOG.debug("- policy help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+
+ } else if (StringUtils.isNotBlank(policyType)) {
+ LOG.debug("- policy list command for type {}", policyType);
+ try {
+ for (final AbstractPolicyTO policyTO : policyService.list(PolicyType.valueOf(policyType))) {
+ System.out.println(policyTO);
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ } catch (final IllegalArgumentException ex) {
+ System.out.println(" - Error: " + policyType + " isn't a valid policy type, try with:");
+ for (final PolicyType type : PolicyType.values()) {
+ System.out.println(" *** " + type.name() + ": " + type.getDescription());
+ }
+ }
+ } else if (policyIdToRead > -1L) {
+ LOG.debug("- policy read {} command", policyIdToRead);
+ try {
+ System.out.println(policyService.read(policyIdToRead));
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (policyIdToDelete > -1L) {
+ try {
+ LOG.debug("- policy delete {} command", policyIdToDelete);
+ policyService.delete(policyIdToDelete);
+ System.out.println(" - Report " + policyIdToDelete + " deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ReportCommand.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ReportCommand.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ReportCommand.java
new file mode 100644
index 0000000..17f0e14
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/commands/ReportCommand.java
@@ -0,0 +1,193 @@
+/*
+ * 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.syncope.client.cli.commands;
+
+import com.beust.jcommander.Parameter;
+import com.beust.jcommander.Parameters;
+import java.io.IOException;
+import java.io.SequenceInputStream;
+import java.util.List;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.transform.TransformerConfigurationException;
+import javax.xml.transform.TransformerException;
+import org.apache.syncope.client.cli.SyncopeServices;
+import org.apache.syncope.client.cli.util.XmlUtils;
+import org.apache.syncope.common.lib.SyncopeClientException;
+import org.apache.syncope.common.lib.to.ReportExecTO;
+import org.apache.syncope.common.lib.to.ReportTO;
+import org.apache.syncope.common.lib.types.ReportExecExportFormat;
+import org.apache.syncope.common.lib.wrap.ReportletConfClass;
+import org.apache.syncope.common.rest.api.service.ReportService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.xml.sax.SAXException;
+
+@Parameters(
+ commandNames = "report",
+ optionPrefixes = "-",
+ separators = "=",
+ commandDescription = "Apache Syncope report service")
+public class ReportCommand extends AbstractCommand {
+
+ private static final Logger LOG = LoggerFactory.getLogger(ReportCommand.class);
+
+ private final String helpMessage = "Usage: report [options]\n"
+ + " Options:\n"
+ + " -h, --help \n"
+ + " -l, --list \n"
+ + " -r, --read \n"
+ + " Syntax: -r={POLICY-ID} \n"
+ + " -d, --delete \n"
+ + " Syntax: -d={POLICY-ID} \n"
+ + " -e, --execute \n"
+ + " Syntax: -e={POLICY-ID} \n"
+ + " -re, --read-executecution \n"
+ + " Syntax: -re={EXECUTION-ID} \n"
+ + " -de, --delete-executecution \n"
+ + " Syntax: -de={EXECUTION-ID} \n"
+ + " -eer, --export-executecution-result \n"
+ + " Syntax: -eer={EXECUTION-ID} \n"
+ + " -rc, --reportlet-class";
+
+ @Parameter(names = { "-r", "--read" })
+ public Long reportIdToRead = -1L;
+
+ @Parameter(names = { "-d", "--delete" })
+ public Long reportIdToDelete = -1L;
+
+ @Parameter(names = { "-e", "--execute" })
+ public Long reportIdToExecute = -1L;
+
+ @Parameter(names = { "-re", "--read-execution" })
+ public Long executionIdToRead = -1L;
+
+ @Parameter(names = { "-de", "--delete-execution" })
+ public Long executionIdToDelete = -1L;
+
+ @Parameter(names = { "-eer", "--export-execution-result" })
+ public Long exportId = -1L;
+
+ @Parameter(names = { "-rc", "--reportlet-class" })
+ public boolean reportletClass = false;
+
+ @Override
+ public void execute() {
+ final ReportService reportService = SyncopeServices.get(ReportService.class);
+ LOG.debug("Report service successfully created");
+
+ if (help) {
+ LOG.debug("- report help command");
+ System.out.println(helpMessage);
+ } else if (list) {
+ LOG.debug("- report list command");
+ try {
+ for (final ReportTO reportTO : reportService.list().getResult()) {
+ System.out.println(reportTO);
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (reportIdToRead > -1L) {
+ LOG.debug("- report read {} command", reportIdToRead);
+ try {
+ System.out.println(reportService.read(reportIdToRead));
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (reportIdToDelete > -1L) {
+ try {
+ LOG.debug("- report delete {} command", reportIdToDelete);
+ reportService.delete(reportIdToDelete);
+ System.out.println(" - Report " + reportIdToDelete + " deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (reportIdToExecute > -1L) {
+ try {
+ LOG.debug("- report execute {} command", reportIdToExecute);
+ reportService.execute(reportIdToExecute);
+ final List<ReportExecTO> executionList = reportService.read(reportIdToExecute).getExecutions();
+ final ReportExecTO lastExecution = executionList.get(executionList.size() - 1);
+ System.out.println(" - Report execution id: " + lastExecution.getKey());
+ System.out.println(" - Report execution status: " + lastExecution.getStatus());
+ System.out.println(" - Report execution start date: " + lastExecution.getStartDate());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (executionIdToRead > -1L) {
+ try {
+ LOG.debug("- report execution read {} command", executionIdToRead);
+ ReportExecTO reportExecTO = reportService.readExecution(executionIdToRead);
+ System.out.println(" - Report execution id: " + reportExecTO.getKey());
+ System.out.println(" - Report execution status: " + reportExecTO.getStatus());
+ System.out.println(" - Report execution start date: " + reportExecTO.getStartDate());
+ System.out.println(" - Report execution end date: " + reportExecTO.getEndDate());
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (executionIdToDelete > -1L) {
+ try {
+ LOG.debug("- report execution delete {} command", executionIdToDelete);
+ reportService.deleteExecution(executionIdToDelete);
+ System.out.println(" - Report execution " + executionIdToDelete + "successfyllt deleted!");
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else if (exportId > -1L) {
+ LOG.debug("- report export command for report: {}", exportId);
+
+ try {
+ XmlUtils.createXMLFile((SequenceInputStream) reportService.exportExecutionResult(exportId,
+ ReportExecExportFormat.XML).getEntity(), "export_" + exportId + ".xml");
+ System.out.println(" - " + "export_" + exportId + " successfully created");
+ } catch (final IOException ex) {
+ LOG.error("Error creating xml file", ex);
+ System.out.println(" - Error creating " + "export_" + exportId + " " + ex.getMessage());
+ } catch (final ParserConfigurationException ex) {
+ LOG.error("Error creating xml file", ex);
+ System.out.println(" - Error creating " + "export_" + exportId + " " + ex.getMessage());
+ } catch (final SAXException ex) {
+ LOG.error("Error creating xml file", ex);
+ System.out.println(" - Error creating " + "export_" + exportId + " " + ex.getMessage());
+ } catch (final TransformerConfigurationException ex) {
+ LOG.error("Error creating xml file", ex);
+ System.out.println(" - Error creating " + "export_" + exportId + " " + ex.getMessage());
+ } catch (final TransformerException ex) {
+ LOG.error("Error creating xml file", ex);
+ System.out.println(" - Error creating export_" + exportId + " " + ex.getMessage());
+ } catch (final SyncopeClientException ex) {
+ LOG.error("Error calling configuration service", ex);
+ System.out.println(" - Error calling configuration service " + ex.getMessage());
+ }
+ } else if (reportletClass) {
+ try {
+ LOG.debug("- reportlet configuration class list command");
+ System.out.println("Reportlet conf classes");
+ for (final ReportletConfClass reportletConfClass : reportService.getReportletConfClasses()) {
+ System.out.println(" *** " + reportletConfClass.getElement());
+ }
+ } catch (final SyncopeClientException ex) {
+ System.out.println(" - Error: " + ex.getMessage());
+ }
+ } else {
+ System.out.println(helpMessage);
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/util/XmlUtils.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/util/XmlUtils.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/util/XmlUtils.java
new file mode 100644
index 0000000..fa228d5
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/util/XmlUtils.java
@@ -0,0 +1,47 @@
+/*
+ * 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.syncope.client.cli.util;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.SequenceInputStream;
+import java.io.StringReader;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.transform.TransformerConfigurationException;
+import javax.xml.transform.TransformerException;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.dom.DOMSource;
+import javax.xml.transform.stream.StreamResult;
+import org.apache.cxf.helpers.IOUtils;
+import org.xml.sax.InputSource;
+import org.xml.sax.SAXException;
+
+public class XmlUtils {
+
+ public static void createXMLFile(final SequenceInputStream sis, final String filePath)
+ throws TransformerConfigurationException, TransformerException, SAXException, IOException,
+ ParserConfigurationException {
+
+ TransformerFactory.newInstance().newTransformer()
+ .transform(new DOMSource(DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(
+ new InputSource(new StringReader(IOUtils.toString(sis))))),
+ new StreamResult(new File(filePath)));
+ }
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/validators/DebugLevelValidator.java
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/validators/DebugLevelValidator.java b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/validators/DebugLevelValidator.java
new file mode 100644
index 0000000..58c12f3
--- /dev/null
+++ b/syncope620/client/cli/src/main/java/org/apache/syncope/client/cli/validators/DebugLevelValidator.java
@@ -0,0 +1,61 @@
+/*
+ * 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.syncope.client.cli.validators;
+
+import com.beust.jcommander.IParameterValidator;
+import com.beust.jcommander.ParameterException;
+
+public class DebugLevelValidator implements IParameterValidator {
+
+ @Override
+ public void validate(final String name, final String value) throws ParameterException {
+ if (!Levels.contains(value)) {
+ final StringBuilder exceptionMessage = new StringBuilder();
+ exceptionMessage.append("Parameter ")
+ .append(name)
+ .append(" should be :\n");
+ for (final Levels l : Levels.values()) {
+ exceptionMessage.append(l).append("\n");
+ }
+ System.out.println(">>>> " + exceptionMessage.toString());
+ }
+ }
+
+ private enum Levels {
+
+ OFF,
+ FATAL,
+ ERROR,
+ WARN,
+ INFO,
+ DEBUG,
+ TRACE,
+ ALL;
+
+ public static boolean contains(final String name) {
+ for (final Levels c : Levels.values()) {
+ if (c.name().equals(name)) {
+ return true;
+ }
+ }
+ return false;
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/resources/log4j2.xml
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/resources/log4j2.xml b/syncope620/client/cli/src/main/resources/log4j2.xml
new file mode 100644
index 0000000..0688f6b
--- /dev/null
+++ b/syncope620/client/cli/src/main/resources/log4j2.xml
@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+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.
+-->
+<configuration status="WARN">
+
+ <appenders>
+
+ <RollingRandomAccessFile name="main" fileName="${log.directory}/cli.log"
+ filePattern="${log.directory}/cli-%d{yyyy-MM-dd}.log.gz"
+ immediateFlush="false" append="true">
+ <PatternLayout>
+ <pattern>%d{HH:mm:ss.SSS} %-5level %logger - %msg%n</pattern>
+ </PatternLayout>
+ <Policies>
+ <TimeBasedTriggeringPolicy/>
+ <SizeBasedTriggeringPolicy size="250 MB"/>
+ </Policies>
+ </RollingRandomAccessFile>
+
+ </appenders>
+
+ <loggers>
+
+ <asyncLogger name="com.beust" additivity="false" level="DEBUG">
+ <appender-ref ref="main"/>
+ </asyncLogger>
+
+ <asyncLogger name="org.apache.syncope.cli" additivity="false" level="DEBUG">
+ <appender-ref ref="main"/>
+ </asyncLogger>
+
+ <asyncLogger name="org.apache.syncope.client" additivity="false" level="OFF">
+ <appender-ref ref="main"/>
+ </asyncLogger>
+
+ <root level="DEBUG">
+ <appender-ref ref="main"/>
+ </root>
+
+ </loggers>
+
+</configuration>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/cli/src/main/resources/syncope.properties
----------------------------------------------------------------------
diff --git a/syncope620/client/cli/src/main/resources/syncope.properties b/syncope620/client/cli/src/main/resources/syncope.properties
new file mode 100644
index 0000000..9f84a72
--- /dev/null
+++ b/syncope620/client/cli/src/main/resources/syncope.properties
@@ -0,0 +1,19 @@
+# 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.
+syncope.rest.services=http://localhost:9080/syncope/rest/
+syncope.user=admin
+syncope.password=password
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/client/pom.xml
----------------------------------------------------------------------
diff --git a/syncope620/client/pom.xml b/syncope620/client/pom.xml
index 0143d08..78bfcbd 100644
--- a/syncope620/client/pom.xml
+++ b/syncope620/client/pom.xml
@@ -36,6 +36,7 @@ under the License.
<modules>
<module>lib</module>
<module>console</module>
+ <module>cli</module>
</modules>
</project>
http://git-wip-us.apache.org/repos/asf/syncope/blob/689e8bbb/syncope620/pom.xml
----------------------------------------------------------------------
diff --git a/syncope620/pom.xml b/syncope620/pom.xml
index 9ca00b9..37c783b 100644
--- a/syncope620/pom.xml
+++ b/syncope620/pom.xml
@@ -907,6 +907,12 @@ under the License.
<version>${codemirror.version}</version>
</dependency>
+ <dependency>
+ <groupId>com.beust</groupId>
+ <artifactId>jcommander</artifactId>
+ <version>1.47</version>
+ </dependency>
+
<!-- TEST -->
<dependency>
<groupId>net.tirasa.connid.bundles.soap</groupId>