#include <tcutil.h>
#include <tctdb.h>
#include <stdlib.h>
#include <stdbool.h>
#include <stdint.h>
#include <string.h>
#include <stdio.h>

/* function prototypes */
int main(int argc, char **argv);
static void proc(TCTMPL *tmpl, TCMPOOL *mpool);

/* main routine */
int main(int argc, char **argv){
  TCTMPL *tmpl = tctmplnew();
  tctmplload2(tmpl, "tctchat.tmpl");
  TCMPOOL *mpool = tcmpoolnew();
  proc(tmpl, mpool);
  tcmpooldel(mpool);
  tctmpldel(tmpl);
  return 0;
}

/* process each session */
static void proc(TCTMPL *tmpl, TCMPOOL *mpool){
  printf("Content-Type: text/html; charset=UTF-8\r\n");
  printf("\r\n");
  TCMAP *params = tcmpoolmapnew(mpool);
  char *query = getenv("QUERY_STRING");
  const char *rp = getenv("CONTENT_LENGTH");
  if(rp){
    int clen = tclmin(tcatoi(rp), 1024 * 1024);
    query = tcmpoolmalloc(mpool, clen + 1);
    fread(query, 1, clen, stdin);
    query[clen] = '\0';
  }
  if(query) tcwwwformdecode(query, params);
  const char *author = tcmapget4(params, "author", "");
  const char *text = tcmapget4(params, "text", "");
  int page = tcatoi(tcmapget4(params, "page", "1"));
  const char *dbpath = tctmplconf(tmpl, "dbpath");
  if(!dbpath) dbpath = "casket.tct";
  TCLIST *msgs = tcmpoollistnew(mpool);
  TCTDB *tdb = tctdbnew();
  tcmpoolpush(mpool, tdb, (void (*)(void *))tctdbdel);
  rp = getenv("REQUEST_METHOD");
  if(rp && !strcmp(rp, "POST") && *author != '\0' && *text != '\0'){
    if(!tctdbopen(tdb, dbpath, TDBOWRITER | TDBOCREAT))
      tclistprintf(msgs, "The database could not be opened (%s).", tctdberrmsg(tctdbecode(tdb)));
    tctdbsetindex(tdb, "", TDBITDECIMAL | TDBITKEEP);
    char pkbuf[64];
    int pksiz = sprintf(pkbuf, "%.0f", tctime() * 1000);
    TCMAP *cols = tcmpoolmapnew(mpool);
    tcmapput2(cols, "a", author);
    tcmapput2(cols, "t", text);
    tctdbtranbegin(tdb);
    if(!tctdbputkeep(tdb, pkbuf, pksiz, cols)) tclistprintf(msgs, "The message is ignored.");
    tctdbtrancommit(tdb);
  } else {
    if(!tctdbopen(tdb, dbpath, TDBOREADER))
      tclistprintf(msgs, "The database could not be opened (%s).", tctdberrmsg(tctdbecode(tdb)));
  }
  TCLIST *logs = tcmpoollistnew(mpool);
  TDBQRY *qry = tctdbqrynew(tdb);
  tcmpoolpush(mpool, qry, (void (*)(void *))tctdbqrydel);
  tctdbqrysetorder(qry, "", TDBQONUMDESC);
  tctdbqrysetlimit(qry, 16, page > 0 ? (page - 1) * 16 : 0);
  TCLIST *res = tctdbqrysearch(qry);
  tcmpoolpushlist(mpool, res);
  int rnum = tclistnum(res);
  for(int i = rnum - 1; i >= 0; i--){
    int pksiz;
    const char *pkbuf = tclistval(res, i, &pksiz);
    TCMAP *cols = tctdbget(tdb, pkbuf, pksiz);
    if(cols){
      tcmpoolpushmap(mpool, cols);
      tcmapprintf(cols, "pk", "%s", pkbuf);
      char date[64];
      tcdatestrwww(tcatoi(pkbuf) / 1000, INT_MAX, date);
      tcmapput2(cols, "d", date);
      const char *astr = tcmapget4(cols, "a", "");
      tcmapprintf(cols, "c", "c%02u", tcgetcrc(astr, strlen(astr)) % 12 + 1);
      tclistpushmap(logs, cols);
    }
  }
  TCMAP *vars = tcmpoolmapnew(mpool);
  if(tclistnum(msgs) > 0) tcmapputlist(vars, "msgs", msgs);
  if(tclistnum(logs) > 0) tcmapputlist(vars, "logs", logs);
  tcmapprintf(vars, "author", "%s", author);
  if(page > 1) tcmapprintf(vars, "prev", "%d", page - 1);
  if(tctdbrnum(tdb) > page * 16) tcmapprintf(vars, "next", "%d", page + 1);
  char *str = tctmpldump(tmpl, vars);
  fwrite(str, 1, strlen(str), stdout);
  tcfree(str);
}