OpenNMS · joseanesONMS · Jul 30, 2026 · Jul 30, 2026
diff --git a/opennms-webapp-rest/src/main/java/org/opennms/web/rest/v1/NotificationConfigRestService.java b/opennms-webapp-rest/src/main/java/org/opennms/web/rest/v1/NotificationConfigRestService.java
diff --git a/opennms-webapp-rest/src/main/webapp/WEB-INF/menu/menu-template.json b/opennms-webapp-rest/src/main/webapp/WEB-INF/menu/menu-template.json
@@ -262,7 +262,7 @@
         {
           "id": "notifications",
           "name": "Notifications",
-          "url": "notification/index.jsp",
+          "url": "ui/index.html#/admin/notifications",
           "locationMatch": "notification",
           "roles": null
         },

diff --git a/...ms-webapp-rest/src/test/java/org/opennms/web/rest/v1/NotificationConfigRestServiceIT.java b/...ms-webapp-rest/src/test/java/org/opennms/web/rest/v1/NotificationConfigRestServiceIT.java
@@ -0,0 +1,247 @@
+/*
+ * Licensed to The OpenNMS Group, Inc (TOG) under one or more
+ * contributor license agreements.  See the LICENSE.md file
+ * distributed with this work for additional information
+ * regarding copyright ownership.
+ *
+ * TOG licenses this file to You under the GNU Affero General
+ * Public License Version 3 (the "License") or (at your option)
+ * any later version.  You may not use this file except in
+ * compliance with the License.  You may obtain a copy of the
+ * License at:
+ *
+ *      https://www.gnu.org/licenses/agpl-3.0.txt
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied.  See the License for the specific
+ * language governing permissions and limitations under the
+ * License.
+ */
+package org.opennms.web.rest.v1;
+
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+import java.io.File;
+import java.sql.Connection;
+import java.sql.Statement;
+import java.nio.charset.Charset;
+import java.util.TreeMap;
+import java.util.SortedMap;
+
+import javax.ws.rs.core.MediaType;
+
+import org.apache.commons.io.FileUtils;
+import org.json.JSONArray;
+import org.json.JSONObject;
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.opennms.core.test.ConfigurationTestUtils;
+import org.opennms.core.test.MockLogAppender;
+import org.opennms.core.test.OpenNMSJUnit4ClassRunner;
+import org.opennms.core.test.db.annotations.JUnitTemporaryDatabase;
+import org.opennms.core.test.rest.AbstractSpringJerseyRestTestCase;
+import org.opennms.core.db.DataSourceFactory;
+import org.opennms.netmgt.filter.FilterDaoFactory;
+import org.opennms.netmgt.filter.api.FilterDao;
+import org.opennms.netmgt.filter.api.FilterParseException;
+import org.opennms.test.JUnitConfigurationEnvironment;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.mock.web.MockHttpServletRequest;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.web.WebAppConfiguration;
+
+@RunWith(OpenNMSJUnit4ClassRunner.class)
+@WebAppConfiguration
+@ContextConfiguration(locations={
+        "classpath:/META-INF/opennms/applicationContext-soa.xml",
+        "classpath:/META-INF/opennms/applicationContext-commonConfigs.xml",
+        "classpath:/META-INF/opennms/applicationContext-minimal-conf.xml",
+        "classpath:/META-INF/opennms/applicationContext-dao.xml",
+        "classpath:/META-INF/opennms/applicationContext-mockConfigManager.xml",
+        "classpath*:/META-INF/opennms/component-service.xml",
+        "classpath*:/META-INF/opennms/component-dao.xml",
+        "classpath:/META-INF/opennms/applicationContext-databasePopulator.xml",
+        "classpath:/META-INF/opennms/mockEventIpcManager.xml",
+        "file:src/main/webapp/WEB-INF/applicationContext-svclayer.xml",
+        "file:src/main/webapp/WEB-INF/applicationContext-cxf-common.xml",
+        "classpath:/applicationContext-rest-test.xml"
+})
+@JUnitConfigurationEnvironment(systemProperties="org.opennms.timeseries.strategy=integration")
+@JUnitTemporaryDatabase
+public class NotificationConfigRestServiceIT extends AbstractSpringJerseyRestTestCase {
+
+    private static final String INVALID_RULE = "this is not a rule";
+
+    private String m_onmsHome;
+
+    private FilterDao m_filterDao;
+
+    @Override
+    protected void beforeServletStart() throws Exception {
+        MockLogAppender.setupLogging();
+        File etc = new File("target/test-work-dir/etc");
+        etc.mkdirs();
+        m_onmsHome = etc.getParent();
+        System.setProperty("opennms.home", m_onmsHome);
+        ConfigurationTestUtils.setRelativeHomeDirectory(m_onmsHome);
+
+        FileUtils.writeStringToFile(new File(etc, "notifd-configuration.xml"), "<?xml version=\"1.0\"?>"
+                + "<notifd-configuration status=\"off\" match-all=\"true\">"
+                + "<queue><queue-id>default</queue-id><interval>20s</interval>"
+                + "<handler-class><name>org.opennms.netmgt.notifd.DefaultQueueHandler</name></handler-class>"
+                + "</queue>"
+                + "</notifd-configuration>", Charset.defaultCharset());
+        // deliberately NOT calling NotifdConfigFactory.init() here: the service
+        // must initialize it itself (cold-start ordering regression guard)
+
+        FileUtils.writeStringToFile(new File(etc, "notifications.xml"), "<?xml version=\"1.0\"?>"
+                + "<notifications xmlns=\"http://xmlns.opennms.org/xsd/notifications\">"
+                + "<header><rev>1.2</rev><created>Wednesday, February 6, 2002 10:10:00 AM EST</created><mstation>localhost</mstation></header>"
+                + "<notification name=\"junitNotification\" status=\"on\">"
+                + "<uei>uei.opennms.org/nodes/nodeDown</uei>"
+                + "<rule>IPADDR != '0.0.0.0'</rule>"
+                + "<destinationPath>Email-Admin</destinationPath>"
+                + "<text-message>node down</text-message>"
+                + "</notification>"
+                + "</notifications>", Charset.defaultCharset());
+
+        FileUtils.writeStringToFile(new File(etc, "destinationPaths.xml"), "<?xml version=\"1.0\"?>"
+                + "<destinationPaths>"
+                + "<header><rev>1.2</rev><created>Wednesday, February 6, 2002 10:10:00 AM EST</created><mstation>localhost</mstation></header>"
+                + "<path name=\"Email-Admin\">"
+                + "<target><name>Admin</name><command>javaEmail</command></target>"
+                + "</path>"
+                + "</destinationPaths>", Charset.defaultCharset());
+
+        FileUtils.writeStringToFile(new File(etc, "notificationCommands.xml"), "<?xml version=\"1.0\"?>"
+                + "<notification-commands xmlns=\"http://xmlns.opennms.org/xsd/notificationCommands\">"
+                + "<header><ver>.9</ver><created>Wednesday, February 6, 2002 10:10:00 AM EST</created><mstation>localhost</mstation></header>"
+                + "<command binary=\"false\">"
+                + "<name>javaEmail</name>"
+                + "<execute>org.opennms.netmgt.notifd.JavaMailNotificationStrategy</execute>"
+                + "<comment>send an email</comment>"
+                + "</command>"
+                + "</notification-commands>", Charset.defaultCharset());
+
+        FileUtils.writeStringToFile(new File(etc, "groups.xml"), "<?xml version=\"1.0\"?>"
+                + "<groupinfo xmlns=\"http://xmlns.opennms.org/xsd/groups\">"
+                + "<header><rev>1.3</rev><created>Wednesday, February 6, 2002 10:10:00 AM EST</created><mstation>localhost</mstation></header>"
+                + "<groups><group><name>Admin</name><user>admin</user></group></groups>"
+                + "<roles><role name=\"junit-oncall\" supervisor=\"admin\" membership-group=\"Admin\"/></roles>"
+                + "</groupinfo>", Charset.defaultCharset());
+
+        m_filterDao = mock(FilterDao.class);
+        final SortedMap<Integer, String> nodeMap = new TreeMap<>();
+        nodeMap.put(1, "node1");
+        when(m_filterDao.getNodeMap("IPADDR IPLIKE *.*.*.*")).thenReturn(nodeMap);
+        doThrow(new FilterParseException("invalid rule")).when(m_filterDao).validateRule(INVALID_RULE);
+        FilterDaoFactory.setInstance(m_filterDao);
+    }
+
+    // Required so context initialization can't repoint opennms.home at
+    // opennms-base-assembly between servlet start and the first request.
+    @Override
+    public void afterServletStart() throws Exception {
+        System.setProperty("opennms.home", m_onmsHome);
+        ConfigurationTestUtils.setRelativeHomeDirectory(m_onmsHome);
+        // Seed the node row for the pathoutage foreign key through the same
+        // DataSource the service uses, so it is committed and visible to the
+        // service's own connections regardless of test transactions.
+        try (Connection conn = DataSourceFactory.getInstance().getConnection();
+             Statement st = conn.createStatement()) {
+            st.execute("INSERT INTO monitoringlocations (id, monitoringarea) VALUES ('Default', 'Default') ON CONFLICT (id) DO NOTHING");
+            st.execute("INSERT INTO node (nodeid, nodecreatetime, nodelabel, location) VALUES (1, now(), 'node1', 'Default') ON CONFLICT (nodeid) DO NOTHING");
+        }
+    }
+
+    @Test
+    public void testNotifdStatus() throws Exception {
+        JSONObject status = new JSONObject(getJson("/notification-config/status"));
+        Assert.assertEquals("off", status.getString("status"));
+
+        sendData(PUT, MediaType.APPLICATION_JSON, "/notification-config/status", "{\"status\":\"on\"}", 204);
+        status = new JSONObject(getJson("/notification-config/status"));
+        Assert.assertEquals("on", status.getString("status"));
+
+        // only on/off are valid
+        sendData(PUT, MediaType.APPLICATION_JSON, "/notification-config/status", "{\"status\":\"maybe\"}", 400);
+    }
+
+    @Test
+    public void testPathOutageLifecycle() throws Exception {
+        JSONArray outages = new JSONArray(getJson("/notification-config/path-outages"));
+        Assert.assertEquals(0, outages.length());
+
+        JSONObject preview = new JSONObject(getJson("/notification-config/path-outages/preview?rule=IPADDR%20IPLIKE%20*.*.*.*"));
+        Assert.assertEquals(1, preview.getInt("totalCount"));
+        Assert.assertEquals("node1", preview.getJSONArray("nodes").getJSONObject(0).getString("nodeLabel"));
+
+        sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages",
+                "{\"rule\":\"IPADDR IPLIKE *.*.*.*\",\"criticalIp\":\"192.168.1.1\",\"criticalSvc\":\"ICMP\"}", 204);
+        outages = new JSONArray(getJson("/notification-config/path-outages"));
+        Assert.assertEquals(1, outages.length());
+        Assert.assertEquals("192.168.1.1", outages.getJSONObject(0).getString("criticalPathIp"));
+
+        sendRequest(DELETE, "/notification-config/path-outages/1", 204);
+        outages = new JSONArray(getJson("/notification-config/path-outages"));
+        Assert.assertEquals(0, outages.length());
+    }
+
+    @Test
+    public void testPathOutageClearsWithBlankIp() throws Exception {
+        sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages",
+                "{\"rule\":\"IPADDR IPLIKE *.*.*.*\",\"criticalIp\":\"192.168.1.1\"}", 204);
+        Assert.assertEquals(1, new JSONArray(getJson("/notification-config/path-outages")).length());
+
+        // blank critical IP clears the path for the matching nodes
+        sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages",
+                "{\"rule\":\"IPADDR IPLIKE *.*.*.*\"}", 204);
+        Assert.assertEquals(0, new JSONArray(getJson("/notification-config/path-outages")).length());
+    }
+
+    @Test
+    public void testPathOutageValidation() throws Exception {
+        sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages",
+                "{\"rule\":\"" + INVALID_RULE + "\",\"criticalIp\":\"192.168.1.1\"}", 400);
+        sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages", "{}", 400);
+        sendRequest(GET, "/notification-config/path-outages/preview", 400);
+    }
+
+    @Test
+    public void testDestinationPathsReadable() throws Exception {
+        // the read side ships in the base PR: the event-notification editor
+        // needs the path list for its destination picker
+        // order-independent: sibling tests may add or rename paths
+        JSONObject list = new JSONObject(getJson("/notification-config/destination-paths"));
+        Assert.assertTrue(list.getJSONArray("path").length() >= 1);
+        final String firstName = list.getJSONArray("path").getJSONObject(0).getString("name");
+        JSONObject path = new JSONObject(getJson("/notification-config/destination-paths/"
+                + java.net.URLEncoder.encode(firstName, java.nio.charset.StandardCharsets.UTF_8)));
+        Assert.assertEquals(firstName, path.getString("name"));
+    }
+
+    @Test
+    public void testForbiddenForNonAdmin() throws Exception {
+        setUser("nobody", new String[]{ "ROLE_USER" });
+        try {
+            sendRequest(GET, "/notification-config/status", 403);
+            sendData(PUT, MediaType.APPLICATION_JSON, "/notification-config/status", "{\"status\":\"on\"}", 403);
+            sendData(POST, MediaType.APPLICATION_JSON, "/notification-config/path-outages",
+                    "{\"rule\":\"IPADDR IPLIKE *.*.*.*\"}", 403);
+        } finally {
+            setUser("admin", new String[]{ "ROLE_ADMIN" });
+        }
+    }
+
+    private String getJson(final String url) throws Exception {
+        // the instance createRequest carries the setUser() user AND roles
+        final MockHttpServletRequest request = createRequest(GET, url);
+        request.addHeader("Accept", MediaType.APPLICATION_JSON);
+        return sendRequest(request, 200);
+    }
+}
diff --git a/ui/src/components/AdminNotifications/ConfigureNotificationsDialog.vue b/ui/src/components/AdminNotifications/ConfigureNotificationsDialog.vue
@@ -0,0 +1,111 @@
+<template>
+  <Dialog
+    :visible="visible"
+    modal
+    maximizable
+    header="Configure Notifications"
+    class="configure-notifications-dialog"
+    :style="{ width: '1100px', maxWidth: '95vw' }"
+    data-test="configure-notifications-dialog"
+    @update:visible="(value: boolean) => emit('update:visible', value)"
+  >
+    <Tabs v-model:value="activeTab">
+      <TabList>
+        <Tab value="path-outages" data-test="tab-path-outages">Path Outages</Tab>
+        <Tab value="general" data-test="tab-general">General</Tab>
+      </TabList>
+      <TabPanels>
+        <TabPanel value="path-outages">
+          <PathOutagesTab />
+        </TabPanel>
+        <TabPanel value="general">
+          <div class="general-tab">
+            <div class="status-toggle">
+              <PToggleSwitch
+                :modelValue="store.notifdStatus === 'on'"
+                :disabled="store.notifdStatus === null || statusPending"
+                aria-label="Turn notifications on or off"
+                data-test="notifd-status-toggle"
+                @update:modelValue="onStatusToggle"
+              />
+              <span class="status-label">Notifications are <strong>{{ store.notifdStatus ?? 'unknown' }}</strong></span>
+            </div>
+            <p class="status-hint">
+              System-wide switch. While off, OpenNMS will not create outgoing notices for any
+              event. The current status is also reflected by the bell icon in the top bar.
+            </p>
+          </div>
+        </TabPanel>
+      </TabPanels>
+    </Tabs>
+  </Dialog>
+</template>
+
+<script setup lang="ts">
+import { ref, watch } from 'vue'
+
+import Dialog from 'primevue/dialog'
+import Tab from 'primevue/tab'
+import TabList from 'primevue/tablist'
+import TabPanel from 'primevue/tabpanel'
+import TabPanels from 'primevue/tabpanels'
+import Tabs from 'primevue/tabs'
+import ToggleSwitch from 'primevue/toggleswitch'
+
+import PathOutagesTab from '@/components/AdminNotifications/PathOutagesTab.vue'
+import { useNotificationConfigStore } from '@/stores/notificationConfigStore'
+import { NotifdStatus } from '@/types/notificationConfig'
+
+const PToggleSwitch = ToggleSwitch
+
+const props = defineProps<{
+  visible: boolean
+}>()
+
+const emit = defineEmits(['update:visible'])
+
+const store = useNotificationConfigStore()
+
+const activeTab = ref('general')
+const statusPending = ref(false)
+const populated = ref(false)
+
+watch(
+  () => props.visible,
+  async (isVisible) => {
+    if (isVisible && !populated.value) {
+      await store.populate()
+      populated.value = true
+    }
+  }
+)
+
+const onStatusToggle = async (value: boolean) => {
+  statusPending.value = true
+  try {
+    await store.setStatus((value ? 'on' : 'off') as NotifdStatus)
+  } finally {
+    statusPending.value = false
+  }
+}
+</script>
+
+<style lang="scss" scoped>
+.general-tab {
+  padding: 1rem 0;
+
+  .status-toggle {
+    display: flex;
+    align-items: center;
+    gap: 0.75rem;
+  }
+
+  .status-hint {
+    margin-top: 1rem;
+    color: var(--p-text-muted-color);
+    font-size: 0.9rem;
+    max-width: 60ch;
+  }
+}
+
+</style>