Subversion Repositories XServices

/*

 *   Copyright 2013 Brian Rosenberger (Brutex Network)

 *

 *   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 net.brutex.emitter;

import net.brutex.emitter.util.EmitterUtil;

import net.brutex.emitter.util.PasswordEncrypter;

import net.brutex.sbm.sbmappservices72.AEWebservicesFaultFault;

import net.brutex.sbm.sbmappservices72.Sbmappservices72PortType;

import net.brutex.sbm.sbmappservices72.api.*;

import net.brutex.svn.SVNAdminCommand;

import net.brutex.svn.SVNAdminExecutor;

import net.brutex.svn.SVNCommitInfo;

import net.brutex.svn.SVNLookExecutor;

import org.apache.axiom.om.*;

import org.apache.axiom.om.xpath.AXIOMXPath;

import org.apache.commons.cli.Options;

import org.apache.commons.cli.*;

import org.apache.commons.configuration.Configuration;

import org.apache.commons.configuration.ConfigurationException;

import org.apache.commons.configuration.PropertiesConfiguration;

import org.apache.cxf.endpoint.Client;

import org.apache.cxf.frontend.ClientProxy;

import org.apache.cxf.interceptor.LoggingInInterceptor;

import org.apache.cxf.interceptor.LoggingOutInterceptor;

import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;

import org.apache.http.client.ClientProtocolException;

import org.apache.log4j.Logger;

import org.jaxen.JaxenException;

import javax.xml.stream.XMLStreamException;

import java.io.*;

import java.math.BigInteger;

import java.net.MalformedURLException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

/**

 * The Class ALFEmitter.

 *

 * @author Brian Rosenberger, bru(at)brutex.de

 * @since 0.1

 */

public class ALFEmitter {

	public static final String VERSION = "0.2";

	private static Logger logger = Logger.getRootLogger();

	//

	// Keys to read from the configuration file.

	//

	private static final String OPTION_SVNLOOK = "svnlook";

	private static final String OPTION_SVNADMIN = "svnadmin";

	private static final String OPTION_LOCALE = "env.LANG";

	private static final String OPTION_ENCODING = "env.encoding";

	private static final String OPTION_ISSUEPATTERN = "issuepattern";

	private static final String OPTION_EVENTTEMPLATE = "eventtemplate";

	private static final String OPTION_EVENTNAMESPACE = "eventnamespace";

	private static final String OPTION_EVENTMANAGER_URL = "eventmanager";

	private static final String OPTION_EVENTMANAGER_USER = "eventmanager.user";

	private static final String OPTION_EVENTMANAGER_PASSWORD = "eventmanager.password";

	private static final String OPTION_EVENTMANAGER_ENCRYPTED = "eventmanager.encrypted";

	private static final String OPTION_SBM_ENDPOINT = "sbmappservices72";

	private static final String OPTION_SBM_USER = "sbmuser";

	private static final String OPTION_SBM_PASSWORD = "sbmpassword";

	private static final String OPTION_SBM_ENCRYPTED = "sbmencrypted";

	private static final String OPTION_SBM_TABLE = "querytable";

	private static final String OPTION_SBM_QUERY = "query";

	private static final String OPTION_MARKER_LOGMESSAGE = "marker.logmessage";

	private static final String OPTION_MARKER_AUTHOR = "marker.author";

	private static final String OPTION_MARKER_REVISION = "marker.revision";

	private static final String OPTION_MARKER_ADDEDFILES = "marker.addedfiles";

	private static final String OPTION_MARKER_DELETEDFILES = "marker.deletedfiles";

	private static final String OPTION_MARKER_CHANGEDFILES = "marker.changedfiles";

	private static final String OPTION_MARKER_ISSUES = "marker.issues";

	private static final String OPTION_MARKER_INTERNALISSUES = "marker.internalissues";

	private static final String OPTION_REMOVE_ISSUES_FROM_COMMIT = "removeissuesfromcommit";

	private static final String OPTION_IS_SOAPENABLED = "isSoapEnabled";

	private static final String OPTION_IS_DROPENABLED = "isDropResponse";

	private static final String OPTION_IS_FORCEFAILENABLED = "forcefail";

	private static final String OPTION_IS_VERIFICATIONENABLED = "isWithVerification";

	private static final String OPTION_IS_UPDATECOMMITMESSAGE = "isWithMessageUpdate";

	private static final String OPTION_IS_WSTRACE = "trace";

	private static final String OPTION_IS_XMLPROCESSINGENABLED = "isXmlProcessingEnabled";

	//

	// Command line parameters

	//

	private static final String PARAM_REPOS = "repos";

	private static final String PARAM_TXN = "txn";

	private static final String PARAM_REV = "rev";

	private static final String PARAM_CONFIG = "conf";

	//

	// Member variables

	//

	private final String repos;

	private final String txn;

	private final String rev;

	private SVNCommitInfo info;

	private OMElement template = null;

	private Configuration config;

	private String nss = null;

	private final long startTime;

	//Member for SBM endpoint configuration

	private final String endpoint;

	private final String sbm_user;

	private String sbm_pass;

	private final String querytable;

	private final String query;

	private final List<String> internalissues = new ArrayList<String>();

	//SBM IssueTypePrefix+IssueId, Title

	private final Map<String, String> issues_titles = new HashMap<String, String>();

	/**

	 * The main method.

	 *

	 * @param args the arguments

	 */

	public static void main(String[] args) {

		long startTime = System.currentTimeMillis();

		CommandLineParser parser = new BasicParser();

		CommandLine cmd = null;

		try {

			cmd = parser.parse( getOptions(), args);

		} catch (ParseException e1) {

			logger.error(e1.getMessage());

			printHelp();

			System.exit(1);

		}

		try {

			ALFEmitter emitter = new ALFEmitter(cmd, startTime);

		} catch (ConfigurationException e) {

			System.exit(1);

		} catch (MalformedURLException e) {

			logger.error("Could not find/ load wsdl url.", e);

			System.exit(1);

		}

		long endTime = System.currentTimeMillis();

		logger.debug("Total execution took '"+(endTime-startTime)+"' milliseconds.");

		System.exit(0);

	}

	/**

	 * Read a configuration parameter from the config file

	 * Creates log messages according to parameters.

	 *

	 * @param key				property name

	 * @param defaultValue		default value or null

	 * @param isRequired		whether or not this is a required option

	 * @param logmessage		optional log message (or null)

	 * @return					property value

	 * @throws ConfigurationException

	 */

	private Object readConfProperty(String key, Object defaultValue, boolean isRequired, PropertyType type, String logmessage) throws ConfigurationException {

		Object value = null;

		switch (type) {

		case BOOLEAN:

			value = config.getBoolean(key, (Boolean) defaultValue);

			break;

		case STRINGARRAY:

			value = config.getStringArray(key);

			defaultValue = null;

			break;

		default:

			value = config.getString(key, (String) defaultValue);

			break;

		}

		if(isRequired && value == null) {

			//required property

			if(defaultValue == null) {

				//No value, no default

				String s = String.format("Could not load a value for the key '%s' from the configuration file. This is a required property without a default.", key);

				logger.error(s);

				throw new ConfigurationException(s);

			}

			if(defaultValue!=null) {

				//No value, but default

				logger.debug(String.format("Using property value '%s' for key '%s'. This is the default value. The property is required.", value, key));

			}

		}

		if( (! isRequired) && value == null) {

			//not required

			if(value == null && defaultValue == null) {

				//No value, no default

				String s = String.format("Could not load a value for the key '%s' from the configuration file. This property has no default, but it is optional anyway.", key);

				logger.warn(s);

			}

			if(value == null && defaultValue!=null) {

				//No value, but default

				logger.debug(String.format("Using property value '%s' for key '%s'. This is the default value. The property is optional.", value, key));

			}

		}

		if(logmessage==null) logmessage="";

		if(key.contains("password") && value!=null ) {

			logger.debug(String.format("Using property value '%s' for key '%s'. %s", "******", key, logmessage));

		} else {

			if(value!=null) logger.debug(String.format("Using property value '%s' for key '%s'. %s", value, key, logmessage));

		}

		return value;

	}

	private String readConfPropertyAsString(String key, String defaultValue, boolean isRequired, String logmessage) throws ConfigurationException {

		return (String) readConfProperty(key, defaultValue, isRequired, PropertyType.STRING, logmessage);

	}

	private String[] readConfPropertyAsStringArray(String key, boolean isRequired, String logmessage) throws ConfigurationException {

		return (String[]) readConfProperty(key, null, isRequired, PropertyType.STRINGARRAY, logmessage);

	}

	private boolean readConfPropertyAsBoolean(String key, boolean defaultValue, boolean isRequired, String logmessage) throws ConfigurationException {

		Boolean b =  (Boolean) readConfProperty(key, defaultValue, isRequired, PropertyType.BOOLEAN, logmessage);

		return b.booleanValue();

	}

	private ALFEmitter(CommandLine cmd, long startTime) throws ConfigurationException, MalformedURLException {

		this.startTime = startTime;

		repos = cmd.getOptionValue(PARAM_REPOS);

		txn = cmd.getOptionValue(PARAM_TXN);

		rev = cmd.getOptionValue(PARAM_REV);

		String config_file = cmd.getOptionValue(PARAM_CONFIG, "emitter.properties");

		EmitterUtil.verifyFile(config_file, false, false);

		logger.debug(String.format("Using REPOS='%s' and TXN='%s'.", repos, txn));

		config = null;

		try {

			config = new PropertiesConfiguration(config_file);

		} catch (ConfigurationException e) {

			logger.error("Could not find/ load '"+config_file+"' file.", e);

			this.exit(1);

		}

		/*

		 * Load Properties from Configuration file

		 */

		//it might be interesting to look into SVNKit

		//for a pure Java implementation in future

			final String svnlook			=	readConfPropertyAsString(OPTION_SVNLOOK, null, true, null);

			EmitterUtil.verifyFile(svnlook, false, true);

			final String locale				=	readConfPropertyAsString(OPTION_LOCALE, "de_DE.UTF-8", true, null);

			final String encoding			=	readConfPropertyAsString(OPTION_ENCODING, "UTF-8", true, "Note that this should match your selected '"+OPTION_LOCALE+"'.");

			// Issue Id RegEx to parse commit message

			final String[] issuepatterns = readConfPropertyAsStringArray(OPTION_ISSUEPATTERN, false, null);

			StringBuilder sb = new StringBuilder(); for(String s : issuepatterns) sb.append(s);

			logger.debug(String.format("Using issue id patterns: '%s'.", sb.toString()));

			// Flags to indicate what should be done

			final boolean isSoapEnabled 	= readConfPropertyAsBoolean(OPTION_IS_SOAPENABLED, true, true, null);

			final boolean isXmlProcessingEnabled 	= readConfPropertyAsBoolean(OPTION_IS_XMLPROCESSINGENABLED, true, true, null);

			final boolean isWithVerification= readConfPropertyAsBoolean(OPTION_IS_VERIFICATIONENABLED, false, true, null);

			final boolean isRemoveIssues	= readConfPropertyAsBoolean(OPTION_REMOVE_ISSUES_FROM_COMMIT, false, true, "");

			final boolean isWithCommitUpdate= readConfPropertyAsBoolean(OPTION_IS_UPDATECOMMITMESSAGE, false, true, "");

			/*

			 * SVNLook phase

			 * Use svnlook to obtain information from SVN

			 */

			SVNLookExecutor exec = new SVNLookExecutor(new File(svnlook), repos);

			if(cmd.hasOption(PARAM_TXN)) exec.setTXN(txn);

			if(cmd.hasOption(PARAM_REV)) exec.setRev(rev);

			exec.setEncoding(encoding);

			exec.setLocale(locale);

			info = exec.getCommitInfo();

			info.parseIssues(issuepatterns, isRemoveIssues);

			logger.debug("SVNCommitInfo author: "+ info.getAuthor());

			SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ");

			String datestring = f.format(info.getDate());

			datestring= datestring.substring(0, 26) + ":" + datestring.substring(26); //hack into ISO 8601 format

			logger.debug("SVNCommitInfo date: "+ datestring);

			logger.debug("SVNCommitInfo log message: "+ info.getLogmessage());

			logger.debug("SVNCommitInfo file list: "+ info.getChangeFileListAsString());

			/*

			 * Verification phase

			 */

			boolean isTrace = false;

			if(isWithVerification) {

				boolean isEncrypted;

				isEncrypted					=	readConfPropertyAsBoolean(OPTION_SBM_ENCRYPTED, false, false, null);

				sbm_user 					= 	readConfPropertyAsString(OPTION_SBM_USER, null, true, null);

				sbm_pass 					= 	readConfPropertyAsString(OPTION_SBM_PASSWORD, null, false, null);

				if(isEncrypted) sbm_pass = PasswordEncrypter.decrypt(sbm_pass);

				endpoint					= 	readConfPropertyAsString(OPTION_SBM_ENDPOINT, "http://localhost/gsoap/gsoap_ssl.dll?sbmappservices72", true, null);

				querytable					= 	readConfPropertyAsString(OPTION_SBM_TABLE, null, true, null);

				query						= 	readConfPropertyAsString(OPTION_SBM_QUERY, null, false, null);

				isTrace						=	readConfPropertyAsBoolean(OPTION_IS_WSTRACE, false, true, null);

				logger.debug(String.format("Starting verification for '%s' issues in the list.", info.getIssues().size()));

				boolean isOK = verify(info.getIssues(), isTrace);

				if(! isOK ) {

					logger.error("Verification of issue failed. No matching issue was found.");

					this.exit(1);

				}

			} else {

				sbm_user = null; sbm_pass=null; endpoint=null; querytable=null; query=null;

			}

			/*

			 * Modify original commit message

			 * using svnadmin command

			 */

			if(isWithCommitUpdate) {

				String svnadmin = readConfPropertyAsString(OPTION_SVNADMIN, null, true, null);

				EmitterUtil.verifyFile(svnadmin, false, true);

				/* If verification was turned on, we do already have the titles

				 * so only try to load the items when verification was off

				 */

				if(! isWithVerification) {

					verify(info.getIssues(), isTrace);

				}

				/* Append associated items information and change log message */

				StringBuffer newmessage = new StringBuffer();

				newmessage.append(info.getLogmessage());

				newmessage.append("\n\n Associated SBM items:\n");

				for(String s : issues_titles.keySet()) {

					newmessage.append(s+": ");

					newmessage.append(issues_titles.get(s));

					newmessage.append("\n");

				}

				postCommitUpdate(new File(svnadmin), repos, locale, encoding, rev, newmessage.toString());

			}

			/*

			 * XML processing phase

			 */

			if(isXmlProcessingEnabled) {

			}

			/*

			 * ALF Event Send phase

			 */

			String eventmanager = null;

			if(isSoapEnabled) {

				eventmanager 		= 	readConfPropertyAsString(OPTION_EVENTMANAGER_URL, null, true, null);

			}

		/**

		 * Event XML Erzeugen

		 */

		try {

			String resultxml=null;

			if(isXmlProcessingEnabled) {

				processXml();

				addALFSecurity();

				addEventHeader();

				// Serialize xml message to String

				StringWriter out = new StringWriter();

				template.getParent().serialize(out);

				out.flush();

				resultxml =  out.getBuffer().toString();

				if(isTrace) logger.debug("ALFEvent result:\n"+resultxml);

			} else {

				logger.debug("Xml processing is deactivated.");

			}

			if(isSoapEnabled && isXmlProcessingEnabled) {

				final boolean isDropResponse 	= readConfPropertyAsBoolean(OPTION_IS_DROPENABLED, true, true, null);

				SimpleHttpEvent sender = new SimpleHttpEvent(eventmanager, resultxml);

				sender.sendSoap(isDropResponse);

				logger.debug(String.format("Sending/ receiving the soap message took '%s' milliseconds.", sender.getDuration()));

			} else {

				logger.warn("Sending soap message and/ or xml processing is deactivated.");

			}

		} catch (FileNotFoundException e) {

			logger.error(e.getMessage(), e);

			this.exit(1);

		} catch (ClientProtocolException e) {

			logger.error(e.getMessage(), e);

			this.exit(1);

		} catch (IOException e) {

			logger.error(e.getMessage(), e);

			this.exit(1);

		} catch (XMLStreamException e) {

			logger.error(e.getMessage(), e);

			this.exit(1);

		} catch (JaxenException e) {

			logger.error(e.getMessage(), e);

			this.exit(1);

		} finally {

			String forcefail = config.getString(OPTION_IS_FORCEFAILENABLED, "");

			if(forcefail.length()>0) {

				logger.warn("Force fail is active. All commits will be blocked.");

				this.exit(1);

			}

		}

	}

		private void addEventHeader() throws JaxenException {

			AXIOMXPath path = new AXIOMXPath("//bru1:Base/bru1:EventId");

			path.addNamespace("bru1",  nss);

			OMElement n = (OMElement) path.selectSingleNode(template);

			if(n==null) {

				logger.error("<Base> element in message is incomplete. <EventId> is missing.");

			} else {

				n.addChild( n.getOMFactory().createOMText("1"));

			}

			path = new AXIOMXPath("//bru1:Base/bru1:ObjectId");

			path.addNamespace("bru1",  nss);

			n = (OMElement) path.selectSingleNode(template);

			if(n==null) {

				logger.error("<Base> element in message is incomplete. <ObjectId> is missing.");

			} else {

				n.addChild( n.getOMFactory().createOMText(info.getTxn() ));

			}

		}

		private void addALFSecurity() throws ConfigurationException, JaxenException {

			final String eventmanager_user 	= 	readConfPropertyAsString(OPTION_EVENTMANAGER_USER, null, false, null);

			String eventmanager_pass 	= 	readConfPropertyAsString(OPTION_EVENTMANAGER_PASSWORD, null, false, null);

			final boolean eventmanager_enc  =   readConfPropertyAsBoolean(OPTION_EVENTMANAGER_ENCRYPTED, false, false, null);

			if(eventmanager_enc) eventmanager_pass = PasswordEncrypter.decrypt(eventmanager_pass);

			AXIOMXPath path = new AXIOMXPath("//bru1:User");

			OMNamespace ns = template.findNamespace(nss, null);

			path.addNamespace("bru1", nss);

			OMElement n = (OMElement) path.selectSingleNode(template);

			if(n== null) {

				logger.warn( String.format("<User> element was not found in namespace '%s'. Cannot add ALFSecurity elements. This is required since SBM 10.1.x.", nss));

			} else {

				/*

				 *  <ns:User>

            		<!--Optional:-->

               		<ns:ALFSecurity>

                  		<ns:UsernameToken>

                     		<ns:Username>admin</ns:Username>

                     		<ns:Password></ns:Password>

                  		</ns:UsernameToken>

               		</ns:ALFSecurity>

					</ns:User>

				 */

				n.removeChildren();

				OMFactory fac = n.getOMFactory();

				fac.createOMComment(n, "Generated by SVN-ALFEmitter");

				OMElement sec = fac.createOMElement("ALFSecurity", ns);

				OMElement token = fac.createOMElement("UsernameToken", ns);

				OMElement user = fac.createOMElement("Username", ns);

				user.addChild( fac.createOMText(eventmanager_user));

				OMElement pass = fac.createOMElement("Password", ns);

				pass.addChild(fac.createOMText(eventmanager_pass, OMNode.CDATA_SECTION_NODE));

				token.addChild( user );

				token.addChild( pass);

				sec.addChild(token);

				n.addChild(sec);

			}

		}

		private void processXml() throws ConfigurationException, JaxenException {

			// read additional configuration

			final String eventtemplate 		= 	readConfPropertyAsString(OPTION_EVENTTEMPLATE, null, true, null);

			EmitterUtil.verifyFile(eventtemplate, false, false);

			try {

				template = OMXMLBuilderFactory.createOMBuilder(new FileInputStream(new File(eventtemplate)))

						.getDocument().getOMDocumentElement();

			} catch (FileNotFoundException e1) {

				logger.error(String.format("Could not load XML event template from file '%s'.", eventtemplate), e1);

				this.exit(1);

			}

			nss 	= 	readConfPropertyAsString(OPTION_EVENTNAMESPACE, "http://www.eclipse.org/alf/schema/EventBase/1", true, null);

			final String marker_logmessage 	= 	readConfPropertyAsString(OPTION_MARKER_LOGMESSAGE, "@@logmessage@@", true, null);

			final String marker_author 		= 	readConfPropertyAsString(OPTION_MARKER_AUTHOR, "@@author@@", true, null);

			final String marker_revision	= 	readConfPropertyAsString(OPTION_MARKER_REVISION, "@@revision@@", true, null);

			final String marker_addedfiles 	= 	readConfPropertyAsString(OPTION_MARKER_ADDEDFILES, "@@addedfiles@@", true, null);

			final String marker_deletedfiles = 	readConfPropertyAsString(OPTION_MARKER_DELETEDFILES, "@@deletedfiles@@", true, null);

			final String marker_changedfiles = 	readConfPropertyAsString(OPTION_MARKER_CHANGEDFILES, "@@changedfiles@@", true, null);

			final String marker_fileselementname = readConfPropertyAsString("marker.fileselementname", "file", true, null);

			final String marker_issues 		= 	readConfPropertyAsString(OPTION_MARKER_ISSUES, "@@issues@@", true, null);

			final String marker_issueselementname = readConfPropertyAsString("marker.issueselementname", "issue", true, null);

			final String marker_internalissues    = readConfPropertyAsString(OPTION_MARKER_INTERNALISSUES, "@@internalissues@@", true, null);

			SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ");

			String datestring = f.format(info.getDate());

			datestring= datestring.substring(0, 26) + ":" + datestring.substring(26); //hack into ISO 8601 format

			// add content from SVNCommitInfo object where

			// XML commit markers are

			addElement( marker_logmessage, info.getLogmessage(), true);

			addElement(marker_author, info.getAuthor(), false);

			addElement(marker_revision, info.getRev(), false);

			addElement("@@timestamp@@", datestring, false);

			addElements(marker_changedfiles, info.getChangedFiles(), marker_fileselementname);

			addElements(marker_deletedfiles, info.getDeletedFiles(), marker_fileselementname);

			addElements(marker_addedfiles, info.getAddedFiles(), marker_fileselementname);

			addElements(marker_issues, info.getIssues(), marker_issueselementname);

			addElements(marker_internalissues, internalissues, marker_issueselementname);

		}

		private boolean verify(List<String> issues, boolean isTrace) throws MalformedURLException {

			for(String issueid : issues) {

				TTItemList items = getTTItems(issueid, isTrace);

				if(items == null) {

					return false;

				}

			}

			return true;

	}

		private TTItemList getTTItems(String issueid, boolean isTrace) throws MalformedURLException {

			long startTime = System.currentTimeMillis();

			Sbmappservices72PortType port = null;

		    JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();

		    factory.setServiceClass(Sbmappservices72PortType.class);

		    factory.setAddress(endpoint);

		    port = (Sbmappservices72PortType) factory.create();

		    logger.debug("Total execution of sbmappservices72 wsdl read took '"+(System.currentTimeMillis()-startTime)+"' milliseconds.");

			if(isTrace) {

				Client client = ClientProxy.getClient(port);

		        client.getInInterceptors().add(new LoggingInInterceptor());

		        client.getOutInterceptors().add(new LoggingOutInterceptor());

			}

	        /* -- */

	        logger.debug("Total execution of sbmappservices72 initialisation took '"+(System.currentTimeMillis()-startTime)+"' milliseconds.");

			ObjectFactory fac = new ObjectFactory();

			Auth auth = fac.createAuth();

			auth.setUserId(fac.createAuthUserId(sbm_user));

			auth.setPassword(fac.createAuthPassword(sbm_pass));

			TableIdentifier table = fac.createTableIdentifier();

			table.setDbName(fac.createTableIdentifierDbName(querytable));

			MultipleResponseItemOptions options = fac.createMultipleResponseItemOptions();

			options.setSpecifiedSections(fac.createResponseItemOptionsSpecifiedSections("SECTION:FIXED"));

			options.setSections(SectionsOption.SECTIONS_SPECIFIED);

			issueid = issueid.replaceAll("[^0-9]", "");

			String queryWhereClause = "TS_ISSUEID = '"+issueid+"'";

			if(query!=null && query.length()>0) queryWhereClause = queryWhereClause + " And " + query;

			TTItemList items = null;

			logger.debug(String.format("Using query against table '%s'. Query where clause: '%s'", querytable, queryWhereClause ));

			try {

					startTime = System.currentTimeMillis();

					items = port.getItemsByQuery(auth, table, queryWhereClause, "", null, BigInteger.valueOf(1), options);

					logger.debug("Total execution of sbmappservices72 GetItems took '"+(System.currentTimeMillis()-startTime)+"' milliseconds.");

					//Marshaller m = JAXBContext.newInstance(TTItemList.class).createMarshaller();

					//m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

					//m.marshal( new JAXBElement<TTItemList>(new QName("uri","local"), TTItemList.class, items), System.err);

					logger.debug(String.format("Got Response from getItemsByQuery"));

					if(items!=null) {

						logger.debug(String.format("Verification query matched '%s' item(s) for issue '%s.'",items.getTotalCount(), issueid));

					}

					if(items.getTotalCount().intValue()<=0) {

						return null;

					} else {

						/* store internal ids (tableid:itemid) */

						internalissues.add(items.getItem().get(0).getId().getValue().getTableIdItemId().getValue());

						/* Store a map entry with internal id and title */

						issues_titles.put(items.getItem().get(0).getId().getValue().getDisplayName().getValue(),

											items.getItem().get(0).getTitle().getValue());

					}

			} catch (AEWebservicesFaultFault e) {

					logger.debug("Web service fault: " + e.getFaultInfo());

			} catch (Exception e) {

					logger.debug("Unknown Exception", e);

			}

			return items;

		}

		private void postCommitUpdate(File svnadmin, String repos, String locale, String encoding, String revision, String newmessage) {

			SVNAdminExecutor exec = new SVNAdminExecutor(svnadmin, repos);

			exec.setRev(revision);

			exec.setMessage(newmessage);

			exec.setEncoding(encoding);

			exec.setLocale(locale);

			exec.executeSVNAdmin(SVNAdminCommand.SETLOG);

		}

		private void addElement(String pattern, String newCdata, boolean wrapCDATA) throws JaxenException {

			OMComment comment = findComment(pattern);

			if(comment!=null) {

				OMFactory fac = OMAbstractFactory.getOMFactory();

				int type = OMNode.TEXT_NODE;

				if(wrapCDATA) {

					type = OMNode.CDATA_SECTION_NODE;

				}

				OMText text = fac.createOMText(newCdata, type);

				comment.insertSiblingAfter(text);

			}

		}

		private void addElements(String pattern, List<String> files, String elementName) throws JaxenException {

			if(files.size()<=0) return;

			OMComment comment = findComment(pattern);

			if(comment!=null) {

				OMFactory fac = OMAbstractFactory.getOMFactory();

				OMNamespace ns = template.findNamespace(nss, null);

				if(ns == null) logger.error(String.format("The namespace '%s' is not defined in the template.", nss));

				for(String s : files) {

					OMElement e = fac.createOMElement(elementName, ns);

					OMText text = fac.createOMText(s, OMNode.TEXT_NODE);

					e.addChild(text);

					comment.insertSiblingAfter(e);

				}

			}

		}

		private OMComment findComment(String pattern) throws JaxenException {

			AXIOMXPath path = new AXIOMXPath("//comment()[. = '"+pattern+"'][1]");

			//OMNamespace ns = template.findNamespace(nss, null);

			path.addNamespace("bru1", nss);

			OMComment n = (OMComment) path.selectSingleNode(template);

			if(n!=null) return n;

			logger.warn("Comment '"+pattern+"' was not found in the XML template.");

			return null;

		}

	private void exit(int errorCode) {

		long endTime = System.currentTimeMillis();

		logger.debug("Total execution took '"+(endTime-startTime)+"' milliseconds.");

		System.exit(errorCode);

	}

	private static Options getOptions() {

		Option repository = Option.builder(PARAM_REPOS)

				.argName("repository")

				.hasArg()

				.longOpt("repository")

				.desc("Path or Url to the SVN repository")

				.required()

				.build();

		Option txn = Option.builder(PARAM_TXN)

				.argName("transactionid")

				.hasArg()

				.longOpt("transaction")

				.desc("The SVN transaction id to examine (TXN). You cannot combine txn with -rev. "

						+ "When a txn is given, the repository path must be a local path.")

				.build();

		Option rev = Option.builder(PARAM_REV)

				.argName("revision")

				.hasArg()

				.desc("A revision to examine. You cannot combine revision with -txn.")

				.build();

		OptionGroup group = new OptionGroup()

				.addOption(txn)

				.addOption(rev);

		Option config = Option.builder(PARAM_CONFIG)

				.argName("config_file")

				.hasArg()

				.longOpt("config")

				.desc("The configuration file to use. Defaults to 'emitter.properties'.")

				.build();

		Options options = new Options();

		options.addOption(repository);

		options.addOption(config);

		options.addOptionGroup(group);

		return options;

	}

	private static void printHelp() {

		// automatically generate the help statement

		HelpFormatter formatter = new HelpFormatter();

		String header = "\nSVN-ALFEventEmitter " + VERSION + ", a SVN hook implemented in Java to emit Eclipse ALFEvents on commit.\n\n";

		String footer = "Please send bug reports to bru@brutex.de.\n(c)2020 Brian Rosenberger";

		formatter.setWidth(80);

		formatter.printHelp("java -jar SVN-ALFEventEmitter", header, getOptions(), footer, true);

	}

	private enum PropertyType {

		STRING(), STRINGARRAY(), BOOLEAN();

	}

}