Unnamed Fossil Project

#ifdef _YO_BUFFER_BUILTIN
  {
    if ( capacity < 0 )
      __Raise(YO_ERROR_OUT_OF_RANGE,0);

    if ( !bf ) bf = Buffer_Init(0);

    if ( bf->capacity < capacity )
      {
        bf->at = __Realloc_Npl(bf->at,capacity+1);
        bf->capacity = capacity;


      }
      
    return bf;
  }
#endif
  ;

................................................................................
    
    E = p + len;
    
    while ( p != E )
      {
        do 
          { 
            if ( *p < 30 || *p == '\\' || *p == brk ) 
              break; 
            ++p; 
          } 
        while ( p != E );
        
        if ( q != p )
          Buffer_Append(bf,q,p-q);
................................................................................
            else if ( *p == '\r' ) Buffer_Append(bf,"\\r",2);
            else if ( *p == '\\' ) Buffer_Append(bf,"\\\\",2);
            else if ( *p == brk )  
              { 
                Buffer_Fill_Append(bf,'\\',1);
                Buffer_Fill_Append(bf,brk,1);
              }

            else if ( *p == '"' ) Buffer_Append(bf,"\\\"",2);


            else if ( *p < 30 ) 
              {
                Buffer_Append(bf,"\\x",2);
                Buffer_Hex_Append(bf,p,1);
              }
          
            ++p;

#ifdef _YO_BUFFER_BUILTIN
  {
    if ( capacity < 0 )
      __Raise(YO_ERROR_OUT_OF_RANGE,0);

    if ( !bf ) bf = Buffer_Init(0);

    if ( bf->capacity < capacity || !bf->at )
      {
        bf->at = __Realloc_Npl(bf->at,capacity+1);
        bf->capacity = capacity;
        STRICT_REQUIRE(bf->count <= bf->capacity );
        bf->at[bf->count] = 0;
      }
      
    return bf;
  }
#endif
  ;

................................................................................
    
    E = p + len;
    
    while ( p != E )
      {
        do 
          { 
            if ( *p < 30 || *p == '\\' || *p == brk || *p == '"' || *p == '\'' ) 
              break; 
            ++p; 
          } 
        while ( p != E );
        
        if ( q != p )
          Buffer_Append(bf,q,p-q);
................................................................................
            else if ( *p == '\r' ) Buffer_Append(bf,"\\r",2);
            else if ( *p == '\\' ) Buffer_Append(bf,"\\\\",2);
            else if ( *p == brk )  
              { 
                Buffer_Fill_Append(bf,'\\',1);
                Buffer_Fill_Append(bf,brk,1);
              }
            else if ( *p == '"' ) 
              Buffer_Append(bf,"\\\"",2);
            else if ( *p == '\'' ) 
              Buffer_Append(bf,"\\'",2);
            else if ( *p < 30 ) 
              {
                Buffer_Append(bf,"\\x",2);
                Buffer_Hex_Append(bf,p,1);
              }
          
            ++p;

#define _YO_DICTO_BUILTIN
#endif

#include "yoyo.hc"
#include "crc.hc"
#include "buffer.hc"
#include "array.hc"


typedef struct _YO_DICTO_REC
  {
    struct _YO_DICTO_REC *next;
    void *ptr;
    byte_t hashcode;
    char key[1];
................................................................................
    dicto_apply_filter_t filter = _filter;
    if ( o && o->table ) 
      for ( i = 0; i < o->width; ++i )
        {      
          nrec = o->table[i];
          while ( nrec )
            {
              filter(nrec->key,nrec->ptr,state);
              nrec = nrec->next;
            }  
        }
  }
#endif
  ;

................................................................................
                  Buffer_Append(bf,", ",2); 
              else 
                j = 1; 
              if ( pretty )
                Buffer_Fill_Append(bf,' ',2); 
              Buffer_Append(bf,nrec->key,-1);
              Buffer_Append(bf,": ",2);
              print(bf,nrec->ptr);
              nrec = nrec->next;
            }  
        }
    
    if ( j && pretty )
      Buffer_Fill_Append(bf,'\n',1); 
    Buffer_Fill_Append(bf,'}',1);
................................................................................
      return Buffer_Take_Data(bf);
    else
      return bf->at+start;
  }
#endif
  ;












#endif /* C_once_38B1FFE7_1462_42EB_BABE_AA8E0BE62203 */

#define _YO_DICTO_BUILTIN
#endif

#include "yoyo.hc"
#include "crc.hc"
#include "buffer.hc"
#include "array.hc"
#include "string.hc"

typedef struct _YO_DICTO_REC
  {
    struct _YO_DICTO_REC *next;
    void *ptr;
    byte_t hashcode;
    char key[1];
................................................................................
    dicto_apply_filter_t filter = _filter;
    if ( o && o->table ) 
      for ( i = 0; i < o->width; ++i )
        {      
          nrec = o->table[i];
          while ( nrec )
            {
              __Auto_Release filter(nrec->key,nrec->ptr,state);
              nrec = nrec->next;
            }  
        }
  }
#endif
  ;

................................................................................
                  Buffer_Append(bf,", ",2); 
              else 
                j = 1; 
              if ( pretty )
                Buffer_Fill_Append(bf,' ',2); 
              Buffer_Append(bf,nrec->key,-1);
              Buffer_Append(bf,": ",2);
              __Auto_Release print(bf,nrec->ptr);
              nrec = nrec->next;
            }  
        }
    
    if ( j && pretty )
      Buffer_Fill_Append(bf,'\n',1); 
    Buffer_Fill_Append(bf,'}',1);
................................................................................
      return Buffer_Take_Data(bf);
    else
      return bf->at+start;
  }
#endif
  ;

YO_DICTO *Dicto_Set_Str(YO_DICTO *dicto, char *key, void *val)
#ifdef _YO_DICTO_BUILTIN  
  {
    if ( !dicto )
      dicto = Dicto_Ptrs();
    Dicto_Put(dicto,key,Str_Copy_Npl(val,-1));
    return dicto; 
  }
#endif
  ;
  
#endif /* C_once_38B1FFE7_1462_42EB_BABE_AA8E0BE62203 */

    if ( Raise_If_Cfile_Is_Not_Opened(f) )
      {
        YO_BUFFER *L;
        quad_t len = Cfile_Available(f);
        if ( len > INT_MAX )
          Yo_Raise(YO_ERROR_IO,
            "file to big to be read in one pass",__Yo_FILE__,__LINE__);
        L = Buffer_Init(0);
        while ( len ) 
          /* windoze text mode reads less then available, so we need to read carefully*/
          {
            Buffer_Grow_Reserve(L,L->count+(int)len);
            L->count += Cfile_Read(f,L->at+L->count,(int)len,0);
            L->at[L->count] = 0;
            len = Cfile_Available(f);

    if ( Raise_If_Cfile_Is_Not_Opened(f) )
      {
        YO_BUFFER *L;
        quad_t len = Cfile_Available(f);
        if ( len > INT_MAX )
          Yo_Raise(YO_ERROR_IO,
            "file to big to be read in one pass",__Yo_FILE__,__LINE__);
        L = Buffer_Reserve(0,len);
        while ( len ) 
          /* windoze text mode reads less then available, so we need to read carefully*/
          {
            Buffer_Grow_Reserve(L,L->count+(int)len);
            L->count += Cfile_Read(f,L->at+L->count,(int)len,0);
            L->at[L->count] = 0;
            len = Cfile_Available(f);

/*

Copyright © 2010-2011, Alexéy Sudachén, alexey@sudachen.name, Chile

In USA, UK, Japan and other countries allowing software patents:

    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 3 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.

    http://www.gnu.org/licenses/

Otherwise:

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.

Except as contained in this notice, the name of a copyright holder shall not
be used in advertising or otherwise to promote the sale, use or other dealings
in this Software without prior written authorization of the copyright holder.

*/

#ifndef C_once_FAC5C358_605A_4663_A129_F9C093097A9C
#define C_once_FAC5C358_605A_4663_A129_F9C093097A9C

#include "yoyo.hc"
#include "string.hc"
#include "buffer.hc"

#ifdef _LIBYOYO
#define _YO_DEFPARS_BUILTIN
#endif

typedef struct _YO_LINEBUF
  {
    void *file;
    char *file_name;
    void *fast_file_obj;
    int  (*fast_file_read)(void *obj, void *bf, int count, int mincount);
    char *at;
    byte_t *tail;
    int  tail_len;
    int  cur_line;
    int  next_line;
    int  eof;
    YO_BUFFER *line;
  } YO_LINEBUF;

void YO_LINEBUF_Destruct(YO_LINEBUF *lb)
  {
    __Unrefe(lb->line);
    __Unrefe(lb->file);
    free(lb->file_name);
  }

YO_LINEBUF *Linebuf_Init(void *file, char *file_name)
  {
    YO_LINEBUF *lb = __Object_Dtor(sizeof(YO_LINEBUF),YO_LINEBUF_Destruct);
    lb->file = __Refe(file);
    lb->file_name = Str_Copy_Npl(file_name,-1);
    lb->line = __Refe(Buffer_Init(0));
    lb->fast_file_obj = lb->file;
    lb->fast_file_read = Yo_Find_Method_Of(&lb->fast_file_obj,Oj_Read_OjMID,YO_RAISE_ERROR);
    return lb;
  }
  
int Linebuf_Nextline(YO_LINEBUF *lb)
  {
    int i,j;

    byte_t *tail;

    tail = lb->line->at;
    
    if ( lb->tail_len )
      {
        memmove(lb->line->at,lb->tail,lb->tail_len);
        Buffer_Resize(lb->line,lb->tail_len);
      }

    lb->cur_line = lb->next_line;
    lb->tail = 0;
    lb->tail_len = 0;
    i = 0;      
    for (;;)
      {
        for ( ; tail[i] ; ++i )
          if ( tail[i] == '\n' )
            {
              tail[i] = 0;
              lb->tail = tail +i;
              lb->tail_len = lb->line->count - i;
              ++lb->next_line;
              break;
            }
          else if ( tail[i] == '\r' && i+1 < lb->line->count && tail[i+1] == '\n')
            {
              tail[i] = 0;
              lb->tail = tail + i + 1;
              lb->tail_len = lb->line->count - (i+1);
              ++lb->next_line;
              break;
            }

        if ( !lb->tail )
          {
            Buffer_Reserve(lb->line,i+256);
            j = lb->fast_file_read(lb->fast_file_obj,lb->line->at+i,256,0);
            if ( j )
              Buffer_Resize(lb->line,i+j);
            else
              break;
          }
        else
          break;
      }
  
    lb->at = lb->line->at;
    lb->eof = !lb->at[0] && lb->next_line == lb->cur_line;
    return !lb->eof;
  }

int Linebuf_ExtendLine(YO_LINEBUF *lb)
  {
    return 0;
  }
  
int Linebuf_Eof(YO_LINEBUF *lb)
  {
    return lb->eof;
  }
  
int Linebuf_Lineno(YO_LINEBUF *lb)
  {
    return lb->cur_line;
  }

#endif /* C_once_FAC5C358_605A_4663_A129_F9C093097A9C */

        }
        
    return __Pool(R);
  }
#endif
  ;





























#endif /* C_once_0ED387CD_668B_44C3_9D91_A6336A2F5F48 */

        }
        
    return __Pool(R);
  }
#endif
  ;

char *Str_Quote(char *S)
#ifdef _YO_STRING_BUILTIN  
  {
    int S_len = S? strlen(S):0;
    int R_count = 0;
    int R_capacity = S_len+1;
    char *R = 0;

    if ( S )
      for ( ; *S; ++S )
        {
          if ( 0 ) ;
          else if ( *(signed char*)S < 30
            || *S == '"' || *S == '\'' ||*S == '\\' 
          )
            {
              char b[5] = {0,};
              Str_Hex_Byte(*S,'\\',b);
              R_count += __Elm_Append_Npl(&R,R_count,b,4,1,&R_capacity);
            }
          else R_count += __Elm_Append_Npl(&R,R_count,S,1,1,&R_capacity);
        }
        
    return __Pool(R);
  }
#endif
  ;
    
#endif /* C_once_0ED387CD_668B_44C3_9D91_A6336A2F5F48 */

  {
    char *foo;

    if ( !host ) host = Webhost_Init();

    foo = cfg?Xnode_Value_Get_Str(&cfg->root,"doc_root",0):0;
    if ( !foo ) foo = Current_Directory();
    Webhost_Set_Doc_Root(host,foo);
  
    foo = cfg?Xnode_Value_Get_Str(&cfg->root,"exec_root",0):0;
    Webhost_Set_Exec_Root(host,foo);

    return host;
  }
#endif
  ;

#endif /*C_once_A719E9E5_B5AB_4A78_A061_34860A495936*/

  {
    char *foo;

    if ( !host ) host = Webhost_Init();

    foo = cfg?Xnode_Value_Get_Str(&cfg->root,"doc_root",0):0;
    if ( !foo ) foo = Current_Directory();
    Webhost_Add_Doc_Root(host,foo);
  
    foo = cfg?Xnode_Value_Get_Str(&cfg->root,"exec_root",0):0;
    Webhost_Set_Exec_Root(host,foo);

    return host;
  }
#endif
  ;

#endif /*C_once_A719E9E5_B5AB_4A78_A061_34860A495936*/

    __Destruct(svc);
  }
#endif
  ;
    
typedef struct _YO_WEBHOST
  {
    char *doc_root;
    char *exec_root;

    YO_ARRAY *indexes;
    YO_ARRAY *services;
    
    int disable_index: 1;
  } YO_WEBHOST;
  
void YO_WEBHOST_Destruct(YO_WEBHOST *host)
#ifdef _YO_WEBHOST_BUILTIN
  {
    __Unrefe(host->indexes);
    free(host->doc_root);
    free(host->exec_root);
    __Destruct(host);
  }
#endif
  ;
  
typedef struct _YO_WEBHOST_CGIST
................................................................................
  ;
  
YO_WEBHOST *Webhost_Init()
#ifdef _YO_WEBHOST_BUILTIN
  {
    YO_WEBHOST *host = __Object_Dtor(sizeof(YO_WEBHOST),YO_WEBHOST_Destruct);
    host->indexes = __Refe(Array_Pchars());

    return host;
  }
#endif
  ;
  
YO_WEBHOST *Webhost_Set_Doc_Root(YO_WEBHOST *host, char *doc_root)
#ifdef _YO_WEBHOST_BUILTIN
  {
    free(host->doc_root);
    host->doc_root = doc_root?Str_Copy_Npl(doc_root,-1):0;
    return host;
  }
#endif
  ;
  
YO_WEBHOST *Webhost_Set_Exec_Root(YO_WEBHOST *host, char *exec_root)
#ifdef _YO_WEBHOST_BUILTIN
................................................................................
      }
      
    return fpath;    
  }
#endif
  ;
    
char *Webhost_Find_Handler(YO_WEBHOST *host, char *query, char **script, char **pathinfo,YO_WEBHOST_SERVICE **h)
#ifdef _YO_WEBHOST_BUILTIN
  {
    char *fpath = 0;
    
    if ( !host->services ) return 0;
    __Auto_Ptr(fpath)
      {
        int i, L;

        YO_ARRAY *extL = Array_Init();
        YO_ARRAY *patL = Str_Split(query,"/");
        YO_BUFFER *bf  = Buffer_Acquire(Path_Normilize_Npl(host->doc_root));
        
        for ( i = 0; i < host->services->count; ++i )
          {
            YO_WEBHOST_SERVICE *svc = host->services->at[i];
            if ( svc->ext ) Array_Push(extL,svc->ext);
          }
                  
................................................................................
      }
      
    return fpath;    
  }
#endif
  ;

YO_ARRAY *Webhost_Setup_Environment(YO_WEBHOST *host, YO_HTTPD_REQUEST *rqst, char *path, char *script, char *pathinfo, YO_URL *url)
#ifdef _YO_WEBHOST_BUILTIN
  {
    YO_ARRAY *env;
    __Auto_Ptr(env)
      {    
        char *method = 0;
        env = Array_Pchars();
................................................................................
            case HTTPD_PUT_METHOD:  method = "PUT";  break;
          }
        
        Array_Push(env,Str_Concat_Npl("REQUEST_METHOD=",method));
        Array_Push(env,Str_Concat_Npl("REMOTE_ADDR=",rqst->remote_addr));
        Array_Push(env,Str_Concat_Npl("REMOTE_HOST=",rqst->remote_addr));
        Array_Push(env,Str_Concat_Npl("REQUEST_URI=",url->uri));

        Array_Push(env,Str_Concat_Npl("DOCUMENT_ROOT=",host->doc_root));
        Array_Push(env,Str_Concat_Npl("HTTP_REFERRER=",Dicto_Get(rqst->qhdr,"REFERRER","")));
        if ( Dicto_Has(rqst->qhdr,"COOKIE") )
          Array_Push(env,Str_Concat_Npl("HTTP_COOKIE=",Dicto_Get(rqst->qhdr,"COOKIE","")));
        
        //("HTTP_USER_AGENT");
        //("HTTP_ACCEPT_LANGUAGE");
        //("SERVER_NAME");
................................................................................
          }
      }
    return 0;
  }
#endif
  ;
    
void Webhost_Execute_Service(YO_WEBHOST_CGIST *st)
#ifdef _YO_WEBHOST_BUILTIN
  {


    YO_ARRAY *env = Webhost_Setup_Environment(st->host,st->rqst,st->path,st->script,st->pathinfo,st->url);
    st->rqst->outstrm_type = Mime_String_Of_Npl(YO_MIME_HTML);
    st->rqst->outstrm = __Refe(Cfile_Temp());
    st->cgi = __Refe(Cgi_Init_2(st->rqst->instrm,st->rqst->outstrm,(char**)env->at));
    Tasque_Alert(0,st->svc->callback,st);
  }
#endif
  ;
................................................................................
    __Auto_Release 
      {
        char *curdir = Current_Directory();
        
        __Try_Except
          {
            YO_ARRAY *env;

            Change_Directory(Path_Dirname(st->path));
            env = Webhost_Setup_Environment(st->host,st->rqst,st->path,st->script,st->pathinfo,st->url);
            
            st->pipex = __Refe(Pipex_Exec(Path_Basename(st->path),0,PIPEX_TMPFILE,PIPEX_NONE,(char**)env->at));
            
            if ( st->rqst->instrm )
              {
                int c = Oj_Copy_File(st->rqst->instrm,st->pipex->fin);
                Oj_Flush(st->pipex->fin);
................................................................................
            for ( i = 0; i < L; ++i ) if ( b[i] < 30 || b[i] > 127 ) b[i] = '.';
            if ( rqst->instrm_length > MAX_L ) memcpy(b+MAX_L-3,">>>",3);
            Log_Info("[%p] POSTDTA %s",rqst,b);
          }
        
        if ( host->services )
          {
            YO_WEBHOST_SERVICE *svc;
            svc = Webhost_Find_Service(host->services,url->query,&script,&pathinfo);
            if ( svc )
              {
                YO_WEBHOST_CGIST *st = Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url);
                st->svc = __Refe(svc);
                Webhost_Execute_Service(st);
                return 0;
              }
          }
        
        #ifdef __windoze
        if ( host->exec_root )
          {
................................................................................
            if ( path )
              return Webhost_Execute_CGI(Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url));
          }
        #endif
        
        if ( host->services )
          {


            YO_WEBHOST_SERVICE *svc = 0;



            path = Webhost_Find_Handler(host,url->query,&script,&pathinfo,&svc);


            if ( svc )
              {
                YO_WEBHOST_CGIST *st = Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url);
                st->svc = __Refe(svc);
                Webhost_Execute_Service(st);
                return 0;
              }
          }
          


        path = Path_Join(host->doc_root,url->query);
        path = Path_Normposix(path);
        
        if ( File_Get_Stats(path,&stats,1)->f.exists )






          {
            if ( stats.f.is_directory )
              {
                for ( i = 0; i < host->indexes->count; ++i )
                  {
                    char *path1 = Path_Join(path,host->indexes->at[i]);
                    if ( File_Get_Stats(path1,&stats,1)->f.exists )

    __Destruct(svc);
  }
#endif
  ;
    
typedef struct _YO_WEBHOST
  {

    char *exec_root;
    YO_ARRAY *doc_roots;
    YO_ARRAY *indexes;
    YO_ARRAY *services;
    
    int disable_index: 1;
  } YO_WEBHOST;
  
void YO_WEBHOST_Destruct(YO_WEBHOST *host)
#ifdef _YO_WEBHOST_BUILTIN
  {
    __Unrefe(host->indexes);
    __Unrefe(host->doc_roots);
    free(host->exec_root);
    __Destruct(host);
  }
#endif
  ;
  
typedef struct _YO_WEBHOST_CGIST
................................................................................
  ;
  
YO_WEBHOST *Webhost_Init()
#ifdef _YO_WEBHOST_BUILTIN
  {
    YO_WEBHOST *host = __Object_Dtor(sizeof(YO_WEBHOST),YO_WEBHOST_Destruct);
    host->indexes = __Refe(Array_Pchars());
    host->doc_roots = __Refe(Array_Pchars());
    return host;
  }
#endif
  ;
  
YO_WEBHOST *Webhost_Add_Doc_Root(YO_WEBHOST *host, char *doc_root)
#ifdef _YO_WEBHOST_BUILTIN
  {
    if ( doc_root )
      Array_Push(host->doc_roots,Str_Copy_Npl(doc_root,-1));
    return host;
  }
#endif
  ;
  
YO_WEBHOST *Webhost_Set_Exec_Root(YO_WEBHOST *host, char *exec_root)
#ifdef _YO_WEBHOST_BUILTIN
................................................................................
      }
      
    return fpath;    
  }
#endif
  ;
    
char *Webhost_Find_Handler(YO_WEBHOST *host, char *doc_root, char *query, char **script, char **pathinfo,YO_WEBHOST_SERVICE **h)
#ifdef _YO_WEBHOST_BUILTIN
  {
    char *fpath = 0;
    
    if ( !host->services ) return 0;
    __Auto_Ptr(fpath)
      {
        int i, L;

        YO_ARRAY *extL = Array_Init();
        YO_ARRAY *patL = Str_Split(query,"/");
        YO_BUFFER *bf  = Buffer_Acquire(Path_Normilize_Npl(doc_root));
        
        for ( i = 0; i < host->services->count; ++i )
          {
            YO_WEBHOST_SERVICE *svc = host->services->at[i];
            if ( svc->ext ) Array_Push(extL,svc->ext);
          }
                  
................................................................................
      }
      
    return fpath;    
  }
#endif
  ;

YO_ARRAY *Webhost_Setup_Environment(char *doc_root, YO_HTTPD_REQUEST *rqst, char *path, char *script, char *pathinfo, YO_URL *url)
#ifdef _YO_WEBHOST_BUILTIN
  {
    YO_ARRAY *env;
    __Auto_Ptr(env)
      {    
        char *method = 0;
        env = Array_Pchars();
................................................................................
            case HTTPD_PUT_METHOD:  method = "PUT";  break;
          }
        
        Array_Push(env,Str_Concat_Npl("REQUEST_METHOD=",method));
        Array_Push(env,Str_Concat_Npl("REMOTE_ADDR=",rqst->remote_addr));
        Array_Push(env,Str_Concat_Npl("REMOTE_HOST=",rqst->remote_addr));
        Array_Push(env,Str_Concat_Npl("REQUEST_URI=",url->uri));
        if ( doc_root )
          Array_Push(env,Str_Concat_Npl("DOCUMENT_ROOT=",doc_root));
        Array_Push(env,Str_Concat_Npl("HTTP_REFERRER=",Dicto_Get(rqst->qhdr,"REFERRER","")));
        if ( Dicto_Has(rqst->qhdr,"COOKIE") )
          Array_Push(env,Str_Concat_Npl("HTTP_COOKIE=",Dicto_Get(rqst->qhdr,"COOKIE","")));
        
        //("HTTP_USER_AGENT");
        //("HTTP_ACCEPT_LANGUAGE");
        //("SERVER_NAME");
................................................................................
          }
      }
    return 0;
  }
#endif
  ;
    
void Webhost_Execute_Service(YO_WEBHOST_CGIST *st, char *doc_root)
#ifdef _YO_WEBHOST_BUILTIN
  {
    YO_ARRAY *env;
    if ( !doc_root ) doc_root = st->host->doc_roots->count?st->host->doc_roots->at[0]:0;
    env = Webhost_Setup_Environment(doc_root,st->rqst,st->path,st->script,st->pathinfo,st->url);
    st->rqst->outstrm_type = Mime_String_Of_Npl(YO_MIME_HTML);
    st->rqst->outstrm = __Refe(Cfile_Temp());
    st->cgi = __Refe(Cgi_Init_2(st->rqst->instrm,st->rqst->outstrm,(char**)env->at));
    Tasque_Alert(0,st->svc->callback,st);
  }
#endif
  ;
................................................................................
    __Auto_Release 
      {
        char *curdir = Current_Directory();
        
        __Try_Except
          {
            YO_ARRAY *env;
            char *doc_root = st->host->doc_roots->count?st->host->doc_roots->at[0]:0;
            Change_Directory(Path_Dirname(st->path));
            env = Webhost_Setup_Environment(doc_root,st->rqst,st->path,st->script,st->pathinfo,st->url);
            
            st->pipex = __Refe(Pipex_Exec(Path_Basename(st->path),0,PIPEX_TMPFILE,PIPEX_NONE,(char**)env->at));
            
            if ( st->rqst->instrm )
              {
                int c = Oj_Copy_File(st->rqst->instrm,st->pipex->fin);
                Oj_Flush(st->pipex->fin);
................................................................................
            for ( i = 0; i < L; ++i ) if ( b[i] < 30 || b[i] > 127 ) b[i] = '.';
            if ( rqst->instrm_length > MAX_L ) memcpy(b+MAX_L-3,">>>",3);
            Log_Info("[%p] POSTDTA %s",rqst,b);
          }
        
        if ( host->services )
          {
            YO_WEBHOST_SERVICE *svc = 0;
            svc = Webhost_Find_Service(host->services,url->query,&script,&pathinfo);
            if ( svc )
              {
                YO_WEBHOST_CGIST *st = Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url);
                st->svc = __Refe(svc);
                Webhost_Execute_Service(st,host->doc_roots->at[0]);
                return 0;
              }
          }
        
        #ifdef __windoze
        if ( host->exec_root )
          {
................................................................................
            if ( path )
              return Webhost_Execute_CGI(Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url));
          }
        #endif
        
        if ( host->services )
          {
            char *doc_root = 0;
            char *path = 0;
            YO_WEBHOST_SERVICE *svc = 0;
            for ( i = 0; i < host->doc_roots->count; ++i )
              {
                doc_root = host->doc_roots->at[i];
                path = Webhost_Find_Handler(host,doc_root,url->query,&script,&pathinfo,&svc);
                if ( path ) break;
              }
            if ( svc )
              {
                YO_WEBHOST_CGIST *st = Webhost_CGI_State(host, rqst, __Retain(path), script, pathinfo, url);
                st->svc = __Refe(svc);
                Webhost_Execute_Service(st,doc_root);
                return 0;
              }
          }
          
        for ( i = 0; i < host->doc_roots->count; ++i )
          {
            path = Path_Join(host->doc_roots->at[i],url->query);
            path = Path_Normposix(path);

            if ( File_Get_Stats(path,&stats,1)->f.exists )
              break;
            else
              path = 0;
          }
        
        if ( path )
          {
            if ( stats.f.is_directory )
              {
                for ( i = 0; i < host->indexes->count; ++i )
                  {
                    char *path1 = Path_Join(path,host->indexes->at[i]);
                    if ( File_Get_Stats(path1,&stats,1)->f.exists )

#endif
  ;

YO_XNODE *Xnode_Next_If(YO_XNODE *node, char *tag_name)
#ifdef _YO_XDATA_BUILTIN
  {
    ushort_t tag;
    YO_XNODE *n;
      
    if ( !node ) return 0;
    n = Xnode_Refacc(node);
    
    STRICT_REQUIRE( n );
    STRICT_REQUIRE( tag_name );
    STRICT_REQUIRE( (n->opt&XVALUE_OPT_IS_VALUE) == 0 );
    
    tag = (ushort_t)(longptr_t)Xdata_Resolve_Name(n->xdata,tag_name,0);
    

#endif
  ;

YO_XNODE *Xnode_Next_If(YO_XNODE *node, char *tag_name)
#ifdef _YO_XDATA_BUILTIN
  {
    ushort_t tag;
    YO_XNODE *n = node;
      
    if ( !node ) return 0;
    //n = Xnode_Refacc(node);
    
    STRICT_REQUIRE( n );
    STRICT_REQUIRE( tag_name );
    STRICT_REQUIRE( (n->opt&XVALUE_OPT_IS_VALUE) == 0 );
    
    tag = (ushort_t)(longptr_t)Xdata_Resolve_Name(n->xdata,tag_name,0);
    

void Def_Parse_In_Node( YO_XDEF_STATE *st, YO_XNODE *n )
#ifdef _YO_XDEF_BUILTIN
  {
    Def_Parse_Skip_Spaces(st);
    
    for ( ; *st->text && *st->text != '}' ; Def_Parse_Skip_Spaces(st) ) 
      {

        int go_deeper = 0;
        YO_XNODE *nn = 0;
        
        __Auto_Release
          {
            YO_XDEF_VALUE value = {0};
            char *name; 
................................................................................
                if ( *st->text != ')' )
                  __Raise(YO_ERROR_ILLFORMED,__Format("expected ')' at line %d",st->lineno));
                ++st->text;
                Def_Parse_Skip_Spaces(st);
              }
            
            






            if ( *st->text == '=' )
              {
                ++st->text;
                Def_Parse_Skip_Spaces(st);
                Def_Parse_Get_Value(st,&value);
                Def_Parse_Skip_Spaces(st);
              }
................................................................................
            
            if ( *st->text == '<' && st->text[1] == '=' )
              {
                YO_XDATA *xd = 0; 
                YO_XNODE *sn = 0;
                char *include_file;
                char *subnode = 0;

                st->text += 2;
                Def_Parse_Skip_Spaces(st);
                include_file = Def_Parse_Get_Literal(st);
                Def_Parse_Skip_Spaces(st);





                subnode = strchr(include_file,':');
                if ( subnode ) *subnode++ = 0;
                if ( st->dirname ) include_file = Path_Join(st->dirname,include_file);


                xd = Def_Parse_File(include_file);
                sn = subnode?Xnode_Query_Node(&xd->root,subnode):&xd->root;
                if ( sn )
                  {
                    nn = Xnode_Append_Refnode(n,name,sn);
                    name = 0;

                  }
              }
            
            if ( nodename )
              {
                if ( !nn )
                  nn = Xnode_Append(n,name);
................................................................................
                  nn = Xnode_Append(n,name);
                if ( value.type )
                  Def_Parse_In_Node_Set_Value(nn,"$",&value);
              }
            else if ( value.type )
              {
                if ( name || !nn )


                  Def_Parse_In_Node_Set_Value(n,name,&value);

                else
                  Def_Parse_In_Node_Set_Value(nn,"$",&value);
              }
              
          }
        
        if ( go_deeper )

void Def_Parse_In_Node( YO_XDEF_STATE *st, YO_XNODE *n )
#ifdef _YO_XDEF_BUILTIN
  {
    Def_Parse_Skip_Spaces(st);
    
    for ( ; *st->text && *st->text != '}' ; Def_Parse_Skip_Spaces(st) ) 
      {
        int set_if_not_set = 0;
        int go_deeper = 0;
        YO_XNODE *nn = 0;
        
        __Auto_Release
          {
            YO_XDEF_VALUE value = {0};
            char *name; 
................................................................................
                if ( *st->text != ')' )
                  __Raise(YO_ERROR_ILLFORMED,__Format("expected ')' at line %d",st->lineno));
                ++st->text;
                Def_Parse_Skip_Spaces(st);
              }
            
            
            if ( *st->text == '?' && st->text[1] == '=' )
              {
                set_if_not_set = 1;
                ++st->text;
              }

            if ( *st->text == '=' )
              {
                ++st->text;
                Def_Parse_Skip_Spaces(st);
                Def_Parse_Get_Value(st,&value);
                Def_Parse_Skip_Spaces(st);
              }
................................................................................
            
            if ( *st->text == '<' && st->text[1] == '=' )
              {
                YO_XDATA *xd = 0; 
                YO_XNODE *sn = 0;
                char *include_file;
                char *subnode = 0;
                int  skip_if_dsnt_exists = 0;
                st->text += 2;
                Def_Parse_Skip_Spaces(st);
                include_file = Def_Parse_Get_Literal(st);
                Def_Parse_Skip_Spaces(st);
                if ( *include_file == '?' )
                  {
                    ++include_file;
                    skip_if_dsnt_exists = 1;
                  }
                subnode = strchr(include_file,':');
                if ( subnode ) *subnode++ = 0;
                if ( st->dirname ) include_file = Path_Join(st->dirname,include_file);
                if ( !skip_if_dsnt_exists || File_Exists(include_file) )
                  {
                    xd = Def_Parse_File(include_file);
                    sn = subnode?Xnode_Query_Node(&xd->root,subnode):&xd->root;
                    if ( sn )
                      {
                        nn = Xnode_Append_Refnode(n,name,sn);
                        name = 0;
                      }
                  }
              }
            
            if ( nodename )
              {
                if ( !nn )
                  nn = Xnode_Append(n,name);
................................................................................
                  nn = Xnode_Append(n,name);
                if ( value.type )
                  Def_Parse_In_Node_Set_Value(nn,"$",&value);
              }
            else if ( value.type )
              {
                if ( name || !nn )
                  {
                    if ( !set_if_not_set || !Xnode_Value(n,name,0) )
                      Def_Parse_In_Node_Set_Value(n,name,&value);
                  }
                else
                  Def_Parse_In_Node_Set_Value(nn,"$",&value);
              }
              
          }
        
        if ( go_deeper )

        return source - S_source;
      }
      
    return 0;
  }
#endif
  ;





















int Xtmpl_Dump_Template(YO_XNODE *n, char *source)
#ifdef _YO_XTMPL_BUILTIN 
  {
    char *S_source = source;
    for ( ; *source && *source != '}'; ) ++source;
    
................................................................................
        YO_XNODE *ext = Xnode_Append(n,tag);
        char *expr = Str_Trim_Copy_L(S_source,source-S_source);
        if ( expr && *expr )
          {
            YO_XVALUE *val = Xnode_Value(ext,"$",1);
            Xvalue_Set_Or_Put_Str(val,expr);
          }

        source += Xtmpl_Macro_Template(ext,source+1,close_tag);
        return source - S_source;
      }
      
    return 0;
  }
#endif
  ;
................................................................................
    static char t_set[]      = "set{";
    static char t_repeat[]   = "repeat{";
    static char t_at[]       = "at{";
    static char t_at1[]      = "at1{";
    static char t_inc[]      = "inc{";
    static char t_dec[]      = "dec{";
    static char t_expand[]   = "{";

    static char t_comment[]  = "/*";
    char *S_source = source;
    char *Q;
    int close_len = close_tag?strlen(close_tag):0;
    
    for ( Q = source; *source; )
      {
................................................................................
                Q = source;
              }
            else if ( !strncmp(source+1,t_expand,sizeof(t_expand)-1) )
              {
                source += sizeof(t_expand);
                source += Xtmpl_Expand_Template(n,source);
                Q = source;






              }
            else if ( !strncmp(source+1,t_liftup,sizeof(t_liftup)-1) )
              {
                source += sizeof(t_liftup);
                source += Xtmpl_Liftup_Template(n,source);
                Q = source;
              }
................................................................................
            char S[3];
            sprintf(S,"%d",i);
            Dicto_Put(ctx->global,S,__Refe(m));
            Xvalue_Set_Str(&m->value,L->at[i],strlen(L->at[i]));
          }
        Xtmpl_Query_Str_Bf(ctx,L->at[0],bf);
      }







    else if ( Xnode_Tag_Is(n,"def") )
      {
        Xtmpl_Def_Macro(ctx,n);
      }
    else if ( Xnode_Tag_Is(n,"set") )
      {
        Xtmpl_Set_Value(ctx,n);
................................................................................
          Xtmpl_Handle_Node_Out(bf,n,&ctx);
        n = Xnode_Next(n);
      }
  }
#endif
  ;
  











void Xtmpl_Step_Down(YO_BUFFER *bf, YO_XNODE *tmpl, YO_XDATA *model)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_DICTO *global = Dicto_Refs();
    YO_XTMPL_UP upstep_q[32] = { {tmpl, 0}, };
    YO_XNODE *down; 
    YO_XTMPL_UP *upstep = upstep_q;


    
    for ( down = Xnode_Down_If(tmpl,"extends"); down; )
      {
        Xtmpl_Step_Down_Global_Set(upstep->tmpl,down,global,model);
        upstep[1].up = upstep;
        ++upstep;
        upstep->tmpl = down;
................................................................................
        ctx.tmpl   = tmpl;
        Xtmpl_Step_Up(bf,upstep,"content",&ctx);
      }
  }
#endif
  ;

char *Xtmpl_Produce_Out(YO_BUFFER *bf, YO_XDATA *tmpl, YO_XDATA *model)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_BUFFER *xbf = bf;
    if ( !xbf ) xbf = Buffer_Init(0);
    Buffer_Append(bf,"\n",1);
    Xtmpl_Step_Down(bf,&tmpl->root,model);
    return bf?xbf->at:Buffer_Take_Data(xbf);
  }
#endif
  ;

#ifdef _YO_XTMPL_BUILTIN 

................................................................................
        Dicto_Put(dt,S,__Refe(doc)); /* doc can be NULL */
      }
    return doc;
  }

#endif













YO_XDATA *Xtmpl_Autoload(char *root,  char *name, char **langlist /*zero terminated langiages list*/)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_XDATA *doc = 0;
    __Auto_Release /* document is retaining by template cache */
      {
        if (langlist) for ( ; !doc && *langlist; ++langlist )

        return source - S_source;
      }
      
    return 0;
  }
#endif
  ;

int Xtmpl_Quote_Template(YO_XNODE *n, char *source)
#ifdef _YO_XTMPL_BUILTIN 
  {
    char *S_source = source;
    for ( ; *source && *source != '}'; ) ++source;
    
    if ( *source == '}' )
      {
        YO_XNODE *ext = Xnode_Append(n,"quote");
        YO_XVALUE *val = Xnode_Value(ext,"$",1);
        Xvalue_Set_Str(val,S_source,source-S_source);
        ++source;
        return source - S_source;
      }
      
    return 0;
  }
#endif
  ;

int Xtmpl_Dump_Template(YO_XNODE *n, char *source)
#ifdef _YO_XTMPL_BUILTIN 
  {
    char *S_source = source;
    for ( ; *source && *source != '}'; ) ++source;
    
................................................................................
        YO_XNODE *ext = Xnode_Append(n,tag);
        char *expr = Str_Trim_Copy_L(S_source,source-S_source);
        if ( expr && *expr )
          {
            YO_XVALUE *val = Xnode_Value(ext,"$",1);
            Xvalue_Set_Or_Put_Str(val,expr);
          }
        ++source;
        source += Xtmpl_Macro_Template(ext,source,close_tag);
        return source - S_source;
      }
      
    return 0;
  }
#endif
  ;
................................................................................
    static char t_set[]      = "set{";
    static char t_repeat[]   = "repeat{";
    static char t_at[]       = "at{";
    static char t_at1[]      = "at1{";
    static char t_inc[]      = "inc{";
    static char t_dec[]      = "dec{";
    static char t_expand[]   = "{";
    static char t_quote[]    = "quote{";
    static char t_comment[]  = "/*";
    char *S_source = source;
    char *Q;
    int close_len = close_tag?strlen(close_tag):0;
    
    for ( Q = source; *source; )
      {
................................................................................
                Q = source;
              }
            else if ( !strncmp(source+1,t_expand,sizeof(t_expand)-1) )
              {
                source += sizeof(t_expand);
                source += Xtmpl_Expand_Template(n,source);
                Q = source;
              }
            else if ( !strncmp(source+1,t_quote,sizeof(t_quote)-1) )
              {
                source += sizeof(t_quote);
                source += Xtmpl_Quote_Template(n,source);
                Q = source;
              }
            else if ( !strncmp(source+1,t_liftup,sizeof(t_liftup)-1) )
              {
                source += sizeof(t_liftup);
                source += Xtmpl_Liftup_Template(n,source);
                Q = source;
              }
................................................................................
            char S[3];
            sprintf(S,"%d",i);
            Dicto_Put(ctx->global,S,__Refe(m));
            Xvalue_Set_Str(&m->value,L->at[i],strlen(L->at[i]));
          }
        Xtmpl_Query_Str_Bf(ctx,L->at[0],bf);
      }
    else if ( Xnode_Tag_Is(n,"quote") )
      {
        int i;
        char *query = Xnode_Value_Get_Str(n,"$",0);
        YO_XVALUE *m = Xtmpl_Query_Value(ctx,query);
        if ( m ) Buffer_Quote_Append(bf,Xvalue_Get_Str(m,""),-1,0);
      }
    else if ( Xnode_Tag_Is(n,"def") )
      {
        Xtmpl_Def_Macro(ctx,n);
      }
    else if ( Xnode_Tag_Is(n,"set") )
      {
        Xtmpl_Set_Value(ctx,n);
................................................................................
          Xtmpl_Handle_Node_Out(bf,n,&ctx);
        n = Xnode_Next(n);
      }
  }
#endif
  ;
  
#ifdef _YO_XTMPL_BUILTIN 
void Xtmpl_Glob_Set(char *key, char *val, YO_DICTO *glob)
  {
      YO_XNODE *t;
      YO_BUFFER *bf = Buffer_Init(0);
      YO_XTMPL_VALUE *m = YO_XTMPL_VALUE_Init();
      Dicto_Put(glob,key,__Refe(m));
      Xvalue_Set_Str(&m->value,val,-1);
  }
#endif
  
void Xtmpl_Step_Down(YO_BUFFER *bf, YO_XNODE *tmpl, YO_XDATA *model, YO_DICTO *glob)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_DICTO *global = Dicto_Refs();
    YO_XTMPL_UP upstep_q[32] = { {tmpl, 0}, };
    YO_XNODE *down; 
    YO_XTMPL_UP *upstep = upstep_q;
    
    Dicto_Apply(glob,Xtmpl_Glob_Set,global);
    
    for ( down = Xnode_Down_If(tmpl,"extends"); down; )
      {
        Xtmpl_Step_Down_Global_Set(upstep->tmpl,down,global,model);
        upstep[1].up = upstep;
        ++upstep;
        upstep->tmpl = down;
................................................................................
        ctx.tmpl   = tmpl;
        Xtmpl_Step_Up(bf,upstep,"content",&ctx);
      }
  }
#endif
  ;

char *Xtmpl_Produce_Out(YO_BUFFER *bf, YO_XDATA *tmpl, YO_XDATA *model, YO_DICTO *glob)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_BUFFER *xbf = bf;
    if ( !xbf ) xbf = Buffer_Init(0);
    Buffer_Append(bf,"\n",1);
    Xtmpl_Step_Down(bf,&tmpl->root,model,glob);
    return bf?xbf->at:Buffer_Take_Data(xbf);
  }
#endif
  ;

#ifdef _YO_XTMPL_BUILTIN 

................................................................................
        Dicto_Put(dt,S,__Refe(doc)); /* doc can be NULL */
      }
    return doc;
  }

#endif

void Xtmpl_Drop_Cache()
#ifdef _YO_XTMPL_BUILTIN 
  {
    if ( Xtmpl_Cache_Dicto )
      {
        __Unrefe(Xtmpl_Cache_Dicto);
        Xtmpl_Cache_Dicto = __Refe(Dicto_Refs());
      }
  }
#endif
  ;
  
YO_XDATA *Xtmpl_Autoload(char *root,  char *name, char **langlist /*zero terminated langiages list*/)
#ifdef _YO_XTMPL_BUILTIN 
  {
    YO_XDATA *doc = 0;
    __Auto_Release /* document is retaining by template cache */
      {
        if (langlist) for ( ; !doc && *langlist; ++langlist )