modules/cdn2/cdn2.module

<?php
// $Id$

/*
 * @file cdn2.module
 */

// Find node nid matching video ID in cck field
// If status is error, throw a watchdog entry
// If status is complete,
//     Push file to CDN
//     Update CCK field to hold CDN URL
//     Publish Entry
// Respond with "OK"
//

define('CDN2_DEFAULT_ENDPOINT', 'http://soap.cdn2.net:8080/services/transcodeService?wsdl');
define('CDN2_DEFAULT_FORM', 'http://upload1.cdn2.net:8080/fileUpload.html');

require_once('cdn2_field.inc');

/**
 * parent function to render out the video node. Directs calls out to individual video assets.
 */
function theme_cdn2_video($node, $field, $items, $teaser, $page) {
  $output = '';
  $presets = _cdn2_get_available_presets();
  $output_items = array();
  if (count($items)) {
    foreach ($items as $item) {
      if (isset($item['assets']) && count($item['assets'])) {
        for ($asset_key = 0; $asset_key < count($item['assets']); $asset_key++) {
          $asset = $item['assets'][$asset_key];
          if (user_access('view cdn2 video transcoded with '. $asset['preset_name']) && $presets[$asset['preset_name']]->fileFormat != 'JPEG') {
          $output_items[] = '<div id="node-'. $node->nid .'-'. $asset['preset_name'] .'">'. theme('cdn2_video_asset', $node, $asset, $presets[$asset['preset_name']]) .'</div>';
          $preset_list[$asset['preset_name']] = '<a href="#node-'. $node->nid .'-'. $asset['preset_name'] .'"><span>'. $presets[$asset['preset_name']]->friendlyName .'</span></a>';
          }
        }
      }
    }
  }
  if (count($preset_list)) {
    $output .= '<div class="cdn2_tabs">';
    $output .= '<ul>';
    foreach ($preset_list as $preset_name => $preset_list_item) {
      if (strpos($preset_name, 'thumb') == FALSE) {
        $output .= '<li>'. $preset_list_item .'</li>';
      }
    }
    $output .= '</ul>';
    $output .= implode("\n", $output_items);
    $output .= '</div>';
  }
  return $output;
}

/**
 * parent function to render wrapper around a video asset.  Delegates to
 * appropriate theming functions based on preset short name, followed by
 * file format, then finally the generic type.
 */
function theme_cdn2_video_asset(&$node, &$asset, $preset) {
  $output = '';
  $output .= '<div class="cdn2_video_asset">';
  if ($asset['preset_name'] && user_access('view cdn2 video transcoded with '. $preset->shortName)) {
    if (theme_get_function('cdn2_video_asset_'. drupal_strtolower($preset->shortName))) {
      $output .= theme('cdn2_video_asset_'. drupal_strtolower($preset->shortName), $node, $asset, $preset);
    } 
    else if (theme_get_function('cdn2_video_asset_'. drupal_strtolower($preset->fileFormat))) {
      $output .= theme('cdn2_video_asset_'. drupal_strtolower($preset->fileFormat), $node, $asset, $preset);
    } 
    else {
      $output .= theme('cdn2_video_asset_generic', $node, $asset, $preset);
    }
    $output .= '</div>';
    $output .= '<div class="cdn2_metadata">';
    $output .= theme('cdn2_video_asset_metadata', $node, $asset, $preset);
    $output .= '</div>';
    $output .= '<div class="clear-block" style="clear: left"><!-- --></div>';
 
   return $output;
  }
}

/**
 * themes the video length as a time formatted as (hh:mm:ss)
 */
function theme_cdn2_asset_video_length($video_length) {
  if (!is_numeric($video_length)) {
    return $video_length;
  }

  $hms = '';
  $hours = intval(intval($video_length) / 3600);
  $hms .= str_pad($hours, 2, '0', STR_PAD_LEFT) .':';
  $minutes = intval(($video_length / 60) % 60);
  $hms .= str_pad($minutes, 2, '0', STR_PAD_LEFT) .':';
  $seconds = intval($video_length % 60);
  $hms .= str_pad($seconds, 2, '0', STR_PAD_LEFT);

  return $hms;
}

/**
 * themes file size in kb, mb, etc.
 */
function theme_cdn2_asset_file_size($file_size) {
  $output = '';
  if (!is_numeric($file_size)) {
    // try stripping off 'kb' from the end
    //
    $file_size = str_replace('kB', '', $file_size);
    if (!is_numeric($file_size)) {
      return $file_size;
    }
  }
  if ($file_size < 1024) {
    $output .= $file_size .' KBytes';
  }
  elseif ($file_size < 1048576) {
    $file_size = $file_size / 1024;
    $file_size = round($file_size, 2);
    $output .= $file_size .' MBytes';
  }
  else {
    $file_size = $file_size / 1048576;
    $file_size = round($file_size, 2);
    $output .= $file_size .' GBytes';
  }
  return $output;
}

/**
 * theme metadata about a video asset
 */
function theme_cdn2_video_asset_metadata(&$node, $asset, $preset) {
  $items = array();
  $title = t('Video Information:');
  $item = t('Duration: ');
  // TODO: theme the video length into DD:MM:SS
  $item .= ($asset['video_length'] === NULL) ? 'unknown' : theme('cdn2_asset_video_length', $asset['video_length']);
  $items[] = $item;
  $item =  t('File Size: ');
  // TODO: 
  $item .= ($asset['file_size'] === NULL) ? 'unknown' : theme('cdn2_asset_file_size', $asset['file_size']);
  $items[] = $item;
  $item = t('File Format: ');
  switch ($preset->fileFormat) {
    case 'FLASH':
      $item .= t('Flash Video (FLV)');
      break;
    case 'MOV':
      $item .= t('Quicktime (MOV)');
      break;
    default: 
      $item .= $preset->fileFormat;
      break;
  }
  $items[] = $item;
  $items[] = l('Download raw video file', $asset['asset_fetch_url']);
  
  return theme('item_list', $items, $title);
}

/**
 * custom theming function for quicktime videos
 */
function theme_cdn2_video_asset_mov(&$node, &$asset, $preset, $width = 320, $height = 240) {
  $output = '
<object classid="clsid:02BF25D5-8C17-4B23-BC80-D3488ABDDC6B" codebase="http://www.apple.com/qtactivex/qtplugin.cab" width="%s" height="%s">
  <param name="src" value="%s">
  <param name="autoplay" value="false">
  <param name="type" value="video/quicktime" width="%s" height="%s">
  <param name="scale" value="tofit">
  <embed src="%s" width="%s" height="%s" scale="tofit" autoplay="false" type="video/quicktime" pluginspage="http://www.apple.com/quicktime/download/">
</object>';
  $output = sprintf($output, $width, $height, $asset['asset_fetch_url'], $width, $height, $asset['asset_fetch_url'], $width, $height);
  return $output;
}

function theme_cdn2_video_asset_mov_hd_low_res(&$node, &$asset, $preset) {
  return theme('cdn2_video_asset_mov', $node, $asset, $preset, 640, 360);
}

function theme_cdn2_video_asset_mov_hd_high_res(&$node, &$asset, $preset) {
  return theme('cdn2_video_asset_mov', $node, $asset, $preset, 640, 360);
}

/**
 * custom theming function for flv types
 */
function theme_cdn2_video_asset_flash(&$node, &$asset, $preset) {
  $player = variable_get('cdn2_flash_player', 'flowplayer');
  
  $players = module_invoke_all('cdn2_player', 'flash');
  $player = $players[$player];
  $theme_function = $player['theme function'];

  return theme($theme_function, $node, $asset, $preset, '320', '240');
}

/**
 * custom theming function for flv hd types
 */
function theme_cdn2_video_asset_flash_flv_hd_low(&$node, &$asset, $preset) {
  $player = variable_get('cdn2_flash_player', 'flowplayer');
  
  $players = module_invoke_all('cdn2_player', 'flash');
  $player = $players[$player];
  $theme_function = $player['theme function'];

  return theme($theme_function, $node, $asset, $preset, '640', '360');
}

function theme_cdn2_video_asset_Flash_flv_hd_high(&$node, &$asset, $preset) {
  return theme('cdn2_video_asset_flash_flv_hd_low', $node, $asset, $preset);
}


/**
 * theming function for a thumbnail
 */
function theme_cdn2_video_asset_320x240_thumb(&$node, &$asset, $preset) {
  //  return '<img src="'. check_url($asset['asset_fetch_url']) .'" alt="'. check_plain($node->title) .'"/>';
}

/**
 * theming function for other (unknown) types that renders them as
 * a link to the downloadable file.
 */
function theme_cdn2_video_asset_generic(&$node, &$asset, $preset) {
  return l($preset->friendlyName, $asset['asset_fetch_url']);    
}


/**
 * Implementation of hook_perm().
 */
function cdn2_perm() {
  $perms = array('administer cdn2', 'administer cdn2 formats', 'delete cdn2 video');
  $enabled_presets = variable_get('cdn2_allowed_presets', array());
  foreach ($enabled_presets as $preset) { 
    if ($preset) { 
      $perms[] = 'transcode cdn2 video to '. $preset;
      $perms[] = 'view cdn2 video transcoded with '. $preset;
    }
  }
  return $perms;
}


function _cdn2_get_assets_for_node($nid) {
  $query = 'SELECT id, nid, video_token, preset_name, status, asset_fetch_url FROM {cdn2_videos} WHERE nid=%d';
  $resultset = db_query($query, $nid);
  $results = array();
  while ($row = db_fetch_array($resultset)) {
    $results[] = $row;
  }
  return $results;
}

/**
 * Implementation of hook_widget_settings().
 */
function cdn2_widget_settings($op, $widget) {
  switch ($op) {
    case 'callbacks':
        break;
    case 'form':
        $form = array();
        return $form;
    case 'validate':
      break;
    case 'save':
      return array('cdn2');
  }
}

function cdn2_xmlrpc() {
  //video_token, preset_name, status_as_string, asset_fetch_url
  
  // format of this response:
  /* 
     xmlrpc method name (e.g. module.function)
     callback function (e.g. module_function)
     method signature:
       first argument is the return type.
       remainder are arguments to the function.
  */
  return array(
    array(
      'cdn2.updateStatus',
      'cdn2_update_status',
      array('boolean',  // return value
            'string',   // dateTime
            'string',   // calculatedHash
            'string',   // videoToken
            'string',   // preset shortName
            'string',   // status
            'string',   // fileName
            'string',   // fileSize
            'string'),  // videoLength
      t('Update the status of a CDN2 video'),
    )
  );
}


function _cdn2_update_video_asset_status($video_token, $preset_name, $status, $asset_fetch_url, $file_size, $video_length) {
  $content_types = _cdn2_get_content_types();
  
  foreach ($content_types as $content_type) {
    $nid = _cdn2_get_nid_by_video_token($content_type, $video_token);
    // if the node has not yet been submitted, it's possible that we'll get a status message back before then.  So 
    // we persist the videotoken with a nid of zero and the node save will handle the population.  Hence why we ignore the nid here.
    //
    
    // fetch the existing video_nid if it exists
    //
    $query = "SELECT nid FROM {cdn2_video_node} where video_token='%s'";
    $video_nid = db_result(db_query($query, $video_token));
    
    
    $query = "SELECT id FROM {cdn2_videos} WHERE video_token = '%s' AND preset_name = '%s'";
    $result = db_result(db_query($query, $video_token, $preset_name));
    
    if (!$result) {
      // creating a new record for the video asset.  If the video's nid is set,
      // we pass that, too
      //
      $id = db_next_id('cdn2_videos_id');
      $query = "INSERT INTO {cdn2_videos} (id, nid, video_token, preset_name, status, asset_fetch_url, file_size, video_length) 
                  VALUES(%d, %d, '%s', '%s', '%s', '%s', '%s', '%s')";
      db_query($query, $id, $video_nid, $video_token, $preset_name, $status, $asset_fetch_url, $file_size, $video_length);
    }
    else {
      // update the video asset independent of node context
      $query = "UPDATE {cdn2_videos} SET status='%s', asset_fetch_url='%s', file_size='%s', video_length='%s' WHERE preset_name='%s' AND video_token='%s'";
      db_query($query, $status, $asset_fetch_url, $preset_name, $video_token);
    }
  }  

  // check to see if the video was already submitted.  If it was, we update the node with nid associated in cdn2_video_node.  If not, we do nothing as
  // it will get picked up by the node save itself.
  //
  if ($video_nid) {
    // here we update the cdn2_videos table with the correct nid (in case the node was already submitted)
    //
    $query = "UPDATE {cdn2_videos} SET nid=%d WHERE video_token='%s'";
    db_query($query, $video_nid, $video_token);
    
    // forcing a re-save of the node to clear cache
    //
    $node = node_load($video_nid);
      
    $content_type = $node->type;
    $field_name = _cdn2_get_field_names_by_content_type($content_type);
    
    if ($update = variable_get('cdn2_workflow_settings', 0)) {
      // update the node's status based on workflow settings
      
      if (!$node->status) {
        $node->status = 1;
        watchdog('cdn2', 'Marked '. $node->title .' as published');
      }
    }
    node_save($node);
  } 
  watchdog('cdn2', 'Completed transcoding '. $preset_name .' for video token '. $video_token);
  return TRUE;
}


/**
 * invoked when xmlrpc status callback is run
 */
function cdn2_update_status($date_time, $calculated_hash, $video_token, $preset_name, $status, $asset_fetch_url, $file_size, $video_length) {
  include_once('Crypt/HMAC.php');
  if (!class_exists('Crypt_HMAC')) {
    watchdog("cdn2", 'PEAR Package Crypt_HMAC is required to use the CDN2 module.', WATCHDOG_ERROR);
    return FALSE;
  }
  require_once('lib/libcdn2.inc');
  
  $cdn2_secret_key = variable_get("cdn2_secret_key", "");
  
  $hmac = new CDN2_Crypt_HMAC($cdn2_secret_key);
  $hmac->setKey($cdn2_secret_key);
  $hmac->setFunction("sha1");
  
  $message = variable_get("cdn2_client_id", "") . $date_time;
  $verified_hash = $hmac->hash($message);
  if ($verified_hash != $calculated_hash) {
    // failed hash check.. Do nothing
    watchdog("cdn2", "Invalid hash specified.  Ignoring xmlrpc request.", WATCHDOG_ERROR);
    return FALSE;
  }
  watchdog("cdn2", "Received valid authentication hash.  Processing request.");
  switch ($status) {
    case 'error':
      drupal_mail('admin_error_mail', variable_get('site_mail'), 'Error', 'There was an error in the transcoding process');
      break;
    case 'complete':
      watchdog('cdn2', sprintf('Updating status of video: %s with preset %s', $video_token, $preset_name), 'info');
      _cdn2_update_video_asset_status($video_token, $preset_name, $status, $asset_fetch_url, $file_size, $video_length);
      break;
    case 'deleted':
      $content_types = _cdn2_get_content_types();
      
      foreach ($content_types as $content_type) {
        $nid = _cdn2_get_nid_by_video_token($content_type, $video_token);
        $query = "SELECT id FROM {cdn2_videos} WHERE nid = %d";
        $result = db_result(db_query($query, $nid));
        
        if ($result) {
          $query = "DELETE FROM {cdn2_videos} WHERE nid=%d ";
          db_query($query, $nid);
        }
        else {
          watchdog("cdn2", t('Error on deletion: nid %d, not found in cdn2_videos table', $nid), WATCHDOG_ERROR);
        }
      }  
      break;      
  }
  // TODO: make sure this still works
  module_invoke_all('cdn2_video_asset_status', $video_token, $preset_name, $status, $asset_fetch_url, $file_size, $video_length);
  return TRUE;
}

function _cdn2_get_nid_by_video_token($content_type, $video_token) {
    $field_name = _cdn2_get_field_names_by_content_type($content_type);
    $query = "SELECT nid FROM {%s} WHERE %s = '%s'";
    $result = db_query($query, 'content_type_'. $content_type, $field_name[0] .'_value', $video_token);
    $nid = db_fetch_object($result);
    return $nid->nid;
}
/*
 * cdn2_menu
 * hook_menu implementation
 * 
 */
function cdn2_menu() {
  $items = array();
    $items[] = array(
      'path'               => 'admin/settings/cdn2',
      'title'              => t('CDN2 Settings'),
      'description'        => t('Configure CDN2'),
      'callback'           => 'drupal_get_form',
      'callback arguments' => 'cdn2_settings',
      'type'               => MENU_NORMAL_ITEM,
      'access'             => user_access('administer site configuration'),
    );
    $items[] = array(
      'path' => 'admin/settings/cdn2/config',
      'title' => t('CDN2 Settings'),
      'description' => t('Configure CDN2'),
      'callback' => 'drupal_get_form',
      'callback arguments' => 'cdn2_settings',
      'type' => MENU_DEFAULT_LOCAL_TASK,
      'access' => user_access('administer site configuration'),
    );
    
    $items[] = array(
      'path' => 'admin/settings/cdn2/formats',
      'title' => t('CDN2 Formats'),
      'description' => t('Select which formats to allow users to transcode to.'),
      'callback' => 'drupal_get_form',
      'callback arguments' => 'cdn2_format_settings',
      'type' => MENU_LOCAL_TASK,
      'access' => user_access('administer cdn2 formats')
    );
    $items[] = array(
      'path'               => 'admin/settings/cdn2/workflow',
      'title'              => t('CDN2 Workflow Settings'),
      'description'        => t('General workflow settings for CDN2'),
      'callback'           => 'drupal_get_form',
      'callback arguments' => 'cdn2_workflow_settings',
      'type'               => MENU_LOCAL_TASK,
      'access'             => user_access('administer site configuration'),
    );
    $items[] = array(
      'path' => 'cdn2/uploadform',
      'title' => t('Video upload form'),
      'access' => user_access('access content'),
      'type' => MENU_CALLBACK,
      'callback' => 'cdn2_upload_form'
    );
    $items[] = array(
      'path' => 'cdn2/xmlrpc',
      'title' => t('XMLRPC callback'),
      'access' => user_access('access content'),
      'type' => MENU_CALLBACK,
      'callback' => 'cdn2_xmlrpc',
    );
    $items[] = array(
      'path' => 'cdn2/complete',
      'title' => t('Upload Complete'),
      'access' => user_access('access content'),
      'type' => MENU_CALLBACK,
      'callback' => 'cdn2_upload_complete'
    );
    
    $items[] = array(
      'path' => 'cdn2/uploadform/status',
      'title' => t('Upload Status'),
      'access' => user_access('access content'),
      'type' => MENU_CALLBACK,
      'callback' => 'cdn2_get_upload_status',
      'callback arguments' => array(arg(3)),
    );
  return $items;
}

function cdn2_workflow_settings() {
  $form['cdn2_workflow_settings'] = array(
    '#type' => 'radios',
    '#title' => t('Workflow Settings'),
    '#default_value' => variable_get('cdn2_workflow_settings', 0),
    '#options' => array('1' => t('Publish node after transcoding is completed'), '0' => t('Do not automatically publish')),
  );
  return system_settings_form($form);
}

function cdn2_format_settings() {
  $form = array();
  drupal_add_css(drupal_get_path('module', 'cdn2') .'/cdn2.css');
  drupal_add_js('/misc/jquery.js');
  drupal_add_js(drupal_get_path('module', 'cdn2') .'/js/jquery.selectboxes.pack.js');
  drupal_add_js(drupal_get_path('module', 'cdn2') .'/js/cdn2_admin.js');
  $form['cdn2_markup'] = array(
    '#type' => 'markup',
    '#value' => t('Select the video formats that users should be able to transcode upload video to.  Note that all formats checked below will be available users.  You can configure permissions for which users have access to view and upload to certain formats by visiting the ') . l('user roles', 'admin/user/roles') . t(' page.')
  );
  $form['cdn2_presets'] = array(
    '#type' => 'fieldset',
    '#title' => t('Transcode Presets'),
    '#attributes' => array('id' => 'cdn2_presets_fieldset')
  );
  $presets = _cdn2_get_available_presets();
  $options = array();
  $selection_options = array();
  $selection_options['Select...'] = 'Select...';
  $cdn2_allowed_presets = variable_get('cdn2_allowed_presets', array());
  $js_list = array();
  $js_list[] = 'var aPresetList = new Array();';
  if (count($presets)) {
    foreach ($presets as $preset) {
      if ($preset->fileFormat != 'JPEG') {
        $options[$preset->shortName] = sprintf(
          '<div style="display:inline;">%s<br/><div class="description">Dimensions: %s<br/>Video Codec: %s (%sbps)<br/>Audio Codec: %s (%sbps)</div></div>',
          $preset->friendlyName,
          $preset->videoDimensions,
          $preset->videoCodec,
          $preset->videoBitRate,
          $preset->audioCodec,
          $preset->audioBitrate);
        $selection_options[$preset->shortName] = $preset->friendlyName;
        $js_list[] = sprintf('aPresetList[\'%s\'] = \'%s\';', $preset->shortName, $preset->friendlyName);
      }
    }
  }
  $js_output .= implode("\n", $js_list) ."\n";
  drupal_add_js($js_output, 'inline');
  $form['cdn2_presets']['cdn2_allowed_presets'] = array(
    '#type' => 'checkboxes',
    '#title' => 'Allowed Presets',
    '#default_value' => $cdn2_allowed_presets,
    '#description' => t('Set the types of presets that are transcoded by default.  Items of this list may be exposed by allowing them permissions on the drupal permissions page.'),
    '#options' => $options,
    '#suffix' => '<div class="clear-block"></div>'
  );

  $top_keys = array_keys($selection_options);
  $top_key = $top_keys[1];
  $cdn2_default_preset = variable_get('cdn2_default_preset', $top_key);
  $form['cdn2_presets']['cdn2_default_preset'] = array(
    '#type' => 'select',
    '#title' => t('Show format by default'),
    '#default_value' => $cdn2_default_preset, 
    '#options' => $selection_options
  );


  $cdn2_flash_players = module_invoke_all('cdn2_player', 'flash');
  $cdn2_flash_player_options = array();
  if (count($cdn2_flash_players)) {
    $form['cdn2_playback'] = array(
      '#type' => 'fieldset',
      '#title' => t('Playback Settings')
    );
    
    foreach ($cdn2_flash_players as $name => $player) {
      $cdn2_flash_player_options[$name] = $player['title'] .' ('. l($player['source url'], $player['source url'], array('target' => '_new')) .')';
    }
    
    $form['cdn2_playback']['cdn2_flash_player'] = array(
      '#type' => 'radios',
      '#title' => t('Preferred Flash Player'),
      '#options' => $cdn2_flash_player_options,
      '#default_value' => variable_get('cdn2_flash_player', 'flowplayer')
    );
  }

  $output = system_settings_form($form);

  return $output;
}

/*
 * cdn2_settings
 * Admin settings hook
 *
 * Form for the cdn2 module's settings.
 */
function cdn2_settings() {
  $form['cdn2_uploader_endpoint'] = array(
    '#type'          => 'textfield',
    '#title'         => t('SOAP Endpoint'),
    '#default_value' => variable_get('cdn2_uploader_endpoint', CDN2_DEFAULT_ENDPOINT),
    '#required'      => TRUE,
    '#description'   => t('The URL of the uploader\'s SOAP service'),
  );
  $form['cdn2_uploader_form'] = array(
    '#type'          => 'textfield',
    '#title'         => t('Upload form URL'),
    '#default_value' => variable_get('cdn2_uploader_form', CDN2_DEFAULT_FORM),
    '#required'      => TRUE,
    '#description'   => t('The URL of the uploader\'s HTML form'),
  );
  $form['cdn2_client_id'] = array(
    '#type'          => 'textfield',
    '#title'         => t('Client ID'),
    '#default_value' => variable_get('cdn2_client_id', ''),
    '#required'      => TRUE,
    '#description'   => t('Your client ID for the cdn2 service.'),
  );

  $form['cdn2_secret_key'] = array(
    '#type'          => 'textfield',
    '#title'         => t('Secret Key'),
    '#default_value' => variable_get('cdn2_secret_key', ''),
    '#required'      => TRUE,
    '#description'   => t('The Secret Key provided to you for the cdn2 service.'),
  );
  cache_clear_all();

  $output = system_settings_form($form);

  return $output;
}

function _cdn2_filter_presets_by_user($account, $assoc_presets, $show_all) {
  $user_presets = array();
  $cdn2_allowed_presets = variable_get('cdn2_allowed_presets', array());
  foreach ($assoc_presets as $short_name => $preset) {
    if (user_access('transcode cdn2 video to '. $short_name, $account) && $cdn2_allowed_presets[$short_name] !== 0) {
      $user_presets[$short_name] = $preset;
    }
  }
  return $user_presets;
}

function _cdn2_get_available_presets($account = NULL, $show_all = TRUE) {
  static $assoc_presets;
  if (count($assoc_presets)) {
    if ($account) {
      return _cdn2_filter_presets_by_user($account, $assoc_presets);
    }
    return $assoc_presets;
  }
  $presets = unserialize(cache_get('cdn2_presets')->data);
  if (!$presets) {
    $cdn2 = _cdn2_get_soap_client();
    if (!$cdn2) {
      return NULL;
    }
    $presets = $cdn2->getFormatPresets();
    if ($presets['error']) {
      drupal_set_message('Error occurred: '. $presets['error'], 'error');
      return NULL;
    } 
  }
  $assoc_presets = array();
  foreach ($presets as $preset) {
    $assoc_presets[$preset->shortName] = $preset;
  }
  cache_set('cdn2_presets', 'cache', serialize($assoc_presets), time() + 86400);
  if ($account) {
    return _cdn2_filter_presets_by_user($account, $assoc_presets, $show_all);
  }
  return $assoc_presets;
}

function _cdn2_content_types() {
  $type_list = array(0 => 'None');
  $result = db_query("SELECT distinct(type_name) as name FROM {node_field_instance} ORDER BY type_name");
  while ($row = db_fetch_object($result)) {
    $type_list[$row->name] = $row->name;
  }
  return $type_list;
}

function _cdn2_cck_fields() {
  $field_list = array(0 => 'None');
  $result = db_query("SELECT distinct(field_name) as name, label FROM {node_field_instance} where type_name = '%s' ORDER BY label", variable_get('cdn2_content_type', ''));
  while ($row = db_fetch_object($result)) {
    $field_list[$row->name] = $row->label;
  }
  return $field_list;
}

function cdn2_upload_form($token=0, $messages = '') {
  global $user;
  $redirect_url = url('cdn2/complete', NULL, NULL, TRUE);
  $action = variable_get('cdn2_uploader_form', CDN2_DEFAULT_FORM);
  $jquery   = '/misc/jquery.js';
  $jquery_progressbar = '/'. drupal_get_path('module', 'cdn2') .'/js/jquery.progressbar.min.js';
  $our_jquery = '/'. drupal_get_path('module', 'cdn2') .'/js/upload.js';
  $style_css = "/". path_to_theme() ."/style.css";
  $cdn2_progress_image = '/'. drupal_get_path('module', 'cdn2') .'/images/progressbg_blue.gif';
  $cdn2_progress_boximage = '/'. drupal_get_path('module', 'cdn2') .'/images/progressbar.gif';

  $presets = _cdn2_get_available_presets($user);
  $preset_inputs = '';
  $i = 0;
  foreach ($presets as $short_name => $preset) {
    # Note: each input name here must be prefixed by 'selectedPresets' to be properly processed by the backend service
    # If the backend service does not properly parse these args, it will not approve the selected formats for 
    # processing, and no transcoding will occur.
    $inputName = "selectedPresets".$i; 
    $preset_inputs .= sprintf('<input type="checkbox" name="%s" value="%s" checked/>%s<br/>', $inputName, $short_name, $preset->friendlyName);
    $i++;
  }
  if ($messages) {
    $messages = '<div class="error">'. $messages .'</div>'."\n";
  }
  $output = <<<HTML
<html class="js" lang="en" xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
  <head>
    <title></title>
    <style type="text/css" media="all">@import "/modules/node/node.css";</style>
    <style type="text/css" media="all">@import "/modules/system/defaults.css";</style>
    <style type="text/css" media="all">@import "/modules/system/system.css";</style>
    <style type="text/css" media="all">@import "$style_css";</style>
    <style>
      #progress-bar {
        display: none;
      }
      #progress-info {
        display: none;
      }
      body {
        background: transparent;
      }
    </style>
    <script language="javascript" type="text/javascript">
      var cdn2_progress_image = '$cdn2_progress_image';
      var cdn2_progress_boximage = '$cdn2_progress_boximage';
    </script>
    <script type="text/javascript" src="$jquery"></script>
    <script type="text/javascript" src="$jquery_progressbar"></script>
    <script type="text/javascript" src="$our_jquery"></script>
  </head>
  <body>
   $messages
   <form id="upload" action="$action" method="post" enctype="multipart/form-data">
     <div class="form-item">
        <p><label>Upload a video: </label>
        <input type="hidden" name="videoToken" id="videoToken" value="$token"/>
        <input type="hidden" name="redirectUrl" value="$redirect_url"/>
        <input type="file" name="file"/></p>
        <p>
          <label>Show this file in the following formats:</label>
          $preset_inputs
        </p>
            <input type="submit" name="Send" value="Upload"/>
          </div>
        </form>
        <div id="progress-info"><p>Your video is uploading.  Please do not submit your  form or navigate away from this page until it is complete.</p>
          <b>Upload Progress:</b>
        </div>
        <div id="progress-bar"></div>
  </body>
</html>
HTML;

  print $output;
}

/**
 * shows the upload form in an iframe
 */
function cdn2_upload_complete($video_token = '') {
  $error = $_REQUEST['e'];
  $video_token = check_plain($video_token);
  if ($error) {
    // show the upload form again, with the error inline.
    //
    print cdn2_upload_form($video_token, $error);
    return;
  }

  // save the video token in the database.  Note that it will not yet be associated with a node.  That's okay.
  //
  $vid = db_next_id("cdn2_video_vid");

  $query = "INSERT INTO {cdn2_video_node} (vid, nid, video_token, is_submitted) values(%d, 0, '%s', %d)";
  db_query($query, $vid, $video_token, 1);

  $jquery = '/misc/jquery.js';
  $style_css = "/". path_to_theme() ."/style.css";
  $output = <<<HTML
  <html class="js" lang="en" xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
  <head>
    <title></title>
    <style type="text/css" media="all">@import "/modules/node/node.css";</style>
    <style type="text/css" media="all">@import "/modules/system/defaults.css";</style>
    <style type="text/css" media="all">@import "/modules/system/system.css";</style>
    <style type="text/css" media="all">@import "$style_css";</style>
    <script type="text/javascript" src="$jquery"></script>
<p>Your video has been uploaded.  It can take some time to process, so be patient.</p>

<p>Please make sure you <b>submit</b> this page before continuing, otherwise your video will be lost.</p>
<script language="javascript">
  $(document).ready(function(){
      $(window.parent.document).find('input#edit-cdn2-is-submitted').val('true');
      $(window.parent.document).find('input#edit-submit').removeAttr('disabled');
      return;
  });
</script>
</body>
</html>
HTML;

  print $output;
}

function cdn2_get_upload_status($vidid) {
    $cdn2 = _cdn2_get_soap_client();
    // this PRINT_R is NOT FOR DEBUGGING.  Don't remove it, mmkay?
    print_r($cdn2->getVideoUploadStatus($vidid));
}

function _cdn2_get_soap_client() {
  include_once('Crypt/HMAC.php');
  if (!class_exists('Crypt_HMAC')) {
    drupal_set_message('PEAR Package Crypt_HMAC is required to use the CDN2 module.', 'error');
    return;
  }
  require_once('lib/libcdn2.inc');

  $site_token = variable_get('cdn2_client_id', 'workhabit');
  $secret_key = variable_get('cdn2_secret_key', '');
  $endpoint_url = variable_get('cdn2_uploader_endpoint', CDN2_DEFAULT_ENDPOINT);
  try {
    return new ErrorHandlingSoapClient(CDN2SoapClientImpl::getInstance($endpoint_url, $site_token, $secret_key));
  } catch (Exception $e) {
    drupal_set_message($e->getMessage(), 'error');
    watchdog('error', $e->getMessage());
  } 
  return NULL;
}


function _cdn2_get_content_types() {
  $widget_info = cdn2_widget_info();
  $content_types = array();
  foreach ($widget_info as $key => $value) {
    $query = "SELECT type_name FROM {node_field_instance} WHERE widget_type='%s'";
    $result = db_query($query, $key);
    while ($row = db_fetch_object($result)) {
      $content_types[] = $row->type_name;
    }
  }
  return $content_types;
}

function _cdn2_get_field_names_by_content_type($content_type) {
    $query = "SELECT field_name FROM {node_field_instance} WHERE type_name='%s'";
    $result = db_query($query, $content_type);
    while ($row = db_fetch_object($result)) {
      $field_names[] = $row->field_name;
    }
    return $field_names;
}