f89e074dd1
Governed substrate for autonomous agents: scoped identity (passports), audited actions, MCP workspace. Infra IPs and secrets redacted for public release.
360 lines
12 KiB
JavaScript
360 lines
12 KiB
JavaScript
// backend/routes/v3/telegram/lifePipeline.js
|
||
// Life Pipeline quick commands: /sprint, /today, /done, /weight, /mood
|
||
|
||
import { apiLogger, sendMessage, dbRun, dbGet, dbAll, isPostgres, safeJsonParse } from './shared.js';
|
||
|
||
/**
|
||
* Handle /sprint command — Show current sprint tasks.
|
||
*/
|
||
export async function handleSprint(chatId) {
|
||
try {
|
||
const rows = await dbAll(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND (data->>'state') NOT IN ('Done', 'Archive')
|
||
ORDER BY
|
||
CASE data->>'priority'
|
||
WHEN 'P1' THEN 1
|
||
WHEN 'P2' THEN 2
|
||
WHEN 'P3' THEN 3
|
||
ELSE 4
|
||
END ASC,
|
||
id DESC`
|
||
: `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND json_extract(data, '$.state') NOT IN ('Done', 'Archive')
|
||
ORDER BY id DESC`
|
||
);
|
||
|
||
if (!rows || rows.length === 0) {
|
||
await sendMessage(chatId, '📋 *Sprint* — нет активных задач.');
|
||
return;
|
||
}
|
||
|
||
// Group by priority
|
||
const groups = {};
|
||
for (const row of rows) {
|
||
const d = safeJsonParse(row.data, {});
|
||
const prio = d.priority || 'No Priority';
|
||
if (!groups[prio]) groups[prio] = [];
|
||
groups[prio].push({ id: row.id, ...d });
|
||
}
|
||
|
||
const prioEmoji = { P1: '🔴', P2: '🟠', P3: '🟡' };
|
||
const stateEmoji = { 'In Progress': '🔄', 'To Do': '📌', 'Backlog': '📥', 'Review': '👀', 'Blocked': '🚫' };
|
||
let msg = `📋 *Sprint* — ${rows.length} задач(а)\n\n`;
|
||
|
||
for (const prio of ['P1', 'P2', 'P3', 'No Priority']) {
|
||
const items = groups[prio];
|
||
if (!items || items.length === 0) continue;
|
||
msg += `${prioEmoji[prio] || '⚪'} *${prio}* (${items.length})\n`;
|
||
for (const item of items) {
|
||
const st = stateEmoji[item.state] || '▪️';
|
||
const title = (item.title || item.name || 'Untitled').substring(0, 60);
|
||
msg += ` ${st} \`#${item.id || ''}\` ${title}\n`;
|
||
}
|
||
msg += '\n';
|
||
}
|
||
|
||
msg += '✅ Отметить: `/done <id>`';
|
||
await sendMessage(chatId, msg);
|
||
} catch (err) {
|
||
apiLogger.error({ err }, '[Telegram] /sprint command failed');
|
||
await sendMessage(chatId, '❌ Ошибка загрузки спринта.');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Handle /today command — Morning briefing on demand (calendar + tasks + health).
|
||
*/
|
||
export async function handleToday(chatId) {
|
||
try {
|
||
const todayStart = new Date();
|
||
todayStart.setHours(0, 0, 0, 0);
|
||
const todayEnd = new Date();
|
||
todayEnd.setHours(23, 59, 59, 999);
|
||
|
||
// Active sprint tasks (not Done/Archive)
|
||
const tasks = await dbAll(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND (data->>'state') NOT IN ('Done', 'Archive')
|
||
ORDER BY
|
||
CASE data->>'priority'
|
||
WHEN 'P1' THEN 1
|
||
WHEN 'P2' THEN 2
|
||
WHEN 'P3' THEN 3
|
||
ELSE 4
|
||
END ASC
|
||
LIMIT 10`
|
||
: `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND json_extract(data, '$.state') NOT IN ('Done', 'Archive')
|
||
ORDER BY id DESC
|
||
LIMIT 10`
|
||
);
|
||
|
||
// Today's completed tasks
|
||
const doneToday = await dbAll(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND (data->>'state') = 'Done'
|
||
AND (data->>'completed_date')::date = CURRENT_DATE`
|
||
: `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2649
|
||
AND json_extract(data, '$.state') = 'Done'
|
||
AND date(json_extract(data, '$.completed_date')) = date('now')`
|
||
);
|
||
|
||
// Today's health metrics
|
||
const healthMetrics = await dbAll(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2643
|
||
AND (data->>'recorded_at')::date = CURRENT_DATE
|
||
ORDER BY created_at DESC`
|
||
: `SELECT id, data FROM table_rows
|
||
WHERE table_id = 2643
|
||
AND date(json_extract(data, '$.recorded_at')) = date('now')
|
||
ORDER BY created_at DESC`
|
||
);
|
||
|
||
// Calendar events for today
|
||
let calendarEvents = [];
|
||
try {
|
||
calendarEvents = await dbAll(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows
|
||
WHERE table_id IN (SELECT id FROM tables WHERE name ILIKE '%calendar%' LIMIT 1)
|
||
AND (data->>'start_time')::date = CURRENT_DATE
|
||
ORDER BY data->>'start_time' ASC
|
||
LIMIT 10`
|
||
: `SELECT id, data FROM table_rows
|
||
WHERE table_id IN (SELECT id FROM tables WHERE name LIKE '%calendar%' LIMIT 1)
|
||
AND date(json_extract(data, '$.start_time')) = date('now')
|
||
ORDER BY json_extract(data, '$.start_time') ASC
|
||
LIMIT 10`
|
||
);
|
||
} catch (_) { /* calendar table may not exist */ }
|
||
|
||
// Build message
|
||
const dateStr = new Date().toLocaleDateString('ru-RU', { weekday: 'long', day: 'numeric', month: 'long' });
|
||
let msg = `☀️ *Брифинг на сегодня*\n📅 ${dateStr}\n\n`;
|
||
|
||
// Calendar section
|
||
if (calendarEvents && calendarEvents.length > 0) {
|
||
msg += '🗓 *Календарь:*\n';
|
||
for (const evt of calendarEvents) {
|
||
const d = safeJsonParse(evt.data, {});
|
||
const time = d.start_time ? new Date(d.start_time).toLocaleTimeString('ru-RU', { hour: '2-digit', minute: '2-digit' }) : '';
|
||
const title = d.title || d.summary || d.name || 'Событие';
|
||
msg += ` 🕐 ${time} — ${title}\n`;
|
||
}
|
||
msg += '\n';
|
||
} else {
|
||
msg += '🗓 *Календарь:* нет событий\n\n';
|
||
}
|
||
|
||
// Tasks section
|
||
msg += `📋 *Задачи* (${(tasks || []).length} активных):\n`;
|
||
if (tasks && tasks.length > 0) {
|
||
for (const row of tasks) {
|
||
const d = safeJsonParse(row.data, {});
|
||
const prio = d.priority ? `[${d.priority}]` : '';
|
||
const title = (d.title || d.name || 'Untitled').substring(0, 50);
|
||
msg += ` ▪️ ${prio} ${title}\n`;
|
||
}
|
||
} else {
|
||
msg += ' _Нет активных задач_\n';
|
||
}
|
||
msg += '\n';
|
||
|
||
// Done today
|
||
if (doneToday && doneToday.length > 0) {
|
||
msg += `✅ *Завершено сегодня:* ${doneToday.length}\n`;
|
||
for (const row of doneToday) {
|
||
const d = safeJsonParse(row.data, {});
|
||
const title = (d.title || d.name || 'Untitled').substring(0, 50);
|
||
msg += ` ✔️ ${title}\n`;
|
||
}
|
||
msg += '\n';
|
||
}
|
||
|
||
// Health section
|
||
if (healthMetrics && healthMetrics.length > 0) {
|
||
msg += '💪 *Здоровье сегодня:*\n';
|
||
for (const row of healthMetrics) {
|
||
const d = safeJsonParse(row.data, {});
|
||
if (d.metric_type === 'weight') {
|
||
msg += ` ⚖️ Вес: ${d.value} ${d.unit || 'кг'}\n`;
|
||
} else if (d.metric_type === 'mood') {
|
||
msg += ` 😊 Настроение: ${d.value}/10\n`;
|
||
} else {
|
||
msg += ` 📊 ${d.metric_type}: ${d.value}\n`;
|
||
}
|
||
}
|
||
msg += '\n';
|
||
}
|
||
|
||
msg += '💡 `/sprint` — все задачи | `/done <id>` — завершить';
|
||
await sendMessage(chatId, msg);
|
||
} catch (err) {
|
||
apiLogger.error({ err }, '[Telegram] /today command failed');
|
||
await sendMessage(chatId, '❌ Ошибка загрузки брифинга.');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Handle /done command — Mark a sprint task as Done.
|
||
*/
|
||
export async function handleDone(chatId, text) {
|
||
const parts = text.split(/\s+/);
|
||
const rowId = parseInt(parts[1], 10);
|
||
|
||
if (!rowId || isNaN(rowId)) {
|
||
await sendMessage(chatId, '❓ Использование: `/done <id>`\nПример: `/done 1234`');
|
||
return;
|
||
}
|
||
|
||
try {
|
||
// Verify the row exists and belongs to the sprint table
|
||
const row = await dbGet(
|
||
isPostgres()
|
||
? `SELECT id, data FROM table_rows WHERE id = $1 AND table_id = 2649`
|
||
: `SELECT id, data FROM table_rows WHERE id = ? AND table_id = 2649`,
|
||
[rowId]
|
||
);
|
||
|
||
if (!row) {
|
||
await sendMessage(chatId, `❌ Задача #${rowId} не найдена в спринте.`);
|
||
return;
|
||
}
|
||
|
||
const now = new Date().toISOString();
|
||
|
||
// Update state to Done and set completed_date
|
||
if (isPostgres()) {
|
||
await dbRun(
|
||
`UPDATE table_rows
|
||
SET data = jsonb_set(
|
||
jsonb_set(data, '{state}', '"Done"'),
|
||
'{completed_date}', $1::jsonb
|
||
),
|
||
updated_at = NOW()
|
||
WHERE id = $2 AND table_id = 2649`,
|
||
[JSON.stringify(now), rowId]
|
||
);
|
||
} else {
|
||
await dbRun(
|
||
`UPDATE table_rows
|
||
SET data = json_set(json_set(data, '$.state', 'Done'), '$.completed_date', ?),
|
||
updated_at = datetime('now')
|
||
WHERE id = ? AND table_id = 2649`,
|
||
[now, rowId]
|
||
);
|
||
}
|
||
|
||
const d = safeJsonParse(row.data, {});
|
||
const title = (d.title || d.name || 'Untitled').substring(0, 60);
|
||
|
||
await sendMessage(chatId,
|
||
`✅ *Задача завершена!*\n\n` +
|
||
`*#${rowId}* — ${title}\n` +
|
||
`📅 ${new Date().toLocaleDateString('ru-RU')}`
|
||
);
|
||
|
||
apiLogger.info({ rowId, title }, '[Telegram] Task marked as Done via /done');
|
||
} catch (err) {
|
||
apiLogger.error({ err, rowId }, '[Telegram] /done command failed');
|
||
await sendMessage(chatId, `❌ Ошибка при завершении задачи #${rowId}.`);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Handle /weight command — Record weight in Health Metrics (table_id = 2643).
|
||
*/
|
||
export async function handleWeight(chatId, text) {
|
||
const parts = text.split(/\s+/);
|
||
const value = parseFloat(parts[1]);
|
||
|
||
if (!value || isNaN(value) || value < 20 || value > 300) {
|
||
await sendMessage(chatId, '❓ Использование: `/weight <кг>`\nПример: `/weight 75.5`');
|
||
return;
|
||
}
|
||
|
||
try {
|
||
const now = new Date().toISOString();
|
||
const rowData = JSON.stringify({
|
||
metric_type: 'weight',
|
||
value: value,
|
||
unit: 'kg',
|
||
recorded_at: now
|
||
});
|
||
|
||
if (isPostgres()) {
|
||
await dbRun(
|
||
`INSERT INTO table_rows (table_id, data, created_at, updated_at)
|
||
VALUES (2643, $1::jsonb, NOW(), NOW())`,
|
||
[rowData]
|
||
);
|
||
} else {
|
||
await dbRun(
|
||
`INSERT INTO table_rows (table_id, data, created_at, updated_at)
|
||
VALUES (2643, ?, datetime('now'), datetime('now'))`,
|
||
[rowData]
|
||
);
|
||
}
|
||
|
||
await sendMessage(chatId, `✅ Вес записан: ${value} кг`);
|
||
apiLogger.info({ value }, '[Telegram] Weight recorded via /weight');
|
||
} catch (err) {
|
||
apiLogger.error({ err, value }, '[Telegram] /weight command failed');
|
||
await sendMessage(chatId, '❌ Ошибка записи веса.');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Handle /mood command — Record mood in Health Metrics (table_id = 2643).
|
||
*/
|
||
export async function handleMood(chatId, text) {
|
||
const parts = text.split(/\s+/);
|
||
const value = parseInt(parts[1], 10);
|
||
|
||
if (!value || isNaN(value) || value < 1 || value > 10) {
|
||
await sendMessage(chatId, '❓ Использование: `/mood <1-10>`\nПример: `/mood 7`');
|
||
return;
|
||
}
|
||
|
||
try {
|
||
const now = new Date().toISOString();
|
||
const rowData = JSON.stringify({
|
||
metric_type: 'mood',
|
||
value: value,
|
||
recorded_at: now
|
||
});
|
||
|
||
if (isPostgres()) {
|
||
await dbRun(
|
||
`INSERT INTO table_rows (table_id, data, created_at, updated_at)
|
||
VALUES (2643, $1::jsonb, NOW(), NOW())`,
|
||
[rowData]
|
||
);
|
||
} else {
|
||
await dbRun(
|
||
`INSERT INTO table_rows (table_id, data, created_at, updated_at)
|
||
VALUES (2643, ?, datetime('now'), datetime('now'))`,
|
||
[rowData]
|
||
);
|
||
}
|
||
|
||
await sendMessage(chatId, `✅ Настроение записано: ${value}/10`);
|
||
apiLogger.info({ value }, '[Telegram] Mood recorded via /mood');
|
||
} catch (err) {
|
||
apiLogger.error({ err, value }, '[Telegram] /mood command failed');
|
||
await sendMessage(chatId, '❌ Ошибка записи настроения.');
|
||
}
|
||
}
|
||
|