feat(monitor): send heartbeat on install/update and version change

- onExtensionAfterInstall: immediate heartbeat after package install - onAfterInitialise: detect version change on first admin page load, send heartbeat if version differs from last sent, store version in plugin params to avoid re-sending every session
2026-06-09 12:31:57 -05:00
parent 119a6a37b7
commit bdbbf6d2a8
1 changed files with 54 additions and 1 deletions
@@ -34,10 +34,63 @@ class Monitor extends CMSPlugin implements SubscriberInterface
 	public static function getSubscribedEvents(): array
 	{
 		return [
-			'onExtensionAfterSave' => 'onExtensionAfterSave',
+			'onExtensionAfterSave'    => 'onExtensionAfterSave',
+			'onAfterInitialise'       => 'onAfterInitialise',
+			'onExtensionAfterInstall' => 'onExtensionAfterInstall',
 		];
 	}

+	/**
+	 * Send heartbeat on first admin page load after install/update.
+	 */
+	public function onAfterInitialise(): void
+	{
+		$app = $this->getApplication();
+		if (!$app->isClient('administrator')) return;
+		if (!$this->params->get('heartbeat_enabled', 1)) return;
+
+		$session = \Joomla\CMS\Factory::getSession();
+		if ($session->get('mokosuite.heartbeat_sent', false)) return;
+
+		// Check if version changed since last heartbeat
+		$lastVersion = $this->params->get('_last_heartbeat_version', '');
+		$currentVersion = $this->getMokoSuiteVersion();
+
+		if ($lastVersion !== $currentVersion)
+		{
+			$session->set('mokosuite.heartbeat_sent', true);
+			$this->sendHeartbeat();
+
+			// Store version so we don't re-send every session
+			try
+			{
+				$db = \Joomla\CMS\Factory::getDbo();
+				$params = json_decode($this->params->toString(), true) ?: [];
+				$params['_last_heartbeat_version'] = $currentVersion;
+				$db->setQuery(
+					$db->getQuery(true)
+						->update('#__extensions')
+						->set('params = ' . $db->quote(json_encode($params)))
+						->where('element = ' . $db->quote('mokosuite_monitor'))
+						->where('folder = ' . $db->quote('system'))
+						->where('type = ' . $db->quote('plugin'))
+				)->execute();
+			}
+			catch (\Throwable $e) {}
+		}
+	}
+
+	/**
+	 * Send heartbeat immediately after package install/update.
+	 */
+	public function onExtensionAfterInstall($installer, $eid): void
+	{
+		if (!$this->params->get('heartbeat_enabled', 1)) return;
+
+		try { $this->sendHeartbeat(); }
+		catch (\Throwable $e) {}
+	}
+
 	/**
 	 * After saving this plugin or the core plugin, send heartbeat.
 	 */