Phraseanet/lib/classes/databox/status.php

<?php

/*
 * This file is part of Phraseanet
 *
 * (c) 2005-2015 Alchemy
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

use Alchemy\Phrasea\Application;
use Alchemy\Phrasea\SearchEngine\Elastic\RecordHelper;
use Symfony\Component\HttpFoundation\File\UploadedFile;
use Alchemy\Phrasea\Exception\InvalidArgumentException;
use MediaAlchemyst\Specification\Image as ImageSpecification;
use Symfony\Component\HttpFoundation\File\Exception\FileException;
use Alchemy\Phrasea\Model\RecordInterface;

class databox_status
{
    public static function getSearchStatus(Application $app)
    {
        $see_all = $structures = $stats = [];
        foreach ($app['acl']->get($app['authentication']->getUser())->get_granted_sbas() as $databox) {
            $see_all[$databox->get_sbas_id()] = false;
            foreach ($databox->get_collections() as $collection) {
                if ($app['acl']->get($app['authentication']->getUser())->has_right_on_base($collection->get_base_id(), 'chgstatus')) {
                    $see_all[$databox->get_sbas_id()] = true;
                    break;
                }
            }
            $structures[$databox->get_sbas_id()] = $databox->getStatusStructure();
        }

        foreach ($structures as $databox_id => $structure) {
            if (false === $see_all[$databox_id]) {
                $structure = array_filter(function($status) {
                    return (bool) $status['searchable'];
                }, $structure->toArray());
            }

            foreach($structure as $bit => $status) {
                $key = RecordHelper::normalizeFlagKey($status['labelon']);

                if (isset($stats[$key])) {
                    $status = $stats[$key];
                }

                $status['sbas'][] = $databox_id;
                $status['bit'] = $bit;

                $stats[$key] = $status;
            }
        }
        return $stats;
    }

    public static function deleteIcon(Application $app, $databox_id, $bit, $switch)
    {
        $databox = $app['phraseanet.appbox']->get_databox($databox_id);

        $statusStructure = $app['factory.status-structure']->getStructure($databox);

        if (!$statusStructure->hasStatus($bit)) {
            throw new InvalidArgumentException(sprintf('bit %s does not exists on database %s', $bit, $statusStructure->getDatabox()->get_dbname()));
        }

        $status = $statusStructure->getStatus($bit);

        $switch = in_array($switch, ['on', 'off']) ? $switch : false;

        if (!$switch) {
            return false;
        }

        if ($status['img_' . $switch]) {
            if (isset($status['path_' . $switch])) {
                $app['filesystem']->remove($status['path_' . $switch]);
            }

            $status['img_' . $switch] = false;
            unset($status['path_' . $switch]);
        }

        return true;
    }

    public static function updateIcon(Application $app, $databox_id, $bit, $switch, UploadedFile $file)
    {
        $databox = $app['phraseanet.appbox']->get_databox($databox_id);

        $statusStructure = $app['factory.status-structure']->getStructure($databox);

        if (!$statusStructure->hasStatus($bit)) {
            throw new InvalidArgumentException(sprintf('bit %s does not exists', $bit));
        }

        $status = $statusStructure->getStatus($bit);

        $switch = in_array($switch, ['on', 'off']) ? $switch : false;

        if (!$switch) {
            throw new Exception_InvalidArgument();
        }

        $url = $statusStructure->getUrl();
        $path = $statusStructure->getPath();

        if ($file->getSize() >= 65535) {
            throw new Exception_Upload_FileTooBig();
        }

        if ( ! $file->isValid()) {
            throw new Exception_Upload_Error();
        }

        self::deleteIcon($app, $databox_id, $bit, $switch);

        $name = "-stat_" . $bit . "_" . ($switch == 'on' ? '1' : '0') . ".gif";

        try {
            $file = $file->move($app['root.path'] . "/config/status/", $path.$name);
        } catch (FileException $e) {
            throw new Exception_Upload_CannotWriteFile();
        }

        $custom_path = $app['root.path'] . '/www/custom/status/';

        $app['filesystem']->mkdir($custom_path, 0750);

        //resize status icon 16x16px
        $imageSpec = new ImageSpecification();
        $imageSpec->setResizeMode(ImageSpecification::RESIZE_MODE_OUTBOUND);
        $imageSpec->setDimensions(16, 16);

        $filePath = sprintf("%s%s", $path, $name);
        $destPath = sprintf("%s%s", $custom_path, basename($path . $name));

        try {
            $app['media-alchemyst']->turninto($filePath, $destPath, $imageSpec);
        } catch (\MediaAlchemyst\Exception $e) {

        }

        $status['img_' . $switch] = $url . $name;
        $status['path_' . $switch] = $filePath;

        return true;
    }

    public static function operation_and(Application $app, $stat1, $stat2)
    {
        $conn = $app['phraseanet.appbox']->get_connection();

        $status = '0';

        if (substr($stat1, 0, 2) === '0x') {
            $stat1 = self::hex2bin($app, substr($stat1, 2));
        }
        if (substr($stat2, 0, 2) === '0x') {
            $stat2 = self::hex2bin($app, substr($stat2, 2));
        }

        $sql = 'select bin(0b' . trim($stat1) . ' & 0b' . trim($stat2) . ') as result';

        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $row = $stmt->fetch(PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    /**
     * compute ((0 M s1) M s2) where M is the "mask" operator
     * nb : s1,s2 are binary mask strings as "01x0xx1xx0x", no other format (hex) supported
     *
     * @param Application $app
     * @param $stat1 a binary mask "010x1xx0.." STRING
     * @param $stat2 a binary mask "x100x1..." STRING
     *
     * @return binary string
     */
    public static function operation_mask(Application $app, $stat1, $stat2)
    {
        $conn = $app['phraseanet.appbox']->get_connection();

        $status = '0';
        $stat1_or  = '0b' . trim(str_replace("x", "0", $stat1));
        $stat1_and = '0b' . trim(str_replace("x", "1", $stat1));
        $stat2_or  = '0b' . trim(str_replace("x", "0", $stat2));
        $stat2_and = '0b' . trim(str_replace("x", "1", $stat2));

        // $sql = "SELECT BIN(((((0 | :o1) & :a1)) | :o2) & :a2) AS result";
        // $stmt = $conn->prepare($sql);
        // $stmt->execute(array(':o1'=>$stat1_or, ':a1'=>$stat1_and, ':o2'=>$stat2_or, ':a2'=>$stat2_and));

        $sql = "SELECT BIN(((((0 | $stat1_or) & $stat1_and)) | $stat2_or) & $stat2_and) AS result";
        $stmt = $conn->prepare($sql);
        $stmt->execute();

        $row = $stmt->fetch(\PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    public static function operation_and_not(Application $app, $stat1, $stat2)
    {
        $conn = $app['phraseanet.appbox']->get_connection();

        $status = '0';

        if (substr($stat1, 0, 2) === '0x') {
            $stat1 = self::hex2bin($app, substr($stat1, 2));
        }
        if (substr($stat2, 0, 2) === '0x') {
            $stat2 = self::hex2bin($app, substr($stat2, 2));
        }

        $sql = 'select bin(0b' . trim($stat1) . ' & ~0b' . trim($stat2) . ') as result';

        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $row = $stmt->fetch(PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    public static function operation_or(Application $app, $stat1, $stat2)
    {
        $conn = $app['phraseanet.appbox']->get_connection();

        $status = '0';

        if (substr($stat1, 0, 2) === '0x') {
            $stat1 = self::hex2bin($app, substr($stat1, 2));
        }
        if (substr($stat2, 0, 2) === '0x') {
            $stat2 = self::hex2bin($app, substr($stat2, 2));
        }

        $sql = 'select bin(0b' . trim($stat1) . ' | 0b' . trim($stat2) . ') as result';

        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $row = $stmt->fetch(PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    public static function dec2bin(Application $app, $status)
    {
        $status = (string) $status;

        if ( ! ctype_digit($status)) {
            throw new \Exception(sprintf('`%s`is non-decimal value', $status));
        }

        $conn = $app['phraseanet.appbox']->get_connection();

        $sql = 'select bin(' . $status . ') as result';

        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $row = $stmt->fetch(PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        $status = '0';

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    public static function hex2bin(Application $app, $status)
    {
        $status = (string) $status;
        if (substr($status, 0, 2) === '0x') {
            $status = substr($status, 2);
        }

        if ( ! ctype_xdigit($status)) {
            throw new \Exception('Non-hexadecimal value');
        }

        $conn = $app['phraseanet.appbox']->get_connection();

        $sql = 'select BIN( CAST( 0x' . trim($status) . ' AS UNSIGNED ) ) as result';

        $stmt = $conn->prepare($sql);
        $stmt->execute();
        $row = $stmt->fetch(PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        $status = '0';

        if ($row) {
            $status = $row['result'];
        }

        return $status;
    }

    public static function bitIsSet($bitValue, $nthBit)
    {
        return (bool) ($bitValue & (1 << $nthBit));
    }
}