#include <cassert>

#include "Node.hh"

NetworkNode::NetworkNode (NetworkSession &session, NetworkTCPTransport *tcp, NetworkUDP *udp, const NetworkAddress &address) :
    session(session), tcp(tcp), udp(udp), address(address) {
    
    // connect signals
    slots.connect(tcp->sig_disconnect(), this, &NetworkNode::on_disconnect);
    slots.connect(tcp->sig_packet(), &session, &NetworkSession::handle_message, this);
    
}

NetworkNode::~NetworkNode (void) {
    delete tcp;
}

void NetworkNode::on_disconnect (void) {
    // tell session
    session.handle_disconnect(this);

    // fire signal
    _sig_disconnected();
    
    // delete
//    delete this;
}

void NetworkNode::write_packet_header (NetworkPacketOutput &pkt, NetworkChannelID channel_id) {
    pkt.write_uint16(channel_id);
}

void NetworkNode::send_raw (const NetworkPacketBuffer &pkt, bool reliable) {
    // either tcp or udp
    if (reliable) {
        assert(tcp);

        tcp->write_packet(pkt);

    } else {
        udp->sendto(pkt, address);
    }

}

void NetworkNode::send (NetworkChannelID channel_id, const NetworkPacketBuffer &pkt, bool reliable) {
    assert(channel_id > 0);
    
    // add our header
    NetworkPacket pkt2;
    
    write_packet_header(pkt2, channel_id);
    pkt2.write_packet(pkt);
    
    // send
    send_raw(pkt2, reliable);
}
        
const NetworkAddress& NetworkNode::getRemoteAddress (void) {
    return address;
}