<%@page import="org.apache.axis.transport.http.AdminServlet"%>
<%!private static final String cvsId = "$Id: ws_admin_listdatasources.jsp,v 1.0 2016/07/25 11:12:00 thu Exp $";%>
<%@ page language="java" contentType="text/html; charset=UTF-8"%>
<%@ page import="com.hof.util.*, java.util.*, java.text.*"%>
<%@ page import="com.hof.web.form.*"%>
<%@ page import="com.hof.mi.web.service.*"%>
<%
	/*
	
	  List DataSources
	  Using Java generated stubs rather that using the Yellowfin webservices API..
	
	*/
	String baseuri = request.getRequestURI();
	int index = baseuri.lastIndexOf('/');
	if (index >= 0)
		baseuri = baseuri.substring(0, index);

	String self = request.getServletPath();
	self = self.substring(self.lastIndexOf('/') + 1);
	self = baseuri + "/" + self;

	AdministrationServiceResponse rs = null;
	AdministrationServiceRequest rsr = new AdministrationServiceRequest();
	AdministrationServiceService ts = new AdministrationServiceServiceLocator("localhost", 8080,
			"/services/AdministrationService", false);
	AdministrationServiceSoapBindingStub rssbs = (AdministrationServiceSoapBindingStub) ts
			.getAdministrationService();

	rsr.setLoginId("admin@yellowfin.com.au");
	rsr.setPassword("test");
	rsr.setOrgId(new Integer(1));
	rsr.setFunction("LISTDATASOURCES");

	rs = rssbs.remoteAdministrationCall(rsr);

	String tmp = (String) request.getParameter("sourceId");
	String cmd = (String) request.getParameter("cmd");
	
	String errorMsg = "";
	String successMsg = "";
	StringBuilder listDataSources = new StringBuilder();
	AdministrationDataSource selectedDs = null;
	AdministrationDataSource[] dataSources = null;

	Integer selectedId = null;	
	if (tmp != null && !tmp.isEmpty()) {
		try {
			selectedId = Integer.valueOf(tmp.trim());
		} catch (Exception ex) {
			//ignore
		}
	}
	
	if ("SUCCESS".equals(rs.getStatusCode())) {
		dataSources = rs.getDatasources();
		successMsg = "DATASOURCE LISTING DONE.";
	} else {
		errorMsg = "Failed to list available data sources. Code: " + rs.getErrorCode();
	}
	
	if ("SAVEDATASOURCE".equals(cmd)) {
		 
		String name = (String)request.getParameter("sourceName");
		String desc = (String)request.getParameter("sourceDesc");
		String connectionType = (String)request.getParameter("connectionType");
		String sourceOptions = (String)request.getParameter("dataSourceOptions");
		
		AdministrationDataSource adm = new AdministrationDataSource();
		try {
			adm.setSourceId(selectedId);		
			adm.setSourceName(name);
			adm.setSourceDescription(desc);
			adm.setConnectionType(connectionType);		
			adm.setConnectionTypeCode("GENERICUSER");
			adm.setAccessLevelCode((String)request.getParameter("accessLevelCode"));
			adm.setConnectionDriver((String)request.getParameter("connectionDriver"));
			adm.setConnectionPath((String)request.getParameter("connectionPath"));
			adm.setConnectionString((String)request.getParameter("connectionString"));
			adm.setConnectionTypeCode((String)request.getParameter("connectionTypeCode"));
			adm.setMaxmimumConnections(Integer.valueOf(request.getParameter("maxConnections")));
			adm.setMinimumConnections(Integer.valueOf(request.getParameter("minConnections")));
			adm.setMaxRows(Integer.valueOf(request.getParameter("maxRows")));
			adm.setRefreshTime(Integer.valueOf(request.getParameter("refreshTime")));
			adm.setConnectionTimeout(Integer.valueOf(request.getParameter("timeOut")));
			adm.setSourceType((String)request.getParameter("sourceType"));
			adm.setLogFile((String)request.getParameter("logFile"));
			adm.setUserName((String)request.getParameter("userName"));
			adm.setTimezone((String)request.getParameter("timeZone"));
			adm.setUserPassword((String)request.getParameter("password"));
			
			if (sourceOptions != null && !sourceOptions.isEmpty()) {
				String[] kvs = sourceOptions.split(";");
				List<AdministrationDataSourceOption> admSourceOptions = new ArrayList<AdministrationDataSourceOption>();
				
				for (String kv : kvs) {
					String[] p = kv.split("#");
					AdministrationDataSourceOption opt = new AdministrationDataSourceOption();
					if (p.length > 1) {					
						opt.setOptionKey(p[0]);
						opt.setOptionValue(p[1]);					
					} else if (p.length > 0){
						opt.setOptionKey(p[0]);
						opt.setOptionValue(null);
					}
					
					admSourceOptions.add(opt);
				}
				AdministrationDataSourceOption[] options = new AdministrationDataSourceOption[admSourceOptions.size()];
				adm.setSourceOptions(admSourceOptions.toArray(options));
			}
			
			rsr.setFunction("SAVEDATASOURCE");
			rsr.setDatasource(adm);
			
			rs = rssbs.remoteAdministrationCall(rsr);
			
			boolean isNewDataSource = (selectedId == null); 
					
			if ("SUCCESS".equals(rs.getStatusCode())) {
				selectedDs = rs.getLoadedDataSource();
				selectedId = selectedDs.getSourceId(); 
				// reload list
				rsr.setFunction("LISTDATASOURCES");
				rs = rssbs.remoteAdministrationCall(rsr);
				
				if ("SUCCESS".equals(rs.getStatusCode())) {
					dataSources = rs.getDatasources();
				} else {
					errorMsg = "Failed to load data source list. Code: " + rs.getErrorCode();
				}
				// load full details for newly created data source			
				rsr.setSourceId(selectedId);
				rsr.setFunction("LOADDATASOURCE");
		
				rs = rssbs.remoteAdministrationCall(rsr);
		
				if ("SUCCESS".equals(rs.getStatusCode())) {
					selectedDs = rs.getLoadedDataSource();
					if (isNewDataSource)
						successMsg = "DATASOURCE HAS BEEN CREATED. NEW DATASOURCE ID:" + selectedId;
					else	
						successMsg = "DATASOURCE HAS BEEN SAVED.";
				} else {
					selectedDs = null;				
					errorMsg = "Failed to load data source details. Code: " + rs.getErrorCode();
				}			
			} else {
				selectedDs = null;			 
				errorMsg = "Failed to load data source details. Code: " + rs.getErrorCode();
			}
		} catch (Exception ex) {
			selectedDs = null;			 
			errorMsg = "Failed to save data source details. Error: " + ex.getMessage();
		}
		
	}
	
	if ("LINKDATASOURCE".equals(cmd)) {
		try {
			Integer primarySourceId = null;
			Integer clientSourceId = null;
			String param1 = (String) request.getParameter("primarySourceId");
			String param2 = (String) request.getParameter("clientSourceId");
			
			if (param1 != null && !param1.isEmpty())
				primarySourceId = Integer.valueOf(param1);
			if (param2 != null && !param2.isEmpty())
				clientSourceId = Integer.valueOf(param2);
			
			rsr.setFunction("LINKDATASOURCE");
			rsr.setSourceId(primarySourceId);
			AdministrationDataSourceClientLink link = new AdministrationDataSourceClientLink();
			link.setSourceId(clientSourceId);	
			rsr.setSourceClientLink(link);
			
			rs = rssbs.remoteAdministrationCall(rsr);
			
			if ("SUCCESS".equals(rs.getStatusCode())) {			
				selectedDs = rs.getLoadedDataSource();
				selectedId = selectedDs.getSourceId(); 
				successMsg = "CLIENT DATASOURCE HAS BEEN LINKED TO PRIMARY.";
			} else {
				selectedDs = null;			 
				errorMsg = "Failed to link primary source with client source. Code: " + rs.getErrorCode();
			}
		} catch (Exception ex) {
			selectedDs = null;			 
			errorMsg = "Failed to link primary source with client source. Error: " + ex.getMessage();
		}
	}
	
	if ("LOADDATASOURCE".equals(cmd) && selectedId != null) {
		rsr.setSourceId(selectedId);
		rsr.setFunction("LOADDATASOURCE");

		rs = rssbs.remoteAdministrationCall(rsr);

		if ("SUCCESS".equals(rs.getStatusCode())) {
			selectedDs = rs.getLoadedDataSource();
			successMsg = "DATASOURCE DETAILS HAS BEEN LOADED.";
		} else {
			selectedDs = null;
			errorMsg = "Failed to load data source details. Code: " + rs.getErrorCode();
		}
	}
	
	if (dataSources != null) {
		for (int i = 0; i < dataSources.length; i++) {
			AdministrationDataSource dataSource = dataSources[i];

			listDataSources.append("<br/><b>").append((i + 1)).append(") ").append(dataSource.getSourceId())
					.append(" - ").append(dataSource.getSourceName()).append("</b><br/><i>")
					.append(dataSource.getSourceDescription()).append("</i><br/><br/> Source Type:&nbsp;&nbsp;")
					.append(dataSource.getSourceType()).append("<br/> Connection Type:&nbsp;&nbsp;")
					.append(dataSource.getConnectionType()).append("<br/> Driver:&nbsp;&nbsp;")
					.append(dataSource.getConnectionDriver()).append("<br/> Maximum Connection:&nbsp;&nbsp;")
					.append(dataSource.getMaxmimumConnections()).append("<br/>")
					.append(dataSource.getConnectionDriver()).append("<br/> Access Level Code:&nbsp;&nbsp;")
					.append(dataSource.getAccessLevelCode()).append("<br/>");
		}
	}
%>
<%!
public String printString(Object str) {
	if (str != null)
		return str.toString();
	return "";
}
 %>
<html>
<head>
<style type="text/css">
body {
	font-family: arial;
	font-size: 12px;
}
label {
	width: 150px;		
}
input[type=text] {
	margin-top: 3px;
	margin-bottom: 3px;
	color: blue;
}
</style>
<script type="text/javascript">
	function loadDataSource() {
		document.getElementById("cmd").value = "LOADDATASOURCE";
		document.getElementById("testForm").submit();
	}

	function saveDataSource(save) {
		document.getElementById("cmd").value = "SAVEDATASOURCE";
		var sourceOptions = document.getElementsByName("options");
		var tmp = "";
		if (sourceOptions && sourceOptions.length > 0) {
			for (i = 0; i < sourceOptions.length; i ++) {
				var val = sourceOptions[i].value;
				var rel = sourceOptions[i].getAttribute("rel");
				tmp = tmp + rel + "#" + val + ";";
			}			
			document.getElementById("dataSourceOptions").value = tmp;
		}		
		if (!save) {
			document.getElementById("sourceId").value = "";
		}
		document.getElementById("testForm").submit();
	}
	
	function linkSources() {
		document.getElementById("cmd").value = "LINKDATASOURCE";
		document.getElementById("testForm").submit();
	}
</script>
</head>
<body>
<form id="testForm" action="<%=self%>" method="post">
	<br/><br/>
	<center><h3 style="color: green;"><%=successMsg%></h3></center>
	<center><h3 style="color: red;"><%=errorMsg%></h3></center>
	<div style="float: left; width: 33%;">		
		<h2>1. Data Source Listing</h2>
		<div style="width: 90%; margin: auto; height: 80%; overflow: auto;">			
			<%=listDataSources.toString()%>
		</div>
	</div>
	<div style="float: left; width: 33%;">		
		<div style="width: 90%; margin: auto;">
			<h2>2. Load & Edit Data Source</h2>			
				<input type="hidden" id="cmd" name="cmd" value="" />	
				<input type="hidden" id="dataSourceOptions" name="dataSourceOptions" value="">				
				<div>
					<br /> <b>Load data source details</b> <br /> <i>Please pick the
						data source ID from the datasource list, enter it into the input below
						and hit "load" button </i> <br />
					<br />
					<label>Data Source ID</label><br/> 
					<input type="text" id="sourceId" name="sourceId" value="<%=selectedId != null ? selectedId: ""%>"> <input
						type="button" name="process" value="Load"
						onclick="loadDataSource()">
				</div>
				<br />
				<div style="float: left; width: 50%;">					
					<b>Data Source details</b> <br />
					<%
						if (selectedDs != null) {
					%>
					<label for="sourceId">Source Id:</label><br /> <input type="text"
						name="id"
						value="<%=selectedDs.getSourceId() != null ? selectedDs.getSourceId().toString(): ""%>"
						readonly="readonly" style="background-color: grey;"/><br /> 
					<label
						for="sourceName">Source Name:</label><br /> <input type="text"
						id="sourceName" name="sourceName"
						value="<%=printString(selectedDs.getSourceName())%>" /><br /> <label
						for="sourceDesc">Source Description:</label><br /> <input
						type="text" id="sourceDesc" name="sourceDesc"
						value="<%=printString(selectedDs.getSourceDescription())%>" /><br /><label
						for="connectionType">Connection Type:</label><br /> <input
						type="text" id="connectionType" name="connectionType"
						value="<%=printString(selectedDs.getConnectionType())%>" /><br />
						
					<br />	
					<label >Time Zone:</label><br />
					<input type="text" name="timeZone" value="<%=printString(selectedDs.getTimezone())%>"><br />
					<label >Access Level Code:</label><br />
					<input type="text" name="accessLevelCode" value="<%=printString(selectedDs.getAccessLevelCode())%>"><br />
					<label >Connection Driver:</label><br />
					<input type="text" name="connectionDriver" value="<%=printString(selectedDs.getConnectionDriver())%>"><br />
					<label >Connection Path:</label><br />
					<input type="text" name="connectionPath" value="<%=printString(selectedDs.getConnectionPath())%>"><br />
					<label >Connection String</label><br />
					<input type="text" name="connectionString" value="<%=printString(selectedDs.getConnectionString())%>"><br />
					<label >Connection Type Code:</label><br />
					<input type="text" name="connectionTypeCode" value="<%=printString(selectedDs.getConnectionTypeCode())%>">	<br />				
					<input type="hidden" name="logFile" value="<%=printString(selectedDs.getLogFile())%>">					
					<input type="hidden" name="sourceType" value="<%=printString(selectedDs.getSourceType())%>">
					<label style="color:red;">User:</label><br />					
					<input type="text" name="userName" value="<%=printString(selectedDs.getUserName())%>"><br/>
					<label style="color:red;">Password:</label><br />					
					<input type="password" name="password" value="<%=printString(selectedDs.getUserPassword())%>"><br/>
					<label >Max Connections:</label><br />
					<input type="text" name="maxConnections" value="<%=printString(selectedDs.getMaxmimumConnections())%>"><br />
					<label >Min Connections:</label><br />
					<input type="text" name="minConnections" value="<%=printString(selectedDs.getMinimumConnections())%>"><br />
					<label >Max Rows:</label><br />
					<input type="text" name="maxRows" value="<%=printString(selectedDs.getMaxRows())%>"><br />
					<label >Refresh Time:</label><br />
					<input type="text" name="refreshTime" value="<%=printString(selectedDs.getRefreshTime())%>"><br />
					<label >Time out:</label><br />
					<input type="text" name="timeOut" value="<%=printString(selectedDs.getConnectionTimeout())%>"><br />					
					</div>
					<div style="float: left; width: 50%;">
					<b>Options</b><br /><br/>					
					<%		
						AdministrationDataSourceOption[] options = selectedDs.getSourceOptions();
						if (options != null) {
							int idx = 0;
								for (AdministrationDataSourceOption opt : options) {							
%>
					<label><%=opt.getOptionKey()%></label><br/>
					<input type="text" name="options" value="<%=printString(opt.getOptionValue())%>" rel="<%=printString(opt.getOptionKey())%>" /><br/>													
<%					
									idx ++;
								}
						}
%>					
					<br/>
					<b>Linked Client Source:</b><br /> 
					<%
						AdministrationDataSourceClientLink[] linkedClientSources = selectedDs.getClientSources();
						if (linkedClientSources != null) {
							for (AdministrationDataSourceClientLink ls : linkedClientSources) {
					%>
							<span>Client Org ID:</span>&nbsp;&nbsp;
							<%=ls.getClientOrgId().toString()%><br /> <span>Internal Ref:</span>&nbsp;&nbsp;
							<%=ls.getClientOrgRef()%><br /> <span>Source ID:</span>&nbsp;&nbsp;
							<%=ls.getSourceId().toString()%><br /><br />
					<%
							}
						}
					
				}		
%>
					<br/>
					<input type="button" value="Save Data Source" onclick="saveDataSource(true)" /><br/><br/>
					<input type="button" value="Clear Source ID and Save As New Data Source" onclick="saveDataSource(false)" />
					<br/><br/>
				</div>			
		</div>			
	</div>
	<div style="float: left; width: 33%;">		
		<div style="width: 90%; margin: auto;">
			<h2>3. Link Client Source to Primary Source</h2>
			<span>Primary Source Id</span><br/>
			<input type="text" name="primarySourceId" value="" /><br/>
			<span>Client Source Id</span><br/>
			<input type="text" name="clientSourceId" value=""/><br/><br/>
			<input type="button" value="Link Client Source to Primary" onclick="linkSources()"/>
			
		</div>
	</div>						
	<br />
	<br />
</form>	
</body>
</html>