tweak game interface bus mode

GameFiles/GameInterface/_integration_base.gsc

@@ -44,6 +44,8 @@ Setup()
     level.commonKeys.enabled  = "sv_iw4madmin_integration_enabled";
     level.commonKeys.busMode  = "sv_iw4madmin_integration_busmode";
     level.commonKeys.busDir   = "sv_iw4madmin_integration_busdir";
+    level.eventBus.inLocation = "";
+    level.eventBus.outLocation = "";
     
     level.notifyTypes                                   = spawnstruct();
     level.notifyTypes.gameFunctionsInitialized          = "GameFunctionsInitialized";
@@ -175,22 +177,22 @@ _GetPlayerFromClientNum( clientNum )
     return undefined;
 }
 
-_GetInboundData()
+_GetInboundData( location )
 {
     return GetDvar( level.eventBus.inVar );
 }
 
-_GetOutboundData()
+_GetOutboundData( location )
 {
     return GetDvar( level.eventBus.outVar );
 }
 
-_SetInboundData( data )
+_SetInboundData( location, data )
 {
     return SetDvar( level.eventBus.inVar, data );
 }
 
-_SetOutboundData( data )
+_SetOutboundData( location, data )
 {
     return SetDvar( level.eventBus.outVar, data );
 }
@@ -361,22 +363,25 @@ MonitorBus()
 {
     level endon( level.eventTypes.gameEnd );
     
-    [[level.overrideMethods[level.commonFunctions.SetInboundData]]]( "" );
+    level.eventBus.inLocation = level.eventBus.inVar + "_" + GetDvar( "net_port" );
-    [[level.overrideMethods[level.commonFunctions.SetOutboundData]]]( "" );
+    level.eventBus.outLocation = level.eventBus.outVar + "_" + GetDvar( "net_port" );
+
+    [[level.overrideMethods[level.commonFunctions.SetInboundData]]]( level.eventBus.inLocation, "" );
+    [[level.overrideMethods[level.commonFunctions.SetOutboundData]]]( level.eventBus.outLocation, "" );
 
     for( ;; )
     {
         wait ( 0.1 );
         
         // check to see if IW4MAdmin is ready to receive more data
-        inVal = [[level.busMethods[level.commonFunctions.getInboundData]]]();
+        inVal = [[level.busMethods[level.commonFunctions.getInboundData]]]( level.eventBus.inLocation );
 
         if ( !IsDefined( inVal ) || inVal == "" )
         {
             level notify( "bus_ready" );
         }
         
-        eventString = [[level.busMethods[level.commonFunctions.getOutboundData]]]();
+        eventString = [[level.busMethods[level.commonFunctions.getOutboundData]]]( level.eventBus.outLocation );
         
         if ( !IsDefined( eventString ) || eventString == "" ) 
         {
@@ -388,7 +393,7 @@ MonitorBus()
         groupSeparator = GetSubStr( GetDvar( "GroupSeparatorChar" ), 0, 1 );
         NotifyEvent( strtok( eventString, groupSeparator ) );
         
-        [[level.busMethods[level.commonFunctions.SetOutboundData]]]( "" );
+        [[level.busMethods[level.commonFunctions.SetOutboundData]]]( level.eventBus.outLocation, "" );
     }
 }
 
@@ -400,11 +405,11 @@ QueueEvent( request, eventType, notifyEntity )
     maxWait = level.eventBus.timeout * 1000; // 30 seconds
     timedOut = "";
    
-    while ( [[level.busMethods[level.commonFunctions.getInboundData]]]() != "" && ( GetTime() - start ) < maxWait )
+    while ( [[level.busMethods[level.commonFunctions.getInboundData]]]( level.eventBus.inLocation ) != "" && ( GetTime() - start ) < maxWait )
     {
         level [[level.overrideMethods[level.commonFunctions.waittillNotifyOrTimeout]]]( "bus_ready", 1 );
         
-        if ( [[level.busMethods[level.commonFunctions.getInboundData]]]() != "" )
+        if ( [[level.busMethods[level.commonFunctions.getInboundData]]]( level.eventBus.inLocation ) != "" )
         {
             LogDebug( "A request is already in progress..." );
             timedOut = "set";
@@ -423,14 +428,14 @@ QueueEvent( request, eventType, notifyEntity )
             notifyEntity NotifyClientEventTimeout( eventType );
         }
         
-        [[level.busMethods[level.commonFunctions.SetInboundData]]]( "" );
+        [[level.busMethods[level.commonFunctions.SetInboundData]]]( level.eventBus.inLocation, "" );
 
         return;
     }
     
     LogDebug( "<- " + request );
     
-    [[level.busMethods[level.commonFunctions.setInboundData]]]( request );
+    [[level.busMethods[level.commonFunctions.setInboundData]]]( level.eventBus.inLocation, request );
 }
 
 ParseDataString( data ) 

GameFiles/GameInterface/_integration_iw4x.gsc

@@ -102,24 +102,24 @@ WaitForClientEvents()
     }
 }
 
-GetInboundData()
+GetInboundData( location )
 {
-    return FileRead( level.eventBus.inVar);
+    return FileRead( location );
 }
 
-GetOutboundData()
+GetOutboundData( location )
 {
-    return FileRead( level.eventBus.outVar );
+    return FileRead( location );
 }
 
-SetInboundData( data )
+SetInboundData( location, data )
 {
-    FileWrite( level.eventBus.inVar, data, "write" );
+    FileWrite( location, data, "write" );
 }
 
-SetOutboundData( data )
+SetOutboundData( location, data )
 {
-    FileWrite(level.eventBus.outVar, data, "write" );
+    FileWrite( location, data, "write" );
 }
 
 GetMaxClients()

GameFiles/GameInterface/_integration_shared.gsc

@@ -202,6 +202,8 @@ OnBusModeRequestedCallback( event )
     data = [];
     data["mode"] = GetDvar( level.commonKeys.busMode );
     data["directory"] = GetDvar( level.commonKeys.busDir );
+    data["inLocation"] = level.eventBus.inLocation;
+    data["outLocation"] = level.eventBus.outLocation;
 
     scripts\_integration_base::LogDebug( "Bus mode requested" );
 

Plugins/ScriptPlugins/GameInterface.js

@@ -1,8 +1,7 @@
 const servers = {};
-const inDvar = 'sv_iw4madmin_in';
+let inDvar = 'sv_iw4madmin_in';
-const outDvar = 'sv_iw4madmin_out';
+let outDvar = 'sv_iw4madmin_out';
 const integrationEnabledDvar = 'sv_iw4madmin_integration_enabled';
-const pollingRate = 300;
 const groupSeparatorChar = '\x1d';
 const recordSeparatorChar = '\x1e';
 const unitSeparatorChar = '\x1f';
@@ -15,6 +14,7 @@ const init = (registerNotify, serviceResolver, config, scriptHelper) => {
     registerNotify('IGameServerEventSubscriptions.ServerValueReceived', (serverValueEvent, _) => plugin.onServerValueReceived(serverValueEvent));
     registerNotify('IGameServerEventSubscriptions.ServerValueSetCompleted', (serverValueEvent, _) => plugin.onServerValueSetCompleted(serverValueEvent));
     registerNotify('IGameServerEventSubscriptions.MonitoringStarted', (monitorStartEvent, _) => plugin.onServerMonitoringStart(monitorStartEvent));
+    registerNotify('IGameEventSubscriptions.MatchStarted', (matchStartEvent, _) => plugin.onMatchStart(matchStartEvent));
     registerNotify('IManagementEventSubscriptions.ClientPenaltyAdministered', (penaltyEvent, _) => plugin.onPenalty(penaltyEvent));
 
     plugin.onLoad(serviceResolver, config, scriptHelper);
@@ -30,14 +30,31 @@ const plugin = {
     logger: null,
     commands: null,
     scriptHelper: null,
+    configWrapper: null,
+    config: {
+        pollingRate: 300
+    },
 
-    onLoad: function (serviceResolver, config, scriptHelper) {
+    onLoad: function (serviceResolver, configWrapper, scriptHelper) {
         this.serviceResolver = serviceResolver;
         this.eventManager = serviceResolver.resolveService('IManager');
         this.logger = serviceResolver.resolveService('ILogger', ['ScriptPluginV2']);
         this.commands = commands;
-        this.config = config;
+        this.configWrapper = configWrapper;
         this.scriptHelper = scriptHelper;
+
+        const storedConfig = this.configWrapper.getValue('config', newConfig => {
+            if (newConfig) {
+                plugin.logger.logInformation('{Name} config reloaded.', plugin.name);
+                plugin.config = newConfig;
+            }
+        });
+
+        if (storedConfig != null) {
+            this.config = storedConfig
+        } else {
+            this.configWrapper.setValue('config', this.config);
+        }
     },
 
     onClientEnteredMatch: function (clientEvent) {
@@ -110,6 +127,11 @@ const plugin = {
         this.initializeServer(monitorStartEvent.server);
     },
 
+    onMatchStart: function (matchStartEvent) {
+        busMode = 'rcon';
+        this.sendEventMessage(matchStartEvent.server, true, 'GetBusModeRequested', null, null, null, {});
+    },
+
     initializeServer: function (server) {
         servers[server.id] = {
             enabled: false,
@@ -139,6 +161,9 @@ const plugin = {
         serverState.running = true;
         serverState.initializationInProgress = false;
         
+        // todo: this might not work for all games
+        responseEvent.server.rconParser.configuration.floodProtectInterval = 150;
+
         this.sendEventMessage(responseEvent.server, true, 'GetBusModeRequested', null, null, null, {});
         this.sendEventMessage(responseEvent.server, true, 'GetCommandsRequested', null, null, null, {});
         this.requestGetDvar(inDvar, responseEvent.server);
@@ -346,7 +371,11 @@ const plugin = {
         if (event.eventType === 'GetBusModeRequested') {
             if (event.data?.directory && event.data?.mode) {
                 busMode = event.data.mode;
-                busDir = event.data.directory;
+                busDir = event.data.directory.replace('\'', '').replace('"', '');
+                if (event.data?.inLocation && event.data?.outLocation) {
+                    inDvar = event.data?.inLocation;
+                    outDvar = event.data?.outLocation;
+                }
                 this.logger.logDebug('Setting bus mode to {mode} {dir}', busMode, busDir);
             }
         }
@@ -408,7 +437,7 @@ const plugin = {
         
         const serverEvents = importNamespace('SharedLibraryCore.Events.Server');
         const requestEvent = new serverEvents.ServerValueRequestEvent(dvarName, server);
-        requestEvent.delayMs = pollingRate;
+        requestEvent.delayMs = this.config.pollingRate;
         requestEvent.timeoutMs = 2000;
         requestEvent.source = this.name;
 
@@ -418,7 +447,7 @@ const plugin = {
             const diff = new Date().getTime() - end.getTime();
 
             if (diff < extraDelay) {
-                requestEvent.delayMs = (extraDelay - diff) + pollingRate;
+                requestEvent.delayMs = (extraDelay - diff) + this.config.pollingRate;
                 this.logger.logDebug('Increasing delay time to {Delay}ms due to recent map change', requestEvent.delayMs);
             }
         }
@@ -468,7 +497,7 @@ const plugin = {
 
         const serverEvents = importNamespace('SharedLibraryCore.Events.Server');
         const requestEvent = new serverEvents.ServerValueSetRequestEvent(dvarName, dvarValue, server);
-        requestEvent.delayMs = pollingRate;
+        requestEvent.delayMs = this.config.pollingRate;
         requestEvent.timeoutMs = 2000;
         requestEvent.source = this.name;
 
@@ -478,7 +507,7 @@ const plugin = {
             const diff = new Date().getTime() - end.getTime();
 
             if (diff < extraDelay) {
-                requestEvent.delayMs = (extraDelay - diff) + pollingRate;
+                requestEvent.delayMs = (extraDelay - diff) + this.config.pollingRate;
                 this.logger.logDebug('Increasing delay time to {Delay}ms due to recent map change', requestEvent.delayMs);
             }
         }