X-Git-Url: http://git.localhorst.tv/?a=blobdiff_plain;f=src%2Fserver%2Fnet.cpp;fp=src%2Fserver%2Fnet.cpp;h=f5e974d7e71bcfb9808e08a7d9fc909aa1dbe2d8;hb=b07f3c123fff221edeffb4864bab7db88d0d1f4d;hp=e88ca1fc28b93c577ebb7676a334cbc2b0e05039;hpb=20d0a76d2519c71009c3b3babec0df27529f8142;p=blank.git

diff --git a/src/server/net.cpp b/src/server/net.cpp
index e88ca1f..f5e974d 100644
--- a/src/server/net.cpp
+++ b/src/server/net.cpp
@@ -6,6 +6,7 @@
 #include "../geometry/distance.hpp"
 #include "../io/WorldSave.hpp"
 #include "../model/Model.hpp"
+#include "../shared/CommandService.hpp"
 #include "../world/ChunkIndex.hpp"
 #include "../world/Entity.hpp"
 #include "../world/World.hpp"
@@ -647,7 +648,7 @@ uint16_t ClientConnection::SendMessage(uint8_t type, uint32_t from, const string
 
 
 NetworkCLIFeedback::NetworkCLIFeedback(Player &p, ClientConnection &c)
-: CLIContext(p)
+: CLIContext(&p)
 , conn(c) {
 
 }
@@ -682,7 +683,8 @@ Server::Server(
 , spawn_index(world.Chunks().MakeIndex(wc.spawn, 3))
 , save(save)
 , player_model(nullptr)
-, cli(world) {
+, cli(world)
+, cmd_srv() {
 #pragma GCC diagnostic pop
 	if (!serv_set) {
 		throw NetError("SDLNet_AllocSocketSet");
@@ -702,6 +704,10 @@ Server::Server(
 
 	serv_pack.data = new Uint8[sizeof(Packet)];
 	serv_pack.maxlen = sizeof(Packet);
+
+	if (conf.cmd_port) {
+		cmd_srv.reset(new CommandService(cli, conf.cmd_port));
+	}
 }
 
 Server::~Server() {
@@ -719,10 +725,16 @@ Server::~Server() {
 
 void Server::Wait(int dt) noexcept {
 	SDLNet_CheckSockets(serv_set, dt);
+	if (cmd_srv) {
+		cmd_srv->Wait(0);
+	}
 }
 
 bool Server::Ready() noexcept {
-	return SDLNet_CheckSockets(serv_set, 0) > 0;
+	if (SDLNet_CheckSockets(serv_set, 0) > 0) {
+		return true;
+	}
+	return cmd_srv && cmd_srv->Ready();
 }
 
 void Server::Handle() {
@@ -735,6 +747,9 @@ void Server::Handle() {
 		// a boo boo happened
 		throw NetError("SDLNet_UDP_Recv");
 	}
+	if (cmd_srv) {
+		cmd_srv->Handle();
+	}
 }
 
 void Server::HandlePacket(const UDPpacket &udp_pack) {
@@ -774,6 +789,9 @@ void Server::Update(int dt) {
 			++client;
 		}
 	}
+	if (cmd_srv) {
+		cmd_srv->Send();
+	}
 }
 
 void Server::SetPlayerModel(const Model &m) noexcept {