rethinkdb-validator-stream
Validate rethinkdb queries streaming to the socket
Installation
npm i --save rethinkdb-validator-stream
Usage
var createValidatorStream = var astStream = ... // incoming ast streamvar socket = ... // rethinkdb socket connectionvar replyStream = ... // outgoing reply stream var opts = db: 'database' // optional, specify database requirement for all queries whitelist: // exact reql query or reql validator, // see `http://github.com/tjmehta/validate-reql` for examples var validatorStream = // incoming pipelineastStream// handle validation errorsvalidatorStream// outgoign pipelinesocket
Credits
Thank you Mike Mintz! Code is heavily inspired by rethinkdb-websocket-server
License
MIT