D-Net

package eu.dnetlib.administration.uis.modules.workflows;

import java.io.IOException;

import java.io.StringReader;

import java.util.Map;

import java.util.Map.Entry;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;

import org.dom4j.Document;

import org.dom4j.Element;

import org.dom4j.io.SAXReader;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.core.io.ClassPathResource;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import eu.dnetlib.clients.dsManager.DatasourceDesc;

import eu.dnetlib.clients.dsManager.DsManagerClient;

import eu.dnetlib.clients.dsManager.IfaceDesc;

import eu.dnetlib.clients.is.InformationServiceClient;

import eu.dnetlib.miscutils.functional.xml.ApplyXsltDom4j;

@Controller

public class WorkflowsOtherController {

	@Value("${ds.vocabulary.compatibilityLevels}")

	private String compatibilityLevelsVocabulary;

	@Autowired

	private InformationServiceClient isClient;

	@Autowired

	private DsManagerClient dsManagerClient;

	@RequestMapping("/page/datasource_api")

	public void getDatasourceApiHtml(final HttpServletResponse res, @RequestParam final String dsId, @RequestParam final String ifaceId) throws Exception {

		// final String profile = wfUtils.getDatasourceProfile(dsId);

		/*

		 * final DatasourceDesc ds = dsManagerClient.getDatasource(dsId);

		 *

		 * final SAXReader reader = new SAXReader(); final Document doc = reader.read(new StringReader(profile));

		 *

		 * final Node ifcNode = doc.selectSingleNode("//INTERFACE[@id = '" + ifaceId + "']");

		 *

		 * final String profileId = doc.valueOf("//RESOURCE_IDENTIFIER/@value");

		 *

		 * final String protocol = ifcNode.valueOf("./ACCESS_PROTOCOL"); final Element extra =

		 * doc.getRootElement().addElement("extra_info");

		 *

		 * final Element compLevels = extra.addElement("compatibilityLevels"); for (final VocabularyEntry e :

		 * wfUtils.fetchVocabularyTerms(compatibilityLevelsVocabulary)) { final Element l = compLevels.addElement("level");

		 * l.setText(e.getName()); }

		 *

		 * final Element parameters = extra.addElement("parameters"); for (final Object o : ifcNode.selectNodes("./ACCESS_PROTOCOL/@*")) {

		 * final Element p = parameters.addElement("param"); p.addAttribute("name", ((Node) o).getName()); p.setText(((Node) o).getText());

		 * }

		 *

		 * final Element extraFields = extra.addElement("extraFields"); for (final Object o :

		 * ifcNode.selectNodes("./INTERFACE_EXTRA_FIELD")) { final Element f = extraFields.addElement("field"); f.addAttribute("name",

		 * ((Node) o).valueOf("@name")); f.setText(((Node) o).getText()); }

		 *

		 * final Element wfs = extra.addElement("workflows"); for (final WorkflowItem item : wfUtils.listWorflowsForApi(profileId, ifaceId))

		 * { final Element wf = wfs.addElement("workflow"); wf.addAttribute("id", item.getWfId()); wf.addAttribute("name", item.getName());

		 * wf.addAttribute("description", item.getDesc()); if (item.isDestroy()) { wf.addAttribute("destroy", "1"); } } final Map<String,

		 * String> params = new HashMap<>(); params.put("profileId", doc.valueOf("//RESOURCE_IDENTIFIER/@value")); params.put("ifaceId",

		 * ifaceId); params.put("protocol", protocol); params.put("baseUrl", ifcNode.valueOf("./BASE_URL")); params.put("prefix",

		 * doc.valueOf(".//FIELD[./key = 'NamespacePrefix']/value")); params.put("typology", ifcNode.valueOf("@typology"));

		 * params.put("compliance", ifcNode.valueOf("@compliance")); params.put("overrideCompliance",

		 * ifcNode.valueOf("./INTERFACE_EXTRA_FIELD[@name='overriding_compliance']"));

		 *

		 * doc.selectSingleNode("/RESOURCE_PROFILE/HEADER").detach();

		 * doc.selectSingleNode("/RESOURCE_PROFILE/BODY/CONFIGURATION/INTERFACES").detach();

		 * doc.selectSingleNode("/RESOURCE_PROFILE/BODY/CONFIGURATION/EXTRA_FIELDS").detach();

		 * doc.selectSingleNode("/RESOURCE_PROFILE/BODY/QOS").detach(); doc.selectSingleNode("/RESOURCE_PROFILE/BODY/STATUS").detach();

		 * doc.selectSingleNode("/RESOURCE_PROFILE/BODY/SECURITY_PARAMETERS").detach();

		 * doc.selectSingleNode("/RESOURCE_PROFILE/BODY/BLACKBOARD").detach();

		 *

		 * applyXsltAndSend(res, doc, "/xslt/datasource_api.xslt", params);

		 *

		 */

	}

	@RequestMapping("/page/wf")

	public void getWorkflowHtml(final HttpServletResponse res, @RequestParam(value = "id", required = true) final String id) throws Exception {

		final SAXReader reader = new SAXReader();

		final String profile = isClient.getProfile(id);

		final Document doc = reader.read(new StringReader(profile));

		final Element dsNode = (Element) doc.selectSingleNode("//DATASOURCE");

		if (dsNode != null) {

			final String dsId = dsNode.valueOf("@id");

			final String ifaceId = dsNode.valueOf("@interface");

			final DatasourceDesc ds = dsManagerClient.getDatasource(dsId);

			final IfaceDesc iface = ds.getInterfaces().stream().filter(ifc -> ifc.getId().equals(ifaceId)).findFirst().get();

			dsNode.addAttribute("name", ds.getOfficialName());

			dsNode.addAttribute("protocol", iface.getAccessProtocol());

			final Element extraFields = dsNode.addElement("extraFields");

			for (final Entry<String, String> e : iface.getExtraFields().entrySet()) {

				final Element f = extraFields.addElement("field");

				f.addAttribute("name", e.getKey());

				f.setText(e.getValue());

			}

		}

		applyXsltAndSend(res, doc, "/xslt/wf.xslt", null);

	}

	private void applyXsltAndSend(final HttpServletResponse res, final Document doc, final String path, final Map<String, String> params) throws IOException {

		final ApplyXsltDom4j xslt = new ApplyXsltDom4j(new ClassPathResource(path), params);

		res.setContentType("text/html");

		IOUtils.copy(new StringReader(xslt.apply(doc)), res.getOutputStream());

	}

}