import java.io.File;
import java.io.IOException;
import java.nio.file.Path;
-import java.util.ArrayList;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.io.FileUtils;
import org.onap.nbi.apis.servicecatalog.jolt.FindServiceSpecJsonTransformer;
import org.onap.nbi.apis.servicecatalog.jolt.GetServiceSpecJsonTransformer;
+import org.onap.nbi.apis.servicecatalog.jolt.PostServiceResponseSpecJsonTransformer;
+import org.onap.nbi.apis.servicecatalog.jolt.PostServiceSpecJsonTransformer;
+import org.onap.nbi.apis.servicecatalog.model.ServiceSpecificationRequest;
import org.onap.nbi.apis.serviceorder.ServiceCatalogUrl;
import org.onap.sdc.tosca.parser.exceptions.SdcToscaParserException;
import org.slf4j.Logger;
@Autowired
FindServiceSpecJsonTransformer findServiceSpecJsonTransformer;
+ // Change for processing POST request
+ @Autowired
+ PostServiceSpecJsonTransformer postServiceSpecJsonTransformer;
+
+ @Autowired
+ PostServiceResponseSpecJsonTransformer postServiceResponseSpecJsonTransformer ;
+
@Autowired
ToscaInfosProcessor toscaInfosProcessor;
return null;
}
}
+
+ public Map create(String userId, ServiceSpecificationRequest specRequest) {
+ ObjectMapper mapper = new ObjectMapper();
+ LinkedHashMap specRequestMap = mapper.convertValue(specRequest, LinkedHashMap.class);
+ HashMap<Object, Object> serviceCatalogInput = (HashMap) postServiceSpecJsonTransformer.transform(specRequestMap);
+
+ //Call SDC Post API
+ Map sdcResponse = sdcClient.callPost(serviceCatalogInput,userId);
+ LOGGER.info("SDC response " + sdcResponse);
+ //Transform SDC Response
+ LinkedHashMap<Object,Object> serviceCatalogResponse =null;
+ if (!CollectionUtils.isEmpty(sdcResponse)) {
+ serviceCatalogResponse = (LinkedHashMap)postServiceResponseSpecJsonTransformer.transform(sdcResponse);
+ }
+ return serviceCatalogResponse;
+ }
+
}