HumanStream.cxx

Go to the documentation of this file.

/*
 *  HumanStream.cxx
 *  ers
 *
 *  Created by Matthias Wiesmann on 01.12.04.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */
 
#include "ers/HumanStream.h"
#include "ers/ers.h"
#include <assert.h>
 
const char* const ers::HumanStream::KEY = "human";
 
namespace {
  ers::Stream* create_stream( const std::string& protocol, const std::string& uri ) {
    (void)uri;
    if ( protocol == ers::HumanStream::KEY ) { return new ers::HumanStream(); }
    return 0;
  } //
  bool registered =
      ers::StreamFactory::instance()->register_factory( ers::HumanStream::KEY, create_stream );
} // anonymous namespace
 
/** Dumps the content of an issue into a string
 * This class is used internally by the Issue class to produce then description field.
 * \param issue_ptr the Issue to serialise
 * \return string description
 */
 
std::string ers::HumanStream::to_string( const Issue* issue_ptr ) throw() {
  try
  {
    HumanStream ers_stream;
    ers_stream.send( issue_ptr );
    std::string str = ers_stream.to_string();
    return str;
  } catch ( std::exception& ex )
  {
    std::string msg = "error while building message " + std::string( ex.what() );
    return msg;
  } //
} // to_string
 
ers::HumanStream::HumanStream() : ers::Stream() {} // HumanStream
ers::HumanStream::HumanStream( const HumanStream& other ) : ers::Stream( other ) {}
ers::HumanStream::~HumanStream() {}
 
/** \return the content of the stream as a string
 */
 
std::string ers::HumanStream::to_string() { return m_out_stream.str(); } // to_string
 
/** Clears the content of the stream
 */
 
void ers::HumanStream::clear() { m_out_stream.str( "" ); } // clear
 
void ers::HumanStream::print_to( std::ostream& stream ) const {
  stream << ers::HumanStream::KEY << ':';
} // print_to
 
void ers::HumanStream::send( const Issue* issue_ptr ) {
  ERS_PRE_CHECK_PTR( issue_ptr );
  if ( m_out_stream )
  {
    try
    {
      const string_map_type* table        = issue_ptr->get_value_table();
      const std::string      message_str  = issue_ptr->get_value( Issue::MESSAGE_KEY );
      const std::string      severity_str = issue_ptr->get_value( Issue::SEVERITY_KEY );
      m_out_stream << "issue: " << message_str << "(" << severity_str << ")[";
      bool first = true;
      for ( string_map_type::const_iterator pos = table->begin(); pos != table->end(); ++pos )
      {
        const std::string& key   = pos->first;
        const std::string& value = pos->second;
        if ( first ) { first = false; }
        else { m_out_stream << ", "; } // first or not
        m_out_stream << key << "=\"" << value << '\"';
      } // for
      m_out_stream << "]";
    } catch ( std::ios_base::failure& ex )
    { throw ers::Issue( ERS_HERE, ers::error, &ex ); } // catch generic I/O errors
  }                                                    // if m_out_stream
} // send