flt_openclose.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 <time.h>
#include <sys/types.h>

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

/*
 * I think, a sequential search within a range of 256 is reasonable. I think, there are never more than
 * 20 or 30 values in it.
 *
 */
unsigned long long saved_threads[256];  /* Maximum 256 opened threads. This should be enough */
int sclen = 0;
t_string Cgi;
int ThreadsOpenByDefault = -1;

void parse_query_string(t_cf_hash *head,int cl) {
  u_char *val = cf_cgi_get(head,"o");
  u_char *pos = val;
  u_char buff[50];
  unsigned long long tid = 0;
  int i = 0;
  int len;

  if(val) {
    while((tid = strtoull(pos,(char **)&pos,10)) > 0) {
      pos += 1;
      saved_threads[sclen++] = tid;
    }
  }

  val = cf_cgi_get(head,"a");
  if(val) {
    if(cl) { /* threads are closed by default!! */
      if(cf_strcmp(val,"open") == 0) {
  val = cf_cgi_get(head,"t");
  if(val) {
    saved_threads[sclen++] = strtoull(val,NULL,10);
  }
      }
      else {
  val = cf_cgi_get(head,"t");
  if(val) {
    tid = strtoull(val,NULL,10);

    for(i=0;i<sclen;i++) {
      if(tid == saved_threads[i]) {
        saved_threads[i] = -1;
        break;
      }
    }
  }
      }
    }
    else {
      if(cf_strcmp(val,"open") == 0) {
  val = cf_cgi_get(head,"t");
  if(val) {
    tid = strtoull(val,NULL,10);

    for(i=0;i<sclen;i++) {
      if(tid == saved_threads[i]) {
        saved_threads[i] = -1;
        break;
      }
    }
  }
      }
      else {
  val = cf_cgi_get(head,"t");
  if(val) {
    saved_threads[sclen++] = strtoull(val,NULL,10);
  }
      }

    } /* end else */
  }

  for(i=0;i<sclen;i++) {
    if(saved_threads[i] != -1 && saved_threads[i] != 0) {
      str_init(&Cgi);
      len = sprintf(buff,"%lld",saved_threads[i]);
      str_chars_append(&Cgi,buff,len);
      break;
    }
  }

  if(i+1 < sclen) {
    for(i++;i<sclen;i++) {
      if(saved_threads[i] != -1 && saved_threads[i] != 0) {
  len = sprintf(buff,"%%2C%lld",saved_threads[i]);
  str_chars_append(&Cgi,buff,len);
      }
    }
  }

}

int execute_filter(t_cf_hash *head,t_configuration *dc,t_configuration *vc,t_cl_thread *thread,int mode) {
  if(ThreadsOpenByDefault != -1 && mode == 0) {
    int cl = !ThreadsOpenByDefault;
    t_name_value *vs = NULL;
    t_message *msg;
    int i = 0;
    u_char buff[500];
    u_char *UserName = cf_hash_get(GlobalValues,"UserName",8);

    if(UserName) {
      vs = cfg_get_value(dc,"UBaseURL");
    }
    else {
      vs = cfg_get_value(dc,"BaseURL");
    }

    if(!sclen && head) { // get me the list of opened threads
      parse_query_string(head,cl);
    }

    tpl_cf_setvar(&thread->messages->tpl,"openclose","1",1,0);

    i = sprintf(buff,"t%lld",thread->tid);
    tpl_cf_setvar(&thread->messages->tpl,"unanch",buff,i,0);

    if(cl) { /* threads are closed by default! */
      for(i=0;i<sclen;i++) {
  if(saved_threads[i] == thread->tid) {
    tpl_cf_setvar(&thread->messages->tpl,"open","1",1,0);
    i = sprintf(buff,"%s?t=%lld&a=close",vs->values[0],thread->tid);
    tpl_cf_setvar(&thread->messages->tpl,"link_oc",buff,i,1);

    if(Cgi.len) {
      tpl_cf_appendvar(&thread->messages->tpl,"link_oc","&o=",7);
      tpl_cf_appendvar(&thread->messages->tpl,"link_oc",Cgi.content,Cgi.len);
    }

    return FLT_DECLINE; /* thread is open */
  }
      }

      i = sprintf(buff,"%s?t=%lld&a=open",vs->values[0],thread->tid);
      tpl_cf_setvar(&thread->messages->tpl,"link_oc",buff,i,1);

      if(Cgi.len) {
  tpl_cf_appendvar(&thread->messages->tpl,"link_oc","&o=",7);
  tpl_cf_appendvar(&thread->messages->tpl,"link_oc",Cgi.content,Cgi.len);
      }

      msg = thread->messages->next;

      /* thread is closed */
      if(msg) {
  for(;msg;msg=msg->next) {
    msg->may_show = 0;
  }
      }
    }
    else { /* threads are open by default! */
      /* check, if the actual thread is in the closed threads list */
      for(i=0;i<sclen;i++) {
  if(thread->tid == saved_threads[i]) { /* this thread is closed */
    i = sprintf(buff,"%s?t=%lld&a=open",vs->values[0],thread->tid);
    tpl_cf_setvar(&thread->messages->tpl,"link_oc",buff,i,1);

    if(Cgi.len) {
      tpl_cf_appendvar(&thread->messages->tpl,"link_oc","&o=",7);
      tpl_cf_appendvar(&thread->messages->tpl,"link_oc",Cgi.content,Cgi.len);
    }

    msg = thread->messages->next;

    /* hide postings */
    if(msg) {
      for(;msg;msg=msg->next) {
        msg->may_show = 0;
      }
    }

    return FLT_DECLINE; /* thread is open */
  }
      }

      /* this thread must be open */
      tpl_cf_setvar(&thread->messages->tpl,"open","1",1,0);
      i = sprintf(buff,"%s?t=%lld&a=close",vs->values[0],thread->tid);
      tpl_cf_setvar(&thread->messages->tpl,"link_oc",buff,i,1);

      if(Cgi.len) {
  tpl_cf_appendvar(&thread->messages->tpl,"link_oc","&o=",7);
  tpl_cf_appendvar(&thread->messages->tpl,"link_oc",Cgi.content,Cgi.len);
      }
    }

    return FLT_OK;
  }

  return FLT_DECLINE;
}

int get_conf(t_configfile *cfile,t_conf_opt *opt,u_char **args,int argnum) {
  int *x = (int *)opt->data;
  *x     = cf_strcmp(args[0],"yes") == 0 ? 1 : 0;

  return 0;
}

t_conf_opt config[] = {
  { "ThreadsOpenByDefault", get_conf, &ThreadsOpenByDefault },
  { NULL, NULL, NULL }
};

t_handler_config handlers[] = {
  { VIEW_HANDLER, execute_filter },
  { 0, NULL }
};

t_module_config flt_openclose = {
  config,
  handlers,
  NULL,
  NULL,
  NULL,
  NULL
};

/* eof */

---