Transport.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_http_Transport_hpp
#define anna_http_Transport_hpp

#include <anna/core/DataBlock.hpp>

#include <anna/comm/Transport.hpp>
#include <anna/comm/TransportFactory.hpp>
#include <anna/comm/TransportFactoryImpl.hpp>

#include <anna/http/internal/Tokenizer.hpp>
#include <anna/http/Message.hpp>

namespace anna {

namespace http {

class EncodedBlock;

namespace parser {
class Abstract;
}

class Transport : public comm::Transport {
public:
  Transport();

  virtual ~Transport() {;}

  int getContentLength() const { return a_contentLength; }

  http::Message* getInputMessage() noexcept(false);

  void setContentLength(const int contentLength) noexcept(false) { a_contentLength = contentLength; }

  void setBodyOffset(const int bodyOffset) noexcept(false) { a_bodyOffset = bodyOffset; }

  void clear() ;

  const http::Message* externalDecode(const char* buffer, const int length) noexcept(false);

  http::Message* allocateInputMessage(const Message::Type::_v type) noexcept(false);

  EncodedBlock* getEncodedBlock() ;

  const Tokenizer& split(const Token& token) noexcept(false);

  const Tokenizer& split(const Token& token, const char* separator) noexcept(false);

  const Tokenizer& split(const Token& token, const char separator) noexcept(false);

  static const char* className() { return "anna::http::Transport"; }

  static comm::TransportFactory& getFactory() { return st_factory; }

private:
  //-------------------------------------------------------------------------------------
  // - a_parser: Analizador del mensaje HTTP. Realiza un analisis en profundidad para
  // interpretar el contenido del mensaje.
  // - a_contentLenth: Tamaño indicado por la etiqueta HTTP Content-length.
  // - a_bodyOffset: Indica el desplazamiento que hay que aplicar en http::Transport::decode
  // para direccionar el contenido del mensaje HTTP.
  // - a_result: El decode nos obliga a devolver un DataBlock => devolvemos el
  // a_inputMessage que nos dara la direccion al http::Message al invocar a
  // DataBlock::getData.
  // - a_haveToClear: Indica si el metodo calculeSize debe iniciar el estado de la instancia.
  // - a_inputMessage: Instancia del mensaje obtenida al realizar el analisis detallado
  // del ultimo mensaje recibido.
  //--------------------------------------------------------------------------------------
  const parser::Abstract* a_parser;
  int a_contentLength;
  int a_bodyOffset;
  DataBlock a_result;
  bool a_haveToClear;
  http::Message* a_inputMessage;
  Tokenizer a_fullScope;
  Tokenizer a_lineScope;
  EncodedBlock* a_encodedBlock;
  int a_lastChunkedByte;
  const DataBlock* a_fullMessage;

  static comm::TransportFactoryImpl <http::Transport> st_factory;

  void setParserState(const parser::Abstract* parser) noexcept(false);

  int calculeSize(const DataBlock&) noexcept(false);
  const comm::Message* decode(const DataBlock&) noexcept(false);
  const DataBlock& code(comm::Message&) noexcept(false);

  /*
     static const Token* tryRequest (const Tokenizer&) ;
     static const Token* tryResponse (const Tokenizer&) ;
  */
  friend class anna::Allocator <http::Transport>;
  friend class parser::Abstract;
};

}
}
#endif