meb/OLD-server-architecture
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: standardize database environment variables to POSTGRES prefix and update gitignore with common development patterns

Browse Source
This commit is contained in:
Giuseppe Raffa
2026-03-28 16:05:11 +01:00
parent bcfce32adb
commit 33b9be13de
4 changed files with 34 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
.gitignore vendored
View File

@@ -1,2 +1,19 @@
.env .env
node_modules node_modules
**/dist/
**/build/
.npm/
**.log
**/data/
**.sqlite
**.db
**/volumes/
.DS_Store
Thumbs.db
.vscode/
.idea/
**/tsconfig.tsbuildinfo
.eslintcache

8
api/src/storage/postgres.js
View File

@@ -1,10 +1,10 @@
const { Pool } = require('pg'); const { Pool } = require('pg');
const config = { const config = {
user: process.env.PG_USER, user: process.env.POSTGRES_USER,
password: process.env.PG_PASSWORD, password: process.env.POSTGRES_PASSWORD,
host: process.env.PG_HOST, host: process.env.POSTGRES_HOST,
port: process.env.PG_PORT, port: process.env.POSTGRES_PORT,
max: 10, max: 10,
idleTimeoutMillis: 30000, idleTimeoutMillis: 30000,
connectionTimeoutMillis: 5000 connectionTimeoutMillis: 5000

10
auth/src/storage/database.js
View File

@@ -1,16 +1,16 @@
const { Pool } = require('pg'); const { Pool } = require('pg');
const config = { const config = {
user: process.env.DB_USER, user: process.env.POSTGRES_USER,
password: process.env.DB_PASSWORD, password: process.env.POSTGRES_PASSWORD,
host: process.env.DB_HOST, host: process.env.POSTGRES_HOST,
port: process.env.DB_PORT, port: process.env.POSTGRES_PORT,
max: 10, max: 10,
idleTimeoutMillis: 30000, idleTimeoutMillis: 30000,
connectionTimeoutMillis: 5000 connectionTimeoutMillis: 5000
} }
const pool = new Pool({ ...config, database: process.env.DB_NAME }); const pool = new Pool({ ...config, database: process.env.POSTGRES_NAME });
pool.on('error', (err) => { pool.on('error', (err) => {
console.error('Error in database', err); console.error('Error in database', err);

16
realtime/src/helper/authdb.js
View File

@@ -2,11 +2,11 @@ const { Pool } = require('pg');
const { hash, generateShortId } = require('./cryptoUtils'); const { hash, generateShortId } = require('./cryptoUtils');
const pool = new Pool({ const pool = new Pool({
user: process.env.DB_USER, user: process.env.POSTGRES_USER,
host: process.env.DB_HOST, host: process.env.POSTGRES_HOST,
database: process.env.DB_NAME, database: process.env.POSTGRES_NAME,
password: process.env.DB_PASSWORD, password: process.env.POSTGRES_PASSWORD,
port: process.env.DB_PORT, port: process.env.POSTGRES_PORT,
}) })
async function checkDB() { async function checkDB() {
@@ -30,7 +30,7 @@ async function getSensor(token) {
async function createSensor(name, code) { async function createSensor(name, code) {
const hashedCode = hash(code); const hashedCode = hash(code);
// Verifica se l'hash esiste già // Verifica se l'hash esiste già
const result = await pool.query('SELECT id FROM sensors WHERE code_hash = $1', [hashedCode]); const result = await pool.query('SELECT id FROM sensors WHERE code_hash = $1', [hashedCode]);
if (result.rows.length > 0) { if (result.rows.length > 0) {
@@ -40,7 +40,7 @@ async function createSensor(name, code) {
// Genera un ID casuale di 8 caratteri (ottimizzato per spazio, non solo alfanumerico) // Genera un ID casuale di 8 caratteri (ottimizzato per spazio, non solo alfanumerico)
const sensorId = generateShortId(8); const sensorId = generateShortId(8);
await pool.query('INSERT INTO sensors (id, name, code_hash, is_active, last_seen, created_at) VALUES ($1, $2, $3, $4, $5, $6)', await pool.query('INSERT INTO sensors (id, name, code_hash, is_active, last_seen, created_at) VALUES ($1, $2, $3, $4, $5, $6)',
[sensorId, name, hashedCode, true, new Date(), new Date()]); [sensorId, name, hashedCode, true, new Date(), new Date()]);
} }
@@ -61,7 +61,7 @@ async function updateLastSeen(id) {
*/ */
async function setSensorActivity(id, is_active) { async function setSensorActivity(id, is_active) {
await pool.query('UPDATE sensors SET is_active = $1 WHERE id = $2', [is_active, id]); await pool.query('UPDATE sensors SET is_active = $1 WHERE id = $2', [is_active, id]);
} }
async function sensorsExists(id) { async function sensorsExists(id) {
const result = await pool.query('SELECT id FROM sensors WHERE id = $1', [id]); const result = await pool.query('SELECT id FROM sensors WHERE id = $1', [id]);