/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 *                                                                         *
 *  Copyright (C) 2015 Simon Stuerz <simon.stuerz@guh.guru>                *
 *                                                                         *
 *  This file is part of guh.                                              *
 *                                                                         *
 *  Guh 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, version 2 of the License.                *
 *                                                                         *
 *  Guh 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 guh. If not, see <http://www.gnu.org/licenses/>.            *
 *                                                                         *
 * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */

#include "logsresource.h"
#include "httprequest.h"
#include "loggingcategories.h"
#include "guhcore.h"
#include "logging/logengine.h"

#include <QJsonDocument>

namespace guhserver {

LogsResource::LogsResource(QObject *parent) :
    RestResource(parent)
{
}

QString LogsResource::name() const
{
    return "logs";
}

HttpReply *LogsResource::proccessRequest(const HttpRequest &request, const QStringList &urlTokens)
{
    // check method
    HttpReply *reply;
    switch (request.method()) {
    case HttpRequest::Get:
        reply = proccessGetRequest(request, urlTokens);
        break;
    default:
        reply = createErrorReply(HttpReply::BadRequest);
        break;
    }
    return reply;
}

HttpReply *LogsResource::proccessGetRequest(const HttpRequest &request, const QStringList &urlTokens)
{
    // GET /api/v1/logs?filter={ogFilter}
    if (urlTokens.count() == 3) {
        // check filter
        QString filterString;
        if (request.url().hasQuery()) {
            if (request.urlQuery().hasQueryItem("filter")) {
                filterString = request.urlQuery().queryItemValue("filter");
            }
        }
        return getLogEntries(filterString);
    }
    return createErrorReply(HttpReply::NotImplemented);}

HttpReply *LogsResource::getLogEntries(const QString &filterString)
{
    qCDebug(dcRest) << "Get log entries";

    QPair<bool, QVariant> verification = RestResource::verifyPayload(filterString.toUtf8());
    if (!verification.first)
        return createErrorReply(HttpReply::BadRequest);

    QVariantMap filterMap = verification.second.toMap();

    LogFilter filter = JsonTypes::unpackLogFilter(filterMap);

    QVariantList entries;
    foreach (const LogEntry &entry, GuhCore::instance()->logEngine()->logEntries(filter)) {
        entries.append(JsonTypes::packLogEntry(entry));
    }
    HttpReply *reply = createSuccessReply();
    reply->setPayload(QJsonDocument::fromVariant(entries).toJson());
    return reply;
}

}