[Notification Template API] Event Handler Implementation

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/constants/SQLConstants.java

@@ -97,4 +97,7 @@ public class SQLConstants {
     public static final String DELETE_APP_NOTIFICATION_TEMPLATES_BY_TYPE_SQL =
             "DELETE FROM IDN_NOTIFICATION_APP_TEMPLATE WHERE TYPE_ID = (" + GET_NOTIFICATION_TYPE_ID_SQL +
                     ") AND APP_ID = :APP_ID; AND TENANT_ID = :TENANT_ID;";
+    public static final String DELETE_ALL_APP_NOTIFICATION_TEMPLATES_BY_TYPE_SQL =
+            "DELETE FROM IDN_NOTIFICATION_APP_TEMPLATE WHERE TYPE_ID = (" + GET_NOTIFICATION_TYPE_ID_SQL +
+                    ") AND TENANT_ID = :TENANT_ID;";
 }

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/constants/TemplateMgtConstants.java

@@ -0,0 +1,112 @@
+/*
+ * Copyright (c) 2024, WSO2 LLC. (http://www.wso2.org) All Rights Reserved.
+ *
+ * WSO2 Inc. licenses this file to you under the Apache License,
+ *  Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.wso2.carbon.email.mgt.constants;
+
+public class TemplateMgtConstants {
+
+    private TemplateMgtConstants() {}
+
+    public static final String DEFAULT_EMAIL_NOTIFICATION_LOCALE = "en_US";
+    public static final String DEFAULT_SMS_NOTIFICATION_LOCALE = "en_US";
+
+    /**
+     * Class which contains the error scenarios.
+     */
+    public static class ErrorScenarios {
+
+        // NTM - NOTIFICATION TEMPLATE MANAGER
+        public static final String NOTIFICATION_TEMPLATE_MANAGER = "NTM";
+    }
+
+    /**
+     * Class which contains the error codes for template management.
+     */
+    public static class ErrorCodes {
+        public static final String TEMPLATE_TYPE_ALREADY_EXISTS = "65001";
+        public static final String TEMPLATE_TYPE_NOT_FOUND = "65002";
+        public static final String TEMPLATE_ALREADY_EXISTS = "65003";
+        public static final String TEMPLATE_NOT_FOUND = "65004";
+        public static final String ERROR_ADDING_TEMPLATE = "65005";
+        public static final String ERROR_UPDATING_TEMPLATE = "65006";
+        public static final String ERROR_SYSTEM_RESOURCE_DELETION_NOT_ALLOWED = "65007";
+        public static final String ERROR_RESOLVING_MAIN_APPLICATION = "65008";
+    }
+
+    /**
+     * Enum which contains error codes and corresponding error messages.
+     */
+    public enum ErrorMessages {
+
+        ERROR_CODE_EMPTY_TEMPLATE_NAME("60001", "Notification template name cannot be empty."),
+        ERROR_CODE_EMPTY_LOCALE("60002", "Locale code cannot be empty"),
+        ERROR_CODE_INVALID_LOCALE("60003", "Locale code is invalid."),
+        ERROR_CODE_EMPTY_TEMPLATE_CHANNEL("60004", "Notification template channel cannot be empty"),
+        ERROR_CODE_INVALID_SMS_TEMPLATE("60005", "Body of a SMS template cannot be empty."),
+        ERROR_CODE_INVALID_SMS_TEMPLATE_CONTENT("60006", "SMS template cannot have a subject or footer"),
+        ERROR_CODE_INVALID_EMAIL_TEMPLATE("60007", "Subject/Body/Footer sections of an email template " +
+                "cannot be empty."),
+        ERROR_CODE_INVALID_TEMPLATE_DISPLAY_NAME("60008", "Invalid template display name."),
+        ERROR_CODE_NULL_TEMPLATE_OBJECT("60009", "Notification template is not provided."),
+        ERROR_CODE_TEMPLATE_TYPE_ALREADY_EXISTS(ErrorCodes.TEMPLATE_TYPE_ALREADY_EXISTS,
+                "Notification template type : %s already exists in tenant : %s"),
+        ERROR_CODE_TEMPLATE_TYPE_NOT_FOUND(ErrorCodes.TEMPLATE_TYPE_NOT_FOUND, "Notification template type :" +
+                " %s doesn't exist in tenant : %s"),
+        ERROR_CODE_TEMPLATE_ALREADY_EXISTS(ErrorCodes.TEMPLATE_ALREADY_EXISTS, "Notification template : %s" +
+                " already exists in tenant : %s"),
+        ERROR_CODE_TEMPLATE_NOT_FOUND(ErrorCodes.TEMPLATE_NOT_FOUND, "Notification template : %s " +
+                "doesn't exist in tenant : %s"),
+        ERROR_CODE_SYSTEM_TEMPLATE_TYPE_NOT_FOUND(ErrorCodes.TEMPLATE_TYPE_NOT_FOUND,
+                "System notification template type : %s doesn't exist."),
+        ERROR_CODE_SYSTEM_TEMPLATE_NOT_FOUND(ErrorCodes.TEMPLATE_NOT_FOUND, "System notification " +
+                "template : %s doesn't exist"),
+        ERROR_CODE_ERROR_ADDING_TEMPLATE(ErrorCodes.ERROR_ADDING_TEMPLATE, "Error when adding template : %s" +
+                " to tenant : %s"),
+        ERROR_CODE_ERROR_UPDATING_TEMPLATE(ErrorCodes.ERROR_UPDATING_TEMPLATE, "Error when updating " +
+                "template : %s on tenant : %s"),
+        ERROR_CODE_SYSTEM_RESOURCE_DELETION_NOT_ALLOWED(ErrorCodes.ERROR_SYSTEM_RESOURCE_DELETION_NOT_ALLOWED,
+                "System resource deletion not allowed. %S"),
+        ERROR_CODE_ERROR_RESOLVING_MAIN_APPLICATION(ErrorCodes.ERROR_RESOLVING_MAIN_APPLICATION,
+                "Error when resolving main application : %s");
+
+        private final String code;
+        private final String message;
+
+        ErrorMessages(String code, String message) {
+
+            this.code = code;
+            this.message = message;
+        }
+
+        public String getCode() {
+
+            return code;
+        }
+
+        public String getMessage() {
+
+            return message;
+        }
+
+        @Override
+        public String toString() {
+
+            return code + " - " + message;
+        }
+    }
+}

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/internal/I18nMgtServiceComponent.java

@@ -28,6 +28,7 @@
 import org.wso2.carbon.context.PrivilegedCarbonContext;
 import org.wso2.carbon.email.mgt.EmailTemplateManager;
 import org.wso2.carbon.email.mgt.EmailTemplateManagerImpl;
+import org.wso2.carbon.email.mgt.NotificationTemplateManagerImpl;
 import org.wso2.carbon.email.mgt.SMSProviderPayloadTemplateManager;
 import org.wso2.carbon.email.mgt.SMSProviderPayloadTemplateManagerImpl;
 import org.wso2.carbon.email.mgt.constants.I18nMgtConstants;
@@ -61,6 +62,7 @@
 import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.Hashtable;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
@@ -110,6 +112,20 @@ protected void activate(ComponentContext context) {
                 log.error("Error registering Email Template Mgt Service.");
             }
 
+            // Register Notification Template Mgt Service as an OSGi service.
+            NotificationTemplateManagerImpl notificationTemplateManager = new NotificationTemplateManagerImpl();
+            Hashtable<String, String> serviceProperties = new Hashtable<>();
+            serviceProperties.put("service.name", "NotificationTemplateManager");
+            ServiceRegistration notificationTemplateSR = bundleCtx.registerService(
+                    NotificationTemplateManager.class.getName(), notificationTemplateManager, serviceProperties);
+            if (notificationTemplateSR != null) {
+                if (log.isDebugEnabled()) {
+                    log.debug("Notification Template Mgt Service registered.");
+                }
+            } else {
+                log.error("Error registering Notification Template Mgt Service.");
+            }
+
             // Register EmailTemplateManagerImpl.
             ServiceRegistration notificationManagerSR = bundleCtx
                     .registerService(NotificationTemplateManager.class.getName(), emailTemplateManager, null);

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/DBBasedTemplateManager.java

@@ -328,6 +328,25 @@ public void deleteNotificationTemplates(String displayName, String notificationC
         }
     }
 
+    @Override
+    public void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+
+        String templateTypeKey = displayName.toLowerCase();
+        int tenantId = getTenantId(tenantDomain);
+
+        orgNotificationTemplateDAO.removeNotificationTemplates(templateTypeKey, notificationChannel, tenantId);
+        if (log.isDebugEnabled()) {
+            log.debug(String.format("Org %s templates for type: %s for tenant: %s successfully deleted.",
+                    notificationChannel, displayName, tenantDomain));
+        }
+        appNotificationTemplateDAO.removeAllNotificationTemplates(templateTypeKey, notificationChannel, tenantId);
+        if (log.isDebugEnabled()) {
+            log.debug(String.format("App %s templates for type: %s for all applications for tenant: %s " +
+                            "successfully deleted.", notificationChannel, displayName, tenantDomain));
+        }
+    }
+
     /**
      * Get the tenant id of the given tenant domain.
      * @param tenantDomain

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/HybridTemplateManager.java

@@ -102,6 +102,20 @@ public void deleteNotificationTemplateType(String displayName, String notificati
         }
     }
 
+    @Override
+    public void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+
+        if (dbBasedTemplateManager.isNotificationTemplateTypeExists(displayName, notificationChannel, tenantDomain)) {
+            dbBasedTemplateManager.deleteAllNotificationTemplates(displayName, notificationChannel, tenantDomain);
+        }
+
+        if (registryBasedTemplateManager.isNotificationTemplateTypeExists(displayName, notificationChannel,
+                tenantDomain)) {
+            registryBasedTemplateManager.deleteAllNotificationTemplates(displayName, notificationChannel, tenantDomain);
+        }
+    }
+
     @Override
     public void addOrUpdateNotificationTemplate(NotificationTemplate notificationTemplate, String applicationUuid,
                                                 String tenantDomain) throws NotificationTemplateManagerServerException {

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/RegistryBasedTemplateManager.java

@@ -297,6 +297,23 @@ public void deleteNotificationTemplates(String displayName, String notificationC
         }
     }
 
+    @Override
+    public void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+
+        String templateType = I18nEmailUtil.getNormalizedName(displayName);
+        String path = buildTemplateRootDirectoryPath(templateType, notificationChannel, null);
+
+        try {
+            Collection templates = (Collection) resourceMgtService.getIdentityResource(path, tenantDomain);
+            for (String subPath : templates.getChildren()) {
+                resourceMgtService.deleteIdentityResource(subPath, tenantDomain);
+            }
+        } catch (IdentityRuntimeException | RegistryException e) {
+            throw new NotificationTemplateManagerServerException("Error while deleting notification templates.", e);
+        }
+    }
+
     /**
      * Get the notification template from resource.
      *

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/SystemDefaultTemplateManager.java

@@ -112,6 +112,13 @@ public void deleteNotificationTemplateType(String displayName, String notificati
         throw new UnsupportedOperationException();
     }
 
+    @Override
+    public void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+
+        throw new UnsupportedOperationException();
+    }
+
     @Override
     public void addOrUpdateNotificationTemplate(NotificationTemplate notificationTemplate, String applicationUuid,
                                                 String tenantDomain) throws NotificationTemplateManagerServerException {

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/TemplatePersistenceManager.java

@@ -73,6 +73,19 @@ List<String> listNotificationTemplateTypes(String notificationChannel, String te
     void deleteNotificationTemplateType(String displayName, String notificationChannel, String tenantDomain)
             throws NotificationTemplateManagerServerException;
 
+    /**
+     * Delete both organization level and application level notification templates under a notification template type.
+     *
+     * @param displayName           Display Name.
+     * @param notificationChannel   Notification channel.
+     * @param tenantDomain          Tenant domain.
+     * @throws NotificationTemplateManagerServerException If an error occurred while resetting the template type.
+     */
+    default void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+        // not implemented
+    }
+
     /**
      * Update the notification template if exists or add a new template if not exists.
      *

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/TemplatePersistenceManagerFactory.java

@@ -33,7 +33,8 @@ public class TemplatePersistenceManagerFactory {
     private static final Log log = LogFactory.getLog(TemplatePersistenceManagerFactory.class);
 
     /**
-     * Returns a {@link TemplatePersistenceManager} implementation based on the configuration.
+     * Returns a {@link TemplatePersistenceManager} implementation based on the configuration that handles both system
+     * templates and user defined templates.
      *
      * If the storage type is configured as database, an instance of {@link DBBasedTemplateManager} will be returned.
      * If the storage type is configured as hybrid, an instance of {@link HybridTemplateManager} will be returned.
@@ -66,4 +67,60 @@ public TemplatePersistenceManager getTemplatePersistenceManager() {
         }
         return new UnifiedTemplateManager(persistenceManager);
     }
+
+    /**
+     * Returns a {@link TemplatePersistenceManager} implementation based on the configuration that handles only user
+     * defined templates.
+     *
+     * If the storage type is configured as database, an instance of {@link DBBasedTemplateManager} will be returned.
+     * If the storage type is configured as hybrid, an instance of {@link HybridTemplateManager} will be returned.
+     * If the storage type is configured as registry, an instance of {@link RegistryBasedTemplateManager} will be returned.
+     * For any other case, an instance of {@link DBBasedTemplateManager} will be returned.
+     *
+     * @return an implementation of {@link TemplatePersistenceManager}.
+     */
+    public TemplatePersistenceManager getUserDefinedTemplatePersistenceManager() {
+
+        String notificationTemplatesStorageType = IdentityUtil.getProperty(NOTIFICATION_TEMPLATES_STORAGE_CONFIG);
+
+        TemplatePersistenceManager persistenceManager = new DBBasedTemplateManager();
+
+        if (StringUtils.isNotBlank(notificationTemplatesStorageType)) {
+            switch (notificationTemplatesStorageType) {
+                case "hybrid":
+                    persistenceManager = new HybridTemplateManager();
+                    log.info("Hybrid template persistent manager initialized.");
+                    break;
+                case "registry":
+                    persistenceManager = new RegistryBasedTemplateManager();
+                    log.warn("Registry based template persistent manager initialized.");
+                    break;
+            }
+        }
+
+        if (log.isDebugEnabled()) {
+            log.debug("Template persistent manager initialized with the type: " + persistenceManager.getClass());
+        }
+        return persistenceManager;
+    }
+
+    /**
+     * Returns a {@link TemplatePersistenceManager} implementation based on the configuration that handles only
+     * system templates.
+     *
+     * If the storage type is configured as database, an instance of {@link DBBasedTemplateManager} will be returned.
+     * If the storage type is configured as hybrid, an instance of {@link HybridTemplateManager} will be returned.
+     * If the storage type is configured as registry, an instance of {@link RegistryBasedTemplateManager} will be returned.
+     * For any other case, an instance of {@link DBBasedTemplateManager} will be returned.
+     *
+     * @return an implementation of {@link TemplatePersistenceManager}.
+     */
+    public TemplatePersistenceManager getSystemTemplatePersistenceManager() {
+
+        SystemDefaultTemplateManager inMemoryTemplateManager = new SystemDefaultTemplateManager();
+        if (log.isDebugEnabled()) {
+            log.debug("Template persistent manager initialized with the type: " + inMemoryTemplateManager.getClass());
+        }
+        return inMemoryTemplateManager;
+    }
 }

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/UnifiedTemplateManager.java

@@ -82,6 +82,16 @@ public void deleteNotificationTemplateType(String displayName, String notificati
         }
     }
 
+    @Override
+    public void deleteAllNotificationTemplates(String displayName, String notificationChannel, String tenantDomain)
+            throws NotificationTemplateManagerServerException {
+
+        if (templatePersistenceManager.isNotificationTemplateTypeExists(displayName, notificationChannel,
+                tenantDomain)) {
+            templatePersistenceManager.deleteAllNotificationTemplates(displayName, notificationChannel, tenantDomain);
+        }
+    }
+
     @Override
     public void addOrUpdateNotificationTemplate(NotificationTemplate notificationTemplate, String applicationUuid,
                                                 String tenantDomain) throws NotificationTemplateManagerServerException {

components/email-mgt/org.wso2.carbon.email.mgt/src/main/java/org/wso2/carbon/email/mgt/store/dao/AppNotificationTemplateDAO.java

@@ -38,6 +38,7 @@
 import static org.wso2.carbon.email.mgt.constants.I18nMgtConstants.NotificationTableColumns.TENANT_ID;
 import static org.wso2.carbon.email.mgt.constants.I18nMgtConstants.NotificationTableColumns.TYPE_ID;
 import static org.wso2.carbon.email.mgt.constants.I18nMgtConstants.NotificationTableColumns.TYPE_KEY;
+import static org.wso2.carbon.email.mgt.constants.SQLConstants.DELETE_ALL_APP_NOTIFICATION_TEMPLATES_BY_TYPE_SQL;
 import static org.wso2.carbon.email.mgt.constants.SQLConstants.DELETE_APP_NOTIFICATION_TEMPLATES_BY_TYPE_SQL;
 import static org.wso2.carbon.email.mgt.constants.SQLConstants.DELETE_APP_NOTIFICATION_TEMPLATE_SQL;
 import static org.wso2.carbon.email.mgt.constants.SQLConstants.GET_APP_NOTIFICATION_TEMPLATE_SQL;
@@ -275,4 +276,24 @@ public void removeNotificationTemplates(String templateType, String channelName,
             throw new NotificationTemplateManagerServerException(error, e);
         }
     }
+
+    public void removeAllNotificationTemplates(String templateType, String channelName, int tenantId)
+            throws NotificationTemplateManagerServerException {
+
+        NamedJdbcTemplate namedJdbcTemplate = JdbcUtils.getNewNamedJdbcTemplate();
+        try {
+            namedJdbcTemplate.executeUpdate(DELETE_ALL_APP_NOTIFICATION_TEMPLATES_BY_TYPE_SQL,
+                    preparedStatement -> {
+                        preparedStatement.setString(TYPE_KEY, templateType.toLowerCase());
+                        preparedStatement.setString(CHANNEL, channelName);
+                        preparedStatement.setInt(TENANT_ID, tenantId);
+                        preparedStatement.setInt(TENANT_ID, tenantId);
+                    });
+        } catch (DataAccessException e) {
+            String error =
+                    String.format("Error while deleting %s templates of type %s from all applications in %s tenant.",
+                            channelName, templateType, tenantId);
+            throw new NotificationTemplateManagerServerException(error, e);
+        }
+    }
 }