CloudKey.php

<?php

define('CLOUDKEY_SECLEVEL_NONE', 0);
define('CLOUDKEY_SECLEVEL_DELEGATE', 1 << 0);
define('CLOUDKEY_SECLEVEL_ASNUM', 1 << 1);
define('CLOUDKEY_SECLEVEL_IP', 1 << 2);
define('CLOUDKEY_SECLEVEL_USERAGENT', 1 << 3);
define('CLOUDKEY_SECLEVEL_USEONCE', 1 << 4);
define('CLOUDKEY_SECLEVEL_COUNTRY', 1 << 5);
define('CLOUDKEY_SECLEVEL_REFERER', 1 << 6);
define('CLOUDKEY_SECLEVEL_REFERER_STRICT', 1 << 15);

class CloudKey
{
    private
        $objects = array();

    protected
        $user_id = null,
        $api_key = null,
        $base_url = null,
        $cdn_url = null,
        $proxy = null,
        $timeout = 30;

    public function __construct($user_id, $api_key, $base_url = null, $cdn_url = null, $proxy = null, $timeout = 30)
    {
        $this->user_id = $user_id;
        $this->api_key = $api_key;
        $this->base_url = $base_url;
        $this->cdn_url = $cdn_url;
        $this->proxy = $proxy;
        $this->timeout = $timeout;
    }

    public function __get($name)
    {
        if (!isset($this->objects[$name]))
        {
            $class = 'CloudKey_' . ucfirst($name);
            if (!class_exists($class))
            {
                $class = 'CloudKey_Api';
            }
            $this->objects[$name] = new $class($this->user_id, $this->api_key, $this->base_url, $this->cdn_url, $name, $this->proxy, $this->timeout);
            $this->objects[$name]->parent = $this;
        }

        return $this->objects[$name];
    }

}

class CloudKey_Media extends CloudKey_Api
{
    public function get_embed_url($args)
    {
        $id = null;
        $seclevel = CLOUDKEY_SECLEVEL_NONE;
        $expires = null;
        $asnum = null;
        $ip = null;
        $useragent = null;
        $countries = null;
        $referers = null;
        $secure = false;
        extract($args);
        if ($secure == true) {
            $base_url = $this->secure_base_url;
        }
        else {
            $base_url = $this->base_url;
        }
        $url = sprintf('%s/player/embed/%s/%s', $base_url, $this->user_id, $id);
        return CloudKey_Helpers::sign_url($url, $this->api_key, $seclevel, $asnum, $ip, $useragent, $countries, $referers, $expires);
    }

    public function get_swf_url($args)
    {
        $id = null;
        $seclevel = CLOUDKEY_SECLEVEL_NONE;
        $expires = null;
        $asnum = null;
        $ip = null;
        $useragent = null;
        $countries = null;
        $referers = null;
        extract($args);
        $url = sprintf('%s/player/swf/%s/%s', $this->base_url, $this->user_id, $id);
        return CloudKey_Helpers::sign_url($url, $this->api_key, $seclevel, $asnum, $ip, $useragent, $countries, $referers, $expires);
    }

    public function get_stream_url($args)
    {
        $id = null;
        $asset_name = 'mp4_h264_aac';
        $seclevel = CLOUDKEY_SECLEVEL_NONE;
        $expires = null;
        $asnum = null;
        $ip = null;
        $useragent = null;
        $countries = null;
        $referers = null;
        $extension = '';
        $version = '';
        $download = false;
        $filename = '';
        $protocol = null;
        extract($args);
        if (!in_array($protocol, array(null, "hls", "rtmp", "hps", "http", "hds", "ss", "dash"))) {
            throw new CloudKey_InvalidParamException(sprintf('%s is not a valid streaming protocol', $protocol));
        }
        if ($extension == '')
        {
            $parts = explode('_', $asset_name);
            $extension = ($parts[0] != $asset_name) ? $parts[0] : $extension;
        }
        if ($version != '')
        {
            $version = sprintf('-%d', $version);
        }
    	if (strncmp('jpeg_thumbnail_', $asset_name, 15) == 0)
        {
            return sprintf('http://static.dmcloud.net/%s/%s/%s%s.%s', $this->user_id, $id, $asset_name, $version, $extension);
        }

        if ($download or $filename)
        {
            $protocol = 'http';
        }

        if (strpos($asset_name, 'abs') === 0)
        {
            $extension = '';
            if ($protocol == null)
            {
                throw new CloudKey_InvalidParamException('protocol is required for abs asset_name');
            }
        }

        $url = sprintf('%s/route%s/%s/%s/%s%s%s', $this->cdn_url, $protocol ? "/$protocol" : '', $this->user_id, $id, $asset_name, $version, $extension != '' ? ".$extension" : '');
        if ($filename)
        {
            $url = sprintf('%s?filename=%s', $url, urlencode(utf8_encode($filename)));
        }
        return CloudKey_Helpers::sign_url($url, $this->api_key, $seclevel, $asnum, $ip, $useragent, $countries, $referers, $expires);
    }
}

class CloudKey_File extends CloudKey_Api
{
    public function upload_file($file)
    {
        $result = parent::upload();

        $ch = curl_init();

        curl_setopt_array($ch, array
        (
            CURLOPT_URL => $result->url,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HEADER => false,
            CURLOPT_FOLLOWLOCATION => true,
            CURLOPT_CONNECTTIMEOUT => 30,
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => array('file' => new \CURLFile($file)),
        ));

        if ($this->proxy !== null)
        {
            curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
            curl_setopt($ch, CURLOPT_PROXY, $this->proxy);
        }

        $json_response = curl_exec($ch);

        if (curl_errno($ch))
        {
            throw new CloudKey_TransportException(curl_error($ch), curl_errno($ch));
        }

        curl_close($ch);

        return json_decode($json_response);
    }
}

class CloudKey_Api
{
    protected
        $user_id = null,
        $api_key = null,
        $endpoint = null,
        $base_url = 'http://api.dmcloud.net',
        $cdn_url = 'http://cdn.dmcloud.net',
        $object = null,
        $proxy = null,
        $timeout = null;

    public function __construct($user_id, $api_key, $base_url = null, $cdn_url = null, $object = null, $proxy = null, $timeout = 30)
    {
        if ($user_id === null || $api_key === null)
        {
            throw new CloudKey_InvalidParamException('You must provide valid user_id and api_key parameters');
        }

        $this->user_id = $user_id;
        $this->api_key = $api_key;
        $this->proxy = $proxy;
        $this->timeout = $timeout;

        if ($base_url !== null)
        {
            $this->base_url = $base_url;
        }
        $this->secure_base_url = str_replace("http:", "https:", $this->base_url);

        if ($cdn_url !== null)
        {
            $this->cdn_url = $cdn_url;
        }

        if (get_class($this) !== 'CloudKey_Api' && $object === null)
        {
            $this->object = str_replace('cloudkey_', '', strtolower(get_class($this)));
        }
        else
        {
            $this->object = $object;
        }

        $this->endpoint = $this->base_url . '/api';
    }

    public function __call($method, $args)
    {
        if (isset($args[0]))
        {
            if (!is_array($args[0]))
            {
                throw new CloudKey_InvalidMethodException(sprintf('%s requires an array as first argument', $method));
            }
            $args = $args[0];
        }
        else
        {
            unset($args);
        }

        $object = null;
        if (strpos($method, '__') !== FALSE)
        {
            list($object, $method) = explode('__', $method);
        }
        elseif ($this->object !== null)
        {
            $object = $this->object;
        }

        $request = array
        (
            'call' => $object . '.' . $method,
        );

        if (isset($args))
        {
            $request['args'] = $args;
        }

        $request['auth'] = $this->user_id . ':' . md5($this->user_id . CloudKey_Helpers::normalize($request) . $this->api_key);

        $ch = curl_init();

        curl_setopt_array($ch, array
        (
            CURLOPT_URL => $this->endpoint,
            CURLOPT_HTTPHEADER => array('Content-Type: application/json'),
            CURLOPT_POSTFIELDS => json_encode($request),
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_FOLLOWLOCATION => true,
            CURLOPT_CONNECTTIMEOUT => $this->timeout,
            CURLOPT_TIMEOUT => $this->timeout,
            CURLOPT_PROXY => $this->proxy,
        ));

        if ($this->proxy !== null)
        {
            curl_setopt($ch, CURLOPT_PROXY, $this->proxy);
        }

        $json_response = curl_exec($ch);

        if (curl_errno($ch))
        {
            throw new CloudKey_TransportException(curl_error($ch), curl_errno($ch));
        }

        $status_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        $response = json_decode($json_response);

        if ($response === null)
        {
            throw new CloudKey_SerializerException('Cannot unserialize response.');
        }

        if (isset($response->error))
        {
            $error = $response->error;
            if (!isset($error->code))
            {
                throw new CloudKey_RPCException('Invalid error format.');
            }

            $message = isset($error->message) ? $error->message : null;

            switch ($error->code)
            {
                case 200: $e = new CloudKey_ProcessorException($message); break;
                case 300: $e = new CloudKey_TransportException($message); break;
                case 400: $e = new CloudKey_AuthenticationErrorException($message); break;
                case 410: $e = new CloudKey_RateLimitExceededException($message); break;
                case 500: $e = new CloudKey_SerializerException($message); break;

                case 600: $e = new CloudKey_InvalidRequestException($message); break;
                case 610: $e = new CloudKey_InvalidObjectException($message); break;
                case 620: $e = new CloudKey_InvalidMethodException($message); break;
                case 630: $e = new CloudKey_InvalidParamException($message); break;

                case 1000: $e = new CloudKey_ApplicationException($message); break;
                case 1010: $e = new CloudKey_NotFoundException($message); break;
                case 1020: $e = new CloudKey_ExistsException($message); break;
                case 1030: $e = new CloudKey_LimitExceededException($message); break;

                default: $e = new CloudKey_RPCException($message, $error->code); break;
            }

            if (isset($error->data))
            {
                $e->data = $error->data;
            }
            throw $e;
        }
        else
        {
            return isset($response->result) ? $response->result : null;
        }
    }
}


define('DRM_TOKEN_TIMEOUT', 600);

class CloudKey_Helpers
{
  static public function gen_drm_token($user_id, $media_id, $api_key, $rights=null, $meta=null, $callback_url=null, $expires=null, $max_replay=null, $encode=true)
  {
    $info = array(
                 'user_id' => $user_id,
                 'media_id' => $media_id,
                 'expires' => intval($expires == null ? time() + DRM_TOKEN_TIMEOUT : $expires),
                 'nonce' => md5(uniqid(rand(), true)),
                 );

    if ($max_replay != null)
      {
        $info['max_replay'] = $max_replay;
      }
    if ($rights != null)
      {
        $info['rights'] = $rights;
      }
    if ($meta != null)
      {
        $info['meta'] = $meta;
      }
    if ($callback_url != null)
      {
        $info['callback_url'] = $callback_url;
      }

    $info['auth'] = md5(self::normalize($info) . $api_key);

    $payload = json_encode($info);
    if ($encode)
      {
        $payload = strtr(base64_encode($payload), '+/', '-_');
      }
    return $payload;
  }

    static public function normalize($data)
    {
        $normalized = '';

        if (is_array($data))
        {
            if (isset($data[0]))
            {
                foreach ($data as $value)
                {
                    $normalized .= is_array($value) ? self::normalize($value) : (is_bool($value) ? ($value ? 'true' : 'false') : $value);
                }
            }
            else
            {
                ksort($data);
                foreach ($data as $key => $value)
                {
                    $normalized .= $key . (is_array($value) ? self::normalize($value) : (is_bool($value) ? ($value ? 'true' : 'false') : $value));
                }
            }
        }
        else
        {
            $normalized = $data;
        }

        return $normalized;
    }

    static public function sign_url($url, $secret, $seclevel=CLOUDKEY_SECLEVEL_NONE, $asnum=null, $ip=null, $useragent=null, $countries=null, $referers=null, $expires=null)
    {
        // Compute digest
        $expires = intval($expires == null ? time() + 7200 : $expires);
        @list($url, $query) = @explode('?', $url, 2);
        $secparams = '';
        $public_secparams = array();
        if (!($seclevel & CLOUDKEY_SECLEVEL_DELEGATE))
        {
            if ($seclevel & CLOUDKEY_SECLEVEL_ASNUM)
            {
                if (!isset($asnum))
                {
                    throw new InvalidArgumentException('ASNUM security level required and no AS number provided.');
                }
                $secparams .= $asnum;
            }
            if ($seclevel & CLOUDKEY_SECLEVEL_IP)
            {
                if (!isset($ip))
                {
                    throw new InvalidArgumentException('IP security level required and no IP address provided.');
                }
                $secparams .= $ip;
            }
            if ($seclevel & CLOUDKEY_SECLEVEL_USERAGENT)
            {
                if (!isset($useragent))
                {
                    throw new InvalidArgumentException('USERAGENT security level required and no user-agent provided.');
                }
                $secparams .= $useragent;
            }
            if ($seclevel & CLOUDKEY_SECLEVEL_COUNTRY)
            {
                if (!isset($countries) || count($countries) === 0)
                {
                    throw new InvalidArgumentException('COUNTRY security level required and no country list provided.');
                }
                if (!is_array($countries))
                {
                    throw new InvalidArgumentException('Invalid format for COUNTRY, should be an array of country codes.');
                }
                if ($countries[0] === '-')
                {
                    array_shift($countries);
                    $countries = '-' . implode(',', $countries);
                }
                else
                {
                    $countries = implode(',', $countries);
                }
                if (!preg_match('/^-?(?:[a-zA-Z]{2})(?:,[a-zA-Z]{2})*$/', $countries))
                {
                    throw new InvalidArgumentException('Invalid format for COUNTRY security level parameter.');
                }
                $public_secparams[] = 'cc=' . strtolower($countries);
            }
            if ($seclevel & CLOUDKEY_SECLEVEL_REFERER || $seclevel & CLOUDKEY_SECLEVEL_REFERER_STRICT)
            {
                if (!isset($referers) || count($referers) === 0)
                {
                    throw new InvalidArgumentException('REFERER security level required and no referer list provided.');
                }
                if (!array($referers))
                {
                    throw new InvalidArgumentException('Invalid format for REFERER, should be a list of url strings.');
                }
                $public_secparams[] = 'rf=' . urlencode(implode(' ', array_map(create_function('$r', 'return str_replace(" ", "%20", $r);'), $referers)));
            }
        }
        $public_secparams_encoded = '';
        if (count($public_secparams) > 0)
        {
          $public_secparams_encoded = strtr(base64_encode(gzcompress(implode('&', $public_secparams))), '+/', '-_');
        }
        $rand    = '';
        $letters = 'abcdefghijklmnopqrstuvwxyz0123456789';
        for ($i = 0; $i < 8; $i++)
        {
            $rand .= $letters[rand(0, 35)];
        }
        $digest = md5(implode('', array($seclevel, $url, $expires, $rand, $secret, $secparams, $public_secparams_encoded)));

        // Return signed URL
        return sprintf('%s?%sauth=%s-%d-%s-%s%s', $url, ($query ? $query . '&' : ''), $expires, $seclevel, $rand, $digest, ($public_secparams_encoded ? '-' . $public_secparams_encoded : ''));
    }
}

class CloudKey_Exception extends Exception {}
class CloudKey_RPCException extends CloudKey_Exception {public $data = null;}
class CloudKey_ProcessorException extends CloudKey_RPCException {}
class CloudKey_TransportException extends CloudKey_RPCException {}
class CloudKey_SerializerException extends CloudKey_RPCException {}
class CloudKey_AuthenticationErrorException extends CloudKey_RPCException {}
class CloudKey_RateLimitExceededException extends CloudKey_AuthenticationErrorException {}

class CloudKey_InvalidRequestException extends CloudKey_RPCException {}
class CloudKey_InvalidObjectException extends CloudKey_InvalidRequestException {}
class CloudKey_InvalidMethodException extends CloudKey_InvalidRequestException {}
class CloudKey_InvalidParamException extends CloudKey_InvalidRequestException {}

class CloudKey_ApplicationException extends CloudKey_RPCException {}
class CloudKey_NotFoundException extends CloudKey_ApplicationException {}
class CloudKey_ExistsException extends CloudKey_ApplicationException {}
class CloudKey_LimitExceededException extends CloudKey_ApplicationException {}