tweak(server): apply rate limiter to reassembled events as well

code/components/citizen-resources-core/include/EventReassemblyComponent.h

@@ -13,10 +13,15 @@ namespace fx
 class Resource;
 class ResourceManager;
 
-class EventReassemblySink
+class CRC_EXPORT EventReassemblySink
 {
 public:
 	virtual void SendPacket(int target, std::string_view data) = 0;
+
+	virtual bool LimitEvent(int source) 
+	{
+		return false;
+	}
 };
 
 class CRC_EXPORT EventReassemblyComponent : public fwRefCountable, public IAttached<ResourceManager>

code/components/citizen-resources-core/src/EventReassemblyComponent.cpp

@@ -310,6 +310,11 @@ void EventReassemblyComponentImpl::HandleReceivedPacket(int source, const std::s
 	// get the resource manager and eventing component
 	fwRefContainer<fx::ResourceEventManagerComponent> eventManager = m_resourceManager->GetComponent<fx::ResourceEventManagerComponent>();
 
+	if (m_sink->LimitEvent(source))
+	{
+		return;
+	}
+
 	// and queue the event
 	eventManager->QueueEvent(
 		std::string{ eventName },

code/components/citizen-server-impl/src/ServerResources.cpp

@@ -313,6 +313,33 @@ static class : public fx::EventReassemblySink
 		}
 	}
 
+	virtual bool LimitEvent(int source) override
+	{
+		static fx::RateLimiterStore<uint32_t, false> netEventRateLimiterStore{ instance->GetComponent<console::Context>().GetRef() };
+		static auto netEventRateLimiter = netEventRateLimiterStore.GetRateLimiter("netEvent", fx::RateLimiterDefaults{ 50.f, 200.f });
+		static auto netFloodRateLimiter = netEventRateLimiterStore.GetRateLimiter("netEventFlood", fx::RateLimiterDefaults{ 75.f, 300.f });
+
+		if (!netEventRateLimiter->Consume(source))
+		{
+			if (!netFloodRateLimiter->Consume(source))
+			{
+				gscomms_execute_callback_on_main_thread([this, source]()
+				{
+					auto client = instance->GetComponent<fx::ClientRegistry>()->GetClientByNetID(source);
+
+					if (client)
+					{
+						instance->GetComponent<fx::GameServer>()->DropClient(client, "Unreliable network event overflow.");
+					}
+				});
+			}
+
+			return true;
+		}
+
+		return false;
+	}
+
 public:
 	fx::ServerInstanceBase* instance;
 } g_reassemblySink;