libanetd/example/anetd.cpp

/*
 * Example Client for libanetd
 * Copyright (C) 2012 Justin Hammond
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 */


// Boost
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/shared_ptr.hpp>

#include "anetd/anetd.hpp"
#include "anetd/LogClass.hpp"

using namespace DynamX::anetd;
using namespace DynamX::Logging;

class printer
{

public:
  printer (boost::asio::io_service & io) :
    timer1_ (io, boost::posix_time::seconds (1)),
    count_ (0)
  {

    timer1_.async_wait (boost::bind (&printer::print1, this));


  }


   ~printer ()
  {

    LogDebug(boost::str(boost::format("Final count is %1%") % count_));

  }


  void print1 ()
  {

    if (count_ < 20)

      {

	LogDebug(boost::str(boost::format("Timer 1: %1%") % count_));

	++count_;


	timer1_.expires_at (timer1_.expires_at () +
			    boost::posix_time::seconds (1));

	timer1_.
	  async_wait (boost::bind (&printer::print1, this));

      }

  }


private:

  boost::asio::deadline_timer timer1_;


  int count_;

};

void HTTPCallback(http_response *response) {
	LogDebug(response->getStatus());
}

		class MyLogImpl : public i_LogImpl
		{
public:
			friend class Log;

			MyLogImpl( std::string const& _filename, bool const _bConsoleOutput, LogLevel const _saveLevel): i_LogImpl(_filename,_bConsoleOutput,_saveLevel ) {
				std::cout << "start" << std::endl;
			};
			~MyLogImpl() {};
			private:
			void Write( LogLevel _level, std::string message ) { std::cout << message << std::endl; };
			void SetLoggingState( LogLevel _saveLevel) {}
			void SetLogFileName( std::string _filename ){}

			LogLevel m_saveLevel;
			bool m_bConsoleOutput;
		};

// Application entry point.
int
main (int argc, char *argv[])
{

  //Log::SetLoggingClass(new MyLogImpl("", true, LogLevel_Error));
  Log::Create("", true, LogLevel_Debug);



  // Initialize default settings.
  //std::string server = "https://www.google.com/search";
  //server = "http://10.1.1.1/Services.asp";
  std::string server = "http://weather.yahooapis.com/forecastrss?w=2502265&u=c";

  boost::asio::io_service io;
  printer p(io);


  // Ask for the server URL if one wasn't read from command line arguments.
  if (server.empty ())

    {

      std::cout << boost::this_thread::get_id() << " " << "Please, specify the server URL: ";

      std::cin >> server;

    }


  boost::shared_ptr < http_engine > transmitter_block;
  http_response_file response;
  response.setHTTPAuth("User", "password");
  response.setURL(server);
  // Initialize the transmitter block.
  transmitter_block =
    boost::shared_ptr < http_engine > (new http_engine (&io));
  transmitter_block->setProxyAuth("User", "password");
  transmitter_block->setCallback(boost::bind(HTTPCallback, _1));
  transmitter_block->Starttransfer (&response);

  io.run();
  transmitter_block->Status.wait();
  std::cout << transmitter_block->Status.get()->getStatus() << std::endl;
  std::cout << transmitter_block->Status.get()->getDescription() << std::endl;


  return 0;

}