feat(livestreams): GO-orchestrated live spectating via a relay server

GenOnlineService/Constants.cs

@@ -1156,6 +1156,10 @@ public void UpdateSessionLobbyID(Int64 newLobbyID)
 
 		// lobby id
 		public Int64 currentLobbyID = -1;
+
+		// Observer-chat rate gate: last time this session sent an observer chat message
+		// (Environment.TickCount64). Dies with the socket, so no cleanup is needed.
+		public long m_timeLastObserverChatSent = -1;
 	}
 
 	public class UserWebSocketInstance
@@ -1399,6 +1403,14 @@ public enum EAccountType
 		DevAccount = 3
 	}
 
+	// Per-user livestream privilege (users.user_priority).
+	public enum EUserPriority
+	{
+		None = 0,
+		Player = 1,		// their matches are highlighted in the Watch Live browser
+		Viewer = 2		// skips the livestream password and broadcast-delay gates
+	}
+
 	public class PlayerStats
 	{
 		const int numGeneralsEntries = 15;
@@ -2545,7 +2557,15 @@ public enum EWebSocketMessageID
 		AC_REGISTER_PLAYER = 40,
 		AC_DEREGISTER_PLAYER = 41,
 		WS_KEEPALIVE = 42,
-		WS_KEEPALIVE_CLIENT = 43
+		WS_KEEPALIVE_CLIENT = 43,
+		LOBBY_OBSERVER_SUBSCRIBE = 44,
+		LOBBY_OBSERVER_UNSUBSCRIBE = 45,
+		LOBBY_OBSERVER_LOBBY_CHANGED = 46,
+		LOBBY_OBSERVER_GAME_STARTING = 47,
+		LOBBY_OBSERVER_STREAM_LIVE = 48,
+		LOBBY_OBSERVER_GAME_STARTED = 49,
+		LOBBY_OBSERVER_CHAT_FROM_CLIENT = 50,
+		LOBBY_OBSERVER_LIST_REQUEST = 51
 	};
 
 	public static class UserPresence
@@ -2643,6 +2663,24 @@ public class WebSocketMessage_StartMatch : WebSocketMessage
 		public string screenshot_url { get; set; } = String.Empty;
 	}
 
+	// All six observer events share one shape; msg_id distinguishes them. Only GAME_STARTED sets
+	// delay_seconds, which is what a waiting observer times its watch-key request against.
+	public class WebSocketMessage_LobbyObserverEvent : WebSocketMessage
+	{
+		public Int64 lobby_id { get; set; } = -1;
+		public int? delay_seconds { get; set; } = null;
+	}
+
+	// Observer chat into a pre-game lobby. Deliberately no action / announcement /
+	// show_announcement_to_host fields: the member path trusts those verbatim (letting a member
+	// post an unprefixed line that looks like a system message); this path has the server decide
+	// the formatting instead.
+	public class WebSocketMessage_LobbyObserverChatInbound : WebSocketMessage
+	{
+		public Int64 lobby_id { get; set; } = -1;
+		public string? message { get; set; }
+	}
+
 	public abstract class WebSocketMessage
 	{
 		public int msg_id { get; set; }

GenOnlineService/Controllers/CheckLogin/CheckLoginController.cs

@@ -155,6 +155,7 @@ public async Task<APIResult> Post_InternalHandler(string jsonData, string ipAddr
 							}
 
 							bool bIsAdmin = await Database.Users.IsUserAdmin(db, user_id);
+							EUserPriority userPriority = await Database.Users.GetUserPriority(db, user_id);
 #else
 							EPendingLoginState? loginState = await Database.PendingLogins.GetPendingLoginState(db, gameCode.ToUpper());
 
@@ -166,6 +167,7 @@ public async Task<APIResult> Post_InternalHandler(string jsonData, string ipAddr
 									string strDisplayName = await Database.Users.GetDisplayName(db, user_id);
 
 								bool bIsAdmin = await Database.Users.IsUserAdmin(db, user_id);
+								EUserPriority userPriority = await Database.Users.GetUserPriority(db, user_id);
 #endif
 
 							if (state == EPendingLoginState.Waiting)
@@ -207,8 +209,8 @@ public async Task<APIResult> Post_InternalHandler(string jsonData, string ipAddr
 										string exe_crc = data.ContainsKey("exe_crc") ? data["exe_crc"].ToString() : "NONE";
 										Helpers.RegisterInitialPlayerExeCRC(user_id, exe_crc);
 
-										var sessiontoken = Program.g_tokenGenerator.GenerateToken(strDisplayName, user_id, ipAddr, Program.JwtTokenGenerator.ETokenType.Session, knownClientID, sessionType, bIsAdmin);
-										var refreshtoken = Program.g_tokenGenerator.GenerateToken(strDisplayName, user_id, ipAddr, Program.JwtTokenGenerator.ETokenType.Refresh, knownClientID, sessionType, false, out string refreshJti);
+										var sessiontoken = Program.g_tokenGenerator.GenerateToken(strDisplayName, user_id, ipAddr, Program.JwtTokenGenerator.ETokenType.Session, knownClientID, sessionType, bIsAdmin, userPriority);
+										var refreshtoken = Program.g_tokenGenerator.GenerateToken(strDisplayName, user_id, ipAddr, Program.JwtTokenGenerator.ETokenType.Refresh, knownClientID, sessionType, false, EUserPriority.None, out string refreshJti);
 
 										// rotation: only this refresh token is accepted from now on
 										await TokenRevocationManager.OnTokensIssued(user_id, sessionType, refreshJti);