Add IP-addresses and MAC-addresses to event

CHANGELOG.asciidoc

@@ -104,6 +104,7 @@ https://github.com/elastic/beats/compare/v6.0.0-beta2...master[Check the HEAD di
 - Added logging of system info at Beat startup. {issue}5946[5946]
 - Do not log errors if X-Pack Monitoring is enabled but Elastisearch X-Pack is not. {pull}6627[6627]
 - Add rename processor. {pull}6292[6292]
+- Add IP-addresses and MAC-addresses to add_host_metadata. {pull}6878[6878]
 
 *Auditbeat*
 

libbeat/processors/add_host_metadata/_meta/fields.yml

@@ -31,3 +31,12 @@
           type: keyword
           description: >
             OS family (e.g. redhat, debian, freebsd, windows).
+        - name: ip
+          type: ip
+          description: >
+            List of IP-addresses.
+        - name: mac
+          type: keyword
+          description: >
+            List of hardware-addresses, usually MAC-addresses.
+

libbeat/processors/add_host_metadata/add_host_metadata.go

@@ -1,13 +1,16 @@
 package add_host_metadata
 
 import (
+	"fmt"
+	"net"
 	"time"
 
 	"github.com/elastic/beats/libbeat/beat"
 	"github.com/elastic/beats/libbeat/common"
 	"github.com/elastic/beats/libbeat/processors"
 	"github.com/elastic/go-sysinfo"
 	"github.com/elastic/go-sysinfo/types"
+	"github.com/pkg/errors"
 )
 
 func init() {
@@ -18,19 +21,27 @@ type addHostMetadata struct {
 	info       types.HostInfo
 	lastUpdate time.Time
 	data       common.MapStr
+	config     Config
 }
 
 const (
+	processorName   = "add_host_metadata"
 	cacheExpiration = time.Minute * 5
 )
 
-func newHostMetadataProcessor(_ *common.Config) (processors.Processor, error) {
+func newHostMetadataProcessor(cfg *common.Config) (processors.Processor, error) {
+	config := defaultConfig()
+	if err := cfg.Unpack(&config); err != nil {
+		return nil, errors.Wrapf(err, "fail to unpack the %v configuration", processorName)
+	}
+
 	h, err := sysinfo.Host()
 	if err != nil {
 		return nil, err
 	}
 	p := &addHostMetadata{
-		info: h.Info(),
+		info:   h.Info(),
+		config: config,
 	}
 	return p, nil
 }
@@ -71,10 +82,57 @@ func (p *addHostMetadata) loadData() {
 		if p.info.OS.Build != "" {
 			p.data.Put("host.os.build", p.info.OS.Build)
 		}
+
+		if p.config.NetInfoEnabled {
+			// IP-address and MAC-address
+			var ipList, hwList = p.getNetInfo()
+			p.data.Put("host.ip", ipList)
+			p.data.Put("host.mac", hwList)
+		}
+
 		p.lastUpdate = time.Now()
 	}
 }
 
+func (p addHostMetadata) getNetInfo() ([]string, []string) {
+	var ipList []string
+	var hwList []string
+
+	// Get all interfaces and loop through them
+	ifaces, err := net.Interfaces()
+	if err != nil {
+		return ipList, hwList
+	}
+	for _, i := range ifaces {
+		// Skip loopback interfaces
+		if i.Flags&net.FlagLoopback == net.FlagLoopback {
+			continue
+		}
+
+		hw := i.HardwareAddr.String()
+		// Skip empty hardware addresses
+		if hw != "" {
+			hwList = append(hwList, hw)
+		}
+
+		addrs, err := i.Addrs()
+		if err != nil {
+			return ipList, hwList
+		}
+		for _, addr := range addrs {
+			switch v := addr.(type) {
+			case *net.IPNet:
+				ipList = append(ipList, v.IP.String())
+			case *net.IPAddr:
+				ipList = append(ipList, v.IP.String())
+			}
+		}
+	}
+
+	return ipList, hwList
+}
+
 func (p addHostMetadata) String() string {
-	return "add_host_metadata=[]"
+	return fmt.Sprintf("%v=[netinfo.enabled=[%v]]",
+		processorName, p.config.NetInfoEnabled)
 }

libbeat/processors/add_host_metadata/add_host_metadata_test.go

@@ -18,7 +18,10 @@ func TestRun(t *testing.T) {
 		Fields:    common.MapStr{},
 		Timestamp: time.Now(),
 	}
-	p, err := newHostMetadataProcessor(nil)
+	testConfig, err := common.NewConfigFrom(map[string]interface{}{})
+	assert.NoError(t, err)
+
+	p, err := newHostMetadataProcessor(testConfig)
 	if runtime.GOOS != "windows" && runtime.GOOS != "darwin" && runtime.GOOS != "linux" {
 		assert.IsType(t, types.ErrNotImplemented, err)
 		return
@@ -31,4 +34,39 @@ func TestRun(t *testing.T) {
 	v, err := newEvent.GetValue("host.os.family")
 	assert.NoError(t, err)
 	assert.NotNil(t, v)
+
+	v, err = newEvent.GetValue("host.ip")
+	assert.Error(t, err)
+	assert.Nil(t, v)
+
+	v, err = newEvent.GetValue("host.mac")
+	assert.Error(t, err)
+	assert.Nil(t, v)
+
+	event = &beat.Event{
+		Fields:    common.MapStr{},
+		Timestamp: time.Now(),
+	}
+	testConfig, err = common.NewConfigFrom(map[string]interface{}{
+		"netinfo.enabled": true,
+	})
+	assert.NoError(t, err)
+
+	p, err = newHostMetadataProcessor(testConfig)
+	if runtime.GOOS != "windows" && runtime.GOOS != "darwin" && runtime.GOOS != "linux" {
+		assert.IsType(t, types.ErrNotImplemented, err)
+		return
+	}
+	assert.NoError(t, err)
+
+	newEvent, err = p.Run(event)
+	assert.NoError(t, err)
+
+	v, err = newEvent.GetValue("host.ip")
+	assert.NoError(t, err)
+	assert.NotNil(t, v)
+
+	v, err = newEvent.GetValue("host.mac")
+	assert.NoError(t, err)
+	assert.NotNil(t, v)
 }

libbeat/processors/add_host_metadata/config.go

@@ -0,0 +1,16 @@
+package add_host_metadata
+
+//import (
+//	"github.com/elastic/beats/libbeat/processors"
+//)
+
+// Config for add_host_metadata processor.
+type Config struct {
+	NetInfoEnabled bool `config:"netinfo.enabled"` // Add IP and MAC to event
+}
+
+func defaultConfig() Config {
+	return Config{
+		//		netInfoEnabled: "false",
+	}
+}