|
@@ -51,7 +51,7 @@ function unSubscribeStream(unSubStream) {
|
|
|
* 初始化监听事件
|
|
|
*/
|
|
|
export function initListener(vue) {
|
|
|
- rtc.on('login_success', data => {
|
|
|
+ rtc.on('login_success', (data) => {
|
|
|
console.log('登录成功', data);
|
|
|
vue.roomData = data;
|
|
|
// 初始化画板
|
|
@@ -63,7 +63,7 @@ export function initListener(vue) {
|
|
|
});
|
|
|
});
|
|
|
|
|
|
- rtc.on('login_failed', data => {
|
|
|
+ rtc.on('login_failed', (data) => {
|
|
|
console.log('登录失败', data);
|
|
|
Message({
|
|
|
message: `${i18n.t('Key443')}:${JSON.stringify(data)}`,
|
|
@@ -93,8 +93,8 @@ export function initListener(vue) {
|
|
|
const device = store.state.app.liveDevice;
|
|
|
vue.device = data;
|
|
|
|
|
|
- const isVideo = device.video.length > 0 && data.video.some(item => item.deviceId === device.video);
|
|
|
- const isAudio = device.audio.length > 0 && data.audio.some(item => item.deviceId === device.audio);
|
|
|
+ const isVideo = device.video.length > 0 && data.video.some((item) => item.deviceId === device.video);
|
|
|
+ const isAudio = device.audio.length > 0 && data.audio.some((item) => item.deviceId === device.audio);
|
|
|
|
|
|
if (!isVideo && !isAudio) {
|
|
|
vue.setDevice();
|
|
@@ -110,7 +110,7 @@ export function initListener(vue) {
|
|
|
});
|
|
|
});
|
|
|
|
|
|
- rtc.on('conference_join_failed', err => {
|
|
|
+ rtc.on('conference_join_failed', (err) => {
|
|
|
// 加入房间失败 err为错误原因
|
|
|
console.log('加入房间失败', err);
|
|
|
Message({
|
|
@@ -120,7 +120,7 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 新增订阅流事件
|
|
|
- rtc.on('allow_sub', tryStream => {
|
|
|
+ rtc.on('allow_sub', (tryStream) => {
|
|
|
if (tryStream.isMixed()) {
|
|
|
console.log('是混合流,不订阅');
|
|
|
} else {
|
|
@@ -156,13 +156,13 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 房间全量信息事件(人员进出时广播)
|
|
|
- rtc.on('room_context', roomData => {
|
|
|
+ rtc.on('room_context', (roomData) => {
|
|
|
vue.roomContext = JSON.parse(roomData);
|
|
|
vue.getLiveRoomData_DRTD();
|
|
|
console.log('房间全量信息事件(人员进出时广播)', JSON.parse(roomData));
|
|
|
});
|
|
|
|
|
|
- rtc.on('publish_stream', str => {
|
|
|
+ rtc.on('publish_stream', (str) => {
|
|
|
console.log('直播已开启', str);
|
|
|
Message({
|
|
|
type: 'success',
|
|
@@ -171,7 +171,7 @@ export function initListener(vue) {
|
|
|
vue.liveStat = true;
|
|
|
});
|
|
|
|
|
|
- rtc.on('end_stream', str => {
|
|
|
+ rtc.on('end_stream', (str) => {
|
|
|
console.log('直播已关闭', str);
|
|
|
Message({
|
|
|
type: 'success',
|
|
@@ -181,17 +181,17 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 单个用户配置监听
|
|
|
- rtc.on('switch_user_settings', settingData => {
|
|
|
+ rtc.on('switch_user_settings', (settingData) => {
|
|
|
console.log('单个用户配置监听', JSON.parse(settingData));
|
|
|
});
|
|
|
|
|
|
// 人员列表事件(人员麦序变化时广播)
|
|
|
- rtc.on('speak_context', speakData => {
|
|
|
+ rtc.on('speak_context', (speakData) => {
|
|
|
vue.speakData = JSON.parse(speakData);
|
|
|
console.log('人员列表事件(人员麦序变化时广播)', JSON.parse(speakData));
|
|
|
});
|
|
|
|
|
|
- rtc.on('switch_settings', data => {
|
|
|
+ rtc.on('switch_settings', (data) => {
|
|
|
console.log('房间设置事件', JSON.parse(data)); // 房间设置事件
|
|
|
const { changed, settings } = JSON.parse(data);
|
|
|
if (changed.includes('allow_chat')) {
|
|
@@ -199,19 +199,19 @@ export function initListener(vue) {
|
|
|
}
|
|
|
});
|
|
|
|
|
|
- rtc.on('publishStreamErr', data => {
|
|
|
+ rtc.on('publishStreamErr', (data) => {
|
|
|
console.log(`推流意外终止:${data.streamName}`);
|
|
|
// 直播开启状态下,尝试重推这条流
|
|
|
publishStream('picture');
|
|
|
});
|
|
|
|
|
|
// 网络整体状态事件
|
|
|
- rtc.on('netStatus', data => {
|
|
|
+ rtc.on('netStatus', (data) => {
|
|
|
vue.netStatus = data.netStatus;
|
|
|
});
|
|
|
|
|
|
// 单条流状态通知事件
|
|
|
- rtc.on('streamStatus', data => {
|
|
|
+ rtc.on('streamStatus', (data) => {
|
|
|
console.log(data);
|
|
|
});
|
|
|
|
|
@@ -220,12 +220,12 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 视频无法自动播放
|
|
|
- rtc.on('playError', data => {
|
|
|
+ rtc.on('playError', (data) => {
|
|
|
console.log('视频无法自动播放', data);
|
|
|
});
|
|
|
|
|
|
// 监听通知移除流事件
|
|
|
- rtc.on('stream_removed', stream => {
|
|
|
+ rtc.on('stream_removed', (stream) => {
|
|
|
console.log('监听通知移除流事件', stream);
|
|
|
const streamType = stream.streamType();
|
|
|
if (streamType === 10 || streamType === 1) {
|
|
@@ -235,7 +235,7 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 停止订阅流
|
|
|
- rtc.on('unSub', stream => {
|
|
|
+ rtc.on('unSub', (stream) => {
|
|
|
console.log('停止订阅流', stream);
|
|
|
unSubscribeStream(stream);
|
|
|
});
|
|
@@ -245,7 +245,7 @@ export function initListener(vue) {
|
|
|
*/
|
|
|
|
|
|
// 监听自己被邀请事件
|
|
|
- rtc.on('inviteUp', uid => {
|
|
|
+ rtc.on('inviteUp', (uid) => {
|
|
|
console.log('监听自己被邀请事件', uid);
|
|
|
vue.dealStudentConnection(uid, 1, vue.roomInfo.video_mode);
|
|
|
vue.callLoading = true;
|
|
@@ -260,7 +260,7 @@ export function initListener(vue) {
|
|
|
vue.invite = false;
|
|
|
});
|
|
|
|
|
|
- rtc.on('videoModeChange', data => {
|
|
|
+ rtc.on('videoModeChange', (data) => {
|
|
|
console.log('连麦音视频模式更新成功监听回调', data.settings.video_mode);
|
|
|
vue.roomInfo.video_mode = data.settings.video_mode;
|
|
|
});
|
|
@@ -305,7 +305,7 @@ export function initListener(vue) {
|
|
|
/**
|
|
|
* 监听聊天事件
|
|
|
*/
|
|
|
- rtc.on('chat_message', data => {
|
|
|
+ rtc.on('chat_message', (data) => {
|
|
|
const dat = JSON.parse(data);
|
|
|
// 敏感词过滤:如果发送的聊天消息被系统判定包含敏感词,则只有发送者能收到本条消息,房间内其他人都不会收到这条聊天消息。
|
|
|
// 如果返回消息中有 isFilterChat 字段(消息不包含敏感词返回数据中无isFilterChat字段),且isFilterChat的值为1,则说明该消息包含敏感字,除发送者外其他人不会收到这条消息。
|
|
@@ -323,7 +323,7 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 接收自定义消息
|
|
|
- rtc.on('publish_message', data => {
|
|
|
+ rtc.on('publish_message', (data) => {
|
|
|
// 连接中途下麦
|
|
|
if (data.type === 'handsDown-load' && data.uid === vue.room_user_id) {
|
|
|
vue.callLoading = false;
|
|
@@ -337,13 +337,13 @@ export function initListener(vue) {
|
|
|
});
|
|
|
|
|
|
// 文档翻页事件
|
|
|
- rtc.on('page_change', data => {
|
|
|
+ rtc.on('page_change', (data) => {
|
|
|
const pageData = JSON.parse(data);
|
|
|
console.log(pageData);
|
|
|
});
|
|
|
|
|
|
// 文档变更事件
|
|
|
- rtc.on('flipMessage', data => {
|
|
|
+ rtc.on('flipMessage', (data) => {
|
|
|
const action = data.action;
|
|
|
if (action === 'changeDoc') {
|
|
|
console.log('changeDoc', data);
|