39 lines
1.4 KiB
JavaScript
39 lines
1.4 KiB
JavaScript
import { pool } from '../pool.js';
|
|
import { recordAudit } from './audit.js';
|
|
|
|
export async function create({ action_id, tier, params, agent_id, requested_by }) {
|
|
const { rows: [r] } = await pool.query(
|
|
`INSERT INTO agent_actions(action_id, tier, params, agent_id, requested_by)
|
|
VALUES($1,$2,$3,$4,$5) RETURNING *`,
|
|
[action_id, tier, params || {}, agent_id || null, requested_by || null]
|
|
);
|
|
await recordAudit(requested_by, 'create', 'agent_action', r.id, null, r);
|
|
return r;
|
|
}
|
|
|
|
export async function listPending({ limit = 100 } = {}) {
|
|
const { rows } = await pool.query(
|
|
`SELECT * FROM agent_actions WHERE status='pending' ORDER BY created_at LIMIT $1`, [limit]);
|
|
return rows;
|
|
}
|
|
|
|
export async function getById(id) {
|
|
const { rows: [r] } = await pool.query(`SELECT * FROM agent_actions WHERE id=$1`, [id]);
|
|
return r;
|
|
}
|
|
|
|
export async function resolve(id, status, result, resolved_by) {
|
|
const { rows: [r] } = await pool.query(
|
|
`UPDATE agent_actions SET status=$1, result=$2, resolved_by=$3, resolved_at=now()
|
|
WHERE id=$4 AND status='pending' RETURNING *`,
|
|
[status, result || null, resolved_by || null, id]);
|
|
if (r) await recordAudit(resolved_by, 'update', 'agent_action', id, null, r);
|
|
return r;
|
|
}
|
|
|
|
export async function recent({ limit = 50 } = {}) {
|
|
const { rows } = await pool.query(
|
|
`SELECT * FROM agent_actions WHERE status<>'pending' ORDER BY resolved_at DESC NULLS LAST LIMIT $1`, [limit]);
|
|
return rows;
|
|
}
|