fix: update sensors route to correctly pass database name to query function
This commit is contained in:
@@ -32,6 +32,7 @@ app.get('/health', (req, res) => {
|
|||||||
|
|
||||||
app.use('/connect', require('./routes/connect'));
|
app.use('/connect', require('./routes/connect'));
|
||||||
app.use('/sensors', require('./routes/sensors'));
|
app.use('/sensors', require('./routes/sensors'));
|
||||||
|
app.use('/sessions', require('./routes/sessions'));
|
||||||
|
|
||||||
app.listen(3000, '0.0.0.0', () => {
|
app.listen(3000, '0.0.0.0', () => {
|
||||||
console.log(`Realtime started`);
|
console.log(`Realtime started`);
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ const db = require('../store/db');
|
|||||||
|
|
||||||
router.get('/', async (req, res) => {
|
router.get('/', async (req, res) => {
|
||||||
try {
|
try {
|
||||||
const result = await db.query('SELECT id, name FROM sensors', [], 'sensors');
|
const result = await db.query('sensors', 'SELECT id, name FROM sensors');
|
||||||
res.json(result.rows);
|
res.json(result.rows);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('Error fetching sensors', err);
|
console.error('Error fetching sensors', err);
|
||||||
@@ -14,7 +14,7 @@ router.get('/', async (req, res) => {
|
|||||||
router.get('/:id', async (req, res) => {
|
router.get('/:id', async (req, res) => {
|
||||||
const { id } = req.params;
|
const { id } = req.params;
|
||||||
try {
|
try {
|
||||||
const result = await db.query('SELECT id, name FROM sensors WHERE id = $1', [id], 'sensors');
|
const result = await db.query('sensors', 'SELECT id, name FROM sensors WHERE id = $1', [id]);
|
||||||
if (result.rows.length === 0) {
|
if (result.rows.length === 0) {
|
||||||
return res.status(404).json({ error: 'sensor not found' });
|
return res.status(404).json({ error: 'sensor not found' });
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user