From d325a8acf8dd20a190eca1adcfdd80af2648e107 Mon Sep 17 00:00:00 2001 From: Pan-YuJie <646836760@qq.com> Date: Fri, 28 Apr 2023 17:28:55 +0800 Subject: [PATCH] test: add ThreadPoolRunStateHandler --- hippo4j-core/pom.xml | 1 + .../state/ThreadPoolRunStateHandlerTest.java | 14 +++++++------- .../filter/JWTAuthenticationFilterTest.java | 17 +++++++++++++++++ .../service/impl/UserServiceImplTest.java | 19 ++++++++++++++++++- 4 files changed, 43 insertions(+), 8 deletions(-) diff --git a/hippo4j-core/pom.xml b/hippo4j-core/pom.xml index b3fccec9..4067d24d 100644 --- a/hippo4j-core/pom.xml +++ b/hippo4j-core/pom.xml @@ -8,6 +8,7 @@ ${revision} hippo4j-core + cn.hippo4j diff --git a/hippo4j-core/src/test/java/cn/hippo4j/core/executor/state/ThreadPoolRunStateHandlerTest.java b/hippo4j-core/src/test/java/cn/hippo4j/core/executor/state/ThreadPoolRunStateHandlerTest.java index 49c43b04..ada71ae0 100644 --- a/hippo4j-core/src/test/java/cn/hippo4j/core/executor/state/ThreadPoolRunStateHandlerTest.java +++ b/hippo4j-core/src/test/java/cn/hippo4j/core/executor/state/ThreadPoolRunStateHandlerTest.java @@ -59,7 +59,7 @@ public class ThreadPoolRunStateHandlerTest { } @Test - void testSupplement(){ + void testSupplement() { long used = MemoryUtil.heapMemoryUsed(); long max = MemoryUtil.heapMemoryMax(); String memoryProportion = StringUtil.newBuilder( @@ -77,8 +77,8 @@ public class ThreadPoolRunStateHandlerTest { String threadPoolId = poolRunStateInfo.getTpId(); - try(final MockedStatic globalThreadPoolManage = mockStatic(GlobalThreadPoolManage.class)) { - globalThreadPoolManage.when(()->GlobalThreadPoolManage.getExecutorService("1")).thenReturn(new DynamicThreadPoolWrapper()); + try (final MockedStatic globalThreadPoolManage = mockStatic(GlobalThreadPoolManage.class)) { + globalThreadPoolManage.when(() -> GlobalThreadPoolManage.getExecutorService("1")).thenReturn(new DynamicThreadPoolWrapper()); DynamicThreadPoolWrapper executorService = GlobalThreadPoolManage.getExecutorService(threadPoolId); Assertions.assertNotNull(executorService); } @@ -89,7 +89,7 @@ public class ThreadPoolRunStateHandlerTest { Assertions.assertNotNull(pool); String rejectedName; - rejectedName="java.util.concurrent.ThreadPoolExecutor.AbortPolicy"; + rejectedName = "java.util.concurrent.ThreadPoolExecutor.AbortPolicy"; poolRunStateInfo.setRejectedName(rejectedName); ManyThreadPoolRunStateInfo manyThreadPoolRunStateInfo = BeanUtil.convert(poolRunStateInfo, ManyThreadPoolRunStateInfo.class); @@ -102,8 +102,8 @@ public class ThreadPoolRunStateHandlerTest { } @Test - void testGetheapMemory(){ - try(MockedStatic memoryUtil = mockStatic(MemoryUtil.class)) { + void testGetHeapMemory() { + try (MockedStatic memoryUtil = mockStatic(MemoryUtil.class)) { memoryUtil.when(MemoryUtil::heapMemoryUsed).thenReturn(57534464L); memoryUtil.when(MemoryUtil::heapMemoryMax).thenReturn(8566865920L); Assertions.assertEquals(8566865920L, MemoryUtil.heapMemoryMax()); @@ -112,7 +112,7 @@ public class ThreadPoolRunStateHandlerTest { } @Test - void testMemoryProportion(){ + void testMemoryProportion() { long used = 57534464L; long max = 8566865920L; String memoryProportion = StringUtil.newBuilder( diff --git a/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/filter/JWTAuthenticationFilterTest.java b/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/filter/JWTAuthenticationFilterTest.java index 69bb388d..8d3b412c 100644 --- a/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/filter/JWTAuthenticationFilterTest.java +++ b/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/filter/JWTAuthenticationFilterTest.java @@ -1,3 +1,20 @@ +/* + * 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 cn.hippo4j.auth.filter; import cn.hippo4j.common.toolkit.ReflectUtil; diff --git a/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/service/impl/UserServiceImplTest.java b/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/service/impl/UserServiceImplTest.java index 2af4a45c..8f92e423 100644 --- a/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/service/impl/UserServiceImplTest.java +++ b/hippo4j-server/hippo4j-auth/src/test/java/cn/hippo4j/auth/service/impl/UserServiceImplTest.java @@ -1,3 +1,20 @@ +/* + * 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 cn.hippo4j.auth.service.impl; import org.junit.Assert; @@ -7,7 +24,7 @@ class UserServiceImplTest { @Test void checkPasswordLength() { - //密码为null、空串、过短、过长都会抛出异常 + // 密码为null、空串、过短、过长都会抛出异常 UserServiceImpl userService = new UserServiceImpl(null, null, null); Assert.assertThrows(RuntimeException.class, () -> userService.checkPasswordLength(null)); Assert.assertThrows(RuntimeException.class, () -> userService.checkPasswordLength(""));