Merge branch 'volume-logs'

7 files changed, 311 insertions, 33 deletions

diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/AbstractClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/AbstractClient.java
index 10064341..fedfacaa 100644
--- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/AbstractClient.java
+++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/AbstractClient.java
@@ -161,7 +161,7 @@ public abstract class AbstractClient {
 	 */

 	@SuppressWarnings({ "unchecked", "rawtypes" })

 	protected Object postRequest(Class responseClass, Form form) {

-		return resource.type(MediaType.APPLICATION_FORM_URLENCODED_TYPE).header("Authorization", authHeader)

+		return resource.type(MediaType.APPLICATION_FORM_URLENCODED_TYPE).header(HTTP_HEADER_AUTH, authHeader)

 				.accept(MediaType.TEXT_XML).post(responseClass, form);

 	}

 

@@ -179,7 +179,7 @@ public abstract class AbstractClient {
 	@SuppressWarnings({ "rawtypes", "unchecked" })

 	protected Object postRequest(String subResourceName, Class responseClass, Form form) {

 		return resource.path(subResourceName).type(MediaType.APPLICATION_FORM_URLENCODED_TYPE)

-				.header("Authorization", authHeader).accept(MediaType.TEXT_XML).post(responseClass, form);

+				.header(HTTP_HEADER_AUTH, authHeader).accept(MediaType.TEXT_XML).post(responseClass, form);

 	}

 

 	/**

@@ -195,7 +195,21 @@ public abstract class AbstractClient {
 	 */

 	protected Object putRequest(String subResourceName, Class responseClass, Form form) {

 		return resource.path(subResourceName).type(MediaType.APPLICATION_FORM_URLENCODED_TYPE)

-				.header("Authorization", authHeader).accept(MediaType.TEXT_XML).put(responseClass, form);

+				.header(HTTP_HEADER_AUTH, authHeader).accept(MediaType.TEXT_XML).put(responseClass, form);

+	}

+

+	/**

+	 * Submits given Form using PUT method to the given sub-resource and returns the object received as response

+	 * 

+	 * @param responseClass

+	 *            Class of the object expected as response

+	 * @param form

+	 *            Form to be submitted

+	 * @return Object of given class received as response

+	 */

+	protected Object putRequest(Class responseClass, Form form) {

+		return resource.type(MediaType.APPLICATION_FORM_URLENCODED_TYPE).header(HTTP_HEADER_AUTH, authHeader)

+				.accept(MediaType.TEXT_XML).put(responseClass, form);

 	}

 

 	/**

@@ -209,7 +223,7 @@ public abstract class AbstractClient {
 	 */

 	protected Object putRequest(String subResourceName, Class responseClass) {

 		return resource.path(subResourceName).type(MediaType.APPLICATION_FORM_URLENCODED_TYPE)

-				.header("Authorization", authHeader).accept(MediaType.TEXT_XML).put(responseClass);

+				.header(HTTP_HEADER_AUTH, authHeader).accept(MediaType.TEXT_XML).put(responseClass);

 	}

 

 	/**

diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/ClustersClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/ClustersClient.java
index 08c380e0..8eeb96fe 100644
--- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/ClustersClient.java
+++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/ClustersClient.java
@@ -19,6 +19,7 @@
 package com.gluster.storage.management.client;
 
 import static com.gluster.storage.management.core.constants.RESTConstants.FORM_PARAM_CLUSTER_NAME;
+import static com.gluster.storage.management.core.constants.RESTConstants.FORM_PARAM_SERVER_NAME;
 import static com.gluster.storage.management.core.constants.RESTConstants.RESOURCE_PATH_CLUSTERS;
 
 import java.util.List;
@@ -58,6 +59,13 @@ public class ClustersClient extends AbstractClient {
 		return (Status)postRequest(Status.class, form);
 	}
 	
+	public Status registerCluster(String clusterName, String knownServer) {
+		Form form = new Form();
+		form.add(FORM_PARAM_CLUSTER_NAME, clusterName);
+		form.add(FORM_PARAM_SERVER_NAME, knownServer);
+		return (Status)putRequest(Status.class, form);
+	}
+	
 	public Status deleteCluster(String clusterName) {
 		return (Status)deleteSubResource(clusterName, Status.class);
 	}
diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/UsersClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/UsersClient.java
index 099b64a0..864418a7 100644
--- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/UsersClient.java
+++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/UsersClient.java
@@ -18,6 +18,8 @@
  *******************************************************************************/
 package com.gluster.storage.management.client;
 
+import javax.ws.rs.core.Response;
+
 import com.gluster.storage.management.core.model.Status;
 import com.sun.jersey.api.client.UniformInterfaceException;
 import com.sun.jersey.api.representation.Form;
@@ -27,7 +29,6 @@ public class UsersClient extends AbstractClient {
 	private static final String RESOURCE_NAME = "users";
 	private static final String FORM_PARAM_OLD_PASSWORD = "oldpassword";
 	private static final String FORM_PARAM_NEW_PASSWORD = "newpassword";
-	private static final int HTTP_STATUS_UNAUTHORIZED = 401;
 
 	private String generateSecurityToken(String user, String password) {
 		return new String(Base64.encode(user + ":" + password));
@@ -48,7 +49,8 @@ public class UsersClient extends AbstractClient {
 			return authStatus;
 		} catch (Exception e) {
 			if (e instanceof UniformInterfaceException
-					&& ((UniformInterfaceException) e).getResponse().getStatus() == HTTP_STATUS_UNAUTHORIZED) {
+					&& ((UniformInterfaceException) e).getResponse().getStatus() == Response.Status.UNAUTHORIZED
+							.getStatusCode()) {
 				// authentication failed. clear security token.
 				setSecurityToken(null);
 				return new Status(Status.STATUS_CODE_FAILURE, "Invalid user id or password!");
diff --git a/src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/constants/RESTConstants.java b/src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/constants/RESTConstants.java
index 80622992..33323021 100644
--- a/src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/constants/RESTConstants.java
+++ b/src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/constants/RESTConstants.java
@@ -40,6 +40,7 @@ public class RESTConstants {
 	public static final String RESOURCE_SERVERS = "servers";
 
 	public static final String FORM_PARAM_CLUSTER_NAME = "clusterName";
+	public static final String FORM_PARAM_SERVER_NAME = "serverName";
 	public static final String FORM_PARAM_DISKS = "disks";
 	public static final String FORM_PARAM_OPERATION = "operation";
 	public static final String FORM_PARAM_VALUE_START = "start";
diff --git a/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/ClusterSelectionDialog.java b/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/ClusterSelectionDialog.java
index 7bc6eb58..f001da62 100644
--- a/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/ClusterSelectionDialog.java
+++ b/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/ClusterSelectionDialog.java
@@ -24,8 +24,11 @@ import org.eclipse.jface.dialogs.Dialog;
 import org.eclipse.jface.dialogs.IDialogConstants;
 import org.eclipse.jface.fieldassist.ControlDecoration;
 import org.eclipse.swt.SWT;
+import org.eclipse.swt.custom.StackLayout;
 import org.eclipse.swt.events.ModifyEvent;
 import org.eclipse.swt.events.ModifyListener;
+import org.eclipse.swt.events.SelectionAdapter;
+import org.eclipse.swt.events.SelectionEvent;
 import org.eclipse.swt.events.TraverseEvent;
 import org.eclipse.swt.events.TraverseListener;
 import org.eclipse.swt.layout.GridData;
@@ -36,6 +39,7 @@ import org.eclipse.swt.widgets.Composite;
 import org.eclipse.swt.widgets.Control;
 import org.eclipse.swt.widgets.Label;
 import org.eclipse.swt.widgets.Shell;
+import org.eclipse.swt.widgets.Text;
 
 import com.gluster.storage.management.gui.IImageKeys;
 import com.gluster.storage.management.gui.utils.GUIHelper;
@@ -44,14 +48,31 @@ import com.gluster.storage.management.gui.utils.GUIHelper;
  * Cluster selection dialog, which prompts for the cluster name to be managed
  */
 public class ClusterSelectionDialog extends Dialog {
+	protected enum CLUSTER_MODE { SELECT, CREATE, REGISTER };
+	
 	private Combo clusterNameCombo = null;
+	private Text newClusterNameText = null;
+	private Text existingClusterNameText = null;
+	private Text serverNameText = null;
 	private Button okButton;
 
 	private final GUIHelper guiHelper = GUIHelper.getInstance();
 	private Composite composite;
-	private ControlDecoration errorDecoration;
+	private ControlDecoration newClusterNameErrorDecoration;
+	private ControlDecoration existingClusterNameErrorDecoration;
+	private ControlDecoration serverNameErrorDecoration;
 	private List<String> clusters;
+	private Button selectButton;
+	private Button createButton;
+	private Button registerButton;
+	private Composite clusterSelectionComposite;
+	private Composite clusterCreationComposite;
+	private Composite clusterRegisterComposite;
+	private StackLayout stackLayout;
+
 	private String clusterName;
+	private CLUSTER_MODE clusterMode;
+	private String serverName;
 
 	public ClusterSelectionDialog(Shell parentShell, List<String> clusters) {
 		super(parentShell);
@@ -79,24 +100,20 @@ public class ClusterSelectionDialog extends Dialog {
 	}
 
 	private void createClusterNameLabel(Composite composite) {
-		Label userIdLabel = new Label(composite, SWT.NONE);
-		userIdLabel.setText("&Cluster to Manage:");
-		userIdLabel.setLayoutData(new GridData(GridData.END, GridData.CENTER, false, false));
+		Label clusterNameLabel = new Label(composite, SWT.NONE);
+		clusterNameLabel.setText("Cluster &Name:");
+		clusterNameLabel.setLayoutData(new GridData(GridData.END, GridData.CENTER, false, false));
 	}
 
 	private void createClusterNameCombo(Composite composite) {
-		clusterNameCombo = new Combo(composite, SWT.BORDER);
+		clusterNameCombo = new Combo(composite, SWT.READ_ONLY);
 		clusterNameCombo.setItems(clusters.toArray(new String[0]));
 		clusterNameCombo.select(0);
-
-//		GridData layoutData = new GridData(SWT.FILL, GridData.FILL, true, false);
-//		layoutData.widthHint = convertWidthInCharsToPixels(32);
-//		clusterNameCombo.setLayoutData(layoutData);
 	}
 
 	private void configureDialogLayout(Composite composite) {
 		GridLayout layout = (GridLayout) composite.getLayout();
-		layout.numColumns = 2;
+		layout.numColumns = 3;
 		layout.marginLeft = 20;
 		layout.marginRight = 20;
 		layout.marginTop = 20;
@@ -123,13 +140,191 @@ public class ClusterSelectionDialog extends Dialog {
 		composite = (Composite) super.createDialogArea(parent);
 		configureDialogLayout(composite);
 
-		createClusterNameLabel(composite);
-		createClusterNameCombo(composite);
-		createErrorDecoration();
+		createRadioButtons();
+		createSubComposites();
 
 		return composite;
 	}
 
+	private void createSubComposites() {
+		Composite subComposite = new Composite(composite, SWT.NONE);
+		GridData data = new GridData();
+		data.horizontalSpan = 3;
+		subComposite.setLayoutData(data);
+		stackLayout = new StackLayout();
+		subComposite.setLayout(stackLayout);
+		
+		createClusterSelectionComposite(subComposite, stackLayout);
+		createClusterCreationComposite(subComposite);
+		createClusterRegisterComposite(subComposite);
+		
+		createRadioButtonListeners(subComposite);
+		if(clusters.size() > 0) {
+			selectButton.setSelection(true);
+		} else {
+			createButton.setSelection(true);
+		}
+	}
+
+	private void createClusterRegisterComposite(Composite composite) {
+		clusterRegisterComposite = new Composite(composite, SWT.NONE);
+		GridLayout layout = new GridLayout(2, false);
+		clusterRegisterComposite.setLayout(layout);
+
+		createClusterNameLabel(clusterRegisterComposite);
+		existingClusterNameText = createText(clusterRegisterComposite);
+		existingClusterNameText.setToolTipText("Enter a name for the cluster being registered.");
+		existingClusterNameErrorDecoration = createErrorDecoration(existingClusterNameText, "Please enter a cluster name!");
+		existingClusterNameErrorDecoration.show();
+		
+		createClusterServerLabel(clusterRegisterComposite);
+		serverNameText = createText(clusterRegisterComposite);
+		serverNameText.setToolTipText("Enter host name / IP address of one of the servers of the cluster.");
+		serverNameErrorDecoration = createErrorDecoration(serverNameText, "Please enter a server name!");
+		serverNameErrorDecoration.show();
+	}
+
+	private void createClusterServerLabel(Composite composite) {
+		Label serverNameLabel = new Label(composite, SWT.NONE);
+		serverNameLabel.setText("Server Na&me:");
+		serverNameLabel.setLayoutData(new GridData(GridData.END, GridData.CENTER, false, false));
+	}
+
+	private void createClusterCreationComposite(Composite subComposite) {
+		clusterCreationComposite = new Composite(subComposite, SWT.NONE);
+		GridLayout layout = new GridLayout(2, false);
+		clusterCreationComposite.setLayout(layout);
+
+		createClusterNameLabel(clusterCreationComposite);
+		newClusterNameText = createText(clusterCreationComposite);
+		newClusterNameText.setToolTipText("Enter name of the cluster to be created");
+		newClusterNameErrorDecoration = createErrorDecoration(newClusterNameText, "Please enter cluster name!");
+		newClusterNameErrorDecoration.show();
+	}
+
+	private Text createText(Composite parent) {
+		Text text = new Text(parent, SWT.NONE);
+		GridData layoutData = new GridData(SWT.FILL, GridData.FILL, true, false);
+		int width = convertWidthInCharsToPixels(32);
+		layoutData.widthHint = width;
+		layoutData.minimumWidth = width;
+		text.setLayoutData(layoutData);
+		
+		text.addModifyListener(new ModifyListener() {
+			@Override
+			public void modifyText(ModifyEvent e) {
+				validate();
+			}
+		});
+		
+		return text;
+	}
+
+	private void createClusterSelectionComposite(Composite subComposite, StackLayout stackLayout) {
+		clusterSelectionComposite = new Composite(subComposite, SWT.NONE);
+		GridLayout layout = new GridLayout(2, false);
+		clusterSelectionComposite.setLayout(layout);
+		createClusterNameLabel(clusterSelectionComposite);
+		createClusterNameCombo(clusterSelectionComposite);
+		stackLayout.topControl = clusterSelectionComposite;
+	}
+
+	private void createRadioButtons() {
+		{
+			if (clusters.size() > 0) {
+				selectButton = new Button(composite, SWT.RADIO);
+				selectButton.setText("&Select");
+			}
+		}
+		{
+			createButton = new Button(composite, SWT.RADIO);
+			createButton.setText("&Create");
+		}
+		{
+			registerButton = new Button(composite, SWT.RADIO);
+			registerButton.setText("&Register");
+		}
+	}
+	
+	private void validate() {
+		okButton.setEnabled(false);
+		
+		if(selectButton.getSelection()) {
+			okButton.setEnabled(true);
+			return;
+		}
+		
+		if(createButton.getSelection()) {
+			String newClusterName = newClusterNameText.getText().trim(); 
+			if(newClusterName.isEmpty()) {
+				newClusterNameErrorDecoration.setDescriptionText("Please enter a cluster name!");
+				newClusterNameErrorDecoration.show();
+			} else if(clusters.contains(newClusterName)) {
+				newClusterNameErrorDecoration.setDescriptionText("Cluster [" + newClusterName + "] already exists!");
+				newClusterNameErrorDecoration.show();
+			} else {
+				okButton.setEnabled(true);
+				newClusterNameErrorDecoration.hide();
+			}
+		}
+		
+		if(registerButton.getSelection()) {
+			okButton.setEnabled(true);
+			String clusterName = existingClusterNameText.getText().trim(); 
+			if(existingClusterNameText.getText().trim().isEmpty()) {
+				existingClusterNameErrorDecoration.setDescriptionText("Please enter a cluster name!");
+				existingClusterNameErrorDecoration.show();
+				okButton.setEnabled(false);
+			} else if(clusters.contains(clusterName)) {
+				existingClusterNameErrorDecoration.setDescriptionText("Cluster [" + clusterName + "] already exists!");
+				existingClusterNameErrorDecoration.show();
+				okButton.setEnabled(false);
+			} else {
+				existingClusterNameErrorDecoration.hide();
+			}
+			
+			if(serverNameText.getText().trim().isEmpty()) {
+				serverNameErrorDecoration.show();
+				okButton.setEnabled(false);
+			} else {
+				serverNameErrorDecoration.hide();
+			}
+		}
+	}
+
+	private void createRadioButtonListeners(final Composite parent) {
+		if (clusters.size() > 0) {
+			selectButton.addSelectionListener(new SelectionAdapter() {
+				@Override
+				public void widgetSelected(SelectionEvent e) {
+					stackLayout.topControl = clusterSelectionComposite;
+					clusterNameCombo.select(0);
+					validate();
+					parent.layout();
+					clusterNameCombo.setFocus();
+				}
+			});
+		}
+		createButton.addSelectionListener(new SelectionAdapter() {
+			@Override
+			public void widgetSelected(SelectionEvent e) {
+				stackLayout.topControl = clusterCreationComposite;
+				validate();
+				parent.layout();
+				newClusterNameText.setFocus();
+			}
+		});
+		registerButton.addSelectionListener(new SelectionAdapter() {
+			@Override
+			public void widgetSelected(SelectionEvent e) {
+				stackLayout.topControl = clusterRegisterComposite;
+				validate();
+				parent.layout();
+				existingClusterNameText.setFocus();
+			}
+		});
+	}
+
 	@Override
 	protected void createButtonsForButtonBar(Composite parent) {
 		okButton = createButton(parent, IDialogConstants.OK_ID, IDialogConstants.OK_LABEL, true);
@@ -138,10 +333,11 @@ public class ClusterSelectionDialog extends Dialog {
 		setupDataBinding();
 	}
 	
-	private void createErrorDecoration() {
-		errorDecoration = guiHelper.createErrorDecoration(clusterNameCombo);
-		errorDecoration.setDescriptionText("Please select an existing cluster name, or enter a new one!");
+	private ControlDecoration createErrorDecoration(Text text, String message) {
+		ControlDecoration errorDecoration = guiHelper.createErrorDecoration(text);
+		errorDecoration.setDescriptionText(message);
 		errorDecoration.hide();
+		return errorDecoration;
 	}
 
 	/**
@@ -156,10 +352,10 @@ public class ClusterSelectionDialog extends Dialog {
 			public void modifyText(ModifyEvent e) {
 				if(clusterNameCombo.getText().trim().isEmpty()) {
 					okButton.setEnabled(false);
-					errorDecoration.show();
+					newClusterNameErrorDecoration.show();
 				} else {
 					okButton.setEnabled(true);
-					errorDecoration.hide();
+					newClusterNameErrorDecoration.hide();
 				}
 			}
 		});
@@ -167,11 +363,29 @@ public class ClusterSelectionDialog extends Dialog {
 	
 	@Override
 	protected void okPressed() {
-		clusterName = clusterNameCombo.getText();
+		if(selectButton.getSelection()) {
+			clusterMode = CLUSTER_MODE.SELECT;
+			clusterName = clusterNameCombo.getText();
+		} else if(createButton.getSelection()) {
+			clusterMode = CLUSTER_MODE.CREATE;
+			clusterName = newClusterNameText.getText().trim();
+		} else if(registerButton.getSelection()) {
+			clusterMode = CLUSTER_MODE.REGISTER;
+			clusterName = existingClusterNameText.getText().trim();
+			serverName = serverNameText.getText().trim();
+		}
 		super.okPressed();
 	}
 
 	public String getClusterName() {
 		return clusterName;
 	}
+
+	public CLUSTER_MODE getClusterMode() {
+		return clusterMode;
+	}
+
+	public String getServerName() {
+		return serverName;
+	}
 }
diff --git a/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/LoginDialog.java b/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/LoginDialog.java
index 947a8747..502923ba 100644
--- a/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/LoginDialog.java
+++ b/src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/LoginDialog.java
@@ -51,6 +51,7 @@ import com.gluster.storage.management.core.model.ConnectionDetails;
 import com.gluster.storage.management.core.model.Status;
 import com.gluster.storage.management.core.response.StringListResponse;
 import com.gluster.storage.management.gui.IImageKeys;
+import com.gluster.storage.management.gui.dialogs.ClusterSelectionDialog.CLUSTER_MODE;
 import com.gluster.storage.management.gui.utils.GUIHelper;
 import com.gluster.storage.management.gui.validators.StringRequiredValidator;
 
@@ -212,13 +213,17 @@ public class LoginDialog extends Dialog {
 				cancelPressed();
 				return;
 			}
+			
 			try {
+				CLUSTER_MODE mode = clusterDialog.getClusterMode();
 				String clusterName = clusterDialog.getClusterName();
-				if(clusterNames.contains(clusterName)) {
+				switch(mode) {
+				case SELECT:
 					GlusterDataModelManager.getInstance().initializeModel(usersClient.getSecurityToken(),
-						clusterName);
-				} else {
-					Status status = createCluster(clustersClient, clusterName);
+							clusterName);
+					break;
+				case CREATE:
+					Status status = clustersClient.createCluster(clusterName);
 					if(!status.isSuccess()) {
 						MessageDialog.openError(getShell(), "Cluster Creation Failed!", status.toString());
 						setReturnCode(RETURN_CODE_ERROR);
@@ -226,6 +231,9 @@ public class LoginDialog extends Dialog {
 					}
 					GlusterDataModelManager.getInstance().initializeModelWithNewCluster(usersClient.getSecurityToken(),
 							clusterName);
+					break;
+				case REGISTER:
+					break;
 				}
 				super.okPressed();
 					
@@ -239,10 +247,6 @@ public class LoginDialog extends Dialog {
 		}
 	}
 
-	private Status createCluster(ClustersClient clustersClient, String clusterName) {
-		return clustersClient.createCluster(clusterName);
-	}
-
 	private List<String> getClusterNames(ClustersClient clustersClient) {
 		StringListResponse clustersResponse = clustersClient.getClusters();
 		List<String> clusters = new ArrayList<String>();
diff --git a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/ClustersResource.java b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/ClustersResource.java
index f04941cf..18bece88 100644
--- a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/ClustersResource.java
+++ b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/ClustersResource.java
@@ -19,6 +19,7 @@
 package com.gluster.storage.management.server.resources;
 
 import static com.gluster.storage.management.core.constants.RESTConstants.FORM_PARAM_CLUSTER_NAME;
+import static com.gluster.storage.management.core.constants.RESTConstants.FORM_PARAM_SERVER_NAME;
 import static com.gluster.storage.management.core.constants.RESTConstants.PATH_PARAM_CLUSTER_NAME;
 import static com.gluster.storage.management.core.constants.RESTConstants.RESOURCE_PATH_CLUSTERS;
 
@@ -35,10 +36,14 @@ import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
 
+import com.gluster.storage.management.core.exceptions.ConnectionException;
+import com.gluster.storage.management.core.model.GlusterServer;
 import com.gluster.storage.management.core.model.Status;
 import com.gluster.storage.management.core.response.StringListResponse;
 import com.gluster.storage.management.server.data.ClusterInfo;
 import com.gluster.storage.management.server.data.PersistenceDao;
+import com.gluster.storage.management.server.data.ServerInfo;
+import com.gluster.storage.management.server.utils.GlusterUtil;
 import com.sun.jersey.api.core.InjectParam;
 
 /**
@@ -49,6 +54,12 @@ public class ClustersResource {
 
 	@InjectParam
 	private PersistenceDao clusterDao;
+	
+	@InjectParam
+	private GlusterServersResource glusterServersResource;
+	
+	@InjectParam
+	private GlusterUtil glusterUtil;
 
 	public void setClusterDao(PersistenceDao clusterDao) {
 		this.clusterDao = clusterDao;
@@ -86,6 +97,30 @@ public class ClustersResource {
 					+ "]: [" + e.getMessage() + "]");
 		}
 	}
+	
+	public Status registerCluster(@FormParam(FORM_PARAM_CLUSTER_NAME) String clusterName,
+			@FormParam(FORM_PARAM_SERVER_NAME) String knownServer) {
+		EntityTransaction txn = clusterDao.startTransaction();
+		ClusterInfo cluster = new ClusterInfo();
+		cluster.setName(clusterName);
+		
+		GlusterServer server = new GlusterServer(knownServer);
+		try {
+			List<GlusterServer> glusterServers = glusterUtil.getGlusterServers(server);
+			List<ServerInfo> servers = new ArrayList<ServerInfo>();
+			for(GlusterServer glusterServer : glusterServers) {
+				ServerInfo serverInfo = new ServerInfo();
+				serverInfo.setName(glusterServer.getName());
+				serverInfo.setCluster(cluster);
+				servers.add(serverInfo);
+			}
+			cluster.setServers(servers);
+			clusterDao.save(cluster);
+			return Status.STATUS_SUCCESS;
+		} catch(Exception e) {
+			return new Status(e);
+		}
+	}
 
 	@SuppressWarnings("unchecked")
 	@Path("{" + PATH_PARAM_CLUSTER_NAME + "}")