src/main/java/org/onap/dmaap/mmagent/UpdateMirrorMaker.java

   1 /*******************************************************************************
   2  *  ============LICENSE_START=======================================================
   3  *  org.onap.dmaap
   4  *  ================================================================================
   5  *  Copyright © 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  *        http://www.apache.org/licenses/LICENSE-2.0
  11 *
  12  *  Unless required by applicable law or agreed to in writing, software
  13  *  distributed under the License is distributed on an "AS IS" BASIS,
  14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  *  See the License for the specific language governing permissions and
  16  *  limitations under the License.
  17  *  ============LICENSE_END=========================================================
  18  *
  19  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  20  *
  21  *******************************************************************************/
  22  package org.onap.dmaap.mmagent;
  23
  24 import java.util.Date;
  25
  26 import org.apache.http.HttpStatus;
  27 import org.json.JSONObject;
  28
  29 import org.onap.dmaap.dmf.mr.CambriaApiException;
  30 import org.onap.dmaap.dmf.mr.exception.DMaaPResponseCode;
  31 import org.onap.dmaap.dmf.mr.exception.ErrorResponse;
  32 import org.onap.dmaap.dmf.mr.utils.Utils;
  33
  34 public class UpdateMirrorMaker {
  35         String messageID;
  36         MirrorMaker updateMirrorMaker;
  37
  38         public MirrorMaker getUpdateMirrorMaker() {
  39                 return updateMirrorMaker;
  40         }
  41
  42         public void setUpdateMirrorMaker(MirrorMaker updateMirrorMaker) {
  43                 this.updateMirrorMaker = updateMirrorMaker;
  44         }
  45
  46         public String getMessageID() {
  47                 return messageID;
  48         }
  49
  50         public void setMessageID(String messageID) {
  51                 this.messageID = messageID;
  52         }
  53         public void validateJSON(JSONObject jsonObj) throws CambriaApiException
  54         {
  55                 ErrorResponse errRes = new ErrorResponse(HttpStatus.SC_BAD_REQUEST,
  56                                 DMaaPResponseCode.INCORRECT_JSON.getResponseCode(), "", null, Utils.getFormattedDate(new Date()), null, null, null,
  57                                                 null,
  58                                 "");
  59
  60
  61                 if(jsonObj.has("consumer")&& null==this.updateMirrorMaker.getConsumer())
  62                 {
  63                         errRes.setErrorMessage("Please provide Consumer host:port details");
  64                         throw new CambriaApiException(errRes);
  65                 }
  66                 if(jsonObj.has("producer")&& null==this.updateMirrorMaker.getProducer())
  67                 {
  68                         errRes.setErrorMessage("Please provide Producer host:port details");
  69                         throw new CambriaApiException(errRes);
  70                 }
  71                 if(jsonObj.has("numStreams")&& this.updateMirrorMaker.getNumStreams()<=0)
  72                 {
  73                         errRes.setErrorMessage("Please provide numStreams value");
  74                         throw new CambriaApiException(errRes);
  75                 }
  76                 if(jsonObj.has("whitelist"))
  77                 {
  78                         errRes.setErrorMessage("Please use Create Whitelist API to add whitelist topics");
  79                         throw new CambriaApiException(errRes);
  80                 }
  81
  82         }
  83 }