// 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 com.cloud.vpc; import com.cloud.exception.InvalidParameterValueException; import com.cloud.network.NetworkManager; import com.cloud.network.NetworkModel; import com.cloud.network.dao.NetworkDao; import com.cloud.network.vpc.*; import com.cloud.network.vpc.dao.NetworkACLDao; import com.cloud.network.vpc.dao.VpcGatewayDao; import com.cloud.tags.dao.ResourceTagDao; import com.cloud.user.Account; import com.cloud.user.AccountManager; import com.cloud.user.AccountVO; import com.cloud.user.UserContext; import com.cloud.utils.component.ComponentContext; import junit.framework.TestCase; import org.apache.cloudstack.api.command.user.network.CreateNetworkACLCmd; import org.apache.cloudstack.test.utils.SpringUtils; import org.apache.log4j.Logger; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.Mockito; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.FilterType; import org.springframework.core.type.classreading.MetadataReader; import org.springframework.core.type.classreading.MetadataReaderFactory; import org.springframework.core.type.filter.TypeFilter; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.test.context.support.AnnotationConfigContextLoader; import javax.inject.Inject; import java.io.IOException; import java.util.UUID; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(loader = AnnotationConfigContextLoader.class) public class NetworkACLServiceTest extends TestCase{ @Inject NetworkACLService _aclService; @Inject AccountManager _accountMgr; @Inject VpcManager _vpcMgr; @Inject NetworkACLManager _networkAclMgr; @Inject NetworkACLDao _networkACLDao; @Inject NetworkACLItemDao _networkACLItemDao; private CreateNetworkACLCmd createACLItemCmd; private NetworkACLVO acl; private NetworkACLItemVO aclItem; private static final Logger s_logger = Logger.getLogger( NetworkACLServiceTest.class); @Before public void setUp() { ComponentContext.initComponentsLifeCycle(); Account account = new AccountVO("testaccount", 1, "testdomain", (short) 0, UUID.randomUUID().toString()); UserContext.registerContext(1, account, null, true); createACLItemCmd = new CreateNetworkACLCmd(){ @Override public Long getACLId(){ return 3L; } @Override public Integer getNumber(){ return 1; } @Override public String getProtocol(){ return "TCP"; } }; acl = new NetworkACLVO(){ @Override public Long getVpcId(){ return 1L; } @Override public long getId(){ return 1L; } }; aclItem = new NetworkACLItemVO(){ @Override public long getAclId(){ return 4L; } }; } @Test public void testCreateACL() throws Exception { Mockito.when(_vpcMgr.getVpc(Mockito.anyLong())).thenReturn(new VpcVO()); Mockito.when(_networkAclMgr.createNetworkACL("acl_new", "acl desc", 1L)).thenReturn(acl); assertNotNull(_aclService.createNetworkACL("acl_new", "acl desc", 1L)); } @Test(expected = InvalidParameterValueException.class) public void testDeleteDefaultACL() throws Exception { Mockito.when(_networkACLDao.findById(Mockito.anyLong())).thenReturn(acl); Mockito.when(_networkAclMgr.deleteNetworkACL(acl)).thenReturn(true); _aclService.deleteNetworkACL(1L); } @Test public void testCreateACLItem() throws Exception { Mockito.when(_vpcMgr.getVpc(Mockito.anyLong())).thenReturn(new VpcVO()); Mockito.when(_networkAclMgr.getNetworkACL(Mockito.anyLong())).thenReturn(acl); Mockito.when(_networkAclMgr.createNetworkACLItem(Mockito.anyInt(), Mockito.anyInt(), Mockito.anyString(), Mockito.anyList(), Mockito.anyInt(), Mockito.anyInt(), Mockito.any(NetworkACLItem.TrafficType.class), Mockito.anyLong(), Mockito.anyString(), Mockito.anyInt())).thenReturn(new NetworkACLItemVO()); Mockito.when(_networkACLItemDao.findByAclAndNumber(Mockito.anyLong(), Mockito.anyInt())).thenReturn(null); assertNotNull(_aclService.createNetworkACLItem(createACLItemCmd)); } @Test(expected = InvalidParameterValueException.class) public void testCreateACLItemDuplicateNumber() throws Exception { Mockito.when(_vpcMgr.getVpc(Mockito.anyLong())).thenReturn(new VpcVO()); Mockito.when(_networkAclMgr.getNetworkACL(Mockito.anyLong())).thenReturn(acl); Mockito.when(_networkACLItemDao.findByAclAndNumber(Mockito.anyLong(), Mockito.anyInt())).thenReturn(new NetworkACLItemVO()); _aclService.createNetworkACLItem(createACLItemCmd); } @Test public void testDeleteACLItem() throws Exception { Mockito.when(_networkACLItemDao.findById(Mockito.anyLong())).thenReturn(aclItem); Mockito.when(_networkAclMgr.revokeNetworkACLItem(Mockito.anyLong())).thenReturn(true); assertTrue(_aclService.revokeNetworkACLItem(1L)); } @Configuration @ComponentScan(basePackageClasses={NetworkACLServiceImpl.class}, includeFilters={@ComponentScan.Filter(value=NetworkACLTestConfiguration.Library.class, type= FilterType.CUSTOM)}, useDefaultFilters=false) public static class NetworkACLTestConfiguration extends SpringUtils.CloudStackTestConfiguration{ @Bean public AccountManager accountManager() { return Mockito.mock(AccountManager.class); } @Bean public NetworkManager networkManager() { return Mockito.mock(NetworkManager.class); } @Bean public NetworkModel networkModel() { return Mockito.mock(NetworkModel.class); } @Bean public VpcManager vpcManager() { return Mockito.mock(VpcManager.class); } @Bean public ResourceTagDao resourceTagDao() { return Mockito.mock(ResourceTagDao.class); } @Bean public NetworkACLDao networkACLDao() { return Mockito.mock(NetworkACLDao.class); } @Bean public NetworkACLItemDao networkACLItemDao() { return Mockito.mock(NetworkACLItemDao.class); } @Bean public NetworkDao networkDao() { return Mockito.mock(NetworkDao.class); } @Bean public NetworkACLManager networkACLManager() { return Mockito.mock(NetworkACLManager.class); } @Bean public VpcGatewayDao vpcGatewayDao () { return Mockito.mock(VpcGatewayDao.class); } public static class Library implements TypeFilter { @Override public boolean match(MetadataReader mdr, MetadataReaderFactory arg1) throws IOException { mdr.getClassMetadata().getClassName(); ComponentScan cs = NetworkACLTestConfiguration.class.getAnnotation(ComponentScan.class); return SpringUtils.includedInBasePackageClasses(mdr.getClassMetadata().getClassName(), cs); } } } }