/**
 *  $Id: main.c 53 2008-01-10 00:19:41Z mbroeker $
 * $URL: http://localhost/svn/c/VirtualReader/trunk/src/main.c $
 */

#include <sentence.h>
#include <keyboard.h>
#include <thread.h>
#include <audioplayer.h>
#include <interface.h>

#define STARTWRITER   0
#define      WRITER   1
#define      READER   2

#define        STEP   2         // jump back n-steps

void find_next (ThreadData * data)
{
    long tm = (long)audioplayer_gettime ();
    long position;
    int i, max;

    max = words (data->sentences[data->satz]);

    for (i = 0; i < max; i++) {
        if (data->timings[data->satz][i] > tm)
            break;
    }

    position = data->timings[data->satz][i];
    audioplayer_settime (position);
}

void find_prev (ThreadData * data)
{
    long tm = (long)audioplayer_gettime ();
    long position;
    int i, max;

    max = words (data->sentences[data->satz]);

    for (i = STEP; i < max; i++) {
        if (data->timings[data->satz][i] > tm)
            break;
    }

    position = data->timings[data->satz][i - STEP];
    audioplayer_settime (position);
}

int main (int argc, char **argv)
{
    char **sentences = NULL;    // to store an array of strings
    char *Text = NULL;          // to store the content of a textfile
    long **timings = NULL;      // to store the timings
    int i, count;               // sentence counter
    int verbose = 0;

    pthread_t p_thread, w_thread;

    ThreadData *data[3];        // independent thread data

    tts_options ttsopt = interface_get_cl_opts (argc, argv);
    ttshandles ttsh = interface_init (ttsopt);

    if ((Text = readbuffer (ttsopt.TextFile)) != NULL) {
        sentences = getstrings (Text, &count);
        free (Text);
    } else {
        printf ("ERROR: Textfile %s is corrupt.\n", ttsopt.TextFile);
        free (ttsopt.TextFile);
        free (ttsopt.AudioFile);
        free (ttsopt.Voice);
        free (ttsopt.Path);

        return EXIT_SUCCESS;
    }

    // Timinganalyse des Textes
    if ((timings = calloc ((size_t) count, sizeof (long *) + 1)) == NULL) {
        free (ttsopt.TextFile);
        free (ttsopt.AudioFile);
        free (ttsopt.Voice);
        free (ttsopt.Path);

        return EXIT_SUCCESS;
    }

    for (i = 0; i < count; i++) {
        timings[i] = interface_get_timing (ttsh, sentences[i]);
    }

    /*
     * Initialize Sound
     */
    if (audio_init ())
        fprintf (stderr, "AUDIO ERROR\n");

    for (i = 0; i < 3; i++) {
        data[i] = malloc (sizeof (ThreadData) + 1);
        if (data[i] == NULL)
            exit (0);
        data[i]->ttsopt = ttsopt;
        data[i]->ttsh = ttsh;
        data[i]->fname = ttsopt.TextFile;
        data[i]->sentences = sentences;
        data[i]->timings = timings;
    }

    /*
     * write sentences from 0-1 :)
     */
    data[STARTWRITER]->satz = 0;
    data[STARTWRITER]->items = 1;

    pthread_create (&w_thread, NULL, (void *)writewav, data[STARTWRITER]);
    pthread_join (w_thread, NULL);

    /*
     * write sentences from 1-count :)
     */
    data[WRITER]->satz = 1;
    data[WRITER]->items = count;
    pthread_create (&w_thread, NULL, (void *)writewav, data[WRITER]);

    data[READER]->satz = 0;
    data[READER]->items = count;
    pthread_create (&p_thread, NULL, (void *)readtext, data[READER]);

    while (data[READER]->satz < data[READER]->items) {
        switch (getSingleKey ()) {
        case 'i':
            // next word
            if (data[READER]->satz < data[READER]->items)
                find_next (data[READER]);
            else
                printf ("ERROR: Cannot seek anymore\n");
            break;

        case 'j':
            // previous sentence
            if (data[READER]->satz > 0) {
                data[READER]->satz--;
                p_thread_restart (p_thread, readtext, data[READER]);
            }
            break;

        case 'k':
            // previous word
            find_prev (data[READER]);
            break;

        case 'l':
            // next sentence
            if (data[READER]->satz < data[READER]->items) {
                data[READER]->satz++;
                p_thread_restart (p_thread, readtext, data[READER]);
            }
            break;

        case 'p':
            // print useful informations
            printf ("Current Position:  [%5d/%5d]ms = #%d\n",
                    audioplayer_gettime (), audioplayer_getwavelength (NULL), audioplayer_getposition ());
            break;

        case 'q':
            // quit
            pthread_cancel (w_thread);
            pthread_cancel (p_thread);
            data[READER]->satz = data[READER]->items;
            break;

        case 'r':
            // reset player
            pthread_cancel (p_thread);
            if (!pthread_join (p_thread, NULL))
                printf ("RESET\n");
            break;
        case 's':
            printf ("S[%d]: %s\n", data[READER]->satz, sentences[data[READER]->satz]);
            break;
        case 'v':
            verbose ^= 1;
            audioplayer_setverbose (verbose);
            break;

        default:
            /*
             * unknown command
             */
            break;
        }
    }

    if (!pthread_join (p_thread, NULL))
        printf ("The last thread exited\n");

    // cleanup memory
    for (i = 0; i < count; i++) {
        if (sentences[i] != NULL)
            free (sentences[i]);
        if (timings[i] != NULL)
            free (timings[i]);
    }

    if (sentences != NULL)
        free (sentences);

    if (timings != NULL)
        free (timings);

    for (i = 0; i < 3; i++)
        if (data[i] != NULL)
            free (data[i]);

    /*
     * Cleanup sound
     */
    audio_shutdown ();
    pthread_exit (NULL);
}