:sparkles: Util

1 files changed, 34 insertions, 0 deletions

diff --git a/src/test/rethink_test.ts b/src/test/rethink_test.ts
new file mode 100644

index 00000000..d1470515
--- /dev/null
+++ b/src/test/rethink_test.ts
@@ -0,0 +1,34 @@
+import { r } from "rethinkdb-ts";
+
+async function main() {
+	const connection = await r.connect({ port: 28015 });
+
+	const db = r.db("test");
+	const cursor = await db
+		.table("guilds")
+		.get(0)
+		.changes({ squash: true })
+		.map(function (row) {
+			return row("old_val")
+				.keys()
+				.setUnion(row("new_val").keys())
+				.concatMap(function (key) {
+					return r.branch(
+						row("old_val")(key).ne(row("new_val")(key)).default(true),
+						[[key, row("new_val")(key).default(null)]],
+						[]
+					);
+				})
+				.coerceTo("object");
+		})
+		.run(connection);
+
+	console.log("each");
+	cursor.each(function (err, row) {
+		if (err) throw err;
+		console.log(row);
+	});
+	console.log("eachend");
+}
+
+main();