add room create and delete test case and rebuild forward

Author: vanga-top

src/main/java/com/qiniu/rtc/QRTCClient.java

@@ -107,6 +107,40 @@ public Response call() throws QiniuException {
 
     /////////////////////////room service//////////////////////////////////////
 
+    /**
+     * 创建房间
+     *
+     * @param roomParam
+     * @return
+     * @throws QiniuException
+     */
+    public QRTCResult<RoomResult> createRoom(final RoomParam roomParam) throws QiniuException {
+        ServiceCallFunc func = new ServiceCallFunc() {
+            @Override
+            public Response call() throws QiniuException {
+                return roomService.createRoom(appId, roomParam);
+            }
+        };
+        return buildResult(func, RoomResult.class);
+    }
+
+    /**
+     * 删除房间
+     *
+     * @param roomName
+     * @return
+     * @throws QiniuException
+     */
+    public QRTCResult<RoomResult> deleteRoom(final String roomName) throws QiniuException {
+        ServiceCallFunc func = new ServiceCallFunc() {
+            @Override
+            public Response call() throws QiniuException {
+                return roomService.deleteRoom(appId, roomName);
+            }
+        };
+        return buildResult(func, RoomResult.class);
+    }
+
     /**
      * 获取房间内的所有用户
      *
@@ -271,7 +305,7 @@ public QRTCResult<MergeResult> updateMergeTrack(final MergeTrackParam mergeTrack
         ServiceCallFunc updateMergeTrackFunc = new ServiceCallFunc() {
             @Override
             public Response call() throws QiniuException {
-                UrlParam mergeTrackUrlParam  = UrlParam.builder().appId(appId).roomName(roomName).jobId(jobId).build();
+                UrlParam mergeTrackUrlParam = UrlParam.builder().appId(appId).roomName(roomName).jobId(jobId).build();
                 return mergeService.updateMergeTrack(mergeTrackParam, mergeTrackUrlParam);
             }
         };
@@ -292,7 +326,7 @@ public QRTCResult<MergeResult> updateMergeWatermarks(final WatermarksParam water
         ServiceCallFunc updateMergeWatermarksFunc = new ServiceCallFunc() {
             @Override
             public Response call() throws QiniuException {
-                UrlParam mergeWatermarksUrlParam  = UrlParam.builder().appId(appId).roomName(roomName).jobId(jobId).build();
+                UrlParam mergeWatermarksUrlParam = UrlParam.builder().appId(appId).roomName(roomName).jobId(jobId).build();
                 return mergeService.updateMergeWatermarks(watermarksParam, mergeWatermarksUrlParam);
             }
         };

src/main/java/com/qiniu/rtc/model/RoomParam.java

@@ -0,0 +1,13 @@
+// codebeat:disable[TOO_MANY_IVARS]
+package com.qiniu.rtc.model;
+
+import lombok.Data;
+
+@Data
+public class RoomParam {
+    private String roomName;
+    private int maxUsers;
+    private int autoCloseTtlS;
+    private int noEntreTtlS;
+    private boolean openRoom;
+}

src/main/java/com/qiniu/rtc/model/RoomResult.java

@@ -14,6 +14,7 @@ public class RoomResult {
     private List<String> rooms;
     private boolean end;
     private int offset;
+    private String roomId;
 
     @Data
     public static class UserInfo {

src/main/java/com/qiniu/rtc/service/RoomService.java

@@ -3,6 +3,7 @@
 
 import com.qiniu.common.QiniuException;
 import com.qiniu.http.Response;
+import com.qiniu.rtc.model.RoomParam;
 import com.qiniu.rtc.model.UrlParam;
 import com.qiniu.rtc.model.RoomAccess;
 import com.qiniu.util.Auth;
@@ -22,6 +23,32 @@ public RoomService(Auth auth) {
     }
 
 
+    /**
+     * 创建房间
+     *
+     * @param appId
+     * @param roomParam
+     * @return
+     * @throws QiniuException
+     */
+    public Response createRoom(String appId, RoomParam roomParam) throws QiniuException {
+        String urlPattern = "/v3/apps/%s/createroom";
+        return postCall(roomParam, urlPattern, appId);
+    }
+
+    /**
+     * 删除房间
+     *
+     * @param appId
+     * @param roomName
+     * @return
+     * @throws QiniuException
+     */
+    public Response deleteRoom(String appId, String roomName) throws QiniuException {
+        String urlPattern = "/v3/apps/%s/rooms/%s";
+        return deleteCall(null, urlPattern, appId, roomName);
+    }
+
     /**
      * @param appId    房间所属帐号的 app
      * @param roomName 操作所查询的连麦房间
@@ -54,7 +81,7 @@ public Response kickUser(String appId, String roomName, String userId) throws Qi
      * 获取当前所有活跃的房间
      *
      * @param roomNamePrefix
-     * @param urlParam 分页参数
+     * @param urlParam       分页参数
      * @return
      * @throws QiniuException
      */

src/test/java/test/com/qiniu/rtc/RtcTest.java

@@ -25,9 +25,11 @@ public static void initQRTC() throws QiniuException {
         appParam.setMaxUsers(20);
         appParam.setNoAutoKickUser(false);
         QRTCResult<AppResult> result = QRTC.createApp(appParam, TestConfig.testAccessKey, TestConfig.testSecretKey);
+        //初始化接口，一般有appId的话建议直接走这个接口初始化了
         client = QRTC.init(TestConfig.testAccessKey, TestConfig.testSecretKey, result.getResult().getAppId());
     }
 
+
     @Disabled
     @Test
     public void testApp() throws QiniuException {
@@ -46,6 +48,15 @@ public void testApp() throws QiniuException {
     @Disabled
     @Test
     public void testRoom() throws Exception {
+        //创建房间
+        RoomParam roomParam = new RoomParam();
+        roomParam.setRoomName("test_room_create");
+        roomParam.setOpenRoom(true);
+        roomParam.setAutoCloseTtlS(30);
+        roomParam.setNoEntreTtlS(3600);
+        roomParam.setMaxUsers(20);
+        QRTCResult<RoomResult> roomResult = client.createRoom(roomParam);
+        assert roomResult.getCode() == 200;
         //获取房间
         QRTCResult<RoomResult> result = client.listUser("1207");
         assert result.getCode() == 200;
@@ -58,6 +69,9 @@ public void testRoom() throws Exception {
         //获取token
         String token = client.getRoomToken("1207", "testUser", System.currentTimeMillis() / 1000, "user");
         System.out.println(token);
+        //删除房间
+        roomResult = client.deleteRoom(roomParam.getRoomName());
+        assert roomResult.getCode() == 200;
     }
 
     @Disabled