pt/pf_app
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Tag operation result rows with pf_note and pf_op

Browse Source 
Forecast tables don't carry pf_note; it's joined from pf.log on /data
fetch. RETURNING * from scale/recode/clone INSERTs lacks those fields,
so rows appended via table.update arrived with pf_note null until a
reload re-ran the join. Inject pf_note and pf_op server-side from the
request before responding.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
Paul Trowbridge 2026-04-28 21:33:32 -04:00
parent 8492557621
commit 15ab5a3a13
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
routes/operations.js
View File

@ -254,7 +254,8 @@ module.exports = function(pool) {
}); });
const result = await runSQL(sql); const result = await runSQL(sql);
res.json({ rows: result.rows, rows_affected: result.rows.length }); const rows = result.rows.map(r => ({ ...r, pf_note: note || null, pf_op: 'scale' }));
res.json({ rows, rows_affected: rows.length });
} catch (err) { } catch (err) {
console.error(err); console.error(err);
res.status(err.status || 500).json({ error: err.message }); res.status(err.status || 500).json({ error: err.message });
@ -289,7 +290,8 @@ module.exports = function(pool) {
}); });
const result = await runSQL(sql); const result = await runSQL(sql);
res.json({ rows: result.rows, rows_affected: result.rows.length }); const rows = result.rows.map(r => ({ ...r, pf_note: note || null, pf_op: 'recode' }));
res.json({ rows, rows_affected: rows.length });
} catch (err) { } catch (err) {
console.error(err); console.error(err);
res.status(err.status || 500).json({ error: err.message }); res.status(err.status || 500).json({ error: err.message });
@ -326,7 +328,8 @@ module.exports = function(pool) {
}); });
const result = await runSQL(sql); const result = await runSQL(sql);
res.json({ rows: result.rows, rows_affected: result.rows.length }); const rows = result.rows.map(r => ({ ...r, pf_note: note || null, pf_op: 'clone' }));
res.json({ rows, rows_affected: rows.length });
} catch (err) { } catch (err) {
console.error(err); console.error(err);
res.status(err.status || 500).json({ error: err.message }); res.status(err.status || 500).json({ error: err.message });