Skip to content

Commit

Permalink
Merge branch 'development' into ODIM-7805
Browse files Browse the repository at this point in the history
  • Loading branch information
chauberahul1993 authored Sep 13, 2023
2 parents 2870e78 + 887f1fc commit 0a0e2ff
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions svc-events/events/publishevttosubscriber.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,16 +136,16 @@ func (e *ExternalInterfaces) PublishEventsToDestination(ctx context.Context, dat
flag = true
}
}
if strings.EqualFold("Alert", inEvent.EventType) {
if strings.Contains(inEvent.MessageID, "ServerPostDiscoveryComplete") || strings.Contains(inEvent.MessageID, "ServerPostComplete") {
go rediscoverSystemInventory(ctx, deviceUUID, inEvent.OriginOfCondition.Oid)
flag = true
}
if strings.Contains(inEvent.MessageID, "ServerPoweredOn") || strings.Contains(inEvent.MessageID, "ServerPoweredOff") {
go updateSystemPowerState(ctx, deviceUUID, rawMessage.Events[index].OriginOfCondition.Oid, inEvent.MessageID)
flag = true
}
} else if strings.EqualFold("ResourceAdded", message.Events[0].EventType) || strings.EqualFold("ResourceRemoved", message.Events[0].EventType) {
//if strings.EqualFold("Alert", inEvent.EventType) {
if strings.Contains(inEvent.MessageID, "ServerPostDiscoveryComplete") || strings.Contains(inEvent.MessageID, "ServerPostComplete") {
go rediscoverSystemInventory(ctx, deviceUUID, inEvent.OriginOfCondition.Oid)
flag = true
}
if strings.Contains(inEvent.MessageID, "ServerPoweredOn") || strings.Contains(inEvent.MessageID, "ServerPoweredOff") {
go updateSystemPowerState(ctx, deviceUUID, rawMessage.Events[index].OriginOfCondition.Oid, inEvent.MessageID)
flag = true
}
if strings.EqualFold("ResourceAdded", message.Events[0].EventType) || strings.EqualFold("ResourceRemoved", message.Events[0].EventType) {
if strings.Contains(message.Events[0].OriginOfCondition.Oid, "Volumes") {
s := strings.Split(message.Events[0].OriginOfCondition.Oid, "/")
storageURI := fmt.Sprintf("/%s/%s/%s/%s/%s/", s[1], s[2], s[3], s[4], s[5])
Expand Down

0 comments on commit 0a0e2ff

Please sign in to comment.