diff options
Diffstat (limited to 'storage-backend')
| -rw-r--r-- | storage-backend/index.php | 11 | ||||
| -rw-r--r-- | storage-backend/lib/functions.filetransfer.inc.php | 45 | ||||
| -rw-r--r-- | storage-backend/lib/xmpp.util.inc.php | 69 |
3 files changed, 120 insertions, 5 deletions
diff --git a/storage-backend/index.php b/storage-backend/index.php index d153e63..3707963 100644 --- a/storage-backend/index.php +++ b/storage-backend/index.php @@ -11,7 +11,7 @@ * size * content_type * user_jid - * receipient_jid + * recipient_jid * 403: In case the XMPP Server Key is not valid * 406: * File is empty (error code: 1) @@ -50,6 +50,7 @@ include_once(__DIR__.'/lib/functions.common.inc.php'); include_once(__DIR__.'/lib/functions.http.inc.php'); include_once(__DIR__.'/lib/functions.filetransfer.inc.php'); +include_once(__DIR__.'/lib/xmpp.util.inc.php'); $method = $_SERVER['REQUEST_METHOD']; // Load configuration @@ -74,6 +75,10 @@ switch ($method) { } switch ($slotType) { + case 'list': + $slots = readSlots($userJid); + $result = ['list' => $slots]; + break; case 'delete': // Check if all parameters needed for an delete are present - return 400 (bad request) if a parameter is missing / empty $fileURL = getMandatoryPostParameter('file_url'); @@ -104,7 +109,7 @@ switch ($method) { $filename = rawurlencode(getMandatoryPostParameter('filename')); $filesize = getMandatoryPostParameter('size'); $mimeType = getOptionalPostParameter('content_type'); - $receipientJid = getMandatoryPostParameter('receipient_jid'); + $recipientJid = getMandatoryPostParameter('recipient_jid'); // check file name - return 406 (not acceptable) if file contains invalid characters foreach ($config['invalid_characters_in_filename'] as $invalidCharacter) { @@ -122,7 +127,7 @@ switch ($method) { } // generate slot uuid, register slot uuid and expected file size and expected mime type $slotUUID = generate_uuid(); - registerSlot($slotUUID, $filename, $filesize, $mimeType, $userJid, $receipientJid, $config); + registerSlot($slotUUID, $filename, $filesize, $mimeType, $userJid, $recipientJid, $config); if (!mkdir(getUploadFilePath($slotUUID, $config))) { sendHttpReturnCodeAndJson(500, "Could not create directory for upload."); } diff --git a/storage-backend/lib/functions.filetransfer.inc.php b/storage-backend/lib/functions.filetransfer.inc.php index 679cef1..607d30f 100644 --- a/storage-backend/lib/functions.filetransfer.inc.php +++ b/storage-backend/lib/functions.filetransfer.inc.php @@ -16,8 +16,49 @@ function getUploadFilePath($slotUUID, $config, $filename = NULL) { } function loadSlotParameters($slotUUID, $config) { - $slotParameters = require(getSlotFilePath($slotUUID, $config)); + $slotFilePath = getSlotFilePath($slotUUID, $config); + $slotParameters = require($slotFilePath); $slotParameters['filename'] = $slotParameters['filename']; + $slotParameters['creation_time'] = filemtime($slotFilePath); return $slotParameters; -}
\ No newline at end of file +} + +function readSlots($jid) { + global $config; + + $jid = getBareJid($jid); + $slots = array(); + + if ($handle = opendir($config['slot_registry_dir'])) { + while (false !== ($entry = readdir($handle))) { + if ($entry != "." && $entry != ".." && $entry != ".htaccess") { + $slotUUID = $entry; + $params = loadSlotParameters($slotUUID, $config); + $senderBareJid = getBareJid($params['user_jid']); + $recipientBareJid = (array_key_exists('receipient_jid', $params)) ? getBareJid($params['receipient_jid']) : ''; + if ($senderBareJid == $jid || $recipientBareJid == $jid) { + $filePath = getUploadFilePath($slotUUID, $config, $params['filename']); + $file = []; + $fileExists = file_exists($filePath); + $file['url'] = ""; + $file['sent_time'] = $params['creation_time']; + if ($fileExists) { + $file['url'] = $config['base_url_get'].$slotUUID.'/'.$params['filename']; + } + $file['fileinfo'] = []; + $file['fileinfo']['filename'] = $params['filename']; + $file['fileinfo']['filesize'] = $params['filesize']; + $file['fileinfo']['content_type'] = $params['content_type']; + $file['sender_jid'] = $senderBareJid; + $file['recipient_jid'] = $recipientBareJid; + if (null == $file['receipient_jid']) { + $file['receipient_jid'] = ""; + } + $slots[] = $file; + } + } + } + } + return $slots; +} diff --git a/storage-backend/lib/xmpp.util.inc.php b/storage-backend/lib/xmpp.util.inc.php new file mode 100644 index 0000000..cdc90fb --- /dev/null +++ b/storage-backend/lib/xmpp.util.inc.php @@ -0,0 +1,69 @@ +<?php +/* + * xmpp jid util functions. + */ + +function getJidDomain($jid) { + if (null == $jid) { + return null; + } + + $atIndex = strpos($jid, '@'); + $slashIndex = strpos($jid, '/'); + + if ($slashIndex !== false) { + if ($slashIndex > $atIndex) {// 'local@domain.foo/resource' and 'local@domain.foo/res@otherres' case + return substr($jid, $atIndex + 1, $slashIndex - $atIndex + 1); + } else {// 'domain.foo/res@otherres' case + return substr($jid, 0, $slashIndex); + } + } else { + return substr($jid, $atIndex + 1); + } +} + +function getJidLocalPart($jid) { + if ($jid == null) { + return null; + } + + $atIndex = strpos($jid, '@'); + if ($atIndex === false || $atIndex == 0) { + return ""; + } + + $slashIndex = strpos($jid, '/'); + if ($slashIndex !== false && $slashIndex < $atIndex) { + return ""; + } else { + return substr($jid, 0, $atIndex); + } +} + +function getBareJid($jid) { + if ($jid == null) { + return null; + } + + $slashIndex = strpos($jid, '/'); + if ($slashIndex === false) { + return $jid; + } else if ($slashIndex == 0) { + return ""; + } else { + return substr($jid, 0, $slashIndex); + } +} + +function getResource($jid) { + if ($jid == null) { + return null; + } + + $slashIndex = strpos($jid, '/'); + if ($slashIndex + 1 > strlen($jid) || $slashIndex === false) { + return ""; + } else { + return substr($jid, $slashIndex + 1); + } +} |