Merge pull request #14 from Comcast/feature/add-auth-msg

Update to the latest webpa-common code and update accordingly.

src/glide.yaml

@@ -2,7 +2,7 @@ package: .
 homepage: https://github.com/Comcast/talaria
 import:
 - package: github.com/Comcast/webpa-common
-  version: 71a8464dd17e855b29b904b64bc928b31370224f
+  version: ae4ce7815a4dc6a3d982f6aee96619da71ffc358
   subpackages:
   - device
   - logging

src/talaria/dispatcher.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/Comcast/webpa-common/device"
 	"github.com/Comcast/webpa-common/logging"
+	"github.com/Comcast/webpa-common/wrp"
 )
 
 // outboundEnvelope is a tuple of information related to handling an asynchronous HTTP request
@@ -140,22 +141,24 @@ func (d *dispatcher) OnDeviceEvent(event *device.Event) {
 		return
 	}
 
-	var (
-		destination = event.Message.To()
-		contentType = event.Format.ContentType()
-	)
-
-	if strings.HasPrefix(destination, EventPrefix) {
-		eventType := destination[len(EventPrefix):]
-		if err := d.dispatchEvent(eventType, contentType, event.Contents); err != nil {
-			d.logger.Error("Error dispatching event [%s]: %s", destination, err)
-		}
-	} else if strings.HasPrefix(destination, DNSPrefix) {
-		unfilteredURL := destination[len(DNSPrefix):]
-		if err := d.dispatchTo(unfilteredURL, contentType, event.Contents); err != nil {
-			d.logger.Error("Error dispatching to [%s]: %s", destination, err)
+	if routable, ok := event.Message.(wrp.Routable); ok {
+		var (
+			destination = routable.To()
+			contentType = event.Format.ContentType()
+		)
+
+		if strings.HasPrefix(destination, EventPrefix) {
+			eventType := destination[len(EventPrefix):]
+			if err := d.dispatchEvent(eventType, contentType, event.Contents); err != nil {
+				d.logger.Error("Error dispatching event [%s]: %s", destination, err)
+			}
+		} else if strings.HasPrefix(destination, DNSPrefix) {
+			unfilteredURL := destination[len(DNSPrefix):]
+			if err := d.dispatchTo(unfilteredURL, contentType, event.Contents); err != nil {
+				d.logger.Error("Error dispatching to [%s]: %s", destination, err)
+			}
+		} else {
+			d.logger.Error("Unable to route to [%s]", destination)
 		}
-	} else {
-		d.logger.Error("Unable to route to [%s]", destination)
 	}
 }