terom@89: 
terom@89: #include <cassert>
terom@89: 
terom@89: #include "NetworkObject.hh"
terom@89: 
terom@89: /* 
terom@89:  * NetworkObject_Controller 
terom@89:  */
terom@89: NetworkObjectController::NetworkObjectController (NetworkSession &session, NetworkChannelID channel_id) :
terom@89:     session(session), channel_id(channel_id) {
terom@89:     
terom@89:     // setup signals
terom@89:     slot_message = session.sig_chan_message(channel_id).connect(this, &NetworkObjectController::on_message);
terom@89: }
terom@89: 
terom@89: void NetworkObjectController::on_message (NetworkPacket &pkt, NetworkNode *node) {
terom@89:     uint32_t obj_id = pkt.read_uint32();
terom@89:     uint16_t msg_id = pkt.read_uint16();
terom@89:     
terom@89:     // lookup object
terom@89:     NetworkObject *obj = objects[obj_id];
terom@89: 
terom@89:     if (obj) {
terom@89:         obj->handle_packet(node, msg_id, pkt);
terom@89: 
terom@89:     } else {
terom@89:         handle_create(obj_id, msg_id, pkt, node);
terom@89:     }
terom@89: }
terom@89: 
terom@89: /* 
terom@89:  * NetworkObject_ServerController 
terom@89:  */
terom@89: NetworkObject_ServerController::NetworkObject_ServerController (NetworkSession &session, NetworkChannelID channel_id) :
terom@89:     NetworkObjectController(session, channel_id), id_pool(0) {
terom@89: 
terom@89: }
terom@89: 
terom@89: NetworkObjectID NetworkObject_ServerController::getObjectID (void) {
terom@89:     return ++id_pool;
terom@89: }
terom@89:         
terom@89: void NetworkObject_ServerController::handle_create (NetworkObjectID obj_id, NetworkMessageID msg_id, NetworkPacket &pkt, NetworkNode *node) {
terom@89:     (void) obj_id;
terom@89:     (void) msg_id;
terom@89:     (void) pkt;
terom@89:     (void) node;
terom@89: 
terom@89:     // XXX: fail
terom@89:     throw CL_Error("clients cannot create objects");
terom@89: }
terom@89:         
terom@89: /* 
terom@89:  * NetworkObject_ClientController *
terom@89:  */
terom@89: NetworkObject_ClientController::NetworkObject_ClientController (NetworkSession &session, NetworkChannelID channel_id, NetworkNode *server) :
terom@89:     NetworkObjectController(session, channel_id), server(server) {
terom@89: 
terom@89: 
terom@89: }
terom@89:         
terom@89: void NetworkObject_ClientController::handle_create (NetworkObjectID obj_id, NetworkMessageID msg_id, NetworkPacket &pkt, NetworkNode *node) {
terom@89:     // we only communicate with the server
terom@89:     assert(node == server);
terom@89:     
terom@89:     // create new object
terom@89:     NetworkObject_Client *obj = new NetworkObject_Client(*this, obj_id);
terom@89:     
terom@89:     // signal
terom@89:    _sig_create(obj, msg_id, pkt); 
terom@89: }
terom@89: 
terom@89: /* 
terom@89:  * NetworkObject 
terom@89:  */
terom@89: NetworkObject::NetworkObject (NetworkObjectController &controller, NetworkObjectID obj_id) :
terom@89:     obj_id(obj_id) {
terom@89:     
terom@89:     assert(obj_id);
terom@89: 
terom@89:     controller.objects[obj_id] = this;
terom@89: }
terom@89:         
terom@89: void NetworkObject::buildPacket (NetworkPacket &pkt, NetworkMessageID msg_id, const NetworkPacket &payload) {
terom@89:     pkt.write_uint32(obj_id);
terom@89:     pkt.write_uint16(msg_id);
terom@89:     pkt.write_packet(payload);
terom@89: }
terom@89: 
terom@89: std::ostream& operator<< (std::ostream &s, const NetworkObject &obj) {
terom@89:     return s << "<NetworkObject #" << obj.obj_id << ">";
terom@89: }
terom@89: 
terom@89: /* 
terom@89:  * NetworkObject_Server 
terom@89:  */
terom@89: NetworkObject_Server::NetworkObject_Server (NetworkObject_ServerController &controller) :
terom@89:     NetworkObject(controller, controller.getObjectID()), controller(controller) {
terom@89:     
terom@89: }
terom@89: 
terom@89: void NetworkObject_Server::handle_packet (NetworkNode *node, NetworkMessageID msg_id, NetworkPacket &pkt) {
terom@89:     _map_sig_message[msg_id](node, pkt);
terom@89: }
terom@89: 
terom@89: void NetworkObject_Server::send_to (NetworkNode *dst, NetworkMessageID msg_id, const NetworkPacket &pkt, bool reliable) {
terom@89:     NetworkPacket pkt_out;
terom@89: 
terom@89:     buildPacket(pkt_out, msg_id, pkt);
terom@89: 
terom@89:     dst->send(controller.channel_id, pkt_out, reliable);
terom@89: }
terom@89: 
terom@89: void NetworkObject_Server::send_all (NetworkMessageID msg_id, const NetworkPacket &pkt, bool reliable) {
terom@89:     send_all_except(msg_id, pkt, NULL, reliable);
terom@89: }
terom@89: 
terom@89: void NetworkObject_Server::send_all_except (NetworkMessageID msg_id, const NetworkPacket &pkt, NetworkNode *black_sheep, bool reliable) {
terom@89:     NetworkPacket pkt_out;
terom@89: 
terom@89:     buildPacket(pkt_out, msg_id, pkt);
terom@89:     
terom@89:     controller.session.send_all_except(controller.channel_id, pkt_out, black_sheep, reliable);
terom@89: }
terom@89:  
terom@89: /* 
terom@89:  * NetworkObject_Client 
terom@89:  */
terom@89: NetworkObject_Client::NetworkObject_Client (NetworkObject_ClientController &controller, NetworkObjectID id) :
terom@89:     NetworkObject(controller, id), controller(controller) { 
terom@89:     
terom@89:     // nothing
terom@89: }
terom@89: 
terom@89: void NetworkObject_Client::handle_packet (NetworkNode *node, NetworkMessageID msg_id, NetworkPacket &pkt) {
terom@89:     assert(node == controller.server);
terom@89: 
terom@89:     _map_sig_message[msg_id](pkt);
terom@89: }
terom@89:        
terom@89: void NetworkObject_Client::send (NetworkMessageID msg_id, const NetworkPacket &pkt, bool reliable) {
terom@89:     NetworkPacket pkt_out;
terom@89: 
terom@89:     buildPacket(pkt_out, msg_id, pkt);
terom@89: 
terom@89:     controller.server->send(controller.channel_id, pkt_out, reliable);
terom@89: }
terom@89: