[utils] Add alert utils

Signed-off-by: Mykola <mykola_kobets@epam.com>

Author: mykola-kobets-epam

resourcemonitor/resourcemonitor_internal_test.go

@@ -29,6 +29,7 @@ import (
 	"github.com/aosedge/aos_common/aoserrors"
 	"github.com/aosedge/aos_common/aostypes"
 	"github.com/aosedge/aos_common/api/cloudprotocol"
+	"github.com/aosedge/aos_common/utils/alertutils"
 	"github.com/shirou/gopsutil/disk"
 	"github.com/shirou/gopsutil/mem"
 	log "github.com/sirupsen/logrus"
@@ -766,7 +767,7 @@ func TestInstances(t *testing.T) {
 	alertLoop:
 		for _, expectedAlert := range item.alerts {
 			for _, receivedAlert := range alertSender.alerts {
-				if AlertsEqual(expectedAlert, receivedAlert) {
+				if alertutils.AlertsPayloadEqual(expectedAlert, receivedAlert) {
 					continue alertLoop
 				}
 			}
@@ -1233,43 +1234,13 @@ func (host *testInstancesUsage) FillSystemInfo(instanceID string, instance *inst
 	return nil
 }
 
-func AlertsEqual(alert1, alert2 interface{}) bool {
-	switch alert1casted := alert1.(type) {
-	case cloudprotocol.SystemQuotaAlert:
-		alert2casted, ok := alert2.(cloudprotocol.SystemQuotaAlert)
-
-		if !ok {
-			return false
-		}
-
-		alert1casted.Timestamp = time.Time{}
-		alert2casted.Timestamp = time.Time{}
-
-		return reflect.DeepEqual(alert1casted, alert2casted)
-
-	case cloudprotocol.InstanceQuotaAlert:
-		alert2casted, ok := alert2.(cloudprotocol.InstanceQuotaAlert)
-
-		if !ok {
-			return false
-		}
-
-		alert1casted.Timestamp = time.Time{}
-		alert2casted.Timestamp = time.Time{}
-
-		return reflect.DeepEqual(alert1casted, alert2casted)
-	}
-
-	return false
-}
-
 func AlertSlicesEqual(alerts1, alerts2 []interface{}) bool {
 	if len(alerts1) != len(alerts2) {
 		return false
 	}
 
 	for i := range alerts1 {
-		if !AlertsEqual(alerts1[i], alerts2[i]) {
+		if !alertutils.AlertsPayloadEqual(alerts1[i], alerts2[i]) {
 			return false
 		}
 	}

utils/alertutils/alertutils.go

@@ -0,0 +1,121 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+// Copyright (C) 2024 Renesas Electronics Corporation.
+// Copyright (C) 2024 EPAM Systems, Inc.
+//
+// Licensed 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 alertutils
+
+import (
+	"reflect"
+
+	"github.com/aosedge/aos_common/api/cloudprotocol"
+)
+
+// AlertsPayloadEqual compares alerts ignoring timestamp.
+//
+//nolint:funlen
+func AlertsPayloadEqual(alert1, alert2 interface{}) bool {
+	switch alert1casted := alert1.(type) {
+	case cloudprotocol.SystemAlert:
+		alert2casted, ok := alert2.(cloudprotocol.SystemAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.CoreAlert:
+		alert2casted, ok := alert2.(cloudprotocol.CoreAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.DownloadAlert:
+		alert2casted, ok := alert2.(cloudprotocol.DownloadAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.SystemQuotaAlert:
+		alert2casted, ok := alert2.(cloudprotocol.SystemQuotaAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.InstanceQuotaAlert:
+		alert2casted, ok := alert2.(cloudprotocol.InstanceQuotaAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.DeviceAllocateAlert:
+		alert2casted, ok := alert2.(cloudprotocol.DeviceAllocateAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.ResourceValidateAlert:
+		alert2casted, ok := alert2.(cloudprotocol.ResourceValidateAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+
+	case cloudprotocol.ServiceInstanceAlert:
+		alert2casted, ok := alert2.(cloudprotocol.ServiceInstanceAlert)
+		if !ok {
+			return false
+		}
+
+		newAlert1 := alert1casted
+		newAlert1.Timestamp = alert2casted.Timestamp
+
+		return reflect.DeepEqual(newAlert1, alert2casted)
+	}
+
+	return false
+}