feat(openapi): create app

apollo-openapi/src/main/java/com/ctrip/framework/apollo/openapi/api/AppOpenApiService.java

@@ -18,13 +18,22 @@
 
 import com.ctrip.framework.apollo.openapi.dto.OpenAppDTO;
 import com.ctrip.framework.apollo.openapi.dto.OpenEnvClusterDTO;
+import java.util.Collections;
 import java.util.List;
 
 /**
  * @author wxq
  */
 public interface AppOpenApiService {
 
+  default void createApp(OpenAppDTO openAppDTO) {
+    throw new UnsupportedOperationException();
+  }
+
+  default void createApp(String env, OpenAppDTO openAppDTO) {
+    throw new UnsupportedOperationException();
+  }
+
   List<OpenEnvClusterDTO> getEnvClusterInfo(String appId);
 
   List<OpenAppDTO> getAllApps();

apollo-openapi/src/main/java/com/ctrip/framework/apollo/openapi/client/ApolloOpenApiClient.java

@@ -65,6 +65,14 @@ private ApolloOpenApiClient(String portalUrl, String token, RequestConfig reques
     releaseService = new ReleaseOpenApiService(client, baseUrl, GSON);
   }
 
+  public void createApp(OpenAppDTO openAppDTO) {
+    appService.createApp(openAppDTO);
+  }
+
+  public void createApp(String env, OpenAppDTO openAppDTO) {
+    appService.createApp(env, openAppDTO);
+  }
+
   /**
    * Get the environment and cluster information
    */

apollo-openapi/src/main/java/com/ctrip/framework/apollo/openapi/client/service/AppOpenApiService.java

@@ -39,6 +39,44 @@ public AppOpenApiService(CloseableHttpClient client, String baseUrl, Gson gson)
     super(client, baseUrl, gson);
   }
 
+  @Override
+  public void createApp(OpenAppDTO openAppDTO) {
+    checkNotEmpty(openAppDTO.getAppId(), "App id");
+    checkNotEmpty(openAppDTO.getName(), "App name");
+    OpenApiPathBuilder pathBuilder = OpenApiPathBuilder.newBuilder()
+        .customResource("apps/create");
+
+    try (CloseableHttpResponse response = post(pathBuilder, openAppDTO)) {
+      gson.fromJson(EntityUtils.toString(response.getEntity()), void.class);
+    } catch (Throwable ex) {
+      throw new RuntimeException(
+          String.format("Create app: %s for appId: %s failed", openAppDTO.getName(),
+              openAppDTO.getAppId()), ex);
+    }
+  }
+
+  @Override
+  public void createApp(String env, OpenAppDTO openAppDTO) {
+    checkNotEmpty(env, "Env");
+    checkNotEmpty(openAppDTO.getAppId(), "App id");
+    checkNotEmpty(openAppDTO.getName(), "App name");
+    OpenApiPathBuilder pathBuilder = OpenApiPathBuilder.newBuilder()
+        .envPathVal(env)
+        .customResource("apps/create")
+        ;
+
+    try (CloseableHttpResponse response = post(pathBuilder, openAppDTO)) {
+      gson.fromJson(EntityUtils.toString(response.getEntity()), void.class);
+    } catch (Throwable ex) {
+      throw new RuntimeException(String.format(
+          "Create app: %s for appId: %s in env: %s failed",
+          openAppDTO.getName(),
+          openAppDTO.getAppId(),
+          env
+      ), ex);
+    }
+  }
+
   @Override
   public List<OpenEnvClusterDTO> getEnvClusterInfo(String appId) {
     checkNotEmpty(appId, "App id");

apollo-openapi/src/test/java/com/ctrip/framework/apollo/openapi/client/ApolloOpenApiClientTest.java

@@ -16,8 +16,14 @@
  */
 package com.ctrip.framework.apollo.openapi.client;
 
-import static org.junit.Assert.assertEquals;
-import org.junit.Test;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+import com.ctrip.framework.apollo.openapi.dto.OpenAppDTO;
+import java.util.Collections;
+import java.util.List;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
 
 public class ApolloOpenApiClientTest {
 
@@ -32,11 +38,67 @@ public void testCreate() {
     assertEquals(someToken, client.getToken());
   }
 
-  @Test(expected = IllegalArgumentException.class)
+  @Test
   public void testCreateWithInvalidUrl() {
     String someInvalidUrl = "someInvalidUrl";
     String someToken = "someToken";
 
-    ApolloOpenApiClient.newBuilder().withPortalUrl(someInvalidUrl).withToken(someToken).build();
+    assertThrows(
+        IllegalArgumentException.class,
+        () -> ApolloOpenApiClient.newBuilder().withPortalUrl(someInvalidUrl).withToken(someToken).build()
+    );
+  }
+
+  @Test
+  @Disabled("only for integration test")
+  public void testCreateApp() {
+    String someUrl = "http://localhost:8070";
+//    String someToken = "0627b87948c30517157e8b2a9565e473b5a97323a50128f584838ed10559d3fd";
+    String someToken = "9d0a241e9cb2300f302a875b1195340b2b6f56373cf5ca5d006a3f4e1a46b3ef";
+
+    ApolloOpenApiClient client = ApolloOpenApiClient.newBuilder()
+        .withPortalUrl(someUrl)
+        .withToken(someToken)
+        .withReadTimeout(200 * 1000)
+        .withConnectTimeout(200 * 1000)
+        .build();
+
+    final String appId = "openapi-create-app";
+    OpenAppDTO openAppDTO = new OpenAppDTO();
+    openAppDTO.setName("openapi create app 测试名字");
+    openAppDTO.setAppId(appId);
+    openAppDTO.setOwnerName("user-test-xxx1");
+    openAppDTO.setOwnerEmail("[email protected]");
+    openAppDTO.setOrgId("orgId1");
+    openAppDTO.setOrgName("orgName1");
+//    client.createApp(openAppDTO);
+
+    List<OpenAppDTO> list = client.getAppsByIds(Collections.singletonList(appId));
+  }
+
+  @Test
+  @Disabled("only for integration test")
+  public void testCreateAppWithEnv() {
+    String someUrl = "http://localhost:8070";
+    String someToken = "9d0a241e9cb2300f302a875b1195340b2b6f56373cf5ca5d006a3f4e1a46b3ef";
+
+    ApolloOpenApiClient client = ApolloOpenApiClient.newBuilder()
+        .withPortalUrl(someUrl)
+        .withToken(someToken)
+        .withReadTimeout(200 * 1000)
+        .withConnectTimeout(200 * 1000)
+        .build();
+
+    final String appId = "openapi-create-app-in-dev";
+    OpenAppDTO openAppDTO = new OpenAppDTO();
+    openAppDTO.setName("openapi create app 测试名字");
+    openAppDTO.setAppId(appId);
+    openAppDTO.setOwnerName("user-test-xxx1");
+    openAppDTO.setOwnerEmail("[email protected]");
+    openAppDTO.setOrgId("orgId1");
+    openAppDTO.setOrgName("orgName1");
+    client.createApp("dev", openAppDTO);
+
+    List<OpenAppDTO> list = client.getAppsByIds(Collections.singletonList(appId));
   }
 }