Subversion Repositories XServices

/*
 *   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.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
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.AntProperty;
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.ResourceInterface;
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.commons.codec.binary.Base64;
import org.apache.commons.codec.binary.Base64InputStream;
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.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)
         */
        @Override
        @WebMethod(operationName = "basename")
        public ReturnCode basename(@WebParam(name = "file") String filename,
                        @WebParam(name = "suffix") String suffix) {
                return basename(new File(filename), suffix);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#base64Encode(net.brutex.xservices
         * .types.FileSetResource)
         */
        @Override
        @WebMethod(operationName = "downloadFile")
        public AttachmentType downloadFile(@WebParam(name = "file") FileResource res) {
                InputStream is = null;
                try {
                        is = res.getAntResource(null).getInputStream();
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                DataHandler h = new DataHandler(new StreamDataSource(
                                "application/binary", is));
                AttachmentType t = new AttachmentType();
                t.setContent(h);
                return t;
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#base64Decode(net.brutex.xservices
         * .types.AttachmentType)
         */
        @Override
        @WebMethod(operationName = "uploadFile")
        public String uploadFile(@WebParam(name = "file") AttachmentType file) {
                DataHandler h =  file.getContent();
                File f = new File(file.getFilename());
                FileOutputStream fout;
                try {
                        fout = new FileOutputStream(f);
                        /*
                         * InputStream in = h.getInputStream();
                        int b;
                        while( (b=in.read())!= -1 ) {
                                fout.write(b);
                        }
                        */
                        h.writeTo(fout);
                        fout.flush();
                        fout.close();
                        //in.close();
                } catch (FileNotFoundException e) {
                        throw new BuildException(e);
                } catch (IOException e) {
                        throw new BuildException(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)
         */
        @Override
        @WebMethod(operationName = "copy")
        public ReturnCode copy(@WebParam(name = "fileset") FileSetResource src,
                        @WebParam(name = "todir") String todir,
                        @WebParam(name = "preservelastmodified") boolean plm,
                        @WebParam(name = "overwrite") boolean overwrite,
                        @WebParam(name = "encoding") String encoding) throws XServicesFault {
                return copy(src, new File(todir), plm, overwrite, encoding);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#loadRes(net.brutex.xservices
         * .types.FileResource, java.lang.String)
         */
        @Override
        @WebMethod(operationName = "loadResource")
        public ReturnCode loadRes(@WebParam(name = "resource") FileResource res,
                        @WebParam(name = "encoding") String encoding) {
                if (encoding == null || encoding.equals("")) {
                        encoding = System.getProperty("file.encoding");
                }
                return loadResource(res, encoding);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#loadResFromArchive(net.brutex
         * .xservices.types.ArchiveResource, java.lang.String)
         */
        @Override
        @WebMethod(operationName = "loadResourceFromArchive")
        public ReturnCode loadResFromArchive(
                        @WebParam(name = "archiveresource") ArchiveResource res,
                        @WebParam(name = "encoding") String encoding) {
                if (encoding == null || encoding.equals("")) {
                        encoding = System.getProperty("file.encoding");
                }
                return loadResource(res, encoding);
        }

        /*
         * (non-Javadoc)
         * 
         * @see net.brutex.xservices.ws.impl.FileService#echo2file(java.lang.String,
         * java.lang.String, java.lang.String, boolean)
         */
        @Override
        @WebMethod(operationName = "echoToFile")
        public ReturnCode echo2file(@WebParam(name = "message") String message,
                        @WebParam(name = "file") String file,
                        @WebParam(name = "encoding") String encoding,
                        @WebParam(name = "append") boolean append) {
                return echo(message, new File(file), encoding, append);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#changeOwner(net.brutex.xservices
         * .types.FileSetResource, java.lang.String)
         */
        @Override
        @WebMethod(operationName = "changeOwner")
        public ReturnCode changeOwner(
                        @WebParam(name = "fileset") FileSetResource res,
                        @WebParam(name = "owner") String owner) {
                return chown(res, owner);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#changeGroup(net.brutex.xservices
         * .types.FileSetResource, java.lang.String)
         */
        @Override
        @WebMethod(operationName = "changeGroup")
        public ReturnCode changeGroup(
                        @WebParam(name = "fileset") FileSetResource res,
                        @WebParam(name = "group") String group) {
                return chgrp(res, group);
        }

        /*
         * (non-Javadoc)
         * 
         * @see
         * net.brutex.xservices.ws.impl.FileService#changeMode(net.brutex.xservices
         * .types.FileSetResource, java.lang.String)
         */
        @Override
        @WebMethod(operationName = "changeMode")
        public ReturnCode changeMode(
                        @WebParam(name = "fileset") FileSetResource res,
                        @WebParam(name = "permissions") String perm) {
                return chmod(res, perm);
        }

        @WebMethod(exclude = true)
        private ReturnCode basename(File file, String suffix) {
                Basename basename = new Basename();
                RunTask runner = new RunTask(basename);
                basename.setFile(file);
                if (suffix != null && !suffix.equals("")) {
                        basename.setSuffix(suffix);
                }
                basename.setProperty("basename.value");
                return runner.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode loadResource(ResourceInterface src, String encoding) {
                LoadResource lr = new LoadResource();
                lr.setTaskName("LoadResource");
                RunTask runner = new RunTask(lr);
                lr.addConfigured(src.getAntResource(lr.getProject()));
                lr.setEncoding(encoding);
                System.out.println("Using encoding: " + encoding);
                lr.setProperty("LoadResource.out");
                return runner.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode echo(String msg, File file, String encoding,
                        boolean append) {
                Echo echo = new Echo();
                echo.setTaskName("toFile");
                RunTask runTask = new RunTask(echo);
                echo.addText(msg);
                echo.setEncoding(encoding);
                echo.setFile(file);
                echo.setAppend(append);
                return runTask.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode copy(FileSetResource src, File dst,
                        boolean preservelastmodified, boolean overwrite, String encoding) {
                Copy copy = new Copy();
                copy.setTaskName("Copy");
                RunTask runner = new RunTask(copy);
                FileSet set = src.getAntResource(copy.getProject());
                copy.add(set);

                if (dst.isDirectory()) {
                        copy.setTodir(dst);
                }
                if (dst.isFile()) {
                        copy.setTofile(dst);
                }
                copy.setOverwrite(overwrite);
                copy.setPreserveLastModified(preservelastmodified);
                if (encoding != null && !encoding.equals("")) {
                        copy.setOutputEncoding(encoding);
                } else {
                        copy.setOutputEncoding(System.getProperty("file.encoding"));
                }

                return runner.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode chown(FileSetResource src, String owner) {
                Chown chown = new Chown();
                chown.setTaskName("Chown");
                RunTask runner = new RunTask(chown);
                chown.setOwner(owner);
                FileSet set = src.getAntResource(chown.getProject());
                chown.add(set);
                chown.setMaxParallel(300);
                return runner.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode chgrp(FileSetResource src, String group) {
                Chgrp chgrp = new Chgrp();
                chgrp.setTaskName("Chgrp");
                RunTask runner = new RunTask(chgrp);
                chgrp.setGroup(group);
                FileSet set = src.getAntResource(chgrp.getProject());
                chgrp.add(set);
                chgrp.setMaxParallel(300);
                return runner.postTask();
        }

        @WebMethod(exclude = true)
        private ReturnCode chmod(FileSetResource src, String perm) {
                Chmod chmod = new Chmod();
                chmod.setTaskName("Chmod");
                RunTask runner = new RunTask(chmod);
                FileSet set = src.getAntResource(chmod.getProject());
                chmod.add(set);
                chmod.setMaxParallel(300);
                chmod.setPerm(perm);
                chmod.setVerbose(true);
                return runner.postTask();
        }

}