/*
	Copyright (C) 1999-2017 Claude SIMON (http://q37.info/contact/).

	This file is part of the Epeios framework.

	The Epeios framework is free software: you can redistribute it and/or
	modify it under the terms of the GNU Affero General Public License as
	published by the Free Software Foundation, either version 3 of the
	License, or (at your option) any later version.

	The Epeios framework 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
	Affero General Public License for more details.

	You should have received a copy of the GNU Affero General Public License
	along with the Epeios framework.  If not, see <http://www.gnu.org/licenses/>
*/

// Client-Server Devices CoMmoN

#ifndef CSDCMN__INC
# define CSDCMN__INC

# define CSDCMN_NAME		"CSDCMN"

# if defined( E_DEBUG ) && !defined( CSDCMN_NODBG )
#  define CSDCMN_DBG
# endif

# include "err.h"

# include "bso.h"
# include "tol.h"
# include "flw.h"
# include "str.h"
# include "dtfptb.h"

namespace csdcmn {
	typedef bso::uint__ sVersion;

	qCDEF( sVersion, UndefinedVersion, BSO_UINT_MAX );

	void SendProtocol(
		const char *Id,
		sVersion Version,
		flw::oflow__ &Flow );

	sVersion GetProtocolVersion(
		const char *Id,
		flw::iflow__ &Flow );	// If 'UndefinedVersion' is returned, then the protocol is not the good one, or the content of the flow is not valid.

	// Facilities.

	inline const str::dString &Get_(
		flw::sRFlow &Flow,
		str::dString &String )
	{
		bso::sSize Size = 0;
		
		dtfptb::VGet( Flow, Size );

		while ( Size-- )
			String.Append( Flow.Get() );

		return String;
	}

	inline const str::dString &Get(
		flw::sRFlow &Flow,
		str::dString &String )
	{
		return Get_( Flow, String );
	}

	inline const str::dString &Get(
		flw::sRFlow &Flow,
		str::wString &String )
	{
		return Get_( Flow, String );
	}

	inline void Put_(
		const str::dString &String,
		flw::sWFlow &Flow )
	{
		dtfptb::VPut( String.Amount(), Flow );

		sdr::sRow Row = String.First();

		while ( Row != qNIL ) {
			Flow.Put( String( Row ) );

			Row = String.Next( Row );
		}
	}

	inline void Put(
		const str::dString &String,
		flw::sWFlow &Flow )
	{
		return Put_( String, Flow );
	}

	inline void Put(
		const str::wString &String,
		flw::sWFlow &Flow )
	{
		return Put_( String, Flow );
	}

	inline void Put(
		const char *String,
		flw::sWFlow &Flow )
	{
		return Put_( str::wString( String ), Flow );
	}

	inline void Put(
		char *String,
		flw::sWFlow &Flow )
	{
		return Put( (const char *)String, Flow );
	}

	void Put_(
		const str::dStrings &Strings,
		flw::sWFlow &Flow );

	inline void Put(
		const str::dStrings &Strings,
		flw::sWFlow &Flow )
	{
		return Put_( Strings, Flow );
	}

	inline void Put(
		const str::wStrings &Strings,
		flw::sWFlow &Flow )
	{
		return Put_( Strings, Flow );
	}

	void Get_(
		flw::sRFlow &Flow,
		str::dStrings &Strings );

	inline void Get(
		flw::sRFlow &Flow,
		str::dStrings &Strings )
	{
		Get_( Flow, Strings );
	}

	inline void Get(
		flw::sRFlow &Flow,
		str::wStrings &Strings )
	{
		Get_( Flow, Strings );
	}

	template <typename integer> void Put(
		integer Integer,
		flw::sWFlow &Flow )
	{
		return dtfptb::VPut( Integer, Flow );
	}

	template <typename integer> integer Get(
		flw::sRFlow &Flow,
		integer &Integer )
	{
		return dtfptb::VGet( Flow, Integer );
	}
}

#endif