From d7c950e145f3654872cfb421df72f8f9b3e24c14 Mon Sep 17 00:00:00 2001
From: Stephen J Day <stephen.day@docker.com>
Date: Wed, 29 Nov 2017 14:03:32 -0800
Subject: [PATCH] events: define fieldpath implement for envelope

Signed-off-by: Stephen J Day <stephen.day@docker.com>
---
 events/events.go | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)

diff --git a/events/events.go b/events/events.go
index 87b94c310..2bfedb1e8 100644
--- a/events/events.go
+++ b/events/events.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"time"
 
+	"github.com/containerd/typeurl"
 	"github.com/gogo/protobuf/types"
 )
 
@@ -15,6 +16,36 @@ type Envelope struct {
 	Event     *types.Any
 }
 
+// Field returns the value for the given fieldpath as a string, if defined.
+// If the value is not defined, the second value will be false.
+func (e *Envelope) Field(fieldpath []string) (string, bool) {
+	if len(fieldpath) == 0 {
+		return "", false
+	}
+
+	switch fieldpath[0] {
+	// unhandled: timestamp
+	case "namespace":
+		return string(e.Namespace), len(e.Namespace) > 0
+	case "topic":
+		return string(e.Topic), len(e.Topic) > 0
+	case "event":
+		decoded, err := typeurl.UnmarshalAny(e.Event)
+		if err != nil {
+			return "", false
+		}
+
+		adaptor, ok := decoded.(interface {
+			Field([]string) (string, bool)
+		})
+		if !ok {
+			return "", false
+		}
+		return adaptor.Field(fieldpath[1:])
+	}
+	return "", false
+}
+
 // Event is a generic interface for any type of event
 type Event interface{}