TypeError: horizon_server._reql_conn.read is not a function

[vignestion]

How to use reql embed quries with horizon

horizon_server._reql_conn.read().then((reql_conn) => {
                          ^

const express = require('express');
const https = require('https');
const path = require('path');
const fs = require('fs');
const horizon = require('@horizon/server');
const r = horizon.r;

const app = express();

// Serve our static stuff like css
app.use(express.static(path.join(__dirname, 'dist')));

// Send all requests to index.html
app.get('*', function (req, res) {
    res.sendFile(path.join(__dirname, 'dist', 'index.html'));
});
const options = {
    key: fs.readFileSync(path.resolve(__dirname, './horizon-key.pem')),
    cert: fs.readFileSync(path.resolve(__dirname, './horizon-cert.pem')),
};

const PORT = 8181;

const server = https.createServer(options, app);

server.listen(PORT, function() {
    console.log('Express server running at localhost:' + PORT);
});

const horizon_options = {
    project_name: 'react_horizon',
    permissions: false,

    auth: {
        token_secret:  'sd',
        allow_anonymous: true,
        allow_unauthenticated: true,

    }
};
const horizon_server = horizon(server, horizon_options);
//error 
horizon_server._reql_conn.read().then((reql_conn) => {
    var doc = r.db('react_horizon').table('views').get(2).run(reql_conn.connection());
    console.log(doc)
});

[jirikolarik]

Hey, something like that wouldn't work?

const connection =  horizon_server._reql_conn.connection();
horizon.r.db('database').table('..').customQuery.run(connection);

[MichalZalecki]

@jirikolarik Not quite

Error: Connection to the database is down.

@githubitsme Try _ready_promise instead of read().

horizonServer._reql_conn._ready_promise.then((reql_conn) => {

[jirikolarik]

I got it working like this:

horizonServer._reql_conn.ready().then(() => { // eslint-disable-line no-underscore-dangle
  const conn = horizonServer._reql_conn.connection();
  horizon.r.db('database').table('..').customQuery.run(connection);
});