* Copyright 2022 Haiku Inc. All rights reserved.
* Distributed under the terms of the MIT License.
*
* Authors:
* Niels Sascha Reedijk, niels.reedijk@gmail.com
*/
#include "HttpDebugLogger.h"
#include <iostream>
#include <ErrorsExt.h>
#include <HttpSession.h>
#include <NetServicesDefs.h>
using namespace BPrivate::Network;
HttpDebugLogger::HttpDebugLogger()
:
BLooper("HttpDebugLogger")
{
}
void
HttpDebugLogger::SetConsoleLogging(bool enabled)
{
fConsoleLogging = enabled;
}
void
HttpDebugLogger::SetFileLogging(const char* path)
{
if (auto status = fLogFile.SetTo(path, B_WRITE_ONLY | B_CREATE_FILE | B_OPEN_AT_END);
status != B_OK)
throw BSystemError("BFile::SetTo()", status);
}
void
HttpDebugLogger::MessageReceived(BMessage* message)
{
BString output;
if (!message->HasInt32(UrlEventData::Id))
return BLooper::MessageReceived(message);
int32 id = message->FindInt32(UrlEventData::Id);
output << "[" << id << "] ";
switch (message->what) {
case UrlEvent::HostNameResolved:
{
BString hostname;
message->FindString(UrlEventData::HostName, &hostname);
output << "<HostNameResolved> " << hostname;
break;
}
case UrlEvent::ConnectionOpened:
output << "<ConnectionOpened>";
break;
case UrlEvent::UploadProgress:
{
off_t numBytes = message->GetInt64(UrlEventData::NumBytes, -1);
off_t totalBytes = message->GetInt64(UrlEventData::TotalBytes, -1);
output << "<UploadProgress> bytes uploaded " << numBytes;
if (totalBytes == -1)
output << " (total unknown)";
else
output << " (" << totalBytes << " total)";
break;
}
case UrlEvent::ResponseStarted:
{
output << "<ResponseStarted>";
break;
}
case UrlEvent::HttpRedirect:
{
BString redirectUrl;
message->FindString(UrlEventData::HttpRedirectUrl, &redirectUrl);
output << "<HttpRedirect> to: " << redirectUrl;
break;
}
case UrlEvent::HttpStatus:
{
int16 status = message->FindInt16(UrlEventData::HttpStatusCode);
output << "<HttpStatus> code: " << status;
break;
}
case UrlEvent::HttpFields:
{
output << "<HttpFields> All fields parsed";
break;
}
case UrlEvent::DownloadProgress:
{
off_t numBytes = message->GetInt64(UrlEventData::NumBytes, -1);
off_t totalBytes = message->GetInt64(UrlEventData::TotalBytes, -1);
output << "<DownloadProgress> bytes downloaded " << numBytes;
if (totalBytes == -1)
output << " (total unknown)";
else
output << " (" << totalBytes << " total)";
break;
}
case UrlEvent::BytesWritten:
{
off_t numBytes = message->GetInt64(UrlEventData::NumBytes, -1);
output << "<BytesWritten> bytes written to output: " << numBytes;
break;
}
case UrlEvent::RequestCompleted:
{
bool success = message->GetBool(UrlEventData::Success, false);
output << "<RequestCompleted> success: ";
if (success)
output << "true";
else
output << "false";
break;
}
case UrlEvent::DebugMessage:
{
uint32 debugType = message->GetUInt32(UrlEventData::DebugType, 0);
BString debugMessage;
message->FindString(UrlEventData::DebugMessage, &debugMessage);
output << "<DebugMessage> ";
switch (debugType) {
case UrlEventData::DebugInfo:
output << "INFO: ";
break;
case UrlEventData::DebugWarning:
output << "WARNING: ";
break;
case UrlEventData::DebugError:
output << "ERROR: ";
break;
default:
output << "UNKNOWN: ";
break;
}
output << debugMessage;
break;
}
default:
return BLooper::MessageReceived(message);
}
if (fConsoleLogging)
std::cout << output.String() << std::endl;
if (fLogFile.InitCheck() == B_OK) {
output += '\n';
if (auto status = fLogFile.WriteExactly(output.String(), output.Length()); status != B_OK)
throw BSystemError("BFile::WriteExactly()", status);
if (auto status = fLogFile.Flush(); status != B_OK)
throw BSystemError("BFile::Flush()", status);
}
}
