diff options
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/servlets/CsarBuildServlet.java')
| -rw-r--r-- | catalog-be/src/main/java/org/openecomp/sdc/be/servlets/CsarBuildServlet.java | 296 |
1 files changed, 296 insertions, 0 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/servlets/CsarBuildServlet.java b/catalog-be/src/main/java/org/openecomp/sdc/be/servlets/CsarBuildServlet.java new file mode 100644 index 0000000000..4ba6b7516d --- /dev/null +++ b/catalog-be/src/main/java/org/openecomp/sdc/be/servlets/CsarBuildServlet.java @@ -0,0 +1,296 @@ +/*- + * ============LICENSE_START======================================================= + * SDC + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ + +package org.openecomp.sdc.be.servlets; + +import java.nio.ByteBuffer; +import java.nio.CharBuffer; +import java.nio.charset.CharacterCodingException; +import java.nio.charset.Charset; +import java.nio.charset.CharsetEncoder; + +import javax.servlet.http.HttpServletRequest; +import javax.ws.rs.GET; +import javax.ws.rs.Path; +import javax.ws.rs.PathParam; +import javax.ws.rs.core.Context; +import javax.ws.rs.core.Response; + +import org.openecomp.sdc.be.resources.data.ESArtifactData; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.jcabi.aspects.Loggable; +//import org.openecomp.sdc.be.builders.tosca.api.TopologyService; +//import org.openecomp.sdc.be.tosca.parsers.ParserMode; + +@Loggable(prepend = true, value = Loggable.DEBUG, trim = false) +@Path("/services") +public class CsarBuildServlet extends ToscaDaoServlet { + + private static Logger log = LoggerFactory.getLogger(CsarBuildServlet.class.getName()); + + @GET + @Path("/{serviceName}/{serviceVersion}") + public Response getDefaultTemplate(@Context final HttpServletRequest request, @PathParam("serviceName") final String serviceName, @PathParam("serviceVersion") final String serviceVersion) { + + return null;// buildToscaCsar(request, serviceName, serviceVersion); + + } + + @GET + @Path("/{serviceName}/{serviceVersion}/csar") + public Response getToscaCsarTemplate(@Context final HttpServletRequest request, @PathParam("serviceName") final String serviceName, @PathParam("serviceVersion") final String serviceVersion) { + + return null; // buildToscaCsar(request, serviceName, serviceVersion); + + } + + /* + * private Response buildToscaCsar(final HttpServletRequest request, String serviceName, String serviceVersion) { log.debug("Building CSAR for service:{} , version:{}", serviceName, serviceVersion); ServletContext context = + * request.getSession().getServletContext(); ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); ZipOutputStream zipOutputStream = new ZipOutputStream(byteArrayOutputStream); String fileName = + * serviceName+"_"+serviceVersion+".zip"; + * + * IResourceUploader resourceUploader = getResourceUploader(context); TopologyService topologyService = getToscaYamlBuilder(context).getServiceYaml(serviceName, serviceVersion, ParserMode.CSAR, "Scripts"); try { + * + * + * //Add Service yml to Zip addZipEntry(zipOutputStream, "Definitions/"+serviceName+".yaml", topologyService.getTopologyServiceYaml()); + * + * //Add Resources to Zip addResourcesToZip(zipOutputStream, topologyService); + * + * //Add Artifacts to Zip addArtifactsToZip(serviceName, serviceVersion, zipOutputStream, resourceUploader); + * + * //Prepare Tosca metadata addToscaMetaToZip(zipOutputStream, topologyService, resourceUploader); + * + * } + * + * catch (IOException e) { log.error("Failed to create CSAR file", e); return null; } finally{ try { byteArrayOutputStream.close(); zipOutputStream.close(); } catch (IOException e) { log.error("Failed to close output srream", e); } + * + * } return buildResponse(fileName, byteArrayOutputStream); + * + * + * } + */ + + public static final String TOSCA_META_PATH = "TOSCA-Metadata/TOSCA.meta"; + // protected void addToscaMetaToZip(ZipOutputStream zipOutputStream, + // TopologyService topService, IResourceUploader resUploader) throws + // IOException { + // String serviceVersion = topService.getTopologyVersion(); + // String serviceName = topService.getTopologyName(); + // StringBuffer buff = new StringBuffer(); + // + // String[] serviceToscaMeta = prepareToscaMetaHeader(serviceName); + // + // for( String toAppend : serviceToscaMeta){ + // buff.append(toAppend); + // } + // + // List<String> toscaMetaComponents = + // prepareToscaMetaComponents(topService.getDependenciesYamls().keySet()); + // for( String toAppend : toscaMetaComponents ){ + // buff.append(toAppend); + // } + // + // Either<ServiceArtifactsDataCollection, ResourceUploadStatus> + // getServiceArtifactsCollectionStatus = + // Either.right(ResourceUploadStatus.ERROR);//resUploader.getServiceArtifactsCollection(serviceName, + // serviceVersion); + // if(getServiceArtifactsCollectionStatus.isLeft()){ + // List<String> toscaMetaArtifacts = + // prepareToscaMetaArtifacts(getServiceArtifactsCollectionStatus.left().value()); + // for( String toAppend : toscaMetaArtifacts ){ + // buff.append(toAppend); + // } + // } + // + // addZipEntry(zipOutputStream, TOSCA_META_PATH, buff.toString()); + // } + + // protected List<String> prepareToscaMetaArtifacts( + // ServiceArtifactsDataCollection serviceArtifactsDataCollection) { + // List<String> artifactsForToscaMeta = new ArrayList<String>(); + // Iterator<Entry<String, List<ArtifactData>>> nodeTemplateArtifactsItr = + // serviceArtifactsDataCollection.getServiceArtifactDataMap().entrySet().iterator(); + // while( nodeTemplateArtifactsItr.hasNext() ){ + // Entry<String, List<ArtifactData>> nodeNameArtifacts = + // nodeTemplateArtifactsItr.next(); + // String nodeName = nodeNameArtifacts.getKey(); + // Iterator<ArtifactData> artifactDataItr = + // nodeNameArtifacts.getValue().iterator(); + // while( artifactDataItr.hasNext() ){ + // ArtifactData artifactData = artifactDataItr.next(); + // artifactsForToscaMeta.add("\n"); + // artifactsForToscaMeta.add("Name: "+getArtifactPath(nodeName, + // artifactData)+"\n"); + // artifactsForToscaMeta.add("Content-Type: + // application/"+getAppliactionMime(artifactData.getArtifactName())+"\n"); + // } + // } + // return artifactsForToscaMeta; + // } + + // protected List<String> prepareToscaMetaComponents(Set<String> components) + // { + // Iterator<String> resourceNameItr = components.iterator(); + // List<String> componentsForToscaMeta = new ArrayList<String>(); + // while( resourceNameItr.hasNext() ){ + // String resourceName = resourceNameItr.next(); + // componentsForToscaMeta.add("\n"); + // componentsForToscaMeta.add("Name: "+getResourcePath(resourceName)+"\n"); + // componentsForToscaMeta.add("Content-Type: + // application/vnd.oasis.tosca.definitions.yaml\n"); + // + // } + // return componentsForToscaMeta; + // } + + protected String[] prepareToscaMetaHeader(String serviceName) { + return new String[] { "TOSCA-Meta-File-Version: 1.0\n", "CSAR-Version: 1.1\n", "Created-By: INTERWISE\n", "\n", "Entry-Definitions: Definitions/" + serviceName + ".yaml\n", "\n", "Name: Definitions/" + serviceName + ".yaml\n", + "Content-Type: application/vnd.oasis.tosca.definitions.yaml\n" }; + } + + protected String getAppliactionMime(String fileName) { + String mimeType; + if (fileName.contains(".sh")) { + mimeType = "x-sh"; + } else if (fileName.contains(".yang")) { + mimeType = "yang"; + } + + else if (fileName.contains(".rar")) { + mimeType = "x-rar-compressed"; + } + + else if (fileName.contains(".zip")) { + mimeType = "zip"; + } + + else if (fileName.contains(".tar")) { + mimeType = "x-tar"; + } + + else if (fileName.contains(".7z")) { + mimeType = "x-7z-compressed"; + } + + else { + // Undefined + mimeType = "undefined"; + } + return mimeType; + } + + // protected void addResourcesToZip(ZipOutputStream zipOutputStream, + // TopologyService topService) throws IOException { + // Iterator<Entry<String, String>> resourceNameDataItr = + // topService.getDependenciesYamls().entrySet().iterator(); + // while( resourceNameDataItr.hasNext() ){ + // Entry<String, String> resourceNameData = resourceNameDataItr.next(); + // addZipEntry(zipOutputStream, getResourcePath(resourceNameData.getKey()), + // resourceNameData.getValue()); + // } + // } + + protected String getArtifactPath(String nodeTamplateName, ESArtifactData artifactData) { + // return "Scripts/"+nodeTamplateName+"/"+ + // artifactData.getArtifactName(); + return "Scripts/" + nodeTamplateName + "/" + artifactData.getId(); + } + + protected String getResourcePath(String resourceName) { + return "Definitions/" + resourceName + ".yaml"; + } + + // protected void addArtifactsToZip(String serviceName, String + // serviceVersion, ZipOutputStream zipOutputStream, IResourceUploader + // resourceUploader) + // throws IOException { + // //Add Artifacts to Zip + // Either<ServiceArtifactsDataCollection, ResourceUploadStatus> + // getServiceArtifactsCollectionStatus = + // Either.right(ResourceUploadStatus.ERROR);//resourceUploader.getServiceArtifactsCollection(serviceName, + // serviceVersion); + // if(getServiceArtifactsCollectionStatus.isLeft()){ + // Iterator<Entry<String, List<ArtifactData>>> nodeTemplateArtifactsItr + // =getServiceArtifactsCollectionStatus.left().value().getServiceArtifactDataMap().entrySet().iterator(); + // while( nodeTemplateArtifactsItr.hasNext() ){ + // Entry<String, List<ArtifactData>> nodeTemplateArtifacts = + // nodeTemplateArtifactsItr.next(); + // String nodeTamplateName = nodeTemplateArtifacts.getKey(); + // List<ArtifactData> artifacts = nodeTemplateArtifacts.getValue(); + // for(ArtifactData artifactData : artifacts ){ + // addZipEntry(zipOutputStream, + // getArtifactPath(nodeTamplateName,artifactData), artifactData.getData()); + // } + // + // } + // } + // } + + // private Response buildResponse(String fileName, ByteArrayOutputStream + // fileOutputStream) { + // final InputStream inputStream = new + // ByteArrayInputStream(fileOutputStream.toByteArray()); + // + // StreamingOutput stream = new StreamingOutput() { + // public void write(OutputStream output) throws WebApplicationException { + // try { + // IOUtils.copy(inputStream, output); + // } catch (Exception e) { + // throw new WebApplicationException(e); + // } + // } + // }; + // + // return + // Response.ok(stream).type(MediaType.APPLICATION_OCTET_STREAM_TYPE).header("content-disposition","attachment; + // filename = "+fileName).build(); + // } + + // protected void addZipEntry(ZipOutputStream zipOutputStream, String + // filePath, String data) throws IOException { + // addZipEntry(zipOutputStream, filePath, encodeString(data)); + // } + + private byte[] encodeString(String data) throws CharacterCodingException { + Charset charset = Charset.forName("UTF-8"); + CharsetEncoder encoder = charset.newEncoder(); + ByteBuffer bb = encoder.encode(CharBuffer.wrap(data.toCharArray())); + byte[] ba = new byte[bb.limit()]; + bb.get(ba); + return ba; + } + + // private void addZipEntry(ZipOutputStream zipOutputStream, String + // filePath, byte[] data) throws IOException { + // log.debug("Adding to CSAR zip :{}", filePath); + // ZipEntry entry = new ZipEntry(filePath); + // zipOutputStream.putNextEntry(entry); + // zipOutputStream.write(data); + // zipOutputStream.closeEntry(); + // } + + @Override + public Logger getLogger() { + return log; + } + +} |