WebSVN – XServices – Path Comparison – /xservices/trunk/src/java/net/ Rev HEAD and /xservices/trunk/src/java/net Rev 71

Ignore whitespace Rev HEAD → Rev 71

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/DateServiceImpl.java
 ,0 → 1,190
+/*
+ *   Copyright 2011 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.xservices.ws.impl;
+import java.math.BigInteger;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.GregorianCalendar;
+import java.util.TimeZone;
+import javax.jws.WebService;
+import net.brutex.xservices.types.DateFormatType;
+import net.brutex.xservices.types.DateTimeUnits;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.ws.DateService;
+import net.brutex.xservices.ws.XServicesFault;
+/**
+ * @author Brian Rosenberger
+ *
+ */
+@WebService(
+                targetNamespace = BrutexNamespaces.WS_XSERVICES,
+                endpointInterface = "net.brutex.xservices.ws.DateService",
+                serviceName = DateService.SERVICE_NAME
+                        )
+public class DateServiceImpl implements DateService {
+        private static String ERR_INVALIDFORMAT = "Invalid format pattern.";
+        private static String ERR_INVALIDTIMEZONE = "Invalid timezone.";
+        public GregorianCalendar getDate(String timezone) throws XServicesFault {
+                if (! isValidTimezone(timezone) ) {
+                        String valid_ids = "";
+                        String[] tid = TimeZone.getAvailableIDs();
+                        for (String s : tid) {
+                                valid_ids += s + "\n";
+                        }
+                        throw new XServicesFault("Please supply a valid timezone id or none. Valid timezones are:\n" + valid_ids,
+                                        new Exception( ));
+                }
+                        if (timezone == null || timezone.length()<1 ) timezone = "GMT0";
+                        GregorianCalendar c = new GregorianCalendar(TimeZone.getTimeZone(timezone));
+                        return c;
+        }
+        public BigInteger getTimestamp() {
+                Date d = new Date();
+                long l = d.getTime();
+                return new BigInteger(Long.toString(l));
+        }
+        public BigInteger getTimestamp2() {
+                Date d = new Date();
+                long l = d.getTime()/1000;
+                return new BigInteger(Long.toString(l));
+        }
+        public GregorianCalendar getInTimezone(GregorianCalendar cal,
+                        String timezone) throws XServicesFault {
+                if(! isValidTimezone(timezone)) throw new XServicesFault(ERR_INVALIDTIMEZONE);
+                GregorianCalendar c = new GregorianCalendar(TimeZone.getTimeZone(timezone));
+                c.setTimeInMillis(cal.getTimeInMillis());
+                return c;
+        }
+        public String formatDate(GregorianCalendar cal, DateFormatType format) throws XServicesFault {
+                return formatDateAdvanced(cal, format.format());
+        }
+        public String formatDateAdvanced(GregorianCalendar cal, String format)
+                        throws XServicesFault {
+                String result= null;
+                try {
+                        SimpleDateFormat f = new SimpleDateFormat(format);
+                        result = f.format(cal.getTime());
+                } catch (IllegalArgumentException e) {
+                        throw new XServicesFault(ERR_INVALIDFORMAT + e.getMessage());
+                }
+                return result;
+        }
+        public GregorianCalendar parseDate(String s, DateFormatType format, String timezone) throws XServicesFault {
+                return parseDateAdvanced(s, format.format(), timezone);
+        }
+        public GregorianCalendar parseDateAdvanced(String s, String format, String timezone) throws XServicesFault {
+                SimpleDateFormat f = null;
+                Date date = null;
+                if(timezone==null | timezone.equals("")) timezone = TimeZone.getDefault().getID();
+                if(! isValidTimezone(timezone)) throw new XServicesFault(ERR_INVALIDTIMEZONE);
+                try {
+                        f = new SimpleDateFormat(format);
+                        date = f.parse(s);
+                } catch(IllegalArgumentException e) {
+                        throw new XServicesFault(ERR_INVALIDFORMAT + e.getMessage());
+                } catch (ParseException e) {
+                        throw new XServicesFault("Cannot parse date: "+ e.getMessage());
+                }
+                GregorianCalendar cal = new GregorianCalendar();
+                cal.setTimeZone(TimeZone.getTimeZone(timezone));
+                cal.setTime(date);
+                return cal;
+        }
+        public BigInteger dateTimeDiff(GregorianCalendar fromCal,
+                        GregorianCalendar toCal) throws XServicesFault {
+                long diff = toCal.getTimeInMillis() - fromCal.getTimeInMillis();
+                BigInteger d = new BigInteger(String.valueOf(diff), 10);
+                return d;
+        }
+        public BigInteger dateTimeDiff2(GregorianCalendar fromCal,
+                        GregorianCalendar toCal, DateTimeUnits unit) throws XServicesFault {
+                BigInteger d = dateTimeDiff(fromCal, toCal);
+                switch (unit) {
+                case SECONDS:
+                        d = d.divide(new BigInteger("1000"));
+                        break;
+                case MINUTES:
+                        d = d.divide(new BigInteger("60000"));
+                        break;
+                case HOURS:
+                        d = d.divide(new BigInteger("3600000"));
+                        break;
+                case DAYS:
+                        d = d.divide(new BigInteger("86400000"));
+                }
+                return d;
+        }
+        public GregorianCalendar dateAdd(GregorianCalendar cal, BigInteger value, DateTimeUnits unit)
+                        throws XServicesFault {
+                switch (unit) {
+                case SECONDS:
+                        cal.add(GregorianCalendar.SECOND, value.intValue());
+                        break;
+                case MINUTES:
+                        cal.add(GregorianCalendar.MINUTE, value.intValue());
+                        break;
+                case HOURS:
+                        cal.add(GregorianCalendar.HOUR_OF_DAY, value.intValue());
+                        break;
+                case DAYS:
+                        cal.add(GregorianCalendar.DAY_OF_MONTH, value.intValue());
+                        break;
+                default:
+                        cal.add(GregorianCalendar.MILLISECOND, value.intValue());
+                }
+                return cal;
+        }
+        private boolean isValidTimezone(String id) {
+                boolean yes = false;
+                for( String s: TimeZone.getAvailableIDs()) {
+                        if(s.equals(id)) {
+                                yes = true;
+                                break;
+                        }
+                }
+                return yes;
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/FileServiceImpl.java
 ,0 → 1,370
+/*
+ *   Copyright 2010 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.xservices.ws.impl;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.List;
+import javax.activation.DataHandler;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import net.brutex.xservices.types.ArchiveResource;
+import net.brutex.xservices.types.AttachmentType;
+import net.brutex.xservices.types.FileResource;
+import net.brutex.xservices.types.FileSetResource;
+import net.brutex.xservices.types.ReplacePattern;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.RunTask;
+import net.brutex.xservices.ws.FileService;
+import net.brutex.xservices.ws.XServicesFault;
+import org.apache.cxf.aegis.type.mtom.StreamDataSource;
+import org.apache.tools.ant.BuildException;
+import org.apache.tools.ant.taskdefs.Basename;
+import org.apache.tools.ant.taskdefs.Chmod;
+import org.apache.tools.ant.taskdefs.Copy;
+import org.apache.tools.ant.taskdefs.Echo;
+import org.apache.tools.ant.taskdefs.LoadResource;
+import org.apache.tools.ant.taskdefs.Replace;
+import org.apache.tools.ant.taskdefs.optional.ReplaceRegExp;
+import org.apache.tools.ant.taskdefs.optional.unix.Chgrp;
+import org.apache.tools.ant.taskdefs.optional.unix.Chown;
+import org.apache.tools.ant.types.FileSet;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.FileService", serviceName = "FileService")
+public class FileServiceImpl implements FileService {
+        /*
+         * (non-Javadoc)
+         *
+         * @see net.brutex.xservices.ws.impl.FileService#basename(java.lang.String,
+         * java.lang.String)
+         */
+        public String basename(String filename, String suffix) {
+                final String BASENAME_VALUE = "basename.value";
+                Basename basename = new Basename();
+                RunTask runner = new RunTask(basename);
+                basename.setFile(new File(filename));
+                if (suffix != null && !suffix.equals("")) {
+                        basename.setSuffix(suffix);
+                }
+                basename.setProperty(BASENAME_VALUE);
+                ReturnCode r = runner.postTask();
+                return r.getProperty(BASENAME_VALUE);
+        }
+        public ReturnCode replaceInFile(FileResource res, String search,
+                        String replace) throws XServicesFault {
+                ReturnCode r = null;
+                Replace rep = new Replace();
+                rep.setTaskName("Replace");
+                RunTask runner = new RunTask(rep);
+                rep.addConfigured(res.getAntResource(rep.getProject()));
+                rep.setToken(search);
+                rep.setValue(replace);
+                try {
+                        r = runner.postTask();
+                } catch (BuildException e) {
+                        throw new XServicesFault(e);
+                }
+                return r;
+        }
+        public ReturnCode replaceInFile2(FileResource res,
+                        List<ReplacePattern> patternList) throws XServicesFault {
+                ReturnCode r = null;
+                for (ReplacePattern pat : patternList) {
+                        Replace rep = new Replace();
+                        rep.setTaskName("Replace");
+                        RunTask runner = new RunTask(rep);
+                        rep.addConfigured(res.getAntResource(rep.getProject()));
+                        rep.setToken(pat.search);
+                        rep.setValue(pat.replace);
+                        try {
+                                r = runner.postTask();
+                        } catch (BuildException e) {
+                                throw new XServicesFault(e);
+                        }
+                }
+                return r;
+        }
+        public ReturnCode replaceInFileRegEx(FileResource res, String search,
+                        String replace, String flags) throws XServicesFault {
+                ReplaceRegExp rep = new ReplaceRegExp();
+                rep.setTaskName("ReplaceRegExp");
+                RunTask runner = new RunTask(rep);
+                File infile = new File(res.uri);
+                rep.setFile(infile);
+                rep.setMatch(search);
+                rep.setReplace(replace);
+                rep.setFlags(flags);
+                try {
+                        ReturnCode r = runner.postTask();
+                        return r;
+                } catch (BuildException e) {
+                        throw new XServicesFault(e);
+                }
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#base64Encode(net.brutex.xservices
+         * .types.FileSetResource)
+         */
+        public AttachmentType downloadFile(FileResource res) throws XServicesFault {
+                InputStream is = null;
+                try {
+                        is = res.getAntResource(null).getInputStream();
+                        StreamDataSource ssource = new StreamDataSource(
+                                        "application/binary", is);
+                        DataHandler h = new DataHandler(ssource);
+                        AttachmentType t = new AttachmentType();
+                        t.setContent(h);
+                        t.setFilename(res.getAntResource(null).getName());
+                        return t;
+                } catch (IOException e) {
+                        throw new XServicesFault(e);
+                }
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#base64Decode(net.brutex.xservices
+         * .types.AttachmentType)
+         */
+        public String uploadFile(AttachmentType file) throws XServicesFault {
+                DataHandler h = file.getContent();
+                File f = new File(file.getFilename());
+                FileOutputStream fout;
+                try {
+                        fout = new FileOutputStream(f);
+                        h.writeTo(fout);
+                        fout.flush();
+                        fout.close();
+                } catch (FileNotFoundException e) {
+                        throw new XServicesFault(e);
+                } catch (IOException e) {
+                        throw new XServicesFault(e);
+                }
+                return file.getFilename();
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#copy(net.brutex.xservices.types
+         * .FileSetResource, java.lang.String, boolean, boolean, java.lang.String)
+         */
+        public ReturnCode copy(FileSetResource src, String todir, boolean plm,
+                        boolean overwrite, String encoding) throws XServicesFault {
+                Copy copy = new Copy();
+                copy.setTaskName("Copy");
+                RunTask runner = new RunTask(copy);
+                FileSet set = src.getAntResource(copy.getProject());
+                copy.add(set);
+                File dst = new File(todir);
+                if (dst.isDirectory()) {
+                        copy.setTodir(dst);
+                }
+                if (dst.isFile()) {
+                        copy.setTofile(dst);
+                }
+                copy.setOverwrite(overwrite);
+                copy.setPreserveLastModified(plm);
+                if (encoding != null && !encoding.equals("")) {
+                        copy.setOutputEncoding(encoding);
+                } else {
+                        copy.setOutputEncoding(System.getProperty("file.encoding"));
+                }
+                return runner.postTask();
+        }
+        public ReturnCode copyFile(String fromFile, String tofile, boolean overwrite)
+                        throws XServicesFault {
+                Copy copy = new Copy();
+                copy.setTaskName("Copy");
+                RunTask runner = new RunTask(copy);
+                File f = new File(fromFile);
+                if (!f.isFile())
+                        throw new XServicesFault("File '" + fromFile + "' not found.");
+                copy.setFile(new File(fromFile));
+                copy.setTofile(new File(tofile));
+                copy.setOverwrite(overwrite);
+                return runner.postTask();
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#loadRes(net.brutex.xservices
+         * .types.FileResource, java.lang.String)
+         */
+        public String loadRes(FileResource res, String encoding)
+                        throws XServicesFault {
+                if (encoding == null || encoding.equals("")) {
+                        encoding = System.getProperty("file.encoding");
+                }
+                LoadResource lr = new LoadResource();
+                lr.setTaskName("LoadResource");
+                RunTask runner = new RunTask(lr);
+                lr.addConfigured(res.getAntResource(lr.getProject()));
+                lr.setEncoding(encoding);
+                System.out.println("Using encoding: " + encoding);
+                lr.setProperty("LoadResource.out");
+                ReturnCode r = runner.postTask();
+                return r.getProperty("LoadResource.out");
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#loadResFromArchive(net.brutex
+         * .xservices.types.ArchiveResource, java.lang.String)
+         */
+        public String loadResFromArchive(ArchiveResource res, String encoding) {
+                if (encoding == null || encoding.equals("")) {
+                        encoding = System.getProperty("file.encoding");
+                }
+                LoadResource lr = new LoadResource();
+                lr.setTaskName("LoadResource");
+                RunTask runner = new RunTask(lr);
+                lr.addConfigured(res.getAntResource(lr.getProject()));
+                lr.setEncoding(encoding);
+                System.out.println("Using encoding: " + encoding);
+                lr.setProperty("LoadResource.out");
+                ReturnCode r = runner.postTask();
+                return r.getProperty("LoadResource.out");
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see net.brutex.xservices.ws.impl.FileService#echo2file(java.lang.String,
+         * java.lang.String, java.lang.String, boolean)
+         */
+        public ReturnCode echo2file(String message, String file, String encoding,
+                        boolean append) throws XServicesFault {
+                Echo echo = new Echo();
+                echo.setTaskName("toFile");
+                RunTask runTask = new RunTask(echo);
+                echo.addText(message);
+                echo.setEncoding(encoding);
+                File f = new File(file);
+                try {
+                        if (!f.canWrite())
+                                throw new XServicesFault("Cannot write to file: "
+                                                + f.getCanonicalPath());
+                        echo.setFile(f);
+                        echo.setAppend(append);
+                        ReturnCode c = runTask.postTask();
+                        return c;
+                } catch (BuildException e) {
+                        throw new XServicesFault("Error in echo2file.", e);
+                } catch (IOException e) {
+                        throw new XServicesFault("Cannot write to file.", e);
+                }
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#changeOwner(net.brutex.xservices
+         * .types.FileSetResource, java.lang.String)
+         */
+        public ReturnCode changeOwner(FileSetResource res, String owner) {
+                Chown chown = new Chown();
+                chown.setTaskName("Chown");
+                RunTask runner = new RunTask(chown);
+                chown.setOwner(owner);
+                FileSet set = res.getAntResource(chown.getProject());
+                chown.add(set);
+                chown.setMaxParallel(300);
+                return runner.postTask();
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#changeGroup(net.brutex.xservices
+         * .types.FileSetResource, java.lang.String)
+         */
+        public ReturnCode changeGroup(FileSetResource res, String group) {
+                Chgrp chgrp = new Chgrp();
+                chgrp.setTaskName("Chgrp");
+                RunTask runner = new RunTask(chgrp);
+                chgrp.setGroup(group);
+                FileSet set = res.getAntResource(chgrp.getProject());
+                chgrp.add(set);
+                chgrp.setMaxParallel(300);
+                return runner.postTask();
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.FileService#changeMode(net.brutex.xservices
+         * .types.FileSetResource, java.lang.String)
+         */
+        public ReturnCode changeMode(FileSetResource res, String perm) {
+                Chmod chmod = new Chmod();
+                chmod.setTaskName("Chmod");
+                RunTask runner = new RunTask(chmod);
+                FileSet set = res.getAntResource(chmod.getProject());
+                chmod.add(set);
+                chmod.setMaxParallel(300);
+                chmod.setPerm(perm);
+                chmod.setVerbose(true);
+                return runner.postTask();
+        }
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/ArchiveServiceImpl.java
 ,0 → 1,324
+/*
+ *   Copyright 2010 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.xservices.ws.impl;
+import java.io.File;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import net.brutex.xservices.types.ArchiveResource;
+import net.brutex.xservices.types.CompressionType;
+import net.brutex.xservices.types.FileResource;
+import net.brutex.xservices.types.ResourceInterface;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.RunTask;
+import net.brutex.xservices.util.UnRarTask;
+import net.brutex.xservices.ws.ArchiveService;
+import org.apache.tools.ant.taskdefs.BUnzip2;
+import org.apache.tools.ant.taskdefs.BZip2;
+import org.apache.tools.ant.taskdefs.Expand;
+import org.apache.tools.ant.taskdefs.GUnzip;
+import org.apache.tools.ant.taskdefs.GZip;
+import org.apache.tools.ant.taskdefs.Untar;
+import org.apache.tools.ant.taskdefs.Zip;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES,
+                endpointInterface="net.brutex.xservices.ws.ArchiveService",
+                serviceName = "ArchiveService")
+public class ArchiveServiceImpl implements ArchiveService {
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#bzip2(net.brutex.xservices.types.FileResource, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_BZIP2, action = WS_OPERATION_BZIP2)
+    public ReturnCode bzip2(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) {
+        return bzip(src, new File(file));
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#bzip2FromArchive(net.brutex.xservices.types.ArchiveResource, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_BZIP2_ARCHIVE, action = WS_OPERATION_BZIP2_ARCHIVE)
+   public ReturnCode bzip2FromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) {
+return null;//       return bzip(src, new File(file));
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#gzip(net.brutex.xservices.types.FileResource, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_GZIP, action = WS_OPERATION_GZIP)
+    public ReturnCode gzip(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) {
+        return gzip(src, new File(file));
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#gzipFromArchive(net.brutex.xservices.types.ArchiveResource, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_GZIP_ARCHIVE, action = WS_OPERATION_GZIP_ARCHIVE)
+    public ReturnCode gzipFromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) {
+        return gzip(src, new File(file));
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#gunzip(java.lang.String, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_GUNZIP, action = WS_OPERATION_GUNZIP)
+    public ReturnCode gunzip(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) {
+        File target = null;
+        if (!dest.equals("") && dest != null) {
+            target = new File(dest);
+        }
+        return GUnzip(new FileResource(FileResource.Type.FILE, src), target);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#bunzip2(java.lang.String, java.lang.String)
+         */
+        @WebMethod(operationName = WS_OPERATION_BUNZIP2)
+    public ReturnCode bunzip2(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) {
+        File target = null;
+        if (!dest.equals("") && dest != null) {
+            target = new File(dest);
+        }
+        return BUnzip2(new FileResource(FileResource.Type.FILE, src), target);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#gunzipFromURL(java.lang.String, java.lang.String)
+         */
+        @WebMethod(operationName = "gunzipFromURL")
+    public ReturnCode gunzipFromURL(@WebParam(name = WS_PARAM_SOURCEURL) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) {
+        File target = null;
+        if (!dest.equals("") && dest != null) {
+            target = new File(dest);
+        }
+        return GUnzip(new FileResource(FileResource.Type.URL, src), target);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#bunzip2FromURL(java.lang.String, java.lang.String)
+         */
+        @WebMethod(operationName = "bunzip2FromURL")
+    public ReturnCode bunzip2FromURL(@WebParam(name = WS_PARAM_SOURCEURL) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) {
+        File target = null;
+        if (!dest.equals("") && dest != null) {
+            target = new File(dest);
+        }
+        return BUnzip2(new FileResource(FileResource.Type.URL, src), target);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#zip(net.brutex.xservices.types.FileResource, java.lang.String, boolean, java.lang.String, int)
+         */
+        @WebMethod(operationName = "zip")
+    public ReturnCode zip(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding,
+            @WebParam(name = "compresslevel") int level) {
+        if (level > 9) {
+            level = 9;
+        }
+        if (level < 0) {
+            level = 0;
+        }
+        return zip(src, new File(file), encoding, !overwrite, level);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#zipFromArchive(net.brutex.xservices.types.ArchiveResource, java.lang.String, boolean, java.lang.String, int)
+         */
+        @WebMethod(operationName = "zipFromArchive")
+    public ReturnCode zipFromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean update,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding,
+            @WebParam(name = "compresslevel") int level) {
+        return zip(src, new File(file), encoding, !update, level);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#unzip(java.lang.String, java.lang.String, boolean, java.lang.String)
+         */
+        @WebMethod(operationName = "unzip")
+    public ReturnCode unzip(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding) {
+        return unzip(new File(src), new File(dest), overwrite, encoding);
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#unrar(java.lang.String, java.lang.String)
+         */
+        @WebMethod(operationName = "unrar")
+    public ReturnCode unrar(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) {
+        return unrar(new File(src), new File(dest));
+    }
+    /* (non-Javadoc)
+         * @see net.brutex.xservices.ws.ArchiveService#untar(java.lang.String, java.lang.String, boolean, net.brutex.xservices.types.CompressionType)
+         */
+        @WebMethod(operationName = "untar")
+    public ReturnCode untar(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = "compression") CompressionType compression) {
+        Untar.UntarCompressionMethod c = new Untar.UntarCompressionMethod();
+        switch (compression) {
+            case GZIP:
+                c.setValue("gzip");
+                break;
+            case BZIP2:
+                c.setValue("bzip2");
+                break;
+            default:
+                c.setValue("none");
+                break;
+        }
+        return untar(new File(src), new File(dest), overwrite, c);
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode bzip(ResourceInterface src, File dst) {
+        if (dst.exists() && dst.isFile()) {
+            dst.delete();
+        }
+        BZip2 bzip = new BZip2();
+        bzip.setTaskName("BZip2");
+        RunTask runner = new RunTask(bzip);
+        bzip.setSrcResource(src.getAntResource(bzip.getProject()));
+        bzip.setDestfile(dst);
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode gzip(ResourceInterface src, File dst) {
+        if (dst.exists() && dst.isFile()) {
+            dst.delete();
+        }
+        GZip gzip = new GZip();
+        gzip.setTaskName("GZip");
+        RunTask runner = new RunTask(gzip);
+        gzip.addConfigured(src.getAntResource(gzip.getProject()));
+        gzip.setDestfile(dst);
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode zip(ResourceInterface src, File dst, String encoding, boolean update, int compresslevel) {
+        Zip zip = new Zip();
+        zip.setTaskName("Zip");
+        RunTask runner = new RunTask(zip);
+        zip.add(src.getAntResource(zip.getProject()));
+        zip.setDestFile(dst);
+        if (encoding != null && !encoding.equals("")) {
+            zip.setEncoding(encoding);
+        }
+        zip.setUpdate(update);
+        zip.setLevel(compresslevel);
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode GUnzip(ResourceInterface src, File dst) {
+        GUnzip uz = new GUnzip();
+        uz.setTaskName("GUnzip");
+        RunTask runner = new RunTask(uz);
+        uz.setSrcResource(src.getAntResource(uz.getProject()));
+        if (dst != null) {
+            uz.setDest(dst);
+        }
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode BUnzip2(ResourceInterface src, File dst) {
+        BUnzip2 uz = new BUnzip2();
+        uz.setTaskName("BUnzip2");
+        RunTask runner = new RunTask(uz);
+        uz.setSrcResource(src.getAntResource(uz.getProject()));
+        if (dst != null) {
+            uz.setDest(dst);
+        }
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode unzip(File src, File dest, boolean overwrite, String encoding) {
+        Expand unzip = new Expand();
+        unzip.setTaskName("UnZip");
+        RunTask runner = new RunTask(unzip);
+        unzip.setSrc(src);
+        unzip.setDest(dest);
+        unzip.setOverwrite(overwrite);
+        if (encoding != null && !encoding.equals("")) {
+            unzip.setEncoding(encoding);
+        }
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode untar(File src, File dest, boolean overwrite, Untar.UntarCompressionMethod compression) {
+        Untar unzip = new Untar();
+        unzip.setTaskName("Untar");
+        RunTask runner = new RunTask(unzip);
+        unzip.setSrc(src);
+        unzip.setDest(dest);
+        unzip.setOverwrite(overwrite);
+        unzip.setCompression(compression);
+        return runner.postTask();
+    }
+    @WebMethod(exclude = true)
+    private ReturnCode unrar(File src, File dst) {
+        UnRarTask unrar = new UnRarTask();
+        unrar.setTaskName("UnRar");
+        RunTask runner = new RunTask(unrar);
+        unrar.setSrc(src);
+        unrar.setDst(dst);
+        return runner.postTask();
+    }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/ExecuteServiceImpl.java
 ,0 → 1,354
+/*
+ *   Copyright 2010 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.xservices.ws.impl;
+import java.io.File;
+import java.util.UUID;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import net.brutex.xservices.types.HostConnection;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.JobWrapper;
+import net.brutex.xservices.util.RunTask;
+import net.brutex.xservices.ws.ExecuteService;
+import net.brutex.xservices.ws.XServicesFault;
+import org.apache.tools.ant.taskdefs.ExecTask;
+import org.apache.tools.ant.taskdefs.optional.net.RExecTask;
+import org.apache.tools.ant.taskdefs.optional.net.TelnetTask;
+import org.apache.tools.ant.taskdefs.optional.ssh.SSHExec;
+import org.apache.tools.ant.types.Commandline;
+import org.mozilla.javascript.Context;
+import org.mozilla.javascript.Scriptable;
+import org.quartz.JobBuilder;
+import org.quartz.JobDetail;
+import org.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.quartz.Trigger;
+import static org.quartz.TriggerBuilder.*;
+import static org.quartz.SimpleScheduleBuilder.*;
+import org.quartz.TriggerUtils;
+import org.quartz.impl.StdSchedulerFactory;
+import org.quartz.impl.triggers.SimpleTriggerImpl;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.ExecuteService", serviceName = "ExecuteService")
+public class ExecuteServiceImpl implements ExecuteService {
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommand(java.lang.String,
+         * java.lang.String, long)
+         */
+        @WebMethod(operationName = "runCommand")
+        public ReturnCode runCommand(@WebParam(name = "executable") String cmd,
+                        @WebParam(name = "argline") String args,
+                        @WebParam(name = "timeout") long timeout) {
+                return executeCommand(cmd, Commandline.translateCommandline(args),
+                                null, false, null, false, true, false, timeout);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommandWithArgs(java.lang
+         * .String, java.lang.String[], long)
+         */
+        @WebMethod(operationName = "runCommandWithArgs")
+        public ReturnCode runCommandWithArgs(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "arg") String[] args,
+                        @WebParam(name = "timeout") long timeout) {
+                return executeCommand(cmd, args, null, false, null, false, true, false,
+                                timeout);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommandAsync(java.lang
+         * .String, java.lang.String)
+         */
+        @WebMethod(operationName = "runCommandAsync")
+        public ReturnCode runCommandAsync(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "argline") String args) {
+                return executeCommand(cmd, Commandline.translateCommandline(args),
+                                null, true, null, false, true, false, 0);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommandAsyncWithArgs(java
+         * .lang.String, java.lang.String[])
+         */
+        @WebMethod(operationName = "runCommandAsyncWithArgs")
+        public ReturnCode runCommandAsyncWithArgs(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "arg") String[] args) {
+                return executeCommand(cmd, args, null, true, null, false, true, false,
+);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommandWithSSH(java.lang
+         * .String, int, java.lang.String, java.lang.String, java.lang.String, long)
+         */
+        @WebMethod(operationName = "runCommandWithSSH")
+        public ReturnCode runCommandWithSSH(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout) {
+                return sshExec(host.hostname, host.user, host.password, host.port, cmd,
+                                timeout);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runCommandWithSSHKeyAuth(
+         * java.lang.String, int, java.lang.String, java.lang.String,
+         * java.lang.String, java.lang.String, long)
+         */
+        @WebMethod(operationName = "runCommandWithSSHKeyAuth")
+        public ReturnCode runCommandWithSSHKeyAuth(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "keyfile") String keyfile,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout) {
+                return sshExecWithCert(host.hostname, host.user, host.password,
+                                keyfile, host.port, cmd, timeout);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#rExec(net.brutex.xservices
+         * .types.HostConnection, java.lang.String, long)
+         */
+        @WebMethod(operationName = "rExec")
+        public ReturnCode rExec(@WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout) {
+                return rexec(host.hostname, host.port, host.user, host.password, cmd,
+                                timeout);
+        }
+        /*
+         * (non-Javadoc)
+         *
+         * @see
+         * net.brutex.xservices.ws.impl.ExecuteService#runTelnet(net.brutex.xservices
+         * .types.HostConnection, java.lang.String, java.lang.String,
+         * java.lang.String, long)
+         */
+        @WebMethod(operationName = "telnet")
+        public ReturnCode runTelnet(@WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "prompt") String prompt,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "expect") String expect,
+                        @WebParam(name = "timeout") long timeout) {
+                return telnet(host.hostname, host.port, host.user, host.password, cmd,
+                                timeout, prompt, expect);
+        }
+        public void runJScript(String script) throws XServicesFault {
+                try {
+                        // Create and enter a Context. A Context stores information about
+                        // the execution environment of a script.
+                        Context cx = Context.enter();
+                        cx.setOptimizationLevel(0);
+                        cx.setLanguageVersion(Context.VERSION_1_7);
+                        // cx is the Context instance you're using to run scripts
+                        /*
+                         * cx.setClassShutter(new ClassShutter() { public boolean
+                         * visibleToScripts(String className) {
+                         * if(className.startsWith("adapter")) return true;
+                         * if(className.startsWith("java.lang.System") ||
+                         * className.startsWith
+                         * ("org.apache.tomcat.util.log.SystemLogHandler")) return true;
+                         * System.out.println(className + " is blocked."); return false; }
+                         * });
+                         */
+                        // Initialise the standard objects (Object, Function, etc.). This
+                        // must be done before scripts can be
+                        // executed. The null parameter tells initStandardObjects
+                        // to create and return a scope object that we use
+                        // in later calls.
+                        Scriptable scope = cx.initStandardObjects();
+                        // Object wrappedOut = Context.javaToJS(System.out, scope);
+                        // Object wrappedOut2 = Context.javaToJS(this, scope);
+                        // scope.put("out", scope, wrappedOut);
+                        // scope.put("exe", scope, wrappedOut2);
+                        // Execute the script
+                        // cx.evaluateString(scope, "importClass('java.lang.System');\n",
+                        // "head", 1, null);
+                        // cx.evaluateString(scope, "importPackage('java.util');\n", "head",
+                        // 2, null);
+                        Object obj = cx
+                                        .evaluateString(scope, script, "TestScript", 1, null);
+                } catch (Exception e) {
+                        System.out.println(e.getMessage());
+                } finally {
+                        // Exit the Context. This removes the association between the
+                        // Context and the current thread and is an
+                        // essential cleanup action. There should be a call to exit for
+                        // every call to enter.
+                        Context.exit();
+                }
+        }
+        @WebMethod(exclude = true)
+        private ReturnCode executeCommand(String executable, String[] args,
+                        File dir, boolean spawn, String inputstring,
+                        boolean newenvironment, boolean vmlauncher, boolean searchpath,
+                        long timeout) {
+                ExecTask exe = new ExecTask();
+                RunTask runner = new RunTask(exe);
+                /*
+                 * Commandline cmdl = new Commandline(); cmdl.setExecutable(executable);
+                 * cmdl.addArguments(args); System.out.println(cmdl.describeCommand());
+                 */
+                exe.setExecutable(executable);
+                for (String s : args) {
+                        exe.createArg().setValue(s);
+                }
+                exe.setDir(dir);
+                if (spawn) {
+                        exe.setSpawn(spawn);
+                } else {
+                        exe.setTimeout(timeout);
+                        exe.setInputString(inputstring);
+                        exe.setOutputproperty("ExecuteService.stdout");
+                        exe.setErrorProperty("ExecuteService.stderr");
+                        exe.setResultProperty("ExecuteService.result");
+                }
+                exe.setNewenvironment(newenvironment);
+                exe.setVMLauncher(vmlauncher);
+                exe.setSearchPath(searchpath);
+                return runner.postTask();
+        }
+        @WebMethod(exclude = true)
+        private ReturnCode sshExec(String host, String username, String password,
+                        int port, String command, long timeout) {
+                SSHExec sshexec = new SSHExec();
+                RunTask runner = new RunTask(sshexec);
+                sshexec.setHost(host);
+                sshexec.setUsername(username);
+                sshexec.setPassword(password);
+                sshexec.setPort(port);
+                sshexec.setCommand(command);
+                sshexec.setTrust(true);
+                sshexec.setTimeout(timeout);
+                sshexec.setOutputproperty("SSHExec.stdout");
+                return runner.postTask();
+        }
+        @WebMethod(exclude = true)
+        private ReturnCode sshExecWithCert(String host, String username,
+                        String passphrase, String keyfile, int port, String command,
+                        long timeout) {
+                SSHExec sshexec = new SSHExec();
+                RunTask runner = new RunTask(sshexec);
+                sshexec.setHost(host);
+                sshexec.setUsername(username);
+                sshexec.setKeyfile(keyfile);
+                sshexec.setPassphrase(passphrase);
+                sshexec.setPort(port);
+                sshexec.setCommand(command);
+                sshexec.setTrust(true);
+                sshexec.setTimeout(timeout);
+                sshexec.setOutputproperty("SSHExec.stdout");
+                return runner.postTask();
+        }
+        @WebMethod(exclude = true)
+        private ReturnCode rexec(String host, int port, String username,
+                        String password, String command, long timeout) {
+                RExecTask rexec = new RExecTask();
+                RunTask runner = new RunTask(rexec);
+                rexec.setServer(host);
+                rexec.setPort(port);
+                rexec.setUserid(username);
+                rexec.setPassword(password);
+                rexec.setCommand(command);
+                rexec.setTimeout((int) Math.round(timeout));
+                return runner.postTask();
+        }
+        @WebMethod(exclude = true)
+        private ReturnCode telnet(String host, int port, String username,
+                        String password, String command, long timeout, String prompt,
+                        String expect) {
+                TelnetTask rexec = new TelnetTask();
+                RunTask runner = new RunTask(rexec);
+                rexec.setServer(host);
+                rexec.setPort(port);
+                rexec.setUserid(username);
+                rexec.setPassword(password);
+                rexec.setTimeout((int) Math.round(timeout));
+                rexec.createRead().addText(prompt);
+                rexec.createWrite().addText(command);
+                rexec.createRead().addText(expect);
+                return runner.postTask();
+        }
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/JobServiceImpl.java
 ,0 → 1,151
+/*
+ *   Copyright 2011 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.xservices.ws.impl;
+import static org.quartz.TriggerBuilder.newTrigger;
+import java.util.ArrayList;
+import java.util.GregorianCalendar;
+import java.util.List;
+import java.util.Set;
+import java.util.TimeZone;
+import java.util.UUID;
+import javax.jws.WebService;
+import org.quartz.JobBuilder;
+import org.quartz.JobDataMap;
+import org.quartz.JobDetail;
+import org.quartz.JobKey;
+import org.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.quartz.SimpleTrigger;
+import org.quartz.Trigger;
+import org.quartz.TriggerKey;
+import org.quartz.impl.StdSchedulerFactory;
+import org.quartz.impl.matchers.GroupMatcher;
+import net.brutex.xservices.types.ScheduledJob;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.JobWrapper;
+import net.brutex.xservices.ws.JobService;
+import net.brutex.xservices.ws.XServicesFault;
+/**
+ * @author Brian Rosenberger
+ * @since 0.5.0
+ *
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.JobService", serviceName = JobService.SERVICE_NAME)
+public class JobServiceImpl implements JobService {
+        public List<ScheduledJob> getJobList() throws XServicesFault {
+                List<ScheduledJob> joblist = new ArrayList<ScheduledJob>();
+                try {
+                        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
+                        List<String> jobgroups = scheduler.getJobGroupNames();
+                        for (String g : jobgroups) {
+                                GroupMatcher m = GroupMatcher.groupContains(g);
+                                Set<JobKey> keyset = scheduler.getJobKeys(m);
+                                for (JobKey key : keyset) {
+                                        JobDataMap detail = scheduler.getJobDetail(key)
+                                                        .getJobDataMap();
+                                        ScheduledJob job = new ScheduledJob(key.getName(),
+                                                        (GregorianCalendar) detail.get("date"),
+                                                        detail.getString("script"));
+                                        joblist.add(job);
+                                }
+                        }
+                } catch (SchedulerException e) {
+                        throw new XServicesFault(e);
+                }
+                return joblist;
+        }
+        public ScheduledJob getJob(String uuid) throws XServicesFault {
+                try {
+                        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
+                        JobDetail job = scheduler.getJobDetail(new JobKey(uuid, "DEFAULT"));
+                        if (job == null)
+                                throw new XServicesFault("Job not found.");
+                        Trigger t = scheduler.getTrigger(new TriggerKey(uuid));
+                        GregorianCalendar cal = new GregorianCalendar(TimeZone.getDefault());
+                        cal.setTime(t.getStartTime());
+                        return new ScheduledJob(uuid, cal, job.getJobDataMap().getString(
+                                        "script"), job.getDescription());
+                } catch (SchedulerException e) {
+                        e.printStackTrace();
+                        throw new XServicesFault(e);
+                }
+        }
+        public void deleteJob(String uuid) throws XServicesFault {
+                try {
+                        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
+                        JobKey key = new JobKey(uuid, "DEFAULT");
+                        JobDetail job = scheduler.getJobDetail(key);
+                        if (job == null)
+                                throw new XServicesFault("Job not found.");
+                        Trigger t = scheduler.getTrigger(new TriggerKey(uuid));
+                        scheduler.deleteJob(key);
+                } catch (SchedulerException e) {
+                        throw new XServicesFault(e);
+                }
+        }
+        public String scheduleJob(ScheduledJob job) throws XServicesFault {
+                try {
+                        // Grab the Scheduler instance from the Factory
+                        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
+                        // and start it off
+                        if (!scheduler.isStarted())
+                                scheduler.start();
+                        if (scheduler.isInStandbyMode())
+                                scheduler.resumeAll();
+                        String identity = UUID.randomUUID().toString();
+                        //String identity = "test";
+                        JobDetail job2 = JobBuilder.newJob(JobWrapper.class)
+                                        .withIdentity(identity).build();
+                        job2.getJobDataMap().put("script", job.getScript());
+                        job2.getJobDataMap().put("description", job.getDescription());
+                        job2.getJobDataMap().put("date", job.getDate());
+                        SimpleTrigger t = (SimpleTrigger) newTrigger()
+                                        .withIdentity(identity).startAt(job.getDate().getTime())
+                                        .build();
+                        ;
+                        scheduler.scheduleJob(job2, t);
+                        return identity;
+                } catch (SchedulerException e) {
+                        e.printStackTrace();
+                        throw new XServicesFault(e);
+                }
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/ws/impl/MiscServiceImpl.java
 ,0 → 1,156
+/*
+ *   Copyright 2010 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.xservices.ws.impl;
+import java.util.Enumeration;
+import java.util.Properties;
+import javax.jws.WebService;
+import net.brutex.xservices.types.FileSetResource;
+import net.brutex.xservices.types.HostConnection;
+import net.brutex.xservices.types.MailMimeType;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.RunTask;
+import net.brutex.xservices.ws.MiscService;
+import org.apache.cxf.annotations.WSDLDocumentation;
+import org.apache.cxf.annotations.WSDLDocumentationCollection;
+import org.apache.tools.ant.taskdefs.HostInfo;
+import org.apache.tools.ant.taskdefs.Sleep;
+import org.apache.tools.ant.taskdefs.email.EmailTask;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@WSDLDocumentationCollection({
+                @WSDLDocumentation("My portType documentation"),
+                @WSDLDocumentation(value = "My top level documentation", placement = WSDLDocumentation.Placement.TOP),
+                @WSDLDocumentation(value = "My binding doc", placement = WSDLDocumentation.Placement.BINDING) })
+@WebService(
+                targetNamespace = BrutexNamespaces.WS_XSERVICES,
+                endpointInterface = "net.brutex.xservices.ws.MiscService",
+                serviceName = "MiscService"
+                        )
+public class MiscServiceImpl implements MiscService {
+        @WSDLDocumentation(value = "Get information about a host.")
+        public ReturnCode getHostinfo(String hostname) {
+                return antGetHostinfo(hostname, null);
+        }
+        @WSDLDocumentation(value = "Get XService information.")
+        public ReturnCode getInfo() {
+                ReturnCode r = new ReturnCode();
+                r.returnCode = 0;
+                // Get all system properties
+                Properties props = System.getProperties();
+                // Enumerate all system properties
+                Enumeration<String> e = (Enumeration<String>) props.propertyNames();
+                for (; e.hasMoreElements(); ) {
+                    // Get property name
+                    String propName = (String)e.nextElement();
+                    // Get property value
+                    String propValue = (String)props.get(propName);
+                    r.stdOut = r.stdOut + propName + ": " + propValue + "\n";
+                }
+                return r;
+        }
+        public ReturnCode sendMailSimple(HostConnection mailhost, String from,
+                        String tolist, String subject, String message) {
+                return sendMail(from, from, tolist, "", "", subject, message,
+                                "text/plain", null, mailhost.hostname, mailhost.port,
+                                mailhost.user, mailhost.password, "utf-8", false, false);
+        }
+        public ReturnCode sendMailSimpleWithAttachment(HostConnection mailhost,
+                        String from, String tolist, String subject, String message,
+                        FileSetResource res) {
+                return sendMail(from, from, tolist, "", "", subject, message,
+                                "text/plain", res, mailhost.hostname, mailhost.port,
+                                mailhost.user, mailhost.password, "utf-8", false, false);
+        }
+        public ReturnCode sendMail(HostConnection mailhost, String from,
+                        String tolist, String cclist, String bcclist, String subject,
+                        MailMimeType mimetype, String charset, String message,
+                        FileSetResource res, boolean ssl, boolean tls) {
+                return sendMail(from, from, tolist, cclist, bcclist, subject, message,
+                                mimetype.value(), res, mailhost.hostname, mailhost.port,
+                                mailhost.user, mailhost.password, charset, tls, ssl);
+        }
+        public ReturnCode sleep(int minutes, int seconds) {
+                return sleep(0, minutes, seconds, 0);
+        }
+        private ReturnCode antGetHostinfo(String hostname, String prefix) {
+                HostInfo info = new HostInfo();
+                info.setTaskName("HostInfo");
+                RunTask runner = new RunTask(info);
+                info.setHost(hostname);
+                // info.setPrefix(prefix);
+                return runner.postTask();
+        }
+        private ReturnCode sendMail(String from, String replyto, String tolist,
+                        String cclist, String bcclist, String subject, String message,
+                        String messagemimetype, FileSetResource attachments,
+                        String mailhost, int mailport, String user, String password,
+                        String charset, boolean tls, boolean ssl) {
+                EmailTask mail = new EmailTask();
+                mail.setTaskName("Mail");
+                RunTask runner = new RunTask(mail);
+                mail.setFrom(from);
+                mail.setReplyTo(replyto);
+                mail.setToList(tolist);
+                mail.setCcList(cclist);
+                mail.setBccList(bcclist);
+                mail.setSubject(subject);
+                mail.setMessage(message);
+                mail.setMessageMimeType(messagemimetype);
+                if (attachments != null) {
+                        mail.addFileset(attachments.getAntResource(mail.getProject()));
+                }
+                mail.setMailhost(mailhost);
+                mail.setMailport(mailport);
+                mail.setUser(user);
+                mail.setPassword(password);
+                mail.setCharset(charset);
+                mail.setSSL(ssl);
+                mail.setEnableStartTLS(tls);
+                return runner.postTask();
+        }
+        private ReturnCode sleep(int hours, int minutes, int seconds,
+                        int milliseconds) {
+                Sleep sleep = new Sleep();
+                sleep.setTaskName("Sleep");
+                RunTask runner = new RunTask(sleep);
+                sleep.setHours(hours);
+                sleep.setMinutes(minutes);
+                sleep.setSeconds(seconds);
+                sleep.setMilliseconds(milliseconds);
+                return runner.postTask();
+        }
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/DateService.java
 ,0 → 1,232
+/*
+ *   Copyright 2011 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.xservices.ws;
+import java.math.BigInteger;
+import java.util.GregorianCalendar;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import javax.xml.bind.annotation.XmlElement;
+import net.brutex.xservices.types.DateFormatType;
+import net.brutex.xservices.types.DateTimeUnits;
+import net.brutex.xservices.util.BrutexNamespaces;
+import org.apache.cxf.annotations.WSDLDocumentation;
+import org.apache.cxf.annotations.WSDLDocumentationCollection;
+/**
+ * Date and time related services.
+ * @author Brian Rosenberger
+ *
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+@WSDLDocumentationCollection(
+    {
+        @WSDLDocumentation(value = BrutexNamespaces.BRUTEX_COPYRIGHT, placement = WSDLDocumentation.Placement.TOP)
+    }
+)
+public interface DateService {
+        public static final String SERVICE_NAME = "DateService";
+        final String OPERATION_GETDATE = "getDate";
+        final String OPERATION_GETTIMESTAMP = "getTimestamp";
+        final String OPERATION_GETTIMESTAMP2 = "getTimestamp2";
+        final String OPERATION_GETINTIMEZONE = "getInTimezone";
+        final String OPERATION_FORMATDATE = "formatDate";
+        final String OPERATION_FORMATDATEADVANCED = "formatDateAdvanced";
+        final String OPERATION_PARSEDATE = "parseDate";
+        final String OPERATION_PARSEDATEADVANCED = "parseDateAdvanced";
+        final String OPERATION_DATETIMEDIFF = "dateTimeDiff";
+        final String OPERATION_DATETIMEDIFF2 = "dateTimeDiff2";
+        final String OPERATION_DATEADD = "dateAdd";
+        final String PARAM_TIMEZONE = "timezone";
+        final String PARAM_DATETIME = "datetime";
+        final String PARAM_FORMAT = "format";
+        final String PARAM_UNIT = "unit";
+        /**
+         * Get current date and time.
+         *
+         * @param timezone Optional timezone. Defaults to server timezone.
+         * @return Current date and time.
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_GETDATE)
+        @WSDLDocumentation(value="Get current date and time.")
+        public abstract GregorianCalendar getDate(
+                        @WebParam(name=PARAM_TIMEZONE) String timezone) throws XServicesFault;
+        /**
+         * Get milliseconds since 01.01.1970.
+         *
+         * @return timestamp milliseconds
+         */
+        @WebMethod(operationName=OPERATION_GETTIMESTAMP)
+        @WSDLDocumentation(value="Get milliseconds since 01.01.1970 (Unix timestap).")
+        public abstract BigInteger getTimestamp();
+        /**
+         * Get seconds since 01.01.1970.
+         *
+         * @return timestamp seconds
+         */
+        @WebMethod(operationName=OPERATION_GETTIMESTAMP2)
+        @WSDLDocumentation(value="Get seconds since 01.01.1970 (Unix timestap).")
+        public abstract BigInteger getTimestamp2();
+        /**
+         * Display a date time with a different time zone.
+         * Changes representation only (no conversion).
+         *
+         * @param cal date time.
+         * @param timezone time zone
+         * @return date time
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_GETINTIMEZONE)
+        public abstract GregorianCalendar getInTimezone(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) GregorianCalendar cal,
+                        @WebParam(name=PARAM_TIMEZONE) @XmlElement(required=true) String timezone) throws XServicesFault;
+        /**
+         * Formats a date with pre-defined patterns.
+         *
+         * @param cal date time to be formatted
+         * @param format Pattern to be used for date formating
+         * @return formatted date/time string
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_FORMATDATE)
+        public abstract String formatDate(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) GregorianCalendar cal,
+                        @WebParam(name=PARAM_FORMAT) @XmlElement(required=true) DateFormatType format) throws XServicesFault;
+        /**
+         * Formats a date with a free form pattern.
+         * Uses SimpleDateFormat patterns
+         * The following pattern letters are defined (all other characters from 'A' to 'Z' and from 'a' to 'z' are reserved):
+    Letter      Date or Time Component  Presentation    Examples
+    G   Era designator  Text    AD
+    y   Year    Year    1996; 96
+    M   Month in year   Month   July; Jul; 07
+    w   Week in year    Number  27
+    W   Week in month   Number  2
+    D   Day in year     Number  189
+    d   Day in month    Number  10
+    F   Day of week in month    Number  2
+    E   Day in week     Text    Tuesday; Tue
+    a   Am/pm marker    Text    PM
+    H   Hour in day (0-23)      Number  0
+    k   Hour in day (1-24)      Number  24
+    K   Hour in am/pm (0-11)    Number  0
+    h   Hour in am/pm (1-12)    Number  12
+    m   Minute in hour  Number  30
+    s   Second in minute        Number  55
+    S   Millisecond     Number  978
+    z   Time zone       General time zone       Pacific Standard Time; PST; GMT-08:00
+    Z   Time zone       RFC 822 time zone       -0800
+         * @param cal Date time to be formatted
+         * @param format Format string
+         * @return Date time formatted according to format string
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_FORMATDATEADVANCED)
+        public abstract String formatDateAdvanced(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) GregorianCalendar cal,
+                        @WebParam(name=PARAM_FORMAT) @XmlElement(required=true) String format) throws XServicesFault;
+        /**
+         * Converts a string into date using pre-defined date formats.
+         *
+         * @param s Date/ time as string
+         * @param format date format
+         * @param timezone timezone
+         * @return XML Date
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_PARSEDATE)
+        public abstract GregorianCalendar parseDate(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) String s,
+                        @WebParam(name=PARAM_FORMAT) @XmlElement(required=true) DateFormatType format,
+                        @WebParam(name=PARAM_TIMEZONE) String timezone) throws XServicesFault;
+        /**
+         * Converts a string into date using any format.
+         * @param s date/ time as string
+         * @param format date format
+         * @param timezone timezone
+         * @return XML Date
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_PARSEDATEADVANCED)
+        public abstract GregorianCalendar parseDateAdvanced(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) String s,
+                        @WebParam(name=PARAM_FORMAT) @XmlElement(required=true) String format,
+                        @WebParam(name=PARAM_TIMEZONE) String timezone) throws XServicesFault;
+        /**
+         * Calculate elapsed time between two dates.
+         * @param fromCal First date.
+         * @param toCal Second date.
+         * @return Elapsed time in milliseconds
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_DATETIMEDIFF)
+        public abstract BigInteger dateTimeDiff(
+                        @WebParam(name="fromDateTime") @XmlElement(required=true) GregorianCalendar fromCal,
+                        @WebParam(name="toDateTime") @XmlElement(required=true) GregorianCalendar toCal) throws XServicesFault;
+        /**
+         * Fully elapsed units between two dates.
+         * 4:15:10-4:15:55 in minutes = 0 and in seconds = 45
+         *
+         * @param fromCal
+         * @param toCal
+         * @param unit
+         * @return Date/time difference in unit
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_DATETIMEDIFF2)
+        @WSDLDocumentation(value="Get elapsed time between to dates.")
+        public abstract BigInteger dateTimeDiff2(
+                        @WebParam(name="fromDateTime") @XmlElement(required=true) GregorianCalendar fromCal,
+                        @WebParam(name="toDateTime") @XmlElement(required=true) GregorianCalendar toCal,
+                        @WebParam(name="PARAM_UNIT") DateTimeUnits unit) throws XServicesFault;
+        /**
+         * Add or subtract a time span from a date.
+         *
+         * @param cal The initial date.
+         * @param value The amount to add.
+         * @param unit The unit the amount is defined in.
+         * @return New date and time.
+         * @throws XServicesFault
+         *
+         */
+        @WebMethod(operationName=OPERATION_DATEADD)
+        @WSDLDocumentation(value="Add or substract a time span from a date.")
+        public abstract GregorianCalendar dateAdd(
+                        @WebParam(name=PARAM_DATETIME) @XmlElement(required=true) GregorianCalendar cal,
+                        @WebParam(name="value") @XmlElement(required=true) BigInteger value,
+                        @WebParam(name=PARAM_UNIT) @XmlElement(required=true) DateTimeUnits unit) throws XServicesFault;
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/ws/FileService.java
 ,0 → 1,253
+/*
+ *   Copyright 2010 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.xservices.ws;
+import java.util.List;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import javax.xml.bind.annotation.XmlElement;
+import org.apache.cxf.annotations.WSDLDocumentation;
+import org.apache.cxf.annotations.WSDLDocumentationCollection;
+import net.brutex.xservices.types.ArchiveResource;
+import net.brutex.xservices.types.AttachmentType;
+import net.brutex.xservices.types.FileResource;
+import net.brutex.xservices.types.FileSetResource;
+import net.brutex.xservices.types.ReplacePattern;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import net.brutex.xservices.util.XServicesDocumentation;
+/**
+ * File related web service operations.
+ *
+ * @author Brian Rosenberger
+ * @since 0.3.0
+ *
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+@WSDLDocumentationCollection(
+    {
+        @WSDLDocumentation(value = BrutexNamespaces.BRUTEX_COPYRIGHT, placement = WSDLDocumentation.Placement.TOP)
+    }
+)
+public interface FileService {
+        final String OPERATION_BASENAME ="basename";
+        final String OPERATION_DOWNLOADFILE ="downloadFile";
+        final String OPERATION_UPLOADFILE ="uploadFile";
+        final String OPERATION_COPY ="copy";
+        final String OPERATION_COPYFILE ="copyFile";
+        final String OPERATION_LOADRESOURCE = "loadResource";
+        final String OPERATION_LOADRESOURCEFROMARCHIVE = "loadResourceFromArchive";
+        final String OPERATION_ECHOTOFILE = "echoToFile";
+        final String OPERATION_CHANGEOWNER = "changeOwner";
+        final String OPERATION_CHANGEMODE = "changeMode";
+        final String OPERATION_CHANGEGROUP = "changeGroup";
+        final String OPERATION_REPLACEINFILE = "replaceInFile";
+        final String OPERATION_REPLACEINFILE2 = "replaceInFile2";
+        final String OPERATION_REPLACEINFILEREGEX = "replaceInFileRegEx";
+        final String PARAM_FILE = "file";
+        final String PARAM_ENCODING = "encoding";
+        final String PARAM_OVERRIDE = "override";
+        /**
+         * @param filename
+         * @param suffix
+         * @return The base name of the given file excluding the suffix.
+         */
+        @WSDLDocumentation(value = "The base name of the given file excluding the suffix.")
+        @WebMethod(operationName = OPERATION_BASENAME)
+        public abstract String basename(
+                        @WebParam(name = PARAM_FILE) @XmlElement(required=true) String filename,
+                        @WebParam(name = "suffix") String suffix);
+        /**
+         * @param res
+         * @return The file itself (MTOM attachment or inline base64) including some file metadata.
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(XServicesDocumentation.SERVICE_OPERATION_DOWNLOADFILE)
+        @WebMethod(operationName = OPERATION_DOWNLOADFILE)
+        public abstract AttachmentType downloadFile(
+                        @WebParam(name = FileResource.XML_NAME) FileResource res) throws XServicesFault;
+        /**
+         * @param file
+         * @return The file name of the file that has been uploaded.
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(XServicesDocumentation.SERVICE_OPERATION_UPLOADFILE)
+        @WebMethod(operationName = OPERATION_UPLOADFILE)
+        public abstract String uploadFile(
+                        @WebParam(name = PARAM_FILE) AttachmentType file) throws XServicesFault;
+        /**
+         * @param src
+         * @param todir
+         * @param plm
+         * @param overwrite
+         * @param encoding
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_COPY)
+        @WebMethod(operationName = OPERATION_COPY)
+        public abstract ReturnCode copy(
+                        @WebParam(name =  FileSetResource.XML_NAME) @XmlElement(required=true) FileSetResource src,
+                        @WebParam(name = "todir") @XmlElement(required=true) String todir,
+                        @WebParam(name = "preservelastmodified") boolean plm,
+                        @WebParam(name = PARAM_OVERRIDE) boolean overwrite,
+                        @WebParam(name = PARAM_ENCODING) String encoding) throws XServicesFault;
+        /**
+         * @param fromFile
+         * @param tofile
+         * @param overwrite
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_COPYFILE)
+        @WebMethod(operationName = OPERATION_COPYFILE)
+        public abstract ReturnCode copyFile(
+                        @WebParam(name = "fromFile") @XmlElement(required=true) String fromFile,
+                        @WebParam(name = "toFile") @XmlElement(required=true) String tofile,
+                        @WebParam(name = PARAM_OVERRIDE) boolean overwrite) throws XServicesFault;
+        /**
+         * @param res
+         * @param encoding
+         * @return content of the resource
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_LOADRESOURCE)
+        @WebMethod(operationName = OPERATION_LOADRESOURCE)
+        public abstract String loadRes(
+                        @WebParam(name = FileResource.XML_NAME) FileResource res,
+                        @WebParam(name = PARAM_ENCODING) String encoding) throws XServicesFault;
+        /**
+         * @param res
+         * @param encoding
+         * @return content of the resource
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_LOADRESOURCEFROMARCHIVE)
+        @WebMethod(operationName = OPERATION_LOADRESOURCEFROMARCHIVE)
+        public abstract String loadResFromArchive(
+                        @WebParam(name = "archiveresource") ArchiveResource res,
+                        @WebParam(name = PARAM_ENCODING) String encoding) throws XServicesFault;
+        /**
+         * @param message
+         * @param file
+         * @param encoding
+         * @param append
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_ECHOTOFILE)
+        @WebMethod(operationName = OPERATION_ECHOTOFILE)
+        public abstract ReturnCode echo2file(
+                        @WebParam(name = "message") @XmlElement(required=true) String message,
+                        @WebParam(name = PARAM_FILE) @XmlElement(required=true) String file,
+                        @WebParam(name = PARAM_ENCODING) String encoding,
+                        @WebParam(name = "append") boolean append) throws XServicesFault;
+        /**
+         * Changes the owner of a file or all files inside specified directories.
+         * Right now it has effect only under Unix/ Linux as it is implemented through
+         * the 'chown' command.
+         *
+         * @param res Collection of files/ directories
+         * @param owner Identifier of the new owner
+         * @return
+         */
+        @WebMethod(operationName = OPERATION_CHANGEOWNER)
+        public abstract ReturnCode changeOwner(
+                        @WebParam(name =  FileSetResource.XML_NAME) FileSetResource res,
+                        @WebParam(name = "owner") @XmlElement(required=true) String owner);
+        /**
+         * Changes the group owner of a file or all files inside specified directories.
+         * Right now it has effect only under Unix/ Linux as it is implemented through
+         * the 'chgrp' command.
+         *
+         * @param res Collection of files/ directories
+         * @param group Identifier of the new group owner
+         * @return
+         */
+        @WebMethod(operationName = OPERATION_CHANGEGROUP)
+        public abstract ReturnCode changeGroup(
+                        @WebParam(name =  FileSetResource.XML_NAME) FileSetResource res,
+                        @WebParam(name = "group") @XmlElement(required=true) String group);
+        /**
+         * @param res
+         * @param perm
+         * @return
+         */
+        @WebMethod(operationName = OPERATION_CHANGEMODE)
+        public abstract ReturnCode changeMode(
+                        @WebParam(name = FileSetResource.XML_NAME) FileSetResource res,
+                        @WebParam(name = "permissions") @XmlElement(required=true) String perm);
+        /**
+         * @param res
+         * @param search
+         * @param replace
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_REPLACEINFILE)
+        @WebMethod(operationName = OPERATION_REPLACEINFILE)
+        public abstract ReturnCode replaceInFile(
+                        @WebParam(name = FileResource.XML_NAME) @XmlElement(required=true) FileResource res,
+                        @WebParam(name = "search") @XmlElement(required=true) String search,
+                        @WebParam(name = "replace") @XmlElement(required=true) String replace) throws XServicesFault;
+        /**
+         * @param res
+         * @param patternList
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_REPLACEINFILE2)
+        @WebMethod(operationName = OPERATION_REPLACEINFILE2)
+        public abstract ReturnCode replaceInFile2(
+                        @WebParam(name = FileResource.XML_NAME) FileResource res,
+                        @WebParam(name = "patternList") List<ReplacePattern> patternList) throws XServicesFault;
+        /**
+         * @param res
+         * @param search
+         * @param replace
+         * @param flags
+         * @return
+         * @throws XServicesFault
+         */
+        @WSDLDocumentation(value = XServicesDocumentation.SERVICE_OPERATION_REPLACEINFILEREGEX)
+        @WebMethod(operationName = OPERATION_REPLACEINFILEREGEX)
+        public abstract ReturnCode replaceInFileRegEx(
+                        @WebParam(name = FileResource.XML_NAME) FileResource res,
+                        @WebParam(name = "search") String search,
+                        @WebParam(name = "replace") String replace,
+                        @WebParam(name = "flags") String flags) throws XServicesFault;
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/ExecuteService.java
 ,0 → 1,145
+/*
+ *   Copyright 2011 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.xservices.ws;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import javax.xml.bind.annotation.XmlElement;
+import net.brutex.xservices.types.HostConnection;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+/**
+ * Task execution web service
+ *
+ * @author Brian Rosenberger
+ * @since 0.1.0
+ *
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+public interface ExecuteService {
+        /**
+         * @param cmd
+         * @param args
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "runCommand")
+        public abstract ReturnCode runCommand(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "argline") String args,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param cmd
+         * @param args
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "runCommandWithArgs")
+        public abstract ReturnCode runCommandWithArgs(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "arg") String[] args,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param cmd
+         * @param args
+         * @return
+         */
+        @WebMethod(operationName = "runCommandAsync")
+        public abstract ReturnCode runCommandAsync(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "argline") String args);
+        /**
+         * @param cmd
+         * @param args
+         * @return
+         */
+        @WebMethod(operationName = "runCommandAsyncWithArgs")
+        public abstract ReturnCode runCommandAsyncWithArgs(
+                        @WebParam(name = "executable") String cmd,
+                        @WebParam(name = "arg") String[] args);
+        /**
+         * @param host
+         * @param cmd
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "runCommandWithSSH")
+        public abstract ReturnCode runCommandWithSSH(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param host
+         * @param keyfile
+         * @param cmd
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "runCommandWithSSHKeyAuth")
+        public abstract ReturnCode runCommandWithSSHKeyAuth(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "keyfile") String keyfile,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param host
+         * @param cmd
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "rExec")
+        public abstract ReturnCode rExec(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param host
+         * @param prompt
+         * @param cmd
+         * @param expect
+         * @param timeout
+         * @return
+         */
+        @WebMethod(operationName = "telnet")
+        public abstract ReturnCode runTelnet(
+                        @WebParam(name = "host") HostConnection host,
+                        @WebParam(name = "prompt") String prompt,
+                        @WebParam(name = "command") String cmd,
+                        @WebParam(name = "expect") String expect,
+                        @WebParam(name = "timeout") long timeout);
+        /**
+         * @param script
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName = "runJavaScript")
+        public abstract void runJScript(
+                        @WebParam(name = "script") @XmlElement(required=true) String script) throws XServicesFault;
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/JobService.java
 ,0 → 1,102
+/*
+ *   Copyright 2011 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.xservices.ws;
+import java.math.BigInteger;
+import java.util.GregorianCalendar;
+import java.util.List;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import javax.xml.bind.annotation.XmlElement;
+import net.brutex.xservices.types.DateFormatType;
+import net.brutex.xservices.types.DateTimeUnits;
+import net.brutex.xservices.types.ScheduledJob;
+import net.brutex.xservices.util.BrutexNamespaces;
+import org.apache.cxf.annotations.WSDLDocumentation;
+import org.apache.cxf.annotations.WSDLDocumentationCollection;
+/**
+ * Job management services.
+ * @author Brian Rosenberger
+ * @since 0.5.0
+ *
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+public interface JobService {
+        public static final String SERVICE_NAME = "JobService";
+        final String OPERATION_GETJOBLIST = "getJobs";
+        final String OPERATION_SCHEDULEJOB = "scheduleJob";
+        final String OPERATION_GETJOB = "getJob";
+        final String OPERATION_DELETEJOB = "deleteJob";
+        final String PARAM_JOB = "job";
+        /**
+         * Get a full list of all scheduled jobs.
+         *
+         * @return List of scheduled jobs
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_GETJOBLIST)
+        @WSDLDocumentation(value="Get list of scheduled jobs")
+        public abstract List<ScheduledJob> getJobList() throws XServicesFault;
+        /**
+         * Add a job to the scheduler.
+         *
+         * @param job
+         * @return The unique identifier of the job.
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_SCHEDULEJOB)
+        @WSDLDocumentation(value="Schedule a job")
+        public abstract String scheduleJob(
+                        @WebParam(name=PARAM_JOB) @XmlElement(required=true) ScheduledJob job)
+                        throws XServicesFault;
+        /**
+         * Get a job by id.
+         *
+         * @param uuid
+         * @return Job details
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_GETJOB)
+        @WSDLDocumentation(value="Get a job by id")
+        public abstract ScheduledJob getJob(
+                        @WebParam(name="id") @XmlElement(required=true) String uuid) throws XServicesFault;
+        /**
+         * Delete a job from scheduler.
+         *
+         * @param uuid Id of the job that should be deleted
+         * @throws XServicesFault
+         */
+        @WebMethod(operationName=OPERATION_DELETEJOB)
+        @WSDLDocumentation(value="Delete a scheduled job.")
+        public abstract void deleteJob(
+                        @WebParam(name="id") @XmlElement(required=true) String uuid) throws XServicesFault;
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/ws/MiscService.java
 ,0 → 1,123
+/*
+ *   Copyright 2010 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.xservices.ws;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import net.brutex.xservices.types.FileSetResource;
+import net.brutex.xservices.types.HostConnection;
+import net.brutex.xservices.types.MailMimeType;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+import org.apache.cxf.annotations.WSDLDocumentation;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ * @since 0.4.0
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+public interface MiscService {
+    /**
+     * @param hostname
+     * @return
+     */
+    @WebMethod(operationName = "getHostinfo")
+    public ReturnCode getHostinfo(@WebParam(name = "hostname") String hostname);
+    /**
+     *
+     * @param mailhost
+     * @param from
+     * @param tolist
+     * @param subject
+     * @param message
+     * @return
+     */
+    @WebMethod(operationName = "sendMailSimple")
+    public ReturnCode sendMailSimple(@WebParam(name = "mailhost") HostConnection mailhost,
+            @WebParam(name = "from") String from,
+            @WebParam(name = "to") String tolist,
+            @WebParam(name = "subject") String subject,
+            @WebParam(name = "message") String message);
+    /**
+     *
+     * @param mailhost
+     * @param from
+     * @param tolist
+     * @param subject
+     * @param message
+     * @param res
+     * @return
+     */
+    @WebMethod(operationName = "sendMailSimpleWithAttachment")
+    public ReturnCode sendMailSimpleWithAttachment(@WebParam(name = "mailhost") HostConnection mailhost,
+            @WebParam(name = "from") String from,
+            @WebParam(name = "to") String tolist,
+            @WebParam(name = "subject") String subject,
+            @WebParam(name = "message") String message,
+            @WebParam(name = "attachments") FileSetResource res);
+    /**
+     *
+     * @param mailhost
+     * @param from
+     * @param tolist
+     * @param cclist
+     * @param bcclist
+     * @param subject
+     * @param mimetype
+     * @param charset
+     * @param message
+     * @param res
+     * @param ssl
+     * @param tls
+     * @return
+     */
+    @WebMethod(operationName = "sendMail")
+    public ReturnCode sendMail(@WebParam(name = "mailhost") HostConnection mailhost,
+            @WebParam(name = "from") String from,
+            @WebParam(name = "to") String tolist,
+            @WebParam(name = "cc") String cclist,
+            @WebParam(name = "bcc") String bcclist,
+            @WebParam(name = "subject") String subject,
+            @WebParam(name = "mimetype") MailMimeType mimetype,
+            @WebParam(name = "charset") String charset,
+            @WebParam(name = "message") String message,
+            @WebParam(name = "attachments") FileSetResource res,
+            @WebParam(name = "useSSL") boolean ssl,
+            @WebParam(name = "useStartTLS") boolean tls);
+    /**
+     *
+     * @param minutes
+     * @param seconds
+     * @return
+     */
+    @WebMethod(operationName = "sleep")
+    public ReturnCode sleep(@WebParam(name = "minutes") int minutes,
+            @WebParam(name = "seconds") int seconds);
+    @WebMethod(operationName = "getInfo")
+    public ReturnCode getInfo();
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/ArchiveService.java
 ,0 → 1,205
+/*
+ *   Copyright 2010 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.xservices.ws;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebService;
+import net.brutex.xservices.types.ArchiveResource;
+import net.brutex.xservices.types.CompressionType;
+import net.brutex.xservices.types.FileResource;
+import net.brutex.xservices.types.FileSetResource;
+import net.brutex.xservices.types.ReturnCode;
+import net.brutex.xservices.util.BrutexNamespaces;
+/**
+ * Archiving related web service.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ * @since 0.4.0
+ */
+@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES)
+public interface ArchiveService {
+    final String WS_OPERATION_BZIP2 = "bzip2";
+    final String WS_OPERATION_BZIP2_ARCHIVE = "bzip2FromArchive";
+    final String WS_OPERATION_GZIP = "gzip";
+    final String WS_OPERATION_GZIP_ARCHIVE = "gzipFromArchive";
+    final String WS_OPERATION_UNZIP = "unzip";
+    final String WS_OPERATION_GUNZIP = "gunzip";
+    final String WS_OPERATION_BUNZIP2 = "bunzip2";
+    final String WS_PARAM_SOURCEFILE = "source";
+    final String WS_PARAM_SOURCEFILE_STRING = "srcfile";
+    final String WS_PARAM_SOURCEURL = "srcurl";
+    final String WS_PARAM_SOURCEARCHIVE = "archivesource";
+    final String WS_PARAM_DESTFILE = "destfile";
+    final String WS_PARAM_DESTDIR = "destdir";
+    final String WS_PARAM_ENCODING = "encoding";
+    final String WS_PARAM_OVERWRITE = "overwrite";
+    final String WS_PARAM_COMPRESS = "compresslevel";
+    /**
+     * @param src
+     * @param file
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_BZIP2, action = WS_OPERATION_BZIP2)
+    public ReturnCode bzip2(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) throws XServicesFault;
+    /**
+     * @param src
+     * @param file
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_BZIP2_ARCHIVE, action = WS_OPERATION_BZIP2_ARCHIVE)
+    public ReturnCode bzip2FromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) throws XServicesFault;
+    /**
+     * @param src
+     * @param file
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_GZIP, action = WS_OPERATION_GZIP)
+    public ReturnCode gzip(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) throws XServicesFault;
+    /**
+     * @param src
+     * @param file
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_GZIP_ARCHIVE, action = WS_OPERATION_GZIP_ARCHIVE)
+    public ReturnCode gzipFromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_GUNZIP, action = WS_OPERATION_GUNZIP)
+    public ReturnCode gunzip(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = WS_OPERATION_BUNZIP2)
+    public ReturnCode bunzip2(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "gunzipFromURL")
+    public ReturnCode gunzipFromURL(@WebParam(name = WS_PARAM_SOURCEURL) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "bunzip2FromURL")
+    public ReturnCode bunzip2FromURL(@WebParam(name = WS_PARAM_SOURCEURL) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) throws XServicesFault;
+    /**
+     * @param src
+     * @param file
+     * @param overwrite
+     * @param encoding
+     * @param level
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "zip")
+    public ReturnCode zip(@WebParam(name = WS_PARAM_SOURCEFILE) FileResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding,
+            @WebParam(name = WS_PARAM_COMPRESS) int level) throws XServicesFault;
+    /**
+     * @param src
+     * @param file
+     * @param update
+     * @param encoding
+     * @param level
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "zipFromArchive")
+    public ReturnCode zipFromArchive(@WebParam(name = WS_PARAM_SOURCEARCHIVE) ArchiveResource src,
+            @WebParam(name = WS_PARAM_DESTFILE) String file,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean update,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding,
+            @WebParam(name = "compresslevel") int level) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @param overwrite
+     * @param encoding
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "unzip")
+    public ReturnCode unzip(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = WS_PARAM_ENCODING) String encoding) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "unrar")
+    public ReturnCode unrar(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest) throws XServicesFault;
+    /**
+     * @param src
+     * @param dest
+     * @param overwrite
+     * @param compression
+     * @return
+     * @throws XServicesFault
+     */
+    @WebMethod(operationName = "untar")
+    public ReturnCode untar(@WebParam(name = WS_PARAM_SOURCEFILE_STRING) String src,
+            @WebParam(name = WS_PARAM_DESTDIR) String dest,
+            @WebParam(name = WS_PARAM_OVERWRITE) boolean overwrite,
+            @WebParam(name = "compression") CompressionType compression) throws XServicesFault;
+}

 /xservices/trunk/src/java/net/brutex/xservices/ws/XServicesFault.java
 ,0 → 1,97
+/*
+ *   Copyright 2010 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.xservices.ws;
+import java.util.GregorianCalendar;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlRootElement;
+import javax.xml.bind.annotation.XmlType;
+import javax.xml.datatype.DatatypeConfigurationException;
+import javax.xml.datatype.DatatypeFactory;
+import javax.xml.datatype.XMLGregorianCalendar;
+import javax.xml.ws.WebFault;
+import net.brutex.xservices.util.BrutexNamespaces;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@WebFault(targetNamespace=BrutexNamespaces.WS_XSERVICES)
+public class XServicesFault extends Exception {
+    /**
+         *
+         */
+        private static final long serialVersionUID = -6779279189376374820L;
+        public XServicesFault(String message, Exception e) {
+        this(message, e.getCause());
+    }
+    public XServicesFault(String string) {
+        this(string, new Exception(string).getCause());
+    }
+    public XServicesFault(Exception e) {
+        this(e.getMessage(), e.getCause());
+    }
+    public XServicesFault(String message, Throwable cause) {
+        super(message, cause);
+        this.faultstring=message;
+        try {
+            timestamp = DatatypeFactory.newInstance().newXMLGregorianCalendar(new GregorianCalendar());
+        } catch (DatatypeConfigurationException ex) {
+            System.err.println(ex.getMessage());
+        }
+    }
+    /**
+     * The error message.
+     */
+    @XmlElement(name="faultstring", namespace=BrutexNamespaces.WS_XSERVICES)
+    public String faultstring = "";
+    /**
+     * Username under which the web service has been executed.
+     */
+    @XmlElement(name="username", namespace=BrutexNamespaces.WS_XSERVICES)
+    public String username = System.getProperty("user.name");
+    /**
+     * Home directory of the user profile running the web service.
+     */
+    @XmlElement(name="homedir", namespace=BrutexNamespaces.WS_XSERVICES)
+    public String homedir = System.getProperty("user.home");
+    /**
+     * Timestamp when the fault was thrown.
+     */
+    @XmlElement(name="timstamp", namespace=BrutexNamespaces.WS_XSERVICES)
+    public XMLGregorianCalendar timestamp = null;
+    /**
+     * Java runtime version.
+     */
+    @XmlElement(name="jvmversion")
+    public String jvmruntime = System.getProperty("java.version");
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ReturnCode.java
 ,0 → 1,91
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.util.List;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlType;
+import net.brutex.xservices.util.BrutexNamespaces;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType(namespace=BrutexNamespaces.WS_XSERVICES, name="ReturnCodeType")
+public class ReturnCode {
+    /**
+     * Numeric return code.
+     *
+     * The numeric return code of the last operation on the underlying operation
+     * systen (OS). In general the return code indicates the failure or success
+     * of a command. Which value indicates success is dependent on the OS, most
+     * linux based systems use "0" for success.
+     */
+    @XmlElement(required=true, nillable=false)
+    public int returnCode=0;
+    /**
+     * Standard Out as provided by the OS.
+     *
+     * The stdOut given by the last operation (if any).
+     */
+    @XmlElement(name="stdOut", nillable=false)
+    public String stdOut="";
+    /**
+     * The Standard Error as provided by the OS.
+     *
+     * The stdErr given by the last operation (if any). The presents of any
+     * value here ususally indicates that a failure has occured.
+     */
+    @XmlElement(name="stdErr", nillable=false)
+    public String stdErr="";
+    @XmlElement(name="propertyList", nillable=true)
+    public List<AntProperty> property = null;
+    /**
+     * Create a new ReturnCode default constructor.
+     */
+    public ReturnCode() {
+    }
+    /**
+     * Create a new ReturnCode.
+     *
+     * @param returnCode    return code integer value
+     * @param stdOut        standard out string
+     * @param stdErr        standard error string
+     */
+    public ReturnCode(int returnCode, String stdOut, String stdErr, List<AntProperty> props) {
+        this.returnCode = returnCode;
+        this.stdOut = stdOut;
+        this.stdErr = stdErr;
+        this.property = props;
+    }
+    public String getProperty(String key) {
+        for(AntProperty prop : this.property) {
+                if(prop.equals(key)) return prop.value;
+        }
+        return null;
+    }
+    public String getStdOut() { return this.stdOut; }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ScheduledJob.java
 ,0 → 1,135
+/*
+ *   Copyright 2011 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.xservices.types;
+import java.util.GregorianCalendar;
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlType;
+import net.brutex.xservices.util.BrutexNamespaces;
+/**
+ * Scheduled job type
+ *
+ * @author Brian Rosenberger
+ * @since 0.5.0
+ *
+ */
+@XmlType(namespace=BrutexNamespaces.WS_XSERVICES)
+@XmlAccessorType(XmlAccessType.FIELD)
+public class ScheduledJob {
+        @XmlElement(required=true,name="name")
+        private String name;
+        @XmlElement(required=false, name="description")
+        private String description;
+        @XmlElement(required=true, name="datetime")
+        private GregorianCalendar date;
+        @XmlElement(name="script")
+        private String script;
+        /**
+         * Create a new scheduled job.
+         *
+         * @param name Job name.
+         * @param datetime Scheduled date and time.
+         * @param script The script to execute.
+         */
+        public ScheduledJob(String name, GregorianCalendar datetime, String script) {
+                this.name = name;
+                this.date = datetime;
+                this.script = script;
+                this.description = null;
+        }
+        /**
+         * Create a new scheduled job.
+         *
+         * @param name Job name.
+         * @param datetime Scheduled date and time.
+         * @param script The script to execute.
+         * @param description Job description.
+         */
+        public ScheduledJob(String name, GregorianCalendar datetime, String script, String description) {
+                this.name = name;
+                this.date = datetime;
+                this.script = script;
+                this.description = description;
+        }
+        /**
+         * Create a new scheduled job.
+         */
+        public ScheduledJob() {
+                this.name = null;
+                this.date=null;
+                this.script=null;
+        }
+        /**
+         * Set name of the job.
+         * @param name
+         */
+        public void setName(String name) {
+                this.name = name;
+        }
+        /**
+         * Get name of the job.
+         * @return job name
+         */
+        public String getName() {
+                return name;
+        }
+        /**
+         * Set scheduled date.
+         * @param date
+         */
+        public void setDate(GregorianCalendar date) {
+                this.date = date;
+        }
+        /**
+         * get scheduled date.
+         * @return date
+         */
+        public GregorianCalendar getDate() {
+                return date;
+        }
+        public void setScript(String script) {
+                this.script = script;
+        }
+        public String getScript() {
+                return script;
+        }
+        public void setDescription(String desc) {
+                this.description = desc;
+        }
+        public String getDescription() {
+                return description;
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/DateTimeUnits.java
 ,0 → 1,71
+/*
+ *   Copyright 2011 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.xservices.types;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlEnumValue;
+/**
+ * Different pre-defined date formats.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlEnum(value = String.class)
+public enum DateTimeUnits {
+    /**
+     * milliseconds
+     */
+    @XmlEnumValue("milliseconds")
+    MILLISECONDS("milliseconds"),
+    /**
+     * seconds
+     */
+    @XmlEnumValue("seconds")
+    SECONDS("seconds"),
+    /**
+     * minutes
+     */
+    @XmlEnumValue("minutes")
+    MINUTES("minutes"),
+    /**
+     * hours
+     */
+    @XmlEnumValue("hours")
+    HOURS("hours"),
+    /**
+     * days
+     */
+    @XmlEnumValue("days")
+    DAYS("days");
+    private String value;
+    DateTimeUnits(String value) {
+        this.value = value;
+    }
+    /**
+     * Return the value of the enum.
+     * @return  String representation of the mime type
+     */
+    public String value() {
+        return value;
+    }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/DateFormatType.java
 ,0 → 1,65
+/*
+ *   Copyright 2011 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.xservices.types;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlEnumValue;
+/**
+ * Different pre-defined date formats.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlEnum(value = String.class)
+public enum DateFormatType {
+    /**
+     * ISO 8601 format (2011-05-24T14:39Z)
+     */
+    @XmlEnumValue("ISO 8601")
+    ISO8601("ISO 8601", "yyyy-MM-dd'T'HH:mm:ssZ"),
+    /**
+     * yyyy/mm/dd
+     */
+    @XmlEnumValue("yyyy/mm/dd")
+    YYYYMMDD("yyyy/mm/dd", "yyyy/MM/dd"),
+    /**
+     * dd.mm.yyyy
+     */
+    @XmlEnumValue("dd.mm.yyyy")
+    DDMMYY("dd.mm.yyyy", "dd.MM.yyyy");
+    private String value;
+    private String format;
+    DateFormatType(String value, String format) {
+        this.value = value;
+        this.format = format;
+    }
+    /**
+     * Return the value of the enum.
+     * @return  String representation of the mime type
+     */
+    public String value() {
+        return value;
+    }
+    public String format() {
+        return format;
+    }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/FileSetResource.java
 ,0 → 1,132
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.io.File;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlType;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.types.FileSet;
+import org.apache.tools.ant.types.Resource;
+import org.apache.tools.ant.types.TarFileSet;
+import org.apache.tools.ant.types.ZipFileSet;
+/**
+ * Set of files from various sources.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType(name = "FileSetType", namespace = "http://ws.xservices.brutex.net",
+propOrder = {"type", "source", "filter", "excludes", "casesensitive"})
+public class FileSetResource implements ResourceSetInterface {
+        public static final String XML_NAME = "fileset";
+    /**
+     * Type of FileSet
+     */
+    @XmlElement(name = "FileSetType", required = true, nillable = false, defaultValue = "FILES")
+    public FileSetType type = FileSetType.FILES;
+    /**
+     * File set source.
+     *
+     * Depends on the file set type. This is either an archive file or a
+     * directory.
+     */
+    @XmlElement(name = "source", required = true, nillable = false)
+    public String source = "";
+    /**
+     * Pattern of files to include.
+     *
+     */
+    @XmlElement(name = PatternSetType.XML_NAME, required = true, nillable = true)
+    public PatternSetType filter;
+    /**
+     * Pattern of files to exclude.
+     */
+    @XmlElement(name = "excludes", required = false, nillable = true, defaultValue = "")
+    public String excludes = "";
+    /**
+     * Case sensitivity for include/ exclude patterns.
+     */
+    @XmlElement(name = "casesensitive", required = true, nillable = false, defaultValue = "true")
+    public boolean casesensitive = true;
+    /**
+     * Get Ant FileSet for this file set.
+     *
+     * @param p     Ant project
+     * @return      Ant FileSet for this file set.
+     */
+    public FileSet getAntResource(Project p) {
+        FileSet set = null;
+        switch (type) {
+            case ZIP:
+                ZipFileSet zset = new ZipFileSet();
+                zset.setSrc(new File(source));
+                zset.setEncoding(System.getProperty("file.encoding"));
+                set = zset;
+                break;
+            case TAR:
+                TarFileSet tset = new TarFileSet();
+                tset.setSrc(new File(source));
+                set = tset;
+                break;
+            case GZTAR:
+                Resource res = new FileResource(FileResource.Type.GZIP, source).getAntResource(p);
+                TarFileSet gzset = new TarFileSet();
+                gzset.setSrcResource(res);
+                set = gzset;
+                break;
+            default: //FILES
+                set = new FileSet();
+                set.setDir(new File(source));
+        }
+        set.setProject(p);
+        //set.setIncludes(includes);
+        set.setExcludes(excludes);
+        set.setCaseSensitive(casesensitive);
+        return set;
+    }
+    /**
+     * File set types.
+     */
+    @XmlEnum()
+    @XmlType(name="resourcetype")
+    public enum FileSetType {
+        /**
+         * Set of files (this is based on a directory, so provide a path only
+         * as file set source).
+         */
+        FILES,
+        /**
+         * Set of files inside a ZIP archive.
+         */
+        ZIP,
+        /**
+         * Set of files inside a TAR archive (without compression).
+         */
+        TAR,
+        /**
+         * Set of files inside a gzip compressed TAR archive.
+         */
+        GZTAR
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/FileResource.java
 ,0 → 1,139
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.io.File;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlType;
+import net.brutex.xservices.util.BrutexNamespaces;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.types.Resource;
+import org.apache.tools.ant.types.resources.BZip2Resource;
+import org.apache.tools.ant.types.resources.GZipResource;
+import org.apache.tools.ant.types.resources.URLResource;
+/**
+ * File based resource declaration.
+ *
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType(name="FileResourceType", namespace=BrutexNamespaces.WS_XSERVICES)
+public class FileResource
+implements ResourceInterface {
+        public static final String XML_NAME = "file";
+    /**
+     * File resource type.
+     */
+    @XmlElement(defaultValue = "FILE", nillable = false, required = true)
+    public Type type = Type.FILE;
+    /**
+     * URI to file.
+     *
+     * Examples:<br>
+     * <code>c:/path/to/myfile.txt<br>
+     * /usr/share/file<br>
+     * http://server/path/file.zip</code>
+     */
+    @XmlElement(nillable = false, required = true)
+    public String uri;
+    /**
+     * File resource type.
+     *
+     * Defines the wrapper around the source.
+     */
+    @XmlEnum(value=String.class)
+    public enum Type {
+        /**
+         * Plain file from OS accessible file system.
+         */
+        FILE,
+        /**
+         * File from URL (http, https, ftp, ...)
+         */
+        URL,
+        /**
+         * File from file system with on-the-fly GZIP decompression
+         */
+        GZIP,
+        /**
+         * File from file system with on-the-fly BZIP2 decompression
+         */
+        BZIP2
+    }
+    /**
+     * Creates a FileResource.
+     *
+     * @param type      file resource type
+     * @param uri       file resource uri
+     */
+    public FileResource(Type type, String uri) {
+        this.type = type;
+        this.uri = uri;
+    }
+    /**
+     * Create an empty FileResource
+     */
+    public FileResource() {
+    }
+    /**
+     * Get Apache Ant Resource type.
+     *
+     * @param p     Ant project
+     * @return      This FileResource as Ant Resource
+     */
+    public Resource getAntResource(Project p) {
+        Resource res = null;
+        switch (type) {
+            case URL:
+                URLResource ures = new URLResource(uri);
+                res = ures;
+                break;
+            case GZIP:
+                GZipResource gres = new GZipResource(
+                        new org.apache.tools.ant.types.resources.FileResource(new File(uri)));
+                res = gres;
+                break;
+            case BZIP2:
+                BZip2Resource bres = new BZip2Resource(
+                        new org.apache.tools.ant.types.resources.FileResource(new File(uri)));
+                res = bres;
+                break;
+            default:
+                //Default is Type FILE
+                res = new org.apache.tools.ant.types.resources.FileResource(new File(uri));
+        }
+        res.setProject(p);
+        return res;
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ReplacePattern.java
 ,0 → 1,75
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlRootElement;
+/**
+ * Generic key/ value pairs.
+ *
+ * @author Brian Rosenberger
+ */
+@XmlRootElement
+public class ReplacePattern {
+    /**
+     * Search string.
+     */
+    @XmlElement(required=true)
+    public String search ="";
+    /**
+     * Replace string.
+     */
+    @XmlElement(required=true)
+    public String replace="";
+    /**
+     * Converts a Map&lt;String, String&gt; into a list of
+     * ReplacePattern.
+     * @param map   The map to convert
+     * @return      A list of key/value pairs
+     */
+    public static List<ReplacePattern> createAntPropertyList(Map<String, String> map) {
+        List<ReplacePattern> list = new ArrayList<ReplacePattern>();
+        for(Map.Entry<String, String> e : map.entrySet()) {
+            list.add(new ReplacePattern(e.getKey(), e.getValue()));
+        }
+        return list;
+    }
+    /**
+     * Creates a new ReplacePattern.
+     * @param name
+     * @param value
+     */
+    public ReplacePattern(String search, String replace) {
+        this.search = search;
+        this.replace = replace;
+    }
+    /**
+     * Creates a new ReplacePattern.
+     */
+    public ReplacePattern() {
+    }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/SelectorTypeInterface.java
 ,0 → 1,27
+/*
+ *   Copyright 2011 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.xservices.types;
+import org.apache.tools.ant.types.selectors.FileSelector;
+/**
+ *
+ * @author Brian Rosenberger
+ */
+public interface SelectorTypeInterface {
+        public FileSelector getSelector();
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ResourceInterface.java
 ,0 → 1,37
+/*
+ *   Copyright 2010 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.xservices.types;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.types.Resource;
+/**
+ * Wrapper for a single file like Ant Resources.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public interface ResourceInterface {
+    /**
+     * Get this resource as Ant Resource.
+     *
+     * @param p     Ant project
+     * @return      this resource as Ant Resource
+     */
+    Resource getAntResource(Project p);
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ResourceSetInterface.java
 ,0 → 1,35
+/*
+ *   Copyright 2011 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.
+ */
+/**
+ * Wrapper for Ant Resource Sets. A resource set
+ * is simply a collection of resources.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+package net.brutex.xservices.types;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.types.ResourceCollection;
+/**
+ * Wrapper for Ant Resource Collection.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public interface ResourceSetInterface {
+        public ResourceCollection getAntResource(Project p);
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/AttachmentType.java
 ,0 → 1,57
+/*
+ *   Copyright 2011 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.xservices.types;
+import java.io.File;
+import java.io.IOException;
+import javax.activation.DataHandler;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlMimeType;
+public class AttachmentType {
+        private DataHandler content;
+        private String filename = null;
+        public void setContent(DataHandler content) {
+                this.content = content;
+        }
+        @XmlMimeType("application/octet-stream")
+        @XmlElement(required=true)
+        public DataHandler getContent() {
+                return content;
+        }
+        public String getFilename() {
+                if(filename==null || filename.equals("")) {
+                        try {
+                                filename = File.createTempFile("XServices_", ".tmp").getPath();
+                        } catch (IOException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
+                }
+                return filename;
+        }
+        public void setFilename(String filename) {
+                this.filename = filename;
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/types/HostConnection.java
 ,0 → 1,44
+/*
+ *   Copyright 2010 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.xservices.types;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlType;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType(name="connection")
+public class HostConnection {
+    public HostConnection() {
+    }
+    @XmlElement(name="hostname", required=true, nillable=false)
+    public String hostname;
+    @XmlElement(name="port", required=false, nillable=false)
+    public int port;
+    @XmlElement(name="user", required=false, nillable=false)
+    public String user;
+    @XmlElement(name="password", required=false, nillable=false)
+    public String password;
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ArchiveResource.java
 ,0 → 1,122
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.io.File;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlType;
+import net.brutex.xservices.util.BrutexNamespaces;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.types.Resource;
+import org.apache.tools.ant.types.resources.TarResource;
+import org.apache.tools.ant.types.resources.ZipResource;
+import org.apache.tools.tar.TarEntry;
+import org.apache.tools.zip.ZipEntry;
+/**
+ * Resource from archive declaration.
+ *
+ * Defines a resource within an archive.
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType(namespace = BrutexNamespaces.WS_XSERVICES, name="ArchiveResourceType")
+public class ArchiveResource
+        implements ResourceInterface {
+    /**
+     * Archive Type.
+     */
+    @XmlElement(defaultValue = "ZIP", nillable = false, required = true)
+    public ArchiveType type = ArchiveType.ZIP;
+    /**
+     * Archive file.
+     *
+     * Path and filename of the archive to use.
+     */
+    @XmlElement(nillable = false, required = true)
+    public String archive;
+    /**
+     * URI within the archive.
+     *
+     * This is usually a filename or a path/filename combination. Relative paths
+     * are based from the archive root. It depends on how the archive has been
+     * created whether or not it is possible to use relative paths, absolute
+     * paths are required otherwise. Uses "/" as separator.
+     */
+    @XmlElement(nillable = false, required = true)
+    public String uri;
+    /**
+     * Supported archive types.
+     */
+    @XmlEnum(value=String.class)
+    public enum ArchiveType {
+        /**
+         * Zip archive type.
+         */
+        ZIP,
+        /**
+         * Tar archive type, without compression
+         */
+        TAR,
+        /**
+         * Tar archive type, with GZIP compression
+         */
+        GZTAR
+    }
+    /**
+     * Get Apache Ant Resource Type.
+     *
+     * @param p     Ant project
+     * @return      this ArchiveResource as Ant Resource
+     */
+    public Resource getAntResource(Project p) {
+        Resource res = null;
+        switch (type) {
+            case TAR:
+                TarEntry tarentry = new TarEntry(uri);
+                TarResource tres = new TarResource(new File(archive), tarentry);
+                res = tres;
+                break;
+            case GZTAR:
+                TarResource gres = new TarResource(new org.apache.tools.ant.types.resources.GZipResource(
+                        new org.apache.tools.ant.types.resources.FileResource(
+                        new File(archive))), new TarEntry(uri));
+                res = gres;
+                break;
+            default: //This is type ZIP also
+                ZipEntry zipentry = new ZipEntry(uri);
+                if (zipentry.getTime() == -1) {
+                    zipentry.setTime(System.currentTimeMillis());
+                }
+                res = new ZipResource(new File(archive), null, zipentry);
+                break;
+        }
+        res.setProject(p);
+        return res;
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/ContainsSelectorType.java
 ,0 → 1,53
+/*
+ *   Copyright 2010 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.xservices.types;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlType;
+import org.apache.tools.ant.types.selectors.ContainsSelector;
+import org.apache.tools.ant.types.selectors.FileSelector;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlType
+public class ContainsSelectorType implements SelectorTypeInterface {
+    public static final String XML_NAME="contains";
+    public ContainsSelectorType() {
+    }
+    public FileSelector getSelector() {
+        ContainsSelector selector = new ContainsSelector();
+        selector.setCasesensitive(casesensitive);
+        selector.setText(text);
+        selector.setIgnorewhitespace(ignorewhitespace);
+        return selector;
+    }
+   @XmlElement(required=true, nillable=false)
+   public String text;
+   @XmlElement(required=true, defaultValue="true")
+   public boolean casesensitive;
+   @XmlElement(required=true, defaultValue="false")
+   public boolean ignorewhitespace;
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/SelectorType.java
 ,0 → 1,36
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.util.List;
+import javax.xml.bind.annotation.XmlElement;
+import org.apache.tools.ant.types.selectors.FileSelector;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public abstract class SelectorType implements SelectorTypeInterface {
+    public SelectorType() {
+    }
+    @XmlElement(name=ContainsSelectorType.XML_NAME, nillable=true)
+    public List<ContainsSelectorType> contains;
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/PatternElement.java
 ,0 → 1,20
+/*
+ * To change this template, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package net.brutex.xservices.types;
+import javax.xml.bind.annotation.XmlType;
+import javax.xml.bind.annotation.XmlValue;
+/**
+ *
+ * @author brian
+ */
+@XmlType()
+public class PatternElement {
+    @XmlValue()
+    public String pattern;
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/PatternSetType.java
 ,0 → 1,41
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.util.List;
+import javax.xml.bind.annotation.XmlElement;
+/**
+ *
+ * @author Brian Rosenberger
+ */
+public class PatternSetType {
+    public static final String XML_NAME = "filter";
+    @XmlElement(required=false, nillable=false, defaultValue="**/*")
+    public List<PatternElement> include;
+    @XmlElement(required=false, nillable=false)
+    public List<PatternElement> exclude;
+    @XmlElement(required=false, nillable=true)
+    public SelectorType selector;
+    public PatternSetType() {
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/AntProperty.java
 ,0 → 1,75
+/*
+ *   Copyright 2010 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.xservices.types;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlRootElement;
+/**
+ * Generic key/ value pairs.
+ *
+ * @author Brian Rosenberger
+ */
+@XmlRootElement
+public class AntProperty {
+    /**
+     * Key of the entry.
+     */
+    @XmlElement(required=true)
+    public String name ="";
+    /**
+     * Value of the entry.
+     */
+    @XmlElement(required=true)
+    public String value="";
+    /**
+     * Converts a Map&lt;String, String&gt; into a list of
+     * AntProperties.
+     * @param map   The map to convert
+     * @return      A list of key/value pairs
+     */
+    public static List<AntProperty> createAntPropertyList(Map<String, String> map) {
+        List<AntProperty> list = new ArrayList<AntProperty>();
+        for(Map.Entry<String, String> e : map.entrySet()) {
+            list.add(new AntProperty(e.getKey(), e.getValue()));
+        }
+        return list;
+    }
+    /**
+     * Creates a new AntProperty.
+     * @param name
+     * @param value
+     */
+    public AntProperty(String name, String value) {
+        this.name = name;
+        this.value = value;
+    }
+    /**
+     * Creates a new AntProperty.
+     */
+    public AntProperty() {
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/MailMimeType.java
 ,0 → 1,54
+/*
+ *   Copyright 2010 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.xservices.types;
+import javax.xml.bind.annotation.XmlEnum;
+import javax.xml.bind.annotation.XmlEnumValue;
+/**
+ * MIME types for email messages.
+ * This type restricts the mime types to be used within the
+ * email body.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlEnum(value = String.class)
+public enum MailMimeType {
+    /**
+     * Plain text.
+     */
+    @XmlEnumValue("text/plain")
+    PLAIN("text/plain"),
+    /**
+     * HTML
+     */
+    @XmlEnumValue("text/html")
+    HTML("text/html");
+    private String value;
+    MailMimeType(String value) {
+        this.value = value;
+    }
+    /**
+     * Return the value of the enum.
+     * @return  String representation of the mime type
+     */
+    public String value() {
+        return value;
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/types/CompressionType.java
 ,0 → 1,28
+/*
+ *   Copyright 2010 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.xservices.types;
+import javax.xml.bind.annotation.XmlEnum;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+@XmlEnum()
+public enum CompressionType {
+    NONE, GZIP, BZIP2
+}

 /xservices/trunk/src/java/net/brutex/xservices/util/BrutexQuartzConnectionProvider.java
 ,0 → 1,181
+/*
+ *   Copyright 2011 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.xservices.util;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.List;
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+import org.quartz.utils.ConnectionProvider;
+/**
+ * @author Brian Rosenberger
+ *
+ */
+public class BrutexQuartzConnectionProvider implements ConnectionProvider {
+        private Connection conn = null;
+        private final Logger logger = Logger.getLogger(this.getClass().getCanonicalName());
+        public Connection getConnection() throws SQLException {
+                if( conn!= null && conn.isValid(5)) {
+                        logger.debug("Checking tables on pre-exisiting database connection.");
+                        checkTables();
+                        return conn;
+                }
+                try {
+                        // Class.forName("org.hsqldb.jdbc.JDBCDriver" );
+                        Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
+                } catch (Exception e) {
+                        logger.fatal("Failed to load Derby JDBC driver.");
+                        e.printStackTrace();
+                        return null;
+                }
+                if(isConnected(false)) {
+                        checkTables();
+                } else {
+                        return null;
+                }
+                return conn;
+        }
+        public void shutdown() throws SQLException {
+                try {
+                        // Class.forName("org.hsqldb.jdbc.JDBCDriver" );
+                        Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
+                } catch (Exception e) {
+                        System.err.println("ERROR: failed to load Derby JDBC driver.");
+                        e.printStackTrace();
+                        return;
+                }
+                String t = this.getClass().getClassLoader().getResource("/").toString()
+                                .substring(6);
+                t += "../data/db";
+                System.out.println("Shut down embedded database now.");
+                Connection c = DriverManager.getConnection("jdbc:derby:" + t
+                                + ";shutdown=true;");
+        }
+        private synchronized void recursiveDelete(File dbDir) {
+                File[] files = dbDir.listFiles();
+                for (int i = 0; i < files.length; i++) {
+                        if (files[i].isFile()) {
+                                files[i].delete();
+                        } else {
+                                recursiveDelete(files[i]);
+                                files[i].delete();
+                        }
+                }
+                dbDir.delete();
+        }
+        private synchronized void checkTables() throws SQLException {
+                logger.debug("Checking QUARTZ database schema.");
+                if(!isConnected(false)) {
+                        logger.error("Failed to validate QUARTZ database schema.");
+                        return;
+                }
+                List<String> ddl_list = new ArrayList<String>(11);
+                ddl_list.add("QRTZ_JOB_DETAILS");
+                ddl_list.add("QRTZ_TRIGGERS");
+                ddl_list.add("QRTZ_SIMPLE_TRIGGERS");
+                ddl_list.add("QRTZ_CRON_TRIGGERS");
+                ddl_list.add("QRTZ_SIMPROP_TRIGGERS");
+                ddl_list.add("QRTZ_BLOB_TRIGGERS");
+                ddl_list.add("QRTZ_CALENDARS");
+                ddl_list.add("QRTZ_PAUSED_TRIGGER_GRPS");
+                ddl_list.add("QRTZ_FIRED_TRIGGERS");
+                ddl_list.add("QRTZ_SCHEDULER_STATE");
+                ddl_list.add("QRTZ_LOCKS");
+                String ddl = this.getClass().getClassLoader().getResource("/").toString()
+                .substring(6)+ "../data/";
+                DatabaseMetaData dmd = conn.getMetaData();
+                for (String tbl : ddl_list) {
+                        ResultSet rs = dmd.getTables(null, "APP", tbl, null);
+                        if (!rs.next()) {
+                                logger.log(Level.INFO, "Adding DDL for table "+ tbl);
+                                Statement st = conn.createStatement();
+                                File ddlFile = new File(ddl + tbl + ".ddl");
+                                String create = "";
+                                try {
+                                                BufferedReader r = new BufferedReader(new FileReader(ddlFile));
+                                                while (r.ready()) {
+                                                        create += r.readLine() + "\n";
+                                                }
+                                                create.trim();
+                                                if( st.execute(create)) {
+                                                        logger.log(Level.INFO, "Table " + tbl + " created.");
+                                                }
+                                        } catch (FileNotFoundException ex) {
+                                                ex.printStackTrace();
+                                        } catch (IOException ex) {
+                                                ex.printStackTrace();
+                                        } catch (SQLException ex) {
+                                                logger.log(Level.ERROR, "Error executing statement "+ create );
+                                                System.out.println(ex.getMessage());
+                                        }
+                                } else {
+                                        logger.trace("Table "+tbl+" exists.");
+                                }
+                        }
+                }
+        private synchronized boolean isConnected(boolean fail) throws SQLException {
+                if(conn!=null && conn.isValid(5)) {
+                        return true;
+                } else {
+                        String t = this.getClass().getClassLoader().getResource("/").toString().substring(6); // WEB-INF/classes
+                        t += "../data/db";
+                        logger.debug("Database directory is set to '" + t + "'");
+                        try {
+                                this.conn = DriverManager.getConnection("jdbc:derby:" + t + ";create=true;");
+                        } catch (SQLException ex) {
+                                logger.error(ex.getMessage(), ex);
+                                if(!fail) {
+                                        logger.warn("Deleting database directory.");
+                                        recursiveDelete(new File(t));
+                                        logger.warn("Retrying to connect to database.");
+                                        return isConnected(true);
+                                } else {
+                                        return false;
+                                }
+                        }
+                }
+                return false;
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/util/JobWrapper.java
 ,0 → 1,96
+/*
+ *   Copyright 2011 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.xservices.util;
+import java.io.Serializable;
+import java.util.Date;
+import org.mozilla.javascript.Context;
+import org.mozilla.javascript.Scriptable;
+import org.quartz.Job;
+import org.quartz.JobDataMap;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+/**
+ * Wrapper for jobs that can be executed through quartz scheduler.
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ * @since 0.5.0
+ *
+ */
+public class JobWrapper implements Job, Serializable {
+        public void execute(JobExecutionContext jcontext)
+        throws JobExecutionException {
+                try {
+                        System.out.println("Executing scheduled job '"+jcontext.getJobDetail().getKey().getName()+"' at " + new Date());
+                        JobDataMap jdMap = jcontext.getJobDetail().getJobDataMap();
+                        String script = jdMap.getString("script");
+                        // Create and enter a Context. A Context stores information about
+                        // the execution environment of a script.
+                        Context cx = Context.enter();
+                        cx.setOptimizationLevel(0);
+                        cx.setLanguageVersion(Context.VERSION_1_7);
+                        // cx is the Context instance you're using to run scripts
+                        /*
+                         * cx.setClassShutter(new ClassShutter() { public boolean
+                         * visibleToScripts(String className) {
+                         * if(className.startsWith("adapter")) return true;
+                         * if(className.startsWith("java.lang.System") ||
+                         * className.startsWith
+                         * ("org.apache.tomcat.util.log.SystemLogHandler")) return true;
+                         * System.out.println(className + " is blocked."); return false; }
+                         * });
+                         */
+                        // Initialise the standard objects (Object, Function, etc.). This
+                        // must be done before scripts can be
+                        // executed. The null parameter tells initStandardObjects
+                        // to create and return a scope object that we use
+                        // in later calls.
+                        Scriptable scope = cx.initStandardObjects();
+                        //Object wrappedOut = Context.javaToJS(System.out, scope);
+                        //Object wrappedOut2 = Context.javaToJS(this, scope);
+                        //scope.put("out", scope, wrappedOut);
+                        //scope.put("exe", scope, wrappedOut2);
+                        // Execute the script
+                        // cx.evaluateString(scope, "importClass('java.lang.System');\n",
+                        // "head", 1, null);
+                        // cx.evaluateString(scope, "importPackage('java.util');\n", "head",
+                        // 2, null);
+                        Object obj = cx
+                                        .evaluateString(scope, script, "TestScript", 1, null);
+                } catch (Exception e) {
+                        System.out.println(e.getMessage());
+                } finally {
+                        // Exit the Context. This removes the association between the
+                        // Context and the current thread and is an
+                        // essential cleanup action. There should be a call to exit for
+                        // every call to enter.
+                        Context.exit();
+                }
+        }
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/util/XServicesDocumentation.java
 ,0 → 1,71
+/*
+ *   Copyright 2011 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.xservices.util;
+/**
+ * Holds static documentation.
+ *
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public class XServicesDocumentation {
+    public static final String BRUTEX_COPYRIGHT = "" +
+        "/*\n" +
+        "*   Copyright 2010 Brian Rosenberger (Brutex Network)\n" +
+        "*\n" +
+        "*   Licensed under the Apache License, Version 2.0 (the \"License\")\n" +
+        "*   you may not use this file except in compliance with the License.\n" +
+        "*   You may obtain a copy of the License at\n" +
+        "*\n" +
+        "*       http://www.apache.org/licenses/LICENSE-2.0\n" +
+        "*\n" +
+        "*   Unless required by applicable law or agreed to in writing, software\n" +
+        "*   distributed under the License is distributed on an \"AS IS\" BASIS,\n" +
+        "*   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n" +
+        "*   See the License for the specific language governing permissions and\n" +
+        "*   limitations under the License.\n" +
+        "*/";
+    public static final String SERVICE_OPERATION_DOWNLOADFILE = "Download a file from the maschine where the service is running in order " +
+        "to process it with the client. The file is either downloaded as a MTOM attachment or " +
+        "as inline base64 encoded block. Keep in mind that unless you are using MTOM, a lot of " +
+        "java heap memory is used.";
+    public static final String SERVICE_OPERATION_UPLOADFILE = "Send a file from client to web service server using either " +
+    "MTOM attachment or base64 inline attachment.";
+    public static final String SERVICE_OPERATION_COPY = "Copies a fileset locally on the server.";
+    public static final String SERVICE_OPERATION_COPYFILE = "Copies a single file locally on the server";
+    public static final String SERVICE_OPERATION_LOADRESOURCE = "Load the content of a resource";
+    public static final String SERVICE_OPERATION_LOADRESOURCEFROMARCHIVE = "Load the content of a resource";
+    public static final String SERVICE_OPERATION_ECHOTOFILE = "Write or append a string to a file";
+    public static final String SERVICE_OPERATION_REPLACEINFILE = "Replaces every <pattern> with a string in an ascii file";
+    public static final String SERVICE_OPERATION_REPLACEINFILE2 = "Replaces every <pattern> with a string in an ascii file";
+    public static final String SERVICE_OPERATION_REPLACEINFILEREGEX = "Replaces every <regex pattern> with a string in an ascii file";
+    private XServicesDocumentation() {};
+}
 Property changes:
 Added: svn:mime-type
 +text/plain
 \ No newline at end of property

 /xservices/trunk/src/java/net/brutex/xservices/util/RunTask.java
 ,0 → 1,100
+/*
+ *   Copyright 2010 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.xservices.util;
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+import java.util.HashMap;
+import java.util.Map;
+import net.brutex.xservices.types.AntProperty;
+import net.brutex.xservices.types.ReturnCode;
+import org.apache.tools.ant.BuildException;
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.Target;
+import org.apache.tools.ant.Task;
+import org.apache.tools.ant.listener.TimestampedLogger;
+import org.apache.tools.ant.taskdefs.Echo;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public class RunTask {
+    Project antproject;
+    Target anttarget;
+    Task anttask;
+    ByteArrayOutputStream myout = new ByteArrayOutputStream();
+    ByteArrayOutputStream myerr = new ByteArrayOutputStream();
+    PrintStream out = new PrintStream(myout);
+    PrintStream err = new PrintStream(myerr);
+    TimestampedLogger log = null;
+    public RunTask(Task anttask) {
+        antproject = new Project();
+        antproject.init();
+        antproject.setBasedir(System.getProperty("java.io.tmpdir"));
+        log = new TimestampedLogger();
+        log.setOutputPrintStream(out);
+        log.setErrorPrintStream(err);
+        log.setMessageOutputLevel(Echo.EchoLevel.WARN.getLevel());
+        antproject.addBuildListener(log);
+        anttarget = new Target();
+        anttarget.setName("XBridgeNGDynamicTarget");
+        anttarget.setProject(antproject);
+        antproject.addTarget(anttarget);
+        this.anttask = anttask;
+        prepareTask();
+    }
+    private void prepareTask()
+            throws BuildException {
+        anttask.init();
+        anttask.setProject(antproject);
+        anttask.setOwningTarget(anttarget);
+        anttarget.addTask(anttask);
+        antproject.addOrReplaceTarget(anttarget);
+    }
+    /**
+     * @return ReturnCode type {@link ReturnCode}
+     * @throws BuildException
+     */
+    public ReturnCode postTask() throws BuildException {
+        int returnCode = 0;
+        Map<String, String> origMap = new HashMap<String, String>();
+        Map<String, String> newMap = null;
+        origMap.putAll(antproject.getProperties());
+        antproject.executeTarget(anttarget.getName());
+        newMap = antproject.getProperties();
+        newMap.putAll(antproject.getUserProperties());
+        for (Map.Entry<String, String> e : origMap.entrySet()) {
+            newMap.remove(e.getKey());
+        }
+        //anttask.execute();
+        return new ReturnCode(returnCode,
+                myout.toString(),
+                myerr.toString(),
+                AntProperty.createAntPropertyList(newMap));
+    }
+}

 /xservices/trunk/src/java/net/brutex/xservices/util/BrutexNamespaces.java
 ,0 → 1,54
+/*
+ *   Copyright 2010 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.xservices.util;
+/**
+ * Holds static namespace information.
+ *
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public class BrutexNamespaces {
+    /**
+     * Brutex Network XServices web service name space declaration
+     */
+    public static final String WS_XSERVICES = "http://ws.xservices.brutex.net";
+    /**
+     * Copyright and license agreement statement.
+     */
+    public static final String BRUTEX_COPYRIGHT = "" +
+        "/*\n" +
+        "*   Copyright 2010 Brian Rosenberger (Brutex Network)\n" +
+        "*\n" +
+        "*   Licensed under the Apache License, Version 2.0 (the \"License\")\n" +
+        "*   you may not use this file except in compliance with the License.\n" +
+        "*   You may obtain a copy of the License at\n" +
+        "*\n" +
+        "*       http://www.apache.org/licenses/LICENSE-2.0\n" +
+        "*\n" +
+        "*   Unless required by applicable law or agreed to in writing, software\n" +
+        "*   distributed under the License is distributed on an \"AS IS\" BASIS,\n" +
+        "*   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n" +
+        "*   See the License for the specific language governing permissions and\n" +
+        "*   limitations under the License.\n" +
+        "*/";
+    private BrutexNamespaces() {};
+}

 /xservices/trunk/src/java/net/brutex/xservices/util/UnRarTask.java
 ,0 → 1,74
+/*
+ *   Copyright 2010 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.xservices.util;
+import de.innosystec.unrar.Archive;
+import de.innosystec.unrar.exception.RarException;
+import de.innosystec.unrar.rarfile.FileHeader;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.List;
+import org.apache.tools.ant.BuildException;
+import org.apache.tools.ant.Task;
+/**
+ *
+ * @author Brian Rosenberger, bru@brutex.de
+ */
+public class UnRarTask extends Task {
+    private File dst = null;
+    private File src = null;
+    public File getDst() {
+        return dst;
+    }
+    public void setDst(File dst) {
+        this.dst = dst;
+    }
+    public File getSrc() {
+        return src;
+    }
+    public void setSrc(File src) {
+        this.src = src;
+    }
+    @Override
+    public void execute() {
+        if(src==null ) throw new BuildException("Please supply a source archive file.");
+        if(!src.exists()) throw new BuildException("Archive '"+src.getName()+"' does not exist.");
+        try {
+            if(dst==null) dst = new File(src.getParent());
+            Archive ar = new Archive(src);
+            List<FileHeader> list = ar.getFileHeaders();
+            for(FileHeader h : list) {
+                ar.extractFile(h, new FileOutputStream(new File(dst.getAbsolutePath()+"/"+h.getFileNameString())));
+            }
+        } catch (RarException ex) {
+            throw new BuildException(ex.getMessage(), ex);
+        } catch (IOException ex) {
+            throw new BuildException(ex.getMessage(), ex);
+        }
+    }
+}

Subversion Repositories XServices

Compare Revisions

Ignore whitespace Rev HEAD → Rev 71