mirror of
https://github.com/pocoproject/poco.git
synced 2025-10-23 08:31:43 +02:00
fixed line endings
This commit is contained in:
Guenter Obiltschnig
@@ -1,131 +1,131 @@
|
||||
//
|
||||
// AbstractHTTPRequestHandler.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/AbstractHTTPRequestHandler.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: AbstractHTTPRequestHandler
|
||||
//
|
||||
// Copyright (c) 2007, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/AbstractHTTPRequestHandler.h"
|
||||
#include "Poco/Net/HTTPServerRequest.h"
|
||||
#include "Poco/Net/HTTPServerResponse.h"
|
||||
#include "Poco/Net/HTMLForm.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/Exception.h"
|
||||
|
||||
|
||||
using Poco::NumberFormatter;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
AbstractHTTPRequestHandler::AbstractHTTPRequestHandler():
|
||||
_pRequest(0),
|
||||
_pResponse(0),
|
||||
_pForm(0)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
AbstractHTTPRequestHandler::~AbstractHTTPRequestHandler()
|
||||
{
|
||||
delete _pForm;
|
||||
}
|
||||
|
||||
|
||||
void AbstractHTTPRequestHandler::handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
|
||||
{
|
||||
_pRequest = &request;
|
||||
_pResponse = &response;
|
||||
if (authenticate())
|
||||
{
|
||||
try
|
||||
{
|
||||
run();
|
||||
}
|
||||
catch (Poco::Exception& exc)
|
||||
{
|
||||
if (!response.sent())
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_INTERNAL_SERVER_ERROR, exc.displayText());
|
||||
}
|
||||
}
|
||||
catch (std::exception& exc)
|
||||
{
|
||||
if (!response.sent())
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_INTERNAL_SERVER_ERROR, exc.what());
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_UNAUTHORIZED, "");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
bool AbstractHTTPRequestHandler::authenticate()
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
HTMLForm& AbstractHTTPRequestHandler::form()
|
||||
{
|
||||
if (!_pForm)
|
||||
_pForm = new HTMLForm(request(), request().stream());
|
||||
|
||||
return *_pForm;
|
||||
}
|
||||
|
||||
|
||||
void AbstractHTTPRequestHandler::sendErrorResponse(HTTPResponse::HTTPStatus status, const std::string& message)
|
||||
{
|
||||
response().setStatusAndReason(status);
|
||||
std::string statusAndReason(NumberFormatter::format(static_cast<int>(response().getStatus())));
|
||||
statusAndReason += " - ";
|
||||
statusAndReason += response().getReason();
|
||||
std::string page("<HTML><HEAD><TITLE>");
|
||||
page += statusAndReason;
|
||||
page += "</TITLE></HEAD><BODY><H1>";
|
||||
page += statusAndReason;
|
||||
page += "</H1>";
|
||||
page += "<P>";
|
||||
page += message;
|
||||
page += "</P></BODY></HTML>";
|
||||
response().sendBuffer(page.data(), page.size());
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// AbstractHTTPRequestHandler.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/AbstractHTTPRequestHandler.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: AbstractHTTPRequestHandler
|
||||
//
|
||||
// Copyright (c) 2007, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/AbstractHTTPRequestHandler.h"
|
||||
#include "Poco/Net/HTTPServerRequest.h"
|
||||
#include "Poco/Net/HTTPServerResponse.h"
|
||||
#include "Poco/Net/HTMLForm.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/Exception.h"
|
||||
|
||||
|
||||
using Poco::NumberFormatter;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
AbstractHTTPRequestHandler::AbstractHTTPRequestHandler():
|
||||
_pRequest(0),
|
||||
_pResponse(0),
|
||||
_pForm(0)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
AbstractHTTPRequestHandler::~AbstractHTTPRequestHandler()
|
||||
{
|
||||
delete _pForm;
|
||||
}
|
||||
|
||||
|
||||
void AbstractHTTPRequestHandler::handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
|
||||
{
|
||||
_pRequest = &request;
|
||||
_pResponse = &response;
|
||||
if (authenticate())
|
||||
{
|
||||
try
|
||||
{
|
||||
run();
|
||||
}
|
||||
catch (Poco::Exception& exc)
|
||||
{
|
||||
if (!response.sent())
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_INTERNAL_SERVER_ERROR, exc.displayText());
|
||||
}
|
||||
}
|
||||
catch (std::exception& exc)
|
||||
{
|
||||
if (!response.sent())
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_INTERNAL_SERVER_ERROR, exc.what());
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
sendErrorResponse(HTTPResponse::HTTP_UNAUTHORIZED, "");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
bool AbstractHTTPRequestHandler::authenticate()
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
HTMLForm& AbstractHTTPRequestHandler::form()
|
||||
{
|
||||
if (!_pForm)
|
||||
_pForm = new HTMLForm(request(), request().stream());
|
||||
|
||||
return *_pForm;
|
||||
}
|
||||
|
||||
|
||||
void AbstractHTTPRequestHandler::sendErrorResponse(HTTPResponse::HTTPStatus status, const std::string& message)
|
||||
{
|
||||
response().setStatusAndReason(status);
|
||||
std::string statusAndReason(NumberFormatter::format(static_cast<int>(response().getStatus())));
|
||||
statusAndReason += " - ";
|
||||
statusAndReason += response().getReason();
|
||||
std::string page("<HTML><HEAD><TITLE>");
|
||||
page += statusAndReason;
|
||||
page += "</TITLE></HEAD><BODY><H1>";
|
||||
page += statusAndReason;
|
||||
page += "</H1>";
|
||||
page += "<P>";
|
||||
page += message;
|
||||
page += "</P></BODY></HTML>";
|
||||
response().sendBuffer(page.data(), page.size());
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
@@ -1,67 +1,67 @@
|
||||
//
|
||||
// AsyncSocketChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/AsyncSocketChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: AsyncIO
|
||||
// Module: AsyncSocketChannel
|
||||
//
|
||||
// Copyright (c) 2007, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/AsyncSocketChannel.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
AsyncSocketChannel::AsyncSocketChannel(const StreamSocket& socket):
|
||||
_socket(socket)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
AsyncSocketChannel::~AsyncSocketChannel()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
int AsyncSocketChannel::write(const void* buffer, int length)
|
||||
{
|
||||
return _socket.sendBytes(buffer, length);
|
||||
}
|
||||
|
||||
|
||||
int AsyncSocketChannel::read(void* buffer, int length)
|
||||
{
|
||||
return _socket.receiveBytes(buffer, length);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// AsyncSocketChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/AsyncSocketChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: AsyncIO
|
||||
// Module: AsyncSocketChannel
|
||||
//
|
||||
// Copyright (c) 2007, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/AsyncSocketChannel.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
AsyncSocketChannel::AsyncSocketChannel(const StreamSocket& socket):
|
||||
_socket(socket)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
AsyncSocketChannel::~AsyncSocketChannel()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
int AsyncSocketChannel::write(const void* buffer, int length)
|
||||
{
|
||||
return _socket.sendBytes(buffer, length);
|
||||
}
|
||||
|
||||
|
||||
int AsyncSocketChannel::read(void* buffer, int length)
|
||||
{
|
||||
return _socket.receiveBytes(buffer, length);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
@@ -1,94 +1,94 @@
|
||||
//
|
||||
// HTTPServerRequestImpl.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/HTTPServerRequestImpl.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: HTTPServerRequestImpl
|
||||
//
|
||||
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/HTTPServerRequestImpl.h"
|
||||
#include "Poco/Net/HTTPServerSession.h"
|
||||
#include "Poco/Net/HTTPHeaderStream.h"
|
||||
#include "Poco/Net/HTTPStream.h"
|
||||
#include "Poco/Net/HTTPFixedLengthStream.h"
|
||||
#include "Poco/Net/HTTPChunkedStream.h"
|
||||
#include "Poco/Net/HTTPServerParams.h"
|
||||
#include "Poco/String.h"
|
||||
|
||||
|
||||
using Poco::icompare;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
HTTPServerRequestImpl::HTTPServerRequestImpl(HTTPServerResponse& response, HTTPServerSession& session, HTTPServerParams* pParams):
|
||||
_response(response),
|
||||
_pStream(0),
|
||||
_pParams(pParams)
|
||||
{
|
||||
poco_check_ptr (_pParams);
|
||||
|
||||
_pParams->duplicate();
|
||||
|
||||
HTTPHeaderInputStream hs(session);
|
||||
read(hs);
|
||||
|
||||
// Now that we know socket is still connected, obtain addresses
|
||||
_clientAddress = session.clientAddress();
|
||||
_serverAddress = session.serverAddress();
|
||||
|
||||
if (getChunkedTransferEncoding())
|
||||
_pStream = new HTTPChunkedInputStream(session);
|
||||
else if (getContentLength() != HTTPMessage::UNKNOWN_CONTENT_LENGTH)
|
||||
_pStream = new HTTPFixedLengthInputStream(session, getContentLength());
|
||||
else if (getMethod() == HTTPRequest::HTTP_GET || getMethod() == HTTPRequest::HTTP_HEAD)
|
||||
_pStream = new HTTPFixedLengthInputStream(session, 0);
|
||||
else
|
||||
_pStream = new HTTPInputStream(session);
|
||||
}
|
||||
|
||||
|
||||
HTTPServerRequestImpl::~HTTPServerRequestImpl()
|
||||
{
|
||||
_pParams->release();
|
||||
delete _pStream;
|
||||
}
|
||||
|
||||
|
||||
bool HTTPServerRequestImpl::expectContinue() const
|
||||
{
|
||||
return has("Expect") && icompare(get("Expect"), "100-continue") == 0;
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// HTTPServerRequestImpl.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/HTTPServerRequestImpl.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: HTTPServerRequestImpl
|
||||
//
|
||||
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/HTTPServerRequestImpl.h"
|
||||
#include "Poco/Net/HTTPServerSession.h"
|
||||
#include "Poco/Net/HTTPHeaderStream.h"
|
||||
#include "Poco/Net/HTTPStream.h"
|
||||
#include "Poco/Net/HTTPFixedLengthStream.h"
|
||||
#include "Poco/Net/HTTPChunkedStream.h"
|
||||
#include "Poco/Net/HTTPServerParams.h"
|
||||
#include "Poco/String.h"
|
||||
|
||||
|
||||
using Poco::icompare;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
HTTPServerRequestImpl::HTTPServerRequestImpl(HTTPServerResponse& response, HTTPServerSession& session, HTTPServerParams* pParams):
|
||||
_response(response),
|
||||
_pStream(0),
|
||||
_pParams(pParams)
|
||||
{
|
||||
poco_check_ptr (_pParams);
|
||||
|
||||
_pParams->duplicate();
|
||||
|
||||
HTTPHeaderInputStream hs(session);
|
||||
read(hs);
|
||||
|
||||
// Now that we know socket is still connected, obtain addresses
|
||||
_clientAddress = session.clientAddress();
|
||||
_serverAddress = session.serverAddress();
|
||||
|
||||
if (getChunkedTransferEncoding())
|
||||
_pStream = new HTTPChunkedInputStream(session);
|
||||
else if (getContentLength() != HTTPMessage::UNKNOWN_CONTENT_LENGTH)
|
||||
_pStream = new HTTPFixedLengthInputStream(session, getContentLength());
|
||||
else if (getMethod() == HTTPRequest::HTTP_GET || getMethod() == HTTPRequest::HTTP_HEAD)
|
||||
_pStream = new HTTPFixedLengthInputStream(session, 0);
|
||||
else
|
||||
_pStream = new HTTPInputStream(session);
|
||||
}
|
||||
|
||||
|
||||
HTTPServerRequestImpl::~HTTPServerRequestImpl()
|
||||
{
|
||||
_pParams->release();
|
||||
delete _pStream;
|
||||
}
|
||||
|
||||
|
||||
bool HTTPServerRequestImpl::expectContinue() const
|
||||
{
|
||||
return has("Expect") && icompare(get("Expect"), "100-continue") == 0;
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
@@ -1,176 +1,176 @@
|
||||
//
|
||||
// HTTPServerResponseImpl.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/HTTPServerResponseImpl.cpp#3 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: HTTPServerResponseImpl
|
||||
//
|
||||
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/HTTPServerResponseImpl.h"
|
||||
#include "Poco/Net/HTTPServerSession.h"
|
||||
#include "Poco/Net/HTTPHeaderStream.h"
|
||||
#include "Poco/Net/HTTPStream.h"
|
||||
#include "Poco/Net/HTTPFixedLengthStream.h"
|
||||
#include "Poco/Net/HTTPChunkedStream.h"
|
||||
#include "Poco/File.h"
|
||||
#include "Poco/Timestamp.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/StreamCopier.h"
|
||||
#include "Poco/CountingStream.h"
|
||||
#include "Poco/Exception.h"
|
||||
#include "Poco/FileStream.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/DateTimeFormat.h"
|
||||
|
||||
|
||||
using Poco::File;
|
||||
using Poco::Timestamp;
|
||||
using Poco::NumberFormatter;
|
||||
using Poco::StreamCopier;
|
||||
using Poco::OpenFileException;
|
||||
using Poco::DateTimeFormatter;
|
||||
using Poco::DateTimeFormat;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
HTTPServerResponseImpl::HTTPServerResponseImpl(HTTPServerSession& session):
|
||||
_session(session),
|
||||
_pStream(0)
|
||||
{
|
||||
Timestamp now;
|
||||
setDate(now);
|
||||
}
|
||||
|
||||
|
||||
HTTPServerResponseImpl::~HTTPServerResponseImpl()
|
||||
{
|
||||
delete _pStream;
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendContinue()
|
||||
{
|
||||
HTTPHeaderOutputStream hs(_session);
|
||||
hs << getVersion() << " 100 Continue\r\n\r\n";
|
||||
}
|
||||
|
||||
|
||||
std::ostream& HTTPServerResponseImpl::send()
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
if (getChunkedTransferEncoding())
|
||||
{
|
||||
HTTPHeaderOutputStream hs(_session);
|
||||
write(hs);
|
||||
_pStream = new HTTPChunkedOutputStream(_session);
|
||||
}
|
||||
else if (getContentLength() != HTTPMessage::UNKNOWN_CONTENT_LENGTH)
|
||||
{
|
||||
Poco::CountingOutputStream cs;
|
||||
write(cs);
|
||||
_pStream = new HTTPFixedLengthOutputStream(_session, getContentLength() + cs.chars());
|
||||
write(*_pStream);
|
||||
}
|
||||
else
|
||||
{
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
setKeepAlive(false);
|
||||
write(*_pStream);
|
||||
}
|
||||
return *_pStream;
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendFile(const std::string& path, const std::string& mediaType)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
File f(path);
|
||||
Timestamp dateTime = f.getLastModified();
|
||||
File::FileSize length = f.getSize();
|
||||
set("Last-Modified", DateTimeFormatter::format(dateTime, DateTimeFormat::HTTP_FORMAT));
|
||||
setContentLength(static_cast<int>(length));
|
||||
setContentType(mediaType);
|
||||
setChunkedTransferEncoding(false);
|
||||
|
||||
Poco::FileInputStream istr(path);
|
||||
if (istr.good())
|
||||
{
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
StreamCopier::copyStream(istr, *_pStream);
|
||||
}
|
||||
else throw OpenFileException(path);
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendBuffer(const void* pBuffer, std::size_t length)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setContentLength(static_cast<int>(length));
|
||||
setChunkedTransferEncoding(false);
|
||||
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
_pStream->write(static_cast<const char*>(pBuffer), static_cast<std::streamsize>(length));
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::redirect(const std::string& uri)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setStatusAndReason(HTTPResponse::HTTP_FOUND);
|
||||
set("Location", uri);
|
||||
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::requireAuthentication(const std::string& realm)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setStatusAndReason(HTTPResponse::HTTP_UNAUTHORIZED);
|
||||
std::string auth("Basic realm=\"");
|
||||
auth.append(realm);
|
||||
auth.append("\"");
|
||||
set("WWW-Authenticate", auth);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// HTTPServerResponseImpl.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/HTTPServerResponseImpl.cpp#3 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: HTTPServer
|
||||
// Module: HTTPServerResponseImpl
|
||||
//
|
||||
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/HTTPServerResponseImpl.h"
|
||||
#include "Poco/Net/HTTPServerSession.h"
|
||||
#include "Poco/Net/HTTPHeaderStream.h"
|
||||
#include "Poco/Net/HTTPStream.h"
|
||||
#include "Poco/Net/HTTPFixedLengthStream.h"
|
||||
#include "Poco/Net/HTTPChunkedStream.h"
|
||||
#include "Poco/File.h"
|
||||
#include "Poco/Timestamp.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/StreamCopier.h"
|
||||
#include "Poco/CountingStream.h"
|
||||
#include "Poco/Exception.h"
|
||||
#include "Poco/FileStream.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/DateTimeFormat.h"
|
||||
|
||||
|
||||
using Poco::File;
|
||||
using Poco::Timestamp;
|
||||
using Poco::NumberFormatter;
|
||||
using Poco::StreamCopier;
|
||||
using Poco::OpenFileException;
|
||||
using Poco::DateTimeFormatter;
|
||||
using Poco::DateTimeFormat;
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
HTTPServerResponseImpl::HTTPServerResponseImpl(HTTPServerSession& session):
|
||||
_session(session),
|
||||
_pStream(0)
|
||||
{
|
||||
Timestamp now;
|
||||
setDate(now);
|
||||
}
|
||||
|
||||
|
||||
HTTPServerResponseImpl::~HTTPServerResponseImpl()
|
||||
{
|
||||
delete _pStream;
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendContinue()
|
||||
{
|
||||
HTTPHeaderOutputStream hs(_session);
|
||||
hs << getVersion() << " 100 Continue\r\n\r\n";
|
||||
}
|
||||
|
||||
|
||||
std::ostream& HTTPServerResponseImpl::send()
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
if (getChunkedTransferEncoding())
|
||||
{
|
||||
HTTPHeaderOutputStream hs(_session);
|
||||
write(hs);
|
||||
_pStream = new HTTPChunkedOutputStream(_session);
|
||||
}
|
||||
else if (getContentLength() != HTTPMessage::UNKNOWN_CONTENT_LENGTH)
|
||||
{
|
||||
Poco::CountingOutputStream cs;
|
||||
write(cs);
|
||||
_pStream = new HTTPFixedLengthOutputStream(_session, getContentLength() + cs.chars());
|
||||
write(*_pStream);
|
||||
}
|
||||
else
|
||||
{
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
setKeepAlive(false);
|
||||
write(*_pStream);
|
||||
}
|
||||
return *_pStream;
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendFile(const std::string& path, const std::string& mediaType)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
File f(path);
|
||||
Timestamp dateTime = f.getLastModified();
|
||||
File::FileSize length = f.getSize();
|
||||
set("Last-Modified", DateTimeFormatter::format(dateTime, DateTimeFormat::HTTP_FORMAT));
|
||||
setContentLength(static_cast<int>(length));
|
||||
setContentType(mediaType);
|
||||
setChunkedTransferEncoding(false);
|
||||
|
||||
Poco::FileInputStream istr(path);
|
||||
if (istr.good())
|
||||
{
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
StreamCopier::copyStream(istr, *_pStream);
|
||||
}
|
||||
else throw OpenFileException(path);
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::sendBuffer(const void* pBuffer, std::size_t length)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setContentLength(static_cast<int>(length));
|
||||
setChunkedTransferEncoding(false);
|
||||
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
_pStream->write(static_cast<const char*>(pBuffer), static_cast<std::streamsize>(length));
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::redirect(const std::string& uri)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setStatusAndReason(HTTPResponse::HTTP_FOUND);
|
||||
set("Location", uri);
|
||||
|
||||
_pStream = new HTTPOutputStream(_session);
|
||||
write(*_pStream);
|
||||
}
|
||||
|
||||
|
||||
void HTTPServerResponseImpl::requireAuthentication(const std::string& realm)
|
||||
{
|
||||
poco_assert (!_pStream);
|
||||
|
||||
setStatusAndReason(HTTPResponse::HTTP_UNAUTHORIZED);
|
||||
std::string auth("Basic realm=\"");
|
||||
auth.append(realm);
|
||||
auth.append("\"");
|
||||
set("WWW-Authenticate", auth);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
@@ -1,355 +1,355 @@
|
||||
//
|
||||
// RemoteSyslogChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/RemoteSyslogChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: Logging
|
||||
// Module: RemoteSyslogChannel
|
||||
//
|
||||
// Copyright (c) 2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/RemoteSyslogChannel.h"
|
||||
#include "Poco/Message.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/Net/SocketAddress.h"
|
||||
#include "Poco/Net/DNS.h"
|
||||
#include "Poco/LoggingFactory.h"
|
||||
#include "Poco/Instantiator.h"
|
||||
#include "Poco/String.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
const std::string RemoteSyslogChannel::BSD_TIMEFORMAT("%b %f %H:%M:%S");
|
||||
const std::string RemoteSyslogChannel::SYSLOG_TIMEFORMAT("%Y-%m-%dT%H:%M:%S.%i%z");
|
||||
const std::string RemoteSyslogChannel::PROP_NAME("name");
|
||||
const std::string RemoteSyslogChannel::PROP_FACILITY("facility");
|
||||
const std::string RemoteSyslogChannel::PROP_FORMAT("format");
|
||||
const std::string RemoteSyslogChannel::PROP_LOGHOST("loghost");
|
||||
const std::string RemoteSyslogChannel::PROP_HOST("host");
|
||||
|
||||
|
||||
RemoteSyslogChannel::RemoteSyslogChannel():
|
||||
_logHost("localhost"),
|
||||
_name("-"),
|
||||
_facility(SYSLOG_USER),
|
||||
_bsdFormat(false),
|
||||
_open(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
RemoteSyslogChannel::RemoteSyslogChannel(const std::string& address, const std::string& name, int facility, bool bsdFormat):
|
||||
_logHost(address),
|
||||
_name(name),
|
||||
_facility(facility),
|
||||
_bsdFormat(bsdFormat),
|
||||
_open(false)
|
||||
{
|
||||
if (_name.empty()) _name = "-";
|
||||
}
|
||||
|
||||
|
||||
RemoteSyslogChannel::~RemoteSyslogChannel()
|
||||
{
|
||||
close();
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::open()
|
||||
{
|
||||
if (_open) return;
|
||||
|
||||
SocketAddress sa;
|
||||
if (_logHost.find(':') != std::string::npos)
|
||||
sa = SocketAddress(_logHost);
|
||||
else
|
||||
sa = SocketAddress(_logHost, SYSLOG_PORT);
|
||||
|
||||
_socket.connect(sa);
|
||||
if (_host.empty())
|
||||
{
|
||||
try
|
||||
{
|
||||
_host = DNS::thisHost().name();
|
||||
}
|
||||
catch (Poco::Exception&)
|
||||
{
|
||||
_host = _socket.address().host().toString();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::close()
|
||||
{
|
||||
if (_open)
|
||||
{
|
||||
_socket.close();
|
||||
_open = false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::log(const Message& msg)
|
||||
{
|
||||
if (!_open) open();
|
||||
|
||||
std::string m;
|
||||
m.reserve(1024);
|
||||
m += '<';
|
||||
m += Poco::NumberFormatter::format(getPrio(msg) + _facility);
|
||||
m += '>';
|
||||
if (_bsdFormat)
|
||||
{
|
||||
m += Poco::DateTimeFormatter::format(msg.getTime(), BSD_TIMEFORMAT);
|
||||
m += ' ';
|
||||
m += _host;
|
||||
}
|
||||
else
|
||||
{
|
||||
m += "1 "; // version
|
||||
m += Poco::DateTimeFormatter::format(msg.getTime(), SYSLOG_TIMEFORMAT);
|
||||
m += ' ';
|
||||
m += _host;
|
||||
m += ' ';
|
||||
m += _name;
|
||||
m += ' ';
|
||||
m += Poco::NumberFormatter::format(msg.getPid());
|
||||
m += ' ';
|
||||
m += msg.getSource();
|
||||
}
|
||||
m += ' ';
|
||||
m += msg.getText();
|
||||
|
||||
_socket.sendBytes(m.data(), (int) m.size());
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::setProperty(const std::string& name, const std::string& value)
|
||||
{
|
||||
if (name == PROP_NAME)
|
||||
{
|
||||
_name = value;
|
||||
if (_name.empty()) _name = "-";
|
||||
}
|
||||
else if (name == PROP_FACILITY)
|
||||
{
|
||||
std::string facility;
|
||||
if (Poco::icompare(value, 4, "LOG_") == 0)
|
||||
facility = Poco::toUpper(value.substr(4));
|
||||
else if (Poco::icompare(value, 4, "SYSLOG_") == 0)
|
||||
facility = Poco::toUpper(value.substr(7));
|
||||
else
|
||||
facility = Poco::toUpper(value);
|
||||
|
||||
if (facility == "KERN")
|
||||
_facility = SYSLOG_KERN;
|
||||
else if (facility == "USER")
|
||||
_facility = SYSLOG_USER;
|
||||
else if (facility == "MAIL")
|
||||
_facility = SYSLOG_MAIL;
|
||||
else if (facility == "DAEMON")
|
||||
_facility = SYSLOG_DAEMON;
|
||||
else if (facility == "AUTH")
|
||||
_facility = SYSLOG_AUTH;
|
||||
else if (facility == "AUTHPRIV")
|
||||
_facility = SYSLOG_AUTHPRIV;
|
||||
else if (facility == "SYSLOG")
|
||||
_facility = SYSLOG_SYSLOG;
|
||||
else if (facility == "LPR")
|
||||
_facility = SYSLOG_LPR;
|
||||
else if (facility == "NEWS")
|
||||
_facility = SYSLOG_NEWS;
|
||||
else if (facility == "UUCP")
|
||||
_facility = SYSLOG_UUCP;
|
||||
else if (facility == "CRON")
|
||||
_facility = SYSLOG_CRON;
|
||||
else if (facility == "FTP")
|
||||
_facility = SYSLOG_FTP;
|
||||
else if (facility == "NTP")
|
||||
_facility = SYSLOG_NTP;
|
||||
else if (facility == "LOGAUDIT")
|
||||
_facility = SYSLOG_LOGAUDIT;
|
||||
else if (facility == "LOGALERT")
|
||||
_facility = SYSLOG_LOGALERT;
|
||||
else if (facility == "CLOCK")
|
||||
_facility = SYSLOG_CLOCK;
|
||||
else if (facility == "LOCAL0")
|
||||
_facility = SYSLOG_LOCAL0;
|
||||
else if (facility == "LOCAL1")
|
||||
_facility = SYSLOG_LOCAL1;
|
||||
else if (facility == "LOCAL2")
|
||||
_facility = SYSLOG_LOCAL2;
|
||||
else if (facility == "LOCAL3")
|
||||
_facility = SYSLOG_LOCAL3;
|
||||
else if (facility == "LOCAL4")
|
||||
_facility = SYSLOG_LOCAL4;
|
||||
else if (facility == "LOCAL5")
|
||||
_facility = SYSLOG_LOCAL5;
|
||||
else if (facility == "LOCAL6")
|
||||
_facility = SYSLOG_LOCAL6;
|
||||
else if (facility == "LOCAL7")
|
||||
_facility = SYSLOG_LOCAL7;
|
||||
}
|
||||
else if (name == PROP_LOGHOST)
|
||||
{
|
||||
_logHost = value;
|
||||
}
|
||||
else if (name == PROP_HOST)
|
||||
{
|
||||
_host = value;
|
||||
}
|
||||
else if (name == PROP_FORMAT)
|
||||
{
|
||||
_bsdFormat = (value == "bsd");
|
||||
}
|
||||
else
|
||||
{
|
||||
Channel::setProperty(name, value);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
std::string RemoteSyslogChannel::getProperty(const std::string& name) const
|
||||
{
|
||||
if (name == PROP_NAME)
|
||||
{
|
||||
if (_name != "-")
|
||||
return _name;
|
||||
else
|
||||
return "";
|
||||
}
|
||||
else if (name == PROP_FACILITY)
|
||||
{
|
||||
if (_facility == SYSLOG_KERN)
|
||||
return "KERN";
|
||||
else if (_facility == SYSLOG_USER)
|
||||
return "USER";
|
||||
else if (_facility == SYSLOG_MAIL)
|
||||
return "MAIL";
|
||||
else if (_facility == SYSLOG_DAEMON)
|
||||
return "DAEMON";
|
||||
else if (_facility == SYSLOG_AUTH)
|
||||
return "AUTH";
|
||||
else if (_facility == SYSLOG_AUTHPRIV)
|
||||
return "AUTHPRIV";
|
||||
else if (_facility == SYSLOG_SYSLOG)
|
||||
return "SYSLOG";
|
||||
else if (_facility == SYSLOG_LPR)
|
||||
return "LPR";
|
||||
else if (_facility == SYSLOG_NEWS)
|
||||
return "NEWS";
|
||||
else if (_facility == SYSLOG_UUCP)
|
||||
return "UUCP";
|
||||
else if (_facility == SYSLOG_CRON)
|
||||
return "CRON";
|
||||
else if (_facility == SYSLOG_FTP)
|
||||
return "FTP";
|
||||
else if (_facility == SYSLOG_NTP)
|
||||
return "NTP";
|
||||
else if (_facility == SYSLOG_LOGAUDIT)
|
||||
return "LOGAUDIT";
|
||||
else if (_facility == SYSLOG_LOGALERT)
|
||||
return "LOGALERT";
|
||||
else if (_facility == SYSLOG_CLOCK)
|
||||
return "CLOCK";
|
||||
else if (_facility == SYSLOG_LOCAL0)
|
||||
return "LOCAL0";
|
||||
else if (_facility == SYSLOG_LOCAL1)
|
||||
return "LOCAL1";
|
||||
else if (_facility == SYSLOG_LOCAL2)
|
||||
return "LOCAL2";
|
||||
else if (_facility == SYSLOG_LOCAL3)
|
||||
return "LOCAL3";
|
||||
else if (_facility == SYSLOG_LOCAL4)
|
||||
return "LOCAL4";
|
||||
else if (_facility == SYSLOG_LOCAL5)
|
||||
return "LOCAL5";
|
||||
else if (_facility == SYSLOG_LOCAL6)
|
||||
return "LOCAL6";
|
||||
else if (_facility == SYSLOG_LOCAL7)
|
||||
return "LOCAL7";
|
||||
else
|
||||
return "";
|
||||
}
|
||||
else if (name == PROP_LOGHOST)
|
||||
{
|
||||
return _logHost;
|
||||
}
|
||||
else if (name == PROP_HOST)
|
||||
{
|
||||
return _host;
|
||||
}
|
||||
else if (name == PROP_FORMAT)
|
||||
{
|
||||
return _bsdFormat ? "bsd" : "new";
|
||||
}
|
||||
else
|
||||
{
|
||||
return Channel::getProperty(name);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
int RemoteSyslogChannel::getPrio(const Message& msg)
|
||||
{
|
||||
switch (msg.getPriority())
|
||||
{
|
||||
case Message::PRIO_TRACE:
|
||||
case Message::PRIO_DEBUG:
|
||||
return SYSLOG_DEBUG;
|
||||
case Message::PRIO_INFORMATION:
|
||||
return SYSLOG_INFORMATIONAL;
|
||||
case Message::PRIO_NOTICE:
|
||||
return SYSLOG_NOTICE;
|
||||
case Message::PRIO_WARNING:
|
||||
return SYSLOG_WARNING;
|
||||
case Message::PRIO_ERROR:
|
||||
return SYSLOG_ERROR;
|
||||
case Message::PRIO_CRITICAL:
|
||||
return SYSLOG_CRITICAL;
|
||||
case Message::PRIO_FATAL:
|
||||
return SYSLOG_ALERT;
|
||||
default:
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::registerChannel()
|
||||
{
|
||||
Poco::LoggingFactory::defaultFactory().registerChannelClass("RemoteSyslogChannel", new Poco::Instantiator<RemoteSyslogChannel, Poco::Channel>);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// RemoteSyslogChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/RemoteSyslogChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: Logging
|
||||
// Module: RemoteSyslogChannel
|
||||
//
|
||||
// Copyright (c) 2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/RemoteSyslogChannel.h"
|
||||
#include "Poco/Message.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/Net/SocketAddress.h"
|
||||
#include "Poco/Net/DNS.h"
|
||||
#include "Poco/LoggingFactory.h"
|
||||
#include "Poco/Instantiator.h"
|
||||
#include "Poco/String.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
const std::string RemoteSyslogChannel::BSD_TIMEFORMAT("%b %f %H:%M:%S");
|
||||
const std::string RemoteSyslogChannel::SYSLOG_TIMEFORMAT("%Y-%m-%dT%H:%M:%S.%i%z");
|
||||
const std::string RemoteSyslogChannel::PROP_NAME("name");
|
||||
const std::string RemoteSyslogChannel::PROP_FACILITY("facility");
|
||||
const std::string RemoteSyslogChannel::PROP_FORMAT("format");
|
||||
const std::string RemoteSyslogChannel::PROP_LOGHOST("loghost");
|
||||
const std::string RemoteSyslogChannel::PROP_HOST("host");
|
||||
|
||||
|
||||
RemoteSyslogChannel::RemoteSyslogChannel():
|
||||
_logHost("localhost"),
|
||||
_name("-"),
|
||||
_facility(SYSLOG_USER),
|
||||
_bsdFormat(false),
|
||||
_open(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
RemoteSyslogChannel::RemoteSyslogChannel(const std::string& address, const std::string& name, int facility, bool bsdFormat):
|
||||
_logHost(address),
|
||||
_name(name),
|
||||
_facility(facility),
|
||||
_bsdFormat(bsdFormat),
|
||||
_open(false)
|
||||
{
|
||||
if (_name.empty()) _name = "-";
|
||||
}
|
||||
|
||||
|
||||
RemoteSyslogChannel::~RemoteSyslogChannel()
|
||||
{
|
||||
close();
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::open()
|
||||
{
|
||||
if (_open) return;
|
||||
|
||||
SocketAddress sa;
|
||||
if (_logHost.find(':') != std::string::npos)
|
||||
sa = SocketAddress(_logHost);
|
||||
else
|
||||
sa = SocketAddress(_logHost, SYSLOG_PORT);
|
||||
|
||||
_socket.connect(sa);
|
||||
if (_host.empty())
|
||||
{
|
||||
try
|
||||
{
|
||||
_host = DNS::thisHost().name();
|
||||
}
|
||||
catch (Poco::Exception&)
|
||||
{
|
||||
_host = _socket.address().host().toString();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::close()
|
||||
{
|
||||
if (_open)
|
||||
{
|
||||
_socket.close();
|
||||
_open = false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::log(const Message& msg)
|
||||
{
|
||||
if (!_open) open();
|
||||
|
||||
std::string m;
|
||||
m.reserve(1024);
|
||||
m += '<';
|
||||
m += Poco::NumberFormatter::format(getPrio(msg) + _facility);
|
||||
m += '>';
|
||||
if (_bsdFormat)
|
||||
{
|
||||
m += Poco::DateTimeFormatter::format(msg.getTime(), BSD_TIMEFORMAT);
|
||||
m += ' ';
|
||||
m += _host;
|
||||
}
|
||||
else
|
||||
{
|
||||
m += "1 "; // version
|
||||
m += Poco::DateTimeFormatter::format(msg.getTime(), SYSLOG_TIMEFORMAT);
|
||||
m += ' ';
|
||||
m += _host;
|
||||
m += ' ';
|
||||
m += _name;
|
||||
m += ' ';
|
||||
m += Poco::NumberFormatter::format(msg.getPid());
|
||||
m += ' ';
|
||||
m += msg.getSource();
|
||||
}
|
||||
m += ' ';
|
||||
m += msg.getText();
|
||||
|
||||
_socket.sendBytes(m.data(), (int) m.size());
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::setProperty(const std::string& name, const std::string& value)
|
||||
{
|
||||
if (name == PROP_NAME)
|
||||
{
|
||||
_name = value;
|
||||
if (_name.empty()) _name = "-";
|
||||
}
|
||||
else if (name == PROP_FACILITY)
|
||||
{
|
||||
std::string facility;
|
||||
if (Poco::icompare(value, 4, "LOG_") == 0)
|
||||
facility = Poco::toUpper(value.substr(4));
|
||||
else if (Poco::icompare(value, 4, "SYSLOG_") == 0)
|
||||
facility = Poco::toUpper(value.substr(7));
|
||||
else
|
||||
facility = Poco::toUpper(value);
|
||||
|
||||
if (facility == "KERN")
|
||||
_facility = SYSLOG_KERN;
|
||||
else if (facility == "USER")
|
||||
_facility = SYSLOG_USER;
|
||||
else if (facility == "MAIL")
|
||||
_facility = SYSLOG_MAIL;
|
||||
else if (facility == "DAEMON")
|
||||
_facility = SYSLOG_DAEMON;
|
||||
else if (facility == "AUTH")
|
||||
_facility = SYSLOG_AUTH;
|
||||
else if (facility == "AUTHPRIV")
|
||||
_facility = SYSLOG_AUTHPRIV;
|
||||
else if (facility == "SYSLOG")
|
||||
_facility = SYSLOG_SYSLOG;
|
||||
else if (facility == "LPR")
|
||||
_facility = SYSLOG_LPR;
|
||||
else if (facility == "NEWS")
|
||||
_facility = SYSLOG_NEWS;
|
||||
else if (facility == "UUCP")
|
||||
_facility = SYSLOG_UUCP;
|
||||
else if (facility == "CRON")
|
||||
_facility = SYSLOG_CRON;
|
||||
else if (facility == "FTP")
|
||||
_facility = SYSLOG_FTP;
|
||||
else if (facility == "NTP")
|
||||
_facility = SYSLOG_NTP;
|
||||
else if (facility == "LOGAUDIT")
|
||||
_facility = SYSLOG_LOGAUDIT;
|
||||
else if (facility == "LOGALERT")
|
||||
_facility = SYSLOG_LOGALERT;
|
||||
else if (facility == "CLOCK")
|
||||
_facility = SYSLOG_CLOCK;
|
||||
else if (facility == "LOCAL0")
|
||||
_facility = SYSLOG_LOCAL0;
|
||||
else if (facility == "LOCAL1")
|
||||
_facility = SYSLOG_LOCAL1;
|
||||
else if (facility == "LOCAL2")
|
||||
_facility = SYSLOG_LOCAL2;
|
||||
else if (facility == "LOCAL3")
|
||||
_facility = SYSLOG_LOCAL3;
|
||||
else if (facility == "LOCAL4")
|
||||
_facility = SYSLOG_LOCAL4;
|
||||
else if (facility == "LOCAL5")
|
||||
_facility = SYSLOG_LOCAL5;
|
||||
else if (facility == "LOCAL6")
|
||||
_facility = SYSLOG_LOCAL6;
|
||||
else if (facility == "LOCAL7")
|
||||
_facility = SYSLOG_LOCAL7;
|
||||
}
|
||||
else if (name == PROP_LOGHOST)
|
||||
{
|
||||
_logHost = value;
|
||||
}
|
||||
else if (name == PROP_HOST)
|
||||
{
|
||||
_host = value;
|
||||
}
|
||||
else if (name == PROP_FORMAT)
|
||||
{
|
||||
_bsdFormat = (value == "bsd");
|
||||
}
|
||||
else
|
||||
{
|
||||
Channel::setProperty(name, value);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
std::string RemoteSyslogChannel::getProperty(const std::string& name) const
|
||||
{
|
||||
if (name == PROP_NAME)
|
||||
{
|
||||
if (_name != "-")
|
||||
return _name;
|
||||
else
|
||||
return "";
|
||||
}
|
||||
else if (name == PROP_FACILITY)
|
||||
{
|
||||
if (_facility == SYSLOG_KERN)
|
||||
return "KERN";
|
||||
else if (_facility == SYSLOG_USER)
|
||||
return "USER";
|
||||
else if (_facility == SYSLOG_MAIL)
|
||||
return "MAIL";
|
||||
else if (_facility == SYSLOG_DAEMON)
|
||||
return "DAEMON";
|
||||
else if (_facility == SYSLOG_AUTH)
|
||||
return "AUTH";
|
||||
else if (_facility == SYSLOG_AUTHPRIV)
|
||||
return "AUTHPRIV";
|
||||
else if (_facility == SYSLOG_SYSLOG)
|
||||
return "SYSLOG";
|
||||
else if (_facility == SYSLOG_LPR)
|
||||
return "LPR";
|
||||
else if (_facility == SYSLOG_NEWS)
|
||||
return "NEWS";
|
||||
else if (_facility == SYSLOG_UUCP)
|
||||
return "UUCP";
|
||||
else if (_facility == SYSLOG_CRON)
|
||||
return "CRON";
|
||||
else if (_facility == SYSLOG_FTP)
|
||||
return "FTP";
|
||||
else if (_facility == SYSLOG_NTP)
|
||||
return "NTP";
|
||||
else if (_facility == SYSLOG_LOGAUDIT)
|
||||
return "LOGAUDIT";
|
||||
else if (_facility == SYSLOG_LOGALERT)
|
||||
return "LOGALERT";
|
||||
else if (_facility == SYSLOG_CLOCK)
|
||||
return "CLOCK";
|
||||
else if (_facility == SYSLOG_LOCAL0)
|
||||
return "LOCAL0";
|
||||
else if (_facility == SYSLOG_LOCAL1)
|
||||
return "LOCAL1";
|
||||
else if (_facility == SYSLOG_LOCAL2)
|
||||
return "LOCAL2";
|
||||
else if (_facility == SYSLOG_LOCAL3)
|
||||
return "LOCAL3";
|
||||
else if (_facility == SYSLOG_LOCAL4)
|
||||
return "LOCAL4";
|
||||
else if (_facility == SYSLOG_LOCAL5)
|
||||
return "LOCAL5";
|
||||
else if (_facility == SYSLOG_LOCAL6)
|
||||
return "LOCAL6";
|
||||
else if (_facility == SYSLOG_LOCAL7)
|
||||
return "LOCAL7";
|
||||
else
|
||||
return "";
|
||||
}
|
||||
else if (name == PROP_LOGHOST)
|
||||
{
|
||||
return _logHost;
|
||||
}
|
||||
else if (name == PROP_HOST)
|
||||
{
|
||||
return _host;
|
||||
}
|
||||
else if (name == PROP_FORMAT)
|
||||
{
|
||||
return _bsdFormat ? "bsd" : "new";
|
||||
}
|
||||
else
|
||||
{
|
||||
return Channel::getProperty(name);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
int RemoteSyslogChannel::getPrio(const Message& msg)
|
||||
{
|
||||
switch (msg.getPriority())
|
||||
{
|
||||
case Message::PRIO_TRACE:
|
||||
case Message::PRIO_DEBUG:
|
||||
return SYSLOG_DEBUG;
|
||||
case Message::PRIO_INFORMATION:
|
||||
return SYSLOG_INFORMATIONAL;
|
||||
case Message::PRIO_NOTICE:
|
||||
return SYSLOG_NOTICE;
|
||||
case Message::PRIO_WARNING:
|
||||
return SYSLOG_WARNING;
|
||||
case Message::PRIO_ERROR:
|
||||
return SYSLOG_ERROR;
|
||||
case Message::PRIO_CRITICAL:
|
||||
return SYSLOG_CRITICAL;
|
||||
case Message::PRIO_FATAL:
|
||||
return SYSLOG_ALERT;
|
||||
default:
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void RemoteSyslogChannel::registerChannel()
|
||||
{
|
||||
Poco::LoggingFactory::defaultFactory().registerChannelClass("RemoteSyslogChannel", new Poco::Instantiator<RemoteSyslogChannel, Poco::Channel>);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -1,217 +1,217 @@
|
||||
//
|
||||
// SMTPChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/SMTPChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: Logging
|
||||
// Module: SMTPChannel
|
||||
//
|
||||
// Copyright (c) 2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/SMTPChannel.h"
|
||||
#include "Poco/Net/MailMessage.h"
|
||||
#include "Poco/Net/MailRecipient.h"
|
||||
#include "Poco/Net/SMTPClientSession.h"
|
||||
#include "Poco/Net/StringPartSource.h"
|
||||
#include "Poco/Message.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/DateTimeFormat.h"
|
||||
#include "Poco/LocalDateTime.h"
|
||||
#include "Poco/LoggingFactory.h"
|
||||
#include "Poco/Instantiator.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/FileStream.h"
|
||||
#include "Poco/File.h"
|
||||
#include "Poco/Environment.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
const std::string SMTPChannel::PROP_MAILHOST("mailhost");
|
||||
const std::string SMTPChannel::PROP_SENDER("sender");
|
||||
const std::string SMTPChannel::PROP_RECIPIENT("recipient");
|
||||
const std::string SMTPChannel::PROP_LOCAL("local");
|
||||
const std::string SMTPChannel::PROP_ATTACHMENT("attachment");
|
||||
const std::string SMTPChannel::PROP_TYPE("type");
|
||||
const std::string SMTPChannel::PROP_DELETE("delete");
|
||||
const std::string SMTPChannel::PROP_THROW("throw");
|
||||
|
||||
|
||||
SMTPChannel::SMTPChannel():
|
||||
_mailHost("localhost"),
|
||||
_local(true),
|
||||
_type("text/plain"),
|
||||
_delete(false),
|
||||
_throw(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
SMTPChannel::SMTPChannel(const std::string& mailhost, const std::string& sender, const std::string& recipient):
|
||||
_mailHost(mailhost),
|
||||
_sender(sender),
|
||||
_recipient(recipient),
|
||||
_local(true),
|
||||
_type("text/plain"),
|
||||
_delete(false),
|
||||
_throw(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
SMTPChannel::~SMTPChannel()
|
||||
{
|
||||
close();
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::open()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::close()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::log(const Message& msg)
|
||||
{
|
||||
try
|
||||
{
|
||||
MailMessage message;
|
||||
message.setSender(_sender);
|
||||
message.addRecipient(MailRecipient(MailRecipient::PRIMARY_RECIPIENT, _recipient));
|
||||
message.setSubject("Log Message from " + _sender);
|
||||
std::stringstream content;
|
||||
content << "Log Message\r\n"
|
||||
<< "===========\r\n\r\n"
|
||||
<< "Host: " << Environment::nodeName() << "\r\n"
|
||||
<< "Logger: " << msg.getSource() << "\r\n";
|
||||
|
||||
if (_local)
|
||||
{
|
||||
DateTime dt(msg.getTime());
|
||||
content << "Timestamp: " << DateTimeFormatter::format(LocalDateTime(dt), DateTimeFormat::RFC822_FORMAT) << "\r\n";
|
||||
}
|
||||
else
|
||||
content << "Timestamp: " << DateTimeFormatter::format(msg.getTime(), DateTimeFormat::RFC822_FORMAT) << "\r\n";
|
||||
|
||||
content << "Priority: " << NumberFormatter::format(msg.getPriority()) << "\r\n"
|
||||
<< "Process ID: " << NumberFormatter::format(msg.getPid()) << "\r\n"
|
||||
<< "Thread: " << msg.getThread() << " (ID: " << msg.getTid() << ")\r\n"
|
||||
<< "Message text: " << msg.getText() << "\r\n\r\n";
|
||||
|
||||
message.addContent(new StringPartSource(content.str()));
|
||||
|
||||
if (!_attachment.empty())
|
||||
{
|
||||
{
|
||||
Poco::FileInputStream fis(_attachment, std::ios::in | std::ios::binary | std::ios::ate);
|
||||
if (fis.good())
|
||||
{
|
||||
int size = fis.tellg();
|
||||
char* pMem = new char [size];
|
||||
fis.seekg(std::ios::beg);
|
||||
fis.read(pMem, size);
|
||||
message.addAttachment(_attachment, new StringPartSource(std::string(pMem, size), _type, _attachment));
|
||||
delete [] pMem;
|
||||
}
|
||||
}
|
||||
if (_delete) File(_attachment).remove();
|
||||
}
|
||||
|
||||
SMTPClientSession session(_mailHost);
|
||||
session.login();
|
||||
session.sendMessage(message);
|
||||
session.close();
|
||||
}
|
||||
catch (Exception&)
|
||||
{
|
||||
if (_throw) throw;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::setProperty(const std::string& name, const std::string& value)
|
||||
{
|
||||
if (name == PROP_MAILHOST)
|
||||
_mailHost = value;
|
||||
else if (name == PROP_SENDER)
|
||||
_sender = value;
|
||||
else if (name == PROP_RECIPIENT)
|
||||
_recipient = value;
|
||||
else if (name == PROP_LOCAL)
|
||||
_local = isTrue(value);
|
||||
else if (name == PROP_ATTACHMENT)
|
||||
_attachment = value;
|
||||
else if (name == PROP_TYPE)
|
||||
_type = value;
|
||||
else if (name == PROP_DELETE)
|
||||
_delete = isTrue(value);
|
||||
else if (name == PROP_THROW)
|
||||
_throw = isTrue(value);
|
||||
else
|
||||
Channel::setProperty(name, value);
|
||||
}
|
||||
|
||||
|
||||
std::string SMTPChannel::getProperty(const std::string& name) const
|
||||
{
|
||||
if (name == PROP_MAILHOST)
|
||||
return _mailHost;
|
||||
else if (name == PROP_SENDER)
|
||||
return _sender;
|
||||
else if (name == PROP_RECIPIENT)
|
||||
return _recipient;
|
||||
else if (name == PROP_LOCAL)
|
||||
return _local ? "true" : "false";
|
||||
else if (name == PROP_ATTACHMENT)
|
||||
return _attachment;
|
||||
else if (name == PROP_TYPE)
|
||||
return _type;
|
||||
else if (name == PROP_DELETE)
|
||||
return _delete ? "true" : "false";
|
||||
else if (name == PROP_THROW)
|
||||
return _throw ? "true" : "false";
|
||||
else
|
||||
return Channel::getProperty(name);
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::registerChannel()
|
||||
{
|
||||
Poco::LoggingFactory::defaultFactory().registerChannelClass("SMTPChannel",
|
||||
new Poco::Instantiator<SMTPChannel, Poco::Channel>);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
//
|
||||
// SMTPChannel.cpp
|
||||
//
|
||||
// $Id: //poco/svn/Net/src/SMTPChannel.cpp#2 $
|
||||
//
|
||||
// Library: Net
|
||||
// Package: Logging
|
||||
// Module: SMTPChannel
|
||||
//
|
||||
// Copyright (c) 2006, Applied Informatics Software Engineering GmbH.
|
||||
// and Contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person or organization
|
||||
// obtaining a copy of the software and accompanying documentation covered by
|
||||
// this license (the "Software") to use, reproduce, display, distribute,
|
||||
// execute, and transmit the Software, and to prepare derivative works of the
|
||||
// Software, and to permit third-parties to whom the Software is furnished to
|
||||
// do so, all subject to the following:
|
||||
//
|
||||
// The copyright notices in the Software and this entire statement, including
|
||||
// the above license grant, this restriction and the following disclaimer,
|
||||
// must be included in all copies of the Software, in whole or in part, and
|
||||
// all derivative works of the Software, unless such copies or derivative
|
||||
// works are solely in the form of machine-executable object code generated by
|
||||
// a source language processor.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
|
||||
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
|
||||
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
|
||||
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
||||
// DEALINGS IN THE SOFTWARE.
|
||||
//
|
||||
|
||||
|
||||
#include "Poco/Net/SMTPChannel.h"
|
||||
#include "Poco/Net/MailMessage.h"
|
||||
#include "Poco/Net/MailRecipient.h"
|
||||
#include "Poco/Net/SMTPClientSession.h"
|
||||
#include "Poco/Net/StringPartSource.h"
|
||||
#include "Poco/Message.h"
|
||||
#include "Poco/DateTimeFormatter.h"
|
||||
#include "Poco/DateTimeFormat.h"
|
||||
#include "Poco/LocalDateTime.h"
|
||||
#include "Poco/LoggingFactory.h"
|
||||
#include "Poco/Instantiator.h"
|
||||
#include "Poco/NumberFormatter.h"
|
||||
#include "Poco/FileStream.h"
|
||||
#include "Poco/File.h"
|
||||
#include "Poco/Environment.h"
|
||||
|
||||
|
||||
namespace Poco {
|
||||
namespace Net {
|
||||
|
||||
|
||||
const std::string SMTPChannel::PROP_MAILHOST("mailhost");
|
||||
const std::string SMTPChannel::PROP_SENDER("sender");
|
||||
const std::string SMTPChannel::PROP_RECIPIENT("recipient");
|
||||
const std::string SMTPChannel::PROP_LOCAL("local");
|
||||
const std::string SMTPChannel::PROP_ATTACHMENT("attachment");
|
||||
const std::string SMTPChannel::PROP_TYPE("type");
|
||||
const std::string SMTPChannel::PROP_DELETE("delete");
|
||||
const std::string SMTPChannel::PROP_THROW("throw");
|
||||
|
||||
|
||||
SMTPChannel::SMTPChannel():
|
||||
_mailHost("localhost"),
|
||||
_local(true),
|
||||
_type("text/plain"),
|
||||
_delete(false),
|
||||
_throw(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
SMTPChannel::SMTPChannel(const std::string& mailhost, const std::string& sender, const std::string& recipient):
|
||||
_mailHost(mailhost),
|
||||
_sender(sender),
|
||||
_recipient(recipient),
|
||||
_local(true),
|
||||
_type("text/plain"),
|
||||
_delete(false),
|
||||
_throw(false)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
SMTPChannel::~SMTPChannel()
|
||||
{
|
||||
close();
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::open()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::close()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::log(const Message& msg)
|
||||
{
|
||||
try
|
||||
{
|
||||
MailMessage message;
|
||||
message.setSender(_sender);
|
||||
message.addRecipient(MailRecipient(MailRecipient::PRIMARY_RECIPIENT, _recipient));
|
||||
message.setSubject("Log Message from " + _sender);
|
||||
std::stringstream content;
|
||||
content << "Log Message\r\n"
|
||||
<< "===========\r\n\r\n"
|
||||
<< "Host: " << Environment::nodeName() << "\r\n"
|
||||
<< "Logger: " << msg.getSource() << "\r\n";
|
||||
|
||||
if (_local)
|
||||
{
|
||||
DateTime dt(msg.getTime());
|
||||
content << "Timestamp: " << DateTimeFormatter::format(LocalDateTime(dt), DateTimeFormat::RFC822_FORMAT) << "\r\n";
|
||||
}
|
||||
else
|
||||
content << "Timestamp: " << DateTimeFormatter::format(msg.getTime(), DateTimeFormat::RFC822_FORMAT) << "\r\n";
|
||||
|
||||
content << "Priority: " << NumberFormatter::format(msg.getPriority()) << "\r\n"
|
||||
<< "Process ID: " << NumberFormatter::format(msg.getPid()) << "\r\n"
|
||||
<< "Thread: " << msg.getThread() << " (ID: " << msg.getTid() << ")\r\n"
|
||||
<< "Message text: " << msg.getText() << "\r\n\r\n";
|
||||
|
||||
message.addContent(new StringPartSource(content.str()));
|
||||
|
||||
if (!_attachment.empty())
|
||||
{
|
||||
{
|
||||
Poco::FileInputStream fis(_attachment, std::ios::in | std::ios::binary | std::ios::ate);
|
||||
if (fis.good())
|
||||
{
|
||||
int size = fis.tellg();
|
||||
char* pMem = new char [size];
|
||||
fis.seekg(std::ios::beg);
|
||||
fis.read(pMem, size);
|
||||
message.addAttachment(_attachment, new StringPartSource(std::string(pMem, size), _type, _attachment));
|
||||
delete [] pMem;
|
||||
}
|
||||
}
|
||||
if (_delete) File(_attachment).remove();
|
||||
}
|
||||
|
||||
SMTPClientSession session(_mailHost);
|
||||
session.login();
|
||||
session.sendMessage(message);
|
||||
session.close();
|
||||
}
|
||||
catch (Exception&)
|
||||
{
|
||||
if (_throw) throw;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::setProperty(const std::string& name, const std::string& value)
|
||||
{
|
||||
if (name == PROP_MAILHOST)
|
||||
_mailHost = value;
|
||||
else if (name == PROP_SENDER)
|
||||
_sender = value;
|
||||
else if (name == PROP_RECIPIENT)
|
||||
_recipient = value;
|
||||
else if (name == PROP_LOCAL)
|
||||
_local = isTrue(value);
|
||||
else if (name == PROP_ATTACHMENT)
|
||||
_attachment = value;
|
||||
else if (name == PROP_TYPE)
|
||||
_type = value;
|
||||
else if (name == PROP_DELETE)
|
||||
_delete = isTrue(value);
|
||||
else if (name == PROP_THROW)
|
||||
_throw = isTrue(value);
|
||||
else
|
||||
Channel::setProperty(name, value);
|
||||
}
|
||||
|
||||
|
||||
std::string SMTPChannel::getProperty(const std::string& name) const
|
||||
{
|
||||
if (name == PROP_MAILHOST)
|
||||
return _mailHost;
|
||||
else if (name == PROP_SENDER)
|
||||
return _sender;
|
||||
else if (name == PROP_RECIPIENT)
|
||||
return _recipient;
|
||||
else if (name == PROP_LOCAL)
|
||||
return _local ? "true" : "false";
|
||||
else if (name == PROP_ATTACHMENT)
|
||||
return _attachment;
|
||||
else if (name == PROP_TYPE)
|
||||
return _type;
|
||||
else if (name == PROP_DELETE)
|
||||
return _delete ? "true" : "false";
|
||||
else if (name == PROP_THROW)
|
||||
return _throw ? "true" : "false";
|
||||
else
|
||||
return Channel::getProperty(name);
|
||||
}
|
||||
|
||||
|
||||
void SMTPChannel::registerChannel()
|
||||
{
|
||||
Poco::LoggingFactory::defaultFactory().registerChannelClass("SMTPChannel",
|
||||
new Poco::Instantiator<SMTPChannel, Poco::Channel>);
|
||||
}
|
||||
|
||||
|
||||
} } // namespace Poco::Net
|
||||
|
||||
Reference in New Issue
Block a user