msb-core/apiroute/apiroute-service/src/test/java/org/openo/msb/wrapper/ApiRouteServiceWrapperTest.java

   1 /**
   2  * Copyright 2016 ZTE Corporation.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.openo.msb.wrapper;
  17
  18 import org.junit.After;
  19 import org.junit.Assert;
  20 import org.junit.Before;
  21 import org.junit.BeforeClass;
  22 import org.junit.Test;
  23 import org.openo.msb.api.ApiRouteInfo;
  24 import org.openo.msb.api.RouteServer;
  25 import org.openo.msb.api.exception.ExtendedInternalServerErrorException;
  26 import org.openo.msb.api.exception.ExtendedNotFoundException;
  27
  28 public class ApiRouteServiceWrapperTest {
  29     private static ApiRouteServiceWrapper apiRouteServiceWrapper;
  30
  31     @BeforeClass
  32     public static void setUpBeforeClass() throws Exception {
  33         apiRouteServiceWrapper=ApiRouteServiceWrapper.getInstance();
  34     }
  35
  36     @Before
  37     public void setUp() {
  38         ApiRouteInfo apiRouteInfo=new ApiRouteInfo();
  39         apiRouteInfo.setServiceName("testForJunit");
  40         apiRouteInfo.setVersion("v1");
  41         apiRouteInfo.setUrl("/api/test/v1");
  42         RouteServer[] servers=new RouteServer[]{new RouteServer("127.0.0.1","80")};
  43         apiRouteInfo.setServers(servers);
  44         try {
  45             apiRouteServiceWrapper.saveApiRouteInstance(apiRouteInfo, "");
  46         }
  47         catch(ExtendedInternalServerErrorException e){
  48         }
  49         catch (Exception e){
  50             Assert.fail("Exception" + e.getMessage());
  51         }
  52
  53     }
  54
  55     @After
  56     public void tearDown() {
  57         try {
  58             apiRouteServiceWrapper.deleteApiRoute("testForJunit", "v1", "*", "");
  59         }
  60         catch(ExtendedInternalServerErrorException e){
  61
  62         }catch (Exception e) {
  63             Assert.fail("Exception" + e.getMessage());
  64         }
  65     }
  66
  67     @Test
  68     public void testGetAllApiRouteInstances(){
  69         try {
  70         ApiRouteInfo[] apiRouteInfoList=apiRouteServiceWrapper.getAllApiRouteInstances();
  71         Assert.assertTrue(apiRouteInfoList.length >= 0);
  72         }
  73         catch(ExtendedInternalServerErrorException e){
  74
  75         }
  76         catch(Exception e){
  77             Assert.fail("Exception" + e.getMessage());
  78         }
  79
  80     }
  81
  82     @Test
  83     public void testGetApiRouteInstance_not_exist(){
  84         ApiRouteInfo apiRouteInfo = null;
  85         try {
  86            apiRouteInfo=apiRouteServiceWrapper.getApiRouteInstance("testForJunit", "v2");
  87            Assert.assertNotNull(apiRouteInfo);
  88         }
  89         catch(ExtendedInternalServerErrorException e){
  90
  91         }
  92         catch(ExtendedNotFoundException e){
  93             Assert.assertNull(apiRouteInfo);
  94         }
  95
  96     }
  97
  98     @Test
  99     public void testGetApiRouteInstance_exist(){
 100         try {
 101         ApiRouteInfo apiRouteInfo=apiRouteServiceWrapper.getApiRouteInstance("testForJunit", "v1");
 102         Assert.assertNotNull(apiRouteInfo);
 103         }
 104         catch(ExtendedInternalServerErrorException e){
 105
 106         }
 107         catch(Exception e){
 108             Assert.fail("Exception" + e.getMessage());
 109         }
 110
 111     }
 112
 113     @Test
 114     public void testUpdateApiRouteInstance(){
 115         try {
 116
 117             ApiRouteInfo apiRouteInfo=new ApiRouteInfo();
 118             apiRouteInfo.setServiceName("testForJunit");
 119             apiRouteInfo.setVersion("v1");
 120             apiRouteInfo.setUrl("/api/test_update/v1");
 121             RouteServer[] servers=new RouteServer[]{new RouteServer("127.0.0.1","80")};
 122             apiRouteInfo.setServers(servers);
 123
 124             ApiRouteInfo new_apiRouteInfo= apiRouteServiceWrapper.updateApiRouteInstance("testForJunit", "v1", apiRouteInfo, "");
 125             Assert.assertEquals("/api/test_update/v1", new_apiRouteInfo.getUrl());
 126         }
 127         catch(ExtendedInternalServerErrorException e){
 128
 129         }
 130         catch(Exception e){
 131             Assert.assertEquals("Get Jedis from pool failed!",e.getMessage());
 132
 133 //            Assert.fail("Exception" + e.getMessage());
 134
 135         }
 136     }
 137
 138     @Test
 139     public void testUpdateApiRouteStatus(){
 140         try {
 141             ApiRouteInfo new_apiRouteInfo= apiRouteServiceWrapper.updateApiRouteStatus("testForJunit", "v1", "0");
 142             Assert.assertEquals("0",new_apiRouteInfo.getStatus());
 143         }
 144         catch(ExtendedInternalServerErrorException e){
 145
 146         }catch(Exception e){
 147             Assert.fail("Exception" + e.getMessage());
 148
 149         }
 150     }
 151
 152     @Test
 153     public void testGetApiGatewayPort(){
 154         try {
 155             String port= apiRouteServiceWrapper.getApiGatewayPort();
 156             Assert.assertEquals("10080",port);
 157         }catch(Exception e){
 158             Assert.fail("Exception" + e.getMessage());
 159
 160         }
 161     }
 162
 163
 164 }