command in v3/packager-new/glassfish-gui/build.xml
static final String ADMIN_APP_WAR = "admingui.war";
/**
* Constructor.
*/
public WebApplicationAdapter() throws IOException {
initHtml = Utils.packageResource2String("downloadgui.html");
statusHtml = Utils.packageResource2String("status.html");
}
/**
*
*/
public String getContextRoot() {
return contextRoot; //default is /admin
}
/**
*
*/
public void afterService(GrizzlyRequest req, GrizzlyResponse res) throws Exception {
}
/**
*
*/
public void fireAdapterEvent(String type, Object data) {
}
/**
*
*/
public void service(GrizzlyRequest req, GrizzlyResponse res) {
try {
if (!latch.await(100L, TimeUnit.SECONDS)) {
// todo : better error reporting.
log.severe("Cannot process admin console request in time");
return;
}
} catch (InterruptedException ex) {
log.severe("Cannot process admin console request");
return;
}
logRequest(req);
handleAuth(req, res);
if (isApplicationLoaded()) {
handleLoadedState();
} else {
synchronized(this) {
if (isInstalling()) {
sendStatusPage(res);
} else {
if (isApplicationLoaded()) {
// Double check here that it is not now loaded (not
// likely, but possible)
handleLoadedState();
} else if (!hasPermission(req)) {
// Ask for permission
sendConsentPage(req, res);
} else {
try {
// We have permission and now we should install
// (or load) the application.
setInstalling(true);
setStateMsg(AdapterState.INSTALLING);
startThread(); // Thread must set installing false
} catch (Exception ex) {
// Ensure we haven't crashed with the installing
// flag set to true (not likely).
setInstalling(false);
}
sendStatusPage(res);
}
}
}
}
}
/**
*
*/
private boolean isApplicationLoaded() {
return (stateMsg == AdapterState.APPLICATION_LOADED);
}
/**
*
*/
boolean isInstalling() {
return installing;
}
/**
*
*/
void setInstalling(boolean flag) {
installing = flag;
}
/**
* This method sets the current state.
*/
void setStateMsg(AdapterState msg) {
stateMsg = msg;
}
/**
* This method returns the current state, which will be one of the
* following values:
*
* - AdapterSate.UNINITIAZED
* - AdapterSate.INSTALLING
* - AdapterSate.APPLICATION_NOT_INSTALLED
* - AdapterSate.APPLICATION_INSTALLED_BUT_NOT_LOADED
* - AdapterSate.APPLICATION_LOADED
*/
AdapterState getStateMsg() {
return stateMsg;
}
/**
*
*/
public void postConstruct() {
events.register(this);
//set up the environment properly
init();
}
/**
*
*/
public void event(@RestrictTo(EventTypes.SERVER_READY_NAME) Event event) {
latch.countDown();
if (log != null) {
if (log.isLoggable(Level.FINE)) {
log.fine("WebApplicationAdapter is ready.");
}
}
}
/**
*
*/
private void handleAuth(GrizzlyRequest greq, GrizzlyResponse gres) {
try {
File realmFile = new File(env.getProps().get(SystemPropertyConstants.INSTANCE_ROOT_PROPERTY) + "/config/admin-keyfile");
if (authenticator!=null && realmFile.exists()) {
if (!authenticator.authenticate(greq.getRequest(), realmFile)) {
gres.setStatus(HttpURLConnection.HTTP_UNAUTHORIZED);
gres.addHeader("WWW-Authenticate", "BASIC");
gres.finishResponse();
}
}
} catch (Exception ex) {
throw new RuntimeException(ex);
}
}
/**
*
*/
private void init() {
if ((as == null) || (as.getProperty() == null) || as.getProperty().isEmpty()) {
String msg = "Define following properties in element in domain.xml" +
"for admin console to work properly\n" +
ServerTags.ADMIN_CONSOLE_CONTEXT_ROOT + ", " +
ServerTags.ADMIN_CONSOLE_DOWNLOAD_LOCATION + ", " +
ServerTags.ADMIN_CONSOLE_LOCATION_ON_DISK;
log.info(msg);
return;
}
List props = as.getProperty();
for (Property prop : props) {
setContextRoot(prop);
//setDownloadLocations(prop);
setLocationOnDisk(prop);
}
initState();
}
/**
*
*/
private void initState() {
// It is a given that the application is NOT loaded to begin with
if (appExistsInConfig()) {
setStateMsg(AdapterState.APPLICATION_INSTALLED_BUT_NOT_LOADED);
} else {
setStateMsg(AdapterState.APPLICATION_NOT_INSTALLED);
}
}
/**
*
*/
private boolean appExistsInConfig() {
return (getConfig() != null);
}
/**
*
*/
Application getConfig() {
//no application-ref logic here -- that's on purpose for now
Application app = domain.getSystemApplicationReferencedFrom(env.getInstanceName(), ADMIN_APP_NAME);
return app;
}
/**
*
*/
private void logRequest(GrizzlyRequest req) {
// FIXME: Change all INFO to FINE
log.info("WebApplicationAdapter's STATE IS: " + getStateMsg());
if (log.isLoggable(Level.FINE)) {
log.log(Level.FINE, "Current Thread: " + Thread.currentThread().getName());
Enumeration names = req.getParameterNames();
while (names.hasMoreElements()) {
String name = (String) names.nextElement();
String values = Arrays.toString(req.getParameterValues(name));
log.fine("Parameter name: " + name + " values: " + values);
}
}
}
/**
*
*/
private void setContextRoot(Property prop) {
if (prop == null) {
contextRoot = ServerEnvironmentImpl.DEFAULT_ADMIN_CONSOLE_CONTEXT_ROOT;
return;
}
if (ServerTags.ADMIN_CONSOLE_CONTEXT_ROOT.equals(prop.getName())) {
if ((prop.getValue() != null) && prop.getValue().startsWith("/")) {
contextRoot = prop.getValue();
log.info("Admin Console Adapter: context root: " + contextRoot);
} else {
log.info("Invalid context root for the admin console application, using default:" + ServerEnvironmentImpl.DEFAULT_ADMIN_CONSOLE_CONTEXT_ROOT);
contextRoot = ServerEnvironmentImpl.DEFAULT_ADMIN_CONSOLE_CONTEXT_ROOT;
}
}
}
/*
private void setDownloadLocations(Property prop) {
if (ServerTags.ADMIN_CONSOLE_DOWNLOAD_LOCATION.equals(prop.getName())) {
String value = prop.getValue();
if (value != null && !"".equals(value)) {
Pattern sp = Pattern.compile("\\|");
String[] strings = sp.split(value);
for (String s : strings) {
try {
urls.add(new URL(s));
logFine(s);
} catch (MalformedURLException me) {
log.info("Ignored invalid URL format: " + s);
}
}
} else {
log.info("The value for: " + prop.getName() + " is invalid");
}
}
}
*/
/**
*
*/
private void setLocationOnDisk(Property prop) {
if (ServerTags.ADMIN_CONSOLE_LOCATION_ON_DISK.equals(prop.getName())) {
if (prop.getValue() != null) {
diskLocation = new File(prop.getValue());
//System.out.println("Admin Console will be downloaded to: " + diskLocation.getAbsolutePath());
logFine("Admin Console will be downloaded to: " + diskLocation.getAbsolutePath());
if (!diskLocation.canWrite()) {
log.warning(diskLocation.getAbsolutePath() + " can't be written to, download will fail");
}
}
}
}
/**
*
*/
enum InteractionResult {
OK,
CANCEL,
FIRST_TIMER;
}
/**
* Determines if the user has permission.
*/
private boolean hasPermission(GrizzlyRequest req) {
//do this quickly as this is going to block the grizzly worker thread!
//check for returning user?
InteractionResult ir = getUserInteractionResult(req);
if (ir == InteractionResult.OK) {
// FIXME: I need to "remember" this answer in a persistent way!! Or it will popup this message EVERY time after the server restarts.
isOK = true;
}
return isOK;
}
/**
*
*/
private void startThread() {
new InstallerThread(urls, diskLocation, proxyHost, proxyPort, this, habitat, domain, env, contextRoot, log).start();
}
/**
*
*/
private synchronized InteractionResult getUserInteractionResult(GrizzlyRequest req) {
String v = visitorId + "";
if ((req.getParameter(VISITOR_PARAM) != null) && (v.equals(req.getParameter(VISITOR_PARAM)))) {
if (req.getParameter(OK_PARAM) != null) {
proxyHost = req.getParameter(PROXY_HOST_PARAM);
if (proxyHost != null) {
String ps = req.getParameter(PROXY_PORT_PARAM);
try {
proxyPort = Integer.parseInt(ps);
} catch (NumberFormatException nfe) {
//ignore
}
}
return InteractionResult.OK;
} else { //canceled
return InteractionResult.CANCEL;
}
}
// This is a first-timer
return InteractionResult.FIRST_TIMER;
}
/**
*
*/
private synchronized void sendConsentPage(GrizzlyRequest req, GrizzlyResponse res) { //should have only one caller
GrizzlyOutputBuffer ob = res.getOutputBuffer();
res.setStatus(200);
res.setContentType("text/html");
byte[] bytes;
try {
try {
String hp = (contextRoot.startsWith("/")) ? "" : "/";
hp += contextRoot + "/";
visitorId = System.currentTimeMillis(); //sufficiently unique
bytes = initHtml.replace(MYURL_TOKEN, hp).replace(VISITOR_TOKEN, visitorId+"").getBytes();
} catch (Exception ex) {
bytes = ("Catastrophe:" + ex.getMessage()).getBytes();
}
res.setContentLength(bytes.length);
ob.write(bytes, 0, bytes.length);
ob.flush();
} catch (IOException ex) {
throw new RuntimeException(ex);
}
}
/**
*
*/
private void sendStatusPage(GrizzlyResponse res) {
GrizzlyOutputBuffer ob = res.getOutputBuffer();
res.setStatus(200);
res.setContentType("text/html");
byte[] bytes;
try {
String status = "" + getStateMsg();
bytes = statusHtml.replace(STATUS_TOKEN, status).getBytes();
res.setContentLength(bytes.length);
ob.write(bytes, 0, bytes.length);
ob.flush();
} catch (IOException ex) {
throw new RuntimeException(ex);
}
}
/**
*
*/
private void handleLoadedState() {
// do nothing
statusHtml = null;
initHtml = null;
}
/**
*
*/
private void logFine(String s) {
if (log.isLoggable(Level.FINE)) {
log.log(Level.FINE, s);
}
}
}