// This file may be redistributed and modified only under the terms of
// the GNU Lesser General Public License (See COPYING for details).
// Copyright (C) 2000 Stefanus Du Toit

#include <Atlas/Message/DecoderBase.h>

namespace Atlas { namespace Message {

DecoderBase::DecoderBase()
{
}

void DecoderBase::streamBegin()
{
    state.push(STATE_STREAM);
}

void DecoderBase::streamMessage(const Map&)
{
    Element::MapType m;
    maps.push(m);
    state.push(STATE_MAP);
}

void DecoderBase::streamEnd()
{
    state.pop();
}

void DecoderBase::mapItem(const std::string& name, const Map&)
{
    Element::MapType m;
    names.push(name);
    maps.push(m);
    state.push(STATE_MAP);
}

void DecoderBase::mapItem(const std::string& name, const List&)
{
    Element::ListType l;
    names.push(name);
    lists.push(l);
    state.push(STATE_LIST);
}
    
void DecoderBase::mapItem(const std::string& name, long i)
{
    maps.top()[name] = i;
}
    
void DecoderBase::mapItem(const std::string& name, double d)
{
    maps.top()[name] = d;
}
    
void DecoderBase::mapItem(const std::string& name, const std::string& s)
{
    maps.top()[name] = s;
}

void DecoderBase::mapEnd()
{
    Element::MapType map = maps.top();
    maps.pop();
    state.pop();
    switch (state.top()) {
        case STATE_MAP:
            maps.top()[names.top()] = map;
            names.pop();
            break;
        case STATE_LIST:
            lists.top().insert(lists.top().end(), map);
            break;
        case STATE_STREAM:
            objectArrived(map);
            break;
    }
}
  
void DecoderBase::listItem(const Map&)
{
    Element::MapType map;
    maps.push(map);
    state.push(STATE_MAP);
}
    
void DecoderBase::listItem(const List&)
{
    Element::ListType list;
    lists.push(list);
    state.push(STATE_LIST);
}
    
void DecoderBase::listItem(long i)
{
    lists.top().push_back(i);
}

void DecoderBase::listItem(double d)
{
    lists.top().push_back(d);
}
    
void DecoderBase::listItem(const std::string& s)
{
    lists.top().push_back(s);
}
    
void DecoderBase::listEnd()
{
    Element::ListType list = lists.top();
    lists.pop();
    state.pop();
    switch (state.top()) {
        case STATE_MAP:
            maps.top()[names.top()] = list;
            names.pop();
            break;
        case STATE_LIST:
            lists.top().push_back(list);
            break;
        case STATE_STREAM:
            // XXX - report error?
            break;
    }
}
    
} } // namespace Atlas::Message