/*
 * Embedded Linux library
 * Copyright (C) 2020  Intel Corporation
 *
 * SPDX-License-Identifier: LGPL-2.1-or-later
 */

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <arpa/inet.h>
#include <netinet/in.h>
#include <linux/types.h>
#include <linux/if_arp.h>
#include <errno.h>
#include <time.h>

#include "log.h"
#include "random.h"
#include "time.h"
#include "time-private.h"
#include "net.h"
#include "timeout.h"
#include "uintset.h"
#include "private.h"
#include "useful.h"
#include "icmp6.h"
#include "netlink.h"
#include "rtnl.h"
#include "dhcp6-private.h"
#include "dhcp6.h"

#define CLIENT_DEBUG(fmt, args...)					\
	l_util_debug(client->debug_handler, client->debug_data,		\
			"%s:%i " fmt, __func__, __LINE__, ## args)

/*
 * RFC8415: Table 1 - Transmission and Retransmission Parameters
 */
#define SOL_MAX_DELAY	1
#define SOL_TIMEOUT	1
#define SOL_MAX_RT	3600
#define INF_MAX_DELAY	1
#define INF_TIMEOUT	1
#define INF_MAX_RT	3600
#define REQ_MAX_RC	10
#define REQ_TIMEOUT	1
#define REQ_MAX_RT	30
#define REN_TIMEOUT	10
#define REN_MAX_RT	600
#define REB_TIMEOUT	10
#define REB_MAX_RT	600
#define REL_TIMEOUT	1
#define REL_MAX_RC	4

enum dhcp6_message_type {
	DHCP6_MESSAGE_TYPE_SOLICIT = 1,
	DHCP6_MESSAGE_TYPE_ADVERTISE = 2,
	DHCP6_MESSAGE_TYPE_REQUEST = 3,
	DHCP6_MESSAGE_TYPE_CONFIRM = 4,
	DHCP6_MESSAGE_TYPE_RENEW = 5,
	DHCP6_MESSAGE_TYPE_REBIND = 6,
	DHCP6_MESSAGE_TYPE_REPLY = 7,
	DHCP6_MESSAGE_TYPE_RELEASE = 8,
	DHCP6_MESSAGE_TYPE_DECLINE = 9,
	DHCP6_MESSAGE_TYPE_RECONFIGURE = 10,
	DHCP6_MESSAGE_TYPE_INFORMATION_REQUEST = 11,
	DHCP6_MESSAGE_TYPE_RELAY_FORW = 12,
	DHCP6_MESSAGE_TYPE_RELAY_REPL = 13,
};

static const char *message_type_to_string(uint8_t t)
{
	switch (t) {
	case DHCP6_MESSAGE_TYPE_SOLICIT:
		return "Solicit";
	case DHCP6_MESSAGE_TYPE_ADVERTISE:
		return "Advertise";
	case DHCP6_MESSAGE_TYPE_REQUEST:
		return "Request";
	case DHCP6_MESSAGE_TYPE_CONFIRM:
		return "Confirm";
	case DHCP6_MESSAGE_TYPE_RENEW:
		return "Renew";
	case DHCP6_MESSAGE_TYPE_REBIND:
		return "Rebind";
	case DHCP6_MESSAGE_TYPE_REPLY:
		return "Reply";
	case DHCP6_MESSAGE_TYPE_RELEASE:
		return "Release";
	case DHCP6_MESSAGE_TYPE_DECLINE:
		return "Decline";
	case DHCP6_MESSAGE_TYPE_RECONFIGURE:
		return "Reconfigure";
	case DHCP6_MESSAGE_TYPE_INFORMATION_REQUEST:
		return "Information-request";
	case DHCP6_MESSAGE_TYPE_RELAY_FORW:
		return "Relay-forward";
	case DHCP6_MESSAGE_TYPE_RELAY_REPL:
		return "Relay-reply";
	default:
		break;
	}

	return "Unknown";
}

static const char *option_to_string(uint16_t o)
{
	switch (o) {
	case DHCP6_OPTION_CLIENT_ID:
		return "CLIENTID";
	case DHCP6_OPTION_SERVER_ID:
		return "SERVERID";
	case DHCP6_OPTION_IA_NA:
		return "IA_NA";
	case DHCP6_OPTION_IA_TA:
		return "IA_TA";
	case DHCP6_OPTION_IA_PD:
		return "IA_PD";
	case DHCP6_OPTION_REQUEST_OPTION:
		return "ORO";
	case DHCP6_OPTION_ELAPSED_TIME:
		return "ELAPSED_TIME";
	case DHCP6_OPTION_PREFERENCE:
		return "PREFERENCE";
	case DHCP6_OPTION_STATUS_CODE:
		return "STATUS_CODE";
	case DHCP6_OPTION_RAPID_COMMIT:
		return "RAPID_COMMIT";
	case DHCP6_OPTION_USER_CLASS:
		return "USER_CLASS";
	case DHCP6_OPTION_VENDOR_CLASS:
		return "VENDOR_CLASS";
	case DHCP6_OPTION_VENDOR_OPTS:
		return "VENDOR_OPTS";
	case L_DHCP6_OPTION_DNS_SERVERS:
		return "DNS_SERVERS";
	case L_DHCP6_OPTION_DOMAIN_LIST:
		return "DOMAIN_LIST";
	case L_DHCP6_OPTION_SNTP_SERVERS:
		return "SNTP_SERVERS";
	case DHCP6_OPTION_INF_RT:
		return "INF_RT";
	case L_DHCP6_OPTION_NTP_SERVER:
		return "NTP_SERVER";
	case DHCP6_OPTION_SOL_MAX_RT:
		return "SOL_MAX_RT";
	case DHCP6_OPTION_INF_MAX_RT:
		return "INF_MAX_RT";
	default:
		break;
	}

	return NULL;
}

/* RFC 8415, Section 21.13, Table 3 */
static const char *status_to_string(uint16_t status)
{
	switch (status) {
	case 0:
		return "Success";
	case 1:
		return "UnspecFail";
	case 2:
		return "NoAddrsAvail";
	case 3:
		return "NoBinding";
	case 4:
		return "NotOnLink";
	case 5:
		return "UseMulticast";
	case 6:
		return "NoPrefixAvail";
	default:
		break;
	}

	return "Unknown";
}

struct dhcp6_message_builder {
	uint16_t options_capacity;
	uint16_t options_pos;
	uint16_t option_start;
	struct dhcp6_message *message;
};

static const size_t OPTION_HEADER_LEN = 4;

static inline size_t next_size(size_t s)
{
	static const size_t mask = (size_t) (-1LL) << 8;
	return (s & mask) + 256;
}

static uint8_t *option_reserve(struct dhcp6_message_builder *builder,
								size_t len)
{
	uint8_t *p;
	size_t options_end;

	options_end = builder->options_pos + len;

	if (options_end > builder->options_capacity) {
		builder->options_capacity =
			next_size(sizeof(struct dhcp6_message) + options_end);
		builder->message =
			l_realloc(builder->message, builder->options_capacity);
	}

	p = builder->message->options + builder->options_pos;
	builder->options_pos = options_end;

	return p;
}

static void option_start(struct dhcp6_message_builder *builder, uint16_t type)
{
	builder->option_start = builder->options_pos;
	l_put_be16(type, option_reserve(builder, OPTION_HEADER_LEN));
}

static void option_finalize(struct dhcp6_message_builder *builder)
{
	uint8_t *p;
	uint16_t len;

	len = builder->options_pos - builder->option_start - OPTION_HEADER_LEN;
	p = builder->message->options + builder->option_start;
	l_put_be16(len, p + 2);
}

static void option_append_uint16(struct dhcp6_message_builder *builder,
					uint16_t type, uint16_t v)
{
	uint8_t *p = option_reserve(builder, OPTION_HEADER_LEN + sizeof(v));

	l_put_be16(type, p);
	l_put_be16(sizeof(v), p + 2);
	l_put_be16(v, p + OPTION_HEADER_LEN);
}

static void option_append_bytes(struct dhcp6_message_builder *builder,
				uint16_t type, const void *bytes, uint16_t len)
{
	uint8_t *p = option_reserve(builder, OPTION_HEADER_LEN + len);

	l_put_be16(type, p);
	l_put_be16(len, p + 2);
	memcpy(p + OPTION_HEADER_LEN, bytes, len);
}

static struct dhcp6_message_builder *dhcp6_message_builder_new(
						enum dhcp6_message_type type,
						uint32_t transaction_id,
						uint16_t options_capacity)
{
	struct dhcp6_message_builder *builder;

	builder = l_new(struct dhcp6_message_builder, 1);

	builder->message =
		(struct dhcp6_message *) l_new(uint8_t,
						sizeof(struct dhcp6_message) +
						options_capacity);
	builder->message->transaction_id = L_CPU_TO_BE32(transaction_id);
	builder->message->msg_type = type;
	builder->options_capacity = options_capacity;

	return builder;
}

static struct dhcp6_message *dhcp6_message_builder_free(
					struct dhcp6_message_builder *builder,
					bool free_message, size_t *out_size)
{
	struct dhcp6_message *ret;

	if (free_message) {
		memset(builder->message, 0,
			sizeof(struct dhcp6_message) + builder->options_pos);
		l_free(builder->message);
		builder->message = NULL;
	}

	ret = builder->message;

	if (out_size)
		*out_size = sizeof(struct dhcp6_message) + builder->options_pos;

	l_free(builder);

	return ret;
}

static void option_append_elapsed_time(struct dhcp6_message_builder *builder,
					uint64_t transaction_start_t)
{
	uint16_t elapsed_time;
	uint64_t time_diff;

	if (!transaction_start_t) {
		/*
		 * Field is set to 0 in the first message in the message
		 * exchange.
		 */
		elapsed_time = 0;
		goto done;
	}

	time_diff = l_time_now() - transaction_start_t;

	if (time_diff < UINT16_MAX * L_USEC_PER_MSEC * 10)
		elapsed_time = l_time_to_msecs(time_diff) / 10;
	else
		elapsed_time = UINT16_MAX;

done:
	option_append_uint16(builder, DHCP6_OPTION_ELAPSED_TIME,
							elapsed_time);
}

enum dhcp6_state {
	DHCP6_STATE_INIT,
	DHCP6_STATE_SOLICITING,
	DHCP6_STATE_REQUESTING_INFORMATION,
	DHCP6_STATE_REQUESTING,
	DHCP6_STATE_BOUND,
	DHCP6_STATE_RENEWING,
	DHCP6_STATE_REBINDING,
	DHCP6_STATE_RELEASING,
};

static const char *dhcp6_state_to_str(enum dhcp6_state s)
{
	switch (s) {
	case DHCP6_STATE_INIT:
		return "Init";
	case DHCP6_STATE_SOLICITING:
		return "Soliciting";
	case DHCP6_STATE_REQUESTING_INFORMATION:
		return "Requesting-Information";
	case DHCP6_STATE_REQUESTING:
		return "Requesting";
	case DHCP6_STATE_BOUND:
		return "Bound";
	case DHCP6_STATE_RENEWING:
		return "Renewing";
	case DHCP6_STATE_REBINDING:
		return "Rebinding";
	case DHCP6_STATE_RELEASING:
		return "Releasing";
	};

	return "Invalid";
}

struct l_dhcp6_client {
	enum dhcp6_state state;

	uint32_t transaction_id;
	uint64_t transaction_start_t;

	struct duid *duid;
	uint16_t duid_len;

	struct l_uintset *request_options;

	uint32_t ifindex;

	struct dhcp6_transport *transport;

	uint64_t attempt_delay;
	uint8_t attempt;

	struct l_timeout *timeout_send;
	struct l_dhcp6_lease *lease;
	struct l_timeout *timeout_lease;

	struct l_icmp6_client *icmp6;

	struct l_netlink *rtnl;
	uint32_t rtnl_add_cmdid;
	struct l_rtnl_address *rtnl_configured_address;

	l_dhcp6_client_event_cb_t event_handler;
	void *event_data;
	l_dhcp6_destroy_cb_t event_destroy;

	uint8_t addr[6];
	uint8_t addr_len;
	uint8_t addr_type;

	struct in6_addr ll_address;

	l_dhcp6_debug_cb_t debug_handler;
	l_dhcp6_destroy_cb_t debug_destroy;
	void *debug_data;

	bool stateless : 1;
	bool nodelay : 1;
	bool nora : 1;
	bool request_pd : 1;
	bool request_na : 1;
	bool no_rapid_commit : 1;
	bool lla_randomized : 1;
};

static const struct in6_addr all_nodes = DHCP6_ADDR_LINKLOCAL_ALL_NODES;

static void request_options_foreach(uint32_t opt, void *user_data)
{
	struct dhcp6_message_builder *builder = user_data;

	l_put_be16(opt, option_reserve(builder, 2));
}

static void option_append_option_request(struct dhcp6_message_builder *builder,
					const struct l_uintset *request_options,
					enum dhcp6_state state)
{
	struct l_uintset *clone = NULL;

	option_start(builder, DHCP6_OPTION_REQUEST_OPTION);

	switch (state) {
	case DHCP6_STATE_SOLICITING:
	case DHCP6_STATE_REQUESTING:
		clone = l_uintset_clone(request_options);
		l_uintset_put(clone, DHCP6_OPTION_SOL_MAX_RT);
		break;
	case DHCP6_STATE_REQUESTING_INFORMATION:
		clone = l_uintset_clone(request_options);
		l_uintset_put(clone, DHCP6_OPTION_INF_RT);
		l_uintset_put(clone, DHCP6_OPTION_INF_MAX_RT);
		break;
	case DHCP6_STATE_INIT:
	case DHCP6_STATE_BOUND:
	case DHCP6_STATE_RENEWING:
	case DHCP6_STATE_REBINDING:
	case DHCP6_STATE_RELEASING:
		break;
	}

	l_uintset_foreach(clone ? clone : request_options,
				request_options_foreach, builder);
	option_finalize(builder);

	l_uintset_free(clone);
}

static int option_append_ia_common(struct l_dhcp6_client *client,
				struct dhcp6_message_builder *builder,
				uint16_t option)
{
	option_start(builder, option);

	/*
	 * RFC 7844, Section 4.5 recommends:
	 * "Clients MAY meet the privacy, uniqueness, and stability
	 * requirements of the IAID by constructing it as the combination of 1
	 * octet encoding the interface number in the system, and the first 3
	 * octets of the link-layer address."
	 *
	 * For ethernet, the first three octets are the oui of the vendor, so
	 * we use the last octets instead.  Also, since we currently do not
	 * request more than one address, we simply use the last 4 octets of
	 * our link layer address
	 */

	switch (client->addr_type) {
	case ARPHRD_ETHER:
		memcpy(option_reserve(builder, 4), client->addr + 2, 4);
		break;
	default:
		L_WARN_ON(true);
		return -EOPNOTSUPP;
	}

	return 0;
}

static void option_append_ia_na(struct l_dhcp6_client *client,
				struct dhcp6_message_builder *builder)
{
	void *ia_addr;

	if (option_append_ia_common(client, builder, DHCP6_OPTION_IA_NA) < 0)
		return;

	l_put_be32(0, option_reserve(builder, 4));
	l_put_be32(0, option_reserve(builder, 4));

	if (!client->lease)
		goto done;

	ia_addr = option_reserve(builder, 28);
	l_put_be16(DHCP6_OPTION_IA_ADDR, ia_addr);
	l_put_be16(24, ia_addr + 2);
	memcpy(ia_addr + 4, client->lease->ia_na.info.addr, 16);
	l_put_be32(client->lease->ia_na.info.preferred_lifetime, ia_addr + 20);
	l_put_be32(client->lease->ia_na.info.valid_lifetime, ia_addr + 24);

done:
	option_finalize(builder);
}

static void option_append_ia_pd(struct l_dhcp6_client *client,
				struct dhcp6_message_builder *builder)
{
	if (option_append_ia_common(client, builder, DHCP6_OPTION_IA_PD) < 0)
		return;

	l_put_be32(0, option_reserve(builder, 4));
	l_put_be32(0, option_reserve(builder, 4));

	option_finalize(builder);
}

static void client_enable_option(struct l_dhcp6_client *client,
						enum l_dhcp6_option option)
{
	const char *s;

	switch (option) {
	case L_DHCP6_OPTION_DNS_SERVERS:
	case L_DHCP6_OPTION_DOMAIN_LIST:
	case L_DHCP6_OPTION_SNTP_SERVERS:
	case L_DHCP6_OPTION_NTP_SERVER:
		break;
	default:
		s = option_to_string(option);

		if (s)
			CLIENT_DEBUG("Ignore request option: %s", s);
		else
			CLIENT_DEBUG("Ignore request option: %u", option);

		return;
	}

	l_uintset_put(client->request_options, option);
}

static void client_duid_generate_addr_plus_time(struct l_dhcp6_client *client)
{
	uint16_t duid_len;
	uint32_t time_stamp;
	static const time_t JAN_FIRST_2000_IN_SEC = 946684800UL;

	if (client->duid)
		return;

	duid_len = 2 + 2 + 4 + client->addr_len;

	/*
	 * The time value is the time that the DUID is generated, represented in
	 * seconds since midnight (UTC), January 1, 2000, modulo 2^32
	 */
	time_stamp = (time(NULL) - JAN_FIRST_2000_IN_SEC) & 0xFFFFFFFFU;

	client->duid = l_malloc(duid_len);
	client->duid_len = duid_len;

	client->duid->type = L_CPU_TO_BE16(DUID_TYPE_LINK_LAYER_ADDR_PLUS_TIME);
	l_put_be16(client->addr_type, client->duid->identifier);
	l_put_be32(time_stamp, client->duid->identifier + 2);
	memcpy(client->duid->identifier + 2 + 4, client->addr,
							client->addr_len);
}

static void client_duid_generate_addr(struct l_dhcp6_client *client)
{
	if (client->duid)
		return;

	/*
	 * RFC 7844, Section 4.3 Client Identifier DHCPv6 Option:
	 * "When using the anonymity profile in conjunction with randomized
	 * link-layer addresses, DHCPv6 clients MUST use DUID format
	 * number 3 -- link-layer address.  The value of the link-layer
	 * address should be the value currently assigned to the interface.
	 */
	client->duid_len = 4 + client->addr_len;
	client->duid = l_malloc(client->duid_len);
	client->duid->type = L_CPU_TO_BE16(DUID_TYPE_LINK_LAYER_ADDR);
	l_put_be16(client->addr_type, client->duid->identifier);
	memcpy(client->duid->identifier + 2, client->addr, client->addr_len);
}

static void set_retransmission_delay(struct l_dhcp6_client *client,
					uint32_t irt_sec, uint32_t mrt_sec,
					uint8_t mrc)
{
	uint64_t irt_ms;
	uint64_t mrt_ms;

	if (mrc && mrc < client->attempt)
		return;

	/* TODO add check for duration */

	irt_ms = irt_sec * L_MSEC_PER_SEC;
	mrt_ms = mrt_sec * L_MSEC_PER_SEC;

	/* RFC 8415, Section 15:
	 * RT for the first message transmission is based on IRT:
	 * 	RT = IRT + RAND*IRT
	 *
	 * RT for each subsequent message transmission is based on the
	 * previous value of RT:
	 * 	RT = 2*RTprev + RAND*RTprev
	 *
	 * MRT specifies an upper bound on the value of RT (disregarding the
	 * randomization added by the use of RAND).  If MRT has a value of 0,
	 * there is no upper limit on the value of RT.  Otherwise:
	 * 	if (RT > MRT)
	 * 		RT = MRT + RAND*MRT
	 */
	if (!client->attempt_delay) {
		client->attempt_delay = _time_fuzz_msecs(irt_ms);

		/*
		 * RFC 8415, Section 18.2.1:
		 * ... the first RT MUST be selected to be strictly greater
		 * than IRT by choosing RAND to be strictly greater than 0.
		 */
		if (client->state == DHCP6_STATE_SOLICITING &&
				client->attempt_delay < irt_ms)
			client->attempt_delay += irt_ms / 10;
	} else {
		if (mrt_ms && client->attempt_delay > mrt_ms)
			client->attempt_delay = _time_fuzz_msecs(mrt_ms);
		else
			client->attempt_delay +=
					_time_fuzz_msecs(client->attempt_delay);
	}

	l_timeout_modify_ms(client->timeout_send, client->attempt_delay);
}

static struct dhcp6_message *dhcp6_client_build_message(
						struct l_dhcp6_client *client,
						enum dhcp6_message_type type,
						size_t *out_len)
{
	struct dhcp6_message_builder *builder;

	builder = dhcp6_message_builder_new(type, client->transaction_id, 128);

	option_append_bytes(builder, DHCP6_OPTION_CLIENT_ID,
					client->duid, client->duid_len);

	if (type == DHCP6_MESSAGE_TYPE_REQUEST ||
			type == DHCP6_MESSAGE_TYPE_RENEW)
		option_append_bytes(builder, DHCP6_OPTION_SERVER_ID,
					client->lease->server_id,
					client->lease->server_id_len);

	if (client->request_na)
		option_append_ia_na(client, builder);

	option_append_option_request(builder, client->request_options,
						client->state);

	option_append_elapsed_time(builder, client->transaction_start_t);

	if (type == DHCP6_MESSAGE_TYPE_SOLICIT && !client->no_rapid_commit)
		option_append_bytes(builder, DHCP6_OPTION_RAPID_COMMIT,
						NULL, 0);

	if (client->request_pd)
		option_append_ia_pd(client, builder);

	return dhcp6_message_builder_free(builder, false, out_len);
}

static int dhcp6_client_send_solicit(struct l_dhcp6_client *client)
{
	L_AUTO_FREE_VAR(struct dhcp6_message *, solicit);
	size_t solicit_len;

	CLIENT_DEBUG("");

	solicit = dhcp6_client_build_message(client,
						DHCP6_MESSAGE_TYPE_SOLICIT,
						&solicit_len);
	return client->transport->send(client->transport, &all_nodes,
						solicit, solicit_len);
}

static int dhcp6_client_send_request(struct l_dhcp6_client *client)
{
	L_AUTO_FREE_VAR(struct dhcp6_message *, request);
	size_t request_len;

	CLIENT_DEBUG("");

	request = dhcp6_client_build_message(client,
						DHCP6_MESSAGE_TYPE_REQUEST,
						&request_len);
	return client->transport->send(client->transport, &all_nodes,
							request, request_len);
}

static int dhcp6_client_send_information_request(struct l_dhcp6_client *client)
{
	static const struct in6_addr all_nodes = DHCP6_ADDR_LINKLOCAL_ALL_NODES;
	struct dhcp6_message_builder *builder;
	L_AUTO_FREE_VAR(struct dhcp6_message *, information_request);
	size_t information_request_len;
	int error;

	CLIENT_DEBUG("");

	builder = dhcp6_message_builder_new(
					DHCP6_MESSAGE_TYPE_INFORMATION_REQUEST,
					client->transaction_id, 128);

	option_append_elapsed_time(builder, client->transaction_start_t);
	option_append_option_request(builder, client->request_options,
					DHCP6_STATE_REQUESTING_INFORMATION);

	information_request = dhcp6_message_builder_free(builder, false,
						&information_request_len);

	error = client->transport->send(client->transport, &all_nodes,
						information_request,
						information_request_len);
	return error;
}

static int dhcp6_client_send_renew(struct l_dhcp6_client *client)
{
	L_AUTO_FREE_VAR(struct dhcp6_message *, renew);
	size_t renew_len;

	CLIENT_DEBUG("");

	renew = dhcp6_client_build_message(client,
						DHCP6_MESSAGE_TYPE_RENEW,
						&renew_len);
	return client->transport->send(client->transport, &all_nodes,
						renew, renew_len);
}

static int dhcp6_client_send_rebind(struct l_dhcp6_client *client)
{
	L_AUTO_FREE_VAR(struct dhcp6_message *, rebind);
	size_t rebind_len;

	CLIENT_DEBUG("");

	rebind = dhcp6_client_build_message(client,
						DHCP6_MESSAGE_TYPE_REBIND,
						&rebind_len);
	return client->transport->send(client->transport, &all_nodes,
						rebind, rebind_len);
}

static int dhcp6_client_send_release(struct l_dhcp6_client *client)
{
	return 0;
}

static int dhcp6_client_send_next(struct l_dhcp6_client *client)
{
	int r;

	switch (client->state) {
	case DHCP6_STATE_SOLICITING:
		r = dhcp6_client_send_solicit(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, SOL_TIMEOUT, SOL_MAX_RT, 0);
		break;
	case DHCP6_STATE_REQUESTING_INFORMATION:
		r = dhcp6_client_send_information_request(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, INF_TIMEOUT, INF_MAX_RT, 0);
		break;
	case DHCP6_STATE_REQUESTING:
		r = dhcp6_client_send_request(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, REQ_TIMEOUT, REQ_MAX_RT,
								REQ_MAX_RC);
		break;
	case DHCP6_STATE_RENEWING:
		r = dhcp6_client_send_renew(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, REN_TIMEOUT, REN_MAX_RT, 0);
		break;
	case DHCP6_STATE_REBINDING:
		r = dhcp6_client_send_rebind(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, REB_TIMEOUT, REB_MAX_RT, 0);
		break;
	case DHCP6_STATE_RELEASING:
		r = dhcp6_client_send_release(client);
		if (r < 0)
			return r;

		set_retransmission_delay(client, REL_TIMEOUT, 0, REL_MAX_RC);
		break;
	case DHCP6_STATE_INIT:
	case DHCP6_STATE_BOUND:
		return -EINVAL;
	}

	/* Set after the first successfully sent message. */
	if (!client->transaction_start_t)
		client->transaction_start_t = l_time_now();

	client->attempt += 1;
	return 0;
}

static inline void dhcp6_client_event_notify(struct l_dhcp6_client *client,
						enum l_dhcp6_client_event event)
{
	if (client->event_handler)
		client->event_handler(client, event, client->event_data);
}

static void dhcp6_client_enter_state(struct l_dhcp6_client *client,
					enum dhcp6_state new_state)
{
	client->state = new_state;
	l_util_debug(client->debug_handler, client->debug_data,
			"Entering state: %s", dhcp6_state_to_str(new_state));
}

static inline void dhcp6_client_new_transaction(struct l_dhcp6_client *client,
						enum dhcp6_state new_state)
{
	client->attempt = 0;
	client->attempt_delay = 0;
	client->transaction_id = l_getrandom_uint32() & 0x00FFFFFFU;
	client->transaction_start_t = 0;

	dhcp6_client_enter_state(client, new_state);
}

static void dhcp6_client_timeout_send(struct l_timeout *timeout,
								void *user_data)
{
	struct l_dhcp6_client *client = user_data;

	CLIENT_DEBUG("");

	if (client->state == DHCP6_STATE_SOLICITING
			&& client->attempt && client->lease) {
		CLIENT_DEBUG("Received a lease during initial request time");
		dhcp6_client_new_transaction(client, DHCP6_STATE_REQUESTING);
	}

	if (dhcp6_client_send_next(client) < 0)
		l_dhcp6_client_stop(client);
}

static void dhcp6_client_lease_expired(struct l_timeout *timeout,
							void *user_data)
{
	struct l_dhcp6_client *client = user_data;

	CLIENT_DEBUG("");

	l_dhcp6_client_stop(client);
	dhcp6_client_event_notify(client, L_DHCP6_CLIENT_EVENT_LEASE_EXPIRED);
}

static void dhcp6_client_t2_expired(struct l_timeout *timeout, void *user_data)
{
	struct l_dhcp6_client *client = user_data;
	uint32_t elapsed =
		l_time_to_msecs(l_time_now() - client->lease->start_time);
	uint32_t valid = l_dhcp6_lease_get_valid_lifetime(client->lease) *
				L_MSEC_PER_SEC;

	CLIENT_DEBUG("");

	dhcp6_client_new_transaction(client, DHCP6_STATE_REBINDING);
	l_timeout_set_callback(client->timeout_lease,
				dhcp6_client_lease_expired, client, NULL);

	if (valid <= elapsed) {
		dhcp6_client_lease_expired(client->timeout_lease, client);
		return;
	}

	l_timeout_modify_ms(client->timeout_lease, valid - elapsed);
}

static void dhcp6_client_t1_expired(struct l_timeout *timeout, void *user_data)
{
	struct l_dhcp6_client *client = user_data;
	uint32_t next_timeout;

	CLIENT_DEBUG("");

	/* timeout_send was destroyed when entering BOUND, re-create */
	client->timeout_send = l_timeout_create_ms(0,
						dhcp6_client_timeout_send,
						client, NULL);
	dhcp6_client_new_transaction(client, DHCP6_STATE_RENEWING);

	if (dhcp6_client_send_next(client) < 0) {
		l_dhcp6_client_stop(client);
		return;
	}

	next_timeout = _dhcp6_lease_get_t2(client->lease) -
					_dhcp6_lease_get_t1(client->lease);
	l_timeout_modify(client->timeout_lease, next_timeout);
	l_timeout_set_callback(client->timeout_lease, dhcp6_client_t2_expired,
					client, NULL);
}

static void dhcp6_client_address_add_cb(int error, uint16_t type,
						const void *data, uint32_t len,
						void *user_data)
{
	struct l_dhcp6_client *client = user_data;

	client->rtnl_add_cmdid = 0;

	if (error < 0 && error != -EEXIST) {
		l_rtnl_address_free(client->rtnl_configured_address);
		client->rtnl_configured_address = NULL;
		CLIENT_DEBUG("Unable to set address on ifindex: %u: %d(%s)",
				client->ifindex, error,
				strerror(-error));
		return;
	}
}

static void dhcp6_client_setup_lease(struct l_dhcp6_client *client,
					uint64_t timestamp)
{
	uint32_t t1 = _dhcp6_lease_get_t1(client->lease);
	uint32_t t2 = _dhcp6_lease_get_t2(client->lease);
	enum l_dhcp6_client_event event;

	client->lease->start_time = timestamp;

	/* TODO: Emit IP_CHANGED if any addresses were removed / added */
	if (L_IN_SET(client->state, DHCP6_STATE_REQUESTING,
				DHCP6_STATE_SOLICITING,
				DHCP6_STATE_REQUESTING_INFORMATION))
		event = L_DHCP6_CLIENT_EVENT_LEASE_OBTAINED;
	else
		event = L_DHCP6_CLIENT_EVENT_LEASE_RENEWED;

	l_timeout_remove(client->timeout_lease);
	client->timeout_lease = NULL;

	/*
	 * Switch over to BOUND state so that l_dhcp6_client_get_lease() will
	 * return the lease properly
	 */
	dhcp6_client_enter_state(client, DHCP6_STATE_BOUND);
	dhcp6_client_event_notify(client, event);

	if (t1 == 0xffffffff || t2 == 0xffffffff) {
		CLIENT_DEBUG("T1 (%u) or T2 (%u) was infinite", t1, t2);
		return;
	}

	client->timeout_lease = l_timeout_create_ms(_time_fuzz_secs(t1, 1),
							dhcp6_client_t1_expired,
							client, NULL);

	if (client->rtnl) {
		struct l_rtnl_address *a;
		L_AUTO_FREE_VAR(char *, ip) =
			l_dhcp6_lease_get_address(client->lease);
		uint8_t prefix_len =
			l_dhcp6_lease_get_prefix_length(client->lease);
		uint32_t p = l_dhcp6_lease_get_preferred_lifetime(client->lease);
		uint32_t v = l_dhcp6_lease_get_valid_lifetime(client->lease);

		a = l_rtnl_address_new(ip, prefix_len);
		l_rtnl_address_set_noprefixroute(a, true);
		l_rtnl_address_set_lifetimes(a, p, v);
		l_rtnl_address_set_expiry(a, timestamp + p * L_USEC_PER_SEC,
						timestamp + v * L_USEC_PER_SEC);

		client->rtnl_add_cmdid =
			l_rtnl_ifaddr_add(client->rtnl, client->ifindex, a,
						dhcp6_client_address_add_cb,
						client, NULL);
		if (client->rtnl_add_cmdid)
			client->rtnl_configured_address = a;
		else {
			l_rtnl_address_free(a);
			CLIENT_DEBUG("Configuring address via RTNL failed");
		}
	}
}

void __dhcp6_option_iter_init(struct dhcp6_option_iter *iter,
				const void *options, size_t len)
{
	memset(iter, 0, sizeof(*iter));
	iter->max = len;
	iter->options = options;
}

bool _dhcp6_option_iter_init(struct dhcp6_option_iter *iter,
				const struct dhcp6_message *message, size_t len)
{
	if (!message)
		return false;

	if (len < sizeof(struct dhcp6_message))
		return false;

	__dhcp6_option_iter_init(iter, message->options,
					len - sizeof(struct dhcp6_message));

	return true;
}

static bool option_next(struct dhcp6_option_iter *iter,
				uint16_t *t, uint16_t *l, const void **v)
{
	uint16_t type;
	uint16_t len;

	while (iter->pos + 4 <= iter->max) {
		type = l_get_be16(iter->options + iter->pos);
		len = l_get_be16(iter->options + iter->pos + 2);

		if (iter->pos + 4 + len > iter->max)
			return false;

		*t = type;
		*l = len;
		*v = &iter->options[iter->pos + 4];

		iter->pos += 4 + len;
		return true;
	}

	return false;
}

bool _dhcp6_option_iter_next(struct dhcp6_option_iter *iter, uint16_t *type,
				uint16_t *len, const void **data)
{
	bool r;
	uint16_t t;
	uint16_t l;
	const void *v;

	r = option_next(iter, &t, &l, &v);

	if (!r)
		return false;

	if (type)
		*type = t;

	if (len)
		*len = l;

	if (data)
		*data = v;

	return true;
}

static int dhcp6_client_validate_message(struct l_dhcp6_client *client,
					bool expect_client_id,
					const struct dhcp6_message *message,
					size_t len)
{
	struct dhcp6_option_iter iter;
	uint16_t t;
	uint16_t l;
	const void *v;
	bool duid_verified = false;
	bool server_id_present = false;
	const char *mstr = message_type_to_string(message->msg_type);

	CLIENT_DEBUG("Validating %s", mstr);

	_dhcp6_option_iter_init(&iter, message, len);

	/* Check for duplicate options and reject the message if it has any */
	while (_dhcp6_option_iter_next(&iter, &t, &l, &v)) {
		struct dhcp6_option_iter seek;
		uint16_t duplicate;

		/*
		 * Refer to RFC 8415, Section 24, Table 4 for what we consider
		 * singleton options.  Note that some implementation still
		 * send multiple non-singleton options
		 * (for example, STATUS_CODE), so we allow these for
		 * interoperability.  We mandate IA_NA, IA_TA and IA_PD to be
		 * singletons
		 */
		switch (t) {
		case DHCP6_OPTION_CLIENT_ID:
		case DHCP6_OPTION_SERVER_ID:
		case DHCP6_OPTION_IA_NA:
		case DHCP6_OPTION_IA_TA:
		case DHCP6_OPTION_IA_PD:
		case DHCP6_OPTION_REQUEST_OPTION:
		case DHCP6_OPTION_ELAPSED_TIME:
		case DHCP6_OPTION_PREFERENCE:
		case DHCP6_OPTION_RAPID_COMMIT:
		case DHCP6_OPTION_USER_CLASS:
		case L_DHCP6_OPTION_DNS_SERVERS:
		case L_DHCP6_OPTION_DOMAIN_LIST:
		case L_DHCP6_OPTION_SNTP_SERVERS:
		case DHCP6_OPTION_INF_RT:
		case L_DHCP6_OPTION_NTP_SERVER:
		case DHCP6_OPTION_SOL_MAX_RT:
		case DHCP6_OPTION_INF_MAX_RT:
			break;
		case DHCP6_OPTION_STATUS_CODE:
		case DHCP6_OPTION_VENDOR_CLASS:
		case DHCP6_OPTION_VENDOR_OPTS:
		default:
			/* Multiples allowed */
			continue;
		}

		memcpy(&seek, &iter, sizeof(struct dhcp6_option_iter));

		while (_dhcp6_option_iter_next(&seek, &duplicate, NULL, NULL)) {
			const char *s;

			if (duplicate != t)
				continue;

			s = option_to_string(t);
			if (s)
				CLIENT_DEBUG("Reject %s: Multiple %s options",
						mstr, s);
			else
				CLIENT_DEBUG("Reject %s: Multiple %u options",
						mstr, t);

			return -EBADMSG;
		}
	}

	_dhcp6_option_iter_init(&iter, message, len);

	while (_dhcp6_option_iter_next(&iter, &t, &l, &v)) {
		switch (t) {
		case DHCP6_OPTION_CLIENT_ID:
			if (client->duid_len != l ||
					memcmp(client->duid, v, l)) {
				CLIENT_DEBUG("Message %s - invalid option: %s",
						mstr, option_to_string(t));
				return -EINVAL;
			}

			duid_verified = true;
			break;
		case DHCP6_OPTION_STATUS_CODE:
			if (l < 2)
				return -EBADMSG;

			if (l_get_be16(v) > 0) {
				CLIENT_DEBUG("Message %s - Status %s", mstr,
					status_to_string(l_get_be16(v)));
				return -EINVAL;
			}
			break;
		case DHCP6_OPTION_SERVER_ID:
			server_id_present = true;
			break;
		default:
			break;
		}
	}

	if (expect_client_id && !duid_verified) {
		CLIENT_DEBUG("Message %s - no client id option found", mstr);
		return -EBADMSG;
	}

	if (!server_id_present) {
		CLIENT_DEBUG("Message %s has no server id", mstr);
		return -EBADMSG;
	}

	return 0;
}

static int dhcp6_client_receive_advertise(struct l_dhcp6_client *client,
					const struct dhcp6_message *advertise,
					size_t len)
{
	int r;
	struct l_dhcp6_lease *lease;
	struct dhcp6_option_iter iter;

	if (advertise->msg_type != DHCP6_MESSAGE_TYPE_ADVERTISE)
		return -EINVAL;

	r = dhcp6_client_validate_message(client, true, advertise, len);
	if (r < 0)
		return r;

	_dhcp6_option_iter_init(&iter, advertise, len);
	lease = _dhcp6_lease_parse_options(&iter, client->addr + 2);
	if (!lease)
		return -EBADMSG;

	/*
	 * RFC 8415, Section 18.2.9:
	 * "The client MUST ignore any Advertise message that contains no
	 * addresses (IA Address options (see Section 21.6) encapsulated in
	 * IA_NA options (see Section 21.4) or IA_TA options
	 * (see Section 21.5)) and no delegated prefixes (IA Prefix options
	 * (see Section 21.22) encapsulated in IA_PD options
	 * (see Section 21.21))"
	 */
	r = -EINVAL;
	if (!lease->have_na && !lease->have_pd)
		goto bad_lease;

	if (client->request_na && !lease->have_na) {
		CLIENT_DEBUG("Requested Non-Temporary address, but not present"
				" in lease, ignoring...");
		goto bad_lease;
	}

	if (client->request_pd && !lease->have_pd) {
		CLIENT_DEBUG("Requested Prefix Delegation but not present in"
				" lease, ignoring...");
		goto bad_lease;
	}

	if (!client->lease || client->lease->preference < lease->preference) {
		_dhcp6_lease_free(client->lease);
		client->lease = lease;

		/*
		 * RFC 8415, Section 18.2.1
		 * "If the client receives a valid Advertise message that
		 * includes a Preference option with a preference value of 255,
		 * the client immediately begins a client-initiated message
		 * exchange (as described in Section 18.2.2) by sending a
		 * Request message to the server from which the Advertise
		 * message was received.
		 *
		 * "If the client does not receive any valid Advertise messages
		 * before the first RT has elapsed, it then applies the
		 * retransmission mechanism described in Section 15.  The
		 * client terminates the retransmission process as soon as it
		 * receives any valid Advertise message, and the client acts on
		 * the received Advertise message without waiting for any
		 * additional Advertise messages."
		 */
		if (lease->preference == 0xff) {
			CLIENT_DEBUG("Received a lease with max preference");
			return DHCP6_STATE_REQUESTING;
		}

		if (client->attempt > 1) {
			CLIENT_DEBUG("Received a valid Advertise after first"
					" retransmission.");
			return DHCP6_STATE_REQUESTING;
		}
	} else
		_dhcp6_lease_free(lease);

	return DHCP6_STATE_SOLICITING;

bad_lease:
	_dhcp6_lease_free(lease);
	return r;
}

static int dhcp6_client_receive_reply(struct l_dhcp6_client *client,
					const struct dhcp6_message *reply,
					size_t len)
{
	struct l_dhcp6_lease *lease;
	struct dhcp6_option_iter iter;
	int r;
	/*
	 * Per RFC 7844 Section 4.3.1 we never send Client ID options in
	 * Information-requests so don't expect the replies to contain them.
	 */
	bool expect_client_id =
		(client->state != DHCP6_STATE_REQUESTING_INFORMATION);

	if (reply->msg_type != DHCP6_MESSAGE_TYPE_REPLY)
		return -EINVAL;

	r = dhcp6_client_validate_message(client, expect_client_id, reply, len);
	if (r < 0)
		return r;

	_dhcp6_option_iter_init(&iter, reply, len);
	lease = _dhcp6_lease_parse_options(&iter, client->addr + 2);
	if (!lease)
		return -EBADMSG;

	if (client->state == DHCP6_STATE_SOLICITING && !lease->rapid_commit) {
		CLIENT_DEBUG("Requested Rapid Commit, but reply received"
				" without it.  Ignoring");
		_dhcp6_lease_free(lease);
		return -EBADMSG;
	}

	if (client->request_na && !lease->have_na) {
		CLIENT_DEBUG("Requested Non-Temporary address, but not present"
				" in lease, FAIL.");
		goto bad_lease;
	}

	if (client->request_pd && !lease->have_pd) {
		CLIENT_DEBUG("Requested Prefix Delegation but not present in"
				" lease, FAIL");
		goto bad_lease;
	}

	_dhcp6_lease_free(client->lease);
	client->lease = lease;

	return DHCP6_STATE_BOUND;

bad_lease:
	_dhcp6_lease_free(lease);
	l_dhcp6_client_stop(client);
	dhcp6_client_event_notify(client, L_DHCP6_CLIENT_EVENT_NO_LEASE);
	return r;
}

static void dhcp6_client_rx_message(const void *data, size_t len,
					uint64_t timestamp, void *userdata)
{
	struct l_dhcp6_client *client = userdata;
	const struct dhcp6_message *message = data;
	int r = client->state;

	CLIENT_DEBUG("");

	if (len < sizeof(struct dhcp6_message))
		return;

	switch (message->msg_type) {
        case DHCP6_MESSAGE_TYPE_ADVERTISE:
        case DHCP6_MESSAGE_TYPE_REPLY:
        case DHCP6_MESSAGE_TYPE_RECONFIGURE:
                break;
	default:
		/* Discard invalid message types */
		return;
	}

	if ((message->transaction_id & L_CPU_TO_BE32(0x00FFFFFFU)) !=
					L_CPU_TO_BE32(client->transaction_id))
		return;

	switch (client->state) {
	case DHCP6_STATE_INIT:
	case DHCP6_STATE_BOUND:
		return;
	case DHCP6_STATE_REQUESTING_INFORMATION:
		r = dhcp6_client_receive_reply(client, message, len);
		if (r < 0)
			return;

		break;
	case DHCP6_STATE_SOLICITING:
		r = dhcp6_client_receive_advertise(client, message, len);
		if (r >= 0)
			break;

		if (client->no_rapid_commit)
			return;

		/* Fall through */
	case DHCP6_STATE_REQUESTING:
	case DHCP6_STATE_RENEWING:
	case DHCP6_STATE_REBINDING:
		r = dhcp6_client_receive_reply(client, message, len);
		if (r < 0)
			return;
		break;
	case DHCP6_STATE_RELEASING:
		break;
	}

	if (r == (int) client->state)
		return;

	if (r == DHCP6_STATE_BOUND) {
		l_timeout_remove(client->timeout_send);
		client->timeout_send = NULL;
		dhcp6_client_setup_lease(client, timestamp);
		return;
	}

	dhcp6_client_new_transaction(client, r);

	if (dhcp6_client_send_next(client) < 0)
		l_dhcp6_client_stop(client);
}

static void dhcp6_client_send_initial(struct l_dhcp6_client *client)
{
	uint32_t delay;

	if (client->stateless) {
		dhcp6_client_new_transaction(client,
					DHCP6_STATE_REQUESTING_INFORMATION);
		delay = _time_pick_interval_secs(0, INF_MAX_DELAY);
	} else {
		dhcp6_client_new_transaction(client, DHCP6_STATE_SOLICITING);
		delay = _time_pick_interval_secs(0, SOL_MAX_DELAY);
	}

	/*
	 * RFC 8415, Section 18.2.1:
	 * "The first Solicit message from the client on the interface SHOULD
	 * be delayed by a random amount of time between 0 and SOL_MAX_DELAY.
	 * This random delay helps desynchronize clients that start a DHCP
	 * session at the same time, such as after recovery from a power
	 * failure or after a router outage after seeing that DHCP is
	 * available in Router Advertisement messages..."
	 *
	 * Similar verbiage in Section 18.2.6, except it uses 'MUST':
	 * "The first Information-request message from the client on the
	 * interface MUST be delayed by a random amount of time between 0 and
	 * INF_MAX_DELAY."
	 *
	 * In certain situations, like when a WiFi network was just joined,
	 * there's no point in waiting a random time, so we forgo the wait
	 * if no delay is requested
	 */
	if (client->nodelay)
		delay = 0;

	client->timeout_send = l_timeout_create_ms(delay,
						dhcp6_client_timeout_send,
						client, NULL);

	if (client->nodelay)
		dhcp6_client_timeout_send(NULL, client);
}

static void dhcp6_client_icmp6_event(struct l_icmp6_client *icmp6,
					enum l_icmp6_client_event event,
					void *event_data, void *user_data)
{
	struct l_dhcp6_client *client = user_data;

	if (client->nora)
		return;

	switch (event) {
	case L_ICMP6_CLIENT_EVENT_ROUTER_FOUND:
	{
		const struct l_icmp6_router *r =
			l_icmp6_client_get_router(icmp6);
		bool managed = l_icmp6_router_get_managed(r);
		bool other = l_icmp6_router_get_other(r);

		CLIENT_DEBUG("Received RA, managed: %s, other: %s",
				managed ? "yes" : "no",
				other ? "yes" : "no");

		/* We only process the first RA received for now */
		if (!client->timeout_send)
			return;

		l_timeout_remove(client->timeout_send);
		client->timeout_send = NULL;

		if (!managed && !other) {
			l_dhcp6_client_stop(client);
			dhcp6_client_event_notify(client,
						L_DHCP6_CLIENT_EVENT_NO_LEASE);
			return;
		}

		if (managed)
			dhcp6_client_send_initial(client);

		break;
	}
	}
}

static void dhcp6_client_no_ra(struct l_timeout *timeout, void *user_data)
{
	struct l_dhcp6_client *client = user_data;

	CLIENT_DEBUG("No Router Advertisements received, assume no DHCPv6");
	l_dhcp6_client_stop(client);
	dhcp6_client_event_notify(client, L_DHCP6_CLIENT_EVENT_NO_LEASE);
}

LIB_EXPORT struct l_dhcp6_client *l_dhcp6_client_new(uint32_t ifindex)
{
	struct l_dhcp6_client *client;

	client = l_new(struct l_dhcp6_client, 1);

	client->state = DHCP6_STATE_INIT;
	client->ifindex = ifindex;

	client->icmp6 = l_icmp6_client_new(ifindex);
	l_icmp6_client_add_event_handler(client->icmp6,
						dhcp6_client_icmp6_event,
						client, NULL);

	client->request_options = l_uintset_new(256);
	client_enable_option(client, L_DHCP6_OPTION_DOMAIN_LIST);
	client_enable_option(client, L_DHCP6_OPTION_DNS_SERVERS);

	return client;
}

LIB_EXPORT void l_dhcp6_client_destroy(struct l_dhcp6_client *client)
{
	if (unlikely(!client))
		return;

	if (client->state != DHCP6_STATE_INIT)
		l_dhcp6_client_stop(client);

	l_icmp6_client_free(client->icmp6);

	if (client->event_destroy)
		client->event_destroy(client->event_data);

	_dhcp6_transport_free(client->transport);
	l_uintset_free(client->request_options);
	l_free(client->duid);

	l_free(client);
}

LIB_EXPORT const struct l_dhcp6_lease *l_dhcp6_client_get_lease(
					const struct l_dhcp6_client *client)
{
	if (unlikely(!client))
		return NULL;

	switch (client->state) {
	case DHCP6_STATE_INIT:
	case DHCP6_STATE_SOLICITING:
	case DHCP6_STATE_REQUESTING:
	case DHCP6_STATE_RELEASING:
		return NULL;
	case DHCP6_STATE_BOUND:
	case DHCP6_STATE_RENEWING:
	case DHCP6_STATE_REBINDING:
	case DHCP6_STATE_REQUESTING_INFORMATION:
		break;
	}

	return client->lease;
}

LIB_EXPORT bool l_dhcp6_client_set_address(struct l_dhcp6_client *client,
						uint8_t type,
						const uint8_t *addr,
						size_t addr_len)
{
	if (unlikely(!client))
		return false;

	switch (type) {
	case ARPHRD_ETHER:
		if (addr_len != ETH_ALEN)
			return false;
		break;
	default:
		return false;
	}

	client->addr_len = addr_len;
	memcpy(client->addr, addr, addr_len);
	client->addr_type = type;

	return true;
}

/*
 * Set the link local address to use instead of binding to the in6addr_any
 * address by default.  This allows multiple clients to coexist simultaneously
 * on different ifindexes
 */
LIB_EXPORT bool l_dhcp6_client_set_link_local_address(
						struct l_dhcp6_client *client,
						const char *ll)
{
	if (unlikely(!client))
		return false;

	if (inet_pton(AF_INET6, ll, &client->ll_address) != 1)
		return false;

	if (!client->nora)
		l_icmp6_client_set_link_local_address(client->icmp6, ll, false);

	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_debug(struct l_dhcp6_client *client,
						l_dhcp6_debug_cb_t function,
						void *user_data,
						l_dhcp6_destroy_cb_t destroy)
{
	if (unlikely(!client))
		return false;

	if (client->debug_destroy)
		client->debug_destroy(client->debug_data);

	client->debug_handler = function;
	client->debug_destroy = destroy;
	client->debug_data = user_data;

	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_event_handler(struct l_dhcp6_client *client,
					l_dhcp6_client_event_cb_t handler,
					void *userdata,
					l_dhcp6_destroy_cb_t destroy)
{
	if (unlikely(!client))
		return false;

	if (client->event_destroy)
		client->event_destroy(client->event_data);

	client->event_handler = handler;
	client->event_data = userdata;
	client->event_destroy = destroy;

	return true;
}

/*
 * Sets whether Link-Layer Address (LLA) has been randomized for this link or
 * connection.  If LLA has been randomized, then DUID based on the LLA
 * is used instead of other DUID generation methods
 */
LIB_EXPORT bool l_dhcp6_client_set_lla_randomized(struct l_dhcp6_client *client,
							bool randomized)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->lla_randomized = randomized;

	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_no_rapid_commit(
						struct l_dhcp6_client *client,
						bool no_rapid_commit)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->no_rapid_commit = no_rapid_commit;

	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_nodelay(struct l_dhcp6_client *client,
						bool nodelay)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->nodelay = nodelay;

	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_nora(struct l_dhcp6_client *client,
					bool nora)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->nora = nora;

	return true;
}

/*
 * Set l_netlink object to use for sending RTNL commands.  If set, then
 * l_dhcp6_client will add / delete addresses obtained via DHCPv6
 * automatically.
 */
LIB_EXPORT bool l_dhcp6_client_set_rtnl(struct l_dhcp6_client *client,
						struct l_netlink *rtnl)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->rtnl = rtnl;
	return true;
}

LIB_EXPORT bool l_dhcp6_client_set_stateless(struct l_dhcp6_client *client,
								bool stateless)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client->stateless = stateless;

	return true;
}

LIB_EXPORT struct l_icmp6_client *l_dhcp6_client_get_icmp6(
						struct l_dhcp6_client *client)
{
	if (unlikely(!client))
		return NULL;

	return client->icmp6;
}

LIB_EXPORT bool l_dhcp6_client_add_request_option(struct l_dhcp6_client *client,
						enum l_dhcp6_option option)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	client_enable_option(client, option);

	return true;
}

LIB_EXPORT bool l_dhcp6_client_start(struct l_dhcp6_client *client)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	if (!client->addr_len) {
		uint8_t mac[6];

		if (!l_net_get_mac_address(client->ifindex, mac))
			return false;

		l_dhcp6_client_set_address(client, ARPHRD_ETHER, mac, ETH_ALEN);
	}

	if (client->lla_randomized)
		client_duid_generate_addr(client);
	else
		client_duid_generate_addr_plus_time(client);

	client->request_na = !client->stateless;

	if (!client->transport) {
		client->transport =
			_dhcp6_default_transport_new(client->ifindex,
							&client->ll_address,
							DHCP6_PORT_CLIENT);

		if (!client->transport)
			return false;
	}

	if (client->transport->open) {
		int r = client->transport->open(client->transport);

		if (r < 0) {
			CLIENT_DEBUG("Transport failed to open: %s",
					strerror(-r));
			return false;
		}
	}

	_dhcp6_transport_set_rx_callback(client->transport,
						dhcp6_client_rx_message,
						client);

	if (client->nora || client->addr_type != ARPHRD_ETHER) {
		dhcp6_client_send_initial(client);
		return true;
	}

	l_icmp6_client_set_address(client->icmp6, client->addr);
	l_icmp6_client_set_debug(client->icmp6, client->debug_handler,
					client->debug_data,
					client->debug_destroy);
	l_icmp6_client_set_nodelay(client->icmp6, client->nodelay);

	if (!l_icmp6_client_start(client->icmp6))
		return false;

	/*
	 * Start a timer.  In case there are no router advertisements that
	 * come back in a reasonable time, fail with a NO_LEASE event
	 */
	client->timeout_send = l_timeout_create(10, dhcp6_client_no_ra,
						client, NULL);
	return true;
}

LIB_EXPORT bool l_dhcp6_client_stop(struct l_dhcp6_client *client)
{
	if (unlikely(!client))
		return false;

	CLIENT_DEBUG("");

	if (client->rtnl_add_cmdid) {
		l_netlink_cancel(client->rtnl, client->rtnl_add_cmdid);
		client->rtnl_add_cmdid = 0;
	}

	if (client->rtnl_configured_address) {
		l_rtnl_ifaddr_delete(client->rtnl, client->ifindex,
					client->rtnl_configured_address,
					NULL, NULL, NULL);
		l_rtnl_address_free(client->rtnl_configured_address);
		client->rtnl_configured_address = NULL;
	}

	_dhcp6_lease_free(client->lease);
	client->lease = NULL;

	if (!client->nora)
		l_icmp6_client_stop(client->icmp6);

	l_timeout_remove(client->timeout_send);
	client->timeout_send = NULL;

	l_timeout_remove(client->timeout_lease);
	client->timeout_lease = NULL;

	l_free(client->duid);
	client->duid = NULL;

	if (client->transport && client->transport->close)
		client->transport->close(client->transport);

	client->state = DHCP6_STATE_INIT;

	return true;
}

bool _dhcp6_client_set_transport(struct l_dhcp6_client *client,
					struct dhcp6_transport *transport)
{
	if (unlikely(!client))
		return false;

	if (unlikely(client->state != DHCP6_STATE_INIT))
		return false;

	if (client->transport)
		_dhcp6_transport_free(client->transport);

	client->transport = transport;
	return true;
}