Recordings are listed in the database as soon as they are available on the remote Zoom servers. Meeting and recording lists are kept up-to-date. This also allows meeting participant attendance tracking (not implemented yet).pull/3383/head
Sébastien Ducoulombier
5 years ago
parent
9ca1c03ff3
commit
83db53798f
@ -0,0 +1,100 @@ |
||||
<?php |
||||
/* For license terms, see /license.txt */ |
||||
|
||||
use Chamilo\PluginBundle\Zoom\API\MeetingInfoGet; |
||||
use Chamilo\PluginBundle\Zoom\API\RecordingMeeting; |
||||
use Chamilo\PluginBundle\Zoom\MeetingEntity; |
||||
use Chamilo\PluginBundle\Zoom\RecordingEntity; |
||||
use Chamilo\PluginBundle\Zoom\RegistrantEntity; |
||||
|
||||
if ('POST' !== $_SERVER['REQUEST_METHOD']) { |
||||
http_response_code(404); // Not found |
||||
exit; |
||||
} |
||||
|
||||
$authorizationHeaderValue = apache_request_headers()['authorization']; // TODO handle non-apache installations |
||||
|
||||
require __DIR__.'/config.php'; |
||||
|
||||
if (api_get_plugin_setting('zoom', 'verificationToken') !== $authorizationHeaderValue) { |
||||
http_response_code(401); // Unauthorized |
||||
exit; |
||||
} |
||||
|
||||
$body = file_get_contents('php://input'); |
||||
$decoded = json_decode($body); |
||||
if (is_null($decoded) || !is_object($decoded) || !isset($decoded->event) || !isset($decoded->payload->object)) { |
||||
error_log(sprintf('Did not recognize event notification: %s', $body)); |
||||
http_response_code(422); // Unprocessable Entity |
||||
exit; |
||||
} |
||||
$object = $decoded->payload->object; |
||||
list($objectType, $action) = explode('.', $decoded->event); |
||||
switch ($objectType) { |
||||
case 'meeting': |
||||
$meetingRepository = $entityManager->getRepository(MeetingEntity::class); |
||||
$registrantRepository = $entityManager->getRepository(RegistrantEntity::class); |
||||
switch ($action) { |
||||
case 'deleted': |
||||
$meetingEntity = $meetingRepository->find($object->id); |
||||
if (!is_null($meetingEntity)) { |
||||
$entityManager->remove($meetingEntity); |
||||
} |
||||
break; |
||||
case 'ended': |
||||
case 'started': |
||||
$entityManager->persist( |
||||
( |
||||
$meetingRepository->find($object->id)->setStatus($action) |
||||
?: (new MeetingEntity)->setMeetingInfoGet(MeetingInfoGet::fromObject($object)) |
||||
) |
||||
); |
||||
$entityManager->flush(); |
||||
break; |
||||
case 'participant_joined': |
||||
case 'participant_left': |
||||
$registrant = $registrantRepository->find($object->participant->id); |
||||
if (!is_null($registrant)) { |
||||
// TODO log attendance |
||||
} |
||||
break; |
||||
case 'alert': |
||||
default: |
||||
error_log(sprintf('Event "%s" on %s was unhandled: %s', $action, $objectType, $body)); |
||||
http_response_code(501); // Not Implemented |
||||
} |
||||
break; |
||||
case 'recording': |
||||
$recordingRepository = $entityManager->getRepository(RecordingEntity::class); |
||||
switch ($action) { |
||||
case 'completed': |
||||
$entityManager->persist( |
||||
(new RecordingEntity())->setRecordingMeeting(RecordingMeeting::fromObject($object)) |
||||
); |
||||
$entityManager->flush(); |
||||
break; |
||||
case 'recovered': |
||||
if (is_null($recordingRepository->find($object->uuid))) { |
||||
$entityManager->persist( |
||||
(new RecordingEntity())->setRecordingMeeting(RecordingMeeting::fromObject($object)) |
||||
); |
||||
$entityManager->flush(); |
||||
} |
||||
break; |
||||
case 'trashed': |
||||
case 'deleted': |
||||
$recordingEntity = $recordingRepository->find($object->uuid); |
||||
if (!is_null($recordingEntity)) { |
||||
$entityManager->remove($recordingEntity); |
||||
$entityManager->flush(); |
||||
} |
||||
break; |
||||
default: |
||||
error_log(sprintf('Event "%s" on %s was unhandled: %s', $action, $objectType, $body)); |
||||
http_response_code(501); // Not Implemented |
||||
} |
||||
break; |
||||
default: |
||||
error_log(sprintf('Event "%s" on %s was unhandled: %s', $action, $objectType, $body)); |
||||
http_response_code(501); // Not Implemented |
||||
} |
||||
Loading…
Reference in new issue