Skip to content
Snippets Groups Projects
Commit dd12c201 authored by cramakri's avatar cramakri
Browse files

LMS-2072 Fixed tests (I think).

SVN: 20179
parent ec0281ca
No related branches found
No related tags found
No related merge requests found
...@@ -101,7 +101,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -101,7 +101,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
private final IImmutableCopier copier; private final IImmutableCopier copier;
private DataSetInformation override; private DataSetInformation overrideOrNull;
PutDataSetExecutor(PutDataSetService service, IETLServerPlugin plugin, String sessionToken, PutDataSetExecutor(PutDataSetService service, IETLServerPlugin plugin, String sessionToken,
NewDataSetDTO newDataSet, InputStream inputStream) NewDataSetDTO newDataSet, InputStream inputStream)
...@@ -141,7 +141,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -141,7 +141,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
getOpenBisService().checkSpaceAccess(sessionToken, spaceId); getOpenBisService().checkSpaceAccess(sessionToken, spaceId);
writeDataSetToTempDirectory(); writeDataSetToTempDirectory();
createDefaultOverride(); overrideOrNull = null;
// Register the data set // Register the data set
try try
...@@ -164,10 +164,10 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -164,10 +164,10 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
{ {
// Remember the old override, replace it with the override for the execution, then restore // Remember the old override, replace it with the override for the execution, then restore
// it // it
DataSetInformation oldOverride = override; DataSetInformation oldOverride = overrideOrNull;
if (newOverride != null) if (newOverride != null)
{ {
override = newOverride; overrideOrNull = newOverride;
} }
RegistrationHelper helper = new RegistrationHelper(service, plugin, dataSet); RegistrationHelper helper = new RegistrationHelper(service, plugin, dataSet);
...@@ -184,7 +184,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -184,7 +184,7 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
} }
}).runAlgorithm(); }).runAlgorithm();
override = oldOverride; overrideOrNull = oldOverride;
return Collections.singletonList(helper.getDataSetInformation()); return Collections.singletonList(helper.getDataSetInformation());
} }
...@@ -248,30 +248,25 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -248,30 +248,25 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
public DataSetInformation getCallerDataSetInformation() public DataSetInformation getCallerDataSetInformation()
{ {
return override; DataSetInformation dataSetInfo = new DataSetInformation();
}
private void createDefaultOverride()
{
override = new DataSetInformation();
DataSetOwner owner = getDataSetOwner(); DataSetOwner owner = getDataSetOwner();
switch (owner.getType()) switch (owner.getType())
{ {
case EXPERIMENT: case EXPERIMENT:
override.setExperimentIdentifier(tryExperimentIdentifier()); dataSetInfo.setExperimentIdentifier(tryExperimentIdentifier());
break; break;
case SAMPLE: case SAMPLE:
SampleIdentifier sampleId = trySampleIdentifier(); SampleIdentifier sampleId = trySampleIdentifier();
override.setSampleCode(sampleId.getSampleCode()); dataSetInfo.setSampleCode(sampleId.getSampleCode());
override.setSpaceCode(sampleId.getSpaceLevel().getSpaceCode()); dataSetInfo.setSpaceCode(sampleId.getSpaceLevel().getSpaceCode());
override.setInstanceCode(sampleId.getSpaceLevel().getDatabaseInstanceCode()); dataSetInfo.setInstanceCode(sampleId.getSpaceLevel().getDatabaseInstanceCode());
break; break;
} }
String typeCode = newDataSet.tryDataSetType(); String typeCode = newDataSet.tryDataSetType();
if (null != typeCode) if (null != typeCode)
{ {
override.setDataSetType(new DataSetType(typeCode)); dataSetInfo.setDataSetType(new DataSetType(typeCode));
} }
Map<String, String> primitiveProps = newDataSet.getProperties(); Map<String, String> primitiveProps = newDataSet.getProperties();
...@@ -282,8 +277,10 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -282,8 +277,10 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
{ {
properties.add(new NewProperty(key, primitiveProps.get(key))); properties.add(new NewProperty(key, primitiveProps.get(key)));
} }
override.setDataSetProperties(properties); dataSetInfo.setDataSetProperties(properties);
} }
return dataSetInfo;
} }
private void writeDataSetToTempDirectory() throws IOException private void writeDataSetToTempDirectory() throws IOException
...@@ -465,10 +462,13 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -465,10 +462,13 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
public DataSetType getDataSetType(File incomingDataSetPath) public DataSetType getDataSetType(File incomingDataSetPath)
{ {
DataSetType dataSetType = override.getDataSetType(); if (null != overrideOrNull)
if (null != dataSetType)
{ {
return dataSetType; DataSetType dataSetType = overrideOrNull.getDataSetType();
if (null != dataSetType)
{
return dataSetType;
}
} }
return pluginTypeExtractor.getDataSetType(incomingDataSetPath); return pluginTypeExtractor.getDataSetType(incomingDataSetPath);
} }
...@@ -635,14 +635,45 @@ class PutDataSetExecutor implements IDataSetHandlerRpc ...@@ -635,14 +635,45 @@ class PutDataSetExecutor implements IDataSetHandlerRpc
IEncapsulatedOpenBISService openbisService) throws UserFailureException, IEncapsulatedOpenBISService openbisService) throws UserFailureException,
EnvironmentFailureException EnvironmentFailureException
{ {
if (null != override) if (null != overrideOrNull)
{ {
return override; return overrideOrNull;
} else }
DataSetInformation dataSetInfo =
plugin.getDataSetInfoExtractor().getDataSetInformation(incomingDataSetPath,
openbisService);
DataSetOwner owner = getDataSetOwner();
switch (owner.getType())
{ {
return plugin.getDataSetInfoExtractor().getDataSetInformation(incomingDataSetPath, case EXPERIMENT:
openbisService); dataSetInfo.setExperimentIdentifier(tryExperimentIdentifier());
break;
case SAMPLE:
SampleIdentifier sampleId = trySampleIdentifier();
dataSetInfo.setSampleCode(sampleId.getSampleCode());
dataSetInfo.setSpaceCode(sampleId.getSpaceLevel().getSpaceCode());
dataSetInfo.setInstanceCode(sampleId.getSpaceLevel().getDatabaseInstanceCode());
break;
} }
String typeCode = newDataSet.tryDataSetType();
if (null != typeCode)
{
dataSetInfo.setDataSetType(new DataSetType(typeCode));
}
Map<String, String> primitiveProps = newDataSet.getProperties();
if (false == primitiveProps.isEmpty())
{
ArrayList<NewProperty> properties = new ArrayList<NewProperty>();
for (String key : primitiveProps.keySet())
{
properties.add(new NewProperty(key, primitiveProps.get(key)));
}
dataSetInfo.setDataSetProperties(properties);
}
return dataSetInfo;
} }
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment