application/adapter/http/update.c

Go to the documentation of this file.

/**
 * \file
 *
 * \author  Georg Hopp
 *
 * \copyright
 * Copyright © 2013  Georg Hopp
 *
 * This program 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.
 *
 * This program 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 this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#define _GNU_SOURCE

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

#include "application/application.h"
#include "application/adapter/http.h"
#include "hash.h"
#include "http/worker.h"
#include "http/header.h"
#include "http/message.h"
#include "router.h"

#define NO_SESSION_SID      NULL

static
inline
char *
getSessionId(Hash cookies)
{
    HashValue sidstr = hashGet(cookies, CSTRA("sid"));

    if (NULL != sidstr) {
        return (char*)sidstr->value;
    }

    return NO_SESSION_SID;
}

void
applicationAdapterHttpUpdate(void * _this, void * subject)
{
    ApplicationAdapterHttp this    = _this;
    HttpWorker             worker  = (HttpWorker)subject;
    Session                session = NULL;
    time_t                 now     = time(NULL);

    char   * sid;
    char     buf[1000];
    size_t   nbuf;

    applicationSessionCleanup(this->application, now);

    sid = getSessionId(worker->current_request->cookies);
    session = applicationSessionGet(this->application, sid);

    if (NULL == session) {
        session = applicationSessionStart(this->application);
    }

    // send session cookie
    nbuf = sprintf(buf, "sid=%s;Path=/", session->id);
    queuePut(
            worker->additional_headers, 
            new(HttpHeader, CSTRA("Set-Cookie"), buf, nbuf));

    worker->current_response = (HttpMessage)routerRoute(
            this->router,
            worker->current_request,
            session);
}

// vim: set ts=4 sw=4: