HOS-24599: Implement AH_MSG_TRAP_BOOTOS trap over telegraf

Author: PadmaPriya-Extreme

plugins/inputs/ah_trap/ah_trap.go

@@ -378,11 +378,56 @@ func (t *TrapPlugin) Gather_Ah_send_trap(trapType uint32, trapBuf [256]byte, acc
 		       "powerMode_poeTrap":     powerModeToString(poe.PowerMode),
 	       }, nil)
 
+       case AH_MSG_TRAP_BOOTOS:
+              var bootos AhTgrafBootOsTrap
+              copy((*[unsafe.Sizeof(bootos)]byte)(unsafe.Pointer(&bootos))[:], trapBuf[:unsafe.Sizeof(bootos)])
+
+              acc.AddFields("TrapEvent", map[string]interface{}{
+                      "trapId_bootosTrap":     bootos.TrapID,
+                      "osType_bootosTrap":      osTypeToString(bootos.OsType),
+                      "status_bootosTrap":      bootosStatusToString(bootos.Status),
+                      "description_bootosTrap":   ahutil.CleanCString(bootos.Description[:]),
+              }, nil)
+
 	}
 
 	return nil
 }
 
+/*
+Helper function to convert osType value to string for bootos trap
+*/
+func osTypeToString(osType uint8) string {
+       switch osType {
+       case 0:
+               return "HOS"
+       case 1:
+               return "WiNG"
+       case 2:
+               return "WiNG-CAMP"
+       case 3:
+               return "WiNG-DIST"
+       default:
+               return fmt.Sprintf("UNKNOWN(%d)", osType)
+       }
+}
+
+/*
+Helper function to convert bootos status value to string
+*/
+func bootosStatusToString(status uint8) string {
+       switch status {
+       case 0:
+               return "Success"
+       case 1:
+               return "Failed"
+       case 2:
+               return "Legacy HW"
+       default:
+               return fmt.Sprintf("UNKNOWN(%d)", status)
+       }
+}
+
 /*
 Helper function to convert powerMode value to string
 */
@@ -565,7 +610,19 @@ func (t *TrapPlugin) trapListener(conn net.PacketConn) {
                        if err := t.Gather_Ah_send_trap(trapType, trapBuf, t.acc); err != nil {
                                log.Printf("[ah_trap] Error gathering Poe trap: %v", err)
                        }
-		}
+	       case AH_MSG_TRAP_BOOTOS:
+		       var bootos AhTgrafBootOsTrap
+		       expected := int(unsafe.Sizeof(bootos))
+		       if len(payload) != expected {
+			       log.Printf("[ah_trap] Invalid Bootos size: got %d, expected %d", len(payload), expected)
+			       continue
+		       }
+		       var trapBuf [AH_TRAP_SIZE_256]byte
+		       copy(trapBuf[:expected], payload)
+		       if err := t.Gather_Ah_send_trap(trapType, trapBuf, t.acc); err != nil {
+			       log.Printf("[ah_trap] Error gathering Bootos trap: %v", err)
+		       }
+	       }
 	}
 }
 

plugins/inputs/ah_trap/ah_trap_defines_common.go

@@ -30,6 +30,7 @@ const (
 	AH_TRAP_SIZE_300	  = 300
 	AH_TRAP_SIZE_256         = 256
 	AH_MSG_TRAP_POE          = 16
+	AH_MSG_TRAP_BOOTOS       = 121
 )
 
 const (
@@ -96,6 +97,13 @@ type AhTgrafPoeTrap struct {
 	PowerMode       uint8
 }
 
+type AhTgrafBootOsTrap struct {
+	TrapID		uint8
+	OsType		uint8
+	Status		uint8
+	Description	[TRAP_DCRPT_LEN]byte
+}
+
 type AhFailureTrap struct {
 	Name  [AH_MAX_TRAP_OBJ_NAME+1]byte
 	Cause int32