construct/include/ircd/client.h

/*
 *  charybdis: A useful ircd.
 *  client.h: The ircd client header.
 *
 *  Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center
 *  Copyright (C) 1996-2002 Hybrid Development Team
 *  Copyright (C) 2002-2004 ircd-ratbox development team
 *  Copyright (C) 2005 William Pitcock and Jilles Tjoelker
 *  Copyright (C) 2005-2016 Charybdis Development Team
 *
 *  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; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  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
 */

#pragma once
#define HAVE_IRCD_CLIENT_H

namespace ircd {

IRCD_EXCEPTION(ircd::error, client_error)
IRCD_EXCEPTION(client_error, broken_pipe)
IRCD_EXCEPTION(client_error, disconnected)

struct socket;
struct client
{
	struct init;

	using host_port_pair = std::pair<std::string, uint16_t>;
	using host_port = IRCD_WEAK_T(host_port_pair);
	using list = std::list<client *>;

	static list clients;

	string_view type;
	unique_const_iterator<list> clit;
	std::shared_ptr<socket> sock;

	virtual bool serve();
	bool main() noexcept;

  public:
	client(std::shared_ptr<socket>);
	client(const host_port &, const seconds &timeout = 5s);
	client();
	client(client &&) = delete;
	client(const client &) = delete;
	client &operator=(client &&) = delete;
	client &operator=(const client &) = delete;
	virtual ~client() noexcept;
};

struct client::init
{
	init();
	~init() noexcept;
};

client::host_port remote_addr(const client &);
client::host_port local_addr(const client &);
std::string string(const client::host_port &);
const auto &host(const client::host_port &);
const auto &port(const client::host_port &);

const char *write(client &, const char *&start, const char *const &stop);
char *read(client &, char *&start, char *const &stop);
string_view readline(client &, char *&start, char *const &stop);

http::response::write_closure write_closure(client &);
parse::read_closure read_closure(client &);

std::shared_ptr<client> add_client(std::shared_ptr<socket>);  // Creates a client.

} // namespace ircd

inline const auto &
ircd::port(const client::host_port &host_port)
{
	return host_port.second;
}

inline const auto &
ircd::host(const client::host_port &host_port)
{
	return host_port.first;
}