flt_deleted.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/stat.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"
/* }}} */

struct {
  u_char **BlackList;
  long BLlen;
  int FollowUps;
  time_t ShowFrom;
  time_t ShowUntil;
  u_char *DeletedFile;
  t_cf_tree tree;
} Cfg = { NULL, 0, 0, 0, 0, NULL, { NULL, NULL, NULL } };

int flt_deleted_compare(t_cf_tree_dataset *a,t_cf_tree_dataset *b) {
  if(*((unsigned long long *)a->key) < *((unsigned long long *)b->key)) return -1;
  if(*((unsigned long long *)a->key) > *((unsigned long long *)b->key)) return 1;

  return 0;
}

void flt_deleted_create_tree() {
  FILE *fd;
  struct stat st;
  u_int64_t *field;
  u_int32_t i,nmem = 0;

  t_cf_tree_dataset data;
  data.data = NULL;

  if(!Cfg.tree.root) {
    if(stat(Cfg.DeletedFile,&st) == 0) {
      nmem  = st.st_size / sizeof(*field);
      field = fo_alloc(NULL,nmem,sizeof(*field),FO_ALLOC_MALLOC);

      if((fd = fopen(Cfg.DeletedFile,"r")) == NULL) {
        free(field);
        return;
      }

      fread(field,sizeof(*field),st.st_size / sizeof(*field),fd);
      fclose(fd);

      cf_tree_init(&Cfg.tree,flt_deleted_compare,NULL);
      for(i=0;i<nmem;i++) {
        data.key = memdup(&field[i],sizeof(*field));
        cf_tree_insert(&Cfg.tree,NULL,&data);
      }

      free(field);
    }
    else {
      if((fd = fopen(Cfg.DeletedFile,"w")) !=NULL) {
        fclose(fd);
      }
    }
  }
}


int execute_filter(t_cf_hash *head,t_configuration *dc,t_configuration *vc,t_cl_thread *thread,int mode) {
  t_name_value *url;
  u_char *UserName = cf_hash_get(GlobalValues,"UserName",8);
  t_cf_tree_dataset dt;
  size_t len;
  u_char buff[150];

  dt.data = NULL;

  if(mode == 0) {
    if(UserName) {
      url = cfg_get_value(dc,"UBaseURL");

      if(Cfg.DeletedFile) {
        flt_deleted_create_tree();

        dt.key = &thread->tid;

        if(cf_tree_find(&Cfg.tree,Cfg.tree.root,&dt)) {
          thread->messages->may_show = 0;
          delete_subtree(thread->messages);
        }
        else {
          len = snprintf(buff,150,"%s?a=d&t=%lld",url->values[0],thread->tid);
          tpl_cf_setvar(&thread->messages->tpl,"dellink",buff,len,1);
        }
      }
    }

    return FLT_OK;
  }

  return FLT_DECLINE;
}

int posting_list_filter(t_cf_hash *head,t_configuration *dc,t_configuration *vc,t_message *msg,unsigned long long tid,int mode) {
  long i;

  if(Cfg.BLlen) {
    for(i=0;i<Cfg.BLlen;i++) {
      if(cf_strcasecmp(msg->author,Cfg.BlackList[i]) == 0) {
        msg->may_show = 0;

        if(Cfg.FollowUps == 0) {
          if(!delete_subtree(msg)) {
            return FLT_OK;
          }
        }
      }
    }
  }

  if(mode == 0) {
    if(Cfg.ShowFrom) {
      if(msg->may_show) {
        if(msg->date < Cfg.ShowFrom) {
          msg->may_show = 0;
        }
      }
    }

    if(Cfg.ShowUntil) {
      if(msg->may_show) {
        if(msg->date > Cfg.ShowUntil) {
          msg->may_show = 0;
        }
      }
    }
  }

  return FLT_OK;
}

int delete_thread(t_cf_hash *head,t_configuration *dc,t_configuration *vc) {
  u_char *c_tid,*qs,*a;
  FILE *fd;
  u_int64_t tid;

  if(head && Cfg.DeletedFile) {
    qs = getenv("QUERY_STRING");

    if(qs) {
      a = cf_cgi_get(head,"a");

      if(a && cf_strcmp(a,"d") == 0) {
  c_tid = cf_cgi_get(head,"t");

  if(c_tid) {
          tid = strtoull(c_tid,NULL,10);

          if(tid) {
            flt_deleted_create_tree();

            fd = fopen(Cfg.DeletedFile,"a");
            if(fd) {
              fwrite(&tid,sizeof(tid),1,fd);
              fclose(fd);
            }
            else {
              perror("delete_thread: fopen");
            }

            cf_hash_entry_delete(head,"t",1);
            cf_hash_entry_delete(head,"a",1);
          }
        }
      }

      return FLT_OK;
    }
  }

  return FLT_DECLINE;
}

int flt_del_handle_command(t_configfile *cf,t_conf_opt *opt,u_char **args,int argnum) {
  long i;

  if(cf_strcmp(opt->name,"BlackList") == 0) {
    if(Cfg.BLlen) {
      for(i=0;i<Cfg.BLlen;i++) {
        free(Cfg.BlackList[i]);
      }
      free(Cfg.BlackList);
    }

    Cfg.BLlen = split(args[0],",",&Cfg.BlackList);
  }
  else if(cf_strcmp(opt->name,"ShowBlacklistFollowups") == 0) {
    Cfg.FollowUps = cf_strcasecmp(args[0],"yes") == 0;
  }
  else if(cf_strcmp(opt->name,"ShowFrom") == 0) {
    Cfg.ShowFrom = strtol(args[0],NULL,10);
  }
  else if(cf_strcmp(opt->name,"ShowUntil") == 0) {
    Cfg.ShowUntil = strtol(args[0],NULL,10);
  }
  else if(cf_strcmp(opt->name,"DeletedFile") == 0) {
    if(Cfg.DeletedFile) free(Cfg.DeletedFile);
    Cfg.DeletedFile = strdup(args[0]);
  }

  return 0;
}

void flt_del_cleanup(void) {
  long i;
  if(Cfg.BLlen) {
    for(i=0;i<Cfg.BLlen;i++) {
      free(Cfg.BlackList[i]);
    }
    free(Cfg.BlackList);
  }

  if(Cfg.DeletedFile) free(Cfg.DeletedFile);
}

int flt_deleted_validate(t_cf_hash *head,t_configuration *dc,t_configuration *vc,time_t last_modified,int sock) {
  struct stat st;

  if(Cfg.DeletedFile) {
    if(stat(Cfg.DeletedFile,&st) == -1) return FLT_DECLINE;
    if(st.st_mtime > last_modified) return FLT_EXIT;
  }

  return FLT_OK;
}

time_t flt_deleted_lm(t_cf_hash *head,t_configuration *dc,t_configuration *vc,int sock) {
  struct stat st;

  if(Cfg.DeletedFile) {
    if(stat(Cfg.DeletedFile,&st) == -1) return -1;
    return st.st_mtime;
  }


  return -1;
}

t_conf_opt config[] = {
  { "BlackList",               flt_del_handle_command, NULL },
  { "ShowBlacklistFollowups",  flt_del_handle_command, NULL },
  { "ShowFrom",                flt_del_handle_command, NULL },
  { "ShowUntil",               flt_del_handle_command, NULL },
  { "DeletedFile",             flt_del_handle_command, NULL },
  { NULL, NULL, NULL }
};

t_handler_config handlers[] = {
  { INIT_HANDLER,      delete_thread       },
  { VIEW_HANDLER,      execute_filter      },
  { VIEW_LIST_HANDLER, posting_list_filter },
  { 0, NULL }
};

t_module_config flt_deleted = {
  config,
  handlers,
  flt_deleted_validate,
  flt_deleted_lm,
  NULL,
  flt_del_cleanup
};

/* eof */

---