/*
**  L2 - OSSP Logging Library
**  Copyright (c) 2001 The OSSP Project (http://www.ossp.org/)
**  Copyright (c) 2001 Cable & Wireless Deutschland (http://www.cw.com/de/)
**
**  This file is part of OSSP L2, a flexible logging library which
**  can be found at http://www.ossp.org/pkg/l2/.
**
**  Permission to use, copy, modify, and distribute this software for
**  any purpose with or without fee is hereby granted, provided that
**  the above copyright notice and this permission notice appear in all
**  copies.
**
**  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
**  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
**  MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
**  IN NO EVENT SHALL THE AUTHORS AND COPYRIGHT HOLDERS AND THEIR
**  CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
**  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
**  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
**  USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
**  ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
**  OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
**  OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
**  SUCH DAMAGE.
**
**  l2.c: internal C implementation
**
*/

#include "l2.h"
#include "l2_p.h"

l2_stream_t *l2_stream_create(void)
{
    l2_stream_t *st;
    int i;
    
    if ((st = (l2_stream_t *)malloc(sizeof(l2_stream_t))) == NULL)
        return NULL;
    st->levelmask = 0;
    for (i = 0; i < L2_MAX_CHANNELS; i++)
        st->channels[i].ch = NULL;
    for (i = 0; i < L2_MAX_FORMATTERS; i++)
        st->formatters[i].cb = NULL;
    return st;
}

l2_result_t l2_stream_channel(l2_stream_t *st, l2_channel_t *ch, unsigned int levelmask)
{
    int i;

    if (st == NULL || ch == NULL || levelmask == 0)
        return L2_ERROR;
    for (i = 0; i < L2_MAX_CHANNELS && st->channels[i].ch != NULL; i++)
        ;
    if (i == L2_MAX_CHANNELS)
        return L2_ERROR;
    st->channels[i].ch = ch;
    st->channels[i].levelmask = levelmask;
    return L2_OK;
}

l2_result_t l2_stream_formatter(l2_stream_t *st, char id, l2_formatter_t cb, l2_context_t *ctx)
{
    int i;

    if (st == NULL || id == '\0' || cb != NULL)
        return L2_ERROR;
    for (i = 0; i < L2_MAX_FORMATTERS && st->formatters[i].cb != NULL; i++)
        ;
    if (i == L2_MAX_FORMATTERS)
        return L2_ERROR;
    st->formatters[i].id   = id;
    st->formatters[i].ctx  = ctx;
    st->formatters[i].cb   = cb;
    return L2_OK;
}

l2_result_t l2_stream_levels(l2_stream_t *st, unsigned int levelmask, unsigned int *levelmaskold)
{
    if (st == NULL)
        return L2_ERROR;
    if (levelmaskold != NULL)
        *levelmaskold = st->levelmask;
    st->levelmask = levelmask;
    return L2_OK;
}

l2_result_t l2_stream_log(l2_stream_t *st, unsigned int level, const char *fmt, ...)
{
    va_list ap;
    l2_result_t rv;

    if (st == NULL || level == 0 || fmt == NULL)
        return L2_ERROR;
    va_start(ap, fmt);
    rv = l2_stream_vlog(st, level, fmt, ap);
    va_end(ap);
    return rv;
}

static int l2_stream_vlog_flush(l2_util_format_t *vfmt)
{
    return -1;
}

static void l2_stream_vlog_format(
    l2_util_format_t *vfmt,
    char *cPrefix, char *cPad, char **cppOut, size_t *npOutLen,
    char *cpBuf, int nBufLenMax, char *cpParam, char cId, va_list *apArgs)
{
    l2_stream_t *st = (l2_stream_t *)(vfmt->data[0].vp);
    int i;

    /* init result */
    *cPrefix = '\0';
    *cPad = ' ';
    *cppOut = NULL;
    *npOutLen = 0;

    /* iterate over all configured formatters */
    for (i = 0; i < L2_MAX_FORMATTERS && st->formatters[i].cb != NULL; i++) {
        if (st->formatters[i].id == cId) {
            if (st->formatters[i].cb(st->formatters[i].ctx, cId, cpParam, 
                                     cpBuf, nBufLenMax, npOutLen, apArgs) == L2_OK) {
                *cppOut = cpBuf;
                break;
            }
        }
    }
    return;
}

l2_result_t l2_stream_vlog(l2_stream_t *st, unsigned int level, const char *fmt, va_list ap)
{
    int i;
    int l, j;
    size_t len;
    l2_result_t rv;
    l2_util_format_t vfmt;

    if (st == NULL || fmt == NULL || ap == NULL)
        return L2_ERROR;

    /* make sure only a single level is specified */
    for (l = level, j = 0; l != 0; l = (l >> 1))
        j++;
    if (j != 1)
        return L2_ERROR;

    /* check whether level is globally enabled */
    if (!(st->levelmask & level))
        return L2_OK;
    
    /* format message */
    vfmt.curpos = st->message;
    vfmt.endpos = st->message+ L2_MAX_MSGSIZE;
    vfmt.data[0].vp = st;
    vfmt.flush  = l2_stream_vlog_flush;
    vfmt.format = l2_stream_vlog_format;
    if ((len = l2_util_format(&vfmt, fmt, ap)) == -1)
        return L2_ERROR;

    rv = L2_OK;
    for (i = 0; i < L2_MAX_CHANNELS && st->channels[i].ch != NULL; i++) {
        if (st->channels[i].levelmask & level) {
            if ((rv = l2_channel_write(st->channels[i].ch, st->message, len)) != L2_OK)
                break;
        }
    }
    return rv;
}

l2_result_t l2_stream_destroy(l2_stream_t *st)
{
    int i;

    if (st == NULL)
        return L2_ERROR;
    for (i = 0; i < L2_MAX_CHANNELS && st->channels[i].ch != NULL; i++)
        l2_channel_destroy(st->channels[i].ch);
    free(st);
    return L2_OK;
}