/* state.c - high level DHCP state machine
 *
 * Copyright (c) 2011-2015 Nicholas J. Kain <njkain at gmail dot com>
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * - Redistributions of source code must retain the above copyright notice,
 *   this list of conditions and the following disclaimer.
 *
 * - Redistributions in binary form must reproduce the above copyright notice,
 *   this list of conditions and the following disclaimer in the documentation
 *   and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "nk/log.h"
#include "nk/random.h"

#include "state.h"
#include "ifchange.h"
#include "arp.h"
#include "options.h"
#include "ndhc.h"
#include "sys.h"
#include "netlink.h"

// Simulates netlink carrier down event if carrier went down while suspended.
#define SUSPEND_IF_NOCARRIER() \
    if (r == -99) { \
        cs->ifsPrevState = IFS_DOWN; \
        ifnocarrier_action(cs); \
        dhcp_wake_ts = -1; \
        return; \
    }

static void selecting_packet(struct client_state_t cs[static 1],
                             struct dhcpmsg packet[static 1],
                             uint8_t msgtype, uint32_t srcaddr);
static void an_packet(struct client_state_t cs[static 1],
                      struct dhcpmsg packet[static 1],
                      uint8_t msgtype, uint32_t srcaddr);
static void selecting_timeout(struct client_state_t cs[static 1],
                              long long nowts);
static void requesting_timeout(struct client_state_t cs[static 1],
                               long long nowts);
static void bound_timeout(struct client_state_t cs[static 1],
                          long long nowts);
static void renewing_timeout(struct client_state_t cs[static 1],
                             long long nowts);
static void rebinding_timeout(struct client_state_t cs[static 1],
                              long long nowts);
static void released_timeout(struct client_state_t cs[static 1],
                             long long nowts);
static void xmit_release(struct client_state_t cs[static 1]);
static void print_release(struct client_state_t cs[static 1]);
static void frenew(struct client_state_t cs[static 1]);

typedef struct {
    void (*packet_fn)(struct client_state_t cs[static 1],
                      struct dhcpmsg packet[static 1],
                      uint8_t msgtype, uint32_t srcaddr);
    void (*timeout_fn)(struct client_state_t cs[static 1], long long nowts);
    void (*force_renew_fn)(struct client_state_t cs[static 1]);
    void (*force_release_fn)(struct client_state_t cs[static 1]);
} dhcp_state_t;

static const dhcp_state_t dhcp_states[] = {
    { selecting_packet, selecting_timeout, 0, print_release}, // SELECTING
    { an_packet, requesting_timeout, 0, print_release},       // REQUESTING
    { 0, bound_timeout, frenew, xmit_release},                // BOUND
    { an_packet, renewing_timeout, 0, xmit_release},          // RENEWING
    { an_packet, rebinding_timeout, 0, xmit_release},         // REBINDING
    { 0, 0, 0, xmit_release},                                 // BOUND_GW_CHECK
    { 0, 0, 0, xmit_release},                                // COLLISION_CHECK
    { 0, released_timeout, frenew, 0},                       // RELEASED
    { 0, 0, 0, 0},                                           // NUM_STATES
};

static unsigned int num_dhcp_requests;
static long long dhcp_wake_ts = -1;

static int delay_timeout(struct client_state_t cs[static 1], size_t numpackets)
{
    int to = 64;
    char tot[] = { 4, 8, 16, 32, 64 };
    if (numpackets < sizeof tot)
        to = tot[numpackets];
    // Distribution is a bit biased but it doesn't really matter.
    return to * 1000 + (nk_random_u32(&cs->rnd32_state) & 0x7fffffffu) % 1000;
}

static int reinit_shared_deconfig(struct client_state_t cs[static 1])
{
    if (ifchange_deconfig(cs) < 0)
        return -1;
    arp_close_fd(cs);
    cs->clientAddr = 0;
    num_dhcp_requests = 0;
    cs->got_router_arp = 0;
    cs->got_server_arp = 0;
    memset(&cs->routerArp, 0, sizeof cs->routerArp);
    memset(&cs->serverArp, 0, sizeof cs->serverArp);
    arp_reset_send_stats();
    return 0;
}

int reinit_selecting(struct client_state_t cs[static 1], int timeout)
{
    if (reinit_shared_deconfig(cs) < 0) {
        // XXX: This should retry until it succeeds.
        suicide("%s: (%s) deconfiguring interface failed",
                client_config.interface, __func__);
    }
    cs->dhcpState = DS_SELECTING;
    dhcp_wake_ts = curms() + timeout;
    start_dhcp_listen(cs);
    return 0;
}

static int set_released(struct client_state_t cs[static 1])
{
    if (reinit_shared_deconfig(cs) < 0) {
        // XXX: This should retry until it succeeds.
        suicide("%s: (%s) deconfiguring interface failed",
                client_config.interface, __func__);
    }
    cs->dhcpState = DS_RELEASED;
    dhcp_wake_ts = -1;
    stop_dhcp_listen(cs);
    return 0;
}

// Triggered after a DHCP lease request packet has been sent and no reply has
// been received within the response wait time.  If we've not exceeded the
// maximum number of request retransmits, then send another packet and wait
// again.  Otherwise, return to the DHCP initialization state.
static void requesting_timeout(struct client_state_t cs[static 1],
                               long long nowts)
{
    if (num_dhcp_requests >= 5) {
        reinit_selecting(cs, 0);
        return;
    }
    int r = send_selecting(cs);
    if (r < 0) {
        log_warning("%s: Failed to send a selecting request packet.",
                    client_config.interface);
        SUSPEND_IF_NOCARRIER();
    }
    dhcp_wake_ts = nowts + delay_timeout(cs, num_dhcp_requests);
    num_dhcp_requests++;
}

// Triggered when the lease has been held for a significant fraction of its
// total time, and it is time to renew the lease so that it is not lost.
static void bound_timeout(struct client_state_t cs[static 1], long long nowts)
{
    long long rnt = cs->leaseStartTime + cs->renewTime * 1000;
    if (nowts < rnt) {
        dhcp_wake_ts = rnt;
        return;
    }
    cs->dhcpState = DS_RENEWING;
    start_dhcp_listen(cs);
    renewing_timeout(cs, nowts);
}

// Triggered when a DHCP renew request has been sent and no reply has been
// received within the response wait time.  This function is also directly
// called by bound_timeout() when it is time to renew a lease before it
// expires.  Check to see if the lease is still valid, and if it is, send
// a unicast DHCP renew packet.  If it is not, then change to the REBINDING
// state to send broadcast queries.
static void renewing_timeout(struct client_state_t cs[static 1],
                             long long nowts)
{
    long long rbt = cs->leaseStartTime + cs->rebindTime * 1000;
    if (nowts >= rbt) {
        cs->dhcpState = DS_REBINDING;
        rebinding_timeout(cs, nowts);
        return;
    }
    if (rbt - nowts < 30000) {
        dhcp_wake_ts = rbt;
        return;
    }
    int r = send_renew(cs);
    if (r < 0) {
        log_warning("%s: Failed to send a renew request packet.",
                    client_config.interface);
        SUSPEND_IF_NOCARRIER();
    }
    dhcp_wake_ts = nowts + ((rbt - nowts) / 2);
}

// Triggered when a DHCP rebind request has been sent and no reply has been
// received within the response wait time.  Check to see if the lease is still
// valid, and if it is, send a broadcast DHCP renew packet.  If it is not, then
// change to the SELECTING state to get a new lease.
static void rebinding_timeout(struct client_state_t cs[static 1],
                              long long nowts)
{
    long long elt = cs->leaseStartTime + cs->lease * 1000;
    if (nowts >= elt) {
        log_line("%s: Lease expired.  Searching for a new lease...",
                 client_config.interface);
        reinit_selecting(cs, 0);
        return;
    }
    if (elt - nowts < 30000) {
        dhcp_wake_ts = elt;
        return;
    }
    int r = send_rebind(cs);
    if (r < 0) {
        log_warning("%s: Failed to send a rebind request packet.",
                    client_config.interface);
        SUSPEND_IF_NOCARRIER();
    }
    dhcp_wake_ts = nowts + ((elt - nowts) / 2);
}

static void released_timeout(struct client_state_t cs[static 1],
                             long long nowts)
{
    (void)cs;
    (void)nowts;
    dhcp_wake_ts = -1;
}

static int validate_serverid(struct client_state_t cs[static 1],
                             struct dhcpmsg packet[static 1],
                             const char typemsg[static 1])
{
    int found;
    uint32_t sid = get_option_serverid(packet, &found);
    if (!found) {
        log_line("%s: Received %s with no server id.  Ignoring it.",
                 client_config.interface, typemsg);
        return 0;
    }
    if (cs->serverAddr != sid) {
        char svrbuf[INET_ADDRSTRLEN];
        inet_ntop(AF_INET, &(struct in_addr){.s_addr=sid},
                  svrbuf, sizeof svrbuf);
        log_line("%s: Received %s with an unexpected server id: %s.  Ignoring it.",
                 client_config.interface, typemsg, svrbuf);
        return 0;
    }
    return 1;
}

// Can transition to DS_BOUND or DS_SELECTING.
static void an_packet(struct client_state_t cs[static 1],
                      struct dhcpmsg packet[static 1], uint8_t msgtype,
                      uint32_t srcaddr)
{
    (void)srcaddr;
    if (msgtype == DHCPACK) {
        if (!validate_serverid(cs, packet, "a DHCP ACK"))
            return;
        cs->lease = get_option_leasetime(packet);
        cs->leaseStartTime = curms();
        if (!cs->lease) {
            log_line("%s: No lease time received; assuming 1h.",
                     client_config.interface);
            cs->lease = 60 * 60;
        } else {
            if (cs->lease < 60) {
                log_warning("Server sent lease of <1m.  Forcing lease to 1m.",
                            client_config.interface);
                cs->lease = 60;
            }
        }
        // Always use RFC2131 'default' values.  It's not worth validating
        // the remote server values, if they even exist, for sanity.
        cs->renewTime = cs->lease >> 1;
        cs->rebindTime = (cs->lease >> 3) * 0x7; // * 0.875
        dhcp_wake_ts = cs->leaseStartTime + cs->renewTime * 1000;

        // Only check if we are either in the REQUESTING state, or if we
        // have received a lease with a different IP than what we had before.
        if (cs->dhcpState == DS_REQUESTING ||
            memcmp(&packet->yiaddr, &cs->clientAddr, 4)) {
            char clibuf[INET_ADDRSTRLEN];
            inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->clientAddr},
                      clibuf, sizeof clibuf);
            log_line("%s: Accepted a firm offer for %s.  Validating...",
                     client_config.interface, clibuf);
            if (arp_check(cs, packet) < 0) {
                log_warning("%s: Failed to make arp socket.  Searching for new lease...",
                            client_config.interface);
                reinit_selecting(cs, 3000);
            }
        } else {
            log_line("%s: Lease refreshed to %u seconds.",
                     client_config.interface, cs->lease);
            cs->dhcpState = DS_BOUND;
            arp_set_defense_mode(cs);
            stop_dhcp_listen(cs);
        }

    } else if (msgtype == DHCPNAK) {
        if (!validate_serverid(cs, packet, "a DHCP NAK"))
            return;
        log_line("%s: Our request was rejected.  Searching for a new lease...",
                 client_config.interface);
        reinit_selecting(cs, 3000);
    }
}

static void selecting_packet(struct client_state_t cs[static 1],
                             struct dhcpmsg packet[static 1], uint8_t msgtype,
                             uint32_t srcaddr)
{
    if (msgtype == DHCPOFFER) {
        int found;
        uint32_t sid = get_option_serverid(packet, &found);
        if (found) {
            char clibuf[INET_ADDRSTRLEN];
            char svrbuf[INET_ADDRSTRLEN];
            char srcbuf[INET_ADDRSTRLEN];
            cs->serverAddr = sid;
            cs->xid = packet->xid;
            cs->clientAddr = packet->yiaddr;
            cs->srcAddr = srcaddr;
            cs->dhcpState = DS_REQUESTING;
            dhcp_wake_ts = curms();
            num_dhcp_requests = 0;
            inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->clientAddr},
                      clibuf, sizeof clibuf);
            inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->serverAddr},
                      svrbuf, sizeof svrbuf);
            inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->srcAddr},
                      srcbuf, sizeof srcbuf);
            log_line("%s: Received IP offer: %s from server %s via %s.",
                     client_config.interface, clibuf, svrbuf, srcbuf);
        } else {
            log_line("%s: Invalid offer received: it didn't have a server id.",
                     client_config.interface);
        }
    }
}

// Triggered after a DHCP discover packet has been sent and no reply has
// been received within the response wait time.  If we've not exceeded the
// maximum number of discover retransmits, then send another packet and wait
// again.  Otherwise, background or fail.
static void selecting_timeout(struct client_state_t cs[static 1],
                              long long nowts)
{
    if (cs->init && num_dhcp_requests >= 2) {
        if (client_config.background_if_no_lease) {
            log_line("%s: No lease; going to background.",
                     client_config.interface);
            cs->init = 0;
            background();
        } else if (client_config.abort_if_no_lease)
            suicide("%s: No lease; failing.", client_config.interface);
    }
    if (num_dhcp_requests == 0)
        cs->xid = nk_random_u32(&cs->rnd32_state);
    int r = send_discover(cs);
    if (r < 0) {
        log_warning("%s: Failed to send a discover request packet.",
                    client_config.interface);
        SUSPEND_IF_NOCARRIER();
    }
    dhcp_wake_ts = nowts + delay_timeout(cs, num_dhcp_requests);
    num_dhcp_requests++;
}

static void xmit_release(struct client_state_t cs[static 1])
{
    char clibuf[INET_ADDRSTRLEN];
    char svrbuf[INET_ADDRSTRLEN];
    inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->clientAddr},
              clibuf, sizeof clibuf);
    inet_ntop(AF_INET, &(struct in_addr){.s_addr=cs->serverAddr},
              svrbuf, sizeof svrbuf);
    log_line("%s: Unicasting a release of %s to %s.", client_config.interface,
             clibuf, svrbuf);
    int r = send_release(cs);
    if (r < 0) {
        log_warning("%s: Failed to send a release request packet.",
                    client_config.interface);
        SUSPEND_IF_NOCARRIER();
    }
    print_release(cs);
}

static void print_release(struct client_state_t cs[static 1])
{
    log_line("%s: ndhc going to sleep.  Wake it by sending a SIGUSR1.",
             client_config.interface);
    set_released(cs);
}

static void frenew(struct client_state_t cs[static 1])
{
    if (cs->dhcpState == DS_BOUND) {
        log_line("%s: Forcing a DHCP renew...", client_config.interface);
        cs->dhcpState = DS_RENEWING;
        start_dhcp_listen(cs);
        int r = send_renew(cs);
        if (r < 0) {
            log_warning("%s: Failed to send a renew request packet.",
                        client_config.interface);
            SUSPEND_IF_NOCARRIER();
        }
    } else if (cs->dhcpState == DS_RELEASED)
        reinit_selecting(cs, 0);
}

void ifup_action(struct client_state_t cs[static 1])
{
    // If we have a lease, check to see if our gateway is still valid via ARP.
    // If it fails, state -> SELECTING.
    if (cs->routerAddr && (cs->dhcpState == DS_BOUND ||
                           cs->dhcpState == DS_RENEWING ||
                           cs->dhcpState == DS_REBINDING)) {
        int r = arp_gw_check(cs);
        if (r >= 0) {
            log_line("%s: Interface is back.  Revalidating lease...",
                     client_config.interface);
            return;
        } else {
            SUSPEND_IF_NOCARRIER();
            log_warning("%s: arp_gw_check could not make arp socket.",
                        client_config.interface);
        }
    }
    if (cs->dhcpState == DS_SELECTING)
        return;
    log_line("%s: Interface is back.  Searching for new lease...",
             client_config.interface);
    reinit_selecting(cs, 0);
}

void ifdown_action(struct client_state_t cs[static 1])
{
    log_line("%s: Interface shut down.  Going to sleep.",
             client_config.interface);
    set_released(cs);
}

void ifnocarrier_action(struct client_state_t cs[static 1])
{
    (void)cs;
    log_line("%s: Carrier down.", client_config.interface);
}

void packet_action(struct client_state_t cs[static 1],
                   struct dhcpmsg packet[static 1], uint8_t msgtype,
                   uint32_t srcaddr)
{
    if (dhcp_states[cs->dhcpState].packet_fn)
        dhcp_states[cs->dhcpState].packet_fn(cs, packet, msgtype, srcaddr);
}

void timeout_action(struct client_state_t cs[static 1], long long nowts)
{
    handle_arp_timeout(cs, nowts);
    if (dhcp_states[cs->dhcpState].timeout_fn)
        dhcp_states[cs->dhcpState].timeout_fn(cs, nowts);
}

void force_renew_action(struct client_state_t cs[static 1])
{
    if (dhcp_states[cs->dhcpState].force_renew_fn)
        dhcp_states[cs->dhcpState].force_renew_fn(cs);
}

void force_release_action(struct client_state_t cs[static 1])
{
    if (dhcp_states[cs->dhcpState].force_release_fn)
        dhcp_states[cs->dhcpState].force_release_fn(cs);
}

long long dhcp_get_wake_ts(void)
{
    return dhcp_wake_ts;
}