Subversion Repositories XServices

Rev

Details | Last modification | View Log | RSS feed

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