test: run evaluateSync in tests

Author: judofyr

src/evaluator/operators.ts

@@ -74,7 +74,7 @@ export const operators: {[key in OpCall]: GroqOperatorFn} = {
   },
 
   // eslint-disable-next-line func-name-matching
-  'in': async function inop(left, right) {
+  'in': function inop(left, right) {
     if (right.type === 'path') {
       if (left.type !== 'string') {
         return NULL_VALUE
@@ -83,16 +83,28 @@ export const operators: {[key in OpCall]: GroqOperatorFn} = {
       return right.data.matches(left.data) ? TRUE_VALUE : FALSE_VALUE
     }
 
-    if (right.isArray()) {
-      for await (const b of right) {
-        if (isEqual(left, b)) {
+    if (right.type === 'array') {
+      for (const b of right.data) {
+        if (isEqual(left, fromJS(b))) {
           return TRUE_VALUE
         }
       }
 
       return FALSE_VALUE
     }
 
+    if (right.type === 'stream') {
+      return (async () => {
+        for await (const b of right) {
+          if (isEqual(left, b)) {
+            return TRUE_VALUE
+          }
+        }
+
+        return FALSE_VALUE
+      })()
+    }
+
     return NULL_VALUE
   },
 

test/generate.js

@@ -18,6 +18,8 @@ const DISABLED_TESTS = [
   /score\(\) function \/ Illegal use/, // we're missing validation here
 ]
 
+const IS_SYNCHRONOUS = (test) => !/changed(Any|Only)/.test(test.query)
+
 const WHITESPACE_REGEX = /\s+/g
 
 const OUTPUT = process.stdout
@@ -48,7 +50,7 @@ function space() {
 write(`const fs = require('fs')`)
 write(`const ndjson = require('ndjson')`)
 write(`const tap = require('tap')`)
-write(`const {evaluate, parse} = require('../src/1')`)
+write(`const {evaluate, parse, evaluateSync, toJS} = require('../src/1')`)
 space()
 
 write(`tap.setTimeout(0)`)
@@ -233,6 +235,13 @@ process.stdin
         write(`data = JSON.parse(JSON.stringify(data))`)
         write(`replaceScoreWithPos(data)`)
         write(`tt.match(data, result)`)
+        if (IS_SYNCHRONOUS(entry)) {
+          write(`// Sync`)
+          write(`let syncValue = evaluateSync(tree, {dataset, params})`)
+          write(`let syncData = toJS(syncValue)`)
+          write(`replaceScoreWithPos(syncData)`)
+          write(`tt.match(syncData, result)`)
+        }
       } else {
         write(`tt.throws(() => parse(query))`)
       }