#include <stdlib.h>
#include <stdbool.h>
#include <err.h>
#include <stdio.h>
#include <getopt.h>

#include <event2/event.h>

#include "sock.h"
#include "line_proto.h"
#include "irc_line.h"

#define CONNECT_HOST "irc.fixme.fi"
#define CONNECT_SERV "6697"
#define LINE_LENGTH 512

static struct option options[] = {
    {"help",            0,  NULL,   'h' },
    {"hostname",        1,  NULL,   'H' },
    {"port",            1,  NULL,   'P' },
    {"ssl",             0,  NULL,   'S' },
    {0,                 0,  0,      0   },
};

void usage (const char *exe) 
{
    printf("Usage: %s [OPTIONS]\n", exe);
    printf("\n");
    printf(" --help / -h            display this message\n");
    printf(" --hostname / -H HOST   set hostname to connect to\n");
    printf(" --port / -P PORT       set service port to connect to\n");
    printf(" --ssl / -S             use SSL\n");
}

void on_line (char *line_buf, void *arg) 
{
    struct irc_line line;
    int err;

    // parse
    if ((err = irc_line_parse(&line, line_buf)))
        printf("!!! Invalid line: %s: %s\n", line_buf, error_name(err));

    else
        printf("<<< prefix=%s, command=%s, args={%s, %s, %s, ...}\n",
                line.prefix, line.command, line.args[0], line.args[1], line.args[2]
        );
}

int main (int argc, char **argv) 
{
    int opt, option_index;
    struct event_base *ev_base;
    struct sock_stream *sock;
    struct line_proto *lp;
    struct error_info _err;

    const char *hostname = CONNECT_HOST, *portname = CONNECT_SERV;
    bool ssl = 0;
    
    // parse options
    while ((opt = getopt_long(argc, argv, "hH:P:S", options, &option_index)) != -1) {
        switch (opt) {
            case 'h':
                usage(argv[0]);
                return EXIT_SUCCESS;

            case 'H':
                hostname = optarg;
                break;
            
            case 'P':
                portname = optarg;
                break;

            case 'S':
                ssl = true;
                break;

            case '?':
                usage(argv[0]);
                return EXIT_FAILURE;
        }
    }

    // initialize libevent
    if ((ev_base = event_base_new()) == NULL)
        err(1, "event_base_new");

    // initialize sock module
    if (sock_init(ev_base, &_err))
        errx(1, "sock_init: %s", error_msg(&_err));

    // over-simplified connect
    if (ssl) {
        if (sock_ssl_connect(&sock, hostname, portname, &_err))
            errx(1, "sock_ssl_connect: %s", error_msg(&_err));

    } else {
        if (sock_tcp_connect(&sock, hostname, portname, &_err))
            errx(1, "sock_tcp_connect: %s", error_msg(&_err));

    }

    // line protocol, with safety margin for buffer
    if (line_proto_create(&lp, sock, LINE_LENGTH * 2, on_line, NULL, &_err))
        errx(1, "line_proto_create: %s", error_msg(&_err));

    // run event loop
    if (event_base_dispatch(ev_base))
        errx(1, "event_base_dispatch");
    
    // ok, no cleanup
    return 0;
}