/*
  (c) 2007 Christopher Olsen

  $Id$
*/

#include <sys/types.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
#include <time.h>
#include <netdb.h>
#include <mysql/mysql.h>

#define NUM_THREADS   1
#define MYPORT        9999         // the port users will be connecting to
#define BACKLOG       10           // how many pending connections queue will hold
#define LOG_FILE      "./tuved.log"
#define PING_INTERVAL 20
#define MAX_PING      2
#define MAX_COUNT     2
#define MAX_TOPIC_LEN 128
#define MAX_CHAN_LEN  32
#define MAX_USER_LEN  32
#define MAX_BANS      30
#define VERSION       "v0.40"
#define MYSQL_HOST_NAME "ubuse.ubixos.com"
#define MYSQL_USERNAME  "tuve"
#define MYSQL_PASSWORD  "5558585"
#define MYSQL_DB_NAME   "tuve"
#define VIDE_PAD_TIME   2 // Time Added To Video End To Ensure All Are In Sync

/* Cannel Modes */
#define CHAN_MODES      6 // Count Of Channel Modes
#define CHAN_RANDOM     0 // Random Videos
#define CHAN_QUEUE      1 // Users Queues
#define CHAN_TIME       2 // Video Time Limit
#define CHAN_RATING     3 // Video Parental Rating
#define CHAN_CLASS      4 // Video Classs
#define CHAN_LIVE       5 // Channel Is In Live Stream Mode

typedef struct tuveUserList {
  struct tuveUserList  *prev;
  struct tuveUserList  *next;
  struct myConnections *user; 
  } tuveUserList_t;

typedef struct tuveChanList {
  struct tuveChanList  *prev;
  struct tuveChanList  *next;
  struct tuveUserList  *users;
  struct tuveUserList  *nextUser;
  long long bans[MAX_BANS];
  char   modes[CHAN_MODES];
  time_t topicSet;
  char   topicSetBy[MAX_USER_LEN];
  char   topic[MAX_TOPIC_LEN];
  char   channel[MAX_CHAN_LEN];
  char   videoFile[256];            // File Name Of Video
  char   videoChanTitle[256];       // Video Title Displayed In The Channel w/ Links
  char   videoTitle[256];           // Video Title w/o Links
  int    videoEnd;                  // Time At Which The Server Considers The Video Has Ended
  int    songTime;
  int    userCount;
  int    vid;
  short  count;
  short  maxTime;
  } tuveChanList_t;

typedef struct tuveUserChans {
  struct tuveUserChans *prev;
  struct tuveUserChans *next;
  char   channel[32];
  } tuveUserChans_t;

typedef struct tuveUser {
  short  ident;
  short  pfailed;
  short  status;
  short  mode;
  short  queue;
  long long uid;
  time_t pong;
  time_t idle;
  char   username[MAX_USER_LEN];
  tuveUserChans_t *chans;
  } tuveUser_t;


typedef struct myConnections {
  struct myConnections *prev;
  struct myConnections *next;
  int    fd;
  int    recLen;
  char   data[1024];
  char   host[128];
  tuveUser_t userInfo;
  time_t signedOn;
  } myConnections_t;

/*
  Global variables very not safe
 */

extern int songCount;
extern int playCount;
extern int channelCount;
extern int userCount;
extern int listenerFD;
extern int highSock;
extern myConnections_t *connections;
extern FILE *logFile;
extern tuveChanList_t *channels;
extern pthread_mutex_t chanMutex;
extern time_t startTime;

/* Socket Functions */
ssize_t sReadSocket(int socketFD,void *buffer,size_t length);
myConnections_t *sFindConnection(int fd); 
int sStartListener();
int sAddConnection(int,char *host);
int sGetConnections(fd_set *);
int sProcessConnections(fd_set *);
int sSendPing(time_t);                                                // Sends Ping To All Sockets
int sCleanConnections();                                              // Cleans Up The Dead Connections
int sSendData(myConnections_t *con,char const * __restrict fmt, ...); // Sends Data To A Socket
/*
 * End Socket functions
 */

/* Log Functions */
int writeLog(int level,char const * __restrict, ...);

/* Channel Functions */
int tuveChanList(myConnections_t *userConnection);                     // Sends Channel List To Provided Users
int tuveChanPart(const char *channel,myConnections_t *userConnection); // Parts A User From A Channel
int tuveChanResume(const char *channel);                               // Resumes Streaming In A Channel
int tuveChanJoin(const char *channel,myConnections_t *userConnection); // Joins A Users To A Channel
int tuveAddChan(const char *channel,myConnections_t *userConnection);
int tuveAddToChanList(const char *channel,myConnections_t *userConnection);
int tuveSendAllInChan(const char *channel,myConnections_t *userConnection,char *output);
int tuveDelUserChans(myConnections_t *userConnection,char *msg);
int tuveRemoveFromChanList(const char *channel,myConnections_t *userConnection);
int tuveSetTopic(myConnections_t *userConnection,char *chan,char *topic);
int tuveSendAllInUsersChans(myConnections_t *userConnection,char *output);
int tuveDelChan(const char *channel,myConnections_t *userConnection);
int tuveKick(char *by,char *chan,char *nick,char *msg);
tuveChanList_t *findChan(const char *);
int tuveBan(const char *channel,const char *nick);
int tuveUnBan(const char *channel,const char *nick);
int tuveVerifyBan(const char *channel,const char *nick);
/*
 * End Channel Functions
 */

/* Bot Functions */
void *tuveBotThread(void *threadid);
int tuveBotCMD(myConnections_t *userConnection,char *chan,char *data);
int tuveBotSetSong(char *channel,char *nick,char *artist,char *title,int length,char *file,int vid);
int tuveBotSetVideo(char *chan,char *nick,int vid);
/*
 * End Bot Functions
 */

/* Nick Functions */
int tuveVerifyNick(char *nick);
myConnections_t *findNick(const char *);
int tuveWhois(myConnections_t *userConnection,char *nick);
/*
 * End Nick Functions
 */

/* Server Functions */
int tuveStatus(myConnections_t *userConnection);
/*
 * End Server Functions
 */

/* Database Functions */
int dbInit();
MYSQL_RES *dbQuery(const char *query);
/*
 * End Database Functions
 */