From 7e8d5f9fe9f2f86896f614412f03fe226da79707 Mon Sep 17 00:00:00 2001
From: Tobie Morgan Hitchcock <tobie@abcum.com>
Date: Tue, 5 Dec 2017 10:44:25 +0000
Subject: [PATCH] Add tests for using params with CONTENT/MERGE/DIFF

---
 db/update_test.go | 87 +++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 85 insertions(+), 2 deletions(-)

diff --git a/db/update_test.go b/db/update_test.go
index c94b05ae..0463fbfb 100644
--- a/db/update_test.go
+++ b/db/update_test.go
@@ -365,6 +365,33 @@ func TestUpdate(t *testing.T) {
 
 	})
 
+	Convey("Update a record using CONTENT stored in a $param", t, func() {
+
+		setupDB()
+
+		txt := `
+		USE NS test DB test;
+		Let data = {"other":true};
+		CREATE person:test SET test="text";
+		UPDATE person:test CONTENT $data;
+		SELECT * FROM person;
+		`
+
+		res, err := Execute(setupKV(), txt, nil)
+		So(err, ShouldBeNil)
+		So(res, ShouldHaveLength, 5)
+		So(res[2].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[2].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[2].Result[0]).Get("other").Data(), ShouldEqual, nil)
+		So(res[3].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[3].Result[0]).Get("test").Data(), ShouldEqual, nil)
+		So(data.Consume(res[3].Result[0]).Get("other").Data(), ShouldEqual, true)
+		So(res[4].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[4].Result[0]).Get("test").Data(), ShouldEqual, nil)
+		So(data.Consume(res[4].Result[0]).Get("other").Data(), ShouldEqual, true)
+
+	})
+
 	Convey("Update a record using MERGE", t, func() {
 
 		setupDB()
@@ -427,6 +454,33 @@ func TestUpdate(t *testing.T) {
 
 	})
 
+	Convey("Update a record using MERGE stored in a $param", t, func() {
+
+		setupDB()
+
+		txt := `
+		USE NS test DB test;
+		LET data = {"other":true};
+		CREATE person:test SET test="text";
+		UPDATE person:test MERGE $data;
+		SELECT * FROM person;
+		`
+
+		res, err := Execute(setupKV(), txt, nil)
+		So(err, ShouldBeNil)
+		So(res, ShouldHaveLength, 5)
+		So(res[2].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[2].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[2].Result[0]).Get("other").Data(), ShouldEqual, nil)
+		So(res[3].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[3].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[3].Result[0]).Get("other").Data(), ShouldEqual, true)
+		So(res[4].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[4].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[4].Result[0]).Get("other").Data(), ShouldEqual, true)
+
+	})
+
 	Convey("Update a record using DIFF", t, func() {
 
 		setupDB()
@@ -442,15 +496,44 @@ func TestUpdate(t *testing.T) {
 		So(err, ShouldBeNil)
 		So(res, ShouldHaveLength, 4)
 		So(res[1].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[1].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[1].Result[0]).Get("other").Data(), ShouldEqual, nil)
 		So(res[2].Result, ShouldHaveLength, 1)
-		So(data.Consume(res[3].Result[0]).Get("test").Data(), ShouldEqual, "text")
-		So(data.Consume(res[3].Result[0]).Get("other").Data(), ShouldEqual, true)
+		So(data.Consume(res[2].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[2].Result[0]).Get("other").Data(), ShouldEqual, true)
 		So(res[3].Result, ShouldHaveLength, 1)
 		So(data.Consume(res[3].Result[0]).Get("test").Data(), ShouldEqual, "text")
 		So(data.Consume(res[3].Result[0]).Get("other").Data(), ShouldEqual, true)
 
 	})
 
+	Convey("Update a record using DIFF stored in a $param", t, func() {
+
+		setupDB()
+
+		txt := `
+		USE NS test DB test;
+		LET data = [{"op":"add","path":"/other","value":true}];
+		CREATE person:test SET test="text";
+		UPDATE person:test DIFF $data;
+		SELECT * FROM person;
+		`
+
+		res, err := Execute(setupKV(), txt, nil)
+		So(err, ShouldBeNil)
+		So(res, ShouldHaveLength, 5)
+		So(res[2].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[2].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[2].Result[0]).Get("other").Data(), ShouldEqual, nil)
+		So(res[3].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[3].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[3].Result[0]).Get("other").Data(), ShouldEqual, true)
+		So(res[4].Result, ShouldHaveLength, 1)
+		So(data.Consume(res[4].Result[0]).Get("test").Data(), ShouldEqual, "text")
+		So(data.Consume(res[4].Result[0]).Get("other").Data(), ShouldEqual, true)
+
+	})
+
 	Convey("Update records using DIFF", t, func() {
 
 		setupDB()