2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.onap.policy.drools.lifecycle;
23 import com.fasterxml.jackson.annotation.JsonIgnore;
25 import org.onap.policy.common.gson.annotation.GsonJsonIgnore;
26 import org.onap.policy.common.utils.coder.CoderException;
27 import org.onap.policy.drools.controller.DroolsControllerConstants;
28 import org.onap.policy.drools.domain.models.artifact.NativeArtifactPolicy;
29 import org.onap.policy.drools.protocol.configuration.ControllerConfiguration;
30 import org.onap.policy.drools.protocol.configuration.DroolsConfiguration;
31 import org.onap.policy.drools.system.PolicyController;
32 import org.onap.policy.drools.system.PolicyControllerConstants;
33 import org.onap.policy.drools.system.PolicyEngineConstants;
34 import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
35 import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyTypeIdentifier;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
39 public class PolicyTypeNativeArtifactController implements PolicyTypeController {
40 private static final Logger logger = LoggerFactory.getLogger(PolicyTypeNativeArtifactController.class);
43 protected final ToscaPolicyTypeIdentifier policyType;
47 protected final transient LifecycleFsm fsm;
49 public PolicyTypeNativeArtifactController(LifecycleFsm fsm, ToscaPolicyTypeIdentifier policyType) {
50 this.policyType = policyType;
55 public boolean deploy(ToscaPolicy policy) {
56 NativeArtifactPolicy nativePolicy;
57 PolicyController controller;
59 nativePolicy = fsm.getDomainMaker().convertTo(policy, NativeArtifactPolicy.class);
60 DroolsConfiguration droolsConfig =
61 new DroolsConfiguration(
62 nativePolicy.getProperties().getRulesArtifact().getArtifactId(),
63 nativePolicy.getProperties().getRulesArtifact().getGroupId(),
64 nativePolicy.getProperties().getRulesArtifact().getVersion());
67 PolicyControllerConstants.getFactory().get(nativePolicy.getProperties().getController().getName());
68 if (controller.getDrools().isBrained()) {
69 logger.warn("upgrade of a live controller is strongly discouraged (undeploy first): {} -> {}",
70 controller, droolsConfig);
73 return update(nativePolicy, droolsConfig);
74 } catch (CoderException | RuntimeException e) {
75 logger.warn("Invalid Policy: {}", policy);
81 public boolean undeploy(ToscaPolicy policy) {
83 NativeArtifactPolicy nativePolicy = fsm.getDomainMaker().convertTo(policy, NativeArtifactPolicy.class);
84 DroolsConfiguration noConfig =
85 new DroolsConfiguration(
86 DroolsControllerConstants.NO_ARTIFACT_ID,
87 DroolsControllerConstants.NO_GROUP_ID,
88 DroolsControllerConstants.NO_VERSION);
90 return update(nativePolicy, noConfig);
91 } catch (RuntimeException | CoderException e) {
92 logger.warn("Invalid Policy: {}", policy);
97 private boolean update(NativeArtifactPolicy nativePolicy, DroolsConfiguration droolsConfig) {
98 ControllerConfiguration controllerConfig =
99 new ControllerConfiguration(nativePolicy.getProperties().getController().getName(),
100 ControllerConfiguration.CONFIG_CONTROLLER_OPERATION_UPDATE, droolsConfig);
101 return PolicyEngineConstants.getManager().updatePolicyController(controllerConfig) != null;