WebSVN – XServices – Diff – /xservices/trunk/src/java/net/brutex/xservices/util/RunTask.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.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);
    }
 
    public ReturnCode postTask() {
        int returnCode = 0;
        Map<String, String> origMap = new HashMap<String, String>();
        Map<String, String> newMap = null;
        origMap.putAll(antproject.getProperties());
        try {
            antproject.executeTarget(anttarget.getName());
        } catch (BuildException ex) {
            err.print(ex.getMessage());
            returnCode = 1;
        }
        newMap = antproject.getProperties();
 
        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));
 
    }
}

Rev 18	Rev 20
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.util;`	16	`package net.brutex.xservices.util;`
17		17
18	`import java.io.ByteArrayOutputStream;`	18	`import java.io.ByteArrayOutputStream;`
19	`import java.io.PrintStream;`	19	`import java.io.PrintStream;`
20	`import java.util.HashMap;`	20	`import java.util.HashMap;`
21	`import java.util.Map;`	21	`import java.util.Map;`
22	`import net.brutex.xservices.types.AntProperty;`	22	`import net.brutex.xservices.types.AntProperty;`
23	`import net.brutex.xservices.types.ReturnCode;`	23	`import net.brutex.xservices.types.ReturnCode;`
24	`import org.apache.tools.ant.BuildException;`	24	`import org.apache.tools.ant.BuildException;`
25	`import org.apache.tools.ant.Project;`	25	`import org.apache.tools.ant.Project;`
26	`import org.apache.tools.ant.Target;`	26	`import org.apache.tools.ant.Target;`
27	`import org.apache.tools.ant.Task;`	27	`import org.apache.tools.ant.Task;`
28	`import org.apache.tools.ant.listener.TimestampedLogger;`	28	`import org.apache.tools.ant.listener.TimestampedLogger;`
29	`import org.apache.tools.ant.taskdefs.Echo;`	29	`import org.apache.tools.ant.taskdefs.Echo;`
30		30
31	`/**`	31	`/**`
32	`*`	32	`*`
33	`* @author Brian Rosenberger, bru@brutex.de`	33	`* @author Brian Rosenberger, bru@brutex.de`
34	`*/`	34	`*/`
35	`public class RunTask {`	35	`public class RunTask {`
36		36
37	`Project antproject;`	37	`Project antproject;`
38	`Target anttarget;`	38	`Target anttarget;`
39	`Task anttask;`	39	`Task anttask;`
40	`ByteArrayOutputStream out = new ByteArrayOutputStream();`	40	`ByteArrayOutputStream myout = new ByteArrayOutputStream();`
41	`ByteArrayOutputStream err = new ByteArrayOutputStream();`	41	`ByteArrayOutputStream myerr = new ByteArrayOutputStream();`
-		42	`PrintStream out = new PrintStream(myout);`
-		43	`PrintStream err = new PrintStream(myerr);`
42	`TimestampedLogger log = null;`	44	`TimestampedLogger log = null;`
43		45
44	`public RunTask(Task anttask) {`	46	`public RunTask(Task anttask) {`
45		47
46	`antproject = new Project();`	48	`antproject = new Project();`
47	`antproject.init();`	49	`antproject.init();`
48	`antproject.setBasedir(System.getProperty("java.io.tmpdir"));`	50	`antproject.setBasedir(System.getProperty("java.io.tmpdir"));`
49	`log = new TimestampedLogger();`	51	`log = new TimestampedLogger();`
50	`log.setOutputPrintStream(new PrintStream(out));`	52	`log.setOutputPrintStream(out);`
51	`log.setErrorPrintStream(new PrintStream(err));`	53	`log.setErrorPrintStream(err);`
52	`log.setMessageOutputLevel(Echo.EchoLevel.WARN.getLevel());`	54	`log.setMessageOutputLevel(Echo.EchoLevel.WARN.getLevel());`
53		55
54	`antproject.addBuildListener(log);`	56	`antproject.addBuildListener(log);`
55		57
56	`anttarget = new Target();`	58	`anttarget = new Target();`
57	`anttarget.setName("XBridgeNGDynamicTarget");`	59	`anttarget.setName("XBridgeNGDynamicTarget");`
58	`anttarget.setProject(antproject);`	60	`anttarget.setProject(antproject);`
59	`antproject.addTarget(anttarget);`	61	`antproject.addTarget(anttarget);`
60		62
61	`this.anttask = anttask;`	63	`this.anttask = anttask;`
62	`prepareTask();`	64	`prepareTask();`
63	`}`	65	`}`
64		66
65	`private void prepareTask()`	67	`private void prepareTask()`
66	`throws BuildException {`	68	`throws BuildException {`
67	`anttask.init();`	69	`anttask.init();`
68	`anttask.setProject(antproject);`	70	`anttask.setProject(antproject);`
69	`anttask.setOwningTarget(anttarget);`	71	`anttask.setOwningTarget(anttarget);`
70	`anttarget.addTask(anttask);`	72	`anttarget.addTask(anttask);`
71	`antproject.addOrReplaceTarget(anttarget);`	73	`antproject.addOrReplaceTarget(anttarget);`
72	`}`	74	`}`
73		75
74	`public ReturnCode postTask() {`	76	`public ReturnCode postTask() {`
75	`int returnCode = 0;`	77	`int returnCode = 0;`
76	`Map<String, String> origMap = new HashMap<String, String>();`	78	`Map<String, String> origMap = new HashMap<String, String>();`
77	`Map<String, String> newMap = null;`	79	`Map<String, String> newMap = null;`
78	`origMap.putAll(antproject.getProperties());`	80	`origMap.putAll(antproject.getProperties());`
79	`try {`	81	`try {`
80	`antproject.executeTarget(anttarget.getName());`	82	`antproject.executeTarget(anttarget.getName());`
81	`} catch (BuildException ex) {`	83	`} catch (BuildException ex) {`
82	`new PrintStream(err).println(ex.getMessage());`	84	`err.print(ex.getMessage());`
83	`returnCode = 1;`	85	`returnCode = 1;`
84	`}`	86	`}`
85	`newMap = antproject.getProperties();`	87	`newMap = antproject.getProperties();`
86		88
87	`for (Map.Entry<String, String> e : origMap.entrySet()) {`	89	`for (Map.Entry<String, String> e : origMap.entrySet()) {`
88	`newMap.remove(e.getKey());`	90	`newMap.remove(e.getKey());`
89	`}`	91	`}`
90		92
91	`//anttask.execute();`	93	`//anttask.execute();`
92	`return new ReturnCode(returnCode,`	94	`return new ReturnCode(returnCode,`
93	`out.toString(),`	95	`myout.toString(),`
94	`err.toString(),`	96	`myerr.toString(),`
95	`AntProperty.createAntPropertyList(newMap));`	97	`AntProperty.createAntPropertyList(newMap));`
96		98
97	`}`	99	`}`
98	`}`	100	`}`

Subversion Repositories XServices

(root)/xservices/trunk/src/java/net/brutex/xservices/util/RunTask.java – Rev 18 → 20