/[drupal]/contributions/modules/query_export/query_export.module

Diff of /contributions/modules/query_export/query_export.module

Parent Directory | Revision Log | View Revision Graph Revision Graph | View Patch Patch

-revision 1.1,
Thu Jun  8 06:34:55 2006 UTC
+revision 1.2,
Sat Aug 26 00:06:30 2006 UTC
 Line 12
   *
   *
   * @author Rob Thorne (rob AT torenware.com)
-  * @copyright Bioneers 2006
+  * @copyright © 2006 by Collective Heritage Institute
   * @license GPL v. 2.0
   * @version 4.7.0 - development
   * @see
 Line 21
   */
-   //includes here.
+ //includes here.
  $mod_path = drupal_get_path('module', 'query_export');
  require_once $mod_path . "/metadata.inc";
+ require_once $mod_path . "/views.inc";
+ require_once $mod_path . "/civicrm.inc";
+ require_once $mod_path . "/formatters.inc";
  if (module_exist('civinode')) {
    $civinode_path = drupal_get_path('module', 'civinode');
    require_once $civinode_path . "/civinode_utils.inc";
-Line 34 
 define('QUERY_EXPORT_ERROR_BASE', 8300);
+Line 37 
 define('QUERY_EXPORT_ERROR_BASE', 8300);
  define('QUERY_EXPORT_ERROR_NO_AUTH',          QUERY_EXPORT_ERROR_BASE + 1);
  define('QUERY_EXPORT_ERROR_NO_SUCH_QUERY',    QUERY_EXPORT_ERROR_BASE + 2);
  define('QUERY_EXPORT_ERROR_SERVER_IS_HORKED', QUERY_EXPORT_ERROR_BASE + 3);
+ define('QUERY_EXPORT_ERROR_UNAUTHORIZED',     QUERY_EXPORT_ERROR_BASE + 4);
+ //Some Jserv defaults
+ define('QUERY_EXPORT_DEFAULT_JSERV', 'http://localhost:8081/jasperService');
  /**
   * Implementation of hook_help
   *
-Line 43 
 define('QUERY_EXPORT_ERROR_SERVER_IS_HOR
+Line 50 
 define('QUERY_EXPORT_ERROR_SERVER_IS_HOR
  function query_export_help($section) {
    switch ($section) {
-     case 'admin/help#query_export':
+   case 'admin/help#query_export':
-       $output = '<p>'. t('The query_export module is used to create query definitions you want to expose to XML-RPC, for report generation and other purposes. ') .'</p>';
+     $output = '<p>'. t('The query_export module is used to create query definitions you want to expose to XML-RPC, for report generation and other purposes. ') .'</p>';
-       $output .= '<p>'. t('The query_export administration interface allows for complex configuration.') .'</p>';
+     $output .= '<p>'. t('The query_export administration interface allows for complex configuration.') .'</p>';
-       $output .= t('<p>You can</p>
+     $output .= t('<p>You can</p>
  <ul>
  <li><em>Items Listed Here...</em></li></ul>
  ', array('%node-add-query_export' => url('node/add/query_export'), '%admin-settings-content-types-query_export' => url('admin/settings/content-types/query_export')));
-       return $output;
+     return $output;
-     case 'admin/modules#description':
+   case 'admin/modules#description':
-       return t('Allows users to define node queries for export via XML-RPC.');
+     return t('Allows users to define node queries for export via XML-RPC.');
-     case 'node/add#query_export':
+   case 'node/add#query_export':
-       return t('Query Exports are definitions of queries you want to use in reporting applications like JasperReports.');
+     return t('Query Exports are definitions of queries you want to use in reporting applications like JasperReports.');
    }
  }
-Line 63 
 function query_export_help($section) {
+Line 70 
 function query_export_help($section) {
   * Implementation of hook_node_info().
   */
  function query_export_node_info() {
-   return array('query_export' => array('name' => t('query_export'), 'base' => 'query_export'));
+   return array('query_export' => array('name' => t('Jasper Report Definition'), 'base' => 'query_export'));
  }
  /**
   * Implementation of hook_perm().
+  *
+  * Custom tables are a quick hack that will likely go away in
+  * official versions (June 2006 RMT).
   */
  function query_export_perm() {
-   return array('create query exports', 'administer query exports', 'access query exports via XML-RPC');
+   return array('create query exports', 'administer query exports', 'access query exports via XML-RPC', 'access custom tables');
  }
  /**
-Line 80 
 function query_export_access($op, $node)
+Line 90 
 function query_export_access($op, $node)
    //TO DO: this piece requires thought.
    global $user;
-   if ($op == 'create') {
+   if ($op == 'create' or $op == 'update' or $op == 'delete') {
      return user_access('create query exports');
    }
    /**
-   if ($op == 'update' || $op == 'delete') {
+      if ($op == 'update' || $op == 'delete') {
-     if (user_access('edit own stories') && ($user->uid == $node->uid)) {
+      if (user_access('edit own stories') && ($user->uid == $node->uid)) {
-       return TRUE;
+      return TRUE;
-     }
+      }
-   }
+      }
    **/
  }
-Line 102 
 function query_export_menu($may_cache) {
+Line 112 
 function query_export_menu($may_cache) {
    if ($may_cache) {
      //Admin screens, query creation screens
      $items[] = array('path' => 'query_export/test_rpc',
-          'title' => t('Test RPC Routines'),
+                      'title' => t('Test RPC Routines'),
-          'callback' => 'query_export_test_rpc',
+                      'callback' => 'query_export_test_rpc',
-          'type' => MENU_CALLBACK,
+                      'type' => MENU_CALLBACK,
-          'access' => 1
+                      'access' => user_access('create query exports')
-          );
+                      );
+     $items[] = array('path' => 'query_export/field_editor',
+                      'title' => t('Set Up Field Handlers'),
+                      'callback' => 'query_export_edit_field_info_form',
+                      'type' => MENU_CALLBACK,
+                      'access' => user_access('create query exports')
+                      );
+     $items[] = array('path' => 'query_export/param_editor',
+                      'title' => t('Set Up Default Parameters'),
+                      'callback' => 'query_export_edit_default_params_form',
+                      'type' => MENU_CALLBACK,
+                      'access' => user_access('create query exports')
+                      );
+     $items[] = array('path' => 'query_export/render',
+                      'title' => t('Produce A Report In Jasper Reports'),
+                      'callback' => 'query_export_render_form',
+                      'type' => MENU_CALLBACK,
+                      'access' => user_access('access query exports via XML-RPC')
+                      );
    }
    return $items;
-Line 114 
 function query_export_menu($may_cache) {
+Line 144 
 function query_export_menu($may_cache) {
  /**
+  * Menu handler for rendering reports
+  *
+  */
+ function query_export_render_form(){
+   $node_arg = arg(2) and is_numeric(arg(2)) ? arg(2) : FALSE;
+   $output = '';
+   if (!$node_arg) {
+     $output .= "This page should have a listing of possible rep defs";
+   }
+   else {
+     $node = node_load($node_arg);
+     if (!$node or $node->type != 'query_export')
+       drupal_not_found();
+     //$output .= "This should be a form to render Node $node_arg, if it exists";
+     //If we are processing, set up the call to the proxy.
+     if (isset($_POST['edit'])) {
+       $edit = $_POST['edit'];
+       $params = array();
+       if (isset($edit['output_type'])) {
+         if ($edit['output_type'] == 'csv') {
+           return query_export_render_csv_file($node,
+                                               $edit['query_string']
+                                               );
+         }
+         else
+           $params['format'] = urlencode($edit['output_type']);
+       }
+       if (isset($edit['query_string']))
+         $params['qstring'] = urlencode($edit['query_string']);
+       error_log('About to launch our proxy...');
+       return query_export_render_report($node_arg, $params);
+     }
+     $form = array();
+     $form['dummy_label'] =
+       array('#type' => 'item',
+             '#title' => t('Definition Name'),
+             '#value' => $node->title);
+     $form['dummy_dsource'] =
+       array('#type' => 'item',
+             '#title' => t('Data Source'),
+             '#value' => query_export_query_ui_name($node->query_name));
+     $form['dummy_dstype'] =
+       array('#type' => 'item',
+             '#title' => t('Source Type'),
+             '#value' => $node->query_type);
+     if (module_exist('civinode') and $node->query_type == 'civicrm') {
+       global $user;
+       $pid = $node->query_profile ?
+         $node->query_profile :
+         civinode_get_default_profile_id($user->uid);
+       $prof_title = civinode_get_profile_title($pid);
+       $form['dummy_prof_id'] =
+         array('#type' => 'item',
+               '#title' => t('Contact Fields From Profile'),
+               '#value' => $prof_title);
+     }
+     $form['output_type'] =
+       array('#type' => 'select',
+             '#title' => t('Type Of Output'),
+             '#description' => t('Jasper Reports can generate multiple kinds of output.  Choose the desired format for this report'),
+             '#default_value' => 'csv',
+             '#options' =>
+             array('pdf' => t("PDF File"),
+                   'xls' => t('MS Excel Spreadsheet'),
+                   'html' => t('HTML Web Page'),
+                   'rtf' => t('Rich Text (RTF)'),
+                   'txt' => t('Plain Text'),
+                   'csv' => t('CSV File')
+                   )
+             );
+     $form['query_string'] =
+       array('#type' => 'textfield',
+             '#title' => t('Query String'),
+             '#description' => t('For some report types, you can pass an optional query string that will further restrict what rows you will get in your report  You should ask your system admin how to use this, since this is an "Advanced Feature".  YMMV :-)'),
+             '#size' => 30,
+             '#maxlength' => 60
+             );
+     $form['submit'] =
+       array('#type' => 'submit',
+             '#value' => t('Run Report')
+             );
+     $output .= drupal_get_form('request_jasper_form', $form);
+   }
+   return $output;
+ }
+ /**
+  * Bridging functions for the Java servlet
+  *
+  */
+ /**
+  * Ask the servlet to compile and reload a report definition
+  *
+  * @param int $nid  node id of the report to load or reload.
+  * @return TRUE on success
+  */
+ function query_export_request_compile($nid){
+   $base = variable_get('query_export_jserv_url', QUERY_EXPORT_DEFAULT_JSERV);
+   if ($base) {
+     //$len = strlen($base);
+     //build the query string
+     $qs = "?compile=$nid";
+     $curl = curl_init();
+     $url = $base . $qs;
+     curl_setopt($curl, CURLOPT_URL, $url);
+     curl_setopt($curl, CURLOPT_RETURNTRANSFER, TRUE);
+     $rslt = curl_exec($curl);
+     //For now, just log this
+     error_log("Polled $url and got: " . $rslt);
+     //Need to test result, but for now...
+     $match = array();
+     if (preg_match('/^Status\:\s+(\S+)/', $rslt, $match)) {
+       error_log("Got code: " . $match[1]);
+       return TRUE;
+     }
+   }
+   return FALSE;
+ }
+ /**
+  * Process a report rendering via the servlet
+  *
+  */
+ function query_export_render_report($nid, $params = array()){
+   //build request for proxy.
+   $base = variable_get('query_export_jserv_url', QUERY_EXPORT_DEFAULT_JSERV);
+   //Check for params or set defaults
+   //?report=nid&cookie=xxxx&qstring=xxxxxx&format=pdf
+   //TO DO: this should really be using URL encoding functions
+   $cookie = query_export_generate_cookie($nid);
+   if (isset($params['format']))
+     $format = $params['format'];
+   else
+     $format = 'pdf';
+   $qs = "?report=$nid&format=$format&cookie=$cookie";
+   if (isset($params['qstring']))
+     $qs .= "&qstring=" . $params['qstring'];
+   if ($base) {
+     //$len = strlen($base);
+     //build the query string
+     $node = node_load($nid);
+     $file_name = query_export_query_ui_name($node->query_name);
+     //Get an extension and MIME type
+     switch ($format) {
+     case 'pdf':
+       $extension = "pdf";
+       $mime = 'application/pdf';
+       break;
+     case 'xls':
+       $extension = "xls";
+       $mime = 'application/vnd.ms-excel';
+       break;
+     case 'html':
+       $extension = "html";
+       $mime = 'text/html';
+       break;
+     case 'txt':
+       $extension = "txt";
+       $mime = 'text/plain';
+       break;
+     case 'doc':
+       $extension = "doc";
+       $mime = 'application/msword';
+       break;
+     case 'rtf':
+       $extension = "rtf";
+       $mime = 'application/rtf';
+       break;
+     default:
+       $extension = "bin";
+       $mime = 'application/octet-stream';
+       break;
+     }
+     $curl = curl_init();
+     $url = $base . $qs;
+     curl_setopt($curl, CURLOPT_URL, $url);
+     curl_setopt($curl, CURLOPT_RETURNTRANSFER, FALSE);
+     curl_setopt($curl, CURLOPT_BINARYTRANSFER, TRUE);
+     curl_setopt($curl, CURLOPT_HEADER, FALSE); //write our own
+     //curl_setopt($curl, CURLOPT_FAILONERROR, 1);
+     //We need to proxy over our headers
+     //curl_setopt($curl, CURLOPT_HEADERFUNCTION,
+     //            'query_export_proxy_header_callback');
+     curl_setopt($curl, CURLOPT_WRITEFUNCTION,
+                 'query_export_proxy_data_callback');
+     $date = date('r');
+     error_log("Start transfer at $date");
+     header( "Content-type: $mime" );
+     $file_name .= "." . $extension;
+     $file_name = strtr($file_name, array(' ' => "_"));
+     header( "Content-disposition: attachment; filename=$file_name" );
+     curl_exec($curl);
+     $errno = curl_errno($curl);
+     if ($errno)
+       error_log(curl_error($curl));
+     error_log("Called curl_exec with $errno for " . $url);
+     curl_close($curl);
+     exit(0);
+   }
+ }
+ /**
+  * Proxy http headers
+  *
+  * Curl callback to proxy over the HTTP headers
+  */
+ function query_export_proxy_header_callback($curl_obj, $header){
+   error_log($header);
+   if (preg_match('/^HTTP\:/', $header) or
+       preg_match('/^Content/', $header)) {
+     header($header);
+     return strlen($header);
+   }
+   return 0;
+ }
+ function query_export_proxy_data_callback($curl_obj, $data){
+   $size = strlen($data);
+   print $data;
+ #error_log("Wrote $size bytes");
+   return $size;
+ }
+ /**
+  * Implementation of hook_settings
+  *
+  */
+ function query_export_settings(){
+   $form['query_export_jserv_url'] =
+     array('#type' => 'textfield',
+           '#default_value' => variable_get('query_export_jserv_url',
+                                            QUERY_EXPORT_DEFAULT_JSERV),
+           '#title' => t('URL of your Drupal/Jasper bridge'),
+           '#description' => t('If you want to run Jasper Reports queries, you need ' .
+                               'to supply a URL of your Drupal bridge servlet.'),
+           '#size' => 35,
+           '#maxlength' => 60);
+   return $form;
+ }
+ /**
+  *
+  * Implementation of hook_view
+  *
+  *
+  */
+ function query_export_view(&$node, $teaser = FALSE, $page = FALSE){
+   //Very simple rendering so we can see settings
+   $items = array();
+   $items[] = t('<b>Data Source Name:</b> ') . query_export_query_ui_name($node->query_name);
+   $items[] = t('<b>Type Of Data:</b> ') . $node->query_type;
+   if ($node->query_type == 'civicrm' and $node->query_profile) {
+     if (module_exist('civinode')) {
+       $profile = civinode_get_profile_title($node->query_profile);
+     }
+     else
+       $profile = t('<em>NA</em>');
+     $items[] = t('<b>Use Fields From CRM Profile:</b> ') . $profile;
+   }
+   $output = theme('item_list', $items, t('Report Parameters'));
+   if (module_exist('views') and $node->nid) {
+     $output .= t('<br /><p>You can define special handlers to modify the way some of your fields are formatted,
+     or in the case of custom queries (queries where you write the SQL yourself) where you want to make report
+     generators like iReport aware that you are exporting a particular field.  You can add new definitions or
+     edit existing fields here:</p>');
+     $num_field_defs = query_export_load_field_definitions($node->nid);
+     if ($num_field_defs) {
+       $view = views_get_view('query_export_field_defs');
+       $output .= views_build_view('embed', $view, array($node->nid), TRUE, 20);
+       $output .= "<br />";
+     }
+     $output .= l(t('Add A Special Handler'), 'query_export/field_editor/' . $node->nid);
+     $output .= "<br /><br />\n";
+     $output .= t('<p>You can also define default parameters that can be passed to the report generator
+ to define ranges for queries or to add a parameter to restrict the report to one group or contact. You may
+ add these here:</p><br />');
+     //TO DO: render a view here.
+     $all_params = query_export_fetch_default_param($node->nid);
+     if (count($all_params)) {
+       $view = views_get_view('query_export_param_embed');
+       $output .= views_build_view('embed', $view, array($node->nid), TRUE, 20);
+       $output .= "<br />";
+     }
+     $output .= l(t('Define A Default Parameter'), 'query_export/param_editor/' . $node->nid);
+     $output .= "<br /><br />\n";
+   }
+   $node->body = $output;
+   $node->teaser = $output;
+ }
+ /**
+  * Implementation of hook_link.
+  *
+  * Link goes to the "generate report" page for that node.
+  * @author
+  * @param
+  * @return
+  * @exeption
+  * @see
+  */
+ function query_export_link($type, $node = NULL, $teaser = false){
+   $links = array();
+   if ($type == 'node' and $node->type == 'query_export' and $node->nid) {
+     if (user_access('access query exports via XML-RPC')) {
+       $links[] = l(t('generate a report'), "query_export/render/" . $node->nid,
+                    array('title' => t('Generate a JasperReports report.')));
+     }
+   }
+   return $links;
+ }
+ /**
+  * Implementation of hook_prepare.
+  *
+  * We use this to set up the uploads
+  */
+ function query_export_prepare(&$node){
+   // Clears our files in session when you enter the edit view the first time.
+   // This is so files don't linger on the form if you happen to leave the node
+   // and come back into it.
+   if(count($_POST) == 0) {
+     unset($_SESSION['jasper_jrxml_file']);
+   }
+   //We need to remember if we already have an upload from
+   //before
+   $have_upload = $node->report_text ? TRUE : FALSE;
+   // check for an upload
+   if ($file = file_check_upload('jasper_jrxml_upload')) {
+     // save the upload into drupal's temp directory
+     $temppath = file_directory_temp() . '/jasper/';
+     file_check_directory($temppath, TRUE);
+     $node->jasper_jrxml_file = file_save_upload($file, $temppath .'/'. $file->filename,
+                                                 FILE_EXISTS_REPLACE);
+     $node->jasper_jrxml_file->newfile = TRUE;
+     $_SESSION['jasper_jrxml_file'] = $node->jasper_jrxml_file;
+     $have_upload = TRUE;
+   }
+   else if (!empty($_SESSION['jasper_jrxml_file'])) {
+     $node->jasper_jrxml_file = $_SESSION['jasper_jrxml_file'];
+     $have_upload = TRUE;
+   }
+   else {
+     //May not need this, since we will not keep the file
+     if ($node->jasper_jrxml_file)
+       $_SESSION['jasper_jrxml_file'] = $node->jasper_jrxml_file;
+   }
+   //And if we have an upload, save away this info so that we
+   //can see this later in processing
+   //form_set_value(array('qe_have_upload' =>
+   //              array('#value' => $have_upload)),)
+ }
+ /**
+  * Function to aid managing uploads
+  *
+  * @param int $nid
+  */
+ function query_export_report_rec_has_text($nid){
+   $sql = "SELECT length(report_text) FROM {query_export_reports} WHERE nid = %d";
+   return db_result(db_query($sql,$nid));
+ }
+ /**
   * Implementation of hook_validate().
   */
- function query_export_validate($node) {
+ function query_export_validate(&$node) {
-   //node_validate_title($node);
+   //First, as far as query names go, There Can Be Only One.
+   if ($node->query_type == 'views') {
+     $node->crm_query = '';
+     if (!$node->views_query) {
+       form_set_error('views_query', t("Please choose a View to extract data from"));
+     }
+     $node->query_name = $node->views_query;
+   }
+   else if ($node->query_type == 'civicrm') {
+     $node->views_query = '';
+     if (!$node->crm_query) {
+       form_set_error('crm_query', t("Please choose a CiviCRM group to extract data from"));
+     }
+     $node->query_name = $node->crm_query;
+   }
+   //Check if we need an upload
+   $had_report = FALSE;
+   if ($node->nid) {
+     $had_report = query_export_report_rec_has_text($node->nid);
+   }
+   if (!$had_report && !isset($_SESSION['jasper_jrxml_file'])) {
+     form_set_error('jasper_jrxml_upload', t('Please choose a Jasper Reports definition file (JRXML) to upload.'));
+   }
+   //Prepare stuff gets thrown away?  Fix it here as well
+   if (isset($_SESSION['jasper_jrxml_file'])) {
+     $node->jasper_jrxml_file = $_SESSION['jasper_jrxml_file'];
+   }
+ }
+ function query_export_submit(&$node) {
+   //Set derived fields if not already set
+   if (!isset($node->query_name)) {
+     if ($node->query_type == 'civicrm')
+       $node->query_name = $node->crm_query;
+     elseif ($node->query_type == 'views')
+       $node->query_name = "views::" . $node->views_query;
+     else
+       $node->query_name = "custom::custom_{$node->nid}";
+   }
+   // check if the file was stored in the session during audio_prepare().
+   if (isset($_SESSION['jasper_jrxml_file'])) {
+     $node->jasper_jrxml_file = $_SESSION['jasper_jrxml_file'];
+     //Scoop up the file and delete it
+     $report_source = file_get_contents($node->jasper_jrxml_file->filepath);
+     if (!$report_source) {
+       drupal_set_message(t('Warning -- upload failed!'));
+       error_log("Upload error: " . $node->jasper_jrxml_file->filepath);
+     }
+     else {
+       $node->report_text = $report_source;
+       $node->jasper = NULL;
+     }
+     // won't be needing this any longer
+     file_delete($node->jasper_jrxml_file);
+     unset($_SESSION['jasper_jrxml_file']);
+   }
+ }
+ /**
+  * Implementation of hook_insert
+  */
+ function query_export_insert(&$node) {
+   $sql = "INSERT INTO {query_export_reports}
+           (nid, last_update, query_name, query_type,query_profile,
+            query_sql, report_text)
+           VALUES(%d,UNIX_TIMESTAMP(),'%s','%s',%d,'%s','%s')";
+   db_query($sql, $node->nid,
+            $node->query_name, $node->query_type,
+            $node->query_profile,
+            $node->query_sql,
+            $node->report_text);
+   //Get the proxy to update the record
+   query_export_request_compile($node->nid);
  }
  /**
+  * Implementation of hook_update
+  *
+  */
+ function query_export_update($node){
+   if ($node->report_text) {
+     //If we are not setting this now, we want
+     //to 0 out the jasper object, but we don't
+     //want to remove an existing report.
+     $set_report = "report_text = '%s',";
+   }
+   else
+     $set_report = '';
+   $sql = "UPDATE {query_export_reports}
+           SET
+             query_name = '%s', query_type = '%s',
+             query_profile = %d,
+             query_sql = '%s',
+             $set_report
+             last_update = UNIX_TIMESTAMP(),
+             jasper = NULL
+           WHERE nid = %d";
+   if ($set_report)
+     db_query($sql,
+              $node->query_name, $node->query_type,
+              $node->query_profile, $node->query_sql,
+              $node->report_text, $node->nid);
+   else
+     db_query($sql,
+              $node->query_name, $node->query_type,
+              $node->query_profile, $node->query_sql, $node->nid);
+   //Get the proxy to update the record
+   query_export_request_compile($node->nid);
+ }
+ /**
+  * Implementation of hook_load
+  *
+  */
+ function query_export_load($node){
+   $sql = 'SELECT * FROM {query_export_reports} WHERE nid = %d';
+   $obj = db_fetch_object(db_query($sql, $node->nid));
+   unset($obj->jasper); //we do not use this internally
+   if ($obj->query_type == 'civicrm')
+     $obj->crm_query = $obj->query_name;
+   else if ($obj->query_type == 'views')
+     $obj->views_query = $obj->query_name;
+   return $obj;
+ }
+ /**
+  * Implementation of hook_delete
+  *
+  */
+ function query_export_delete($node){
+   $sql = "DELETE FROM {query_export_reports} WHERE nid = %d ";
+   db_query($sql, $node->nid);
+ }
+ /**
   * Implementation of hook_form().
   */
  function query_export_form(&$node) {
-   $form['title'] = array('#type' => 'textfield', '#title' => t('Title'), '#required' => TRUE, '#default_value' => $node->title, '#weight' => -5);
+   $form['#attributes'] = array("enctype" => "multipart/form-data");
-   //TO DO: Lots of stuff here.
+   $form['title'] = array('#type' => 'textfield', '#title' => t('Short Query Description'), '#required' => TRUE, '#default_value' => $node->title, '#weight' => -5);
+   //Handle preview problems...
+   if (!isset($node->query_type)) {
+     if (isset($_POST['edit'])) {
+       $edit = $_POST['edit'];
+       if (isset($edit['query_type'])) {
+         // make some resettings
+         if ($edit['query_type'] != 'views')
+           $_POST['edit']['views_query'] = '';
+         else if ($edit['query_type'] != 'civicrm')
+           $_POST['edit']['crm_query'] = '';
+       }
+     }
+   }
+   $form['query_type'] =
+     array('#type' => 'radios',
+           '#title' => t('Type Of Data Object'),
+           '#description' => t('What kind of data do you want to use for your report?'),
+           '#options' =>
+           array(
+                 'civicrm' => t('CiviCRM Group Of Contacts'),
+                 'views' => t('Drupals Views Data'),
+                 'custom' => t('Custom Query (SQL)'),
+                 ),
+           '#required' => TRUE,
+           '#default_value' => $node->query_type
+           );
+   //Nice option for use of Stupid Java Script tricks: hide one or the other:
+   $v_options =
+     array('' => "-- select a view --",
+           query_export_list_views_queries());
+   $v_default = $node->views_query ? $node->views_query : '';
+   $c_options =    array('' => "-- select a CiviCRM group --",
+                         query_export_list_civicrm_queries());
+   $c_default =  $node->crm_query ? $node->crm_query : '';
+   $form['views_query'] =
+     array('#type' => 'select',
+           '#title' => t('Exportable Drupal Views'),
+           '#options' => $v_options,
+           '#default_value' => $v_default,
+           '#description' => t('Choose a views table to pass to the reporting engine'));
+   $form['crm_query'] =
+     array('#type' => 'select',
+           '#title' => t('Exportable CiviCRM Groups'),
+           '#options' => $c_options,
+           '#default_value' => $c_default,
+           '#description' => t('Choose a group of CiviCRM contacts to pass to the reporting engine'));
+   if (module_exist('civinode')) {
+     $profile_opts = civinode_profile_selector(t('CRM Profile'),
+                                               t('For formatting CiviCRM contacts, choose a profile to define what fields to pass to the reporting engine'),
+                                               $node->query_profile);
+     $form['query_profile'] = $profile_opts;
+   }
+   //Custom stuff
+   $form['query_sql'] =
+     array('#type' => 'textarea',
+           '#title' => t('Custom SQL'),
+           '#description' => t("For custom queries only, you can design your own query on any Drupal table.  This is an advanced feature, and if your database disappears in a puff of smoke, don't say we didn't warn you :-)"),
+           '#cols' => 60,
+           '#rows' => 10,
+           '#default_value' => $node->query_sql
+           );
+   //File object for upload
+   $form['jasper_jrxml_upload'] =
+     array(
+           '#type' => 'file',
+           '#title' => t('Attach JRXML File'),
+           '#description' =>
+           t('Select a JasperReports report definition file (.jrxml) to upload to the server'));
    return $form;
  }
+ /**
+  * Implementation of hook_form_alter:
+  * Add a copy button to the main node form
+  *
+  */
+ function query_export_form_alter($form_id, &$form){
+   if ($form_id == 'query_export_node_form') {
+     $copy_value = t('Copy');
+     //check for '#submit' key, 'submit' item(s) #submit['node_form_submit']
+     //#node key on submit,  key nid['#value']
+     //check for a delete item, and if it exists, add a copy as well
+     if (isset($form['delete'])) {
+       //construct our copy button
+       if (!isset($form['copy'])) {
+         $form['copy'] =
+           array('#type' => 'submit',
+                 '#value' => $copy_value);
+         $form['copy']['#weight'] = $form['delete']['#weight'] + 2;
+       }
+     }
+   }
+ }
+ /**
+  * Take advantage of EditAsNew module if available.  For now,
+  * I'm using the renamed template.module version of this.
+  *
+  */
+ function query_export_template_insert(&$node, $template_node){
+   error_log("Template insert was called");
+ }
  function query_export_xmlrpc() {
    $methods = array();
-Line 141 
 function query_export_xmlrpc() {
+Line 847 
 function query_export_xmlrpc() {
    //with everything else.
    $methods[] =
      array(
-     'drupal.qexport.login',
+           'drupal.qexport.login',
-     'query_export_qexport_login_handler',
+           'query_export_qexport_login_handler',
-     array('struct', 'string', 'string'),
+           array('struct', 'string', 'string'),
-     t('Login/Authentication For Query Export. Takes user/pw, returns qe result object.'));
+           t('Login/Authentication For Query Export. Takes user/pw, returns qe result object.'));
    //Get queries of a certain type. pass cookie as first arg,
    //params as second.  params is a struct, with keys:
-Line 152 
 function query_export_xmlrpc() {
+Line 858 
 function query_export_xmlrpc() {
    //allow taxonomy somehow.
    $methods[] =
      array(
-     'drupal.qexport.query.list',
+           'drupal.qexport.query.list',
-     'query_export_qexport_query_list_handler',
+           'query_export_qexport_query_list_handler',
-     array('array', 'string', 'struct'),
+           array('array', 'string', 'struct'),
-     t('Fetches a list of queries that meet some set of criteria'));
+           t('Fetches a list of queries that meet some set of criteria'));
    //This method returns meta data about a query. For now, enough
    //info to describe the query to the reporting engine, whatever
    //that is.
    $methods[] =
      array(
-     'drupal.qexport.query.metadata',
+           'drupal.qexport.query.metadata',
-     'query_export_qexport_query_metadata_handler',
+           'query_export_qexport_query_metadata_handler',
-     array('array', 'string', 'string'),
+           array('array', 'string', 'string'),
-     t('Fetches metadata about a query'));
+           t('Fetches metadata about a query'));
-Line 175 
 function query_export_xmlrpc() {
+Line 881 
 function query_export_xmlrpc() {
    //queries.
    $methods[] =
      array(
-     'drupal.qexport.query.run',
+           'drupal.qexport.query.run',
-     'query_export_qexport_query_run_handler',
+           'query_export_qexport_query_run_handler',
-     array('array', 'string', 'string', 'struct'),
+           array('array', 'string', 'string', 'struct'),
-     t('Fetches an array of records for a query'));
+           t('Fetches an array of records for a query'));
-Line 204 
 function query_export_qexport_login_hand
+Line 910 
 function query_export_qexport_login_hand
    else {
      return array('user' => $user_name, 'cookie' => $auth_obj->cookie,
                   'expires' => $auth_obj->expires
-            );
+                  );
    }
-  //test stub
+   //test stub
-  //return array('user' => $user_name, 'cookie' => 'monster');
+   //return array('user' => $user_name, 'cookie' => 'monster');
  }
-Line 217 
 function query_export_qexport_query_list
+Line 923 
 function query_export_qexport_query_list
    error_log("user recognized as ", $access->user);
    if(!user_access('access query exports via XML-RPC')){
      error_log("User not authorized");
-     return array(); //isn't there a nicer way to bail??
+     return xmlrpc_server_error(QUERY_EXPORT_ERROR_UNAUTHORIZED, t('Not authorized for this user'));
    }
    //Test stub
    //return array('fortunes', 'quick_hits', 'best_episodes');
-Line 231 
 function query_export_qexport_query_meta
+Line 937 
 function query_export_qexport_query_meta
    global $user;
    $access = query_export_auth_from_cookie($cookie, $user);
    if(!user_access('access query exports via XML-RPC'))
-     return array(); //isn't there a nicer way to bail??
+     return xmlrpc_server_error(QUERY_EXPORT_ERROR_UNAUTHORIZED, t('Not authorized for this user'));
    return _qex_test_get_metadata($qname);
    //Test stub
    /**
-   return array(
+      return array(
-          array('name' => 'name',
+      array('name' => 'name',
-          'type' => 'string',
+      'type' => 'string',
-          'size' => 20,
+      'size' => 20,
-          'required' => 1),
+      'required' => 1),
-          array('name' => 'rating',
+      array('name' => 'rating',
-          'type' => 'int',
+      'type' => 'int',
-          'required' => 1)
+      'required' => 1)
-          );
+      );
    **/
  }
-Line 252 
 function query_export_qexport_query_meta
+Line 958 
 function query_export_qexport_query_meta
  function query_export_qexport_query_run_handler($cookie, $qname, $qparams){
    $results = array();
    /**
-   //Test stub
+    //Test stub
-   $results[] = array('name' => "Uncle Junior", 'rating' => 9);
+    $results[] = array('name' => "Uncle Junior", 'rating' => 9);
-   $results[] = array('name' => "Big Tony", 'rating' => 15);
+    $results[] = array('name' => "Big Tony", 'rating' => 15);
-   $results[] = array('name' => "Little Tony", 'rating' => 0);
+    $results[] = array('name' => "Little Tony", 'rating' => 0);
    **/
    global $user;
+   error_log("Entering Run XMLRPC handler");
    $access = query_export_auth_from_cookie($cookie, $user);
-   if(!user_access('access query exports via XML-RPC'))
+   if(!user_access('access query exports via XML-RPC')) {
-     return array(); //isn't there a nicer way to bail??
+     error_log("Not authorized for run!!");
+     return xmlrpc_server_error(QUERY_EXPORT_ERROR_UNAUTHORIZED, t('Not authorized for this user'));
+   }
+   error_log("OK for run; about to request records");
    return _qex_test_get_records_for_query($qname, $qparams);
  }
  /**
- * Authentication functions
+  * Authentication functions
- *
+  *
- */
+  */
  /**
- * Authenticate against drupal and return a query_export
+  * Authenticate against drupal and return a query_export
- * auth record. Return NULL if we did not authenticate.
+  * auth record. Return NULL if we did not authenticate.
- *
+  *
- */
+  */
  function query_export_authenticate($user_name, $password){
    global $user;
-Line 294 
 function query_export_authenticate($user
+Line 1003 
 function query_export_authenticate($user
    //And create the record (slight possibility of collision. Do I need to
    //add some kind of random seed as well?
    $sql = "INSERT INTO {query_export_auth} (uid, expires, user_name, cookie) " .
-          "VALUES(%d, %d, '%s', '%s')";
+     "VALUES(%d, %d, '%s', '%s')";
    db_query($sql, $user_obj->uid, $expires, $user_name, $cookie);
    //And get back our object
-   $obj = db_fetch_object(db_query("SELECT * FROM {{query_export_auth}} WHERE cookie = '%s'", $cookie));
+   $obj = db_fetch_object(db_query("SELECT * FROM {query_export_auth} WHERE cookie = '%s'", $cookie));
    return $obj;
  }
+ /**
+  * Create a cookie record so our user can pass a temporary
+  * authorization to our Java proxy
+  *
+  */
+ function query_export_generate_cookie($seed = 'salt'){
+   global $user;
+   //Calculate our expiry time
+   //Default at 1 minute
+   $expires = 60 + time();
+   //Make a cookie
+   $dough = sprintf("%s%d%s", $user->name, $expires, $salt);
+   $cookie = md5($dough);
+   //And create the record (slight possibility of collision. Do I need to
+   //add some kind of random seed as well?
+   $sql = "INSERT INTO {query_export_auth} (uid, expires, user_name, cookie) " .
+     "VALUES(%d, %d, '%s', '%s')";
+   db_query($sql, $user->uid, $expires, $user->name, $cookie);
+   $time = date('r');
+   error_log("$date: cookie $cookie for user " . $user->name);
+   return $cookie;
+ }
  /**
- * Authenticate by looking up the cookie. Must find the cookie, and
+  * Authenticate by looking up the cookie. Must find the cookie, and
- * the cookie should still be valid.
+  * the cookie should still be valid.
- *
+  *
- */
+  */
  function query_export_auth_from_cookie($cookie, &$user_obj){
    global $user;
-Line 324 
 function query_export_auth_from_cookie($
+Line 1061 
 function query_export_auth_from_cookie($
      _query_export_construct_user($obj->uid);
      if ($user->uid) {
+       $time = date('r');
+       error_log("$time: authed as user " . $user->uid . "with cookie $cookie");
        return $obj;
      }
    }
+   $time = date('r');
+   error_log("$time: auth failed with cookie $cookie");
    //Or we are nobody at all
    return NULL;
  }
-Line 394 
 function query_export_test_rpc(){
+Line 1135 
 function query_export_test_rpc(){
  }
- function _qex_test_avail_queries(){
+ function query_export_list_civicrm_queries(){
-   $queries = array();
-   //For now, let's export one query for each flexinode type we know about
-   if (module_exist('flexinode')) {
-     $types = flexinode_content_types();
-     foreach($types as $ctype_id => $type_data){
-       $key = 'flexinode::flexinode-' . $ctype_id;
-       $queries[$key] = $type_data->name; //
-     }
-   }
    //And for civicrm, list our groups
+   $queries = array();
    if (module_exist('civicrm') and module_exist('civinode')) {
      $groups = civinode_get_groups(); //get 'em all for now
      if($groups){
-Line 414 
 function _qex_test_avail_queries(){
+Line 1147 
 function _qex_test_avail_queries(){
        }
      }
    }
+   return $queries;
+ }
+ function _qex_test_avail_queries(){
+   $queries = array();
+   //For now, let's export one query for each flexinode type we know about
+   /**
+   //No flexinode unless someone begs :-)
+   //and pays too, for that matter
+   if (module_exist('flexinode')) {
+   $types = flexinode_content_types();
+   foreach($types as $ctype_id => $type_data){
+   $key = 'flexinode::flexinode-' . $ctype_id;
+   $queries[$key] = $type_data->name; //
+   }
+   }
+   **/
+   //And for civicrm, list our groups
+   if (module_exist('civicrm') and module_exist('civinode')) {
+     $queries = query_export_list_civicrm_queries();
+   }
+   //If we have created an custom queries, fetch them now
+   $custom_queries = _qex_fetch_custom_queries();
+   foreach ($custom_queries as $qname => $qtitle) {
+     $queries[$qname] = $qtitle;
+   }
    if (module_exist('views') and module_exist('civinode')) {
-     $groups = civinode_get_groups(); //get 'em all for now
      //TO DO: I probably need to wrap this stuff into
      //some kind of loader function.
      if (!function_exists('query_export_list_views_queries')) {
-Line 437 
 function _qex_test_avail_queries(){
+Line 1198 
 function _qex_test_avail_queries(){
  }
+ /**
+  * Return our custom queries
+  *
+  */
+ function _qex_fetch_custom_queries(){
+   $sql = "select q.query_name, n.title as query_title from {node} n LEFT JOIN {query_export_reports} q ON (n.nid = q.nid) WHERE q.query_type = 'custom'";
+   //exclude queries we do not have the right to see
+   $mod_sql = db_rewrite_sql($sql, 'n', 'nid');
+   $rslt = db_query($mod_sql);
+   $queries = array();
+   while ($row = db_fetch_array($rslt)) {
+     $queries[$row['query_name']] = $row['query_title'];
+   }
+   return $queries;
+ }
  function _qex_test_get_metadata($qname){
    list($namespace, $name) = explode('::', $qname);
    //Test data: all legal names have this
-Line 445 
 function _qex_test_get_metadata($qname){
+Line 1223 
 function _qex_test_get_metadata($qname){
    $type_info = query_export_get_type($namespace, $name);
    if(!$type_info){
      //consider logging error or telling xmlrpc
+     error_log("No type info... bailing");
      return xmlrpc_server_error(QUERY_EXPORT_ERROR_NO_SUCH_QUERY, t('Query is unknown to server'));
    }
    //Do not pass internal data to XMLRPC
-Line 457 
 function _qex_test_get_metadata($qname){
+Line 1236 
 function _qex_test_get_metadata($qname){
  function _qex_test_get_records_for_query($qname, $params){
    list($namespace, $name) = explode('::', $qname);
+   //Temporary hack: custom types
+   //if ($namespace == 'custom' and !user_access('access custom tables'))
+   //  xmlrpc_server_error(QUERY_EXPORT_ERROR_UNAUTHORIZED, t('Not authorized for this user'));
    //process parameters
    $args = isset($params['args']) ? $params['args'] : FALSE;
    $start = isset($params['start']) ? $params['start'] : 0;
-   $num_recs = isset($params['num_recs']) ? $params['num_recs'] : 200;
+   //num_recs should be 0 if no limit, the number otherwise. Not all sources
+   //implement this (currently, only CiviCRM does)
+   $num_recs = isset($params['num_recs']) ? $params['num_recs'] : 0;
+   $profile = isset($params['profile_id']) ? $params['profile_id'] : 0;
+   $query_nid = isset($params['query_nid']) ? $params['query_nid'] : 0;
+   return query_export_get_record_array($namespace, $name, $query_nid,
+                                        $args, $profile, $start, $num_recs);
+ }
+ /**
+  * Some view support for choosing queries
+  *
+  */
+ /**
+  * Implementation of hook_views_tables (View API)
+  *
+  */
+ function query_export_views_tables(){
+   $tables['query_export_defs'] =
+     array('name' => 'query_export_reports',
+           'provider' => 'query_export',
+           'join' =>
+           array('left' =>
+                 array('table' => 'node',
+                       'field' => 'nid'),
+                 'right' =>
+                 array('field' => 'nid')
+                 ),
+           'fields' =>
+           array('query_name' =>
+                 array('name' => t('Query Exporter: Query Name'),
+                       'handler' => 'query_export_qname_view_handler',
+                       'sortable' => TRUE),
+                 'query_type' =>
+                 array('name' => t('Query Exporter: Query Type')),
+                 'query_profile' =>
+                 array('name' => t('Query Exporter: CRM Profile Definition'),
+                       'handler' => 'query_export_profile_view_handler'
+                       ),
+                 'last_update' =>
+                 array('name' => t('Query Exporter: Last Updated'),
+                       'handler' => 'query_export_unix_time_view_handler'),
+                 )
+           );
+   //Expose data handlers
+   $tables['query_export_formatters'] =
+     array('name' => 'query_export_data_handlers',
+           'provider' => 'query_export',
+           'join' =>
+           array('left' =>
+                 array('table' => 'node',
+                       'field' => 'nid'),
+                 'right' =>
+                 array('field' => 'nid')
+                 ),
+           'fields' =>
+           array(
+                 'field_name' =>
+                 array('name' => t('Query Exporter: Field Name'),
+                       'addlfields' => array('nid'),
+                       'handler' =>
+                       array('query_export_formatter_field_link_handler' => t('Edit Or Delete Link'),
+                             'query_export_passthru_handler' => t('Pass through')),
+                       'sortable' => TRUE),
+                 'handler' =>
+                 array('name' => t('Query Exporter: Data Formatter'),
+                       'handler' => 'query_export_formatter_name_handler'),
+                 'extra' =>
+                 array('name' => t('Query Exporter: Extra Formatter Info')),
+                 )
+           );
+   //Expose default parameters
+   $tables['query_export_parameters'] =
+     array('name' => 'query_export_param_defaults',
+           'provider' => 'query_export',
+           'join' =>
+           array('left' =>
+                 array('table' => 'node',
+                       'field' => 'nid'),
+                 'right' =>
+                 array('field' => 'nid')
+                 ),
+           'fields' =>
+           array(
+                 'param_name' =>
+                 array('name' => t('Query Exporter: Default Parameter'),
+                       'addlfields' => array('nid'),
+                       'handler' =>
+                       array('query_export_param_link_handler' => t('Edit Or Delete Link'),
+                             'query_export_passthru_handler' => t('Pass through')),
+                       'sortable' => TRUE),
+                 'default_value' =>
+                 array('name' => t('Query Exporter: Default Param Value')),
+                 'description' =>
+                 array('name' => t('Query Exporter: Parameter Description')),
+                 )
+           );
+   return $tables;
+ }
+ function query_export_profile_view_handler($fieldinfo, $fielddata, $value, $data){
+   if (module_exist('civinode') and module_exist('civicrm')) {
+     if ($value)
+       $title = civinode_get_profile_title($value);
+     else
+       $title = t('NA');
+     if ($title)
+       return $title;
+     else
+       return $value;
+   }
+   else
+     return t('NA');
+ }
+ function query_export_qname_view_handler($fieldinfo, $fielddata, $value, $data){
+   return query_export_query_ui_name($value);
+ }
+ function query_export_unix_time_view_handler($fieldinfo, $fielddata, $value, $data){
+   if (!$value or !is_numeric($value))
+     return t('NA');
+   return date('r', $value);
+ }
+ function query_export_formatter_name_handler($fieldinfo, $fielddata, $value, $data){
+   query_export_prime_handler_cache(); //safe to call multiple times
+   $title = query_export_get_data_handlers($value);
+   if ($title)
+     return $title;
+   else
+     return $value;
+ }