| package aQute.bnd.osgi; |
| |
| import java.io.*; |
| |
| import aQute.libg.command.*; |
| |
| public class CommandResource extends WriteResource { |
| final long lastModified; |
| final Builder domain; |
| final String command; |
| final File wd; |
| |
| public CommandResource(String command, Builder domain, long lastModified, File wd) { |
| this.lastModified = lastModified; |
| this.domain = domain; |
| this.command = command; |
| this.wd = wd; |
| } |
| |
| @Override |
| public void write(OutputStream out) throws IOException, Exception { |
| StringBuilder errors = new StringBuilder(); |
| StringBuilder stdout = new StringBuilder(); |
| domain.trace("executing command %s", command); |
| Command cmd = new Command("sh"); |
| cmd.setCwd(wd); |
| cmd.inherit(); |
| String oldpath = cmd.var("PATH"); |
| |
| String path = domain.getProperty("-PATH"); |
| if (path != null) { |
| path = path.replaceAll("\\s*,\\s*", File.pathSeparator); |
| path = path.replaceAll("\\$\\{@\\}", oldpath); |
| cmd.var("PATH", path); |
| domain.trace("PATH: %s", path); |
| } |
| OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8"); |
| int result = cmd.execute(command, stdout, errors); |
| osw.append(stdout); |
| osw.flush(); |
| if (result != 0) { |
| throw new Exception("executing command failed" + command + "\n"+ stdout + "\n" + errors); |
| } |
| } |
| |
| @Override |
| public long lastModified() { |
| return lastModified; |
| } |
| |
| } |