#include "main_thread.h"
#include "global_config.h"
#include <boost/bind.hpp>
void Main_Thread::init()
{
url.init(this);
url.reserve(10);
url.add("^/$", boost::bind(&Main_Thread::show_main_page,this));
url.add("^$", boost::bind(&Main_Thread::show_main_page,this));
url.add("^/login$", boost::bind(&Main_Thread::show_login,this));
url.add("^/logout$", boost::bind(&Main_Thread::show_logout,this));
url.add("^/newpost$", boost::bind(&Main_Thread::show_post_form,this));
url.add("^/post$", boost::bind(&Main_Thread::get_post_message,this));
url.add("^/dologin$", boost::bind(&Main_Thread::do_login,this));
try {
db.open();
}
catch(MySQL_DB_Err &e)
{
throw HTTP_Error(e.get());
}
}
void Main_Thread::load_cookies()
{
const vector<HTTPCookie> &cookies = env->getCookieList();
unsigned int i;
username.clear();
visitor.clear();
email.clear();
vurl.clear();
password.clear();
for(i=0;i<cookies.size();i++) {
if(cookies[i].getName()=="username") {
username=cookies[i].getValue();
}
else if(cookies[i].getName()=="password") {
password=cookies[i].getValue();
}
else if(cookies[i].getName()=="visitor") {
visitor=cookies[i].getValue();
}
else if(cookies[i].getName()=="email") {
email=cookies[i].getValue();
}
else if(cookies[i].getName()=="url") {
vurl=cookies[i].getValue();
}
}
}
void Main_Thread::check_athentication_by_name(string name,string password)
{
MySQL_DB_Res res=db.query(
escape( "SELECT password,id from cp_users "
"WHERE username='%1%' LIMIT 1")<<name);
MySQL_DB_Row row;
if((row=res.next())!=NULL){
if(password==row[0]) {
authenticated=true;
user_id=atoi(row[1]);
}
username=name;
}
else {
username.clear();
authenticated=false;
}
password.clear();
}
void Main_Thread::check_athentication()
{
load_cookies();
check_athentication_by_name(username,password);
}
void Main_Thread::load_inputs()
{
const vector<FormEntry> &elements=cgi->getElements();
unsigned i;
page=0;
message.clear();
for(i=0;i<elements.size();i++) {
string const &name=elements[i].getName();
if(name=="message"){
message=elements[i].getValue();
}
else if(name=="username"){
new_username=elements[i].getValue();
}
else if(name=="password"){
new_password=elements[i].getValue();
}
}
}
void Main_Thread::show_login()
{
out.puts(
"<html><body>"
"<form name=\"input\" action="/?originalUrl=https%3A%2F%2Fsourceforge.net%2F%253C%2Fspan">\"/site/dologin\" method=\"post\">\n"
" Username: <input type=\"text\" name=\"username\">\n<br>"
" Password: <input type=\"password\" name=\"password\">\n"
//"<input type=\"hidden\" name=\"id\" value=\"dologin\">\n"
" <input type=\"submit\" value=\"Submit\"></form>\n"
"</html></body>");
}
void Main_Thread::do_login()
{
load_inputs();
check_athentication_by_name(new_username,new_password);
if(authenticated) {
set_header(new HTTPRedirectHeader("/site/"));
HTTPCookie cookie_u("username",username,"","",7*24*3600,"/",false);
response_header->setCookie(cookie_u);
HTTPCookie cookie_p("password",new_password,"","",7*24*3600,"/",false);
response_header->setCookie(cookie_p);
}
else {
username="";
password="";
set_header(new HTTPRedirectHeader("/site/login"));
}
};
void Main_Thread::show_logout()
{
set_header(new HTTPRedirectHeader("/site/"));
HTTPCookie cookie("username","","","",0,"/",false);
response_header->setCookie(cookie);
cookie.setName("password");
cookie.setValue("");
response_header->setCookie(cookie);
}
void Main_Thread::printhtml(char const *text)
{
int c;
while((c=*text++)!=0) {
switch(c) {
case '\n': out.puts("<br>\n"); break;
case '<': out.puts("<"); break;
case '>': out.puts(">"); break;
case '&': out.puts("&"); break;
default:
out.putchar(c);
}
}
}
void Main_Thread::show_main_page()
{
check_athentication();
if(authenticated) {
out.printf("<h1>Wellcome %s to forum</h1>\n",username.c_str());
}
else {
out.puts("<h1>Wellcome to the forum</h1>");
}
out.puts("<a href="/?originalUrl=https%3A%2F%2Fsourceforge.net%2F%253C%2Fspan">\"/site/newpost\">New Post</a><br>");
out.puts("<a href="/?originalUrl=https%3A%2F%2Fsourceforge.net%2F%253C%2Fspan">\"/site/logout\">Logout</a><br>");
MySQL_DB_Res res = db.query(
"SELECT cp_messages.id,message,username "
"FROM cp_messages,cp_users "
"WHERE cp_messages.user_id=cp_users.id "
"ORDER BY cp_messages.id DESC LIMIT 10");
MySQL_DB_Row row;
out.puts("<dl>\n");
while((row=res.next())!=NULL) {
out.printf("<dt>Message %s, by %s</dt>\n<dd>\n",row[0],row[2]);
printhtml(row[1]);
out.puts("</dd>\n");
}
out.puts("</dl>\n");
}
void Main_Thread::show_post_form()
{
check_athentication();
if(authenticated) {
out.puts(
"<html><body>"
"<form name=\"input\" action="/?originalUrl=https%3A%2F%2Fsourceforge.net%2F%253C%2Fspan">\"/site/post\" method=\"post\">\n"
"<TEXTAREA NAME=\"message\" COLS=40 ROWS=6></TEXTAREA><br>\n"
//"<input type=\"hidden\" name=\"id\" value=\"post\">\n"
" <input type=\"submit\" value=\"Submit\"></form>\n"
"</html></body>");
}
else {
set_header(new HTTPRedirectHeader("/site/login"));
}
}
void Main_Thread::get_post_message()
{
check_athentication();
load_inputs();
if(!authenticated){
set_header(new HTTPRedirectHeader("/site/login"));
return;
}
db.exec(escape("INSERT INTO cp_messages (message,user_id) values('%1%',%2%)")
<<message<<user_id);
set_header(new HTTPRedirectHeader("/site/"));
}
void Main_Thread::show_page()
{
url.parse();
}
void Main_Thread::main()
{
try {
show_page();
}
catch (MySQL_DB_Err &mysql_err) {
throw HTTP_Error(mysql_err.get());
}
}
