#include <stdio.h>
#include <sys/types.h>
#include <sys/file.h>
#include <unistd.h>

#include "al.h"
#include "sio.h"

extern sio_module_t sio_module_fd;
extern sio_module_t sio_module_zlib;
extern sio_module_t sio_module_buffer;
extern sio_module_t sio_module_sio;

#define e(f) rc = f; printf("%s = %s\n",#f, sio_error(rc)); fflush(stdout);
#define s(f) src = f; printf("%s = %s\n",#f, sa_error(src)); fflush(stdout);

int main(int argc, char *argv[])
{
    int fd;
    sio_rc_t rc;

    sio_t *sio;
    sio_stage_t *sios_fd, *sios_buffer, *sios_zlib;

    sio_t *sio2;
    sio_stage_t *sios2_sio;
    al_label_t data_label, error_label, eof_label;

    char buf[513];
    size_t buflen;
    int level;
    size_t actual;

#ifdef WRITE
    fd = open("output", O_WRONLY|O_TRUNC|O_CREAT, 0666);

    {
        int i;
        for (i=0; i<sizeof(buf)-16; i += 16)
            sprintf(buf+i,"Hello world %03.3d\n",i);
        buf[i] = '\0';
    }

#else
    fd = open("output", O_RDONLY);
#endif

    e(sio_create(&sio));
    e(sio_create_stage(sio, &sio_module_fd, &sios_fd));
    e(sio_create_stage(sio, &sio_module_zlib, &sios_zlib));
    e(sio_create_stage(sio, &sio_module_buffer, &sios_buffer));

    e(sio_configure_stage(sio, sios_fd, "fd", &fd));
    buflen = 512;
    e(sio_configure_stage(sio, sios_fd, "buflen", &buflen));

    buflen = 200;
    e(sio_configure_stage(sio, sios_buffer, "outputsize", &buflen));
    e(sio_configure_stage(sio, sios_buffer, "inputsize", &buflen));

    buflen = 200;
    e(sio_configure_stage(sio, sios_zlib, "outputsize", &buflen));
    e(sio_configure_stage(sio, sios_zlib, "inputsize", &buflen));
    level = 0;
    e(sio_configure_stage(sio, sios_zlib, "outputlevel", &level));
    level = -1;
    e(sio_configure_stage(sio, sios_zlib, "inputlevel", &level));

    e(sio_create(&sio2));
    e(sio_create_stage(sio2, &sio_module_sio, &sios2_sio));

    e(sio_label(sio, SIO_LN_DATA, &data_label));
    e(sio_label(sio, SIO_LN_ERROR, &error_label));
    e(sio_label(sio, SIO_LN_EOF, &eof_label));
    e(sio_configure_stage(sio2, sios2_sio, "upstream", sio));
    e(sio_configure_stage(sio2, sios2_sio, "mydatalabel", data_label));
    e(sio_configure_stage(sio2, sios2_sio, "myerrorlabel", error_label));
    e(sio_configure_stage(sio2, sios2_sio, "myeoflabel", eof_label));

    e(sio_attach(sio2, sios2_sio, SIO_MODE_READWRITE));

    {
        e(sio_attach(sio, sios_fd, SIO_MODE_READWRITE));
        e(sio_attach(sio, sios_zlib, SIO_MODE_READWRITE));
        e(sio_attach(sio, sios_buffer, SIO_MODE_READWRITE));

#ifdef WRITE
        e(sio_write(sio2, buf, strlen(buf), &actual));
        e(sio_push(sio2));
#else
        do {
            actual = 0;
            e(sio_read(sio2, buf, sizeof(buf), &actual));
            printf("actual = %d\n",actual);
            fwrite(buf, actual, 1, stdout);
            printf("\n");
        } while (sio_flag(sio2, SIO_FLAG_EOF) == SIO_FALSE);
#endif

        e(sio_detach(sio, sios_buffer));
        e(sio_detach(sio, sios_zlib));
        e(sio_detach(sio, sios_fd));
    }

    e(sio_detach(sio2, sios2_sio));

    e(sio_destroy_stage(sio2, sios2_sio));
    e(sio_destroy(sio2));

    e(sio_destroy_stage(sio, sios_buffer));
    e(sio_destroy_stage(sio, sios_zlib));
    e(sio_destroy_stage(sio, sios_fd));
    e(sio_destroy(sio));

    close(fd);

    return 0;
}