@Component(value="artifactBusinessLogic") public class ArtifactsBusinessLogic extends BaseBusinessLogic
Modifier and Type | Class and Description |
---|---|
static class |
ArtifactsBusinessLogic.ArtifactOperation |
applicationDataTypeCache, attributeOperation, componentsUtils, elementDao, graphLockOperation, groupOperation, groupTypeOperation, productOperation, propertyOperation, resourceOperation, serviceOperation, titanGenericDao, userAdmin
Constructor and Description |
---|
ArtifactsBusinessLogic() |
Modifier and Type | Method and Description |
---|---|
fj.data.Either<ArtifactDefinition,StorageOperationStatus> |
addHeatEnvArtifact(ArtifactDefinition artifactHeatEnv,
ArtifactDefinition artifact,
String parentId,
NodeTypeEnum parentType,
boolean inTransaction) |
EnumMap<AuditingFieldsKeysEnum,Object> |
createArtifactAuditingFields(ArtifactDefinition artifactDefinition,
String prevArtifactUuid,
String currentArtifactUuid) |
fj.data.Either<ArtifactDefinition,ResponseFormat> |
createArtifactPlaceHolderInfo(String resourceId,
String logicalName,
Map<String,Object> artifactInfoMap,
String userId,
ArtifactGroupTypeEnum groupType,
boolean inTransaction) |
ArtifactDefinition |
createArtifactPlaceHolderInfo(String resourceId,
String logicalName,
Map<String,Object> artifactInfoMap,
User user,
ArtifactGroupTypeEnum groupType) |
ESArtifactData |
createEsArtifactData(ArtifactDataDefinition artifactInfo,
byte[] artifactPayload) |
StorageOperationStatus |
deleteAllComponentArtifactsIfNotOnGraph(List<ArtifactDefinition> artifacts) |
fj.data.Either<Operation,ResponseFormat> |
deleteArtifactByInterface(String resourceId,
String interfaceType,
String operationName,
String userId,
String artifactId,
org.apache.commons.lang3.tuple.ImmutablePair<User,Resource> userResourceAuditPair,
boolean shouldLock,
boolean inTransaction) |
fj.data.Either<ArtifactDefinition,ResponseFormat> |
deleteArtifactOnComponentByUUID(javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
deletes an artifact on a component by UUID
|
fj.data.Either<ArtifactDefinition,ResponseFormat> |
deleteArtifactOnRiByUUID(javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
String resourceInstanceName,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
deletes an artifact an a resource instance by UUID
|
StorageOperationStatus |
deleteIfNotOnGraph(String artifactId,
String artifactEsId,
boolean deleteOnlyPayload) |
fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> |
downloadArtifact(String artifactUniqueId) |
fj.data.Either<byte[],ResponseFormat> |
downloadComponentArtifactByUUIDs(ComponentTypeEnum componentType,
String componentUuid,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> auditAdditionalParam)
downloads artifact of component by UUIDs
|
fj.data.Either<byte[],ResponseFormat> |
downloadResourceInstanceArtifactByUUIDs(ComponentTypeEnum componentType,
String componentUuid,
String resourceInstanceName,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> auditAdditionalParam)
downloads an artifact of resource instance of component by UUIDs
|
fj.data.Either<byte[],ResponseFormat> |
downloadRsrcArtifactByNames(String serviceName,
String serviceVersion,
String resourceName,
String resourceVersion,
String artifactName) |
fj.data.Either<byte[],ResponseFormat> |
downloadRsrcInstArtifactByNames(String serviceName,
String serviceVersion,
String resourceInstanceName,
String artifactName) |
fj.data.Either<byte[],ResponseFormat> |
downloadServiceArtifactByNames(String serviceName,
String serviceVersion,
String artifactName) |
ArtifactDefinition |
extractArtifactDefinition(fj.data.Either<ArtifactDefinition,Operation> eitherArtifact) |
fj.data.Either<Boolean,ResponseFormat> |
fillArtifactPayload(Wrapper<byte[]> payloadWrapper,
ArtifactDefinition artifactMD) |
void |
fillArtifactPayloadValidation(Wrapper<ResponseFormat> errorWrapper,
Wrapper<byte[]> payloadWrapper,
ArtifactDefinition artifactDefinition) |
fj.data.Either<ArtifactDefinition,ResponseFormat> |
generateAndSaveHeatEnvArtifact(ArtifactDefinition artifactDefinition,
String payload,
Component component,
String resourceInstanceName,
User modifier,
boolean shouldLock) |
fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> |
generateAndSaveToscaArtifact(ArtifactDefinition artifactDefinition,
Component component,
User user,
boolean isInCertificationRequest,
boolean shouldLock,
boolean inTransaction,
boolean fetchTemplatesFromDB) |
protected fj.data.Either<ArtifactDefinition,ResponseFormat> |
generateArtifactPayload(ArtifactDefinition artifactDefinition,
Component component,
String resourceInstanceName,
User modifier,
boolean shouldLock,
Supplier<Long> payloadUpdateDateGen,
Supplier<fj.data.Either<ESArtifactData,ResponseFormat>> esDataCreator) |
fj.data.Either<ArtifactDefinition,ResponseFormat> |
generateHeatEnvArtifact(ArtifactDefinition artifactDefinition,
Component component,
String resourceInstanceName,
User modifier,
boolean shouldLock) |
fj.data.Either<Map<String,ArtifactDefinition>,StorageOperationStatus> |
getArtifacts(String parentId,
NodeTypeEnum parentType,
boolean inTransaction,
ArtifactGroupTypeEnum groupType) |
ComponentOperation |
getComponentOperation(NodeTypeEnum componentType) |
List<ArtifactDefinition> |
getDeploymentArtifacts(Component parentComponent,
NodeTypeEnum parentType,
String ciId) |
IResourceOperation |
getResourceOperation() |
fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> |
handleArtifactRequest(String componentId,
String userId,
ComponentTypeEnum componentType,
ArtifactsBusinessLogic.ArtifactOperation operation,
String artifactId,
ArtifactDefinition artifactInfo,
String origMd5,
String originData,
String interfaceName,
String operationName,
String parentId,
String containerComponentType) |
fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> |
handleArtifactRequest(String componentId,
String userId,
ComponentTypeEnum componentType,
ArtifactsBusinessLogic.ArtifactOperation operation,
String artifactId,
ArtifactDefinition artifactInfo,
String origMd5,
String originData,
String interfaceName,
String operationName,
String parentId,
String containerComponentType,
boolean shouldLock,
boolean inTransaction) |
void |
handleAuditing(AuditingActionEnum auditingActionEnum,
Component component,
String componentId,
User user,
ArtifactDefinition artifactDefinition,
String prevArtifactUuid,
String currentArtifactUuid,
ResponseFormat responseFormat,
ComponentTypeEnum componentTypeEnum,
String resourceInstanceName) |
fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> |
handleDelete(String parentId,
String artifactId,
User user,
AuditingActionEnum auditingAction,
ComponentTypeEnum componentType,
Component parent,
String interfaceType,
String operationName,
boolean shouldLock,
boolean inTransaction) |
fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> |
handleDownloadRequestById(String componentId,
String artifactId,
String userId,
ComponentTypeEnum componentType,
String parentId,
String containerComponentType) |
fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> |
handleDownloadToscaModelRequest(Component component,
ArtifactDefinition csarArtifact,
boolean shouldLock,
boolean inTransaction) |
void |
handleTransaction(fj.data.Either<Operation,ResponseFormat> opState) |
boolean |
isValidJson(byte[] jsonToParse) |
boolean |
isValidXml(byte[] xmlToParse) |
fj.data.Either<ArtifactDefinition,ResponseFormat> |
updateArtifactOnComponentByUUID(String data,
javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
updates an artifact on a component by UUID
|
fj.data.Either<ArtifactDefinition,ResponseFormat> |
updateArtifactOnRiByUUID(String data,
javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
String resourceInstanceName,
String artifactUUID,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
updates an artifact on a resource instance by UUID
|
fj.data.Either<ArtifactDefinition,ResponseFormat> |
uploadArtifactToComponentByUUID(String data,
javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
uploads an artifact to a component by UUID
|
fj.data.Either<ArtifactDefinition,ResponseFormat> |
uploadArtifactToRiByUUID(String data,
javax.servlet.http.HttpServletRequest request,
ComponentTypeEnum componentType,
String componentUuid,
String resourceInstanceName,
Map<AuditingFieldsKeysEnum,Object> additionalParams)
upload an artifact to a resource instance by UUID
|
fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> |
validateAndHandleArtifact(String componentUniqueId,
ComponentTypeEnum componentType,
ArtifactsBusinessLogic.ArtifactOperation operation,
String artifactUniqueId,
ArtifactDefinition artifactDefinition,
String origMd5,
String originData,
String interfaceName,
String operationName,
String parentId,
User user,
Component component,
boolean shouldLock,
boolean inTransaction)
This Method validates only the Artifact and does not validate user / role / component ect...
For regular usage use handleArtifactRequest(String, String, ComponentTypeEnum, ArtifactOperation, String, ArtifactDefinition, String, String, String, String, String, String) |
void |
validateArtifactTypeExists(Wrapper<ResponseFormat> responseWrapper,
ArtifactDefinition artifactInfo) |
void |
validateFileExtension(Wrapper<ResponseFormat> responseWrapper,
IDeploymentArtifactTypeConfigGetter deploymentConfigGetter,
ArtifactDefinition artifactInfo,
NodeTypeEnum parentType,
ArtifactTypeEnum artifactType) |
void |
validateSingleArtifactType(Wrapper<ResponseFormat> errorWrapper,
ArtifactTypeEnum allowedArtifactType,
Component parentComponent,
NodeTypeEnum parentType,
String parentRiId) |
void |
validateSingleDeploymentArtifactName(Wrapper<ResponseFormat> errorWrapper,
String artifactName,
Component parentComponent,
NodeTypeEnum parentType) |
fj.data.Either<List<HeatParameterDefinition>,ResponseFormat> |
validateUploadParamsFromEnvFile(AuditingActionEnum auditingAction,
Component parent,
User user,
ArtifactDefinition artifactInfo,
String artifactId,
ComponentTypeEnum componentType,
String riName,
List<HeatParameterDefinition> currentHeatEnvParams,
List<HeatParameterDefinition> updatedHeatEnvParams,
String currArtifactName) |
commitOrRollback, getAllDataTypes, getComponentOperation, getComponentOperationByParentComponentType, getComponentTypeByParentComponentType, getIComponentOperation, getResource, getType, handleDefaultValue, lockComponent, lockComponent, lockComponentByName, setComponentsUtils, setGraphLockOperation, setTitanGenericDao, setUserAdmin, unlockComponent, unlockComponent, validateCanWorkOnComponent, validateCanWorkOnComponent, validateComponentExists, validateComponentExists, validateComponentExistsByFilter, validateComponentLock, validateComponentType, validateComponentTypeEnum, validateJsonBody, validatePropertyDefaultValue, validateUserExist, validateUserExists, validateUserExists, validateUserExistsActionStatus, validateUserNotEmpty, validateUserRole
public fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> handleArtifactRequest(String componentId, String userId, ComponentTypeEnum componentType, ArtifactsBusinessLogic.ArtifactOperation operation, String artifactId, ArtifactDefinition artifactInfo, String origMd5, String originData, String interfaceName, String operationName, String parentId, String containerComponentType)
public fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> handleArtifactRequest(String componentId, String userId, ComponentTypeEnum componentType, ArtifactsBusinessLogic.ArtifactOperation operation, String artifactId, ArtifactDefinition artifactInfo, String origMd5, String originData, String interfaceName, String operationName, String parentId, String containerComponentType, boolean shouldLock, boolean inTransaction)
public fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> validateAndHandleArtifact(String componentUniqueId, ComponentTypeEnum componentType, ArtifactsBusinessLogic.ArtifactOperation operation, String artifactUniqueId, ArtifactDefinition artifactDefinition, String origMd5, String originData, String interfaceName, String operationName, String parentId, User user, Component component, boolean shouldLock, boolean inTransaction)
handleArtifactRequest(String, String, ComponentTypeEnum, ArtifactOperation, String, ArtifactDefinition, String, String, String, String, String, String)
public fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> generateAndSaveToscaArtifact(ArtifactDefinition artifactDefinition, Component component, User user, boolean isInCertificationRequest, boolean shouldLock, boolean inTransaction, boolean fetchTemplatesFromDB)
public fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> handleDownloadToscaModelRequest(Component component, ArtifactDefinition csarArtifact, boolean shouldLock, boolean inTransaction)
componentId
- artifactId
- userId
- componentType
- parentId
- TODOpublic fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> handleDownloadRequestById(String componentId, String artifactId, String userId, ComponentTypeEnum componentType, String parentId, String containerComponentType)
public void handleAuditing(AuditingActionEnum auditingActionEnum, Component component, String componentId, User user, ArtifactDefinition artifactDefinition, String prevArtifactUuid, String currentArtifactUuid, ResponseFormat responseFormat, ComponentTypeEnum componentTypeEnum, String resourceInstanceName)
public EnumMap<AuditingFieldsKeysEnum,Object> createArtifactAuditingFields(ArtifactDefinition artifactDefinition, String prevArtifactUuid, String currentArtifactUuid)
public fj.data.Either<fj.data.Either<ArtifactDefinition,Operation>,ResponseFormat> handleDelete(String parentId, String artifactId, User user, AuditingActionEnum auditingAction, ComponentTypeEnum componentType, Component parent, String interfaceType, String operationName, boolean shouldLock, boolean inTransaction)
public void validateArtifactTypeExists(Wrapper<ResponseFormat> responseWrapper, ArtifactDefinition artifactInfo)
public void validateFileExtension(Wrapper<ResponseFormat> responseWrapper, IDeploymentArtifactTypeConfigGetter deploymentConfigGetter, ArtifactDefinition artifactInfo, NodeTypeEnum parentType, ArtifactTypeEnum artifactType)
public void fillArtifactPayloadValidation(Wrapper<ResponseFormat> errorWrapper, Wrapper<byte[]> payloadWrapper, ArtifactDefinition artifactDefinition)
public fj.data.Either<Boolean,ResponseFormat> fillArtifactPayload(Wrapper<byte[]> payloadWrapper, ArtifactDefinition artifactMD)
public boolean isValidXml(byte[] xmlToParse)
public boolean isValidJson(byte[] jsonToParse)
public void validateSingleArtifactType(Wrapper<ResponseFormat> errorWrapper, ArtifactTypeEnum allowedArtifactType, Component parentComponent, NodeTypeEnum parentType, String parentRiId)
public void validateSingleDeploymentArtifactName(Wrapper<ResponseFormat> errorWrapper, String artifactName, Component parentComponent, NodeTypeEnum parentType)
public List<ArtifactDefinition> getDeploymentArtifacts(Component parentComponent, NodeTypeEnum parentType, String ciId)
public void handleTransaction(fj.data.Either<Operation,ResponseFormat> opState)
public fj.data.Either<Operation,ResponseFormat> deleteArtifactByInterface(String resourceId, String interfaceType, String operationName, String userId, String artifactId, org.apache.commons.lang3.tuple.ImmutablePair<User,Resource> userResourceAuditPair, boolean shouldLock, boolean inTransaction)
public StorageOperationStatus deleteAllComponentArtifactsIfNotOnGraph(List<ArtifactDefinition> artifacts)
public StorageOperationStatus deleteIfNotOnGraph(String artifactId, String artifactEsId, boolean deleteOnlyPayload)
public fj.data.Either<byte[],ResponseFormat> downloadRsrcArtifactByNames(String serviceName, String serviceVersion, String resourceName, String resourceVersion, String artifactName)
public fj.data.Either<byte[],ResponseFormat> downloadRsrcInstArtifactByNames(String serviceName, String serviceVersion, String resourceInstanceName, String artifactName)
public fj.data.Either<byte[],ResponseFormat> downloadServiceArtifactByNames(String serviceName, String serviceVersion, String artifactName)
public fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<String,byte[]>,ResponseFormat> downloadArtifact(String artifactUniqueId)
public ESArtifactData createEsArtifactData(ArtifactDataDefinition artifactInfo, byte[] artifactPayload)
public IResourceOperation getResourceOperation()
public fj.data.Either<ArtifactDefinition,ResponseFormat> createArtifactPlaceHolderInfo(String resourceId, String logicalName, Map<String,Object> artifactInfoMap, String userId, ArtifactGroupTypeEnum groupType, boolean inTransaction)
public ArtifactDefinition createArtifactPlaceHolderInfo(String resourceId, String logicalName, Map<String,Object> artifactInfoMap, User user, ArtifactGroupTypeEnum groupType)
public fj.data.Either<Map<String,ArtifactDefinition>,StorageOperationStatus> getArtifacts(String parentId, NodeTypeEnum parentType, boolean inTransaction, ArtifactGroupTypeEnum groupType)
public fj.data.Either<ArtifactDefinition,StorageOperationStatus> addHeatEnvArtifact(ArtifactDefinition artifactHeatEnv, ArtifactDefinition artifact, String parentId, NodeTypeEnum parentType, boolean inTransaction)
public fj.data.Either<ArtifactDefinition,ResponseFormat> generateHeatEnvArtifact(ArtifactDefinition artifactDefinition, Component component, String resourceInstanceName, User modifier, boolean shouldLock)
artifactDefinition
- public fj.data.Either<ArtifactDefinition,ResponseFormat> generateAndSaveHeatEnvArtifact(ArtifactDefinition artifactDefinition, String payload, Component component, String resourceInstanceName, User modifier, boolean shouldLock)
artifactDefinition
- payload
- protected fj.data.Either<ArtifactDefinition,ResponseFormat> generateArtifactPayload(ArtifactDefinition artifactDefinition, Component component, String resourceInstanceName, User modifier, boolean shouldLock, Supplier<Long> payloadUpdateDateGen, Supplier<fj.data.Either<ESArtifactData,ResponseFormat>> esDataCreator)
public fj.data.Either<List<HeatParameterDefinition>,ResponseFormat> validateUploadParamsFromEnvFile(AuditingActionEnum auditingAction, Component parent, User user, ArtifactDefinition artifactInfo, String artifactId, ComponentTypeEnum componentType, String riName, List<HeatParameterDefinition> currentHeatEnvParams, List<HeatParameterDefinition> updatedHeatEnvParams, String currArtifactName)
public ComponentOperation getComponentOperation(NodeTypeEnum componentType)
public ArtifactDefinition extractArtifactDefinition(fj.data.Either<ArtifactDefinition,Operation> eitherArtifact)
public fj.data.Either<byte[],ResponseFormat> downloadComponentArtifactByUUIDs(ComponentTypeEnum componentType, String componentUuid, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> auditAdditionalParam)
componentType
- componentUuid
- artifactUUID
- auditAdditionalParam
- public fj.data.Either<byte[],ResponseFormat> downloadResourceInstanceArtifactByUUIDs(ComponentTypeEnum componentType, String componentUuid, String resourceInstanceName, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> auditAdditionalParam)
componentType
- componentUuid
- resourceName
- artifactUUID
- auditAdditionalParam
- public fj.data.Either<ArtifactDefinition,ResponseFormat> uploadArtifactToComponentByUUID(String data, javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, Map<AuditingFieldsKeysEnum,Object> additionalParams)
data
- request
- componentType
- componentUuid
- additionalParams
- public fj.data.Either<ArtifactDefinition,ResponseFormat> uploadArtifactToRiByUUID(String data, javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, String resourceInstanceName, Map<AuditingFieldsKeysEnum,Object> additionalParams)
data
- request
- componentType
- componentUuid
- resourceInstanceName
- additionalParams
- public fj.data.Either<ArtifactDefinition,ResponseFormat> updateArtifactOnComponentByUUID(String data, javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> additionalParams)
data
- request
- componentType
- componentUuid
- artifactUUID
- additionalParams
- public fj.data.Either<ArtifactDefinition,ResponseFormat> updateArtifactOnRiByUUID(String data, javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, String resourceInstanceName, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> additionalParams)
data
- request
- componentType
- componentUuid
- resourceInstanceName
- artifactUUID
- additionalParams
- public fj.data.Either<ArtifactDefinition,ResponseFormat> deleteArtifactOnComponentByUUID(javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> additionalParams)
request
- componentType
- componentUuid
- artifactUUID
- additionalParams
- public fj.data.Either<ArtifactDefinition,ResponseFormat> deleteArtifactOnRiByUUID(javax.servlet.http.HttpServletRequest request, ComponentTypeEnum componentType, String componentUuid, String resourceInstanceName, String artifactUUID, Map<AuditingFieldsKeysEnum,Object> additionalParams)
request
- componentType
- componentUuid
- resourceInstanceName
- artifactUUID
- additionalParams
- Copyright © 2017. All rights reserved.