Updating to null works now

Also some minor cleanups

Author: sharpner

config.go

@@ -25,6 +25,7 @@ type Mongo struct {
 
 //Watch defines one watch that redkeep will do for you
 type Watch struct {
+	//TODO validate collections to be in this scheme: database.collection
 	TrackCollection       string            `json:"trackCollection" validate:"required,gt=0"`
 	TrackFields           []string          `json:"trackFields" validate:"required,min=1,dive,min=1"`
 	TargetCollection      string            `json:"targetCollection" validate:"required,min=1"`

tail.go

@@ -120,11 +120,6 @@ func handleUpdate(
 	command map[string]interface{},
 	selector map[string]interface{},
 ) {
-	// update all w.TrackFields (that are in command)
-	// in w.TargetCollection
-	// WHERE w.TriggerReference
-	//
-	//selector
 	session := s.Copy()
 	defer session.Close()
 	p := strings.Index(w.TargetCollection, ".")
@@ -135,7 +130,7 @@ func handleUpdate(
 	normalizingFields := bson.M{}
 	for _, field := range w.TrackFields {
 		value := GetValue("$set."+field, command)
-		if value != nil {
+		if HasKey("$set."+field, command) {
 			normalizingFields[w.TargetNormalizedField+"."+field] = value
 		}
 	}
@@ -165,7 +160,6 @@ func HasKey(key string, ds interface{}) bool {
 	}
 
 	if _, ok := data[key]; ok {
-		log.Printf("Key found: [%s]\n", key)
 		return true
 	}
 

tail_test.go

@@ -14,7 +14,32 @@ import (
 )
 
 var _ = Describe("Tail", func() {
-	Context("Test getValue", func() {
+	Context("Test HasKey", func() {
+		It("validate functionality", func() {
+			toTest := map[string]interface{}{
+				"fish": map[string]interface{}{
+					"dog": "cat",
+				},
+				"tree": nil,
+				"yellow": map[string]interface{}{
+					"red": nil,
+				},
+			}
+			actual := HasKey("blub", toTest)
+			Expect(actual).To(Equal(false))
+
+			actual = HasKey("fish.dog", toTest)
+			Expect(actual).To(Equal(true))
+
+			actual = HasKey("yellow.red", toTest)
+			Expect(actual).To(Equal(true))
+
+			actual = HasKey("tree", toTest)
+			Expect(actual).To(Equal(true))
+		})
+	})
+
+	Context("test GetValue", func() {
 		It("will find the first value", func() {
 			testReference := mgo.DBRef{
 				Collection: "diff",