WebSVN – XServices – Diff – /xservices/trunk/src/java/net/brutex/xservices/ws/impl/FileServiceImpl.java


/*
 *   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.ByteArrayOutputStream;
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.ReplacePattern;
import net.brutex.xservices.types.ReturnCode;
import net.brutex.xservices.types.ant.ArchiveResource;
import net.brutex.xservices.types.ant.AttachmentType;
import net.brutex.xservices.types.ant.FileResource;
import net.brutex.xservices.types.ant.FileSetResource;
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);
		}
	}
	
	public byte[] encodeFile(FileResource res) throws XServicesFault {
		InputStream is = null;
		try {
			is = res.getAntResource(null).getInputStream();
		
		ByteArrayOutputStream buffer = new ByteArrayOutputStream();
 
		int nRead;
		byte[] data = new byte[4096];
		while ((nRead = is.read(data, 0, data.length)) != -1) {
		  buffer.write(data, 0, nRead);
		}
		buffer.flush();
		return buffer.toByteArray();
		
		} 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();
	}
 
}

Rev 83	Rev 92
1	`/*`	1	`/*`
2	`* Copyright 2010 Brian Rosenberger (Brutex Network)`	2	`* Copyright 2010 Brian Rosenberger (Brutex Network)`
3	`*`	3	`*`
4	`* Licensed under the Apache License, Version 2.0 (the "License");`	4	`* Licensed under the Apache License, Version 2.0 (the "License");`
5	`* you may not use this file except in compliance with the License.`	5	`* you may not use this file except in compliance with the License.`
6	`* You may obtain a copy of the License at`	6	`* You may obtain a copy of the License at`
7	`*`	7	`*`
8	`* http://www.apache.org/licenses/LICENSE-2.0`	8	`* http://www.apache.org/licenses/LICENSE-2.0`
9	`*`	9	`*`
10	`* Unless required by applicable law or agreed to in writing, software`	10	`* Unless required by applicable law or agreed to in writing, software`
11	`* distributed under the License is distributed on an "AS IS" BASIS,`	11	`* distributed under the License is distributed on an "AS IS" BASIS,`
12	`* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.`	12	`* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.`
13	`* See the License for the specific language governing permissions and`	13	`* See the License for the specific language governing permissions and`
14	`* limitations under the License.`	14	`* limitations under the License.`
15	`*/`	15	`*/`
16	`package net.brutex.xservices.ws.impl;`	16	`package net.brutex.xservices.ws.impl;`
-		17
17		18	`import java.io.ByteArrayOutputStream;`
18	`import java.io.File;`	19	`import java.io.File;`
19	`import java.io.FileNotFoundException;`	20	`import java.io.FileNotFoundException;`
20	`import java.io.FileOutputStream;`	21	`import java.io.FileOutputStream;`
21	`import java.io.IOException;`	22	`import java.io.IOException;`
22	`import java.io.InputStream;`	23	`import java.io.InputStream;`
23	`import java.util.List;`	24	`import java.util.List;`
24		25
25	`import javax.activation.DataHandler;`	26	`import javax.activation.DataHandler;`
26	`import javax.jws.WebMethod;`	27	`import javax.jws.WebMethod;`
27	`import javax.jws.WebParam;`	28	`import javax.jws.WebParam;`
28	`import javax.jws.WebService;`	29	`import javax.jws.WebService;`
29		30
30	`import net.brutex.xservices.types.ReplacePattern;`	31	`import net.brutex.xservices.types.ReplacePattern;`
31	`import net.brutex.xservices.types.ReturnCode;`	32	`import net.brutex.xservices.types.ReturnCode;`
32	`import net.brutex.xservices.types.ant.ArchiveResource;`	33	`import net.brutex.xservices.types.ant.ArchiveResource;`
33	`import net.brutex.xservices.types.ant.AttachmentType;`	34	`import net.brutex.xservices.types.ant.AttachmentType;`
34	`import net.brutex.xservices.types.ant.FileResource;`	35	`import net.brutex.xservices.types.ant.FileResource;`
35	`import net.brutex.xservices.types.ant.FileSetResource;`	36	`import net.brutex.xservices.types.ant.FileSetResource;`
36	`import net.brutex.xservices.util.BrutexNamespaces;`	37	`import net.brutex.xservices.util.BrutexNamespaces;`
37	`import net.brutex.xservices.util.RunTask;`	38	`import net.brutex.xservices.util.RunTask;`
38	`import net.brutex.xservices.ws.FileService;`	39	`import net.brutex.xservices.ws.FileService;`
39	`import net.brutex.xservices.ws.XServicesFault;`	40	`import net.brutex.xservices.ws.XServicesFault;`
40		41
41	`import org.apache.cxf.aegis.type.mtom.StreamDataSource;`	42	`import org.apache.cxf.aegis.type.mtom.StreamDataSource;`
42	`import org.apache.tools.ant.BuildException;`	43	`import org.apache.tools.ant.BuildException;`
43	`import org.apache.tools.ant.taskdefs.Basename;`	44	`import org.apache.tools.ant.taskdefs.Basename;`
44	`import org.apache.tools.ant.taskdefs.Chmod;`	45	`import org.apache.tools.ant.taskdefs.Chmod;`
45	`import org.apache.tools.ant.taskdefs.Copy;`	46	`import org.apache.tools.ant.taskdefs.Copy;`
46	`import org.apache.tools.ant.taskdefs.Echo;`	47	`import org.apache.tools.ant.taskdefs.Echo;`
47	`import org.apache.tools.ant.taskdefs.LoadResource;`	48	`import org.apache.tools.ant.taskdefs.LoadResource;`
48	`import org.apache.tools.ant.taskdefs.Replace;`	49	`import org.apache.tools.ant.taskdefs.Replace;`
49	`import org.apache.tools.ant.taskdefs.optional.ReplaceRegExp;`	50	`import org.apache.tools.ant.taskdefs.optional.ReplaceRegExp;`
50	`import org.apache.tools.ant.taskdefs.optional.unix.Chgrp;`	51	`import org.apache.tools.ant.taskdefs.optional.unix.Chgrp;`
51	`import org.apache.tools.ant.taskdefs.optional.unix.Chown;`	52	`import org.apache.tools.ant.taskdefs.optional.unix.Chown;`
52	`import org.apache.tools.ant.types.FileSet;`	53	`import org.apache.tools.ant.types.FileSet;`
53		54
54	`/**`	55	`/**`
55	`*`	56	`*`
56	`* @author Brian Rosenberger, bru@brutex.de`	57	`* @author Brian Rosenberger, bru@brutex.de`
57	`*/`	58	`*/`
58	`@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.FileService", serviceName = "FileService")`	59	`@WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.FileService", serviceName = "FileService")`
59	`public class FileServiceImpl implements FileService {`	60	`public class FileServiceImpl implements FileService {`
60		61
61	`/*`	62	`/*`
62	`* (non-Javadoc)`	63	`* (non-Javadoc)`
63	`*`	64	`*`
64	`* @see net.brutex.xservices.ws.impl.FileService#basename(java.lang.String,`	65	`* @see net.brutex.xservices.ws.impl.FileService#basename(java.lang.String,`
65	`* java.lang.String)`	66	`* java.lang.String)`
66	`*/`	67	`*/`
67		68
68	`public String basename(String filename, String suffix) {`	69	`public String basename(String filename, String suffix) {`
69	`final String BASENAME_VALUE = "basename.value";`	70	`final String BASENAME_VALUE = "basename.value";`
70	`Basename basename = new Basename();`	71	`Basename basename = new Basename();`
71	`RunTask runner = new RunTask(basename);`	72	`RunTask runner = new RunTask(basename);`
72	`basename.setFile(new File(filename));`	73	`basename.setFile(new File(filename));`
73	`if (suffix != null && !suffix.equals("")) {`	74	`if (suffix != null && !suffix.equals("")) {`
74	`basename.setSuffix(suffix);`	75	`basename.setSuffix(suffix);`
75	`}`	76	`}`
76	`basename.setProperty(BASENAME_VALUE);`	77	`basename.setProperty(BASENAME_VALUE);`
77	`ReturnCode r = runner.postTask();`	78	`ReturnCode r = runner.postTask();`
78	`return r.getProperty(BASENAME_VALUE);`	79	`return r.getProperty(BASENAME_VALUE);`
79	`}`	80	`}`
80		81
81	`public ReturnCode replaceInFile(FileResource res, String search,`	82	`public ReturnCode replaceInFile(FileResource res, String search,`
82	`String replace) throws XServicesFault {`	83	`String replace) throws XServicesFault {`
83	`ReturnCode r = null;`	84	`ReturnCode r = null;`
84	`Replace rep = new Replace();`	85	`Replace rep = new Replace();`
85	`rep.setTaskName("Replace");`	86	`rep.setTaskName("Replace");`
86	`RunTask runner = new RunTask(rep);`	87	`RunTask runner = new RunTask(rep);`
87	`rep.addConfigured(res.getAntResource(rep.getProject()));`	88	`rep.addConfigured(res.getAntResource(rep.getProject()));`
88	`rep.setToken(search);`	89	`rep.setToken(search);`
89	`rep.setValue(replace);`	90	`rep.setValue(replace);`
90	`try {`	91	`try {`
91	`r = runner.postTask();`	92	`r = runner.postTask();`
92	`} catch (BuildException e) {`	93	`} catch (BuildException e) {`
93	`throw new XServicesFault(e);`	94	`throw new XServicesFault(e);`
94	`}`	95	`}`
95	`return r;`	96	`return r;`
96	`}`	97	`}`
97		98
98	`public ReturnCode replaceInFile2(FileResource res,`	99	`public ReturnCode replaceInFile2(FileResource res,`
99	`List<ReplacePattern> patternList) throws XServicesFault {`	100	`List<ReplacePattern> patternList) throws XServicesFault {`
100	`ReturnCode r = null;`	101	`ReturnCode r = null;`
101	`for (ReplacePattern pat : patternList) {`	102	`for (ReplacePattern pat : patternList) {`
102	`Replace rep = new Replace();`	103	`Replace rep = new Replace();`
103	`rep.setTaskName("Replace");`	104	`rep.setTaskName("Replace");`
104	`RunTask runner = new RunTask(rep);`	105	`RunTask runner = new RunTask(rep);`
105	`rep.addConfigured(res.getAntResource(rep.getProject()));`	106	`rep.addConfigured(res.getAntResource(rep.getProject()));`
106	`rep.setToken(pat.search);`	107	`rep.setToken(pat.search);`
107	`rep.setValue(pat.replace);`	108	`rep.setValue(pat.replace);`
108	`try {`	109	`try {`
109	`r = runner.postTask();`	110	`r = runner.postTask();`
110	`} catch (BuildException e) {`	111	`} catch (BuildException e) {`
111	`throw new XServicesFault(e);`	112	`throw new XServicesFault(e);`
112	`}`	113	`}`
113	`}`	114	`}`
114	`return r;`	115	`return r;`
115	`}`	116	`}`
116		117
117	`public ReturnCode replaceInFileRegEx(FileResource res, String search,`	118	`public ReturnCode replaceInFileRegEx(FileResource res, String search,`
118	`String replace, String flags) throws XServicesFault {`	119	`String replace, String flags) throws XServicesFault {`
119	`ReplaceRegExp rep = new ReplaceRegExp();`	120	`ReplaceRegExp rep = new ReplaceRegExp();`
120	`rep.setTaskName("ReplaceRegExp");`	121	`rep.setTaskName("ReplaceRegExp");`
121	`RunTask runner = new RunTask(rep);`	122	`RunTask runner = new RunTask(rep);`
122	`File infile = new File(res.uri);`	123	`File infile = new File(res.uri);`
123	`rep.setFile(infile);`	124	`rep.setFile(infile);`
124	`rep.setMatch(search);`	125	`rep.setMatch(search);`
125	`rep.setReplace(replace);`	126	`rep.setReplace(replace);`
126	`rep.setFlags(flags);`	127	`rep.setFlags(flags);`
127	`try {`	128	`try {`
128	`ReturnCode r = runner.postTask();`	129	`ReturnCode r = runner.postTask();`
129	`return r;`	130	`return r;`
130	`} catch (BuildException e) {`	131	`} catch (BuildException e) {`
131	`throw new XServicesFault(e);`	132	`throw new XServicesFault(e);`
132	`}`	133	`}`
133	`}`	134	`}`
134		135
135	`/*`	136	`/*`
136	`* (non-Javadoc)`	137	`* (non-Javadoc)`
137	`*`	138	`*`
138	`* @see`	139	`* @see`
139	`* net.brutex.xservices.ws.impl.FileService#base64Encode(net.brutex.xservices`	140	`* net.brutex.xservices.ws.impl.FileService#base64Encode(net.brutex.xservices`
140	`* .types.FileSetResource)`	141	`* .types.FileSetResource)`
141	`*/`	142	`*/`
142		143
143	`public AttachmentType downloadFile(FileResource res) throws XServicesFault {`	144	`public AttachmentType downloadFile(FileResource res) throws XServicesFault {`
144	`InputStream is = null;`	145	`InputStream is = null;`
145	`try {`	146	`try {`
146	`is = res.getAntResource(null).getInputStream();`	147	`is = res.getAntResource(null).getInputStream();`
147	`StreamDataSource ssource = new StreamDataSource(`	148	`StreamDataSource ssource = new StreamDataSource(`
148	`"application/binary", is);`	149	`"application/binary", is);`
149	`DataHandler h = new DataHandler(ssource);`	150	`DataHandler h = new DataHandler(ssource);`
150	`AttachmentType t = new AttachmentType();`	151	`AttachmentType t = new AttachmentType();`
151	`t.setContent(h);`	152	`t.setContent(h);`
152	`t.setFilename(res.getAntResource(null).getName());`	153	`t.setFilename(res.getAntResource(null).getName());`
153	`return t;`	154	`return t;`
154	`} catch (IOException e) {`	155	`} catch (IOException e) {`
-		156	`throw new XServicesFault(e);`
-		157	`}`
-		158	`}`
-		159
-		160	`public byte[] encodeFile(FileResource res) throws XServicesFault {`
-		161	`InputStream is = null;`
-		162	`try {`
-		163	`is = res.getAntResource(null).getInputStream();`
-		164
-		165	`ByteArrayOutputStream buffer = new ByteArrayOutputStream();`
-		166
-		167	`int nRead;`
-		168	`byte[] data = new byte[4096];`
-		169	`while ((nRead = is.read(data, 0, data.length)) != -1) {`
-		170	`buffer.write(data, 0, nRead);`
-		171	`}`
-		172	`buffer.flush();`
-		173	`return buffer.toByteArray();`
-		174
-		175	`} catch (IOException e) {`
155	`throw new XServicesFault(e);`	176	`throw new XServicesFault(e);`
156	`}`	177	`}`
157	`}`	178	`}`
158		179
159	`/*`	180	`/*`
160	`* (non-Javadoc)`	181	`* (non-Javadoc)`
161	`*`	182	`*`
162	`* @see`	183	`* @see`
163	`* net.brutex.xservices.ws.impl.FileService#base64Decode(net.brutex.xservices`	184	`* net.brutex.xservices.ws.impl.FileService#base64Decode(net.brutex.xservices`
164	`* .types.AttachmentType)`	185	`* .types.AttachmentType)`
165	`*/`	186	`*/`
166		187
167	`public String uploadFile(AttachmentType file) throws XServicesFault {`	188	`public String uploadFile(AttachmentType file) throws XServicesFault {`
168	`DataHandler h = file.getContent();`	189	`DataHandler h = file.getContent();`
169	`File f = new File(file.getFilename());`	190	`File f = new File(file.getFilename());`
170	`FileOutputStream fout;`	191	`FileOutputStream fout;`
171	`try {`	192	`try {`
172	`fout = new FileOutputStream(f);`	193	`fout = new FileOutputStream(f);`
173	`h.writeTo(fout);`	194	`h.writeTo(fout);`
174	`fout.flush();`	195	`fout.flush();`
175	`fout.close();`	196	`fout.close();`
176	`} catch (FileNotFoundException e) {`	197	`} catch (FileNotFoundException e) {`
177	`throw new XServicesFault(e);`	198	`throw new XServicesFault(e);`
178	`} catch (IOException e) {`	199	`} catch (IOException e) {`
179	`throw new XServicesFault(e);`	200	`throw new XServicesFault(e);`
180	`}`	201	`}`
181	`return file.getFilename();`	202	`return file.getFilename();`
182	`}`	203	`}`
183		204
184	`/*`	205	`/*`
185	`* (non-Javadoc)`	206	`* (non-Javadoc)`
186	`*`	207	`*`
187	`* @see`	208	`* @see`
188	`* net.brutex.xservices.ws.impl.FileService#copy(net.brutex.xservices.types`	209	`* net.brutex.xservices.ws.impl.FileService#copy(net.brutex.xservices.types`
189	`* .FileSetResource, java.lang.String, boolean, boolean, java.lang.String)`	210	`* .FileSetResource, java.lang.String, boolean, boolean, java.lang.String)`
190	`*/`	211	`*/`
191		212
192	`public ReturnCode copy(FileSetResource src, String todir, boolean plm,`	213	`public ReturnCode copy(FileSetResource src, String todir, boolean plm,`
193	`boolean overwrite, String encoding) throws XServicesFault {`	214	`boolean overwrite, String encoding) throws XServicesFault {`
194	`Copy copy = new Copy();`	215	`Copy copy = new Copy();`
195	`copy.setTaskName("Copy");`	216	`copy.setTaskName("Copy");`
196	`RunTask runner = new RunTask(copy);`	217	`RunTask runner = new RunTask(copy);`
197	`FileSet set = src.getAntResource(copy.getProject());`	218	`FileSet set = src.getAntResource(copy.getProject());`
198	`copy.add(set);`	219	`copy.add(set);`
199	`File dst = new File(todir);`	220	`File dst = new File(todir);`
200	`if (dst.isDirectory()) {`	221	`if (dst.isDirectory()) {`
201	`copy.setTodir(dst);`	222	`copy.setTodir(dst);`
202	`}`	223	`}`
203	`if (dst.isFile()) {`	224	`if (dst.isFile()) {`
204	`copy.setTofile(dst);`	225	`copy.setTofile(dst);`
205	`}`	226	`}`
206	`copy.setOverwrite(overwrite);`	227	`copy.setOverwrite(overwrite);`
207	`copy.setPreserveLastModified(plm);`	228	`copy.setPreserveLastModified(plm);`
208	`if (encoding != null && !encoding.equals("")) {`	229	`if (encoding != null && !encoding.equals("")) {`
209	`copy.setOutputEncoding(encoding);`	230	`copy.setOutputEncoding(encoding);`
210	`} else {`	231	`} else {`
211	`copy.setOutputEncoding(System.getProperty("file.encoding"));`	232	`copy.setOutputEncoding(System.getProperty("file.encoding"));`
212	`}`	233	`}`
213	`return runner.postTask();`	234	`return runner.postTask();`
214	`}`	235	`}`
215		236
216		237
217	`public ReturnCode copyFile(String fromFile, String tofile, boolean overwrite)`	238	`public ReturnCode copyFile(String fromFile, String tofile, boolean overwrite)`
218	`throws XServicesFault {`	239	`throws XServicesFault {`
219	`Copy copy = new Copy();`	240	`Copy copy = new Copy();`
220	`copy.setTaskName("Copy");`	241	`copy.setTaskName("Copy");`
221	`RunTask runner = new RunTask(copy);`	242	`RunTask runner = new RunTask(copy);`
222	`File f = new File(fromFile);`	243	`File f = new File(fromFile);`
223	`if (!f.isFile())`	244	`if (!f.isFile())`
224	`throw new XServicesFault("File '" + fromFile + "' not found.");`	245	`throw new XServicesFault("File '" + fromFile + "' not found.");`
225	`copy.setFile(new File(fromFile));`	246	`copy.setFile(new File(fromFile));`
226	`copy.setTofile(new File(tofile));`	247	`copy.setTofile(new File(tofile));`
227	`copy.setOverwrite(overwrite);`	248	`copy.setOverwrite(overwrite);`
228	`return runner.postTask();`	249	`return runner.postTask();`
229	`}`	250	`}`
230		251
231	`/*`	252	`/*`
232	`* (non-Javadoc)`	253	`* (non-Javadoc)`
233	`*`	254	`*`
234	`* @see`	255	`* @see`
235	`* net.brutex.xservices.ws.impl.FileService#loadRes(net.brutex.xservices`	256	`* net.brutex.xservices.ws.impl.FileService#loadRes(net.brutex.xservices`
236	`* .types.FileResource, java.lang.String)`	257	`* .types.FileResource, java.lang.String)`
237	`*/`	258	`*/`
238		259
239	`public String loadRes(FileResource res, String encoding)`	260	`public String loadRes(FileResource res, String encoding)`
240	`throws XServicesFault {`	261	`throws XServicesFault {`
241	`if (encoding == null \|\| encoding.equals("")) {`	262	`if (encoding == null \|\| encoding.equals("")) {`
242	`encoding = System.getProperty("file.encoding");`	263	`encoding = System.getProperty("file.encoding");`
243	`}`	264	`}`
244	`LoadResource lr = new LoadResource();`	265	`LoadResource lr = new LoadResource();`
245	`lr.setTaskName("LoadResource");`	266	`lr.setTaskName("LoadResource");`
246	`RunTask runner = new RunTask(lr);`	267	`RunTask runner = new RunTask(lr);`
247	`lr.addConfigured(res.getAntResource(lr.getProject()));`	268	`lr.addConfigured(res.getAntResource(lr.getProject()));`
248	`lr.setEncoding(encoding);`	269	`lr.setEncoding(encoding);`
249	`System.out.println("Using encoding: " + encoding);`	270	`System.out.println("Using encoding: " + encoding);`
250	`lr.setProperty("LoadResource.out");`	271	`lr.setProperty("LoadResource.out");`
251	`ReturnCode r = runner.postTask();`	272	`ReturnCode r = runner.postTask();`
252	`return r.getProperty("LoadResource.out");`	273	`return r.getProperty("LoadResource.out");`
253	`}`	274	`}`
254		275
255	`/*`	276	`/*`
256	`* (non-Javadoc)`	277	`* (non-Javadoc)`
257	`*`	278	`*`
258	`* @see`	279	`* @see`
259	`* net.brutex.xservices.ws.impl.FileService#loadResFromArchive(net.brutex`	280	`* net.brutex.xservices.ws.impl.FileService#loadResFromArchive(net.brutex`
260	`* .xservices.types.ArchiveResource, java.lang.String)`	281	`* .xservices.types.ArchiveResource, java.lang.String)`
261	`*/`	282	`*/`
262		283
263	`public String loadResFromArchive(ArchiveResource res, String encoding) {`	284	`public String loadResFromArchive(ArchiveResource res, String encoding) {`
264	`if (encoding == null \|\| encoding.equals("")) {`	285	`if (encoding == null \|\| encoding.equals("")) {`
265	`encoding = System.getProperty("file.encoding");`	286	`encoding = System.getProperty("file.encoding");`
266	`}`	287	`}`
267	`LoadResource lr = new LoadResource();`	288	`LoadResource lr = new LoadResource();`
268	`lr.setTaskName("LoadResource");`	289	`lr.setTaskName("LoadResource");`
269	`RunTask runner = new RunTask(lr);`	290	`RunTask runner = new RunTask(lr);`
270	`lr.addConfigured(res.getAntResource(lr.getProject()));`	291	`lr.addConfigured(res.getAntResource(lr.getProject()));`
271	`lr.setEncoding(encoding);`	292	`lr.setEncoding(encoding);`
272	`System.out.println("Using encoding: " + encoding);`	293	`System.out.println("Using encoding: " + encoding);`
273	`lr.setProperty("LoadResource.out");`	294	`lr.setProperty("LoadResource.out");`
274	`ReturnCode r = runner.postTask();`	295	`ReturnCode r = runner.postTask();`
275	`return r.getProperty("LoadResource.out");`	296	`return r.getProperty("LoadResource.out");`
276		297
277	`}`	298	`}`
278		299
279	`/*`	300	`/*`
280	`* (non-Javadoc)`	301	`* (non-Javadoc)`
281	`*`	302	`*`
282	`* @see net.brutex.xservices.ws.impl.FileService#echo2file(java.lang.String,`	303	`* @see net.brutex.xservices.ws.impl.FileService#echo2file(java.lang.String,`
283	`* java.lang.String, java.lang.String, boolean)`	304	`* java.lang.String, java.lang.String, boolean)`
284	`*/`	305	`*/`
285		306
286	`public ReturnCode echo2file(String message, String file, String encoding,`	307	`public ReturnCode echo2file(String message, String file, String encoding,`
287	`boolean append) throws XServicesFault {`	308	`boolean append) throws XServicesFault {`
288		309
289	`Echo echo = new Echo();`	310	`Echo echo = new Echo();`
290	`echo.setTaskName("toFile");`	311	`echo.setTaskName("toFile");`
291	`RunTask runTask = new RunTask(echo);`	312	`RunTask runTask = new RunTask(echo);`
292	`echo.addText(message);`	313	`echo.addText(message);`
293	`echo.setEncoding(encoding);`	314	`echo.setEncoding(encoding);`
294	`File f = new File(file);`	315	`File f = new File(file);`
295	`try {`	316	`try {`
296	`if (!f.canWrite())`	317	`if (!f.canWrite())`
297		318
298	`throw new XServicesFault("Cannot write to file: "`	319	`throw new XServicesFault("Cannot write to file: "`
299	`+ f.getCanonicalPath());`	320	`+ f.getCanonicalPath());`
300		321
301	`echo.setFile(f);`	322	`echo.setFile(f);`
302	`echo.setAppend(append);`	323	`echo.setAppend(append);`
303	`ReturnCode c = runTask.postTask();`	324	`ReturnCode c = runTask.postTask();`
304	`return c;`	325	`return c;`
305	`} catch (BuildException e) {`	326	`} catch (BuildException e) {`
306	`throw new XServicesFault("Error in echo2file.", e);`	327	`throw new XServicesFault("Error in echo2file.", e);`
307	`} catch (IOException e) {`	328	`} catch (IOException e) {`
308	`throw new XServicesFault("Cannot write to file.", e);`	329	`throw new XServicesFault("Cannot write to file.", e);`
309	`}`	330	`}`
310	`}`	331	`}`
311		332
312	`/*`	333	`/*`
313	`* (non-Javadoc)`	334	`* (non-Javadoc)`
314	`*`	335	`*`
315	`* @see`	336	`* @see`
316	`* net.brutex.xservices.ws.impl.FileService#changeOwner(net.brutex.xservices`	337	`* net.brutex.xservices.ws.impl.FileService#changeOwner(net.brutex.xservices`
317	`* .types.FileSetResource, java.lang.String)`	338	`* .types.FileSetResource, java.lang.String)`
318	`*/`	339	`*/`
319		340
320	`public ReturnCode changeOwner(FileSetResource res, String owner) {`	341	`public ReturnCode changeOwner(FileSetResource res, String owner) {`
321	`Chown chown = new Chown();`	342	`Chown chown = new Chown();`
322	`chown.setTaskName("Chown");`	343	`chown.setTaskName("Chown");`
323	`RunTask runner = new RunTask(chown);`	344	`RunTask runner = new RunTask(chown);`
324	`chown.setOwner(owner);`	345	`chown.setOwner(owner);`
325	`FileSet set = res.getAntResource(chown.getProject());`	346	`FileSet set = res.getAntResource(chown.getProject());`
326	`chown.add(set);`	347	`chown.add(set);`
327	`chown.setMaxParallel(300);`	348	`chown.setMaxParallel(300);`
328	`return runner.postTask();`	349	`return runner.postTask();`
329	`}`	350	`}`
330		351
331	`/*`	352	`/*`
332	`* (non-Javadoc)`	353	`* (non-Javadoc)`
333	`*`	354	`*`
334	`* @see`	355	`* @see`
335	`* net.brutex.xservices.ws.impl.FileService#changeGroup(net.brutex.xservices`	356	`* net.brutex.xservices.ws.impl.FileService#changeGroup(net.brutex.xservices`
336	`* .types.FileSetResource, java.lang.String)`	357	`* .types.FileSetResource, java.lang.String)`
337	`*/`	358	`*/`
338		359
339	`public ReturnCode changeGroup(FileSetResource res, String group) {`	360	`public ReturnCode changeGroup(FileSetResource res, String group) {`
340	`Chgrp chgrp = new Chgrp();`	361	`Chgrp chgrp = new Chgrp();`
341	`chgrp.setTaskName("Chgrp");`	362	`chgrp.setTaskName("Chgrp");`
342	`RunTask runner = new RunTask(chgrp);`	363	`RunTask runner = new RunTask(chgrp);`
343	`chgrp.setGroup(group);`	364	`chgrp.setGroup(group);`
344	`FileSet set = res.getAntResource(chgrp.getProject());`	365	`FileSet set = res.getAntResource(chgrp.getProject());`
345	`chgrp.add(set);`	366	`chgrp.add(set);`
346	`chgrp.setMaxParallel(300);`	367	`chgrp.setMaxParallel(300);`
347	`return runner.postTask();`	368	`return runner.postTask();`
348	`}`	369	`}`
349		370
350	`/*`	371	`/*`
351	`* (non-Javadoc)`	372	`* (non-Javadoc)`
352	`*`	373	`*`
353	`* @see`	374	`* @see`
354	`* net.brutex.xservices.ws.impl.FileService#changeMode(net.brutex.xservices`	375	`* net.brutex.xservices.ws.impl.FileService#changeMode(net.brutex.xservices`
355	`* .types.FileSetResource, java.lang.String)`	376	`* .types.FileSetResource, java.lang.String)`
356	`*/`	377	`*/`
357		378
358	`public ReturnCode changeMode(FileSetResource res, String perm) {`	379	`public ReturnCode changeMode(FileSetResource res, String perm) {`
359	`Chmod chmod = new Chmod();`	380	`Chmod chmod = new Chmod();`
360	`chmod.setTaskName("Chmod");`	381	`chmod.setTaskName("Chmod");`
361	`RunTask runner = new RunTask(chmod);`	382	`RunTask runner = new RunTask(chmod);`
362	`FileSet set = res.getAntResource(chmod.getProject());`	383	`FileSet set = res.getAntResource(chmod.getProject());`
363	`chmod.add(set);`	384	`chmod.add(set);`
364	`chmod.setMaxParallel(300);`	385	`chmod.setMaxParallel(300);`
365	`chmod.setPerm(perm);`	386	`chmod.setPerm(perm);`
366	`chmod.setVerbose(true);`	387	`chmod.setVerbose(true);`
367	`return runner.postTask();`	388	`return runner.postTask();`
368	`}`	389	`}`
369		390
370	`}`	391	`}`

Subversion Repositories XServices

(root)/xservices/trunk/src/java/net/brutex/xservices/ws/impl/FileServiceImpl.java – Rev 83 → 92