Merge branch 'insp3' into master.

1 files changed, 92 insertions, 0 deletions

diff --git a/include/modules/monitor.h b/include/modules/monitor.h
new file mode 100644
index 000000000..2f92a9449
--- /dev/null
+++ b/include/modules/monitor.h
@@ -0,0 +1,92 @@
+/*
+ * InspIRCd -- Internet Relay Chat Daemon
+ *
+ *   Copyright (C) 2022 Sadie Powell <sadie@witchery.services>
+ *   Copyright (C) 2021 delthas <delthas@dille.cc>
+ *
+ * This file is part of InspIRCd.  InspIRCd is free software: you can
+ * redistribute it and/or modify it under the terms of the GNU General Public
+ * License as published by the Free Software Foundation, version 2.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+ * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
+ * details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+
+#pragma once
+
+namespace Monitor
+{
+	class APIBase;
+	class API;
+	class ForEachHandler;
+	class WriteWatchersWithCap;
+}
+
+class Monitor::APIBase
+	: public DataProvider
+{
+public:
+	APIBase(Module* parent)
+		: DataProvider(parent, "monitor")
+	{
+	}
+
+	/** Runs the provided handler for all watchers of a user
+	* @param user The user to check watchers for.
+	* @param handler The handler to execute for each watcher of that event.
+	* @param extended_only Whether to only run the handler for watchers using the extended-notify cap.
+	*/
+	virtual void ForEachWatcher(User* user, ForEachHandler& handler, bool extended_only = true) = 0;
+};
+
+class Monitor::API final
+	: public dynamic_reference<Monitor::APIBase>
+{
+public:
+	API(Module* parent)
+		: dynamic_reference<Monitor::APIBase>(parent, "monitor")
+	{
+	}
+};
+
+class Monitor::ForEachHandler
+{
+public:
+	/** Method to execute for each watcher of a user.
+	 * Derived classes must implement this.
+	 * @param user Current watcher of the user
+	 */
+	virtual void Execute(LocalUser* user) = 0;
+};
+
+
+class Monitor::WriteWatchersWithCap
+	: public Monitor::ForEachHandler
+{
+private:
+	const Cap::Capability& cap;
+	ClientProtocol::Event& ev;
+	uint64_t sentid;
+
+	void Execute(LocalUser* user) override
+	{
+		if (user->already_sent != sentid && cap.IsEnabled(user))
+			user->Send(ev);
+	}
+
+public:
+	WriteWatchersWithCap(Monitor::API& monitorapi, User* user, ClientProtocol::Event& event, const Cap::Capability& capability, uint64_t id)
+		: cap(capability)
+		, ev(event)
+		, sentid(id)
+	{
+		if (monitorapi)
+			monitorapi->ForEachWatcher(user, *this);
+	}
+};