@@ -77,14 +77,14 @@ let filter_messages msg_name_list msg_obj_uuid alert all_msgs =
7777 let msg_body, (msg_name, msg_prio) = alert in
7878 all_msgs
7979 |> List. filter (fun (_ref , record ) ->
80- record.API. message_obj_uuid = msg_obj_uuid
81- && List. mem record.API. message_name msg_name_list
82- )
80+ record.API. message_obj_uuid = msg_obj_uuid
81+ && List. mem record.API. message_name msg_name_list
82+ )
8383 |> List. partition (fun (_ref , record ) ->
84- record.API. message_body <> msg_body
85- || record.API. message_name <> msg_name
86- || record.API. message_priority <> msg_prio
87- )
84+ record.API. message_body <> msg_body
85+ || record.API. message_name <> msg_name
86+ || record.API. message_priority <> msg_prio
87+ )
8888
8989let alert ~rpc ~session_id raw_alerts =
9090 let now = Clock.Date. now () in
@@ -93,20 +93,20 @@ let alert ~rpc ~session_id raw_alerts =
9393 (fun {cls; obj_uuid; obj_description; alert_conditions; expiry} ->
9494 maybe_generate_alert now obj_description alert_conditions expiry
9595 |> Option. map (fun alert ->
96- let msg_name_list =
97- List. map (fun (_ , (msg_name , _ )) -> msg_name) alert_conditions
98- in
99- all_msgs |> filter_messages msg_name_list obj_uuid alert
100- |> fun (outdated , current ) ->
101- List. iter
102- (fun (self , _ ) -> XenAPI.Message. destroy ~rpc ~session_id ~self )
103- outdated ;
104- if current = [] then
105- let body, (name, priority) = alert in
106- XenAPI.Message. create ~rpc ~session_id ~name ~priority ~cls
107- ~obj_uuid ~body
108- |> ignore
109- )
96+ let msg_name_list =
97+ List. map (fun (_ , (msg_name , _ )) -> msg_name) alert_conditions
98+ in
99+ all_msgs |> filter_messages msg_name_list obj_uuid alert
100+ |> fun (outdated , current ) ->
101+ List. iter
102+ (fun (self , _ ) -> XenAPI.Message. destroy ~rpc ~session_id ~self )
103+ outdated ;
104+ if current = [] then
105+ let body, (name, priority) = alert in
106+ XenAPI.Message. create ~rpc ~session_id ~name ~priority ~cls
107+ ~obj_uuid ~body
108+ |> ignore
109+ )
110110 |> ignore
111111 )
112112 raw_alerts
0 commit comments