//OpenSCADA file: tprotocols.h
/***************************************************************************
 *   Copyright (C) 2003-2022 by Roman Savochenko, <roman@oscada.org>       *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; version 2 of the License.               *
 *                                                                         *
 *   This program 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 General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#ifndef TPROTOCOLS_H
#define TPROTOCOLS_H

#define SPRT_VER	20		//ProtocolS type modules version
#define SPRT_ID		"Protocol"

#include <string>

#include "tsubsys.h"
#include "ttransports.h"

using std::string;

namespace OSCADA
{

//************************************************
//* TProtocolIn                                  *
//************************************************
class TProtocol;

class TProtocolIn : public TCntrNode
{
    public:
	//Methods
	TProtocolIn( const string &name );
	virtual ~TProtocolIn( );

	string	name( )			{ return mName.c_str(); }
	AutoHD<TTransportIn> &srcTr( )	{ return mSrcTr; }	//Source or return address
	const string &srcAddr( )	{ return mSrcAddr; }
	virtual unsigned waitReqTm( )	{ return 0; }		//Wait for the request timeout, miliseconds, after which call to
								//the input protocol object with the empty message, for like to initiative poll allow.
								//Value '0' used for disable the mechanism and waiting to any data

	virtual void setSrcTr( TTransportIn *vl )	{ mSrcTr = vl; }
	virtual void setSrcAddr( const string &vl )	{ mSrcAddr = vl; }

	int writeTo( const string &data );	//Backward request to source, for asynchronous responds to requests mostly

	// Process input messages
	//  * mess( ) - Send messages by it's point from the transports.
	//              False - for full request came.
	//              True  - for need tail or just wait.
	virtual bool mess( const string &request, string &answer )	{ answer = ""; return false; }

	TProtocol &owner( ) const;

    private:
	//Methods
	const char *nodeName( ) const	{ return mName.c_str(); }

	//Attributes
	string	mName,
		mSrcAddr;	//Source or return address into readable, first line, and service information,
				//second line, for backward requests by writeTo()
	AutoHD<TTransportIn>	mSrcTr;
	int	mThrId;		//Transport's thread id
};

//************************************************
//* TProtocol                                    *
//************************************************ 
class TTransportOut;

class TProtocol: public TModule
{
    public:
	TProtocol( const string &id );
	virtual ~TProtocol( );

	// Addon items list for input protocol addressing
	virtual void itemListIn( vector<string> &ls, const string &curIt = "" );

	// Input protocol
	void list( vector<string> &list ) const		{ chldList(m_pr,list); }
	bool openStat( const string &name ) const	{ return chldPresent(m_pr,name); }
	void open( const string &name, TTransportIn *tr = NULL, const string &sender = "" );
	void close( const string &name );
	AutoHD<TProtocolIn> at( const string &name ) const	{ return chldAt(m_pr,name); }

	// Output protocol
	virtual void outMess( XMLNode &io, TTransportOut &tro )
	{ throw TError(nodePath().c_str(), _("Function '%s' is not supported!"), "outMess"); }

    private:
	//Methods
	virtual TProtocolIn *in_open( const string &id )
	{ throw TError(nodePath().c_str(), _("Function '%s' is not supported!"), "in_open"); }

	//Attributes
	int	m_pr;
};

//************************************************
//* TProtocolS                                   *
//************************************************ 
class TProtocolS : public TSubSYS
{
    public:
	TProtocolS( );
	~TProtocolS( );

	string subName( ) const	{ return _("Transport Protocols"); }
	int subVer( ) const	{ return SPRT_VER; }

	AutoHD<TProtocol> at( const string &iid ) const	{ return modAt(iid); }

	string optDescr( );

    protected:
	void load_( );

    private:
	void cntrCmdProc( XMLNode *opt );       //Control interface command process
};

}

#endif // TPROTOCOLS_H