直播

all_backend_api/janus_live_request.py

@@ -10,6 +10,7 @@ class live_request(BaseRequest):
         self.data = self.api_load(path_setting.ADDLIVESERVICE_CONFIG)
         self.data = self.api_load(path_setting.DELETELIVESERVICE_CONFIG)
         self.data = self.api_load(path_setting.DELETEGIFT_CONFIG)
+        self.data = self.api_load(path_setting.M_GET_CHANNEL_STATUS_CONFIG)
 
     #主播-推荐袋美购列表展示
     def live_services(self, channel_id, stream_id, offset, size):
@@ -73,8 +74,15 @@ class live_request(BaseRequest):
         self.params["version"] = version
         return self.api_send(self.data["delete_live_gift"])
 
+    #获取直播间状态
+    def m_get_channel_status(self, channel_id, version,  device_id='97B6764B-2135-4761-9911-701C38CBC272'):
+        self.params["channel_id"] = channel_id
+        self.params["version"] = version
+        return self.api_send(self.data["m_get_channel_status"])
+
 if __name__ == '__main__':
-    print(live_request().live_services("745", "4177", "0", "10"))
-    print(live_request().search_service("beijing", "745", "", "0", "20", "7.45.0"))
-    print(live_request().add_live_service("745", "560641", "7.45.0"))
-    print(live_request().delete_live_service("745", "7242", "7.45.0"))
+    # print(live_request().live_services("745", "4177", "0", "10"))
+    # print(live_request().search_service("beijing", "745", "", "0", "20", "7.45.0"))
+    # print(live_request().add_live_service("745", "560641", "7.45.0"))
+    # print(live_request().delete_live_service("745", "7242", "7.45.0"))
\ No newline at end of file
+    print(live_request().m_get_channel_status("745", "7.46.0"))
\ No newline at end of file

all_backend_api/janus_live_request.yaml

@@ -78,4 +78,15 @@ delete_live_gift:
   json: {}
   isLogin: 1
 
+#获取直播间状态
+m_get_channel_status:
+  method: GET
+  url: /api/janus/live/m/get_channel_status
+  params:
+    channel_id: ${channel_id}
+    version: ${version}
+  data: {}
+  json: {}
+  isLogin: 1
+
 

all_backend_api/live_request.py

@@ -21,6 +21,19 @@ class living_request(BaseRequest):
         self.params["device_type"] = device_type
         return self.api_send(self.data["pushlive_info"])
 
+    #观众进入直播间
+    def enter(self,channel_id, from_source, version, device_id="97B6764B-2135-4761-9911-701C38CBC272"):
+        self.params["channel_id"] = channel_id
+        self.params["from_source"] = from_source
+        self.params["version"] = version
+        return self.api_send(self.data["enter"])
+
+    #观众离开直播间
+    def leave(self,channel_id, version, device_id="97B6764B-2135-4761-9911-701C38CBC272"):
+        self.params["channel_id"] = channel_id
+        self.params["version"] = version
+        return self.api_send(self.data["leave"])
+
 
 
 if __name__ == '__main__':

all_backend_api/live_request.yaml

@@ -24,30 +24,25 @@ pushlive_info:
   json: {}
   isLogin: 1
 
-#主播-推荐袋美购列表展示
-live_services:
-  method: GET
-  url: /api/janus/live/live_services
+#观众进入直播间
+enter:
+  method: get
+  url: /api/live/enter
   params:
     channel_id: ${channel_id}
-    stream_id: ${stream_id}
-    offset: ${offset}
-    size: ${size}
+    from_source: ${from_source}
+    version: ${version}
   data: {}
   json: {}
   isLogin: 1
 
-#主播-推荐袋商品捜索功能
-search_services:
-  method: GET
-  url: /api/janus/live/search_services
+#观众离开直播间
+leave:
+  method: get
+  url: /api/live/leave
   params:
-    current_city_id: ${current_city_id}
     channel_id: ${channel_id}
-    query: ${query}
-    offset: ${offset}
-    size: ${size}
-    trace_id: ${trace_id}
+    version: ${version}
   data: {}
   json: {}
   isLogin: 1

path_setting.py

@@ -573,6 +573,18 @@ DELETELIVESERVICE = os.path.join(BASE_DIR, "backend_auto/test_backend_data/janus
 DELETEGIFT_CONFIG = os.path.join(BASE_DIR, "backend_auto/all_backend_api", "janus_live_request.yaml")
 DELETEGIFT = os.path.join(BASE_DIR, "backend_auto/test_backend_data/janus_live_data", "delete_live_gift.yaml")
 
+#获取直播间状态
+M_GET_CHANNEL_STATUS_CONFIG = os.path.join(BASE_DIR, "backend_auto/all_backend_api", "janus_live_request.yaml")
+M_GET_CHANNEL_STATUS = os.path.join(BASE_DIR, "backend_auto/test_backend_data/janus_live_data", "m_get_channel_status.yaml")
+
+#观众进入直播间
+ENTER_CONFIG = os.path.join(BASE_DIR, "backend_auto/all_backend_api", "live_request.yaml")
+ENTER = os.path.join(BASE_DIR, "backend_auto/test_backend_data/live_data", "enter.yaml")
+
+#观众离开直播间
+LEAVE_CONFIG = os.path.join(BASE_DIR, "backend_auto/all_backend_api", "live_request.yaml")
+LEAVE = os.path.join(BASE_DIR, "backend_auto/test_backend_data/live_data", "leave.yaml")
+
 #免费招募活动详情
 FREE_RECRUIT_DETAIL_CONFIG = os.path.join(BASE_DIR, "backend_auto/all_backend_api", "feed_request.yaml")
 FREE_RECRUIT_DETAIL = os.path.join(BASE_DIR, "backend_auto/test_backend_data/feed_data", "free_recruit_detail.yaml")

test_backend_case/janus_live_case/test_m_get_channel_status.py

+import pytest
+
+import path_setting
+from all_backend_api.janus_live_request import live_request
+from ids_list import get_ids
+from in_common.base_request import BaseRequest
+
+
+class TestMGetChannelStatus:
+    data = BaseRequest().api_load(path_setting.M_GET_CHANNEL_STATUS)
+    m_get_channel_status_case, m_get_channel_status_data = get_ids(data, "m_get_channel_status")
+
+    @pytest.mark.parametrize("param", m_get_channel_status_data, ids=m_get_channel_status_case)
+    def test_m_get_channel_status_data(self, param):
+        print("查看直播状态啦~~~")
+        r = live_request().m_get_channel_status(param["channel_id"], param["version"])
+        if r["error"] == 0:
+            assert r["data"]["status"] == param["assert"]
\ No newline at end of file

test_backend_case/live_case/test_enter.py

+import pytest
+from ids_list import get_ids
+import path_setting
+from in_common.base_request import BaseRequest
+from all_backend_api.live_request import living_request
+
+
+class TestEnter:
+    data = BaseRequest().api_load(path_setting.ENTER)
+    enter_case, enter_data = get_ids(data,"enter")
+
+    @pytest.mark.parametrize("param", enter_data, ids=enter_case)
+    def test_enter(self, param):
+        r = living_request().enter(param["channel_id"], param["from_source"], param["version"])
+        print("观众进入直播间啦~~~")
+        if r["error"] == 0:
+            assert r["error"] == param["assert"]
\ No newline at end of file

test_backend_case/live_case/test_leave.py

+import pytest
+from ids_list import get_ids
+import path_setting
+from in_common.base_request import BaseRequest
+from all_backend_api.live_request import living_request
+
+
+class TestLeave:
+    data = BaseRequest().api_load(path_setting.LEAVE)
+    leave_case, leave_data = get_ids(data,"leave")
+
+    @pytest.mark.parametrize("param", leave_data, ids=leave_case)
+    def test_leave(self, param):
+        r = living_request().leave(param["channel_id"], param["version"])
+        print("观众离开直播间了，呜呜呜")
+        if r["error"] == 0:
+            assert r["error"] == param["assert"]
\ No newline at end of file

test_backend_data/janus_live_data/m_get_channel_status.yaml

+m_get_channel_status:
+#查看直播状态
+  -
+    case: "查看直播状态"
+    channel_id: "745"
+    version: "7.45.0"
+    assert : True
\ No newline at end of file

test_backend_data/live_data/enter.yaml

+enter:
+#观众从app进入直播间
+  -
+    case: "观众从app进入直播间"
+    channel_id: "745"
+    from_source: "app"
+    version: "7.45.0"
+    assert: 0
\ No newline at end of file

test_backend_data/live_data/leave.yaml

+leave:
+#观众离开直播间了，呜呜呜
+  -
+    case: "观众离开直播间了，呜呜呜"
+    channel_id: "745"
+    version: "7.45.0"
+    assert: 0
\ No newline at end of file