Mercurial > zfc9000 / changeset

--- a/sources/interface.cpp	Wed Jan 27 19:44:36 2021 +0200
+++ b/sources/interface.cpp	Wed Jan 27 19:48:41 2021 +0200
@@ -1086,6 +1086,13 @@
 		this->m_session.disconnect();
 		*shouldquit = true;
 	}
+	else if (command == "watch")
+	{
+		if (not args.empty())
+			m_session.requestWatch(args);
+		else
+			printError("No CVars to watch.\n");
+	}
 	else
 		printError("Unknown command: %s\n", command.data());
 }

--- a/sources/network/rconsession.cpp	Wed Jan 27 19:44:36 2021 +0200
+++ b/sources/network/rconsession.cpp	Wed Jan 27 19:48:41 2021 +0200
@@ -118,6 +118,7 @@
 		}
 	}
 
+	// Check for new packets in our socket
 	std::stringstream errors;
 	for (net::Datagram datagram; m_socket.read(datagram, errors);)
 	{
@@ -195,6 +196,10 @@
 				}
 
 				m_interface->print("End of previous messages.\n");
+
+				// Watch sv_hostname so that we can update the titlebar when it changes.
+				requestWatch("sv_hostname");
+				m_interface->print ("Watch requested.\n");
 				break;
 
 			case SVRC_UPDATE:
@@ -234,6 +239,40 @@
 					}
 				}
 				break;
+
+			case SVRC_WATCHINGCVAR:
+				m_interface->print ("You are now watching %s\n", stream.readString().data());
+				m_interface->print ("Its value is: %s\n", stream.readString().data());
+				break;
+
+			case SVRC_ALREADYWATCHINGCVAR:
+				m_interface->print ("You are already watching %s\n", stream.readString().data());
+				break;
+
+			case SVRC_WATCHCVARNOTFOUND:
+				m_interface->print ("CVar %s not found\n", stream.readString().data());
+				break;
+
+			case SVRC_CVARCHANGED:
+				{
+					String name = stream.readString();
+					String value = stream.readString();
+					m_interface->print ("The value of CVar %s", name.data());
+					m_interface->print (" is now %s\n", value.data());
+
+					// If sv_hostname changes, update the titlebar
+					if (name == "sv_hostname")
+					{
+						m_hostname = value;
+						m_interface->setTitle(m_hostname);
+					}
+				}
+				break;
+
+			case SVRC_YOUREDISCONNECTED:
+				m_interface->print ("You have been disconnected: %s\n", stream.readString().data());
+				m_interface->disconnected();
+				break;
 			}
 		}
 	}
@@ -402,4 +441,28 @@
 	m_interface = interface;
 }
 
+// -------------------------------------------------------------------------------------------------
+//
+void RCONSession::requestWatch(const String& cvar)
+{
+	const std::vector<std::string> cvars{{cvar}};
+	requestWatch(cvars);
+}
+
+// -------------------------------------------------------------------------------------------------
+//
+void RCONSession::requestWatch(const std::vector<std::string>& cvars)
+{
+	std::vector<unsigned char> message;
+	Bytestream stream(message);
+	stream.writeByte(CLRC_WATCHCVAR);
+	for (String cvar : cvars)
+	{
+		normalize(cvar);
+		stream.writeString(cvar);
+	}
+	stream.writeString("");
+	send(message);
+}
+
 END_ZFC_NAMESPACE

--- a/sources/network/rconsession.h	Wed Jan 27 19:44:36 2021 +0200
+++ b/sources/network/rconsession.h	Wed Jan 27 19:48:41 2021 +0200
@@ -54,6 +54,11 @@
 	SVRC_UPDATE,
 	SVRC_TABCOMPLETE,
 	SVRC_TOOMANYTABCOMPLETES,
+	SVRC_WATCHINGCVAR,
+	SVRC_ALREADYWATCHINGCVAR,
+	SVRC_WATCHCVARNOTFOUND,
+	SVRC_CVARCHANGED,
+	SVRC_YOUREDISCONNECTED,
 };
 
 // -------------------------------------------------------------------------------------------------
@@ -66,6 +71,7 @@
 	CLRC_PONG,
 	CLRC_DISCONNECT,
 	CLRC_TABCOMPLETE,
+	CLRC_WATCHCVAR,
 };
 
 // -------------------------------------------------------------------------------------------------
@@ -107,6 +113,8 @@
 	bool                        isActive() const;
 	void                        processServerUpdates(Bytestream& packet);
 	void                        requestTabCompletion(const std::string& part);
+	void                        requestWatch (const String& cvar);
+	void                        requestWatch (const StringList& cvars);
 	bool send(const std::vector<unsigned char>& packet);
 	bool                        sendCommand(const std::string& commandString);
 	void                        sendHello();