You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
442 lines
19 KiB
442 lines
19 KiB
<?php
|
|
include_once 'services/getSession/getSession.class.php';
|
|
include_once 'services/loginUser/loginUser.class.php';
|
|
include_once 'services/addRoomWithModerationAndExternalType/addRoomWithModerationAndExternalType.class.php';
|
|
include_once 'services/getRoomWithCurrentUsersById/getRoomWithCurrentUsersById.class.php';
|
|
include_once 'services/setUserObjectAndGenerateRoomHashByURLAndRecFlag/setUserObjectAndGenerateRoomHashByURLAndRecFlag.class.php';
|
|
include_once 'services/closeRoom/closeRoom.class.php';
|
|
include_once 'services/getRoomById/getRoomById.class.php';
|
|
/**
|
|
* Open Meetings-Chamilo connector class
|
|
*/
|
|
class om_integration {
|
|
|
|
var $url;
|
|
var $salt;
|
|
var $api;
|
|
var $user_complete_name = null;
|
|
var $protocol = 'http://';
|
|
var $debug = false;
|
|
var $logout_url = null;
|
|
var $plugin_enabled = false;
|
|
var $sessionId = "";
|
|
|
|
/**
|
|
* Constructor (generates a connection to the API and the Chamilo settings
|
|
* required for the connection to the videoconference server)
|
|
*/
|
|
function __construct() {
|
|
|
|
// initialize video server settings from global settings
|
|
$plugin = om_integrationPlugin::create();
|
|
|
|
$om_plugin = $plugin->get('tool_enable');
|
|
$om_host = $plugin->get('host');
|
|
$om_user = $plugin->get('user');
|
|
$om_pass = $plugin->get('pass');
|
|
|
|
$this->table = Database::get_main_table('plugin_om_meeting');
|
|
|
|
if ( $om_plugin ) {
|
|
$user_info = api_get_user_info();
|
|
$this->user_complete_name = $user_info['complete_name'];
|
|
$this->user = $om_user;
|
|
$this->pass = $om_pass;
|
|
$this->url = $om_host;
|
|
|
|
// Setting OM api
|
|
define('CONFIG_OMUSER_SALT', $this->user);
|
|
define('CONFIG_OMPASS_SALT', $this->pass);
|
|
define('CONFIG_OMSERVER_BASE_URL', $this->url);
|
|
|
|
$this->api = new OpenMeetings();
|
|
$this->plugin_enabled = $om_plugin;
|
|
}
|
|
}
|
|
/**
|
|
* Checks whether a user is teacher in the current course
|
|
* @return bool True if the user can be considered a teacher in this course, false otherwise
|
|
*/
|
|
function is_teacher() {
|
|
return api_is_course_admin() || api_is_coach() || api_is_platform_admin();
|
|
}
|
|
/**
|
|
* Login the user with OM Server
|
|
* @return bool True if the user is correct and false when is incorrect
|
|
*/
|
|
function loginUser() {
|
|
try{
|
|
$objGetSession = new getSession();
|
|
$objloginUser = new loginUser();
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/UserService?wsdl";
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
//Verifying if there is already an active session
|
|
if(empty($_SESSION['sessOpenMeeting'])){
|
|
$gsFun = $omServices->getSession($objGetSession);
|
|
$_SESSION['sessOpenMeeting'] = $objloginUser->SID = $this->sessionId = $gsFun->return->session_id;
|
|
$objloginUser->username = CONFIG_OMUSER_SALT;
|
|
$objloginUser->userpass = CONFIG_OMPASS_SALT;
|
|
|
|
$luFn = $omServices->loginUser($objloginUser);
|
|
|
|
if ( $luFn->return > 0 )
|
|
return true;
|
|
else
|
|
return false;
|
|
}else{
|
|
$this->sessionId = $_SESSION['sessOpenMeeting'];
|
|
return true;
|
|
}
|
|
}catch( SoapFault $e){
|
|
echo "<h1>Warning</h1>
|
|
<p>We have detected some problems </br>
|
|
Fault: {$e->faultstring}</p>";
|
|
return false;
|
|
}
|
|
}
|
|
/*
|
|
* Creating a Room for the meeting
|
|
* @return bool True if the user is correct and false when is incorrect
|
|
*/
|
|
function create_meeting( $params ) {
|
|
//$id = Database::insert($this->table, $params);
|
|
try{
|
|
$objAddRoom = new addRoomWithModerationAndExternalType();
|
|
$roomtypes_id = $isModerated = ( $this->is_teacher() ) ? 1 : 2 ;
|
|
$params['c_id'] = api_get_course_int_id();
|
|
$course_name = 'COURSE_ID_' . $params['c_id'] .'_NAME_' . $params['meeting_name'];
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/RoomService?wsdl";
|
|
|
|
$objAddRoom->SID = $this->sessionId;
|
|
$objAddRoom->name = $course_name;
|
|
$objAddRoom->roomtypes_id = $roomtypes_id;
|
|
$objAddRoom->comment = 'Curso: ' . $params['meeting_name'] . ' Plugin for Chamilo';
|
|
$objAddRoom->numberOfPartizipants = 40;
|
|
$objAddRoom->ispublic = true;
|
|
$objAddRoom->appointment = false;
|
|
$objAddRoom->isDemoRoom = false;
|
|
$objAddRoom->demoTime = false;
|
|
$objAddRoom->isModeratedRoom = $isModerated;
|
|
$objAddRoom->externalRoomType = true;
|
|
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
$adFun = $omServices->addRoomWithModerationAndExternalType( $objAddRoom );
|
|
|
|
if( $adFun->return > -1 ){
|
|
$meetingId = $params['id'] = $adFun->return;
|
|
$params['status'] = '1';
|
|
$params['meeting_name'] = $course_name;
|
|
$params['created_at'] = date('l jS \of F Y h:i:s A');
|
|
|
|
Database::insert($this->table, $params);
|
|
|
|
$this->join_meeting($meetingId);
|
|
}else{
|
|
return -1;
|
|
}
|
|
|
|
}catch( SoapFault $e){
|
|
echo "<h1>Warning</h1>
|
|
<p>We have detected some problems </br>
|
|
Fault: {$e->faultstring}</p>";
|
|
return -1;
|
|
}
|
|
|
|
}
|
|
/**
|
|
* Returns a meeting "join" URL
|
|
* @param string The name of the meeting (usually the course code)
|
|
* @return mixed The URL to join the meeting, or false on error
|
|
* @todo implement moderator pass
|
|
* @assert ('') === false
|
|
* @assert ('abcdefghijklmnopqrstuvwxyzabcdefghijklmno') === false
|
|
*/
|
|
function join_meeting($meetingid) {
|
|
|
|
if (empty($meetingid)) { return false; }
|
|
$meeting_data = Database::select('*', $this->table, array('where' => array('id = ? AND status = 1 ' => $meetingid)), 'first');
|
|
if (empty($meeting_data)) {
|
|
if ($this->debug) error_log("meeting does not exist: $meetingid ");
|
|
return false;
|
|
}
|
|
|
|
$params = array( 'room_id' => $meetingid );
|
|
|
|
$returnVal = $this->setUserObjectAndGenerateRoomHashByURLAndRecFlag( $params );
|
|
$urlWithoutProtocol = str_replace("http://", CONFIG_OMSERVER_BASE_URL);
|
|
$imgWithoutProtocol = str_replace("http://", $_SESSION['_user']['avatar'] );
|
|
|
|
$iframe = CONFIG_OMSERVER_BASE_URL . "/?" .
|
|
"secureHash=" . $returnVal /*.
|
|
'&username=FRAGOTE' .
|
|
'&firstname=DD' .
|
|
'&lastname=DDDD' .
|
|
'&profilePictureUrl=X' .
|
|
'&email=xxx' .
|
|
'&externalUserId=fragote' .
|
|
'&room_id=38' .
|
|
'&scopeRoomId=38' .
|
|
'&becomeModeratorAsInt=1' .
|
|
'&showAudioVideoTestAsInt=0' .
|
|
'&allowRecording=1'*/;
|
|
|
|
printf("<iframe src='%s' width='%s' height = '%s' />", $iframe, "100%", 640);
|
|
|
|
}
|
|
/**
|
|
* Checks if the videoconference server is running.
|
|
* Function currently disabled (always returns 1)
|
|
* @return bool True if server is running, false otherwise
|
|
* @assert () === false
|
|
*/
|
|
function is_server_running() {
|
|
return true;
|
|
}
|
|
/**
|
|
* Gets the password for a specific meeting for the current user
|
|
* @return string A moderator password if user is teacher, or the course code otherwise
|
|
*/
|
|
function get_user_meeting_password() {
|
|
if ($this->is_teacher()) {
|
|
return $this->get_mod_meeting_password();
|
|
} else {
|
|
return api_get_course_id();
|
|
}
|
|
}
|
|
/**
|
|
* Generated a moderator password for the meeting
|
|
* @return string A password for the moderation of the videoconference
|
|
*/
|
|
function get_mod_meeting_password() {
|
|
return api_get_course_id().'mod';
|
|
}
|
|
/**
|
|
* Get information about the given meeting
|
|
* @param array ...?
|
|
* @return mixed Array of information on success, false on error
|
|
* @assert (array()) === false
|
|
*/
|
|
function get_meeting_info($params) {
|
|
try {
|
|
$result = $this->api->getMeetingInfoArray($params);
|
|
if ($result == null) {
|
|
if ($this->debug) error_log("Failed to get any response. Maybe we can't contact the BBB server.");
|
|
} else {
|
|
return $result;
|
|
}
|
|
} catch (Exception $e) {
|
|
if ($this->debug) error_log('Caught exception: ', $e->getMessage(), "\n");
|
|
}
|
|
return false;
|
|
}
|
|
function setUserObjectAndGenerateRecordingHashByURL( $params ) {
|
|
$username = $_SESSION['_user']['username'];
|
|
$firstname = $_SESSION['_user']['firstname'];
|
|
$lastname = $_SESSION['_user']['lastname'];
|
|
$userId = $_SESSION['_user']['user_id'];
|
|
$systemType = 'chamilo';
|
|
$room_id = $params['room_id'];
|
|
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/UserService?wsdl";
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
$objRec = new setUserObjectAndGenerateRecordingHashByURL();
|
|
|
|
$objRec->SID = $this->sessionId;
|
|
$objRec->username = $username;
|
|
$objRec->firstname = $firstname;
|
|
$objRec->lastname = $lastname;
|
|
$objRec->externalUserId = $userId;
|
|
$objRec->externalUserType = $systemType;
|
|
$objRec->recording_id = $recording_id;
|
|
|
|
$orFn = $omServices->setUserObjectAndGenerateRecordingHashByURL( $objRec );
|
|
return $orFn->return;
|
|
|
|
}
|
|
function setUserObjectAndGenerateRoomHashByURLAndRecFlag( $params ) {
|
|
$username = $_SESSION['_user']['username'];
|
|
$firstname = $_SESSION['_user']['firstname'];
|
|
$lastname = $_SESSION['_user']['lastname'];
|
|
$profilePictureUrl = $_SESSION['_user']['avatar'];
|
|
$email = $_SESSION['_user']['mail'];
|
|
$userId = $_SESSION['_user']['user_id'];
|
|
$systemType = 'Chamilo';
|
|
$room_id = $params['room_id'];
|
|
$becomeModerator = ( $this->is_teacher() ? 1 : 0 );
|
|
$allowRecording = 1; //Provisional
|
|
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/UserService?wsdl";
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
$objRec = new setUserObjectAndGenerateRoomHashByURLAndRecFlag();
|
|
|
|
$objRec->SID = $this->sessionId;
|
|
$objRec->username = $username;
|
|
$objRec->firstname = $firstname;
|
|
$objRec->lastname = $lastname;
|
|
$objRec->profilePictureUrl = $profilePictureUrl;
|
|
$objRec->email = $email;
|
|
$objRec->externalUserId = $userId;
|
|
$objRec->externalUserType = $systemType;
|
|
$objRec->room_id = $room_id;
|
|
$objRec->becomeModeratorAsInt = $becomeModerator;
|
|
$objRec->showAudioVideoTestAsInt = 1;
|
|
$objRec->allowRecording = $allowRecording;
|
|
|
|
$rcFn = $omServices->setUserObjectAndGenerateRoomHashByURLAndRecFlag( $objRec );
|
|
|
|
return $rcFn->return;
|
|
}
|
|
|
|
/**
|
|
* Gets all the course meetings saved in the plugin_bbb_meeting table
|
|
* @return array Array of current open meeting rooms
|
|
*/
|
|
function get_course_meetings() {
|
|
$new_meeting_list = array();
|
|
$item = array();
|
|
$pass = $this->get_user_meeting_password();
|
|
$this->loginUser();
|
|
$meeting_list = Database::select('*', $this->table, array('where' => array('c_id = ? ' => api_get_course_int_id())));
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/RoomService?wsdl";
|
|
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
$objRoom = new getRoomById();
|
|
$objCurrentUsers = new getRoomWithCurrentUsersById();
|
|
$objRoom->SID = $objCurrentUsers->SID = $this->sessionId;
|
|
foreach ($meeting_list as $meeting_db) {
|
|
$objRoom->rooms_id = $objCurrentUsers->rooms_id = $meeting_db['id'];
|
|
try{
|
|
$objRoomId = $omServices->getRoomById($objRoom);
|
|
|
|
if(empty($objRoomId->return)){
|
|
Database::delete($this->table, "id = {$meeting_db['id']}");
|
|
continue;
|
|
}
|
|
$objCurUs = $omServices->getRoomWithCurrentUsersById($objCurrentUsers);
|
|
}catch( SoapFault $e ){
|
|
echo $e->faultstring;
|
|
exit;
|
|
}
|
|
//if( empty($objCurUs->returnMeetingID) ) continue;
|
|
|
|
$current_room = array(
|
|
'roomtype' => $objCurUs->return->roomtype->roomtypes_id,
|
|
'meetingName' => $objCurUs->return->name,
|
|
'meetingId' => $objCurUs->return->meetingID,
|
|
'createTime' => $objCurUs->return->rooms_id,
|
|
'showMicrophoneStatus' => $objCurUs->return->showMicrophoneStatus,
|
|
'attendeePw' => $objCurUs->return->attendeePW,
|
|
'moderatorPw' => $objCurUs->return->moderators,
|
|
'isClosed' => $objCurUs->return->isClosed,
|
|
'allowRecording' => $objCurUs->return->allowRecording,
|
|
'startTime' => $objCurUs->return->startTime,
|
|
'endTime' => $objCurUs->return->updatetime,
|
|
'participantCount' => count($objCurUs->return->currentusers),
|
|
'maxUsers' => $objCurUs->return->numberOfPartizipants,
|
|
'moderatorCount' => count($objCurUs->return->moderators)
|
|
);
|
|
// Then interate through attendee results and return them as part of the array:
|
|
foreach ($objCurUs->return->currentusers as $a)
|
|
$current_room[] = array(
|
|
'userId' => $a->username,
|
|
'fullName' => $a->firstname . " " . $a->lastname,
|
|
'isMod' => $a->isMod
|
|
);
|
|
|
|
$meeting_om = $current_room;
|
|
|
|
if (empty( $meeting_om ))
|
|
if ($meeting_db['status'] == 1 && $this->is_teacher())
|
|
$this->end_meeting($meeting_db['id']);
|
|
else
|
|
$meeting_om['add_to_calendar_url'] = api_get_self().'?action=add_to_calendar&id='.$meeting_db['id'].'&start='.api_strtotime($meeting_db['startTime']);
|
|
|
|
$meeting_om['end_url'] = api_get_self().'?action=end&id='.$meeting_db['id'];
|
|
|
|
$record_array = array();
|
|
|
|
// if ($meeting_db['record'] == 1) {
|
|
// $recordingParams = array(
|
|
// 'meetingId' => $meeting_db['id'], //-- OPTIONAL - comma separate if multiple ids
|
|
// );
|
|
//
|
|
// $records = $this->api->getRecordingsWithXmlResponseArray($recordingParams);
|
|
// if (!empty($records)) {
|
|
// $count = 1;
|
|
// if (isset($records['message']) && !empty($records['message'])) {
|
|
// if ($records['messageKey'] == 'noRecordings') {
|
|
// $record_array[] = get_lang('NoRecording');
|
|
// } else {
|
|
// //$record_array[] = $records['message'];
|
|
// }
|
|
// } else {
|
|
// foreach ($records as $record) {
|
|
// if (is_array($record) && isset($record['recordId'])) {
|
|
// $url = Display::url(get_lang('ViewRecord'), $record['playbackFormatUrl'], array('target' => '_blank'));
|
|
// if ($this->is_teacher()) {
|
|
// $url .= Display::url(Display::return_icon('link.gif',get_lang('CopyToLinkTool')), api_get_self().'?action=copy_record_to_link_tool&id='.$meeting_db['id'].'&record_id='.$record['recordId']);
|
|
// $url .= Display::url(Display::return_icon('agenda.png',get_lang('AddToCalendar')), api_get_self().'?action=add_to_calendar&id='.$meeting_db['id'].'&start='.api_strtotime($meeting_db['created_at']).'&url='.$record['playbackFormatUrl']);
|
|
// $url .= Display::url(Display::return_icon('delete.png',get_lang('Delete')), api_get_self().'?action=delete_record&id='.$record['recordId']);
|
|
// }
|
|
// //$url .= api_get_self().'?action=publish&id='.$record['recordID'];
|
|
// $count++;
|
|
// $record_array[] = $url;
|
|
// } else {
|
|
//
|
|
// }
|
|
// }
|
|
// }
|
|
// }
|
|
// //var_dump($record_array);
|
|
// $item['show_links'] = implode('<br />', $record_array);
|
|
//
|
|
// }
|
|
//
|
|
//$item['created_at'] = api_convert_and_format_date($meeting_db['created_at']);
|
|
// //created_at
|
|
//
|
|
// $item['publish_url'] = api_get_self().'?action=publish&id='.$meeting_db['id'];
|
|
// $item['unpublish_url'] = api_get_self().'?action=unpublish&id='.$meeting_db['id'];
|
|
//
|
|
//if ($meeting_db['status'] == 1) {
|
|
// $joinParams = array(
|
|
// 'meetingId' => $meeting_db['id'], //-- REQUIRED - A unique id for the meeting
|
|
// 'username' => $this->user_complete_name, //-- REQUIRED - The name that will display for the user in the meeting
|
|
// 'password' => $pass, //-- REQUIRED - The attendee or moderator password, depending on what's passed here
|
|
// 'createTime' => '', //-- OPTIONAL - string. Leave blank ('') unless you set this correctly.
|
|
// 'userID' => '', // -- OPTIONAL - string
|
|
// 'webVoiceConf' => '' // -- OPTIONAL - string
|
|
// );
|
|
// $returnVal = $this->setUserObjectAndGenerateRoomHashByURLAndRecFlag( array('room_id' => $meeting_db['id']) );
|
|
// $joinUrl = CONFIG_OMSERVER_BASE_URL . "?" .
|
|
// "secureHash=" . $returnVal;
|
|
//
|
|
// $item['go_url'] = $joinUrl;
|
|
//}
|
|
$item = array_merge($item, $meeting_db, $meeting_om);
|
|
$new_meeting_list[] = $item;
|
|
}
|
|
return $new_meeting_list;
|
|
}
|
|
function end_meeting( $meetingId ){
|
|
try{
|
|
$this->loginUser();
|
|
$urlWsdl = CONFIG_OMSERVER_BASE_URL . "/services/RoomService?wsdl";
|
|
$omServices = new SoapClient( $urlWsdl );
|
|
$objClose = new closeRoom();
|
|
$objClose->SID = $this->sessionId;
|
|
$objClose->room_id = $meetingId;
|
|
$objClose->status = false;
|
|
$crFn = $omServices->closeRoom( $objClose );
|
|
if( $crFn > 0 )
|
|
Database::update($this->table, array('status' => 0, 'closed_at' => api_get_utc_datetime()), array('id = ? ' => $meetingId));
|
|
|
|
}catch( SoapFault $e){
|
|
echo "<h1>Warning</h1>
|
|
<p>We have detected some problems </br>
|
|
Fault: {$e->faultstring}</p>";
|
|
exit;
|
|
return -1;
|
|
}
|
|
}
|
|
} |