#ifndef QPID_AMQP_MESSAGEREADER_H
#define QPID_AMQP_MESSAGEREADER_H

/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */

#include "qpid/amqp/CharSequence.h"
#include "qpid/amqp/Reader.h"
#include "qpid/amqp/ListReader.h"
#include "qpid/types/Variant.h"
#include "qpid/CommonImportExport.h"

namespace qpid {
namespace amqp {

/**
 * Reader for an AMQP 1.0 message
 */
class MessageReader : public Reader
{
  public:
    QPID_COMMON_EXTERN MessageReader();

    //header, properties, amqp-sequence, amqp-value
    QPID_COMMON_EXTERN bool onStartList(uint32_t, const CharSequence&, const Descriptor*);
    QPID_COMMON_EXTERN void onEndList(uint32_t, const Descriptor*);

    //delivery-annotations, message-annotations, application-headers, amqp-value
    QPID_COMMON_EXTERN bool onStartMap(uint32_t, const CharSequence&, const Descriptor*);
    QPID_COMMON_EXTERN void onEndMap(uint32_t, const Descriptor*);

    //data, amqp-value
    QPID_COMMON_EXTERN void onBinary(const CharSequence&, const Descriptor*);

    //amqp-value
    QPID_COMMON_EXTERN void onNull(const Descriptor*);
    QPID_COMMON_EXTERN void onString(const CharSequence&, const Descriptor*);
    QPID_COMMON_EXTERN void onSymbol(const CharSequence&, const Descriptor*);
    QPID_COMMON_EXTERN void onBoolean(bool, const Descriptor*);
    QPID_COMMON_EXTERN void onUByte(uint8_t, const Descriptor*);
    QPID_COMMON_EXTERN void onUShort(uint16_t, const Descriptor*);
    QPID_COMMON_EXTERN void onUInt(uint32_t, const Descriptor*);
    QPID_COMMON_EXTERN void onULong(uint64_t, const Descriptor*);
    QPID_COMMON_EXTERN void onByte(int8_t, const Descriptor*);
    QPID_COMMON_EXTERN void onShort(int16_t, const Descriptor*);
    QPID_COMMON_EXTERN void onInt(int32_t, const Descriptor*);
    QPID_COMMON_EXTERN void onLong(int64_t, const Descriptor*);
    QPID_COMMON_EXTERN void onFloat(float, const Descriptor*);
    QPID_COMMON_EXTERN void onDouble(double, const Descriptor*);
    QPID_COMMON_EXTERN void onUuid(const CharSequence&, const Descriptor*);
    QPID_COMMON_EXTERN void onTimestamp(int64_t, const Descriptor*);
    QPID_COMMON_EXTERN bool onStartArray(uint32_t, const CharSequence&, const Constructor&, const Descriptor*);
    QPID_COMMON_EXTERN void onEndArray(uint32_t, const Descriptor*);
    QPID_COMMON_EXTERN void onDescriptor(const Descriptor&, const char*);

    //header:
    virtual void onDurable(bool) = 0;
    virtual void onPriority(uint8_t) = 0;
    virtual void onTtl(uint32_t) = 0;
    virtual void onFirstAcquirer(bool) = 0;
    virtual void onDeliveryCount(uint32_t) = 0;

    //properties:
    virtual void onMessageId(uint64_t) = 0;
    virtual void onMessageId(const CharSequence&, qpid::types::VariantType) = 0;
    virtual void onUserId(const CharSequence&) = 0;
    virtual void onTo(const CharSequence&) = 0;
    virtual void onSubject(const CharSequence&) = 0;
    virtual void onReplyTo(const CharSequence&) = 0;
    virtual void onCorrelationId(uint64_t) = 0;
    virtual void onCorrelationId(const CharSequence&, qpid::types::VariantType) = 0;
    virtual void onContentType(const CharSequence&) = 0;
    virtual void onContentEncoding(const CharSequence&) = 0;
    virtual void onAbsoluteExpiryTime(int64_t) = 0;
    virtual void onCreationTime(int64_t) = 0;
    virtual void onGroupId(const CharSequence&) = 0;
    virtual void onGroupSequence(uint32_t) = 0;
    virtual void onReplyToGroupId(const CharSequence&) = 0;

    virtual void onApplicationProperties(const CharSequence&) = 0;
    virtual void onDeliveryAnnotations(const CharSequence&) = 0;
    virtual void onMessageAnnotations(const CharSequence&) = 0;
    virtual void onBody(const CharSequence&, const Descriptor&) = 0;
    virtual void onBody(const qpid::types::Variant&, const Descriptor&) = 0;
    virtual void onFooter(const CharSequence&) = 0;

    QPID_COMMON_EXTERN CharSequence getBareMessage() const;

  private:
    /*
    class DurableReader : public Reader
    {
      public:
        DurableReader(MessageReader&);
        void onBoolean(bool v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class PriorityReader : public Reader
    {
      public:
        PriorityReader(MessageReader&);
        void onUByte(uint8_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class TtlReader : public Reader
    {
      public:
        TtlReader(MessageReader&);
        void onUInt(uint32_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class FirstAcquirerReader : public Reader
    {
      public:
        FirstAcquirerReader(MessageReader&);
        void onBoolean(bool v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class DeliveryCountReader : public Reader
    {
      public:
        DeliveryCountReader(MessageReader&);
        void onUInt(uint32_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };

    class MessageIdReader : public Reader
    {
      public:
        MessageIdReader(MessageReader&);
        void onUuid(const qpid::types::Uuid& v, const Descriptor*);
        void onULong(uint64_t v, const Descriptor*);
        void onString(const CharSequence& v, const Descriptor*);
        void onBinary(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class UserIdReader : public Reader
    {
      public:
        UserIdReader(MessageReader&);
        void onBinary(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class ToReader : public Reader
    {
      public:
        ToReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class SubjectReader : public Reader
    {
      public:
        SubjectReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class ReplyToReader : public Reader
    {
      public:
        ReplyToReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class CorrelationIdReader : public Reader
    {
      public:
        CorrelationIdReader(MessageReader&);
        void onUuid(const qpid::types::Uuid& v, const Descriptor*);
        void onULong(uint64_t v, const Descriptor*);
        void onString(const CharSequence& v, const Descriptor*);
        void onBinary(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class ContentTypeReader : public Reader
    {
      public:
        ContentTypeReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class ContentEncodingReader : public Reader
    {
      public:
        ContentEncodingReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class AbsoluteExpiryTimeReader : public Reader
    {
      public:
        AbsoluteExpiryTimeReader(MessageReader&);
        void onTimestamp(int64_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class CreationTimeReader : public Reader
    {
      public:
        CreationTimeReader(MessageReader&);
        void onTimestamp(int64_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class GroupIdReader : public Reader
    {
      public:
        GroupIdReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class GroupSequenceReader : public Reader
    {
      public:
        GroupSequenceReader(MessageReader&);
        void onUInt(uint32_t v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    class ReplyToGroupIdReader : public Reader
    {
      public:
        ReplyToGroupIdReader(MessageReader&);
        void onString(const CharSequence& v, const Descriptor*);
      private:
        MessageReader& parent;
    };
    */

    class HeaderReader : public Reader //public ListReader
    {
      public:
        //Reader& getReader(size_t index);

        HeaderReader(MessageReader&);
        void onBoolean(bool v, const Descriptor*);  // durable, first-acquirer
        void onUByte(uint8_t v, const Descriptor*); // priority
        void onUInt(uint32_t v, const Descriptor*); // ttl, delivery-count
        void onNull(const Descriptor*);
      private:
        MessageReader& parent;
        size_t index;
    };
    class PropertiesReader : public Reader //public ListReader
    {
      public:
        //Reader& getReader(size_t index);

        PropertiesReader(MessageReader&);
        void onUuid(const CharSequence& v, const Descriptor*); // message-id, correlation-id
        void onULong(uint64_t v, const Descriptor*); // message-id, correlation-id
        void onBinary(const CharSequence& v, const Descriptor*); // message-id, correlation-id, user-id
        void onString(const CharSequence& v, const Descriptor*); // message-id, correlation-id, group-id, reply-to-group-id, subject, to, reply-to
        void onSymbol(const CharSequence& v, const Descriptor*); // content-type, content-encoding
        void onTimestamp(int64_t v, const Descriptor*); // absolute-expiry-time, creation-time
        void onUInt(uint32_t v, const Descriptor*); // group-sequence
        void onNull(const Descriptor*);
      private:
        MessageReader& parent;
        size_t index;
    };
    HeaderReader headerReader;
    PropertiesReader propertiesReader;
    Reader* delegate;
    CharSequence bare;
};
}} // namespace qpid::amqp

#endif  /*!QPID_AMQP_MESSAGEREADER_H*/