// created on 30/7/2002 at 00:31

// Npgsql.NpgsqlMediator.cs
//
// Author:
//	Francisco Jr. (fxjrlists@yahoo.com.br)
//
//	Copyright (C) 2002 The Npgsql Development Team
//	npgsql-general@gborg.postgresql.org
//	http://gborg.postgresql.org/project/npgsql/projdisplay.php
//
// 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, or (at your option) any later version.
//
// 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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

using System;
using System.Text;
using System.Collections;

namespace Npgsql
{
    ///<summary>
    /// This class is responsible for serving as bridge between the backend
    /// protocol handling and the core classes. It is used as the mediator for
    /// exchanging data generated/sent from/to backend.
    /// </summary>
    ///

    internal sealed class NpgsqlMediator
    {
        private ArrayList							_errorMessages;
        private	ArrayList							_resultSets;
        private ArrayList							_responses;
        private ArrayList             _notifications;

        private NpgsqlRowDescription	_rd;
        private ArrayList							_rows;


        public NpgsqlMediator()
        {
            _errorMessages = new ArrayList();
            _resultSets = new ArrayList();
            _responses = new ArrayList();
            _notifications = new ArrayList();
        }

        public void Reset()
        {
            _errorMessages.Clear();
            _resultSets.Clear();
            _responses.Clear();
            _notifications.Clear();
            _rd = null;
        }

        public ArrayList Errors
        {
            get
            {
                return _errorMessages;
            }
        }

        public ArrayList Notifications
        {
            get
            {
                return _notifications;
            }

        }

        public void AddNotification(NpgsqlNotificationEventArgs data)
        {
            _notifications.Add(data);
        }



        public void AddCompletedResponse(String response)
        {
            if (_rd != null)
            {
                // Finished receiving the resultset. Add it to the buffer.
                _resultSets.Add(new NpgsqlResultSet(_rd, _rows));

                // Add a placeholder response.
                _responses.Add(null);

                // Discard the RowDescription.
                _rd = null;
            }
            else
            {
                // Add a placeholder resultset.
                _resultSets.Add(null);
                // It was just a non query string. Just add the response.
                _responses.Add(response);
            }

        }

        public void AddRowDescription(NpgsqlRowDescription rowDescription)
        {
            _rd = rowDescription;
            _rows = new ArrayList();
        }

        public void AddAsciiRow(NpgsqlAsciiRow asciiRow)
        {
            _rows.Add(asciiRow);
        }

        public void AddBinaryRow(NpgsqlBinaryRow asciiRow)
        {
            _rows.Add(asciiRow);
        }


        public void AddBackendKeydata(NpgsqlBackEndKeyData keydata)
        {
            _responses.Add(keydata);	//hack
        }

        public ArrayList GetResultSets()
        {
            return _resultSets;
        }

        public ArrayList GetCompletedResponses()
        {
            return _responses;
        }

        public NpgsqlBackEndKeyData GetBackEndKeyData()
        {
            return (NpgsqlBackEndKeyData)_responses[0];	//hack
        }


    }
}