content: /*
   * Copyright 1999-2020 Alibaba Group Holding Ltd.
   *
   * 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.
   */
  
  package com.alibaba.nacos.config.server.remote;
  
  import com.alibaba.nacos.api.config.remote.request.ConfigRemoveRequest;
  import com.alibaba.nacos.api.config.remote.response.ConfigRemoveResponse;
  import com.alibaba.nacos.api.exception.NacosException;
  import com.alibaba.nacos.api.remote.request.RequestMeta;
  import com.alibaba.nacos.auth.annotation.Secured;
  import com.alibaba.nacos.common.utils.NamespaceUtil;
  import com.alibaba.nacos.config.server.constant.Constants;
  import com.alibaba.nacos.config.server.service.ConfigOperationService;
  import com.alibaba.nacos.config.server.service.repository.ConfigInfoGrayPersistService;
  import com.alibaba.nacos.config.server.service.repository.ConfigInfoPersistService;
  import com.alibaba.nacos.config.server.utils.ParamUtils;
  import com.alibaba.nacos.core.control.TpsControl;
  import com.alibaba.nacos.core.namespace.filter.NamespaceValidation;
  import com.alibaba.nacos.core.paramcheck.ExtractorManager;
  import com.alibaba.nacos.core.paramcheck.impl.ConfigRequestParamExtractor;
  import com.alibaba.nacos.core.remote.RequestHandler;
  import com.alibaba.nacos.core.utils.Loggers;
  import com.alibaba.nacos.plugin.auth.constant.ActionTypes;
  import com.alibaba.nacos.plugin.auth.constant.SignType;
  import org.springframework.stereotype.Component;
  
  /**
   * handler to remove config.
   *
   * @author liuzunfei
   * @version $Id: ConfiRemoveRequestHandler.java, v 0.1 2020年07月16日 5:49 PM liuzunfei Exp $
   */
  @Component
  public class ConfigRemoveRequestHandler extends RequestHandler<ConfigRemoveRequest, ConfigRemoveResponse> {
      
      private final ConfigInfoPersistService configInfoPersistService;
      
      private final ConfigInfoGrayPersistService configInfoGrayPersistService;
      
      private final ConfigOperationService configOperationService;
      
      public ConfigRemoveRequestHandler(ConfigInfoPersistService configInfoPersistService,
              ConfigInfoGrayPersistService configInfoGrayPersistService, ConfigOperationService configOperationService) {
          this.configInfoPersistService = configInfoPersistService;
          this.configInfoGrayPersistService = configInfoGrayPersistService;
          this.configOperationService = configOperationService;
      }
      
      @Override
      @NamespaceValidation
      @TpsControl(pointName = "ConfigRemove")
      @Secured(action = ActionTypes.WRITE, signType = SignType.CONFIG)
      @ExtractorManager.Extractor(rpcExtractor = ConfigRequestParamExtractor.class)
      public ConfigRemoveResponse handle(ConfigRemoveRequest configRemoveRequest, RequestMeta meta)
              throws NacosException {
          // check tenant
          String tenant = configRemoveRequest.getTenant();
          tenant = NamespaceUtil.processNamespaceParameter(tenant);
          String dataId = configRemoveRequest.getDataId();
          String group = configRemoveRequest.getGroup();
          String tag = configRemoveRequest.getTag();
          try {
              ParamUtils.checkTenant(tenant);
              ParamUtils.checkParam(dataId, group, "datumId", "rm");
              ParamUtils.checkParam(tag);
              String clientIp = meta.getClientIp();
              configOperationService.deleteConfig(dataId, group, tenant, tag, clientIp, null, Constants.RPC);
              return ConfigRemoveResponse.buildSuccessResponse();
          } catch (Exception e) {
              Loggers.REMOTE_DIGEST.error("remove config error,error msg is {}", e.getMessage(), e);
              return ConfigRemoveResponse.buildFailResponse(e.getMessage());
          }
      }
      
  }
  