acooks/jittertrap

#include <stdio.h>
#include <stdlib.h>
#include <getopt.h>
#include <string.h>
#include <signal.h>
#include <unistd.h>

#include <libwebsockets.h>
#include <jansson.h>

#include "proto.h"
#include "jt_messages.h"
#include "jt_client_msg_handler.h"

struct lws_protocols protocols[] = {
        [PROTOCOL_JITTERTRAP] =
            {
                .name = "jittertrap",
                .callback = callback_jittertrap,
                .per_session_data_size = 0,
                .rx_buffer_size = 4096,
            },
        {.name = NULL,
         .callback = NULL,
         .per_session_data_size = 0,
         .rx_buffer_size = 0 } /* end */
};

/* jittertrap protocol */
int callback_jittertrap(struct lws *wsi, enum lws_callback_reasons reason,
                        void *user __attribute__((unused)), void *in,
                        size_t len __attribute__((unused)))
{
    switch (reason) {

    case LWS_CALLBACK_CLIENT_ESTABLISHED:
        fprintf(stderr, "callback_jittertrap:"
                        " LWS_CALLBACK_CLIENT_ESTABLISHED\n");

        /*
         * start the ball rolling,
         * LWS_CALLBACK_CLIENT_WRITEABLE will come next service
         */

        lws_callback_on_writable(wsi);
        break;

    case LWS_CALLBACK_CLIENT_CONNECTION_ERROR:
        fprintf(stderr, "LWS_CALLBACK_CLIENT_CONNECTION_ERROR\n");
        // was_closed = 1;
        return -1;
        break;

    case LWS_CALLBACK_CLOSED:
        fprintf(stderr, "LWS_CALLBACK_CLOSED\n");
        // was_closed = 1;
        return -1;
        break;

    case LWS_CALLBACK_CLIENT_RECEIVE:
        // fprintf(stderr, "\rrx %d '%s'", (int)len, (char *)in);
        jt_client_msg_handler(in);
        break;

    case LWS_CALLBACK_CLIENT_WRITEABLE:
        lws_callback_on_writable(wsi);
        break;

    default:
        /* fprintf(stderr, "callback reason: %d\n", reason); */
        break;
    }

    return 0;
}