/*************************************************************************
 * Copyright 2009 Ralph Spitzner (rasp@spitzner.org)
 *
 * This file is part of Yahdr.
 *
 * Yahdr is free software: you can redistribute it and/or modify
 *    it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * Yahdr is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with Yahdr.  If not, see <http://www.gnu.org/licenses/>.
 **************************************************************************/



#include "defs.hpp"

extern struct rbuf *mypackbuf;
using namespace std;




int handleDefault( ehttp &obj, void *cookie );
static string recorddir,htmltemplate,dbname,channelselect;


uint16_t adapter,demux_adapter;
static ehttp   http;



DVBtcontrol *dvbctrl;
CHANNEL *basechan,*chanp;


sql::mysql::MySQL_Driver *driver;
sql::Connection *con;
sql::Statement *stmt;


struct rbuf *rbufmain,*rbufrun,*rbufvid,*rbuftim;

#define NUMCLIENTS 8



void setpids(CPIDS *pidlist,uint16_t *pidarr, uint16_t *numpids)
    {
    CPIDS *p;
    uint16_t count = 1;

   p = pidlist;
   printf("############# setpids\n");
    while(p)
        {
        printf("count=%d p=%d\n",count,p->pid);
        if((p->type == 2) || (p->type == 27))
            pidarr[0] = p->pid;
        else
            pidarr[count++] = p->pid;
        p = p->next;
        }
    *numpids = count;
#warning above pidcount correct ?
    pidarr[count] = 0;
    }




string *specialchars(unsigned char *data)
    {
    string *ret;
    char special[256];
    int x;
    unsigned char *p;

    if (!(ret = new string))
        {
        cout << "no mem for new string ??" << endl;
        exit(0);
        }
    ret->assign("");

    p = data;

    while (*data != '\0')
        {
        x = 0;
        if (*data < 0x10)
            data++;
        else if (*data == 0x10)
            data += 3;
        switch (*data)
            {
            case 0x8a:
            case 0x0a:
            case 0x0d:
                ret->append("<br>");
                x = 1;
                break;
                /*        case 0x20:
                          ret->append("&nbsp;");
                          x = 1;
                          break;*/
            case 0x86:
                //ret->append("<strong>");
                x = 1;
                break;
            case 0x87:
                //ret->append("</strong>");
                x = 1;
                break;
            case '\'':
                ret->append("&#x27;");
                x = 1;
                break;
            case '"':
                ret->append("&quot;");
                x = 1;
                break;
            case '\\':
                ret->append("&#x5c;");
                x = 1;
                break;
            case '\t':
                for (int i = 0; i != 4; i++)
                    ret->append("&nbsp;");
                x = 1;
                break;
            case '/':
                ret->append("&#x2f;");
                x = 1;
                break;
            }
        if ( *data > 0x7f && x == 0)
            {
            sprintf(special,"&#%d;",(unsigned char)*data);
            ret->append(special);
            }
        else if ( x == 0)
            ret->append(1,(char)*data);
        //    printf("data = %x -> %c  %c\n", *data & 0xff,*data, *data > 0x7f ? '-' : '!');

        data++;

        //cout << "str: " << ret->data() << endl;
        }
    return ret;
    }













int my_write_out(uint8_t *buf, int count)
    {
    key_t msgkey = MPG_MSG_KEY;
    static int mq_id;
    static uint32_t pcount;
    static MPG_MSG msg;
    static int recfile;
    if (mq_id == 0)
        mq_id = msgget(msgkey,IPC_CREAT|0666);


    if (count == -1)
        {
        printf("supposed to write -1 ?\n");
        return -1;

        }
    memcpy(msg.data,buf,count);
    msg.size = count;

    msg.type = MSG_DATA;

    msg.seq  = pcount ++;
    for (int x = 0; x != MAXCLIENTS; x++)
        {
        if (rbufrun->http_pids[x] != 0)
            {
            msg.address = x;
            msgsnd(mq_id,&msg,sizeof(MPG_MSG),0);
            }
        }


    if (rbufrun->recording == 1)
        {
        if (recfile == 0)
            {
            printf("[%d]my_write_out: opening '%s' for recording...\n",getpid(),rbufrun->recfile);
            recfile = open(rbufrun->recfile,O_WRONLY|O_CREAT,0666);
            }
        else
            write(recfile,buf,count);
        }
    else if (recfile)
        {
        if (rbufrun->recording == 0)
            {
            close(recfile);
            recfile = 0;
            }
        }
    pcount ++;
    return count;
    }


uint8_t checkpid(rbuf *buffer,uint16_t pid)
    {
    uint16_t count;
    switch(pid)
        {
        case 0:
        case 1:
        case 16 ... 18:
        case 20:
            return 1;
        default:
            count = buffer->numpids;
            do
                {
                // printf("checking pid %d\n",pid);
                if(pid == buffer->cpids[count])
                    {
                    return 0x80 + count;

                    }

                }
            while(count-- > 0);

        }
    return false;
    }




pid_t run(string device)
    {
    pid_t me;

    int dvr;
    int audio,video;
    int count;
    uint16_t npid1;
    uint8_t buffer[(1024*64)];
    int c,syn,num;
    int oldvpid,oldapid;
    int shmid;
    key_t key;
    int rewr;



    me = fork();

    if (!me)
        {

        key = 18081968;


        if ((shmid = shmget(key, sizeof(struct rbuf), 0666)) < 0)
            {
            perror("shmget run");
            exit(1);
            }
        if ((rbufrun = (struct rbuf *)shmat(shmid, NULL, 0)) == (struct rbuf *) -1)
            {
            perror("shmat");
            exit(1);
            }

        //while(1)
        //;


        if (!(dvr = open(device.data(),O_RDONLY)))
            {
            printf("[run] no dvr >%s<\n",device.data());
            return false;
            }


        while (1)
            {
            count = 0;
            while (1)
                {
                read(dvr,buffer,1);
                if (count++ == GIVE_UP)
                    {
                    fprintf(stderr,"I can hardly believe this is MPEG-2 TS. (buffer[0] = %x..\n",buffer[0]&0xff);
                    exit(-1);
                    }
                c = buffer[0] & 0xff;
                syn = c == 0x47 ? 1 : 0;
                if (syn)
                    {
                    printf("c = %x\n",c);
                    read(dvr,buffer,188);
                    printf("next = %x\n",buffer[187] & 0xff);

                    if (buffer[187] == 0x47)
                        {
                        read(dvr,&buffer,187);
                        break;
                        }
                    }
                }
            printf("synced\n");
            while (1)
                {
                num = read(dvr,buffer,188);

                if (buffer[0] != 0x47 || num != 188)
                    {
                    printf("resync\n");
                    break;
                    }


                npid1 = (buffer[1] & 0x1f)  << 8;
                npid1 |= buffer[2];
                rewr = checkpid(rbufrun,npid1); // see if we want this pid
                buffer[1] &= 0xe0;
                buffer[2] = rewr;
                my_write_out(buffer,188);
                //else if(rewr > 0)
                //my_write_out(buffer,188);


                /*  if (npid1 == rbufrun->vpid)
                  {
                      buffer[1] &= 0xe0;
                      buffer[2] = 101;
                  }
                  else if (npid1 == rbufrun->apid)
                  {
                      buffer[1] &= 0xe0;
                      buffer[2] = 102;
                  }*/
                }
            }



        }
    else
        return me;

    }

/*******************************************************
request handler for video port
********************************************************/








pid_t handlereq(int sock,int clnum)
    {

    pid_t me;


    me = fork();
    if (!me)
        {
        uint8_t buffer[4096];
        int len;
        int shmid;
        key_t key;
        int mybeat;

        key_t msgkey = MPG_MSG_KEY;
        int mq_id;
        MPG_MSG msg;

        mq_id = msgget(msgkey,0);





        key = 18081968;

        if ((shmid = shmget(key, sizeof(struct rbuf), 0666)) < 0)
            {
            printf("[%d]handlereq: shmget ",getpid());
            return 0;
            }
        if ((rbufvid = (struct rbuf *)shmat(shmid, NULL, 0)) == (struct rbuf *) -1)
            {
            printf("[%d]handlereq: shmat",getpid());
            return 0;
            }



        for (int i = 0; i != MAXCLIENTS; i++)
            {
            if (rbufvid->http_pids[i] == me)
                {
                mybeat = i;
                break;
                }
            }


        read(sock,buffer,1023);
        printf("new client\n");
        sprintf((char *)buffer,"HTTP/1.1 200 OK\nContent-Type: video/mpeg\n\n");
        write(sock,buffer,strlen((char *)buffer));
        //fcntl(sock,O_NONBLOCK);
        // int flag = 1;
        // int result = setsockopt(sock,            /* socket affected */
        //                         IPPROTO_TCP,     /* set option at TCP level */
        //                         TCP_NODELAY,     /* name of option */
        //                         (char *) &flag,  /* the cast is historical
        //                                           cruft */
        //                         sizeof(int));    /* length of option value */
        // if (result < 0)
        // printf("TCP_NODEAY set failed\n");


        while (1)
            {

            msgrcv(mq_id,&msg,sizeof(MPG_MSG),0,0);
            if (msg.address != clnum)
                continue;
            len = 0;

            //printf("write size = %d\n",msg.size);
            len = send(sock,&msg.data,msg.size,0);
            if (len < 0 )
                {

                close(sock);
                printf("[%d]handlereq: client lost... (len = %d, wrote %d)\n",getpid(),msg.size,len);

                rbufvid->http_pids[clnum] = 0;


                //while(msgrcv(mq_id,&msg,sizeof(MPG_MSG),0,0) != -1)
                //  printf("getting msgs\n");


                return 0;
                }

            rbufvid->http_beats[mybeat] = time(0);

            }


        return 1;
        }
    else
        return me;
    }



pid_t servvid()
    {

    pid_t me;
    int good;

    me = fork();

    if (!me)
        {
        int sockfd, newsockfd, clilen;
        int clients;
        struct sockaddr_in serv_addr, cli_addr;

        clients = 0;



        sockfd = socket(AF_INET, SOCK_STREAM , 0);
        if (sockfd < 0)
            {
            printf("Video out sock fail\n");
            return 0;
            }

        bzero((char *) &serv_addr, sizeof(serv_addr));
        serv_addr.sin_family = AF_INET;
        serv_addr.sin_addr.s_addr = INADDR_ANY;
        serv_addr.sin_port = htons(666);
        if (::bind(sockfd, (struct sockaddr *) &serv_addr,
                   sizeof(serv_addr)) < 0)
            {
            printf("[%d]servvid: ERROR on binding\n",getpid());
            return 0;
            }
        listen(sockfd,5);
        clilen = sizeof(cli_addr);


        while (1)
            {
            newsockfd = accept(sockfd,
                               (struct sockaddr *) &cli_addr,
                               (socklen_t *)&clilen);
            if (newsockfd < 0)
                {
                printf("[%d]servvid: ERROR on accept\n",getpid());
                exit(0);
                }
            good = 0;
            for (clients = 0; clients != MAXCLIENTS; clients++)
                {

                if (rbufmain->http_pids[clients] == 0)
                    {
                    rbufmain->http_pids[clients] = handlereq(newsockfd,clients);
                    good = 1;
                    break;
                    }
                }
            if (good == 0)
                cout << "MAXCLIENTS reached no service :-) " << endl;
            }




        }
    else
        return me;
    }

#warning werk here


static  sql::mysql::MySQL_Driver *cdriver;
static   sql::Connection *ccon;
static   sql::Statement *cstmt;


sql::Statement *check_sql(sql::mysql::MySQL_Driver *driver,sql::Connection *con,sql::Statement *stmt)
    {


    try
        {
        cstmt = stmt;
        stmt->execute("use epg");

        }
    catch (sql::SQLException &e)
        {
        cout << __FUNCTION__ ;
        cout << " at " << __LINE__;
        cout << "########## ERR: " << e.what();
        cout << " (MySQL error code: " << e.getErrorCode();
        cout << ", SQLState: " << e.getSQLState() << " )" << endl;
        cout << "re-animating sql" << endl;



        cdriver = sql::mysql::get_mysql_driver_instance();
        ccon = cdriver->connect("tcp://127.0.0.1:3306", "fernseher", "glotze");
        cstmt = ccon->createStatement();
        cstmt->execute("USE epg");
        }
    return cstmt;
    }







static void my_handler(int sig);
struct itimerval mval;

void start_timer(void)
    {

    mval.it_value.tv_sec = 10;
    mval.it_value.tv_usec = 0 ;
    mval.it_interval.tv_sec = 10;
    mval.it_interval.tv_usec = 0;
    signal(SIGALRM,&my_handler);
    setitimer(ITIMER_REAL,&mval,0);

    }






static void my_handler(int sig)
    {
    sql::ResultSet  *res;
    time_t now;
    char buffer[256];
    CHANNEL *tp,*cp;
    static sql::mysql::MySQL_Driver *tdriver;
    static sql::Connection *tcon;
    static sql::Statement *tstmt;


    int shmid;
    key_t key;
    static time_t endtime;
    static int target_id;
    int errcount;
    static int event,start;

    int rstatus,ichan;


    now = time(0);
    if (tdriver == 0)
        {
        tdriver = sql::mysql::get_mysql_driver_instance();
        tcon = tdriver->connect("tcp://127.0.0.1:3306", "fernseher", "glotze");
        tstmt = tcon->createStatement();
        tstmt->execute("USE epg");
        }
    key = 18081968;
    if (rbuftim == NULL)
        {

        if ((shmid = shmget(key, sizeof(struct rbuf), 0666)) < 0)
            {
            perror("shmget timer");
            exit(1);
            }
        if ((rbuftim = (struct rbuf *)shmat(shmid, NULL, 0)) == (struct rbuf *) -1)
            {
            perror("shmat");
            exit(1);
            }
        }





    tstmt  = check_sql(tdriver,tcon,tstmt);

    tp = basechan;
    now = time(0);
    printf("## beat %s",ctime(&now));

    for (int i = 0; i != MAXCLIENTS; i++)
        {
        if (rbuftim->http_pids[i] != 0)
            {
            //printf("%d last beat @ %s",rbuftim->http_pids[i],ctime(&rbuftim->http_beats[i]));
            if ((now - rbuftim->http_beats[i] >= 30) && (rbuftim->http_beats[i] != 0))
                {
                printf("[timer]: video server [%d] idle for %d seconds, killing it....\n",(int)rbuftim->http_pids[i],(int)(now - rbuftim->http_beats[i]));
                kill(rbuftim->http_pids[i],SIGKILL);
                rbuftim->http_pids[i] = 0;
                rbuftim->http_beats[i] = 0;

                }
            }
        }



    if (rbuftim->recording == 0)
        {
        sprintf(buffer,"select * from recordings where start>%d and start<%d;",(int)now-240,(int)now+120);
        try
            {
            res = tstmt->executeQuery(buffer);
            }
        catch (sql::SQLException &e)
            {
            cout << __FUNCTION__ ;
            cout << " at " << __LINE__;
            cout << "########## ERR: " << e.what();
            cout << " (MySQL error code: " << e.getErrorCode();
            cout << ", SQLState: " << e.getSQLState() << " )" << endl;
            cout << "not ok 1" << endl;
            }
        if (res)
            {
            if (res->next() && rbuftim->recording == 0 && res->getInt("recflag") == 1)
                {
                errcount = 0;
                //dvbctrl->tuneto(res->getInt("freq"),res->getInt("bw"),(fe_modulation_t)res->getInt("qam"));
                ichan = res->getInt("intchan");
                cp = basechan;
                while (cp)
                    {
                    if (cp->channum == ichan)
                        break;
                    cp = cp->next;
                    }

                //delete sp;
#warning "WERK on pid setting !!!"
                printf("recording, setting pids\n");
                setpids(cp->cpids,rbufmain->cpids,&rbufmain->numpids);
                dvbctrl->tuneto(cp->freq,cp->bw,cp->cpids,cp->qam);
                printf("tuneto done....");



                endtime = res->getInt("start") + res->getInt("duration") + 240;
                target_id = res->getInt("event_id");

                event = res->getInt("event_id");
                start = res->getInt("start");

                while (1)
                    {
                    rstatus = checkrunning(adapter,res->getInt("event_id"));
                    if (errcount > 20 && time(0) > res->getInt("start")) /// sender sent not defined as status 20 times, start anyway
                        {
                        endtime = time(0) + res->getInt("duration")+180;
                        strcpy(rbuftim->recfile,res->getString("filename").data());
                        rbuftim->recording = 1;
                        shmdt(rbuftim);
                        return;
                        }
                    printf("timer: rstatus %d\n",rstatus);
                    switch (rstatus)
                        {
                        case -1:
                        case  0:
                            errcount ++;
                            break;
                        case 4:
                            //case 2:
                            if (rbuftim->recording == 0)
                                {
                                endtime = time(0) + res->getInt("duration")+180;
                                strcpy(rbuftim->recfile,res->getString("filename").data());
                                rbuftim->recording = 1;
                                }

                            return;
                            break;
                        }
                    sleep(2);
                    }
                }
            else
                {
                sprintf(buffer,"select * from recordings where start>%d and start<%d;",(int)now-30,(int)now+30);
                try
                    {
                    res = tstmt->executeQuery(buffer);
                    }
                catch (sql::SQLException &e)
                    {
                    cout << __FUNCTION__ ;
                    cout << "########## ERR: " << e.what();
                    cout << " (MySQL error code: " << e.getErrorCode();
                    cout << ", SQLState: " << e.getSQLState() << " )" << endl;
                    cout << "not ok 1" << endl;
                    }
                if (res->next())
                    {
                    if (rbuftim->recording == 0 && res->getInt("recflag") == 0)
                        {
                        /// just switch channels
                        ichan = res->getInt("intchan");
                        cp = basechan;
                        while (cp)
                            {
                            if (cp->channum == ichan)
                                break;
                            cp = cp->next;
                            }

                  //      delete sp;
                        setpids(cp->cpids,rbufmain->cpids,&rbufmain->numpids);
                        dvbctrl->tuneto(cp->freq,cp->bw,cp->cpids,cp->qam);


                        //dvbctrl->tuneto(res->getInt("freq"),res->getInt("bw"),(fe_modulation_t)res->getInt(9));
                        sprintf(buffer,"delete from recordings where event_id=%d and start=%d",
                                res->getInt("event_id"),res->getInt("start"));
                        stmt->execute(buffer);
                        }
                    }
                }


            }
        }

    else if (rbuftim->recording == 1 && rbuftim->instant == 0)
        {
        rstatus = checkrunning(adapter,target_id);
        if (time(0) > endtime )
            {
            printf("stop recording [running status %d + grace timeout(end %d now %d]\n",rstatus,(int)endtime,(int)time(0));
            sprintf(buffer,"delete from recordings where event_id=%d and start=%d;",event,start);
            printf("SQL: %s\n",buffer);
            try
                {
                tstmt->execute(buffer);
                }
            catch (sql::SQLException &e)
                {
                cout << __FUNCTION__ ;
                cout << " at " << __LINE__;
                cout << "########## ERR: " << e.what();
                cout << " (MySQL error code: " << e.getErrorCode();
                cout << ", SQLState: " << e.getSQLState() << " )" << endl;
                cout << "not ok 1" << endl;
                }
            rbuftim->recording = 0;
            }
        }

    }



#warning something stinks here killhandler calling itself ?

void killhandler(int sig)
    {

    int shmid;
    key_t key;
    struct rbuf *rbufkill;

    key = 18081968;

    if ((shmid = shmget(key, sizeof(struct rbuf), 0666)) < 0)
        {
        perror("shmget timer");
        exit(1);
        }
    if ((rbufkill = (struct rbuf *)shmat(shmid, NULL, 0)) == (struct rbuf *) -1)
        {
        perror("shmat");
        exit(1);
        }
    printf("caught signal %d, terminating\n",sig);

    printf("Killing videoserver(s)..");
    fflush(stdout);

    for (int i = 0; i != MAXCLIENTS; i++)
        {
        if (rbufkill->http_pids[i] != 0)
            {
            printf("[%d]..",rbufkill->http_pids[i]);
            fflush(stdout);
            kill(rbufkill->http_pids[i],SIGINT);
            rbufkill->http_pids[i] = 0;
            }
        }
    if (rbufkill->servvid != 0)
        {
        printf("\nKilling videoport-handler [%d]\n",rbufkill->servvid);
        kill(rbufkill->servvid,SIGINT);
        rbufkill->servvid = 0;
        }
    if (rbufkill->run_pid != 0)
        {
        printf("Killing video-packethandler [%d]\n",rbufkill->run_pid);
        kill(rbufkill->run_pid,SIGINT);
        rbufkill->run_pid = 0;
        }
    printf("exiting...\n");
    exit(0);


    }

static int con_fd;


void handle_http(int *s,Connection *c)
    {
    struct pollfd poller;
    int err;
    pid_t me;




    if (!fork())
        {
        me = getpid();
        poller.fd = *s;
        poller.events = POLLIN | POLLRDHUP;
        /// this has to be here aswell because of fork()

        /*  driver = sql::mysql::get_mysql_driver_instance();
          con = driver->connect("tcp://127.0.0.1:3306", "fernseher", "glotze");
          stmt = con->createStatement();
          con->setSchema("epg");
        */

        con_fd = *s;
        while (1)
            {
            printf("[%d]handle_http: polling ...\n",me);
            /// 300 sec. is what netscape/seamonkey usually requests,
            /// no sense in taking Keep-Alive: <time> serious, because
            /// it could keep us alive forever.....

            err = poll(&poller,1,300*1000);
            if (err == 0) /// timeout
                {
                printf("[%d]handle_http: timeout for connection\n",me);
                break;
                }
            else if (poller.revents & POLLRDHUP) /// other end closed conn
                {
                printf("[%d]handle_http: other end hung up\n",me);
                break;
                }
            printf("[%d]handle_http: parse...\n",me);
            http.parse_request(*s, NULL);
            }
        printf("[%d]handle_http: close...\n",me);
        c->close(*s);
        }
    return;
    }



int main(int argc,char **argv)
    {
    struct ConfigFile::confval *cval;

    int shmid;
    key_t key;

    int s = 0;
    int getepg = 0;
    string adaptpath = "/dev/dvb/adapter";
    ConfigFile *conf;
    uint16_t device;


    key = 18081968;
    if ((shmid = shmget(key, sizeof(struct rbuf), IPC_CREAT  | 0666)) < 0)
        {
        perror("shmget main");
        printf("requested size %d\n",sizeof(struct rbuf));
        exit(1);
        }


    if ((rbufmain = (struct rbuf*)shmat(shmid, NULL, 0)) == (struct rbuf *) -1)
        {
        perror("shmat");
        exit(1);
        }
    bzero(rbufmain,sizeof(struct rbuf));

    if (!(conf = new ConfigFile((char *)"/usr/local/etc/yahdr.config")))
        {
        printf("Configfile not found !\n");
        exit(88);
        }


    signal(SIGTERM,&killhandler);
    signal(SIGINT,&killhandler);


    if (!(cval = conf->findkey((char *)"dvb-adapter",conf->first)))
        {
        printf("dvb-adapter # not in config !\n");
        exit(88);
        }
    adapter = device = atoi(cval->value);
    adaptpath += cval->value ;
    adaptpath += "/dvr";
#warning device # to be in config
    adaptpath += "0";
    if (!(cval = conf->findkey((char *)"record-dir",conf->first)))
        {
        printf("dvb-adapter # not in config !\n");
        exit(88);
        }
    recorddir = cval->value;

    if (!(cval = conf->findkey((char *)"html-template",conf->first)))
        {
        printf("html-template not in config !\n");
        exit(88);
        }

    htmltemplate = cval->value;


    if (!(cval = conf->findkey((char *)"db-name",conf->first)))
        {
        printf("db-name not in config !\n");
        exit(88);
        }

    dbname = cval->value;




/// prepare MySql conn

    driver = sql::mysql::get_mysql_driver_instance();
    con = driver->connect("tcp://127.0.0.1:3306", "fernseher", "glotze");
    stmt = con->createStatement();
    con->setSchema("epg");




/// DVB

    if (!(cval = conf->findkey((char *)"channel-select",conf->first)))
        {
        printf("channel-select not in config !\n");
        channelselect = "";
        }
    else
        {
        channelselect = cval->value;
        }

    if (!(cval = conf->findkey((char *)"demux-adapter",conf->first)))
        {
        printf("demux-adapter not in config using adapter #%d!\n",adapter);
        demux_adapter = adapter;
        }
    else
        {
        demux_adapter = atoi(cval->value);
        }
    if (!(cval = conf->findkey((char *)"adapter-type",conf->first)))
        {
        printf("adapter-type not in config !\n");
        exit(88);
        }
    if (!strcasecmp(cval->value,"C"))
        {
        dvbctrl = new DVBccontrol;
        }
    else
        {
        dvbctrl = new DVBtcontrol;
        }
    if (argc == 2)
        {
        if (!strcmp(argv[1],"scan"))
            {
            printf("Scanning for programs...\n");
            dvbctrl->scan();
            printf("Done scanning, exiting.\n");
            exit(0);
            }
        else if (!strcmp(argv[1],"getepg"))
            {
            printf("reading EPG, this may take a while....\n");
            getepg = 1;
            }
        else
            {
            printf("ignoring unknown option >%s<\n",argv[1]);
            printf("use %s <scan|getepg>, or no option\n",argv[0]);
            }
        }

    cout << "reading channels ..." ;
    fflush(stdout);
    basechan = readchans(&channelselect);
    cout << "done." << endl;
    if (getepg == 1)
        do_all_epg();
    setpids(basechan->cpids,rbufmain->cpids,&rbufmain->numpids);
    dvbctrl->tuneto(basechan->freq,basechan->bw,basechan->cpids,basechan->qam);

    //while(1);


    rbufmain->run_pid = run(adaptpath);


    if ((rbufmain->servvid = servvid()) == 0)
        {
        killhandler(15);
        exit(0);
        }

    start_timer();
/// start httpd
    if ( http.init() != EHTTP_ERR_OK )
        {
        printf("Can't initalize ehttpd\r\n");
        exit(1);
        }

    http.add_handler(NULL,handleDefault);
    Connection c(0);
    if ( c.init(8000) )
        exit(1);


    printf("Wait for request\r\n");
    while (s>-1)
        {
        printf("accept...\r\n");
        int s=c.accept();
        if ( s >-1 )
            {

            handle_http(&s,&c);
            }
        }

    // Close down our connection class
    c.terminate();




    }


/// calculate duration from next event - this one
/// (epg data sometimes sends 0 duration, or completelely wrong times)


int get_duration(int tsid,int service,time_t start)
    {
    sql::ResultSet  *dres;
    static sql::Statement *dstmt;

    char buffer[256];
    int duration;

    stmt  = check_sql(driver,con,stmt);
    sprintf(buffer,"select * from epgsev where tsid=%d and service_id=%d and start>%d order by start limit 1;",
            tsid,service,(int)start);
    dres = stmt->executeQuery(buffer);

    if (dres)
        {
        if (dres->next())
            {
            duration = dres->getInt(4);
            duration -= start;
            return duration;
            }
        }

    return -1;
    }



string *getepgdat(string *showepg, string *reread)
    {
    int cnum;
    string *retstr;
    char buffer[256];
    time_t start;
    int dur;
    time_t near;
    sql::ResultSet  *res;
    CookEpg *cepg;
    cepg = new CookEpg;

    CHANNEL *tp;

    retstr = new string;

    cnum = atoi(showepg->data());

    tp = basechan;




    do
        {
        if (tp->channum == cnum)
            break;
        }
    while ((tp = tp->next));


    if (!reread->empty())
        {
        if (tp != chanp && rbufmain->recording == 1)
            {
            retstr->append("<h2>Will not change channel while recording....</h2>");
            delete cepg;
            return retstr;
            }
        else
            {
            if (tp != chanp)
                {
                setpids(tp->cpids,rbufmain->cpids,&rbufmain->numpids);
                dvbctrl->tuneto(tp->freq,tp->bw,tp->cpids,tp->qam);
                }
            cepg->do_all();

            }
        }





    stmt  = check_sql(driver,con,stmt);

    sprintf(buffer,"select * from epgsev where tsid=%d and service_id=%d and start>%d order by start limit 50;",
            tp->tsid,tp->pnum,(int)time(0));
    printf("SQL=%s=\n",buffer);
    try
        {
        res = stmt->executeQuery(buffer);
        }
    catch (sql::SQLException &e)
        {
        cout << __FUNCTION__ ;
        cout << "########## ERR: " << e.what();
        cout << " (MySQL error code: " << e.getErrorCode();
        cout << ", SQLState: " << e.getSQLState() << " )" << endl;
        cout << "not ok 1" << endl;
        }

    retstr->assign("<a href=\"?page=channels&epg=");
    sprintf(buffer,"%d",cnum);
    retstr->append(buffer);
    retstr->append("&reread=1\">Re-Read EPG</a>");
    retstr->append("&nbsp;&nbsp;<a href=\"?page=channels\">Return to channellist</a><br>");
    retstr->append("<table>");


    if (res)
        {
        if (res->next())
            {
            do
                {

                start = res->getInt(4);
                ctime_r(&start,(char *)&buffer);
                //retstr->append("<table width=\"100%\">");
                retstr->append("<tr><td width=\"50%\">");
                retstr->append(buffer);
                retstr->append("</td><td>");
                dur = get_duration(res->getInt(1),res->getInt(2),res->getInt(4));
                dur = dur /60;
                sprintf(buffer,"%d min. id=%d",dur,res->getInt(3));

                retstr->append(buffer);
                retstr->append("</td><td width=\"20%\">");

                sprintf(buffer,"<a href=\"?page=channels&record=1&event_id=%d&pnum=%d\">Record</a></td><td>",
                        res->getInt(3),cnum);
                retstr->append(buffer);
                sprintf(buffer,"<a href=\"?page=channels&fview=1&event_id=%d&pnum=%d\">Watch</a></td></tr><tr><td><strong>",
                        res->getInt(3),cnum);
                retstr->append(buffer);

                retstr->append(res->getString(6));
                retstr->append("</strong></td><td colspan=\"3\">");
                //printf("%s\n",stmt->ValueString(6).data());

                retstr->append(res->getString(7));
                retstr->append("&nbsp;");
                retstr->append("</td></tr><tr><td colspan=\"4\" width=\"400\">");

                retstr->append(res->getString(8));
                retstr->append("&nbsp;");
                retstr->append("</td></tr>");
                //retstr->append("</table");
                }
            while (res->next());

            }
        else
            retstr->append("<h2>No EPG DATA !</h2>"); /// nothing in db -> read it



        }

    retstr->append("</table>");





    delete cepg;

    return retstr;
    }



string *findepg(char *what)
    {
    char buffer[1024];
    string *retstr;
    time_t now,start,dur;
    CHANNEL *tp;
    now = time(0);
    retstr = new string;
    sql::ResultSet  *res;
    int count;
    int tpnum;
    count = 0;

    stmt  = check_sql(driver,con,stmt);

    sprintf(buffer,"select * from epgsev where title like '%%%s%%' and start > '%d' order by start limit 20;",
            what,(int)now);
    try
        {
        res = stmt->executeQuery(buffer);
        }
    catch (sql::SQLException &e)
        {
        cout << __FUNCTION__ ;
        cout << "########## ERR: " << e.what();
        cout << " (MySQL error code: " << e.getErrorCode();
        cout << ", SQLState: " << e.getSQLState() << " )" << endl;
        cout << "not ok 1" << endl;
        }

    retstr->assign("<table><tr><td>");

    if (res)
        {
        printf("result\n");
        if (res->next())
            {
            printf("next\n");
            do
                {
                tp = basechan;
                tpnum = res->getInt(2);
                do
                    {
                    if (tp->pnum == tpnum)
                        break;
                    }
                while ((tp = tp->next));
                if (tp == NULL)
                    tp = basechan;
                if (tp != NULL)
                    {

                    start = res->getInt(4);
                    ctime_r(&start,(char *)&buffer);
                    retstr->append("<table width=\"100%\">");
                    retstr->append("<tr><td width=\"30%\">");
                    retstr->append(buffer);
                    retstr->append("</td><td> ");
                    dur = get_duration(res->getInt(1),res->getInt(2),res->getInt(4));
                    dur = dur /60;
                    sprintf(buffer,"%d min. id=%d",(int)dur,res->getInt(3));

                    retstr->append(buffer);
                    retstr->append("</td><td>");

                    retstr->append((char *) tp->provider);
                    retstr->append(" - ");
                    retstr->append((char *)tp->name);
                    retstr->append("</td><td width=\"10%\">");
                    sprintf(buffer,"<a href=\"?page=channels&record=1&event_id=%d&pnum=%d\">Record</a></td>",res->getInt(3),tp->channum);
                    retstr->append(buffer);
                    sprintf(buffer,"<td width=\"10%%\"><a href=\"?page=channels&fview=1&event_id=%d&pnum=%d\">Watch</a></td>",res->getInt(3),tp->channum);
                    retstr->append(buffer);
                    retstr->append("</tr><tr><td colspan=\"2\"><strong>"),
                    retstr->append(res->getString(6));
                    retstr->append("</strong></td><td colspan=\"3\">");
                    retstr->append(res->getString(7));
                    retstr->append("</td><td></tr><tr><td colspan=\"5\" width=\"400\">");
                    retstr->append(res->getString(8));
                    retstr->append("</td></tr>");
                    retstr->append("</table");
                    }
                else
                    printf("transpomder %d not found ?!\n",tpnum);
                }
            while (res->next());

            }
        else
            {
            retstr->append("<h2>Nothing found matching ->");
            retstr->append(what);
            retstr->append("<- !</h2>");
            }
        }

    retstr->append("</td></tr></table>");
    return retstr;

    }



string *getnexts(int start_time)
    {
    time_t now,start;
    CHANNEL *cp;
    string *ret;
    sql::ResultSet  *res;
    char buffer[256],where[256];
    int tsid,service_id,intchan;

    now = time(0);
    cp = basechan,
         ret = new string;


    ret->assign("<a href=\"?page=channels\">Back to channellist</a><br><table>");

    stmt  = check_sql(driver,con,stmt);

    if(start_time == 0)
        {
        sprintf(buffer,"select intchan,start,title,tsid,service_id,event_id  from epgsev where start > '%d' and start < %d order by start,intchan;",
                (int)now,(int)(now + (60*60*5)));
        printf("SQL: %s\n",buffer);

        res = stmt->executeQuery(buffer);
        }
    else
        {
        sprintf(buffer,"select intchan,start,title,tsid,service_id,event_id  from epgsev where start >= '%d' and start < '%d' order by start,intchan;",
                start_time,(start_time + (60*60*5)));
        printf("SQL: %s\n",buffer);

        res = stmt->executeQuery(buffer);

        }
    intchan = 0;

    if (res)
        {
        if (res->next())
            {

            do
                {
                tsid = res->getInt("tsid");
                service_id = res->getInt("service_id");
                cp = basechan;
                while (cp)
                    {
                    if ((service_id == cp->pnum) && (tsid == cp->tsid))
                        {
                        //           printf("name %s\n",cp->name);
                        break;
                        }

                    cp = cp->next;
                    }
                if (cp == NULL)
                    {
                    continue;
                    }
                if (!strcmp((char *)cp->stype,"RADIO"))
                    continue;

                ret->append("<tr><td width=\"25%\">");
                start = res->getInt("start");
                ctime_r(&start,buffer);

                ret->append(buffer);
                ret->append("</td><td>");
                ret->append(res->getString("title").data());
                ret->append("</td><td>");
                ret->append((char *)cp->provider);
                ret->append("&nbsp;-&nbsp;");
                ret->append((char *)cp->name);
                ret->append("</td><td>");
                sprintf(buffer,"<a href=\"?page=channels&fview=1&event_id=%d&pnum=%d\">Watch</a></td></tr>",
                        res->getInt("event_id"),res->getInt("intchan"));
                ret->append(buffer);
                intchan = res->getInt("intchan");
                }
            while (res->next());
            }
        }
    return ret;


    }

void do_all_epg()
    {

    char sql[256];
    char msg[256];
    string content;
    sql::ResultSet  *res;
    CookEpg *cepg;
    cepg = new CookEpg;

    stmt  = check_sql(driver,con,stmt);

    sprintf(sql,"delete from epgsev;"); /// get the hammer
    stmt->execute(sql);
    sprintf(sql,"select distinct(freq),bw,qam from channels;");
    res = stmt->executeQuery(sql);
    if (res)
        {
        while (res->next())
            {
            sprintf(msg,"Reading epg for transponder: %d\n",res->getInt("freq"));
            printf("%s",msg);
            dvbctrl->tuneto(res->getInt("freq"),res->getInt("bw"),NULL,(fe_modulation_t)res->getInt("qam"));
            printf("epg returns %s\n",cepg->do_all() == true ? "true" : "false");
            }
        }
    /*#warning weitermachen

        printf("indexing shows\n");

        sprintf(sql,"select distinct intchan from epgsev order by intchan");
        res = stmt->executeQuery(sql);
        if (res)
          {
            sprintf(sql,"select * from epgsev where intchan='%d' order by start", res->getInt("intchan"));

          }
    */

    }

void schedule_rec(string *prog,string *event_id)
    {


    int chann,event;
    char buffer[1024];
    char tbuf[256];
    int start;
    CHANNEL *ct;
    sql::ResultSet  *res;
    ct = basechan;
    chann = atoi(prog->data());
    event = atoi(event_id->data());


    do
        {
        if (ct->channum == chann)
            break;
        }
    while ((ct = ct->next));

    stmt  = check_sql(driver,con,stmt);

    sprintf(buffer,"select * from epgsev where tsid=%d and service_id=%d and event_id=%d;",ct->tsid,ct->pnum,event);
    res = stmt->executeQuery(buffer);
    printf("SELECT: %s\n",buffer);
    if (res->next())
        {
        start = res->getInt(4);
        ctime_r((time_t *)&start,tbuf);
        tbuf[strlen(tbuf)-1] = '\0';
        sprintf(buffer,"insert into recordings values(%d,%d,%d,%d,'%s/%s-%s-%s.ts',1);",
                res->getInt("intchan"),res->getInt("event_id"),res->getInt("start"),
                get_duration(res->getInt("tsid"),res->getInt("service_id"),res->getInt("start")),
                recorddir.data(),ct->name,tbuf,(char *)res->getString("title").data(),ct->qam);

        printf("INSERT: %s\n",buffer);
        stmt->execute(buffer);
        }

    }

void schedule_view(string *prog,string *event_id)
    {


    int chann,event;
    char buffer[1024];
    char tbuf[256];
    int start;
    CHANNEL *ct;
    sql::ResultSet  *res;
    ct = basechan;
    chann = atoi(prog->data());
    event = atoi(event_id->data());


    do
        {
        if (ct->channum == chann)
            break;
        }
    while ((ct = ct->next));

    stmt  = check_sql(driver,con,stmt);

    sprintf(buffer,"select * from epgsev where tsid=%d and service_id=%d and event_id=%d;",ct->tsid,ct->pnum,event);
    res = stmt->executeQuery(buffer);
    printf("SELECT: %s\n",buffer);
    if (res->next())
        {
        start = res->getInt(4);
        ctime_r((time_t *)&start,tbuf);
        tbuf[strlen(tbuf)-1] = '\0';

        sprintf(buffer,"insert into recordings values(%d,%d,%d,%d,'%s/%s-%s-%s.ts',0);",
                res->getInt("intchan"),res->getInt("event_id"),res->getInt("start"),
                get_duration(res->getInt("tsid"),res->getInt("service_id"),res->getInt("start")),
                recorddir.data(),ct->name,tbuf,(char *)res->getString("title").data(),ct->qam);

        printf("INSERT: %s\n",buffer);
        stmt->execute(buffer);
        }

    }


void instant_record()
    {
    time_t now;


    now = time(0);
    strcpy(rbufmain->recfile,recorddir.data());
    strcat(rbufmain->recfile,"/instant_rec-");
    strcat(rbufmain->recfile,ctime(&now));
    rbufmain->recfile[strlen(rbufmain->recfile)-1] = '\0';
    strcat(rbufmain->recfile,".mpeg");
    rbufmain->recording = 1;
    rbufmain->instant = 1;
    return;
    }


string *do_recpage(string *event,string *start)
    {
    string *ret;

    char buffer[256];
    sql::ResultSet  *res;

    ret = new string;
    ret->assign("<h2>Scheduled recordings:</h2><br><table>");

    stmt  = check_sql(driver,con,stmt);


    if (!event->empty() && !start->empty())
        {
        sprintf(buffer,"delete from recordings where event_id=%s and start=%s;",event->data(),start->data());
        stmt->execute(buffer);
        }

    sprintf(buffer,"select * from recordings where recflag=1 order by start; ");
    res = stmt->executeQuery(buffer);

    if (res)
        {
        if (res->next())
            {
            do
                {
                ret->append("<tr><td>");
                /*              p = (char *)stmt->ValueString(7).data();
                              p = strrchr(p,'/');
                              p++;*/
                ret->append(res->getString("filename").data());
                ret->append("</td><td>");
                sprintf(buffer,"<a href=\"?page=recordings&event=%d&start=%d\">Delete</a></td></tr>",
                        res->getInt("event_id"),res->getInt("start"));
                ret->append(buffer);
                }
            while (res->next());
            }
        else
            ret->append("No recordings found !");
        }
    ret->append("</table>");
    ret->append("<a href=\"?page=channels\">Return to channellist</a>");
    return ret;
    }


string *do_viewpage(string *event,string *start)
    {
    string *ret;

    char buffer[256];
    sql::ResultSet  *res;


    ret = new string;
    ret->assign("<h2>Scheduled shows:</h2><br><table>");

    stmt  = check_sql(driver,con,stmt);


    if (!event->empty() && !start->empty())
        {
        sprintf(buffer,"delete from recordings where event_id=%s and start=%s;",event->data(),start->data());
        stmt->execute(buffer);
        }

    sprintf(buffer,"select * from recordings where recflag=0 order by start; ");
    res = stmt->executeQuery(buffer);

    if (res)
        {
        if (res->next())
            {
            do
                {
                ret->append("<tr><td>");
                ret->append(res->getString("filename").data());
                ret->append("</td><td>");
                sprintf(buffer,"<a href=\"?page=shows&event=%d&start=%d\">Delete</a></td></tr>",
                        res->getInt("event_id"),res->getInt("start"));
                ret->append(buffer);
                }
            while (res->next());
            }
        else
            ret->append("No shows found !");
        }
    ret->append("</table>");
    ret->append("<a href=\"?page=channels\">Return to channellist</a>");
    return ret;
    }



string *build_tform()
    {
    string *ret = new string;
    char buffer[512];

    ret->assign("\
<script language=\"javascript\">\
function getsecs()\
{\
var hours = document.getElementsByName(\"hour\")[0];\
var minutes = document.getElementsByName(\"minute\")[0];\
var epoch = document.getElementsByName(\"epoch\")[0];\
var tdate = new Date();\
\
tdate.setHours(hours.value);\
tdate.setMinutes(minutes.value);\
tdate.setSeconds('0');\
tdate.setMilliseconds('0');\
\
var secs = tdate.getTime();\
epoch.value = secs;\
}\
</script>\
\
<form method=\"get\">\
<table border=\"0\">\
<tr>\
<td>\
What's on at:\
<input type=\"hidden\" name=\"page\" value=\"onat\">\
<input type=\"hidden\" name=\"epoch\" value=\"0\">\
</td>\
<td>\
<select size=\"1\" name=\"hour\">");
    for(int i=0; i != 24; i++)
        {
        if(i == 20)
            ret->append("<option selected>20</option>");
        else
            {
            sprintf(buffer,"<option>%02d</option>",i);
            ret->append(buffer);
            }
        }
    ret->append("</select>\
</td>\
<td>\
<select size=\"1\" name=\"minute\">\
<option>00</option>\
<option>15</option>\
<option>30</option>\
<option>45</option>\
</td>\
<td>\
<input type=\"submit\" name=\"getat\" value=\"Go!\" onClick=\"getsecs()\";>\
</td>\
</tr>\
</table>\
</form>");

    return ret;
    }





int handleDefault( ehttp &obj, void *cookie )
    {
    CHANNEL *cp;
    APID *apidp;
    char apids[16],buffer[256];
    int ichan,iapid;
    string *sp;
    //---------------------------------------------------------------
    //      #1b
    //      Specify the name of the HTML template file to be used.
    //      The template file is just a HTML file, with ##TAGS## embedded
    //      and these tags get replace with something when out_replace
    //      is called
    //---------------------------------------------------------------
    obj.out_set_file((char *)htmltemplate.data());

    cp = basechan;


    string page = obj.getUrlParam((char *)"page");
    string content;
    cout << "param:" << page << endl;




    if (page == "whatnext")
        {
        string *page;

        page = getnexts(0);
        obj.out_replace_token("TITLE","Next up");
        obj.out_replace_token("HEADER","Next up:");
        content += page->data();
        obj.out_replace_token("CONTENT",content);
        obj.out_replace();
        string req = obj.getFilename();
        delete page;
        return obj.out_commit();
        }


    if (page == "onat")
        {
        string *page;
        long long  when;
        string epo = obj.getUrlParam((char *)"epoch");
        char *s;

        s = strdup(epo.data());
        sscanf(epo.data(), "%lld", &when);
        when /= 1000;
        //	printf("string %s int %lld\n",epo.data(),when);

        page = getnexts(when);
        obj.out_replace_token("TITLE","Shows");
        obj.out_replace_token("HEADER","Programs:");
        content += page->data();
        obj.out_replace_token("CONTENT",content);
        obj.out_replace();
        string req = obj.getFilename();
        delete page;
        return obj.out_commit();
        }




    if (page == "recordings")
        {
        string *page;
        string ev = obj.getUrlParam((char *)"event");
        string start = obj.getUrlParam((char *)"start");
        obj.out_replace_token("TITLE","Manage recordings");
        obj.out_replace_token("HEADER","Scheduled recordings:");

        page = do_recpage(&ev,&start);
        content = page->data();
        obj.out_replace_token("CONTENT",content);
        obj.out_replace();
        string req = obj.getFilename();
        delete page;
        return obj.out_commit();

        }


    if (page == "shows")
        {
        string *page;
        string ev = obj.getUrlParam((char *)"event");
        string start = obj.getUrlParam((char *)"start");
        obj.out_replace_token("TITLE","View shows");
        obj.out_replace_token("HEADER","Scheduled shows to view:");

        page = do_viewpage(&ev,&start);
        content = page->data();
        obj.out_replace_token("CONTENT",content);
        obj.out_replace();
        string req = obj.getFilename();
        delete page;
        return obj.out_commit();

        }



    if (page == "searchepg")
        {
        string term = obj.getUrlParam((char *)"term");
        string *res;
        char *sp,*dat;
        obj.out_replace_token("TITLE","Search EPG");
        obj.out_replace_token("HEADER","Find in EPG");

        if (term == "")
            {
            content += "<form method=\"get\" >";
            content += "Enter searchstring<br>";
            content += "<input type=\"text\" name=\"term\">";
            content += "<input type=\"hidden\" name=\"page\" value=\"searchepg\">";
            content += "<input type=\"submit\" name=\"Submit\" value=\"Submit\">";
            content += "</form><br>";
            printf("done\n");
            }
        else
            {
            dat = sp = (char *)term.data();
            while ((sp = strchr(sp,'+')))
                *sp = '%';
            res = findepg(dat);
            content += res->data();
            delete res;

            }
        content += "<a href=\"?page=channels\">Back to channellist</a>&nbsp;&nbsp;";
        content += "<a href=\"?page=searchepg\">Find again</a><br>";
        obj.out_replace_token("CONTENT",content);
        obj.out_replace();
        string req = obj.getFilename();
        printf("commit\n");
        return obj.out_commit();


        }



    if (page == "channels")
        {
        int cnum;

        cnum = 0;

        obj.out_replace_token("TITLE","Available Channels");
        obj.out_replace_token("HEADER","Available channels:");



        string stoprec = obj.getUrlParam((char *)"stoprec");
        string record = obj.getUrlParam((char *)"record");
        string fview  = obj.getUrlParam((char *)"fview");
        string instantrec = obj.getUrlParam((char *)"instantrec");

        if (record == "1")
            {
            string cnum = obj.getUrlParam((char*)"pnum");
            string event_id = obj.getUrlParam((char *)"event_id");

            schedule_rec(&cnum,&event_id);
            content += "Event: ";
            content += event_id;
            content += " scheduled for recording...<br>";
            }
        if (instantrec == "1")
            {
            instant_record();
            content += "recording started....<br>";
            }

        if (stoprec == "1")
            {
            rbufmain->recording = 0;
            rbufmain->instant = 0;
            content += "recording stopped (user request)....<br>";
            }

        if (fview == "1")
            {
            string cnum = obj.getUrlParam((char*)"pnum");
            string event_id = obj.getUrlParam((char *)"event_id");

            schedule_view(&cnum,&event_id);
            content += "Event: ";
            content += event_id;
            content += " scheduled for viewing...<br>";
            }




        string set = obj.getUrlParam((char *)"set");
        string sapid = obj.getUrlParam((char *)"apid");
        string showepg = obj.getUrlParam((char *)"epg");
        string reread = obj.getUrlParam((char *)"reread");
        string override = obj.getUrlParam((char *)"override");


        if (showepg != "")
            {
            string *epgdat;
            obj.out_replace_token("TITLE","EPG");
            obj.out_replace_token("HEADER","EPG:");

            epgdat = getepgdat(&showepg,&reread);
            content = epgdat->data();
            delete epgdat;
            }






        if (set != "")
            {

            if (rbufmain->recording == 1 && override != "1")
                {
                content = "<h2>Currently recording....(";
                content += rbufmain->recfile;
                content += ")</h2>";
                content += "<a href=\"?page=channels&override=1&set=";
                content += set.data();
                content += "\">Switch anyway</a> hit browser back otherwise....<br>";
                if (override != "1")
                    {
                    obj.out_replace_token("CONTENT",content);
                    obj.out_replace();
                    return obj.out_commit();
                    }
                }




            content += "Active channel: ";
            cp = basechan ;
            ichan = atoi((char *)set.data());
            iapid = atoi((char *)sapid.data());
            while (cp)
                {
                if (cp->channum == ichan)
                    break;
                cp = cp->next;
                }
            chanp = cp;
            sp = specialchars(cp->name);

            content += sp->data();
            delete sp;
            setpids(cp->cpids,rbufmain->cpids,&rbufmain->numpids);
            dvbctrl->tuneto(cp->freq,cp->bw,cp->cpids,cp->qam);

            content += "<br>";
            }
        content += "<table><tr>";
        content += "<td><a href=\"?page=recordings\">Manage recordings</a></td>";
        content += "<td><a href=\"?page=shows\">Manage shows</a></td>";
        content += "<td><a href=\"?page=searchepg\">Search EPG</a></td>";
        content += "<td><a href=\"?page=whatnext\">Next on</a></td>";


        if (rbufmain->recording == 0)
            {
            content += "<td><a href=\"?page=channels&instantrec=1\">Instant record</a></td>";
            }
        else
            {
            content += "<td><a href=\"?page=channels&stoprec=1\">Stop recording</a></td>";
            }
        content += "</tr>";
        content += "<tr><td colspan=\"5\"><center>";
        content += build_tform()->data();
        content += "</center></td></tr></table>";
        content += "<br><table>";
        cp = basechan;
        do
            {
            sprintf(buffer,"%d",cp->channum);

            content +="<tr><td>";
            content += "<a name=\"";
            content += buffer;
            content += "\"></a>";
            content += "<a href=\"";
            content += "index.html?page=channels&epg=";
            content += buffer;
            content += "\">EPG</a></td><td>";
            content += (char *)cp->provider;
            //sprintf(tpbuf,"&nbsp;TP:%d",cp->tpnum);
            //content += tpbuf;
            content += "</td><td>";
            content += (char *)cp->stype;
            content += "</td><td>";
            content += "<a name=\"";
            content += buffer;
            content += "\"></a>";
            content += "<a href=\"";
//          sprintf(tbuf,"%d.html#%s",time(0),buffer);
//          content += tbuf;
            content += "?page=channels&set=";
            content += buffer;
            content += "\">";  // a href
            content += (char *)cp->name;
            content += "</a></td>";

            content += "</tr>\n";

            }
        while ((cp = cp->next));
        content += "</table>";
        obj.out_replace_token("CONTENT",content);
        }



//---------------------------------------------------------------
//      #2b
//      This is where most of the work happens in the request
//      handler.
//
//      Create your dynamic content.  In this case, we simply replace
//      the ##MESSAGE## tag in the template file with the "Hello
//      World" string.
//
//      At this point, you might check for get or post requests
//      and     pass commands to your app via the cookie, or get content
//      (application status as one example) via the cookie.
//---------------------------------------------------------------
    string req = obj.getFilename();



//---------------------------------------------------------------
//      #3b
//      Replace all the tags in the template file with tokens
//---------------------------------------------------------------
    obj.out_replace();

//---------------------------------------------------------------
//      #4b
//      Write the content to the socket
//---------------------------------------------------------------
    return obj.out_commit();
    }