Nail/ipwhitelist-app
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v2: таблицы v2_→оригинальные + impersonation модуль (IMPERSONATION_TARGET + EXTRA_COMPANIES)

Browse Source
This commit is contained in:
naeel
2026-06-15 09:16:10 +04:00
parent cfaf8f34c3
commit 814d066b10
6 changed files with 70 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
v2/src/db/queries.js
+24 -24
View File
@@ -10,14 +10,14 @@
// 3. Фронтенды не видят SQL — только через crud API.
//
// ЧТО ПРИНИМАЕТ:
// companyId — внутренний id из v2_companies (число).
// companyId — внутренний id из companies (число).
// cidr — УЖЕ проверенный CIDR (валидация в crud/).
// email, impBy — для аудита.
//
// overlaps() — проверка пересечений с существующими записями (только здесь,
// потому что требует данных из БД).
//
// ТАБЛИЦЫ: v2_companies, v2_entries, v2_audit (префикс v2_ — изоляция).
// ТАБЛИЦЫ: companies, whitelist_entries, audit_log (префикс v2_ — изоляция).
// ═══════════════════════════════════════════════════════════════════════════════
const { pool } = require('./index');
@@ -31,8 +31,8 @@ const { overlaps } = require('../validators');
*/
async function getOrCreateCompany(clientId, companyName) {
const res = await pool.query(
`INSERT INTO v2_companies (client_id, name) VALUES ($1, $2)
ON CONFLICT (client_id) DO UPDATE SET name = COALESCE(v2_companies.name, EXCLUDED.name)
`INSERT INTO companies (client_id, name) VALUES ($1, $2)
ON CONFLICT (client_id) DO UPDATE SET name = COALESCE(companies.name, EXCLUDED.name)
RETURNING *`,
[clientId, companyName || clientId]
);
@@ -51,11 +51,11 @@ async function getLimit(company) {
/**
* Список записей компании.
* @param {number} companyId — v2_companies.id
* @param {number} companyId — companies.id
* @param {boolean} includeDeleted — показать удалённые
*/
async function listEntries(companyId, includeDeleted = false) {
let sql = 'SELECT * FROM v2_entries WHERE company_id = $1';
let sql = 'SELECT * FROM whitelist_entries WHERE company_id = $1';
const params = [companyId];
if (!includeDeleted) sql += ' AND deleted_at IS NULL';
sql += ' ORDER BY created_at DESC';
@@ -71,19 +71,19 @@ async function createEntry(companyId, cidr, comment, userEmail, impersonatedBy,
await client.query('BEGIN');
const company = (await client.query(
'SELECT * FROM v2_companies WHERE id = $1 FOR UPDATE', [companyId]
'SELECT * FROM companies WHERE id = $1 FOR UPDATE', [companyId]
)).rows[0];
if (!company) throw new Error('Компания не найдена');
const limit = await getLimit(company);
const cnt = (await client.query(
'SELECT COUNT(*)::int AS c FROM v2_entries WHERE company_id = $1 AND deleted_at IS NULL',
'SELECT COUNT(*)::int AS c FROM whitelist_entries WHERE company_id = $1 AND deleted_at IS NULL',
[companyId]
)).rows[0].c;
if (cnt >= limit) throw new Error(`Лимит исчерпан: ${cnt} из ${limit}`);
const existing = (await client.query(
'SELECT value_cidr FROM v2_entries WHERE company_id = $1 AND deleted_at IS NULL',
'SELECT value_cidr FROM whitelist_entries WHERE company_id = $1 AND deleted_at IS NULL',
[companyId]
)).rows;
for (const row of existing) {
@@ -93,7 +93,7 @@ async function createEntry(companyId, cidr, comment, userEmail, impersonatedBy,
}
const res = await client.query(
`INSERT INTO v2_entries (company_id, value_cidr, comment, created_by)
`INSERT INTO whitelist_entries (company_id, value_cidr, comment, created_by)
VALUES ($1, $2, $3, $4) RETURNING *`,
[companyId, cidr, comment || null, userEmail]
);
@@ -115,16 +115,16 @@ async function updateEntry(entryId, companyId, cidr, comment, userEmail, imperso
const client = await pool.connect();
try {
await client.query('BEGIN');
await client.query('SELECT * FROM v2_companies WHERE id = $1 FOR UPDATE', [companyId]);
await client.query('SELECT * FROM companies WHERE id = $1 FOR UPDATE', [companyId]);
const old = (await client.query(
'SELECT * FROM v2_entries WHERE id = $1 AND company_id = $2 AND deleted_at IS NULL',
'SELECT * FROM whitelist_entries WHERE id = $1 AND company_id = $2 AND deleted_at IS NULL',
[entryId, companyId]
)).rows[0];
if (!old) throw new Error('Запись не найдена');
const existing = (await client.query(
'SELECT value_cidr FROM v2_entries WHERE company_id = $1 AND deleted_at IS NULL AND id <> $2',
'SELECT value_cidr FROM whitelist_entries WHERE company_id = $1 AND deleted_at IS NULL AND id <> $2',
[companyId, entryId]
)).rows;
for (const row of existing) {
@@ -134,7 +134,7 @@ async function updateEntry(entryId, companyId, cidr, comment, userEmail, imperso
}
const res = await client.query(
`UPDATE v2_entries SET value_cidr = $1, comment = $2, updated_by = $3, updated_at = NOW()
`UPDATE whitelist_entries SET value_cidr = $1, comment = $2, updated_by = $3, updated_at = NOW()
WHERE id = $4 AND company_id = $5 RETURNING *`,
[cidr, comment || old.comment, userEmail, entryId, companyId]
);
@@ -158,13 +158,13 @@ async function deleteEntry(entryId, companyId, userEmail, impersonatedBy) {
await client.query('BEGIN');
const old = (await client.query(
'SELECT * FROM v2_entries WHERE id = $1 AND company_id = $2 AND deleted_at IS NULL',
'SELECT * FROM whitelist_entries WHERE id = $1 AND company_id = $2 AND deleted_at IS NULL',
[entryId, companyId]
)).rows[0];
if (!old) throw new Error('Запись не найдена');
await client.query(
'UPDATE v2_entries SET deleted_by = $1, deleted_at = NOW() WHERE id = $2 AND company_id = $3',
'UPDATE whitelist_entries SET deleted_by = $1, deleted_at = NOW() WHERE id = $2 AND company_id = $3',
[userEmail, entryId, companyId]
);
await logAudit(userEmail, companyId, 'DELETE', old.value_cidr, null, entryId, impersonatedBy, client);
@@ -180,15 +180,15 @@ async function deleteEntry(entryId, companyId, userEmail, impersonatedBy) {
// ── Админ ─────────────────────────────────────────────────────────────────────
async function getCompanyById(id) {
const res = await pool.query('SELECT * FROM v2_companies WHERE id = $1', [id]);
const res = await pool.query('SELECT * FROM companies WHERE id = $1', [id]);
return res.rows[0] || null;
}
async function getAllCompanies() {
const res = await pool.query(`
SELECT c.*, COUNT(e.id)::int AS active_count
FROM v2_companies c
LEFT JOIN v2_entries e ON e.company_id = c.id AND e.deleted_at IS NULL
FROM companies c
LEFT JOIN whitelist_entries e ON e.company_id = c.id AND e.deleted_at IS NULL
GROUP BY c.id
ORDER BY c.name, c.client_id
`);
@@ -197,7 +197,7 @@ async function getAllCompanies() {
async function setLimit(companyId, newLimit) {
const result = await pool.query(
'UPDATE v2_companies SET custom_limit = $1, updated_at = NOW() WHERE id = $2',
'UPDATE companies SET custom_limit = $1, updated_at = NOW() WHERE id = $2',
[newLimit, companyId]
);
if (result.rowCount === 0) {
@@ -210,7 +210,7 @@ async function setLimit(companyId, newLimit) {
// ── Экспорт ───────────────────────────────────────────────────────────────────
async function getExportCIDRs(companyId = null) {
let sql = 'SELECT value_cidr FROM v2_entries WHERE deleted_at IS NULL';
let sql = 'SELECT value_cidr FROM whitelist_entries WHERE deleted_at IS NULL';
const params = [];
if (companyId) { sql += ' AND company_id = $1'; params.push(companyId); }
sql += ' ORDER BY value_cidr';
@@ -221,7 +221,7 @@ async function getExportCIDRs(companyId = null) {
async function logAudit(userEmail, companyId, action, oldValue, newValue, entryId, impersonatedBy, db = pool) {
await db.query(
`INSERT INTO v2_audit (user_email, company_id, action, old_value, new_value, entry_id, impersonated_by)
`INSERT INTO audit_log (user_email, company_id, action, old_value, new_value, entry_id, impersonated_by)
VALUES ($1, $2, $3, $4, $5, $6, $7)`,
[userEmail, companyId, action, oldValue, newValue, entryId || null, impersonatedBy || null]
);
@@ -230,8 +230,8 @@ async function logAudit(userEmail, companyId, action, oldValue, newValue, entryI
async function getAudit(companyId = null) {
let sql = `
SELECT a.*, c.name AS company_name, c.client_id
FROM v2_audit a
JOIN v2_companies c ON c.id = a.company_id
FROM audit_log a
JOIN companies c ON c.id = a.company_id
`;
const params = [];
if (companyId) { sql += ' WHERE a.company_id = $1'; params.push(companyId); }
v2/src/db/schema.js
+9 -9
View File
@@ -8,9 +8,9 @@
// 3. Безопасно для production: IF NOT EXISTS.
//
// ТАБЛИЦЫ:
// v2_companies — client_id (W-номер), name, custom_limit
// v2_entries — CIDR, комментарий, кто создал/изменил/удалил
// v2_audit — все действия: CREATE/UPDATE/DELETE, с impersonated_by
// companies — client_id (W-номер), name, custom_limit
// whitelist_entries — CIDR, комментарий, кто создал/изменил/удалил
// audit_log — все действия: CREATE/UPDATE/DELETE, с impersonated_by
//
// ИНДЕКСЫ: на company_id для быстрых SELECT + на unique(client_id).
// ═══════════════════════════════════════════════════════════════════════════════
@@ -18,7 +18,7 @@
async function ensureSchema(pool) {
await pool.query(`
-- Компании: W-номер уникален, upsert через ON CONFLICT
CREATE TABLE IF NOT EXISTS v2_companies (
CREATE TABLE IF NOT EXISTS companies (
id SERIAL PRIMARY KEY,
client_id VARCHAR(64) NOT NULL UNIQUE,
name VARCHAR(255),
@@ -28,7 +28,7 @@ async function ensureSchema(pool) {
);
-- Записи: CIDR + метаданные, soft delete
CREATE TABLE IF NOT EXISTS v2_entries (
CREATE TABLE IF NOT EXISTS whitelist_entries (
id SERIAL PRIMARY KEY,
company_id INTEGER NOT NULL,
value_cidr VARCHAR(64) NOT NULL,
@@ -42,7 +42,7 @@ async function ensureSchema(pool) {
);
-- Аудит: каждое действие с возможностью отследить имперсонацию
CREATE TABLE IF NOT EXISTS v2_audit (
CREATE TABLE IF NOT EXISTS audit_log (
id SERIAL PRIMARY KEY,
user_email VARCHAR(255) NOT NULL,
company_id INTEGER NOT NULL,
@@ -54,11 +54,11 @@ async function ensureSchema(pool) {
created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
);
CREATE INDEX IF NOT EXISTS idx_v2_audit_company_time
ON v2_audit(company_id, created_at DESC);
CREATE INDEX IF NOT EXISTS idx_audit_log_company_time
ON audit_log(company_id, created_at DESC);
`);
console.log('[v2:db] Schema ensured');
console.log('[db] Schema ensured');
}
module.exports = { ensureSchema };