This is an automated email from the ASF dual-hosted git repository.
gongchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
The following commit(s) were added to refs/heads/master by this push:
new 659346ddd [Improve] add CollectServer unit test (#2379)
659346ddd is described below
commit 659346ddd7b1e3f1b981cbd672b78be1fc374893
Author: YuLuo <[email protected]>
AuthorDate: Thu Jul 25 21:47:15 2024 +0800
[Improve] add CollectServer unit test (#2379)
Signed-off-by: yuluo-yx <[email protected]>
Signed-off-by: YuLuo <[email protected]>
Co-authored-by: tomsun28 <[email protected]>
---
.../dispatch/entrance/CollectServerTest.java | 147 +++++++++++++++++++++
1 file changed, 147 insertions(+)
diff --git
a/collector/src/test/java/org/apache/hertzbeat/collector/dispatch/entrance/CollectServerTest.java
b/collector/src/test/java/org/apache/hertzbeat/collector/dispatch/entrance/CollectServerTest.java
new file mode 100644
index 000000000..6e1367923
--- /dev/null
+++
b/collector/src/test/java/org/apache/hertzbeat/collector/dispatch/entrance/CollectServerTest.java
@@ -0,0 +1,147 @@
+/*
+ * 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.hertzbeat.collector.dispatch.entrance;
+
+import java.util.concurrent.ScheduledExecutorService;
+
+import io.netty.channel.Channel;
+import org.apache.hertzbeat.collector.dispatch.CollectorInfoProperties;
+import org.apache.hertzbeat.collector.dispatch.DispatchProperties;
+import
org.apache.hertzbeat.collector.dispatch.entrance.internal.CollectJobService;
+import org.apache.hertzbeat.collector.dispatch.timer.TimerDispatch;
+import org.apache.hertzbeat.common.entity.message.ClusterMsg;
+import org.apache.hertzbeat.common.support.CommonThreadPool;
+import org.apache.hertzbeat.remoting.RemotingClient;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.test.util.ReflectionTestUtils;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+/**
+ * test case for {@link CollectServer}
+ */
+
+@ExtendWith(MockitoExtension.class)
+class CollectServerTest {
+
+ @Mock
+ private CollectJobService collectJobService;
+
+ @Mock
+ private TimerDispatch timerDispatch;
+
+ @Mock
+ private DispatchProperties properties;
+
+ @Mock
+ private DispatchProperties.EntranceProperties entranceProperties;
+
+ @Mock
+ private DispatchProperties.EntranceProperties.NettyProperties
nettyProperties;
+
+ @Mock
+ private CommonThreadPool threadPool;
+
+ @Mock
+ private CollectorInfoProperties infoProperties;
+
+ private CollectServer collectServer;
+
+ private CollectServer.CollectNettyEventListener
collectNettyEventListener;
+
+ @BeforeEach
+ void setUp() {
+
+ when(nettyProperties.getManagerHost()).thenReturn("127.0.0.1");
+ when(nettyProperties.getManagerPort()).thenReturn(8080);
+ when(entranceProperties.getNetty()).thenReturn(nettyProperties);
+ when(properties.getEntrance()).thenReturn(entranceProperties);
+
+ collectServer = new CollectServer(collectJobService,
timerDispatch, properties, threadPool, infoProperties);
+ collectNettyEventListener = collectServer.new
CollectNettyEventListener();
+ }
+
+ @Test
+ void testRun() throws Exception {
+
+ RemotingClient remotingClient = mock(RemotingClient.class);
+ ReflectionTestUtils.setField(collectServer, "remotingClient",
remotingClient);
+
+ collectServer.run();
+
+ verify(remotingClient, times(1)).start();
+ }
+
+ @Test
+ void testShutdown() {
+
+ RemotingClient remotingClient = mock(RemotingClient.class);
+ ReflectionTestUtils.setField(collectServer, "remotingClient",
remotingClient);
+ ReflectionTestUtils.setField(collectServer,
"scheduledExecutor", mock(ScheduledExecutorService.class));
+
+ collectServer.shutdown();
+
+ ScheduledExecutorService scheduledExecutor =
(ScheduledExecutorService) ReflectionTestUtils.getField(collectServer,
"scheduledExecutor");
+ verify((scheduledExecutor), times(1)).shutdownNow();
+ verify(remotingClient, times(1)).shutdown();
+ }
+
+ @Test
+ void testSendMsg() {
+
+ RemotingClient remotingClient = mock(RemotingClient.class);
+ ReflectionTestUtils.setField(collectServer, "remotingClient",
remotingClient);
+ ClusterMsg.Message message = mock(ClusterMsg.Message.class);
+
+ collectServer.sendMsg(message);
+
+ verify(remotingClient, times(1)).sendMsg(message);
+ }
+
+ @Test
+ void testOnChannelActive() {
+
+ RemotingClient remotingClient = mock(RemotingClient.class);
+ ReflectionTestUtils.setField(collectServer, "remotingClient",
remotingClient);
+
+ Channel channel = mock(Channel.class);
+
when(collectJobService.getCollectorIdentity()).thenReturn("collector1");
+ when(collectJobService.getCollectorMode()).thenReturn("mode1");
+ when(infoProperties.getIp()).thenReturn("127.0.0.1");
+ when(infoProperties.getVersion()).thenReturn("1.0");
+
+ collectNettyEventListener.onChannelActive(channel);
+
+ verify(timerDispatch, times(1)).goOnline();
+ verify(remotingClient,
times(1)).sendMsg(any(ClusterMsg.Message.class));
+
+ ScheduledExecutorService scheduledExecutor =
+ (ScheduledExecutorService)
ReflectionTestUtils.getField(collectServer, "scheduledExecutor");
+ assertNotNull(scheduledExecutor);
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
