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