diff --git a/thread.c b/thread.c index 54112df..869a8cf 100644 --- a/thread.c +++ b/thread.c @@ -14,7 +14,6 @@ tid = (int)threadid; writeLog(0,"Starting Bot's CMD Thread: [%d]\n", tid); while (1) { - writeLog(0,"THREAD LOOPED\n"); if (connected == 0) { sleep(5); if (joinChan == 1) { @@ -25,7 +24,7 @@ } else { sleep(30); - res = dbQuery("SELECT channel,rating,classification FROM channels WHERE updated = 1",1); + res = dbQuery("SELECT channel,rating,classification,random,queue,exclusive,time FROM channels WHERE updated = 1",1); if (mysql_num_rows(res) > 0) { for (i = 0;i < mysql_num_rows(res);i++) { row = mysql_fetch_row(res); @@ -43,6 +42,28 @@ sWriteSocket("MSG %s:.tv mode +C %i",row[0],tmpVal); else sWriteSocket("MSG %s:.tv mode -C",row[0]); + /* Set Random */ + if (row[3] == '1') + sWriteSocket("MSG %s:.tv mode +R",row[0]); + else + sWriteSocket("MSG %s:.tv mode -R",row[0]); + /* Set Queue */ + if (row[4] == '1') + sWriteSocket("MSG %s:.tv mode +Q",row[0]); + else + sWriteSocket("MSG %s:.tv mode -Q",row[0]); + /* Set Exclusive */ + if (row[5] == '1') + sWriteSocket("MSG %s:.tv mode +E",row[0]); + else + sWriteSocket("MSG %s:.tv mode -E",row[0]); + /* Set Time */ + tmpVal = atoi(row[6]); + if (tmpVal > 0) + sWriteSocket("MSG %s:.tv mode +T %i",row[0],tmpVal); + else + sWriteSocket("MSG %s:.tv mode -T",row[0]); + sprintf(qryStr,"UPDATE channels SET updated = 0 WHERE channel = '%s'",row[0]); dbQuery(qryStr,0); }