in data-resource-management-service/drms-rdbms-impl/drms-server/src/main/java/org/apache/airavata/drms/api/persistance/mapper/StoragePreferenceMapper.java [23:64]
public static AnyStoragePreference map(Resource resource, AnyStorage anyStorage) throws Exception {
AnyStoragePreference.Builder anyStoragePrefBuilder = AnyStoragePreference.newBuilder();
Set<ResourceProperty> resourcePropertySet = resource.getResourceProperty();
String type = null;
for (ResourceProperty resourceProperty : resourcePropertySet) {
if (resourceProperty.getPropertyKey().equals("type")) {
type = resourceProperty.getPropertyValue();
break;
}
}
switch (type) {
case StoragePreferenceConstants.SSH_STORAGE_PREFERENCE_TYPE_LABEL:
SSHStoragePreference.Builder builder = SSHStoragePreference.newBuilder();
builder.setStorage(anyStorage.getSshStorage());
setObjectFieldsUsingMap(builder, resource);
SSHStoragePreference sshStoragePreference = builder.build();
anyStoragePrefBuilder.setSshStoragePreference(sshStoragePreference);
break;
case StoragePreferenceConstants.S3_STORAGE_PREFERENCE_TYPE_LABEL:
S3StoragePreference.Builder s3Builder = S3StoragePreference.newBuilder();
s3Builder.setStorage(anyStorage.getS3Storage());
setObjectFieldsUsingMap(s3Builder, resource);
anyStoragePrefBuilder.setS3StoragePreference(s3Builder.build());
break;
case StoragePreferenceConstants.SDA_STORAGE_PREFERENCE_TYPE_LABEL:
SDAStoragePreference.Builder sdaBuilder = SDAStoragePreference.newBuilder();
sdaBuilder.setStorage(anyStorage.getSshStorage());
setObjectFieldsUsingMap(sdaBuilder, resource);
anyStoragePrefBuilder.setSdaStoragePreference(sdaBuilder.build());
break;
default:
throw new Exception("Unsupported storage type for deserializing : " + type);
}
return anyStoragePrefBuilder.build();
}