From 72f7b7109d1cdf3ec1f5fb022170dedc8c9dc5e1 Mon Sep 17 00:00:00 2001
From: Heshan <heshan@heidisoft.com>
Date: Fri, 4 Mar 2011 23:20:28 +0530
Subject: Creating presets which can be exported with features, chostools and
move subsidary module to modules directory
---
modules/video_zencoder/includes/LICENSE | 20 +
modules/video_zencoder/includes/README.markdown | 199 ++++++
modules/video_zencoder/includes/Zencoder.php | 240 +++++++
modules/video_zencoder/includes/lib/JSON.php | 805 ++++++++++++++++++++++++
modules/video_zencoder/includes/zencoder.inc | 253 ++++++++
5 files changed, 1517 insertions(+)
create mode 100644 modules/video_zencoder/includes/LICENSE
create mode 100644 modules/video_zencoder/includes/README.markdown
create mode 100644 modules/video_zencoder/includes/Zencoder.php
create mode 100644 modules/video_zencoder/includes/lib/JSON.php
create mode 100644 modules/video_zencoder/includes/zencoder.inc
(limited to 'modules/video_zencoder/includes')
diff --git a/modules/video_zencoder/includes/LICENSE b/modules/video_zencoder/includes/LICENSE
new file mode 100644
index 0000000..d1f0a51
--- /dev/null
+++ b/modules/video_zencoder/includes/LICENSE
@@ -0,0 +1,20 @@
+Copyright (c) 2010 Zencoder
+
+Permission is hereby granted, free of charge, to any person obtaining
+a copy of this software and associated documentation files (the
+"Software"), to deal in the Software without restriction, including
+without limitation the rights to use, copy, modify, merge, publish,
+distribute, sublicense, and/or sell copies of the Software, and to
+permit persons to whom the Software is furnished to do so, subject to
+the following conditions:
+
+The above copyright notice and this permission notice shall be
+included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
diff --git a/modules/video_zencoder/includes/README.markdown b/modules/video_zencoder/includes/README.markdown
new file mode 100644
index 0000000..0be2256
--- /dev/null
+++ b/modules/video_zencoder/includes/README.markdown
@@ -0,0 +1,199 @@
+Zencoder API PHP Library
+==========================
+
+Author: [Steve Heffernan](http://www.steveheffernan.com) (steve (a) zencoder (.) com)
+Company: [Zencoder - Online Video Encoder](http://zencoder.com)
+Version: 1.1
+Date: 2010-06-04
+Repository: <http://github.com/zencoder/zencoder-php/>
+
+For more details on the Zencoder API requirements visit
+<http://zencoder.com/docs/api>
+
+
+ENCODING JOB
+------------
+The ZencoderJob object creates an encoding job using [cURL](http://zencoder.com/docs/glossary/curl/)
+to send [JSON](http://zencoder.com/docs/glossary/json/) formatted parameters to Zencoder's encoding API.
+
+### Step 1
+Visit the [API builder](https://app.zencoder.com/api_builder) in your account,
+and execute a successful encoding job.
+
+### Step 2
+Copy the successful JSON string, starting with the first curly brace "{",
+and pass it as the parameters for a new ZencoderJob object. Execute the script on your server to test that it works.
+
+#### Example
+ <pre>
+ <?php
+
+ // Make sure this points to a copy of Zencoder.php on the same server as this script.
+ require_once("zencoder-php/Zencoder.php");
+
+ // New Encoding Job
+ $encoding_job = new ZencoderJob('
+ {
+ "api_key": "93h630j1dsyshjef620qlkavnmzui3",
+ "input": "s3://bucket-name/file-name.avi"
+ "outputs": [
+ {
+ "label": "web"
+ }
+ ]
+ }
+ ');
+
+ // Check if it worked
+ if ($encoding_job->created) {
+ // Success
+ echo "w00t! \n\n";
+ echo "Job ID: ".$encoding_job->id."\n";
+ echo "Output '".$encoding_job->outputs["web"]->label."' ID: ".$encoding_job->outputs["web"]->id."\n";
+ // Store Job/Output IDs to update their status when notified or to check their progress.
+ } else {
+ // Failed
+ echo "Fail :(\n\n";
+ echo "Errors:\n";
+ foreach($encoding_job->errors as $error) {
+ echo $error."\n";
+ }
+ }
+
+ echo "\nAll Job Attributes:\n";
+ var_dump($encoding_job);
+
+ ?>
+ </pre>
+
+### Step 3
+Modify the above script to meet your needs.
+Your [API Request History](https://app.zencoder.com/api_requests) may come in handy.
+You can revisit your [API builder](https://app.zencoder.com/api_builder) to add/update parameters of the JSON.
+
+You can translate the JSON string into nested associative arrays so that you can dynamically change attributes like "input".
+The previous JSON example would become:
+
+ $encoding_job = new ZencoderJob(array(
+ "api_key" => "93h630j1dsyshjef620qlkavnmzui3",
+ "input" => "s3://bucket-name/file-name.avi",
+ "outputs" => array(
+ array(
+ "label" => "web"
+ )
+ )
+ ));
+
+
+GENERAL API REQUESTS
+--------------------
+A general API request can be used for all API functionality including **Job Listing**, **Job Details**, **Account Creation**, **Account Details** (even Job Creation if desired). See the [API docs](http://zencoder.com/docs/api/) for all possible API requests.
+The first argument is the **API URL**.
+The second argument is your **API Key**.
+The third argument is the **request parameters** if needed. It can either be a JSON string or an array of parameters.
+
+
+#### Example Job List Request
+
+ $request = new ZencoderRequest(
+ 'https://app.zencoder/api/jobs',
+ '93h630j1dsyshjef620qlkavnmzui3'
+ );
+
+ if ($request->successful) {
+ print_r($request->results);
+ } else {
+ foreach($request->errors as $error) {
+ echo $error."\n";
+ }
+ }
+
+#### Example Account Creation Request
+
+ $request = new ZencoderRequest(
+ 'https://app.zencoder/api/account',
+ false, // API key isn't needed for new account creation
+ array(
+ "terms_of_service" => "1",
+ "email" => "test@example.com",
+ "password" => "1234"
+ )
+ );
+
+ if ($request->successful) {
+ print_r($request->results);
+ } else {
+ foreach($request->errors as $error) {
+ echo $error."\n";
+ }
+ }
+
+
+NOTIFICATION HANDLING
+----------------------
+The ZencoderOutputNotification class is used to capture and parse JSON data sent from
+Zencoder to your app when an output file has been completed.
+
+
+
+### Step 1
+Create a script to receive notifications, and upload it to a location on your server that is publicly accessible.
+
+#### Example
+ <?php
+
+ // Make sure this points to a copy of Zencoder.php on the same server as this script.
+ require("Zencoder.php");
+
+ // Catch notification
+ $notification = ZencoderOutputNotification::catch_and_parse();
+
+ // Check output/job state
+ if($notification->output->state == "finished") {
+ echo "w00t!\n";
+
+ // If you're encoding to multiple outputs and only care when all of the outputs are finished
+ // you can check if the entire job is finished.
+ if($notification->job->state == "finished") {
+ echo "Dubble w00t!";
+ }
+ } elseif ($notification->output->state == "cancelled") {
+ echo "Cancelled!\n";
+ } else {
+ echo "Fail!\n";
+ echo $notification->output->error_message."\n";
+ echo $notification->output->error_link;
+ }
+
+ ?>
+
+### Step 2
+In the parameters for an encoding job, add the URL for your script to the notifications array of each output you want to be notified for.
+Then submit the job to test if it works.
+
+**You can view the results at:**
+<https://app.zencoder.com/notifications>
+
+#### Example
+ ...
+ "outputs" => array(
+ array(
+ "label" => "web",
+ "notifications" => array("http://example.com.com/encoding/notification.php")
+ ),
+ array(
+ "label" => "iPhone",
+ "notifications" => array("http://example.com.com/encoding/notification.php")
+ )
+ )
+ ...
+
+
+### Step 3
+Modify the above script to meet your needs.
+Your [notifications page](https://app.zencoder.com/notifications) will come in handy.
+
+VERSIONS
+---------
+ Version 1.1 - 2010-06-04 Added General API Requests
+ Version 1.0 - 2010-04-02 Jobs and Notifications.
\ No newline at end of file
diff --git a/modules/video_zencoder/includes/Zencoder.php b/modules/video_zencoder/includes/Zencoder.php
new file mode 100644
index 0000000..4ff0db7
--- /dev/null
+++ b/modules/video_zencoder/includes/Zencoder.php
@@ -0,0 +1,240 @@
+<?php
+/*
+
+ Zencoder API PHP Library
+ Version: 1.0
+ See the README file for info on how to use this library.
+
+*/
+define('ZENCODER_LIBRARY_NAME', "ZencoderPHP");
+define('ZENCODER_LIBRARY_VERSION', "1.0");
+
+// Add JSON functions for PHP < 5.2.0
+if(!function_exists('json_encode')) {
+ require_once('lib/JSON.php');
+ $GLOBALS['JSON_OBJECT'] = new Services_JSON(SERVICES_JSON_LOOSE_TYPE);
+ function json_encode($value) { return $GLOBALS['JSON_OBJECT']->encode($value); }
+ function json_decode($value) { return $GLOBALS['JSON_OBJECT']->decode($value); }
+}
+
+class ZencoderJob {
+
+ var $new_job_url = "https://app.zencoder.com/api/jobs"; //https://app.zencoder.com/api/jobs
+ //https://zencoder-staging.heroku.com/api/jobs
+ var $new_job_params = array();
+ var $new_job_json;
+ var $created = false;
+ var $errors = array();
+
+ // Attributes
+ var $id;
+ var $outputs = array();
+
+ // Initialize
+ function ZencoderJob($params, $options = array()) {
+
+ // Build using params if not sending request
+ if($options["build"]) {
+ $this->update_attributes($params);
+ return true;
+ }
+
+ $this->new_job_params = $params;
+ $this->created = $this->create();
+ }
+
+ // Send Job Request to API
+ function create() {
+ // Send request
+ $request = new ZencoderRequest($this->new_job_url, false, $this->new_job_params);
+
+ if($request->successful) {
+ $this->update_attributes($request->results);
+ return true;
+ } else {
+ $this->errors = array_merge($this->errors, $request->errors);
+ return false;
+ }
+ }
+
+ // Add/Update attributes on the job object.
+ function update_attributes($attributes = array()) {
+ foreach($attributes as $attr_name => $attr_value) {
+ // Create output file objects
+ if($attr_name == "outputs" && is_array($attr_value)) {
+ $this->create_outputs($attr_value);
+ } elseif (!function_exists($this->$attr_name)) {
+ $this->$attr_name = $attr_value;
+ }
+ }
+ }
+
+ // Create output file objects from returned parameters.
+ // Use the Label for the key if avaiable.
+ function create_outputs($outputs = array()) {
+ foreach($outputs as $output_attrs) {
+ if($output_attrs["label"]) {
+ $this->outputs[$output_attrs["label"]] = new ZencoderOutputFile($output_attrs);
+ } else {
+ $this->outputs[] = new ZencoderOutputFile($output_attrs);
+ }
+ }
+ }
+}
+
+class ZencoderOutputFile {
+
+ var $id;
+ var $label;
+ var $url;
+ var $state;
+ var $error_message;
+ var $error_link;
+
+ function ZencoderOutputFile($attributes = array()) {
+ $this->update_attributes($attributes);
+ }
+
+ // Add/Update attributes on the file object.
+ function update_attributes($attributes = array()) {
+ foreach($attributes as $attr_name => $attr_value) {
+ if(!function_exists($this->$attr_name)) {
+ $this->$attr_name = $attr_value;
+ }
+ }
+ }
+}
+
+// General API request class
+class ZencoderRequest {
+
+ var $successful = false;
+ var $errors = array();
+ var $raw_results;
+ var $results;
+
+ function ZencoderRequest($url, $api_key = "", $params = "") {
+
+ // Add api_key to url if supplied
+ if($api_key) {
+ $url .= "?api_key=".$api_key;
+ }
+
+ // Get JSON
+ if(is_string($params)) {
+ $json = trim($params);
+ } else if(is_array($params)) {
+ $json = json_encode($params);
+ } else {
+ $json = false;
+ }
+
+ // Create request
+ $request = new ZencoderCURL($url, $json);
+
+ // Check for connection errors
+ if ($request->connected == false) {
+ $this->errors[] = $request->error;
+ return;
+ }
+
+ $status_code = intval($request->status_code);
+ $this->raw_results = $request->results;
+
+ // Parse returned JSON
+ $this->results = json_decode($this->raw_results, true);
+
+ // Return based on HTTP status code
+ if($status_code >= 200 && $status_code <= 206) {
+ $this->successful = true;
+ } else {
+ // Get job request errors if any
+ if(is_array($this->results["errors"])) {
+ foreach($this->results["errors"] as $error) {
+ $this->errors[] = $error;
+ }
+ } else {
+ $this->errors[] = "Unknown Error\n\nHTTP Status Code: ".$request->status_code."\n"."Raw Results: \n".$request->raw_results;
+ }
+ }
+ }
+}
+
+// ZencoderCURL
+// The connection class to perform the actual request to the surver
+// using cURL http://php.net/manual/en/book.curl.php
+class ZencoderCURL {
+
+ var $options = array(
+ CURLOPT_RETURNTRANSFER => 1, // Return content of the url
+ CURLOPT_HEADER => 0, // Don't return the header in result
+ CURLOPT_HTTPHEADER => array("Content-Type: application/json", "Accept: application/json"),
+ CURLOPT_CONNECTTIMEOUT => 0, // Time in seconds to timeout send request. 0 is no timeout.
+ CURLOPT_FOLLOWLOCATION => 1, // Follow redirects.
+ );
+
+ var $connected;
+ var $results;
+ var $status_code;
+ var $error;
+
+ // Initialize
+ function ZencoderCURL($url, $json, $options = array()) {
+
+ // Add library details to request
+ $this->options[CURLOPT_HTTPHEADER][] = "Zencoder-Library-Name: ".ZENCODER_LIBRARY_NAME;
+ $this->options[CURLOPT_HTTPHEADER][] = "Zencoder-Library-Version: ".ZENCODER_LIBRARY_VERSION;
+
+ // If posting data
+ if($json) {
+ $this->options[CURLOPT_POST] = 1;
+ $this->options[CURLOPT_POSTFIELDS] = $json;
+ }
+
+ // Add cURL options to defaults (can't use array_merge)
+ foreach($options as $option_key => $option) {
+ $this->options[$option_key] = $option;
+ }
+
+ // Initialize session
+ $ch = curl_init($url);
+
+ // Set transfer options
+ curl_setopt_array($ch, $this->options);
+ curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
+
+ // Execute session and store returned results
+ $this->results = curl_exec($ch);
+
+ // Store the HTTP status code given (201, 404, etc.)
+ $this->status_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+
+ // Check for cURL error
+ if (curl_errno($ch)) {
+ $this->error = 'cURL connection error ('.curl_errno($ch).'): '.htmlspecialchars(curl_error($ch)).' <a href="http://www.google.com/search?q='.urlencode("curl error ".curl_error($ch)).'">Search</a>';
+ $this->connected = false;
+ } else {
+ $this->connected = true;
+ }
+
+ // Close session
+ curl_close($ch);
+ }
+}
+
+// Capture incoming notifications from Zencoder to your app
+class ZencoderOutputNotification {
+
+ var $output;
+ var $job;
+
+ function ZencoderOutputNotification($params) {
+ if($params["output"]) $this->output = new ZencoderOutputFile($params["output"]);
+ if($params["job"]) $this->job = new ZencoderJob($params["job"], array("build" => true));
+ }
+
+ function catch_and_parse() {
+ $notificiation_data = json_decode(trim(file_get_contents('php://input')), true);
+ return new ZencoderOutputNotification($notificiation_data);
+ }
+}
diff --git a/modules/video_zencoder/includes/lib/JSON.php b/modules/video_zencoder/includes/lib/JSON.php
new file mode 100644
index 0000000..f36a203
--- /dev/null
+++ b/modules/video_zencoder/includes/lib/JSON.php
@@ -0,0 +1,805 @@
+<?php
+/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */
+
+/**
+ * Converts to and from JSON format.
+ *
+ * JSON (JavaScript Object Notation) is a lightweight data-interchange
+ * format. It is easy for humans to read and write. It is easy for machines
+ * to parse and generate. It is based on a subset of the JavaScript
+ * Programming Language, Standard ECMA-262 3rd Edition - December 1999.
+ * This feature can also be found in Python. JSON is a text format that is
+ * completely language independent but uses conventions that are familiar
+ * to programmers of the C-family of languages, including C, C++, C#, Java,
+ * JavaScript, Perl, TCL, and many others. These properties make JSON an
+ * ideal data-interchange language.
+ *
+ * This package provides a simple encoder and decoder for JSON notation. It
+ * is intended for use with client-side Javascript applications that make
+ * use of HTTPRequest to perform server communication functions - data can
+ * be encoded into JSON notation for use in a client-side javascript, or
+ * decoded from incoming Javascript requests. JSON format is native to
+ * Javascript, and can be directly eval()'ed with no further parsing
+ * overhead
+ *
+ * All strings should be in ASCII or UTF-8 format!
+ *
+ * LICENSE: Redistribution and use in source and binary forms, with or
+ * without modification, are permitted provided that the following
+ * conditions are met: Redistributions of source code must retain the
+ * above copyright notice, this list of conditions and the following
+ * disclaimer. Redistributions in binary form must reproduce the above
+ * copyright notice, this list of conditions and the following disclaimer
+ * in the documentation and/or other materials provided with the
+ * distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
+ * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN
+ * NO EVENT SHALL CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+ * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
+ * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR
+ * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
+ * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
+ * DAMAGE.
+ *
+ * @category
+ * @package Services_JSON
+ * @author Michal Migurski <mike-json@teczno.com>
+ * @author Matt Knapp <mdknapp[at]gmail[dot]com>
+ * @author Brett Stimmerman <brettstimmerman[at]gmail[dot]com>
+ * @copyright 2005 Michal Migurski
+ * @license http://www.opensource.org/licenses/bsd-license.php
+ * @link http://pear.php.net/pepr/pepr-proposal-show.php?id=198
+ */
+
+/**
+ * Marker constant for Services_JSON::decode(), used to flag stack state
+ */
+define('SERVICES_JSON_SLICE', 1);
+
+/**
+ * Marker constant for Services_JSON::decode(), used to flag stack state
+ */
+define('SERVICES_JSON_IN_STR', 2);
+
+/**
+ * Marker constant for Services_JSON::decode(), used to flag stack state
+ */
+define('SERVICES_JSON_IN_ARR', 3);
+
+/**
+ * Marker constant for Services_JSON::decode(), used to flag stack state
+ */
+define('SERVICES_JSON_IN_OBJ', 4);
+
+/**
+ * Marker constant for Services_JSON::decode(), used to flag stack state
+ */
+define('SERVICES_JSON_IN_CMT', 5);
+
+/**
+ * Behavior switch for Services_JSON::decode()
+ */
+define('SERVICES_JSON_LOOSE_TYPE', 16);
+
+/**
+ * Behavior switch for Services_JSON::decode()
+ */
+define('SERVICES_JSON_SUPPRESS_ERRORS', 32);
+
+/**
+ * Converts to and from JSON format.
+ *
+ * Brief example of use:
+ *
+ * <code>
+ * // create a new instance of Services_JSON
+ * $json = new Services_JSON();
+ *
+ * // convert a complexe value to JSON notation, and send it to the browser
+ * $value = array('foo', 'bar', array(1, 2, 'baz'), array(3, array(4)));
+ * $output = $json->encode($value);
+ *
+ * print($output);
+ * // prints: ["foo","bar",[1,2,"baz"],[3,[4]]]
+ *
+ * // accept incoming POST data, assumed to be in JSON notation
+ * $input = file_get_contents('php://input', 1000000);
+ * $value = $json->decode($input);
+ * </code>
+ */
+class Services_JSON
+{
+ /**
+ * constructs a new JSON instance
+ *
+ * @param int $use object behavior flags; combine with boolean-OR
+ *
+ * possible values:
+ * - SERVICES_JSON_LOOSE_TYPE: loose typing.
+ * "{...}" syntax creates associative arrays
+ * instead of objects in decode().
+ * - SERVICES_JSON_SUPPRESS_ERRORS: error suppression.
+ * Values which can't be encoded (e.g. resources)
+ * appear as NULL instead of throwing errors.
+ * By default, a deeply-nested resource will
+ * bubble up with an error, so all return values
+ * from encode() should be checked with isError()
+ */
+ function Services_JSON($use = 0)
+ {
+ $this->use = $use;
+ }
+
+ /**
+ * convert a string from one UTF-16 char to one UTF-8 char
+ *
+ * Normally should be handled by mb_convert_encoding, but
+ * provides a slower PHP-only method for installations
+ * that lack the multibye string extension.
+ *
+ * @param string $utf16 UTF-16 character
+ * @return string UTF-8 character
+ * @access private
+ */
+ function utf162utf8($utf16)
+ {
+ // oh please oh please oh please oh please oh please
+ if(function_exists('mb_convert_encoding')) {
+ return mb_convert_encoding($utf16, 'UTF-8', 'UTF-16');
+ }
+
+ $bytes = (ord($utf16{0}) << 8) | ord($utf16{1});
+
+ switch(true) {
+ case ((0x7F & $bytes) == $bytes):
+ // this case should never be reached, because we are in ASCII range
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return chr(0x7F & $bytes);
+
+ case (0x07FF & $bytes) == $bytes:
+ // return a 2-byte UTF-8 character
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return chr(0xC0 | (($bytes >> 6) & 0x1F))
+ . chr(0x80 | ($bytes & 0x3F));
+
+ case (0xFFFF & $bytes) == $bytes:
+ // return a 3-byte UTF-8 character
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return chr(0xE0 | (($bytes >> 12) & 0x0F))
+ . chr(0x80 | (($bytes >> 6) & 0x3F))
+ . chr(0x80 | ($bytes & 0x3F));
+ }
+
+ // ignoring UTF-32 for now, sorry
+ return '';
+ }
+
+ /**
+ * convert a string from one UTF-8 char to one UTF-16 char
+ *
+ * Normally should be handled by mb_convert_encoding, but
+ * provides a slower PHP-only method for installations
+ * that lack the multibye string extension.
+ *
+ * @param string $utf8 UTF-8 character
+ * @return string UTF-16 character
+ * @access private
+ */
+ function utf82utf16($utf8)
+ {
+ // oh please oh please oh please oh please oh please
+ if(function_exists('mb_convert_encoding')) {
+ return mb_convert_encoding($utf8, 'UTF-16', 'UTF-8');
+ }
+
+ switch(strlen($utf8)) {
+ case 1:
+ // this case should never be reached, because we are in ASCII range
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return $utf8;
+
+ case 2:
+ // return a UTF-16 character from a 2-byte UTF-8 char
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return chr(0x07 & (ord($utf8{0}) >> 2))
+ . chr((0xC0 & (ord($utf8{0}) << 6))
+ | (0x3F & ord($utf8{1})));
+
+ case 3:
+ // return a UTF-16 character from a 3-byte UTF-8 char
+ // see: http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ return chr((0xF0 & (ord($utf8{0}) << 4))
+ | (0x0F & (ord($utf8{1}) >> 2)))
+ . chr((0xC0 & (ord($utf8{1}) << 6))
+ | (0x7F & ord($utf8{2})));
+ }
+
+ // ignoring UTF-32 for now, sorry
+ return '';
+ }
+
+ /**
+ * encodes an arbitrary variable into JSON format
+ *
+ * @param mixed $var any number, boolean, string, array, or object to be encoded.
+ * see argument 1 to Services_JSON() above for array-parsing behavior.
+ * if var is a strng, note that encode() always expects it
+ * to be in ASCII or UTF-8 format!
+ *
+ * @return mixed JSON string representation of input var or an error if a problem occurs
+ * @access public
+ */
+ function encode($var)
+ {
+ switch (gettype($var)) {
+ case 'boolean':
+ return $var ? 'true' : 'false';
+
+ case 'NULL':
+ return 'null';
+
+ case 'integer':
+ return (int) $var;
+
+ case 'double':
+ case 'float':
+ return (float) $var;
+
+ case 'string':
+ // STRINGS ARE EXPECTED TO BE IN ASCII OR UTF-8 FORMAT
+ $ascii = '';
+ $strlen_var = strlen($var);
+
+ /*
+ * Iterate over every character in the string,
+ * escaping with a slash or encoding to UTF-8 where necessary
+ */
+ for ($c = 0; $c < $strlen_var; ++$c) {
+
+ $ord_var_c = ord($var{$c});
+
+ switch (true) {
+ case $ord_var_c == 0x08:
+ $ascii .= '\b';
+ break;
+ case $ord_var_c == 0x09:
+ $ascii .= '\t';
+ break;
+ case $ord_var_c == 0x0A:
+ $ascii .= '\n';
+ break;
+ case $ord_var_c == 0x0C:
+ $ascii .= '\f';
+ break;
+ case $ord_var_c == 0x0D:
+ $ascii .= '\r';
+ break;
+
+ case $ord_var_c == 0x22:
+ case $ord_var_c == 0x2F:
+ case $ord_var_c == 0x5C:
+ // double quote, slash, slosh
+ $ascii .= '\\'.$var{$c};
+ break;
+
+ case (($ord_var_c >= 0x20) && ($ord_var_c <= 0x7F)):
+ // characters U-00000000 - U-0000007F (same as ASCII)
+ $ascii .= $var{$c};
+ break;
+
+ case (($ord_var_c & 0xE0) == 0xC0):
+ // characters U-00000080 - U-000007FF, mask 110XXXXX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $char = pack('C*', $ord_var_c, ord($var{$c + 1}));
+ $c += 1;
+ $utf16 = $this->utf82utf16($char);
+ $ascii .= sprintf('\u%04s', bin2hex($utf16));
+ break;
+
+ case (($ord_var_c & 0xF0) == 0xE0):
+ // characters U-00000800 - U-0000FFFF, mask 1110XXXX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $char = pack('C*', $ord_var_c,
+ ord($var{$c + 1}),
+ ord($var{$c + 2}));
+ $c += 2;
+ $utf16 = $this->utf82utf16($char);
+ $ascii .= sprintf('\u%04s', bin2hex($utf16));
+ break;
+
+ case (($ord_var_c & 0xF8) == 0xF0):
+ // characters U-00010000 - U-001FFFFF, mask 11110XXX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $char = pack('C*', $ord_var_c,
+ ord($var{$c + 1}),
+ ord($var{$c + 2}),
+ ord($var{$c + 3}));
+ $c += 3;
+ $utf16 = $this->utf82utf16($char);
+ $ascii .= sprintf('\u%04s', bin2hex($utf16));
+ break;
+
+ case (($ord_var_c & 0xFC) == 0xF8):
+ // characters U-00200000 - U-03FFFFFF, mask 111110XX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $char = pack('C*', $ord_var_c,
+ ord($var{$c + 1}),
+ ord($var{$c + 2}),
+ ord($var{$c + 3}),
+ ord($var{$c + 4}));
+ $c += 4;
+ $utf16 = $this->utf82utf16($char);
+ $ascii .= sprintf('\u%04s', bin2hex($utf16));
+ break;
+
+ case (($ord_var_c & 0xFE) == 0xFC):
+ // characters U-04000000 - U-7FFFFFFF, mask 1111110X
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $char = pack('C*', $ord_var_c,
+ ord($var{$c + 1}),
+ ord($var{$c + 2}),
+ ord($var{$c + 3}),
+ ord($var{$c + 4}),
+ ord($var{$c + 5}));
+ $c += 5;
+ $utf16 = $this->utf82utf16($char);
+ $ascii .= sprintf('\u%04s', bin2hex($utf16));
+ break;
+ }
+ }
+
+ return '"'.$ascii.'"';
+
+ case 'array':
+ /*
+ * As per JSON spec if any array key is not an integer
+ * we must treat the the whole array as an object. We
+ * also try to catch a sparsely populated associative
+ * array with numeric keys here because some JS engines
+ * will create an array with empty indexes up to
+ * max_index which can cause memory issues and because
+ * the keys, which may be relevant, will be remapped
+ * otherwise.
+ *
+ * As per the ECMA and JSON specification an object may
+ * have any string as a property. Unfortunately due to
+ * a hole in the ECMA specification if the key is a
+ * ECMA reserved word or starts with a digit the
+ * parameter is only accessible using ECMAScript's
+ * bracket notation.
+ */
+
+ // treat as a JSON object
+ if (is_array($var) && count($var) && (array_keys($var) !== range(0, sizeof($var) - 1))) {
+ $properties = array_map(array($this, 'name_value'),
+ array_keys($var),
+ array_values($var));
+
+ foreach($properties as $property) {
+ if(Services_JSON::isError($property)) {
+ return $property;
+ }
+ }
+
+ return '{' . join(',', $properties) . '}';
+ }
+
+ // treat it like a regular array
+ $elements = array_map(array($this, 'encode'), $var);
+
+ foreach($elements as $element) {
+ if(Services_JSON::isError($element)) {
+ return $element;
+ }
+ }
+
+ return '[' . join(',', $elements) . ']';
+
+ case 'object':
+ $vars = get_object_vars($var);
+
+ $properties = array_map(array($this, 'name_value'),
+ array_keys($vars),
+ array_values($vars));
+
+ foreach($properties as $property) {
+ if(Services_JSON::isError($property)) {
+ return $property;
+ }
+ }
+
+ return '{' . join(',', $properties) . '}';
+
+ default:
+ return ($this->use & SERVICES_JSON_SUPPRESS_ERRORS)
+ ? 'null'
+ : new Services_JSON_Error(gettype($var)." can not be encoded as JSON string");
+ }
+ }
+
+ /**
+ * array-walking function for use in generating JSON-formatted name-value pairs
+ *
+ * @param string $name name of key to use
+ * @param mixed $value reference to an array element to be encoded
+ *
+ * @return string JSON-formatted name-value pair, like '"name":value'
+ * @access private
+ */
+ function name_value($name, $value)
+ {
+ $encoded_value = $this->encode($value);
+
+ if(Services_JSON::isError($encoded_value)) {
+ return $encoded_value;
+ }
+
+ return $this->encode(strval($name)) . ':' . $encoded_value;
+ }
+
+ /**
+ * reduce a string by removing leading and trailing comments and whitespace
+ *
+ * @param $str string string value to strip of comments and whitespace
+ *
+ * @return string string value stripped of comments and whitespace
+ * @access private
+ */
+ function reduce_string($str)
+ {
+ $str = preg_replace(array(
+
+ // eliminate single line comments in '// ...' form
+ '#^\s*//(.+)$#m',
+
+ // eliminate multi-line comments in '/* ... */' form, at start of string
+ '#^\s*/\*(.+)\*/#Us',
+
+ // eliminate multi-line comments in '/* ... */' form, at end of string
+ '#/\*(.+)\*/\s*$#Us'
+
+ ), '', $str);
+
+ // eliminate extraneous space
+ return trim($str);
+ }
+
+ /**
+ * decodes a JSON string into appropriate variable
+ *
+ * @param string $str JSON-formatted string
+ *
+ * @return mixed number, boolean, string, array, or object
+ * corresponding to given JSON input string.
+ * See argument 1 to Services_JSON() above for object-output behavior.
+ * Note that decode() always returns strings
+ * in ASCII or UTF-8 format!
+ * @access public
+ */
+ function decode($str)
+ {
+ $str = $this->reduce_string($str);
+
+ switch (strtolower($str)) {
+ case 'true':
+ return true;
+
+ case 'false':
+ return false;
+
+ case 'null':
+ return null;
+
+ default:
+ $m = array();
+
+ if (is_numeric($str)) {
+ // Lookie-loo, it's a number
+
+ // This would work on its own, but I'm trying to be
+ // good about returning integers where appropriate:
+ // return (float)$str;
+
+ // Return float or int, as appropriate
+ return ((float)$str == (integer)$str)
+ ? (integer)$str
+ : (float)$str;
+
+ } elseif (preg_match('/^("|\').*(\1)$/s', $str, $m) && $m[1] == $m[2]) {
+ // STRINGS RETURNED IN UTF-8 FORMAT
+ $delim = substr($str, 0, 1);
+ $chrs = substr($str, 1, -1);
+ $utf8 = '';
+ $strlen_chrs = strlen($chrs);
+
+ for ($c = 0; $c < $strlen_chrs; ++$c) {
+
+ $substr_chrs_c_2 = substr($chrs, $c, 2);
+ $ord_chrs_c = ord($chrs{$c});
+
+ switch (true) {
+ case $substr_chrs_c_2 == '\b':
+ $utf8 .= chr(0x08);
+ ++$c;
+ break;
+ case $substr_chrs_c_2 == '\t':
+ $utf8 .= chr(0x09);
+ ++$c;
+ break;
+ case $substr_chrs_c_2 == '\n':
+ $utf8 .= chr(0x0A);
+ ++$c;
+ break;
+ case $substr_chrs_c_2 == '\f':
+ $utf8 .= chr(0x0C);
+ ++$c;
+ break;
+ case $substr_chrs_c_2 == '\r':
+ $utf8 .= chr(0x0D);
+ ++$c;
+ break;
+
+ case $substr_chrs_c_2 == '\\"':
+ case $substr_chrs_c_2 == '\\\'':
+ case $substr_chrs_c_2 == '\\\\':
+ case $substr_chrs_c_2 == '\\/':
+ if (($delim == '"' && $substr_chrs_c_2 != '\\\'') ||
+ ($delim == "'" && $substr_chrs_c_2 != '\\"')) {
+ $utf8 .= $chrs{++$c};
+ }
+ break;
+
+ case preg_match('/\\\u[0-9A-F]{4}/i', substr($chrs, $c, 6)):
+ // single, escaped unicode character
+ $utf16 = chr(hexdec(substr($chrs, ($c + 2), 2)))
+ . chr(hexdec(substr($chrs, ($c + 4), 2)));
+ $utf8 .= $this->utf162utf8($utf16);
+ $c += 5;
+ break;
+
+ case ($ord_chrs_c >= 0x20) && ($ord_chrs_c <= 0x7F):
+ $utf8 .= $chrs{$c};
+ break;
+
+ case ($ord_chrs_c & 0xE0) == 0xC0:
+ // characters U-00000080 - U-000007FF, mask 110XXXXX
+ //see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $utf8 .= substr($chrs, $c, 2);
+ ++$c;
+ break;
+
+ case ($ord_chrs_c & 0xF0) == 0xE0:
+ // characters U-00000800 - U-0000FFFF, mask 1110XXXX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $utf8 .= substr($chrs, $c, 3);
+ $c += 2;
+ break;
+
+ case ($ord_chrs_c & 0xF8) == 0xF0:
+ // characters U-00010000 - U-001FFFFF, mask 11110XXX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $utf8 .= substr($chrs, $c, 4);
+ $c += 3;
+ break;
+
+ case ($ord_chrs_c & 0xFC) == 0xF8:
+ // characters U-00200000 - U-03FFFFFF, mask 111110XX
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $utf8 .= substr($chrs, $c, 5);
+ $c += 4;
+ break;
+
+ case ($ord_chrs_c & 0xFE) == 0xFC:
+ // characters U-04000000 - U-7FFFFFFF, mask 1111110X
+ // see http://www.cl.cam.ac.uk/~mgk25/unicode.html#utf-8
+ $utf8 .= substr($chrs, $c, 6);
+ $c += 5;
+ break;
+
+ }
+
+ }
+
+ return $utf8;
+
+ } elseif (preg_match('/^\[.*\]$/s', $str) || preg_match('/^\{.*\}$/s', $str)) {
+ // array, or object notation
+
+ if ($str{0} == '[') {
+ $stk = array(SERVICES_JSON_IN_ARR);
+ $arr = array();
+ } else {
+ if ($this->use & SERVICES_JSON_LOOSE_TYPE) {
+ $stk = array(SERVICES_JSON_IN_OBJ);
+ $obj = array();
+ } else {
+ $stk = array(SERVICES_JSON_IN_OBJ);
+ $obj = new stdClass();
+ }
+ }
+
+ array_push($stk, array('what' => SERVICES_JSON_SLICE,
+ 'where' => 0,
+ 'delim' => false));
+
+ $chrs = substr($str, 1, -1);
+ $chrs = $this->reduce_string($chrs);
+
+ if ($chrs == '') {
+ if (reset($stk) == SERVICES_JSON_IN_ARR) {
+ return $arr;
+
+ } else {
+ return $obj;
+
+ }
+ }
+
+ //print("\nparsing {$chrs}\n");
+
+ $strlen_chrs = strlen($chrs);
+
+ for ($c = 0; $c <= $strlen_chrs; ++$c) {
+
+ $top = end($stk);
+ $substr_chrs_c_2 = substr($chrs, $c, 2);
+
+ if (($c == $strlen_chrs) || (($chrs{$c} == ',') && ($top['what'] == SERVICES_JSON_SLICE))) {
+ // found a comma that is not inside a string, array, etc.,
+ // OR we've reached the end of the character list
+ $slice = substr($chrs, $top['where'], ($c - $top['where']));
+ array_push($stk, array('what' => SERVICES_JSON_SLICE, 'where' => ($c + 1), 'delim' => false));
+ //print("Found split at {$c}: ".substr($chrs, $top['where'], (1 + $c - $top['where']))."\n");
+
+ if (reset($stk) == SERVICES_JSON_IN_ARR) {
+ // we are in an array, so just push an element onto the stack
+ array_push($arr, $this->decode($slice));
+
+ } elseif (reset($stk) == SERVICES_JSON_IN_OBJ) {
+ // we are in an object, so figure
+ // out the property name and set an
+ // element in an associative array,
+ // for now
+ $parts = array();
+
+ if (preg_match('/^\s*(["\'].*[^\\\]["\'])\s*:\s*(\S.*),?$/Uis', $slice, $parts)) {
+ // "name":value pair
+ $key = $this->decode($parts[1]);
+ $val = $this->decode($parts[2]);
+
+ if ($this->use & SERVICES_JSON_LOOSE_TYPE) {
+ $obj[$key] = $val;
+ } else {
+ $obj->$key = $val;
+ }
+ } elseif (preg_match('/^\s*(\w+)\s*:\s*(\S.*),?$/Uis', $slice, $parts)) {
+ // name:value pair, where name is unquoted
+ $key = $parts[1];
+ $val = $this->decode($parts[2]);
+
+ if ($this->use & SERVICES_JSON_LOOSE_TYPE) {
+ $obj[$key] = $val;
+ } else {
+ $obj->$key = $val;
+ }
+ }
+
+ }
+
+ } elseif ((($chrs{$c} == '"') || ($chrs{$c} == "'")) && ($top['what'] != SERVICES_JSON_IN_STR)) {
+ // found a quote, and we are not inside a string
+ array_push($stk, array('what' => SERVICES_JSON_IN_STR, 'where' => $c, 'delim' => $chrs{$c}));
+ //print("Found start of string at {$c}\n");
+
+ } elseif (($chrs{$c} == $top['delim']) &&
+ ($top['what'] == SERVICES_JSON_IN_STR) &&
+ ((strlen(substr($chrs, 0, $c)) - strlen(rtrim(substr($chrs, 0, $c), '\\'))) % 2 != 1)) {
+ // found a quote, we're in a string, and it's not escaped
+ // we know that it's not escaped becase there is _not_ an
+ // odd number of backslashes at the end of the string so far
+ array_pop($stk);
+ //print("Found end of string at {$c}: ".substr($chrs, $top['where'], (1 + 1 + $c - $top['where']))."\n");
+
+ } elseif (($chrs{$c} == '[') &&
+ in_array($top['what'], array(SERVICES_JSON_SLICE, SERVICES_JSON_IN_ARR, SERVICES_JSON_IN_OBJ))) {
+ // found a left-bracket, and we are in an array, object, or slice
+ array_push($stk, array('what' => SERVICES_JSON_IN_ARR, 'where' => $c, 'delim' => false));
+ //print("Found start of array at {$c}\n");
+
+ } elseif (($chrs{$c} == ']') && ($top['what'] == SERVICES_JSON_IN_ARR)) {
+ // found a right-bracket, and we're in an array
+ array_pop($stk);
+ //print("Found end of array at {$c}: ".substr($chrs, $top['where'], (1 + $c - $top['where']))."\n");
+
+ } elseif (($chrs{$c} == '{') &&
+ in_array($top['what'], array(SERVICES_JSON_SLICE, SERVICES_JSON_IN_ARR, SERVICES_JSON_IN_OBJ))) {
+ // found a left-brace, and we are in an array, object, or slice
+ array_push($stk, array('what' => SERVICES_JSON_IN_OBJ, 'where' => $c, 'delim' => false));
+ //print("Found start of object at {$c}\n");
+
+ } elseif (($chrs{$c} == '}') && ($top['what'] == SERVICES_JSON_IN_OBJ)) {
+ // found a right-brace, and we're in an object
+ array_pop($stk);
+ //print("Found end of object at {$c}: ".substr($chrs, $top['where'], (1 + $c - $top['where']))."\n");
+
+ } elseif (($substr_chrs_c_2 == '/*') &&
+ in_array($top['what'], array(SERVICES_JSON_SLICE, SERVICES_JSON_IN_ARR, SERVICES_JSON_IN_OBJ))) {
+ // found a comment start, and we are in an array, object, or slice
+ array_push($stk, array('what' => SERVICES_JSON_IN_CMT, 'where' => $c, 'delim' => false));
+ $c++;
+ //print("Found start of comment at {$c}\n");
+
+ } elseif (($substr_chrs_c_2 == '*/') && ($top['what'] == SERVICES_JSON_IN_CMT)) {
+ // found a comment end, and we're in one now
+ array_pop($stk);
+ $c++;
+
+ for ($i = $top['where']; $i <= $c; ++$i)
+ $chrs = substr_replace($chrs, ' ', $i, 1);
+
+ //print("Found end of comment at {$c}: ".substr($chrs, $top['where'], (1 + $c - $top['where']))."\n");
+
+ }
+
+ }
+
+ if (reset($stk) == SERVICES_JSON_IN_ARR) {
+ return $arr;
+
+ } elseif (reset($stk) == SERVICES_JSON_IN_OBJ) {
+ return $obj;
+
+ }
+
+ }
+ }
+ }
+
+ /**
+ * @todo Ultimately, this should just call PEAR::isError()
+ */
+ function isError($data, $code = null)
+ {
+ if (class_exists('pear')) {
+ return PEAR::isError($data, $code);
+ } elseif (is_object($data) && (get_class($data) == 'services_json_error' ||
+ is_subclass_of($data, 'services_json_error'))) {
+ return true;
+ }
+
+ return false;
+ }
+}
+
+if (class_exists('PEAR_Error')) {
+
+ class Services_JSON_Error extends PEAR_Error
+ {
+ function Services_JSON_Error($message = 'unknown error', $code = null,
+ $mode = null, $options = null, $userinfo = null)
+ {
+ parent::PEAR_Error($message, $code, $mode, $options, $userinfo);
+ }
+ }
+
+} else {
+
+ /**
+ * @todo Ultimately, this class shall be descended from PEAR_Error
+ */
+ class Services_JSON_Error
+ {
+ function Services_JSON_Error($message = 'unknown error', $code = null,
+ $mode = null, $options = null, $userinfo = null)
+ {
+
+ }
+ }
+
+}
+
+?>
\ No newline at end of file
diff --git a/modules/video_zencoder/includes/zencoder.inc b/modules/video_zencoder/includes/zencoder.inc
new file mode 100644
index 0000000..c3023b0
--- /dev/null
+++ b/modules/video_zencoder/includes/zencoder.inc
@@ -0,0 +1,253 @@
+<?php
+
+/*
+ * @file
+ * Class file to handle amazon s3 transfers.
+ *
+ */
+
+// Include our class file.
+require_once('Zencoder.php');
+
+define('VIDEO_ZC_PENDING', 0);
+define('VIDEO_ZC_WORKING', 1);
+define('VIDEO_ZC_ACTIVE', 2);
+define('VIDEO_ZC_FAILED', 3);
+
+class video_zencoder_api {
+
+ private $access_key;
+ private $limit;
+ private $bucket;
+
+ public function __construct() {
+ $this->access_key = variable_get('video_zencoder_api_key', '');
+ $this->limit = variable_get('amazon_s3_limit', 5);
+ $this->bucket = variable_get('amazon_s3_bucket', '');
+ }
+
+ /**
+ * create transcoding job on Zencoder.com
+ */
+ public function create($file) {
+ global $base_url;
+ // API Key
+ $api_key = variable_get('video_zencoder_api_key', '');
+ // File details
+ $filename = $file->filename;
+ // Get varialbes
+ $bucket = $this->bucket;
+ $thumb_no = variable_get('video_thumbs', 5);
+
+ $thumb_size = variable_get('video_thumbs_size', '160x120');
+ $thumb_base = $baseurl;
+ $thumb_prefix = $filename;
+ // dimentions
+ $dimentions = explode('x', $file->dimentions);
+
+ $notify_url = variable_get('zc_notify_url', '');
+ $notify_email = variable_get('zc_notify_email', '');
+
+ // Job details
+ $input_name = $bucket . '/' . $filename;
+// watchdog('zencoder', $input_name);
+ // thumbnails
+ // Setup our thmbnail path.
+ $video_thumb_path = variable_get('video_thumb_path', 'video_thumbs');
+ $final_thumb_path = file_default_scheme() . ':/' . $video_thumb_path . '/' . $file->fid;
+
+ // Notifications
+// if(!empty($notify_url))
+// $notifications[] = array('format' => 'json', 'url' => 'http://123.231.58.90/drupal-6/postback/jobs');
+// $url = $base_url . '/postback/jobs';
+ $url = 'http://123.231.63.138/postback/jobs';
+ $notifications[] = array('format' => 'json', 'url' => $url);
+
+ //get the presets
+ $presets = $file->presets;
+ $public = (variable_get('amazon_s3_private', FALSE)) ? 0 : 1;
+
+ // construct the output array with the presets
+ $zc_outputs = array();
+ foreach ($presets as $name => $preset) {
+ $zc_output = array();
+ $lable = 'VIDEO_' . $name . '_' . $file->fid;
+ $width = $dimentions[0];
+ $height = $dimentions[1];
+ $quality = $preset['quality'];
+ $speed = $preset['speed'];
+ $upscale = $preset['upscale'];
+ $stretch = $preset['stretch'];
+ $frame_rate = $preset['frame_rate'];
+ $max_frame_rate = $preset['max_frame_rate'];
+ $keyframe_interval = $preset['keyframe_interval'];
+ $video_bitrate = $preset['video_bitrate'];
+ $bitrate_cap = $preset['bitrate_cap'];
+ $buffer_size = $preset['buffer_size'];
+ $h264_profile = $preset['h264_profile'];
+ $h264_level = $preset['h264_level'];
+ $skip_video = $preset['skip_video'];
+ $audio_codec = $preset['audio_codec'];
+ $audio_bitrate = $preset['audio_bitrate'];
+ $audio_channels = $preset['audio_channels'];
+ $audio_sample_rate = $preset['audio_sample_rate'];
+ $skip_audio = $preset['skip_audio'];
+ $start_clip = $preset['start_clip'];
+ $clip_length = $preset['clip_length'];
+
+ if (!empty($lable))
+ $zc_output['label'] = $lable;
+ if (!empty($bucket))
+ $zc_output['url'] = 's3://' . $bucket . '/' . pathinfo($filename, PATHINFO_DIRNAME) . '/converted/' . pathinfo($filename, PATHINFO_FILENAME) . '.' . $preset['extension'];
+ if (!empty($public))
+ $zc_output['public'] = $public;
+ if (!empty($width))
+ $zc_output['width'] = $width;
+ if (!empty($height))
+ $zc_output['height'] = $height;
+ if (!empty($quality))
+ $zc_output['quality'] = $quality;
+ if (!empty($speed))
+ $zc_output['speed'] = $speed;
+ if (!empty($upscale))
+ $zc_output['upscale'] = $upscale;
+ if (!empty($frame_rate))
+ $zc_output['frame_rate'] = $frame_rate;
+ if (!empty($max_frame_rate))
+ $zc_output['max_frame_rate'] = $max_frame_rate;
+ if (!empty($keyframe_interval))
+ $zc_output['keyframe_interval'] = $keyframe_interval;
+ if (!empty($video_bitrate))
+ $zc_output['video_bitrate'] = $video_bitrate;
+ if (!empty($bitrate_cap))
+ $zc_output['bitrate_cap'] = $bitrate_cap;
+ if (!empty($buffer_size))
+ $zc_output['buffer_size'] = $buffer_size;
+ if (!empty($h264_profile))
+ $zc_output['h264_profile'] = $h264_profile;
+ if (!empty($h264_level))
+ $zc_output['h264_level'] = $h264_level;
+ if (!empty($skip_video))
+ $zc_output['skip_video'] = $skip_video;
+ if (!empty($audio_codec))
+ $zc_output['audio_codec'] = $audio_codec;
+ if (!empty($audio_bitrate))
+ $zc_output['audio_bitrate'] = $audio_bitrate;
+ if (!empty($audio_channels))
+ $zc_output['audio_channels'] = $audio_channels;
+ if (!empty($audio_sample_rate))
+ $zc_output['audio_sample_rate'] = $audio_sample_rate;
+ if (!empty($skip_audio))
+ $zc_output['skip_audio'] = $skip_audio;
+ if (!empty($start_clip))
+ $zc_output['start_clip'] = $start_clip;
+ if (!empty($clip_length))
+ $zc_output['clip_length'] = $clip_length;
+
+ // thumbnails
+ $thumbnails['number'] = $thumb_no;
+ if (!empty($thumb_size))
+ $thumbnails['thumb_size'] = $thumb_size;
+ if (!empty($bucket))
+ $thumbnails['base_url'] = 's3://' . $bucket . '/' . $final_thumb_path;
+ if (!empty($file->fid))
+ $thumbnails['prefix'] = $file->fid;
+ $zc_output['thumbnails'] = $thumbnails;
+
+ //notifications
+ if (!empty($notify_email))
+ $notifications[] = $notify_email;
+ $zc_output['notifications'] = $notifications;
+ $zc_outputs[] = $zc_output;
+ }
+
+
+ $encoding_job_json = array(
+// 'test' => 1,
+// 'download_connections' => -1,
+ 'api_key' => $this->access_key,
+ 'input' => 's3://' . $input_name,
+ 'outputs' => $zc_outputs
+ );
+
+// print_r(($encoding_job_json));
+// exit;
+// watchdog('zencoder', json_encode($encoding_job_json));
+
+ $encoding_job = new ZencoderJob(json_encode($encoding_job_json));
+ // Check if it worked
+ if ($encoding_job->created) {
+// watchdog('zencoder', serialize($encoding_job));
+ return $encoding_job;
+ } else {
+ foreach ($encoding_job->errors as $error) {
+ // echo $error."\n";
+ watchdog('zencoder', 'Zencoder reports some errors. !error', array('!error' => $error), WATCHDOG_ERROR);
+ }
+ return false;
+ }
+ }
+
+ /*
+ * Updates the database after a successful transfer to amazon.
+ */
+
+ public function update($video) {
+ $result = db_query("UPDATE {video_zencoder} SET status=%d, completed=%d WHERE jobid=%d",
+ $video->output->state, time(), $video->job->id);
+ return $result;
+ }
+
+ /*
+ * Verifies the existence of a file id, returns the row or false if none found.
+ */
+
+ public function load_job($jobid) {
+ $sql = db_query("SELECT * FROM {video_zencoder} WHERE jobid=%d", $jobid);
+ $row = db_fetch_object($sql);
+ return $row;
+ }
+
+ /**
+ * Create Zencoder user account
+ */
+ public function create_user($user) {
+
+ $request = new ZencoderRequest(
+ 'https://app.zencoder.com/api/account',
+ false, // API key isn't needed for new account creation
+ array(
+ "terms_of_service" => "1",
+ "email" => $user->email,
+ "affiliate_code" => "drupal-video"
+ )
+ );
+
+ if ($request->successful) {
+ $results = $request->results;
+ variable_set('video_zencoder_api_key', $results['api_key']);
+ $message = drupal_mail('video_zencoder', 'video_zencoder', $user->email, language_default(), $results);
+ if (!$message['result']) {
+ drupal_set_message(t('Unable to send e-mail!. Your Zencoder Details are as below.<br/> <b>API Key</b> : !api_key<br/> <b>Password</b> : !password<br/>', array('!api_key' => $results['api_key'], '!password' => $results['password'])), 'status');
+ } else {
+// drupal_mail('video_zencoder', 'video_zencoder', 'heshanmw@gmail.com', language_default(), $results);
+ drupal_set_message(t('Your account has been created and is ready to start processing on Zencoder'));
+ }
+// return $request->results;
+ return true;
+// variable_set('video_zencoder_api_key', '');
+ } else {
+ $errors = '';
+ foreach ($request->errors as $error) {
+ if ($error == 'Email has already been taken') {
+ drupal_set_message(t('Your account already exists on Zencoder. So !login to here and enter API key below', array('!login' => l(t('login'), 'https://app.zencoder.com/session/new'))));
+ variable_set('video_zencoder_api_key', 'Please enter your API Key');
+ return TRUE;
+ }
+ $errors .= $error;
+ }
+ return $errors;
+ }
+ }
+
+}
\ No newline at end of file
--
cgit v1.2.3