src/main/java/org/onap/clamp/clds/client/CldsEventDelegate.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP CLAMP
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights
   6  *                             reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  * http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END============================================
  20  * ===================================================================
  21  *
  22  */
  23
  24 package org.onap.clamp.clds.client;
  25
  26 import com.att.eelf.configuration.EELFLogger;
  27 import com.att.eelf.configuration.EELFManager;
  28
  29 import org.apache.camel.Exchange;
  30 import org.apache.camel.Handler;
  31 import org.onap.clamp.clds.config.ClampProperties;
  32 import org.onap.clamp.clds.dao.CldsDao;
  33 import org.onap.clamp.clds.model.CldsEvent;
  34 import org.onap.clamp.clds.model.CldsModel;
  35 import org.onap.clamp.clds.model.properties.ModelProperties;
  36 import org.springframework.beans.factory.annotation.Autowired;
  37 import org.springframework.stereotype.Component;
  38
  39 /**
  40  * Create CLDS Event.
  41  */
  42 @Component
  43 public class CldsEventDelegate {
  44
  45     protected static final EELFLogger logger = EELFManager.getInstance().getLogger(CldsEventDelegate.class);
  46     protected static final EELFLogger metricsLogger = EELFManager.getInstance().getMetricsLogger();
  47     @Autowired
  48     private CldsDao cldsDao;
  49     @Autowired
  50     private ClampProperties refProp;
  51
  52     /**
  53      * Insert event using process variables.
  54      *
  55      * @param camelExchange
  56      *            The Camel Exchange object containing the properties
  57      */
  58     @Handler
  59     public void execute(Exchange camelExchange) {
  60         String controlName = (String) camelExchange.getProperty("controlName");
  61         String actionCd = (String) camelExchange.getProperty("actionCd");
  62         String actionStateCd = (String) camelExchange.getProperty("actionStateCd");
  63         // Flag indicate whether it is triggered by Validation Test button from
  64         // UI
  65         boolean isTest = (boolean) camelExchange.getProperty("isTest");
  66         boolean isInsertTestEvent = (boolean) camelExchange.getProperty("isInsertTestEvent");
  67         String userid = (String) camelExchange.getProperty("userid");
  68         // do not insert events for test actions unless flag set to insert them
  69         if (!isTest || isInsertTestEvent) {
  70             // won't really have userid here...
  71             CldsEvent.insEvent(cldsDao, controlName, userid, actionCd, actionStateCd, camelExchange.getExchangeId());
  72         }
  73         generateAutoPolicyId(camelExchange);
  74     }
  75
  76     private void generateAutoPolicyId(Exchange camelExchange) {
  77         ModelProperties prop = ModelProperties.create(camelExchange);
  78         ;
  79         CldsModel cldsModel = CldsModel.retrieve(cldsDao, (String) camelExchange.getProperty("modelName"), false);
  80         cldsModel.setPropText(cldsModel.getPropText().replaceAll("AUTO_GENERATED_POLICY_ID_AT_SUBMIT",
  81                 prop.getPolicyNameForDcaeDeploy(refProp)));
  82         cldsModel.save(cldsDao, (String) camelExchange.getProperty("userid"));
  83     }
  84 }