summaryrefslogtreecommitdiffstats
path: root/controlloop/common/controller-usecases/src/main/java/org/onap/policy/drools/apps/controller/usecases/step/AaiCqStep2.java
blob: 9ae1d7fb04954be5e1e75070ffbcdb5b63f7155a (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
/*-
 * ============LICENSE_START=======================================================
 * ONAP
 * ================================================================================
 * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
 * ================================================================================
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * ============LICENSE_END=========================================================
 */

package org.onap.policy.drools.apps.controller.usecases.step;

import org.onap.policy.aai.AaiCqResponse;
import org.onap.policy.controlloop.actor.aai.AaiActor;
import org.onap.policy.controlloop.actor.aai.AaiCustomQueryOperation;
import org.onap.policy.controlloop.actorserviceprovider.OperationOutcome;

/**
 * Wrapper for {@link AaiCustomQueryOperation}. The {@link #success(OperationOutcome)}
 * method stores the resultant "tenant" object in the step's context.
 */
public class AaiCqStep2 extends Step2 {

    /**
     * Constructs the object using information from another step.
     *
     * @param otherStep step whose information should be used
     */
    public AaiCqStep2(Step2 otherStep) {
        super(otherStep, AaiActor.NAME, AaiCustomQueryOperation.NAME);
    }

    /**
     * Skips the operation if we already have the data.
     */
    @Override
    public boolean start(long remainingMs) {
        if (stepContext.contains(AaiCqResponse.CONTEXT_KEY)) {
            // already have the data
            return false;
        }

        return super.start(remainingMs);
    }

    /**
     * Saves the response for later use.
     */
    @Override
    public void success(OperationOutcome outcome) {
        AaiCqResponse resp = outcome.getResponse();
        stepContext.setProperty(AaiCqResponse.CONTEXT_KEY, resp);

        super.success(outcome);
    }
}