import java.util.Map;
import java.util.Map.Entry;
-import org.codehaus.jackson.JsonParseException;
import org.codehaus.jackson.annotate.JsonProperty;
import org.codehaus.jackson.map.DeserializationConfig;
-import org.codehaus.jackson.map.JsonMappingException;
import org.codehaus.jackson.map.ObjectMapper;
import org.codehaus.jackson.map.annotate.JsonRootName;
-import org.openecomp.mso.logger.MessageEnum;
import org.openecomp.mso.logger.MsoLogger;
import org.openecomp.mso.openstack.exceptions.MsoCloudIdentityNotFound;
return null;
}
- protected synchronized void reloadPropertiesFile() throws JsonParseException, JsonMappingException, IOException, MsoCloudIdentityNotFound {
+ protected synchronized void reloadPropertiesFile() throws IOException, MsoCloudIdentityNotFound {
this.loadCloudConfig(this.configFilePath, this.refreshTimerInMinutes);
}
protected synchronized void loadCloudConfig(String configFile, int refreshTimer)
- throws JsonParseException, JsonMappingException, IOException, MsoCloudIdentityNotFound {
+ throws IOException, MsoCloudIdentityNotFound {
FileReader reader = null;
configFilePath = configFile;
this.refreshTimerInMinutes = refreshTimer;
-
- CloudConfig cloudConfig = null;
this.validCloudConfig=false;
try {
reader = new FileReader(configFile);
// Parse the JSON input into a CloudConfig
- cloudConfig = mapper.readValue(reader, CloudConfig.class);
+ CloudConfig cloudConfig = mapper.readValue(reader, CloudConfig.class);
this.cloudSites = cloudConfig.cloudSites;
this.identityServices = cloudConfig.identityServices;
import java.io.IOException;
import java.net.URISyntaxException;
import java.security.GeneralSecurityException;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
import org.codehaus.jackson.annotate.JsonProperty;
-import org.codehaus.jackson.map.JsonSerializer;
-import org.codehaus.jackson.JsonGenerator;
-import org.codehaus.jackson.map.SerializerProvider;
import org.codehaus.jackson.map.annotate.JsonDeserialize;
import org.codehaus.jackson.map.annotate.JsonSerialize;
-import org.codehaus.jackson.JsonProcessingException;
-
import org.openecomp.mso.openstack.exceptions.MsoAdapterException;
import org.openecomp.mso.openstack.exceptions.MsoException;
-import org.openecomp.mso.openstack.utils.MsoCommonUtils;
import org.openecomp.mso.openstack.utils.MsoKeystoneUtils;
import org.openecomp.mso.openstack.utils.MsoTenantUtils;
import org.openecomp.mso.openstack.utils.MsoTenantUtilsFactory;
import org.openecomp.mso.cloud.authentication.AuthenticationMethodFactory;
import org.openecomp.mso.cloud.authentication.AuthenticationWrapper;
-import org.openecomp.mso.cloud.authentication.models.RackspaceAuthentication;
import org.openecomp.mso.cloud.authentication.wrappers.RackspaceAPIKeyWrapper;
import org.openecomp.mso.cloud.authentication.wrappers.UsernamePasswordWrapper;
import org.openecomp.mso.logger.MessageEnum;
this.id = id;
}
- //DEPRECATED
- public String getKeystoneUrl () throws MsoException {
- if (this.identityServerType.equals(IdentityServerType.KEYSTONE))
- return this.identityUrl;
- else
- return null;
- }
-
public String getKeystoneUrl (String regionId, String msoPropID) throws MsoException {
if (IdentityServerType.KEYSTONE.equals(this.identityServerType)) {
return this.identityUrl;
import java.io.IOException;\r
\r
import org.codehaus.jackson.JsonParser;\r
-import org.codehaus.jackson.JsonProcessingException;\r
import org.codehaus.jackson.JsonToken;\r
import org.codehaus.jackson.map.DeserializationContext;\r
import org.codehaus.jackson.map.JsonDeserializer;\r
-import org.openecomp.mso.cloud.CloudIdentity.IdentityServerType;\r
\r
public class IdentityAuthenticationTypeJsonDeserializer extends JsonDeserializer<IdentityAuthenticationTypeAbstract> {\r
\r
@Override\r
public IdentityAuthenticationTypeAbstract deserialize(JsonParser jsonParser, DeserializationContext deserializationContext)\r
- throws IOException, JsonProcessingException {\r
+ throws IOException {\r
JsonToken token = jsonParser.getCurrentToken();\r
if (JsonToken.VALUE_STRING.equals(token)) {\r
return IdentityAuthenticationTypeAbstract.valueOf(jsonParser.getText());\r
import java.io.IOException;\r
\r
import org.codehaus.jackson.JsonParser;\r
-import org.codehaus.jackson.JsonProcessingException;\r
import org.codehaus.jackson.JsonToken;\r
import org.codehaus.jackson.map.DeserializationContext;\r
import org.codehaus.jackson.map.JsonDeserializer;\r
-import org.openecomp.mso.cloud.CloudIdentity.IdentityServerType;\r
-\r
\r
public class IdentityServerTypeJsonDeserializer extends JsonDeserializer<IdentityServerTypeAbstract> {\r
\r
@Override\r
public IdentityServerTypeAbstract deserialize(JsonParser jsonParser, DeserializationContext deserializationContext)\r
- throws IOException, JsonProcessingException {\r
+ throws IOException {\r
JsonToken token = jsonParser.getCurrentToken();\r
if (JsonToken.VALUE_STRING.equals(token)) {\r
return IdentityServerTypeAbstract.valueOf(jsonParser.getText());\r
import java.io.IOException;\r
\r
import org.codehaus.jackson.JsonGenerator;\r
-import org.codehaus.jackson.JsonProcessingException;\r
import org.codehaus.jackson.map.JsonSerializer;\r
import org.codehaus.jackson.map.SerializerProvider;\r
-import org.openecomp.mso.cloud.CloudIdentity.IdentityServerType;\r
-\r
\r
public class IdentityServerTypeJsonSerializer extends JsonSerializer<IdentityServerTypeAbstract> {\r
\r
@Override\r
public void serialize(IdentityServerTypeAbstract tmpObj, JsonGenerator jsonGenerator, SerializerProvider serializerProvider)\r
- throws IOException, JsonProcessingException {\r
+ throws IOException {\r
jsonGenerator.writeObject(tmpObj.toString());\r
}\r
}\r
public final class AuthenticationMethodFactory {\r
\r
private static Map<String, AuthenticationWrapper> authWrappers = new ConcurrentHashMap<>();\r
- \r
- /**\r
- * \r
- */\r
+\r
private AuthenticationMethodFactory() {}\r
\r
/**\r
package org.openecomp.mso.cloud.authentication.models;
-import org.codehaus.jackson.annotate.JsonIgnore;
import org.codehaus.jackson.annotate.JsonProperty;
import org.codehaus.jackson.map.annotate.JsonRootName;
import com.woorea.openstack.keystone.model.Authentication;
@JsonRootName("auth")
public class RackspaceAuthentication extends Authentication {
- /**
- *
- */
private static final long serialVersionUID = 5451283386875662918L;
- @JsonIgnore
- private String tenantId;
-
- @JsonIgnore
- private String tenantName;
-
public static final class Token {
private String username;
package org.openecomp.mso.openstack.exceptions;
-
/**
- * Cloud site not found exception.
+ * Signals that an attempt to find a specific mso cloud identity has failed.
*/
public class MsoCloudIdentityNotFound extends MsoException {
- /**
- * Serialization id.
- */
private static final long serialVersionUID = 2583769056266415665L;
+
/**
* Default constructor (needed for BPEL/JAXB)
*/
public MsoCloudIdentityNotFound () {
super("Cloud Identity not found");
super.category=MsoExceptionCategory.USERDATA;
- }
-
- /**
- * Constructor to create a new MsoOpenstackException instance
- * @param cloudSite the cloud site
- */
+ }
+
public MsoCloudIdentityNotFound (String cloudIdentity) {
// Set the detailed error as the Exception 'message'
super("Cloud Identity [" + cloudIdentity + "] not found");
package org.openecomp.mso.openstack.exceptions;
-
/**
- * Cloud site not found exception.
+ * Signals that an attempt to find a specific mso cloud site has failed.
*/
public class MsoCloudSiteNotFound extends MsoException {
- /**
- * Serialization id.
- */
private static final long serialVersionUID = 2583769056266415664L;
/**
super("Cloud site not found");
super.category=MsoExceptionCategory.USERDATA;
}
-
- /**
- * Constructor to create a new MsoOpenstackException instance
- * @param cloudSite the cloud site
- */
+
public MsoCloudSiteNotFound (String cloudSite) {
// Set the detailed error as the Exception 'message'
super("Cloud Site [" + cloudSite + "] not found");
* 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.
package org.openecomp.mso.openstack.exceptions;
-
-
public class MsoTenantAlreadyExists extends MsoOpenstackException {
private static final long serialVersionUID = 1L;
- // Constructor to create a new MsoOpenstackException instance
public MsoTenantAlreadyExists (String tenant, String cloud) {
// Set the detailed error as the Exception 'message'
super(409, "Conflict", "Tenant " + tenant + " already exists in Cloud " + cloud);
}
-
+
}
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * 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.mso.openstack.utils;
-
-
-import javax.ejb.EJB;
-import javax.servlet.ServletContextEvent;
-import javax.servlet.ServletContextListener;
-import javax.servlet.annotation.WebListener;
-
-import org.openecomp.mso.cloud.CloudConfigFactory;
-import org.openecomp.mso.cloud.CloudConfigIdentityMapper;
-import org.openecomp.mso.logger.MessageEnum;
-import org.openecomp.mso.logger.MsoLogger;
-
-/**
- * This class will attempt to initialize Cloud Config when part of a web application.
- *
- *
- *
- */
-@WebListener
-public class CloudConfigInitializer implements ServletContextListener
-{
-
- private CloudConfigFactory cloudConfigFactory=new CloudConfigFactory();
-
- public CloudConfigInitializer () {
- }
-
- @Override
- public void contextDestroyed(ServletContextEvent event) {
- // Nothing to do...
- }
-
-
- @Override
- public void contextInitialized(ServletContextEvent event)
- {
-
- // Note - this logger may be before or after MSO Logging configuration applied
- MsoLogger initLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.GENERAL);
- try {
- // Look first in the init-parameters
- String msoPropConfigParam = event.getServletContext().getInitParameter("mso.cloud_config.configuration");
-
- String[] configFileSplit = msoPropConfigParam.split(",");
- for (String msoPropConfig:configFileSplit) {
- String[] msoPropDecoded = msoPropConfig.split("=");
-
- try {
- cloudConfigFactory.initializeCloudConfig(msoPropDecoded[0], Integer.valueOf(msoPropDecoded[1]));
- initLogger.info(MessageEnum.RA_CONFIG_LOAD, msoPropDecoded[0], "", "");
- initLogger.debug("Mso properties successfully loaded:"+msoPropDecoded[0]+"(Timer(mins):"+Integer.valueOf(msoPropDecoded[1]));
- } catch (NumberFormatException ne) {
- initLogger.error(MessageEnum.RA_CONFIG_EXC, msoPropDecoded[0] + ". MSO Properties failed due to conversion error (in web.xml file)", "", "", MsoLogger.ErrorCode.DataError, "MSO Properties failed due to conversion error (in web.xml file)", ne);
- }
- }
-
- // Second, obtain class name that will register all mappings
- String msoMapperClassParam = event.getServletContext().getInitParameter("mso.cloud_config.mapper.class");
- if (msoMapperClassParam != null) {
- Class<?> mapperClass = Class.forName(msoMapperClassParam);
- if (CloudConfigIdentityMapper.class.isAssignableFrom(mapperClass)) {
- ((CloudConfigIdentityMapper)mapperClass.newInstance()).registerAllMappings();
- initLogger.info(MessageEnum.RA_CONFIG_LOAD,msoMapperClassParam+"(Openstack authentication mapper class)","","");
- } else {
- initLogger.info(MessageEnum.RA_CONFIG_LOAD,msoMapperClassParam+"(Openstack authentication mapper class not an implementation of CloudConfigIdentityMapper)","","");
- }
- } else {
- initLogger.info(MessageEnum.RA_CONFIG_LOAD,"Openstack authentication mapper class not specified in web.xml (ONLY core authentication mechanisms will be loaded)","","");
- }
-
- }
- catch (Exception e) {
- initLogger.error(MessageEnum.RA_CONFIG_EXC, "Unknown. MSO Properties failed to initialize completely", "", "", MsoLogger.ErrorCode.AvailabilityError, "Exception - MSO Properties failed to initialize completely", e);
- }
- }
-}
public class MsoCommonUtils {
- private static MsoLogger logger = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
- protected static MsoAlarmLogger alarmLogger = new MsoAlarmLogger();
-
- protected static String retryDelayProp = "ecomp.mso.adapters.po.retryDelay";
+ private static MsoLogger logger = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
+ protected static MsoAlarmLogger alarmLogger = new MsoAlarmLogger();
+ protected static String retryDelayProp = "ecomp.mso.adapters.po.retryDelay";
protected static String retryCountProp = "ecomp.mso.adapters.po.retryCount";
protected static String retryCodesProp = "ecomp.mso.adapters.po.retryCodes";
-
- protected static int retryDelayDefault = 5;
+ protected static int retryDelayDefault = 5;
protected static int retryCountDefault = 3;
protected static String retryCodesDefault = "504";
}
}
- long start = System.currentTimeMillis ();
String requestType;
if (request.getClass ().getEnclosingClass () != null) {
requestType = request.getClass ().getEnclosingClass ().getSimpleName () + "."
public static boolean isNullOrEmpty (String s) {
return s == null || s.isEmpty();
}
-
-
+
+
}
import java.util.HashMap;
import java.util.Map;
-import org.openecomp.mso.cloud.CloudConfig;
-import org.openecomp.mso.cloud.CloudConfigFactory;
import org.openecomp.mso.cloud.CloudIdentity;
import org.openecomp.mso.cloud.CloudSite;
import org.openecomp.mso.logger.MsoAlarmLogger;
import org.openecomp.mso.openstack.exceptions.MsoException;
import org.openecomp.mso.openstack.exceptions.MsoOpenstackException;
import org.openecomp.mso.openstack.exceptions.MsoTenantAlreadyExists;
-import org.openecomp.mso.properties.MsoJavaProperties;
-import org.openecomp.mso.properties.MsoPropertiesException;
-import org.openecomp.mso.properties.MsoPropertiesFactory;
import com.woorea.openstack.base.client.OpenStackBaseException;
import com.woorea.openstack.base.client.OpenStackConnectException;
import com.woorea.openstack.base.client.OpenStackRequest;
* <p>
*
* @param tenantName The tenant name to create
- * @param cloudId The cloud identifier (may be a region) in which to create the tenant.
+ * @param cloudSiteId The cloud identifier (may be a region) in which to create the tenant.
* @return the tenant ID of the newly created tenant
* @throws MsoTenantAlreadyExists Thrown if the requested tenant already exists
* @throws MsoOpenstackException Thrown if the Openstack API call returns an exception
* @return the tenant properties of the queried tenant, or null if not found
* @throws MsoOpenstackException Thrown if the Openstack API call returns an exception
*/
- public MsoTenant queryTenant (String tenantId, String cloudSiteId) throws MsoException, MsoCloudSiteNotFound {
+ public MsoTenant queryTenant (String tenantId, String cloudSiteId) throws MsoException {
// Obtain the cloud site information where we will query the tenant
CloudSite cloudSite = cloudConfig.getCloudSite (cloudSiteId);
if (cloudSite == null) {
* This may be useful if cached credentials get out of sync.
*/
public static void adminCacheReset () {
- adminClientCache = new HashMap <String, KeystoneCacheEntry> ();
+ adminClientCache = new HashMap<>();
}
@Override
- public String getKeystoneUrl(String regionId, String msoPropID, CloudIdentity cloudIdentity) throws MsoException {
+ public String getKeystoneUrl(String regionId, String msoPropID, CloudIdentity cloudIdentity) {
return cloudIdentity.getIdentityUrl();
}
}
import org.openecomp.mso.cloud.CloudConfigFactory;
import org.openecomp.mso.cloud.CloudIdentity;
import org.openecomp.mso.cloud.CloudSite;
-import org.openecomp.mso.logger.MsoLogger;
-import org.openecomp.mso.properties.MsoJavaProperties;
import java.lang.reflect.InvocationTargetException;
public class MsoTenantUtilsFactory {
- private static MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.RA);
-
private CloudConfigFactory cloudConfigFactory= new CloudConfigFactory();
- protected CloudConfig cloudConfig;
- protected MsoJavaProperties msoProps = null;
+ private CloudConfig cloudConfig;
private String msoPropID;
public MsoTenantUtilsFactory (String msoPropID) {
import org.openecomp.mso.cloud.CloudSite;
import org.openecomp.mso.openstack.exceptions.MsoCloudIdentityNotFound;
-
-
/**
* This class implements test methods of the CloudConfig features.
- *
- *
*/
public class CloudConfigTest {
CloudIdentity identity3 = identityMap.get("MTINJVCC101_DCP");
CloudIdentity identity4 = identityMap.get("MTSNJA3DCP1");
-// assertEquals (identity1.getKeystoneUrl(), "http://localhost:5000/v2.0");
-// assertEquals (identity1.getIdentityUrl(), "http://localhost:5000/v2.0");
- assertEquals (identity1.getMsoId(), "john");
- assertEquals (identity1.getMsoPass(), "changeme");
- assertEquals (identity1.getAdminTenant(), "admin");
- assertEquals (identity1.getMemberRole(), "_member_");
- assertEquals (identity1.hasTenantMetadata(), false);
-
-// assertEquals (identity2.getKeystoneUrl(), "http://localhost:5000/v2.0");
-// assertEquals (identity2.getIdentityUrl(), "http://localhost:5000/v2.0");
- assertEquals (identity2.getMsoId(), "mockId");
- assertEquals (identity2.getMsoPass(), "stack123");
- assertEquals (identity2.getAdminTenant(), "service");
- assertEquals (identity2.getMemberRole(), "_member_");
- assertEquals (identity2.hasTenantMetadata(), false);
-
-// assertEquals (identity3.getKeystoneUrl(), "http://localhost:5000/v2.0");
-// assertEquals (identity3.getIdentityUrl(), "http://localhost:5000/v2.0");
- assertEquals (identity3.getMsoId(), "mockIdToo");
- assertEquals (identity3.getMsoPass(), "AICG@mm@@2015");
- assertEquals (identity3.getAdminTenant(), "service");
- assertEquals (identity3.getMemberRole(), "admin");
- assertEquals (identity3.hasTenantMetadata(), true);
-
-// assertEquals (identity4.getKeystoneUrl(), "https://localhost:5000/v2.0");
-// assertEquals (identity4.getIdentityUrl(), "https://localhost:5000/v2.0");
- assertEquals (identity4.getMsoId(), "mockIdToo");
- assertEquals (identity4.getMsoPass(), "2315QRS2015srq");
- assertEquals (identity4.getAdminTenant(), "service");
- assertEquals (identity4.getMemberRole(), "admin");
- assertEquals (identity4.hasTenantMetadata(), true);
+ assertEquals("john", identity1.getMsoId());
+ assertEquals("changeme", identity1.getMsoPass());
+ assertEquals("admin", identity1.getAdminTenant());
+ assertEquals("_member_", identity1.getMemberRole());
+ assertEquals(false, identity1.hasTenantMetadata());
+
+ assertEquals("mockId", identity2.getMsoId());
+ assertEquals("stack123", identity2.getMsoPass());
+ assertEquals("service", identity2.getAdminTenant());
+ assertEquals("_member_", identity2.getMemberRole());
+ assertEquals(false, identity2.hasTenantMetadata());
+
+ assertEquals("mockIdToo", identity3.getMsoId());
+ assertEquals("AICG@mm@@2015", identity3.getMsoPass());
+ assertEquals("service", identity3.getAdminTenant());
+ assertEquals("admin", identity3.getMemberRole());
+ assertEquals(true, identity3.hasTenantMetadata());
+
+ assertEquals("mockIdToo", identity4.getMsoId());
+ assertEquals("2315QRS2015srq", identity4.getMsoPass());
+ assertEquals("service", identity4.getAdminTenant());
+ assertEquals("admin", identity4.getMemberRole());
+ assertEquals(true, identity4.hasTenantMetadata());
}
public final void testGetIdentityService () {
CloudIdentity identity1 = con.getIdentityService("MT_KEYSTONE");
assertNotNull(identity1);
-// assertEquals (identity1.getKeystoneUrl(), "http://localhost:5000/v2.0");
-// assertEquals (identity1.getIdentityUrl(), "http://localhost:5000/v2.0");
assertEquals (identity1.getMsoId(), "john");
assertEquals (identity1.getMsoPass(), "changeme");
assertEquals (identity1.getAdminTenant(), "admin");
Code Review / so.git / commitdiff