View Javadoc

1   /*
2    * Copyright 2007-2008 the original author or authors.
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   */
16  
17  package org.gwe.app.client.admin;
18  
19  import org.apache.commons.logging.Log;
20  import org.apache.commons.logging.LogFactory;
21  import org.gwe.app.client.config.ClientConfig;
22  import org.gwe.drivers.HandleCreationException;
23  import org.gwe.drivers.HandleOperationException;
24  import org.gwe.drivers.bundleManagers.BundleHandle;
25  import org.gwe.drivers.bundleManagers.BundleType;
26  import org.gwe.drivers.bundleManagers.DeploymentException;
27  import org.gwe.drivers.fileSystems.FileHandle;
28  import org.gwe.drivers.netAccess.ConnectorException;
29  import org.gwe.drivers.netAccess.HostHandle;
30  import org.gwe.drivers.netAccess.ShellCommand;
31  import org.gwe.persistence.model.DaemonConfigDesc;
32  import org.gwe.persistence.model.HeadResourceInfo;
33  import org.gwe.persistence.model.OSAppFolder;
34  import org.gwe.utils.IOUtils;
35  import org.gwe.utils.security.ResourceLink;
36  
37  public class ClientDaemonAppManager {
38  
39  	private static Log log = LogFactory.getLog(ClientDaemonAppManager.class);
40  
41  	// Daemon info
42  	private DaemonConfigDesc daemonConfig;
43  
44  	private String localBundlesPath;
45  
46  	public ClientDaemonAppManager(DaemonConfigDesc daemonConfig) {
47  		this.daemonConfig = daemonConfig;
48  		this.localBundlesPath = OSAppFolder.BUNDLES.getRelativeTo(ClientConfig.extractGWE_HOME());
49  	}
50  	
51  	public DaemonConfigDesc getDaemonConfig() {
52  		return daemonConfig;
53  	}
54  	
55  	public void installDaemonIfMissing() throws DeploymentException, RemoteExecutionException {
56  		if (deployDaemon()) setupDaemon();
57  	}
58  	
59  	public boolean deployDaemon() throws DeploymentException {
60  		return deployDaemon(BundleType.ZIP);
61  	}
62  	
63  	public boolean deployDaemon(BundleType bundleType) throws DeploymentException {
64  		ResourceLink<HostHandle> destLink = daemonConfig.getDaemonHostLink();
65  		HeadResourceInfo daemonInfo = daemonConfig.getHeadResource();
66  		
67  		// Resolve daemon bundle and destination
68  		String bundleName = IOUtils.concatenate(daemonConfig.getDistribution().getVersionedName(), "-daemon");
69  		BundleHandle bundle = new BundleHandle(bundleType, localBundlesPath, bundleName);
70  		
71  		// Deploy daemon
72  		return bundle.deploy(destLink, daemonInfo.getInstallPath(), daemonConfig.getKeys());
73  	}
74  	
75  	public boolean setupDaemon() throws RemoteExecutionException {
76  		HeadResourceInfo daemonInfo = daemonConfig.getHeadResource();
77  		String configRemotePath = daemonInfo.toFileProtocol(daemonInfo.getInstallation().getConfigurationFilePath());
78  
79  		try {
80  			FileHandle serLinkHandle = daemonConfig.getKeys().createFileLink(configRemotePath).createHandle();
81  			// TODO: Make aborting of setup phase more robust than just checking for serialized link
82  			// DaemonApp should know when to re-install database and such.
83  			if (serLinkHandle.exists()) return false; 
84  			serLinkHandle.storeObject(daemonConfig);
85          } catch (HandleOperationException e) {
86          	throw new RemoteExecutionException("transfer serialized link to remote destination '" + configRemotePath + "' ", e);
87          }
88  		return true;
89  	}
90  
91  	public void launchDaemon() throws RemoteExecutionException {
92  		ShellCommand cmd = daemonConfig.getHeadResource().createDaemonLauncherCommand();
93          String result = runCommandOnDaemonsHost(cmd);
94          if (!result.contains(cmd.getExitToken())) { 
95          	log.warn("Command '" + cmd.getCmd() + "' failed to execute." + "\n\n" + result.replace("\n", "\n\t"));
96          	throw new RemoteExecutionException("run launch command '" + cmd.getCmd() + "'", new Exception());
97          }
98  	}
99  	
100 	private String runCommandOnDaemonsHost(ShellCommand cmd) throws RemoteExecutionException {
101         ResourceLink<HostHandle> nodeLink = daemonConfig.getDaemonHostLink();
102         try {
103 			return nodeLink.createHandle().runCommand(cmd);
104         } catch (HandleCreationException e) {
105         	throw new RemoteExecutionException("connect to remote host '" + nodeLink.getURI() + "' to launch daemon", e);
106         } catch (ConnectorException e) {
107         	throw new RemoteExecutionException("execute launch command '" + cmd.getCmd() + "'", e);
108         }
109     }
110 }
111