450 lines
14 KiB
PHP
450 lines
14 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace OCA\Memories;
|
|
|
|
use OCA\Memories\AppInfo\Application;
|
|
use OCA\Memories\Service\BinExt;
|
|
use OCP\Files\File;
|
|
use OCP\IConfig;
|
|
|
|
class Exif
|
|
{
|
|
private const FORBIDDEN_EDIT_MIMES = ['image/bmp', 'image/x-dcraw', 'video/MP2T'];
|
|
private const EXIFTOOL_TIMEOUT = 30000;
|
|
private const EXIFTOOL_ARGS = ['-api', 'QuickTimeUTC=1', '-n', '-U', '-json', '--b'];
|
|
|
|
/** Opened instance of exiftool when running in command mode */
|
|
private static $staticProc;
|
|
private static $staticPipes;
|
|
private static $noStaticProc = false;
|
|
|
|
public static function closeStaticExiftoolProc()
|
|
{
|
|
try {
|
|
if (self::$staticProc) {
|
|
fclose(self::$staticPipes[0]);
|
|
fclose(self::$staticPipes[1]);
|
|
fclose(self::$staticPipes[2]);
|
|
proc_terminate(self::$staticProc);
|
|
self::$staticProc = null;
|
|
self::$staticPipes = null;
|
|
}
|
|
} catch (\Exception $ex) {
|
|
}
|
|
}
|
|
|
|
public static function restartStaticExiftoolProc()
|
|
{
|
|
self::closeStaticExiftoolProc();
|
|
self::ensureStaticExiftoolProc();
|
|
}
|
|
|
|
public static function ensureStaticExiftoolProc()
|
|
{
|
|
if (self::$noStaticProc) {
|
|
return;
|
|
}
|
|
|
|
if (!self::$staticProc) {
|
|
self::initializeStaticExiftoolProc();
|
|
usleep(500000); // wait if error
|
|
if (!proc_get_status(self::$staticProc)['running']) {
|
|
error_log('WARN: Failed to create stay_open exiftool process');
|
|
self::$noStaticProc = true;
|
|
self::$staticProc = null;
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
if (!proc_get_status(self::$staticProc)['running']) {
|
|
self::$staticProc = null;
|
|
self::ensureStaticExiftoolProc();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get list of timeline paths as array.
|
|
*/
|
|
public static function getTimelinePaths(string $uid): array
|
|
{
|
|
$config = \OC::$server->get(IConfig::class);
|
|
$paths = $config->getUserValue($uid, Application::APPNAME, 'timelinePath', null) ?? 'Photos/';
|
|
|
|
return array_map(fn ($p) => self::sanitizePath(trim($p)), explode(';', $paths));
|
|
}
|
|
|
|
/**
|
|
* Sanitize a path to keep only ASCII characters and special characters.
|
|
*/
|
|
public static function sanitizePath(string $path)
|
|
{
|
|
$path = mb_ereg_replace('([^\\w\\s\\d\\-_~,;:!@#$&*{}\[\]\'\\[\\]\\(\\).\\\/])', '', $path);
|
|
$path = mb_ereg_replace('\/\/+', '/', $path); // remove extra slashes
|
|
return $path;
|
|
}
|
|
|
|
/**
|
|
* Remove any leading slash present on the path.
|
|
*/
|
|
public static function removeLeadingSlash(string $path)
|
|
{
|
|
return mb_ereg_replace('~^/+~', '', $path);
|
|
}
|
|
|
|
/**
|
|
* Get exif data as a JSON object from a Nextcloud file.
|
|
*/
|
|
public static function getExifFromFile(File &$file)
|
|
{
|
|
$path = $file->getStorage()->getLocalFile($file->getInternalPath());
|
|
if (!\is_string($path)) {
|
|
throw new \Exception('Failed to get local file path');
|
|
}
|
|
|
|
$exif = self::getExifFromLocalPath($path);
|
|
|
|
// We need to remove blacklisted fields to prevent leaking info
|
|
unset($exif['SourceFile'], $exif['FileName'], $exif['ExifToolVersion'], $exif['Directory'], $exif['FileSize'], $exif['FileModifyDate'], $exif['FileAccessDate'], $exif['FileInodeChangeDate'], $exif['FilePermissions'], $exif['ThumbnailImage']);
|
|
|
|
// Ignore zero dates
|
|
$dateFields = [
|
|
'DateTimeOriginal',
|
|
'SubSecDateTimeOriginal',
|
|
'CreateDate',
|
|
'ModifyDate',
|
|
'TrackCreateDate',
|
|
'TrackModifyDate',
|
|
'MediaCreateDate',
|
|
'MediaModifyDate',
|
|
];
|
|
foreach ($dateFields as $field) {
|
|
if (\array_key_exists($field, $exif) && \is_string($exif[$field]) && str_starts_with($exif[$field], '0000:00:00')) {
|
|
unset($exif[$field]);
|
|
}
|
|
}
|
|
|
|
return $exif;
|
|
}
|
|
|
|
/** Get exif data as a JSON object from a local file path */
|
|
public static function getExifFromLocalPath(string &$path)
|
|
{
|
|
if (null !== self::$staticProc) {
|
|
self::ensureStaticExiftoolProc();
|
|
|
|
return self::getExifFromLocalPathWithStaticProc($path);
|
|
}
|
|
|
|
return self::getExifFromLocalPathWithSeparateProc($path);
|
|
}
|
|
|
|
/**
|
|
* Parse date from exif format and throw error if invalid.
|
|
*/
|
|
public static function parseExifDate(array $exif): \DateTime
|
|
{
|
|
// Get date from exif
|
|
$exifDate = $exif['SubSecDateTimeOriginal'] ?? $exif['DateTimeOriginal'] ?? $exif['CreateDate'] ?? null;
|
|
if (null === $exifDate || empty($exifDate) || !\is_string($exifDate)) {
|
|
throw new \Exception('No date found in exif');
|
|
}
|
|
|
|
// Get timezone from exif
|
|
try {
|
|
$exifTz = $exif['OffsetTimeOriginal'] ?? $exif['OffsetTime'] ?? $exif['LocationTZID'] ?? null;
|
|
$exifTz = new \DateTimeZone($exifTz);
|
|
} catch (\Error $e) {
|
|
$exifTz = null;
|
|
}
|
|
|
|
// Force UTC if no timezone found
|
|
$parseTz = $exifTz ?? new \DateTimeZone('UTC');
|
|
|
|
// https://github.com/pulsejet/memories/pull/397
|
|
// https://github.com/pulsejet/memories/issues/485
|
|
|
|
$formats = [
|
|
'Y:m:d H:i', // 2023:03:05 18:58
|
|
'Y:m:d H:iO', // 2023:03:05 18:58+05:00
|
|
'Y:m:d H:i:s', // 2023:03:05 18:58:17
|
|
'Y:m:d H:i:sO', // 2023:03:05 10:58:17+05:00
|
|
'Y:m:d H:i:s.u', // 2023:03:05 10:58:17.000
|
|
'Y:m:d H:i:s.uO', // 2023:03:05 10:58:17.000Z
|
|
];
|
|
|
|
/** @var \DateTime $dt */
|
|
$parsedDate = null;
|
|
|
|
foreach ($formats as $format) {
|
|
if ($parsedDate = \DateTime::createFromFormat($format, $exifDate, $parseTz)) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
// If we couldn't parse the date, throw an error
|
|
if (!$parsedDate) {
|
|
throw new \Exception("Invalid date: {$exifDate}");
|
|
}
|
|
|
|
// Filter out dates before 1800 A.D.
|
|
if ($parsedDate->getTimestamp() < -5364662400) { // 1800 A.D.
|
|
throw new \Exception("Date too old: {$exifDate}");
|
|
}
|
|
|
|
// Force the timezone to be the same as parseTz
|
|
if ($exifTz) {
|
|
$parsedDate->setTimezone($exifTz);
|
|
}
|
|
|
|
return $parsedDate;
|
|
}
|
|
|
|
/**
|
|
* Get the date taken from either the file or exif data if available.
|
|
*/
|
|
public static function getDateTaken(File $file, array $exif): \DateTime
|
|
{
|
|
try {
|
|
return self::parseExifDate($exif);
|
|
} catch (\Exception $ex) {
|
|
} catch (\ValueError $ex) {
|
|
}
|
|
|
|
// Fall back to modification time
|
|
try {
|
|
$parseTz = new \DateTimeZone(getenv('TZ')); // debian
|
|
} catch (\Error $e) {
|
|
$parseTz = new \DateTimeZone('UTC');
|
|
}
|
|
|
|
$dt = new \DateTime('@'.$file->getMtime(), $parseTz);
|
|
$dt->setTimezone($parseTz);
|
|
|
|
return self::forgetTimezone($dt);
|
|
}
|
|
|
|
/**
|
|
* Convert time to local date in UTC.
|
|
*/
|
|
public static function forgetTimezone(\DateTime $date): \DateTime
|
|
{
|
|
return new \DateTime($date->format('Y-m-d H:i:s'), new \DateTimeZone('UTC'));
|
|
}
|
|
|
|
/**
|
|
* Get image dimensions from Exif data.
|
|
*
|
|
* @return array [width, height]
|
|
*/
|
|
public static function getDimensions(array &$exif)
|
|
{
|
|
$width = $exif['ImageWidth'] ?? 0;
|
|
$height = $exif['ImageHeight'] ?? 0;
|
|
|
|
// Check if image is rotated and we need to swap width and height
|
|
$rotation = $exif['Rotation'] ?? 0;
|
|
$orientation = $exif['Orientation'] ?? 0;
|
|
if (\in_array($orientation, [5, 6, 7, 8], true) || \in_array($rotation, [90, 270], true)) {
|
|
return [$height, $width];
|
|
}
|
|
|
|
if ($width <= 0 || $height <= 0 || $width > 100000 || $height > 100000) {
|
|
return [0, 0];
|
|
}
|
|
|
|
return [$width, $height];
|
|
}
|
|
|
|
/**
|
|
* Get the list of MIME Types that are allowed to be edited.
|
|
*/
|
|
public static function allowedEditMimetypes(): array
|
|
{
|
|
return array_diff(array_merge(Application::IMAGE_MIMES, Application::VIDEO_MIMES), self::FORBIDDEN_EDIT_MIMES);
|
|
}
|
|
|
|
/**
|
|
* Set exif data using raw json.
|
|
*
|
|
* @param string $path to local file
|
|
* @param array $data exif data
|
|
*
|
|
* @throws \Exception on failure
|
|
*/
|
|
public static function setExif(string $path, array $data)
|
|
{
|
|
$data['SourceFile'] = $path;
|
|
$raw = json_encode([$data]);
|
|
$cmd = array_merge(self::getExiftool(), ['-json=-', $path]);
|
|
$proc = proc_open($cmd, [
|
|
0 => ['pipe', 'r'],
|
|
1 => ['pipe', 'w'],
|
|
2 => ['pipe', 'w'],
|
|
], $pipes);
|
|
|
|
fwrite($pipes[0], $raw);
|
|
fclose($pipes[0]);
|
|
|
|
$stdout = self::readOrTimeout($pipes[1], self::EXIFTOOL_TIMEOUT);
|
|
fclose($pipes[1]);
|
|
fclose($pipes[2]);
|
|
proc_terminate($proc);
|
|
if (false !== strpos($stdout, 'error')) {
|
|
error_log("Exiftool error: {$stdout}");
|
|
|
|
throw new \Exception('Could not set exif data: '.$stdout);
|
|
}
|
|
}
|
|
|
|
public static function setFileExif(File $file, array $data)
|
|
{
|
|
// Get path to local file so we can skip reading
|
|
$path = $file->getStorage()->getLocalFile($file->getInternalPath());
|
|
|
|
// Set exif data
|
|
self::setExif($path, $data);
|
|
|
|
// Update remote file if not local
|
|
if (!$file->getStorage()->isLocal()) {
|
|
$file->putContent(fopen($path, 'r')); // closes the handler
|
|
}
|
|
|
|
// Touch the file, triggering a reprocess through the hook
|
|
$file->touch();
|
|
}
|
|
|
|
public static function getBinaryExifProp(string $path, string $prop)
|
|
{
|
|
$pipes = [];
|
|
$proc = proc_open(array_merge(self::getExiftool(), [$prop, '-n', '-b', $path]), [
|
|
1 => ['pipe', 'w'],
|
|
2 => ['pipe', 'w'],
|
|
], $pipes);
|
|
stream_set_blocking($pipes[1], false);
|
|
|
|
try {
|
|
return self::readOrTimeout($pipes[1], self::EXIFTOOL_TIMEOUT);
|
|
} catch (\Exception $ex) {
|
|
error_log("Exiftool timeout: [{$path}]");
|
|
|
|
throw new \Exception('Could not read from Exiftool');
|
|
} finally {
|
|
fclose($pipes[1]);
|
|
fclose($pipes[2]);
|
|
proc_terminate($proc);
|
|
}
|
|
}
|
|
|
|
public static function getExifWithDuplicates(string $path)
|
|
{
|
|
return self::getExifFromLocalPathWithSeparateProc($path, ['-G4']);
|
|
}
|
|
|
|
private static function getExiftool(): array
|
|
{
|
|
return BinExt::getExiftool();
|
|
}
|
|
|
|
/** Initialize static exiftool process for local reads */
|
|
private static function initializeStaticExiftoolProc()
|
|
{
|
|
self::closeStaticExiftoolProc();
|
|
self::$staticProc = proc_open(array_merge(self::getExiftool(), ['-stay_open', 'true', '-@', '-']), [
|
|
0 => ['pipe', 'r'],
|
|
1 => ['pipe', 'w'],
|
|
2 => ['pipe', 'w'],
|
|
], self::$staticPipes);
|
|
stream_set_blocking(self::$staticPipes[1], false);
|
|
}
|
|
|
|
/**
|
|
* Read from non blocking handle or throw timeout.
|
|
*
|
|
* @param resource $handle
|
|
* @param int $timeout milliseconds
|
|
* @param string $delimiter null for eof
|
|
*/
|
|
private static function readOrTimeout($handle, int $timeout, ?string $delimiter = null)
|
|
{
|
|
$buf = '';
|
|
$waitedMs = 0;
|
|
|
|
while ($waitedMs < $timeout && ($delimiter ? !str_ends_with($buf, $delimiter) : !feof($handle))) {
|
|
$r = stream_get_contents($handle);
|
|
if (empty($r)) {
|
|
++$waitedMs;
|
|
usleep(1000);
|
|
|
|
continue;
|
|
}
|
|
$buf .= $r;
|
|
}
|
|
|
|
if ($waitedMs >= $timeout) {
|
|
throw new \Exception('Timeout');
|
|
}
|
|
|
|
return $buf;
|
|
}
|
|
|
|
private static function getExifFromLocalPathWithStaticProc(string &$path)
|
|
{
|
|
$args = implode("\n", self::EXIFTOOL_ARGS);
|
|
fwrite(self::$staticPipes[0], "{$path}\n{$args}\n-execute\n");
|
|
fflush(self::$staticPipes[0]);
|
|
|
|
$readyToken = "\n{ready}\n";
|
|
|
|
try {
|
|
$buf = self::readOrTimeout(self::$staticPipes[1], self::EXIFTOOL_TIMEOUT, $readyToken);
|
|
$tokPos = strrpos($buf, $readyToken);
|
|
$buf = substr($buf, 0, $tokPos);
|
|
|
|
return self::processStdout($buf);
|
|
} catch (\Exception $ex) {
|
|
error_log("ERROR: Exiftool may have crashed, restarting process [{$path}]");
|
|
self::restartStaticExiftoolProc();
|
|
|
|
throw new \Exception('Nothing to read from Exiftool');
|
|
}
|
|
}
|
|
|
|
private static function getExifFromLocalPathWithSeparateProc(string &$path, array $extraArgs = [])
|
|
{
|
|
$pipes = [];
|
|
$proc = proc_open(array_merge(self::getExiftool(), self::EXIFTOOL_ARGS, $extraArgs, [$path]), [
|
|
1 => ['pipe', 'w'],
|
|
2 => ['pipe', 'w'],
|
|
], $pipes);
|
|
stream_set_blocking($pipes[1], false);
|
|
|
|
try {
|
|
$stdout = self::readOrTimeout($pipes[1], self::EXIFTOOL_TIMEOUT);
|
|
|
|
return self::processStdout($stdout);
|
|
} catch (\Exception $ex) {
|
|
error_log("Exiftool timeout: [{$path}]");
|
|
|
|
throw new \Exception('Could not read from Exiftool');
|
|
} finally {
|
|
fclose($pipes[1]);
|
|
fclose($pipes[2]);
|
|
proc_terminate($proc);
|
|
}
|
|
}
|
|
|
|
/** Get json array from stdout of exiftool */
|
|
private static function processStdout(string &$stdout)
|
|
{
|
|
$json = json_decode($stdout, true);
|
|
if (!$json) {
|
|
throw new \Exception('Could not read exif data');
|
|
}
|
|
|
|
return $json[0];
|
|
}
|
|
}
|