#include "cmd_todo.h"

static int add_todo(sqlite3 *db, char *user, char *todo)
{
  int rc;

  char sql_add_table[1024];
  snprintf(sql_add_table, 1024, "INSERT INTO todo(user,todo) VALUES('%s','%s');", user, todo);
  printf("%s\n", sql_add_table);
  
  if ((rc = sqlite3_exec(db, sql_add_table, 0, 0, 0)) != SQLITE_OK)
  {
    printf("Cannot prepare statment: %s\n", sqlite3_errmsg(db));
    return -1;
  }

  return 0;
}

static int cb_list_todo_table(void *param1, int argc, char **argv, char **cname)
{
  int i;

  sds *out = (sds *)param1;
  //sds local_out = sdsempty();

  for (i=0; i<argc; i++)
  {
    printf("%s = %s, ", cname[i], argv[i] ? argv[i] : "NULL");
    if (strncmp(cname[i],"id",2) == 0)
    {
      *out = sdscat(*out, argv[i]);
      *out = sdscat(*out, " - ");
    } else if (strncmp(cname[i],"todo",4) == 0)
    {
      *out = sdscat(*out, argv[i]);
      *out = sdscat(*out, "\n");
    }
  }

  printf("\n");

  return 0;
}

static int list_todo(sqlite3 *db, char *user, sds *out)
{
  int rc;
  char *err_msg = NULL;

  char sql_list_table[1024];
  snprintf(sql_list_table, 1024, "SELECT * FROM todo WHERE user='%s'", user);

  if ((rc = sqlite3_exec(db, sql_list_table, cb_list_todo_table, out, &err_msg )) != SQLITE_OK)
  {
    printf("Cant list todo: %s\n", err_msg);

    sqlite3_free(err_msg);

    return -1;
  }

  return 0;
}

static int del_todo(sqlite3 *db, char *user, int id)
{
  int rc;
  char *err_msg;

  char sql_del_table[1024];
  snprintf(sql_del_table, 1024, "DELETE FROM todo WHERE user='%s' AND id=%d;", user, id);

  if ((rc = sqlite3_exec(db, sql_del_table, 0, 0, &err_msg )) != SQLITE_OK)
  {
    printf("Cant del todo: %s\n", err_msg);

    sqlite3_free(err_msg);

    return -1;
  }

  return 0;
}

void *cmd_todo(void *data)
{
  char *ret = NULL;
  char *req_data = NULL;
  int fret;
  int rc;
  int i;

  int count;
  sds params = sdsempty();
  sds out_result = sdsempty(), out_todo = sdsempty();
  sds *tokens;

  sqlite3 *db=NULL;
  sqlite3_stmt *res=NULL;
  char *err_msg = NULL;
  int table_todo_exists=1;

  rpc_call_request  *req  = NULL;
  rpc_call_response *resp = NULL;
  netbyte_store *nb_req = NULL, *nb_resp=NULL;
  char *nb_buf = NULL;

  PRINT("TODO\n");

  req_data = (char *)data;
  if (!req_data)
  {
    PERM();
    return NULL;
  }

  //----------------------------------------------------------------------------
  //prepare request
  nb_req = malloc(sizeof(netbyte_store));
  nb_init(nb_req);
  nb_load(nb_req, req_data);

  if (nb_req == NULL)
  {
    ERROR("implement response\n");
    return NULL;
  }

  fret = rpc_call_req_unmarsh(nb_req, &req);
  if (fret != 0)
  {
    ERROR("Invalid request format\n");
    return NULL;
  }

  //----------------------------------------------------------------------------
  //main code

  PRINT("(%s)-(%s)-(%s)-(%s)-(%s)\n", req->method, req->params, req->user, req->mask, req->server);

  if ((rc = sqlite3_open("todo.db", &db)) != SQLITE_OK)
  {
    printf("Cannot open todo database: %s\n", sqlite3_errmsg(db));
    sqlite3_close(db);

    return 1;
  }

  //check if table excists
  char *sql_check_table = "SELECT COUNT(*) FROM sqlite_master WHERE type='table' AND name='todo'";
  if ((rc = sqlite3_prepare_v2(db, sql_check_table, -1, &res, 0)) != SQLITE_OK)
  {
    printf("Cannot prepare statment: %s\n", sqlite3_errmsg(db));
    sqlite3_close(db);
    return 1;
  }

  rc = sqlite3_step(res);
  if (rc == SQLITE_ROW)
  {
    int iret = sqlite3_column_int(res, 0);
    //printf("%d\n", iret);
    if (iret == 0)
    {
      table_todo_exists = 0;
    } else
    {
      table_todo_exists = 1;
    }
  }

  //if table doesnt excists then create new one
  if (table_todo_exists == 0)
  {
    char *sql_create_table = "CREATE TABLE todo(id INTEGER PRIMARY KEY AUTOINCREMENT, user TEXT, todo TEXT)";
    if ((rc = sqlite3_exec(db, sql_create_table, 0, 0, &err_msg)) != SQLITE_OK)
    {
      printf("Cant create table: %s\n", err_msg);
      sqlite3_free(err_msg);
      sqlite3_close(db);
    }
  }

  params = sdsnew(req->params);
  tokens = sdssplitargs(params, &count);
  if (strncmp(tokens[1],"add",3) == 0)
  {
    PRINT("ADD\n");
    if (count > 2)
    {
      sds sAdd = sdsempty();
      for (i=2;i<count;i++)
      {
        sAdd = sdscat(sAdd, tokens[i]);
        sAdd = sdscat(sAdd, " ");
      }
      add_todo(db, req->user, sAdd);
    }
  } else if (strncmp(tokens[1],"del",3) == 0)
  {
    PRINT("DEL\n");
    if (count > 2)
    {
      int id = atoi(tokens[2]);
      del_todo(db, req->user, id);
    }
    
  } else if (strncmp(tokens[1],"list",4) == 0)
  {
    PRINT("LIST\n");
    list_todo(db, req->user, &out_todo);
    PRINT("%s\n",out_todo);
    out_result = sdscatsds(out_result, out_todo);
    out_result[sdslen(out_result)-1] = 0; //dirty hack mate
    sdsfree(out_todo);
  } else
  {

  }

  sqlite3_finalize(res);
  sqlite3_close(db);

  //----------------------------------------------------------------------------
  //prepare response
  nb_resp = malloc(sizeof(netbyte_store));
  nb_init(nb_resp);

  PNL();
  resp = rpc_call_resp_new(out_result,"None",1);
  resp->user = alloc_new_str(" ");
  resp->server = alloc_new_str(" ");
  resp->mask = alloc_new_str(" ");
  PNL();
  rpc_call_resp_marsh(resp, &nb_resp);

  PNL();
  nb_buf = (char *)nb_create(nb_resp);
  if (nb_buf)
  {
    ret = nb_buf;
  }

  nb_free(nb_resp);
  rpc_call_resp_free(resp);

  return ret;
}