Почему не обновляются данные при выводе через knex?

Question

[Александр Иванов]

При выводе на /api когда добавляю запись в бд и обновляю страницу новые данные не выводятся. Т.е. они выводятся но только при перезагрузке сервера, на php это работает без перезагрузки сервера, поэтому я немного сбит с толку.

// connection DB
const options = {
    client: 'pg',
    connection: {
        host: 'localhost',
        user: 'postgres',
        password: '1',
        database: 'chat'
    }
}
const webpack = require('webpack');
// const webpackDevMiddleware = require('webpack-dev-middleware');
const webpackConfig = require('./webpack.config.js');

const 
    knex = require('knex')(options),
    Koa = require('koa'),
    router = require('koa-router')(),
    http = require('http'),
    app = new Koa(),
    serve = require('koa-static'),
    server = http.createServer(app.callback()),
    io = require('socket.io')(server);

knex.schema.hasTable('messages').then(exists => {
    if (!exists) {
        return knex.schema.createTable('messages', t => {
            t.increments('id').primary();
            t.string('message', 100);
            t.string('idroom', 100);
        });
    }
});

io.on('connection', client => {
    client.join('messages');
    client.on('message', req => {
        insertInto(req);
        io.to('messages').emit('message', req.message);
    });
});

let messages;
knex.select().from('messages').timeout(1000).then(res => {
    messages = JSON.stringify(res);
});

router.get('/api', async (ctx, next) => {
    ctx.body = messages;
});

// add value to database
function insertInto(req){
    req.idroom = 'messages';
    knex.insert([req], ['id']).into('messages')
        .then(() => {
            console.log('result:', { success: true, message: req })
        });
}

app.use(serve(__dirname + '/public'))
    .use(router.routes())
    .use(require('webpack-hot-middleware')(webpack(webpackConfig)))
 
server.listen(process.env.PORT | 3000);
console.log ('Listening at port ' + 3000 + ' ...');

Answer 1

[RidgeA]

вот это

let messages;
knex.select().from('messages').timeout(1000).then(res => {
    messages = JSON.stringify(res);
});

отрабатывает 1 раз при запуске приложения

Comments

[Александр Иванов]

А как это исправить? Я с knex до этого не работал.. и с node тоже

[RidgeA]

нужно, скорее всего, получать сообщения при каждом запросе на API

где-то внутри

router.get('/api', async (ctx, next) => {
    ctx.body = messages;
});

в отличии от PHP, NodeJS запусает процесс и он работает пока не упадет/не будет завершен
Именно по этому сообщения запрашиваются 1 раз и обновляются только после перезапуска сервера