Receiver

/*

** Copyright (C) 2001-2024 Zabbix SIA

**

** Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated

** documentation files (the "Software"), to deal in the Software without restriction, including without limitation the

** rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to

** permit persons to whom the Software is furnished to do so, subject to the following conditions:

**

** The above copyright notice and this permission notice shall be included in all copies or substantial portions

** of the Software.

**

** THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE

** WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR

** COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,

** TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

** SOFTWARE.

**/

​

package server

​

import (

    "encoding/json"

    "fmt"

    "io"

)

​

func handleEvent(rc io.ReadCloser) error {

    decoder := json.NewDecoder(rc)

    for decoder.More() {

        var event event

        if err := decoder.Decode(&event); err != nil {

            return fmt.Errorf("failed to parse history body data %s", err.Error())

        }

​

        errors := event.validate()

        if len(errors) != 0 {

            return fmt.Errorf("failed to validate data errors: %v", errors)

        }

    }

​

    return nil

}

​

func (e event) validate() map[string]string {

    errors := e.generic.validate()

​

    err := e.EventId.validate()

    if err != nil {

        errors["eventId"] = err.Error()

    }

​

    err = e.Severity.validate()

    if err != nil {

        errors["severity"] = err.Error()

    }

​

    err = e.Hosts.validate()

    if err != nil {

        errors["hosts"] = err.Error()

    }

​

    for i, h := range e.Hosts.Value {

        err = h.Host.validate()