httplib._pmod

Go to the documentation of this file.

/* Copyright (C) 2000-2006  Thomas Bopp, Thorsten Hampel, Ludger Merkens
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 * 
 * $Id: httplib.pmod,v 1.1 2008/03/31 13:39:57 exodusd Exp $
 */
#include <config.h>
#include <macros.h>
#include <attributes.h>
#include <classes.h>
#include <database.h>




constant days = ({ "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" });
constant months=(["Jan":0, "Feb":1, "Mar":2, "Apr":3, "May":4, "Jun":5,
            "Jul":6, "Aug":7, "Sep":8, "Oct":9, "Nov":10, "Dec":11,
            "jan":0, "feb":1, "mar":2, "apr":3, "may":4, "jun":5,
            "jul":6, "aug":7, "sep":8, "oct":9, "nov":10, "dec":11,]);
constant montharr = ({ "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug",
                      "Sep", "Oct", "Nov", "Dec" });


/**
 * Identify a browser and return identified parameters
 * as a mapping:
 * client: MSIE|mozilla|opera
 * os: Linux|macosx|windows 95|windows 98|windows nt|windows
 * language: german|english|...
 * xres: resolution x (width)
 * yres: resolution y (height)
 *  
 * @param array id - components of client request header
 * @param mapping request_headers - the mapping of all request headers
 * @return mapping (see function description)
 */
mapping identify_browser(array id, mapping req_headers)
{
    int i;
    mapping client = ([ "language": "english", ]);

    if ( !arrayp(id) || !mappingp(req_headers) )
      return client;

    if ( (i=search(id, "MSIE")) >= 0 ) {
   client["client"] = "MSIE";
   client["client-version"] = id[i+1];
    }
    else {
   string sclient, sversion;
   sscanf(id[0],"%s/%s",sclient,sversion);
   client["client"] = client;
   client["client-version"] = version;
    }
    if ( search(id, "Linux") >= 0 )
   client["os"] = "linux";
    else if ( search(id, "Mac OS X") >= 0 )
   client["os"] = "macosx";
    else if ( search(id, "Windows NT 4.0") >= 0 )
   client["os"] = "windows nt";
    else if ( search(id, "Windows 95") >= 0 )
   client["os"] = "windows 95";
    else if ( search(id, "Windows 98") >= 0 )
   client["os"] = "windows 98";
    else if ( stringp(req_headers["user-agent"]) && 
         search(req_headers["user-agent"], "Windows") >= 0 )
   client["os"] = "windows";
    else 
   client["os"] = "unknown";
    
    
    int xres, yres, tmp1, tmp2;
    xres = 1024;
    yres =  768;
    foreach(id, string modifier) {
   if ( sscanf(modifier, "%dx%d%*s", tmp1, tmp2) >= 2 ) {
       xres = tmp1;
       yres = tmp2;
   }
    }
    client["xres"] = (string)xres;
    client["yres"] = (string)yres;
    if ( mappingp(req_headers) ) {
      client->language = identify_language(req_headers);
    }
    return client;
}

string identify_language(mapping req_headers)
{
  if ( stringp(req_headers["accept-language"]) ) {
    int de, en, zh;
    de = search(req_headers["accept-language"], "de");
    en = search(req_headers["accept-language"], "en");
    zh = search(req_headers["accept-language"], "zh");
    if ( de == -1 && en == -1 && zh >= 0 ) 
      return "chinese";
    else if ( de == -1 )
      return "english";
    else if ( en == -1 || de < en ) 
      return "german";
    else
      return "english";
  }
  return "english";
}

mapping vars_to_utf8(mapping vars, string encoding)
{
  foreach(indices(vars), string key)
    if ( stringp(vars[key]) )
      vars[key] = string_to_utf8(vars[key]);
  return vars;
}

/**
 * Returns if time t is later than time/length string a, or len
 * differs from the length encoded in the string a.
 * Taken from caudium webserver.
 *  
 * @param string a - the timestamp (cached on client side?!)
 * @param int t - a timestamp, modification date with length.
 * @param void|int len - the current length of a file
 * @return 1 or 0, true or false.
 */
int is_modified(string a, int t, void|int len)
{
  mapping t1;

  int day, year, month, hour, minute, second, length;
  string m, extra;
  if(!a)
    return 1;
  t1=gmtime(t);
   // Expects 't' as returned from time(), not UTC.
  sscanf(lower_case(a), "%*s, %s; %s", a, extra);
  if(extra && sscanf(extra, "length=%d", length) && len && length != len)
    return 1;

  if(search(a, "-") != -1)
  {
    sscanf(a, "%d-%s-%d %d:%d:%d", day, m, year, hour, minute, second);
    year += 1900;
    month=months[m];
  } else   if(search(a, ",") == 3) {
    sscanf(a, "%*s, %d %s %d %d:%d:%d", day, m, year, hour, minute, second);
    if(year < 1900) year += 1900;
    month=months[m];
  } else if(!(int)a) {
    sscanf(a, "%*[^ ] %s %d %d:%d:%d %d", m, day, hour, minute, second, year);
    month=months[m];
  } else {
    sscanf(a, "%d %s %d %d:%d:%d", day, m, year, hour, minute, second);
    month=months[m];
    if(year < 1900) year += 1900;
  }

  if(year < (t1["year"]+1900))                                
    return 1;
  else if(year == (t1["year"]+1900)) 
    if(month < (t1["mon"]))  
      return 1;
    else if(month == (t1["mon"]))      
      if(day < (t1["mday"]))   
   return 1;
      else if(day == (t1["mday"]))      
   if(hour < (t1["hour"]))  
     return 1;
   else if(hour == (t1["hour"]))      
     if(minute < (t1["min"])) 
       return 1;
     else if(minute == (t1["min"]))     
       if(second < (t1["sec"])) 
         return 1;
  return 0;
}

string http_date(int t)
{
#if constant(gmtime)
  mapping l = gmtime( t );
#else
  mapping l = localtime(t);
  t += l->timezone - 3600*l->isdst;
  l = localtime(t);
#endif
  return(sprintf("%s, %02d %s %04d %02d:%02d:%02d GMT",
            days[l->wday], l->mday, montharr[l->mon], 1900+l->year,
            l->hour, l->min, l->sec));

}

/**
 * Get a html page which redirects to the given URL.
 *  
 * @param string url - the URL to redirect to.
 * @return html code of redirection to url.
 */
string redirect(string url, int|void refresh_time)
{
  return "<html><head>"+redirect_meta(url, refresh_time)+"</head></html>";
}

string redirect_meta(string url, int|void refresh_time)
{
    return "<meta http-equiv=\"refresh\" content=\""+
   refresh_time+";URL="+url+"\"/>";
}

/**
 * This function takes request and parses the given data,which
 * represents a MIME Message (the body of the request).
 * Returned is a mapping with the parts of the message.
 * HTTP create multipart messages with variable encoded as
 * parts of the body.
 * This function was taken out of caudium code.
 *  
 * @param object req - the request object
 * @param string data - the body of the message
 * @return mapping of parsed variables.
 */
mapping parse_multipart_form_data(object req, string data)
{
    mapping variables = ([ ]);
    
    MIME.Message messg = MIME.Message(data, req->request_headers);
    
    foreach(messg->body_parts||({}), object part) {
   if(part->disp_params->filename) {
            // FIXME: this overwrites multiple parts and only keeps the last one
       variables[part->disp_params->name]=part->getdata();
       string fname=part->disp_params->filename;
       if( part->headers["content-disposition"] ) {
           array fntmp=part->headers["content-disposition"]/";";
           if( sizeof(fntmp) >= 3 && search(fntmp[2],"=") != -1 ) {
               fname=((fntmp[2]/"=")[1]);
               fname=fname[1..(sizeof(fname)-2)];
           }
           
       }
       variables[part->disp_params->name+".filename"]=fname;
   } else {
       if(variables[part->disp_params->name])
           variables[part->disp_params->name] += "\0" + part->getdata();
       else
           variables[part->disp_params->name] = part->getdata();
   }
    }
    return variables;
}

/**
 * return a backtrace in html with <li>
 *  
 * @param array|string bt - the pike backtrace
 * @return html generated 
 */    
string backtrace_html(array|object|string bt)
{
    string errStr = "";
    
    if ( intp(bt) ) {
   werror("wrong backtrace format:\n"+
          sprintf("%O\n",backtrace()));
   throw( ({
       "Wrong backtrace format in backtrace_html().\n", backtrace() })) ;
    }
    
    if ( arrayp(bt) || objectp(bt) ) {
   errStr += "<ul>\n";
   for ( int i = sizeof(bt)-1; i >= 0; i-- ) {
       array line = bt[i];
       if ( stringp(line[0]) ) {
           string oname = line[0];
           int oid;
           if ( sscanf(oname, "/DB:#%d", oid) > 0 )
               oname = _Server->get_module("filepath:tree")->
                   object_to_filename(find_object(oid));
           errStr += sprintf("<li> %s,  line %d</li>\n", oname, line[1]);
       }
   }
   errStr += "</ul>\n";
    }
    else 
   errStr += replace(bt, ({ "\r\n", "\n", "<", ">" }),
                     ({ "<BR/>", "<BR/>", "&lt;", "&gt;" }) );
    return errStr;
}

string html_backtrace(array|object|string bt)
{
    return backtrace_html(bt);
}


/**
 * return a page for displaying errors
 *  
 * @param message - the error message
 * @param back - what page to go back to (action back)
 * @return the html code for the page
 */
string error_page(string message, string|void back)
{
  string html = "";
  // need a webinterface version check here
  object web = _Server->get_module("package:web");
  string wi_version = "0.0.0";
  if (objectp(web)) wi_version = web->get_version();
  array wiv = wi_version / ".";
  
  // if webinterface version >= 2.1, then use new method respecting user
  // stylesheet setting (and may use internationalization in the future..)
  if ( (sizeof(wiv) > 0 && (int)wiv[0]>2) || (sizeof(wiv) > 1 && (int)wiv[0]>=2 &&\
                                         (int)wiv[1]>=1) ) {
    object xsl;
    string xml;

    object user = geteuid();
    if (!objectp(user)) user = this_user();
    object css_style;
    if (objectp(user)) css_style = user->query_attribute("USER_CSS_STYLE");
    xsl = find_object("/stylesheets/errors.xsl");
      xml = "<?xml version='1.0' encoding='utf-8'?>"+
        "<Object>";
      if (objectp(css_style)) {
        xml += "<properties><css_style><Object><path>"+
     _Server->get_module("filepath:tree")->object_to_filename(css_style)+
     "</path></Object></css_style></properties>";
      }
      xml += "<actions/>\n<message><![CDATA["+message+
   "]]></message></Object>";

      mapping myvars = ([]);
      myvars["back"] = back;
      //myvars["message"] = message;    
      /*
      // doesnt work yet, need help and more testing
      // produces strange error "Start Tag expected..." but xsl.xml file looks fine \
?!
);
      werror("xml="+xml+"\r\n");
      */
      html = _Server->get_module("libxslt")->run(xml, xsl, myvars );
  }
  else {  // do it the old-fashioned way...
    object xsl;
    string xml;
    xsl = find_object("/stylesheets/errors.xsl");
      xml = "<?xml version='1.0' encoding='utf-8'?>"+
       "<error><actions/>\n<message><![CDATA["+message+
   "]]></message></error>";
      html = _Server->get_module("libxslt")->run(xml, xsl, (["back": back,]) );
  }
  return html;

}


/**
 * Remove umlaute from a string str and return the changed string.
 *  
 * @param string str - the string to convert.
 * @return the source string with umlaute removed.
 */
string no_uml(string str)
{
    if ( !stringp(str) ) return "";
    return "<![CDATA["+replace_uml(str)+"]]>";
}

string encode_url(string str)
{
    return replace_uml(str);
}

string replace_uml(string str)
{
  if ( !stringp(str) )
    return "";
  string result = "";
  for ( int i = 0; i < sizeof(str); i++ ) {
      switch(str[i]) {
      case '"':
     result += "%22";
     break;
      case '<':
     result += "%3c";
     break;
      case '>':
     result += "%3e";
     break;
      case '?':
     result += "%3f";
     break;
      case ' ':
     result += "%20";
     break;
      case '#':
     result += "%23";
     break;
      case '&':
     result += "%26";
     break;
      case '+':
     result += "%2b";
     break;
      case ',':
     result += "%2c";
     break;
      case ';':
     result += "%3b";
     break;
      case '@':
     result += "%40";
     break;
      case '$':
     result += "%24";
     break;
      case '%':
     result += "%25";
     break;
      case '{':
     result += "%7b";
     break;
      case '}':
     result += "%7d";
     break;
      case '|':
     result += "%7c";
     break;
      case '\\':
     result += "%5c";
     break;
      case '[':
     result += "%5b";
     break;
      case ']':
     result += "%5d";
     break;
      case '`':
     result += "%60";
     break;
      default:
     if ( str[i] >= 128 ) {
         result += sprintf("%%%x", str[i]);
     }
     else
         result += str[i..i];
      }
  }
  return result;

#if 0
  return replace(result,
            ({ "ä", "ö", "ü", "Ä", "Ö", "Ü", "ß", "<", ">", "?", " ", "#", ":", "\303\244", "\303\266", "\303\274", "\303\234", "\303\204", "\303\226", "\303\237", "\"" }),
            ({ "%e4", "%f6", "%fc", "%c4", "%d6", "%dc", "%df",
                     "%3c", "%3e", "%3f", "%20", "%23", "%3a", "%C3%A4", "%C3%B6", "%C3%BC", "%C3%9C", "%C3%84", "%C3%96", "%C3%9F", "%2d" }));  
#endif
}

/**
 * Replace the Umlaute and other unpleasent chars.
 *  
 * @param string str - the string to replace.
 * @return replaced string
 */
string uml_to_html(string str)
{
    if ( !stringp(str) ) return "";
    return 
   replace(str, ({ "ä","ö","ü", "Ä", "Ö", "Ü", "<", ">", "&" }),
           ({ "&auml;", "&ouml;", "&uuml;", "&Auml;", "&Ouml;",
                  "&Uuml;", "&lt;","&gt;", "&amp;" }));
}

string url_to_string(string str)
{
    return Protocols.HTTP.Server.http_decode_string(str);
#if 0
    int len = strlen(str);
    string res = "";
    
    for ( int i = 0; i < len; i++ ) {
   if ( str[i] == '%' && i < len - 2 ) {
       int        val;
       string v = str[i..i];
       if ( sscanf(str[i+1..i+2], "%x", val) ) 
           v[0] = val;
       res += v;
       // jump over %xx value
       i += 2;
   }
   else {
       res += str[i..i];
   }
    }
    return res;
    return replace(str, 
              ({ "%e4", "%f6", "%fc", "%c4", "%d6", "%dc", "%df", 
                     "%3c", "%3e", "%3f", "%20", "%5B", "%5D" }),
              ({ "ä", "ö", "ü", "Ä", "Ö", "Ü", "ß", "<", ">", "?", " ",
                     "[", "]" }));
#endif
}


/**
 * Detect encoding in a string (utf-8 or iso-8859-1)
 *  
 * @param string text - the text to check (should be html)
 * @return the detected encoding - utf8 if nothing else found.
 */
string detect_encoding(string text)
{
  string encoding = "iso-8859-1";
  
  if ( !stringp(text) )
    return encoding;
  
  int n = search(text, "charset=");
  if ( n == -1 ) 
    n = search(text, "CHARSET=");
  
  if ( n > 0 ) {
    string enc;
    
    sscanf(text[n+8..], "%s\"%*s", enc);
    if ( lower_case(enc) == "utf-8" )
      encoding = "utf-8";
    else
      encoding = lower_case(enc);
  }
  return encoding;
}


/**
 * Get the html representation of text/plain content.
 *  
 * @param string text
 * @return the html representation
 */
string text_to_html(string text)
{
    return replace(text, ({ "\n", "  " }), ({ "<br/>", "&nbsp;" }));
}


/**
 * Return a result page in html with the message in the content
 * area.
 *  
 * @param string message - the message to print out.
 * @param string next - the next link in the header area.
 * @param string|void title - the title for the page.
 * @param string|void head - optional header arguments.
 * @return html result page.
 */
string 
result_page(string message, string next, string|void title, string|void head)
{
    string html = "";
    // need a webinterface version check here
    object web = _Server->get_module("package:web");

    string wi_version = "0.0.0";
    if (objectp(web)) wi_version = web->get_version();
    array wiv = wi_version / ".";
    // if webinterface version >= 2.1, then use new method respecting user 
    // stylesheet setting (and may use internationalization in the future..)
    if ( (sizeof(wiv) > 0 && (int)wiv[0]>2) || (sizeof(wiv) > 1 && (int)wiv[0]>=2 && (int)wiv[1]>=1) ) {
      object xsl;
      string xml;
      
      if ( !stringp(title) ) title = "Result";
      if ( !stringp(head) ) head = "";
  
      object user = geteuid();
      if (!objectp(user)) user = this_user();
      object css_style;
      if (objectp(user)) css_style = user->query_attribute("USER_CSS_STYLE");
      xsl = find_object("/stylesheets/result.xsl");
      xml = "<?xml version='1.0' encoding='utf-8'?>"+
            "<Object>";
      if (objectp(css_style)) {
        xml += "<properties><css_style><Object><path>"+
               _Server->get_module("filepath:tree")->object_to_filename(css_style)+
               "</path></Object></css_style></properties>";
      }
      xml += "<head><![CDATA["+head+"]]></head>"+
             "<title>"+title+"</title><actions/>\n<message><![CDATA["+message+
             "]]></message></Object>";
      mapping myvars = ([]);
      myvars["back"] = next;
      myvars["title"] = title;
      myvars["head"] = head;
//      myvars["message"] = message;    
      /*
      // doesnt work yet, need help and more testing
      // produces strange error "Start Tag expected..." but xsl.xml file looks fine ?!
      werror("xml="+xml+"\r\n");
      */
      html = _Server->get_module("libxslt")->run(xml, xsl, myvars );
    }
    else {  // do it the old-fashioned way...
      object xsl;
      string xml;
      
      if ( !stringp(title) ) title = "Result";
      if ( !stringp(head) ) head = "";
  
      xsl = find_object("/stylesheets/result.xsl");
      xml = "<?xml version='1.0' encoding='utf-8'?>"+
          "<result>"+
          "<head><![CDATA["+head+"]]></head>"+
          "<title>"+title+"</title><actions/>\n<message><![CDATA["+message+
          "]]></message></result>";
      html = _Server->get_module("libxslt")->run(xml, xsl, (["back": next,]) );
    }
  return html;
}

/**
 * Return a mapping in appropriate format for Protocols.HTTP to handle.
 *  
 * @param int code - the http return code.
 * @return mapping suitable for Protocols.HTTP
 */
mapping low_answer(int code, string response, void|mapping extra)
{
 mapping answer = ([ "error": code, "rettext": response, ]);
 if ( mappingp(extra) ) 
     answer->extra_heads = extra;
 return answer;
}

/**
 * Get a mapping of client informations from the submitted vars mapping.
 *  
 * @param mapping vars - the submitted variables.
 * @return mapping of client information
 */
mapping get_client_map(mapping vars)
{
  if ( !mappingp(vars->__internal) )
    return ([ ]);
  mapping client_map = 
    identify_browser(
                vars["__internal"]["client"],
                vars["__internal"]["request_headers"]);
  object user = this_user();
  if ( !objectp(user) )
      return client_map;
  string l = user->query_attribute(USER_LANGUAGE);
  if ( stringp(l) )
      client_map->language = l;
  return client_map;
}


mapping
set_auth_cookie(string user, string pass)
{
  mapping c =
    set_cookie("steam_auth", MIME.encode_base64(user+":"+pass));
  c["Cache-Control"] = "no-cache=\"set-cookie\"";
  return c;
}

/**
 * Set a cookie, returns just the header information in a mapping which
 * should be send to http as extra-heads.
 *  
 * @param string name - the name of the cookie.
 * @param string value - value of the cookie.
 * @return mapping of cookie representation.
 */
mapping 
set_cookie(string name, string value, int|void expires, string|void path)
{
  return ([ "Set-Cookie":
       name+"="+Protocols.HTTP.http_encode_cookie(value), ]);
}



/**
 * Basic function to get html from a given object. The function
 * sets some parameters like ports and the hostname of this server.
 * If the variables source is set to true, then only the xml code
 * will be returned wrapped in a html page (inside <pre>).
 *  
 * @param object obj - the object to get xml/html code for
 * @param object xsl - the xsl stylesheet to be used for transformation
 * @return html (?) code as a string
 */
string run_xml(object|string obj, object xsl, mapping vars)
{
    string html, xml;

    if ( !vars->client ) {
   mapping client_map = get_client_map(vars);
   vars |= client_map;
    }

    vars["host"] = _Server->query_config(CFG_WEBSERVER);
    vars["port_ftp"] = (string)_Server->query_config("ftp_port");
    vars["port_http"] = (string)_Server->query_config("https_port");
    vars["port_irc"] = (string)_Server->query_config("irc_port");
    if ( objectp(this_user()) )
      vars["user_id"] = (string)(this_user()->get_object_id());
    else
      vars["user_id"] = (string)(_GUEST->get_object_id());

    if ( stringp(obj) ) {
   xml = obj;
    }
    else {
   xml = _Server->get_module("Converter:XML")->get_xml(obj, xsl, 
                                            vars, (int)vars["active"]);
    }
    if ( vars->source == "true" )
   return xml;
    
    html = _Server->get_module("libxslt")->run(xml, xsl, vars);    

    return html;
}


protected:
 object parse_rxml_tag(object node, mapping variables, mapping tags)
{
    object father = node->father;

    // is it registered rxml entity ?
    object tag = tags[node->name];
    if ( objectp(tag) ) {
   mixed err = catch {
       variables->args = ([ ]);

       // dont trust data in node->data, it does not contain tags
       variables->args->body = node->get_sub_xml();
       // convert the attributes into vars->args
       foreach(indices(node->attributes), string idx) {
           variables->args[idx] = node->attributes[idx];
       }
       string result;
       
       if ( tag->get_object_class() & CLASS_DOCLPC ) 
           result = tag->call_script(variables);
       else
           result = tag->execute(variables);
       
       // replace this node with text node with result !
       node->replace_node(result);
   };
   if ( err != 0 ) {
       if ( stringp(err) || intp(err) )
           node->replace_node("Some error occured: " + err);
       else
           node->replace_node(
               "An error occured on tag " + node->name + "<br/>"+
               err[0]+"<br/><!---"+html_backtrace(err[1])+"--->");
   }
    }
    return father;
}

public:

/**
 * Parse rxml tags inside html files. The html code needs to be
 * wellformed (xhtml).
 *  
 * @param string result - the html code to parse
 * @param mapping variables - a mapping of variables
 * @param mapping tags - tags to replace inside the html code.
 * @return resulting html code with rxml tags replaced.
 */
string rxml(string result, mapping variables, mapping tags)
{
    // parse result
    object root;
    float t = gauge {
    object parser = ((program)"/base/xml_parser")();
    object node = parser->parse_data(result);
    root = node->get_parent();
    
    // now traverse tree to bottom and from there replace rxml tags
    array leafs = node->get_leafs();
    
    for ( int i = 0; i < sizeof(leafs); i++ ) {
   object leaf = leafs[i];
   object father = parse_rxml_tag(leaf, variables, tags);
   // add the father to list for BFS
   if ( objectp(father) && search(leafs, father) == -1 )
       leafs += ({ father });
    }
    };
    return root->get_last_child()->get_xml();
}

protected:
 object stylesheet_from_map(mixed stylesheet)
{
  if ( stringp(stylesheet) )
    return _FILEPATH->path_to_object(stylesheet);
  else if ( objectp(stylesheet) )
    return stylesheet;
  return 0;
}

public:

protected:
 object find_user_stylesheet(object user, object obj, string type)
{
  object xsl;
  mixed xslMap = obj->query_attribute("xsl:"+type);

  if ( objectp(xslMap) )
      return xslMap;

  if ( !mappingp(xslMap) ) 
    xslMap = ([ ]);
  object aGroup = user->get_active_group();
  
  // select the apropriate stylesheet depending on the group
  if ( !objectp(xsl) ) {
    if ( objectp(xslMap[aGroup]) )
      xsl = stylesheet_from_map(xslMap[aGroup]);
    else {
      object grp;
      
      array groups = user->get_groups();
      for ( int i = 0; i < sizeof(groups); i++ ) {
   if (objectp(groups[i]) && groups[i]->status()>=0)
     groups += groups[i]->get_groups();
      }
      
      foreach( groups, grp ) {
   if ( objectp(xslMap[grp]) )
     xsl = stylesheet_from_map(xslMap[grp]);
      }
    }
  }
  return xsl;
}

public:

/**
 * Get the appropriate stylesheet for a user to display obj.
 *  
 * @param object user - the active user
 * @param object obj - the object to show
 * @param mapping vars - variables.
 * @return the appropriate stylesheet to be used.
 */
object get_xsl_stylesheet(object user, object obj, mapping vars)
{
    object xsl;

    xsl = find_user_stylesheet(user, obj, vars->type);
    if ( stringp(vars["style"]) )
      xsl = _FILEPATH->path_to_object(vars["style"]);
    else if ( !objectp(xsl) ) {
      // if no stylesheet is set for the given type explicitely, we take 
      // content and search in the content directory (styles/style)
      xsl = find_user_stylesheet(user, obj, "content");
      if ( objectp(xsl) ) {
   object xslcont = xsl->get_environment();
   if ( !objectp(xslcont) )
     xslcont = find_object("/stylesheets");
// MESSAGE("XSL Container is: %s\n", xslcont->get_identifier());
   xsl = xslcont->get_object_byname(vars->type); 
      }
    }
    if ( !objectp(xsl) ) {
      if ( vars->type == "PDA:content" )
   vars->type = "zaurus";
      xsl = _FILEPATH->path_to_object("/stylesheets/"+vars->type+".xsl");
    }

    return xsl;
}


/**
 * Get the appropriate stylesheet for an object (usually xml document)
 * checks for xsl:document
 *  
 * @param object obj - the object to show
 * @return the appropriate stylesheet to be used using xsl:document or xsl:public
 */
object get_stylesheet(object obj)
{
    object xsl;
    xsl = find_user_stylesheet(this_user(), obj, "document");
    if ( !objectp(xsl) ) {
   if ( obj->query_attribute("xsl:use_public") )
       return obj->query_attribute("xsl:public");
   // try to parse ...
   if ( obj->query_attribute(DOC_MIME_TYPE) == "text/xml" ) {
       string content = obj->get_content();
       if ( stringp(content) && content != "" ) {
         catch {
           object node = xmlDom.parse(content);
           mapping pi = node->get_pi();
           if ( pi["xml-stylesheet"] ) {
                  array stylesheets;

                  if ( !arrayp(pi["xml-stylesheet"]) )
                    stylesheets = ({ pi["xml-stylesheet"] });
                  else
                    stylesheets = pi["xml-stylesheet"];
                  foreach(stylesheets, string stylesheet ) {
                    string styleref;
                    object fp = _Server->get_module("filepath:tree");
                    object env = obj->get_environment();
                    string type = "text/xsl";
                    if ( search(stylesheet, "type=") >= 0 )
                      sscanf(stylesheet, "%*shref=\"%s\"%*s", type);
                    if ( type == "text/xsl" && 
                         sscanf(stylesheet, "%*shref=\"%s\"%*s", styleref) )
                    {
                      if ( sscanf(styleref, "%s.css", styleref) )
                        continue; // no css

                      if ( styleref[0] != '/' )
                        return fp->resolve_path(env,styleref);
                      else
                        return fp->path_to_object(styleref);
                    }
                  }
           }
         };
       }
   }           
    }
    return xsl;
}



class testTag  {
public:
    string execute(mapping vars) {
   return "Hello World to " + vars->args->name;
    }
}

class tagTag  {
public:
    string execute(mapping vars) {
   return "<BODY>"+vars->args->body+"</BODY>";
    }
}

{
    // first test rxml
    string result = 
   "<html><body>Welcome! <h2><test name='test'/></h2></body></html>";

    result = rxml(result, ([ ]), ([ "test": testTag(), ]));
    if ( result !=
    "<html><body>Welcome! <h2>Hello World to test</h2></body></html>" )
   error("rxml test failed - wrong result " + result);
    
    result =  "<a><b><c apply='1'>"+
   "<d name='x'/></c>"+
   "<d name='y'/></b></a>";

    result = rxml(result, ([ ]), ([ "d": testTag(), "c":tagTag(),]));
    if ( result != 
    "<a><b><BODY>Hello World to x</BODY>Hello World to y</b></a>" )
   error("nested rxml test failed !");

    result = "<a><?xml version='1.0'?><x>test</x></a>";
    result = rxml(result, ([ ]), (["a": tagTag(), ]));
    if ( result != "<BODY><?xml version='1.0'?>\n\n<x>test</x></BODY>" )
   error("Failed test with rxml tag with xml in body.\n");
}

string get_tag_name(object tag)
{
  string name = tag->get_identifier();
  sscanf(name, "%s.pike", name);
  return name;
}

function get_tag_function(object tag)
{
  object instance;  
  if ( !objectp(tag) )
    return 0;
  catch(instance = tag->provide_instance());
  if ( !objectp(instance) )
    return 0;

  return instance->execute;
}

function find_tag(string name)
{
  object tags = OBJ("/tags");
  if ( !objectp(tags) ) 
    return 0;
  object tag = tags->get_object_byname(name+".pike");
  if ( !objectp(tag) )
    return 0;
  return get_tag_function(tag);
}


mapping find_tags(object obj)
{
  if ( !objectp(obj) )
    return 0;
  if ( obj->get_object_class() & CLASS_CONTAINER ) {
    mapping result = ([ ]);
    foreach(obj->get_inventory_by_class(CLASS_DOCLPC), object tag) {
      function f = get_tag_function(tag);
      string tagname = get_tag_name(tag);
      if ( !functionp(f) )
   FATAL("Warning - no tag function for tag: %s", tagname);
      else
   result[tagname] = f;
    }
    return result;
  }
  else if ( obj->get_object_class() & CLASS_DOCXSL) {
    object env = obj->get_environment();
    if ( objectp(env) )
      return find_tags(env->get_object_byname("tags"));
  }
  return 0;
}

// hack to force pike to load JSON into the chroot
#if constant(Standards.JSON)
int json = 1;
#endif


};