code: /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You 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 org.apache.skywalking.oap.server.cluster.plugin.nacos;
  
  import com.alibaba.nacos.api.exception.NacosException;
  import com.alibaba.nacos.api.naming.NamingService;
  import com.alibaba.nacos.api.naming.pojo.Instance;
  import org.apache.skywalking.oap.server.core.cluster.RemoteInstance;
  import org.apache.skywalking.oap.server.core.remote.client.Address;
  import org.apache.skywalking.oap.server.library.module.ModuleDefineHolder;
  import org.apache.skywalking.oap.server.telemetry.api.HealthCheckMetrics;
  import org.junit.jupiter.api.BeforeEach;
  import org.junit.jupiter.api.Test;
  import org.mockito.ArgumentCaptor;
  import org.powermock.reflect.Whitebox;
  
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.List;
  
  import static org.junit.jupiter.api.Assertions.assertEquals;
  import static org.mockito.ArgumentMatchers.anyBoolean;
  import static org.mockito.ArgumentMatchers.anyString;
  import static org.mockito.Mockito.doNothing;
  import static org.mockito.Mockito.mock;
  import static org.mockito.Mockito.verify;
  import static org.mockito.Mockito.when;
  
  public class NacosCoordinatorTest {
      private NamingService namingService = mock(NamingService.class);
      private ClusterModuleNacosConfig nacosConfig = new ClusterModuleNacosConfig();
      private NacosCoordinator coordinator;
      private HealthCheckMetrics healthChecker = mock(HealthCheckMetrics.class);
      private Address remoteAddress = new Address("10.0.0.1", 1000, false);
      private Address selfRemoteAddress = new Address("10.0.0.2", 1001, true);
  
      private Address internalAddress = new Address("10.0.0.3", 1002, false);
  
      private static final String SERVICE_NAME = "test-service";
  
      @BeforeEach
      public void setUp() throws NacosException {
          doNothing().when(healthChecker).health();
          nacosConfig.setServiceName(SERVICE_NAME);
          ModuleDefineHolder manager = mock(ModuleDefineHolder.class);
          coordinator = new NacosCoordinator(manager, namingService, nacosConfig);
          Whitebox.setInternalState(coordinator, "healthChecker", healthChecker);
      }
  
      @Test
      @SuppressWarnings("unchecked")
      public void queryRemoteNodesWithNonOrEmpty() throws NacosException {
          when(namingService.selectInstances(anyString(), anyBoolean())).thenReturn(null, Collections.emptyList());
          assertEquals(0, coordinator.queryRemoteNodes().size());
      }
  
      @Test
      public void queryRemoteNodes() throws NacosException {
          registerSelfRemote();
          List<Instance> instances = mockInstance();
          when(namingService.selectInstances(anyString(), anyBoolean())).thenReturn(instances);
          List<RemoteInstance> remoteInstances = coordinator.queryRemoteNodes();
          assertEquals(2, remoteInstances.size());
  
          RemoteInstance selfInstance = remoteInstances.get(0);
          validate(selfRemoteAddress, selfInstance);
  
          RemoteInstance notSelfInstance = remoteInstances.get(1);
          validate(remoteAddress, notSelfInstance);
      }
  
      @Test
      public void queryRemoteNodesWithNullSelf() throws NacosException {
          List<Instance> instances = mockInstance();
          when(namingService.selectInstances(anyString(), anyBoolean())).thenReturn(instances);
          List<RemoteInstance> remoteInstances = coordinator.queryRemoteNodes();
          assertEquals(remoteInstances.size(), instances.size());
      }
  
      @Test
      public void registerRemote() throws NacosException {
          registerRemote(remoteAddress);
      }
  
      @Test
      public void registerSelfRemote() throws NacosException {
          registerRemote(selfRemoteAddress);
      }
  
      @Test
      public void registerRemoteUsingInternal() throws NacosException {
          nacosConfig.setInternalComHost(internalAddress.getHost());
          nacosConfig.setInternalComPort(internalAddress.getPort());
          registerRemote(internalAddress);
      }
  
      private void validate(Address originAddress, RemoteInstance instance) {
          Address instanceAddress = instance.getAddress();
          assertEquals(originAddress.getHost(), instanceAddress.getHost());
          assertEquals(originAddress.getPort(), instanceAddress.getPort());
      }
  
      private void registerRemote(Address address) throws NacosException {
          coordinator.registerRemote(new RemoteInstance(address));
  
          ArgumentCaptor<String> serviceNameArgumentCaptor = ArgumentCaptor.forClass(String.class);
          ArgumentCaptor<String> hostArgumentCaptor = ArgumentCaptor.forClass(String.class);
          ArgumentCaptor<Integer> portArgumentCaptor = ArgumentCaptor.forClass(Integer.class);
          verify(namingService).registerInstance(serviceNameArgumentCaptor.capture(), hostArgumentCaptor.capture(), portArgumentCaptor
              .capture());
  
          assertEquals(SERVICE_NAME, serviceNameArgumentCaptor.getValue());
          assertEquals(address.getHost(), hostArgumentCaptor.getValue());
          assertEquals(Long.valueOf(address.getPort()), Long.valueOf(portArgumentCaptor.getValue()));
      }
  
      private List<Instance> mockInstance() {
          Instance remoteInstance = new Instance();
          Instance selfInstance = new Instance();
          selfInstance.setIp(selfRemoteAddress.getHost());
          selfInstance.setPort(selfRemoteAddress.getPort());
  
          remoteInstance.setIp(remoteAddress.getHost());
          remoteInstance.setPort(remoteAddress.getPort());
  
          List<Instance> instances = new ArrayList<>();
          instances.add(selfInstance);
          instances.add(remoteInstance);
          return instances;
      }
  }
  