//=================================================================
|
// API说明
|
//
|
// Function:
|
//
|
// - session_event_state_cb: 设置全局会话状态回调
|
// - session_event_media_cb: 设置全局话权控制回调
|
//
|
// - session_channel_enter: 进入频道会话
|
// - session_channel_exit: 退出频道会话
|
//
|
// - session_id_generate(uids): 给定用户ID的数组，通过cbSessionIdGenerated事件返回临时会话的唯一SessionId
|
//
|
// - session_call_make(sessionId): 发起一个临时会话
|
// - session_call_bye(sessionId): 挂断一个临时会话
|
// - session_call_incoming_accept(sessionId): 当有临时会呼叫来电时，选择接听此来电
|
// - session_call_incoming_reject(sessionId): 当有临时会呼叫来电时，选择拒接此来电
|
//
|
// - session_talk_request: 申请话语权
|
// - session_talk_release: 释放话语权
|
//
|
// Event:
|
//
|
// - cbSessionIdGenerated: 生成唯一SessionId
|
//
|
// - cbSessionConnecting: 会话建立中
|
// - cbSessionEstablished: 会话已建立
|
// - cbSessionReleased: 会话已结束
|
// - cbSessionIncomingAlert: 临时会话来电
|
//
|
// - cbSessionMediaTalkPrepare: 话语权申请中
|
// - cbSessionMediaTalkBegin: 我开始讲话
|
// - cbSessionMediaTalkEnd: 我结束讲话
|
// - cbSessionMediaListenBegin: 别人开始讲话
|
// - cbSessionMediaListenEnd: 别人结束讲话
|
//
|
// - cbSessionPresence: 会话Presence
|
//
|
//=================================================================
|
|
|
|
//============================================
|
//
|
// 会话列表管理
|
//
|
//============================================
|
|
var gSessionArray = new Array();
|
var gSessionTalkIndex = -1;
|
|
var gSessionListenerRefresh = new Array();
|
|
|
function sessionGetPresenceOnLine(sessionId) {
|
var precense = null;
|
if (gSessionArray != null)
|
{
|
for (var i = 0; i < gSessionArray.length; i++) {
|
if (gSessionArray[i].sessionId == sessionId) {
|
precense = gSessionArray[i].precense;
|
if (precense == undefined) {
|
precense = null;
|
}
|
break;
|
}
|
}
|
}
|
return precense;
|
}
|
|
function sessionArrayPut(session, sessionId) {
|
var oldsession = sessionGetById(sessionId);
|
if (oldsession == null) {
|
gSessionArray.unshift(session);
|
}
|
}
|
|
function sessionArrayRemove(sessionId) {
|
if (gSessionArray != null) {
|
for (var i = 0; i < gSessionArray.length; i++) {
|
if (gSessionArray[i].sessionId == sessionId) {
|
gSessionArray.splice(i, 1);
|
break;
|
}
|
}
|
}
|
}
|
|
function sessionGetByIndex(sessionIndex) {
|
var session = null;
|
for (var i = 0; i < gSessionArray.length; i++) {
|
if (gSessionArray[i].sessionIndex == sessionIndex) {
|
session = gSessionArray[i];
|
break;
|
}
|
}
|
return session;
|
}
|
|
function sessionGetById(sessionId) {
|
var session = null;
|
for (var i = 0; i < gSessionArray.length; i++) {
|
if (gSessionArray[i].sessionId == sessionId) {
|
session = gSessionArray[i];
|
break;
|
}
|
}
|
|
return session;
|
}
|
|
//============================================
|
//
|
// 设置全局会话状态事件
|
//
|
//============================================
|
|
|
var cbSessionConnecting = null;
|
var cbSessionEstablished = null;
|
var cbSessionReleased = null;
|
|
var cbSessionIncomingAlert = null;
|
|
var cbSessionPresence = null;
|
|
var cbSessionMediaTalkPrepare = null;
|
var cbSessionMediaTalkBegin = null;
|
var cbSessionMediaTalkEnd = null;
|
var cbSessionMediaListenBegin = null;
|
var cbSessionMediaListenEnd = null;
|
|
var cbSessionIdGenerated = null;
|
|
//-------------------------------
|
// 设置全局会话状态回调
|
//-------------------------------
|
// cbSessionConnecting(sessionId)
|
// cbSessionEstablished(sessionId)
|
// cbSessionReleased(sessionId, result) result参考：SESSION_RELEASE_REASON_*
|
// cbSessionIncomingAlert(sessionId, callerName)
|
|
function session_event_state_cb(cbSesConnecting, cbSesEstablished, cbSesReleased, cbSesIncomingAlert, cbSesPresence) {
|
cbSessionConnecting = cbSesConnecting;
|
cbSessionEstablished = cbSesEstablished;
|
cbSessionReleased = cbSesReleased;
|
cbSessionIncomingAlert = cbSesIncomingAlert;
|
cbSessionPresence = cbSesPresence;
|
}
|
|
function session_event_refresh_register(cbSesRefresh) {
|
gSessionListenerRefresh.push(cbSesRefresh);
|
}
|
|
function session_event_refresh_unregister(cbSesRefresh) {
|
gSessionListenerRefresh.remove(cbSesRefresh);
|
}
|
|
//-------------------------------
|
// 设置全局话权控制回调
|
//-------------------------------
|
// cbSessionMediaTalkPrepare(sessionId)
|
// cbSessionMediaTalkBegin(sessionId)
|
// cbSessionMediaTalkEnd(sessionId, reason) reason参考：MEDIA_TALK_FINISH_REASON_*
|
// cbSessionMediaListenBegin(sessionId, speaker)
|
// cbSessionMediaListenEnd(sessionId)
|
|
function session_event_media_cb(cbMediaTalkPrepare, cbMediaTalkBegin, cbMediaTalkEnd, cbMediaListenBegin, cbMediaListenEnd) {
|
cbSessionMediaTalkPrepare = cbMediaTalkPrepare;
|
cbSessionMediaTalkBegin = cbMediaTalkBegin;
|
cbSessionMediaTalkEnd = cbMediaTalkEnd;
|
cbSessionMediaListenBegin = cbMediaListenBegin;
|
cbSessionMediaListenEnd = cbMediaListenEnd;
|
}
|
|
//-------------------------------
|
// 设置全局生成SessionId的回调
|
//-------------------------------
|
// cbSessionIdGenerated(sessionId)
|
|
function session_event_session_id_generate(cbSesSessionIdGenerated)
|
{
|
cbSessionIdGenerated = cbSesSessionIdGenerated;
|
}
|
|
|
|
//============================================
|
//
|
// 频道会话进入
|
//
|
//============================================
|
|
|
//-------------------------------
|
// API - 进入频道会话
|
//-------------------------------
|
|
function session_channel_enter(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (cbSessionEstablished != null)
|
cbSessionEstablished(sessionId);
|
if (session.mediaState == MEDIA_STATE_LISTENING) {
|
if (cbSessionMediaListenBegin != null)
|
cbSessionMediaListenBegin(session.sessionId, session.mediaSpeaker);
|
}
|
} else {
|
if (cbSessionConnecting != null)
|
cbSessionConnecting(sessionId);
|
doChannelEnter(sessionId, function(sessionIndex) {
|
var session = new AirSession();
|
session.sessionId = sessionId;
|
session.sessionIndex = sessionIndex;
|
session.sessionState = SESSION_STATE_CONNECTING;
|
sessionArrayPut(session, sessionId);
|
});
|
}
|
}
|
|
|
|
/**
|
* @param replyOk 0成功
|
* @param sessionIndex
|
*/
|
function onChatRoomEnter(replyOk, sessionIndex) {
|
var session = null;
|
session = sessionGetByIndex(sessionIndex);
|
|
if (session != null) {
|
if (replyOk == 0) {
|
session.sessionState = SESSION_STATE_DIALOG;
|
if (cbSessionEstablished != null)
|
cbSessionEstablished(session.sessionId);
|
} else {
|
session.sessionState = SESSION_STATE_IDLE;
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, SESSION_RELEASE_ERROR);
|
sessionArrayRemove(session.sessionId);
|
}
|
}
|
}
|
|
|
//============================================
|
//
|
// 频道会话退出
|
//
|
//============================================
|
|
//-------------------------------
|
// API - 退出频道会话
|
//-------------------------------
|
|
function session_channel_exit(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (session.mediaState == MEDIA_STATE_TALKING) {
|
doTalkRelease(parseInt(session.sessionIndex, 10));
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, MEDIA_TALK_FINISH_RELEASED);
|
if (gSessionTalkIndex == session.sessionIndex)
|
gSessionTalkIndex = -1;
|
} else if (session.mediaState == MEDIA_STATE_LISTENING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaListenEnd != null)
|
cbSessionMediaListenEnd(session.sessionId);
|
}
|
|
sessionArrayRemove(sessionId);
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, SESSION_RELEASE_GENERAL);
|
|
doChannelExit(sessionId);
|
}
|
}
|
|
function onChatRoomExit(sessionIndex) {
|
var session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
if (session.mediaState == MEDIA_STATE_TALKING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, MEDIA_TALK_FINISH_RELEASED);
|
if (gSessionTalkIndex == session.sessionIndex)
|
gSessionTalkIndex = -1;
|
} else if (session.mediaState == MEDIA_STATE_LISTENING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaListenEnd != null)
|
cbSessionMediaListenEnd(session.sessionId);
|
}
|
|
sessionArrayRemove(session.sessionId);
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, SESSION_RELEASE_GENERAL);
|
}
|
}
|
|
//============================================
|
//
|
// 临时会话
|
//
|
//============================================
|
|
function session_id_generate(userids)
|
{
|
if (userids != null && userids.length > 0)
|
{
|
console.log(userids)
|
//{"userids": ["123312", "3423422", "3434"]}
|
var uids = {"userids": userids};
|
var json = JSON.stringify(uids);
|
doSessionTempMatch(json, "0");
|
}
|
}
|
|
function session_call_make(sessionId)
|
{
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (cbSessionEstablished != null)
|
cbSessionEstablished(sessionId);
|
if (session.mediaState == MEDIA_STATE_LISTENING) {
|
if (cbSessionMediaListenBegin != null)
|
cbSessionMediaListenBegin(session.sessionId, session.mediaSpeaker);
|
}
|
} else {
|
if (cbSessionConnecting != null)
|
cbSessionConnecting(sessionId);
|
doSessionTempCall(null, sessionId, 0, function(sessionIndex) {
|
var session = new AirSession();
|
session.sessionId = sessionId;
|
session.sessionIndex = sessionIndex;
|
session.sessionState = SESSION_STATE_CONNECTING;
|
sessionArrayPut(session);
|
});
|
}
|
}
|
|
function session_call_bye(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (session.mediaState == MEDIA_STATE_TALKING) {
|
doTalkRelease(session.sessionIndex);
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, MEDIA_TALK_FINISH_RELEASED);
|
if (gSessionTalkIndex == session.sessionIndex)
|
gSessionTalkIndex = -1;
|
} else if (session.mediaState == MEDIA_STATE_LISTENING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaListenEnd != null)
|
cbSessionMediaListenEnd(session.sessionId);
|
}
|
|
sessionArrayRemove(sessionId); //回调前清除session(频道也一样)
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, SESSION_RELEASE_GENERAL);
|
|
doLeaveCall(parseInt(session.sessionIndex, 10));
|
}
|
}
|
|
function session_call_incoming_accept(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (session.sessionState == SESSION_STATE_CONNECTING) {
|
doAcceptCall(parseInt(session.sessionIndex, 10));
|
}
|
}
|
}
|
|
function session_call_incoming_reject(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
if (session.sessionState == SESSION_STATE_CONNECTING) {
|
doRejectCall(parseInt(session.sessionIndex, 10));
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, SESSION_RELEASE_GENERAL);
|
sessionArrayRemove(sessionId);
|
}
|
}
|
}
|
|
|
//-------------------------------
|
// 会话回调事件
|
//-------------------------------
|
|
// Generated SessionId
|
function onSessionDialogMemberChange(json)
|
{
|
if (cbSessionIdGenerated != null && json != null)
|
cbSessionIdGenerated(json.sessionid);
|
}
|
|
function onSessionIncomingAlert(sessionIndex, user, sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session == null) {
|
session = new AirSession();
|
session.sessionId = sessionId;
|
session.sessionIndex = sessionIndex;
|
session.sessionState = SESSION_STATE_CONNECTING;
|
sessionArrayPut(session);
|
}
|
|
session.sessionState = SESSION_STATE_CONNECTING;
|
if (cbSessionIncomingAlert != null)
|
cbSessionIncomingAlert(sessionId, user);
|
}
|
|
function onSessionEstablish(sessionIndex, sessionId) {
|
var session = null;
|
session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
session.sessionState = SESSION_STATE_DIALOG;
|
if (cbSessionEstablished != null)
|
cbSessionEstablished(session.sessionId);
|
}
|
}
|
|
function onSessionRelease(sessionIndex, releaseReason) {
|
var session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
if (session.mediaState == MEDIA_STATE_TALKING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, MEDIA_TALK_FINISH_RELEASED);
|
if (gSessionTalkIndex == session.sessionIndex)
|
gSessionTalkIndex = -1;
|
} else if (session.mediaState == MEDIA_STATE_LISTENING) {
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaListenEnd != null)
|
cbSessionMediaListenEnd(session.sessionId);
|
}
|
|
sessionArrayRemove(session.sessionId);
|
if (cbSessionReleased != null)
|
cbSessionReleased(session.sessionId, releaseReason);
|
}
|
}
|
|
//============================================
|
//
|
// 会话媒体话权
|
//
|
//============================================
|
|
//-------------------------------
|
// API - 申请话语权
|
//-------------------------------
|
|
function session_talk_request(sessionId) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
gSessionTalkIndex = session.sessionIndex;
|
if (cbSessionMediaTalkPrepare != null)
|
cbSessionMediaTalkPrepare(sessionId);
|
doTalkRequest(parseInt(session.sessionIndex, 10));
|
}
|
}
|
|
|
//-------------------------------
|
// API - 释放话语权
|
//-------------------------------
|
|
function session_talk_release() {
|
if (gSessionTalkIndex >= 0) {
|
var session = sessionGetByIndex(gSessionTalkIndex);
|
if (session != null) {
|
doTalkRelease(parseInt(session.sessionIndex, 10));
|
if (session.mediaState != MEDIA_STATE_LISTENING)
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, MEDIA_TALK_FINISH_RELEASED);
|
//if (session.mediaState == MEDIA_STATE_LISTENING && cbSessionMediaListenBegin != null)
|
// cbSessionMediaListenBegin(session.sessionId, session.mediaSpeaker);
|
}
|
gSessionTalkIndex = -1;
|
}
|
}
|
|
//============================================
|
//
|
// 会话媒体状态事件
|
//
|
//============================================
|
|
function onMediaStateTalk(sessionIndex) {
|
var session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
session.mediaState = MEDIA_STATE_TALKING;
|
if (cbSessionMediaTalkBegin != null)
|
cbSessionMediaTalkBegin(session.sessionId);
|
}
|
}
|
|
function onMediaStateListern(sessionIndex, speaker) {
|
var session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
session.mediaState = MEDIA_STATE_LISTENING;
|
session.mediaSpeaker = speaker;
|
if (cbSessionMediaListenBegin != null)
|
cbSessionMediaListenBegin(session.sessionId, speaker);
|
}
|
}
|
|
function onMediaStateIdle(sessionIndex, reason) {
|
var session = sessionGetByIndex(sessionIndex);
|
if (session != null) {
|
if (reason == -1) // ListenEnd
|
{
|
if (session.mediaState != MEDIA_STATE_TALKING)
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaListenEnd != null)
|
cbSessionMediaListenEnd(session.sessionId);
|
} else // TalkEnd
|
{
|
if (session.mediaState != MEDIA_STATE_LISTENING)
|
session.mediaState = MEDIA_STATE_IDLE;
|
if (cbSessionMediaTalkEnd != null)
|
cbSessionMediaTalkEnd(session.sessionId, reason);
|
//if (session.mediaState == MEDIA_STATE_LISTENING && cbSessionMediaListenBegin != null)
|
// cbSessionMediaListenBegin(session.sessionId, session.mediaSpeaker);
|
}
|
}
|
}
|
|
|
//-------------------------------
|
// 会话锁定与解锁 isLock:0:unlock ,1:lock
|
//-------------------------------
|
function session_lock_opt(sessionId, islock) {
|
var session = sessionGetById(sessionId);
|
if (session != null) {
|
isServiceLock(parseInt(session.sessionIndex, 10), islock);
|
if (islock) {
|
for (var i = 0; i < gSessionArray.length; i++) {
|
gSessionArray[i].lock = 0;
|
}
|
}
|
session.lock = islock;
|
for (var i = 0; i < gSessionListenerRefresh.length; i++)
|
gSessionListenerRefresh[i]();
|
}
|
}
|
|
//============================================
|
//
|
// 会场状态通知
|
//
|
// cbSessionPresence(sessionId, presence)
|
//============================================
|
|
function onSessionDialogPresence(json) {
|
if (cbSessionPresence != null) {
|
var session = sessionGetByIndex(json.sessionindex);
|
if (session != null) {
|
session.precense = null;
|
if (session.precense == null) {
|
session.precense = new Array();
|
}
|
for (var i = 0; i < json.sessionmember.length; i++) {
|
session.precense.push(json.sessionmember[i].ipocid);
|
}
|
cbSessionPresence(session.sessionId, session.precense);
|
}
|
}
|
}
|
|
|
function onSessionChannelPresence(json) {
|
if (cbSessionPresence != null) {
|
var session = sessionGetByIndex(json.sessionindex);
|
if (session != null) {
|
if (session.precense == null) {
|
session.precense = new Array();
|
}
|
|
for (var i = 0; i < json.sessionmember.length; i++) {
|
var found = 0;
|
json.sessionmember[i].userstate = USER_SESSION_STATE_ON_LINE;
|
for (var j = 0; j < session.precense.length; j++) {
|
if (session.precense[j] == json.sessionmember[i].ipocid) {
|
found = 1;
|
break;
|
}
|
}
|
|
if (found == 0) {
|
session.precense.push(json.sessionmember[i].ipocid);
|
}
|
}
|
cbSessionPresence(session.sessionId, session.precense);
|
}
|
}
|
}
|
|
function onSessionChannelUserEnter(json) {
|
if (cbSessionPresence != null) {
|
var session = sessionGetByIndex(json.sessionindex);
|
if (session != null) {
|
if (session.precense == null) {
|
session.precense = new Array();
|
}
|
|
for (var i = 0; i < json.sessionmember.length; i++) {
|
var found = 0;
|
for (var j = 0; j < session.precense.length; j++) {
|
if (session.precense[j] == json.sessionmember[i].ipocid) {
|
found = 1;
|
break;
|
}
|
}
|
if (found == 0) {
|
session.precense.push(json.sessionmember[i].ipocid);
|
}
|
}
|
cbSessionPresence(session.sessionId, session.precense);
|
}
|
}
|
}
|
|
function onSessionChannelUserExit(json) {
|
if (cbSessionPresence != null) {
|
var session = sessionGetByIndex(json.sessionindex);
|
if (session != null) {
|
if (session.precense == null) {
|
session.precense = new Array();
|
}
|
var sessionmember = new Array();
|
for (var i = 0; i < json.sessionmember.length; i++) {
|
for (var i = 0; i < json.sessionmember.length; i++) {
|
for (var j = 0; j < session.precense.length; j++) {
|
if (session.precense[j] == json.sessionmember[i].ipocid) {
|
session.precense.splice(j, 1);
|
break;
|
}
|
}
|
}
|
}
|
cbSessionPresence(session.sessionId, session.precense);
|
}
|
}
|
}
|
