summary refs log tree commit diff
path: root/src/test/rethink_test.ts.disabled
diff options
context:
space:
mode:
authorFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-04-22 23:29:06 +0200
committerFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-04-22 23:29:06 +0200
commit4528a96ded3f2023d193957a95ffbd070e4cfc30 (patch)
tree8ad86c56dbd32dbd85a6d4ec9ce06d950a8fb2b3 /src/test/rethink_test.ts.disabled
parent:zap: :sparkles: prod multi threading (diff)
downloadserver-4528a96ded3f2023d193957a95ffbd070e4cfc30.tar.xz
prepare npm publish
Diffstat (limited to 'src/test/rethink_test.ts.disabled')
-rw-r--r--src/test/rethink_test.ts.disabled34
1 files changed, 34 insertions, 0 deletions
diff --git a/src/test/rethink_test.ts.disabled b/src/test/rethink_test.ts.disabled
new file mode 100644

index 00000000..d1470515 --- /dev/null +++ b/src/test/rethink_test.ts.disabled
@@ -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();