catalog-model/src/main/java/org/openecomp/sdc/be/model/cache/jobs/OverrideJob.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   4  * ================================================================================
   5  * Copyright (C) 2017 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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.openecomp.sdc.be.model.cache.jobs;
  22
  23 import fj.data.Either;
  24 import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
  25 import org.openecomp.sdc.be.model.Component;
  26 import org.openecomp.sdc.be.model.cache.DaoInfo;
  27 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  28 import org.openecomp.sdc.common.log.wrappers.Logger;
  29
  30 /**
  31  * Created by mlando on 9/20/2016.
  32  */
  33 public class OverrideJob extends Job {
  34     private static final Logger log = Logger.getLogger(OverrideJob.class.getName());
  35
  36     public OverrideJob(DaoInfo daoInfo, String componentId, NodeTypeEnum nodeTypeEnum, long timestamp) {
  37         super(daoInfo, componentId, nodeTypeEnum, timestamp);
  38
  39     }
  40
  41     @Override
  42     public Object doWork() {
  43         try {
  44             log.trace("starting work on job.");
  45             log.trace("override component in cache, componentId:{} of nodeTypeEnum:{} with timestamp:{}.", componentId,
  46                     nodeTypeEnum, timestamp);
  47             // get component from grath
  48             Either<Component, StorageOperationStatus> componentRes = daoInfo.getToscaOperationFacade().getToscaElement(componentId);
  49             if (componentRes.isRight()) {
  50                 log.debug("failed to get full component:{} from graph status:{}", componentId,
  51                         componentRes.right().value());
  52                 return false;
  53             }
  54             Component component = componentRes.left().value();
  55             // store in cache
  56             if (!this.daoInfo.getComponentCache().setComponent(component, nodeTypeEnum)) {
  57                 log.debug("failed to store componentId:{} nodeTypeEnum:", componentId, nodeTypeEnum);
  58                 return false;
  59             }
  60             log.debug("cache successfully overrided  componentId:{} nodeTypeEnum:{} timestemp:{}.", componentId,
  61                     nodeTypeEnum, timestamp);
  62             return true;
  63         } catch (Exception e) {
  64             log.debug("an exception was encountered during OverrideJob", e);
  65         } finally {
  66             this.daoInfo.getToscaOperationFacade().commit();
  67         }
  68         return false;
  69
  70     }
  71 }