name, PATHINFO_EXTENSION); // Check if extension is a double-dot extension and, if true, override $ext $revname = strrev($file->name); foreach ($doubledots as $ddot) { if (stripos($revname, $ddot) === 0) { $ext = strrev($ddot); } } do { // Iterate until we reach the maximum number of retries if ($tries-- == 0) { throw new Exception('Gave up trying to find an unused name', 500); } $chars = range('a', 'z'); $name = ''; for ($i = 0; $i < $length; ++$i) { $name .= $chars[array_rand($chars)]; } // Add the extension to the file name if (isset($ext) && $ext !== '') { $name .= '.'.strip_tags($ext); } // Check if a file with the same name does already exist in the database $q = $db->prepare('SELECT COUNT(name) FROM pomf WHERE name = (:name)'); $q->bindValue(':name', $name, PDO::PARAM_STR); $q->execute(); $result = $q->fetchColumn(); // If it does, generate a new name } while ($result > 0); return $name; } /** * Handles the uploading and db entry for a file. * * @param UploadedFile $file * * @return array */ function upload_file($file) { global $db; // Handle file errors if ($file->error) { throw new UploadException($file->error); } // Check if a file with the same hash and size (a file which is the same) does already exist in // the database; if it does, delete the file just uploaded and return the proper link and data. $q = $db->prepare('SELECT filename, COUNT(*) AS count FROM files WHERE hash = (:hash) '. 'AND size = (:size)'); $q->bindValue(':hash', $file->get_sha1(), PDO::PARAM_STR); $q->bindValue(':size', $file->size, PDO::PARAM_INT); $q->execute(); $result = $q->fetch(); if ($result['count'] > 0) { unlink($file->tempfile); return array( 'hash' => $file->get_sha1(), 'name' => $file->name, 'url' => $result['filename'], 'size' => $file->size, ); } // Generate a name for the file $newname = generate_name($file); // Attempt to move it to the static directory if (move_uploaded_file($file->tempfile, POMF_FILES_ROOT.$newname)) { // Need to change permissions for the new file to make it world readable if (chmod(POMF_FILES_ROOT.$newname, 0644)) { // Add it to the database if (empty($_SESSION['id'])) { // Query if user is NOT logged in $q = $db->prepare('INSERT INTO files (hash, originalname, filename, size, date, '. 'expire, delid) VALUES (:hash, :orig, :name, :size, :date, '. ':exp, :del)'); } else { // Query if user is logged in (insert user id together with other data) $q = $db->prepare('INSERT INTO files (hash, originalname, filename, size, date, '. 'expire, delid, user) VALUES (:hash, :orig, :name, :size, '. ':date, :expires, :delid, :user)'); $q->bindValue(':user', $_SESSION['id'], PDO::PARAM_INT); } // Common parameters binding $q->bindValue(':hash', $file->get_sha1(), PDO::PARAM_STR); $q->bindValue(':orig', strip_tags($file->name), PDO::PARAM_STR); $q->bindValue(':name', $newname, PDO::PARAM_STR); $q->bindValue(':size', $file->size, PDO::PARAM_INT); $q->bindValue(':date', date('Y-m-d'), PDO::PARAM_STR); $q->bindValue(':exp', null, PDO::PARAM_STR); $q->bindValue(':del', sha1($file->tempfile), PDO::PARAM_STR); $q->execute(); return array( 'hash' => $file->get_sha1(), 'name' => $file->name, 'url' => POMF_URL.$newname, 'size' => $file->size, ); } else { throw new Exception('Failed to change file permissions', 500); } } else { throw new Exception('Failed to move file to destination', 500); } } /** * Reorder files array by file. * * @param $_FILES * * @return array */ function diverse_array($files) { $result = array(); foreach ($files as $key1 => $value1) { foreach ($value1 as $key2 => $value2) { $result[$key2][$key1] = $value2; } } return $result; } /** * Reorganize the $_FILES array into something saner. * * @param $_FILES * * @return array */ function refiles($files) { $result = array(); $files = diverse_array($files); foreach ($files as $file) { $f = new UploadedFile(); $f->name = $file['name']; $f->mime = $file['type']; $f->size = $file['size']; $f->tempfile = $file['tmp_name']; $f->error = $file['error']; // 'expire' doesn't exist neither in $_FILES nor in UploadedFile; // commented out for future implementation //$f->expire = $file['expire']; $result[] = $f; } return $result; } $type = isset($_GET['output']) ? $_GET['output'] : 'json'; $response = new Response($type); if (isset($_FILES['files'])) { $uploads = refiles($_FILES['files']); try { foreach ($uploads as $upload) { $res[] = upload_file($upload); } $response->send($res); } catch (Exception $e) { $response->error($e->getCode(), $e->getMessage()); } } else { $response->error(400, 'No input file(s)'); }