content: /*
   * Copyright 1999-2018 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.common.Constants;
  import com.alibaba.nacos.api.config.remote.request.ConfigBatchListenRequest;
  import com.alibaba.nacos.api.config.remote.response.ConfigChangeBatchListenResponse;
  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.service.ConfigCacheService;
  import com.alibaba.nacos.config.server.utils.GroupKey2;
  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.ConfigBatchListenRequestParamExtractor;
  import com.alibaba.nacos.core.remote.RequestHandler;
  import com.alibaba.nacos.core.utils.StringPool;
  import com.alibaba.nacos.plugin.auth.constant.ActionTypes;
  import com.alibaba.nacos.plugin.auth.constant.SignType;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.stereotype.Component;
  
  /**
   * config change listen request handler.
   *
   * @author liuzunfei
   * @version $Id: ConfigChangeListenRequestHandler.java, v 0.1 2020年07月14日 10:11 AM liuzunfei Exp $
   */
  @Component
  public class ConfigChangeBatchListenRequestHandler
          extends RequestHandler<ConfigBatchListenRequest, ConfigChangeBatchListenResponse> {
      
      @Autowired
      private ConfigChangeListenContext configChangeListenContext;
      
      @Override
      @NamespaceValidation
      @TpsControl(pointName = "ConfigListen")
      @Secured(action = ActionTypes.READ, signType = SignType.CONFIG)
      @ExtractorManager.Extractor(rpcExtractor = ConfigBatchListenRequestParamExtractor.class)
      public ConfigChangeBatchListenResponse handle(ConfigBatchListenRequest configChangeListenRequest, RequestMeta meta)
              throws NacosException {
          String connectionId = StringPool.get(meta.getConnectionId());
          String tag = configChangeListenRequest.getHeader(Constants.VIPSERVER_TAG);
          ParamUtils.checkParam(tag);
          ConfigChangeBatchListenResponse configChangeBatchListenResponse = new ConfigChangeBatchListenResponse();
          for (ConfigBatchListenRequest.ConfigListenContext listenContext : configChangeListenRequest.getConfigListenContexts()) {
              boolean isNeedTransferNamespace = NamespaceUtil.isNeedTransferNamespace(listenContext.getTenant());
              String namespaceId = NamespaceUtil.processNamespaceParameter(listenContext.getTenant());
              String groupKey = GroupKey2.getKey(listenContext.getDataId(), listenContext.getGroup(), namespaceId);
              groupKey = StringPool.get(groupKey);
              
              String md5 = StringPool.get(listenContext.getMd5());
              
              if (configChangeListenRequest.isListen()) {
                  configChangeListenContext.addListen(groupKey, md5, connectionId, isNeedTransferNamespace);
                  boolean isUptoDate = ConfigCacheService.isUptodate(groupKey, md5, meta.getClientIp(), tag,
                          meta.getAppLabels());
                  if (!isUptoDate) {
                      configChangeBatchListenResponse.addChangeConfig(listenContext.getDataId(), listenContext.getGroup(),
                              listenContext.getTenant());
                  }
              } else {
                  configChangeListenContext.removeListen(groupKey, connectionId);
              }
          }
          
          return configChangeBatchListenResponse;
          
      }
      
  }
  