#include "UDPC_Defines.hpp"
#include "UDPC.h"

#include <cassert>
#include <chrono>
#include <cstring>
#include <optional>
#include <vector>
#include <functional>
#include <type_traits>
#include <string>
#include <sstream>
#include <ios>
#include <iomanip>
#include <regex>
#include <cstdlib>
#include <ctime>
#include <iomanip>

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
#include <netioapi.h>
typedef int socklen_t;

#elif UDPC_PLATFORM == UDPC_PLATFORM_MAC || UDPC_PLATFORM == UDPC_PLATFORM_LINUX
#include <sys/ioctl.h>
#include <net/if.h>
#endif

//static const std::regex ipv6_regex = std::regex(R"d((([0-9a-fA-F]{1,4}:){7,7}[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,7}:|([0-9a-fA-F]{1,4}:){1,6}:[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,5}(:[0-9a-fA-F]{1,4}){1,2}|([0-9a-fA-F]{1,4}:){1,4}(:[0-9a-fA-F]{1,4}){1,3}|([0-9a-fA-F]{1,4}:){1,3}(:[0-9a-fA-F]{1,4}){1,4}|([0-9a-fA-F]{1,4}:){1,2}(:[0-9a-fA-F]{1,4}){1,5}|[0-9a-fA-F]{1,4}:((:[0-9a-fA-F]{1,4}){1,6})|:((:[0-9a-fA-F]{1,4}){1,7}|:)|fe80:(:[0-9a-fA-F]{0,4}){0,4}%[0-9a-zA-Z]{1,}|::(ffff(:0{1,4}){0,1}:){0,1}((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])|([0-9a-fA-F]{1,4}:){1,4}:((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])))d");
static const std::regex ipv6_regex_nolink = std::regex(R"d((([0-9a-fA-F]{1,4}:){7,7}[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,7}:|([0-9a-fA-F]{1,4}:){1,6}:[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,5}(:[0-9a-fA-F]{1,4}){1,2}|([0-9a-fA-F]{1,4}:){1,4}(:[0-9a-fA-F]{1,4}){1,3}|([0-9a-fA-F]{1,4}:){1,3}(:[0-9a-fA-F]{1,4}){1,4}|([0-9a-fA-F]{1,4}:){1,2}(:[0-9a-fA-F]{1,4}){1,5}|[0-9a-fA-F]{1,4}:((:[0-9a-fA-F]{1,4}){1,6})|:((:[0-9a-fA-F]{1,4}){1,7}|:)|::(ffff(:0{1,4}){0,1}:){0,1}((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])|([0-9a-fA-F]{1,4}:){1,4}:((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])))d");
static const std::regex ipv6_regex_linkonly = std::regex(R"d(fe80:(:[0-9a-fA-F]{0,4}){0,4}%([0-9a-zA-Z]+))d");
static const std::regex ipv4_regex = std::regex(R"d((1[0-9][0-9]|2[0-4][0-9]|25[0-5]|[1-9][0-9]|[0-9])\.(1[0-9][0-9]|2[0-4][0-9]|25[0-5]|[1-9][0-9]|[0-9])\.(1[0-9][0-9]|2[0-4][0-9]|25[0-5]|[1-9][0-9]|[0-9])\.(1[0-9][0-9]|2[0-4][0-9]|25[0-5]|[1-9][0-9]|[0-9]))d");
static const std::regex regex_numeric = std::regex("[0-9]+");

UDPC::SentPktInfo::SentPktInfo() :
id(0),
sentTime(std::chrono::steady_clock::now())
{}

std::size_t UDPC::ConnectionIdHasher::operator()(const UDPC_ConnectionId& key) const {
    std::string value((const char*)UDPC_IPV6_ADDR_SUB(key.addr), 16);
    value.push_back((char)((key.scope_id >> 24) & 0xFF));
    value.push_back((char)((key.scope_id >> 16) & 0xFF));
    value.push_back((char)((key.scope_id >> 8) & 0xFF));
    value.push_back((char)(key.scope_id & 0xFF));
    value.push_back((char)((key.port >> 8) & 0xFF));
    value.push_back((char)(key.port & 0xFF));
    return std::hash<std::string>()(value);
}

std::size_t UDPC::IPV6_Hasher::operator()(const UDPC_IPV6_ADDR_TYPE& addr) const {
    return std::hash<std::string>()(std::string((const char*)UDPC_IPV6_ADDR_SUB(addr), 16));
}

UDPC::PKContainer::PKContainer() {
    std::memset(pk, 0, crypto_sign_PUBLICKEYBYTES);
}

UDPC::PKContainer::PKContainer(const unsigned char *pk) {
    std::memcpy(this->pk, pk, crypto_sign_PUBLICKEYBYTES);
}

std::size_t UDPC::PKContainer::operator()(const PKContainer& container) const {
    return std::hash<std::string>()(std::string(
        (const char*)container.pk,
        crypto_sign_PUBLICKEYBYTES));
}

bool UDPC::PKContainer::operator==(const PKContainer& other) const {
    return std::memcmp(pk, other.pk, crypto_sign_PUBLICKEYBYTES) == 0;
}

bool operator ==(const UDPC_ConnectionId& a, const UDPC_ConnectionId& b) {
    return a.addr == b.addr && a.scope_id == b.scope_id && a.port == b.port;
}

bool operator ==(const UDPC_IPV6_ADDR_TYPE& a, const UDPC_IPV6_ADDR_TYPE& b) {
    for(unsigned int i = 0; i < 16; ++i) {
        if(UDPC_IPV6_ADDR_SUB(a)[i] != UDPC_IPV6_ADDR_SUB(b)[i]) {
            return false;
        }
    }
    return true;
}

UDPC::ConnectionData::ConnectionData(bool isUsingLibsodium) :
flags(),
id(0),
lseq(0),
rseq(0),
ack(0xFFFFFFFF),
timer(std::chrono::steady_clock::duration::zero()),
toggleT(UDPC::THIRTY_SECONDS),
toggleTimer(std::chrono::steady_clock::duration::zero()),
toggledTimer(std::chrono::steady_clock::duration::zero()),
addr({0}),
scope_id(0),
port(0),
sentPkts(),
sendPkts(),
priorityPkts(),
sentInfoMap(),
received(std::chrono::steady_clock::now()),
sent(std::chrono::steady_clock::now()),
rtt(std::chrono::steady_clock::duration::zero()),
verifyMessage()
{
    flags.set(0);
    flags.reset(1);

#ifdef UDPC_LIBSODIUM_ENABLED
    if(isUsingLibsodium) {
        if(sodium_init() >= 0) {
            crypto_sign_keypair(pk, sk);
            flags.reset(5);
            flags.set(6);
        } else {
            flags.set(5);
            flags.reset(6);
        }
    } else {
        flags.reset(5);
        flags.reset(6);
    }
#else
    flags.reset(5);
    flags.reset(6);
#endif
}

UDPC::ConnectionData::ConnectionData(
        bool isServer,
        Context *ctx,
        UDPC_IPV6_ADDR_TYPE addr,
        uint32_t scope_id,
        uint16_t port,
        bool isUsingLibsodium,
        unsigned char *sk,
        unsigned char *pk) :
flags(),
id(0),
lseq(0),
rseq(0),
ack(0xFFFFFFFF),
timer(std::chrono::steady_clock::duration::zero()),
toggleT(UDPC::THIRTY_SECONDS),
toggleTimer(std::chrono::steady_clock::duration::zero()),
toggledTimer(std::chrono::steady_clock::duration::zero()),
addr(addr),
scope_id(scope_id),
port(port),
sentPkts(),
sendPkts(),
priorityPkts(),
sentInfoMap(),
received(std::chrono::steady_clock::now()),
sent(std::chrono::steady_clock::now()),
rtt(std::chrono::steady_clock::duration::zero()),
verifyMessage()
{
    flags.set(3);
    if(isServer) {
        id = UDPC::generateConnectionID(*ctx);
        flags.set(4);
    } else {
        lseq = 1;
    }

#ifdef UDPC_LIBSODIUM_ENABLED
    if(isUsingLibsodium) {
        if(sodium_init() >= 0) {
            if(sk && pk) {
                std::memcpy(this->sk, sk, crypto_sign_SECRETKEYBYTES);
                std::memcpy(this->pk, pk, crypto_sign_PUBLICKEYBYTES);
            } else {
                crypto_sign_keypair(this->pk, this->sk);
            }
            flags.reset(5);
            flags.set(6);
        } else {
            flags.set(5);
            flags.reset(6);
        }
    } else {
        flags.reset(5);
        flags.reset(6);
    }
#else
    flags.reset(5);
    flags.reset(6);
#endif
}

UDPC::ConnectionData::~ConnectionData() {
    for(auto iter = sentPkts.begin(); iter != sentPkts.end(); ++iter) {
        std::free(iter->data);
    }
    for(auto iter = sendPkts.begin(); iter != sendPkts.end(); ++iter) {
        std::free(iter->data);
    }
    for(auto iter = priorityPkts.begin(); iter != priorityPkts.end(); ++iter) {
        std::free(iter->data);
    }
}

void UDPC::ConnectionData::cleanupSentPkts() {
    uint32_t id;
    while(sentPkts.size() > UDPC_SENT_PKTS_MAX_SIZE) {
        std::memcpy(&id, sentPkts.front().data + 8, 4);
        id = ntohl(id);
        auto iter = sentInfoMap.find(id);
        assert(iter != sentInfoMap.end()
                && "Sent packet must have correspoding entry in sentInfoMap");
        sentInfoMap.erase(iter);
        std::free(sentPkts.front().data);
        sentPkts.pop_front();
    }
}

UDPC::Context::Context(bool isThreaded) :
_contextIdentifier(UDPC_CONTEXT_IDENTIFIER),
flags(),
isAcceptNewConnections(true),
isReceivingEvents(false),
isAutoUpdating(false),
protocolID(UDPC_DEFAULT_PROTOCOL_ID),
#ifndef NDEBUG
loggingType(UDPC_DEBUG),
#else
loggingType(UDPC_WARNING),
#endif
authPolicy(UDPC_AUTH_POLICY_FALLBACK),
#if UDPC_PLATFORM == UPDC_PLATFORM_WINDOWS
socketHandle(INVALID_SOCKET),
#else
socketHandle(0),
#endif
socketInfo(),
lastUpdated(),
conMap(),
addrConMap(),
idMap(),
deletionMap(),
peerPKWhitelist(),
receivedPkts(),
receivedPktsMutex(),
cSendPkts(),
internalEvents(),
internalEventsMutex(),
externalEvents(),
externalEventsMutex(),
rng_engine(),
thread(),
threadRunning(),
conMapMutex(),
peerPKWhitelistMutex(),
threadedSleepTime(std::chrono::milliseconds(UDPC_UPDATE_MS_DEFAULT)),
keysSet(),
atostrBufIndexMutex(),
atostrBufIndex(0),
setThreadedUpdateMutex(),
enableDisableFuncRunningCount(0)
{
    std::memset(atostrBuf, 0, UDPC_ATOSTR_SIZE);

    if(isThreaded) {
        isAutoUpdating.store(true);
    } else {
        isAutoUpdating.store(false);
    }

    flags.reset(0);

    rng_engine.seed(std::chrono::system_clock::now().time_since_epoch().count());

    threadRunning.store(true);
    keysSet.store(false);
}

UDPC::Context::~Context() {
    // cleanup packets
    for(auto iter = receivedPkts.begin();
             iter != receivedPkts.end();
           ++iter) {
        std::free(iter->data);
    }
    {
        auto iter = cSendPkts.begin();
        auto current = iter.current();
        while(current) {
            std::free(current->data);
            if(!iter.next()) { break; }
            current = iter.current();
        }
    }
}

bool UDPC::Context::willLog(UDPC_LoggingType type) {
    switch(loggingType.load()) {
    case UDPC_LoggingType::UDPC_SILENT:
        return false;
    case UDPC_LoggingType::UDPC_ERROR:
        return type == UDPC_LoggingType::UDPC_ERROR;
    case UDPC_LoggingType::UDPC_WARNING:
        return type == UDPC_LoggingType::UDPC_ERROR
            || type == UDPC_LoggingType::UDPC_WARNING;
    case UDPC_LoggingType::UDPC_INFO:
        return type == UDPC_LoggingType::UDPC_ERROR
            || type == UDPC_LoggingType::UDPC_WARNING
            || type == UDPC_LoggingType::UDPC_INFO;
    case UDPC_LoggingType::UDPC_VERBOSE:
        return type == UDPC_LoggingType::UDPC_ERROR
            || type == UDPC_LoggingType::UDPC_WARNING
            || type == UDPC_LoggingType::UDPC_INFO
            || type == UDPC_LoggingType::UDPC_VERBOSE;
    case UDPC_LoggingType::UDPC_DEBUG:
        return type == UDPC_LoggingType::UDPC_ERROR
            || type == UDPC_LoggingType::UDPC_WARNING
            || type == UDPC_LoggingType::UDPC_INFO
            || type == UDPC_LoggingType::UDPC_VERBOSE
            || type == UDPC_LoggingType::UDPC_DEBUG;
    default:
        return false;
    }
}

void UDPC::Context::update_impl() {
    const auto now = std::chrono::steady_clock::now();
    std::chrono::steady_clock::duration dt = now - lastUpdated;
    std::chrono::steady_clock::duration temp_dt_fs;
    lastUpdated = now;

    // handle internalEvents
    {
        std::lock_guard<std::mutex> intEvLock(internalEventsMutex);
        while(!internalEvents.empty()) {
            auto event = internalEvents.front();
            internalEvents.pop_front();
            switch(event.type) {
            case UDPC_ET_REQUEST_CONNECT:
            {
                if(!isAcceptNewConnections.load()) {
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                        "Ignoring connection request because "
                        "accept-new-connections flag is false");
                    break;
                }
                unsigned char *sk = nullptr;
                unsigned char *pk = nullptr;
                if(keysSet.load()) {
                    sk = this->sk;
                    pk = this->pk;
                }
                UDPC::ConnectionData newCon(
                    false,
                    this,
                    event.conId.addr,
                    event.conId.scope_id,
                    event.conId.port,
#ifdef UDPC_LIBSODIUM_ENABLED
                    flags.test(2) && event.v.enableLibSodium != 0,
                    sk, pk);
#else
                    false,
                    sk, pk);
#endif
                if(newCon.flags.test(5)) {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_ERROR,
                        "Failed to init ConnectionData instance (libsodium "
                        "init fail) while client establishing connection with ",
                        event.conId.addr,
                        " port ",
                        event.conId.port);
                    continue;
                }
                newCon.sent = std::chrono::steady_clock::now() - UDPC::INIT_PKT_INTERVAL_DT;


                std::lock_guard<std::mutex> conMapLock(conMapMutex);
                if(conMap.find(event.conId) == conMap.end()) {
                    conMap.insert(std::make_pair(
                        event.conId,
                        std::move(newCon)));
                    auto addrConIter = addrConMap.find(event.conId.addr);
                    if(addrConIter == addrConMap.end()) {
                        auto insertResult = addrConMap.insert(std::make_pair(
                            event.conId.addr,
                            std::unordered_set<UDPC_ConnectionId, UDPC::ConnectionIdHasher>{}));
                        assert(insertResult.second &&
                            "new connection insert into addrConMap must not fail");
                        addrConIter = insertResult.first;
                    }
                    addrConIter->second.insert(event.conId);
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_INFO,
                        "Client initiating connection to ",
                        event.conId.addr,
                        " port ",
                        event.conId.port,
                        " ...");
                } else {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_WARNING,
                        "Client initiate connection, already connected to peer ",
                        event.conId.addr,
                        " port ",
                        event.conId.port);
                }
            }
                break;
            case UDPC_ET_REQUEST_DISCONNECT:
            {
                std::lock_guard<std::mutex> conMapLock(conMapMutex);
                if(event.v.dropAllWithAddr != 0) {
                    // drop all connections with same address
                    auto addrConIter = addrConMap.find(event.conId.addr);
                    if(addrConIter != addrConMap.end()) {
                        for(auto identIter = addrConIter->second.begin();
                                identIter != addrConIter->second.end();
                                ++identIter) {
                            assert(conMap.find(*identIter) != conMap.end()
                                && "conMap must have connection listed in "
                                "addrConMap");
                            deletionMap.insert(*identIter);
                        }
                    }
                } else {
                    // drop only specific connection with addr and port
                    auto iter = conMap.find(event.conId);
                    if(iter != conMap.end()) {
                        deletionMap.insert(iter->first);
                    }
                }
            }
                break;
            default:
                assert(!"internalEvents got invalid type");
                break;
            }
        }
    }

    {
        // check timed out, check good/bad mode with rtt, remove timed out
        std::vector<UDPC_ConnectionId> removed;
        std::lock_guard<std::mutex> conMapLock(conMapMutex);
        for(auto iter = conMap.begin(); iter != conMap.end(); ++iter) {
            temp_dt_fs = now - iter->second.received;
            if(temp_dt_fs >= UDPC::CONNECTION_TIMEOUT) {
                removed.push_back(iter->first);
                UDPC_CHECK_LOG(this,
                    UDPC_LoggingType::UDPC_VERBOSE,
                    "Timed out connection with ",
                    iter->first.addr,
                    ", port = ",
                    iter->second.port);
                continue;
            }

            // check good/bad mode
            iter->second.toggleTimer += dt;
            iter->second.toggledTimer += dt;
            if(iter->second.flags.test(1) && !iter->second.flags.test(2)) {
                // good mode, bad rtt
                UDPC_CHECK_LOG(this,
                    UDPC_LoggingType::UDPC_VERBOSE,
                    "Switching to bad mode in connection with ",
                    iter->first.addr,
                    ", port = ",
                    iter->second.port);
                iter->second.flags.reset(1);
                if(iter->second.toggledTimer <= UDPC::TEN_SECONDS) {
                    iter->second.toggleT *= 2;
                }
                iter->second.toggledTimer = std::chrono::steady_clock::duration::zero();
                if(isReceivingEvents.load()) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_BAD_MODE, iter->first, false});
                }
            } else if(iter->second.flags.test(1)) {
                // good mode, good rtt
                if(iter->second.toggleTimer >= UDPC::TEN_SECONDS) {
                    iter->second.toggleTimer = std::chrono::steady_clock::duration::zero();
                    iter->second.toggleT /= 2;
                    if(iter->second.toggleT < UDPC::ONE_SECOND) {
                        iter->second.toggleT = UDPC::ONE_SECOND;
                    }
                }
            } else if(!iter->second.flags.test(1) &&
                      iter->second.flags.test(2)) {
                // bad mode, good rtt
                if(iter->second.toggledTimer >= iter->second.toggleT) {
                    iter->second.toggleTimer = std::chrono::steady_clock::duration::zero();
                    iter->second.toggledTimer = std::chrono::steady_clock::duration::zero();
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_VERBOSE,
                        "Switching to good mode in connection with ",
                        iter->first.addr,
                        ", port = ",
                        iter->second.port);
                    iter->second.flags.set(1);
                    if(isReceivingEvents.load()) {
                        std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                        externalEvents.push_back(UDPC_Event{
                            UDPC_ET_GOOD_MODE, iter->first, false});
                    }
                }
            } else {
                // bad mode, bad rtt
                iter->second.toggledTimer = std::chrono::steady_clock::duration::zero();
            }

            iter->second.timer += dt;
            if(iter->second.flags.test(1)) {
                if(iter->second.timer >= UDPC::GOOD_MODE_SEND_RATE) {
                    iter->second.timer -= UDPC::GOOD_MODE_SEND_RATE;
                    iter->second.flags.set(0);
                }
            } else {
                if(iter->second.timer >= UDPC::BAD_MODE_SEND_RATE) {
                    iter->second.timer -= UDPC::BAD_MODE_SEND_RATE;
                    iter->second.flags.set(0);
                }
            }
        }
        for(auto iter = removed.begin(); iter != removed.end(); ++iter) {
            auto addrConIter = addrConMap.find(iter->addr);
            assert(addrConIter != addrConMap.end()
                    && "addrConMap must have an entry for a current connection");
            auto addrConSetIter = addrConIter->second.find(*iter);
            assert(addrConSetIter != addrConIter->second.end()
                    && "nested set in addrConMap must have an entry for a current connection");
            addrConIter->second.erase(addrConSetIter);
            if(addrConIter->second.empty()) {
                addrConMap.erase(addrConIter);
            }

            auto cIter = conMap.find(*iter);
            assert(cIter != conMap.end()
                    && "conMap must have the entry set to be removed");

            if(cIter->second.flags.test(4)) {
                idMap.erase(cIter->second.id);
            }
            if(isReceivingEvents.load()) {
                if(flags.test(1) && cIter->second.flags.test(3)) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_FAIL_CONNECT, *iter, false});
                } else {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_DISCONNECTED, *iter, false});
                }
            }

            conMap.erase(cIter);
        }
    }

    // move queued in cSendPkts to existing connection's sendPkts
    {
        auto sendIter = cSendPkts.begin();
        std::unordered_set<UDPC_ConnectionId, UDPC::ConnectionIdHasher> dropped;
        std::unordered_set<UDPC_ConnectionId, UDPC::ConnectionIdHasher> notQueued;
        while(true) {
            auto next = sendIter.current();
            if(next) {
                std::lock_guard<std::mutex> conMapLock(conMapMutex);
                auto iter = conMap.find(next->receiver);
                if(iter != conMap.end()) {
                    if(iter->second.sendPkts.size() >= UDPC_QUEUED_PKTS_MAX_SIZE) {
                        if(notQueued.find(next->receiver) == notQueued.end()) {
                            notQueued.insert(next->receiver);
                            UDPC_CHECK_LOG(this,
                                UDPC_LoggingType::UDPC_DEBUG,
                                "Not queueing packet to ",
                                next->receiver.addr,
                                ", port = ",
                                next->receiver.port,
                                ", connection's queue reached max size");
                        }
                        if(sendIter.next()) {
                            continue;
                        } else {
                            break;
                        }
                    }
                    iter->second.sendPkts.push_back(*next);
                    if(sendIter.remove()) {
                        continue;
                    } else {
                        break;
                    }
                } else {
                    if(dropped.find(next->receiver) == dropped.end()) {
                        UDPC_CHECK_LOG(this,
                            UDPC_LoggingType::UDPC_WARNING,
                            "Dropped queued packets to ",
                            next->receiver.addr,
                            ", port = ",
                            next->receiver.port,
                            " due to connection not existing");
                        dropped.insert(next->receiver);
                    }
                    if(sendIter.remove()) {
                        continue;
                    } else {
                        break;
                    }
                }
            } else {
                break;
            }
        }
    }

    // update send (only if triggerSend flag is set)
    {
        std::lock_guard<std::mutex> conMapLock(conMapMutex);
        for(auto iter = conMap.begin(); iter != conMap.end(); ++iter) {
            auto delIter = deletionMap.find(iter->first);
            if(!iter->second.flags.test(0) && delIter == deletionMap.end()) {
                continue;
            } else if(delIter != deletionMap.end()) {
                if(iter->second.flags.test(3)) {
                    // not initiated connection yet, no need to send disconnect pkt
                    continue;
                }
                unsigned int sendSize = 0;
                std::unique_ptr<char[]> buf;
                if(flags.test(2) && iter->second.flags.test(6)) {
                    sendSize = UDPC_LSFULL_HEADER_SIZE;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 1;
                } else {
                    sendSize = UDPC_NSFULL_HEADER_SIZE;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 0;
                }
                UDPC::preparePacket(
                    buf.get(),
                    protocolID,
                    iter->second.id,
                    iter->second.rseq,
                    iter->second.ack,
                    &iter->second.lseq,
                    0x3);
                if(flags.test(2) && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                    unsigned char sig[crypto_sign_BYTES];
                    std::memset(buf.get() + UDPC_MIN_HEADER_SIZE + 1, 0, crypto_sign_BYTES);
                    if(crypto_sign_detached(
                        sig, nullptr,
                        (unsigned char*)buf.get(), UDPC_LSFULL_HEADER_SIZE,
                        iter->second.sk) != 0) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                            "Failed to sign packet for peer ",
                            iter->first.addr,
                            ", port ",
                            iter->second.port);
                        continue;
                    }
                    std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE + 1, sig, crypto_sign_BYTES);
#else
                    assert(!"libsodium disabled, invalid state");
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "libsodium is disabled, cannot send packet");
                    continue;
#endif
                }

                UDPC_IPV6_SOCKADDR_TYPE destinationInfo;
                destinationInfo.sin6_family = AF_INET6;
                std::memcpy(
                    UDPC_IPV6_ADDR_SUB(destinationInfo.sin6_addr),
                    UDPC_IPV6_ADDR_SUB(iter->first.addr),
                    16);
                destinationInfo.sin6_port = htons(iter->second.port);
                destinationInfo.sin6_flowinfo = 0;
                destinationInfo.sin6_scope_id = iter->first.scope_id;
                long int sentBytes = sendto(
                    socketHandle,
                    buf.get(),
                    sendSize,
                    0,
                    (struct sockaddr*) &destinationInfo,
                    sizeof(UDPC_IPV6_SOCKADDR_TYPE));
                if(sentBytes != sendSize) {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_ERROR,
                        "Failed to send disconnect packet to ",
                        iter->first.addr,
                        ", port = ",
                        iter->second.port);
                    continue;
                }
                continue;
            }

            // clear triggerSend flag
            iter->second.flags.reset(0);

            if(iter->second.flags.test(3)) {
                if(flags.test(1)) {
                    // is initiating connection to server
                    auto initDT = now - iter->second.sent;
                    if(initDT < UDPC::INIT_PKT_INTERVAL_DT) {
                        continue;
                    }
                    iter->second.sent = now;

                    std::unique_ptr<char[]> buf;
                    unsigned int sendSize = 0;
                    if(flags.test(2) && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                        sendSize = UDPC_CCL_HEADER_SIZE;
                        buf = std::unique_ptr<char[]>(new char[sendSize]);
                        // set type 1
                        uint32_t temp = htonl(1);
                        std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE, &temp, 4);
                        // set public key
                        std::memcpy(
                            buf.get() + UDPC_MIN_HEADER_SIZE + 4,
                            iter->second.pk,
                            crypto_sign_PUBLICKEYBYTES);
                        // set verify message
                        // time in seconds from epoch
                        std::time_t time = std::time(nullptr);
                        if(time <= 0) {
                            UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                                "Failed to get current epoch time");
                            continue;
                        }
                        uint64_t timeInt = time;
# ifndef NDEBUG
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_DEBUG,
                            "Client set up verification epoch time \"",
                            timeInt, "\"");
# endif
                        UDPC::be64((char*)&timeInt);
                        iter->second.verifyMessage =
                            std::unique_ptr<char[]>(new char[12]);
                        // prepend with random data generated by client
                        uint32_t rdata = randombytes_random();
                        std::memcpy(
                            iter->second.verifyMessage.get(),
                            &rdata,
                            4);
                        std::memcpy(
                            iter->second.verifyMessage.get() + 4,
                            &timeInt,
                            8);
                        std::memcpy(
                            buf.get() + UDPC_MIN_HEADER_SIZE + 4 + crypto_sign_PUBLICKEYBYTES,
                            iter->second.verifyMessage.get(),
                            12);
#else
                        assert(!"libsodium is disabled, invalid state");
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                            "libsodium is disabled, cannot send packet");
                        continue;
#endif
                    } else {
                        sendSize = UDPC_CON_HEADER_SIZE;
                        buf = std::unique_ptr<char[]>(new char[sendSize]);
                        buf[UDPC_MIN_HEADER_SIZE] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 1] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 2] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 3] = 0;
                    }
                    UDPC::preparePacket(
                        buf.get(),
                        protocolID,
                        0,
                        0,
                        0xFFFFFFFF,
                        nullptr,
                        0x1);

                    UDPC_IPV6_SOCKADDR_TYPE destinationInfo;
                    destinationInfo.sin6_family = AF_INET6;
                    std::memcpy(UDPC_IPV6_ADDR_SUB(destinationInfo.sin6_addr), UDPC_IPV6_ADDR_SUB(iter->first.addr), 16);
                    destinationInfo.sin6_port = htons(iter->second.port);
                    destinationInfo.sin6_flowinfo = 0;
                    destinationInfo.sin6_scope_id = iter->first.scope_id;
                    long int sentBytes = sendto(
                        socketHandle,
                        buf.get(),
                        sendSize,
                        0,
                        (struct sockaddr*) &destinationInfo,
                        sizeof(UDPC_IPV6_SOCKADDR_TYPE));
                    if(sentBytes != sendSize) {
                        UDPC_CHECK_LOG(this,
                            UDPC_LoggingType::UDPC_ERROR,
                            "Failed to send packet to initiate connection to ",
                            iter->first.addr,
                            ", port = ",
                            iter->second.port);
                        continue;
                    } else {
                        UDPC_CHECK_LOG(
                            this,
                            UDPC_LoggingType::UDPC_INFO,
                            "Sent initiate connection to ",
                            iter->first.addr,
                            ", port = ",
                            iter->second.port,
                            flags.test(2) && iter->second.flags.test(6) ?
                                ", libsodium enabled" : ", libsodium disabled");
                    }
                } else {
                    // is server, initiate connection to client
                    iter->second.flags.reset(3);
                    iter->second.sent = now;

                    std::unique_ptr<char[]> buf;
                    unsigned int sendSize = 0;
                    if(flags.test(2) && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                        sendSize = UDPC_CSR_HEADER_SIZE;
                        buf = std::unique_ptr<char[]>(new char[sendSize]);
                        // set type
                        uint32_t temp = htonl(2);
                        std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE, &temp, 4);
                        // set pubkey
                        std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE + 4,
                            iter->second.pk,
                            crypto_sign_PUBLICKEYBYTES);
                        // set detached sig
                        assert(iter->second.verifyMessage &&
                            "Detached sig in verifyMessage must exist");
                        std::memcpy(
                            buf.get() + UDPC_MIN_HEADER_SIZE + 4 + crypto_sign_PUBLICKEYBYTES,
                            iter->second.verifyMessage.get(),
                            crypto_sign_BYTES);
#else
                        assert(!"libsodium disabled, invalid state");
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                            "libsodium is disabled, cannot send packet");
                        continue;
#endif
                    } else {
                        sendSize = UDPC_CON_HEADER_SIZE;
                        buf = std::unique_ptr<char[]>(new char[sendSize]);
                        buf[UDPC_MIN_HEADER_SIZE] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 1] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 2] = 0;
                        buf[UDPC_MIN_HEADER_SIZE + 3] = 0;
                    }
                    UDPC::preparePacket(
                        buf.get(),
                        protocolID,
                        iter->second.id,
                        iter->second.rseq,
                        iter->second.ack,
                        &iter->second.lseq,
                        0x1);

                    UDPC_IPV6_SOCKADDR_TYPE destinationInfo;
                    destinationInfo.sin6_family = AF_INET6;
                    std::memcpy(UDPC_IPV6_ADDR_SUB(destinationInfo.sin6_addr), UDPC_IPV6_ADDR_SUB(iter->first.addr), 16);
                    destinationInfo.sin6_port = htons(iter->second.port);
                    destinationInfo.sin6_flowinfo = 0;
                    destinationInfo.sin6_scope_id = iter->first.scope_id;
                    long int sentBytes = sendto(
                        socketHandle,
                        buf.get(),
                        sendSize,
                        0,
                        (struct sockaddr*) &destinationInfo,
                        sizeof(UDPC_IPV6_SOCKADDR_TYPE));
                    if(sentBytes != sendSize) {
                        UDPC_CHECK_LOG(this,
                            UDPC_LoggingType::UDPC_ERROR,
                            "Failed to send packet to initiate connection to ",
                            iter->first.addr,
                            ", port = ",
                            iter->second.port);
                        continue;
                    }
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_DEBUG,
                        "Sent init pkt to client ",
                        destinationInfo.sin6_addr,
                        ", port ", iter->second.port);
                }
                continue;
            }

            // Not initiating connection, send as normal on current connection
            if(iter->second.sendPkts.empty() && iter->second.priorityPkts.empty()) {
                // nothing in queues, send heartbeat packet
                auto sentDT = now - iter->second.sent;
                if(sentDT < UDPC::HEARTBEAT_PKT_INTERVAL_DT) {
                    continue;
                }

                unsigned int sendSize = 0;
                std::unique_ptr<char[]> buf;
                if(flags.test(2) && iter->second.flags.test(6)) {
                    sendSize = UDPC_LSFULL_HEADER_SIZE;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 1;
                } else {
                    sendSize = UDPC_NSFULL_HEADER_SIZE;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 0;
                }
                UDPC::preparePacket(
                    buf.get(),
                    protocolID,
                    iter->second.id,
                    iter->second.rseq,
                    iter->second.ack,
                    &iter->second.lseq,
                    0);
                if(flags.test(2) && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                    unsigned char sig[crypto_sign_BYTES];
                    std::memset(buf.get() + UDPC_MIN_HEADER_SIZE + 1, 0, crypto_sign_BYTES);
                    if(crypto_sign_detached(
                        sig, nullptr,
                        (unsigned char*)buf.get(), UDPC_LSFULL_HEADER_SIZE,
                        iter->second.sk) != 0) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                            "Failed to sign packet for peer ",
                            iter->first.addr,
                            ", port ",
                            iter->second.port);
                        continue;
                    }
                    std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE + 1, sig, crypto_sign_BYTES);
#else
                    assert(!"libsodium disabled, invalid state");
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "libsodium is disabled, cannot send packet");
                    continue;
#endif
                }

                UDPC_IPV6_SOCKADDR_TYPE destinationInfo;
                destinationInfo.sin6_family = AF_INET6;
                std::memcpy(
                    UDPC_IPV6_ADDR_SUB(destinationInfo.sin6_addr),
                    UDPC_IPV6_ADDR_SUB(iter->first.addr),
                    16);
                destinationInfo.sin6_port = htons(iter->second.port);
                destinationInfo.sin6_flowinfo = 0;
                destinationInfo.sin6_scope_id = iter->first.scope_id;
                long int sentBytes = sendto(
                    socketHandle,
                    buf.get(),
                    sendSize,
                    0,
                    (struct sockaddr*) &destinationInfo,
                    sizeof(UDPC_IPV6_SOCKADDR_TYPE));
                if(sentBytes != sendSize) {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_ERROR,
                        "Failed to send heartbeat packet to ",
                        iter->first.addr,
                        ", port = ",
                        iter->second.port);
                    continue;
                }

                UDPC_PacketInfo pInfo = UDPC::get_empty_pinfo();
                pInfo.dataSize = UDPC_NSFULL_HEADER_SIZE;
                pInfo.data = (char*)std::malloc(pInfo.dataSize);
                pInfo.flags = 0x4;
                pInfo.sender.addr = in6addr_loopback;
                pInfo.receiver.addr = iter->first.addr;
                pInfo.sender.port = ntohs(socketInfo.sin6_port);
                pInfo.receiver.port = iter->second.port;
                uint32_t temp = htonl(iter->second.lseq - 1);
                std::memcpy(pInfo.data + 8, &temp, 4);
                pInfo.data[UDPC_MIN_HEADER_SIZE] = flags.test(2) && iter->second.flags.test(6) ? 1 : 0;

                iter->second.sentPkts.push_back(std::move(pInfo));
                iter->second.cleanupSentPkts();

                // store other pkt info
                UDPC::SentPktInfo::Ptr sentPktInfo = std::make_shared<UDPC::SentPktInfo>();
                sentPktInfo->id = iter->second.lseq - 1;
                iter->second.sentInfoMap.insert(std::make_pair(sentPktInfo->id, sentPktInfo));
            } else {
                // sendPkts or priorityPkts not empty
                UDPC_PacketInfo pInfo = UDPC::get_empty_pinfo();
                bool isResending = false;
                if(!iter->second.priorityPkts.empty()) {
                    pInfo = iter->second.priorityPkts.front();
                    iter->second.priorityPkts.pop_front();
                    isResending = true;
                } else {
                    pInfo = iter->second.sendPkts.front();
                    iter->second.sendPkts.pop_front();
                }

                std::unique_ptr<char[]> buf;
                unsigned int sendSize = 0;
                if(flags.test(2) && iter->second.flags.test(6)) {
                    sendSize = UDPC_LSFULL_HEADER_SIZE + pInfo.dataSize;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 1;
                } else {
                    sendSize = UDPC_NSFULL_HEADER_SIZE + pInfo.dataSize;
                    buf = std::unique_ptr<char[]>(new char[sendSize]);
                    buf[UDPC_MIN_HEADER_SIZE] = 0;
                }

                UDPC::preparePacket(
                    buf.get(),
                    protocolID,
                    iter->second.id,
                    iter->second.rseq,
                    iter->second.ack,
                    &iter->second.lseq,
                    (pInfo.flags & 0x4) | (isResending ? 0x8 : 0));

                if(flags.test(2) && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                    unsigned char sig[crypto_sign_BYTES];
                    std::memset(buf.get() + UDPC_MIN_HEADER_SIZE + 1, 0, crypto_sign_BYTES);
                    std::memcpy(buf.get() + UDPC_LSFULL_HEADER_SIZE, pInfo.data, pInfo.dataSize);
                    if(crypto_sign_detached(
                        sig, nullptr,
                        (unsigned char*)buf.get(), sendSize,
                        iter->second.sk) != 0) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                            "Failed to sign packet for peer ",
                            iter->first.addr,
                            ", port ",
                            iter->second.port);
                        std::free(pInfo.data);
                        continue;
                    }
                    std::memcpy(buf.get() + UDPC_MIN_HEADER_SIZE + 1, sig, crypto_sign_BYTES);
#else
                    assert(!"libsodium disabled, invalid state");
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "libsodium is disabled, cannot send packet");
                    std::free(pInfo.data);
                    continue;
#endif
                } else {
                    std::memcpy(buf.get() + UDPC_NSFULL_HEADER_SIZE, pInfo.data, pInfo.dataSize);
                }


                UDPC_IPV6_SOCKADDR_TYPE destinationInfo;
                destinationInfo.sin6_family = AF_INET6;
                std::memcpy(
                    UDPC_IPV6_ADDR_SUB(destinationInfo.sin6_addr),
                    UDPC_IPV6_ADDR_SUB(iter->first.addr),
                    16);
                destinationInfo.sin6_port = htons(iter->second.port);
                destinationInfo.sin6_flowinfo = 0;
                destinationInfo.sin6_scope_id = iter->first.scope_id;
                long int sentBytes = sendto(
                    socketHandle,
                    buf.get(),
                    sendSize,
                    0,
                    (struct sockaddr*) &destinationInfo,
                    sizeof(UDPC_IPV6_SOCKADDR_TYPE));
                if(sentBytes != sendSize) {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_ERROR,
                        "Failed to send packet to ",
                        iter->first.addr,
                        ", port = ",
                        iter->second.port);
                    std::free(pInfo.data);
                    continue;
                }

                if((pInfo.flags & 0x4) == 0) {
                    // is check-received, store data in case packet gets lost
                    UDPC_PacketInfo sentPInfo = UDPC::get_empty_pinfo();
                    sentPInfo.dataSize = sendSize;
                    sentPInfo.data = (char*)std::malloc(sentPInfo.dataSize);
                    std::memcpy(sentPInfo.data, buf.get(), sendSize);
                    sentPInfo.flags = 0;
                    sentPInfo.sender.addr = in6addr_loopback;
                    sentPInfo.receiver.addr = iter->first.addr;
                    sentPInfo.sender.port = ntohs(socketInfo.sin6_port);
                    sentPInfo.receiver.port = iter->second.port;

                    iter->second.sentPkts.push_back(std::move(sentPInfo));
                    iter->second.cleanupSentPkts();
                } else {
                    // is not check-received, only id stored in data array
                    UDPC_PacketInfo sentPInfo = UDPC::get_empty_pinfo();
                    sentPInfo.dataSize = UDPC_MIN_HEADER_SIZE;
                    sentPInfo.data = (char*)std::malloc(sentPInfo.dataSize);
                    sentPInfo.flags = 0x4;
                    sentPInfo.sender.addr = in6addr_loopback;
                    sentPInfo.receiver.addr = iter->first.addr;
                    sentPInfo.sender.port = ntohs(socketInfo.sin6_port);
                    sentPInfo.receiver.port = iter->second.port;
                    uint32_t temp = htonl(iter->second.lseq - 1);
                    std::memcpy(sentPInfo.data + 8, &temp, 4);

                    iter->second.sentPkts.push_back(std::move(sentPInfo));
                    iter->second.cleanupSentPkts();
                }

                // store other pkt info
                UDPC::SentPktInfo::Ptr sentPktInfo = std::make_shared<UDPC::SentPktInfo>();
                sentPktInfo->id = iter->second.lseq - 1;
                iter->second.sentInfoMap.insert(std::make_pair(sentPktInfo->id, sentPktInfo));
                std::free(pInfo.data);
            }
            iter->second.sent = now;
        }
    }

    // remove queued for deletion
    for(auto delIter = deletionMap.begin(); delIter != deletionMap.end(); ++delIter) {
        std::lock_guard<std::mutex> conMapLock(conMapMutex);
        auto iter = conMap.find(*delIter);
        if(iter != conMap.end()) {
            if(iter->second.flags.test(4)) {
                idMap.erase(iter->second.id);
            }
            auto addrConIter = addrConMap.find(delIter->addr);
            if(addrConIter != addrConMap.end()) {
                addrConIter->second.erase(*delIter);
                if(addrConIter->second.empty()) {
                    addrConMap.erase(addrConIter);
                }
            }
            if(isReceivingEvents.load()) {
                if(flags.test(1) && iter->second.flags.test(3)) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_FAIL_CONNECT, iter->first, false});
                } else {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_DISCONNECTED, iter->first, false});
                }
            }
            conMap.erase(iter);
        }
    }
    deletionMap.clear();

    // receive packet
    do {
        UDPC_IPV6_SOCKADDR_TYPE receivedData;
        socklen_t receivedDataSize = sizeof(receivedData);
        int bytes = recvfrom(
            socketHandle,
            recvBuf,
            UDPC_PACKET_MAX_SIZE,
            0,
            (struct sockaddr*) &receivedData,
            &receivedDataSize);

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
        if(bytes == 0) {
            // connection closed
            break;
        } else if(bytes == SOCKET_ERROR) {
            int error = WSAGetLastError();
            if(error != WSAEWOULDBLOCK) {
                UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                    "Error receiving packet, ", error);
            }
            break;
        }
#else
        if(bytes == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) {
            // no packet was received
            break;
        }
#endif
        else if(bytes < UDPC_MIN_HEADER_SIZE) {
            // packet size is too small, invalid packet
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Received packet is smaller than header, ignoring packet from ",
                receivedData.sin6_addr,
                ", port = ",
                ntohs(receivedData.sin6_port));
            continue;
        }

        uint32_t temp;
        std::memcpy(&temp, recvBuf, 4);
        temp = ntohl(temp);
        if(temp != protocolID) {
            // Invalid protocol id in packet
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Received packet has invalid protocol id, ignoring packet "
                "from ",
                receivedData.sin6_addr,
                ", port = ",
                ntohs(receivedData.sin6_port));
            continue;
        }

        std::memcpy(&temp, recvBuf + 4, 4);
        uint32_t conID = ntohl(temp);
        std::memcpy(&temp, recvBuf + 8, 4);
        uint32_t seqID = ntohl(temp);
        std::memcpy(&temp, recvBuf + 12, 4);
        uint32_t rseq = ntohl(temp);
        std::memcpy(&temp, recvBuf + 16, 4);
        uint32_t ack = ntohl(temp);

        bool isConnect = conID & UDPC_ID_CONNECT;
        bool isPing = conID & UDPC_ID_PING;
        bool isNotRecChecked = conID & UDPC_ID_NO_REC_CHK;
        bool isResending = conID & UDPC_ID_RESENDING;
        conID &= 0x0FFFFFFF;
        UDPC_ConnectionId identifier =
            UDPC_create_id_full(receivedData.sin6_addr,
                                receivedData.sin6_scope_id,
                                ntohs(receivedData.sin6_port));

        if(isConnect && !isPing && bytes < (int)(UDPC_CON_HEADER_SIZE)) {
            // invalid packet size
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Got connect packet of invalid size from ",
                receivedData.sin6_addr,
                ", port = ",
                ntohs(receivedData.sin6_port),
                ", ignoring");
            continue;
        } else if ((!isConnect || (isConnect && isPing))
                && bytes < (int)UDPC_NSFULL_HEADER_SIZE) {
            // packet is too small
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Got non-connect packet of invalid size from ",
                receivedData.sin6_addr,
                ", port = ",
                ntohs(receivedData.sin6_port),
                ", ignoring");
            continue;
        }

        uint32_t pktType;
        if(isConnect && !isPing) {
            std::memcpy(&pktType, recvBuf + UDPC_MIN_HEADER_SIZE, 4);
            pktType = ntohl(pktType);
            switch(pktType) {
            case 0: // client/server connect with libsodium disabled
                break;
            case 1: // client connect with libsodium enabled
                break;
            case 2: // server connect with libsodium enabled
                break;
            default:
                UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                    "Got invalid connect pktType from ",
                    receivedData.sin6_addr,
                    ", port ", ntohs(receivedData.sin6_port));
                continue;
            }
        } else {
            if(recvBuf[UDPC_MIN_HEADER_SIZE] == 0) {
                // not signed
                pktType = 0;
            } else if(recvBuf[UDPC_MIN_HEADER_SIZE] == 1) {
                // signed
                pktType = 1;
            } else {
                UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                    "Got invalid pktType from ",
                    receivedData.sin6_addr,
                    ", port ", ntohs(receivedData.sin6_port));
                continue;
            }
        }

        if(isConnect && !isPing) {
            // is connect packet and is accepting new connections
            std::lock_guard<std::mutex> conMapLock(conMapMutex);
            if(!flags.test(1)
                    && conMap.find(identifier) == conMap.end()
                    && isAcceptNewConnections.load()) {
                // is receiving as server, connection did not already exist
                int authPolicy = this->authPolicy.load();
                if(pktType == 1 && !flags.test(2)
                        && authPolicy
                            == UDPC_AuthPolicy::UDPC_AUTH_POLICY_STRICT) {
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "Client peer ",
                        receivedData.sin6_addr,
                        " port ",
                        ntohs(receivedData.sin6_port),
                        " attempted connection with packet authentication "
                        "enabled, but auth is disabled and AuthPolicy is "
                        "STRICT");
                    continue;
                } else if(pktType == 0 && flags.test(2)
                        && authPolicy
                            == UDPC_AuthPolicy::UDPC_AUTH_POLICY_STRICT) {
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "Client peer ",
                        receivedData.sin6_addr,
                        " port ",
                        ntohs(receivedData.sin6_port),
                        " attempted connection with packet authentication "
                        "disabled, but auth is enabled and AuthPolicy is "
                        "STRICT");
                    continue;
                }
                unsigned char *sk = nullptr;
                unsigned char *pk = nullptr;
                if(keysSet.load()) {
                    sk = this->sk;
                    pk = this->pk;
                }
                UDPC::ConnectionData newConnection(
                    true,
                    this,
                    receivedData.sin6_addr,
                    receivedData.sin6_scope_id,
                    ntohs(receivedData.sin6_port),
#ifdef UDPC_LIBSODIUM_ENABLED
                    pktType == 1 && flags.test(2),
                    sk, pk);
#else
                    false,
                    sk, pk);
#endif

                if(newConnection.flags.test(5)) {
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_ERROR,
                        "Failed to init ConnectionData instance (libsodium init"
                        " fail) while server establishing connection with ",
                        receivedData.sin6_addr,
                        ", port = ",
                        ntohs(receivedData.sin6_port));
                    continue;
                }
                if(pktType == 1 && flags.test(2)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                    std::memcpy(
                        newConnection.peer_pk,
                        recvBuf + UDPC_MIN_HEADER_SIZE + 4,
                        crypto_sign_PUBLICKEYBYTES);
                    {
                        std::lock_guard<std::mutex>
                            pkWhitelistLock(peerPKWhitelistMutex);
                        if(!peerPKWhitelist.empty()
                                && peerPKWhitelist.find(
                                    UDPC::PKContainer(newConnection.peer_pk))
                                        == peerPKWhitelist.end()) {
                            UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                                "peer_pk is not in whitelist, not establishing "
                                "connection with client");
                            continue;
                        }
                    }
                    newConnection.verifyMessage =
                        std::unique_ptr<char[]>(new char[crypto_sign_BYTES]);
                    std::time_t currentTime = std::time(nullptr);
                    uint64_t receivedTime;
                    std::memcpy(
                        &receivedTime,
                        recvBuf + UDPC_MIN_HEADER_SIZE + 4
                            + crypto_sign_PUBLICKEYBYTES + 4,
                        8);
                    UDPC::be64((char*)&receivedTime);
# ifndef NDEBUG
                    if(willLog(UDPC_LoggingType::UDPC_DEBUG)) {
                        log_impl(UDPC_LoggingType::UDPC_DEBUG,
                            "Server got verification epoch time \"",
                            receivedTime, "\"");
                    }
# endif
                    std::time_t receivedTimeT = receivedTime;
                    if(currentTime < receivedTimeT
                            || currentTime - receivedTimeT > 3) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                            "Got invalid epoch time from client, ignoring");
                        continue;
                    }
                    crypto_sign_detached(
                        (unsigned char*)newConnection.verifyMessage.get(),
                        nullptr,
                        (unsigned char*)(recvBuf + UDPC_MIN_HEADER_SIZE + 4
                            + crypto_sign_PUBLICKEYBYTES),
                        12,
                        newConnection.sk);
#else
                    assert(!"libsodium disabled, invalid state");
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "libsodium is disabled, cannot process received "
                        "packet");
                    continue;
#endif
                }
                UDPC_CHECK_LOG(this,
                    UDPC_LoggingType::UDPC_INFO,
                    "Establishing connection with client ",
                    receivedData.sin6_addr,
                    ", port = ",
                    ntohs(receivedData.sin6_port),
                    ", giving client id = ", newConnection.id,
                    pktType == 1 && flags.test(2) ?
                        ", libsodium enabled" : ", libsodium disabled");

                idMap.insert(std::make_pair(newConnection.id, identifier));
                conMap.insert(std::make_pair(identifier,
                                             std::move(newConnection)));
                auto addrConIter = addrConMap.find(identifier.addr);
                if(addrConIter == addrConMap.end()) {
                    auto insertResult = addrConMap.insert(
                        std::make_pair(
                            identifier.addr,
                            std::unordered_set<UDPC_ConnectionId,
                                               UDPC::ConnectionIdHasher>{}
                        ));
                    assert(insertResult.second
                            && "Must successfully insert into addrConMap");
                    addrConIter = insertResult.first;
                }
                addrConIter->second.insert(identifier);
                if(isReceivingEvents.load()) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_CONNECTED,
                        identifier,
                        false});
                }
            } else if (flags.test(1)) {
                // is client
                auto iter = conMap.find(identifier);
                if(iter == conMap.end() || !iter->second.flags.test(3)) {
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_DEBUG,
                        "client dropped pkt from ",
                        receivedData.sin6_addr,
                        ", port ", ntohs(receivedData.sin6_port));
                    continue;
                }
                int authPolicy = this->authPolicy.load();
                if(pktType == 2 && !iter->second.flags.test(6)
                        && authPolicy
                            == UDPC_AuthPolicy::UDPC_AUTH_POLICY_STRICT) {
                    // This block actually should never happen, because the
                    // server receives a packet first. If client requests
                    // without auth, then the server will either deny
                    // connection (if strict) or fallback to a connection
                    // without auth (if fallback).
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "Server peer ",
                        receivedData.sin6_addr,
                        " port ",
                        ntohs(receivedData.sin6_port),
                        " attempted connection with packet authentication "
                        "enabled, but auth is disabled and AuthPolicy is "
                        "STRICT");
                    continue;
                } else if(pktType == 0 && iter->second.flags.test(6)
                        && authPolicy
                            == UDPC_AuthPolicy::UDPC_AUTH_POLICY_STRICT) {
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "Server peer ",
                        receivedData.sin6_addr,
                        " port ",
                        ntohs(receivedData.sin6_port),
                        " attempted connection with packet authentication "
                        "disabled, but auth is enabled and AuthPolicy is "
                        "STRICT");
                    continue;
                }

                if(pktType == 2 && flags.test(2)
                        && iter->second.flags.test(6)) {
#ifdef UDPC_LIBSODIUM_ENABLED
                    std::memcpy(iter->second.peer_pk,
                        recvBuf + UDPC_MIN_HEADER_SIZE + 4,
                        crypto_sign_PUBLICKEYBYTES);
                    {
                        std::lock_guard<std::mutex>
                            pkWhitelistLock(peerPKWhitelistMutex);
                        if(!peerPKWhitelist.empty()
                                && peerPKWhitelist.find(
                                    UDPC::PKContainer(iter->second.peer_pk))
                                        == peerPKWhitelist.end()) {
                            UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                                "peer_pk is not in whitelist, not establishing "
                                "connection with server");
                            continue;
                        }
                    }
                    if(crypto_sign_verify_detached(
                        (unsigned char*)(recvBuf + UDPC_MIN_HEADER_SIZE + 4
                            + crypto_sign_PUBLICKEYBYTES),
                        (unsigned char*)(iter->second.verifyMessage.get()),
                        12,
                        iter->second.peer_pk) != 0) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                            "Failed to verify peer (server) ",
                            receivedData.sin6_addr,
                            ", port = ",
                            ntohs(receivedData.sin6_port));
                        continue;
                    }
#else
                    assert(!"libsodium disabled, invalid state");
                    UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                        "libsodium is disabled, cannot process received "
                        "packet");
                    continue;
#endif
                } else if(pktType == 0 && iter->second.flags.test(6)) {
                    iter->second.flags.reset(6);
                    if(iter->second.flags.test(7)) {
                        UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_WARNING,
                            "peer is not using libsodium, but peer_pk was "
                            "pre-set, dropping to no-verification mode");
                    }
                }

                iter->second.flags.reset(3);
                iter->second.id = conID;
                iter->second.flags.set(4);
                UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_INFO,
                    "Established connection with server ",
                    receivedData.sin6_addr,
                    ", port = ",
                    ntohs(receivedData.sin6_port),
                    ", got id = ", conID,
                    flags.test(2) && iter->second.flags.test(6) ?
                        ", libsodium enabled" : ", libsodium disabled");
                if(isReceivingEvents.load()) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_CONNECTED,
                        identifier,
                        false});
                }
            }
            continue;
        }

        std::lock_guard<std::mutex> conMapLock(conMapMutex);
        auto iter = conMap.find(identifier);
        if(iter == conMap.end() || iter->second.flags.test(3)
                || !iter->second.flags.test(4) || iter->second.id != conID) {
            continue;
        } else if(isPing && !isConnect) {
            iter->second.flags.set(0);
        }

        if(pktType == 1) {
#ifdef UDPC_LIBSODIUM_ENABLED
            // verify signature of header
            unsigned char sig[crypto_sign_BYTES];
            std::memcpy(sig,
                        recvBuf + UDPC_MIN_HEADER_SIZE + 1,
                        crypto_sign_BYTES);
            std::memset(recvBuf + UDPC_MIN_HEADER_SIZE + 1,
                        0,
                        crypto_sign_BYTES);
            if(crypto_sign_verify_detached(
                sig,
                (unsigned char*)recvBuf,
                bytes,
                iter->second.peer_pk) != 0) {
                UDPC_CHECK_LOG(
                    this,
                    UDPC_LoggingType::UDPC_INFO,
                    "Failed to verify received packet from",
                    receivedData.sin6_addr,
                    ", port = ",
                    ntohs(receivedData.sin6_port),
                    ", ignoring");
                continue;
            }
#else
            assert(!"libsodium disabled, invalid state");
            UDPC_CHECK_LOG(this, UDPC_LoggingType::UDPC_ERROR,
                "libsodium is disabled, cannot process received packet");
            continue;
#endif
        }

        // packet is valid
        UDPC_CHECK_LOG(this,
            UDPC_LoggingType::UDPC_VERBOSE,
            "Received valid packet from ",
            receivedData.sin6_addr,
            ", port = ",
            ntohs(receivedData.sin6_port),
            ", packet id = ", seqID,
            ", good mode = ", iter->second.flags.test(1) ? "yes" : "no",
            isPing && !isConnect ? ", ping"
                : (isPing && isConnect ? ", disc" : ""));

        // check if is delete
        if(isConnect && isPing) {
            auto conIter = conMap.find(identifier);
            if(conIter != conMap.end()) {
                UDPC_CHECK_LOG(this,
                    UDPC_LoggingType::UDPC_VERBOSE,
                    "Packet is request-disconnect packet, deleting "
                    "connection...");
                if(conIter->second.flags.test(4)) {
                    idMap.erase(conIter->second.id);
                }
                auto addrConIter = addrConMap.find(identifier.addr);
                if(addrConIter != addrConMap.end()) {
                    addrConIter->second.erase(identifier);
                    if(addrConIter->second.empty()) {
                        addrConMap.erase(addrConIter);
                    }
                }
                if(isReceivingEvents.load()) {
                    std::lock_guard<std::mutex> extEvLock(externalEventsMutex);
                    externalEvents.push_back(UDPC_Event{
                        UDPC_ET_DISCONNECTED, identifier, false});
                }
                conMap.erase(conIter);
                continue;
            }
        }

        // update rtt
        for(auto sentIter = iter->second.sentPkts.rbegin();
                sentIter != iter->second.sentPkts.rend();
                ++sentIter) {
            uint32_t id;
            std::memcpy(&id, sentIter->data + 8, 4);
            id = ntohl(id);
            if(id == rseq) {
                auto sentInfoIter = iter->second.sentInfoMap.find(id);
                assert(sentInfoIter != iter->second.sentInfoMap.end()
                        && "sentInfoMap should have known stored id");
                auto diff = now - sentInfoIter->second->sentTime;
                if(diff > iter->second.rtt) {
                    iter->second.rtt += (diff - iter->second.rtt) / 10;
                } else {
                    iter->second.rtt -= (iter->second.rtt - diff) / 10;
                }

                iter->second.flags.set(
                    2, iter->second.rtt <= UDPC::GOOD_RTT_LIMIT);

                UDPC_CHECK_LOG(this,
                    UDPC_LoggingType::UDPC_VERBOSE,
                    "RTT: ",
                    UDPC::durationToFSec(iter->second.rtt) * 1000.0f,
                    " milliseconds");
                break;
            }
        }

        iter->second.received = now;

        // check pkt timeout
        --rseq;
        for(; ack != 0; ack = ack << 1) {
            if((ack & 0x80000000) != 0) {
                --rseq;
                continue;
            }

            // pkt not received yet, find it in sent to check if it timed out
            for(auto sentIter = iter->second.sentPkts.rbegin();
                    sentIter != iter->second.sentPkts.rend();
                    ++sentIter) {
                uint32_t sentID;
                std::memcpy(&sentID, sentIter->data + 8, 4);
                sentID = ntohl(sentID);
                if(sentID == rseq) {
                    if((sentIter->flags & 0x4) != 0
                            || (sentIter->flags & 0x8) != 0) {
                        // already resent or not rec-checked pkt
                        break;
                    }
                    auto sentInfoIter = iter->second.sentInfoMap.find(sentID);
                    assert(sentInfoIter != iter->second.sentInfoMap.end()
                            && "Every entry in sentPkts must have a "
                            "corresponding entry in sentInfoMap");
                    auto duration = now - sentInfoIter->second->sentTime;
                    if(duration > UDPC::PACKET_TIMEOUT_TIME) {
                        bool pktSigned =
                            sentIter->data[UDPC_MIN_HEADER_SIZE] == 1;
                        if((pktSigned
                                && sentIter->dataSize
                                    <= UDPC_LSFULL_HEADER_SIZE
                                ) ||
                                    (!pktSigned
                                    && sentIter->dataSize
                                        <= UDPC_NSFULL_HEADER_SIZE)) {
                            UDPC_CHECK_LOG(this,
                                UDPC_LoggingType::UDPC_VERBOSE,
                                "Timed out packet has no payload (probably "
                                "heartbeat packet), ignoring it");
                            sentIter->flags |= 0x8;
                            break;
                        }

                        UDPC_PacketInfo resendingData = UDPC::get_empty_pinfo();
                        if(pktSigned) {
                            resendingData.dataSize =
                                sentIter->dataSize - UDPC_LSFULL_HEADER_SIZE;
                            resendingData.data =
                                (char*)std::malloc(resendingData.dataSize);
                            std::memcpy(resendingData.data,
                                sentIter->data + UDPC_LSFULL_HEADER_SIZE,
                                resendingData.dataSize);
                        } else {
                            resendingData.dataSize =
                                sentIter->dataSize - UDPC_NSFULL_HEADER_SIZE;
                            resendingData.data =
                                (char*)std::malloc(resendingData.dataSize);
                            std::memcpy(resendingData.data,
                                sentIter->data + UDPC_NSFULL_HEADER_SIZE,
                                resendingData.dataSize);
                        }
                        resendingData.flags = 0;
                        iter->second.priorityPkts.push_back(resendingData);
                    }
                    break;
                }
            }

            --rseq;
        }

        // calculate sequence and ack
        bool isOutOfOrder = false;
        uint32_t diff = 0;
        if(seqID > iter->second.rseq) {
            diff = seqID - iter->second.rseq;
            if(diff <= 0x7FFFFFFF) {
                // sequence is more recent
                iter->second.rseq = seqID;
                iter->second.ack = (iter->second.ack >> diff) | 0x80000000;
            } else {
                // sequence is older, recalc diff
                diff = 0xFFFFFFFF - seqID + 1 + iter->second.rseq;
                if((iter->second.ack & (0x80000000 >> (diff - 1))) != 0) {
                    // already received packet
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_VERBOSE,
                        "Received packet is already marked as received, "
                        "ignoring it");
                    continue;
                }
                iter->second.ack |= 0x80000000 >> (diff - 1);
                isOutOfOrder = true;
            }
        } else if(seqID < iter->second.rseq) {
            diff = iter->second.rseq - seqID;
            if(diff <= 0x7FFFFFFF) {
                // sequence is older
                if((iter->second.ack & (0x80000000 >> (diff - 1))) != 0) {
                    // already received packet
                    UDPC_CHECK_LOG(this,
                        UDPC_LoggingType::UDPC_VERBOSE,
                        "Received packet is already marked as received, "
                        "ignoring it");
                    continue;
                }
                iter->second.ack |= 0x80000000 >> (diff - 1);
                isOutOfOrder = true;
            } else {
                // sequence is more recent, recalc diff
                diff = 0xFFFFFFFF - iter->second.rseq + 1 + seqID;
                iter->second.rseq = seqID;
                iter->second.ack = (iter->second.ack >> diff) | 0x80000000;
            }
        } else {
            // already received packet
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Received packet is already marked as received, ignoring it");
            continue;
        }

        if(isOutOfOrder) {
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_INFO,
                "Received packet is out of order");
        }

        if(pktType == 0 && bytes > (int)UDPC_NSFULL_HEADER_SIZE) {
            UDPC_PacketInfo recPktInfo = UDPC::get_empty_pinfo();
            recPktInfo.dataSize = bytes - UDPC_NSFULL_HEADER_SIZE;
            recPktInfo.data = (char*)std::malloc(recPktInfo.dataSize);
            std::memcpy(recPktInfo.data,
                        recvBuf + UDPC_NSFULL_HEADER_SIZE,
                        recPktInfo.dataSize);
            recPktInfo.flags =
                (isConnect ? 0x1 : 0)
                | (isPing ? 0x2 : 0)
                | (isNotRecChecked ? 0x4 : 0)
                | (isResending ? 0x8 : 0);
            recPktInfo.sender.addr = receivedData.sin6_addr;
            recPktInfo.receiver.addr = in6addr_loopback;
            recPktInfo.sender.port = ntohs(receivedData.sin6_port);
            recPktInfo.receiver.port = ntohs(socketInfo.sin6_port);
            recPktInfo.rtt = durationToMS(iter->second.rtt);
            recPktInfo.id = seqID;

            std::lock_guard<std::mutex> receivedPktsLock(receivedPktsMutex);
            receivedPkts.push_back(recPktInfo);
        } else if(pktType == 1 && bytes > (int)UDPC_LSFULL_HEADER_SIZE) {
            UDPC_PacketInfo recPktInfo = UDPC::get_empty_pinfo();
            recPktInfo.dataSize = bytes - UDPC_LSFULL_HEADER_SIZE;
            recPktInfo.data = (char*)std::malloc(recPktInfo.dataSize);
            std::memcpy(recPktInfo.data,
                        recvBuf + UDPC_LSFULL_HEADER_SIZE,
                        recPktInfo.dataSize);
            recPktInfo.flags =
                (isConnect ? 0x1 : 0)
                | (isPing ? 0x2 : 0)
                | (isNotRecChecked ? 0x4 : 0)
                | (isResending ? 0x8 : 0);
            recPktInfo.sender.addr = receivedData.sin6_addr;
            recPktInfo.receiver.addr = in6addr_loopback;
            recPktInfo.sender.port = ntohs(receivedData.sin6_port);
            recPktInfo.receiver.port = ntohs(socketInfo.sin6_port);
            recPktInfo.rtt = durationToMS(iter->second.rtt);
            recPktInfo.id = seqID;

            std::lock_guard<std::mutex> receivedPktsLock(receivedPktsMutex);
            receivedPkts.push_back(recPktInfo);
        } else {
            UDPC_CHECK_LOG(this,
                UDPC_LoggingType::UDPC_VERBOSE,
                "Received packet has no payload (probably heartbeat packet)");
        }
    } while (true);
}

UDPC::Context *UDPC::verifyContext(UDPC_HContext ctx) {
    if(ctx == nullptr) {
        return nullptr;
    }
    UDPC::Context *c = (UDPC::Context *)ctx;
    if(c->_contextIdentifier == UDPC_CONTEXT_IDENTIFIER) {
        return c;
    } else {
        return nullptr;
    }
}

bool UDPC::isBigEndian() {
    /*
     * 0 - unset
     * 1 - is big endian
     * 2 - is not big endian
     */
    static char isBigEndian = 0;
    if(isBigEndian != 0) {
        return isBigEndian == 1;
    }
    union {
        uint32_t i;
        char c[4];
    } bint = {0x01020304};

    isBigEndian = (bint.c[0] == 1 ? 1 : 2);
    return isBigEndian == 1;
}

void UDPC::be64(char *integer) {
    if(UDPC::isBigEndian()) {
        return;
    }
    char conv[8];
    for(unsigned int i = 0; i < 8; ++i) {
        conv[i] = integer[7 - i];
    }
    std::memcpy(integer, conv, 8);
}

void UDPC::be64_copy(char *out, const char *in) {
    if(UDPC::isBigEndian()) {
        return;
    }
    for(unsigned int i = 0; i < 8; ++i) {
        out[i] = in[7 - i];
    }
}

void UDPC::preparePacket(
        char *data, uint32_t protocolID, uint32_t conID, uint32_t rseq,
        uint32_t ack, uint32_t *seqID, int flags) {
    uint32_t temp;

    temp = htonl(protocolID);
    std::memcpy(data, &temp, 4);
    temp = htonl(conID | ((flags & 0x1) != 0 ? UDPC_ID_CONNECT : 0) |
                 ((flags & 0x2) != 0 ? UDPC_ID_PING : 0) |
                 ((flags & 0x4) != 0 ? UDPC_ID_NO_REC_CHK : 0) |
                 ((flags & 0x8) != 0 ? UDPC_ID_RESENDING : 0));
    std::memcpy(data + 4, &temp, 4);

    if(seqID) {
        temp = htonl(*seqID);
        ++(*seqID);
    } else {
        temp = 0;
    }
    std::memcpy(data + 8, &temp, 4);

    temp = htonl(rseq);
    std::memcpy(data + 12, &temp, 4);
    temp = htonl(ack);
    std::memcpy(data + 16, &temp, 4);
}

uint32_t UDPC::generateConnectionID(Context &ctx) {
    auto dist = std::uniform_int_distribution<uint32_t>(0, 0x0FFFFFFF);
    uint32_t id = dist(ctx.rng_engine);
    while(ctx.idMap.find(id) != ctx.idMap.end()) {
        id = dist(ctx.rng_engine);
    }
    return id;
}

float UDPC::durationToFSec(const std::chrono::steady_clock::duration& duration) {
    return (float)duration.count()
        * (float)std::chrono::steady_clock::duration::period::num
        / (float)std::chrono::steady_clock::duration::period::den;
}

uint16_t UDPC::durationToMS(const std::chrono::steady_clock::duration& duration) {
    return std::chrono::duration_cast<std::chrono::milliseconds>(duration).count();
}

float UDPC::timePointsToFSec(
        const std::chrono::steady_clock::time_point& older,
        const std::chrono::steady_clock::time_point& newer) {
    const auto dt = newer - older;
    return (float)dt.count()
        * (float)decltype(dt)::period::num / (float)decltype(dt)::period::den;
}

UDPC_PacketInfo UDPC::get_empty_pinfo() {
    UDPC_PacketInfo pinfo;
    std::memset(&pinfo, 0, sizeof(UDPC_PacketInfo));
    return pinfo;
}

void UDPC::threadedUpdate(Context *ctx) {
    auto now = std::chrono::steady_clock::now();
    decltype(now) nextNow;
    while(ctx->threadRunning.load()) {
        now = std::chrono::steady_clock::now();
        ctx->update_impl();
        nextNow = std::chrono::steady_clock::now();
        std::this_thread::sleep_for(ctx->threadedSleepTime - (nextNow - now));
    }
}

UDPC_ConnectionId UDPC_create_id(UDPC_IPV6_ADDR_TYPE addr, uint16_t port) {
    UDPC_ConnectionId result;

    std::memset(&result, 0, sizeof(UDPC_ConnectionId));

    result.addr = addr;
//    result.scope_id = 0;
    result.port = port;
    return result;
}

UDPC_ConnectionId UDPC_create_id_full(UDPC_IPV6_ADDR_TYPE addr, uint32_t scope_id, uint16_t port) {
    UDPC_ConnectionId result;

    std::memset(&result, 0, sizeof(UDPC_ConnectionId));

    result.addr = addr;
    result.scope_id = scope_id;
    result.port = port;
    return result;
}

UDPC_ConnectionId UDPC_create_id_anyaddr(uint16_t port) {
    UDPC_ConnectionId result;

    std::memset(&result, 0, sizeof(UDPC_ConnectionId));

//    result.addr = in6addr_any;
    result.scope_id = 0;
    result.port = port;
    return result;
}

UDPC_ConnectionId UDPC_create_id_easy(const char *addrString, uint16_t port) {
    UDPC_ConnectionId result;

    std::memset(&result, 0, sizeof(UDPC_ConnectionId));

    result.port = port;

    if(std::regex_match(addrString, ipv6_regex_nolink)
            || std::regex_match(addrString, ipv4_regex)) {
        result.addr = UDPC_strtoa(addrString);
    } else if(std::regex_match(addrString, ipv6_regex_linkonly)) {
        result.addr = UDPC_strtoa_link(addrString, &result.scope_id);
    } else {
        result.addr = in6addr_loopback;
    }
    return result;
}

UDPC_ConnectionId UDPC_create_id_hostname(const char *hostname, uint16_t port) {
    UDPC_ConnectionId result;
    std::memset(&result, 0, sizeof(UDPC_ConnectionId));
    result.port = port;

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
    WORD wVersionRequested = MAKEWORD(2, 2);
    WSADATA wsaData;
    if(WSAStartup(wVersionRequested, &wsaData) != 0) {
        fprintf(stderr, "Failed to initialize Winsock\n");
        return result;
    }
#elif UDPC_PLATFORM == UDPC_PLATFORM_MAC || UDPC_PLATFORM == UDPC_PLATFORM_LINUX
#endif
    addrinfo hints;
    std::memset(&hints, 0, sizeof(addrinfo));

    hints.ai_family = AF_UNSPEC;
    hints.ai_socktype = SOCK_DGRAM;
    hints.ai_protocol = IPPROTO_UDP;

    addrinfo *lookupResult;
    int error = getaddrinfo(hostname, nullptr, &hints, &lookupResult);

    if(error == 0) {
        if(lookupResult->ai_family == AF_INET) {
            sockaddr_in *a4 = (sockaddr_in*)lookupResult->ai_addr;
            result.addr = UDPC_a4toa6(a4->sin_addr.s_addr);
        } else if(lookupResult->ai_family == AF_INET6) {
            sockaddr_in6 *a6 = (sockaddr_in6*)lookupResult->ai_addr;
            result.addr = a6->sin6_addr;
        } else {
            result.addr = in6addr_loopback;
        }
        freeaddrinfo(lookupResult);
    } else {
        result.addr = in6addr_loopback;
    }

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
    WSACleanup();
#endif

    return result;
}

UDPC_HContext UDPC_init(UDPC_ConnectionId listenId, int isClient, int isUsingLibsodium) {
    UDPC::Context *ctx = new UDPC::Context(false);
    ctx->flags.set(1, isClient != 0);
    ctx->authPolicy.exchange(UDPC_AuthPolicy::UDPC_AUTH_POLICY_FALLBACK);

    UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_INFO, "Got listen addr ",
        listenId.addr);

    if(isUsingLibsodium) {
#ifdef UDPC_LIBSODIUM_ENABLED
        // initialize libsodium
        if(sodium_init() < 0) {
            UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR,
                "Failed to initialize libsodium");
            delete ctx;
            return nullptr;
        } else {
            ctx->flags.set(2);
        }
#else
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR,
            "Cannot use libsodium, UDPC was compiled without libsodium support");
        delete ctx;
        return nullptr;
#endif
    } else {
        ctx->flags.reset(2);
    }

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
    // Initialize Winsock
    WORD wVersionRequested = MAKEWORD(2, 2);
    WSADATA wsaData;
    if(WSAStartup(wVersionRequested, &wsaData) != 0) {
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR, "Failed to initialize Winsock");
        delete ctx;
        return nullptr;
    }
#endif

    // create socket
    ctx->socketHandle = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
    if(UDPC_SOCKET_RETURN_ERROR(ctx->socketHandle)) {
        // TODO maybe different way of handling init fail
#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR, "Failed to create socket, ",
            WSAGetLastError());
#else
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR, "Failed to create socket");
#endif
        delete ctx;
        return nullptr;
    }

    // allow ipv4 connections on ipv6 socket
    {
#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
        char no = 0;
#else
        int no = 0;
#endif
        setsockopt(ctx->socketHandle, IPPROTO_IPV6, IPV6_V6ONLY, &no, sizeof(no));
    }

    // bind socket
    ctx->socketInfo.sin6_family = AF_INET6;
    ctx->socketInfo.sin6_addr = listenId.addr;
    ctx->socketInfo.sin6_port = htons(listenId.port);
    ctx->socketInfo.sin6_flowinfo = 0;
    ctx->socketInfo.sin6_scope_id = listenId.scope_id;
    if(bind(ctx->socketHandle, (const struct sockaddr *)&ctx->socketInfo,
            sizeof(UDPC_IPV6_SOCKADDR_TYPE)) < 0) {
        // TODO maybe different way of handling init fail
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR, "Failed to bind socket");
        UDPC_CLEANUPSOCKET(ctx->socketHandle);
        delete ctx;
        return nullptr;
    }

    // TODO verify this is necessary to get the listen port
    if(ctx->socketInfo.sin6_port == 0) {
        UDPC_IPV6_SOCKADDR_TYPE getInfo;
        socklen_t size = sizeof(UDPC_IPV6_SOCKADDR_TYPE);
        if(getsockname(ctx->socketHandle, (struct sockaddr *)&getInfo, &size) == 0) {
            ctx->socketInfo.sin6_port = getInfo.sin6_port;
        }
    }

    // set non-blocking on socket
#if UDPC_PLATFORM == UDPC_PLATFORM_MAC || UDPC_PLATFORM == UDPC_PLATFORM_LINUX
    int nonblocking = 1;
    if(fcntl(ctx->socketHandle, F_SETFL, O_NONBLOCK, nonblocking) == -1) {
#elif UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
    DWORD nonblocking = 1;
    if(ioctlsocket(ctx->socketHandle, FIONBIO, &nonblocking) != 0) {
#else
    {
#endif
        // TODO maybe different way of handling init fail
        UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_ERROR, "Failed to set nonblocking on socket");
        UDPC_CLEANUPSOCKET(ctx->socketHandle);
        delete ctx;
        return nullptr;
    }

    UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_INFO, "Initialized UDPC");

    return (UDPC_HContext) ctx;
}

UDPC_HContext UDPC_init_threaded_update(UDPC_ConnectionId listenId,
                                int isClient, int isUsingLibsodium) {
    UDPC::Context *ctx = (UDPC::Context *)UDPC_init(listenId, isClient, isUsingLibsodium);
    if(!ctx) {
        return nullptr;
    }

    ctx->isAutoUpdating.store(true);
    ctx->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_DEFAULT);
    ctx->thread = std::thread(UDPC::threadedUpdate, ctx);

    UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_INFO, "Initialized threaded UDPC");

    return (UDPC_HContext) ctx;
}

UDPC_HContext UDPC_init_threaded_update_ms(
        UDPC_ConnectionId listenId,
        int isClient,int updateMS, int isUsingLibsodium) {
    UDPC::Context *ctx = (UDPC::Context *)UDPC_init(
        listenId, isClient, isUsingLibsodium);
    if(!ctx) {
        return nullptr;
    }

    ctx->isAutoUpdating.store(true);
    if(updateMS < UDPC_UPDATE_MS_MIN) {
        ctx->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_MIN);
    } else if(updateMS > UDPC_UPDATE_MS_MAX) {
        ctx->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_MAX);
    } else {
        ctx->threadedSleepTime = std::chrono::milliseconds(updateMS);
    }
    ctx->thread = std::thread(UDPC::threadedUpdate, ctx);

    UDPC_CHECK_LOG(ctx, UDPC_LoggingType::UDPC_INFO, "Initialized threaded UDPC");

    return (UDPC_HContext) ctx;
}

int UDPC_enable_threaded_update(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if (!c) {
        return 0;
    }

    c->enableDisableFuncRunningCount.fetch_add(1);

    std::lock_guard<std::mutex> setThreadedLock(c->setThreadedUpdateMutex);

    if(c->flags.test(0) || c->isAutoUpdating.load() || c->thread.joinable()) {
        c->enableDisableFuncRunningCount.fetch_sub(1);
        return 0;
    }

    c->isAutoUpdating.store(true);
    c->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_DEFAULT);
    c->threadRunning.store(true);
    c->thread = std::thread(UDPC::threadedUpdate, c);

    UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Started threaded update");

    c->enableDisableFuncRunningCount.fetch_sub(1);

    return 1;
}

int UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if (!c) {
        return 0;
    }

    c->enableDisableFuncRunningCount.fetch_add(1);

    std::lock_guard<std::mutex> setThreadedLock(c->setThreadedUpdateMutex);

    if(c->flags.test(0) || c->isAutoUpdating.load() || c->thread.joinable()) {
        c->enableDisableFuncRunningCount.fetch_sub(1);
        return 0;
    }

    c->isAutoUpdating.store(true);
    if(updateMS < UDPC_UPDATE_MS_MIN) {
        c->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_MIN);
    } else if(updateMS > UDPC_UPDATE_MS_MAX) {
        c->threadedSleepTime = std::chrono::milliseconds(UDPC_UPDATE_MS_MAX);
    } else {
        c->threadedSleepTime = std::chrono::milliseconds(updateMS);
    }
    c->threadRunning.store(true);
    c->thread = std::thread(UDPC::threadedUpdate, c);

    UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Started threaded update");

    c->enableDisableFuncRunningCount.fetch_sub(1);

    return 1;
}

int UDPC_disable_threaded_update(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if (!c) {
        return 0;
    }

    c->enableDisableFuncRunningCount.fetch_add(1);

    std::lock_guard<std::mutex> setThreadedLock(c->setThreadedUpdateMutex);

    if(c->flags.test(0) || !c->isAutoUpdating.load() || !c->thread.joinable()) {
        c->enableDisableFuncRunningCount.fetch_sub(1);
        return 0;
    }

    c->threadRunning.store(false);
    c->thread.join();
    c->isAutoUpdating.store(false);

    UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Stopped threaded update");

    c->enableDisableFuncRunningCount.fetch_sub(1);

    return 1;
}

int UDPC_is_valid_context(UDPC_HContext ctx) {
    return UDPC::verifyContext(ctx) != nullptr ? 1 : 0;
}

void UDPC_destroy(UDPC_HContext ctx) {
    UDPC::Context *UDPC_ctx = UDPC::verifyContext(ctx);
    if(UDPC_ctx) {
        {
            // Acquire lock so that this code does not run at the same time as
            // enabling/disabling threaded-update.
            std::lock_guard<std::mutex>
                setThreadedLock(UDPC_ctx->setThreadedUpdateMutex);

            // Stop thread if threaded.
            // Set atomic bool to false always so that the thread will always
            // stop at this point.
            UDPC_ctx->threadRunning.store(false);
            if(UDPC_ctx->isAutoUpdating.load() && UDPC_ctx->thread.joinable()) {
                UDPC_ctx->thread.join();
            }
            UDPC_ctx->isAutoUpdating.store(false);

            // Set destructing flag.
            UDPC_ctx->flags.set(0);

            // Drop lock at this point before destructing the context.
        }

        // After lock has been dropped, wait in case there are enable/disable
        // threaded update functions waiting on the lock. Do this via a
        // atomic-int-based spin-lock.
        while(UDPC_ctx->enableDisableFuncRunningCount.load() != 0) {
            std::this_thread::sleep_for(std::chrono::milliseconds(10));
        }

#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
        WSACleanup();
#endif
        UDPC_ctx->_contextIdentifier = 0;
        delete UDPC_ctx;
    }
}

void UDPC_update(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || c->isAutoUpdating.load()) {
        // invalid or is threaded, update should not be called
        return;
    }

    c->update_impl();
}

void UDPC_client_initiate_connection(
        UDPC_HContext ctx,
        UDPC_ConnectionId connectionId,
        int enableLibSodium) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(1)) {
        return;
    }
#ifndef UDPC_LIBSODIUM_ENABLED
    if(enableLibSodium) {
        UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_ERROR,
            "Cannot enable libsodium, UDPC was compiled without libsodium");
        return;
    }
#endif

    std::lock_guard<std::mutex> intEvLock(c->internalEventsMutex);
    c->internalEvents.push_back(UDPC_Event{UDPC_ET_REQUEST_CONNECT, connectionId, enableLibSodium});
}

void UDPC_queue_send(UDPC_HContext ctx, UDPC_ConnectionId destinationId,
                     int isChecked, const void *data, uint32_t size) {
    if(size == 0 || !data) {
        return;
    }

    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return;
    }

    UDPC_PacketInfo sendInfo = UDPC::get_empty_pinfo();
    sendInfo.dataSize = size;
    sendInfo.data = (char*)std::malloc(sendInfo.dataSize);
    std::memcpy(sendInfo.data, data, size);
    sendInfo.sender.addr = in6addr_loopback;
    sendInfo.sender.port = ntohs(c->socketInfo.sin6_port);
    sendInfo.receiver.addr = destinationId.addr;
    sendInfo.receiver.port = destinationId.port;
    sendInfo.flags = (isChecked != 0 ? 0x0 : 0x4);

    c->cSendPkts.push(sendInfo);
}

unsigned long UDPC_get_queue_send_current_size(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->cSendPkts.size();
}

unsigned long UDPC_get_queued_size(UDPC_HContext ctx, UDPC_ConnectionId id, int *exists) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    std::lock_guard<std::mutex> conMapLock(c->conMapMutex);
    auto iter = c->conMap.find(id);
    if(iter != c->conMap.end()) {
        if(exists) {
            *exists = 1;
        }
        return iter->second.sendPkts.size();
    }
    if(exists) {
        *exists = 0;
    }
    return 0;
}

unsigned long UDPC_get_max_queued_size() {
    return UDPC_QUEUED_PKTS_MAX_SIZE;
}

int UDPC_set_accept_new_connections(UDPC_HContext ctx, int isAccepting) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }
    return c->isAcceptNewConnections.exchange(isAccepting == 0 ? false : true)
        ? 1 : 0;
}

void UDPC_drop_connection(UDPC_HContext ctx, UDPC_ConnectionId connectionId, int dropAllWithAddr) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return;
    }

    std::lock_guard<std::mutex> intEvLock(c->internalEventsMutex);
    c->internalEvents.push_back(UDPC_Event{UDPC_ET_REQUEST_DISCONNECT, connectionId, dropAllWithAddr});
    return;
}

int UDPC_has_connection(UDPC_HContext ctx, UDPC_ConnectionId connectionId) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    std::lock_guard<std::mutex> conMapLock(c->conMapMutex);

    return c->conMap.find(connectionId) == c->conMap.end() ? 0 : 1;
}

UDPC_ConnectionId* UDPC_get_list_connected(UDPC_HContext ctx, unsigned int *size) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return nullptr;
    }

    std::lock_guard<std::mutex> conMapLock(c->conMapMutex);

    if(c->conMap.empty()) {
        if(size) {
            *size = 0;
        }
        return nullptr;
    }
    if(size) {
        *size = c->conMap.size();
    }

    UDPC_ConnectionId *list = (UDPC_ConnectionId*)std::calloc(
            c->conMap.size() + 1, sizeof(UDPC_ConnectionId));
    UDPC_ConnectionId *current = list;
    for(auto iter = c->conMap.begin(); iter != c->conMap.end(); ++iter) {
        *current = iter->first;
        ++current;
    }
    // following line is redudnant, since calloc initialized all bits to zero
//    *current = UDPC_ConnectionId{{0}, 0, 0};
    return list;
}

void UDPC_free_list_connected(UDPC_ConnectionId *list) {
    if(list) { std::free(list); }
}

uint32_t UDPC_get_protocol_id(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->protocolID.load();
}

uint32_t UDPC_set_protocol_id(UDPC_HContext ctx, uint32_t id) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->protocolID.exchange(id);
}

UDPC_LoggingType UDPC_get_logging_type(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return UDPC_LoggingType::UDPC_SILENT;
    }
    return static_cast<UDPC_LoggingType>(c->loggingType.load());
}

UDPC_LoggingType UDPC_set_logging_type(UDPC_HContext ctx, UDPC_LoggingType loggingType) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return UDPC_LoggingType::UDPC_SILENT;
    }
    return static_cast<UDPC_LoggingType>(c->loggingType.exchange(loggingType));
}

int UDPC_get_receiving_events(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->isReceivingEvents.load() ? 1 : 0;
}

int UDPC_set_receiving_events(UDPC_HContext ctx, int isReceivingEvents) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->isReceivingEvents.exchange(isReceivingEvents != 0) ? 1 : 0;
}

UDPC_Event UDPC_get_event(UDPC_HContext ctx, unsigned long *remaining) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return UDPC_Event{UDPC_ET_NONE, UDPC_create_id_anyaddr(0), 0};
    }

    std::lock_guard<std::mutex> extEvLock(c->externalEventsMutex);
    if(c->externalEvents.empty()) {
        if(remaining) { *remaining = 0; }
        return UDPC_Event{UDPC_ET_NONE, UDPC_create_id_anyaddr(0), 0};
    } else {
        auto event = c->externalEvents.front();
        c->externalEvents.pop_front();
        if(remaining) { *remaining = c->externalEvents.size(); }
        return event;
    }
}

UDPC_PacketInfo UDPC_get_received(UDPC_HContext ctx, unsigned long *remaining) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return UDPC::get_empty_pinfo();
    }

    std::lock_guard<std::mutex> receivedPktsLock(c->receivedPktsMutex);
    if(c->receivedPkts.empty()) {
        if(remaining) { *remaining = 0; }
        return UDPC::get_empty_pinfo();
    } else {
        auto pinfo = c->receivedPkts.front();
        c->receivedPkts.pop_front();
        if(remaining) { *remaining = c->receivedPkts.size(); }
        return pinfo;
    }
}

void UDPC_free_PacketInfo(UDPC_PacketInfo pInfo) {
    if(pInfo.data && pInfo.dataSize > 0) {
        std::free(pInfo.data);
    }
}

void UDPC_free_PacketInfo_ptr(UDPC_PacketInfo *pInfoPtr) {
    if (pInfoPtr && pInfoPtr->data && pInfoPtr->dataSize > 0) {
        std::free(pInfoPtr->data);
        pInfoPtr->data = nullptr;
        pInfoPtr->dataSize = 0;
    }
}

int UDPC_set_libsodium_keys(UDPC_HContext ctx, const unsigned char *sk, const unsigned char *pk) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    c->keysSet.store(false);
    std::memcpy(c->sk, sk, crypto_sign_SECRETKEYBYTES);
    std::memcpy(c->pk, pk, crypto_sign_PUBLICKEYBYTES);
    c->keysSet.store(true);
    return 1;
}

int UDPC_set_libsodium_key_easy(UDPC_HContext ctx, const unsigned char *sk) {
#ifndef UDPC_LIBSODIUM_ENABLED
    return 0;
#else
    unsigned char pk[crypto_sign_PUBLICKEYBYTES];
    if(crypto_sign_ed25519_sk_to_pk(pk, sk) != 0) {
        return 0;
    }
    return UDPC_set_libsodium_keys(ctx, sk, pk);
#endif
}

int UDPC_unset_libsodium_keys(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    c->keysSet.store(false);
    std::memset(c->pk, 0, crypto_sign_PUBLICKEYBYTES);
    std::memset(c->sk, 0, crypto_sign_SECRETKEYBYTES);
    return 1;
}

int UDPC_add_whitelist_pk(UDPC_HContext ctx, const unsigned char *pk) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    std::lock_guard<std::mutex> pkWhitelistLock(c->peerPKWhitelistMutex);
    auto result = c->peerPKWhitelist.insert(UDPC::PKContainer(pk));
    if(result.second) {
        return c->peerPKWhitelist.size();
    }
    return 0;
}

int UDPC_has_whitelist_pk(UDPC_HContext ctx, const unsigned char *pk) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    std::lock_guard<std::mutex> pkWhitelistLock(c->peerPKWhitelistMutex);
    if(c->peerPKWhitelist.find(UDPC::PKContainer(pk)) != c->peerPKWhitelist.end()) {
        return 1;
    }
    return 0;
}

int UDPC_remove_whitelist_pk(UDPC_HContext ctx, const unsigned char *pk) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    std::lock_guard<std::mutex> pkWhitelistLock(c->peerPKWhitelistMutex);
    if(c->peerPKWhitelist.erase(UDPC::PKContainer(pk)) != 0) {
        return 1;
    }
    return 0;
}

int UDPC_clear_whitelist(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c || !c->flags.test(2)) {
        return 0;
    }

    std::lock_guard<std::mutex> pkWhitelistLock(c->peerPKWhitelistMutex);
    c->peerPKWhitelist.clear();
    return 1;
}

int UDPC_get_auth_policy(UDPC_HContext ctx) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    return c->authPolicy.load();
}

int UDPC_set_auth_policy(UDPC_HContext ctx, int policy) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return 0;
    }

    bool isInRange = false;
    for(int i = 0; i < UDPC_AuthPolicy::UDPC_AUTH_POLICY_SIZE; ++i) {
        if(policy == i) {
            isInRange = true;
            break;
        }
    }
    if(!isInRange) {
        return 0;
    }

    return c->authPolicy.exchange(policy);
}

const char *UDPC_atostr_cid(UDPC_HContext ctx, UDPC_ConnectionId connectionId) {
    return UDPC_atostr(ctx, connectionId.addr);
}

void UDPC_Helper_atostr(char *buffer,
                        UDPC_IPV6_ADDR_TYPE addr,
                        const uint32_t headIndex) {
    uint32_t index = headIndex;
    bool usedDouble = false;

    for(unsigned int i = 0; i < 16; ++i) {
        if(i != 0 && i % 2 == 0) {
            if(headIndex - index > 1 && buffer[index - 1] == ':') {
                if(usedDouble) {
                    if(buffer[index - 2] != ':') {
                        buffer[index++] = '0';
                        buffer[index++] = ':';
                    } else {
                        // continue use of double :, do nothing here
                    }
                } else {
                    usedDouble = true;
                    buffer[index++] = ':';
                }
            } else {
                buffer[index++] = ':';
            }
        }

        if(UDPC_IPV6_ADDR_SUB(addr)[i] == 0
                && (headIndex - index <= 1 || buffer[index] == ':')) {
            continue;
        } else {
            std::stringstream sstream;
            sstream << std::setw(2) << std::setfill('0')
                << std::hex << (unsigned int) UDPC_IPV6_ADDR_SUB(addr)[i];
            std::string out(sstream.str());
            unsigned int outOffset = 0;
            if(headIndex - index <= 1 || buffer[index - 1] == ':') {
                if(out[0] == '0') {
                    if(out[1] == '0') {
                        outOffset = 2;
                    } else {
                        outOffset = 1;
                    }
                }
            }
            if(outOffset == 2) {
                continue;
            } else if(outOffset == 1) {
                if(out[outOffset] != '0') {
                    std::memcpy(buffer + index, out.c_str() + outOffset, 1);
                    ++index;
                }
            } else {
                std::memcpy(buffer + index, out.c_str() + outOffset, 2);
                index += 2;
            }
        }
    }
    if(buffer[index - 1] == ':'
            && (headIndex - index <= 2 || buffer[index - 2] != ':')) {
        buffer[index++] = '0';
    }

    buffer[index] = 0;
}

const char *UDPC_atostr(UDPC_HContext ctx, UDPC_IPV6_ADDR_TYPE addr) {
    UDPC::Context *c = UDPC::verifyContext(ctx);
    if(!c) {
        return nullptr;
    }
    uint32_t headIndex;
    {
        // Use a lock to ensure that "atostrBufIndex" is always a valid value.
        std::lock_guard<std::mutex> indexLock(c->atostrBufIndexMutex);
        c->atostrBufIndex = (c->atostrBufIndex + UDPC_ATOSTR_BUFSIZE) % UDPC_ATOSTR_SIZE;
        headIndex = c->atostrBufIndex;
    }

    UDPC_Helper_atostr(c->atostrBuf, addr, headIndex);

    return c->atostrBuf + headIndex;
}

const char *UDPC_atostr_unsafe(UDPC_IPV6_ADDR_TYPE addr) {
    char *buf = (char*)std::malloc(40);
    std::memset(buf, 0, 40);

    UDPC_Helper_atostr(buf, addr, 0);

    return buf;
}

const char *UDPC_atostr_unsafe_cid(UDPC_ConnectionId cid) {
    return UDPC_atostr_unsafe(cid.addr);
}

void UDPC_atostr_unsafe_free(const char *addrBuf) {
    if (addrBuf) {
        std::free((void*)addrBuf);
    }
}

void UDPC_atostr_unsafe_free_ptr(const char **addrBuf) {
    if (addrBuf && *addrBuf) {
        std::free((void*)*addrBuf);
        *addrBuf = nullptr;
    }
}

UDPC_IPV6_ADDR_TYPE UDPC_strtoa(const char *addrStr) {
    UDPC_IPV6_ADDR_TYPE result = in6addr_loopback;
    std::cmatch matchResults;
    if(std::regex_match(addrStr, matchResults, ipv6_regex_nolink)) {
        if(std::strcmp("::", addrStr) == 0) {
            return in6addr_any;
        }

        unsigned int index = 0;
        unsigned int strIndex = 0;
        int doubleColonIndex = -1;
        unsigned char bytes[2] = {0, 0};
        unsigned char bytesState = 0;
        bool prevColon = false;

        const auto checkInc = [&result, &index, &bytes] () -> bool {
            if(index < 15) {
                UDPC_IPV6_ADDR_SUB(result)[index++] = bytes[0];
                UDPC_IPV6_ADDR_SUB(result)[index++] = bytes[1];
                bytes[0] = 0;
                bytes[1] = 0;
                return false;
            }
            return true;
        };

        while(addrStr[strIndex] != '\0') {
            if(addrStr[strIndex] >= '0' && addrStr[strIndex] <= '9') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - '0');
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - '0');
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - '0');
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - '0');
                    bytesState = 0;
                    if(checkInc()) {
                        return in6addr_loopback;
                    }
                    break;
                default:
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] >= 'a' && addrStr[strIndex] <= 'f') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - 'a' + 10);
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - 'a' + 10);
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - 'a' + 10);
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - 'a' + 10);
                    bytesState = 0;
                    if(checkInc()) {
                        return in6addr_loopback;
                    }
                    break;
                default:
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] >= 'A' && addrStr[strIndex] <= 'F') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - 'A' + 10);
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - 'A' + 10);
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - 'A' + 10);
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - 'A' + 10);
                    bytesState = 0;
                    if(checkInc()) {
                        return in6addr_loopback;
                    }
                    break;
                default:
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] == ':') {
                switch(bytesState) {
                case 1:
                case 2:
                    bytes[1] = bytes[0];
                    bytes[0] = 0;
                    if(checkInc()) {
                        return in6addr_loopback;
                    }
                    break;
                case 3:
                    bytes[1] |= (bytes[0] & 0xF) << 4;
                    bytes[0] = bytes[0] >> 4;
                    if(checkInc()) {
                        return in6addr_loopback;
                    }
                    break;
                case 0:
                    break;
                default:
                    return in6addr_loopback;
                }
                bytesState = 0;
                if(prevColon) {
                    if(doubleColonIndex >= 0) {
                        return in6addr_loopback;
                    } else {
                        doubleColonIndex = index;
                    }
                } else {
                    prevColon = true;
                }
            } else {
                return in6addr_loopback;
            }

            ++strIndex;
        }
        switch(bytesState) {
        case 1:
        case 2:
            bytes[1] = bytes[0];
            bytes[0] = 0;
            if(checkInc()) {
                return in6addr_loopback;
            }
            break;
        case 3:
            bytes[1] |= (bytes[0] & 0xF) << 4;
            bytes[0] = bytes[0] >> 4;
            if(checkInc()) {
                return in6addr_loopback;
            }
            break;
        case 0:
            break;
        default:
            return in6addr_loopback;
        }

        if(doubleColonIndex >= 0) {
            strIndex = 16 - index;
            if(strIndex < 2) {
                return in6addr_loopback;
            }
            for(unsigned int i = 16; i-- > (unsigned int)doubleColonIndex + strIndex; ) {
                UDPC_IPV6_ADDR_SUB(result)[i] = UDPC_IPV6_ADDR_SUB(result)[i - strIndex];
                UDPC_IPV6_ADDR_SUB(result)[i - strIndex] = 0;
            }
        }
    } else if(std::regex_match(addrStr, matchResults, ipv4_regex)) {
        for(unsigned int i = 0; i < 10; ++i) {
            UDPC_IPV6_ADDR_SUB(result)[i] = 0;
        }
        UDPC_IPV6_ADDR_SUB(result)[10] = 0xFF;
        UDPC_IPV6_ADDR_SUB(result)[11] = 0xFF;
        for(unsigned int i = 0; i < 4; ++i) {
            UDPC_IPV6_ADDR_SUB(result)[12 + i] = std::stoi(matchResults[i + 1].str());
        }
    }
    return result;
}

UDPC_IPV6_ADDR_TYPE UDPC_strtoa_link(const char *addrStr, uint32_t *linkId_out) {
    const auto checkSetOut = [&linkId_out] (uint32_t val) {
        if(linkId_out) {
            *linkId_out = val;
        }
    };

    UDPC_IPV6_ADDR_TYPE result({0});
    std::cmatch matchResults;
    const char *linkName = nullptr;

    if(std::regex_match(addrStr, matchResults, ipv6_regex_linkonly)) {
        unsigned int index = 0;
        unsigned int strIndex = 0;
        int doubleColonIndex = -1;
        unsigned char bytes[2] = {0, 0};
        unsigned char bytesState = 0;
        bool prevColon = false;

        const auto checkInc = [&result, &index, &bytes] () -> bool {
            if(index < 15) {
                UDPC_IPV6_ADDR_SUB(result)[index++] = bytes[0];
                UDPC_IPV6_ADDR_SUB(result)[index++] = bytes[1];
                bytes[0] = 0;
                bytes[1] = 0;
                return false;
            }
            return true;
        };

        while(addrStr[strIndex] != '%') {
            if(addrStr[strIndex] >= '0' && addrStr[strIndex] <= '9') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - '0');
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - '0');
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - '0');
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - '0');
                    bytesState = 0;
                    if(checkInc()) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    }
                    break;
                default:
                    checkSetOut(0);
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] >= 'a' && addrStr[strIndex] <= 'f') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - 'a' + 10);
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - 'a' + 10);
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - 'a' + 10);
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - 'a' + 10);
                    bytesState = 0;
                    if(checkInc()) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    }
                    break;
                default:
                    checkSetOut(0);
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] >= 'A' && addrStr[strIndex] <= 'F') {
                switch(bytesState) {
                case 0:
                    bytes[0] = (addrStr[strIndex] - 'A' + 10);
                    bytesState = 1;
                    break;
                case 1:
                    bytes[0] = (bytes[0] << 4) | (addrStr[strIndex] - 'A' + 10);
                    bytesState = 2;
                    break;
                case 2:
                    bytes[1] = (addrStr[strIndex] - 'A' + 10);
                    bytesState = 3;
                    break;
                case 3:
                    bytes[1] = (bytes[1] << 4) | (addrStr[strIndex] - 'A' + 10);
                    bytesState = 0;
                    if(checkInc()) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    }
                    break;
                default:
                    checkSetOut(0);
                    return in6addr_loopback;
                }
                prevColon = false;
            } else if(addrStr[strIndex] == ':') {
                switch(bytesState) {
                case 1:
                case 2:
                    bytes[1] = bytes[0];
                    bytes[0] = 0;
                    if(checkInc()) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    }
                    break;
                case 3:
                    bytes[1] |= (bytes[0] & 0xF) << 4;
                    bytes[0] = bytes[0] >> 4;
                    if(checkInc()) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    }
                    break;
                case 0:
                    break;
                default:
                    checkSetOut(0);
                    return in6addr_loopback;
                }
                bytesState = 0;
                if(prevColon) {
                    if(doubleColonIndex >= 0) {
                        checkSetOut(0);
                        return in6addr_loopback;
                    } else {
                        doubleColonIndex = index;
                    }
                } else {
                    prevColon = true;
                }
            } else {
                checkSetOut(0);
                return in6addr_loopback;
            }

            ++strIndex;
        }
        switch(bytesState) {
        case 1:
        case 2:
            bytes[1] = bytes[0];
            bytes[0] = 0;
            if(checkInc()) {
                checkSetOut(0);
                return in6addr_loopback;
            }
            break;
        case 3:
            bytes[1] |= (bytes[0] & 0xF) << 4;
            bytes[0] = bytes[0] >> 4;
            if(checkInc()) {
                checkSetOut(0);
                return in6addr_loopback;
            }
            break;
        case 0:
            break;
        default:
            checkSetOut(0);
            return in6addr_loopback;
        }
        linkName = addrStr + strIndex + 1;

        if(doubleColonIndex >= 0) {
            strIndex = 16 - index;
            if(strIndex < 2) {
                checkSetOut(0);
                return in6addr_loopback;
            }
            for(unsigned int i = 16; i-- > (unsigned int)doubleColonIndex + strIndex; ) {
                UDPC_IPV6_ADDR_SUB(result)[i] = UDPC_IPV6_ADDR_SUB(result)[i - strIndex];
                UDPC_IPV6_ADDR_SUB(result)[i - strIndex] = 0;
            }
        }
    }

    uint32_t scope_id;
    if(std::regex_match(linkName, regex_numeric)) {
        scope_id = std::atoi(linkName);
    }
#if UDPC_PLATFORM == UDPC_PLATFORM_WINDOWS
    else {
        scope_id = if_nametoindex(linkName);
        if(scope_id == 0) {
            checkSetOut(0);
            return in6addr_loopback;
        }
    }
#elif UDPC_PLATFORM == UDPC_PLATFORM_MAC || UDPC_PLATFORM == UDPC_PLATFORM_LINUX
    else {
        struct ifreq req{{0}, 0, 0};
        std::strncpy(req.ifr_name, linkName, IFNAMSIZ);
        req.ifr_name[IFNAMSIZ - 1] = 0;
        int socketHandle = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
        if(ioctl(socketHandle, SIOCGIFINDEX, &req) < 0) {
            UDPC_CLEANUPSOCKET(socketHandle);
            checkSetOut(0);
            return in6addr_loopback;
        }
        scope_id = req.ifr_ifindex;
        UDPC_CLEANUPSOCKET(socketHandle);
    }
#endif

    checkSetOut(scope_id);
    return result;
}

UDPC_IPV6_ADDR_TYPE UDPC_a4toa6(uint32_t a4_be) {
    if(a4_be == 0) {
        return in6addr_any;
    }

    uint32_t a4 = ntohl(a4_be);

    if(a4 == 0x7F000001) {
        return in6addr_loopback;
    }

    UDPC_IPV6_ADDR_TYPE result;
    for(unsigned int i = 0; i < 10; ++i) {
        UDPC_IPV6_ADDR_SUB(result)[i] = 0;
    }
    UDPC_IPV6_ADDR_SUB(result)[10] = 0xFF;
    UDPC_IPV6_ADDR_SUB(result)[11] = 0xFF;

    for(unsigned int i = 0; i < 4; ++i) {
        UDPC_IPV6_ADDR_SUB(result)[12 + i] = *((uint8_t*)&a4 + (3 - i));
    }

    return result;
}

int UDPC_is_big_endian() {
    return UDPC::isBigEndian() ? 1 : 0;
}

uint16_t UDPC_no16i(uint16_t i) {
    return htons(i);
}

uint32_t UDPC_no32i(uint32_t i) {
    return htonl(i);
}

uint64_t UDPC_no64i(uint64_t i) {
    UDPC::be64((char*)&i);
    return i;
}

float UDPC_no32f(float f) {
    uint32_t *i = reinterpret_cast<uint32_t*>(&f);
    *i = htonl(*i);
    return f;
}

double UDPC_no64f(double f) {
    uint64_t *i = reinterpret_cast<uint64_t*>(&f);
    UDPC::be64((char*)i);
    return f;
}