001// -------------------------------------------------------------------------------- 002// Copyright 2002-2026 Echo Three, LLC 003// 004// Licensed under the Apache License, Version 2.0 (the "License"); 005// you may not use this file except in compliance with the License. 006// You may obtain a copy of the License at 007// 008// http://www.apache.org/licenses/LICENSE-2.0 009// 010// Unless required by applicable law or agreed to in writing, software 011// distributed under the License is distributed on an "AS IS" BASIS, 012// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013// See the License for the specific language governing permissions and 014// limitations under the License. 015// -------------------------------------------------------------------------------- 016 017package com.echothree.model.control.chain.server.logic; 018 019import com.echothree.model.control.chain.common.exception.UnknownChainInstanceNameException; 020import com.echothree.model.control.chain.server.control.ChainControl; 021import com.echothree.model.control.sequence.common.SequenceTypes; 022import com.echothree.model.control.sequence.server.logic.SequenceGeneratorLogic; 023import com.echothree.model.data.chain.server.entity.Chain; 024import com.echothree.model.data.chain.server.entity.ChainEntityRoleType; 025import com.echothree.model.data.chain.server.entity.ChainInstance; 026import com.echothree.model.data.chain.server.entity.ChainType; 027import com.echothree.model.data.core.server.entity.EntityInstance; 028import com.echothree.model.data.party.server.entity.Party; 029import com.echothree.util.common.message.ExecutionErrors; 030import com.echothree.util.common.persistence.BasePK; 031import com.echothree.util.server.control.BaseLogic; 032import com.echothree.util.server.message.ExecutionErrorAccumulator; 033import java.util.HashSet; 034import java.util.Set; 035import javax.enterprise.context.ApplicationScoped; 036import javax.inject.Inject; 037 038@ApplicationScoped 039public class ChainInstanceLogic 040 extends BaseLogic { 041 042 @Inject 043 protected ChainControl chainControl; 044 045 @Inject 046 protected ChainLogic chainLogic; 047 048 @Inject 049 protected ChainTypeLogic chainTypeLogic; 050 051 protected ChainInstanceLogic() { 052 super(); 053 } 054 055 public ChainInstance createChainInstance(final ExecutionErrorAccumulator eea, final Chain chain, final BasePK createdBy) { 056 var defaultChainActionSet = chainControl.getDefaultChainActionSet(chain); 057 ChainInstance chainInstance = null; 058 059 // The lack of a defaultChainActionSet is not a reportable error - it just silently avoids creating a Chain Instance. 060 if(defaultChainActionSet != null) { 061 var sequence = chain.getLastDetail().getChainInstanceSequence(); 062 063 if(sequence == null) { 064 sequence = SequenceGeneratorLogic.getInstance().getDefaultSequence(eea, SequenceTypes.CHAIN_INSTANCE.name()); 065 } 066 067 if(!hasExecutionErrors(eea)) { 068 chainInstance = chainControl.createChainInstance(SequenceGeneratorLogic.getInstance().getNextSequenceValue(sequence), defaultChainActionSet, createdBy); 069 } 070 } 071 072 return chainInstance; 073 } 074 075 public ChainInstance createChainInstance(final ExecutionErrorAccumulator eea, final ChainType chainType, final Party party, final BasePK createdBy) { 076 var chain = chainLogic.getChain(eea, chainType, party); 077 ChainInstance chainInstance = null; 078 079 if(chain != null) { 080 chainInstance = createChainInstance(eea, chain, createdBy); 081 } 082 083 return chainInstance; 084 } 085 086 public ChainInstance createChainInstance(final ExecutionErrorAccumulator eea, final String chainKindName, final String chainTypeName, final Party party, 087 final BasePK createdBy) { 088 var chainType = chainTypeLogic.getChainTypeByName(eea, chainKindName, chainTypeName); 089 ChainInstance chainInstance = null; 090 091 if(!hasExecutionErrors(eea)) { 092 chainInstance = createChainInstance(eea, chainType, party, createdBy); 093 } 094 095 return chainInstance; 096 } 097 098 public ChainInstance getChainInstanceByName(final ExecutionErrorAccumulator eea, final String chainInstanceName) { 099 var chainInstance = chainControl.getChainInstanceByName(chainInstanceName); 100 101 if(chainInstance == null) { 102 handleExecutionError(UnknownChainInstanceNameException.class, eea, ExecutionErrors.UnknownChainInstanceName.name(), chainInstanceName); 103 } 104 105 return chainInstance; 106 } 107 108 public void deleteChainInstanceByChainEntityRoleTypeAndEntityInstance(final ChainEntityRoleType chainEntityRoleType, final EntityInstance entityInstance, 109 final BasePK deletedBy) { 110 var chainInstanceEntityRoles = chainControl.getChainInstanceEntityRoles(chainEntityRoleType, entityInstance); 111 Set<ChainInstance> chainInstances = new HashSet<>(); 112 113 chainInstanceEntityRoles.forEach((chainInstanceEntityRole) -> { 114 chainInstances.add(chainInstanceEntityRole.getChainInstanceForUpdate()); 115 }); 116 117 chainControl.deleteChainInstances(chainInstances, deletedBy); 118 } 119 120}