flt_http.c

Go to the documentation of this file.

/* {{{ Initial comments */
/*
 * $LastChangedDate: 2004-04-01 18:34:17 +0200 (Thu, 01 Apr 2004) $
 * $LastChangedRevision: 50 $
 * $LastChangedBy: ckruse $
 *
 */
/* }}} */

/* {{{ Includes */
#include "config.h"
#include "defines.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <time.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/time.h>

#include "hashlib.h"
#include "readline.h"
#include "utils.h"
#include "configparser.h"
#include "cfcgi.h"
#include "template.h"
#include "clientlib.h"

/* }}} */

struct {
  int send_last_modified;
  long send_expires;
  int expires_set;
  int handle_last_modified_since;
} http_config = { 0, 0, 0, 0 };

time_t flt_http_gmt_diff(void) {
    struct timeval now;
    time_t t1, t2;
    struct tm t;

    gettimeofday(&now, NULL);
    t1 = now.tv_sec;
    t2 = 0;

    t = *gmtime(&t1);

    t.tm_isdst = 0; /* we know this GMT time isn't daylight-savings */
    t2 = mktime(&t);
    return (time_t)difftime(t1, t2);
}

int flt_http_get_month(const u_char *m) {
  if(cf_strncmp(m,"Jan",3) == 0) {
    return 0;
  }
  else if(cf_strncmp(m,"Feb",3) == 0) {
    return 1;
  }
  else if(cf_strncmp(m,"Mar",3) == 0) {
    return 2;
  }
  else if(cf_strncmp(m,"Apr",3) == 0) {
    return 3;
  }
  else if(cf_strncmp(m,"May",3) == 0) {
    return 4;
  }
  else if(cf_strncmp(m,"Jun",3) == 0) {
    return 5;
  }
  else if(cf_strncmp(m,"Jul",3) == 0) {
    return 6;
  }
  else if(cf_strncmp(m,"Aug",3) == 0) {
    return 7;
  }
  else if(cf_strncmp(m,"Sep",3) == 0) {
    return 8;
  }
  else if(cf_strncmp(m,"Oct",3) == 0) {
    return 9;
  }
  else if(cf_strncmp(m,"Nov",3) == 0) {
    return 10;
  }
  else if(cf_strncmp(m,"Dec",3) == 0) {
    return 11;
  }

  return -1;
}

long flt_http_get_lm(int sock) {
  #ifndef CF_SHARED_MEM
  rline_t tsd;
  u_char *line;
  long ret = 0;

  if(writen(sock,"GET LASTMODIFIED 0\n",19) > 0) {
    memset(&tsd,0,sizeof(rline_t));

    if((line = readline(sock,&tsd)) != NULL) {
      ret = strtol(line,NULL,0);
      free(line);
    }
  }

  return ret;
  #else
  return *((time_t *)sock);
  #endif
}

int flt_http_validate_cache(t_cf_hash *head,t_configuration *dc,t_configuration *vc,time_t lm,int sock) {
  t_module *mod;
  t_cache_revalidator fkt;
  size_t i;
  int ret = FLT_DECLINE;

  if(Modules[0].elements) {
    for(i=0;i<Modules[0].elements && (ret == FLT_OK || ret == FLT_DECLINE);i++) {
      mod = array_element_at(&Modules[0],i);

      if(mod->cfg->revalidator) {
        fkt     = (t_cache_revalidator)mod->cfg->revalidator;
        ret     = fkt(head,dc,vc,lm,sock);
      }
    }
  }

  return ret;
}

int flt_http_header_callbacks(t_cf_hash *head,t_cf_hash *header_table,t_configuration *dc,t_configuration *vc,int sock) {
  t_module *mod;
  t_header_hook fkt;
  size_t i;
  int ret = FLT_DECLINE;
  int retret = FLT_OK;

  if(Modules[0].elements) {
    for(i=0;i<Modules[0].elements;i++) {
      mod = array_element_at(&Modules[0],i);
      if(mod->cfg->header_hook) {
        fkt = (t_header_hook)mod->cfg->header_hook;
        ret = fkt(head,header_table,dc,vc,sock);

        if(ret == FLT_EXIT) retret = FLT_EXIT;
      }
    }
  }

  return retret;
}

time_t flt_http_lm_callbacks(t_cf_hash *head,t_configuration *dc,t_configuration *vc,int sock,time_t t1) {
  t_module *mod;
  t_last_modified fkt;
  size_t i;
  time_t ret;

  if(Modules[0].elements) {
    for(i=0;i<Modules[0].elements;i++) {
      mod = array_element_at(&Modules[0],i);
      if(mod->cfg->header_hook) {
        fkt = (t_last_modified)mod->cfg->last_modified;
        ret = fkt(head,dc,vc,sock);

        if(ret == (time_t)-1) continue;
        if(ret > t1) t1 = ret;
      }
    }
  }

  return t1;
}

int flt_http_execute(t_cf_hash *head,t_configuration *dc,t_configuration *vc,int sock) {
  u_char buff[100];
  time_t t,t1;
  struct tm *tm;
  struct tm tm_lm;
  u_char *lm;
  int ret;
  t_cf_hash *header_table = cf_hash_new(NULL);
  ub4 elems = hashsize(header_table->tablesize);
  ub4 i;
  t_cf_hash_entry *ent;
  time_t diff = flt_http_gmt_diff();

  /* {{{ http header management */
  ret = flt_http_header_callbacks(head,header_table,dc,vc,sock);

  cf_hash_entry_delete(header_table,"Last-Modified",13);

  for(i=0;i<elems;i++) {
    if(header_table->table[i]) {
      for(ent=header_table->table[i];ent;ent=ent->next) {
        printf("%s: %s\015\012",ent->key,(char *)ent->data);
      }
    }
  }

  cf_hash_destroy(header_table);

  if(ret == FLT_EXIT) return FLT_EXIT;
  /* }}} */

  if(http_config.handle_last_modified_since || http_config.send_last_modified) {
    t1 = flt_http_get_lm(sock);
    t1 = flt_http_lm_callbacks(head,dc,vc,sock,t1);
    tm = gmtime(&t1);

    if(http_config.send_last_modified) {
      strftime(buff,100,"%a, %d %b %Y %H:%M:%S GMT",tm);
      printf("Last-Modified: %s\015\012",buff);
    }

    if(http_config.handle_last_modified_since) {
      if((lm = getenv("HTTP_IF_MODIFIED_SINCE")) != NULL && *lm != '\0') {
        tm_lm.tm_mday  = atoi(lm+5);
        tm_lm.tm_mon   = flt_http_get_month(lm+8);
        tm_lm.tm_year  = atoi(lm+12) - 1900;
        tm_lm.tm_wday  = 0;
        tm_lm.tm_hour  = atoi(lm+17);
        tm_lm.tm_min   = atoi(lm+20);
        tm_lm.tm_sec   = atoi(lm+23);

        tm_lm.tm_yday  = 0;
        tm_lm.tm_isdst = 0;

        if((t = timegm(&tm_lm)) >= 0) {
          if(t >= t1) {
            ret = flt_http_validate_cache(head,dc,vc,t+diff,sock);

            if(ret != FLT_EXIT) {
              printf("Status: 304 Not Modified\015\012\015\012");
              return FLT_EXIT;
            }
          }
        }
      }
    }
  }

  return FLT_DECLINE;
}

int flt_http_handle_command(t_configfile *cfile,t_conf_opt *opt,u_char **args,int argnum) {
  u_char *ptr = NULL;

  if(argnum == 1) {
    if(cf_strcmp(opt->name,"SendLastModified") == 0) {
      http_config.send_last_modified = cf_strcasecmp(args[0],"yes") == 0;
    }
    else if(cf_strcmp(opt->name,"SendExpires") == 0) {
      http_config.expires_set  = 1;
      http_config.send_expires = strtol(args[0],(char **)&ptr,10);

      if(ptr) {
        if(toupper(*ptr) == 'M') {
          http_config.send_expires *= 60L;
        }
        else if(toupper(*ptr) == 'H') {
          http_config.send_expires *= 60L * 60L;
        }
      }

    }
    else if(cf_strcmp(opt->name,"HandleLastModifiedSince") == 0) {
      if(cf_strcmp(args[0],"yes") == 0) {
        http_config.handle_last_modified_since = 1;
      }
    }
  }
  else {
    fprintf(stderr,"Expecting one argument for directive %s!\n",opt->name);
    return 1;
  }

  return 0;
}

int flt_http_set_headers(t_cf_hash *cgi,t_cf_hash *header_table,t_configuration *dc,t_configuration *vc,int sock) {
  char buff[BUFSIZ];
  size_t len;
  time_t t;
  struct tm *tm;

  if(http_config.expires_set) {
    t  = time(NULL) + http_config.send_expires;
    tm = gmtime(&t);

    if(tm) {
      len = snprintf(buff,BUFSIZ,"public, max-age=%ld",http_config.send_expires);
      cf_hash_set(header_table,"Cache-Control",14,buff,len+1);

      if((len = strftime(buff,BUFSIZ,"%a, %d %b %Y %H:%M:%S GMT",tm))) {
        cf_hash_set(header_table,"Expires",8,buff,len+1);
      }
    }
  }

  return FLT_OK;
}

int flt_http_validate(t_cf_hash *head,t_configuration *dc,t_configuration *vc,time_t last_modified,int sock) {
  u_char *uname = cf_hash_get(GlobalValues,"UserName",8);
  u_char *uconffile = NULL;
  struct stat st;
  int ret = FLT_DECLINE;

  if(uname) {
    uconffile = get_uconf_name(uname);

    if(uconffile) {
      if(stat(uconffile,&st) != -1) {
        if(st.st_mtime <= last_modified) ret = FLT_OK;
      }

      free(uconffile);
    }
  }

  return ret;
}

time_t flt_http_lm(t_cf_hash *head,t_configuration *dc,t_configuration *vc,int sock) {
  u_char *uname = cf_hash_get(GlobalValues,"UserName",8);
  u_char *uconffile = NULL;
  struct stat st;
  time_t ret = -1;

  if(uname) {
    uconffile = get_uconf_name(uname);

    if(uconffile) {
      if(stat(uconffile,&st) != -1) {
        ret = st.st_mtime;
      }

      free(uconffile);
    }
  }

  return ret;
}

t_conf_opt flt_http_config[] = {
  { "SendLastModified",        flt_http_handle_command, NULL },
  { "SendExpires",             flt_http_handle_command, NULL },
  { "HandleLastModifiedSince", flt_http_handle_command, NULL },
  { NULL, NULL, NULL }
};

t_handler_config flt_http_handlers[] = {
  { CONNECT_INIT_HANDLER, flt_http_execute },
  { 0, NULL }
};

t_module_config flt_http = {
  flt_http_config,
  flt_http_handlers,
  flt_http_validate,
  flt_http_lm,
  flt_http_set_headers,
  NULL
};

/* eof */

---