feat #OBS-I649 : set channel as a reciever for a alert rule

Author: JeraldJF

api-service/src/controllers/DatasetRead/DatasetRead.ts

@@ -82,7 +82,7 @@ const readDataset = async (datasetId: string, attributes: string[]): Promise<any
     const api_version = _.get(dataset, "api_version")
     const datasetConfigs: any = {}
     const transformations_config = await datasetService.getTransformations(datasetId, ["field_key", "transformation_function", "mode", "metadata"])
-    const datasourceConfig = await Datasource.findOne({ where: { dataset_id: datasetId, is_primary: true }, attributes: ["datasource"], raw: true })
+    const datasourceConfig = await Datasource.findOne({ where: { dataset_id: datasetId, is_primary: true, type: "druid" }, attributes: ["datasource"], raw: true })
     datasetConfigs["alias"] = _.get(datasourceConfig, "datasource")
     if (api_version !== "v2") {
         datasetConfigs["transformations_config"] = _.map(transformations_config, (config) => {

api-service/src/services/DatasetService.ts

@@ -144,7 +144,7 @@ class DatasetService {
                 {
                     model: Datasource,
                     attributes: ['datasource'],
-                    where: { is_primary: true },
+                    where: { is_primary: true, type: "druid" },
                     required: false
                 },
             ], raw: true, where: filters, attributes, order: [["updated_date", "DESC"]]

api-service/src/services/managers/grafana/alert/helpers/index.ts

@@ -244,11 +244,27 @@ const getMatchingLabels = async (channels: string[]) => {
     }
 }
 
+const getNotificationChannel = async (channels: string[]) => {
+    const fetchChannel = (id: string) => {
+        return Notification.findOne({ where: { id } })
+            .then(response => response?.toJSON())
+            .then(channelMetadata => {
+                const { name, type } = channelMetadata;
+                return name;
+            })
+            .catch(() => null);
+    }
+
+    const [name] = await Promise.all(channels.map(fetchChannel));
+    return name;
+}
+
 const transformRule = async ({ value, condition, metadata, isGroup }: any) => {
     const { name, id, interval, category, frequency, labels = {}, annotations = {}, severity, description, notification = {} } = value;
     const annotationObj = { ...annotations, description: description };
     const channels = _.get(notification, "channels") || [];
     const matchingLabelsForNotification = await getMatchingLabels(channels);
+    const channel = await getNotificationChannel(channels);
 
     const payload = {
         grafana_alert: {
@@ -258,6 +274,7 @@ const transformRule = async ({ value, condition, metadata, isGroup }: any) => {
             exec_err_state: _.get(metadata, "exec_err_state", "Error"),
             data: metadata,
             is_paused: false,
+            ...(channel && { notification_settings: { receiver: channel } })
         },
         for: interval,
         annotations: annotationObj,