* The following server properties are used: *
* prefix.types=image/(jpeg|gif)
* prefix.command= convert -sample 50% \
* ${map.${prefix.type}}:- ${map.${prefix.type}}:-
* map.image/gif=GIF
* map.image/jpeg=JPEG
*
*
* @author Stephen Uhler
* @version 2.3
*/
public class ExecFilter implements Filter {
String command; // image manipulation command to run
Regexp types; // the regular expression to the types
String prefix; // our properties prefix
public boolean
init(Server server, String prefix) {
this.prefix = prefix;
command = server.props.getProperty(prefix + "command");
String reString = server.props.getProperty(prefix + "types");
try {
types = new Regexp(reString, true);
} catch (IllegalArgumentException e) {
server.log(Server.LOG_WARNING, prefix, "Invalid regexp");
return false;
}
return (command != null);
}
/**
* This is the request object before the content was fetched
*/
public boolean respond(Request request) {
return false;
}
/**
* Only filter content types that match
*/
public boolean
shouldFilter(Request request, MimeHeaders headers) {
String type = headers.get("content-type");
boolean ok = (type != null && types.match(type) != null);
request.log(Server.LOG_DIAGNOSTIC, prefix +
"Will filter: " + type + " " + ok);
return ok;
}
/**
* Run content through filter. Process ${...}
*/
public byte[]
filter(Request request, MimeHeaders headers, byte[] content) {
String type = headers.get("content-type");
request.props.put(prefix + "type", type);
String formatted = Format.subst(request.props, command);
request.log(Server.LOG_DIAGNOSTIC, prefix +
"Running: [" + formatted + "] (" + type + ")");
try {
Process process = Runtime.getRuntime().exec(formatted);
OutputStream out = process.getOutputStream();
out.write(content);
out.close();
HttpInputStream in = new HttpInputStream(process.getInputStream());
HttpInputStream err = new HttpInputStream(process.getErrorStream());
ByteArrayOutputStream inB = new ByteArrayOutputStream();
in.copyTo(inB);
if (inB.size() > 0) {
content=inB.toByteArray();
String newType = request.props.getProperty(prefix + "newType");
if (newType != null) {
newType = Format.subst(request.props, newType);
request.log(Server.LOG_DIAGNOSTIC, prefix +
"Changing content type to: " + newType);
headers.put("content-type", newType);
}
} else {
request.log(Server.LOG_DIAGNOSTIC, prefix +
"No content from filter");
}
in.close();
inB.close();
ByteArrayOutputStream errB = new ByteArrayOutputStream();
err.copyTo(errB);
if (errB.size() > 0) {
request.log(Server.LOG_DIAGNOSTIC, prefix +
"Error result: " + errB);
request.props.put(prefix + "error", errB.toString());
}
err.close();
errB.close();
process.waitFor();
} catch (InterruptedException e) {
request.log(Server.LOG_DIAGNOSTIC, prefix +
"Interrupted: " + e.getMessage());
request.props.put(prefix + "error", e.getMessage());
} catch (IOException e) {
request.log(Server.LOG_DIAGNOSTIC, prefix +
"IO Error: " + e.getMessage());
request.props.put(prefix + "error", e.getMessage());
}
return content;
}
}