/* * DaemonStatusRequestHandler.cpp * * Copyright (C) 2008 Matthias Schiffer * * 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 . */ #include "DaemonStatusRequestHandler.h" #include "../ConnectionManager.h" #include #include namespace Mad { namespace Server { namespace RequestHandlers { void DaemonStatusRequestHandler::handlePacket(const Common::XmlPacket &packet) { if(packet.getType() != "GetDaemonStatus") { Common::Logger::log(Common::Logger::ERROR, "Received an unexpected packet."); Common::XmlPacket ret; ret.setType("Error"); ret.add("ErrorCode", Net::Exception::UNEXPECTED_PACKET); sendPacket(ret); signalFinished(); return; } // TODO Require authentication std::string daemonName = packet["daemonName"]; try { boost::shared_ptr daemonCon = ConnectionManager::get()->getDaemonConnection(daemonName); Common::RequestManager::get()->sendRequest0(daemonCon.get(), boost::bind(&DaemonStatusRequestHandler::requestFinished, this, _1)); } catch(Net::Exception &e) { Common::XmlPacket ret; ret.setType("Error"); ret.add("ErrorCode", e.getErrorCode()); ret.add("SubCode", e.getSubCode()); ret.add("SubSubCode", e.getSubSubCode()); ret.add("Where", e.getWhere()); sendPacket(ret); } } void DaemonStatusRequestHandler::requestFinished(Common::Request &request) { try { sendPacket(request.getResult()); } catch(Net::Exception &e) { Common::XmlPacket ret; ret.setType("Error"); ret.add("ErrorCode", e.getErrorCode()); ret.add("SubCode", e.getSubCode()); ret.add("SubSubCode", e.getSubSubCode()); ret.add("Where", e.getWhere()); sendPacket(ret); } signalFinished(); } } } }